From d40c29ecadadff831ebf08f67b45f29a71ebdebc Mon Sep 17 00:00:00 2001
From: Emery Hemingway <ehmry@posteo.net>
Date: Mon, 18 Mar 2024 19:31:45 +0000
Subject: [PATCH] Add http_driver from syndicate-nim

---
 Tupfile                            |  3 ++-
 config.prs                         |  4 +++
 default.nix                        |  8 +++---
 src/schema/config.nim              |  8 ++++++
 src/syndesizer.nim                 |  2 ++
 src/syndesizer/http_driver.nim     | 42 ++++++++++++++++++++++++++++++
 src/syndesizer/http_driver.nim.cfg |  2 ++
 7 files changed, 65 insertions(+), 4 deletions(-)
 create mode 100644 src/syndesizer/http_driver.nim
 create mode 100644 src/syndesizer/http_driver.nim.cfg

diff --git a/Tupfile b/Tupfile
index 28c450e..eaaeaaf 100644
--- a/Tupfile
+++ b/Tupfile
@@ -1,2 +1,3 @@
 include_rules
-: lock.json |> !nim_cfg |> | ./<lock>
+: |> !nim_lk |> {lockfile}
+: {lockfile} |> !nim_cfg |> | ./<lock>
diff --git a/config.prs b/config.prs
index a98d756..4093676 100644
--- a/config.prs
+++ b/config.prs
@@ -26,6 +26,10 @@ UnixAddress = <unix @path string>.
 
 SocketAddress = TcpAddress / UnixAddress .
 
+HttpDriverArguments = <http-driver {
+  dataspace: #:any
+}>.
+
 JsonSocketTranslatorArguments = <json-socket-translator {
   dataspace: #:any
   socket: SocketAddress
diff --git a/default.nix b/default.nix
index c8bf846..85fe51e 100644
--- a/default.nix
+++ b/default.nix
@@ -2,9 +2,11 @@
 
 pkgs.buildNimPackage {
   name = "syndicate_utils";
-  propagatedNativeBuildInputs = [ pkgs.pkg-config ];
-  propagatedBuildInputs =
-    [ pkgs.postgresql pkgs.sqlite pkgs.libxml2 pkgs.libxslt ];
+  propagatedNativeBuildInputs =
+    builtins.attrValues { inherit (pkgs) pkg-config solo5; };
+  propagatedBuildInputs = builtins.attrValues {
+    inherit (pkgs) getdns postgresql solo5 sqlite libxml2 libxslt;
+  };
   lockFile = ./lock.json;
   src = pkgs.lib.sources.cleanSource ./.;
 }
diff --git a/src/schema/config.nim b/src/schema/config.nim
index 74a4197..4bcaaf4 100644
--- a/src/schema/config.nim
+++ b/src/schema/config.nim
@@ -50,6 +50,12 @@ type
   XsltArguments* {.preservesRecord: "xslt".} = object
     `field0`*: XsltArgumentsField0
 
+  HttpDriverArgumentsField0* {.preservesDictionary.} = object
+    `dataspace`* {.preservesEmbedded.}: EmbeddedRef
+
+  HttpDriverArguments* {.preservesRecord: "http-driver".} = object
+    `field0`*: HttpDriverArgumentsField0
+
   WebhooksArgumentsField0* {.preservesDictionary.} = object
     `endpoints`*: Table[seq[string], EmbeddedRef]
     `listen`*: Tcp
@@ -116,6 +122,7 @@ proc `$`*(x: WebsocketArguments | JsonTranslatorArguments | SocketAddress |
     JsonTranslatorConnected |
     JsonSocketTranslatorArguments |
     XsltArguments |
+    HttpDriverArguments |
     WebhooksArguments |
     FileSystemUsageArguments |
     SqliteArguments |
@@ -134,6 +141,7 @@ proc encode*(x: WebsocketArguments | JsonTranslatorArguments | SocketAddress |
     JsonTranslatorConnected |
     JsonSocketTranslatorArguments |
     XsltArguments |
+    HttpDriverArguments |
     WebhooksArguments |
     FileSystemUsageArguments |
     SqliteArguments |
diff --git a/src/syndesizer.nim b/src/syndesizer.nim
index 3e9a740..6686f30 100644
--- a/src/syndesizer.nim
+++ b/src/syndesizer.nim
@@ -9,6 +9,7 @@ import ./syndesizer/[
   base64_decoder,
   cache_actor,
   file_system_usage,
+  http_driver,
   json_socket_translator,
   json_translator,
   pulses,
@@ -20,6 +21,7 @@ runActor("syndesizer") do (turn: var Turn):
     discard spawnBase64Decoder(turn, ds)
     discard spawnCacheActor(turn, ds)
     discard spawnFileSystemUsageActor(turn, ds)
+    discard spawnHttpDriver(turn, ds)
     discard spawnJsonSocketTranslator(turn, ds)
     discard spawnJsonStdioTranslator(turn, ds)
     discard spawnPulseActor(turn, ds)
diff --git a/src/syndesizer/http_driver.nim b/src/syndesizer/http_driver.nim
new file mode 100644
index 0000000..46c0acb
--- /dev/null
+++ b/src/syndesizer/http_driver.nim
@@ -0,0 +1,42 @@
+# SPDX-FileCopyrightText: ☭ Emery Hemingway
+# SPDX-License-Identifier: Unlicense
+
+## Thin wrapper over `syndicate/drivers/http_driver`.
+
+import pkg/preserves, pkg/syndicate
+import pkg/syndicate/drivers/http_driver
+import pkg/taps
+import ../schema/config
+
+proc spawnHttpDriver*(turn: var Turn; ds: Cap): Actor {.discardable.}=
+  http_driver.spawnHttpDriver(turn, ds)
+  during(turn, ds, ?:HttpDriverArguments) do (ds: Cap):
+    http_driver.spawnHttpDriver(turn, ds)
+
+when isMainModule:
+  import syndicate/relays
+
+  when defined(solo5):
+    import solo5
+    acquireDevices([("eth0", netBasic)], netAcquireHook)
+
+    proc envRoute: Route =
+      var pr = parsePreserves $solo5_start_info.cmdline
+      if result.fromPreserves pr:
+        return
+      elif pr.isSequence:
+        for e in pr:
+          if result.fromPreserves e:
+            return
+      quit("failed to parse command line for route to Syndicate gatekeeper")
+
+    runActor("main") do (turn: var Turn):
+      let ds = newDataspace(turn)
+      spawnRelays(turn, ds)
+      resolve(turn, ds, envRoute(), spawnHttpDriver)
+
+  else:
+
+    runActor("main") do (turn: var Turn):
+      resolveEnvironment(turn) do (turn: var Turn; ds: Cap):
+        spawnHttpDriver(turn, ds)
diff --git a/src/syndesizer/http_driver.nim.cfg b/src/syndesizer/http_driver.nim.cfg
new file mode 100644
index 0000000..caff04e
--- /dev/null
+++ b/src/syndesizer/http_driver.nim.cfg
@@ -0,0 +1,2 @@
+define:ipv6Enabled
+include:"std/assertions"