omnivore/packages/api/test/routers/webhooks.test.ts

import { expect } from 'chai'
import 'mocha'
import nock from 'nock'
import { User } from '../../src/entity/user'
import { Webhook } from '../../src/entity/webhook'
import { deleteUser } from '../../src/services/user'
import { createWebhook } from '../../src/services/webhook'
import { createTestUser } from '../db'
import { request } from '../util'

describe('Webhooks Router', () => {
  const token = process.env.PUBSUB_VERIFICATION_TOKEN || ''
  const webhookBaseUrl = 'https://localhost:3000'
  const webhookPath = `/webhooks`

  let user: User
  let webhook: Webhook

  before(async () => {
    // create test user and login
    user = await createTestUser('fakeUser')
    await request
      .post('/local/debug/fake-user-login')
      .send({ fakeEmail: user.email })

    webhook = await createWebhook(
      {
        url: webhookBaseUrl + webhookPath,
        user: { id: user.id },
        eventTypes: ['PAGE_CREATED'],
      },
      user.id
    )
  })

  after(async () => {
    // clean up
    await deleteUser(user.id)
  })

  describe('trigger webhooks', () => {
    it('should trigger webhooks', async () => {
      const data = {
        message: {
          data: Buffer.from(
            JSON.stringify({ userId: user.id, type: 'page' })
          ).toString('base64'),
          publishTime: new Date().toISOString(),
        },
      }

      nock(webhookBaseUrl).post(webhookPath).reply(200)

      const res = await request
        .post('/svc/pubsub/webhooks/trigger/created?token=' + token)
        .send(data)
        .expect(200)
      expect(res.text).to.eql('OK')
    })
  })
})