Rename: Gear5 (#22)

* replace go json with encoding/json

* state locking to avoid collision in reading StreamState maps

* rename project

* Renaming project with Gear5

.gitignore

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

LICENCE

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

README.md

@@ -1,6 +1,6 @@
-# Synkit
+# Gear5
 
-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.
+Gear5 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 @@ Synkit is a new data integration protocol and specification, written in Golang,
 
 ## Getting Started
 
-To start using Synkit, follow these steps:
+To start using Gear5, follow these steps:
 
-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.
+1. **Run Gear5**: Run Gear5 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 Gear5, including connector setup, data source configuration, and integration examples.
 
 ## Contributing
 
-We welcome contributions to Protocol Synkit! If you'd like to contribute, please follow these guidelines:
+We welcome contributions to Protocol Gear5! 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 Synkit repository, clearly describing the changes you've made and their purpose.
+4. Submit a pull request to the main Gear5 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 Synkit is open-source and released under a custom Licence. Please check
+Protocol Gear5 is open-source and released under a custom Licence. Please check
 
 ## Contact
 
-For any questions, feedback, or support related to Synkit, you can reach out to the development team via email at [[email protected]](mailto:[email protected]).
+For any questions, feedback, or support related to Gear5, you can reach out to the development team via email at [[email protected]](mailto:[email protected]).
 
 ## Acknowledgments
 
-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.
+We would like to acknowledge the contributions of all individuals and organizations that have helped make Gear5 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 synkit 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 g5 main.go
 
     echo "============================== Executing connector: $connector with args [$joined_arguments] =============================="
-    ./synkit $joined_arguments
+    ./g5 $joined_arguments
 }
 
 if [ $# -gt 0 ]; then
     argument="$1"
 
     # Capture and join remaining arguments
-    synkit
+    g5
     remaining_arguments=("$@")
     joined_arguments=$(
         IFS=' '

connector.go

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

drivers/base/bulk_driver.go

@@ -1,9 +1,9 @@
 package base
 
 import (
-	"github.com/piyushsingariya/synkit/protocol"
-	"github.com/piyushsingariya/synkit/types"
-	"github.com/piyushsingariya/synkit/utils"
+	"github.com/gear5sh/gear5/protocol"
+	"github.com/gear5sh/gear5/types"
+	"github.com/gear5sh/gear5/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/synkit/protocol"
-	"github.com/piyushsingariya/synkit/types"
-	"github.com/piyushsingariya/synkit/typeutils"
+	"github.com/gear5sh/gear5/protocol"
+	"github.com/gear5sh/gear5/types"
+	"github.com/gear5sh/gear5/typeutils"
 )
 
 type Driver struct {

drivers/base/utils.go

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

drivers/google-sheets/go.mod

@@ -1,4 +1,4 @@
-module github.com/piyushsingariya/synkit/drivers/google-sheets
+module github.com/gear5sh/gear5/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/synkit v0.0.0-00010101000000-000000000000
+	github.com/gear5sh/gear5 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/synkit => ../../
+replace github.com/gear5sh/gear5 => ../../

drivers/google-sheets/internal/google_sheets.go

@@ -4,11 +4,11 @@ import (
 	"fmt"
 	"strings"
 
-	"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"
+	"github.com/gear5sh/gear5/drivers/base"
+	"github.com/gear5sh/gear5/logger"
+	"github.com/gear5sh/gear5/protocol"
+	"github.com/gear5sh/gear5/types"
+	"github.com/gear5sh/gear5/utils"
 	"gopkg.in/Iwark/spreadsheet.v2"
 )
 

drivers/google-sheets/internal/models.go

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

drivers/google-sheets/internal/utils.go

@@ -10,10 +10,10 @@ import (
 
 	"github.com/goccy/go-json"
 
+	"github.com/gear5sh/gear5/logger"
+	"github.com/gear5sh/gear5/types"
+	"github.com/gear5sh/gear5/utils"
 	unidecode "github.com/mozillazg/go-unidecode"
-	"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/synkit"
-	driver "github.com/piyushsingariya/synkit/drivers/google-sheets/internal"
+	"github.com/gear5sh/gear5"
+	driver "github.com/gear5sh/gear5/drivers/google-sheets/internal"
 )
 
 func main() {
 	driver := &driver.GoogleSheets{}
-	synkit.RegisterDriver(driver)
+	gear5.RegisterDriver(driver)
 }

drivers/hubspot/go.mod

@@ -1,12 +1,12 @@
-module github.com/piyushsingariya/synkit/drivers/hubspot
+module github.com/gear5sh/gear5/drivers/hubspot
 
 go 1.22
 
 toolchain go1.22.3
 
 require (
 	github.com/goccy/go-json v0.10.2
-	github.com/piyushsingariya/synkit v0.0.0-20230727050722-6795340c7033
+	github.com/gear5sh/gear5 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/synkit => ../../
+replace github.com/gear5sh/gear5 => ../../

drivers/hubspot/internal/base_stream.go

@@ -15,11 +15,11 @@ import (
 
 	"github.com/goccy/go-json"
 
-	"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"
+	"github.com/gear5sh/gear5/drivers/base"
+	"github.com/gear5sh/gear5/logger"
+	"github.com/gear5sh/gear5/types"
+	"github.com/gear5sh/gear5/typeutils"
+	"github.com/gear5sh/gear5/utils"
 )
 
 type Stream struct {

drivers/hubspot/internal/config.go

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

drivers/hubspot/internal/crm_stream.go

@@ -5,12 +5,12 @@ import (
 	"net/http"
 	"time"
 
-	"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"
+	"github.com/gear5sh/gear5/drivers/base"
+	"github.com/gear5sh/gear5/logger"
+	"github.com/gear5sh/gear5/safego"
+	"github.com/gear5sh/gear5/types"
+	"github.com/gear5sh/gear5/typeutils"
+	"github.com/gear5sh/gear5/utils"
 )
 
 type CRMSearchStream struct {

drivers/hubspot/internal/hubspot.go

@@ -5,14 +5,14 @@ import (
 	"io"
 	"net/http"
 
+	"github.com/gear5sh/gear5/drivers/base"
 	"github.com/goccy/go-json"
-	"github.com/piyushsingariya/synkit/drivers/base"
 
-	"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"
+	"github.com/gear5sh/gear5/jsonschema"
+	"github.com/gear5sh/gear5/jsonschema/schema"
+	"github.com/gear5sh/gear5/protocol"
+	"github.com/gear5sh/gear5/types"
+	"github.com/gear5sh/gear5/utils"
 )
 
 type Hubspot struct {

drivers/hubspot/internal/incremental_stream.go

@@ -4,10 +4,10 @@ import (
 	"net/http"
 	"time"
 
-	"github.com/piyushsingariya/synkit/logger"
-	"github.com/piyushsingariya/synkit/types"
-	"github.com/piyushsingariya/synkit/typeutils"
-	"github.com/piyushsingariya/synkit/utils"
+	"github.com/gear5sh/gear5/logger"
+	"github.com/gear5sh/gear5/types"
+	"github.com/gear5sh/gear5/typeutils"
+	"github.com/gear5sh/gear5/utils"
 )
 
 type IncrementalStream struct {

drivers/hubspot/internal/interface.go

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

drivers/hubspot/internal/utils.go

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

drivers/hubspot/main.go

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