feat: ws1 1455 e2e test for get events

suite/src/__tests__/fast/get-events.test.ts

@@ -0,0 +1,52 @@
+import { describe, expect, test } from '@jest/globals'
+import fetch from 'cross-fetch'
+import { generateRandomEventId, generateRandomEvent } from '../../utils/rustCeramicHelpers'
+
+const CeramicUrls = String(process.env.CERAMIC_URLS).split(',')
+
+async function postEvent(url: string, event: any) {
+  let response = await fetch(url + '/ceramic/events', {
+    method: 'POST',
+    headers: {
+      'Content-Type': 'application/json',
+    },
+    body: JSON.stringify(event),
+  })
+  if (!response.ok) {
+    throw new Error(`HTTP error! status: ${response.status}`)
+  }
+}
+
+async function getEventData(url: string, eventId: string) {
+  let response = await fetch(url + `/ceramic/events/${eventId}`)
+  console.log(response)
+  return response
+}
+
+describe('rust-ceramic e2e test', () => {
+  const ceramicUrl = CeramicUrls[0]
+  test('post and get event data, success', async () => {
+    const eventId = generateRandomEventId()
+    const event = generateRandomEvent(eventId)
+    // publishing the event to rust-ceramic
+    await postEvent(ceramicUrl, event)
+    // fetching the event from its event-id from rust-ceramic
+    const getResponse = await getEventData(ceramicUrl, eventId)
+    expect(getResponse.status).toEqual(200)
+    expect(await getResponse.json()).toEqual({
+      eventId: eventId,
+      eventData: event.eventData,
+    })
+  })
+
+  test('get event data for non-existing event', async () => {
+    const eventId = generateRandomEventId()
+    // fetching the event from its event-id from rust-ceramic
+    const getResponse = await getEventData(ceramicUrl, eventId)
+    const responseText = await getResponse.text()
+    expect(getResponse.status).toEqual(400)
+    expect(responseText).toContain('Event not found')
+    expect(responseText).toContain(eventId)
+    expect(getResponse.statusText).toContain('Bad Request')
+  })
+})

suite/src/utils/rustCeramicHelpers.ts

@@ -0,0 +1,26 @@
+import { randomCID, EventID, StreamID } from '@ceramicnetwork/streamid'
+import { base16 } from 'multiformats/bases/base16'
+import { CARFactory } from 'cartonne'
+import { base64 } from 'multiformats/bases/base64'
+import * as random from '@stablelib/random'
+
+export function generateRandomEventId(): string {
+  const modelID = new StreamID('model', randomCID())
+  const eventId = base16.encode(
+    EventID.createRandom('dev-unstable', 0, {
+      separatorKey: 'model',
+      separatorValue: modelID.toString(),
+    }).bytes,
+  )
+  return eventId
+}
+
+export function generateRandomEvent(eventId: string): any {
+  const carFactory = new CARFactory()
+  const car = carFactory.build().asV1()
+  car.put({ data: base64.encode(random.randomBytes(512)) }, { isRoot: true })
+  return {
+    eventId: eventId,
+    eventData: car.toString('base64'),
+  }
+}