Merge pull request #2568 from lpsinger/circulars-verions-kafka

Always send new versions of GCN Circulars over Kafka
nasa-gcn · Sep 4, 2024 · 7bf8201 · 7bf8201
2 parents 6b8be21 + ce6af66
commit 7bf8201
Showing 1 changed file with 11 additions and 11 deletions.
diff --git a/app/table-streams/circulars/index.ts b/app/table-streams/circulars/index.ts
@@ -113,19 +113,19 @@ export const handler = createTriggerHandler(
  promises.push(removeIndex(id))
  } /* (eventName === 'INSERT' || eventName === 'MODIFY') */ else {
  const circular = unmarshallTrigger(dynamodb!.NewImage) as Circular
- promises.push(putIndex(circular))
+ const { sub, ...cleanedCircular } = circular
+ promises.push(
+ putIndex(circular),
+ sendKafka(
+ 'gcn.circulars',
+ JSON.stringify({
+ $schema: circularsJsonSchemaId,
+ ...cleanedCircular,
+ })
+ )
+ )
  if (eventName === 'INSERT') {
  promises.push(send(circular))
- const { sub, ...cleanedCircular } = circular
- promises.push(
- sendKafka(
- 'gcn.circulars',
- JSON.stringify({
- $schema: circularsJsonSchemaId,
- ...cleanedCircular,
- })
- )
- )
  }
  }