Revert "Merge branch 'main' into clientifrst"

This reverts commit 1fda55e.

Author: Menzorg

.github/workflows/dockerize.yaml

@@ -23,7 +23,7 @@ jobs:
       - uses: actions/checkout@v2
       - uses: actions/setup-node@v1
         with:
-          node-version: 18
+          node-version: '16.20'
       - name: ci
         run: npm ci
       - name: build

.github/workflows/npm-publish.yml

@@ -11,7 +11,7 @@ on:
 
 jobs:
   main:
-    uses: deep-foundation/workflows/.github/workflows/npm-publish.yml@npm-publish-4.0.0
+    uses: deep-foundation/workflows/.github/workflows/npm-publish.yml@npm-publish-1.1.0
     secrets:
       npm-token: ${{ secrets.NPM_TOKEN }}
     with:

.nvmrc

@@ -1 +1 @@
-18
+18.16.1

Dockerfile

@@ -1,4 +1,4 @@
-FROM node:18-alpine3.17 AS node
+FROM node:18.16.1-alpine3.17 AS node
 FROM docker:20.10.8-dind-alpine3.14
 
 COPY --from=node /usr/lib /usr/lib

imports/client.tsx

@@ -351,8 +351,6 @@ export interface DeepClientInstance<L = Link<number>> {
 
   delete<TTable extends 'links'|'numbers'|'strings'|'objects'>(exp: Exp<TTable>, options?: WriteOptions<TTable>):Promise<DeepClientResult<{ id }[]>>;
 
-  serial(options: AsyncSerialParams): Promise<DeepClientResult<{ id }[]>>;
-
   reserve<LL = L>(count: number): Promise<number[]>;
 
   await(id: number): Promise<boolean>;
@@ -374,8 +372,6 @@ export interface DeepClientInstance<L = Link<number>> {
   logout(): Promise<DeepClientAuthResult>;
 
   can(objectIds: number[], subjectIds: number[], actionIds: number[]): Promise<boolean>;
-
-  useDeepSubscription: typeof useDeepSubscription
 }
 
 export interface DeepClientAuthResult {
@@ -786,7 +782,9 @@ export class DeepClient<L = Link<number>> implements DeepClientInstance<L> {
     return { ...q, data: (q)?.data?.m0?.returning };
   };
 
-  async serial({
+  async serial<
+    LL = L
+  >({
     name, operations, returning, silent
   }: AsyncSerialParams): Promise<DeepClientResult<{ id: number }[]>> {
     // @ts-ignore
@@ -1058,14 +1056,14 @@ export class DeepClient<L = Link<number>> implements DeepClientInstance<L> {
       try {
         return await DeepClient.resolveDependency(path);
       } catch (e) {
-        console.log(`IGNORED ERROR: Call to DeepClient.resolveDependency is failed with`, e);
+        console.log(`Call to DeepClient.resolveDependency is failed with`, e);
       }
     }
     if (typeof require !== 'undefined') {
       try {
         return await require(path);
       } catch (e) {
-        console.log(`IGNORED ERROR: Call to require is failed with`, e);
+        console.log(`Call to require is failed with`, e);
       }
     }
     return await import(path);

imports/packager.ts

@@ -280,7 +280,7 @@ export class Packager<L extends Link<any>> {
       let newId;
       if (item.package) {
         newId = await this.client.id(pckg?.dependencies?.[item?.package?.dependencyId]?.name, item.package.containValue, true);
-        if (!newId) pckg.errors.push(`dependency [${pckg?.dependencies?.[item?.package?.dependencyId]?.name} ${item.package.containValue}], not found`);
+        if (!newId) pckg.errors.push(`dependency [${pckg?.dependencies?.[item?.package?.dependencyId]?.name, item.package.containValue}], not founded`);
       } else if (item.type) {
         newId = ids[idsIndex++];
       }
@@ -373,7 +373,7 @@ export class Packager<L extends Link<any>> {
       const ids = await this.client.reserve(counter);
       const { global, difference } = await this.globalizeIds(pckg, ids, sorted);
       if (pckg.errors?.length) {
-        return { errors: pckg.errors };
+        return { errors };
       }
       await this.insertItems(pckg, global, counter, dependedLinks, errors, mutated);
       if (errors.length) return { errors };

migrations/1655979260869-sync-handlers.ts

@@ -313,7 +313,7 @@ const prepareFunction = /*javascript*/`
 const selectValueTable = `\`SELECT * FROM \${table} WHERE link_id = \${linkId}\``;
 const selectLinkByValue = `\`SELECT link_id as id FROM \${table} WHERE value = '\${value}'::\${table==='strings' ? 'text' : table==='objects' ? 'jsonb' : 'bigint'}\``;
 
-const generateSelectWhereCode = /*javascript*/`(_where, shift = 0) => {
+const generateSelectWhereCode = /*javascript*/`(_where) => {
   const where = [];
   let values = [];
   let valueTable;
@@ -322,20 +322,20 @@ const generateSelectWhereCode = /*javascript*/`(_where, shift = 0) => {
     if (_where[keys[i]]) {
       if ( !_where[keys[i]]['_in'] ) {
         if (keys[i] !== 'object' && keys[i] !== 'string' && keys[i] !== 'number') {
-          where.push('"main".'.concat(keys[i], ' = $',values.length+1+shift));
+          where.push('"main".'.concat(keys[i], ' = $',values.length+2));
           values.push(_where[keys[i]]);
         } else {
           const valueKeys = Object.keys(_where[keys[i]]);
           where.push(keys[i].concat('s.link_id = "main".id'));
           valueTable = keys[i].concat('s');
           for (let j = 0; j < valueKeys.length; j++ ){
             if ( !_where[keys[i]][valueKeys[j]]['_in'] ) {
-              where.push('"'.concat(keys[i].concat('s".'), valueKeys[j], ' = $', values.length+1+shift));
+              where.push('"'.concat(keys[i].concat('s".'), valueKeys[j], ' = $', values.length+2));
               values.push(_where[keys[i]][valueKeys[j]]);
             } else {
               const inLength = _where[keys[i]][valueKeys[j]]['_in'].length;
-              let inValues = '$'.concat(values.length+1+shift);
-              for (let l = values.length+2+shift; l < inLength+values.length+1+shift; l++ ) {
+              let inValues = '$'.concat(values.length+2);
+              for (let l = values.length+3; l < inLength+values.length+2; l++ ) {
                 inValues = inValues.concat(',$',l);
               }
               if(typeof _where[keys[i]][valueKeys[j]]['_in'][0] === 'number'){
@@ -352,8 +352,8 @@ const generateSelectWhereCode = /*javascript*/`(_where, shift = 0) => {
         }
       } else {
         const inLength = _where[keys[i]]['_in'].length;
-        let inValues = '$'.concat(values.length+1+shift);
-        for (let l = values.length+2+shift; l < inLength+where.length+1+shift; l++ ) {
+        let inValues = '$'.concat(values.length+2);
+        for (let l = values.length+3; l < inLength+where.length+2; l++ ) {
           inValues = inValues.concat(',$',l);
         }
         if(typeof _where[keys[i]]['_in'][0] === 'number'){
@@ -548,7 +548,8 @@ const findLinkIdByValueCode = /*javascript*/`({ string, object, number, value })
   }
 }`;
 
-const objectSet = `\`update objects set value = jsonb_set(value, $2, $3, true) where link_id = $1\``;
+const wherePush =  `\`\${whereFileds[counter]} = $\${counter}\``;
+const setPush =  `\`\${setFileds[counter]} = $\${counter}\``;
 
 const deepFabric =  /*javascript*/`(ownerId, hasura_session) => {
   hasura_session['x-hasura-role'] = 'link';
@@ -580,11 +581,6 @@ const deepFabric =  /*javascript*/`(ownerId, hasura_session) => {
         plv8.elog(ERROR, 'Id not found by '.concat(start, ' -> ', path.join(' -> ')));
       }
     },
-    objectSet: function(link_id, path, value) {
-      plv8.execute('SELECT set_config($1, $2, $3)', [ 'hasura.user', JSON.stringify({...hasura_session, 'x-hasura-user-id': this.linkId}), true]);
-      hasura_session['x-hasura-user-id'] = this.linkId;
-      plv8.execute(${objectSet}, [link_id, path, value]);
-    },
     select: function(_where, options) {
       if (options?.table && !['links', 'tree', 'can', 'selectors'].includes(options?.table)) plv8.elog(ERROR, 'select not from "links" not permitted');
       plv8.execute('SELECT set_config($1, $2, $3)', [ 'hasura.user', JSON.stringify({...hasura_session, 'x-hasura-user-id': this.linkId}), true]);
@@ -596,7 +592,7 @@ const deepFabric =  /*javascript*/`(ownerId, hasura_session) => {
         const findLinkIdByValue = ${findLinkIdByValueCode};
         const fillValueByLinks = ${fillValueByLinksCode};
         const isDeepEqual = ${isDeepEqualCode};
-        let generated = generateSelectWhere(_where, 1);
+        let generated = generateSelectWhere(_where);
         const where = generated.where;
         let links = [];
         const valueTableString = generated.valueTable ? ', "'.concat(generated.valueTable, '"') : '';
@@ -609,7 +605,7 @@ const deepFabric =  /*javascript*/`(ownerId, hasura_session) => {
       if (options?.table === 'tree'){
         const { id, link_id, parent_id, depth, root_id, position_id, tree_id } = _where;
         const generateSelectWhere = ${generateSelectWhereCode};
-        let generated = generateSelectWhere(_where, 1);
+        let generated = generateSelectWhere(_where);
         const where = generated.where;
         let links = [];
         if (where) links = plv8.execute(${selectTreeWithPermissions}, [ this.linkId, ...generated.values ]);
@@ -836,16 +832,14 @@ const triggerFunctionFabric = (handleOperationTypeId, valueTrigger) => /*javascr
 `;
 
 const deepClientFunction = /*javascript*/`
-
 const checkInsertPermission = ${checkInsertPermissionCode};
 const checkUpdatePermission = ${checkUpdatePermissionCode};
 const checkDeleteLinkPermission = ${checkDeleteLinkPermissionCode}; 
 const hasura_session = JSON.parse(plv8.execute("select current_setting('hasura.user', 't')")[0].current_setting);
 const default_role = hasura_session['x-hasura-role'];
 const default_user_id = hasura_session['x-hasura-user-id'];
-
 const deep = (${deepFabric})(Number(clientlinkid), hasura_session);
-const result = operation === 'id' || operation === 'update' || operation === 'objectSet' ? deep[operation](...args) : deep[operation](args, options);
+const result = operation === 'id' || operation === 'update' ? deep[operation](...args) : deep[operation](args, options);
 if (hasura_session['x-hasura-role'] !== default_role || hasura_session['x-hasura-user-id'] !== default_user_id){
   if (default_role) hasura_session['x-hasura-role'] = default_role; 
   if (default_user_id) hasura_session['x-hasura-user-id'] = default_user_id;

migrations/1693460330175-sync-handlers-update.ts

@@ -1,6 +1,6 @@
 {
   "name": "@deep-foundation/deeplinks",
-  "version": "0.0.291",
+  "version": "0.0.288",
   "license": "Unlicense",
   "type": "module",
   "scripts": {
@@ -20,9 +20,8 @@
     "benchmark": "export DEEPLINKS_HASURA_PATH=localhost:8080; export DEEPLINKS_HASURA_SSL=0; export DEEPLINKS_HASURA_SECRET=myadminsecretkey; ts-node benchmarks/index.ts",
     "migrate": "npm run package:build && npx migrate@latest up --matches '*.js'",
     "unmigrate": "npm run package:build && npx migrate@latest down --matches '*.js'",
-    "migrate-s-h": "npm run package:build && npx migrate@latest up 1693460330175-sync-handlers-update --matches '*.js'",
-    "unmigrate-s-h": "npm run package:build && npx migrate@latest down 1693460330175-sync-handlers-update --matches '*.js'",
-    "remigrate-s-h": "npm run unmigrate-s-h && npm run migrate",
+    "migrate-s-h": "npm run package:build && npx migrate@latest up 1655979260869-sync-handlers --matches '*.js'",
+    "unmigrate-s-h": "npm run package:build && npx migrate@latest down 1655979260869-sync-handlers --matches '*.js'",
     "start-engine-docker": "npm run start-engine-docker-core",
     "start-engine-docker-core": "cd ./node_modules/@deep-foundation/hasura && npm run docker",
     "stop-engine-docker": "cd ./node_modules/@deep-foundation/hasura/local && docker-compose --project-name deep down",
@@ -89,7 +88,7 @@
     "react": "*"
   },
   "engines": {
-    "node": "^18"
+    "node": "^18.16.1"
   },
   "devDependencies": {
     "@testing-library/jest-dom": "^5.16.5",