fix: Add custom error

internal/pkg/service/stream/sink/type/tablesink/keboola/bridge/slice.go

@@ -12,6 +12,7 @@ import (
 	"github.com/keboola/keboola-as-code/internal/pkg/service/stream/storage/level/local/diskreader"
 	"github.com/keboola/keboola-as-code/internal/pkg/service/stream/storage/model"
 	"github.com/keboola/keboola-as-code/internal/pkg/service/stream/storage/statistics"
+	"github.com/keboola/keboola-as-code/internal/pkg/utils/errors"
 )
 
 func (b *Bridge) uploadSlice(ctx context.Context, volume *diskreader.Volume, slice plugin.Slice, stats statistics.Value) error {
@@ -75,6 +76,10 @@ func (b *Bridge) uploadSlice(ctx context.Context, volume *diskreader.Volume, sli
 	// Decrypt file upload credentials
 	var credentials keboola.FileUploadCredentials
 	if keboolaFile.EncryptedCredentials != nil {
+		if b.credentialsEncryptor == nil {
+			return errors.New("missing credentials encryptor")
+		}
+
 		fileMetadata := cloudencrypt.Metadata{"file": slice.FileKey.String()}
 		credentials, err = b.credentialsEncryptor.Decrypt(ctx, keboolaFile.EncryptedCredentials, fileMetadata)
 		if err != nil {

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)
 	}