Method Submit

forms/test_s3_filesystem.go:43–87

Submit validates and performs a S3 filesystem connection test.

()

// Submit validates and performs a S3 filesystem connection test.
func (form *TestS3Filesystem) Submit() error {
	if err := form.Validate(); err != nil {
		return err
	}

	var s3Config core.S3Config

	if form.Filesystem == s3FilesystemBackups {
		s3Config = form.app.Settings().Backups.S3
	} else {
		s3Config = form.app.Settings().S3
	}

	if !s3Config.Enabled {
		return errors.New("S3 storage filesystem is not enabled")
	}

	fsys, err := filesystem.NewS3(
		s3Config.Bucket,
		s3Config.Region,
		s3Config.Endpoint,
		s3Config.AccessKey,
		s3Config.Secret,
		s3Config.ForcePathStyle,
	)
	if err != nil {
		return fmt.Errorf("failed to initialize the S3 filesystem: %w", err)
	}
	defer fsys.Close()

	testPrefix := "pb_settings_test_" + security.PseudorandomString(5)
	testFileKey := testPrefix + "/test.txt"

	// try to upload a test file
	if err := fsys.Upload([]byte("test"), testFileKey); err != nil {
		return fmt.Errorf("failed to upload a test file: %w", err)
	}

	// test prefix deletion (ensures that both bucket list and delete works)
	if errs := fsys.DeletePrefix(testPrefix); len(errs) > 0 {
		return fmt.Errorf("failed to delete a test file: %w", errs[0])
	}

	return nil
}