made the post request headers valid

Author: svdgraaf

src/common/AWSClient4.cpp

@@ -228,22 +228,16 @@ char* AWSClient4::createRequest(MinimalString &reqPayload) {
     char *headers = createRequestHeaders(signature);
 
     char *host = createHost();
-    char* request = new char[strlen(method) + strlen(host) + strlen(awsPath) + strlen(headers) + strlen(reqPayload.getCStr()) + 4]();
-    sprintf(request, "%s %s%s\n%s\n%s", method, createHost(), awsPath, headers, reqPayload.getCStr());
+    char* request = new char[strlen(method) + strlen(host) + strlen(awsPath) + strlen(headers) + strlen(reqPayload.getCStr()) + 12]();
+    sprintf(request, "%s %s HTTP/1.1\n%s\n%s", method, awsPath, headers, reqPayload.getCStr());
 
     return request;
-
-    // createRequestInit(reqPayload);
-    // char* request = headersToRequest();
-    // createRequestCleanup();
-
-    // return request;
 }
 
 char* AWSClient4::sendData(const char* data) {
-    char* server = createHostString();
+    char* server = createHost();
     int port = httpS ? 443 : 80;
-    char* response = httpClient->send(data, "A2MBBEONHC9LUG.iot.eu-west-1.amazonaws.com", port);
+    char* response = httpClient->send(data, server, port);
     delete[] server;
     return response;
 }

src/common/AmazonIOTClient.cpp

@@ -9,15 +9,16 @@ AmazonIOTClient::AmazonIOTClient() : AWSClient4() {
     this->signedHeaders = "host;x-amz-content-sha256;x-amz-date";
     this->uri = "/";
     this->queryString = "";
+    this->httpS = true;
 }
 
 char* AmazonIOTClient::update_shadow(MinimalString shadow, ActionError& actionError) {
     actionError = NONE_ACTIONERROR;
 
     this->method = "POST";
     char* request = createRequest(shadow);
-    // char* response = sendData(request);
-    return request;
+    char* response = sendData(request);
+    return response;
 
 
     // delete[] request;

src/esp8266/ESP8266AWSImplentations.cpp

@@ -25,14 +25,17 @@ char* Esp8266HttpClient::send(const char* request, const char* serverUrl, int po
     String responseBuilder = "Response: ";
     if (client.connect(serverUrl, port)) {
         /* Send the requests */
-        client.println(request);
-        client.println();
+        client.print(request);
+        client.print("\n");
         /* Read the request into responseBuilder. */
         delay(delayTime);
+        Serial.println("<");
         while (client.available()) {
             char c = client.read();
             responseBuilder.concat(c);
+            Serial.print(".");
         }
+        Serial.println(">");
         client.stop();
     } else {
         client.stop();