qgsstaccontroller.h

Go to the documentation of this file.

/***************************************************************************
    qgsstaccontroller.h
    ---------------------
    begin                : August 2024
    copyright            : (C) 2024 by Stefanos Natsis
    email                : uclaros 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 QGSSTACCONTROLLER_H
#define QGSSTACCONTROLLER_H
 
#include <nlohmann/json.hpp>
 
#include "qgis.h"
#include "qgis_core.h"
#include "qgshttpheaders.h"
#include "qgsnetworkreply.h"
#include "qgsstacobject.h"
 
#include <QObject>
 
class QgsStacObject;
class QgsStacCatalog;
class QgsStacCollection;
class QgsStacCollectionList;
class QgsStacItem;
class QgsStacItemCollection;
class QNetworkReply;

class CORE_EXPORT QgsStacController : public QObject
{
    Q_OBJECT
  public:
    explicit QgsStacController() = default;

    ~QgsStacController() override;

    std::unique_ptr< QgsStacCatalog > openLocalCatalog( const QString &fileName ) const;

    std::unique_ptr< QgsStacCollection > openLocalCollection( const QString &fileName ) const;

    std::unique_ptr< QgsStacItem > openLocalItem( const QString &fileName ) const;

    template<class T> std::unique_ptr< T > fetchStacObject( const QUrl &url, QString *error = nullptr ) SIP_SKIP;

    std::unique_ptr< QgsStacItemCollection > fetchItemCollection( const QUrl &url, QString *error = nullptr );

    std::unique_ptr< QgsStacCollectionList > fetchCollections( const QUrl &url, QString *error = nullptr );

    int fetchStacObjectAsync( const QUrl &url );

    int fetchItemCollectionAsync( const QUrl &url );

    int fetchCollectionsAsync( const QUrl &url );

    void cancelPendingAsyncRequests();

    template<class T> std::unique_ptr< T > takeStacObject( int requestId ) SIP_SKIP;

    std::unique_ptr< QgsStacItemCollection > takeItemCollection( int requestId );

    std::unique_ptr< QgsStacCollectionList > takeCollections( int requestId );

    QString authCfg() const;

    void setAuthCfg( const QString &authCfg );
 
  signals:

    void finishedStacObjectRequest( int id, QString errorMessage );

    void finishedItemCollectionRequest( int id, QString errorMessage );

    void finishedCollectionsRequest( int id, QString errorMessage );
 
  private slots:
    void handleStacObjectReply();
    void handleItemCollectionReply();
    void handleCollectionsReply();
 
  private:
    QNetworkReply *fetchAsync( const QUrl &url );
    QgsNetworkReplyContent fetchBlocking( const QUrl &url );
 
    QString mAuthCfg;
    QgsHttpHeaders mHeaders;
    QMap< int, QgsStacObject *> mFetchedStacObjects;
    QMap< int, QgsStacItemCollection *> mFetchedItemCollections;
    QMap< int, QgsStacCollectionList *> mFetchedCollections;
    QVector<QNetworkReply *> mReplies;
    QString mError;
};
 
#endif // QGSSTACCONTROLLER_H