Updated README with latest

Author: codepr

Diff for: README.md

@@ -122,3 +122,58 @@ int main() {
 }
 
 ```
+
+### Roach server draft
+
+Event based server (rely on [ev](https://github.com/codepr/ev.git) at least
+initially), TCP as the main transport protocol, text-based custom protocol
+inspired by RESP but simpler.
+
+#### Simple query language
+
+Definition of a simple, text-based format for clients to interact with the
+server, allowing them to send commands and receive responses.
+
+##### Basic outline
+
+- **Text-Based Format:** Use a text-based format where each command and
+  response is represented as a single line of text.
+- **Commands:** Define a set of commands that clients can send to the server to
+  perform various operations such as inserting data, querying data, and
+  managing the database.
+- **Responses:** Define the format of responses that the server sends back to
+  clients after processing commands. Responses should provide relevant
+  information or acknowledge the completion of the requested operation.
+
+##### Core commands
+
+Define the basic operations in a SQL-like query language
+
+- **CREATE** creates a database or a timeseries
+  `CREATE <database name>`
+  `CREATE <timeseries name> INTO <database name> [<retention period>] [<duplication policy>]`
+
+- **INSERT** insertion of point(s) in a timeseries
+  `INSERT <timeseries name> INTO <database name> <timestamp | *> <value>, ...`
+
+- **SELECT** query a timeseries, selection of point(s) and aggregations
+  `SELECT <timeseries name> FROM <database name> RANGE <start_timestamp> TO <end_timestamp> WHERE value [>|<|=|<=|>=|!=] <literal> AGGREGATE [AVG|MIN|MAX] BY <literal>`
+
+- **DELETE** delete a timeseries or a database
+  `DELETE <database name>`
+  `DELETE <timeseries name> FROM <database name>`
+
+##### Flow:
+
+1. **Client Sends Command:** Clients send commands to the server in the
+       specified text format.
+
+2. **Server Parses Command:** The server parses the received command and
+       executes the corresponding operation on the timeseries database.
+
+3. **Server Sends Response:** After processing the command, the server sends a
+       response back to the client indicating the result of the operation or
+       providing requested data.
+
+4. **Client Processes Response:** Clients receive and process the response from
+       the server, handling success or error conditions accordingly.

Diff for: src/main.c

@@ -325,7 +325,7 @@ int main(void) {
     /*                                  {.timestamp = 1982398, .value =
      * 0.7227}}}; */
 
-    /* roachdb_server_run("127.0.0.1", 17678); */
+    roachdb_server_run("127.0.0.1", 17678);
 
     return 0;
 }

Diff for: src/server.c

@@ -4,6 +4,7 @@
 #include "ev_tcp.h"
 #include "logging.h"
 #include "parser.h"
+#include "protocol.h"
 #include "server.h"
 #include "timeseries.h"
 
@@ -59,9 +60,8 @@ static void execute_statement(Statement *statement) {
             } else {
                 for (size_t i = 0; i < vec_size(coll); i++) {
                     Record r = vec_at(coll, i);
-                    log_info(" %lu {.sec: %lu, .nsec: %lu .value: %.02f }", r.timestamp,
-                             r.tv.tv_sec, r.tv.tv_nsec, r.value);
-    
+                    log_info(" %lu {.sec: %lu, .nsec: %lu .value: %.02f }",
+                             r.timestamp, r.tv.tv_sec, r.tv.tv_nsec, r.value);
                 }
             }
         }
@@ -92,23 +92,42 @@ static void on_write(ev_tcp_handle *client) {
 static void on_data(ev_tcp_handle *client) {
     if (client->buffer.size == 0)
         return;
-
-    char *line_start = client->buffer.buf;
-    char *line_end;
-
-    while ((line_end = strstr(line_start, "\r\n")) != NULL) {
-        *line_end = '\0';
-        log_info("Line received %s", line_start);
-        // Line gets processed here
+    log_info("Data: %s", client->buffer.buf);
+    Request rq;
+    Response rs;
+    ssize_t n = decode_request((const uint8_t *)client->buffer.buf, &rq);
+    if (n < 0) {
+        log_error("Can't decode a request from data");
+        rs.type = STRING_RSP;
+        rs.string_response.rc = 1;
+        strncpy(rs.string_response.message, "Err", 4);
+        rs.string_response.length = 4;
+    } else {
         // Parse into Statement
         size_t total_tokens;
-        Token *tokens = tokenize(line_start, &total_tokens);
+        Token *tokens = tokenize(rq.query, &total_tokens);
         Statement statement = parse(tokens, total_tokens);
         // Execute it
         execute_statement(&statement);
-        line_start = line_end + 2;
+        rs.type = STRING_RSP;
+        rs.string_response.rc = 0;
+        strncpy(rs.string_response.message, "Ok", 3);
+        rs.string_response.length = 3;
     }
 
+    (void)encode_response(&rs, (uint8_t *)client->buffer.buf);
+    /* line_start = line_end + 2; */
+
+    /* char *line_start = client->buffer.buf; */
+    /* char *line_end; */
+
+    /* while ((line_end = strstr(line_start, "\r\n")) != NULL) { */
+    /*     *line_end = '\0'; */
+    /*     log_info("Line received %s", line_start); */
+    /*     // Line gets processed here */
+    /* } */
+    /* } */
+
     ev_tcp_queue_write(client);
 }