Function TestOpenBaseDBFilePersistence

server/server_test.go:595–630

(t *testing.T)

		return
	}
	if !strings.Contains(err.Error(), "unsupported ACME DNS provider") {
		t.Fatalf("expected unsupported provider error, got: %v", err)
	}
}

func TestNewRejectsACMEDNSProviderWithoutDomain(t *testing.T) {
	_, err := New(Config{
		ACMEDNSProvider: "route53",
	})
	if err == nil {
		t.Fatal("expected error when ACME DNS provider is set without ACME domain")
		return
	}
	if !strings.Contains(err.Error(), "ACME DNS provider requires ACME domain") {
		t.Fatalf("expected missing domain error, got: %v", err)
	}
}

func TestStartCredentialRefresh_RollbackAndRetryWhenNoActiveTransaction(t *testing.T) {
	oldInterval := credentialRefreshInterval
	credentialRefreshInterval = 5 * time.Millisecond
	defer func() { credentialRefreshInterval = oldInterval }()

	execer := &mockRefreshExecer{
		secretErrFn: func(callNum int) error {
			if callNum == 1 {
				return errors.New("TransactionContext Error: Current transaction is aborted (please ROLLBACK)")
			}
			return nil
		},
	}

	stop := StartCredentialRefresh(execer, DuckLakeConfig{
		ObjectStore: "s3://bucket/path/",
		S3Provider:  "credential_chain",
	}, func() bool { return false })

	waitForCalls(t, 250*time.Millisecond, func() bool {
		secretCalls, rollbackCalls := execer.calls()