DBInstance.h

Go to the documentation of this file.

  #ifndef OSMSCOUT_CLIENT_QT_DBINSTANCE_H
#define OSMSCOUT_CLIENT_QT_DBINSTANCE_H

/*
 OSMScout - a Qt backend for libosmscout and libosmscout-map
 Copyright (C) 2017 Lukáš Karas

  This library is free software; you can redistribute it and/or
  modify it under the terms of the GNU Lesser General Public
  License as published by the Free Software Foundation; either
  version 2.1 of the License, or (at your option) any later version.

  This library is distributed in the hope that it will be useful,
  but WITHOUT ANY WARRANTY; without even the implied warranty of
  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  Lesser General Public License for more details.

  You should have received a copy of the GNU Lesser General Public
  License along with this library; if not, write to the Free Software
  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307  USA
 */

#include <osmscout/Database.h>
#include <osmscout/LocationService.h>
#include <osmscout/LocationDescriptionService.h>
#include <osmscout/MapService.h>
#include <osmscout/MapPainterQt.h>

#include <osmscout/util/Breaker.h>

#include <osmscout/ClientQtImportExport.h>

#include <QObject>
#include <QMutex>
#include <QDebug>
#include <QMap>
#include <QThread>
#include <QElapsedTimer>
#include <QMutexLocker>

namespace osmscout {

class OSMSCOUT_CLIENT_QT_API QBreaker : public osmscout::Breaker
{
private:
  mutable QMutex mutex;
  bool           aborted;

public:
  QBreaker();

  void Break() override;
  bool IsAborted() const override;
  void Reset() override;
};

class OSMSCOUT_CLIENT_QT_API StyleError
{
    enum StyleErrorType {
        Symbol, Error, Warning, Exception
    };

public:
    StyleError(StyleErrorType type, int line, int column, const QString &text) :
        type(type), line(line), column(column), text(text){}
    explicit StyleError(QString msg);

    StyleErrorType GetType() const { return type; }
    QString GetTypeName() const;
    int GetLine() const{ return line; }
    int GetColumn() const{ return column; }
    const QString &GetText() const { return text; }
    QString GetDescription() const {return GetTypeName()+": "+GetText();}

private:
    StyleErrorType  type;
    int             line;
    int             column;
    QString         text;
};


class OSMSCOUT_CLIENT_QT_API DBInstance : public QObject
{
  Q_OBJECT

public:
  const QString                           path;

private:
  mutable QMutex                          mutex;
  QMap<QThread*,osmscout::MapPainterQt*>  painterHolder; 
  QElapsedTimer                           lastUsage; 

  osmscout::GeoBox                        dbBox; 
  osmscout::DatabaseRef                   database;

  osmscout::LocationServiceRef            locationService;
  osmscout::LocationDescriptionServiceRef locationDescriptionService;
  osmscout::MapServiceRef                 mapService;

  osmscout::StyleConfigRef                styleConfig;

public slots:
  void onThreadFinished();

public:
  DBInstance(const QString &path,
             const osmscout::DatabaseRef& database,
             const osmscout::LocationServiceRef& locationService,
             const osmscout::LocationDescriptionServiceRef& locationDescriptionService,
             const osmscout::MapServiceRef& mapService,
             const osmscout::StyleConfigRef& styleConfig):
    path(path),
    database(database),
    locationService(locationService),
    locationDescriptionService(locationDescriptionService),
    mapService(mapService),
    styleConfig(styleConfig)
  {
    if (!database->GetBoundingBox(dbBox)){
      osmscout::log.Error() << "Failed to get database GeoBox: " << path.toStdString();
    }
    lastUsage.start();
  };

  ~DBInstance() override
  {
    close();
  };

  osmscout::GeoBox GetDBGeoBox() const
  {
    return dbBox;
  }

  bool IsOpen() const
  {
    return database->IsOpen();
  }

  osmscout::DatabaseRef GetDatabase()
  {
    QMutexLocker locker(&mutex);
    lastUsage.restart();
    return database;
  }

  osmscout::MapServiceRef GetMapService()
  {
    QMutexLocker locker(&mutex);
    lastUsage.restart();
    return mapService;
  }

  osmscout::LocationDescriptionServiceRef GetLocationDescriptionService()
  {
    QMutexLocker locker(&mutex);
    lastUsage.restart();
    return locationDescriptionService;
  }

  osmscout::LocationServiceRef GetLocationService()
  {
    QMutexLocker locker(&mutex);
    lastUsage.restart();
    return locationService;
  }

  osmscout::StyleConfigRef GetStyleConfig() const
  {
    return styleConfig;
  }

  qint64 LastUsageMs() const
  {
    QMutexLocker locker(&mutex);
    return lastUsage.elapsed();
  }

  bool LoadStyle(QString stylesheetFilename,
                 std::unordered_map<std::string,bool> stylesheetFlags,
                 QList<StyleError> &errors);

  osmscout::MapPainterQt* GetPainter();

  void close();
};

using DBInstanceRef = std::shared_ptr<DBInstance>;

}

#endif /* OSMSCOUT_CLIENT_QT_DBINSTANCE_H */