telegram_methodMultipart.h

Go to the documentation of this file.

#ifndef YATBCPP_TELEGRAM_METHODMULTIPART_H
#define YATBCPP_TELEGRAM_METHODMULTIPART_H

#include "curl/curl.h"
#include <jsoncpp/json/json.h>
#include "../exceptions/telegram_api_error.h"
#include "../exceptions/curl_error.h"
#include "../types/telegram_type.h"
#include "../exceptions/essential_key_missing.h"
#include "../bot/Token.h"

namespace yatbcpp{
    template <class RETURNTYPE> class telegram_methodMultipart{
    public:

        telegram_methodMultipart(std::string functionname) : functionname(move(functionname)){}

        static size_t WriteCallback(void *contents, size_t size, size_t nmemb, void *stringptr){
            using namespace std;
            ((string*)stringptr)->append((char*)contents, size * nmemb);
            return size * nmemb;
        }



        static RETURNTYPE perform_requestMultipart(Token T, telegram_methodMultipart<RETURNTYPE> &method_body){
            using namespace std;
            string api_url ( "https://api.telegram.org/bot" + T.getToken() + "/" + method_body.getFunctionname() );
            string readBuffer;
            Json::Reader reader;
            Json::Value Response;
            struct curl_slist * curl_header_list =NULL;
            curl_header_list = curl_slist_append( curl_header_list , "Content-Type: multipart/form-data" );

            struct curl_httppost *uploadPost=NULL;
            struct curl_httppost *endptr=NULL;

            method_body.add_to_post(&uploadPost,&endptr);

            CURL* curl = curl_easy_init();

            curl_easy_setopt(curl,CURLOPT_URL,api_url.c_str());
            curl_easy_setopt(curl,CURLOPT_HTTPHEADER,curl_header_list);
            curl_easy_setopt(curl,CURLOPT_HTTPPOST,uploadPost);
            curl_easy_setopt(curl,CURLOPT_WRITEFUNCTION,WriteCallback);
            curl_easy_setopt(curl,CURLOPT_WRITEDATA,&readBuffer);

            CURLcode res = curl_easy_perform(curl);
            reader.parse(readBuffer,Response);
            if(res!=CURLE_OK){
                throw curl_error(res,curl_easy_strerror(res));
            }
            if(Response["ok"].asBool()){
                curl_slist_free_all(curl_header_list);
                curl_easy_cleanup(curl);
                curl_formfree(uploadPost);
                return yatbcpp::fromJson<RETURNTYPE>(Response["result"]);
            }
            else{
                curl_formfree(uploadPost);
                curl_easy_cleanup(curl);
                curl_slist_free_all(curl_header_list);
                throw telegram_api_error(Response["error_code"].asInt(),Response["description"].asString());
            }


        }
        virtual void add_to_post(struct curl_httppost **start,struct curl_httppost **end){}

        const std::string &getFunctionname() const {
            return functionname;
        }

    protected:
        std::string functionname;
    };

}


#endif //YATBCPP_TELEGRAM_METHODMULTIPART_H