(t *testing.T)
| 91 | } |
| 92 | |
| 93 | func TestFromCredentials(t *testing.T) { |
| 94 | ctx := context.Background() |
| 95 | assert := assert.New(t) |
| 96 | r := mocks.NewReader(t) |
| 97 | const bucket, keyID, keySecret, region = "my-bucket", "key-id", "key-secret", "region-1" |
| 98 | |
| 99 | t.Run("with deprecated bucketName", func(_ *testing.T) { |
| 100 | r.On("ReadCredentials", ctx, "secretName", mock.AnythingOfType("*s3.Credentials")).Return(nil).Run( |
| 101 | func(args mock.Arguments) { |
| 102 | credentials := args.Get(2).(*Credentials) |
| 103 | credentials.BucketName = bucket |
| 104 | credentials.Region = region |
| 105 | credentials.SecretAccessKey = keySecret |
| 106 | credentials.AccessKeyID = keyID |
| 107 | }) |
| 108 | |
| 109 | _, err := NewBackendProvider(r).FromCredentials(ctx, "secretName") |
| 110 | assert.NoError(err) |
| 111 | }) |
| 112 | |
| 113 | t.Run("with location", func(_ *testing.T) { |
| 114 | r.On("ReadCredentials", ctx, "secretName", mock.AnythingOfType("*s3.Credentials")).Return(nil).Run( |
| 115 | func(args mock.Arguments) { |
| 116 | credentials := args.Get(2).(*Credentials) |
| 117 | credentials.Location = fmt.Sprintf("https://123.r2.cloudflarestorage.com/%s", bucket) |
| 118 | credentials.Region = region |
| 119 | credentials.SecretAccessKey = keySecret |
| 120 | credentials.AccessKeyID = keyID |
| 121 | }) |
| 122 | |
| 123 | _, err := NewBackendProvider(r).FromCredentials(ctx, "secretName") |
| 124 | assert.NoError(err) |
| 125 | }) |
| 126 | } |
| 127 | |
| 128 | func TestExtractCreds(t *testing.T) { |
| 129 | tetCases := []struct { |
nothing calls this directly
no test coverage detected