· 6 years ago · Jun 19, 2019, 08:46 AM
1func s3Connect(cfg config.Env, logger *zap.SugaredLogger, t *testing.T) *s3.Client {
2 s3Secrets, err := secrets.New(cfg.VaultEndpoint, internalConfig.AppNS, internalConfig.AppName, cfg.S3.VaultPath)
3 require.NoError(t, err)
4
5 accessKey, err := s3Secrets.GetStringValue("access")
6 require.NoError(t, err)
7
8 secretKey, err := s3Secrets.GetStringValue("secret")
9 require.NoError(t, err)
10
11 s3client, err := s3.New(cfg.S3.ServiceEndpoint, accessKey, secretKey, cfg.S3.SitemapPublicEndpoint, cfg.S3.SitemapBucket, logger)
12 require.NoError(t, err)
13
14 return s3client
15}
16
17
18func Test_Ceph(t *testing.T) {
19
20 c := s3Connect(t, cfg, logger)
21 t.Run("Positive", func(t *testing.T) {
22 Url, err := c.Upload(context.Background(),"myname", "ct","no-cache", strings.NewReader("abc"), 3)
23
24 t.Log(t, Url)
25 t.Log(t, err)
26 })
27}