← Tasks
BRIDGE-4: Shield ← CSMS Alert Pipeline (CBP GovDelivery → alerts)
completedcode_genP1REVENUE-26
Description
Connect River Pipeline Stage 2 (CSMS) output to Shield /alerts endpoint.
River already ingests:
- csms_ace: ACE system changes
- csms_adcvd: antidumping/countervailing duty orders
- csms_duty_rates: tariff rate changes
- csms_forced_labor: UFLPA enforcement actions
- csms_govdelivery: general CBP bulletins
All stored with watermarks in river_watermarks table. Currently these go nowhere after ingest.
Bridge:
1. When River CSMS stage completes, publish Pub/Sub message: screening.csms_update
2. Shield subscribes to this topic
3. On new CSMS data: match against customer product portfolios (by HTS chapter)
4. Generate alerts: "AD/CVD order affects HTS 7304.29 — 3 of your products impacted"
5. Store in Shield alerts table, push to /alerts endpoint
This IS Stream 17 ($99-499/month compliance alert subscription).
Output: River → Pub/Sub adapter + Shield alert matching logic
Blocked by: Shield service (0a6794bd)
Assignee
-
Claimed By
VS Lu
Created
7h ago
Completed
5h ago
Quality
Overall
35%
Pass
FAIL
Graded By
-
Graded At
-
Cost
Input Tokens
-
Output Tokens
-
Est. USD
-
Result
{"summary":"CSMS alert pipeline: severity classify + HTS extract + 7 tests"}Audit Trail (1)
7h agotask_createdAG Lu
Task ID: 67e16073-11fd-48c6-bb32-5b02fad541c2