1# frozen_string_literal: true 2 3module StubObjectStorage 4 def stub_dependency_proxy_object_storage(**params) 5 stub_object_storage_uploader(config: ::Gitlab.config.dependency_proxy.object_store, 6 uploader: ::DependencyProxy::FileUploader, 7 **params) 8 end 9 10 def stub_object_storage_pseudonymizer 11 stub_object_storage(connection_params: Pseudonymizer::Uploader.object_store_credentials, 12 remote_directory: Pseudonymizer::Uploader.remote_directory) 13 end 14 15 def stub_object_storage_uploader( 16 config:, 17 uploader:, 18 enabled: true, 19 proxy_download: false, 20 background_upload: false, 21 direct_upload: false 22 ) 23 new_config = config.to_h.deep_symbolize_keys.merge({ 24 enabled: enabled, 25 proxy_download: proxy_download, 26 background_upload: background_upload, 27 direct_upload: direct_upload 28 }) 29 30 # Needed for ObjectStorage::Config compatibility 31 allow(config).to receive(:to_hash).and_return(new_config) 32 allow(config).to receive(:to_h).and_return(new_config) 33 allow(config).to receive(:enabled) { enabled } 34 allow(config).to receive(:proxy_download) { proxy_download } 35 allow(config).to receive(:background_upload) { background_upload } 36 allow(config).to receive(:direct_upload) { direct_upload } 37 38 return unless enabled 39 40 stub_object_storage(connection_params: uploader.object_store_credentials, 41 remote_directory: config.remote_directory) 42 end 43 44 def stub_object_storage(connection_params:, remote_directory:) 45 Fog.mock! 46 47 ::Fog::Storage.new(connection_params).tap do |connection| 48 connection.directories.create(key: remote_directory) # rubocop:disable Rails/SaveBang 49 50 # Cleanup remaining files 51 connection.directories.each do |directory| 52 directory.files.map(&:destroy) 53 end 54 rescue Excon::Error::Conflict 55 end 56 end 57 58 def stub_artifacts_object_storage(uploader = JobArtifactUploader, **params) 59 stub_object_storage_uploader(config: Gitlab.config.artifacts.object_store, 60 uploader: uploader, 61 **params) 62 end 63 64 def stub_external_diffs_object_storage(uploader = described_class, **params) 65 stub_object_storage_uploader(config: Gitlab.config.external_diffs.object_store, 66 uploader: uploader, 67 **params) 68 end 69 70 def stub_lfs_object_storage(**params) 71 stub_object_storage_uploader(config: Gitlab.config.lfs.object_store, 72 uploader: LfsObjectUploader, 73 **params) 74 end 75 76 def stub_package_file_object_storage(**params) 77 stub_object_storage_uploader(config: Gitlab.config.packages.object_store, 78 uploader: ::Packages::PackageFileUploader, 79 **params) 80 end 81 82 def stub_composer_cache_object_storage(**params) 83 stub_object_storage_uploader(config: Gitlab.config.packages.object_store, 84 uploader: ::Packages::Composer::CacheUploader, 85 **params) 86 end 87 88 def stub_uploads_object_storage(uploader = described_class, **params) 89 stub_object_storage_uploader(config: Gitlab.config.uploads.object_store, 90 uploader: uploader, 91 **params) 92 end 93 94 def stub_terraform_state_object_storage(**params) 95 stub_object_storage_uploader(config: Gitlab.config.terraform_state.object_store, 96 uploader: Terraform::StateUploader, 97 **params) 98 end 99 100 def stub_pages_object_storage(uploader = described_class, **params) 101 stub_object_storage_uploader(config: Gitlab.config.pages.object_store, 102 uploader: uploader, 103 **params) 104 end 105 106 def stub_object_storage_multipart_init(endpoint, upload_id = "upload_id") 107 stub_request(:post, %r{\A#{endpoint}tmp/uploads/[%A-Za-z0-9-]*\?uploads\z}) 108 .to_return status: 200, body: <<-EOS.strip_heredoc 109 <?xml version="1.0" encoding="UTF-8"?> 110 <InitiateMultipartUploadResult xmlns="http://s3.amazonaws.com/doc/2006-03-01/"> 111 <Bucket>example-bucket</Bucket> 112 <Key>example-object</Key> 113 <UploadId>#{upload_id}</UploadId> 114 </InitiateMultipartUploadResult> 115 EOS 116 end 117end 118