Function runFilesPostgres

test/_utils.ts:44–80

(abap: ABAP, files: IFile[])

  return "global.abap = abap;\n" + pre + res.objects[0].chunk.getCode();
}

export async function runFilesPostgres(abap: ABAP, files: IFile[]) {
  const memory = files.map(f => new abaplint.MemoryFile(f.filename, f.contents));
  const reg: abaplint.IRegistry = new abaplint.Registry().addFiles(memory);
  const res = await new Transpiler().run(reg);
  abap.console.clear();
  if (res.databaseSetup.schemas.pg.length > 0) {
    const dbName = "transpiler-" + crypto.randomBytes(10).toString("hex");
    abap.context.databaseConnections["DEFAULT"] = new PostgresDatabaseClient({
      user: "postgres",
      host: "localhost",
      database: "postgres",
      password: "postgres",
      port: 5432,
    });
    await abap.context.databaseConnections["DEFAULT"].connect();
    await abap.context.databaseConnections["DEFAULT"].execute(`CREATE DATABASE "${dbName}";`);
    await abap.context.databaseConnections["DEFAULT"].disconnect();

    abap.context.databaseConnections["DEFAULT"] = new PostgresDatabaseClient({
      user: "postgres",
      host: "localhost",
      database: dbName,
      password: "postgres",
      port: 5432,
    });
    await abap.context.databaseConnections["DEFAULT"].connect();
    await abap.context.databaseConnections["DEFAULT"].execute(res.databaseSetup.schemas.pg);
    await abap.context.databaseConnections["DEFAULT"].execute(res.databaseSetup.insert);
  }
  let pre = "";
  for (const o of res.objects) {
    if (o.object.type === "TABL") {
      pre = o.chunk.getCode() + "\n";
    }
  }
  return "global.abap = abap;\n" + pre + res.objects[0].chunk.getCode();
}

export async function runFilesHana(abap: ABAP, files: IFile[]) {