Feature: AWS read-only

internal/elastic/core/snapshots.go

@@ -15,16 +15,19 @@ import (
 )
 
 // CreateAWSRepository -
-func (e *Elastic) CreateAWSRepository(name, awsBucketName, awsRegion string) error {
+func (e *Elastic) CreateAWSRepository(name, awsBucketName, awsRegion string, opts ...models.CreateRepositoryOption) error {
 	query := map[string]interface{}{
 		"type": "s3",
 		"settings": map[string]interface{}{
-			"bucket":      awsBucketName,
-			"endpoint":    fmt.Sprintf("s3.%s.amazonaws.com", awsRegion),
-			"compress":    "true",
-			"max_retries": 3,
+			"bucket":   awsBucketName,
+			"endpoint": fmt.Sprintf("s3.%s.amazonaws.com", awsRegion),
 		},
 	}
+
+	for i := range opts {
+		opts[i](query)
+	}
+
 	var buf bytes.Buffer
 	if err := json.NewEncoder(&buf).Encode(query); err != nil {
 		return err

internal/models/interface.go

@@ -19,7 +19,7 @@ type GeneralRepository interface {
 	UpdateFields(index, id string, data interface{}, fields ...string) error
 	GetEvents([]SubscriptionRequest, int64, int64) ([]Event, error)
 	SearchByText(string, int64, []string, map[string]interface{}, bool) (Result, error)
-	CreateAWSRepository(string, string, string) error
+	CreateAWSRepository(string, string, string, ...CreateRepositoryOption) error
 	ListRepositories() ([]Repository, error)
 	CreateSnapshots(string, string, []string) error
 	RestoreSnapshots(string, string, []string) error

internal/models/options.go

@@ -0,0 +1,25 @@
+package models
+
+// CreateRepositoryOption -
+type CreateRepositoryOption func(map[string]interface{})
+
+// WithReadOnly -
+func WithReadOnly() CreateRepositoryOption {
+	return func(data map[string]interface{}) {
+		data["readonly"] = true
+	}
+}
+
+// WithCompress -
+func WithCompress() CreateRepositoryOption {
+	return func(data map[string]interface{}) {
+		data["compress"] = "true"
+	}
+}
+
+// WithMaxRetries -
+func WithMaxRetries(maxRetries int64) CreateRepositoryOption {
+	return func(data map[string]interface{}) {
+		data["max_retries"] = maxRetries
+	}
+}

internal/reindexer/core/snapshots.go

@@ -7,7 +7,7 @@ import (
 )
 
 // CreateAWSRepository -
-func (r *Reindexer) CreateAWSRepository(name, awsBucketName, awsRegion string) error {
+func (r *Reindexer) CreateAWSRepository(name, awsBucketName, awsRegion string, opts ...models.CreateRepositoryOption) error {
 	return nil
 }
 

scripts/esctl/repository.go

@@ -1,5 +1,7 @@
 package main
 
+import "github.com/baking-bad/bcdhub/internal/models"
+
 type createRepoCommand struct{}
 
 var createRepoCmd createRepoCommand
@@ -11,5 +13,18 @@ func (x *createRepoCommand) Execute(_ []string) error {
 		return err
 	}
 
-	return ctx.Storage.CreateAWSRepository(name, creds.BucketName, creds.Region)
+	opts := []models.CreateRepositoryOption{
+		models.WithCompress(),
+		models.WithMaxRetries(3),
+	}
+
+	readOnlyAnswer, err := askQuestion("Read-only (yes/no):")
+	if err != nil {
+		return err
+	}
+	if readOnlyAnswer == "yes" {
+		opts = append(opts, models.WithReadOnly())
+	}
+
+	return ctx.Storage.CreateAWSRepository(name, creds.BucketName, creds.Region, opts...)
 }