diff options
| author | bt <bt@rctt.net> | 2026-05-16 18:06:39 +0200 |
|---|---|---|
| committer | bt <bt@rctt.net> | 2026-05-16 22:46:48 +0200 |
| commit | b5d08e7908efaa2d9eae9a3d52249bbb51be0761 (patch) | |
| tree | 6b055fd9d69d89008c34b265d4bcc2b7a756ba33 /cmd/daemon | |
| parent | c363f6fd9c643db33941209a6e834c908165bbe3 (diff) | |
| download | solec-b5d08e7908efaa2d9eae9a3d52249bbb51be0761.tar.gz solec-b5d08e7908efaa2d9eae9a3d52249bbb51be0761.zip | |
Add "read" command to daemon CLI
Diffstat (limited to 'cmd/daemon')
| -rw-r--r-- | cmd/daemon/main.go | 16 |
1 files changed, 16 insertions, 0 deletions
diff --git a/cmd/daemon/main.go b/cmd/daemon/main.go index 242a45a..10fb61c 100644 --- a/cmd/daemon/main.go +++ b/cmd/daemon/main.go @@ -9,6 +9,7 @@ import ( "os" "slices" "strings" + "time" "go.rctt.net/solec/server" "go.rctt.net/solec/storage" @@ -19,6 +20,7 @@ import ( var ( cmds = map[string]func(args []string){ "broadcast": sendBroadcast, + "read": readHistory, "exit": exit, } serv *server.Server @@ -74,6 +76,20 @@ func sendBroadcast(args []string) { serv.SendBroadcast(msg) } +func readHistory(args []string) { + if len(args) != 1 { + fmt.Println("usage: read <channel>") + } + + hist, err := serv.Storage.Read(args[0], time.Time{}, 999999, 0) + if err != nil { + fmt.Println(err) + return + } + + fmt.Println(hist) +} + func exit(args []string) { os.Exit(0) } |
