tests

test/components.ts

@@ -25,7 +25,7 @@ import { createWorldsManagerComponent } from '../src/adapters/worlds-manager'
 import { createPermissionsManagerComponent } from '../src/adapters/permissions-manager'
 import { createMockNameOwnership } from './mocks/name-ownership-mock'
 import { createMockUpdateOwnerJob } from './mocks/update-owner-job-mock'
-import { createSnsClientMock } from './mocks/sns-clientmock'
+import { createSnsClientMock } from './mocks/sns-client-mock'
 import { createDotEnvConfigComponent } from '@well-known-components/env-config-provider'
 import { SnsClient } from '../src/adapters/sns-client'
 
@@ -48,7 +48,6 @@ async function initComponents(): Promise<TestComponents> {
   const config = await createDotEnvConfigComponent(
     { path: ['.env.default', '.env'] },
     {
-      AUTH_SECRET: 'some-secret',
       SNS_ARN: 'some-arn'
     }
   )

test/integration/reprocess-ab-handler.spec.ts

@@ -1,33 +1,61 @@
 import { test } from '../components'
-import { stringToUtf8Bytes } from 'eth-connect'
+import { Authenticator } from '@dcl/crypto'
+import { DeploymentToSqs } from '@dcl/schemas/dist/misc/deployments-to-sqs'
 
 test('reprocess asset-bundles handler /reprocess-ab', function ({ components, stubComponents }) {
   beforeEach(async () => {
     const { config } = stubComponents
     config.getString.withArgs('SNS_ARN').resolves('some-arn')
   })
 
-  it('when world exists it responds', async () => {
+  it('can reprocess all worlds', async () => {
     const { localFetch, worldCreator } = components
+    const { snsClient } = stubComponents
 
-    const files = new Map<string, Uint8Array>()
-    files.set('abc.png', Buffer.from(stringToUtf8Bytes('Hello world')))
+    const { entityId, owner } = await worldCreator.createWorldWithScene({})
+    const authChain = Authenticator.signPayload(owner, entityId)
 
-    const { entityId, worldName, entity } = await worldCreator.createWorldWithScene({})
+    snsClient.publishBatch.resolves({
+      Successful: [{ Id: 'mocked-id', MessageId: 'mocked-message-id', SequenceNumber: '1' }],
+      Failed: [],
+      $metadata: {}
+    })
 
-    const r = await localFetch
-      .fetch(`/reprocess-ab`, {
-        method: 'POST',
-        headers: {
-          Authorization: 'Bearer setup_some_secret_here'
+    const r = await localFetch.fetch(`/reprocess-ab`, {
+      method: 'POST',
+      headers: {
+        Authorization: 'Bearer setup_some_secret_here'
+      }
+    })
+
+    const baseUrl = `http://0.0.0.0:3000`
+    expect(r.status).toEqual(200)
+    expect(await r.json()).toMatchObject({
+      baseUrl: baseUrl,
+      batch: expect.arrayContaining<DeploymentToSqs>([
+        {
+          entity: {
+            entityId,
+            authChain
+          },
+          contentServerUrls: [baseUrl]
         }
-      })
-      .catch(console.error)
-
-    // console.log(r.status, r.statusText)
-    // expect(r.status).toEqual(200)
-    // expect(await r.json()).toEqual({
-    //   name: worldName
-    // })
+      ]),
+      successful: 1,
+      failed: 0
+    })
+  })
+
+  it('can not be called if no SNS_ARN configured', async () => {
+    const { localFetch } = components
+
+    const r = await localFetch.fetch(`/reprocess-ab`, {
+      method: 'POST',
+      headers: {
+        Authorization: 'Bearer setup_some_secret_here'
+      }
+    })
+    expect(r.status).toEqual(500)
+    expect(await r.json()).toMatchObject({ error: 'Internal Server Error' })
   })
 })

test/mocks/sns-clientmock.ts → test/mocks/sns-client-mock.ts

@@ -10,10 +10,9 @@ export function createSnsClientMock(): SnsClient {
 
   const publishBatch = jest.fn()
   publishBatch.mockImplementation(() => ({
-    promise: jest.fn().mockResolvedValue({
-      Successful: ['mocked-message-id'],
-      Failed: []
-    })
+    Successful: [{ Id: 'mocked-id', MessageId: 'mocked-message-id', SequenceNumber: '1' }],
+    Failed: [],
+    $metadata: {}
   }))
 
   return {