mitkRESTManager.h

Go to the documentation of this file.

/*============================================================================
 
The Medical Imaging Interaction Toolkit (MITK)
 
Copyright (c) German Cancer Research Center (DKFZ)
All rights reserved.
 
Use of this source code is governed by a 3-clause BSD license that can be
found in the LICENSE file.
 
============================================================================*/
 
#ifndef mitkRESTManager_h
#define mitkRESTManager_h
 
#include <MitkRESTServiceExports.h>
#include <mitkIRESTManager.h>
#include <mitkRESTUtil.h>
 
namespace mitk
{
  class MITKRESTSERVICE_EXPORT RESTManager : public IRESTManager
  {
  public:
    RESTManager();
    ~RESTManager() override;
 
    pplx::task<web::json::value> SendRequest(
      const web::uri &uri,
      const RequestType &type = RequestType::Get,
      const std::map<utility::string_t, utility::string_t> headers = {}) override;
 
    pplx::task<web::json::value> SendJSONRequest(const web::uri &uri,
                                                 const RequestType &type = RequestType::Get,
                                                 const web::json::value *body = nullptr,
                                                 const std::map<utility::string_t, utility::string_t> headers = {},
                                                 const utility::string_t &filePath = {}) override;
 
    pplx::task<web::json::value> SendBinaryRequest(
      const web::uri &uri,
      const RequestType &type = RequestType::Get,
      const std::vector<unsigned char> *body = {},
      const std::map<utility::string_t, utility::string_t> headers = {}) override;
 
    void ReceiveRequest(const web::uri &uri, IRESTObserver *observer) override;
 
    web::http::http_response Handle(const web::uri &uri,
                                    const web::json::value &body,
                                    const web::http::method &method,
                                    const mitk::RESTUtil::ParamMap &headers) override;
 
    void HandleDeleteObserver(IRESTObserver *observer, const web::uri &uri = {}) override;
 
    const std::map<int, RESTServer *> &GetServerMap() override;
    std::map<std::pair<int, utility::string_t>, IRESTObserver *> &GetObservers() override;
 
  private:
    void AddObserver(const web::uri &uri, IRESTObserver *observer);
 
    void RequestForATakenPort(const web::uri &uri, IRESTObserver *observer);
 
    bool DeleteObserver(std::map<std::pair<int, utility::string_t>, IRESTObserver *>::iterator &it);
 
    void SetServerMap(const int port, RESTServer *server);
    void DeleteFromServerMap(const int port);
    void SetObservers(const std::pair<int, utility::string_t> key, IRESTObserver *observer);
 
    std::map<int, RESTServer *> m_ServerMap;                                  // Map with port server pairs
    std::map<std::pair<int, utility::string_t>, IRESTObserver *> m_Observers; // Map with all observers
  };
} // namespace mitk
 
#endif