homelab-frontend

riotpiao-poimen/homelab-frontend

Fork 0

Author	SHA1	Message	Date
Admin Bot	d820f44d44	feat: add typed Poimen REST endpoints and wire workflow types (#32 , #34 ) CI / CI (pull_request) Successful in 2m59s Details - New internal/temporal/poimen.go: PoimenHandler with typed REST endpoints POST /v1/poimen/plan — call PlannerActivity (stub until workflows#23) POST /v1/poimen/execute — start DAG/Orchestrator/Routing workflows GET /v1/poimen/executions — list Poimen workflow executions GET /v1/poimen/executions/:id — describe execution GET /v1/poimen/executions/:id/history — activity event history GET /v1/poimen/executions/:id/stream — SSE events (delegates to sse.go) POST /v1/poimen/executions/:id/signal — pause/resume/cancel DELETE /v1/poimen/executions/:id — terminate workflow - New internal/serviceadapter/poimen_adapter.go: ServiceAdapter spec + factory - Wire PoimenHandler in cmd/gateway/main.go via ServiceAdapter registry - Workflow type registry: dag->DAGWorkflow, orchestrator->OrchestratorWorkflow, routing->RoutingWorkflow (all on poimen-worker task queue) Closes #32 Closes #34	2026-09-26 18:49:17 +08:00
Admin Bot	a4fbd5cf2f	feat: add SSE streaming endpoint for workflow events (#33 ) - New internal/temporal/sse.go: StreamWorkflowEvents handler - Polls Temporal GetWorkflowExecutionHistory every 2s - Maps Temporal event types to semantic SSE events (activity_started/completed/failed, workflow_completed, etc.) - Heartbeat every 15s, clean close on workflow completion - Route: GET /workflow/stream?workflow_id=X&namespace=default - Added stream resource to workflow ServiceAdapter spec Closes #33	2026-09-26 18:44:42 +08:00
Admin Bot	11cef8a889	fix: clean up dead Temporal operations.go stubs (#31 ) - Delete operations.go (TODO stubs, never called by handler.go) - Refactor handler.go: 8 methods delegate to WorkflowGRPCImpl/SearchAttributesGRPCImpl - Remove unused query/v1 import - Remaining inline methods kept (reset, update, activity, namespace, cluster ops) - No behavior change in API responses Closes #31	2026-09-26 18:44:42 +08:00

Author

SHA1

Message

Date

Admin Bot

d820f44d44

feat: add typed Poimen REST endpoints and wire workflow types (#32 , #34 )

CI / CI (pull_request) Successful in 2m59s

Details

- New internal/temporal/poimen.go: PoimenHandler with typed REST endpoints
  POST /v1/poimen/plan — call PlannerActivity (stub until workflows#23)
  POST /v1/poimen/execute — start DAG/Orchestrator/Routing workflows
  GET  /v1/poimen/executions — list Poimen workflow executions
  GET  /v1/poimen/executions/:id — describe execution
  GET  /v1/poimen/executions/:id/history — activity event history
  GET  /v1/poimen/executions/:id/stream — SSE events (delegates to sse.go)
  POST /v1/poimen/executions/:id/signal — pause/resume/cancel
  DELETE /v1/poimen/executions/:id — terminate workflow
- New internal/serviceadapter/poimen_adapter.go: ServiceAdapter spec + factory
- Wire PoimenHandler in cmd/gateway/main.go via ServiceAdapter registry
- Workflow type registry: dag->DAGWorkflow, orchestrator->OrchestratorWorkflow,
  routing->RoutingWorkflow (all on poimen-worker task queue)

Closes #32
Closes #34

2026-09-26 18:49:17 +08:00

Admin Bot

a4fbd5cf2f

feat: add SSE streaming endpoint for workflow events (#33 )

- New internal/temporal/sse.go: StreamWorkflowEvents handler
- Polls Temporal GetWorkflowExecutionHistory every 2s
- Maps Temporal event types to semantic SSE events
  (activity_started/completed/failed, workflow_completed, etc.)
- Heartbeat every 15s, clean close on workflow completion
- Route: GET /workflow/stream?workflow_id=X&namespace=default
- Added stream resource to workflow ServiceAdapter spec

Closes #33

2026-09-26 18:44:42 +08:00

Admin Bot

11cef8a889

fix: clean up dead Temporal operations.go stubs (#31 )

- Delete operations.go (TODO stubs, never called by handler.go)
- Refactor handler.go: 8 methods delegate to WorkflowGRPCImpl/SearchAttributesGRPCImpl
- Remove unused query/v1 import
- Remaining inline methods kept (reset, update, activity, namespace, cluster ops)
- No behavior change in API responses

Closes #31

2026-09-26 18:44:42 +08:00

Compare commits

Diff Content Not Available