feat: Fetch and load Postgresql and spin up as a SUT.

Author: jaqx0r

MODULE.bazel

@@ -46,3 +46,15 @@ use_repo(pnpm, "pnpm")
 
 bazel_dep(name = "bazel_skylib", version = "1.8.2")
 bazel_dep(name = "rules_itest", version = "0.0.41")
+bazel_dep(name = "platforms", version = "1.0.0")
+bazel_dep(name = "rules_img", version = "0.2.8")
+
+pull = use_repo_rule("@rules_img//img:pull.bzl", "pull")
+
+pull(
+    name = "postgresql",
+    digest = "sha256:48c8ad3a7284b82be4482a52076d47d879fd6fb084a1cbfccbd551f9331b0e40",
+    registry = "index.docker.io",
+    repository = "library/postgres",
+    tag = "18.0-alpine3.22",
+)

MODULE.bazel.lock

@@ -0,0 +1,47 @@
+load("@rules_img//img:image.bzl", "image_manifest")
+load("@rules_img//img:load.bzl", "image_load")
+load("@rules_itest//:itest.bzl", "itest_service", "itest_task")
+
+platform(
+    name = "host_docker_platform",
+    constraint_values = ["@platforms//os:linux"],  # but linux OS inside Docker
+    parents = ["@platforms//host"],  # use host CPU
+)
+
+image_manifest(
+    name = "pg_image",
+    base = "@postgresql",
+    platform = ":host_docker_platform",
+)
+
+image_load(
+    name = "load_pg_image",
+    image = ":pg_image",
+    tag = "pg_image:latest",
+)
+
+itest_task(
+    name = "load_pg_image_task",
+    testonly = True,
+    exe = ":load_pg_image",
+)
+
+itest_service(
+    name = "sut",
+    testonly = True,
+    args = [
+        "--name",
+        "pg_image:latest",
+        "--env=POSTGRES_USER,POSTGRES_PASSWORD,POSTGRES_DB",
+    ],
+    env = {
+        "POSTGRES_USER": "postgres",
+        "POSTGRES_PASSWORD": "postgres",
+        "POSTGRES_DB": "postgres",
+    },
+    exe = "//testing/itestcontainer:itestcontainer",
+    named_ports = [
+        "5432",
+    ],
+    deps = [":load_pg_image_task"],
+)

db/BUILD.bazel

@@ -24,6 +24,7 @@ import (
 	"log"
 	"os"
 	"os/signal"
+	"strings"
 	"sync"
 	"syscall"
 
@@ -66,7 +67,7 @@ func main() {
 	// Map the suffix of the named ports to exposed ports.
 	exposedPorts := []string{}
 	for portName, externalPort := range assignedPorts {
-		parts := strings.Split(portname, ":")
+		parts := strings.Split(portName, ":")
 		exposedPortName := parts[len(parts)-1]
 		exposedPorts = append(exposedPorts, externalPort+":"+exposedPortName)
 	}
@@ -125,7 +126,7 @@ func main() {
 	wg.Add(1)
 	go func() {
 		defer wg.Done()
-		name := c.GetContainerId()
+		name := c.GetContainerID()
 		n, err := c.Inspect(ctx)
 		if err != nil {
 			name = n.Name