From 8564ac52409472064f5603bb928abcae30c1a370 Mon Sep 17 00:00:00 2001
From: Simon <sfja.skp@edu.mercantec.dk>
Date: Fri, 10 Feb 2023 17:42:58 +0100
Subject: [PATCH] backend: readded windows tcp

---
 backend/windows.c | 88 +++++++++++++++++++++++++++++++++++++++++++----
 1 file changed, 81 insertions(+), 7 deletions(-)

diff --git a/backend/windows.c b/backend/windows.c
index 5a0efb8..03c4649 100644
--- a/backend/windows.c
+++ b/backend/windows.c
@@ -6,16 +6,90 @@
 #include <stdio.h>
 #include <stdlib.h>
 
-struct TcpServer { };
+struct TcpServer {
+    int server_socket;
+    struct sockaddr_in server_address;
+};
 
-struct TcpConnection { };
+struct TcpConnection {
+    int client_socket;
+    struct sockaddr_in client_address;
+};
 
-void tcp_global_initialize_sockets(void) { }
+void tcp_global_initialize_sockets(void)
+{
+    WSADATA data;
+    WSAStartup(0x0202, &data);
+}
 
-TcpServer* tcp_server_create(const char* ip, uint16_t port) { }
+TcpServer* tcp_server_create(const char* ip, uint16_t port)
+{
+    int server_socket = socket(AF_INET, SOCK_STREAM, 0);
+    if (server_socket < 0) {
+        printf("error: tcp: could not open socket\n");
+        return NULL;
+    }
+    if (setsockopt(server_socket, SOL_SOCKET, SO_REUSEADDR, &(int) { 1 }, sizeof(int)) < 0) {
+        printf("warning: tcp: could not setsockopt SO_REUSEADDR\n");
+    }
+    struct sockaddr_in server_address;
+    server_address.sin_addr.s_addr = inet_addr(ip);
+    server_address.sin_family = AF_INET;
+    server_address.sin_port = htons(port);
+    if (bind(server_socket, (struct sockaddr*)&server_address, sizeof(server_address)) < 0) {
+        printf("error: tcp: could not bind socket\n");
+        return NULL;
+    }
+    if (listen(server_socket, SOMAXCONN) < 0) {
+        printf("error: tcp: could not listen on server\n");
+        return NULL;
+    }
 
-void tcp_connection_destroy(TcpConnection* connection) { }
+    TcpServer* self = malloc(sizeof(TcpServer));
+    *self = (TcpServer) {
+        .server_socket = server_socket,
+        .server_address = server_address,
+    };
+    return self;
+}
 
-ssize_t tcp_recieve(TcpConnection* connection, uint8_t* data, size_t amount) { }
+void tcp_server_destroy(TcpServer* server)
+{
+    closesocket(server->server_socket);
+    free(server);
+}
 
-ssize_t tcp_send(TcpConnection* connection, uint8_t* data, size_t amount) { }
+TcpConnection* tcp_server_accept(TcpServer* server)
+{
+    struct sockaddr_in client_address;
+    socklen_t client_size;
+    int client_socket
+        = accept(server->server_socket, (struct sockaddr*)&client_address, &client_size);
+    if (client_socket < 0) {
+        printf("error: tcp: could not accept connection\n");
+        return NULL;
+    }
+
+    TcpConnection* connection = malloc(sizeof(TcpConnection));
+    *connection = (TcpConnection) {
+        .client_socket = client_socket,
+        .client_address = client_address,
+    };
+    return connection;
+}
+
+void tcp_connection_destroy(TcpConnection* connection)
+{
+    closesocket(connection->client_socket);
+    free(connection);
+}
+
+ssize_t tcp_recieve(TcpConnection* connection, uint8_t* data, size_t amount)
+{
+    return recv(connection->client_socket, data, amount, 0);
+}
+
+ssize_t tcp_send(TcpConnection* connection, uint8_t* data, size_t amount)
+{
+    return send(connection->client_socket, data, amount, 0);
+}