nb_service.h

説明を見る。

/*
 * COPYRIGHT (C) 2017 NEC CORPORATION
 *
 * ALL RIGHTS RESERVED BY NEC CORPORATION,  THIS PROGRAM
 * MUST BE USED SOLELY FOR THE PURPOSE FOR WHICH IT WAS
 * FURNISHED BY NEC CORPORATION,  NO PART OF THIS PROGRAM
 * MAY BE REPRODUCED OR DISCLOSED TO OTHERS,  IN ANY FORM
 * WITHOUT THE PRIOR WRITTEN PERMISSION OF NEC CORPORATION.
 *
 * NEC CONFIDENTIAL AND PROPRIETARY
 */

#ifndef NECBAAS_NBSERVICE_H
#define NECBAAS_NBSERVICE_H

#include <string>
#include <memory>
#include "necbaas/internal/nb_session_token.h"
#include "necbaas/internal/nb_rest_executor.h"
#include "necbaas/internal/nb_rest_executor_pool.h"
#include "necbaas/internal/nb_http_request_factory.h"

namespace necbaas {

class NbService {
   public:
    static std::shared_ptr<NbService> CreateService(const std::string &endpoint_url, const std::string &tenant_id,
                                                    const std::string &app_id, const std::string &app_key,
                                                    const std::string &proxy = "");

    static void SetDebugLogEnabled(bool flag);

    static void SetErrorLogEnabled(bool flag);

    static void SetRestLogEnabled(bool flag);

    virtual ~NbService();

    const std::string &GetAppId() const;

    const std::string &GetAppKey() const;

    const std::string &GetEndpointUrl() const;

    const std::string &GetTenantId() const;

    const std::string &GetProxy() const;

    NbSessionToken GetSessionToken();

    virtual void SetSessionToken(const NbSessionToken &token);

    void ClearSessionToken();

    NbResult<NbHttpResponse> ExecuteRequest(std::function<NbHttpRequest(NbHttpRequestFactory &)> create_request, int timeout);

    NbResult<NbHttpResponse> ExecuteFileDownload(std::function<NbHttpRequest(NbHttpRequestFactory &)> create_request,
                                                 const std::string &file_path, int timeout);

    NbResult<NbHttpResponse> ExecuteFileUpload(std::function<NbHttpRequest(NbHttpRequestFactory &)> create_request,
                                               const std::string &file_path, int timeout);
   private:
    std::string app_id_;                    
    std::string app_key_;                   
    std::string endpoint_url_;              
    std::string tenant_id_;                 
    std::string proxy_;                     
    NbSessionToken session_token_;          
    NbRestExecutorPool rest_executor_pool_; 
    std::mutex session_token_mutex_;        
   protected:
    NbService(const std::string &endpoint_url, const std::string &tenant_id, const std::string &app_id,
              const std::string &app_key, const std::string &proxy);

    virtual NbRestExecutor *PopRestExecutor();

    virtual void PushRestExecutor(NbRestExecutor *executor);

    NbHttpRequestFactory GetHttpRequestFactory();

    NbResult<NbHttpResponse> ExecuteCommon(
        std::function<NbHttpRequest(NbHttpRequestFactory &)> create_request,
        std::function<NbResult<NbHttpResponse>(NbRestExecutor *, const NbHttpRequest &)> executor_method);
};
}  // namespace necbaas
#endif  // NECBAAS_NBSERVICE_H