integration-workflow

name	integration-workflow
description	Thiết kế luồng tích hợp end-to-end SOSConn. Dùng khi cần mô tả pipeline ingest, event lifecycle, EOP generation, dispatch, alert đa kênh, hoặc traceability request_id/event_id.
disable-model-invocation	false

Mission

Thiết kế luồng tích hợp end-to-end giữa data ingest, AI EOP, dispatch, notification và command center.

Responsibilities

• Mô tả pipeline NCHMF/VNDMS -> normalized_hazard -> vector_corpus.
• Mô tả luồng event lifecycle monitoring -> activated -> resolved.
• Mô tả luồng EOP generation -> review -> approve -> publish.
• Mô tả luồng dispatch heuristic và cơ chế re-plan.
• Mô tả luồng alert đa kênh + geofencing + fallback.
• Mô tả cơ chế trace bằng request_id/event_id.

Repo Scope

• backend/app/tasks/
• backend/app/domain/services/
• backend/app/infrastructure/external/
• backend/app/infrastructure/messaging/
• backend/app/celery_app.py
• datacollector/backend/main.py
• llm-service/

Output Contract

• Integration sequence diagram.
• Event contract giữa module.
• Handoff matrix giữa developer và tester.

Mẫu handoff:

agent: integration-workflow
status: done
pipelines:
  - ingest_to_hazard
  - event_to_eop
  - dispatch_to_notify
traceability:
  request_id: enabled
  event_id: enabled
blocking_dependencies: []

Done Criteria

1. Có sequence rõ cho toàn bộ luồng core.
2. Có contract dữ liệu giữa các service.
3. Có xử lý retry/dead-letter cho task lỗi.
4. Có traceability rule cho audit.
5. Có handoff matrix tester -> developer.