Simple get and set impl

src/CMakeLists.txt

@@ -5,7 +5,9 @@ add_executable(cpp_redis main.cpp
         controller.h
         tcp_server.cpp
         tcp_server.h
-        overloaded.h)
+        overloaded.h
+        datastore.h
+        datastore.cpp)
 
 
 target_link_libraries(cpp_redis PRIVATE spdlog::spdlog_header_only)

src/controller.cpp

@@ -27,6 +27,10 @@ RedisType::RedisValue Controller::handleCommand(const std::vector<RedisType::Bul
         return handleEcho(command);
     } else if (commandType == "PING") {
         return handlePing(command);
+    } else if (commandType == "SET") {
+        return handleSet(command);
+    } else if (commandType == "GET") {
+        return handleGet(command);
     }
 
     return RedisType::SimpleError("ERR unsupported command");
@@ -43,3 +47,22 @@ RedisType::RedisValue Controller::handlePing(const std::vector<RedisType::BulkSt
 
     return RedisType::BulkString("PONG");
 }
+RedisType::RedisValue Controller::handleSet(const std::vector<RedisType::BulkString> &command) {
+    if (command.size() != 3) { return RedisType::SimpleError("ERR wrong number of arguments for 'set' command"); }
+
+    auto key = extractStringFromBytes(*command[1].data, 0, (*command[0].data).size());
+    auto val = extractStringFromBytes(*command[2].data, 0, (*command[0].data).size());
+
+    dataStore.store[key] = val;
+
+    return RedisType::BulkString("OK");
+}
+RedisType::RedisValue Controller::handleGet(const std::vector<RedisType::BulkString> &command) {
+    if (command.size() != 2) { return RedisType::SimpleError("ERR wrong number of arguments for 'get' command"); }
+
+    auto key = extractStringFromBytes(*command[1].data, 0, (*command[0].data).size());
+
+    auto val = dataStore.store[key];
+
+    return RedisType::BulkString(val);
+}

src/controller.h

@@ -1,5 +1,6 @@
 #pragma once
 
+#include "datastore.h"
 #include "redis_type.h"
 
 class Controller {
@@ -9,4 +10,9 @@ class Controller {
 private:
     RedisType::RedisValue handleEcho(const std::vector<RedisType::BulkString> &command);
     RedisType::RedisValue handlePing(const std::vector<RedisType::BulkString> &command);
+    RedisType::RedisValue handleSet(const std::vector<RedisType::BulkString> &command);
+    RedisType::RedisValue handleGet(const std::vector<RedisType::BulkString> &command);
+
+
+    DataStore dataStore;
 };

src/datastore.cpp

@@ -0,0 +1 @@
+#include "datastore.h"

src/datastore.h

@@ -0,0 +1,8 @@
+#pragma once
+
+#include <unordered_map>
+
+class DataStore {
+public:
+    std::unordered_map<std::string, std::string> store;
+};