fix: Add custom error

keboola · Dec 17, 2024 · 3676be8 · 3676be8
1 parent e307174
commit 3676be8
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/internal/pkg/service/stream/sink/type/tablesink/keboola/token.go b/internal/pkg/service/stream/sink/type/tablesink/keboola/token.go
@@ -7,6 +7,7 @@ import (
 	"github.com/keboola/go-cloud-encrypt/pkg/cloudencrypt"
 
 	"github.com/keboola/keboola-as-code/internal/pkg/service/stream/definition/key"
+	"github.com/keboola/keboola-as-code/internal/pkg/utils/errors"
 )
 
 // Token is a Storage API Token used to create staging files and import files to the target table.
@@ -27,6 +28,10 @@ func (token Token) ID() string {
 
 func (token Token) DecryptToken(ctx context.Context, encryptor *cloudencrypt.GenericEncryptor[keboola.Token], metadata cloudencrypt.Metadata) (keboola.Token, error) {
 	if token.EncryptedToken != nil {
+		if encryptor == nil {
+			return keboola.Token{}, errors.New("missing token encryptor")
+		}
+
 		return encryptor.Decrypt(ctx, token.EncryptedToken, metadata)
 	}