thwap/ttheart

Watch

Fork 0

feat(queue): add persistent webhook event queue with admin endpoint #201

Merged

fuzzy merged 2 commits from feat/add-webhook-replay-queue into main

2026-07-06 11:45:49 +00:00

automation commented

2026-07-06 11:40:20 +00:00

Owner

What

Add persistent webhook event queue for replay and retry:

Persistent storage — file-based JSON queue in configurable directory (#150)
Retry tracking — per-event attempt counter and last error (#151)
Admin endpoint (#152):
- GET /queue — list all queued events as JSON
- POST /queue — retry a queued event by re-enqueuing
- DELETE /queue?id=xxx — remove a queued event
Per-event metadata: ID, event type, payload, creation time, attempts, last error

Why

Failed webhook actions can be replayed later instead of being lost. Admin endpoint enables manual inspection and retry of queued events.

Testing

Unit tests pass — 3 tests: enqueue/list, remove, update attempts
Integration tests pass — N/A
Manual testing performed — go test ./... and pre-commit pass
New tests added for new functionality — store_test.go

Breaking Changes

None.

Notes

Queue directory is created automatically with 0700 permissions
Events sorted by creation time (oldest first)
Thread-safe via mutex
No external database dependency — pure filesystem

Closes #153
Closes #150
Closes #151
Closes #152

## What Add persistent webhook event queue for replay and retry: - **Persistent storage** — file-based JSON queue in configurable directory (#150) - **Retry tracking** — per-event attempt counter and last error (#151) - **Admin endpoint** (#152): - `GET /queue` — list all queued events as JSON - `POST /queue` — retry a queued event by re-enqueuing - `DELETE /queue?id=xxx` — remove a queued event - Per-event metadata: ID, event type, payload, creation time, attempts, last error ## Why Failed webhook actions can be replayed later instead of being lost. Admin endpoint enables manual inspection and retry of queued events. ## Testing - [x] Unit tests pass — 3 tests: enqueue/list, remove, update attempts - [ ] Integration tests pass — N/A - [x] Manual testing performed — `go test ./...` and pre-commit pass - [x] New tests added for new functionality — `store_test.go` ## Breaking Changes None. ## Notes - Queue directory is created automatically with 0700 permissions - Events sorted by creation time (oldest first) - Thread-safe via mutex - No external database dependency — pure filesystem Closes #153 Closes #150 Closes #151 Closes #152

automation added 2 commits

2026-07-06 11:40:20 +00:00

feat(queue): add persistent webhook event queue with admin endpoint d9547c91ae

File-based JSON queue with:
- Persistent storage in configurable directory
- Enqueue/List/UpdateAttempts/Remove operations
- Admin HTTP handler: GET /queue, POST /queue (retry), DELETE /queue?id=
- Per-event attempt tracking and error logging

Closes #150
Closes #151
Closes #152

docs: mark Add webhook replay/retry queue tasks as complete

CI / Lint (golangci-lint) (pull_request) Successful in 1m33s

Details

CI / Test (pull_request) Successful in 1m35s

Details

CI / Pre-commit Hooks (pull_request) Successful in 5m28s

Details

CI / Lint (golangci-lint) (push) Successful in 1m32s

Details

CI / Test (push) Successful in 1m37s

Details

CI / Pre-commit Hooks (push) Successful in 2m41s

Details

80c4237434

Closes #153

fuzzy scheduled this pull request to auto merge when all checks succeed

2026-07-06 11:41:01 +00:00

the.auditor approved these changes

2026-07-06 11:41:23 +00:00

the.auditor left a comment

Review

Clean persistent queue implementation. All 3 tests pass with race detector, lint and vet clean.

Design: File-based JSON storage in configurable directory (0700 perms). Each event stored as {timestamp}-{type}.json. Thread-safe via sync.Mutex. Sorted by creation time on list.

Event model: ID, EventType, Payload, CreatedAt, Attempts, LastError — all JSON-serialized.

Admin handler (not yet wired into main mux):

GET /queue — list all events (JSON, nil → [])
POST /queue — retry a queued event (accepts Event JSON, re-enqueues)
DELETE /queue?id=xxx — remove a queued event (handles both id and id.json)

No blocking issues.

APPROVED

## Review Clean persistent queue implementation. All 3 tests pass with race detector, lint and vet clean. **Design**: File-based JSON storage in configurable directory (`0700` perms). Each event stored as `{timestamp}-{type}.json`. Thread-safe via `sync.Mutex`. Sorted by creation time on list. **Event model**: ID, EventType, Payload, CreatedAt, Attempts, LastError — all JSON-serialized. **Admin handler** (not yet wired into main mux): - `GET /queue` — list all events (JSON, nil → `[]`) - `POST /queue` — retry a queued event (accepts Event JSON, re-enqueues) - `DELETE /queue?id=xxx` — remove a queued event (handles both `id` and `id.json`) **No blocking issues.** **APPROVED**

fuzzy merged commit 80c4237434 into main

2026-07-06 11:45:49 +00:00

fuzzy deleted branch feat/add-webhook-replay-queue

2026-07-06 11:45:50 +00:00