feat(terraform): deploy execution service

Author: ncduy0303

backend/execution-service/src/index.js

@@ -1,7 +1,9 @@
+const http = require("http");
 const RabbitMQWorker = require("./rabbitmqWorker");
 const PubSubWorker = require("./pubsubWorker");
 
 const useGcp = !!process.env.PUBSUB_PROJECT_ID;
+const PORT = process.env.PORT || 8080;
 
 async function main() {
   let worker;
@@ -16,16 +18,34 @@ async function main() {
 
   await worker.start();
 
+  let server = null;
+  if (useGcp) {
+    // Create a minimal HTTP server for GCP Cloud Run health checks
+    server = http.createServer((req, res) => {
+      res.writeHead(200, { 'Content-Type': 'application/json' });
+      res.end(JSON.stringify({
+        data: 'Hello World!',
+      }));
+    });
+    server.listen(PORT);
+  }
+
   // Graceful shutdown
   process.on("SIGTERM", async () => {
     console.log("SIGTERM signal received: closing worker");
     await worker.stop();
+    if (server) {
+      server.close();
+    }
     process.exit(0);
   });
 
   process.on("SIGINT", async () => {
     console.log("SIGINT signal received: closing worker");
     await worker.stop();
+    if (server) {
+      server.close();
+    }
     process.exit(0);
   });
 }

terraform/main.tf

@@ -75,7 +75,7 @@ resource "google_redis_instance" "redis" {
   depends_on = [google_project_service.apis]
 }
 
-# Pub/Sub Topics (Kafka replacement)
+# Pub/Sub Topics (Kafka/RabbitMQ replacement)
 resource "google_pubsub_topic" "match_topic" {
   name = "match_topic"
 
@@ -100,7 +100,13 @@ resource "google_pubsub_topic" "room_created_topic" {
   depends_on = [google_project_service.apis]
 }
 
-# Pub/Sub Subscriptions (Kafka replacement)
+resource "google_pubsub_topic" "job_execution_topic" {
+  name = "job_execution_topic"
+
+  depends_on = [google_project_service.apis]
+}
+
+# Pub/Sub Subscriptions (Kafka/RabbitMQ replacement)
 resource "google_pubsub_subscription" "match_sub" {
   name  = "match_sub"
   topic = google_pubsub_topic.match_topic.name
@@ -149,6 +155,18 @@ resource "google_pubsub_subscription" "room_created_sub" {
   }
 }
 
+resource "google_pubsub_subscription" "job_execution_sub" {
+  name  = "job_execution_sub"
+  topic = google_pubsub_topic.job_execution_topic.name
+
+  ack_deadline_seconds = 20
+
+  retry_policy {
+    minimum_backoff = "10s"
+    maximum_backoff = "600s"
+  }
+}
+
 # Artifact Registry for Docker images
 resource "google_artifact_registry_repository" "docker_repo" {
   location      = var.region
@@ -465,6 +483,57 @@ resource "google_cloud_run_v2_service" "collaboration_service" {
   depends_on = [google_project_service.apis]
 }
 
+resource "google_cloud_run_v2_service" "execution_service" {
+  name                = "execution-service"
+  location            = var.region
+  deletion_protection = false
+
+  template {
+    service_account = google_service_account.service_account.email
+
+    containers {
+      image = "${var.region}-docker.pkg.dev/${var.project_id}/docker-repo/execution-service:latest"
+
+      ports {
+        container_port = 8080
+      }
+
+      env {
+        name  = "CALLBACK_URL"
+        value = "${google_cloud_run_v2_service.collaboration_service.uri}/api/v1/code/execute-callback"
+      }
+
+      env {
+        name  = "PISTON_URL"
+        value = "https://emkc.org/api/v2/piston/execute"
+      }
+      env {
+        name  = "PUBSUB_PROJECT_ID"
+        value = var.project_id
+      }
+
+      resources {
+        limits = {
+          cpu    = "1"
+          memory = "512Mi"
+        }
+      }
+    }
+  }
+
+  scaling {
+    min_instance_count = 1
+    max_instance_count = 5
+  }
+
+  traffic {
+    type    = "TRAFFIC_TARGET_ALLOCATION_TYPE_LATEST"
+    percent = 100
+  }
+
+  depends_on = [google_project_service.apis]
+}
+
 # Cloud Run Service - Video Call Service
 resource "google_cloud_run_v2_service" "video_call_service" {
   name                = "video-call-service"
@@ -590,6 +659,13 @@ resource "google_cloud_run_service_iam_member" "collaboration_service_public" {
   member   = "allUsers"
 }
 
+resource "google_cloud_run_service_iam_member" "execution_service_public" {
+  service  = google_cloud_run_v2_service.execution_service.name
+  location = google_cloud_run_v2_service.execution_service.location
+  role     = "roles/run.invoker"
+  member   = "allUsers"
+}
+
 resource "google_cloud_run_service_iam_member" "video_call_service_public" {
   service  = google_cloud_run_v2_service.video_call_service.name
   location = google_cloud_run_v2_service.video_call_service.location

terraform/outputs.tf

@@ -28,6 +28,11 @@ output "collaboration_service_url" {
   value       = google_cloud_run_v2_service.collaboration_service.uri
 }
 
+output "execution_service_url" {
+  description = "Execution service URL"
+  value       = google_cloud_run_v2_service.execution_service.uri
+}
+
 output "video_call_service_url" {
   description = "Video call service URL"
   value       = google_cloud_run_v2_service.video_call_service.uri