refactor: remove consumers implementation and duplicate tools

Signed-off-by: Felix Gateru <[email protected]>

.github/workflows/api-tests.yml

@@ -15,7 +15,6 @@ on:
       - "certs/api/**"
       - "channels/api/http/**"
       - "clients/api/http/**"
-      - "consumers/notifiers/api/**"
       - "domains/api/http/**"
       - "groups/api/http/**"
       - "http/api/**"

.github/workflows/check-generated-files.yml

@@ -65,9 +65,6 @@ jobs:
               - "users/emailer.go"
               - "users/hasher.go"
               - "mqtt/events/streams.go"
-              - "consumers/notifiers/notifier.go"
-              - "consumers/notifiers/service.go"
-              - "consumers/notifiers/subscriptions.go"
               - "certs/certs.go"
               - "certs/pki/vault.go"
               - "certs/service.go"
@@ -150,9 +147,6 @@ jobs:
           mv ./users/mocks/service.go ./users/mocks/service.go.tmp
           mv ./journal/mocks/repository.go ./journal/mocks/repository.go.tmp
           mv ./journal/mocks/service.go ./journal/mocks/service.go.tmp
-          mv ./consumers/notifiers/mocks/notifier.go ./consumers/notifiers/mocks/notifier.go.tmp
-          mv ./consumers/notifiers/mocks/repository.go ./consumers/notifiers/mocks/repository.go.tmp
-          mv ./consumers/notifiers/mocks/service.go ./consumers/notifiers/mocks/service.go.tmp
           mv ./certs/mocks/pki.go ./certs/mocks/pki.go.tmp
           mv ./certs/mocks/service.go ./certs/mocks/service.go.tmp
           mv ./provision/mocks/service.go ./provision/mocks/service.go.tmp
@@ -215,9 +209,6 @@ jobs:
           check_mock_changes ./users/mocks/service.go " ./users/mocks/service.go"
           check_mock_changes ./journal/mocks/repository.go " ./journal/mocks/repository.go"
           check_mock_changes ./journal/mocks/service.go " ./journal/mocks/service.go"
-          check_mock_changes ./consumers/notifiers/mocks/notifier.go " ./consumers/notifiers/mocks/notifier.go"
-          check_mock_changes ./consumers/notifiers/mocks/repository.go " ./consumers/notifiers/mocks/repository.go"
-          check_mock_changes ./consumers/notifiers/mocks/service.go " ./consumers/notifiers/mocks/service.go"
           check_mock_changes ./certs/mocks/pki.go " ./certs/mocks/pki.go"
           check_mock_changes ./certs/mocks/service.go " ./certs/mocks/service.go"
           check_mock_changes ./provision/mocks/service.go " ./provision/mocks/service.go"

.github/workflows/tests.yml

@@ -139,19 +139,6 @@ jobs:
               - "auth_grpc.pb.go"
               - "clients/**"
               - "pkg/messaging/**"
-
-            consumers:
-              - "consumers/**"
-              - "cmd/postgres-writer/**"
-              - "cmd/timescale-writer/**"
-              - "cmd/smpp-notifier/**"
-              - "cmd/smtp-notifier/**"
-              - "auth.pb.go"
-              - "auth_grpc.pb.go"
-              - "auth/**"
-              - "pkg/ulid/**"
-              - "pkg/uuid/**"
-              - "pkg/messaging/**"
 
             domains:
               - "domain/**"
@@ -318,11 +305,6 @@ jobs:
         run: |
           go test --race -v -count=1 -coverprofile=coverage/coap.out ./coap/...
 
-      - name: Run consumers tests
-        if: steps.changes.outputs.consumers == 'true' || steps.changes.outputs.workflow == 'true'
-        run: |
-          go test --race -v -count=1 -coverprofile=coverage/consumers.out ./consumers/...
-
       - name: Run HTTP tests
         if: steps.changes.outputs.http == 'true' || steps.changes.outputs.workflow == 'true'
         run: |

Makefile

@@ -3,9 +3,9 @@
 
 SMQ_DOCKER_IMAGE_NAME_PREFIX ?= supermq
 BUILD_DIR ?= build
-SERVICES = auth users clients groups channels domains http coap ws postgres-writer timescale-writer \
-	cli bootstrap mqtt provision certs invitations journal
-TEST_API_SERVICES = journal auth bootstrap certs http invitations notifiers provision clients users channels groups domains
+SERVICES = auth users clients groups channels domains http coap ws cli bootstrap mqtt provision certs \
+	invitations journal
+TEST_API_SERVICES = journal auth bootstrap certs http invitations provision clients users channels groups domains
 TEST_API = $(addprefix test_api_,$(TEST_API_SERVICES))
 DOCKERS = $(addprefix docker_,$(SERVICES))
 DOCKERS_DEV = $(addprefix docker_dev_,$(SERVICES))
@@ -73,7 +73,7 @@ define make_docker_dev
 		-f docker/Dockerfile.dev ./build
 endef
 
-ADDON_SERVICES = bootstrap journal provision certs timescale-writer postgres-writer
+ADDON_SERVICES = bootstrap journal provision certs
 
 EXTERNAL_SERVICES = vault prometheus