From f05098621ede52e88a3a121c257adeb376859d6b Mon Sep 17 00:00:00 2001 From: kekskurse Date: Sat, 15 Jan 2022 01:28:02 +0100 Subject: [PATCH] Create S3 buicket if not exists --- .drone.yml | 5 +++-- main.go | 10 +++++++++- 2 files changed, 12 insertions(+), 3 deletions(-) diff --git a/.drone.yml b/.drone.yml index f64b227..934000e 100644 --- a/.drone.yml +++ b/.drone.yml @@ -24,5 +24,6 @@ steps: key: from_secret: ssh_key script: - - echo hello - - echo world \ No newline at end of file + - cd ~/kuvia-beta;sudo docker-compowe down kuvia + - sudo docker pull kekskurse/kuvia + - cd ~/kuvia-beta;sudo docker-compowe up -d kuvia \ No newline at end of file diff --git a/main.go b/main.go index 848fb9b..d023771 100644 --- a/main.go +++ b/main.go @@ -1,6 +1,7 @@ package main import ( + "context" "database/sql" "embed" "errors" @@ -88,7 +89,14 @@ func s3Connect() { if err != nil { log.Fatal().Err(err).Msg("Cant create s3 client") } - + ctx := context.Background() + bucketexists, err := minioClient.BucketExists(ctx, os.Getenv("S3_BUCKET")) + if err != nil { + log.Fatal().Err(err).Msg("Cant check S3 Bucket exists") + } + if bucketexists == false { + minioClient.MakeBucket(ctx, os.Getenv("S3_BUCKET"), minio.MakeBucketOptions{}) + } s3 = minioClient