Replacement for @absinthe/socket-apollo-link package

absintheSocketLink.ts

// Use at your own risk! No support for mutations currently.

const createSocketLink = (socket: Socket) => {
  const channel = socket.channel('__absinthe__:control')
  channel.join().receive('error', () => console.error('Failed to join Absinthe channel!'))

  return new ApolloLink(operation => {
    return new Observable(observer => {
      const query = print(operation.query)
      const { variables } = operation

      channel
        .push('doc', { query, variables })
        .receive('ok', data => {
          if (!observer.closed) {
            observer.next(data)
            observer.complete()
          }
        })
        .receive('error', response => {
          const error = new Error('AbsintheError') as any

          if (Array.isArray(response.errors)) {
            error.message = response.errors.map((e: any) => e.message).join('; ')
          }

          error.response = response
          observer.error(error)
        })
    })
  })
}