go.mod: bump github.com/conduitio/conduit-connector-sdk from 0.9.1 to 0.11.0

.golangci.yml

@@ -1,3 +1,6 @@
+run:
+  timeout: 5m
+
 linters-settings:
   gofmt:
     simplify: false

Makefile

@@ -12,6 +12,10 @@ test:
 lint:
 	golangci-lint run
 
+.PHONY: generate
+generate:
+	go generate ./...
+
 .PHONY: install-tools
 install-tools:
 	@echo Installing tools from tools.go

acceptance_test.go

@@ -30,8 +30,8 @@ import (
 	"github.com/conduitio-labs/conduit-connector-zendesk/source"
 	"github.com/conduitio-labs/conduit-connector-zendesk/source/position"
 	"github.com/conduitio-labs/conduit-connector-zendesk/zendesk"
+	"github.com/conduitio/conduit-commons/opencdc"
 	sdk "github.com/conduitio/conduit-connector-sdk"
-
 	"github.com/stretchr/testify/assert"
 	"go.uber.org/goleak"
 )
@@ -144,13 +144,13 @@ type AcceptanceTestDriver struct {
 	sdk.ConfigurableAcceptanceTestDriver
 }
 
-func (d AcceptanceTestDriver) GenerateRecord(_ *testing.T, _ sdk.Operation) sdk.Record {
+func (d AcceptanceTestDriver) GenerateRecord(_ *testing.T, _ opencdc.Operation) opencdc.Record {
 	payload := fmt.Sprintf(`{"description":"%s","subject":"%s","raw_subject":"%s"}`, d.randString(32), d.randString(32), d.randString(32))
-	return sdk.Record{
-		Position: sdk.Position(fmt.Sprintf(`{last_modified_time:%v,id:"%v",}`, time.Now().Add(1*time.Second), 0)),
+	return opencdc.Record{
+		Position: opencdc.Position(fmt.Sprintf(`{last_modified_time:%v,id:"%v",}`, time.Now().Add(1*time.Second), 0)),
 		Metadata: nil,
-		Key:      sdk.RawData(fmt.Sprintf("%v", 0)),
-		Payload:  sdk.Change{After: sdk.RawData(payload)},
+		Key:      opencdc.RawData(fmt.Sprintf("%v", 0)),
+		Payload:  opencdc.Change{After: opencdc.RawData(payload)},
 	}
 }
 

cmd/connector/main.go

@@ -16,7 +16,6 @@ package main
 
 import (
 	zendesk "github.com/conduitio-labs/conduit-connector-zendesk"
-
 	sdk "github.com/conduitio/conduit-connector-sdk"
 )
 

connector.go

@@ -17,7 +17,6 @@ package zendesk
 import (
 	"github.com/conduitio-labs/conduit-connector-zendesk/destination"
 	"github.com/conduitio-labs/conduit-connector-zendesk/source"
-
 	sdk "github.com/conduitio/conduit-connector-sdk"
 )
 

destination/destination.go

@@ -12,23 +12,25 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
+//go:generate mockery --name=Writer
+
 package destination
 
 import (
 	"context"
 
 	"github.com/conduitio-labs/conduit-connector-zendesk/config"
 	"github.com/conduitio-labs/conduit-connector-zendesk/zendesk"
+	cconfig "github.com/conduitio/conduit-commons/config"
+	"github.com/conduitio/conduit-commons/opencdc"
 	sdk "github.com/conduitio/conduit-connector-sdk"
 )
 
 type Writer interface {
-	Write(ctx context.Context, records []sdk.Record) error
+	Write(ctx context.Context, records []opencdc.Record) error
 	Close()
 }
 
-//go:generate mockery --name=Writer
-
 type Destination struct {
 	sdk.UnimplementedDestination
 	cfg    Config // destination specific config for zendesk
@@ -41,33 +43,32 @@ func NewDestination() sdk.Destination {
 }
 
 // Parameters returns a map of named Parameters that describe how to configure the Source.
-func (d *Destination) Parameters() map[string]sdk.Parameter {
-	return map[string]sdk.Parameter{
+func (d *Destination) Parameters() cconfig.Parameters {
+	return map[string]cconfig.Parameter{
 		config.KeyDomain: {
 			Default:     "",
-			Required:    true,
 			Description: "A domain is referred as the organization name to which zendesk is registered",
+			Validations: []cconfig.Validation{cconfig.ValidationRequired{}},
 		},
 		config.KeyUserName: {
 			Default:     "",
-			Required:    true,
 			Description: "Login to zendesk performed using username",
+			Validations: []cconfig.Validation{cconfig.ValidationRequired{}},
 		},
 		config.KeyAPIToken: {
 			Default:     "",
-			Required:    true,
 			Description: "password to login",
+			Validations: []cconfig.Validation{cconfig.ValidationRequired{}},
 		},
 		KeyMaxRetries: {
 			Default:     "3",
-			Required:    false,
 			Description: "max API retries, before returning an error",
 		},
 	}
 }
 
 // Configure parses and initializes the config.
-func (d *Destination) Configure(_ context.Context, cfg map[string]string) error {
+func (d *Destination) Configure(_ context.Context, cfg cconfig.Config) error {
 	configuration, err := Parse(cfg)
 	if err != nil {
 		return err
@@ -86,7 +87,7 @@ func (d *Destination) Open(_ context.Context) error {
 }
 
 // Write writes records into a Destination.
-func (d *Destination) Write(ctx context.Context, records []sdk.Record) (int, error) {
+func (d *Destination) Write(ctx context.Context, records []opencdc.Record) (int, error) {
 	err := d.writer.Write(ctx, records)
 	if err != nil {
 		return 0, err

destination/destination_test.go

@@ -21,7 +21,7 @@ import (
 
 	"github.com/conduitio-labs/conduit-connector-zendesk/config"
 	"github.com/conduitio-labs/conduit-connector-zendesk/destination/mocks"
-	sdk "github.com/conduitio/conduit-connector-sdk"
+	"github.com/conduitio/conduit-commons/opencdc"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/mock"
 )
@@ -88,7 +88,7 @@ func TestOpen(t *testing.T) {
 func TestWrite(t *testing.T) {
 	tests := []struct {
 		name   string
-		record sdk.Record
+		record opencdc.Record
 		err    error
 		dest   Destination
 	}{
@@ -102,16 +102,16 @@ func TestWrite(t *testing.T) {
 					return w
 				}(),
 			},
-			record: sdk.Record{
-				Key:     sdk.RawData(`dummy_key`),
-				Payload: sdk.Change{After: sdk.RawData(``)},
+			record: opencdc.Record{
+				Key:     opencdc.RawData(`dummy_key`),
+				Payload: opencdc.Change{After: opencdc.RawData(``)},
 			},
 			err: nil,
 		},
 		{
 			name: "valid case",
-			record: sdk.Record{
-				Payload: sdk.Change{After: sdk.RawData(`"dummy_data":"12345"`)},
+			record: opencdc.Record{
+				Payload: opencdc.Change{After: opencdc.RawData(`"dummy_data":"12345"`)},
 			},
 			dest: Destination{
 				writer: func() Writer {
@@ -124,8 +124,8 @@ func TestWrite(t *testing.T) {
 		},
 		{
 			name: "write invalid case with flush error",
-			record: sdk.Record{
-				Payload: sdk.Change{After: sdk.RawData(`"dummy_data":"12345"`)},
+			record: opencdc.Record{
+				Payload: opencdc.Change{After: opencdc.RawData(`"dummy_data":"12345"`)},
 			},
 			dest: Destination{
 				writer: func() Writer {
@@ -141,7 +141,7 @@ func TestWrite(t *testing.T) {
 
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
-			n, err := tt.dest.Write(context.Background(), []sdk.Record{tt.record})
+			n, err := tt.dest.Write(context.Background(), []opencdc.Record{tt.record})
 			if tt.err != nil {
 				assert.NotNil(t, err)
 				assert.Equal(t, err, tt.err)