const grpc = require('@grpc/grpc-js')
const loader = require('@grpc/proto-loader')
const definition = loader.loadSync(`${__dirname}/test.proto`)
const TestService = grpc.loadPackageDefinition(definition).test.TestService

const server = new grpc.Server()

server.bindAsync('0.0.0.0:9090', grpc.ServerCredentials.createInsecure(), () => {
  server.addService(TestService.service, {
    ping: stream => {
      // Before 1.10.0 you get prefinish -> finish -> close -> cancelled
      // After 1.10.0 you get prefinish -> cancelled -> finish -> close
      stream.on('prefinish', () => console.log('prefinish'))
      stream.on('cancelled', () => console.log('cancelled'))
      stream.on('finish', () => console.log('finish'))
      stream.on('close', () => console.log('close'))

      stream.end()

      setTimeout(() => server.forceShutdown())
    }
  })

  server.start()

  const client = new TestService(`localhost:9090`, grpc.credentials.createInsecure())

  client.ping({}, () => {})
})