4d2d56c8ae
fix(nats): revert to consumer.messages() — fetch() defaults no_wait:true which skips empty queues
lint / lint (push) Has been cancelled
test / unit (push) Has been cancelled
test / integration (push) Has been cancelled
lint / lint (pull_request) Failing after 9m21s
test / unit (pull_request) Failing after 10m57s
test / integration (pull_request) Failing after 16m44s
2026-05-14 23:34:51 +02:00
a4377fe209
fix(nats): remove filter_subject from consumer config
test / unit (push) Has been cancelled
test / integration (push) Has been cancelled
lint / lint (push) Has been cancelled
lint / lint (pull_request) Failing after 9m20s
test / unit (pull_request) Failing after 10m40s
test / integration (pull_request) Failing after 17m47s
2026-05-14 23:29:45 +02:00
16892007a3
fix(nats): use fetch().expires(30s) instead of messages() — without expires NATS returns empty immediately
lint / lint (push) Has been cancelled
test / unit (push) Has been cancelled
test / integration (push) Has been cancelled
test / integration (pull_request) Has been cancelled
test / unit (pull_request) Has been cancelled
lint / lint (pull_request) Has been cancelled
2026-05-14 23:25:01 +02:00
40ed9b1ad8
fix(nats): delete+recreate stream when retention policy is incompatible
lint / lint (push) Has been cancelled
test / unit (push) Has been cancelled
test / integration (push) Has been cancelled
lint / lint (pull_request) Has been cancelled
test / unit (pull_request) Has been cancelled
test / integration (pull_request) Has been cancelled
2026-05-14 23:19:41 +02:00
0caca58c1c
fix(nats): align with movies-diary — Limits retention, single wildcard subject, filter_subject on consumer, prefixed publish
lint / lint (push) Has been cancelled
test / unit (push) Has been cancelled
test / integration (push) Has been cancelled
lint / lint (pull_request) Has been cancelled
test / unit (pull_request) Has been cancelled
test / integration (pull_request) Has been cancelled
2026-05-14 23:17:57 +02:00
9bda23f187
fix(nats): delete old push consumer before creating pull consumer
lint / lint (push) Has been cancelled
test / unit (push) Has been cancelled
test / integration (push) Has been cancelled
lint / lint (pull_request) Failing after 9m10s
test / unit (pull_request) Failing after 10m54s
test / integration (pull_request) Failing after 17m11s
2026-05-14 23:07:05 +02:00
17d2a186e1
fix(nats): switch from push to pull consumer — pull is reliable, push had deliver_subject issues
lint / lint (push) Has been cancelled
test / unit (push) Has been cancelled
test / integration (push) Has been cancelled
lint / lint (pull_request) Failing after 9m35s
test / unit (pull_request) Failing after 11m38s
test / integration (pull_request) Failing after 17m2s
2026-05-14 23:04:03 +02:00
7bbc702e85
debug: add INFO logging to ensure_stream and remote_actor_posts_handler
lint / lint (push) Has been cancelled
test / unit (push) Has been cancelled
test / integration (push) Has been cancelled
lint / lint (pull_request) Failing after 9m42s
test / unit (pull_request) Failing after 10m52s
test / integration (pull_request) Failing after 17m20s
2026-05-14 22:59:12 +02:00
df7fcf5096
fix: add federation.> to NATS stream subjects; update stream on startup; truncate long profile URLs
lint / lint (push) Has been cancelled
test / unit (push) Has been cancelled
test / integration (push) Has been cancelled
lint / lint (pull_request) Failing after 9m48s
test / unit (pull_request) Failing after 10m52s
test / integration (pull_request) Failing after 16m50s
2026-05-14 22:43:43 +02:00
12adddaa16
fix(nats): use explicit subject prefixes — WorkQueue retention disallows > wildcard
lint / lint (push) Has been cancelled
test / unit (push) Has been cancelled
test / integration (push) Has been cancelled
lint / lint (pull_request) Failing after 9m9s
test / unit (pull_request) Successful in 16m19s
test / integration (pull_request) Failing after 17m5s
2026-05-14 17:20:21 +02:00
458feebcdd
feat(nats): migrate to JetStream — at-least-once delivery with durable consumer
lint / lint (push) Has been cancelled
test / unit (push) Has been cancelled
test / integration (push) Has been cancelled
lint / lint (pull_request) Failing after 9m25s
test / unit (pull_request) Successful in 15m53s
test / integration (pull_request) Failing after 16m42s
2026-05-14 16:41:17 +02:00
004bfb427b
feat: implement merge readiness plan to close gaps between v2 and v1
...
lint / lint (push) Has been cancelled
test / unit (push) Has been cancelled
test / integration (push) Has been cancelled
lint / lint (pull_request) Failing after 5m8s
test / unit (pull_request) Successful in 16m18s
test / integration (pull_request) Failing after 16m59s
- Task 1: Fix feed response hydration by adding `to_thought_response` helper and updating feed handlers to return full `ThoughtResponse`.
- Task 2: Wire follower/following REST routes for user feeds.
- Task 3: Add user listing and count endpoints, including `GET /users` and `GET /users/count`.
- Task 4: Implement popular tags feature with `GET /tags/popular`.
- Task 5: Enhance configuration with HOST, CORS_ORIGINS, and optional rate limiting using tower-governor.
2026-05-14 16:28:18 +02:00
e995b29be1
refactor(nats): replace NatsEventConsumer with NatsMessageSource implementing MessageSource
2026-05-14 12:36:45 +02:00
f9ca5836fb
refactor: rename event-publisher → event-transport
2026-05-14 12:30:58 +02:00
cfc8c19175
refactor(nats): strip NatsEventPublisher, add NatsTransport implementing Transport
2026-05-14 12:22:11 +02:00
a0893b1c69
feat(nats): NatsEventPublisher and NatsEventConsumer with payload conversion
2026-05-14 09:54:50 +02:00
63a7001165
chore: scaffold v2 workspace
2026-05-14 03:07:45 +02:00