Implement command and reply

.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 SDK"
+    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: "weekly"
+    commit-message:
+      prefix: ".github:"
+
+  # Maintain dependencies for Go
+  - package-ecosystem: "gomod"
+    directory: "/"
+    schedule:
+      interval: "weekly"
+    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-processor-sdk/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/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/[email protected]
+        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,30 @@
+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-file: 'go.mod'
+
+      # This step sets up the variable steps.golangci-lint-version.outputs.v
+      # to contain the version of golangci-lint (e.g. v1.54.2).
+      # The version is taken from go.mod.
+      - name: Golangci-lint version
+        id: golangci-lint-version
+        run: |
+          GOLANGCI_LINT_VERSION=$( go list -m -f '{{.Version}}' github.com/golangci/golangci-lint )
+          echo "v=$GOLANGCI_LINT_VERSION" >> "$GITHUB_OUTPUT"
+
+      - name: golangci-lint
+        uses: golangci/golangci-lint-action@v3
+        with:
+          version: ${{ steps.golangci-lint-version.outputs.v }}
+          skip-pkg-cache: true

.github/workflows/test.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-file: 'go.mod'
+
+      - name: Test
+        run: make test

.gitignore

@@ -0,0 +1 @@
+.idea/

.golangci.goheader.template

@@ -0,0 +1,13 @@
+Copyright © {{ copyright-year }} Meroxa, Inc.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.

.golangci.yml

@@ -0,0 +1,117 @@
+run:
+  timeout: 3m
+  build-tags:
+    - lint
+
+linters-settings:
+  gofmt:
+    simplify: false
+  govet:
+    check-shadowing: false # TODO enable
+  nolintlint:
+    allow-unused: false # report any unused nolint directives
+    require-explanation: true # require an explanation for nolint directives
+    require-specific: true # require nolint directives to mention the specific linter being suppressed
+  gocyclo:
+    min-complexity: 20
+  goconst:
+    ignore-tests: true
+  goheader:
+    template-path: '.golangci.goheader.template'
+    values:
+      regexp:
+        copyright-year: 20[2-9]\d
+
+issues:
+  exclude-rules:
+    - path: '(.+)acceptance_testing\.go'
+      linters:
+        - stylecheck
+      text: "ST1003: should not use underscores in Go names"
+    # Exclude some linters from running on tests files.
+    - path: _test\.go
+      linters:
+        - dogsled
+        - gosec
+
+linters:
+  # please, do not use `enable-all`: it's deprecated and will be removed soon.
+  # inverted configuration with `enable-all` and `disable` is not scalable during updates of golangci-lint
+  disable-all: true
+  enable:
+    # We plan to enable all of the linters which are commented out.
+    # However, we want to enable them one by one (so we don't have to fix many issues at once).
+    - bodyclose
+    # - depguard
+    - dogsled
+    - durationcheck
+    - errcheck
+    - errname
+    # - errorlint
+    # - exhaustive
+    # - exhaustivestruct
+    - exportloopref
+    # - forbidigo
+    # - forcetypeassert
+    # - funlen
+    # - gochecknoinits
+    - goconst
+    - gocritic
+    - gocyclo
+    # - cyclop # not interested in package complexities at the moment
+    # - godot
+    - gofmt
+    # - gofumpt
+    - goheader
+    - goimports
+    - revive
+    # - gomnd
+    - gomoddirectives
+    - gomodguard
+    - goprintffuncname
+    - gosec
+    - gosimple
+    - govet
+    # - ifshort
+    - ineffassign
+    # - importas
+    # - lll
+    # - misspell
+    - makezero
+    # - nakedret
+    # - nilerr
+    # - nilnil
+    # - nlreturn
+    - noctx
+    - nolintlint
+    # - paralleltest
+    - predeclared
+    - rowserrcheck
+    - staticcheck
+    - stylecheck
+    - sqlclosecheck
+    # - tagliatelle
+    # - tenv
+    # - thelper
+    # - tparallel
+    - typecheck
+    - unconvert
+    # - unparam
+    - unused
+    - wastedassign
+    - whitespace
+  # - wrapcheck
+  # - wsl
+
+  # don't enable:
+  # - asciicheck
+  # - dupl
+  # - gochecknoglobals
+  # - gocognit
+  # - godox
+  # - goerr113
+  # - maligned
+  # - nestif
+  # - prealloc
+  # - testpackage
+  # - wsl

Makefile

@@ -0,0 +1,21 @@
+.PHONY: test
+test:
+	go test $(GOTEST_FLAGS) -race ./...
+
+.PHONY: lint
+lint:
+	golangci-lint run
+
+.PHONY: fmt
+fmt:
+	gofumpt -l -w .
+
+.PHONY: install-tools
+install-tools:
+	@echo Installing tools from tools.go
+	@go list -e -f '{{ join .Imports "\n" }}' tools.go | xargs -tI % go install %
+	@go mod tidy
+
+.PHONY: generate
+generate:
+	go generate ./...

command.go

@@ -0,0 +1,19 @@
+// Copyright © 2023 Meroxa, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package sdk
+
+type Command struct {
+	Name string `json:"name"`
+}