edshot99/eBooru
1
0
Fork 0
forked from e621ng/e621ng
Code Issues 11 Releases 1 Activity

[Tests] Remove unused post archive helper

Browse Source
This commit is contained in:
Earlopain 2022-02-10 17:55:32 +01:00
parent b1a8c4960c
commit 553a861bef
No known key found for this signature in database
GPG Key ID: 6CFB948E15246897
2 changed files with 0 additions and 56 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
test/test_helper.rb
View File

@ -65,7 +65,6 @@ end
class ActiveSupport::TestCase
include PostArchiveTestHelper
include DownloadTestHelper
include IqdbTestHelper
include UploadTestHelper
@ -93,7 +92,6 @@ class ActiveSupport::TestCase
end
class ActionDispatch::IntegrationTest
include PostArchiveTestHelper
include TestHelpers
def method_authenticated(method_name, url, user, options)

54
test/test_helpers/post_archive_test_helper.rb
View File

@ -1,54 +0,0 @@
module PostArchiveTestHelper
def setup
super
mock_post_archive_service!
start_post_archive_transaction
end
def teardown
super
rollback_post_archive_transaction
end
def mock_post_archive_service!
mock_sqs_service = Class.new do
def send_message(msg, *options)
_, json = msg.split(/\n/)
json = JSON.parse(json)
json.delete("created_at")
json["version"] = 1 + PostArchive.where(post_id: json["post_id"]).count
prev = PostArchive.where(post_id: json["post_id"]).order("id desc").first
if prev
json["added_tags"] = json["tags"].scan(/\S+/) - prev.tags.scan(/\S+/)
json["removed_tags"] = prev.tags.scan(/\S+/) - json["tags"].scan(/\S+/)
else
json["added_tags"] = json["tags"].scan(/\S+/)
end
json["parent_changed"] = (prev.nil? || json.key?("parent_id") && prev.parent_id != json["parent_id"])
json["source_changed"] = (prev.nil? || json.key?("source") && prev.source != json["source"])
json["rating_changed"] = (prev.nil? || json.key?("rating") && prev.rating != json["rating"])
if merge?(prev, json)
prev.update_columns(json)
else
PostArchive.create(json)
end
end
def merge?(prev, json)
prev && (prev.updater_id == json["updater_id"]) && (prev.updated_at >= 1.hour.ago)
end
end
PostArchive.stubs(:sqs_service).returns(mock_sqs_service.new)
end
def start_post_archive_transaction
PostArchive.connection.begin_transaction joinable: false
end
def rollback_post_archive_transaction
PostArchive.connection.rollback_transaction
end
end