pubnub.spec.js

/* eslint-env jest */
import waitFor from 'wait-for-async'

import RingCentral from '../src/ringcentral'
import PubNub from '../src/pubnub'

jest.setTimeout(128000)

const rc = new RingCentral(process.env.RINGCENTRAL_CLIENT_ID, process.env.RINGCENTRAL_CLIENT_SECRET, process.env.RINGCENTRAL_SERVER_URL)

describe('pubnub', () => {
  test('SMS notification', async () => {
    await rc.authorize({
      username: process.env.RINGCENTRAL_USERNAME,
      extension: process.env.RINGCENTRAL_EXTENSION,
      password: process.env.RINGCENTRAL_PASSWORD
    })
    let count = 0
    const pubnub = new PubNub(rc, ['/restapi/v1.0/account/~/extension/~/message-store'], message => {
      count += 1
    })
    await pubnub.subscribe()
    await waitFor({ interval: 3000 })
    await rc.post('/restapi/v1.0/account/~/extension/~/sms', {
      to: [{ phoneNumber: process.env.RINGCENTRAL_RECEIVER }],
      from: { phoneNumber: process.env.RINGCENTRAL_USERNAME },
      text: 'Hello world'
    })
    await waitFor({ interval: 3000, times: 10, condition: () => count >= 1 })
    await pubnub.revoke()
    expect(count >= 1).toBe(true)
    await rc.revoke()
  })

  test('Glip post notification', async () => {
    await rc.authorize({
      username: process.env.RINGCENTRAL_USERNAME,
      extension: process.env.RINGCENTRAL_EXTENSION,
      password: process.env.RINGCENTRAL_PASSWORD
    })
    let count = 0
    const pubnub = new PubNub(rc, ['/restapi/v1.0/glip/posts'], message => {
      count += 1
    })
    await pubnub.subscribe()
    await waitFor({ interval: 3000 })
    const r = await rc.get('/restapi/v1.0/glip/groups')
    const groupId = r.data.records[0].id
    await rc.post(`/restapi/v1.0/glip/groups/${groupId}/posts`, {
      text: 'Hello world'
    })
    await waitFor({ interval: 3000, times: 10, condition: () => count >= 1 })
    await pubnub.revoke()
    expect(count >= 1).toBe(true)
    await rc.revoke()
  })
})