tap: move main package to libtap

Author: iameli

.gitignore

@@ -37,6 +37,7 @@ test-coverage.out
 /sonar-cli
 /stress
 /supercollider
+/tap
 
 # Don't ignore this file itself, or other specific dotfiles
 !.gitignore

cmd/tap/main.go

@@ -12,6 +12,7 @@ import (
 
 	_ "net/http/pprof"
 
+	"github.com/bluesky-social/indigo/libtap"
 	_ "github.com/joho/godotenv/autoload"
 
 	"github.com/earthboundkid/versioninfo/v2"
@@ -181,7 +182,7 @@ func runTap(ctx context.Context, cmd *cli.Command) error {
 		return fmt.Errorf("relay-url must start with http:// or https://")
 	}
 
-	config := TapConfig{
+	config := libtap.TapConfig{
 		DatabaseURL:                cmd.String("db-url"),
 		DBMaxConns:                 int(cmd.Int("max-db-conn")),
 		RelayUrl:                   relayUrl,
@@ -203,7 +204,7 @@ func runTap(ctx context.Context, cmd *cli.Command) error {
 	}
 
 	logger.Info("creating tap service")
-	tap, err := NewTap(config)
+	tap, err := libtap.NewTap(config)
 	if err != nil {
 		return err
 	}

cmd/tap/crawler.go libtap/crawler.gocmd/tap/crawler.go renamed to libtap/crawler.go

@@ -1,4 +1,4 @@
-package main
+package libtap
 
 import (
 	"context"
@@ -9,7 +9,7 @@ import (
 
 	comatproto "github.com/bluesky-social/indigo/api/atproto"
 	"github.com/bluesky-social/indigo/atproto/atclient"
-	"github.com/bluesky-social/indigo/cmd/tap/models"
+	"github.com/bluesky-social/indigo/libtap/models"
 	"go.opentelemetry.io/otel/attribute"
 	"gorm.io/gorm"
 	"gorm.io/gorm/clause"

cmd/tap/db_helpers.go libtap/db_helpers.gocmd/tap/db_helpers.go renamed to libtap/db_helpers.go

@@ -1,7 +1,7 @@
-package main
+package libtap
 
 import (
-	"github.com/bluesky-social/indigo/cmd/tap/models"
+	"github.com/bluesky-social/indigo/libtap/models"
 	"gorm.io/gorm"
 )
 

cmd/tap/event_manager.go libtap/event_manager.gocmd/tap/event_manager.go renamed to libtap/event_manager.go

@@ -1,4 +1,4 @@
-package main
+package libtap
 
 import (
 	"context"
@@ -9,7 +9,7 @@ import (
 	"sync/atomic"
 	"time"
 
-	"github.com/bluesky-social/indigo/cmd/tap/models"
+	"github.com/bluesky-social/indigo/libtap/models"
 	"gorm.io/gorm"
 	"gorm.io/gorm/clause"
 )

cmd/tap/firehose.go libtap/firehose.gocmd/tap/firehose.go renamed to libtap/firehose.go

@@ -1,4 +1,4 @@
-package main
+package libtap
 
 import (
 	"context"
@@ -13,9 +13,9 @@ import (
 	"github.com/bluesky-social/indigo/atproto/atdata"
 	"github.com/bluesky-social/indigo/atproto/repo"
 	"github.com/bluesky-social/indigo/atproto/syntax"
-	"github.com/bluesky-social/indigo/cmd/tap/models"
 	"github.com/bluesky-social/indigo/events"
 	"github.com/bluesky-social/indigo/events/schedulers/parallel"
+	"github.com/bluesky-social/indigo/libtap/models"
 	"github.com/gorilla/websocket"
 	"go.opentelemetry.io/otel"
 	"gorm.io/gorm"

cmd/tap/metrics.go libtap/metrics.gocmd/tap/metrics.go renamed to libtap/metrics.go

@@ -1,4 +1,4 @@
-package main
+package libtap
 
 import (
 	"github.com/prometheus/client_golang/prometheus"

cmd/tap/models/models.go libtap/models/models.gocmd/tap/models/models.go renamed to libtap/models/models.go

@@ -1,4 +1,4 @@
-package main
+package libtap
 
 import (
 	"context"

cmd/tap/outbox.go libtap/outbox.gocmd/tap/outbox.go renamed to libtap/outbox.go

@@ -1,12 +1,12 @@
-package main
+package libtap
 
 import (
 	"context"
 	"log/slog"
 
 	"github.com/bluesky-social/indigo/atproto/identity"
 	"github.com/bluesky-social/indigo/atproto/syntax"
-	"github.com/bluesky-social/indigo/cmd/tap/models"
+	"github.com/bluesky-social/indigo/libtap/models"
 	"gorm.io/gorm"
 )