require "spec_helper"
require "securerandom"

describe "REST" do
  let(:client) do
    Ably::Rest::Client.new(api_key: api_key, environment: environment)
  end

  describe "publishing messages" do
    let(:channel) { client.channel("test") }
    let(:event)   { "foo" }
    let(:message) { "woop!" }

    it "should publish the message ok" do
      expect(channel.publish(event, message)).to eql(true)
    end
  end

  describe "fetching channel history" do
    let(:channel) { client.channel("persisted:#{SecureRandom.hex(4)}") }
    let(:expected_history) do
      [
        { :name => "test1", :data => "foo" },
        { :name => "test2", :data => "bar" },
        { :name => "test3", :data => "baz" }
      ]
    end

    before(:each) do
      expected_history.each do |message|
        channel.publish(message[:name], message[:data]) || raise("Unable to publish message")
      end
    end

    it "should return all the history for the channel" do
      actual_history = channel.history

      expect(actual_history.size).to eql(3)

      expected_history.each do |message|
        expect(actual_history).to include(message)
      end
    end

    it "should return paged history" do
      page_1 = channel.history(limit: 1)
      page_2 = page_1.next
      page_3 = page_2.next

      all_items = [page_1[0], page_2[0], page_3[0]]
      expect(all_items.uniq).to eql(all_items)

      expect(page_1.size).to eql(1)
      expect(page_1).to_not be_last
      expect(page_1).to be_first

      # Page 2
      expect(page_2.size).to eql(1)
      expect(page_2).to_not be_last
      expect(page_2).to_not be_first

      # Page 3
      expect(page_3.size).to eql(1)
      expect(page_3).to be_last
      expect(page_3).to_not be_first
    end
  end
end