|  | // Copyright 2015 The Weave Authors. All rights reserved. | 
|  | // Use of this source code is governed by a BSD-style license that can be | 
|  | // found in the LICENSE file. | 
|  |  | 
|  | #ifndef LIBWEAVE_EXAMPLES_PROVIDER_CURL_HTTP_CLIENT_H_ | 
|  | #define LIBWEAVE_EXAMPLES_PROVIDER_CURL_HTTP_CLIENT_H_ | 
|  |  | 
|  | #include <future> | 
|  | #include <string> | 
|  | #include <utility> | 
|  |  | 
|  | #include <base/memory/weak_ptr.h> | 
|  | #include <weave/provider/http_client.h> | 
|  |  | 
|  | namespace weave { | 
|  |  | 
|  | namespace provider { | 
|  | class TaskRunner; | 
|  | } | 
|  |  | 
|  | namespace examples { | 
|  |  | 
|  | // Basic implementation of weave::HttpClient using libcurl. Should be used in | 
|  | // production code as it's blocking and does not validate server certificates. | 
|  | class CurlHttpClient : public provider::HttpClient { | 
|  | public: | 
|  | explicit CurlHttpClient(provider::TaskRunner* task_runner); | 
|  |  | 
|  | void SendRequest(Method method, | 
|  | const std::string& url, | 
|  | const Headers& headers, | 
|  | const std::string& data, | 
|  | const SendRequestCallback& callback) override; | 
|  |  | 
|  | private: | 
|  | void CheckTasks(); | 
|  |  | 
|  | std::vector< | 
|  | std::pair<std::future<std::pair<std::unique_ptr<Response>, ErrorPtr>>, | 
|  | SendRequestCallback>> pending_tasks_; | 
|  | provider::TaskRunner* task_runner_{nullptr}; | 
|  |  | 
|  | base::WeakPtrFactory<CurlHttpClient> weak_ptr_factory_{this}; | 
|  | }; | 
|  |  | 
|  | }  // namespace examples | 
|  | }  // namespace weave | 
|  |  | 
|  | #endif  // LIBWEAVE_EXAMPLES_PROVIDER_CURL_HTTP_CLIENT_H_ |