Added Dockerfile, Migrated Configs to ENV and Composed Publish Workflow.

Author: Abhinav-ark

.github/workflows/publish.yml

@@ -0,0 +1,18 @@
+name: Build and Publish Docker Image
+
+on:
+  push:
+    branches: [main]
+  workflow_dispatch:
+
+jobs:
+  main-workflow:
+    uses: Evolutionary-Algorithms-On-Click/operations/.github/workflows/docker-publish.yml@main
+    with:
+      branch: ${{ github.ref }}
+      image_name: ${{ github.repository }}
+      event_name: ${{ github.event_name }}
+    permissions:
+      contents: read
+      packages: write
+      id-token: write

Dockerfile

@@ -0,0 +1,23 @@
+# golang 1.23
+FROM golang:1.23
+
+# Set the Current Working Directory inside the container
+WORKDIR /runner_controller_microservice
+
+# Copy go mod and sum files
+COPY go.mod go.sum ./
+
+# Download all dependencies. Dependencies will be cached if the go.mod and go.sum files are not changed
+RUN go mod download
+
+# Copy the source from the current directory to the Working Directory inside the container
+COPY . .
+
+# Build the Go app
+RUN go build -o main .
+
+# This container exposes port 5002 to the outside world
+EXPOSE 5002
+
+# Command to run the executable
+CMD ["./main"]

config/default.go

@@ -0,0 +1,15 @@
+  
+services:
+  auth:
+    image: ghcr.io/evolutionary-algorithms-on-click/runner_controller_microservice:main
+    ports:
+      - "5002:5002"
+    environment:
+      DATABASE_URL : postgresql://[email protected]:26257/defaultdb?sslmode=disable
+      MINIO_ENDPOINT : host.docker.internal:9000
+      MINIO_ACCESS_KEY_ID : <MINIO_ACCESS_KEY_ID>
+      MINIO_SECRET_KEY : <MINIO_SECRET_KEY>
+      RABBITMQ_URL : amqp://<user>:<password>@host.docker.internal:5672/
+      FRONTEND_URL : http://host.docker.internal:3000
+      HTTP_PORT : 5002
+      AUTH_GRPC_ADDRESS : host.docker.internal:5001

docker-compose.yml

@@ -1,17 +1,26 @@
 package main
 
 import (
-	"evolve/config"
+	// "evolve/config"
 	"evolve/controller"
 	"evolve/routes"
 	"evolve/util"
 	"fmt"
+	"github.com/rs/cors"
 	"net/http"
+	"os"
+)
 
-	"github.com/rs/cors"
+var (
+	PORT         string
+	FRONTEND_URL string
 )
 
 func main() {
+
+	PORT = fmt.Sprintf(":%s", os.Getenv("HTTP_PORT"))
+	FRONTEND_URL = os.Getenv("FRONTEND_URL")
+
 	var logger = util.NewLogger()
 
 	// Register routes.
@@ -24,15 +33,15 @@ func main() {
 	http.HandleFunc(routes.SHARE_RUN, controller.ShareRun)
 	http.HandleFunc(routes.RUN, controller.UserRun)
 
-	logger.Info(fmt.Sprintf("Test http server on http://localhost%v/api/test", config.PORT))
+	logger.Info(fmt.Sprintf("Test http server on http://localhost%v/api/test", PORT))
 
 	corsHandler := cors.New(cors.Options{
-		AllowedOrigins:   []string{"http://localhost:3000"},
+		AllowedOrigins:   []string{FRONTEND_URL},
 		AllowedMethods:   []string{"GET", "POST", "PUT", "DELETE", "OPTIONS"},
 		AllowedHeaders:   []string{"*"},
 		AllowCredentials: true,
 	}).Handler(http.DefaultServeMux)
-	if err := http.ListenAndServe(config.PORT, corsHandler); err != nil {
+	if err := http.ListenAndServe("0.0.0.0"+PORT, corsHandler); err != nil {
 		logger.Error(fmt.Sprintf("Failed to start server: %v", err))
 		return
 	}

main.go

@@ -2,11 +2,13 @@ package modules
 
 import (
 	"context"
-	"evolve/config"
 	pb "evolve/proto"
 	"evolve/util"
 	"fmt"
 	"net/http"
+	"os"
+
+	// "os"
 	"time"
 
 	"google.golang.org/grpc"
@@ -27,15 +29,15 @@ func Auth(req *http.Request) (map[string]string, error) {
 
 	// Verify the token via a gRPC call
 	// to the auth micro-service.
-	authConn, err := grpc.NewClient(config.AUTH_GRPC_ADDRESS, grpc.WithTransportCredentials(insecure.NewCredentials()))
+	authConn, err := grpc.NewClient(os.Getenv("AUTH_GRPC_ADDRESS"), grpc.WithTransportCredentials(insecure.NewCredentials()))
 	if err != nil {
 		logger.Error(fmt.Sprintf("Failed to create gRPC client: %v", err))
 		return nil, fmt.Errorf("something went wrong")
 	}
 	defer authConn.Close()
 
 	authClient := pb.NewAuthenticateClient(authConn)
-	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
+	ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
 	defer cancel()
 
 	r, err := authClient.Auth(ctx, &pb.TokenValidateRequest{Token: token.Value})