Move eventing outside of internal

Dockerfile

@@ -19,6 +19,7 @@ RUN go mod download
 COPY api ./api
 COPY cmd ./cmd
 COPY internal ./internal
+COPY eventing ./eventing
 COPY main.go Makefile ./
 
 ARG VERSION

cmd/serve/serve.go

@@ -23,11 +23,11 @@ import (
 
 	"github.com/go-kratos/kratos/v2/log"
 
+	eventing "github.com/project-kessel/inventory-api/eventing"
+	eventingapi "github.com/project-kessel/inventory-api/eventing/api"
 	"github.com/project-kessel/inventory-api/internal/authn"
 	"github.com/project-kessel/inventory-api/internal/authz"
 	"github.com/project-kessel/inventory-api/internal/errors"
-	"github.com/project-kessel/inventory-api/internal/eventing"
-	eventingapi "github.com/project-kessel/inventory-api/internal/eventing/api"
 	"github.com/project-kessel/inventory-api/internal/middleware"
 	"github.com/project-kessel/inventory-api/internal/server"
 	"github.com/project-kessel/inventory-api/internal/storage"

internal/eventing/config.go → eventing/config.go

@@ -1,7 +1,7 @@
 package eventing
 
 import (
-	"github.com/project-kessel/inventory-api/internal/eventing/kafka"
+	"github.com/project-kessel/inventory-api/eventing/kafka"
 )
 
 type Config struct {

internal/eventing/factory.go → eventing/factory.go

@@ -2,12 +2,11 @@ package eventing
 
 import (
 	"fmt"
+	"github.com/project-kessel/inventory-api/eventing/api"
+	"github.com/project-kessel/inventory-api/eventing/kafka"
+	"github.com/project-kessel/inventory-api/eventing/stdout"
 
 	"github.com/go-kratos/kratos/v2/log"
-
-	"github.com/project-kessel/inventory-api/internal/eventing/api"
-	"github.com/project-kessel/inventory-api/internal/eventing/kafka"
-	"github.com/project-kessel/inventory-api/internal/eventing/stdout"
 )
 
 func New(c CompletedConfig, source string, logger *log.Helper) (api.Manager, error) {

internal/eventing/kafka/manager.go → eventing/kafka/manager.go

@@ -8,12 +8,12 @@ import (
 	"github.com/confluentinc/confluent-kafka-go/v2/kafka"
 	"github.com/go-kratos/kratos/v2/log"
 	"github.com/google/uuid"
+	eventingapi "github.com/project-kessel/inventory-api/eventing/api"
 	"go.opentelemetry.io/otel"
 	"go.opentelemetry.io/otel/attribute"
 	"go.opentelemetry.io/otel/metric"
 
 	authnapi "github.com/project-kessel/inventory-api/internal/authn/api"
-	"github.com/project-kessel/inventory-api/internal/eventing/api"
 )
 
 type KafkaManager struct {
@@ -93,7 +93,7 @@ func (m *KafkaManager) Errs() <-chan error {
 }
 
 // Lookup figures out which topic should be used for the given identity and resource.
-func (m *KafkaManager) Lookup(identity *authnapi.Identity, resource_type string, resource_id uuid.UUID) (api.Producer, error) {
+func (m *KafkaManager) Lookup(identity *authnapi.Identity, resource_type string, resource_id uuid.UUID) (eventingapi.Producer, error) {
 
 	// there is no complicated topic dispatch logic... for now.
 	producer, err := NewProducer(m, m.Config.DefaultTopic, identity)
@@ -139,7 +139,7 @@ func NewProducer(manager *KafkaManager, topic string, identity *authnapi.Identit
 }
 
 // Produce creates the cloud event and sends it on the Kafka Topic
-func (p *kafkaProducer) Produce(ctx context.Context, event *api.Event) error {
+func (p *kafkaProducer) Produce(ctx context.Context, event *eventingapi.Event) error {
 	e := cloudevents.NewEvent()
 
 	e.SetSpecVersion(cloudevents.VersionV1)

internal/eventing/options.go → eventing/options.go

@@ -2,8 +2,8 @@ package eventing
 
 import (
 	"errors"
+	"github.com/project-kessel/inventory-api/eventing/kafka"
 
-	"github.com/project-kessel/inventory-api/internal/eventing/kafka"
 	"github.com/spf13/pflag"
 )
 

internal/eventing/stdout/manager.go → eventing/stdout/manager.go

@@ -4,11 +4,11 @@ import (
 	"context"
 	"encoding/json"
 	"github.com/google/uuid"
+	eventingapi "github.com/project-kessel/inventory-api/eventing/api"
 	"os"
 
 	"github.com/go-kratos/kratos/v2/log"
 	authnapi "github.com/project-kessel/inventory-api/internal/authn/api"
-	"github.com/project-kessel/inventory-api/internal/eventing/api"
 )
 
 type StdOutManager struct {
@@ -28,7 +28,7 @@ func New(logger *log.Helper) (*StdOutManager, error) {
 	}, nil
 }
 
-func (p *StdOutManager) Produce(ctx context.Context, event *api.Event) error {
+func (p *StdOutManager) Produce(ctx context.Context, event *eventingapi.Event) error {
 	return p.Encoder.Encode(event)
 }
 
@@ -37,7 +37,7 @@ func (m *StdOutManager) Errs() <-chan error {
 }
 
 // Lookup figures out which Producer should be used for the given identity and resource.
-func (m *StdOutManager) Lookup(identity *authnapi.Identity, resource_type string, resource_id uuid.UUID) (api.Producer, error) {
+func (m *StdOutManager) Lookup(identity *authnapi.Identity, resource_type string, resource_id uuid.UUID) (eventingapi.Producer, error) {
 	return m, nil
 }
 

internal/biz/common.go

@@ -2,21 +2,21 @@ package biz
 
 import (
 	"context"
+	"github.com/project-kessel/inventory-api/eventing/api"
 	authzapi "github.com/project-kessel/inventory-api/internal/authz/api"
 	"github.com/project-kessel/inventory-api/internal/biz/model"
-	eventingapi "github.com/project-kessel/inventory-api/internal/eventing/api"
 	"github.com/project-kessel/inventory-api/internal/middleware"
 	"time"
 )
 
-func DefaultResourceSendEvent(ctx context.Context, model *model.Resource, eventer eventingapi.Manager, reportedTime time.Time, operationType eventingapi.OperationType) error {
+func DefaultResourceSendEvent(ctx context.Context, model *model.Resource, eventer api.Manager, reportedTime time.Time, operationType api.OperationType) error {
 	identity, err := middleware.GetIdentity(ctx)
 	if err != nil {
 		return err
 	}
 
 	producer, _ := eventer.Lookup(identity, model.ResourceType, model.ID)
-	evt, err := eventingapi.NewResourceEvent(operationType, model, reportedTime)
+	evt, err := api.NewResourceEvent(operationType, model, reportedTime)
 	if err != nil {
 		return err
 	}
@@ -29,14 +29,14 @@ func DefaultResourceSendEvent(ctx context.Context, model *model.Resource, evente
 	return nil
 }
 
-func DefaultRelationshipSendEvent(ctx context.Context, m *model.Relationship, eventer eventingapi.Manager, reportedTime time.Time, operationType eventingapi.OperationType) error {
+func DefaultRelationshipSendEvent(ctx context.Context, m *model.Relationship, eventer api.Manager, reportedTime time.Time, operationType api.OperationType) error {
 	identity, err := middleware.GetIdentity(ctx)
 	if err != nil {
 		return err
 	}
 
 	producer, _ := eventer.Lookup(identity, m.RelationshipType, m.ID)
-	evt, err := eventingapi.NewRelationshipEvent(operationType, m, reportedTime)
+	evt, err := api.NewRelationshipEvent(operationType, m, reportedTime)
 	if err != nil {
 		return err
 	}

internal/biz/relationships/relationships.go

@@ -3,13 +3,13 @@ package resources
 import (
 	"context"
 	"errors"
+	"github.com/project-kessel/inventory-api/eventing/api"
 	"time"
 
 	"github.com/go-kratos/kratos/v2/log"
 	"github.com/google/uuid"
 	"github.com/project-kessel/inventory-api/internal/biz"
 	"github.com/project-kessel/inventory-api/internal/biz/model"
-	eventingapi "github.com/project-kessel/inventory-api/internal/eventing/api"
 	"gorm.io/gorm"
 )
 
@@ -25,7 +25,7 @@ type ResourceRepository interface {
 
 type Usecase struct {
 	repository         ResourceRepository
-	eventer            eventingapi.Manager
+	eventer            api.Manager
 	log                *log.Helper
 	DisablePersistence bool
 }
@@ -37,7 +37,7 @@ var (
 	ErrRelationshipNotFound = errors.New("relationship not found")
 )
 
-func New(repository ResourceRepository, eventer eventingapi.Manager, logger log.Logger, disablePersistence bool) *Usecase {
+func New(repository ResourceRepository, eventer api.Manager, logger log.Logger, disablePersistence bool) *Usecase {
 	return &Usecase{
 		repository:         repository,
 		eventer:            eventer,
@@ -84,7 +84,7 @@ func (uc *Usecase) Create(ctx context.Context, m *model.Relationship) (*model.Re
 	}
 
 	if uc.eventer != nil {
-		err := biz.DefaultRelationshipSendEvent(ctx, m, uc.eventer, *m.CreatedAt, eventingapi.OperationTypeCreated)
+		err := biz.DefaultRelationshipSendEvent(ctx, m, uc.eventer, *m.CreatedAt, api.OperationTypeCreated)
 
 		if err != nil {
 			return nil, err
@@ -131,7 +131,7 @@ func (uc *Usecase) Update(ctx context.Context, m *model.Relationship, id model.R
 	}
 
 	if uc.eventer != nil {
-		err := biz.DefaultRelationshipSendEvent(ctx, m, uc.eventer, *m.UpdatedAt, eventingapi.OperationTypeUpdated)
+		err := biz.DefaultRelationshipSendEvent(ctx, m, uc.eventer, *m.UpdatedAt, api.OperationTypeUpdated)
 
 		if err != nil {
 			return nil, err
@@ -172,7 +172,7 @@ func (uc *Usecase) Delete(ctx context.Context, id model.ReporterRelationshipId)
 	}
 
 	if uc.eventer != nil {
-		err := biz.DefaultRelationshipSendEvent(ctx, m, uc.eventer, time.Now(), eventingapi.OperationTypeDeleted)
+		err := biz.DefaultRelationshipSendEvent(ctx, m, uc.eventer, time.Now(), api.OperationTypeDeleted)
 
 		if err != nil {
 			return err

internal/biz/resources/resources.go

@@ -4,13 +4,13 @@ import (
 	"context"
 	"errors"
 	"github.com/google/uuid"
+	"github.com/project-kessel/inventory-api/eventing/api"
 	"time"
 
 	"github.com/go-kratos/kratos/v2/log"
 	authzapi "github.com/project-kessel/inventory-api/internal/authz/api"
 	"github.com/project-kessel/inventory-api/internal/biz"
 	"github.com/project-kessel/inventory-api/internal/biz/model"
-	eventingapi "github.com/project-kessel/inventory-api/internal/eventing/api"
 	"github.com/project-kessel/inventory-api/internal/server"
 	"gorm.io/gorm"
 )
@@ -33,14 +33,14 @@ var (
 type Usecase struct {
 	repository         ResourceRepository
 	Authz              authzapi.Authorizer
-	Eventer            eventingapi.Manager
+	Eventer            api.Manager
 	Namespace          string
 	log                *log.Helper
 	Server             server.Server
 	DisablePersistence bool
 }
 
-func New(repository ResourceRepository, authz authzapi.Authorizer, eventer eventingapi.Manager, namespace string, logger log.Logger, disablePersistence bool) *Usecase {
+func New(repository ResourceRepository, authz authzapi.Authorizer, eventer api.Manager, namespace string, logger log.Logger, disablePersistence bool) *Usecase {
 	return &Usecase{
 		repository:         repository,
 		Authz:              authz,
@@ -76,7 +76,7 @@ func (uc *Usecase) Create(ctx context.Context, m *model.Resource) (*model.Resour
 	}
 
 	if uc.Eventer != nil {
-		err := biz.DefaultResourceSendEvent(ctx, m, uc.Eventer, *m.CreatedAt, eventingapi.OperationTypeCreated)
+		err := biz.DefaultResourceSendEvent(ctx, m, uc.Eventer, *m.CreatedAt, api.OperationTypeCreated)
 
 		if err != nil {
 			return nil, err
@@ -122,7 +122,7 @@ func (uc *Usecase) Update(ctx context.Context, m *model.Resource, id model.Repor
 	}
 
 	if uc.Eventer != nil {
-		err := biz.DefaultResourceSendEvent(ctx, m, uc.Eventer, *m.UpdatedAt, eventingapi.OperationTypeUpdated)
+		err := biz.DefaultResourceSendEvent(ctx, m, uc.Eventer, *m.UpdatedAt, api.OperationTypeUpdated)
 
 		if err != nil {
 			return nil, err
@@ -167,7 +167,7 @@ func (uc *Usecase) Delete(ctx context.Context, id model.ReporterResourceId) erro
 	}
 
 	if uc.Eventer != nil {
-		err := biz.DefaultResourceSendEvent(ctx, m, uc.Eventer, time.Now(), eventingapi.OperationTypeDeleted)
+		err := biz.DefaultResourceSendEvent(ctx, m, uc.Eventer, time.Now(), api.OperationTypeDeleted)
 
 		if err != nil {
 			return err

internal/config/config.go

@@ -3,9 +3,9 @@ package config
 import (
 	"fmt"
 	"github.com/go-kratos/kratos/v2/log"
+	"github.com/project-kessel/inventory-api/eventing"
 	"github.com/project-kessel/inventory-api/internal/authn"
 	"github.com/project-kessel/inventory-api/internal/authz"
-	"github.com/project-kessel/inventory-api/internal/eventing"
 	"github.com/project-kessel/inventory-api/internal/server"
 	"github.com/project-kessel/inventory-api/internal/storage"
 	clowder "github.com/redhatinsights/app-common-go/pkg/api/v1"

internal/data/relationships/relationships.go

@@ -3,9 +3,9 @@ package resources
 import (
 	"context"
 	"github.com/google/uuid"
+	eventingapi "github.com/project-kessel/inventory-api/eventing/api"
 	"github.com/project-kessel/inventory-api/internal/biz/model"
 	"github.com/project-kessel/inventory-api/internal/data"
-	eventingapi "github.com/project-kessel/inventory-api/internal/eventing/api"
 	"gorm.io/gorm"
 )