Swap out duckdb-async for @duckdb/node-api.

Author: samcunliffe

backend/package.json

@@ -49,6 +49,7 @@
     "vitest": "^4.0.16"
   },
   "dependencies": {
+    "@duckdb/node-api": "*",
     "@octokit/graphql-schema": "^15.26.1",
     "@octokit/plugin-paginate-graphql": "^6.0.0",
     "@octokit/plugin-retry": "^8.0.3",
@@ -58,7 +59,6 @@
     "esno": "^4.8.0",
     "fs-extra": "^11.3.3",
     "octokit": "^5.0.5",
-    "yaml": "^2.8.2",
-    "duckdb-async": "^1.4.2"
+    "yaml": "^2.8.2"
   }
 }

backend/src/fetchers/fetch_parquet.ts

@@ -6,7 +6,7 @@ import { Config, Result } from '../index';
 import { CustomOctokit } from '../lib/octokit';
 import { queryRepoNames } from './fetcher_utils';
 
-import { Database } from 'duckdb-async';
+import { DuckDBInstance } from '@duckdb/node-api';
 
 async function downloadParquetFile(url: string, outputPath: string) {
     return new Promise((resolve, reject) => {
@@ -74,7 +74,7 @@ export const addCondaData = async (result: Result, octokit: CustomOctokit, confi
         }
     }
 
-    const db = await Database.create( `:memory:` );
+    const db = await DuckDBInstance.create( `:memory:` );
     const formattedString = packages.map((pkg) => `'${pkg}'`).join(',');
 
     const totalDownloads = await db.all(`SELECT pkg_name, SUM(counts)::INTEGER AS total FROM '${baseDir}/*.parquet' WHERE pkg_name IN (${formattedString}) GROUP BY pkg_name`);