feat: batch syncStreams, status refresh cron, refresh token, claim flow (#136 #138 #140 #49)

[benfoster-dev]

Fixes #136
Fixes #138
Fixes #140
Fixes #49

What changed

#136 — Batch syncStreams with concurrency limit

backend/src/services/streamStore.ts

• Replaced the sequential for loop with Promise.all + p-limit(5) — max 5 simultaneous RPC calls instead of N sequential calls
• If the parallel pass throws, falls back to a sequential per-stream loop so progress is preserved
• Logs total sync time in ms and stream count on completion
• Added p-limit to backend/package.json

#138 — Configurable cron for refreshStreamStatuses

backend/src/index.ts

• refreshStreamStatuses() now runs once on startup and then every STATUS_REFRESH_INTERVAL_MS ms (default 60000)
• Setting STATUS_REFRESH_INTERVAL_MS=0 disables automatic refresh (useful in test environments)
• Logs the count of streams transitioned to completed on each run
• Added refreshStreamStatuses to the streamStore import

#140 — Refresh token endpoint

backend/src/services/auth.ts

• Added refreshToken(req, res) that verifies the current Bearer JWT and issues a new one with a fresh 24h expiry
• Returns 401 if the token is missing, malformed, or already expired

backend/src/index.ts

• Registered POST /api/auth/refresh

backend/src/swagger.ts

• Added /api/auth/refresh path with 200 (new token) and 401 (invalid/expired) response schemas

#49 — Claim flow for recipient dashboard

frontend/src/services/soroban.ts (new)

• claimStream(streamId, recipientAddress, amount) calls POST /api/streams/:id/claim with the recipient's Bearer token and returns ClaimResult + history

frontend/src/hooks/useClaimStream.ts (new)

• State machine: idle → pending → confirmed/failed → idle
• Monotonic claimIdRef prevents stale async callbacks from mutating state after a superseded claim
• Blocks concurrent claims while one is in-flight
• Auto-resets to idle after 2s in confirmed state so the "Claimed ✓" label is briefly visible

backend/src/index.ts

• POST /api/streams/:id/claim endpoint: validates the caller is the stream recipient, checks vestedAmount > 0, records a claimed event in the local DB, returns { result: ClaimResult, history: StreamEvent[] }

[vercel]

@benfoster-dev is attempting to deploy a commit to the ritik4ever's projects Team on Vercel.

A member of the Team first needs to authorize it.

[drips-wave]

@benfoster-dev Great news! 🎉 Based on an automated assessment of this PR, the linked Wave issue(s) no longer count against your application limits.

You can now already apply to more issues while waiting for a review of this PR. Keep up the great work! 🚀

Learn more about application limits