zammad/test/unit/twitter_test.rb

# encoding: utf-8
require 'test_helper'

class TwitterTest < ActiveSupport::TestCase

  # app config
  consumer_key    = 'd2zoZBmMXmT7KLPgEHSzpw'
  consumer_secret = 'QMUrlyDlqjITCkWdrOgsTxMVVLxr4A4IW3DIgtIg'

  # user1: armin_theo (is system and is following marion_bauer)
  user1_token        = '1405469528-WQ6XHizgrbYasUwjp0I0TUONhftNkrfrpgFLrdc'
  user1_token_secret = '0LHChGFlQx9jSxM8tkBsuDOMhbJMSXTL2zKJJO5Xk'

  # user2: me_bauer (is following armin_theo)
  user2_token        = '1406098795-XQTjg1Zj5uVW0C11NNpNA4xopyclRJJoriWis0I'
  user2_token_secret = 'T8ph5afeSDjGDA9X1ZBlzEvoSiXfN266ZZUMj5UaY'

  # add channel
  current = Channel.where( :adapter => 'Twitter2' )
  current.each {|r|
    r.destroy
  }
  Channel.create(
    :adapter => 'Twitter2',
    :area    => 'Twitter::Inbound',
    :options => {
      :consumer_key       => consumer_key,
      :consumer_secret    => consumer_secret,
      :oauth_token        => user1_token,
      :oauth_token_secret => user1_token_secret,
      :search             => [
        {
          :item  => '#citheo42',
          :group => 'Twitter',
        },
        {
          :item  => '#citheo24',
          :group => 'Users',
        },
      ],
      :mentions => {
        :group => 'Twitter',
      },
      :direct_messages => {
        :group => 'Twitter',
      }
    },
    :active         => true,
    :created_by_id  => 1,
    :updated_by_id  => 1,
  )

  test 'new outbound and reply' do

    user  = User.find(2)
    group = Group.where( :name => 'Twitter' ).first
    state = Ticket::State.where( :name => 'new' ).first
    priority = Ticket::Priority.where( :name => '2 normal' ).first
    hash  = '#citheo42' + rand(9999).to_s
    text  = 'Today the weather is really nice... ' + hash
    ticket = Ticket.create(
      :group_id       => group.id,
      :customer_id    => user.id,
      :title          => text[0,40],
      :state_id       => state.id,
      :priority_id    => priority.id,
      :updated_by_id  => 1,
      :created_by_id  => 1,
    )
    assert( ticket, "outbound ticket created" )
    article = Ticket::Article.create(
      :ticket_id      => ticket.id,
      :type_id        => Ticket::Article::Type.where( :name => 'twitter status' ).first.id,
      :sender_id      => Ticket::Article::Sender.where( :name => 'Agent' ).first.id,
      :body           => text,
#      :from          => sender.name,
#      :to            => to,
#      :message_id    => tweet.id,
      :internal       => false,
      :updated_by_id  => 1,
      :created_by_id  => 1,
    )
    assert( article, "outbound article created" )
    assert_equal( article.ticket.articles.count, 1 )
    sleep 10

    # reply by me_bauer
    client = Twitter::REST::Client.new do |config|
      config.consumer_key        = consumer_key
      config.consumer_secret     = consumer_secret
      config.access_token        = user2_token
      config.access_token_secret = user2_token_secret
    end
    client.search(hash, :count => 50, :result_type => "recent").collect do |tweet|
      assert_equal( tweet.id, article.message_id )
    end

    reply_hash = '#weather' + rand(9999).to_s
    reply_text = '@armin_theo on my side the weather is also nice! 😍😍😍 ' + reply_hash
    tweet = client.update(
      reply_text,
      {
        :in_reply_to_status_id => article.message_id
      }
    )

    sleep 10

    # fetch check system account
    Channel.fetch

    # check if follow up article has been created
    assert_equal( article.ticket.articles.count, 2 )
    reply_article = article.ticket.articles.last
    assert_equal( reply_article.body, reply_text.utf8_to_3bytesutf8 )

  end

  test 'new by direct message inbound' do
    # cleanup direct messages of system
    client = Twitter::REST::Client.new do |config|
      config.consumer_key        = consumer_key
      config.consumer_secret     = consumer_secret
      config.access_token        = user1_token
      config.access_token_secret = user1_token_secret
    end
    dms = client.direct_messages( :count => 200 )
    dms.each {|dm|
      client.destroy_direct_message(dm.id)
    }

    # direct message to @armin_theo
    client = Twitter::REST::Client.new(
      :consumer_key         => consumer_key,
      :consumer_secret      => consumer_secret,
      :access_token         => user2_token,
      :access_token_secret  => user2_token_secret
    )
    dms = client.direct_messages( :count => 200 )
    dms.each {|dm|
      client.destroy_direct_message(dm.id)
    }
    sleep 10

    hash  = '#citheo44' + rand(9999).to_s
    text  = 'How about the details? ' + hash
    dm = client.create_direct_message(
      'armin_theo',
      text,
    )
    assert( dm, "dm with ##{hash} created" )

    # fetch check system account
    article = nil
    (1..4).each {|loop|
      next if article
      sleep 25

      Channel.fetch

      # check if ticket and article has been created
      article = Ticket::Article.where( :message_id => dm.id ).last
    }
    puts "----------------------------------------"
    puts "DM: " + dm.inspect
    puts "AT: " + article.inspect
    puts "----------------------------------------"

    assert( article, "inbound article created" )
#    ticket  = Ticket.find( article.ticket.id )
    ticket  = article.ticket
    assert( ticket, "ticket of inbound article exists" )
    assert( ticket.articles, "ticket.articles exists" )
    article_count = ticket.articles.count
    assert( article_count )
#    assert_equal( ticket.state.name, 'new' )

    # reply via ticket
    outbound_article = Ticket::Article.create(
      :ticket_id      => ticket.id,
      :type_id        => Ticket::Article::Type.where( :name => 'twitter direct-message' ).first.id,
      :sender_id      => Ticket::Article::Sender.where( :name => 'Agent' ).first.id,
      :body           => text,
#      :from           => sender.name,
      :to             => 'me_bauer',
      :internal       => false,
      :updated_by_id  => 1,
      :created_by_id  => 1,
    )
    assert( outbound_article, "outbound article created" )
    assert_equal( outbound_article.ticket.articles.count, article_count + 1 )
    sleep 10

  end
end