feat: force bucket name regardless of ssh user

.env.example

@@ -7,5 +7,11 @@ MINIO_URL="http://minio:9000"
 MINIO_ROOT_USER="miniosecret"
 MINIO_ROOT_PASSWORD="miniosecret"
 
+# OBJECT_DRIVER="s3"
+# OBJECT_BUCKET_NAME="xyz" # optional, force the bucket name
+# AWS_ACCESS_KEY_ID="yyy"
+# AWS_SECRET_ACCESS_KEY="zzz"
+# AWS_REGION="us-east-2"
+
 # OBJECT_DRIVER="fs"
 # OBJECT_URL="./.storage"

asset.go

@@ -18,3 +18,12 @@ func (an *AssetNamesBasic) BucketName(user string) string {
 func (an *AssetNamesBasic) ObjectName(entry *utils.FileEntry) string {
 	return entry.Filepath
 }
+
+type AssetNamesForceBucket struct {
+	*AssetNamesBasic
+	Name string
+}
+
+func (an *AssetNamesForceBucket) BucketName(user string) string {
+	return an.Name
+}

cmd/authorized_keys/main.go

@@ -18,6 +18,7 @@ func main() {
 	host := pobj.GetEnv("SSH_HOST", "0.0.0.0")
 	port := pobj.GetEnv("SSH_PORT", "2222")
 	keyPath := pobj.GetEnv("SSH_AUTHORIZED_KEYS", "./ssh_data/authorized_keys")
+	bucketName := pobj.GetEnv("OBJECT_BUCKET_NAME", "")
 
 	st, err := pobj.EnvDriverDetector(logger)
 	if err != nil {
@@ -29,6 +30,11 @@ func main() {
 		Logger:  logger,
 		Storage: st,
 	}
+	if bucketName != "" {
+		cfg.AssetNames = &pobj.AssetNamesForceBucket{
+			Name: bucketName,
+		}
+	}
 
 	handler := pobj.NewUploadAssetHandler(cfg)