- 
+
-
-
diff --git a/test/controllers/graphql_controller_10_test.rb b/test/controllers/graphql_controller_10_test.rb
index 0193d1efb8..4d256a7024 100644
--- a/test/controllers/graphql_controller_10_test.rb
+++ b/test/controllers/graphql_controller_10_test.rb
@@ -15,7 +15,6 @@ def setup
Team.current = nil
end
-
test "should uninstall bot using mutation" do
t = create_team slug: 'test'
u = create_user
diff --git a/test/controllers/graphql_controller_11_test.rb b/test/controllers/graphql_controller_11_test.rb
new file mode 100644
index 0000000000..890f7e3d2f
--- /dev/null
+++ b/test/controllers/graphql_controller_11_test.rb
@@ -0,0 +1,60 @@
+require_relative '../test_helper'
+require 'error_codes'
+require 'sidekiq/testing'
+
+class GraphqlController11Test < ActionController::TestCase
+ def setup
+ @controller = Api::V1::GraphqlController.new
+ TestDynamicAnnotationTables.load!
+ end
+
+ def teardown
+ end
+
+ test "should set Smooch user Slack channel URL in background" do
+ Sidekiq::Worker.clear_all
+ u = create_user
+ t = create_team
+ create_team_user team: t, user: u, role: 'admin'
+ p = create_project team: t
+ author_id = random_string
+ set_fields = { smooch_user_data: { id: author_id }.to_json, smooch_user_app_id: 'fake', smooch_user_id: 'fake' }.to_json
+ d = create_dynamic_annotation annotated: p, annotation_type: 'smooch_user', set_fields: set_fields
+ authenticate_with_token
+ url = random_url
+ query = 'mutation { updateDynamicAnnotationSmoochUser(input: { clientMutationId: "1", id: "' + d.graphql_id + '", set_fields: "{\"smooch_user_slack_channel_url\":\"' + url + '\"}" }) { project { dbid } } }'
+
+ Sidekiq::Testing.fake! do
+ post :create, params: { query: query }
+ assert_response :success
+ end
+ Sidekiq::Worker.drain_all
+ assert_equal url, Dynamic.find(d.id).get_field_value('smooch_user_slack_channel_url')
+
+ # Check that cache key exists
+ key = "SmoochUserSlackChannelUrl:Team:#{d.team_id}:#{author_id}"
+ assert_equal url, Rails.cache.read(key)
+
+ # Test using a new mutation `smoochBotAddSlackChannelUrl`
+ url2 = random_url
+ query = 'mutation { smoochBotAddSlackChannelUrl(input: { clientMutationId: "1", id: "' + d.id.to_s + '", set_fields: "{\"smooch_user_slack_channel_url\":\"' + url2 + '\"}" }) { annotation { dbid } } }'
+ Sidekiq::Testing.fake! do
+ post :create, params: { query: query }
+ assert_response :success
+ end
+ assert Sidekiq::Worker.jobs.size > 0
+ assert_equal url, d.reload.get_field_value('smooch_user_slack_channel_url')
+
+ # Execute job and check that URL was set
+ Sidekiq::Worker.drain_all
+ assert_equal url2, d.get_field_value('smooch_user_slack_channel_url')
+
+ # Check that cache key exists
+ assert_equal url2, Rails.cache.read(key)
+
+ # Call mutation with non existing ID
+ query = 'mutation { smoochBotAddSlackChannelUrl(input: { clientMutationId: "1", id: "99999", set_fields: "{\"smooch_user_slack_channel_url\":\"' + url2 + '\"}" }) { annotation { dbid } } }'
+ post :create, params: { query: query }
+ assert_response :success
+ end
+end
diff --git a/test/controllers/graphql_controller_3_test.rb b/test/controllers/graphql_controller_3_test.rb
index 57f9408831..e2892e565c 100644
--- a/test/controllers/graphql_controller_3_test.rb
+++ b/test/controllers/graphql_controller_3_test.rb
@@ -341,49 +341,6 @@ def setup
assert_equal 1, response['item_navigation_offset']
end
- test "should set smooch user slack channel url in background" do
- Sidekiq::Testing.fake! do
- u = create_user
- t = create_team
- create_team_user team: t, user: u, role: 'admin'
- p = create_project team: t
- author_id = random_string
- set_fields = { smooch_user_data: { id: author_id }.to_json, smooch_user_app_id: 'fake', smooch_user_id: 'fake' }.to_json
- d = create_dynamic_annotation annotated: p, annotation_type: 'smooch_user', set_fields: set_fields
- Sidekiq::Worker.drain_all
- assert_equal 0, Sidekiq::Worker.jobs.size
- authenticate_with_token
- url = random_url
- query = 'mutation { updateDynamicAnnotationSmoochUser(input: { clientMutationId: "1", id: "' + d.graphql_id + '", set_fields: "{\"smooch_user_slack_channel_url\":\"' + url + '\"}" }) { project { dbid } } }'
- post :create, params: { query: query }
- assert_response :success
- Sidekiq::Worker.drain_all
- sleep 1
- assert_equal url, Dynamic.find(d.id).get_field_value('smooch_user_slack_channel_url')
- # check that cache key exists
- key = "SmoochUserSlackChannelUrl:Team:#{d.team_id}:#{author_id}"
- assert_equal url, Rails.cache.read(key)
- # test using a new mutation `smoochBotAddSlackChannelUrl`
- Sidekiq::Worker.drain_all
- assert_equal 0, Sidekiq::Worker.jobs.size
- url2 = random_url
- query = 'mutation { smoochBotAddSlackChannelUrl(input: { clientMutationId: "1", id: "' + d.id.to_s + '", set_fields: "{\"smooch_user_slack_channel_url\":\"' + url2 + '\"}" }) { annotation { dbid } } }'
- post :create, params: { query: query }
- assert_response :success
- assert Sidekiq::Worker.jobs.size > 0
- assert_equal url, d.reload.get_field_value('smooch_user_slack_channel_url')
- # execute job and check that url was set
- Sidekiq::Worker.drain_all
- assert_equal url2, d.get_field_value('smooch_user_slack_channel_url')
- # check that cache key exists
- assert_equal url2, Rails.cache.read(key)
- # call mutation with non existing id
- query = 'mutation { smoochBotAddSlackChannelUrl(input: { clientMutationId: "1", id: "99999", set_fields: "{\"smooch_user_slack_channel_url\":\"' + url2 + '\"}" }) { annotation { dbid } } }'
- post :create, params: { query: query }
- assert_response :success
- end
- end
-
test "should get requests from media" do
u = create_user is_admin: true
t = create_team
diff --git a/test/controllers/graphql_controller_4_test.rb b/test/controllers/graphql_controller_4_test.rb
index b1b32efe91..2bdd4ef54b 100644
--- a/test/controllers/graphql_controller_4_test.rb
+++ b/test/controllers/graphql_controller_4_test.rb
@@ -322,9 +322,11 @@ def teardown
@pms.each { |pm| assert_not pm.read }
assert_search_finds_all({ read: 0 })
assert_search_finds_none({ read: 1 })
- query = 'mutation { bulkProjectMediaMarkRead(input: { clientMutationId: "1", ids: ' + @ids + ', read: true }) { ids, team { dbid } } }'
+ query = 'mutation { bulkProjectMediaMarkRead(input: { clientMutationId: "1", ids: ' + @ids + ', read: true }) { updated_objects { id, is_read, dbid }, ids, team { dbid } } }'
post :create, params: { query: query, team: @t.slug }
assert_response :success
+ updated_objects = JSON.parse(@response.body)['data']['bulkProjectMediaMarkRead']['updated_objects']
+ assert_equal @pms.map(&:id).sort, updated_objects.collect{|obj| obj['dbid']}.sort
@pms.each { |pm| assert pm.reload.read }
assert_search_finds_all({ read: 1 })
assert_search_finds_none({ read: 0 })
diff --git a/test/controllers/graphql_controller_9_test.rb b/test/controllers/graphql_controller_9_test.rb
index c3edeaa351..3ae958b198 100644
--- a/test/controllers/graphql_controller_9_test.rb
+++ b/test/controllers/graphql_controller_9_test.rb
@@ -409,6 +409,82 @@ def setup
assert_equal "Not Found", JSON.parse(@response.body)['errors'][0]['message']
end
+ test "should paginate tipline messages" do
+ t = create_team slug: 'test', private: true
+ u = create_user
+ create_team_user user: u, team: t, role: 'admin'
+ uid = random_string
+
+ tp1_uid = create_tipline_message team_id: t.id, uid: uid
+ tp2_uid = create_tipline_message team_id: t.id, uid: uid
+ tp3_uid = create_tipline_message team_id: t.id, uid: uid
+
+ authenticate_with_user(u)
+
+ # Paginating one item per page
+
+ # Page 1
+ query = 'query read { team(slug: "test") { tipline_messages(first: 1, uid:"'+ uid +'") { pageInfo { endCursor, startCursor, hasPreviousPage, hasNextPage } edges { node { dbid } } } } }'
+ post :create, params: { query: query }
+ assert_response :success
+ data = JSON.parse(@response.body)['data']['team']['tipline_messages']
+ results = data['edges'].to_a.collect{ |e| e['node']['dbid'] }
+ assert_equal 1, results.size
+ assert_equal tp3_uid.id, results[0]
+ page_info = data['pageInfo']
+ assert page_info['hasNextPage']
+
+ # Page 2
+ query = 'query read { team(slug: "test") { tipline_messages(first: 1, after: "' + page_info['endCursor'] + '", uid:"'+ uid +'") { pageInfo { endCursor, startCursor, hasPreviousPage, hasNextPage } edges { node { dbid } } } } }'
+ post :create, params: { query: query }
+ assert_response :success
+ data = JSON.parse(@response.body)['data']['team']['tipline_messages']
+ results = data['edges'].to_a.collect{ |e| e['node']['dbid'] }
+ assert_equal 1, results.size
+ assert_equal tp2_uid.id, results[0]
+ page_info = data['pageInfo']
+ assert page_info['hasNextPage']
+
+ # Page 3
+ query = 'query read { team(slug: "test") { tipline_messages(first: 1, after: "' + page_info['endCursor'] + '", uid:"'+ uid +'") { pageInfo { endCursor, startCursor, hasPreviousPage, hasNextPage } edges { node { dbid } } } } }'
+ post :create, params: { query: query }
+ assert_response :success
+ data = JSON.parse(@response.body)['data']['team']['tipline_messages']
+ results = data['edges'].to_a.collect{ |e| e['node']['dbid'] }
+ assert_equal 1, results.size
+ assert_equal tp1_uid.id, results[0]
+ page_info = data['pageInfo']
+ assert !page_info['hasNextPage']
+ # paginate using specific message id
+ tp4_uid = create_tipline_message team_id: t.id, uid: uid
+ query = 'query read { team(slug: "test") { tipline_messages(uid:"'+ uid +'") { pageInfo { endCursor, startCursor, hasPreviousPage, hasNextPage } edges { node { dbid }, cursor } } } }'
+ post :create, params: { query: query }
+ assert_response :success
+ data = JSON.parse(@response.body)['data']['team']['tipline_messages']
+ id_cursor = {}
+ data['edges'].to_a.each{ |e| id_cursor[e['node']['dbid']] = e['cursor'] }
+ # Start with tp4_uid message
+ query = 'query read { team(slug: "test") { tipline_messages(first: 1, after: "' + id_cursor[tp4_uid.id] + '", uid:"'+ uid +'") { pageInfo { endCursor, startCursor, hasPreviousPage, hasNextPage } edges { node { dbid } } } } }'
+ post :create, params: { query: query }
+ assert_response :success
+ data = JSON.parse(@response.body)['data']['team']['tipline_messages']
+ results = data['edges'].to_a.collect{ |e| e['node']['dbid'] }
+ assert_equal 1, results.size
+ assert_equal tp3_uid.id, results[0]
+ page_info = data['pageInfo']
+ assert page_info['hasNextPage']
+ # Next page
+ query = 'query read { team(slug: "test") { tipline_messages(first: 1, after: "' + page_info['endCursor'] + '", uid:"'+ uid +'") { pageInfo { endCursor, startCursor, hasPreviousPage, hasNextPage } edges { node { dbid } } } } }'
+ post :create, params: { query: query }
+ assert_response :success
+ data = JSON.parse(@response.body)['data']['team']['tipline_messages']
+ results = data['edges'].to_a.collect{ |e| e['node']['dbid'] }
+ assert_equal 1, results.size
+ assert_equal tp2_uid.id, results[0]
+ page_info = data['pageInfo']
+ assert page_info['hasNextPage']
+ end
+
protected
def assert_error_message(expected)
diff --git a/test/controllers/webhooks_controller_test.rb b/test/controllers/webhooks_controller_test.rb
index f91de407b7..e809d0001d 100644
--- a/test/controllers/webhooks_controller_test.rb
+++ b/test/controllers/webhooks_controller_test.rb
@@ -232,4 +232,24 @@ def setup
assert_equal '200', response.code
assert_match /ignored/, response.body
end
+
+ test "should process Alegre webhook" do
+ CheckSentry.expects(:notify).never
+ redis = Redis.new(REDIS_CONFIG)
+ redis.del('foo')
+ payload = { 'action' => 'audio', 'data' => { 'requested' => { 'body' => { 'id' => 'foo', 'context' => { 'project_media_id' => random_number } } } } }
+ assert_nil redis.lpop('alegre:webhook:foo')
+
+ post :index, params: { name: :alegre, token: CheckConfig.get('alegre_token') }.merge(payload)
+ response = JSON.parse(redis.lpop('alegre:webhook:foo'))
+ assert_equal 'foo', response.dig('data', 'requested', 'body', 'id')
+
+ travel_to Time.now.since(2.days)
+ assert_nil redis.lpop('alegre:webhook:foo')
+ end
+
+ test "should report error if can't process Alegre webhook" do
+ CheckSentry.expects(:notify).once
+ post :index, params: { name: :alegre, token: CheckConfig.get('alegre_token') }.merge({ foo: 'bar' })
+ end
end
diff --git a/test/models/blocked_tipline_user_test.rb b/test/models/blocked_tipline_user_test.rb
new file mode 100644
index 0000000000..b6374f5555
--- /dev/null
+++ b/test/models/blocked_tipline_user_test.rb
@@ -0,0 +1,33 @@
+require_relative '../test_helper'
+
+class BlockedTiplineUserTest < ActiveSupport::TestCase
+ def setup
+ end
+
+ def teardown
+ end
+
+ test 'should create blocked tipline user' do
+ assert_difference 'BlockedTiplineUser.count' do
+ create_blocked_tipline_user
+ end
+ end
+
+ test 'should not create blocked tipline user if UID is blank' do
+ assert_no_difference 'BlockedTiplineUser.count' do
+ assert_raises ActiveRecord::NotNullViolation do
+ create_blocked_tipline_user uid: nil
+ end
+ end
+ end
+
+ test 'should not block the same user more than once' do
+ uid = random_string
+ create_blocked_tipline_user uid: uid
+ assert_no_difference 'BlockedTiplineUser.count' do
+ assert_raises ActiveRecord::RecordNotUnique do
+ create_blocked_tipline_user uid: uid
+ end
+ end
+ end
+end
diff --git a/test/models/bot/alegre_2_test.rb b/test/models/bot/alegre_2_test.rb
index 804ce5e991..120b3c25fc 100644
--- a/test/models/bot/alegre_2_test.rb
+++ b/test/models/bot/alegre_2_test.rb
@@ -315,6 +315,16 @@ def teardown
RequestStore.store[:pause_database_connection] = false
end
+ test "should block calls on redis blpop for audio request" do
+ stubbed_response = Net::HTTPSuccess.new(1.0, '200', 'OK')
+ stubbed_response.stubs(:body).returns({"queue" => "audio__Model", "body" => {"id" => "123", "callback_url" => "http://example.com/callback"}}.to_json)
+ Net::HTTP.any_instance.stubs(:request).returns(stubbed_response)
+ Redis.any_instance.stubs(:blpop).with("alegre:webhook:123", 120).returns(["alegre:webhook:123", {"tested" => true}.to_json])
+ assert_equal Bot::Alegre.request_api('get', '/audio/similarity/', @params, 'body'), {"tested" => true}
+ Net::HTTP.any_instance.unstub(:request)
+ Redis.any_instance.unstub(:blpop)
+ end
+
test "should get items with similar title" do
create_verification_status_stuff
RequestStore.store[:skip_cached_field_update] = false
diff --git a/test/models/bot/smooch_4_test.rb b/test/models/bot/smooch_4_test.rb
index 80db102e3a..1d619bc543 100644
--- a/test/models/bot/smooch_4_test.rb
+++ b/test/models/bot/smooch_4_test.rb
@@ -476,50 +476,81 @@ def teardown
test "should request resource" do
setup_smooch_bot(true)
- RequestStore.store[:skip_cached_field_update] = false
uid = random_string
rss = '
-
+