joystream/query-node/index-builder/test/integration/query-node.test.ts

import { expect } from 'chai'
import Container from 'typedi'
import { QueryNode, QueryNodeState } from '../../src'
import { sleep } from '../../src/utils/wait-for'

describe('QueryNode', () => {
  before(async () => {
    await QueryNode.create({
      wsProviderURI: process.env.WS_PROVIDER_URI || '',
      redisURI: process.env.REDIS_URI,
    })
  })

  it('Should initialize the indexer', async () => {
    const node = Container.get<QueryNode>('QueryNode')

    expect(node.api, 'Api should be initialized').to.not.be.undefined
    expect(node.indexBuilder, 'IndexBuilder should be initialized').to.not.be
      .undefined

    await Promise.race([node.start(), sleep(100)])

    expect(node.state).to.be.eq(QueryNodeState.STARTED, 'Should be started')

    await node.stop()

    expect(node.state).to.be.eq(QueryNodeState.STOPPED, 'Should be stopped')
  })
})