Store host port on station in db

Author: rcy

gap/db/migrations/014_add_host_port_to_stations.sql

@@ -0,0 +1,5 @@
+alter table stations add column host_port text not null default '';
+
+---- create above / drop below ----
+
+alter table stations drop column host_port;

gap/db/models.go

@@ -37,6 +37,9 @@ insert into stations(station_id, slug, user_id, active) values($1, $2, $3, $4) r
 -- name: SetStationCurrentTrack :exec
 update stations set current_track_id = $1 where station_id = $2;
 
+-- name: SetStationHostPort :exec
+update stations set host_port = $1 where station_id = $2;
+
 -- name: StationCurrentTrack :one
 select tracks.* from stations join tracks on stations.current_track_id = tracks.track_id where stations.station_id = $1;
 

gap/db/query.sql

@@ -263,7 +263,8 @@ CREATE TABLE public.stations (
     current_track_id text,
     background_image_url text DEFAULT ''::text NOT NULL,
     user_id text NOT NULL,
-    is_public boolean DEFAULT false NOT NULL
+    is_public boolean DEFAULT false NOT NULL,
+    host_port text DEFAULT ''::text NOT NULL
 );
 
 

gap/db/query.sql.go

@@ -427,6 +427,12 @@ func (s *Server) startLiq(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	slug := chi.URLParam(r, "slug")
 
+	station, err := s.db.Q().Station(ctx, slug)
+	if err != nil {
+		http.Error(w, err.Error(), http.StatusInternalServerError)
+		return
+	}
+
 	cli, err := client.NewClientWithOpts(client.FromEnv, client.WithAPIVersionNegotiation())
 	if err != nil {
 		http.Error(w, err.Error(), http.StatusInternalServerError)
@@ -507,12 +513,22 @@ func (s *Server) startLiq(w http.ResponseWriter, r *http.Request) {
 
 	resp, err := cli.ContainerInspect(ctx, response.ID)
 	if err != nil {
-		panic(err)
+		http.Error(w, err.Error(), http.StatusInternalServerError)
+		return
 	}
 	for containerPort, bindings := range resp.NetworkSettings.Ports {
 		fmt.Println("containerPort", containerPort)
-		for _, binding := range bindings {
-			fmt.Printf("Container port %s is bound to host port %s\n", containerPort, binding.HostPort)
+		if containerPort.Port() == "1234" {
+			var hostPort string
+			if len(bindings) == 1 {
+				hostPort = bindings[0].HostPort
+			}
+			err := s.db.Q().SetStationHostPort(ctx, hostPort, station.StationID)
+			if err != nil {
+				http.Error(w, err.Error(), http.StatusInternalServerError)
+				return
+			}
+			fmt.Printf("station %s host port=%s\n", station.Slug, hostPort)
 		}
 	}