Contents

require 'spec_helper'

describe GnipApi::PowerTrack::Stream do
  before do
    configure_gem
    @stream = GnipApi::PowerTrack::Stream.new
  end

  describe '#initialize' do
  end

  describe '#process_entries' do
    before do
      @json = File.read('spec/fixtures/activities/real_activity.json')
    end
    
    it 'bulds a Message object from the json' do
      message = @stream.process_entries([@json])
      expect(message.first.class).to eq(Gnip::Activity)
    end
    
    it 'returns empty array if could not parse json' do
      message = @stream.process_entries(['lol'])
      expect(message).to eq([])
    end
  end

  describe '#parse_json' do
    before do
      @json = File.read('spec/fixtures/activities/real_activity.json')
    end

    it 'does not throw error with activity json' do
      expect(Proc.new{@stream.parse_json(@json)}).not_to raise_error
    end

    it 'parses json' do
      parsed = @stream.parse_json @json
      expect(parsed.class).to eq(Hash)
    end

    it 'returns nil if empty json is passed' do
      parsed = @stream.parse_json('')
      expect(parsed).to eq(nil)
    end
    
    it 'returns nil if invalid json is passed' do
      parsed = @stream.parse_json('12,4.,x_VZxuv8{ak{f}}}}} {{ (d(s)aa(((aaaaa)aaa)')
      expect(parsed).to eq(nil)
    end
    
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
gnip_api-1.2.4	spec/gnip_api/power_track/stream_spec.rb
gnip_api-1.2.3	spec/gnip_api/power_track/stream_spec.rb
gnip_api-1.2.2	spec/gnip_api/power_track/stream_spec.rb
gnip_api-1.2.1	spec/gnip_api/power_track/stream_spec.rb
gnip_api-1.2.0	spec/gnip_api/power_track/stream_spec.rb