add http interceptor

Author: huiguangjun

sdk/include/alibabacloud/oss/client/ClientConfiguration.h

@@ -20,6 +20,7 @@
 #include <alibabacloud/oss/Types.h>
 #include <alibabacloud/oss/auth/CredentialsProvider.h>
 #include <alibabacloud/oss/http/HttpClient.h>
+#include <alibabacloud/oss/http/HttpInterceptor.h>
 #include <alibabacloud/oss/utils/Executor.h>
 
 namespace AlibabaCloud
@@ -135,6 +136,11 @@ namespace OSS
         * signature version. default is V1.
         */
         SignatureVersionType signatureVersion;
+
+        /**
+        * Your http interceptor implement
+        */
+        std::shared_ptr<HttpInterceptor> httpInterceptor;
     };
 }
 }

sdk/include/alibabacloud/oss/http/HttpInterceptor.h

@@ -0,0 +1,35 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#pragma once
+
+#include <string>
+#include <alibabacloud/oss/Export.h>
+#include <alibabacloud/oss/http/HttpRequest.h>
+
+namespace AlibabaCloud
+{
+namespace OSS
+{
+    class ALIBABACLOUD_OSS_EXPORT HttpInterceptor
+    {
+    public:
+        HttpInterceptor() = default;
+        virtual ~HttpInterceptor() = default;
+        virtual void preSendRequest(void *handler, const std::shared_ptr<HttpRequest> &request) = 0;
+    };
+}
+}

sdk/src/client/ClientConfiguration.cc

@@ -118,7 +118,8 @@ ClientConfiguration::ClientConfiguration() :
     httpClient(nullptr),
     isPathStyle(false),
     isVerifyObjectStrict(true),
-    signatureVersion(SignatureVersionType::V1)
+    signatureVersion(SignatureVersionType::V1),
+    httpInterceptor(nullptr)
 {
 
 }

sdk/src/http/CurlHttpClient.cc

@@ -418,7 +418,8 @@ CurlHttpClient::CurlHttpClient(const ClientConfiguration &configuration) :
     caFile_(configuration.caFile),
     networkInterface_(configuration.networkInterface),
     sendRateLimiter_(configuration.sendRateLimiter),
-    recvRateLimiter_(configuration.recvRateLimiter)
+    recvRateLimiter_(configuration.recvRateLimiter),
+    httpInterceptor_(configuration.httpInterceptor)
 {
 }
 
@@ -567,6 +568,10 @@ std::shared_ptr<HttpResponse> CurlHttpClient::makeRequest(const std::shared_ptr<
         curl_easy_setopt(curl, CURLOPT_MAX_RECV_SPEED_LARGE, speed);
     }
 
+    if (httpInterceptor_ != nullptr) {
+        httpInterceptor_->preSendRequest(curl, request);
+    }
+
     CURLcode res = curl_easy_perform(curl);
     long response_code= 0;
     curl_easy_getinfo(curl, CURLINFO_RESPONSE_CODE, &response_code);

sdk/src/http/CurlHttpClient.h

@@ -52,6 +52,7 @@ namespace OSS
     public:
         std::shared_ptr<RateLimiter> sendRateLimiter_;
         std::shared_ptr<RateLimiter> recvRateLimiter_;
+        std::shared_ptr<HttpInterceptor> httpInterceptor_;
     };
 }
 }