SQLite logging

src/msg.nim

@@ -10,10 +10,11 @@ proc main =
     data = map(commandLineParams(), parsePreserves)
 
   discard bootDataspace("msg") do (turn: var Turn; root: Cap):
+    spawnRelays(turn, root)
     resolve(turn, root, route) do (turn: var Turn; ds: Cap):
       for e in data:
         message(turn, ds, e)
 
-  for _ in 1..4: poll()
+  for _ in 1..2: poll()
 
 main()

src/schema/config.nim

@@ -49,7 +49,7 @@ type
 
   CacheArgumentsField0* {.preservesDictionary.} = object
     `dataspace`* {.preservesEmbedded.}: EmbeddedRef
-    `lifetime`*: float32
+    `lifetime`*: BiggestFloat
 
   CacheArguments* {.preservesRecord: "cache".} = object
     `field0`*: CacheArgumentsField0

src/schema/net_mapper.nim

@@ -5,9 +5,9 @@ import
 type
   RoundTripTime* {.preservesRecord: "rtt".} = object
     `address`*: string
-    `minimum`*: float32
-    `average`*: float32
-    `maximum`*: float32
+    `minimum`*: BiggestFloat
+    `average`*: BiggestFloat
+    `maximum`*: BiggestFloat
 
 proc `$`*(x: RoundTripTime): string =
   `$`(toPreserves(x))

src/syndesizer/sqlite_actor.nim

@@ -81,6 +81,7 @@ proc extractTuple(stmt: Stmt; arity: cint): Value =
 proc spawnSqliteActor*(turn: var Turn; root: Cap): Actor {.discardable.} =
   spawn("sqlite-actor", turn) do (turn: var Turn):
     during(turn, root, ?:SqliteArguments) do (path: string, ds: Cap):
+      stderr.writeLine("opening SQLite database ", path)
       var db: Sqlite3
       if open_v2(path, addr db, SQLITE_OPEN_READONLY, nil) != SQLITE_OK:
         logError(db, path)
@@ -104,6 +105,7 @@ proc spawnSqliteActor*(turn: var Turn; root: Cap): Actor {.discardable.} =
               if finalize(stmt) != SQLITE_OK: logError(db, statement)
     do:
       close(db)
+      stderr.writeLine("closed SQLite database ", path)
 
 when isMainModule:
   runActor("main") do (turn: var Turn; root: Cap):

src/syndex_card.nim

@@ -126,6 +126,7 @@ proc main =
   else:
     let entity = DumpEntity()
     runActor("syndex_card") do (root: Cap; turn: var Turn):
+      spawnRelays(turn, root)
       resolve(turn, root, route) do (turn: var Turn; ds: Cap):
         discard observe(turn, ds, pat, entity)
 

src/syndump.nim

@@ -64,6 +64,7 @@ proc main =
   runActor("syndex_card") do (root: Cap; turn: var Turn):
     for pat in patterns:
       discard observe(turn, root, pat, entity)
+    spawnRelays(turn, root)
     resolve(turn, root, route) do (turn: var Turn; ds: Cap):
       for pat in patterns:
         discard observe(turn, ds, pat, entity)

syndicate_utils.nimble

@@ -1,6 +1,6 @@
 # Package
 
-version = "20240120"
+version = "20240205"
 author        = "Emery Hemingway"
 description   = "Utilites for Syndicated Actors and Synit"
 license       = "unlicense"