.gitea/workflows/ build_check.yaml

@@ -1,39 +0,0 @@
-name: Gitea Build Check
-run-name: ${{ gitea.actor }} is testing the build
-on:
-  push:
-    branches:
-      - main
-  pull_request:
-    branches: [ "main" ]
-
-jobs:
-  Build:
-    runs-on: ubuntu-latest
-    steps:
-      - uses: actions/checkout@v4
-        with:
-          fetch-depth: 0  # Shallow clones should be disabled for a better relevancy of analysis
-
-      - name: Setup Go environment
-        uses: https://github.com/actions/setup-go@v5
-        with:
-          # The Go version to download (if necessary) and use. Supports semver spec and ranges.
-          go-version: 1.22.0 # optional
-          # Path to the go.mod file.
-          go-version-file: ./go.mod # optional
-          # Set this option to true if you want the action to always check for the latest available version that satisfies the version spec
-          check-latest: true # optional
-          # Used to specify whether caching is needed. Set to true, if you'd like to enable caching.
-          cache: true # optional
-
-      - name: Execute Go Test files with coverage report
-        run: TESTCONTAINERS_RYUK_DISABLED=true go test -v ./... -json -coverprofile="coverage.out" | tee "test-report.out"
-
-      - uses: sonarsource/sonarqube-scan-action@master
-        env:
-          SONAR_TOKEN: ${{ secrets.SONAR_TOKEN }}
-          SONAR_HOST_URL: ${{ vars.SONAR_HOST_URL }}
-        with:
-          args: >
-            -Dsonar.projectKey=Anthrove---plug-sdk

pkg/plug/grpc.go

@@ -2,11 +2,10 @@ package plug
 
 import (
 	"context"
-	"log"
-
 	"git.dragse.it/anthrove/otter-space-sdk/v2/pkg/database"
 	"git.dragse.it/anthrove/otter-space-sdk/v2/pkg/models"
 	"google.golang.org/protobuf/types/known/timestamppb"
+	"log"
 
 	gRPC "git.dragse.it/anthrove/plug-sdk/pkg/grpc"
 	gonanoid "github.com/matoous/go-nanoid/v2"
@@ -17,15 +16,13 @@ type server struct {
 	ctx                   map[string]context.CancelFunc
 	database              database.OtterSpace
 	taskExecutionFunction TaskExecution
-	sendMessageExecution  SendMessageExecution
 }
 
-func NewGrpcServer(database database.OtterSpace, taskExecutionFunction TaskExecution, sendMessageExecution SendMessageExecution) gRPC.PlugConnectorServer {
+func NewGrpcServer(database database.OtterSpace, taskExecutionFunction TaskExecution) gRPC.PlugConnectorServer {
 	return &server{
 		ctx:                   make(map[string]context.CancelFunc),
 		database:              database,
 		taskExecutionFunction: taskExecutionFunction,
-		sendMessageExecution:  sendMessageExecution,
 	}
 }
 
@@ -52,7 +49,7 @@ func (s *server) TaskStart(ctx context.Context, creation *gRPC.PlugTaskCreation)
 
 	go func() {
 		// FIXME: better implement this methode, works for now but needs refactoring
-		err := s.taskExecutionFunction(ctx, s.database, creation.UserSourceName, anthroveUser, creation.DeepScrape, creation.ApiKey, func() {
+		err := s.taskExecutionFunction(ctx, s.database, creation.UserSourceName, anthroveUser, creation.DeepScrape, func() {
 			s.removeTask(id)
 		})
 		if err != nil {
@@ -104,14 +101,3 @@ func (s *server) Ping(_ context.Context, request *gRPC.PingRequest) (*gRPC.PongR
 	}
 	return &response, nil
 }
-
-func (s *server) SendMessage(ctx context.Context, request *gRPC.SendMessageRequest) (*gRPC.SendMessageResponse, error) {
-	messageResponse := gRPC.SendMessageResponse{Success: true}
-
-	err := s.sendMessageExecution(ctx, request.UserId, request.Message)
-	if err != nil {
-		return nil, err
-	}
-
-	return &messageResponse, nil
-}

pkg/plug/server.go

@@ -14,7 +14,7 @@ import (
 )
 
 type TaskExecution func(ctx context.Context, database database.OtterSpace, sourceUsername string, anthroveUser models.User, deepScrape bool, apiKey string, cancelFunction func()) error
-type SendMessageExecution func(ctx context.Context, userSourceID string, message string) error
+type SendMessageExecution func(ctx context.Context, userSourceID string, message string)
 
 type Plug struct {
 	address               string
@@ -58,7 +58,7 @@ func (p *Plug) Listen() error {
 
 	grpcServer := grpc.NewServer()
 
-	pb.RegisterPlugConnectorServer(grpcServer, NewGrpcServer(p.database, p.taskExecutionFunction, p.sendMessageExecution))
+	pb.RegisterPlugConnectorServer(grpcServer, NewGrpcServer(p.database, p.taskExecutionFunction))
 
 	err = grpcServer.Serve(lis)
 	if err != nil {