add script.js and make other changes

Author: HarshCasper

paradedb/sample-movie-search/.gitignore

@@ -1,10 +1,10 @@
 # Dependencies
 node_modules/
+lambda/package-lock.json
 
 # Build output
 dist/
 cdk.out/
-*.js
 *.d.ts
 
 # Keep TypeScript source

paradedb/sample-movie-search/Makefile

@@ -12,6 +12,8 @@ help:
 	@echo "  make deploy        - Deploy CDK stack to LocalStack"
 	@echo "  make init          - Initialize database schema and BM25 index"
 	@echo "  make seed          - Load movie data from S3 into ParadeDB"
+	@echo "  make test-search   - Test the search endpoint"
+	@echo "  make get-api-url   - Get the API Gateway URL"
 	@echo "  make web-ui        - Run the Web UI on localhost port 3000"
 	@echo "  make destroy       - Tear down the stack"
 	@echo "  make clean         - Remove build artifacts"

paradedb/sample-movie-search/README.md

@@ -117,19 +117,19 @@ make seed
 
 ```bash
 # Basic search
-curl "https://movie-search-api.execute-api.localhost.localstack.cloud:4566/dev/search?q=redemption"
+curl "http://movie-search-api.execute-api.localhost.localstack.cloud:4566/dev/search?q=redemption"
 
 # With pagination
-curl "https://movie-search-api.execute-api.localhost.localstack.cloud:4566/dev/search?q=dark%20knight&limit=5&offset=0"
+curl "http://movie-search-api.execute-api.localhost.localstack.cloud:4566/dev/search?q=dark%20knight&limit=5&offset=0"
 
 # Fuzzy search (handles typos)
-curl "https://movie-search-api.execute-api.localhost.localstack.cloud:4566/dev/search?q=godfater"
+curl "http://movie-search-api.execute-api.localhost.localstack.cloud:4566/dev/search?q=godfater"
 ```
 
 ### Get Movie Details
 
 ```bash
-curl "https://movie-search-api.execute-api.localhost.localstack.cloud:4566/dev/movies/tt0111161"
+curl "http://movie-search-api.execute-api.localhost.localstack.cloud:4566/dev/movies/tt0111161"
 ```
 
 ### Example Response

paradedb/sample-movie-search/lambda/index.ts

@@ -19,14 +19,17 @@ interface Movie {
 
 const pool = new Pool({
   host: process.env.PARADEDB_HOST || "paradedb.localhost.localstack.cloud",
-  port: parseInt(process.env.PARADEDB_PORT || "5432"),
-  database: process.env.PARADEDB_DATABASE || "postgres",
-  user: process.env.PARADEDB_USER || "postgres",
-  password: process.env.PARADEDB_PASSWORD || "postgres",
+  port: parseInt(process.env.PARADEDB_PORT || "4566"),
+  database: process.env.PARADEDB_DATABASE || "mydatabase",
+  user: process.env.PARADEDB_USER || "myuser",
+  password: process.env.PARADEDB_PASSWORD || "mypassword",
 });
 
+const S3_ENDPOINT = process.env.S3_ENDPOINT || "http://s3.localhost.localstack.cloud:4566";
+const DATA_BUCKET = process.env.DATA_BUCKET || "movie-search-data";
+
 const s3Client = new S3Client({
-  endpoint: "http://s3.localhost.localstack.cloud:4566",
+  endpoint: S3_ENDPOINT,
   region: "us-east-1",
   forcePathStyle: true,
   credentials: {
@@ -35,8 +38,6 @@ const s3Client = new S3Client({
   },
 });
 
-const DATA_BUCKET = process.env.DATA_BUCKET || "movie-search-data";
-
 function successResponse(data: unknown): APIGatewayProxyResult {
   return {
     statusCode: 200,
@@ -266,34 +267,26 @@ export async function seedHandler(): Promise<APIGatewayProxyResult> {
 
     console.log(`Parsed ${movies.length} movies from bulk file`);
 
-    await client.query("DELETE FROM movies");
+    await client.query("BEGIN");
 
-    let inserted = 0;
-    const batchSize = 100;
+    try {
+      await client.query("DELETE FROM movies");
 
-    for (let i = 0; i < movies.length; i += batchSize) {
-      const batch = movies.slice(i, i + batchSize);
+      const batchSize = 100;
+      let inserted = 0;
 
-      for (const movie of batch) {
-        await client.query(
-          `
-          INSERT INTO movies (id, title, year, genres, rating, directors, actors, plot,
-                              image_url, release_date, rank, running_time_secs)
-          VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12)
-          ON CONFLICT (id) DO UPDATE SET
-            title = EXCLUDED.title,
-            year = EXCLUDED.year,
-            genres = EXCLUDED.genres,
-            rating = EXCLUDED.rating,
-            directors = EXCLUDED.directors,
-            actors = EXCLUDED.actors,
-            plot = EXCLUDED.plot,
-            image_url = EXCLUDED.image_url,
-            release_date = EXCLUDED.release_date,
-            rank = EXCLUDED.rank,
-            running_time_secs = EXCLUDED.running_time_secs
-          `,
-          [
+      for (let i = 0; i < movies.length; i += batchSize) {
+        const batch = movies.slice(i, i + batchSize);
+
+        const values: unknown[] = [];
+        const placeholders: string[] = [];
+
+        batch.forEach((movie, idx) => {
+          const offset = idx * 12;
+          placeholders.push(
+            `($${offset + 1}, $${offset + 2}, $${offset + 3}, $${offset + 4}, $${offset + 5}, $${offset + 6}, $${offset + 7}, $${offset + 8}, $${offset + 9}, $${offset + 10}, $${offset + 11}, $${offset + 12})`
+          );
+          values.push(
             movie.id,
             movie.title,
             movie.year || null,
@@ -305,21 +298,45 @@ export async function seedHandler(): Promise<APIGatewayProxyResult> {
             movie.image_url || null,
             movie.release_date || null,
             movie.rank || null,
-            movie.running_time_secs || null,
-          ]
+            movie.running_time_secs || null
+          );
+        });
+
+        await client.query(
+          `INSERT INTO movies (id, title, year, genres, rating, directors, actors, plot,
+                               image_url, release_date, rank, running_time_secs)
+           VALUES ${placeholders.join(", ")}
+           ON CONFLICT (id) DO UPDATE SET
+             title = EXCLUDED.title,
+             year = EXCLUDED.year,
+             genres = EXCLUDED.genres,
+             rating = EXCLUDED.rating,
+             directors = EXCLUDED.directors,
+             actors = EXCLUDED.actors,
+             plot = EXCLUDED.plot,
+             image_url = EXCLUDED.image_url,
+             release_date = EXCLUDED.release_date,
+             rank = EXCLUDED.rank,
+             running_time_secs = EXCLUDED.running_time_secs`,
+          values
         );
-        inserted++;
+
+        inserted += batch.length;
+        console.log(`Inserted ${inserted}/${movies.length} movies...`);
       }
 
-      console.log(`Inserted ${inserted}/${movies.length} movies...`);
-    }
+      await client.query("COMMIT");
 
-    console.log(`Seeding complete: ${inserted} movies`);
+      console.log(`Seeding complete: ${inserted} movies`);
 
-    return successResponse({
-      message: "Data seeded successfully",
-      count: inserted,
-    });
+      return successResponse({
+        message: "Data seeded successfully",
+        count: inserted,
+      });
+    } catch (error) {
+      await client.query("ROLLBACK");
+      throw error;
+    }
   } catch (error) {
     console.error("Seed error:", error);
     return errorResponse(500, "Seeding failed");

paradedb/sample-movie-search/lib/movie-search-stack.ts

@@ -21,92 +21,91 @@ export class MovieSearchStack extends cdk.Stack {
       destinationBucket: dataBucket,
     });
 
-    const paradeDbEnv = {
+    const lambdaEnv = {
       PARADEDB_HOST: "paradedb.localhost.localstack.cloud",
       PARADEDB_PORT: "4566",
       PARADEDB_DATABASE: "mydatabase",
       PARADEDB_USER: "myuser",
       PARADEDB_PASSWORD: "mypassword",
       DATA_BUCKET: dataBucket.bucketName,
+      S3_ENDPOINT: "http://s3.localhost.localstack.cloud:4566",
     };
 
     const lambdaDir = path.join(__dirname, "../lambda");
-    const getLambdaCode = () => {
-      return lambda.Code.fromAsset(lambdaDir, {
-        bundling: {
-          image: lambda.Runtime.NODEJS_22_X.bundlingImage,
-          command: [
-            "bash",
-            "-c",
-            [
-              "npm install --prefix /asset-input",
-              "npx esbuild /asset-input/index.ts --bundle --platform=node --target=node22 --outfile=/asset-output/index.js",
-            ].join(" && "),
-          ],
-          local: {
-            tryBundle(outputDir: string) {
-              const { spawnSync } = require("child_process");
-              try {
-                const npmResult = spawnSync("npm", ["install"], {
-                  cwd: lambdaDir,
-                  stdio: "inherit",
-                });
-                if (npmResult.status !== 0) return false;
-
-                const esbuildResult = spawnSync(
-                  "npx",
-                  [
-                    "esbuild",
-                    "index.ts",
-                    "--bundle",
-                    "--platform=node",
-                    "--target=node22",
-                    `--outfile=${outputDir}/index.js`,
-                  ],
-                  { cwd: lambdaDir, stdio: "inherit" }
-                );
-                return esbuildResult.status === 0;
-              } catch {
-                return false;
-              }
-            },
+    const lambdaCode = lambda.Code.fromAsset(lambdaDir, {
+      bundling: {
+        image: lambda.Runtime.NODEJS_22_X.bundlingImage,
+        command: [
+          "bash",
+          "-c",
+          [
+            "npm install --prefix /asset-input",
+            "npx esbuild /asset-input/index.ts --bundle --platform=node --target=node22 --outfile=/asset-output/index.js",
+          ].join(" && "),
+        ],
+        local: {
+          tryBundle(outputDir: string) {
+            const { spawnSync } = require("child_process");
+            try {
+              const npmResult = spawnSync("npm", ["install"], {
+                cwd: lambdaDir,
+                stdio: "inherit",
+              });
+              if (npmResult.status !== 0) return false;
+
+              const esbuildResult = spawnSync(
+                "npx",
+                [
+                  "esbuild",
+                  "index.ts",
+                  "--bundle",
+                  "--platform=node",
+                  "--target=node22",
+                  `--outfile=${outputDir}/index.js`,
+                ],
+                { cwd: lambdaDir, stdio: "inherit" }
+              );
+              return esbuildResult.status === 0;
+            } catch {
+              return false;
+            }
           },
         },
-      });
-    };
+      },
+    });
 
     const searchHandler = new lambda.Function(this, "SearchHandler", {
       runtime: lambda.Runtime.NODEJS_22_X,
       handler: "index.searchHandler",
-      code: getLambdaCode(),
-      environment: paradeDbEnv,
+      code: lambdaCode,
+      environment: lambdaEnv,
       timeout: cdk.Duration.seconds(30),
       memorySize: 256,
     });
 
     const movieDetailHandler = new lambda.Function(this, "MovieDetailHandler", {
       runtime: lambda.Runtime.NODEJS_22_X,
       handler: "index.movieDetailHandler",
-      code: getLambdaCode(),
-      environment: paradeDbEnv,
+      code: lambdaCode,
+      environment: lambdaEnv,
       timeout: cdk.Duration.seconds(30),
       memorySize: 256,
     });
 
     const initHandler = new lambda.Function(this, "InitHandler", {
       runtime: lambda.Runtime.NODEJS_22_X,
       handler: "index.initHandler",
-      code: getLambdaCode(),
-      environment: paradeDbEnv,
+      code: lambdaCode,
+      environment: lambdaEnv,
       timeout: cdk.Duration.seconds(60),
       memorySize: 256,
     });
 
     const seedHandler = new lambda.Function(this, "SeedHandler", {
       runtime: lambda.Runtime.NODEJS_22_X,
       handler: "index.seedHandler",
-      code: getLambdaCode(),
-      environment: paradeDbEnv,
+      code: lambdaCode,
+      environment: lambdaEnv,
       timeout: cdk.Duration.minutes(10),
       memorySize: 1024,
     });