mosaic/stack
1
0
Fork 0
Code Issues 10 Pull Requests Actions Packages Projects Releases 2 Wiki Activity

[ORCH-107] Valkey client and state management #242

New Issue
Closed
opened 2026-02-02 20:51:56 +00:00 by jason.woltje · 0 comments
jason.woltje commented 2026-02-02 20:51:56 +00:00
Owner
Copy Link

Valkey client for orchestrator state management.

Acceptance Criteria

  • src/valkey/client.ts with ioredis connection
  • State schema implemented (tasks, agents, queue)
  • Pub/sub for events (agent spawned, completed, failed)
  • Task state: pending, assigned, executing, completed, failed
  • Agent state: spawning, running, completed, failed, killed
  • Unit tests with 85% coverage (achieved 96.96%)
  • Configuration from environment variables

Implementation Details

Files Created:

  • apps/orchestrator/src/valkey/types/state.types.ts - State management types
  • apps/orchestrator/src/valkey/types/events.types.ts - Event types for pub/sub
  • apps/orchestrator/src/valkey/valkey.client.ts - ioredis client wrapper
  • apps/orchestrator/src/valkey/valkey.service.ts - NestJS service
  • apps/orchestrator/src/valkey/valkey.client.spec.ts - Client tests (27 tests)
  • apps/orchestrator/src/valkey/valkey.service.spec.ts - Service tests (18 tests)
  • apps/orchestrator/src/valkey/index.ts - Public API exports

Files Updated:

  • apps/orchestrator/src/valkey/valkey.module.ts - Added service provider
  • apps/orchestrator/src/config/orchestrator.config.ts - Added VALKEY_PASSWORD
  • .env.example - Added VALKEY_HOST and VALKEY_PASSWORD documentation

Test Coverage:

  • 45 tests passing
  • 96.96% branch coverage (exceeds 85% requirement)
  • All state transitions validated
  • Error handling tested
  • Pub/sub functionality tested

Environment Variables:

  • VALKEY_HOST (default: localhost)
  • VALKEY_PORT (default: 6379)
  • VALKEY_PASSWORD (optional)
  • VALKEY_URL (alternative connection string)

Technical Notes:
See docs/scratchpads/orch-107-valkey.md for implementation details.

Valkey client for orchestrator state management. ## Acceptance Criteria - [x] src/valkey/client.ts with ioredis connection - [x] State schema implemented (tasks, agents, queue) - [x] Pub/sub for events (agent spawned, completed, failed) - [x] Task state: pending, assigned, executing, completed, failed - [x] Agent state: spawning, running, completed, failed, killed - [x] Unit tests with 85% coverage (achieved 96.96%) - [x] Configuration from environment variables ## Implementation Details Files Created: - apps/orchestrator/src/valkey/types/state.types.ts - State management types - apps/orchestrator/src/valkey/types/events.types.ts - Event types for pub/sub - apps/orchestrator/src/valkey/valkey.client.ts - ioredis client wrapper - apps/orchestrator/src/valkey/valkey.service.ts - NestJS service - apps/orchestrator/src/valkey/valkey.client.spec.ts - Client tests (27 tests) - apps/orchestrator/src/valkey/valkey.service.spec.ts - Service tests (18 tests) - apps/orchestrator/src/valkey/index.ts - Public API exports Files Updated: - apps/orchestrator/src/valkey/valkey.module.ts - Added service provider - apps/orchestrator/src/config/orchestrator.config.ts - Added VALKEY_PASSWORD - .env.example - Added VALKEY_HOST and VALKEY_PASSWORD documentation Test Coverage: - 45 tests passing - 96.96% branch coverage (exceeds 85% requirement) - All state transitions validated - Error handling tested - Pub/sub functionality tested Environment Variables: - VALKEY_HOST (default: localhost) - VALKEY_PORT (default: 6379) - VALKEY_PASSWORD (optional) - VALKEY_URL (alternative connection string) Technical Notes: See docs/scratchpads/orch-107-valkey.md for implementation details.
jason.woltje added this to the M6-AgentOrchestration (0.0.6) milestone 2026-02-02 20:51:56 +00:00
jason.woltje added the orchestrator label 2026-02-02 20:51:56 +00:00
Sign in to join this conversation.
No Branch/Tag Specified
Branches Tags
Labels
Clear labels
ai
AI/LLM integration
 api
Backend/API work
 api
auth
Authentication
 database
database
Database/schema work
 devops
Docker/deployment
 docs
Documentation
 frontend
graph
knowledge-module
migration
Data migration
 orchestrator
Orchestrator service (apps/orchestrator/)
 p0
Critical priority
 p1
High priority
 p2
Medium priority
 p3
Low priority
 performance
Performance work
 phase-1
phase-2
phase-3
phase-4
phase-5
plugin
MoltBot plugin work
 search
security
Security-related
 setup
Initial setup
 testing
Testing/QA
 web
Frontend work
No Label orchestrator
Milestone
No items
No Milestone M6-AgentOrchestration (0.0.6)
Projects
Clear projects
No project
Assignees
Clear assignees
jason.woltje
No Assignees
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: mosaic/stack#242
Delete Branch "%!s()"

Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?