Export snsUtils (#13)

packages/sns/index.ts

@@ -13,3 +13,5 @@ export type { SNSMessageOptions } from './lib/sns/AbstractSnsPublisher'
 export type { CommonMessage } from './lib/types/MessageTypes'
 
 export { deserializeSNSMessage } from './lib/sns/snsMessageDeserializer'
+
+export { assertTopic, deleteTopic, getTopicAttributes } from './lib/utils/snsUtils'

packages/sns/lib/utils/snsUtils.ts

@@ -1,5 +1,9 @@
 import type { CreateTopicCommandInput, SNSClient } from '@aws-sdk/client-sns'
-import { CreateTopicCommand, GetTopicAttributesCommand } from '@aws-sdk/client-sns'
+import {
+  CreateTopicCommand,
+  DeleteTopicCommand,
+  GetTopicAttributesCommand,
+} from '@aws-sdk/client-sns'
 import type { Either } from '@lokalise/node-core'
 
 type QueueAttributesResult = {
@@ -42,3 +46,19 @@ export async function assertTopic(snsClient: SNSClient, topicOptions: CreateTopi
   }
   return response.TopicArn
 }
+
+export async function deleteTopic(client: SNSClient, topicName: string) {
+  try {
+    const topicArn = await assertTopic(client, {
+      Name: topicName,
+    })
+
+    const command = new DeleteTopicCommand({
+      TopicArn: topicArn,
+    })
+
+    await client.send(command)
+  } catch (err) {
+    // we don't care it operation has failed
+  }
+}

packages/sns/test/consumers/SnsSqsPermissionsConsumer.spec.ts

@@ -7,11 +7,10 @@ import type { AwilixContainer } from 'awilix'
 import { asClass } from 'awilix'
 import { describe, beforeEach, afterEach, expect, it, afterAll, beforeAll } from 'vitest'
 
-import { assertTopic } from '../../lib/utils/snsUtils'
+import { assertTopic, deleteTopic } from '../../lib/utils/snsUtils'
 import { FakeConsumerErrorResolver } from '../fakes/FakeConsumerErrorResolver'
 import type { SnsPermissionPublisher } from '../publishers/SnsPermissionPublisher'
 import { userPermissionMap } from '../repositories/PermissionRepository'
-import { deleteTopic } from '../utils/snsUtils'
 import { registerDependencies, SINGLETON_CONFIG } from '../utils/testContext'
 import type { Dependencies } from '../utils/testContext'
 

packages/sns/test/publishers/SnsPermissionPublisher.spec.ts

@@ -10,13 +10,12 @@ import { describe, beforeEach, afterEach, expect, it, afterAll, beforeAll } from
 
 import { subscribeToTopic } from '../../lib/sns/SnsSubscriber'
 import { deserializeSNSMessage } from '../../lib/sns/snsMessageDeserializer'
-import { assertTopic } from '../../lib/utils/snsUtils'
+import { assertTopic, deleteTopic } from '../../lib/utils/snsUtils'
 import { SnsSqsPermissionConsumer } from '../consumers/SnsSqsPermissionConsumer'
 import type { PERMISSIONS_MESSAGE_TYPE } from '../consumers/userConsumerSchemas'
 import { PERMISSIONS_MESSAGE_SCHEMA } from '../consumers/userConsumerSchemas'
 import { FakeConsumerErrorResolver } from '../fakes/FakeConsumerErrorResolver'
 import { userPermissionMap } from '../repositories/PermissionRepository'
-import { deleteTopic } from '../utils/snsUtils'
 import { registerDependencies, SINGLETON_CONFIG } from '../utils/testContext'
 import type { Dependencies } from '../utils/testContext'