String converters.

lib/typing/converters/converters.go

@@ -0,0 +1,33 @@
+package converters
+
+import (
+	"fmt"
+
+	"github.com/artie-labs/transfer/lib/typing"
+
+	"github.com/artie-labs/transfer/lib/typing/ext"
+)
+
+type StringConverter interface {
+	Convert(value any) (string, error)
+}
+
+func GetStringConverter(kd typing.KindDetails) (StringConverter, error) {
+	switch kd.Kind {
+	case typing.Date.Kind:
+		return DateStringConverter{}, nil
+	}
+
+	return nil, nil
+}
+
+type DateStringConverter struct{}
+
+func (DateStringConverter) Convert(value any) (string, error) {
+	_time, err := ext.ParseDateFromAny(value)
+	if err != nil {
+		return "", fmt.Errorf("failed to cast colVal as date, colVal: '%v', err: %w", value, err)
+	}
+
+	return _time.Format(ext.PostgresDateFormat), nil
+}

lib/typing/values/string.go

@@ -8,6 +8,8 @@ import (
 	"strings"
 	"time"
 
+	"github.com/artie-labs/transfer/lib/typing/converters"
+
 	"github.com/artie-labs/transfer/lib/config/constants"
 	"github.com/artie-labs/transfer/lib/stringutil"
 	"github.com/artie-labs/transfer/lib/typing"
@@ -36,14 +38,17 @@ func ToString(colVal any, colKind typing.KindDetails) (string, error) {
 		return "", fmt.Errorf("colVal is nil")
 	}
 
-	switch colKind.Kind {
-	case typing.Date.Kind:
-		_time, err := ext.ParseDateFromAny(colVal)
-		if err != nil {
-			return "", fmt.Errorf("failed to cast colVal as date, colVal: '%v', err: %w", colVal, err)
-		}
+	sv, err := converters.GetStringConverter(colKind)
+	if err != nil {
+		return "", fmt.Errorf("failed to get string converter: %w", err)
+	}
+
+	// Prioritize converters
+	if sv != nil {
+		return sv.Convert(colVal)
+	}
 
-		return _time.Format(ext.PostgresDateFormat), nil
+	switch colKind.Kind {
 	case typing.Time.Kind:
 		_time, err := ext.ParseTimeFromAny(colVal)
 		if err != nil {