X-Git-Url: https://gitweb.ps.run/matrix_esp_thesis/blobdiff_plain/27a83e93114c31de4b7bd33320a85e5fad0196a3..5cb22046a33f24c1a696990f95e13d534efef497:/src/matrix_http_mongoose.c

diff --git a/src/matrix_http_mongoose.c b/src/matrix_http_mongoose.c
new file mode 100644
index 0000000..3faefa9
--- /dev/null
+++ b/src/matrix_http_mongoose.c
@@ -0,0 +1,153 @@
+#include "matrix.h"
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <stdbool.h>
+#include <mongoose.h>
+
+//#define HTTP_DATA_SIZE 1024
+
+typedef struct MatrixHttpConnection {
+    struct mg_mgr mgr;
+    struct mg_connection * connection;
+    bool connected;
+    char * data;
+    int dataCap;
+    int dataLen;
+    bool dataReceived;
+} MatrixHttpConnection;
+
+static void
+MatrixHttpCallback(
+    struct mg_connection *c,
+    int ev,
+    void *ev_data,
+    void *fn_data)
+{
+    MatrixClient * client = (MatrixClient *)fn_data;
+    MatrixHttpConnection * conn = (MatrixHttpConnection *)client->httpUserData;
+
+    if (ev == MG_EV_CONNECT)
+    {
+        struct mg_str host = mg_url_host(client->server);
+
+        // If s_url is https://, tell client connection to use TLS
+        if (mg_url_is_ssl(client->server))
+        {
+            struct mg_tls_opts opts = {.srvname = host};
+            mg_tls_init(c, &opts);
+        }
+
+        conn->connection = c;
+        conn->connected = true;
+    }
+    if (ev == MG_EV_HTTP_MSG)
+    {
+        // Response
+        struct mg_http_message *hm = (struct mg_http_message *)ev_data;
+        // memcpy_s(client->data, 1024, hm->message.ptr, hm->message.len);
+        // client->dataLen = hm->message.len;
+        memcpy_s(conn->data, conn->dataCap, hm->body.ptr, hm->body.len);
+        conn->dataLen = hm->body.len;
+        conn->dataReceived = true;
+    }
+}
+
+bool
+MatrixHttpInit(
+    MatrixClient * client)
+{
+    MatrixHttpConnection * conn =
+        (MatrixHttpConnection *)malloc(sizeof(MatrixHttpConnection));
+
+    client->httpUserData = conn;
+    
+    mg_mgr_init(&conn->mgr);
+
+    mg_http_connect(&conn->mgr, client->server, MatrixHttpCallback, client);
+
+    while (! conn->connected)
+        mg_mgr_poll(&conn->mgr, 1000);
+
+    return conn->connected;
+}
+
+bool
+MatrixHttpDeinit(
+    MatrixClient * client)
+{
+    MatrixHttpConnection * conn = (MatrixHttpConnection *)client->httpUserData;
+    
+    mg_mgr_free(&conn->mgr);
+
+    free(conn);
+
+    return true;
+}
+
+bool
+MatrixHttpGet(
+    MatrixClient * client,
+    const char * url,
+    char * outResponseBuffer, int outResponseCap, int * outResponseLen)
+{
+    MatrixHttpConnection * conn = (MatrixHttpConnection *)client->httpUserData;
+
+    conn->dataReceived = false;
+
+    struct mg_str host = mg_url_host(client->server);
+
+    mg_printf(conn->connection,
+        "GET %s HTTP/1.1\r\n"
+        "Host: %.*s\r\n"
+        "\r\n",
+        url,
+        host.len, host.ptr);
+
+    conn->data = outResponseBuffer;
+    conn->dataCap = outResponseCap;
+    
+    while (! conn->dataReceived)
+        mg_mgr_poll(&conn->mgr, 1000);
+
+    *outResponseLen = conn->dataLen;
+
+    return conn->dataReceived;
+}
+
+bool
+MatrixHttpPost(
+    MatrixClient * client,
+    const char * url,
+    char * requestBuffer, int requestLen,
+    char * outResponseBuffer, int outResponseCap, int * outResponseLen)
+{
+    MatrixHttpConnection * conn = (MatrixHttpConnection *)client->httpUserData;
+
+    conn->dataReceived = false;
+
+    struct mg_str host = mg_url_host(client->server);
+
+    mg_printf(conn->connection,
+            "POST %s HTTP/1.0\r\n"
+            "Host: %.*s\r\n"
+            "Content-Type: application/json\r\n"
+            "Content-Length: %d\r\n"
+            "\r\n"
+            "%s"
+            "\r\n",
+            url,
+            host.len, host.ptr,
+            requestLen,
+            requestBuffer);
+
+    conn->data = outResponseBuffer;
+    conn->dataCap = outResponseCap;
+    
+    while (! conn->dataReceived)
+        mg_mgr_poll(&conn->mgr, 1000);
+
+    *outResponseLen = conn->dataLen;
+
+    return conn->dataReceived;
+}
\ No newline at end of file