qgssensorthingsshareddata.h

Go to the documentation of this file.

/***************************************************************************
      qgssensorthingsshareddata.h
      ----------------
    begin                : November 2023
    copyright            : (C) 2013 Nyall Dawson
    email                : nyall dot dawson at gmail dot com
 ***************************************************************************
 *                                                                         *
 *   This program is free software; you can redistribute it and/or modify  *
 *   it under the terms of the GNU General Public License as published by  *
 *   the Free Software Foundation; either version 2 of the License, or     *
 *   (at your option) any later version.                                   *
 *                                                                         *
 ***************************************************************************/
 
#ifndef QGSSENSORTHINGSSHAREDDATA_H
#define QGSSENSORTHINGSSHAREDDATA_H
 
#include "qgscoordinatereferencesystem.h"
#include "qgsfeature.h"
#include "qgsfields.h"
#include "qgshttpheaders.h"
#include "qgssensorthingsutils.h"
#include "qgsspatialindex.h"
 
#include <QReadWriteLock>
#include <QVersionNumber>
 
#define SIP_NO_FILE
 
class QgsFeedback;


class QgsSensorThingsSharedData
{
  public:
    QgsSensorThingsSharedData( const QString &uri );

    static QUrl parseUrl( const QUrl &url, bool *isTestEndpoint = nullptr );

    QString error() const { return mError; }
 
    QgsCoordinateReferenceSystem crs() const { return mSourceCRS; }
    QgsRectangle extent() const;
    long long featureCount( QgsFeedback *feedback = nullptr ) const;
    QString subsetString() const;
 
    bool hasCachedAllFeatures() const;
    bool getFeature( QgsFeatureId id, QgsFeature &f, QgsFeedback *feedback = nullptr );
    QgsFeatureIds getFeatureIdsInExtent( const QgsRectangle &extent, QgsFeedback *feedback, const QString &thisPage, QString &nextPage, const QgsFeatureIds &alreadyFetchedIds );
 
    void clearCache();
 
  private:
    bool processFeatureRequest(
      QString &nextPage,
      QgsFeedback *feedback,
      const std::function< void( const QgsFeature & ) > &fetchedFeatureCallback,
      const std::function< bool() > &continueFetchingCallback,
      const std::function< void() > &onNoMoreFeaturesCallback
    );
 
    friend class QgsSensorThingsProvider;
    mutable QReadWriteLock mReadWriteLock { QReadWriteLock::Recursive };
 
    QString mAuthCfg;
    QgsHttpHeaders mHeaders;
    QString mRootUri;
 
    mutable QString mError;
 
    QVersionNumber mVersion = QVersionNumber( 1, 1 );
    QString mEntityBaseUri;
    QString mSubsetString;
    QString mExpandQueryString;
 
    Qgis::SensorThingsEntity mEntityType = Qgis::SensorThingsEntity::Invalid;
    QList< QgsSensorThingsExpansionDefinition > mExpansions;
 
    int mFeatureLimit = 0;
    Qgis::WkbType mGeometryType = Qgis::WkbType::Unknown;
    QString mGeometryField;
    QgsFields mFields;
 
    QgsRectangle mFilterExtent;

    QgsRectangle mFetchedFeatureExtent;
 
    QgsCoordinateReferenceSystem mSourceCRS;
 
    mutable long long mFeatureCount = static_cast< long long >( Qgis::FeatureCountState::Uncounted );
    mutable long long mRetrievedBaseFeatureCount = 0;
 
    QHash<QString, QgsFeatureId> mIotIdToFeatureId;
    QMap<QgsFeatureId, QgsFeature> mCachedFeatures;
    QgsGeometry mCachedExtent;
 
    QgsFeatureId mNextFeatureId = 0;
    bool mHasCachedAllFeatures = false;
 
    int mMaximumPageSize = QgsSensorThingsUtils::DEFAULT_PAGE_SIZE;
 
    QgsSpatialIndex mSpatialIndex;
    mutable QString mNextPage;
};

 
#endif // QGSSENSORTHINGSSHAREDDATA_H