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