4b819d3cb2
It hasn't been necessary to use create_with_id since
ebc79622df, in December 2024.
I have plans to introduce:
```ruby
def create_with_id(id, values)
obj = new(values)
obj.id = id
obj.save_changes
end
```
This will make it easier to use the same id when creating
multiple objects. The first step is removing the existing
uses of create_with_id.
84 lines
3.2 KiB
Ruby
84 lines
3.2 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
require_relative "../spec_helper"
|
|
|
|
RSpec.describe GithubCacheEntry do
|
|
subject(:entry) { described_class.create(repository_id: repository.id, key: "k1", version: "v1", scope: "main", upload_id: "upload-123", created_by: "3c9a861c-ab14-8218-a175-875ebb652f7b") }
|
|
|
|
let(:repository) { GithubRepository.create(name: "test") }
|
|
|
|
describe "#after_destroy" do
|
|
let(:client) { instance_double(Aws::S3::Client) }
|
|
|
|
before { allow(Aws::S3::Client).to receive(:new).and_return(client) }
|
|
|
|
it "deletes the object" do
|
|
expect(entry).to receive(:committed_at).and_return(Time.now)
|
|
expect(client).to receive(:delete_object).with(bucket: repository.bucket_name, key: entry.blob_key)
|
|
entry.destroy
|
|
end
|
|
|
|
it "ignores if the object already deleted" do
|
|
expect(entry).to receive(:committed_at).and_return(Time.now)
|
|
expect(client).to receive(:delete_object).and_raise(Aws::S3::Errors::NoSuchKey.new(nil, nil))
|
|
entry.destroy
|
|
end
|
|
|
|
it "aborts the multipart upload if the cache not committed yet" do
|
|
expect(entry).to receive(:committed_at).and_return(nil)
|
|
expect(client).to receive(:abort_multipart_upload).with(bucket: repository.bucket_name, key: entry.blob_key, upload_id: entry.upload_id)
|
|
expect(client).to receive(:delete_object)
|
|
entry.destroy
|
|
end
|
|
|
|
it "ignores if the multipart upload already aborted" do
|
|
expect(entry).to receive(:committed_at).and_return(nil)
|
|
expect(client).to receive(:abort_multipart_upload).and_raise(Aws::S3::Errors::NoSuchUpload.new(nil, nil))
|
|
expect(client).to receive(:delete_object)
|
|
entry.destroy
|
|
end
|
|
end
|
|
|
|
describe ".destory_where" do
|
|
let(:client) { instance_double(Aws::S3::Client) }
|
|
|
|
before { allow(Aws::S3::Client).to receive(:new).and_return(client) }
|
|
|
|
it "destroy the objects if matched by filter" do
|
|
archive_count = ArchivedRecord.count
|
|
entry
|
|
expect(client).to receive(:abort_multipart_upload).with(bucket: repository.bucket_name, key: entry.blob_key, upload_id: entry.upload_id)
|
|
expect(client).to receive(:delete_object)
|
|
described_class.destroy_where(key: "k1")
|
|
expect(entry).not_to exist
|
|
expect(ArchivedRecord.count).to eq(archive_count + 1)
|
|
end
|
|
|
|
it "does not destroy the object if it is not matched by the filter" do
|
|
archive_count = ArchivedRecord.count
|
|
entry
|
|
described_class.destroy_where(key: "k2")
|
|
expect(entry).to exist
|
|
expect(ArchivedRecord.count).to eq archive_count
|
|
end
|
|
end
|
|
|
|
describe "#destory_where" do
|
|
it "destroy the objects if it is matched by the filter" do
|
|
archive_count = ArchivedRecord.count
|
|
expect(entry).to receive(:after_destroy).and_return(nil)
|
|
expect(entry.destroy_where(key: "k1")).to eq entry
|
|
expect(entry).not_to exist
|
|
expect(ArchivedRecord.count).to eq(archive_count + 1)
|
|
end
|
|
|
|
it "does not destroy the object if it is not matched by the filter" do
|
|
archive_count = ArchivedRecord.count
|
|
expect(entry).not_to receive(:after_destroy)
|
|
expect(entry.destroy_where(key: "k2")).to be_nil
|
|
expect(entry).to exist
|
|
expect(ArchivedRecord.count).to eq archive_count
|
|
end
|
|
end
|
|
end
|