laantungir/nak
1
0
Fork 0
mirror of https://github.com/fiatjaf/nak.git synced 2025-12-08 16:48:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

serve: --negentropy

Browse Source
This commit is contained in:
fiatjaf
2025-11-21 11:24:01 -03:00
parent 26f9b33d53
commit afa31a58fc
1 changed files with 14 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
serve.go
View File

@@ -43,6 +43,10 @@ var serve = &cli.Command{
Usage: "file containing the initial batch of events that will be served by the relay as newline-separated JSON (jsonl)", Usage: "file containing the initial batch of events that will be served by the relay as newline-separated JSON (jsonl)",
DefaultText: "the relay will start empty", DefaultText: "the relay will start empty",
}, },
&cli.BoolFlag{
Name: "negentropy",
Usage: "enable negentropy syncing",
},
&cli.BoolFlag{ &cli.BoolFlag{
Name: "grasp", Name: "grasp",
Usage: "enable grasp server", Usage: "enable grasp server",
@@ -91,6 +95,10 @@ var serve = &cli.Command{
rl.UseEventstore(db, 500) rl.UseEventstore(db, 500)
if c.Bool("negentropy") {
rl.Negentropy = true
}
started := make(chan bool) started := make(chan bool)
exited := make(chan error) exited := make(chan error)
@@ -152,7 +160,12 @@ var serve = &cli.Command{
// relay logging // relay logging
rl.OnRequest = func(ctx context.Context, filter nostr.Filter) (reject bool, msg string) { rl.OnRequest = func(ctx context.Context, filter nostr.Filter) (reject bool, msg string) {
log(" got %s %v\n", color.HiYellowString("request"), colors.italic(filter)) negentropy := ""
if khatru.IsNegentropySession(ctx) {
negentropy = color.HiBlueString("negentropy ")
}
log(" got %s%s %v\n", negentropy, color.HiYellowString("request"), colors.italic(filter))
printStatus() printStatus()
return false, "" return false, ""
} }