{module, test} = QUnit
{consumerTest} = ActionCable.TestHelpers

module "ActionCable.Subscription", ->
  consumerTest "#initialized callback", ({server, consumer, assert, done}) ->
    consumer.subscriptions.create "chat",
      initialized: ->
        assert.ok true
        done()

  consumerTest "#connected callback", ({server, consumer, assert, done}) ->
    subscription = consumer.subscriptions.create "chat",
      connected: ->
        assert.ok true
        done()

    server.broadcastTo(subscription, message_type: "confirmation")

  consumerTest "#disconnected callback", ({server, consumer, assert, done}) ->
    subscription = consumer.subscriptions.create "chat",
      disconnected: ->
        assert.ok true
        done()

    server.broadcastTo subscription, message_type: "confirmation", ->
      server.close()

  consumerTest "#perform", ({consumer, server, assert, done}) ->
    subscription = consumer.subscriptions.create "chat",
      connected: ->
        @perform(publish: "hi")

    server.on "message", (message) ->
      data = JSON.parse(message)
      assert.equal data.identifier, subscription.identifier
      assert.equal data.command, "message"
      assert.deepEqual data.data, JSON.stringify(action: { publish: "hi" })
      done()

    server.broadcastTo(subscription, message_type: "confirmation")