Generate connector yaml (#180)

.github/workflows/release.yml

@@ -3,7 +3,7 @@ name: release
 on:
   push:
     tags:
-      - v*
+      - '*'
 
 permissions:
   contents: write
@@ -18,6 +18,50 @@ jobs:
         with:
           fetch-depth: 0
 
+      - name: Validate Tag Format
+        run: |
+          TAG=${GITHUB_REF#refs/tags/}
+          
+          SV_REGEX="^v(0|[1-9][0-9]*)\.(0|[1-9][0-9]*)\.(0|[1-9][0-9]*)(-((0|[1-9][0-9]*|[0-9]*[a-zA-Z-][0-9a-zA-Z-]*)(\.(0|[1-9][0-9]*|[0-9]*[a-zA-Z-][0-9a-zA-Z-]*))*))?(\+([0-9a-zA-Z-]+(\.[0-9a-zA-Z-]+)*))?$"
+
+          if ! [[ $TAG =~ $SV_REGEX ]]; then
+            echo "$TAG is NOT a valid tag (expected format: v<semver>)"
+            exit 1
+          fi
+
+      - name: Check Version Consistency
+        run: |
+          # Extract tag and remove 'v' prefix if exists
+          TAG=${GITHUB_REF#refs/tags/}
+          
+          # Read version from connector.yaml
+          YAML_VERSION=$(yq e '.specification.version' connector.yaml)
+          
+          # Compare versions
+          if [[ "$TAG" != "$YAML_VERSION" ]]; then
+            echo "Version mismatch detected:"
+            echo "Git Tag: $TAG"
+            echo "connector.yaml Version: $YAML_VERSION"
+            exit 1
+          fi
+
+      - name: Delete Invalid Tag
+        if: failure()
+        uses: actions/github-script@v7
+        with:
+          github-token: ${{secrets.GITHUB_TOKEN}}
+          script: |
+            const tag = context.ref.replace('refs/tags/', '')
+            try {
+              await github.rest.git.deleteRef({
+                owner: context.repo.owner,
+                repo: context.repo.repo,
+                ref: `tags/${tag}`
+              })
+            } catch (error) {
+              console.log('Error deleting tag:', error)
+            }
+
       - name: Set up Go
         uses: actions/setup-go@v5
         with:

Makefile

@@ -26,6 +26,7 @@ test: test-kafka test-redpanda
 .PHONY: generate
 generate:
 	go generate ./...
+	conn-sdk-cli readmegen -w
 
 .PHONY: fmt
 fmt: ## Format Go files using gofumpt and gci.

common/config.go

@@ -43,13 +43,13 @@ type Config struct {
 }
 
 // Validate executes manual validations beyond what is defined in struct tags.
-func (c Config) Validate() error {
+func (c Config) Validate(ctx context.Context) error {
 	var multierr []error
 
-	if err := c.ConfigSASL.Validate(); err != nil {
+	if err := c.ConfigSASL.Validate(ctx); err != nil {
 		multierr = append(multierr, err)
 	}
-	if err := c.ConfigTLS.Validate(); err != nil {
+	if err := c.ConfigTLS.Validate(ctx); err != nil {
 		multierr = append(multierr, err)
 	}
 

common/config_test.go

@@ -76,7 +76,7 @@ func TestConfig_Validate(t *testing.T) {
 	for _, tc := range testCases {
 		t.Run(tc.name, func(t *testing.T) {
 			is := is.New(t)
-			err := tc.cfg.Validate()
+			err := tc.cfg.Validate(context.Background())
 			is.True(err != nil)
 			if actualErr, ok := tc.wantErr.(error); ok {
 				is.True(errors.Is(err, actualErr))

common/sasl.go

@@ -15,6 +15,7 @@
 package common
 
 import (
+	"context"
 	"errors"
 	"fmt"
 
@@ -36,7 +37,7 @@ type ConfigSASL struct {
 }
 
 // Validate executes manual validations beyond what is defined in struct tags.
-func (c ConfigSASL) Validate() error {
+func (c ConfigSASL) Validate(context.Context) error {
 	var multierr []error
 
 	if _, err := c.sasl(); err != nil {

common/tls.go

@@ -15,6 +15,7 @@
 package common
 
 import (
+	"context"
 	"crypto/tls"
 	"crypto/x509"
 	"fmt"
@@ -36,7 +37,7 @@ type ConfigTLS struct {
 }
 
 // Validate executes manual validations beyond what is defined in struct tags.
-func (c ConfigTLS) Validate() error {
+func (c ConfigTLS) Validate(context.Context) error {
 	_, err := c.tls()
 	return err
 }

connector.go

@@ -12,16 +12,25 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
+//go:generate conn-sdk-cli specgen
+
 // Package kafka contains implementations for Kafka source and destination
 // connectors for Conduit.
 package kafka
 
 import (
+	_ "embed"
+
 	sdk "github.com/conduitio/conduit-connector-sdk"
 )
 
+//go:embed connector.yaml
+var specs string
+
+var version = "(devel)"
+
 var Connector = sdk.Connector{
-	NewSpecification: Specification,
+	NewSpecification: sdk.YAMLSpecification(specs, version),
 	NewSource:        NewSource,
 	NewDestination:   NewDestination,
 }