feat: add an encoding package

Nishchal Gautam · Nishchal Gautam · commit 78ea4f30bf04 · 2024-02-12T15:38:26.000+07:00
diff --git a/.github/workflows/snyk.yaml b/.github/workflows/snyk.yaml
@@ -0,0 +1,22 @@
+name: snyk-go
+permissions:
+  contents: read
+
+on:
+  push:
+    branches:
+      - main
+      - master
+  pull_request:
+    types:
+      - opened
+      - edited
+      - synchronize
+
+jobs:
+  repository-snyk-go:
+    name: repository-snyk-go
+    uses: honestbank/workflows/.github/workflows/shared-snyk-go.yaml@main
+    with:
+      org_id: 8a07b336-2638-4096-8c8c-25f891be99e8
+    secrets: inherit
diff --git a/v2/kp_example_test.go b/v2/kp_example_test.go
@@ -11,12 +11,12 @@ import (
 	v2 "github.com/honestbank/kp/v2"
 	"github.com/honestbank/kp/v2/config"
 	consumer2 "github.com/honestbank/kp/v2/consumer"
-	"github.com/honestbank/kp/v2/internal/serialization"
 	"github.com/honestbank/kp/v2/middlewares/consumer"
 	"github.com/honestbank/kp/v2/middlewares/deadletter"
 	"github.com/honestbank/kp/v2/middlewares/retry"
 	"github.com/honestbank/kp/v2/middlewares/retry_count"
 	"github.com/honestbank/kp/v2/producer"
+	"github.com/honestbank/kp/v2/serialization"
 )
 
 type UserLoggedInEvent struct {
diff --git a/v2/middlewares/consumer/consumer_test.go b/v2/middlewares/consumer/consumer_test.go
@@ -8,8 +8,8 @@ import (
 	"github.com/confluentinc/confluent-kafka-go/v2/kafka"
 	"github.com/stretchr/testify/assert"
 
-	"github.com/honestbank/kp/v2/internal/serialization"
 	"github.com/honestbank/kp/v2/middlewares/consumer"
+	"github.com/honestbank/kp/v2/serialization"
 )
 
 type mockConsumer struct {
diff --git a/v2/producer/producer.go b/v2/producer/producer.go
@@ -7,8 +7,8 @@ import (
 
 	"github.com/honestbank/kp/v2/config"
 	"github.com/honestbank/kp/v2/internal/schemaregistry"
-	"github.com/honestbank/kp/v2/internal/serialization"
 	"github.com/honestbank/kp/v2/internal/tracing"
+	"github.com/honestbank/kp/v2/serialization"
 )
 
 type producer[BodyType any] struct {
diff --git a/v2/producer/producer_test.go b/v2/producer/producer_test.go
@@ -15,8 +15,8 @@ import (
 	"github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde/avro"
 	"github.com/stretchr/testify/assert"
 
-	"github.com/honestbank/kp/v2/internal/serialization"
 	"github.com/honestbank/kp/v2/producer"
+	"github.com/honestbank/kp/v2/serialization"
 )
 
 type MyMessage struct {
diff --git a/v2/serialization/benchmark_test.go b/v2/serialization/benchmark_test.go
@@ -11,7 +11,7 @@ import (
 	"github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde/avro"
 	"github.com/stretchr/testify/assert"
 
-	"github.com/honestbank/kp/v2/internal/serialization"
+	"github.com/honestbank/kp/v2/serialization"
 )
 
 func BenchmarkEncode(b *testing.B) {
diff --git a/v2/serialization/decoder.go b/v2/serialization/decoder.go
diff --git a/v2/serialization/encoder.go b/v2/serialization/encoder.go
diff --git a/v2/serialization/serialization_test.go b/v2/serialization/serialization_test.go
@@ -12,7 +12,7 @@ import (
 	"github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde/avro"
 	"github.com/stretchr/testify/assert"
 
-	"github.com/honestbank/kp/v2/internal/serialization"
+	"github.com/honestbank/kp/v2/serialization"
 )
 
 type BenchmarkMessage struct {

Original file line number	Diff line number	Diff line change
`@@ -8,8 +8,8 @@ import (`
`8`	`8`	`"github.com/confluentinc/confluent-kafka-go/v2/kafka"`
`9`	`9`	`"github.com/stretchr/testify/assert"`
`10`	`10`
`11`		`- "github.com/honestbank/kp/v2/internal/serialization"`
`12`	`11`	`"github.com/honestbank/kp/v2/middlewares/consumer"`
	`12`	`+ "github.com/honestbank/kp/v2/serialization"`
`13`	`13`	`)`
`14`	`14`
`15`	`15`	`type mockConsumer struct {`
Original file line number	Diff line number	Diff line change
`@@ -7,8 +7,8 @@ import (`
`7`	`7`
`8`	`8`	`"github.com/honestbank/kp/v2/config"`
`9`	`9`	`"github.com/honestbank/kp/v2/internal/schemaregistry"`
`10`		`- "github.com/honestbank/kp/v2/internal/serialization"`
`11`	`10`	`"github.com/honestbank/kp/v2/internal/tracing"`
	`11`	`+ "github.com/honestbank/kp/v2/serialization"`
`12`	`12`	`)`
`13`	`13`
`14`	`14`	`type producer[BodyType any] struct {`
Original file line number	Diff line number	Diff line change
`@@ -15,8 +15,8 @@ import (`
`15`	`15`	`"github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde/avro"`
`16`	`16`	`"github.com/stretchr/testify/assert"`
`17`	`17`
`18`		`- "github.com/honestbank/kp/v2/internal/serialization"`
`19`	`18`	`"github.com/honestbank/kp/v2/producer"`
	`19`	`+ "github.com/honestbank/kp/v2/serialization"`
`20`	`20`	`)`
`21`	`21`
`22`	`22`	`type MyMessage struct {`
Original file line number	Diff line number	Diff line change
`@@ -11,7 +11,7 @@ import (`
`11`	`11`	`"github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde/avro"`
`12`	`12`	`"github.com/stretchr/testify/assert"`
`13`	`13`
`14`		`- "github.com/honestbank/kp/v2/internal/serialization"`
	`14`	`+ "github.com/honestbank/kp/v2/serialization"`
`15`	`15`	`)`
`16`	`16`
`17`	`17`	`func BenchmarkEncode(b *testing.B) {`
Original file line number	Diff line number	Diff line change
`@@ -12,7 +12,7 @@ import (`
`12`	`12`	`"github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde/avro"`
`13`	`13`	`"github.com/stretchr/testify/assert"`
`14`	`14`
`15`		`- "github.com/honestbank/kp/v2/internal/serialization"`
	`15`	`+ "github.com/honestbank/kp/v2/serialization"`
`16`	`16`	`)`
`17`	`17`
`18`	`18`	`type BenchmarkMessage struct {`