Merge pull request #563 from slingdata-io/v1.4.9

flarco · web-flow · commit 1324ca2359b0 · 2025-05-24T21:56:38.000-03:00
V1.4.9
diff --git a/.gitignore b/.gitignore
@@ -31,6 +31,7 @@ cmd/sling/tests/replications/r.test.yaml
 cmd/sling/tests/pipelines/p.test.yaml
 
 *..go
+*..md
 *__test.go
 
 appicon.png
diff --git a/cmd/sling/resource/examples.sh b/cmd/sling/resource/examples.sh
diff --git a/cmd/sling/sling_cli.go b/cmd/sling/sling_cli.go
@@ -26,19 +26,14 @@ import (
 	"github.com/spf13/cast"
 )
 
-//go:embed examples.sh
-var slingFolder embed.FS
+//go:embed resource/*
+var slingResources embed.FS
 var (
 	examples    = ``
 	ctx         = g.NewContext(context.Background())
 	telemetry   = true
 	interrupted = false
 	machineID   = ""
-	telProps    = g.M(
-		"application", "sling-cli",
-		"version", core.Version,
-		"os", runtime.GOOS+"/"+runtime.GOARCH,
-	)
 )
 
 func init() {
@@ -405,7 +400,7 @@ func init() {
 	}
 
 	// collect examples
-	examplesBytes, _ := slingFolder.ReadFile("examples.sh")
+	examplesBytes, _ := slingResources.ReadFile("resource/examples.sh")
 	examples = string(examplesBytes)
 
 	cliConns.Make().Add()
@@ -433,7 +428,7 @@ func Track(event string, props ...map[string]interface{}) {
 		"user_id", machineID,
 	)
 
-	for k, v := range telProps {
+	for k, v := range core.TelProps {
 		properties[k] = v
 	}
 
diff --git a/cmd/sling/sling_run.go b/cmd/sling/sling_run.go
@@ -6,13 +6,15 @@ import (
 	"os"
 	"path"
 	"path/filepath"
+	"runtime"
 	"runtime/debug"
 	"strings"
 	"time"
 
 	"gopkg.in/yaml.v2"
 
 	"github.com/shirou/gopsutil/v3/mem"
+	"github.com/slingdata-io/sling-cli/core"
 	"github.com/slingdata-io/sling-cli/core/dbio/connection"
 	"github.com/slingdata-io/sling-cli/core/env"
 	"github.com/slingdata-io/sling-cli/core/sling"
@@ -208,7 +210,9 @@ func processRun(c *g.CliSC) (ok bool, err error) {
 runReplication:
 	defer connection.CloseAll()
 
-	g.Info(g.Colorize(g.ColorCyan, "Sling CLI | https://slingdata.io"))
+	if !cast.ToBool(os.Getenv("SLING_THREAD_CHILD")) {
+		g.Info(g.Colorize(g.ColorCyan, "Sling CLI | https://slingdata.io"))
+	}
 
 	if pipelineCfgPath != "" {
 		err = runPipeline(pipelineCfgPath)
@@ -568,6 +572,8 @@ func replicationRun(cfgPath string, cfgOverwrite *sling.Config, selectStreams ..
 }
 
 func runPipeline(pipelineCfgPath string) (err error) {
+	g.DebugLow("Sling version: %s (%s %s)", core.Version, runtime.GOOS, runtime.GOARCH)
+
 	pipeline, err := sling.LoadPipelineConfigFromFile(pipelineCfgPath)
 	if err != nil {
 		return g.Error(err, "could not load pipeline: %s", pipelineCfgPath)
diff --git a/cmd/sling/sling_update.go b/cmd/sling/sling_update.go
@@ -154,7 +154,9 @@ func upgradeBrew() (err error) {
 }
 
 func upgradeScoop() (err error) {
-	g.Info("Sling was installed with scoop. Running `scoop update sling`")
+	g.Warn("Sling was installed with scoop. Try running `scoop update sling`")
+	return nil
+	// errors with "sling" is still running. Need to install manually
 
 	proc, err := process.NewProc("scoop")
 	if err != nil {
diff --git a/core/dbio/database/database.go b/core/dbio/database/database.go
@@ -704,6 +704,7 @@ func (conn *BaseConn) Connect(timeOut ...int) (err error) {
 	}
 
 	conn.SetProp("connected", "true")
+	conn.SetProp("connect_time", cast.ToString(time.Now()))
 
 	return nil
 }
diff --git a/core/dbio/database/database_athena.go b/core/dbio/database/database_athena.go
@@ -154,6 +154,7 @@ func (conn *AthenaConn) Connect(timeOut ...int) (err error) {
 	}
 
 	conn.SetProp("connected", "true")
+	conn.SetProp("connect_time", cast.ToString(time.Now()))
 
 	if !cast.ToBool(conn.GetProp("silent")) {
 		g.Debug(`opened "%s" connection (%s)`, conn.Type, conn.GetProp("sling_conn_id"))
diff --git a/core/dbio/database/database_bigtable.go b/core/dbio/database/database_bigtable.go
@@ -176,6 +176,7 @@ func (conn *BigTableConn) Connect(timeOut ...int) error {
 	}
 
 	conn.SetProp("connected", "true")
+	conn.SetProp("connect_time", cast.ToString(time.Now()))
 
 	return nil
 }
diff --git a/core/dbio/database/database_d1.go b/core/dbio/database/database_d1.go
@@ -128,6 +128,7 @@ func (conn *D1Conn) Connect(timeOut ...int) (err error) {
 	}
 
 	conn.SetProp("connected", "true")
+	conn.SetProp("connect_time", cast.ToString(time.Now()))
 
 	return nil
 }
diff --git a/core/dbio/database/database_duckdb.go b/core/dbio/database/database_duckdb.go
@@ -125,6 +125,7 @@ func (conn *DuckDbConn) Connect(timeOut ...int) (err error) {
 	g.Debug(`opened "%s" connection (%s)`, conn.Type, conn.GetProp("sling_conn_id"))
 
 	conn.SetProp("connected", "true")
+	conn.SetProp("connect_time", cast.ToString(time.Now()))
 
 	if conn.GetType() == dbio.TypeDbMotherDuck {
 		_, err = conn.Exec("SET autoinstall_known_extensions=1; SET autoload_known_extensions=1;" + noDebugKey)
diff --git a/core/dbio/database/database_elasticsearch.go b/core/dbio/database/database_elasticsearch.go
@@ -118,6 +118,7 @@ func (conn *ElasticsearchConn) Connect(timeOut ...int) error {
 	}
 
 	conn.SetProp("connected", "true")
+	conn.SetProp("connect_time", cast.ToString(time.Now()))
 
 	return nil
 }
diff --git a/core/dbio/database/database_mongo.go b/core/dbio/database/database_mongo.go
@@ -93,6 +93,7 @@ func (conn *MongoDBConn) Connect(timeOut ...int) error {
 	}
 
 	conn.SetProp("connected", "true")
+	conn.SetProp("connect_time", cast.ToString(time.Now()))
 
 	return nil
 }
diff --git a/core/dbio/database/database_redshift.go b/core/dbio/database/database_redshift.go
@@ -295,6 +295,17 @@ func (conn *RedshiftConn) BulkImportFlow(tableFName string, df *iop.Dataflow) (c
 	}
 	g.DebugLow("total written: %s to %s", humanize.Bytes(cast.ToUint64(bw)), s3Path)
 
+	// Close and re-establish connection to Redshift to avoid timeout
+	connectTime := cast.ToTime(conn.GetProp("connect_time"))
+	if time.Since(connectTime) > 10*time.Minute {
+		g.Debug("re-establishing redshift connection before COPY command")
+		conn.Close()
+		err = conn.Connect()
+		if err != nil {
+			return df.Count(), g.Error(err, "error reconnecting to redshift before COPY command")
+		}
+	}
+
 	_, err = conn.CopyFromS3(tableFName, s3Path, df.Columns)
 	if err != nil {
 		return df.Count(), g.Error(err, "error copying into redshift from s3")
diff --git a/core/dbio/filesys/fs_ftp.go b/core/dbio/filesys/fs_ftp.go
@@ -228,7 +228,7 @@ func (fs *FtpFileSysClient) List(url string) (nodes FileNodes, err error) {
 
 		// replace double slash issue
 		node.URI = fs.cleanUpNodeURI(node.URI)
-		nodes.Add(node)
+		nodes.AddWhere(pattern, 0, node)
 	}
 
 	return
diff --git a/core/dbio/iop/datastream.go b/core/dbio/iop/datastream.go
@@ -1325,7 +1325,20 @@ func (ds *Datastream) ConsumeCsvReaderChl(readerChn chan *ReaderReady) (err erro
 			// remake row in proper order. row has new structure
 			correctRow := make([]string, len(it.ds.Columns))
 			for incorrectI, correctI := range colMap {
-				correctRow[correctI] = row[incorrectI]
+				// Ensure the target index correctI is valid for correctRow (current schema length)
+				if correctI < len(correctRow) {
+					// Ensure the source index incorrectI is valid for the current data row's length
+					if incorrectI < len(row) {
+						correctRow[correctI] = row[incorrectI]
+					}
+				} else {
+					// This would indicate a schema synchronization issue where colMap's target index
+					// is out of bounds for the current datastream schema size (len(it.ds.Columns)).
+					// This case should ideally not be hit if schema updates are perfectly synchronized.
+					err = g.Error("CSV Schema inconsistency at row #%d (%s): colMap index %d is out of bounds for current schema length %d for column '%s'. Here are all the columns detected: %s", it.Counter+1, ds.Metadata.StreamURL.Value, correctI, len(correctRow), it.ds.Columns.Names()[correctI], g.Marshal(it.ds.Columns.Names()))
+					it.ds.Context.CaptureErr(err)
+					return false
+				}
 			}
 			row = correctRow
 		}
diff --git a/core/dbio/iop/datatype.go b/core/dbio/iop/datatype.go
@@ -563,6 +563,10 @@ func (cols Columns) Coerce(castCols Columns, hasHeader bool, casing ColumnCasing
 	newCols = newCols.ValidateNames(tgtType)
 
 	for i, col := range newCols {
+		if strings.HasPrefix(col.Description, "Sling.Metadata.") {
+			continue // do not modify metadata type
+		}
+
 		if !hasHeader && len(castCols) == len(newCols) {
 			// assume same order since same number of columns and no header
 			col = castCols[i]
diff --git a/core/dbio/templates/types_native_to_general.tsv b/core/dbio/templates/types_native_to_general.tsv
@@ -17,7 +17,7 @@ azuredwh	nchar	text	col_nchar nchar	TRUE	TRUE
 azuredwh	ntext	text	col_ntext ntext	TRUE	TRUE	
 azuredwh	numeric	decimal	col_numeric numeric	TRUE	TRUE	
 azuredwh	nvarchar	text	col_nvarchar nvarchar	TRUE	TRUE	
-azuredwh	real	decimal	col_real real	TRUE	TRUE	
+azuredwh	real	float	col_real real	TRUE	TRUE	
 azuredwh	timestamp	binary	col_timestamp timestamp	TRUE	TRUE	
 azuredwh	smalldatetime	datetime	col_smalldatetime smalldatetime	TRUE	TRUE	
 azuredwh	smallint	smallint	col_smallint smallint	TRUE	TRUE	
@@ -45,7 +45,7 @@ azuresql	nchar	text	col_nchar nchar	TRUE	TRUE
 azuresql	ntext	text	col_ntext ntext	TRUE	TRUE	
 azuresql	numeric	decimal	col_numeric numeric	TRUE	TRUE	
 azuresql	nvarchar	text	col_nvarchar nvarchar	TRUE	TRUE	
-azuresql	real	decimal	col_real real	TRUE	TRUE	
+azuresql	real	float	col_real real	TRUE	TRUE	
 azuresql	smalldatetime	datetime	col_smalldatetime smalldatetime	TRUE	TRUE	
 azuresql	smallint	smallint	col_smallint smallint	TRUE	TRUE	
 azuresql	smallmoney	decimal	col_smallmoney smallmoney	TRUE	TRUE	
@@ -325,7 +325,7 @@ postgres	path	string	col_path path	FALSE	FALSE	geometric path on a plane
 postgres	pg_lsn	bigint	col_pg_lsn pg_lsn	FALSE	FALSE	PostgreSQL Log Sequence Number
 postgres	point	string	col_point point	FALSE	FALSE	geometric point on a plane
 postgres	polygon	string	col_polygon polygon	FALSE	FALSE	closed geometric path on a plane
-postgres	real	decimal	col_real real	TRUE	TRUE	single precision floating-point number (4 bytes)
+postgres	real	float	col_real real	TRUE	TRUE	single precision floating-point number (4 bytes)
 postgres	serial	integer	col_serial serial	TRUE	TRUE	autoincrementing four-byte integer
 postgres	serial2	smallint	col_serial2 serial2	TRUE	TRUE	autoincrementing two-byte integer
 postgres	serial4	integer	col_serial4 serial4	TRUE	TRUE	autoincrementing four-byte integer
@@ -517,7 +517,7 @@ sqlserver	nchar	text	col_nchar nchar(17)	TRUE	TRUE
 sqlserver	ntext	text	col_ntext ntext	TRUE	TRUE	
 sqlserver	numeric	decimal	col_numeric numeric	TRUE	TRUE	
 sqlserver	nvarchar	text	col_nvarchar nvarchar(100)	TRUE	TRUE	
-sqlserver	real	decimal	col_real real	TRUE	TRUE	
+sqlserver	real	float	col_real real	TRUE	TRUE	
 sqlserver	smalldatetime	datetime	col_smalldatetime smalldatetime	TRUE	TRUE	
 sqlserver	smallint	smallint	col_smallint smallint	TRUE	TRUE	
 sqlserver	smallmoney	decimal	col_smallmoney smallmoney	TRUE	TRUE	
diff --git a/core/sling/replication.go b/core/sling/replication.go
@@ -1275,6 +1275,15 @@ func LoadReplicationConfig(content string) (config ReplicationConfig, err error)
 
 	// load compiled tasks if in env
 	if payload := os.Getenv("SLING_REPLICATION_TASKS"); payload != "" {
+		if strings.HasPrefix(payload, "file://") {
+			payloadPath := strings.TrimPrefix(payload, "file://")
+			bytes, err := os.ReadFile(payloadPath)
+			if err != nil {
+				err = g.Error(err, "Could not read replication tasks: "+payloadPath)
+				return config, err
+			}
+			payload = string(bytes)
+		}
 		if err = g.Unmarshal(payload, &config.Tasks); err != nil {
 			err = g.Error(err, "could not unmarshal replication compiled tasks")
 			return
diff --git a/core/version.go b/core/version.go
@@ -2,6 +2,7 @@ package core
 
 import (
 	"os"
+	"runtime"
 	"strings"
 	"time"
 
@@ -12,6 +13,12 @@ import (
 // Version is the version number
 var Version = "dev"
 
+var TelProps = g.M(
+	"application", "sling-cli",
+	"version", Version,
+	"os", runtime.GOOS+"/"+runtime.GOARCH,
+)
+
 func init() {
 	// dev build version is in format => 1.2.2.dev/2024-08-20
 	parts := strings.Split(Version, "/")
diff --git a/go.mod b/go.mod
@@ -24,7 +24,7 @@ require (
 	github.com/elastic/go-elasticsearch/v8 v8.17.0
 	github.com/fatih/color v1.17.0
 	github.com/flarco/bigquery v0.0.9
-	github.com/flarco/g v0.1.142
+	github.com/flarco/g v0.1.146
 	github.com/getsentry/sentry-go v0.27.0
 	github.com/go-sql-driver/mysql v1.8.1
 	github.com/gobwas/glob v0.2.3
@@ -43,6 +43,7 @@ require (
 	github.com/lib/pq v1.10.9
 	github.com/linkedin/goavro/v2 v2.12.0
 	github.com/maja42/goval v1.4.0
+	github.com/mark3labs/mcp-go v0.29.0
 	github.com/mattn/go-sqlite3 v1.14.22
 	github.com/microsoft/go-mssqldb v1.8.0
 	github.com/nqd/flat v0.1.1
@@ -61,7 +62,7 @@ require (
 	github.com/sijms/go-ora/v2 v2.8.24
 	github.com/slingdata-io/sling v0.0.0-20240426022644-3c31b1eb088e
 	github.com/snowflakedb/gosnowflake v1.10.0
-	github.com/spf13/cast v1.6.0
+	github.com/spf13/cast v1.7.1
 	github.com/stretchr/testify v1.10.0
 	github.com/timeplus-io/proton-go-driver/v2 v2.0.19
 	github.com/trinodb/trino-go-client v0.318.0
@@ -247,6 +248,7 @@ require (
 	github.com/xdg-go/pbkdf2 v1.0.0 // indirect
 	github.com/xdg-go/scram v1.1.2 // indirect
 	github.com/xdg-go/stringprep v1.0.4 // indirect
+	github.com/yosida95/uritemplate/v3 v3.0.2 // indirect
 	github.com/yusufpapurcu/wmi v1.2.4 // indirect
 	github.com/zeebo/xxh3 v1.0.2 // indirect
 	go.opencensus.io v0.24.0 // indirect
diff --git a/go.sum b/go.sum
@@ -451,6 +451,8 @@ github.com/lunixbochs/vtclean v1.0.0/go.mod h1:pHhQNgMf3btfWnGBVipUOjRYhoOsdGqdm
 github.com/mailru/easyjson v0.0.0-20190312143242-1de009706dbe/go.mod h1:C1wdFJiN94OJF2b5HbByQZoLdCWB1Yqtg26g4irojpc=
 github.com/maja42/goval v1.4.0 h1:tlX0X+GvjKzWW2Q6qzWwL4Av2KV1bLtzxwzgxiiwEPc=
 github.com/maja42/goval v1.4.0/go.mod h1:LDMwF8ocOwIsMZdwoyHC/3UpV8ABDwEzalxkVV2z/rI=
+github.com/mark3labs/mcp-go v0.29.0 h1:sH1NBcumKskhxqYzhXfGc201D7P76TVXiT0fGVhabeI=
+github.com/mark3labs/mcp-go v0.29.0/go.mod h1:rXqOudj/djTORU/ThxYx8fqEVj/5pvTuuebQ2RC7uk4=
 github.com/matoous/go-nanoid/v2 v2.1.0 h1:P64+dmq21hhWdtvZfEAofnvJULaRR1Yib0+PnU669bE=
 github.com/matoous/go-nanoid/v2 v2.1.0/go.mod h1:KlbGNQ+FhrUNIHUxZdL63t7tl4LaPkZNpUULS8H4uVM=
 github.com/mattn/go-colorable v0.1.2/go.mod h1:U0ppj6V5qS13XJ6of8GYAs25YV2eR4EVcfRqFIhoBtE=
@@ -651,8 +653,8 @@ github.com/snowflakedb/gosnowflake v1.10.0 h1:5hBGKa/jJEhciokzgJcz5xmLNlJ8oUm8vh
 github.com/snowflakedb/gosnowflake v1.10.0/go.mod h1:WC4eGUOH3K9w3pLsdwZsdawIwtWgse4kZPPqNG0Ky/k=
 github.com/sourcegraph/annotate v0.0.0-20160123013949-f4cad6c6324d/go.mod h1:UdhH50NIW0fCiwBSr0co2m7BnFLdv4fQTgdqdJTHFeE=
 github.com/sourcegraph/syntaxhighlight v0.0.0-20170531221838-bd320f5d308e/go.mod h1:HuIsMU8RRBOtsCgI77wP899iHVBQpCmg4ErYMZB+2IA=
-github.com/spf13/cast v1.6.0 h1:GEiTHELF+vaR5dhz3VqZfFSzZjYbgeKDpBxQVS4GYJ0=
-github.com/spf13/cast v1.6.0/go.mod h1:ancEpBxwJDODSW/UG4rDrAqiKolqNNh2DX3mk86cAdo=
+github.com/spf13/cast v1.7.1 h1:cuNEagBQEHWN1FnbGEjCXL2szYEXqfJPbP2HNUaca9Y=
+github.com/spf13/cast v1.7.1/go.mod h1:ancEpBxwJDODSW/UG4rDrAqiKolqNNh2DX3mk86cAdo=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
 github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=
@@ -711,6 +713,8 @@ github.com/xo/dburl v0.3.0 h1:KGkeJB/oQhY/DeeJoYl/1+pNE/JnF6ouAuA8nzpQEQ8=
 github.com/xo/dburl v0.3.0/go.mod h1:TM8VMBT+LWqC3MBOulZjb8FAthcvZq0t/qvDLwS6skU=
 github.com/xyproto/randomstring v1.0.5 h1:YtlWPoRdgMu3NZtP45drfy1GKoojuR7hmRcnhZqKjWU=
 github.com/xyproto/randomstring v1.0.5/go.mod h1:rgmS5DeNXLivK7YprL0pY+lTuhNQW3iGxZ18UQApw/E=
+github.com/yosida95/uritemplate/v3 v3.0.2 h1:Ed3Oyj9yrmi9087+NczuL5BwkIc4wvTb5zIM+UJPGz4=
+github.com/yosida95/uritemplate/v3 v3.0.2/go.mod h1:ILOh0sOhIJR3+L/8afwt/kE++YT040gmv5BQTMR2HP4=
 github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d/go.mod h1:rHwXgn7JulP+udvsHwJoVG1YGAP6VLg4y9I5dyZdqmA=
 github.com/youmark/pkcs8 v0.0.0-20201027041543-1326539a0a0a h1:fZHgsYlfvtyqToslyjUt3VOPF4J7aK/3MPcK7xp3PDk=
 github.com/youmark/pkcs8 v0.0.0-20201027041543-1326539a0a0a/go.mod h1:ul22v+Nro/R083muKhosV54bj5niojjWZvU8xrevuH4=

Original file line number	Diff line number	Diff line change
`@@ -154,7 +154,9 @@ func upgradeBrew() (err error) {`
`154`	`154`	`}`
`155`	`155`
`156`	`156`	`func upgradeScoop() (err error) {`
`157`		- g.Info("Sling was installed with scoop. Running `scoop update sling`")
	`157`	+ g.Warn("Sling was installed with scoop. Try running `scoop update sling`")
	`158`	`+ return nil`
	`159`	`+ // errors with "sling" is still running. Need to install manually`
`158`	`160`
`159`	`161`	`proc, err := process.NewProc("scoop")`
`160`	`162`	`if err != nil {`
Original file line number	Diff line number	Diff line change
`@@ -704,6 +704,7 @@ func (conn *BaseConn) Connect(timeOut ...int) (err error) {`
`704`	`704`	`}`
`705`	`705`
`706`	`706`	`conn.SetProp("connected", "true")`
	`707`	`+ conn.SetProp("connect_time", cast.ToString(time.Now()))`
`707`	`708`
`708`	`709`	`return nil`
`709`	`710`	`}`
Original file line number	Diff line number	Diff line change
`@@ -154,6 +154,7 @@ func (conn *AthenaConn) Connect(timeOut ...int) (err error) {`
`154`	`154`	`}`
`155`	`155`
`156`	`156`	`conn.SetProp("connected", "true")`
	`157`	`+ conn.SetProp("connect_time", cast.ToString(time.Now()))`
`157`	`158`
`158`	`159`	`if !cast.ToBool(conn.GetProp("silent")) {`
`159`	`160`	g.Debug(`opened "%s" connection (%s)`, conn.Type, conn.GetProp("sling_conn_id"))
Original file line number	Diff line number	Diff line change
`@@ -176,6 +176,7 @@ func (conn *BigTableConn) Connect(timeOut ...int) error {`
`176`	`176`	`}`
`177`	`177`
`178`	`178`	`conn.SetProp("connected", "true")`
	`179`	`+ conn.SetProp("connect_time", cast.ToString(time.Now()))`
`179`	`180`
`180`	`181`	`return nil`
`181`	`182`	`}`
Original file line number	Diff line number	Diff line change
`@@ -128,6 +128,7 @@ func (conn *D1Conn) Connect(timeOut ...int) (err error) {`
`128`	`128`	`}`
`129`	`129`
`130`	`130`	`conn.SetProp("connected", "true")`
	`131`	`+ conn.SetProp("connect_time", cast.ToString(time.Now()))`
`131`	`132`
`132`	`133`	`return nil`
`133`	`134`	`}`