forge/modules/setting/storage_test.go at agent/forge-agent-access

mirror of https://github.com/hanzoai/forge.git synced 2026-10-30 15:00:39 +00:00

Files

T

zeekayandHanzo Dev 27cde39e36 Name every remaining identifier, path and default for this product

Storage buckets, indexer names, the bleve analyzer, the lock prefix, SSH host
keys, the markdown front-matter key, the container data paths, the RPM repo id
and the API security scheme all read as this product now, and app.example.ini
matches the code again. The upstream maintainer list and the changelog
generator config went with the release history they belonged to, and the
citation comments state the fact rather than link the issue.

Three inert rules turn out to have been inert because they named a module path
this tree does not use: gci grouped no first-party imports under prefix(), and
depguard let models/migrations import models and modules/structs. They now name
github.com/hanzoai/git. The config example also documented .gitea/workflows
while the code has read .hanzo/workflows for some time.

The authorized_keys marker follows the delegate-hook precedent: the new name is
written and the old one is still recognised, because a marker we do not know is
copied through as a hand-added key and leaves a revoked key authorized. The
stored user_setting key keeps its value; only a migration may change that.

Co-authored-by: Hanzo Dev <[email protected]>

2026-09-10 19:14:35 -07:00

629 lines

22 KiB

Go

Raw Permalink Blame History

 // Copyright 2026 Hanzo AI, Inc. All rights reserved.
 // SPDX-License-Identifier: MIT
 package setting
 import (
 	"path/filepath"
 	"testing"
 	"github.com/stretchr/testify/assert"
 )
 func Test_getStorageMultipleName(t *testing.T) {
 	iniStr := `
 [lfs]
 S3_BUCKET = forge-lfs
 [attachment]
 S3_BUCKET = forge-attachment
 [storage]
 STORAGE_TYPE = s3
 S3_BUCKET = forge-storage
 `
 	cfg, err := NewConfigProviderFromData(iniStr)
 	assert.NoError(t, err)
 	assert.NoError(t, loadAttachmentFrom(cfg))
 	assert.Equal(t, "forge-attachment", Attachment.Storage.S3Config.Bucket)
 	assert.Equal(t, "attachments/", Attachment.Storage.S3Config.BasePath)
 	assert.NoError(t, loadLFSFrom(cfg))
 	assert.Equal(t, "forge-lfs", LFS.Storage.S3Config.Bucket)
 	assert.Equal(t, "lfs/", LFS.Storage.S3Config.BasePath)
 	assert.NoError(t, loadAvatarsFrom(cfg))
 	assert.Equal(t, "forge-storage", Avatar.Storage.S3Config.Bucket)
 	assert.Equal(t, "avatars/", Avatar.Storage.S3Config.BasePath)
 }
 func Test_getStorageS3(t *testing.T) {
 	// STORAGE_TYPE=s3 is the config surface for the S3-compatible client
 	// (hanzoai/s3 = SeaweedFS). Every object type inheriting the [storage]
 	// default resolves to it, and Storage.Type reports "s3" (so ServeDirect
 	// + the storage registry resolve).
 	iniStr := `
 [storage]
 STORAGE_TYPE = s3
 S3_BUCKET = git
 `
 	cfg, err := NewConfigProviderFromData(iniStr)
 	assert.NoError(t, err)
 	assert.True(t, IsValidStorageType("s3"))
 	assert.NoError(t, loadPackagesFrom(cfg))
 	assert.EqualValues(t, "s3", Packages.Storage.Type)
 	assert.Equal(t, "git", Packages.Storage.S3Config.Bucket)
 	assert.Equal(t, "packages/", Packages.Storage.S3Config.BasePath)
 	assert.NoError(t, loadAttachmentFrom(cfg))
 	assert.EqualValues(t, "s3", Attachment.Storage.Type)
 	assert.Equal(t, "git", Attachment.Storage.S3Config.Bucket)
 	assert.Equal(t, "attachments/", Attachment.Storage.S3Config.BasePath)
 	assert.NoError(t, loadLFSFrom(cfg))
 	assert.EqualValues(t, "s3", LFS.Storage.Type)
 	assert.Equal(t, "lfs/", LFS.Storage.S3Config.BasePath)
 	assert.NoError(t, loadActionsFrom(cfg))
 	assert.EqualValues(t, "s3", Actions.LogStorage.Type)
 	assert.Equal(t, "actions_log/", Actions.LogStorage.S3Config.BasePath)
 	assert.EqualValues(t, "s3", Actions.ArtifactStorage.Type)
 	assert.Equal(t, "actions_artifacts/", Actions.ArtifactStorage.S3Config.BasePath)
 }
 func Test_getStorageUseOtherNameAsType(t *testing.T) {
 	iniStr := `
 [attachment]
 STORAGE_TYPE = lfs
 [storage.lfs]
 STORAGE_TYPE = s3
 S3_BUCKET = forge-storage
 `
 	cfg, err := NewConfigProviderFromData(iniStr)
 	assert.NoError(t, err)
 	assert.NoError(t, loadAttachmentFrom(cfg))
 	assert.Equal(t, "forge-storage", Attachment.Storage.S3Config.Bucket)
 	assert.Equal(t, "attachments/", Attachment.Storage.S3Config.BasePath)
 	assert.NoError(t, loadLFSFrom(cfg))
 	assert.Equal(t, "forge-storage", LFS.Storage.S3Config.Bucket)
 	assert.Equal(t, "lfs/", LFS.Storage.S3Config.BasePath)
 }
 func Test_getStorageInheritStorageType(t *testing.T) {
 	iniStr := `
 [storage]
 STORAGE_TYPE = s3
 `
 	cfg, err := NewConfigProviderFromData(iniStr)
 	assert.NoError(t, err)
 	assert.NoError(t, loadPackagesFrom(cfg))
 	assert.EqualValues(t, "s3", Packages.Storage.Type)
 	assert.Equal(t, "forge", Packages.Storage.S3Config.Bucket)
 	assert.Equal(t, "packages/", Packages.Storage.S3Config.BasePath)
 	assert.NoError(t, loadRepoArchiveFrom(cfg))
 	assert.EqualValues(t, "s3", RepoArchive.Storage.Type)
 	assert.Equal(t, "forge", RepoArchive.Storage.S3Config.Bucket)
 	assert.Equal(t, "repo-archive/", RepoArchive.Storage.S3Config.BasePath)
 	assert.NoError(t, loadActionsFrom(cfg))
 	assert.EqualValues(t, "s3", Actions.LogStorage.Type)
 	assert.Equal(t, "forge", Actions.LogStorage.S3Config.Bucket)
 	assert.Equal(t, "actions_log/", Actions.LogStorage.S3Config.BasePath)
 	assert.EqualValues(t, "s3", Actions.ArtifactStorage.Type)
 	assert.Equal(t, "forge", Actions.ArtifactStorage.S3Config.Bucket)
 	assert.Equal(t, "actions_artifacts/", Actions.ArtifactStorage.S3Config.BasePath)
 	assert.NoError(t, loadAvatarsFrom(cfg))
 	assert.EqualValues(t, "s3", Avatar.Storage.Type)
 	assert.Equal(t, "forge", Avatar.Storage.S3Config.Bucket)
 	assert.Equal(t, "avatars/", Avatar.Storage.S3Config.BasePath)
 	assert.NoError(t, loadRepoAvatarFrom(cfg))
 	assert.EqualValues(t, "s3", RepoAvatar.Storage.Type)
 	assert.Equal(t, "forge", RepoAvatar.Storage.S3Config.Bucket)
 	assert.Equal(t, "repo-avatars/", RepoAvatar.Storage.S3Config.BasePath)
 }
 func Test_getStorageInheritStorageTypeAzureBlob(t *testing.T) {
 	iniStr := `
 [storage]
 STORAGE_TYPE = azureblob
 `
 	cfg, err := NewConfigProviderFromData(iniStr)
 	assert.NoError(t, err)
 	assert.NoError(t, loadPackagesFrom(cfg))
 	assert.EqualValues(t, "azureblob", Packages.Storage.Type)
 	assert.Equal(t, "forge", Packages.Storage.AzureBlobConfig.Container)
 	assert.Equal(t, "packages/", Packages.Storage.AzureBlobConfig.BasePath)
 	assert.NoError(t, loadRepoArchiveFrom(cfg))
 	assert.EqualValues(t, "azureblob", RepoArchive.Storage.Type)
 	assert.Equal(t, "forge", RepoArchive.Storage.AzureBlobConfig.Container)
 	assert.Equal(t, "repo-archive/", RepoArchive.Storage.AzureBlobConfig.BasePath)
 	assert.NoError(t, loadActionsFrom(cfg))
 	assert.EqualValues(t, "azureblob", Actions.LogStorage.Type)
 	assert.Equal(t, "forge", Actions.LogStorage.AzureBlobConfig.Container)
 	assert.Equal(t, "actions_log/", Actions.LogStorage.AzureBlobConfig.BasePath)
 	assert.EqualValues(t, "azureblob", Actions.ArtifactStorage.Type)
 	assert.Equal(t, "forge", Actions.ArtifactStorage.AzureBlobConfig.Container)
 	assert.Equal(t, "actions_artifacts/", Actions.ArtifactStorage.AzureBlobConfig.BasePath)
 	assert.NoError(t, loadAvatarsFrom(cfg))
 	assert.EqualValues(t, "azureblob", Avatar.Storage.Type)
 	assert.Equal(t, "forge", Avatar.Storage.AzureBlobConfig.Container)
 	assert.Equal(t, "avatars/", Avatar.Storage.AzureBlobConfig.BasePath)
 	assert.NoError(t, loadRepoAvatarFrom(cfg))
 	assert.EqualValues(t, "azureblob", RepoAvatar.Storage.Type)
 	assert.Equal(t, "forge", RepoAvatar.Storage.AzureBlobConfig.Container)
 	assert.Equal(t, "repo-avatars/", RepoAvatar.Storage.AzureBlobConfig.BasePath)
 }
 type testLocalStoragePathCase struct {
 	loader       func(rootCfg ConfigProvider) error
 	storagePtr   **Storage
 	expectedPath string
 }
 func testLocalStoragePath(t *testing.T, appDataPath, iniStr string, cases []testLocalStoragePathCase) {
 	cfg, err := NewConfigProviderFromData(iniStr)
 	assert.NoError(t, err)
 	AppDataPath = appDataPath
 	for _, c := range cases {
 		assert.NoError(t, c.loader(cfg))
 		storage := *c.storagePtr
 		assert.EqualValues(t, "local", storage.Type)
 		assert.True(t, filepath.IsAbs(storage.Path))
 		assert.Equal(t, filepath.Clean(c.expectedPath), filepath.Clean(storage.Path))
 	}
 }
 func Test_getStorageInheritStorageTypeLocal(t *testing.T) {
 	testLocalStoragePath(t, "/appdata", `
 [storage]
 STORAGE_TYPE = local
 `, []testLocalStoragePathCase{
 		{loadAttachmentFrom, &Attachment.Storage, "/appdata/attachments"},
 		{loadLFSFrom, &LFS.Storage, "/appdata/lfs"},
 		{loadActionsFrom, &Actions.ArtifactStorage, "/appdata/actions_artifacts"},
 		{loadPackagesFrom, &Packages.Storage, "/appdata/packages"},
 		{loadRepoArchiveFrom, &RepoArchive.Storage, "/appdata/repo-archive"},
 		{loadActionsFrom, &Actions.LogStorage, "/appdata/actions_log"},
 		{loadAvatarsFrom, &Avatar.Storage, "/appdata/avatars"},
 		{loadRepoAvatarFrom, &RepoAvatar.Storage, "/appdata/repo-avatars"},
 	})
 }
 func Test_getStorageInheritStorageTypeLocalPath(t *testing.T) {
 	testLocalStoragePath(t, "/appdata", `
 [storage]
 STORAGE_TYPE = local
 PATH = /data/forge
 `, []testLocalStoragePathCase{
 		{loadAttachmentFrom, &Attachment.Storage, "/data/forge/attachments"},
 		{loadLFSFrom, &LFS.Storage, "/data/forge/lfs"},
 		{loadActionsFrom, &Actions.ArtifactStorage, "/data/forge/actions_artifacts"},
 		{loadPackagesFrom, &Packages.Storage, "/data/forge/packages"},
 		{loadRepoArchiveFrom, &RepoArchive.Storage, "/data/forge/repo-archive"},
 		{loadActionsFrom, &Actions.LogStorage, "/data/forge/actions_log"},
 		{loadAvatarsFrom, &Avatar.Storage, "/data/forge/avatars"},
 		{loadRepoAvatarFrom, &RepoAvatar.Storage, "/data/forge/repo-avatars"},
 	})
 }
 func Test_getStorageInheritStorageTypeLocalRelativePath(t *testing.T) {
 	testLocalStoragePath(t, "/appdata", `
 [storage]
 STORAGE_TYPE = local
 PATH = storages
 `, []testLocalStoragePathCase{
 		{loadAttachmentFrom, &Attachment.Storage, "/appdata/storages/attachments"},
 		{loadLFSFrom, &LFS.Storage, "/appdata/storages/lfs"},
 		{loadActionsFrom, &Actions.ArtifactStorage, "/appdata/storages/actions_artifacts"},
 		{loadPackagesFrom, &Packages.Storage, "/appdata/storages/packages"},
 		{loadRepoArchiveFrom, &RepoArchive.Storage, "/appdata/storages/repo-archive"},
 		{loadActionsFrom, &Actions.LogStorage, "/appdata/storages/actions_log"},
 		{loadAvatarsFrom, &Avatar.Storage, "/appdata/storages/avatars"},
 		{loadRepoAvatarFrom, &RepoAvatar.Storage, "/appdata/storages/repo-avatars"},
 	})
 }
 func Test_getStorageInheritStorageTypeLocalPathOverride(t *testing.T) {
 	testLocalStoragePath(t, "/appdata", `
 [storage]
 STORAGE_TYPE = local
 PATH = /data/forge
 [repo-archive]
 PATH = /data/forge/the-archives-dir
 `, []testLocalStoragePathCase{
 		{loadAttachmentFrom, &Attachment.Storage, "/data/forge/attachments"},
 		{loadLFSFrom, &LFS.Storage, "/data/forge/lfs"},
 		{loadActionsFrom, &Actions.ArtifactStorage, "/data/forge/actions_artifacts"},
 		{loadPackagesFrom, &Packages.Storage, "/data/forge/packages"},
 		{loadRepoArchiveFrom, &RepoArchive.Storage, "/data/forge/the-archives-dir"},
 		{loadActionsFrom, &Actions.LogStorage, "/data/forge/actions_log"},
 		{loadAvatarsFrom, &Avatar.Storage, "/data/forge/avatars"},
 		{loadRepoAvatarFrom, &RepoAvatar.Storage, "/data/forge/repo-avatars"},
 	})
 }
 func Test_getStorageInheritStorageTypeLocalPathOverrideEmpty(t *testing.T) {
 	testLocalStoragePath(t, "/appdata", `
 [storage]
 STORAGE_TYPE = local
 PATH = /data/forge
 [repo-archive]
 `, []testLocalStoragePathCase{
 		{loadAttachmentFrom, &Attachment.Storage, "/data/forge/attachments"},
 		{loadLFSFrom, &LFS.Storage, "/data/forge/lfs"},
 		{loadActionsFrom, &Actions.ArtifactStorage, "/data/forge/actions_artifacts"},
 		{loadPackagesFrom, &Packages.Storage, "/data/forge/packages"},
 		{loadRepoArchiveFrom, &RepoArchive.Storage, "/data/forge/repo-archive"},
 		{loadActionsFrom, &Actions.LogStorage, "/data/forge/actions_log"},
 		{loadAvatarsFrom, &Avatar.Storage, "/data/forge/avatars"},
 		{loadRepoAvatarFrom, &RepoAvatar.Storage, "/data/forge/repo-avatars"},
 	})
 }
 func Test_getStorageInheritStorageTypeLocalRelativePathOverride(t *testing.T) {
 	testLocalStoragePath(t, "/appdata", `
 [storage]
 STORAGE_TYPE = local
 PATH = /data/forge
 [repo-archive]
 PATH = the-archives-dir
 `, []testLocalStoragePathCase{
 		{loadAttachmentFrom, &Attachment.Storage, "/data/forge/attachments"},
 		{loadLFSFrom, &LFS.Storage, "/data/forge/lfs"},
 		{loadActionsFrom, &Actions.ArtifactStorage, "/data/forge/actions_artifacts"},
 		{loadPackagesFrom, &Packages.Storage, "/data/forge/packages"},
 		{loadRepoArchiveFrom, &RepoArchive.Storage, "/data/forge/the-archives-dir"},
 		{loadActionsFrom, &Actions.LogStorage, "/data/forge/actions_log"},
 		{loadAvatarsFrom, &Avatar.Storage, "/data/forge/avatars"},
 		{loadRepoAvatarFrom, &RepoAvatar.Storage, "/data/forge/repo-avatars"},
 	})
 }
 func Test_getStorageInheritStorageTypeLocalPathOverride3(t *testing.T) {
 	testLocalStoragePath(t, "/appdata", `
 [storage.repo-archive]
 STORAGE_TYPE = local
 PATH = /data/forge/archives
 `, []testLocalStoragePathCase{
 		{loadAttachmentFrom, &Attachment.Storage, "/appdata/attachments"},
 		{loadLFSFrom, &LFS.Storage, "/appdata/lfs"},
 		{loadActionsFrom, &Actions.ArtifactStorage, "/appdata/actions_artifacts"},
 		{loadPackagesFrom, &Packages.Storage, "/appdata/packages"},
 		{loadRepoArchiveFrom, &RepoArchive.Storage, "/data/forge/archives"},
 		{loadActionsFrom, &Actions.LogStorage, "/appdata/actions_log"},
 		{loadAvatarsFrom, &Avatar.Storage, "/appdata/avatars"},
 		{loadRepoAvatarFrom, &RepoAvatar.Storage, "/appdata/repo-avatars"},
 	})
 }
 func Test_getStorageInheritStorageTypeLocalPathOverride3_5(t *testing.T) {
 	testLocalStoragePath(t, "/appdata", `
 [storage.repo-archive]
 STORAGE_TYPE = local
 PATH = a-relative-path
 `, []testLocalStoragePathCase{
 		{loadAttachmentFrom, &Attachment.Storage, "/appdata/attachments"},
 		{loadLFSFrom, &LFS.Storage, "/appdata/lfs"},
 		{loadActionsFrom, &Actions.ArtifactStorage, "/appdata/actions_artifacts"},
 		{loadPackagesFrom, &Packages.Storage, "/appdata/packages"},
 		{loadRepoArchiveFrom, &RepoArchive.Storage, "/appdata/a-relative-path"},
 		{loadActionsFrom, &Actions.LogStorage, "/appdata/actions_log"},
 		{loadAvatarsFrom, &Avatar.Storage, "/appdata/avatars"},
 		{loadRepoAvatarFrom, &RepoAvatar.Storage, "/appdata/repo-avatars"},
 	})
 }
 func Test_getStorageInheritStorageTypeLocalPathOverride4(t *testing.T) {
 	testLocalStoragePath(t, "/appdata", `
 [storage.repo-archive]
 STORAGE_TYPE = local
 PATH = /data/forge/archives
 [repo-archive]
 PATH = /tmp/forge/archives
 `, []testLocalStoragePathCase{
 		{loadAttachmentFrom, &Attachment.Storage, "/appdata/attachments"},
 		{loadLFSFrom, &LFS.Storage, "/appdata/lfs"},
 		{loadActionsFrom, &Actions.ArtifactStorage, "/appdata/actions_artifacts"},
 		{loadPackagesFrom, &Packages.Storage, "/appdata/packages"},
 		{loadRepoArchiveFrom, &RepoArchive.Storage, "/tmp/forge/archives"},
 		{loadActionsFrom, &Actions.LogStorage, "/appdata/actions_log"},
 		{loadAvatarsFrom, &Avatar.Storage, "/appdata/avatars"},
 		{loadRepoAvatarFrom, &RepoAvatar.Storage, "/appdata/repo-avatars"},
 	})
 }
 func Test_getStorageInheritStorageTypeLocalPathOverride5(t *testing.T) {
 	testLocalStoragePath(t, "/appdata", `
 [storage.repo-archive]
 STORAGE_TYPE = local
 PATH = /data/forge/archives
 [repo-archive]
 `, []testLocalStoragePathCase{
 		{loadAttachmentFrom, &Attachment.Storage, "/appdata/attachments"},
 		{loadLFSFrom, &LFS.Storage, "/appdata/lfs"},
 		{loadActionsFrom, &Actions.ArtifactStorage, "/appdata/actions_artifacts"},
 		{loadPackagesFrom, &Packages.Storage, "/appdata/packages"},
 		{loadRepoArchiveFrom, &RepoArchive.Storage, "/data/forge/archives"},
 		{loadActionsFrom, &Actions.LogStorage, "/appdata/actions_log"},
 		{loadAvatarsFrom, &Avatar.Storage, "/appdata/avatars"},
 		{loadRepoAvatarFrom, &RepoAvatar.Storage, "/appdata/repo-avatars"},
 	})
 }
 func Test_getStorageInheritStorageTypeLocalPathOverride72(t *testing.T) {
 	testLocalStoragePath(t, "/appdata", `
 [repo-archive]
 STORAGE_TYPE = local
 PATH = archives
 `, []testLocalStoragePathCase{
 		{loadRepoArchiveFrom, &RepoArchive.Storage, "/appdata/archives"},
 	})
 }
 func Test_getStorageConfiguration20(t *testing.T) {
 	cfg, err := NewConfigProviderFromData(`
 [repo-archive]
 STORAGE_TYPE = my_storage
 PATH = archives
 `)
 	assert.NoError(t, err)
 	assert.Error(t, loadRepoArchiveFrom(cfg))
 }
 func Test_getStorageConfiguration21(t *testing.T) {
 	testLocalStoragePath(t, "/appdata", `
 [storage.repo-archive]
 `, []testLocalStoragePathCase{
 		{loadRepoArchiveFrom, &RepoArchive.Storage, "/appdata/repo-archive"},
 	})
 }
 func Test_getStorageConfiguration22(t *testing.T) {
 	testLocalStoragePath(t, "/appdata", `
 [storage.repo-archive]
 PATH = archives
 `, []testLocalStoragePathCase{
 		{loadRepoArchiveFrom, &RepoArchive.Storage, "/appdata/archives"},
 	})
 }
 func Test_getStorageConfiguration23(t *testing.T) {
 	cfg, err := NewConfigProviderFromData(`
 [repo-archive]
 STORAGE_TYPE = s3
 S3_ACCESS_KEY_ID = my_access_key
 S3_SECRET_ACCESS_KEY = my_secret_key
 `)
 	assert.NoError(t, err)
 	_, err = getStorage(cfg, "", "", nil)
 	assert.Error(t, err)
 	assert.NoError(t, loadRepoArchiveFrom(cfg))
 	cp := RepoArchive.Storage.ToShadowCopy()
 	assert.Equal(t, "******", cp.S3Config.AccessKeyID)
 	assert.Equal(t, "******", cp.S3Config.SecretAccessKey)
 }
 func Test_getStorageConfiguration24(t *testing.T) {
 	cfg, err := NewConfigProviderFromData(`
 [repo-archive]
 STORAGE_TYPE = my_archive
 [storage.my_archive]
 ; unsupported, storage type should be defined explicitly
 PATH = archives
 `)
 	assert.NoError(t, err)
 	assert.Error(t, loadRepoArchiveFrom(cfg))
 }
 func Test_getStorageConfiguration25(t *testing.T) {
 	cfg, err := NewConfigProviderFromData(`
 [repo-archive]
 STORAGE_TYPE = my_archive
 [storage.my_archive]
 ; unsupported, storage type should be known type
 STORAGE_TYPE = unknown // should be local or s3
 PATH = archives
 `)
 	assert.NoError(t, err)
 	assert.Error(t, loadRepoArchiveFrom(cfg))
 }
 func Test_getStorageConfiguration26(t *testing.T) {
 	cfg, err := NewConfigProviderFromData(`
 [repo-archive]
 STORAGE_TYPE = s3
 S3_ACCESS_KEY_ID = my_access_key
 S3_SECRET_ACCESS_KEY = my_secret_key
 ; wrong configuration
 S3_USE_SSL = abc
 `)
 	assert.NoError(t, err)
 	// assert.Error(t, loadRepoArchiveFrom(cfg))
 	// FIXME: this should return error but now ini package's MapTo() doesn't check type
 	assert.NoError(t, loadRepoArchiveFrom(cfg))
 }
 func Test_getStorageConfiguration27(t *testing.T) {
 	cfg, err := NewConfigProviderFromData(`
 [storage.repo-archive]
 STORAGE_TYPE = s3
 S3_ACCESS_KEY_ID = my_access_key
 S3_SECRET_ACCESS_KEY = my_secret_key
 S3_USE_SSL = true
 `)
 	assert.NoError(t, err)
 	assert.NoError(t, loadRepoArchiveFrom(cfg))
 	assert.Equal(t, "my_access_key", RepoArchive.Storage.S3Config.AccessKeyID)
 	assert.Equal(t, "my_secret_key", RepoArchive.Storage.S3Config.SecretAccessKey)
 	assert.True(t, RepoArchive.Storage.S3Config.UseSSL)
 	assert.Equal(t, "repo-archive/", RepoArchive.Storage.S3Config.BasePath)
 }
 func Test_getStorageConfiguration28(t *testing.T) {
 	cfg, err := NewConfigProviderFromData(`
 [storage]
 STORAGE_TYPE = s3
 S3_ACCESS_KEY_ID = my_access_key
 S3_SECRET_ACCESS_KEY = my_secret_key
 S3_USE_SSL = true
 S3_BASE_PATH = /prefix
 `)
 	assert.NoError(t, err)
 	assert.NoError(t, loadRepoArchiveFrom(cfg))
 	assert.Equal(t, "my_access_key", RepoArchive.Storage.S3Config.AccessKeyID)
 	assert.Equal(t, "my_secret_key", RepoArchive.Storage.S3Config.SecretAccessKey)
 	assert.True(t, RepoArchive.Storage.S3Config.UseSSL)
 	assert.Equal(t, "/prefix/repo-archive/", RepoArchive.Storage.S3Config.BasePath)
 	cfg, err = NewConfigProviderFromData(`
 [storage]
 STORAGE_TYPE = s3
 S3_IAM_ENDPOINT = 127.0.0.1
 S3_USE_SSL = true
 S3_BASE_PATH = /prefix
 `)
 	assert.NoError(t, err)
 	assert.NoError(t, loadRepoArchiveFrom(cfg))
 	assert.Equal(t, "127.0.0.1", RepoArchive.Storage.S3Config.IamEndpoint)
 	assert.True(t, RepoArchive.Storage.S3Config.UseSSL)
 	assert.Equal(t, "/prefix/repo-archive/", RepoArchive.Storage.S3Config.BasePath)
 	cfg, err = NewConfigProviderFromData(`
 [storage]
 STORAGE_TYPE = s3
 S3_ACCESS_KEY_ID = my_access_key
 S3_SECRET_ACCESS_KEY = my_secret_key
 S3_USE_SSL = true
 S3_BASE_PATH = /prefix
 [lfs]
 S3_BASE_PATH = /lfs
 `)
 	assert.NoError(t, err)
 	assert.NoError(t, loadLFSFrom(cfg))
 	assert.Equal(t, "my_access_key", LFS.Storage.S3Config.AccessKeyID)
 	assert.Equal(t, "my_secret_key", LFS.Storage.S3Config.SecretAccessKey)
 	assert.True(t, LFS.Storage.S3Config.UseSSL)
 	assert.Equal(t, "/lfs", LFS.Storage.S3Config.BasePath)
 	cfg, err = NewConfigProviderFromData(`
 [storage]
 STORAGE_TYPE = s3
 S3_ACCESS_KEY_ID = my_access_key
 S3_SECRET_ACCESS_KEY = my_secret_key
 S3_USE_SSL = true
 S3_BASE_PATH = /prefix
 [storage.lfs]
 S3_BASE_PATH = /lfs
 `)
 	assert.NoError(t, err)
 	assert.NoError(t, loadLFSFrom(cfg))
 	assert.Equal(t, "my_access_key", LFS.Storage.S3Config.AccessKeyID)
 	assert.Equal(t, "my_secret_key", LFS.Storage.S3Config.SecretAccessKey)
 	assert.True(t, LFS.Storage.S3Config.UseSSL)
 	assert.Equal(t, "/lfs", LFS.Storage.S3Config.BasePath)
 }
 func Test_getStorageConfiguration29(t *testing.T) {
 	cfg, err := NewConfigProviderFromData(`
 [repo-archive]
 STORAGE_TYPE = azureblob
 AZURE_BLOB_ACCOUNT_NAME = my_account_name
 AZURE_BLOB_ACCOUNT_KEY = my_account_key
 `)
 	assert.NoError(t, err)
 	// assert.Error(t, loadRepoArchiveFrom(cfg))
 	// FIXME: this should return error but now ini package's MapTo() doesn't check type
 	assert.NoError(t, loadRepoArchiveFrom(cfg))
 }
 func Test_getStorageConfiguration30(t *testing.T) {
 	cfg, err := NewConfigProviderFromData(`
 [storage.repo-archive]
 STORAGE_TYPE = azureblob
 AZURE_BLOB_ACCOUNT_NAME = my_account_name
 AZURE_BLOB_ACCOUNT_KEY = my_account_key
 `)
 	assert.NoError(t, err)
 	assert.NoError(t, loadRepoArchiveFrom(cfg))
 	assert.Equal(t, "my_account_name", RepoArchive.Storage.AzureBlobConfig.AccountName)
 	assert.Equal(t, "my_account_key", RepoArchive.Storage.AzureBlobConfig.AccountKey)
 	assert.Equal(t, "repo-archive/", RepoArchive.Storage.AzureBlobConfig.BasePath)
 }
 func Test_getStorageConfiguration31(t *testing.T) {
 	cfg, err := NewConfigProviderFromData(`
 [storage]
 STORAGE_TYPE = azureblob
 AZURE_BLOB_ACCOUNT_NAME = my_account_name
 AZURE_BLOB_ACCOUNT_KEY = my_account_key
 AZURE_BLOB_BASE_PATH = /prefix
 `)
 	assert.NoError(t, err)
 	assert.NoError(t, loadRepoArchiveFrom(cfg))
 	assert.Equal(t, "my_account_name", RepoArchive.Storage.AzureBlobConfig.AccountName)
 	assert.Equal(t, "my_account_key", RepoArchive.Storage.AzureBlobConfig.AccountKey)
 	assert.Equal(t, "/prefix/repo-archive/", RepoArchive.Storage.AzureBlobConfig.BasePath)
 	cfg, err = NewConfigProviderFromData(`
 [storage]
 STORAGE_TYPE = azureblob
 AZURE_BLOB_ACCOUNT_NAME = my_account_name
 AZURE_BLOB_ACCOUNT_KEY = my_account_key
 AZURE_BLOB_BASE_PATH = /prefix
 [lfs]
 AZURE_BLOB_BASE_PATH = /lfs
 `)
 	assert.NoError(t, err)
 	assert.NoError(t, loadLFSFrom(cfg))
 	assert.Equal(t, "my_account_name", LFS.Storage.AzureBlobConfig.AccountName)
 	assert.Equal(t, "my_account_key", LFS.Storage.AzureBlobConfig.AccountKey)
 	assert.Equal(t, "/lfs", LFS.Storage.AzureBlobConfig.BasePath)
 	cfg, err = NewConfigProviderFromData(`
 [storage]
 STORAGE_TYPE = azureblob
 AZURE_BLOB_ACCOUNT_NAME = my_account_name
 AZURE_BLOB_ACCOUNT_KEY = my_account_key
 AZURE_BLOB_BASE_PATH = /prefix
 [storage.lfs]
 AZURE_BLOB_BASE_PATH = /lfs
 `)
 	assert.NoError(t, err)
 	assert.NoError(t, loadLFSFrom(cfg))
 	assert.Equal(t, "my_account_name", LFS.Storage.AzureBlobConfig.AccountName)
 	assert.Equal(t, "my_account_key", LFS.Storage.AzureBlobConfig.AccountKey)
 	assert.Equal(t, "/lfs", LFS.Storage.AzureBlobConfig.BasePath)
 }

629 lines 22 KiB Go Raw Permalink Blame History

629 lines

22 KiB

Go

Raw Permalink Blame History