1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
|
package main
import (
"flag"
"fmt"
"os"
"os/signal"
"path/filepath"
"strings"
"syscall"
"nymdrop/internal/reader"
)
func main() {
keyFile := flag.String("key", "", "path to X25519 private key file (hex, 32 bytes); generated if missing")
inboxID := flag.String("id", "nymdrop-inbox", "nym-client identity id")
wsPort := flag.Int("ws-port", 1977, "nym-client websocket port")
outDir := flag.String("out", "", "directory to save submissions (default: ~/nymdrop-inbox, or <data-dir>/nymdrop-inbox)")
dataDir := flag.String("data-dir", "", "self-contained data directory (key, nym-client state, inbox all live here instead of $HOME — for portable/USB use, no trace left on the host)")
guiMode := flag.Bool("gui", false, "launch the graphical reader instead of the headless/CLI mode")
flag.Parse()
cfg := reader.Config{
KeyFile: *keyFile,
InboxID: *inboxID,
WSPort: *wsPort,
OutDir: *outDir,
DataDir: *dataDir,
Debug: os.Getenv("NYMDROP_DEBUG") != "",
}
if *guiMode {
runGUI(cfg)
return
}
runCLI(cfg)
}
func runCLI(cfg reader.Config) {
hooks := reader.Hooks{
Log: func(format string, args ...any) {
fmt.Printf(format+"\n", args...)
},
SelfAddress: func(addr string) {
fmt.Printf("Nym inbox address: %s\n\n", addr)
},
Submission: func(path, preview string) {
ts := strings.TrimSuffix(filepath.Base(path), ".txt")
fmt.Printf("\n[%s] New submission -> %s\n", ts, path)
fmt.Printf(" %s\n", strings.ReplaceAll(preview, "\n", "\n "))
},
Attachment: func(path string, size int) {
fmt.Printf(" attachment -> %s (%d bytes)\n", path, size)
},
Error: func(err error) {
fmt.Fprintln(os.Stderr, err)
},
}
in, err := reader.Start(cfg, hooks)
if err != nil {
fatalf("%v", err)
}
defer in.Close()
fmt.Printf("nymdrop-reader listening -- submissions saved to %s\n", in.OutDir())
fmt.Println("Press Ctrl+C to quit.")
go in.ReceiveLoop()
sig := make(chan os.Signal, 1)
signal.Notify(sig, syscall.SIGINT, syscall.SIGTERM)
<-sig
fmt.Println("\nShutting down.")
}
func fatalf(format string, args ...any) {
fmt.Fprintf(os.Stderr, "nymdrop-reader: "+format+"\n", args...)
os.Exit(1)
}
|
