Sutty/trabajo-afectivo
5
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Refactoring: Twitter webhook spec.

Browse source
This commit is contained in:
Ryan Lue 2018-12-18 11:40:56 +01:00 committed by Thorsten Eckel
parent 7326122e28
commit 2077fac218
7 changed files with 899 additions and 740 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
spec/factories/channel.rb
View file

@ -9,6 +9,10 @@ FactoryBot.define do
created_by_id 1
factory :twitter_channel do
transient do
custom_options { {} }
end
area 'Twitter::Account'
options do
{
@ -20,8 +24,8 @@ FactoryBot.define do
oauth_token_secret: 'secret',
},
user: {
screen_name: 'system_login',
id: 'system_id',
screen_name: 'system_login',
},
sync: {
import_older_tweets: true,
@ -29,21 +33,21 @@ FactoryBot.define do
search: [
{
term: 'zammad',
group_id: Group.first.id,
group_id: Group.first.id
},
{
term: 'hash_tag1',
group_id: Group.first.id,
},
group_id: Group.first.id
}
],
mentions: {
group_id: Group.first.id,
group_id: Group.first.id
},
direct_messages: {
group_id: Group.first.id,
}
group_id: Group.first.id
}
}
}.deep_merge(custom_options)
end
end
end

542
spec/requests/integration/twitter_webhook_spec.rb
View file

@ -1,282 +1,412 @@
require 'rails_helper'
RSpec.describe 'Integration Twitter Webhook', type: :request do
RSpec.describe 'Twitter Webhook Integration', type: :request do
let!(:external_credential) { create(:twitter_credential, credentials: credentials) }
let(:credentials) { { consumer_key: 'CCC', consumer_secret: 'DDD' } }
let(:agent_user) do
create(:agent_user)
describe '#webhook_verify (for Twitter to confirm Zammad’s credentials)' do
context 'with only cached credentials' do
let!(:external_credential) { nil }
before { Cache.write('external_credential_twitter', credentials) }
it 'returns an HMAC signature for cached credentials plus params[:crc_token]' do
get '/api/v1/channels_twitter_webhook',
params: { crc_token: 'some_random', nonce: 'some_nonce' },
headers: { 'x-twitter-webhooks-signature' => 'something' },
as: :json
expect(response).to have_http_status(200)
expect(json_response).to include('response_token' => 'sha256=VE19eUk6krbdSqWPdvH71xtFhApBAU81uPW3UT65vOs=')
end
end
before(:each) do
@external_credential = ExternalCredential.create!(
name: 'twitter',
credentials: {
consumer_key: 'CCC',
consumer_secret: 'DDD',
}
)
@channel = Channel.create!(
group_id: nil,
area: 'Twitter::Account',
options: {
adapter: 'twitter',
user: {
id: 123,
screen_name: 'zammadhq',
name: 'Zammad HQ',
},
context 'with only credentials stored in DB' do
it 'returns an HMAC signature for stored credentials plus params[:crc_token]' do
get '/api/v1/channels_twitter_webhook',
params: { crc_token: 'some_random', nonce: 'some_nonce' },
headers: { 'x-twitter-webhooks-signature' => 'something' },
as: :json
expect(response).to have_http_status(200)
expect(json_response).to include('response_token' => 'sha256=VE19eUk6krbdSqWPdvH71xtFhApBAU81uPW3UT65vOs=')
end
end
end
describe '#webhook_incoming' do
let!(:channel) do
create(
:twitter_channel,
custom_options: {
auth: {
external_credential_id: 1,
external_credential_id: external_credential.id,
oauth_token: 'AAA',
oauth_token_secret: 'BBB',
consumer_key: 'CCC',
consumer_secret: 'DDD',
},
user: {
id: 123,
name: 'Zammad HQ',
screen_name: 'zammadhq',
},
sync: {
limit: 20,
search: [{ term: '#zammad', group_id: Group.first.id.to_s }, { term: '#hello1234', group_id: Group.first.id.to_s }],
mentions: { group_id: Group.first.id.to_s },
direct_messages: { group_id: Group.first.id.to_s },
track_retweets: false
}
track_retweets: false,
search: [
{
term: '#zammad', group_id: Group.first.id.to_s
},
active: true,
updated_by_id: 1,
created_by_id: 1,
{
term: '#hello1234', group_id: Group.first.id.to_s
}
],
}
}
)
end
describe 'request verify' do
describe 'confirming authenticity of incoming Twitter webhook' do
context 'with valid headers & parameters' do
it 'returns 200 success' do
post '/api/v1/channels_twitter_webhook',
params: { for_user_id: channel.options[:user][:id], key: 'value' },
headers: { 'x-twitter-webhooks-signature' => 'sha256=JjEmBe1lVKT8XldrYUKibF+D5ehp8f0jDk3PXZSHEWI=' },
as: :json
it 'does at config check' do
Cache.write('external_credential_twitter', @external_credential.credentials)
@external_credential.destroy
params = {
crc_token: 'some_random',
nonce: 'some_nonce',
}
get '/api/v1/channels_twitter_webhook', params: params, headers: { 'x-twitter-webhooks-signature' => 'something' }, as: :json
expect(response).to have_http_status(200)
expect(json_response['response_token']).to eq('sha256=VE19eUk6krbdSqWPdvH71xtFhApBAU81uPW3UT65vOs=')
end
end
it 'does configured check' do
Cache.delete('external_credential_twitter')
params = {
crc_token: 'some_random',
nonce: 'some_nonce',
}
get '/api/v1/channels_twitter_webhook', params: params, headers: { 'x-twitter-webhooks-signature' => 'something' }, as: :json
expect(response).to have_http_status(200)
expect(json_response['response_token']).to eq('sha256=VE19eUk6krbdSqWPdvH71xtFhApBAU81uPW3UT65vOs=')
end
context 'when request is missing x-twitter-webhooks-signature header' do
it 'returns 422 with error message' do
post '/api/v1/channels_twitter_webhook', as: :json
end
describe 'request incoming - base' do
it 'does without x-twitter-webhooks-signature header check' do
params = {}
post '/api/v1/channels_twitter_webhook', params: params, as: :json
expect(response).to have_http_status(422)
expect(json_response['error']).to eq('Missing \'x-twitter-webhooks-signature\' header')
expect(json_response).to include('error' => "Missing 'x-twitter-webhooks-signature' header")
end
end
it 'does no external_credential check' do
@external_credential.destroy
params = {}
post '/api/v1/channels_twitter_webhook', params: params, headers: { 'x-twitter-webhooks-signature' => 'something' }, as: :json
context 'when Zammad has no Twitter credentials (in DB or cache)' do
let!(:external_credential) { nil }
let!(:channel) { nil }
it 'returns 422 with error message' do
post '/api/v1/channels_twitter_webhook',
headers: { 'x-twitter-webhooks-signature' => 'something' },
as: :json
expect(response).to have_http_status(422)
expect(json_response['error']).to eq('No such external_credential \'twitter\'!')
expect(json_response).to include('error' => "No such external_credential 'twitter'!")
end
end
it 'does invalid token check' do
params = {}
post '/api/v1/channels_twitter_webhook', params: params, headers: { 'x-twitter-webhooks-signature' => 'something' }, as: :json
context 'with invalid token in x-twitter-webhooks-signature header' do
it 'returns 401 with error message' do
post '/api/v1/channels_twitter_webhook',
headers: { 'x-twitter-webhooks-signature' => 'something' },
as: :json
expect(response).to have_http_status(401)
expect(json_response['error']).to eq('Not authorized')
expect(json_response).to include('error' => 'Not authorized')
end
end
it 'does existing for_user_id check' do
params = { key: 'value' }
post '/api/v1/channels_twitter_webhook', params: params, headers: { 'x-twitter-webhooks-signature' => 'sha256=EERHBy/k17v+SuT+K0OXuwhJtKnPtxi0n/Y4Wye4kVU=' }, as: :json
context 'with :for_user_id request parameter' do
it 'returns 422 with error message' do
post '/api/v1/channels_twitter_webhook',
params: { key: 'value' },
headers: { 'x-twitter-webhooks-signature' => 'sha256=EERHBy/k17v+SuT+K0OXuwhJtKnPtxi0n/Y4Wye4kVU=' },
as: :json
expect(response).to have_http_status(422)
expect(json_response['error']).to eq('Missing \'for_user_id\' in payload!')
expect(json_response).to include('error' => "Missing 'for_user_id' in payload!")
end
end
it 'does invalid user check' do
params = { for_user_id: 'not_existing', key: 'value' }
post '/api/v1/channels_twitter_webhook', params: params, headers: { 'x-twitter-webhooks-signature' => 'sha256=QaJiQl/4WRp/GF37b+eAdF6kPgptjDCLOgAIIbB1s0I=' }, as: :json
context 'with invalid :for_user_id request parameter' do
it 'returns 422 with error message' do
post '/api/v1/channels_twitter_webhook',
params: { for_user_id: 'not_existing', key: 'value' },
headers: { 'x-twitter-webhooks-signature' => 'sha256=QaJiQl/4WRp/GF37b+eAdF6kPgptjDCLOgAIIbB1s0I=' },
as: :json
expect(response).to have_http_status(422)
expect(json_response['error']).to eq('No such channel for user id \'not_existing\'!')
expect(json_response).to include('error' => "No such channel for user id 'not_existing'!")
end
end
end
it 'does valid token check' do
params = { for_user_id: 123, key: 'value' }
post '/api/v1/channels_twitter_webhook', params: params, headers: { 'x-twitter-webhooks-signature' => 'sha256=JjEmBe1lVKT8XldrYUKibF+D5ehp8f0jDk3PXZSHEWI=' }, as: :json
describe 'auto-creation of tickets/articles on webhook receipt' do
let(:webhook_payload) do
JSON.parse(File.read(Rails.root.join('test', 'data', 'twitter', payload_file))).symbolize_keys
end
context 'for outbound DMs' do
context 'not matching any admin-defined filters' do
let(:payload_file) { 'webhook1_direct_message.json' }
it 'returns 200' do
post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json
expect(response).to have_http_status(200)
end
it 'creates closed ticket' do
expect { post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json }
.to change { Ticket.count }.by(1)
expect(Ticket.last.attributes)
.to include(
'title' => 'Hey! Hello!',
'state_id' => Ticket::State.find_by(name: 'closed').id,
'priority_id' => Ticket::Priority.find_by(name: '2 normal').id,
'customer_id' => User.find_by(login: 'zammadhq', firstname: 'Zammad', lastname: 'Hq').id,
'created_by_id' => User.find_by(login: 'zammadhq', firstname: 'Zammad', lastname: 'Hq').id
)
end
describe 'request incoming direct message' do
it 'create new ticket via tweet' do
post '/api/v1/channels_twitter_webhook', params: read_messaage('webhook1_direct_message'), headers: { 'x-twitter-webhooks-signature' => 'sha256=xXu7qrPhqXfo8Ot14c0si9HrdQdBNru5fkSdoMZi+Ms=' }, as: :json
it 'creates first article on closed ticket' do
expect { post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json }
.to change { Ticket::Article.count }.by(1)
expect(Ticket::Article.last.attributes)
.to include(
'from' => '@zammadhq',
'to' => '@medenhofer',
'message_id' => '1062015437679050760',
'created_by_id' => User.find_by(login: 'zammadhq', firstname: 'Zammad', lastname: 'Hq').id
)
end
it 'does not add any attachments to newly created ticket' do
post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json
expect(Ticket::Article.last.attachments).to be_empty
end
end
end
context 'for inbound DMs' do
context 'matching admin-defined #hashtag filter, with a link to an image' do
let(:payload_file) { 'webhook2_direct_message.json' }
it 'returns 200' do
post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json
expect(response).to have_http_status(200)
article = Ticket::Article.find_by(message_id: '1062015437679050760')
expect(article).to be_present
expect(article.from).to eq('@zammadhq')
expect(article.to).to eq('@medenhofer')
expect(article.created_by.login).to eq('zammadhq')
expect(article.created_by.firstname).to eq('Zammad')
expect(article.created_by.lastname).to eq('Hq')
expect(article.attachments.count).to eq(0)
ticket = article.ticket
expect(ticket.title).to eq('Hey! Hello!')
expect(ticket.state.name).to eq('closed')
expect(ticket.priority.name).to eq('2 normal')
expect(ticket.customer.login).to eq('zammadhq')
expect(ticket.customer.firstname).to eq('Zammad')
expect(ticket.customer.lastname).to eq('Hq')
expect(ticket.created_by.login).to eq('zammadhq')
expect(ticket.created_by.firstname).to eq('Zammad')
expect(ticket.created_by.lastname).to eq('Hq')
post '/api/v1/channels_twitter_webhook', params: read_messaage('webhook2_direct_message'), headers: { 'x-twitter-webhooks-signature' => 'sha256=wYiCk7gfAgrnerCpj3XD58hozfVDjcQvcYPZCFH+stU=' }, as: :json
article = Ticket::Article.find_by(message_id: '1063077238797725700')
expect(article).to be_present
expect(article.to).to eq('@zammadhq')
expect(article.from).to eq('@medenhofer')
expect(article.body).to eq("Hello Zammad #zammad @znuny\n\nYeah! https://twitter.com/messages/media/1063077238797725700")
expect(article.created_by.login).to eq('medenhofer')
expect(article.created_by.firstname).to eq('Martin')
expect(article.created_by.lastname).to eq('Edenhofer')
expect(article.attachments.count).to eq(0)
ticket = article.ticket
expect(ticket.title).to eq('Hello Zammad #zammad @znuny Yeah! https://t.co/UfaCwi9cUb')
expect(ticket.state.name).to eq('new')
expect(ticket.priority.name).to eq('2 normal')
expect(ticket.customer.login).to eq('medenhofer')
expect(ticket.customer.firstname).to eq('Martin')
expect(ticket.customer.lastname).to eq('Edenhofer')
post '/api/v1/channels_twitter_webhook', params: read_messaage('webhook3_direct_message'), headers: { 'x-twitter-webhooks-signature' => 'sha256=OTguUdchBdxNal/csZsRkytKL5srrUuezZ3hp/2E404=' }, as: :json
article = Ticket::Article.find_by(message_id: '1063077238797725701')
expect(article).to be_present
expect(article.to).to eq('@zammadhq')
expect(article.from).to eq('@medenhofer')
expect(article.body).to eq('Hello again!')
expect(article.created_by.login).to eq('medenhofer')
expect(article.created_by.firstname).to eq('Martin')
expect(article.created_by.lastname).to eq('Edenhofer')
expect(article.ticket.id).to eq(ticket.id)
expect(article.attachments.count).to eq(0)
ticket = article.ticket
expect(ticket.title).to eq('Hello Zammad #zammad @znuny Yeah! https://t.co/UfaCwi9cUb')
expect(ticket.state.name).to eq('new')
expect(ticket.priority.name).to eq('2 normal')
expect(ticket.customer.login).to eq('medenhofer')
expect(ticket.customer.firstname).to eq('Martin')
expect(ticket.customer.lastname).to eq('Edenhofer')
end
it 'check duplicate' do
post '/api/v1/channels_twitter_webhook', params: read_messaage('webhook1_direct_message'), headers: { 'x-twitter-webhooks-signature' => 'sha256=xXu7qrPhqXfo8Ot14c0si9HrdQdBNru5fkSdoMZi+Ms=' }, as: :json
it 'creates new ticket' do
expect { post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json }
.to change { Ticket.count }.by(1)
expect(Ticket.last.attributes)
.to include(
'title' => 'Hello Zammad #zammad @znuny Yeah! https://t.co/UfaCwi9cUb',
'state_id' => Ticket::State.find_by(name: 'new').id,
'priority_id' => Ticket::Priority.find_by(name: '2 normal').id,
'customer_id' => User.find_by(login: 'medenhofer', firstname: 'Martin', lastname: 'Edenhofer').id,
)
end
it 'creates first article on new ticket' do
expect { post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json }
.to change { Ticket::Article.count }.by(1)
expect(Ticket::Article.last.attributes)
.to include(
'to' => '@zammadhq',
'from' => '@medenhofer',
'body' => "Hello Zammad #zammad @znuny\n\nYeah! https://twitter.com/messages/media/1063077238797725700",
'message_id' => '1063077238797725700',
'created_by_id' => User.find_by(login: 'medenhofer', firstname: 'Martin', lastname: 'Edenhofer').id
)
end
it 'does not add linked image as attachment to newly created ticket' do
post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json
expect(Ticket::Article.last.attachments).to be_empty
end
end
context 'from same sender as previously imported DMs' do
let(:payload_file) { 'webhook3_direct_message.json' }
before { post '/api/v1/channels_twitter_webhook', **previous_webhook_payload, as: :json }
let(:previous_webhook_payload) do
JSON.parse(File.read(Rails.root.join('test', 'data', 'twitter', 'webhook2_direct_message.json'))).symbolize_keys
end
it 'returns 200' do
post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json
expect(response).to have_http_status(200)
end
post '/api/v1/channels_twitter_webhook', params: read_messaage('webhook1_direct_message'), headers: { 'x-twitter-webhooks-signature' => 'sha256=xXu7qrPhqXfo8Ot14c0si9HrdQdBNru5fkSdoMZi+Ms=' }, as: :json
it 'does not create new ticket' do
expect { post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json }
.not_to change { Ticket.count }
end
it 'adds new article to existing, open ticket' do
expect { post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json }
.to change { Ticket::Article.count }.by(1)
expect(Ticket::Article.last.attributes)
.to include(
'to' => '@zammadhq',
'from' => '@medenhofer',
'body' => 'Hello again!',
'message_id' => '1063077238797725701',
'created_by_id' => User.find_by(login: 'medenhofer', firstname: 'Martin', lastname: 'Edenhofer').id,
'ticket_id' => Ticket.find_by(title: 'Hello Zammad #zammad @znuny Yeah! https://t.co/UfaCwi9cUb').id
)
end
it 'does not add any attachments to newly created ticket' do
post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json
expect(Ticket::Article.last.attachments).to be_empty
end
end
end
context 'when receiving duplicate DMs' do
let(:payload_file) { 'webhook1_direct_message.json' }
it 'still returns 200' do
2.times { post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json }
expect(response).to have_http_status(200)
end
expect(Ticket::Article.where(message_id: '1062015437679050760').count).to eq(1)
it 'does not create duplicate articles' do
expect do
2.times { post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json }
end.to change { Ticket::Article.count }.by(1)
end
end
describe 'request incoming direct message' do
it 'create new ticket via tweet' do
context 'for tweets' do
context 'matching admin-defined #hashtag filter, with an image link' do
let(:payload_file) { 'webhook1_tweet.json' }
before do
stub_request(:get, 'http://pbs.twimg.com/profile_images/785412960797745152/wxdIvejo_bigger.jpg')
.to_return(status: 200, body: 'some_content')
stub_request(:get, 'https://pbs.twimg.com/media/DsFKfJRWkAAFEbo.jpg')
.to_return(status: 200, body: 'some_content')
post '/api/v1/channels_twitter_webhook', params: read_messaage('webhook1_tweet'), headers: { 'x-twitter-webhooks-signature' => 'sha256=DmARpz6wdgte6Vj+ePeqC+RHvEDokmwOIIqr4//utkk=' }, as: :json
expect(response).to have_http_status(200)
article = Ticket::Article.find_by(message_id: '1063212927510081536')
expect(article).to be_present
expect(article.from).to eq('@zammadhq')
expect(article.to).to eq('@medenhofer')
expect(article.body).to eq('Hey @medenhofer ! #hello1234 https://twitter.com/zammadhq/status/1063212927510081536/photo/1')
expect(article.created_by.login).to eq('zammadhq')
expect(article.created_by.firstname).to eq('Zammad')
expect(article.created_by.lastname).to eq('Hq')
expect(article.attachments.count).to eq(1)
expect(article.attachments[0].filename).to eq('DsFKfJRWkAAFEbo.jpg')
ticket = article.ticket
expect(ticket.title).to eq('Hey @medenhofer ! #hello1234 https://t.co/f1kffFlwpN')
expect(ticket.state.name).to eq('closed')
expect(ticket.priority.name).to eq('2 normal')
expect(ticket.customer.login).to eq('zammadhq')
expect(ticket.customer.firstname).to eq('Zammad')
expect(ticket.customer.lastname).to eq('Hq')
expect(ticket.created_by.login).to eq('zammadhq')
expect(ticket.created_by.firstname).to eq('Zammad')
expect(ticket.created_by.lastname).to eq('Hq')
end
it 'create new ticket via tweet extended_tweet' do
it 'returns 200' do
post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json
expect(response).to have_http_status(200)
end
it 'creates a closed ticket' do
expect { post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json }
.to change { Ticket.count }.by(1)
expect(Ticket.last.attributes)
.to include(
'title' => 'Hey @medenhofer ! #hello1234 https://t.co/f1kffFlwpN',
'state_id' => Ticket::State.find_by(name: 'closed').id,
'priority_id' => Ticket::Priority.find_by(name: '2 normal').id,
'customer_id' => User.find_by(login: 'zammadhq', firstname: 'Zammad', lastname: 'Hq').id,
'created_by_id' => User.find_by(login: 'zammadhq', firstname: 'Zammad', lastname: 'Hq').id,
)
end
it 'creates first article on closed ticket' do
expect { post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json }
.to change { Ticket::Article.count }.by(1)
expect(Ticket::Article.last.attributes)
.to include(
'from' => '@zammadhq',
'to' => '@medenhofer',
'body' => 'Hey @medenhofer ! #hello1234 https://twitter.com/zammadhq/status/1063212927510081536/photo/1',
'message_id' => '1063212927510081536',
'created_by_id' => User.find_by(login: 'zammadhq', firstname: 'Zammad', lastname: 'Hq').id
)
end
it 'add linked image as attachment to newly created article' do
expect(Ticket::Article.last.attachments)
.to match_array(Store.where(filename: 'DsFKfJRWkAAFEbo.jpg'))
end
end
context 'longer than 140 characters (with no media links)' do
let(:payload_file) { 'webhook2_tweet.json' }
before do
stub_request(:get, 'http://pbs.twimg.com/profile_images/794220000450150401/D-eFg44R_bigger.jpg')
.to_return(status: 200, body: 'some_content')
end
post '/api/v1/channels_twitter_webhook', params: read_messaage('webhook2_tweet'), headers: { 'x-twitter-webhooks-signature' => 'sha256=U7bglX19JitI2xuvyONAc0d/fowIFEeUzkEgnWdGyUM=' }, as: :json
it 'returns 200' do
post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json
expect(response).to have_http_status(200)
article = Ticket::Article.find_by(message_id: '1065035365336141825')
expect(article).to be_present
expect(article.from).to eq('@medenhofer')
expect(article.to).to eq('@znuny')
expect(article.body).to eq('@znuny Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt ut labore et dolore magna aliquyam erat, sed diam voluptua. At vero eos et accusam et justo duo dolores et ea rebum. Stet clita kasd gubergren, no sea takimata sanctus est Lore')
expect(article.created_by.login).to eq('medenhofer')
expect(article.created_by.firstname).to eq('Martin')
expect(article.created_by.lastname).to eq('Edenhofer')
expect(article.attachments.count).to eq(0)
ticket = article.ticket
expect(ticket.title).to eq('@znuny Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy ...')
expect(ticket.state.name).to eq('new')
expect(ticket.priority.name).to eq('2 normal')
expect(ticket.customer.login).to eq('medenhofer')
expect(ticket.customer.firstname).to eq('Martin')
expect(ticket.customer.lastname).to eq('Edenhofer')
expect(ticket.created_by.login).to eq('medenhofer')
expect(ticket.created_by.firstname).to eq('Martin')
expect(ticket.created_by.lastname).to eq('Edenhofer')
end
it 'check duplicate' do
post '/api/v1/channels_twitter_webhook', params: read_messaage('webhook1_tweet'), headers: { 'x-twitter-webhooks-signature' => 'sha256=DmARpz6wdgte6Vj+ePeqC+RHvEDokmwOIIqr4//utkk=' }, as: :json
it 'creates a new ticket' do
expect { post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json }
.to change { Ticket.count }.by(1)
expect(Ticket.last.attributes)
.to include(
'title' => '@znuny Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy ...',
'state_id' => Ticket::State.find_by(name: 'new').id,
'priority_id' => Ticket::Priority.find_by(name: '2 normal').id,
'customer_id' => User.find_by(login: 'medenhofer', firstname: 'Martin', lastname: 'Edenhofer').id,
'created_by_id' => User.find_by(login: 'medenhofer', firstname: 'Martin', lastname: 'Edenhofer').id,
)
end
it 'creates first article on new ticket' do
expect { post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json }
.to change { Ticket::Article.count }.by(1)
expect(Ticket::Article.last.attributes)
.to include(
'from' => '@medenhofer',
'to' => '@znuny',
'body' => '@znuny Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt ut labore et dolore magna aliquyam erat, sed diam voluptua. At vero eos et accusam et justo duo dolores et ea rebum. Stet clita kasd gubergren, no sea takimata sanctus est Lore',
'created_by_id' => User.find_by(login: 'medenhofer', firstname: 'Martin', lastname: 'Edenhofer').id,
'message_id' => '1065035365336141825'
)
end
it 'does not add any attachments to newly created ticket' do
post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json
expect(Ticket::Article.last.attachments).to be_empty
end
end
context 'when receiving duplicate messages' do
let(:payload_file) { 'webhook1_tweet.json' }
it 'still returns 200' do
2.times { post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json }
expect(response).to have_http_status(200)
post '/api/v1/channels_twitter_webhook', params: read_messaage('webhook1_tweet'), headers: { 'x-twitter-webhooks-signature' => 'sha256=DmARpz6wdgte6Vj+ePeqC+RHvEDokmwOIIqr4//utkk=' }, as: :json
expect(response).to have_http_status(200)
expect(Ticket::Article.where(message_id: '1063212927510081536').count).to eq(1)
end
end
def read_messaage(file)
JSON.parse(File.read(Rails.root.join('test', 'data', 'twitter', "#{file}.json")))
it 'does not create duplicate articles' do
expect do
2.times { post '/api/v1/channels_twitter_webhook', **webhook_payload, as: :json }
end.to change { Ticket::Article.count }.by(1)
end
end
end
end
end
end

5
test/data/twitter/webhook1_direct_message.json
View file

@ -1,4 +1,8 @@
{
"headers" : {
"x-twitter-webhooks-signature" : "sha256=xXu7qrPhqXfo8Ot14c0si9HrdQdBNru5fkSdoMZi+Ms="
},
"params" : {
"for_user_id": "123",
"direct_message_events": [
{
@ -63,3 +67,4 @@
}
}
}
}

5
test/data/twitter/webhook1_tweet.json
View file

@ -1,4 +1,8 @@
{
"headers": {
"x-twitter-webhooks-signature": "sha256=DmARpz6wdgte6Vj+ePeqC+RHvEDokmwOIIqr4//utkk="
},
"params": {
"for_user_id": "123",
"tweet_create_events": [
{
@ -160,3 +164,4 @@
}
]
}
}

5
test/data/twitter/webhook2_direct_message.json
View file

@ -1,4 +1,8 @@
{
"headers" : {
"x-twitter-webhooks-signature" : "sha256=wYiCk7gfAgrnerCpj3XD58hozfVDjcQvcYPZCFH+stU="
},
"params": {
"for_user_id": "123",
"direct_message_events": [
{
@ -111,3 +115,4 @@
}
}
}
}

5
test/data/twitter/webhook2_tweet.json
View file

@ -1,4 +1,8 @@
{
"headers": {
"x-twitter-webhooks-signature": "sha256=U7bglX19JitI2xuvyONAc0d/fowIFEeUzkEgnWdGyUM="
},
"params": {
"for_user_id": "123",
"tweet_create_events": [
{
@ -108,3 +112,4 @@
}
]
}
}

5
test/data/twitter/webhook3_direct_message.json
View file

@ -1,4 +1,8 @@
{
"headers" : {
"x-twitter-webhooks-signature" : "sha256=OTguUdchBdxNal/csZsRkytKL5srrUuezZ3hp/2E404="
},
"params" : {
"for_user_id": "123",
"direct_message_events": [
{
@ -55,3 +59,4 @@
}
}
}
}