Project Rename and Postgres Changes

.gitignore

@@ -1,2 +1,2 @@
-shift
+synkit
 .vscode

LICENCE

@@ -1,4 +1,4 @@
-Shift License
+Synkit License
 
 Version 1.1, 30th June 2023
 

README.md

@@ -1,6 +1,6 @@
-# Shift
+# Synkit
 
-Shift is a new data integration protocol and specification, written in Golang, that aims to provide an alternative to existing solutions such as Airbyte, Meltano, and Singer-io. It focuses on simplicity, performance, and extensibility to enable seamless data integration between various systems and applications.
+Synkit is a new data integration protocol and specification, written in Golang, that aims to provide an alternative to existing solutions such as Airbyte, Meltano, and Singer-io. It focuses on simplicity, performance, and extensibility to enable seamless data integration between various systems and applications.
 
 ## Roadmap
 - [ ] Postgres
@@ -11,33 +11,33 @@ Shift is a new data integration protocol and specification, written in Golang, t
 
 ## Getting Started
 
-To start using Shift, follow these steps:
+To start using Synkit, follow these steps:
 
-1. **Run Shift**: Run Shift driver/adapter images directly with config, catalog, and state files.
-2. **Explore the Documentation**: Refer to the documentation for detailed information on how to use Protocol Shift, including connector setup, data source configuration, and integration examples.
+1. **Run Synkit**: Run Synkit driver/adapter images directly with config, catalog, and state files.
+2. **Explore the Documentation**: Refer to the documentation for detailed information on how to use Protocol Synkit, including connector setup, data source configuration, and integration examples.
 
 ## Contributing
 
-We welcome contributions to Protocol Shift! If you'd like to contribute, please follow these guidelines:
+We welcome contributions to Protocol Synkit! If you'd like to contribute, please follow these guidelines:
 
 1. Fork the repository and create a new branch for your feature or bug fix.
 
 2. Commit your changes with descriptive commit messages.
 
 3. Push your changes to your forked repository.
 
-4. Submit a pull request to the main Shift repository, clearly describing the changes you've made and their purpose.
+4. Submit a pull request to the main Synkit repository, clearly describing the changes you've made and their purpose.
 
 5. Participate in the code review process, addressing any feedback or suggestions.
 
 ## License
 
-Protocol Shift is open-source and released under a custom Licence. Please check
+Protocol Synkit is open-source and released under a custom Licence. Please check
 
 ## Contact
 
-For any questions, feedback, or support related to Shift, you can reach out to the development team via email at [piyushsingariya@gmail.com](mailto:piyushsingariya@gmail.com).
+For any questions, feedback, or support related to Synkit, you can reach out to the development team via email at [piyushsingariya@gmail.com](mailto:piyushsingariya@gmail.com).
 
 ## Acknowledgments
 
-We would like to acknowledge the contributions of all individuals and organizations that have helped make Shift possible. Their feedback, ideas, and suggestions have been invaluable in shaping and improving the protocol.
+We would like to acknowledge the contributions of all individuals and organizations that have helped make Synkit possible. Their feedback, ideas, and suggestions have been invaluable in shaping and improving the protocol.

build.sh

@@ -17,17 +17,17 @@ function build_and_run() {
     fi
     cd $path
     go mod tidy
-    go build -ldflags="-w -s -X constants/constants.version=${GIT_VERSION} -X constants/constants.commitsha=${GIT_COMMITSHA} -X constants/constants.releasechannel=${RELEASE_CHANNEL}" -o shift main.go
+    go build -ldflags="-w -s -X constants/constants.version=${GIT_VERSION} -X constants/constants.commitsha=${GIT_COMMITSHA} -X constants/constants.releasechannel=${RELEASE_CHANNEL}" -o synkit main.go
 
     echo "============================== Executing connector: $connector with args [$joined_arguments] =============================="
-    ./shift $joined_arguments
+    ./synkit $joined_arguments
 }
 
 if [ $# -gt 0 ]; then
     argument="$1"
 
     # Capture and join remaining arguments
-    shift
+    synkit
     remaining_arguments=("$@")
     joined_arguments=$(
         IFS=' '

connector.go

@@ -1,12 +1,12 @@
-package shift
+package synkit
 
 import (
 	"fmt"
 	"os"
 
-	"github.com/piyushsingariya/shift/logger"
-	protocol "github.com/piyushsingariya/shift/protocol"
-	"github.com/piyushsingariya/shift/safego"
+	"github.com/piyushsingariya/synkit/logger"
+	protocol "github.com/piyushsingariya/synkit/protocol"
+	"github.com/piyushsingariya/synkit/safego"
 	"github.com/spf13/cobra"
 )
 

drivers/base/bulk_driver.go

@@ -1,9 +1,9 @@
 package base
 
 import (
-	"github.com/piyushsingariya/shift/protocol"
-	"github.com/piyushsingariya/shift/types"
-	"github.com/piyushsingariya/shift/utils"
+	"github.com/piyushsingariya/synkit/protocol"
+	"github.com/piyushsingariya/synkit/types"
+	"github.com/piyushsingariya/synkit/utils"
 )
 
 // Pass dest with all fields initialized to handle nil state case

drivers/base/driver.go

@@ -1,9 +1,9 @@
 package base
 
 import (
-	"github.com/piyushsingariya/shift/protocol"
-	"github.com/piyushsingariya/shift/types"
-	"github.com/piyushsingariya/shift/typeutils"
+	"github.com/piyushsingariya/synkit/protocol"
+	"github.com/piyushsingariya/synkit/types"
+	"github.com/piyushsingariya/synkit/typeutils"
 )
 
 type Driver struct {

drivers/base/utils.go

@@ -3,8 +3,8 @@ package base
 import (
 	"time"
 
-	"github.com/piyushsingariya/shift/logger"
-	"github.com/piyushsingariya/shift/types"
+	"github.com/piyushsingariya/synkit/logger"
+	"github.com/piyushsingariya/synkit/types"
 )
 
 type basestream interface {

drivers/google-sheets/go.mod

@@ -1,4 +1,4 @@
-module github.com/piyushsingariya/shift/drivers/google-sheets
+module github.com/piyushsingariya/synkit/drivers/google-sheets
 
 go 1.22
 
@@ -7,7 +7,7 @@ toolchain go1.22.3
 require (
 	github.com/goccy/go-json v0.10.2
 	github.com/mozillazg/go-unidecode v0.2.0
-	github.com/piyushsingariya/shift v0.0.0-00010101000000-000000000000
+	github.com/piyushsingariya/synkit v0.0.0-00010101000000-000000000000
 	golang.org/x/oauth2 v0.10.0
 	gopkg.in/Iwark/spreadsheet.v2 v2.0.0-20220412131121-41eea1483964
 )
@@ -46,4 +46,4 @@ require (
 	sigs.k8s.io/yaml v1.3.0 // indirect
 )
 
-replace github.com/piyushsingariya/shift => ../../
+replace github.com/piyushsingariya/synkit => ../../

drivers/google-sheets/internal/google_sheets.go

@@ -4,11 +4,11 @@ import (
 	"fmt"
 	"strings"
 
-	"github.com/piyushsingariya/shift/drivers/base"
-	"github.com/piyushsingariya/shift/logger"
-	"github.com/piyushsingariya/shift/protocol"
-	"github.com/piyushsingariya/shift/types"
-	"github.com/piyushsingariya/shift/utils"
+	"github.com/piyushsingariya/synkit/drivers/base"
+	"github.com/piyushsingariya/synkit/logger"
+	"github.com/piyushsingariya/synkit/protocol"
+	"github.com/piyushsingariya/synkit/types"
+	"github.com/piyushsingariya/synkit/utils"
 	"gopkg.in/Iwark/spreadsheet.v2"
 )
 

drivers/google-sheets/internal/models.go

@@ -3,7 +3,7 @@ package driver
 import (
 	"fmt"
 
-	"github.com/piyushsingariya/shift/types"
+	"github.com/piyushsingariya/synkit/types"
 )
 
 type Config struct {

drivers/google-sheets/internal/utils.go

@@ -11,9 +11,9 @@ import (
 	"github.com/goccy/go-json"
 
 	unidecode "github.com/mozillazg/go-unidecode"
-	"github.com/piyushsingariya/shift/logger"
-	"github.com/piyushsingariya/shift/types"
-	"github.com/piyushsingariya/shift/utils"
+	"github.com/piyushsingariya/synkit/logger"
+	"github.com/piyushsingariya/synkit/types"
+	"github.com/piyushsingariya/synkit/utils"
 	"golang.org/x/oauth2"
 	"golang.org/x/oauth2/google"
 	"gopkg.in/Iwark/spreadsheet.v2"

drivers/google-sheets/main.go

@@ -1,11 +1,11 @@
 package main
 
 import (
-	"github.com/piyushsingariya/shift"
-	driver "github.com/piyushsingariya/shift/drivers/google-sheets/internal"
+	"github.com/piyushsingariya/synkit"
+	driver "github.com/piyushsingariya/synkit/drivers/google-sheets/internal"
 )
 
 func main() {
 	driver := &driver.GoogleSheets{}
-	shift.RegisterDriver(driver)
+	synkit.RegisterDriver(driver)
 }

drivers/hubspot/go.mod

@@ -1,12 +1,12 @@
-module github.com/piyushsingariya/shift/drivers/hubspot
+module github.com/piyushsingariya/synkit/drivers/hubspot
 
 go 1.22
 
 toolchain go1.22.3
 
 require (
 	github.com/goccy/go-json v0.10.2
-	github.com/piyushsingariya/shift v0.0.0-20230727050722-6795340c7033
+	github.com/piyushsingariya/synkit v0.0.0-20230727050722-6795340c7033
 	golang.org/x/oauth2 v0.11.0
 )
 
@@ -42,4 +42,4 @@ require (
 	sigs.k8s.io/yaml v1.3.0 // indirect
 )
 
-replace github.com/piyushsingariya/shift => ../../
+replace github.com/piyushsingariya/synkit => ../../

drivers/hubspot/internal/base_stream.go

@@ -15,11 +15,11 @@
 
 	"github.com/goccy/go-json"
 
-	"github.com/piyushsingariya/shift/drivers/base"
-	"github.com/piyushsingariya/shift/logger"
-	"github.com/piyushsingariya/shift/types"
-	"github.com/piyushsingariya/shift/typeutils"
-	"github.com/piyushsingariya/shift/utils"
+	"github.com/piyushsingariya/synkit/drivers/base"
+	"github.com/piyushsingariya/synkit/logger"
+	"github.com/piyushsingariya/synkit/types"
+	"github.com/piyushsingariya/synkit/typeutils"
+	"github.com/piyushsingariya/synkit/utils"
 )
 
 type Stream struct {
@@ -158,7 +158,7 @@
 }
 
 func (s *Stream) ScopeIsGranted(grantedScopes []string) bool {
 	s.grantedScopes = types.Set(grantedScopes)
 	return utils.IsSubset(grantedScopes, s.scopes)
 }
 

drivers/hubspot/internal/config.go

@@ -4,7 +4,7 @@ import (
 	"fmt"
 	"time"
 
-	"github.com/piyushsingariya/shift/logger"
+	"github.com/piyushsingariya/synkit/logger"
 )
 
 type Config struct {

drivers/hubspot/internal/crm_stream.go

@@ -5,12 +5,12 @@ import (
 	"net/http"
 	"time"
 
-	"github.com/piyushsingariya/shift/drivers/base"
-	"github.com/piyushsingariya/shift/logger"
-	"github.com/piyushsingariya/shift/safego"
-	"github.com/piyushsingariya/shift/types"
-	"github.com/piyushsingariya/shift/typeutils"
-	"github.com/piyushsingariya/shift/utils"
+	"github.com/piyushsingariya/synkit/drivers/base"
+	"github.com/piyushsingariya/synkit/logger"
+	"github.com/piyushsingariya/synkit/safego"
+	"github.com/piyushsingariya/synkit/types"
+	"github.com/piyushsingariya/synkit/typeutils"
+	"github.com/piyushsingariya/synkit/utils"
 )
 
 type CRMSearchStream struct {

drivers/hubspot/internal/hubspot.go

@@ -6,13 +6,13 @@
 	"net/http"
 
 	"github.com/goccy/go-json"
-	"github.com/piyushsingariya/shift/drivers/base"
+	"github.com/piyushsingariya/synkit/drivers/base"
 
-	"github.com/piyushsingariya/shift/jsonschema"
-	"github.com/piyushsingariya/shift/jsonschema/schema"
-	"github.com/piyushsingariya/shift/protocol"
-	"github.com/piyushsingariya/shift/types"
-	"github.com/piyushsingariya/shift/utils"
+	"github.com/piyushsingariya/synkit/jsonschema"
+	"github.com/piyushsingariya/synkit/jsonschema/schema"
+	"github.com/piyushsingariya/synkit/protocol"
+	"github.com/piyushsingariya/synkit/types"
+	"github.com/piyushsingariya/synkit/utils"
 )
 
 type Hubspot struct {
@@ -65,7 +65,7 @@
 			WithPrimaryKey(hstream.PrimaryKey()...)
 		stream.WithCursorField(hstream.cursorField())
 
 		streams = append(streams, stream)
 	}
 
 	return streams, nil

drivers/hubspot/internal/incremental_stream.go

@@ -4,10 +4,10 @@
 	"net/http"
 	"time"
 
-	"github.com/piyushsingariya/shift/logger"
-	"github.com/piyushsingariya/shift/types"
-	"github.com/piyushsingariya/shift/typeutils"
-	"github.com/piyushsingariya/shift/utils"
+	"github.com/piyushsingariya/synkit/logger"
+	"github.com/piyushsingariya/synkit/types"
+	"github.com/piyushsingariya/synkit/typeutils"
+	"github.com/piyushsingariya/synkit/utils"
 )
 
 type IncrementalStream struct {
@@ -40,7 +40,7 @@
 		statePk:                 "timestamp",
 	}
 
 	s.availableSyncMode = append(s.availableSyncMode, types.Incremental)
 	return s
 }
 

drivers/hubspot/internal/interface.go

@@ -1,7 +1,7 @@
 package driver
 
 import (
-	"github.com/piyushsingariya/shift/types"
+	"github.com/piyushsingariya/synkit/types"
 )
 
 type HubspotStream interface {

drivers/hubspot/internal/utils.go

@@ -7,9 +7,9 @@ import (
 	"reflect"
 	"strings"
 
-	"github.com/piyushsingariya/shift/logger"
-	"github.com/piyushsingariya/shift/types"
-	"github.com/piyushsingariya/shift/utils"
+	"github.com/piyushsingariya/synkit/logger"
+	"github.com/piyushsingariya/synkit/types"
+	"github.com/piyushsingariya/synkit/utils"
 	"golang.org/x/oauth2"
 )
 

drivers/hubspot/main.go

@@ -1,11 +1,11 @@
 package main
 
 import (
-	"github.com/piyushsingariya/shift"
-	driver "github.com/piyushsingariya/shift/drivers/hubspot/internal"
+	"github.com/piyushsingariya/synkit"
+	driver "github.com/piyushsingariya/synkit/drivers/hubspot/internal"
 )
 
 func main() {
 	driver := &driver.Hubspot{}
-	shift.RegisterDriver(driver)
+	synkit.RegisterDriver(driver)
 }