105 lines
4.0 KiB
Ruby
105 lines
4.0 KiB
Ruby
require 'rails_helper'
|
|
|
|
describe Jobs::EmitWebHookEvent do
|
|
let(:post_hook) { Fabricate(:web_hook) }
|
|
let(:inactive_hook) { Fabricate(:inactive_web_hook) }
|
|
let(:post) { Fabricate(:post) }
|
|
let(:user) { Fabricate(:user) }
|
|
|
|
it 'raises an error when there is no web hook record' do
|
|
expect { subject.execute(event_type: 'post') }.to raise_error(Discourse::InvalidParameters)
|
|
end
|
|
|
|
it 'raises an error when there is no event type' do
|
|
expect { subject.execute(web_hook_id: 1) }.to raise_error(Discourse::InvalidParameters)
|
|
end
|
|
|
|
it "doesn't emit when the hook is inactive" do
|
|
Jobs::EmitWebHookEvent.any_instance.expects(:web_hook_request).never
|
|
subject.execute(web_hook_id: inactive_hook.id, event_type: 'post', post_id: post.id)
|
|
end
|
|
|
|
it 'emits normally with sufficient arguments' do
|
|
Jobs::EmitWebHookEvent.any_instance.expects(:web_hook_request).once
|
|
subject.execute(web_hook_id: post_hook.id, event_type: 'post', post_id: post.id)
|
|
end
|
|
|
|
context 'with category filters' do
|
|
let(:category) { Fabricate(:category) }
|
|
let(:topic) { Fabricate(:topic) }
|
|
let(:topic_with_category) { Fabricate(:topic, category_id: category.id) }
|
|
let(:topic_hook) { Fabricate(:topic_web_hook, categories: [category]) }
|
|
|
|
it "doesn't emit when event is not related with defined categories" do
|
|
Jobs::EmitWebHookEvent.any_instance.expects(:web_hook_request).never
|
|
|
|
subject.execute(web_hook_id: topic_hook.id,
|
|
event_type: 'topic',
|
|
topic_id: topic.id,
|
|
user_id: user.id,
|
|
category_id: topic.category.id)
|
|
end
|
|
|
|
it 'emit when event is related with defined categories' do
|
|
Jobs::EmitWebHookEvent.any_instance.expects(:web_hook_request).once
|
|
|
|
subject.execute(web_hook_id: topic_hook.id,
|
|
event_type: 'topic',
|
|
topic_id: topic_with_category.id,
|
|
user_id: user.id,
|
|
category_id: topic_with_category.category.id)
|
|
end
|
|
end
|
|
|
|
describe '.web_hook_request' do
|
|
it 'creates delivery event record' do
|
|
stub_request(:post, "https://meta.discourse.org/webhook_listener")
|
|
.to_return(body: 'OK', status: 200)
|
|
|
|
WebHookEventType.all.pluck(:name).each do |name|
|
|
web_hook_id = Fabricate("#{name}_web_hook").id
|
|
object_id = Fabricate(name).id
|
|
|
|
expect do
|
|
subject.execute(web_hook_id: web_hook_id, event_type: name, "#{name}_id": object_id)
|
|
end.to change(WebHookEvent, :count).by(1)
|
|
end
|
|
end
|
|
|
|
it 'skips silently on missing post' do
|
|
expect do
|
|
subject.execute(web_hook_id: post_hook.id, event_type: 'post', post_id: (Post.maximum(:id).to_i + 1))
|
|
end.not_to raise_error
|
|
end
|
|
|
|
it 'should not skip trashed post' do
|
|
stub_request(:post, "https://meta.discourse.org/webhook_listener")
|
|
.to_return(body: 'OK', status: 200)
|
|
|
|
expect do
|
|
post.trash!
|
|
subject.execute(web_hook_id: post_hook.id, event_type: 'post', post_id: post.id)
|
|
end.to change(WebHookEvent, :count).by(1)
|
|
end
|
|
|
|
it 'sets up proper request headers' do
|
|
stub_request(:post, "https://meta.discourse.org/webhook_listener")
|
|
.to_return(headers: { test: 'string' }, body: 'OK', status: 200)
|
|
|
|
subject.execute(web_hook_id: post_hook.id, event_type: 'ping', event_name: 'ping')
|
|
event = WebHookEvent.last
|
|
headers = MultiJson.load(event.headers)
|
|
expect(headers['Content-Length']).to eq(13)
|
|
expect(headers['Host']).to eq("meta.discourse.org")
|
|
expect(headers['X-Discourse-Event-Id']).to eq(event.id)
|
|
expect(headers['X-Discourse-Event-Type']).to eq('ping')
|
|
expect(headers['X-Discourse-Event']).to eq('ping')
|
|
expect(headers['X-Discourse-Event-Signature']).to eq('sha256=162f107f6b5022353274eb1a7197885cfd35744d8d08e5bcea025d309386b7d6')
|
|
expect(event.payload).to eq(MultiJson.dump(ping: 'OK'))
|
|
expect(event.status).to eq(200)
|
|
expect(MultiJson.load(event.response_headers)['Test']).to eq('string')
|
|
expect(event.response_body).to eq('OK')
|
|
end
|
|
end
|
|
end
|