Initial Amazon SQS Connector

.github/CODEOWNERS

@@ -0,0 +1,3 @@
+# Define code owners (individuals or teams that are responsible for code in this repository)
+# More about code owners at https://docs.github.com/en/repositories/managing-your-repositorys-settings-and-features/customizing-your-repository/about-code-owners
+*       @ConduitIO/conduit-core

.github/ISSUE_TEMPLATE/1-feature-request.yml

@@ -0,0 +1,11 @@
+name: 🚀 Feature Request
+description: Request a new feature.
+title: "Feature: <title>"
+labels: [feature, triage]
+body:
+- type: textarea
+  attributes:
+    label: Feature description
+    description: A clear and concise description of what you want to happen and what problem will this solve.
+  validations:
+    required: true

.github/ISSUE_TEMPLATE/2-bug.yml

@@ -0,0 +1,29 @@
+name: 🐛 Bug
+description: Report a bug.
+title: "Bug: <title>"
+labels: [bug, triage]
+body:
+- type: textarea
+  attributes:
+    label: Bug description
+    description: A concise description of what you're experiencing and what you expected to happen instead.
+  validations:
+    required: true
+- type: textarea
+  attributes:
+    label: Steps to reproduce
+    description: Steps to reproduce the behavior.
+    placeholder: |
+      1. In this environment...
+      2. With this config...
+      3. Run '...'
+      4. See error...
+  validations:
+    required: true
+- type: input
+  attributes:
+    label: Version
+    description: "Version of connector"
+    placeholder: v0.1.0 darwin/amd64
+  validations:
+    required: true

.github/ISSUE_TEMPLATE/config.yml

@@ -0,0 +1 @@
+blank_issues_enabled: true

.github/dependabot.yml

@@ -0,0 +1,19 @@
+# Docs: https://docs.github.com/en/code-security/supply-chain-security/keeping-your-dependencies-updated-automatically/configuration-options-for-dependency-updates
+version: 2
+updates:
+
+  # Maintain dependencies for GitHub Actions
+  - package-ecosystem: "github-actions"
+    directory: "/"
+    schedule:
+      interval: "daily"
+    commit-message:
+      prefix: ".github:"
+
+  # Maintain dependencies for Go
+  - package-ecosystem: "gomod"
+    directory: "/"
+    schedule:
+      interval: "daily"
+    commit-message:
+      prefix: "go.mod:"

.github/pull_request_template.md

@@ -0,0 +1,13 @@
+### Description
+
+Please include a summary of the change and what type of change it is (new feature, bug fix, refactoring, documentation).
+Please also include relevant motivation and context.
+List any dependencies that are required for this change.
+
+Fixes # (issue)
+
+### Quick checks:
+
+- [ ] There is no other [pull request](https://github.com/conduitio/conduit-connector-connectorname/pulls) for the same update/change.
+- [ ] I have written unit tests.
+- [ ] I have made sure that the PR is of reasonable size and can be easily reviewed.

.github/workflows/build.yml

@@ -0,0 +1,20 @@
+name: build
+
+on:
+  push:
+    branches: [ main ]
+  pull_request:
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+
+      - name: Set up Go
+        uses: actions/setup-go@v4
+        with:
+          go-version: '1.21'
+
+      - name: Test
+        run: make test"

.github/workflows/dependabot-auto-merge-go.yml

@@ -0,0 +1,39 @@
+# This action automatically merges dependabot PRs that update go dependencies (only patch and minor updates).
+# Based on: https://docs.github.com/en/code-security/supply-chain-security/keeping-your-dependencies-updated-automatically/automating-dependabot-with-github-actions#enable-auto-merge-on-a-pull-request 
+
+name: Dependabot auto-merge
+on:
+  pull_request:
+    # Run this action when dependabot labels the PR, we care about the 'go' label.
+    types: [labeled]
+
+permissions:
+  pull-requests: write
+  contents: write
+
+jobs:
+  dependabot-go:
+    runs-on: ubuntu-latest
+    if: ${{ github.actor == 'dependabot[bot]' && contains(github.event.pull_request.labels.*.name, 'go') }}
+    steps:
+      - name: Dependabot metadata
+        id: metadata
+        uses: dependabot/fetch-metadata@v1.6.0
+        with:
+          github-token: "${{ secrets.GITHUB_TOKEN }}"
+
+      - name: Approve PR
+        # Approve only patch and minor updates
+        if: ${{ steps.metadata.outputs.update-type != 'version-update:semver-major' }}
+        run: gh pr review --approve "$PR_URL"
+        env:
+          PR_URL: ${{ github.event.pull_request.html_url }}
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+
+      - name: Enable auto-merge for Dependabot PRs
+        # Enable auto-merging only for patch and minor updates
+        if: ${{ steps.metadata.outputs.update-type != 'version-update:semver-major' }}
+        run: gh pr merge --auto --squash "$PR_URL"
+        env:
+          PR_URL: ${{ github.event.pull_request.html_url }}
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}

.github/workflows/lint.yml

@@ -0,0 +1,19 @@
+name: lint
+
+on:
+  push:
+    branches: [ main ]
+  pull_request:
+
+jobs:
+  golangci-lint:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: actions/setup-go@v4
+        with:
+          go-version: '1.21'
+
+      - name: golangci-lint
+        uses: golangci/golangci-lint-action@v3
+

.github/workflows/release.yml

@@ -0,0 +1,33 @@
+name: release
+
+on:
+  push:
+    tags:
+      - v*
+
+permissions:
+  contents: write
+
+jobs:
+  release:
+    name: Release
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v4
+        with:
+          fetch-depth: 0
+
+      - name: Set up Go
+        uses: actions/setup-go@v4
+        with:
+          go-version: '1.20'
+
+      - name: Run GoReleaser
+        uses: goreleaser/goreleaser-action@v5
+        with:
+          distribution: goreleaser
+          version: latest
+          args: release --rm-dist
+        env:
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}

.golangci.yml

@@ -11,14 +11,6 @@ linters-settings:
     min-complexity: 20
   goconst:
     ignore-tests: true
-  goheader:
-    template-path: '.golangci.goheader.template'
-    values:
-      regexp:
-        copyright-year: 20[2-9]\d
-        authors: Meroxa\, Inc\.( \& Yalantis)?
-  lll:
-    line-length: 120
 
 linters:
   # please, do not use `enable-all`: it's deprecated and will be removed soon.
@@ -43,11 +35,12 @@ linters:
     - gocritic
     - gocyclo
     # - cyclop # not interested in package complexities at the moment
-    - godot
+    # - godot
     - gofmt
     # - gofumpt
+    - goheader
     - goimports
-    - revive
+    # - revive # lots of unused parameters in the template, would be helpful for the user to keep them
     # - gomnd
     - gomoddirectives
     - gomodguard
@@ -58,21 +51,21 @@ linters:
     # - ifshort
     - ineffassign
     # - importas
-    - lll
+    # - lll
     # - misspell
     - makezero
     # - nakedret
     # - nilerr
     # - nilnil
-    - nlreturn
+    # - nlreturn
     - noctx
     - nolintlint
     # - paralleltest
     - predeclared
-    - rowserrcheck
+    # - rowserrcheck
     - staticcheck
     - stylecheck
-    - sqlclosecheck
+    # - sqlclosecheck
     # - tagliatelle
     # - tenv
     # - thelper
@@ -81,20 +74,7 @@ linters:
     - unconvert
     # - unparam
     - unused
-    - wastedassign
+    # - wastedassign
     - whitespace
-  # - wrapcheck
-  # - wsl
-
-  # don't enable:
-  # - asciicheck
-  # - dupl
-  # - gochecknoglobals
-  # - gocognit
-  # - godox
-  # - goerr113
-  # - maligned
-  # - nestif
-  # - prealloc
-  # - testpackage
-  # - wsl
+    # - wrapcheck
+    # - wsl

.goreleaser.yml

@@ -1,22 +1,23 @@
 builds:
-  - main: ./cmd/sqs/main.go
+  - main: ./cmd/connector/main.go
     goos:
       - darwin
       - linux
       - windows
     env:
       - CGO_ENABLED=0
     ldflags:
-      - "-s -w -X 'github.com/conduitio-labs/conduit-connector-amazon-sqs.version={{ .Tag }}'"
+      - "-s -w -X 'github.com/conduitio/conduit-connector-connectorname.version={{ .Tag }}'"
 checksum:
   name_template: checksums.txt
 archives:
-  - replacements:
-      darwin: Darwin
-      linux: Linux
-      windows: Windows
-      386: i386
-      amd64: x86_64
+  - name_template: >-
+      {{ .ProjectName }}_
+      {{- .Version }}_
+      {{- title .Os }}_
+      {{- if eq .Arch "amd64" }}x86_64
+      {{- else if eq .Arch "386" }}i386
+      {{- else }}{{ .Arch }}{{ end }}
 changelog:
   sort: asc
   use: github
@@ -26,4 +27,4 @@ changelog:
       - '^test:'
       - '^go.mod:'
       - '^.github:'
-      - Merge branch
+      - Merge branch

Makefile

@@ -1,6 +1,4 @@
-GOLANG_CI_LINT_VER	:= 	v1.54.2
-VERSION				:=	v0.1.0-dev
-
+VERSION=$(shell git describe --tags --dirty --always)
 .PHONY:
 build:
 	go build -ldflags "-X 'github.com/meroxa/conduit-connector-amazon-sqs.version=${VERSION}'" -o conduit-connector-amazon-sqs cmd/sqs/main.go
@@ -11,8 +9,11 @@ test:
 
 .PHONY: golangci-lint-install
 golangci-lint-install:
-	go install github.com/golangci/golangci-lint/cmd/golangci-lint@$(GOLANG_CI_LINT_VER)
+	go install github.com/golangci/golangci-lint/cmd/golangci-lint
 
 .PHONY:
 lint:
 	golangci-lint run -c .golangci.yml
+
+install-paramgen:
+	go install github.com/conduitio/conduit-connector-sdk/cmd/paramgen@latest

cmd/sqs/main.go

@@ -1,8 +1,8 @@
 package main
 
 import (
+	sqs "github.com/conduitio-labs/conduit-connector-sqs"
 	sdk "github.com/conduitio/conduit-connector-sdk"
-	sqs "github.com/meroxa/conduit-connector-amazon-sqs"
 )
 
 func main() {

config/config.go

@@ -1,43 +1 @@
 package config
-
-type Config struct {
-	AWSAccessKeyID     string `json:"aws.accessKeyId" validate:"required"`
-	AWSSecretAccessKey string `json:"aws.secretAccessKey" validate:"required"`
-	AWSToken           string `json:"aws.token"`
-	AWSQueue           string `json:"aws.queue" validate:"required"`
-}
-
-const (
-	ConfigKeyAWSAccessKeyID = "aws.accessKeyId"
-
-	ConfigKeyAWSSecretAccessKey = "aws.secretAccessKey"
-
-	ConfigKeyAWSToken = "aws.token"
-
-	ConfigKeyAWSQueue = "aws.queue"
-)
-
-func ParseConfig(cfg map[string]string) (Config, error) {
-	var parsed Config
-	key, ok := cfg[ConfigKeyAWSAccessKeyID]
-	if ok {
-		parsed.AWSAccessKeyID = key
-	}
-
-	secret, ok := cfg[ConfigKeyAWSSecretAccessKey]
-	if ok {
-		parsed.AWSSecretAccessKey = secret
-	}
-
-	token, ok := cfg[ConfigKeyAWSToken]
-	if ok {
-		parsed.AWSToken = token
-	}
-
-	queue, ok := cfg[ConfigKeyAWSQueue]
-	if ok {
-		parsed.AWSQueue = queue
-	}
-
-	return parsed, nil
-}