CIEDEV-2140: Release Service Scaffolding (#37)

cmd/release.go

@@ -0,0 +1,30 @@
+package cmd
+
+import (
+	"github.com/terrariumcloud/terrarium/internal/release/services/release"
+
+	"github.com/spf13/cobra"
+)
+
+var releaseServiceCmd = &cobra.Command{
+	Use:   "publish",
+	Short: "Starts the Terrarium GRPC Release service",
+	Long:  "Runs the Terrarium GRPC Release server.",
+	Run:   runReleaseService,
+}
+
+func init() {
+	rootCmd.AddCommand(releaseServiceCmd)
+	// TODO: database
+	//releaseServiceCmd.Flags().StringVarP(&release.ReleaseTableName, "table", "t", release.DefaultReleaseTableName, "Releases table name")
+}
+
+func runReleaseService(cmd *cobra.Command, args []string) {
+	releaseServiceServer := &release.ReleaseService{
+		// Db:     storage.NewDynamoDbClient(awsAccessKey, awsSecretKey, awsRegion),
+		// Table:  release.ReleaseTableName,
+		// Schema: release.GetModulesSchema(release.ReleaseTableName),
+	}
+
+	startGRPCService("release", releaseServiceServer)
+}

docker-compose.yaml

@@ -149,6 +149,27 @@ services:
       - "$AWS_SECRET_ACCESS_KEY"
       - "--aws-region"
       - "$AWS_DEFAULT_REGION"
+  release:
+    build: .
+    image: terrarium:dev
+    container_name: terrarium-release
+    environment:
+    - AWS_ACCESS_KEY_ID
+    - AWS_SECRET_ACCESS_KEY
+    - AWS_DEFAULT_REGION
+    #- OTEL_EXPORTER_OTLP_ENDPOINT
+    ports:
+      - 50007:3001
+    networks:
+      - terrarium
+    command:
+      - publish
+      - "--aws-access-key-id"
+      - "$AWS_ACCESS_KEY_ID"
+      - "--aws-secret-access-key"
+      - "$AWS_SECRET_ACCESS_KEY"
+      - "--aws-region"
+      - "$AWS_DEFAULT_REGION"
 networks:
   terrarium:
     name: terrarium

internal/release/services/release/release.go

@@ -0,0 +1,24 @@
+package release
+
+import (
+	releaseSvc "github.com/terrariumcloud/terrarium/internal/release/services"
+	"google.golang.org/grpc"
+)
+
+type ReleaseService struct {
+	releaseSvc.UnimplementedPublisherServer
+	// Db     storage.DynamoDBTableCreator
+	// Table  string
+	// Schema *dynamodb.CreateTableInput
+}
+
+// Registers ReleaseService with grpc server
+func (s *ReleaseService) RegisterWithServer(grpcServer grpc.ServiceRegistrar) error {
+	// if err := storage.InitializeDynamoDb(s.Table, s.Schema, s.Db); err != nil {
+	// 	return ReleaseTableInitializationError
+	// }
+
+	releaseSvc.RegisterPublisherServer(grpcServer, s)
+
+	return nil
+}