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