create synonym group for eventId if none exists

app/email-incoming/circulars/index.ts

@@ -27,6 +27,10 @@
 import { sendEmail } from '~/lib/email.server'
 import { hostname, origin } from '~/lib/env.server'
 import { putRaw, submitterGroup } from '~/routes/circulars/circulars.server'
+import {
+  createSynonyms,
+  synonymExists,
+} from '~/routes/synonyms/synonyms.server'
 
 interface UserData {
   email: string
@@ -99,6 +103,8 @@
     // Removes sub as a property if it is undefined from the legacy users
     if (!circular.sub) delete circular.sub
     const { circularId } = await putRaw(circular)
+    if (eventId && !(await synonymExists({ eventId })))
+      await createSynonyms([eventId])
 
     // Send a success email
     await sendSuccessEmail({

app/routes/circulars/circulars.server.ts

@@ -22,6 +22,7 @@
 import { dedent } from 'ts-dedent'
 
 import { type User, getUser } from '../_auth/user.server'
+import { createSynonyms, synonymExists } from '../synonyms/synonyms.server'
 import {
   bodyIsValid,
   formatAuthor,
@@ -311,8 +312,10 @@
 
   const eventId = parseEventFromSubject(item.subject)
   if (eventId) circular.eventId = eventId
-
-  return await putRaw(circular)
+  const result = await putRaw(circular)
+  if (eventId && !(await synonymExists({ eventId })))
+    await createSynonyms([eventId])
+  return result
 }
 
 export async function circularRedirect(query: string) {

app/routes/synonyms/synonyms.server.ts

@@ -122,6 +122,20 @@
   return Items as Circular[]
 }
 
+export async function synonymExists({ eventId }: { eventId: string }) {
+  const db = await tables()
+  const { Items } = await db.synonyms.query({
+    KeyConditionExpression: '#eventId = :eventId',
+    ExpressionAttributeNames: {
+      '#eventId': 'eventId',
+    },
+    ExpressionAttributeValues: {
+      ':eventId': eventId,
+    },
+  })
+  return Items.length >= 1
+}
+
 /*
  * If an eventId already has a synonym and is passed in, it will unlink the
  * eventId from the old synonym and the only remaining link will be to the