diff options
| author | Xe Iaso <me@xeiaso.net> | 2024-10-26 09:29:29 -0400 |
|---|---|---|
| committer | Xe Iaso <me@xeiaso.net> | 2024-10-26 09:29:29 -0400 |
| commit | 2c7072c1fab9328c6f2f3a1245e4aa85baac5f73 (patch) | |
| tree | 031ccd9294ea970a5e450ebe3c9bda4c44f7a4ce /cmd | |
| parent | 4ba8b29bb35c61b4bd7fb1208e28af203c347ee6 (diff) | |
| download | x-2c7072c1fab9328c6f2f3a1245e4aa85baac5f73.tar.xz x-2c7072c1fab9328c6f2f3a1245e4aa85baac5f73.zip | |
cmd/{amano,stealthmountain}: I misnamed the nats subjects
Signed-off-by: Xe Iaso <me@xeiaso.net>
Diffstat (limited to 'cmd')
| -rw-r--r-- | cmd/amano/main.go | 6 | ||||
| -rw-r--r-- | cmd/stealthmountain/main.go | 2 |
2 files changed, 4 insertions, 4 deletions
diff --git a/cmd/amano/main.go b/cmd/amano/main.go index 98ec545..bbc867b 100644 --- a/cmd/amano/main.go +++ b/cmd/amano/main.go @@ -79,7 +79,7 @@ func handleEvent(nc *nats.Conn) func(ctx context.Context, ev *jsModels.Event) er return fmt.Errorf("can't marshal account event: %w", err) } - if err := nc.Publish("amano:account", data); err != nil { + if err := nc.Publish("amano.account", data); err != nil { return fmt.Errorf("can't publish account event: %w", err) } case "identity": @@ -88,11 +88,11 @@ func handleEvent(nc *nats.Conn) func(ctx context.Context, ev *jsModels.Event) er return fmt.Errorf("can't marshal identity event: %w", err) } - if err := nc.Publish("amano:identity", data); err != nil { + if err := nc.Publish("amano.identity", data); err != nil { return fmt.Errorf("can't publish identity event: %w", err) } case "commit": - subject := fmt.Sprintf("amano:commit:%s", ev.Commit.Collection) + subject := fmt.Sprintf("amano.commit.%s", ev.Commit.Collection) data, err := json.Marshal(ev.Commit) if err != nil { return fmt.Errorf("can't marshal commit event: %w", err) diff --git a/cmd/stealthmountain/main.go b/cmd/stealthmountain/main.go index d4ae7b0..536bacf 100644 --- a/cmd/stealthmountain/main.go +++ b/cmd/stealthmountain/main.go @@ -19,7 +19,7 @@ import ( ) const ( - PostTopic = "amano:commit:app.bsky.feed.post" + PostTopic = "amano.commit.app.bsky.feed.post" ) var ( |