fix: Implement sync, scheduler, resource encoding (#44)

Fixes #39
cloudquery · Aug 10, 2023 · 4a5f9e8 · 4a5f9e8
1 parent 4c07a3d
commit 4a5f9e8
Show file tree

Hide file tree

Showing 18 changed files with 400 additions and 61 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -82,9 +82,13 @@
     "@apache-arrow/esnext-esm": "^12.0.1",
     "@cloudquery/plugin-pb-javascript": "^0.0.7",
     "@types/luxon": "^3.3.1",
+    "ajv": "^8.12.0",
     "boolean": "^3.2.0",
+    "dot-prop": "^8.0.2",
     "luxon": "^3.4.0",
     "matcher": "^5.0.0",
+    "p-map": "^6.0.0",
+    "p-timeout": "^6.1.2",
     "winston": "^3.10.0",
     "yargs": "^17.7.2"
   }

diff --git a/src/grpc/plugin.ts b/src/grpc/plugin.ts
@@ -6,6 +6,7 @@ import { encodeTables } from '../schema/table.js';
 
 export class MigrateTable extends pluginV3.cloudquery.plugin.v3.Sync.MessageMigrateTable {}
 export class SyncRequest extends pluginV3.cloudquery.plugin.v3.Sync.Request {}
+export class Insert extends pluginV3.cloudquery.plugin.v3.Sync.MessageInsert {}
 export class SyncResponse extends pluginV3.cloudquery.plugin.v3.Sync.Response {}
 export class ReadRequest extends pluginV3.cloudquery.plugin.v3.Read.Request {}
 export class ReadResponse extends pluginV3.cloudquery.plugin.v3.Read.Response {}