zammad/spec/models/channel_spec.rb

require 'rails_helper'

RSpec.describe Channel do
  describe '#fetch', use_vcr: :with_oauth_headers do
    context 'for Twitter driver' do
      context 'with valid token' do
        subject(:twitter_channel) { create(:twitter_channel) }

        # travel back in time when VCR was recorded
        before { travel_to '2020-02-06 13:37 +0100' }

        it 'returns true' do
          expect(twitter_channel.fetch(true)).to be(true)
        end

        it 'sets successful status attributes' do
          expect { twitter_channel.fetch(true) }
            .to change { twitter_channel.reload.attributes }
            .to hash_including(
              'status_in'    => 'ok',
              'last_log_in'  => '',
              'status_out'   => nil,
              'last_log_out' => nil
            )
        end

        it 'adds tickets based on config parameters (mention/DM/search)' do
          expect { twitter_channel.fetch(true) }
            .to change(Ticket, :count).by(21)

          expect(Ticket.last.attributes).to include(
            'title'       => 'RT @BarackObama: Kobe was a legend on the court and just getting started in what...',
            'preferences' => { 'channel_id'          => twitter_channel.id,
                               'channel_screen_name' => twitter_channel.options[:user][:screen_name] },
            'customer_id' => User.find_by(firstname: 'Zammad', lastname: 'Ali').id
          )
        end

        context 'and legacy "import_older_tweets" option' do
          subject(:twitter_channel) { create(:twitter_channel, :legacy) }

          it 'adds tickets based on config parameters (mention/DM/search)' do
            expect { twitter_channel.fetch(true) }
              .to change(Ticket, :count).by(26)

            expect(Ticket.last.attributes).to include(
              'title'       => 'Wir haben unsere DMs deaktiviert. ' \
                               'Leider können wir dank der neuen Twitter API k...',
              'preferences' => { 'channel_id'          => twitter_channel.id,
                                 'channel_screen_name' => twitter_channel.options[:user][:screen_name] },
              'customer_id' => User.find_by(firstname: 'Ccc', lastname: 'Event Logistics').id
            )
          end
        end
      end

      context 'with invalid token' do
        subject(:twitter_channel) { create(:twitter_channel, :invalid) }

        it 'returns false' do
          expect(twitter_channel.fetch(true)).to be(false)
        end

        it 'sets error/nil status attributes' do
          expect { twitter_channel.fetch(true) }
            .to change { twitter_channel.reload.attributes }
            .to hash_including(
              'status_in'    => 'error',
              'last_log_in'  => "Can't use Channel::Driver::Twitter: " \
                                '#<Twitter::Error::Unauthorized: Invalid or expired token.>',
              'status_out'   => nil,
              'last_log_out' => nil
            )
        end
      end
    end
  end
end