Move message api into its own folder (#239)

## tl;dr

- Small refactor to move the GRPC services into subfolders

pkg/api/publishWorker.go → pkg/api/message/publishWorker.go

@@ -1,4 +1,4 @@
-package api
+package message
 
 import (
 	"context"

pkg/api/publish_test.go → pkg/api/message/publish_test.go

@@ -1,4 +1,4 @@
-package api_test
+package message_test
 
 import (
 	"context"

pkg/api/service.go → pkg/api/message/service.go

@@ -1,4 +1,4 @@
-package api
+package message
 
 import (
 	"context"

pkg/api/subscribeWorker.go → pkg/api/message/subscribeWorker.go

@@ -1,4 +1,4 @@
-package api
+package message
 
 import (
 	"context"

pkg/api/subscribe_test.go → pkg/api/message/subscribe_test.go

@@ -1,4 +1,4 @@
-package api_test
+package message_test
 
 import (
 	"context"
@@ -7,7 +7,7 @@ import (
 	"time"
 
 	"github.com/stretchr/testify/require"
-	"github.com/xmtp/xmtpd/pkg/api"
+	"github.com/xmtp/xmtpd/pkg/api/message"
 	"github.com/xmtp/xmtpd/pkg/db"
 	"github.com/xmtp/xmtpd/pkg/db/queries"
 	"github.com/xmtp/xmtpd/pkg/proto/xmtpv4/message_api"
@@ -76,7 +76,7 @@ func insertInitialRows(t *testing.T, store *sql.DB) {
 	testutils.InsertGatewayEnvelopes(t, store, []queries.InsertGatewayEnvelopeParams{
 		allRows[0], allRows[1],
 	})
-	time.Sleep(api.SubscribeWorkerPollTime + 100*time.Millisecond)
+	time.Sleep(message.SubscribeWorkerPollTime + 100*time.Millisecond)
 }
 
 func insertAdditionalRows(t *testing.T, store *sql.DB, notifyChan ...chan bool) {

pkg/api/server.go

@@ -12,6 +12,7 @@ import (
 	"google.golang.org/grpc/reflection"
 
 	"github.com/pires/go-proxyproto"
+	"github.com/xmtp/xmtpd/pkg/api/message"
 	"github.com/xmtp/xmtpd/pkg/blockchain"
 	"github.com/xmtp/xmtpd/pkg/proto/xmtpv4/message_api"
 	"github.com/xmtp/xmtpd/pkg/registrant"
@@ -86,7 +87,7 @@ func NewAPIServer(
 	healthcheck := health.NewServer()
 	healthgrpc.RegisterHealthServer(s.grpcServer, healthcheck)
 
-	replicationService, err := NewReplicationApiService(
+	replicationService, err := message.NewReplicationApiService(
 		ctx,
 		log,
 		registrant,

pkg/interceptors/client/auth_test.go

@@ -6,7 +6,7 @@ import (
 	"testing"
 
 	"github.com/stretchr/testify/require"
-	"github.com/xmtp/xmtpd/pkg/api"
+	"github.com/xmtp/xmtpd/pkg/api/message"
 	"github.com/xmtp/xmtpd/pkg/authn"
 	"github.com/xmtp/xmtpd/pkg/constants"
 	"github.com/xmtp/xmtpd/pkg/proto/xmtpv4/message_api"
@@ -22,7 +22,7 @@ import (
 // Create a mock implementation of the ReplicationApiServer interface
 // but that embeds `UnimplementedReplicationApiServer` (which mockery won't do for us)
 type mockReplicationApiServer struct {
-	api.Service
+	message.Service
 	expectedToken string
 }