fixed integration tests

Author: shamikkarkhanis

internal/database/queries.sql

@@ -101,8 +101,22 @@ WITH updated AS (
     WHERE eid = $1
     RETURNING *
 )
-SELECT v.* FROM events_with_org_ids v
-WHERE v.eid = $1;
+SELECT
+    u.eid,
+    u.location,
+    u.event_time,
+    u.description,
+    u.date_created,
+    u.date_modified,
+    u.title,
+    COALESCE(hosts.org_ids, ARRAY[]::uuid[]) AS org_ids
+FROM updated u
+LEFT JOIN (
+    SELECT eh.eid, ARRAY_AGG(eh.oid)::uuid[] AS org_ids
+    FROM event_hosting eh
+    WHERE eh.eid = $1
+    GROUP BY eh.eid
+) hosts ON hosts.eid = u.eid;
 
 -- name: DeleteEvent :exec
 DELETE FROM events WHERE eid = $1;

internal/database/queries.sql.go

@@ -69,6 +69,9 @@ func New(h *handler.Handler, queries database.Querier, jwtSecret string, allowed
 	r.Use(chimiddleware.RequestID)
 	r.Use(middleware.CORS(allowedOrigins, h.Config.Env == "development"))
 
+	// Public link resolution alias.
+	r.Get("/r/{endpoint_url}", h.ResolveLink)
+
 	// API routes
 	r.Route("/api", func(r chi.Router) {
 		// Health check (public)

internal/router/router.go

@@ -46,16 +46,15 @@ func SetupTestPostgres(t *testing.T) string {
 	return connStr
 }
 
-// SetupTestDB creates a fresh Postgres container, initializes schema.sql, and returns the connection pool.
+// SetupTestDB creates a fresh Postgres container, applies all migrations, and returns the connection pool.
 func SetupTestDB(t *testing.T) *pgxpool.Pool {
 	ctx := context.Background()
 	_, filename, _, _ := runtime.Caller(0)
 	projectRoot := filepath.Join(filepath.Dir(filename), "../..")
-	schemaPath := filepath.Join(projectRoot, "schema.sql")
+	migrationsPath := filepath.Join(projectRoot, "migrations")
 
 	pgContainer, err := postgres.Run(ctx,
 		"postgres:16-alpine",
-		postgres.WithInitScripts(schemaPath),
 		postgres.WithDatabase("test_db"),
 		postgres.WithUsername("test"),
 		postgres.WithPassword("test"),
@@ -79,6 +78,10 @@ func SetupTestDB(t *testing.T) *pgxpool.Pool {
 		t.Fatalf("failed to get connection string: %v", err)
 	}
 
+	if err := database.RunMigrations(ctx, connStr, migrationsPath); err != nil {
+		t.Fatalf("failed to apply migrations: %v", err)
+	}
+
 	pool, err := database.NewPool(ctx, connStr)
 	if err != nil {
 		t.Fatalf("failed to connect to database: %v", err)