From 558ff4d606f61d2be42a197ac0b1a407b91ff006 Mon Sep 17 00:00:00 2001
From: Greg Burd <greg@burd.me>
Date: Wed, 1 May 2024 19:44:44 -0400
Subject: [PATCH] WIP

---
 src/database.cc | 31 ++++++++++++++++++++++++++-----
 src/noidb.cc    |  7 ++++---
 2 files changed, 30 insertions(+), 8 deletions(-)

diff --git a/src/database.cc b/src/database.cc
index 91dd3b5..6d05474 100644
--- a/src/database.cc
+++ b/src/database.cc
@@ -1,15 +1,36 @@
 
 #include "database.hh"
 
-seastar::future<bool> Database::stop() { return seastar::make_ready_future<bool>(true); }
+#include "noidb.hh"
 
-future<sstring> Database::get(const sstring& key) { co_return key; }
+seastar::future<bool> Database::stop() {
+    lg.info("Stopping the database.");
+    co_return true;
+}
 
-future<bool> Database::put(const sstring& key, sstring& val) { co_return true; }
+future<sstring> Database::get(const sstring& key) {
+    lg.info("get: {}", key);
+    co_return key;
+}
 
-future<bool> Database::post(const sstring& key, input_stream<char>* val) { co_return true; }
+future<bool> Database::put(const sstring& key, sstring& val) {
+    lg.info("put: {} -> {}", key, val);
+    co_return true;
+}
 
-future<bool> Database::del(const sstring& key) { co_return true; }
+future<bool> Database::post(const sstring& key, input_stream<char>* stream) {
+    sstring val;
+    while (auto buf = co_await stream->read()) {
+        val.append(buf.get(), buf.size());
+    }
+    lg.info("post: {} -> {}", key, val);
+    co_return true;
+}
+
+future<bool> Database::del(const sstring& key) {
+    lg.info("del: {}", key);
+    co_return true;
+}
 
 GetHandler::GetHandler(Database& db)
   : db(db) {}
diff --git a/src/noidb.cc b/src/noidb.cc
index f61c190..4b88ad3 100644
--- a/src/noidb.cc
+++ b/src/noidb.cc
@@ -1,4 +1,6 @@
 
+#include "noidb.hh"
+
 #include "database.hh"
 
 #include <seastar/apps/lib/stop_signal.hh>
@@ -8,17 +10,16 @@
 #include <seastar/http/httpd.hh>
 #include <seastar/http/request.hh>
 #include <seastar/http/routes.hh>
-#include <seastar/util/log.hh>
 
 #include <stdexcept>
 
 using namespace seastar;
 using namespace httpd;
 
-logger lg("noidb");
-
 namespace bpo = boost::program_options;
 
+seastar::logger lg("noidb");
+
 int main(int argc, char** argv) {
     seastar::app_template app;