feat: add app pkg

cmd/streamer.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"time"
 
+	"github.com/ucpr/mongo-streamer/internal/app"
 	"github.com/ucpr/mongo-streamer/internal/config"
 	"github.com/ucpr/mongo-streamer/internal/mongo"
 	"github.com/ucpr/mongo-streamer/internal/persistent"
@@ -16,15 +17,15 @@ type Streamer struct {
 	st  persistent.StorageBuffer
 }
 
-func NewStreamer(ctx context.Context, cli *mongo.Client, mcfg *config.MongoDB, eh *EventHandler) (*Streamer, error) {
+func NewStreamer(ctx context.Context, cli *mongo.Client, mcfg *config.MongoDB, h *app.Handler) (*Streamer, error) {
 	stLog := persistent.NewLogWriter()
 	st, err := persistent.NewBuffer(10, 5*time.Second, stLog)
 	if err != nil {
 		return nil, err
 	}
 	cs, err := mongo.NewChangeStream(ctx, mongo.ChangeStreamParams{
 		Client:     cli,
-		Handler:    eh.EventHandler,
+		Handler:    h.EventHandler,
 		Storage:    st,
 		Database:   mcfg.Database,
 		Collection: mcfg.Collection,

cmd/wire.go

@@ -7,6 +7,7 @@ import (
 
 	"github.com/google/wire"
 
+	"github.com/ucpr/mongo-streamer/internal/app"
 	"github.com/ucpr/mongo-streamer/internal/config"
 	"github.com/ucpr/mongo-streamer/internal/http"
 	"github.com/ucpr/mongo-streamer/internal/mongo"
@@ -18,8 +19,8 @@ func injectStreamer(ctx context.Context) (*Streamer, error) {
 		config.Set,
 		mongo.Set,
 		pubsub.Set,
+		app.NewHandler,
 		NewStreamer,
-		NewEventHandler,
 	)
 	return nil, nil
 }

cmd/handler.go → internal/app/streamer.go

@@ -1,4 +1,4 @@
-package main
+package app
 
 import (
 	"context"
@@ -8,18 +8,17 @@ import (
 	"github.com/ucpr/mongo-streamer/pkg/log"
 )
 
-type EventHandler struct {
+type Handler struct {
 	pubsub pubsub.Publisher
 }
 
-func NewEventHandler(ps pubsub.Publisher) *EventHandler {
-	return &EventHandler{
+func NewHandler(ps pubsub.Publisher) *Handler {
+	return &Handler{
 		pubsub: ps,
 	}
 }
 
-func (e *EventHandler) EventHandler(ctx context.Context, event []byte) error {
-	log.Info("event", slog.String("event", string(event)))
+func (e *Handler) EventHandler(ctx context.Context, event []byte) error {
 	res := e.pubsub.AsyncPublish(ctx, pubsub.Message{
 		Data: event,
 	})