🚀 Socket Launch Week Day 5:Introducing Repository Access Permissions and Custom Roles.Learn more →
Sign In

@grouparoo/postgres

Package Overview
Dependencies
Maintainers
6
Versions
265
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@grouparoo/postgres - npm Package Compare versions

Comparing version
0.8.2-alpha.0
 to
0.8.2-alpha.1
+2
-69
__tests__/integration/postgresTableImport.ts

@@ -409,29 +409,5 @@ import path from "path";

// run all enqueued associateRecord tasks
const foundAssociateTasks = await specHelper.findEnqueuedTasks(
"import:associateRecord"
);
expect(foundAssociateTasks.length).toEqual(11);
await Promise.all(
foundAssociateTasks.map(
async (t) =>
await specHelper.runTask("import:associateRecord", t.args[0])
)
);
await specHelper.runTask("import:associateRecords", {});
await ImportWorkflow();
// run all enqueued export tasks
const foundExportTasks = await specHelper.findEnqueuedTasks(
"record:export"
);
expect(foundExportTasks.length).toEqual(10);
await Promise.all(
foundExportTasks.map((t) =>
specHelper.runTask("record:export", t.args[0])
)
);
// run the export:enqueue task

@@ -453,12 +429,2 @@ await specHelper.runTask("export:enqueue", {});

// check if the run is done
const foundRunDetermineStateTasks = await specHelper.findEnqueuedTasks(
"run:determineState"
);
await Promise.all(
foundRunDetermineStateTasks.map((t) =>
specHelper.runTask("run:determineState", t.args[0])
)
);
// check the results of the run

@@ -535,28 +501,5 @@ const recordsCount = await GrouparooRecord.count();

// run all enqueued associateRecord tasks
const foundAssociateTasks = await specHelper.findEnqueuedTasks(
"import:associateRecord"
);
expect(foundAssociateTasks.length).toEqual(1); // just the latest record at the end of the schedule
await Promise.all(
foundAssociateTasks.map((t) =>
specHelper.runTask("import:associateRecord", t.args[0])
)
);
await specHelper.runTask("import:associateRecords", {});
await ImportWorkflow();
// run all enqueued export tasks
const foundExportTasks = await specHelper.findEnqueuedTasks(
"record:export"
);
expect(foundExportTasks.length).toEqual(1);
await Promise.all(
foundExportTasks.map((t) =>
specHelper.runTask("record:export", t.args[0])
)
);
// run the export:enqueue task

@@ -576,12 +519,2 @@ await specHelper.runTask("export:enqueue", {});

// check if the run is done
const foundRunDetermineStateTasks = await specHelper.findEnqueuedTasks(
"run:determineState"
);
await Promise.all(
foundRunDetermineStateTasks.map((t) =>
specHelper.runTask("run:determineState", t.args[0])
)
);
// check the results of the run

@@ -588,0 +521,0 @@ const recordsCount = await GrouparooRecord.count();

+12
-12
package.json

@@ -5,3 +5,3 @@ {

"description": "The Grouparoo postgres Plugin",
"version": "0.8.2-alpha.0",
"version": "0.8.2-alpha.1",
"license": "MPL-2.0",

@@ -32,4 +32,4 @@ "private": false,

"dependencies": {
"@grouparoo/app-templates": "0.8.2-alpha.0",
"pg": "8.7.1",
"@grouparoo/app-templates": "0.8.2-alpha.1",
"pg": "8.7.3",
"pg-format": "1.0.4",

@@ -40,4 +40,4 @@ "pg-hstore": "2.3.4",

"devDependencies": {
"@grouparoo/core": "0.8.2-alpha.0",
"@grouparoo/spec-helper": "0.8.2-alpha.0",
"@grouparoo/core": "0.8.2-alpha.1",
"@grouparoo/spec-helper": "0.8.2-alpha.1",
"@types/jest": "*",

@@ -47,15 +47,15 @@ "@types/node": "16.*.*",

"@types/pg-format": "1.0.2",
"@typescript-eslint/eslint-plugin": "5.10.2",
"@typescript-eslint/parser": "5.10.2",
"@typescript-eslint/eslint-plugin": "5.13.0",
"@typescript-eslint/parser": "5.13.0",
"actionhero": "28.1.8",
"csv-parse": "4.16.3",
"eslint": "8.8.0",
"fs-extra": "10.0.0",
"eslint": "8.10.0",
"fs-extra": "10.0.1",
"jest": "27.5.1",
"prettier": "2.5.1",
"sequelize": "6.15.0",
"sequelize": "6.17.0",
"ts-jest": "27.1.3",
"typescript": "4.5.5"
"typescript": "4.6.2"
},
"gitHead": "2b026c35c0f5ec2009f531448de14570ddd288db"
"gitHead": "991d7c1d76c10436e29dd62ee0b5d50568b08c4a"
}