Use correct import path for data connect emulator

CHANGELOG.md

@@ -0,0 +1 @@
+- Fixed an issue where `--import` path was incorrectly resolved for the Data Connect emulator. (#8219)

src/emulator/dataconnect/pgliteServer.ts

@@ -5,7 +5,7 @@
 // They are only available as ESM, and if we import them normally,
 // our tsconfig will convert them to requires, which will cause errors
 // during module resolution.
 const { dynamicImport } = require(true && "../../dynamicImport");
 import * as net from "node:net";
 import * as fs from "fs";
 
@@ -41,10 +41,10 @@
   public db: PGlite | undefined = undefined;
   private server: net.Server | undefined = undefined;
 
   public async createPGServer(host: string = "127.0.0.1", port: number): Promise<net.Server> {
     const getDb = this.getDb.bind(this);
 
     const server = net.createServer(async (socket) => {
       const connection: PostgresConnection = await fromNodeSocket(socket, {
         serverVersion: "16.3 (PGlite 0.2.0)",
         auth: { method: "trust" },
@@ -63,11 +63,11 @@
           const result = await db.execProtocolRaw(data);
           // Extended query patch removes the extra Ready for Query messages that
           // pglite wrongly sends.
           return extendedQueryPatch.filterResponse(data, result);
         },
       });
 
       const extendedQueryPatch: PGliteExtendedQueryPatch = new PGliteExtendedQueryPatch(connection);
 
       socket.on("end", () => {
         logger.debug("Postgres client disconnected");
@@ -89,10 +89,14 @@
 
   async getDb(): Promise<PGlite> {
     if (!this.db) {
+      // First, ensure that the data directory exists - PGLite tries to do this but doesn't do so recursively
+      if (this.dataDirectory && !fs.existsSync(this.dataDirectory)) {
+        fs.mkdirSync(this.dataDirectory, { recursive: true });
+      }
       // Not all schemas will need vector installed, but we don't have an good way
       // to swap extensions after starting PGLite, so we always include it.
       const vector = (await dynamicImport("@electric-sql/pglite/vector")).vector;
       const uuidOssp = (await dynamicImport("@electric-sql/pglite/contrib/uuid_ossp")).uuid_ossp;
       const pgliteArgs: PGliteOptions = {
         debug: this.debug,
         extensions: {

src/emulator/dataconnectEmulator.ts

@@ -73,7 +73,6 @@ export class DataConnectEmulator implements EmulatorInstance {
     let resolvedConfigDir;
     try {
       resolvedConfigDir = this.args.config.path(this.args.configDir);
-
       const info = await DataConnectEmulator.build({ configDir: resolvedConfigDir });
       if (requiresVector(info.metadata)) {
         if (Constants.isDemoProject(this.args.projectId)) {
@@ -125,7 +124,7 @@ export class DataConnectEmulator implements EmulatorInstance {
           dataDirectory = this.args.config.path(dataDirectory);
         }
         const postgresDumpPath = this.args.importPath
-          ? path.join(this.args.config.path(this.args.importPath), "postgres.tar.gz")
+          ? path.join(this.args.importPath, "postgres.tar.gz")
           : undefined;
         this.postgresServer = new PostgresServer({
           dataDirectory,