feat(third-party-integrations): generic dispatcher (#142)

Signed-off-by: Miguel Martinez Trivino <miguel@chainloop.dev>

Author: migmartri

app/controlplane/cmd/wire.go

@@ -22,9 +22,9 @@ package main
 
 import (
 	"github.com/chainloop-dev/chainloop/app/controlplane/internal/biz"
-	"github.com/chainloop-dev/chainloop/app/controlplane/internal/biz/integration"
 	"github.com/chainloop-dev/chainloop/app/controlplane/internal/conf"
 	"github.com/chainloop-dev/chainloop/app/controlplane/internal/data"
+	"github.com/chainloop-dev/chainloop/app/controlplane/internal/dispatcher"
 	"github.com/chainloop-dev/chainloop/app/controlplane/internal/server"
 	"github.com/chainloop-dev/chainloop/app/controlplane/internal/service"
 	backend "github.com/chainloop-dev/chainloop/internal/blobmanager"
@@ -41,7 +41,6 @@ func wireApp(*conf.Bootstrap, credentials.ReaderWriter, log.Logger) (*app, func(
 			server.ProviderSet,
 			data.ProviderSet,
 			biz.ProviderSet,
-			integration.ProviderSet,
 			service.ProviderSet,
 			wire.Bind(new(backend.Provider), new(*oci.BackendProvider)),
 			wire.Bind(new(biz.CASClient), new(*biz.CASClientUseCase)),
@@ -50,6 +49,7 @@ func wireApp(*conf.Bootstrap, credentials.ReaderWriter, log.Logger) (*app, func(
 			wire.Value([]biz.CASClientOpts{}),
 			wire.FieldsOf(new(*conf.Bootstrap), "Server", "Auth", "Data", "CasServer"),
 			loadIntegrations,
+			dispatcher.New,
 			newApp,
 		),
 	)

app/controlplane/cmd/wire_gen.go

@@ -117,7 +117,7 @@ func (uc *IntegrationUseCase) RegisterAndSave(ctx context.Context, orgID string,
 	}
 
 	// Persist the integration configuration
-	return uc.integrationRepo.Create(ctx, orgUUID, preRegistration.Kind, secretID, config)
+	return uc.integrationRepo.Create(ctx, orgUUID, i.Describe().ID, secretID, config)
 }
 
 type AttachOpts struct {
@@ -251,6 +251,7 @@ func (uc *IntegrationUseCase) Delete(ctx context.Context, orgID, integrationID s
 	return uc.integrationRepo.SoftDelete(ctx, integrationUUID)
 }
 
+// List attachments returns the list of attachments for a given organization and optionally workflow
 func (uc *IntegrationUseCase) ListAttachments(ctx context.Context, orgID, workflowID string) ([]*IntegrationAttachment, error) {
 	orgUUID, err := uuid.Parse(orgID)
 	if err != nil {
@@ -264,6 +265,15 @@ func (uc *IntegrationUseCase) ListAttachments(ctx context.Context, orgID, workfl
 		if err != nil {
 			return nil, NewErrInvalidUUID(err)
 		}
+
+		// We check that the workflow belongs to the provided organization
+		// This check is mostly informative to the user
+		wf, err := uc.workflowRepo.GetOrgScoped(ctx, orgUUID, workflowUUID)
+		if err != nil {
+			return nil, err
+		} else if wf == nil {
+			return nil, NewErrNotFound("workflow")
+		}
 	}
 
 	return uc.integrationARepo.List(ctx, orgUUID, workflowUUID)