@pdftron/collab-sql-resolver-generator - npm Package Compare versions

Comparing version 2.0.0-alpha.15 to 2.0.0-alpha.17

dist/index.js

@@ -1,1 +0,1 @@
-!function(e,t){"object"==typeof exports&&"object"==typeof module?module.exports=t():"function"==typeof define&&define.amd?define([],t):"object"==typeof exports?exports.CollabPostgresGenerator=t():e.CollabPostgresGenerator=t()}(global,(function(){return function(e){var t={};function n(r){if(t[r])return t[r].exports;var o=t[r]={i:r,l:!1,exports:{}};return e[r].call(o.exports,o,o.exports,n),o.l=!0,o.exports}return n.m=e,n.c=t,n.d=function(e,t,r){n.o(e,t)||Object.defineProperty(e,t,{enumerable:!0,get:r})},n.r=function(e){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},n.t=function(e,t){if(1&t&&(e=n(e)),8&t)return e;if(4&t&&"object"==typeof e&&e&&e.__esModule)return e;var r=Object.create(null);if(n.r(r),Object.defineProperty(r,"default",{enumerable:!0,value:e}),2&t&&"string"!=typeof e)for(var o in e)n.d(r,o,function(t){return e[t]}.bind(null,o));return r},n.n=function(e){var t=e&&e.__esModule?function(){return e.default}:function(){return e};return n.d(t,"a",t),t},n.o=function(e,t){return Object.prototype.hasOwnProperty.call(e,t)},n.p="",n(n.s=2)}([function(e,t,n){"use strict";var r=this&&this.__createBinding||(Object.create?function(e,t,n,r){void 0===r&&(r=n),Object.defineProperty(e,r,{enumerable:!0,get:function(){return t[n]}})}:function(e,t,n,r){void 0===r&&(r=n),e[r]=t[n]}),o=this&&this.__setModuleDefault||(Object.create?function(e,t){Object.defineProperty(e,"default",{enumerable:!0,value:t})}:function(e,t){e.default=t}),i=this&&this.__importStar||function(e){if(e&&e.__esModule)return e;var t={};if(null!=e)for(var n in e)"default"!==n&&Object.prototype.hasOwnProperty.call(e,n)&&r(t,e,n);return o(t,e),t};Object.defineProperty(t,"__esModule",{value:!0}),t.setupLogger=t.LogLevels=t.LogTags=void 0;var u=i(n(1)),a=n(6);t.LogTags={STANDARD:"STANDARD",ENTITY:"ENTITY",QUERY:"QUERY",MUTATION:"MUTATION",RESPONSE:"RESPONSE",AUTH:"AUTH",CACHE:"CACHE",CONNECTED_USERS:"CONNECTED_USERS",SCROLL_SYNC:"SCROLL_SYNC"},t.LogLevels={ERROR:"error",WARN:"warn",INFO:"info",HTTP:"http",VERBOSE:"verbose",DEBUG:"debug",SILLY:"silly",NONE:"none"};var s=u.default.createLogger({format:u.format.combine(u.format.timestamp({format:"YYYY-MM-DD HH:mm:ss"}))});t.setupLogger=function(e,n,r){e===t.LogLevels.NONE?s.silent=!0:(a.addConsoleTransport(s,e,r),n&&n.length&&a.addTransports(s,n))},t.default=s},function(e,t){e.exports=require("winston")},function(e,t,n){"use strict";var r=this&&this.__assign||function(){return(r=Object.assign||function(e){for(var t,n=1,r=arguments.length;n<r;n++)for(var o in t=arguments[n])Object.prototype.hasOwnProperty.call(t,o)&&(e[o]=t[o]);return e}).apply(this,arguments)},o=this&&this.__createBinding||(Object.create?function(e,t,n,r){void 0===r&&(r=n),Object.defineProperty(e,r,{enumerable:!0,get:function(){return t[n]}})}:function(e,t,n,r){void 0===r&&(r=n),e[r]=t[n]}),i=this&&this.__setModuleDefault||(Object.create?function(e,t){Object.defineProperty(e,"default",{enumerable:!0,value:t})}:function(e,t){e.default=t}),u=this&&this.__importStar||function(e){if(e&&e.__esModule)return e;var t={};if(null!=e)for(var n in e)"default"!==n&&Object.prototype.hasOwnProperty.call(e,n)&&o(t,e,n);return i(t,e),t},a=this&&this.__awaiter||function(e,t,n,r){return new(n||(n=Promise))((function(o,i){function u(e){try{s(r.next(e))}catch(e){i(e)}}function a(e){try{s(r.throw(e))}catch(e){i(e)}}function s(e){var t;e.done?o(e.value):(t=e.value,t instanceof n?t:new n((function(e){e(t)}))).then(u,a)}s((r=r.apply(e,t||[])).next())}))},s=this&&this.__generator||function(e,t){var n,r,o,i,u={label:0,sent:function(){if(1&o[0])throw o[1];return o[1]},trys:[],ops:[]};return i={next:a(0),throw:a(1),return:a(2)},"function"==typeof Symbol&&(i[Symbol.iterator]=function(){return this}),i;function a(i){return function(a){return function(i){if(n)throw new TypeError("Generator is already executing.");for(;u;)try{if(n=1,r&&(o=2&i[0]?r.return:i[0]?r.throw||((o=r.return)&&o.call(r),0):r.next)&&!(o=o.call(r,i[1])).done)return o;switch(r=0,o&&(i=[2&i[0],o.value]),i[0]){case 0:case 1:o=i;break;case 4:return u.label++,{value:i[1],done:!1};case 5:u.label++,r=i[1],i=[0];continue;case 7:i=u.ops.pop(),u.trys.pop();continue;default:if(!(o=u.trys,(o=o.length>0&&o[o.length-1])||6!==i[0]&&2!==i[0])){u=0;continue}if(3===i[0]&&(!o||i[1]>o[0]&&i[1]<o[3])){u.label=i[1];break}if(6===i[0]&&u.label<o[1]){u.label=o[1],o=i;break}if(o&&u.label<o[2]){u.label=o[2],u.ops.push(i);break}o[2]&&u.ops.pop(),u.trys.pop();continue}i=t.call(e,u)}catch(e){i=[6,e],r=0}finally{n=o=0}if(5&i[0])throw i[1];return{value:i[0]?i[1]:void 0,done:!0}}([i,a])}}},d=this&&this.__await||function(e){return this instanceof d?(this.v=e,this):new d(e)},c=this&&this.__asyncGenerator||function(e,t,n){if(!Symbol.asyncIterator)throw new TypeError("Symbol.asyncIterator is not defined.");var r,o=n.apply(e,t||[]),i=[];return r={},u("next"),u("throw"),u("return"),r[Symbol.asyncIterator]=function(){return this},r;function u(e){o[e]&&(r[e]=function(t){return new Promise((function(n,r){i.push([e,t,n,r])>1||a(e,t)}))})}function a(e,t){try{(n=o[e](t)).value instanceof d?Promise.resolve(n.value.v).then(s,c):l(i[0][2],n)}catch(e){l(i[0][3],e)}var n}function s(e){a("next",e)}function c(e){a("throw",e)}function l(e,t){e(t),i.shift(),i.length&&a(i[0][0],i[0][1])}},l=this&&this.__asyncValues||function(e){if(!Symbol.asyncIterator)throw new TypeError("Symbol.asyncIterator is not defined.");var t,n=e[Symbol.asyncIterator];return n?n.call(e):(e="function"==typeof __values?__values(e):e[Symbol.iterator](),t={},r("next"),r("throw"),r("return"),t[Symbol.asyncIterator]=function(){return this},t);function r(n){t[n]=e[n]&&function(t){return new Promise((function(r,o){(function(e,t,n,r){Promise.resolve(r).then((function(t){e({value:t,done:n})}),t)})(r,o,(t=e[n](t)).done,t.value)}))}}},f=this&&this.__read||function(e,t){var n="function"==typeof Symbol&&e[Symbol.iterator];if(!n)return e;var r,o,i=n.call(e),u=[];try{for(;(void 0===t||t-- >0)&&!(r=i.next()).done;)u.push(r.value)}catch(e){o={error:e}}finally{try{r&&!r.done&&(n=i.return)&&n.call(i)}finally{if(o)throw o.error}}return u},m=this&&this.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(t,"__esModule",{value:!0}),t.LogTags=t.LogLevels=t.MutationOperationType=t.SQLClient=void 0;var p=m(n(3)),v=n(4),h=u(n(0)),y=n(7);t.SQLClient={Postgres:"pg",MSSQL:"mssql",SQLite3:"sqlite3",Oracle:"oracledb",MySQL:"mysql"},t.MutationOperationType={CREATE:"create",UPDATE:"update"};var b=n(0);Object.defineProperty(t,"LogLevels",{enumerable:!0,get:function(){return b.LogLevels}}),Object.defineProperty(t,"LogTags",{enumerable:!0,get:function(){return b.LogTags}}),t.default=function(e){var n=e.client,o=e.version,i=void 0===o?"":o,u=e.connection,m=e.pool,b=void 0===m?{min:2,max:10}:m,M=e.getDatabaseTimestamp,g=void 0===M?v.defaultGetDatabaseTimestamp:M,T=e.parseToUnixTimestamp,w=void 0===T?v.defaultParseToUnixTimestamp:T,C=e.logLevel,A=void 0===C?h.LogLevels.ERROR:C,q=e.filterLogsByTag,S=e.transports,x=void 0===S?[]:S;v.testTimeTransformFunctions(w,g),h.setupLogger(A,x,q),h.default.info("Collab SQL Resolver Generator version 2.0.0-alpha.15");var N=y.validateSchema(h.LogLevels,h.LogTags,t.SQLClient).validate(e).error;if(N)throw h.default.error(N.details),new Error(""+N);var _=v.attachAdditionalInfo(e.info),O=p.default({client:n,version:i,connection:u,pool:r({afterCreate:function(e,t){h.default.info("--\x3e Database connected"),t(null,e)}},b),postProcessResponse:function(e,t){if(!t)return e;if(null==t?void 0:t.isCountQuery)return e;if(0===e.length)return e;var n=v.transformToApolloFormat({result:e,columns:null==t?void 0:t.columns,columnsMap:null==t?void 0:t.columnsMap,parseToUnixTimestamp:w});return h.default.log({level:h.LogLevels.DEBUG,tag:h.LogTags.RESPONSE,message:"["+t.from+"]: "+JSON.stringify(n)}),n},debug:A===h.LogLevels.DEBUG,log:{warn:function(e){h.default.warn(e)},error:function(e){h.default.error(e)},deprecate:function(e){h.default.warn(e)},debug:function(e){h.default.log({level:h.LogLevels.DEBUG,tag:h.LogTags.QUERY,message:e})}}}),D=function(e){var t=e.writeMiddleware,n=e.dbDataMap,o=e.operationType,i=e.customContext,u=void 0===i?{}:i;return a(void 0,void 0,void 0,(function(){var e,i,f,m,p,v,h,y;return s(this,(function(b){switch(b.label){case 0:if(e=r({},u),i=r({},n),0===t.length)return[2,i];f=function(){return c(this,arguments,(function(){var n,r,u=this;return s(this,(function(c){switch(c.label){case 0:n=0,r=function(){return a(u,void 0,void 0,(function(){var r;return s(this,(function(u){switch(u.label){case 0:return(r=t[n])?[4,new Promise((function(t){r({data:i,ctx:e,type:o,knex:O,next:function(n,r){n&&(i=n),r&&(e=r),t()}})}))]:[2];case 1:return u.sent(),[2]}}))}))},c.label=1;case 1:return n<t.length?[4,d(r())]:[3,5];case 2:return c.sent(),n++,[4,d(void 0)];case 3:return[4,c.sent()];case 4:return c.sent(),[3,1];case 5:return[4,d(void 0)];case 6:return[2,c.sent()]}}))}))}(),b.label=1;case 1:b.trys.push([1,6,7,12]),m=l(f),b.label=2;case 2:return[4,m.next()];case 3:if((p=b.sent()).done)return[3,5];p.value,f.next(),b.label=4;case 4:return[3,2];case 5:return[3,12];case 6:return v=b.sent(),h={error:v},[3,12];case 7:return b.trys.push([7,,10,11]),p&&!p.done&&(y=m.return)?[4,y.call(m)]:[3,9];case 8:b.sent(),b.label=9;case 9:return[3,11];case 10:if(h)throw h.error;return[7];case 11:return[7];case 12:return[2,i]}}))}))},I=function(e){var r=e.from,o=e.id,i=e.operationType,u=e.entity,d=e.dbDataMap;return a(void 0,void 0,void 0,(function(){var e,a,c,l,m,p,h,y;return s(this,(function(s){switch(s.label){case 0:return e=u.table,a=u.selectFields,c=u.columns,l=u.columnsMap,i!==t.MutationOperationType.CREATE?[3,2]:[4,O(e).queryContext({from:r,columns:c,columnsMap:l}).insert(d)];case 1:return s.sent(),[3,4];case 2:return i!==t.MutationOperationType.UPDATE?[3,4]:[4,O(e).queryContext({from:r,columns:c,columnsMap:l}).where(v.getColumnName(c.id),o).update(d)];case 3:s.sent(),s.label=4;case 4:return m=n===t.SQLClient.SQLite3?"last_insert_rowid() as id":"LAST_INSERT_ID() as id",[4,O.select(O.raw(m))];case 5:return p=f.apply(void 0,[s.sent(),1]),h=p[0],y=h.id,n===t.SQLClient.SQLite3&&a.push("rowid"),[4,O(e).select(a).queryContext({from:r,columns:c,columnsMap:l}).where(v.getColumnName(c.id),y)];case 6:return[2,s.sent()]}}))}))},E=function(e){var r=e.from,o=e.id,i=e.entity,u=e.data,d=e.customContext,c=e.operationType;return a(void 0,void 0,void 0,(function(){var e,a,l,f,m,p,y,b,M;return s(this,(function(s){switch(s.label){case 0:e=i.table,a=i.writeMiddleware,l=void 0===a?[]:a,f=i.selectFields,m=i.columns,p=i.columnsMap,s.label=1;case 1:return s.trys.push([1,9,,10]),[4,D({writeMiddleware:l,dbDataMap:v.toDatabaseFormat({data:u,table:e,columns:m,getDatabaseTimestamp:g,knex:O}),operationType:c,customContext:d})];case 2:return y=s.sent(),b=[],n!==t.SQLClient.SQLite3&&n!==t.SQLClient.MySQL?[3,4]:[4,I({from:r,id:o,operationType:c,entity:i,dbDataMap:y})];case 3:return b=s.sent(),[3,8];case 4:return c!==t.MutationOperationType.CREATE?[3,6]:[4,O(e).queryContext({from:r,columns:m,columnsMap:p}).insert(y).returning(f)];case 5:return b=s.sent(),[3,8];case 6:return[4,O(e).queryContext({from:r,columns:m,columnsMap:p}).where(v.getColumnName(m.id),o).update(y).returning(f)];case 7:b=s.sent(),s.label=8;case 8:return[2,b[0]||null];case 9:return M=s.sent(),h.default.error(M),[3,10];case 10:return[2]}}))}))},j=function(e){var t=e.entity,n=e.id;return a(void 0,void 0,void 0,(function(){var e,r,o;return s(this,(function(i){switch(i.label){case 0:e=t.table,r=t.columns,i.label=1;case 1:return i.trys.push([1,3,,4]),[4,O(e).where(v.getColumnName(r.id),n).del().returning(v.getColumnName(r.id))];case 2:return[2,{id:""+i.sent()[0],successful:!0}];case 3:return o=i.sent(),h.default.error(o),[2,{id:n,successful:!1}];case 4:return[2]}}))}))},L={Query:{user:function(e){return a(void 0,void 0,void 0,(function(){var t,n,r,o,i,u;return s(this,(function(a){switch(a.label){case 0:return t=_.Users,n=t.selectFields,r=void 0===n?[]:n,o=t.table,i=t.columns,u=t.columnsMap,[4,O(o).queryContext({from:"Query.user",columns:i,columnsMap:u}).select(r).where(v.getColumnName(i.id),e).limit(1).then((function(e){return e}))];case 1:return[2,a.sent()[0]||null]}}))}))},userWithEmail:function(e){return a(void 0,void 0,void 0,(function(){var t,n,r,o,i,u;return s(this,(function(a){switch(a.label){case 0:return t=_.Users,n=t.selectFields,r=void 0===n?[]:n,o=t.table,i=t.columns,u=t.columnsMap,[4,O(o).queryContext({from:"Query.userWithEmail",columns:i,columnsMap:u}).select(r).where(v.getColumnName(i.email),e).limit(1)];case 1:return[2,a.sent()[0]||null]}}))}))},annotations:function(e){return a(void 0,void 0,void 0,(function(){var t,n,r,o,i,u,a,d,c,l,f,m,p;return s(this,(function(s){switch(s.label){case 0:return t=e.ids,n=e.documentId,r=e.annotationIds,o=e.filters,i=void 0===o?{}:o,u=e.inReplyTo,a=e.pageNumbers,d=_.Annotations,c=d.selectFields,l=void 0===c?[]:c,f=d.table,m=d.columns,p=d.columnsMap,[4,O(f).queryContext({from:"Query.annotations",columns:m,columnsMap:p}).select(l).where((function(e){t&&e.whereIn(v.getColumnName(m.id),t),r&&e.whereIn(v.getColumnName(m.annotationId),r),n&&e.where(v.getColumnName(m.documentId),n),u&&e.where(v.getColumnName(m.inReplyTo),u),a&&e.whereIn(v.getColumnName(m.pageNumber),a),v.buildFilterQuery(e,i,m,g)})).modify((function(e){v.buildModifyQuery(e,i,m)}))];case 1:return[2,s.sent()]}}))}))},documents:function(e){return a(void 0,void 0,void 0,(function(){var t,n,r,o,i,u,a,d,c,l;return s(this,(function(s){switch(s.label){case 0:return t=e.ids,n=e.userId,r=e.filters,o=void 0===r?{}:r,i=_.Documents,u=i.selectFields,a=void 0===u?[]:u,d=i.table,c=i.columns,l=i.columnsMap,[4,O(d).queryContext({from:"Query.documents",columns:c,columnsMap:l}).select(a).where((function(e){t&&e.whereIn(v.getColumnName(c.id),t),n&&e.whereIn(v.getColumnName(c.id),(function(){this.select(v.getColumnName(_.DocumentMembers.columns.documentId)).from(_.DocumentMembers.table).where(v.getColumnName(_.DocumentMembers.columns.userId),n)})),v.buildFilterQuery(e,o,c,g)})).modify((function(e){v.buildModifyQuery(e,o,c)}))];case 1:return[2,s.sent()]}}))}))},annotationMembers:function(e){return a(void 0,void 0,void 0,(function(){var t,n,r,o,i,u,a,d,c,l,f;return s(this,(function(s){switch(s.label){case 0:return t=e.annotationId,n=e.ids,r=e.userId,o=e.filters,i=void 0===o?{}:o,u=_.AnnotationMembers,a=u.selectFields,d=void 0===a?[]:a,c=u.table,l=u.columns,f=u.columnsMap,[4,O(c).queryContext({from:"Query.annotationMembers",columns:l,columnsMap:f}).select(d).where((function(e){n&&e.whereIn(v.getColumnName(l.id),n),t&&e.where(v.getColumnName(l.annotationId),t),r&&e.where(v.getColumnName(l.userId),r),v.buildFilterQuery(e,i,l,g)})).modify((function(e){v.buildModifyQuery(e,i,l)}))];case 1:return[2,s.sent()]}}))}))},documentMembers:function(e){return a(void 0,void 0,void 0,(function(){var t,n,r,o,i,u,a,d,c,l,f;return s(this,(function(s){switch(s.label){case 0:return t=e.documentId,n=e.ids,r=e.userId,o=e.filters,i=void 0===o?{}:o,u=_.DocumentMembers,a=u.selectFields,d=void 0===a?[]:a,c=u.table,l=u.columns,f=u.columnsMap,[4,O(c).queryContext({from:"Query.documentMembers",columns:l,columnsMap:f}).select(d).where((function(e){n&&e.whereIn(v.getColumnName(l.id),n),t&&e.where(v.getColumnName(l.documentId),t),r&&e.where(v.getColumnName(l.userId),r),v.buildFilterQuery(e,i,l,g)})).modify((function(e){v.buildModifyQuery(e,i,l)}))];case 1:return[2,s.sent()]}}))}))},mentions:function(e){return a(void 0,void 0,void 0,(function(){var t,n,r,o,i,u,a,d,c,l,f,m;return s(this,(function(s){switch(s.label){case 0:return t=e.annotationId,n=e.userId,r=e.documentId,o=e.ids,i=e.filters,u=void 0===i?{}:i,a=_.Mentions,d=a.selectFields,c=void 0===d?[]:d,l=a.table,f=a.columns,m=a.columnsMap,[4,O(l).queryContext({from:"Query.mentions",columns:f,columnsMap:m}).select(c).where((function(e){o&&e.whereIn(v.getColumnName(f.id),o),r&&e.where(v.getColumnName(f.documentId),r),t&&e.where(v.getColumnName(f.annotationId),t),n&&e.where(v.getColumnName(f.userId),n),v.buildFilterQuery(e,u,f,g)})).modify((function(e){v.buildModifyQuery(e,u,f)}))];case 1:return[2,s.sent()]}}))}))},annotationCount:function(e){return a(void 0,void 0,void 0,(function(){var t,n,r,o,i,u,a;return s(this,(function(s){switch(s.label){case 0:return t=e.since,n=e.documentId,r=_.Annotations,o=r.table,i=r.columns,u=r.columnsMap,[4,O(o).queryContext({from:"Query.annotationCount",columns:i,columnsMap:u,isCountQuery:!0}).count({count:[v.getColumnName(i.id)]}).where(v.getColumnName(i.documentId),n).where(v.getColumnName(i.createdAt),">",g(t))];case 1:return a=s.sent(),[2,Number(a[0].count||0)]}}))}))},annotationMemberCount:function(e){return a(void 0,void 0,void 0,(function(){var t,n,r,o,i,u,a,d;return s(this,(function(s){switch(s.label){case 0:return t=e.userId,n=e.documentId,r=e.since,o=_.AnnotationMembers,i=o.table,u=o.columns,a=o.columnsMap,[4,O(i).queryContext({from:"Query.annotationMemberCount",columns:u,columnsMap:a,isCountQuery:!0}).count({count:[v.getColumnName(u.id)]}).where(v.getColumnName(u.documentId),n).where(v.getColumnName(u.userId),t).where(v.getColumnName(u.createdAt),">",g(r))];case 1:return d=s.sent(),[2,Number(d[0].count||0)]}}))}))}},Mutation:{addUser:function(e,n){return a(void 0,void 0,void 0,(function(){return s(this,(function(r){return[2,E({from:"Mutation.addUser",entity:_.Users,data:e,customContext:n,operationType:t.MutationOperationType.CREATE})]}))}))},addAnnotation:function(e,n){return a(void 0,void 0,void 0,(function(){return s(this,(function(r){return[2,E({from:"Mutation.addAnnotation",entity:_.Annotations,data:e,customContext:n,operationType:t.MutationOperationType.CREATE})]}))}))},editAnnotation:function(e,n,r){return a(void 0,void 0,void 0,(function(){var o,i,u,a;return s(this,(function(s){return o=n.xfdf,i=n.pageNumber,u=n.updatedAt,a=n.annotContents,[2,E({from:"Mutation.editAnnotation",customContext:r,entity:_.Annotations,id:e,data:{xfdf:o,pageNumber:i,updatedAt:u,annotContents:a},operationType:t.MutationOperationType.UPDATE})]}))}))},deleteAnnotation:function(e,t){return a(void 0,void 0,void 0,(function(){return s(this,(function(n){switch(n.label){case 0:return[4,j({from:"Mutation.deleteAnnotation",entity:_.Annotations,id:e,customContext:t})];case 1:return[2,n.sent()]}}))}))},addDocument:function(e,n){return a(void 0,void 0,void 0,(function(){return s(this,(function(r){return[2,E({from:"Mutation.addDocument",entity:_.Documents,data:e,customContext:n,operationType:t.MutationOperationType.CREATE})]}))}))},editDocument:function(e,n,r){return a(void 0,void 0,void 0,(function(){var o,i,u;return s(this,(function(a){return o=n.name,i=n.isPublic,u=n.updatedAt,[2,E({from:"Mutation.editDocument",entity:_.Documents,id:e,data:{name:o,isPublic:i,updatedAt:u},customContext:r,operationType:t.MutationOperationType.UPDATE})]}))}))},deleteDocument:function(e,t){return a(void 0,void 0,void 0,(function(){return s(this,(function(n){return[2,j({from:"Mutation.deleteDocument",entity:_.Documents,id:e,customContext:t})]}))}))},addDocumentMember:function(e,n){return a(void 0,void 0,void 0,(function(){return s(this,(function(r){return[2,E({from:"Mutation.addDocumentMember",entity:_.DocumentMembers,data:e,customContext:n,operationType:t.MutationOperationType.CREATE})]}))}))},editDocumentMember:function(e,n,r){return a(void 0,void 0,void 0,(function(){var o,i;return s(this,(function(u){return o=n.lastRead,i=n.updatedAt,[2,E({from:"Mutation.editDocumentMember",entity:_.DocumentMembers,id:e,data:{lastRead:o,updatedAt:i},customContext:r,operationType:t.MutationOperationType.UPDATE})]}))}))},deleteDocumentMember:function(e,t){return a(void 0,void 0,void 0,(function(){return s(this,(function(n){return[2,j({from:"Mutation.deleteDocumentMember",entity:_.DocumentMembers,id:e,customContext:t})]}))}))},addAnnotationMember:function(e,n){return a(void 0,void 0,void 0,(function(){return s(this,(function(r){return[2,E({from:"Mutation.addAnnotationMember",entity:_.AnnotationMembers,data:e,customContext:n,operationType:t.MutationOperationType.CREATE})]}))}))},editAnnotationMember:function(e,n,r){return a(void 0,void 0,void 0,(function(){var o,i;return s(this,(function(u){return o=n.lastRead,i=n.updatedAt,[2,E({from:"Mutation.editAnnotationMember",entity:_.AnnotationMembers,id:e,data:{lastRead:o,updatedAt:i},customContext:r,operationType:t.MutationOperationType.UPDATE})]}))}))},deleteAnnotationMember:function(e,t){return a(void 0,void 0,void 0,(function(){return s(this,(function(n){return[2,j({from:"Mutation.deleteAnnotationMember",entity:_.AnnotationMembers,id:e,customContext:t})]}))}))},addMention:function(e,n){return a(void 0,void 0,void 0,(function(){return s(this,(function(r){return[2,E({from:"Mutation.addMention",entity:_.Mentions,data:e,customContext:n,operationType:t.MutationOperationType.CREATE})]}))}))},deleteMention:function(e,t){return a(void 0,void 0,void 0,(function(){return s(this,(function(n){return[2,j({from:"Mutation.deleteMention",entity:_.Mentions,id:e,customContext:t})]}))}))}}};return _.Snapshots&&(L.Query.snapshots=function(e){return a(void 0,void 0,void 0,(function(){var t,n,r,o,i,u,a,d,c,l;return s(this,(function(s){switch(s.label){case 0:return t=e.ids,n=e.documentId,r=e.filters,o=void 0===r?{}:r,i=_.Snapshots,u=i.selectFields,a=void 0===u?[]:u,d=i.table,c=i.columns,l=i.columnsMap,[4,O(d).queryContext({from:"Query.snapshots",columns:c,columnsMap:l}).select(a).where((function(e){t&&e.whereIn(v.getColumnName(c.id),t),n&&e.where(v.getColumnName(c.documentId),n),v.buildFilterQuery(e,o,c,g)})).modify((function(e){v.buildModifyQuery(e,o,c)}))];case 1:return[2,s.sent()]}}))}))},L.Mutation.addSnapshot=function(e,n){return a(void 0,void 0,void 0,(function(){return s(this,(function(r){return[2,E({from:"Mutation.addSnapshot",entity:_.Snapshots,data:e,customContext:n,operationType:t.MutationOperationType.CREATE})]}))}))},L.Mutation.editSnapshot=function(e,n,r){return a(void 0,void 0,void 0,(function(){var o,i;return s(this,(function(u){return o=n.name,i=n.updatedAt,[2,E({from:"Mutation.editSnapshot",customContext:r,entity:_.Snapshots,id:e,data:{name:o,updatedAt:i},operationType:t.MutationOperationType.UPDATE})]}))}))},L.Mutation.deleteSnapshot=function(e,t){return a(void 0,void 0,void 0,(function(){return s(this,(function(n){switch(n.label){case 0:return[4,j({from:"Mutation.deleteSnapshot",entity:_.Snapshots,id:e,customContext:t})];case 1:return[2,n.sent()]}}))}))}),_.SnapshotAssets&&(L.Query.snapshotAssets=function(e){return a(void 0,void 0,void 0,(function(){var t,n,r,o,i,u,a,d;return s(this,(function(s){switch(s.label){case 0:return t=e.ids,n=e.snapshotId,r=_.SnapshotAssets,o=r.selectFields,i=void 0===o?[]:o,u=r.table,a=r.columns,d=r.columnsMap,[4,O(u).queryContext({from:"Query.snapshotAssets",columns:a,columnsMap:d}).select(i).where((function(e){t&&e.whereIn(v.getColumnName(a.id),t),n&&e.where(v.getColumnName(a.snapshotId),n)}))];case 1:return[2,s.sent()]}}))}))},L.Mutation.addSnapshotAsset=function(e,n){return a(void 0,void 0,void 0,(function(){return s(this,(function(r){return[2,E({from:"Mutation.addSnapshotAsset",entity:_.SnapshotAssets,data:e,customContext:n,operationType:t.MutationOperationType.CREATE})]}))}))},L.Mutation.editSnapshotAsset=function(e,n,r){return a(void 0,void 0,void 0,(function(){var o,i;return s(this,(function(u){return o=n.snapshotId,i=n.updatedAt,[2,E({from:"Mutation.editSnapshotAsset",customContext:r,entity:_.SnapshotAssets,id:e,data:{snapshotId:o,updatedAt:i},operationType:t.MutationOperationType.UPDATE})]}))}))},L.Mutation.deleteSnapshotAsset=function(e,t){return a(void 0,void 0,void 0,(function(){return s(this,(function(n){switch(n.label){case 0:return[4,j({from:"Mutation.deleteSnapshotAsset",entity:_.SnapshotAssets,id:e,customContext:t})];case 1:return[2,n.sent()]}}))}))}),L}},function(e,t){e.exports=require("knex")},function(e,t,n){"use strict";var r=this&&this.__assign||function(){return(r=Object.assign||function(e){for(var t,n=1,r=arguments.length;n<r;n++)for(var o in t=arguments[n])Object.prototype.hasOwnProperty.call(t,o)&&(e[o]=t[o]);return e}).apply(this,arguments)},o=this&&this.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(t,"__esModule",{value:!0}),t.attachAdditionalInfo=t.transformToApolloFormat=t.keysToCamel=t.toUnixTimestamp=t.testTimeTransformFunctions=t.defaultGetDatabaseTimestamp=t.defaultParseToUnixTimestamp=t.toDatabaseFormat=t.buildModifyQuery=t.getColumnName=t.buildFilterQuery=void 0;var i=n(5),u=o(n(0));t.buildFilterQuery=function(e,n,r,o){n.createdBefore&&e.where(t.getColumnName(r.createdAt),"<",o(n.createdBefore)),n.createdAfter&&e.where(t.getColumnName(r.createdAt),">",o(n.createdAfter)),n.updatedBefore&&e.where(t.getColumnName(r.updatedAt),"<",o(n.updatedBefore)),n.updatedAfter&&e.where(t.getColumnName(r.updatedAt),">",o(n.updatedAfter))};t.getColumnName=function(e){return"string"==typeof e?e:e.name};t.buildModifyQuery=function(e,n,r){var o=n.limit,i=n.orderBy,u=n.orderDirection,a=void 0===u?"DESC":u;i&&e.orderBy(t.getColumnName(r[i]),a),o&&e.limit(o)};t.toDatabaseFormat=function(e){var n=e.data,r=e.table,o=e.columns,a=e.getDatabaseTimestamp,s=e.knex,d={};for(var c in n)void 0===o[c]?u.default.warn("SQL Resolver Generator - Received unexpected data { '"+c+"': '"+n[c]+"' } when formatting data for the \""+r+'" table. This data will be ignored.\n\nReceived data:\n\n'+JSON.stringify(n,null,2)):i.TimestampProperties.includes(c)?i.NowTimestampProperties.includes(c)?d[t.getColumnName(o[c])]=s.raw(n[c]):d[t.getColumnName(o[c])]=a(n[c]):d[t.getColumnName(o[c])]=n[c];return d};t.defaultParseToUnixTimestamp=function(e){return new Date(e).getTime()};t.defaultGetDatabaseTimestamp=function(e){return new Date(e).toISOString()};t.testTimeTransformFunctions=function(e,t){var n=Date.now();if(e(t(n))!==n)throw new Error('Configuration error: "getDatabaseTimestamp" and "parseToUnixTimestamp" functions are not compatible. The result of "parseUnixFunc" must be equal to the input of "getDatabaseTimestampFunc". For example, the following must be true: parseUnixFunc(getDatabaseTimestamp('+n+")) === "+n)};t.toUnixTimestamp=function(e,t){return Object.keys(e).forEach((function(n){i.TimestampProperties.includes(n)&&(e[n]=t(e[n]))})),e};t.keysToCamel=function(e,t,n){var r={};return Object.keys(e).forEach((function(o){if(n[o]){var i=n[o],u="string"!=typeof t[i]&&!!t[i].transform;r[i]=u?t[i].transform(e[o]):e[o]}})),r};t.transformToApolloFormat=function(e){var n=e.result,r=e.columns,o=e.columnsMap,i=e.parseToUnixTimestamp,u=[];return n.forEach((function(e){var n=t.keysToCamel(e,r,o),a=t.toUnixTimestamp(n,i);u.push(a)})),u};t.attachAdditionalInfo=function(e){var n={Users:r(r({},e.Users),{columnsMap:{},selectFields:[]}),Annotations:r(r({},e.Annotations),{columnsMap:{},selectFields:[]}),Documents:r(r({},e.Documents),{columnsMap:{},selectFields:[]}),AnnotationMembers:r(r({},e.AnnotationMembers),{columnsMap:{},selectFields:[]}),DocumentMembers:r(r({},e.DocumentMembers),{columnsMap:{},selectFields:[]}),Mentions:r(r({},e.Mentions),{columnsMap:{},selectFields:[]}),Snapshots:r(r({},e.Snapshots),{columnsMap:{},selectFields:[]}),SnapshotAssets:r(r({},e.SnapshotAssets),{columnsMap:{},selectFields:[]})};for(var o in e){var i={},u=e[o].columns;for(var a in u){var s=t.getColumnName(u[a]);n[o].selectFields.push(s),i[s]=a}n[o].columnsMap=i}return n}},function(e,t,n){"use strict";Object.defineProperty(t,"__esModule",{value:!0}),t.NowTimestampProperties=t.TimestampProperties=void 0,t.TimestampProperties=["createdAt","updatedAt","lastRead","annotationCreatedAt"],t.NowTimestampProperties=["createdAt","updatedAt","lastRead"]},function(e,t,n){"use strict";var r=this&&this.__createBinding||(Object.create?function(e,t,n,r){void 0===r&&(r=n),Object.defineProperty(e,r,{enumerable:!0,get:function(){return t[n]}})}:function(e,t,n,r){void 0===r&&(r=n),e[r]=t[n]}),o=this&&this.__setModuleDefault||(Object.create?function(e,t){Object.defineProperty(e,"default",{enumerable:!0,value:t})}:function(e,t){e.default=t}),i=this&&this.__importStar||function(e){if(e&&e.__esModule)return e;var t={};if(null!=e)for(var n in e)"default"!==n&&Object.prototype.hasOwnProperty.call(e,n)&&r(t,e,n);return o(t,e),t};Object.defineProperty(t,"__esModule",{value:!0}),t.addTransports=t.addConsoleTransport=void 0;var u=i(n(1)),a=n(0);t.addConsoleTransport=function(e,t,n){void 0===t&&(t=a.LogLevels.INFO),e.add(new u.default.transports.Console({level:t,format:u.format.combine(u.format((function(e){return(!n||e.tag===n)&&e}))(),u.format.colorize(),u.format.printf((function(e){var t=s(e.message),n=e.tag?" ["+e.tag+"]":"",r=s(e.meta);return e.timestamp+" "+e.level+n+": "+t+" "+r})),u.format.metadata({fillExcept:["message","level","timestamp","label"]}))}))};t.addTransports=function(e,t){t.forEach((function(t){return e.add(t)}))};var s=function(e){var t=e||"";return"object"==typeof e&&null!==e&&(t=JSON.stringify(e,null,2)),t}},function(e,t,n){"use strict";var r=this&&this.__read||function(e,t){var n="function"==typeof Symbol&&e[Symbol.iterator];if(!n)return e;var r,o,i=n.call(e),u=[];try{for(;(void 0===t||t-- >0)&&!(r=i.next()).done;)u.push(r.value)}catch(e){o={error:e}}finally{try{r&&!r.done&&(n=i.return)&&n.call(i)}finally{if(o)throw o.error}}return u},o=this&&this.__spreadArray||function(e,t){for(var n=0,r=t.length,o=e.length;n<r;n++,o++)e[o]=t[n];return e},i=this&&this.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(t,"__esModule",{value:!0}),t.validateSchema=void 0;var u=i(n(8)),a=u.default.alternatives().try(u.default.object({name:u.default.string().required(),transform:u.default.function()}),u.default.string()).required();t.validateSchema=function(e,t,n){var i,s,d;return u.default.object({client:(i=u.default.string()).valid.apply(i,o([],r(Object.values(n)))).required(),connection:u.default.object().required(),pool:{min:u.default.number(),max:u.default.number()},getDatabaseTimestamp:u.default.func(),parseToUnixTimestamp:u.default.func(),getNow:u.default.func(),logLevel:(s=u.default.string()).valid.apply(s,o([],r(Object.values(e)))),filterLogsByTag:(d=u.default.string()).valid.apply(d,o([],r(Object.values(t)))),transports:u.default.array(),info:u.default.object({Users:u.default.object({table:u.default.string().required(),writeMiddleware:u.default.array().items(u.default.function()),columns:u.default.object({id:a.required(),type:a.required(),email:a.required(),userName:a,createdAt:a.required(),updatedAt:a.required()}).required()}).required(),Annotations:u.default.object({table:u.default.string().required(),writeMiddleware:u.default.array().items(u.default.function()),columns:u.default.object({id:a.required(),xfdf:a.required(),authorId:a.required(),annotationId:a.required(),documentId:a.required(),pageNumber:a.required(),createdAt:a.required(),updatedAt:a.required(),inReplyTo:a.required(),annotContents:a}).required()}).required(),Documents:u.default.object({table:u.default.string().required(),writeMiddleware:u.default.array().items(u.default.function()),columns:u.default.object({id:a.required(),authorId:a.required(),createdAt:a.required(),updatedAt:a.required(),isPublic:a.required(),name:a}).required()}).required(),AnnotationMembers:u.default.object({table:u.default.string().required(),writeMiddleware:u.default.array().items(u.default.function()),columns:u.default.object({id:a.required(),userId:a.required(),documentId:a.required(),annotationId:a.required(),lastRead:a.required(),createdAt:a.required(),updatedAt:a.required(),annotationCreatedAt:a.required()}).required()}),DocumentMembers:u.default.object({table:u.default.string().required(),writeMiddleware:u.default.array().items(u.default.function()),columns:u.default.object({id:a.required(),userId:a.required(),documentId:a.required(),lastRead:a.required(),createdAt:a.required(),updatedAt:a.required()}).required()}).required(),Mentions:u.default.object({table:u.default.string().required(),writeMiddleware:u.default.array().items(u.default.function()),columns:u.default.object({id:a.required(),userId:a.required(),documentId:a.required(),annotationId:a.required(),createdAt:a.required(),updatedAt:a.required()}).required()}).required(),Snapshots:u.default.object({table:u.default.string().required(),writeMiddleware:u.default.array().items(u.default.function()),columns:u.default.object({id:a.required(),authorId:a.required(),documentId:a.required(),xfdf:a.required(),name:a.required(),createdAt:a.required(),updatedAt:a.required()}).required()}),SnapshotAssets:u.default.object({table:u.default.string().required(),writeMiddleware:u.default.array().items(u.default.function()),columns:u.default.object({id:a.required(),snapshotId:a.required(),data:a.required(),createdAt:a.required(),updatedAt:a.required()}).required()})}).required()})}},function(e,t){e.exports=require("joi")}]).default}));
+!function(e,t){"object"==typeof exports&&"object"==typeof module?module.exports=t():"function"==typeof define&&define.amd?define([],t):"object"==typeof exports?exports.CollabPostgresGenerator=t():e.CollabPostgresGenerator=t()}(global,(function(){return function(e){var t={};function n(r){if(t[r])return t[r].exports;var o=t[r]={i:r,l:!1,exports:{}};return e[r].call(o.exports,o,o.exports,n),o.l=!0,o.exports}return n.m=e,n.c=t,n.d=function(e,t,r){n.o(e,t)||Object.defineProperty(e,t,{enumerable:!0,get:r})},n.r=function(e){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},n.t=function(e,t){if(1&t&&(e=n(e)),8&t)return e;if(4&t&&"object"==typeof e&&e&&e.__esModule)return e;var r=Object.create(null);if(n.r(r),Object.defineProperty(r,"default",{enumerable:!0,value:e}),2&t&&"string"!=typeof e)for(var o in e)n.d(r,o,function(t){return e[t]}.bind(null,o));return r},n.n=function(e){var t=e&&e.__esModule?function(){return e.default}:function(){return e};return n.d(t,"a",t),t},n.o=function(e,t){return Object.prototype.hasOwnProperty.call(e,t)},n.p="",n(n.s=3)}([function(e,t,n){"use strict";var r=this&&this.__createBinding||(Object.create?function(e,t,n,r){void 0===r&&(r=n),Object.defineProperty(e,r,{enumerable:!0,get:function(){return t[n]}})}:function(e,t,n,r){void 0===r&&(r=n),e[r]=t[n]}),o=this&&this.__setModuleDefault||(Object.create?function(e,t){Object.defineProperty(e,"default",{enumerable:!0,value:t})}:function(e,t){e.default=t}),i=this&&this.__importStar||function(e){if(e&&e.__esModule)return e;var t={};if(null!=e)for(var n in e)"default"!==n&&Object.prototype.hasOwnProperty.call(e,n)&&r(t,e,n);return o(t,e),t};Object.defineProperty(t,"__esModule",{value:!0}),t.setupLogger=t.LogLevels=t.LogTags=void 0;var a=i(n(2)),u=n(7);t.LogTags={STANDARD:"STANDARD",ENTITY:"ENTITY",QUERY:"QUERY",MUTATION:"MUTATION",RESPONSE:"RESPONSE",AUTH:"AUTH",CACHE:"CACHE",CONNECTED_USERS:"CONNECTED_USERS",SCROLL_SYNC:"SCROLL_SYNC"},t.LogLevels={ERROR:"error",WARN:"warn",INFO:"info",HTTP:"http",VERBOSE:"verbose",DEBUG:"debug",SILLY:"silly",NONE:"none"};var s=a.default.createLogger({format:a.format.combine(a.format.timestamp({format:"YYYY-MM-DD HH:mm:ss"}))});t.setupLogger=function(e,n,r){e===t.LogLevels.NONE?s.silent=!0:(u.addConsoleTransport(s,e,r),n&&n.length&&u.addTransports(s,n))},t.default=s},function(e,t,n){"use strict";var r=this&&this.__read||function(e,t){var n="function"==typeof Symbol&&e[Symbol.iterator];if(!n)return e;var r,o,i=n.call(e),a=[];try{for(;(void 0===t||t-- >0)&&!(r=i.next()).done;)a.push(r.value)}catch(e){o={error:e}}finally{try{r&&!r.done&&(n=i.return)&&n.call(i)}finally{if(o)throw o.error}}return a},o=this&&this.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(t,"__esModule",{value:!0}),t.validateResolver=t.validateParams=t.throwError=t.ErrorCodes=void 0;var i=o(n(0));t.ErrorCodes={PERMISSION_ERROR:"PERMISSION_ERROR"};t.throwError=function(e,t,n){var r=t;throw"string"!=typeof r&&(r=t.message||t.toString()),r=e+" - "+r,i.default.error(r),n?new n(r):"string"!=typeof t?t:new Error(r)};t.validateParams=function(e,t){var n,o=function(t){var n=e+' - Paramater "'+t+'" is required';throw i.default.error(n),new Error(n)},a=function(t,n,r){var o=e+' - Parameter "'+t+'" expected type "'+r+'" but got "'+n+'"';throw i.default.error(o),new Error(o)};for(var u in t){var s=r(t[u],3),d=s[0],l=s[1],c=void 0===l?"any":l,f=s[2],m=void 0===f||f;if(null!=d&&""!==d){if("any"!==c){var p=typeof d;if("string"!==c){if("number"!==c){if("array"!==c){if("blob"!==c){if("boolean"!==c){if("object"!==c){if("function"!==c);else if(!(n=d)||"[object Function]"!=={}.toString.call(n))return a(u,p,c)}else if("object"!==p)return a(u,p,c)}else if("boolean"!==p)return a(u,p,c)}else if(!(d instanceof Blob))return a(u,p,c)}else if(!Array.isArray(d))return a(u,p,c)}else if("number"!==p)return a(u,p,c)}else if("string"!==p)return a(u,p,c)}}else if(m)return o(u)}};t.validateResolver=function(e,n){n||t.throwError(e,"Could not find resolvers for the "+e+". Please make sure you provide resolvers for "+e+".")}},function(e,t){e.exports=require("winston")},function(e,t,n){"use strict";var r=this&&this.__assign||function(){return(r=Object.assign||function(e){for(var t,n=1,r=arguments.length;n<r;n++)for(var o in t=arguments[n])Object.prototype.hasOwnProperty.call(t,o)&&(e[o]=t[o]);return e}).apply(this,arguments)},o=this&&this.__createBinding||(Object.create?function(e,t,n,r){void 0===r&&(r=n),Object.defineProperty(e,r,{enumerable:!0,get:function(){return t[n]}})}:function(e,t,n,r){void 0===r&&(r=n),e[r]=t[n]}),i=this&&this.__setModuleDefault||(Object.create?function(e,t){Object.defineProperty(e,"default",{enumerable:!0,value:t})}:function(e,t){e.default=t}),a=this&&this.__importStar||function(e){if(e&&e.__esModule)return e;var t={};if(null!=e)for(var n in e)"default"!==n&&Object.prototype.hasOwnProperty.call(e,n)&&o(t,e,n);return i(t,e),t},u=this&&this.__awaiter||function(e,t,n,r){return new(n||(n=Promise))((function(o,i){function a(e){try{s(r.next(e))}catch(e){i(e)}}function u(e){try{s(r.throw(e))}catch(e){i(e)}}function s(e){var t;e.done?o(e.value):(t=e.value,t instanceof n?t:new n((function(e){e(t)}))).then(a,u)}s((r=r.apply(e,t||[])).next())}))},s=this&&this.__generator||function(e,t){var n,r,o,i,a={label:0,sent:function(){if(1&o[0])throw o[1];return o[1]},trys:[],ops:[]};return i={next:u(0),throw:u(1),return:u(2)},"function"==typeof Symbol&&(i[Symbol.iterator]=function(){return this}),i;function u(i){return function(u){return function(i){if(n)throw new TypeError("Generator is already executing.");for(;a;)try{if(n=1,r&&(o=2&i[0]?r.return:i[0]?r.throw||((o=r.return)&&o.call(r),0):r.next)&&!(o=o.call(r,i[1])).done)return o;switch(r=0,o&&(i=[2&i[0],o.value]),i[0]){case 0:case 1:o=i;break;case 4:return a.label++,{value:i[1],done:!1};case 5:a.label++,r=i[1],i=[0];continue;case 7:i=a.ops.pop(),a.trys.pop();continue;default:if(!(o=a.trys,(o=o.length>0&&o[o.length-1])||6!==i[0]&&2!==i[0])){a=0;continue}if(3===i[0]&&(!o||i[1]>o[0]&&i[1]<o[3])){a.label=i[1];break}if(6===i[0]&&a.label<o[1]){a.label=o[1],o=i;break}if(o&&a.label<o[2]){a.label=o[2],a.ops.push(i);break}o[2]&&a.ops.pop(),a.trys.pop();continue}i=t.call(e,a)}catch(e){i=[6,e],r=0}finally{n=o=0}if(5&i[0])throw i[1];return{value:i[0]?i[1]:void 0,done:!0}}([i,u])}}},d=this&&this.__await||function(e){return this instanceof d?(this.v=e,this):new d(e)},l=this&&this.__asyncGenerator||function(e,t,n){if(!Symbol.asyncIterator)throw new TypeError("Symbol.asyncIterator is not defined.");var r,o=n.apply(e,t||[]),i=[];return r={},a("next"),a("throw"),a("return"),r[Symbol.asyncIterator]=function(){return this},r;function a(e){o[e]&&(r[e]=function(t){return new Promise((function(n,r){i.push([e,t,n,r])>1||u(e,t)}))})}function u(e,t){try{(n=o[e](t)).value instanceof d?Promise.resolve(n.value.v).then(s,l):c(i[0][2],n)}catch(e){c(i[0][3],e)}var n}function s(e){u("next",e)}function l(e){u("throw",e)}function c(e,t){e(t),i.shift(),i.length&&u(i[0][0],i[0][1])}},c=this&&this.__asyncValues||function(e){if(!Symbol.asyncIterator)throw new TypeError("Symbol.asyncIterator is not defined.");var t,n=e[Symbol.asyncIterator];return n?n.call(e):(e="function"==typeof __values?__values(e):e[Symbol.iterator](),t={},r("next"),r("throw"),r("return"),t[Symbol.asyncIterator]=function(){return this},t);function r(n){t[n]=e[n]&&function(t){return new Promise((function(r,o){(function(e,t,n,r){Promise.resolve(r).then((function(t){e({value:t,done:n})}),t)})(r,o,(t=e[n](t)).done,t.value)}))}}},f=this&&this.__read||function(e,t){var n="function"==typeof Symbol&&e[Symbol.iterator];if(!n)return e;var r,o,i=n.call(e),a=[];try{for(;(void 0===t||t-- >0)&&!(r=i.next()).done;)a.push(r.value)}catch(e){o={error:e}}finally{try{r&&!r.done&&(n=i.return)&&n.call(i)}finally{if(o)throw o.error}}return a},m=this&&this.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(t,"__esModule",{value:!0}),t.LogTags=t.LogLevels=t.MutationOperationType=t.SQLClient=void 0;var p=m(n(4)),v=n(5),h=a(n(0)),y=n(8),b=n(1);t.SQLClient={Postgres:"pg",MSSQL:"mssql",SQLite3:"sqlite3",Oracle:"oracledb",MySQL:"mysql"},t.MutationOperationType={CREATE:"create",UPDATE:"update"};var T=n(0);Object.defineProperty(t,"LogLevels",{enumerable:!0,get:function(){return T.LogLevels}}),Object.defineProperty(t,"LogTags",{enumerable:!0,get:function(){return T.LogTags}}),t.default=function(e){var n=e.client,o=e.version,i=void 0===o?"":o,a=e.connection,m=e.pool,T=void 0===m?{min:2,max:10}:m,M=e.getDatabaseTimestamp,w=void 0===M?v.defaultGetDatabaseTimestamp:M,g=e.parseToUnixTimestamp,A=void 0===g?v.defaultParseToUnixTimestamp:g,x=e.logLevel,S=void 0===x?h.LogLevels.ERROR:x,C=e.filterLogsByTag,I=e.transports,q=void 0===I?[]:I;v.testTimeTransformFunctions(A,w),h.setupLogger(S,q,C),h.default.info("Collab SQL Resolver Generator version 2.0.0-alpha.17");var _=y.validateSchema(h.LogLevels,h.LogTags,t.SQLClient).validate(e).error;if(_)throw h.default.error(_.details),new Error(""+_);var O=v.attachAdditionalInfo(e.info),E=p.default({client:n,version:i,connection:a,pool:r({afterCreate:function(e,t){h.default.info("--\x3e Database connected"),t(null,e)}},T),postProcessResponse:function(e,t){if(!t)return e;if(null==t?void 0:t.isCountQuery)return e;if(0===e.length)return e;var n=v.transformToApolloFormat({result:e,columns:null==t?void 0:t.entityInformation.columns,columnMap:t.entityInformation.columnMap,parseToUnixTimestamp:A,from:t.from});return h.default.log({level:h.LogLevels.DEBUG,tag:h.LogTags.RESPONSE,message:"["+t.from+"]: "+JSON.stringify(n)}),n},debug:S===h.LogLevels.DEBUG,log:{warn:function(e){h.default.warn(e)},error:function(e){h.default.error(e)},deprecate:function(e){h.default.warn(e)},debug:function(e){h.default.log({level:h.LogLevels.DEBUG,tag:h.LogTags.QUERY,message:e})}}}),D=function(e){var t=e.writeMiddleware,n=e.dbDataMap,o=e.operationType,i=e.customContext,a=void 0===i?{}:i;return u(void 0,void 0,void 0,(function(){var e,i,f,m,p,v,h;return s(this,(function(y){switch(y.label){case 0:if(e=r({},n),0===t.length)return[2,e];i=function(){return l(this,arguments,(function(){var n,r,i=this;return s(this,(function(l){switch(l.label){case 0:n=0,r=function(){return u(i,void 0,void 0,(function(){var r;return s(this,(function(i){switch(i.label){case 0:return(r=t[n])?[4,new Promise((function(t){r({data:e,ctx:a,type:o,knex:E,next:function(n,r){n&&(e=n),r&&(a=r),t()}})}))]:[2];case 1:return i.sent(),[2]}}))}))},l.label=1;case 1:return n<t.length?[4,d(r())]:[3,5];case 2:return l.sent(),n++,[4,d(void 0)];case 3:return[4,l.sent()];case 4:return l.sent(),[3,1];case 5:return[4,d(void 0)];case 6:return[2,l.sent()]}}))}))}(),y.label=1;case 1:y.trys.push([1,6,7,12]),f=c(i),y.label=2;case 2:return[4,f.next()];case 3:if((m=y.sent()).done)return[3,5];m.value,i.next(),y.label=4;case 4:return[3,2];case 5:return[3,12];case 6:return p=y.sent(),v={error:p},[3,12];case 7:return y.trys.push([7,,10,11]),m&&!m.done&&(h=f.return)?[4,h.call(f)]:[3,9];case 8:y.sent(),y.label=9;case 9:return[3,11];case 10:if(v)throw v.error;return[7];case 11:return[7];case 12:return[2,e]}}))}))},j=function(e){var r=e.from,o=e.id,i=e.operationType,a=e.entity,d=e.dbDataMap,l=e.customContext;return u(void 0,void 0,void 0,(function(){var e,u,c,m,p,v,h,y,b;return s(this,(function(s){switch(s.label){case 0:return e=a.table,u=a.selectFields,c=a.columns,m=a.columnMap,p={from:r,entityInformation:a,customContext:l},i!==t.MutationOperationType.CREATE?[3,2]:[4,E(e).queryContext(p).insert(d)];case 1:return s.sent(),[3,4];case 2:return i!==t.MutationOperationType.UPDATE?[3,4]:[4,E(e).queryContext(p).where(c.id.nameWithTable,o).update(d)];case 3:s.sent(),s.label=4;case 4:return v=n===t.SQLClient.SQLite3?"last_insert_rowid() as id":"LAST_INSERT_ID() as id",[4,E.select(E.raw(v))];case 5:return h=f.apply(void 0,[s.sent(),1]),y=h[0],b=y.id,n===t.SQLClient.SQLite3&&u.push("rowid"),[4,E(e).select(u).queryContext({from:r,columns:c,columnMap:m}).where(c.id.nameWithTable,b)];case 6:return[2,s.sent()]}}))}))},P=function(e){var r=e.from,o=e.id,i=e.entity,a=e.data,d=e.customContext,l=e.operationType;return u(void 0,void 0,void 0,(function(){var e,u,c,f,m,p,h,y,T,M,g,A,x;return s(this,(function(s){switch(s.label){case 0:e=i.table,u=i.writeMiddleware,c=void 0===u?[]:u,f=i.returnFields,m=i.columns,p=i.afterWrite,s.label=1;case 1:return s.trys.push([1,11,,12]),h=v.toDatabaseFormat({data:a,table:e,columns:m,getDatabaseTimestamp:w,knex:E}),[4,D({writeMiddleware:c,dbDataMap:h,operationType:l,customContext:d})];case 2:return y=s.sent(),y=v.removeJoinedData(y,m),T={from:r,customContext:d,entityInformation:i},M=[],n!==t.SQLClient.SQLite3&&n!==t.SQLClient.MySQL?[3,4]:[4,j({from:r,id:o,operationType:l,entity:i,dbDataMap:y,customContext:d})];case 3:return M=s.sent(),[3,8];case 4:return l!==t.MutationOperationType.CREATE?[3,6]:[4,E(e).queryContext(T).insert(y).returning(f)];case 5:return M=s.sent(),[3,8];case 6:return[4,E(e).queryContext(T).where(m.id.nameWithTable,o).update(y).returning(f)];case 7:M=s.sent(),s.label=8;case 8:return(g=M[0]||null)&&(g=v.applyMissingData(a,g,i.columns)),p?[4,p({data:g,knex:E,context:d,operation:l})]:[3,10];case 9:(A=s.sent())&&(g=A),s.label=10;case 10:return[2,g];case 11:return x=s.sent(),b.throwError(""+r,x),[3,12];case 12:return[2]}}))}))},L=function(e){var t=e.entity,n=e.id;return u(void 0,void 0,void 0,(function(){var e,r,o;return s(this,(function(i){switch(i.label){case 0:e=t.table,r=t.columns,i.label=1;case 1:return i.trys.push([1,3,,4]),[4,E(e).where(r.id.nameWithTable,n).del().returning(r.id.nameWithTable)];case 2:return[2,{id:""+i.sent()[0],successful:!0}];case 3:return o=i.sent(),h.default.error(o),[2,{id:n,successful:!1}];case 4:return[2]}}))}))},Q={Query:{user:function(e,t){return u(void 0,void 0,void 0,(function(){var n,r,o,i,a,u;return s(this,(function(s){switch(s.label){case 0:return n=O.Users,r=n.selectFields,o=void 0===r?[]:r,i=n.table,a=n.columns,u={from:"Query.user",entityInformation:O.Users,customContext:t},[4,E(i).queryContext(u).modify((function(e){v.buildJoinQuery(e,O.Users)})).select(o).where(a.id.nameWithTable,e).limit(1).then((function(e){return e}))];case 1:return[2,s.sent()[0]||null]}}))}))},userWithEmail:function(e,t){return u(void 0,void 0,void 0,(function(){var n,r,o,i,a,u;return s(this,(function(s){switch(s.label){case 0:return n=O.Users,r=n.selectFields,o=void 0===r?[]:r,i=n.table,a=n.columns,u={from:"Query.userWithEmail",entityInformation:O.Users,customContext:t},[4,E(i).queryContext(u).modify((function(e){v.buildJoinQuery(e,O.Users)})).select(o).where(a.email.nameWithTable,e).limit(1)];case 1:return[2,s.sent()[0]||null]}}))}))},annotations:function(e,t){return u(void 0,void 0,void 0,(function(){var n,r,o,i,a,u,d,l,c,f,m,p,h;return s(this,(function(s){switch(s.label){case 0:return n=e.ids,r=e.documentId,o=e.annotationIds,i=e.filters,a=void 0===i?{}:i,u=e.inReplyTo,d=e.pageNumbers,l=O.Annotations,c=l.selectFields,f=void 0===c?[]:c,m=l.table,p=l.columns,h={from:"Query.annotations",entityInformation:O.Annotations,customContext:t},[4,E(m).queryContext(h).modify((function(e){v.buildJoinQuery(e,O.Annotations)})).select(f).where((function(e){n&&e.whereIn(p.id.nameWithTable,n),o&&e.whereIn(p.annotationId.nameWithTable,o),r&&e.where(p.documentId.nameWithTable,r),u&&e.where(p.inReplyTo.nameWithTable,u),d&&e.whereIn(p.pageNumber.nameWithTable,d),v.buildFilterQuery(e,a,p,w)})).modify((function(e){v.buildModifyQuery(e,a,p)}))];case 1:return[2,s.sent()]}}))}))},documents:function(e,t){return u(void 0,void 0,void 0,(function(){var n,r,o,i,a,u,d,l,c,f;return s(this,(function(s){switch(s.label){case 0:return n=e.ids,r=e.userId,o=e.filters,i=void 0===o?{}:o,a=O.Documents,u=a.selectFields,d=void 0===u?[]:u,l=a.table,c=a.columns,f={from:"Query.documents",entityInformation:O.Documents,customContext:t},[4,E(l).queryContext(f).modify((function(e){v.buildJoinQuery(e,O.Documents)})).select(d).where((function(e){n&&e.whereIn(c.id.nameWithTable,n),r&&e.whereIn(c.id.nameWithTable,(function(){this.select(O.DocumentMembers.columns.documentId.nameWithTable).from(O.DocumentMembers.table).where(O.DocumentMembers.columns.userId.nameWithTable,r)})),v.buildFilterQuery(e,i,c,w)})).modify((function(e){v.buildModifyQuery(e,i,c)}))];case 1:return[2,s.sent()]}}))}))},annotationMembers:function(e,t){return u(void 0,void 0,void 0,(function(){var n,r,o,i,a,u,d,l,c,f,m;return s(this,(function(s){switch(s.label){case 0:return n=e.annotationId,r=e.ids,o=e.userId,i=e.filters,a=void 0===i?{}:i,u=O.AnnotationMembers,d=u.selectFields,l=void 0===d?[]:d,c=u.table,f=u.columns,m={from:"Query.annotationMembers",entityInformation:O.AnnotationMembers,customContext:t},[4,E(c).queryContext(m).modify((function(e){v.buildJoinQuery(e,O.AnnotationMembers)})).select(l).where((function(e){r&&e.whereIn(f.id.nameWithTable,r),n&&e.where(f.annotationId.nameWithTable,n),o&&e.where(f.userId.nameWithTable,o),v.buildFilterQuery(e,a,f,w)})).modify((function(e){v.buildModifyQuery(e,a,f)}))];case 1:return[2,s.sent()]}}))}))},documentMembers:function(e,t){return u(void 0,void 0,void 0,(function(){var n,r,o,i,a,u,d,l,c,f,m;return s(this,(function(s){switch(s.label){case 0:return n=e.documentId,r=e.ids,o=e.userId,i=e.filters,a=void 0===i?{}:i,u=O.DocumentMembers,d=u.selectFields,l=void 0===d?[]:d,c=u.table,f=u.columns,m={from:"Query.documentMembers",entityInformation:O.DocumentMembers,customContext:t},[4,E(c).queryContext(m).modify((function(e){v.buildJoinQuery(e,O.DocumentMembers)})).select(l).where((function(e){r&&e.whereIn(f.id.nameWithTable,r),n&&e.where(f.documentId.nameWithTable,n),o&&e.where(f.userId.nameWithTable,o),v.buildFilterQuery(e,a,f,w)})).modify((function(e){v.buildModifyQuery(e,a,f)}))];case 1:return[2,s.sent()]}}))}))},mentions:function(e,t){return u(void 0,void 0,void 0,(function(){var n,r,o,i,a,u,d,l,c,f,m,p;return s(this,(function(s){switch(s.label){case 0:return n=e.annotationId,r=e.userId,o=e.documentId,i=e.ids,a=e.filters,u=void 0===a?{}:a,d=O.Mentions,l=d.selectFields,c=void 0===l?[]:l,f=d.table,m=d.columns,p={from:"Query.mentions",entityInformation:O.Mentions,customContext:t},[4,E(f).queryContext(p).modify((function(e){v.buildJoinQuery(e,O.Mentions)})).select(c).where((function(e){i&&e.whereIn(m.id.nameWithTable,i),o&&e.where(m.documentId.nameWithTable,o),n&&e.where(m.annotationId.nameWithTable,n),r&&e.where(m.userId.nameWithTable,r),v.buildFilterQuery(e,u,m,w)})).modify((function(e){v.buildModifyQuery(e,u,m)}))];case 1:return[2,s.sent()]}}))}))},annotationCount:function(e,t){return u(void 0,void 0,void 0,(function(){var n,r,o,i,a,u,d;return s(this,(function(s){switch(s.label){case 0:return n=e.since,r=e.documentId,o=O.Annotations,i=o.table,a=o.columns,u={from:"Query.annotationCount",entityInformation:O.Annotations,customContext:t,isCountQuery:!0},[4,E(i).queryContext(u).modify((function(e){v.buildJoinQuery(e,O.Annotations)})).count({count:[a.id.nameWithTable]}).where(a.documentId.nameWithTable,r).where(a.createdAt.nameWithTable,">",w(n)).whereNotNull(a.authorId.nameWithTable)];case 1:return d=s.sent(),[2,Number(d[0].count||0)]}}))}))},annotationMemberCount:function(e,t){return u(void 0,void 0,void 0,(function(){var n,r,o,i,a,u,d,l;return s(this,(function(s){switch(s.label){case 0:return n=e.userId,r=e.documentId,o=e.since,i=O.AnnotationMembers,a=i.table,u=i.columns,d={from:"Query.annotationMemberCount",entityInformation:O.AnnotationMembers,customContext:t,isCountQuery:!0},[4,E(a).queryContext(d).modify((function(e){v.buildJoinQuery(e,O.AnnotationMembers)})).count({count:[u.id.nameWithTable]}).where(u.documentId.nameWithTable,r).where(u.userId.nameWithTable,n).where(u.createdAt.nameWithTable,">",w(o))];case 1:return l=s.sent(),[2,Number(l[0].count||0)]}}))}))}},Mutation:{addUser:function(e,n){return u(void 0,void 0,void 0,(function(){return s(this,(function(r){return[2,P({from:"Mutation.addUser",entity:O.Users,data:e,customContext:n,operationType:t.MutationOperationType.CREATE})]}))}))},addAnnotation:function(e,n){return u(void 0,void 0,void 0,(function(){return s(this,(function(r){return[2,P({from:"Mutation.addAnnotation",entity:O.Annotations,data:e,customContext:n,operationType:t.MutationOperationType.CREATE})]}))}))},editAnnotation:function(e,n,r){return u(void 0,void 0,void 0,(function(){var o,i,a,u;return s(this,(function(s){return o=n.xfdf,i=n.pageNumber,a=n.updatedAt,u=n.annotContents,[2,P({from:"Mutation.editAnnotation",customContext:r,entity:O.Annotations,id:e,data:{xfdf:o,pageNumber:i,updatedAt:a,annotContents:u},operationType:t.MutationOperationType.UPDATE})]}))}))},deleteAnnotation:function(e,t){return u(void 0,void 0,void 0,(function(){return s(this,(function(n){switch(n.label){case 0:return[4,L({from:"Mutation.deleteAnnotation",entity:O.Annotations,id:e,customContext:t})];case 1:return[2,n.sent()]}}))}))},addDocument:function(e,n){return u(void 0,void 0,void 0,(function(){return s(this,(function(r){return[2,P({from:"Mutation.addDocument",entity:O.Documents,data:e,customContext:n,operationType:t.MutationOperationType.CREATE})]}))}))},editDocument:function(e,n,r){return u(void 0,void 0,void 0,(function(){var o,i,a;return s(this,(function(u){return o=n.name,i=n.isPublic,a=n.updatedAt,[2,P({from:"Mutation.editDocument",entity:O.Documents,id:e,data:{name:o,isPublic:i,updatedAt:a},customContext:r,operationType:t.MutationOperationType.UPDATE})]}))}))},deleteDocument:function(e,t){return u(void 0,void 0,void 0,(function(){return s(this,(function(n){return[2,L({from:"Mutation.deleteDocument",entity:O.Documents,id:e,customContext:t})]}))}))},addDocumentMember:function(e,n){return u(void 0,void 0,void 0,(function(){return s(this,(function(r){return[2,P({from:"Mutation.addDocumentMember",entity:O.DocumentMembers,data:e,customContext:n,operationType:t.MutationOperationType.CREATE})]}))}))},editDocumentMember:function(e,n,r){return u(void 0,void 0,void 0,(function(){var o,i;return s(this,(function(a){return o=n.lastRead,i=n.updatedAt,[2,P({from:"Mutation.editDocumentMember",entity:O.DocumentMembers,id:e,data:{lastRead:o,updatedAt:i},customContext:r,operationType:t.MutationOperationType.UPDATE})]}))}))},deleteDocumentMember:function(e,t){return u(void 0,void 0,void 0,(function(){return s(this,(function(n){return[2,L({from:"Mutation.deleteDocumentMember",entity:O.DocumentMembers,id:e,customContext:t})]}))}))},addAnnotationMember:function(e,n){return u(void 0,void 0,void 0,(function(){return s(this,(function(r){return[2,P({from:"Mutation.addAnnotationMember",entity:O.AnnotationMembers,data:e,customContext:n,operationType:t.MutationOperationType.CREATE})]}))}))},editAnnotationMember:function(e,n,r){return u(void 0,void 0,void 0,(function(){var o,i;return s(this,(function(a){return o=n.lastRead,i=n.updatedAt,[2,P({from:"Mutation.editAnnotationMember",entity:O.AnnotationMembers,id:e,data:{lastRead:o,updatedAt:i},customContext:r,operationType:t.MutationOperationType.UPDATE})]}))}))},deleteAnnotationMember:function(e,t){return u(void 0,void 0,void 0,(function(){return s(this,(function(n){return[2,L({from:"Mutation.deleteAnnotationMember",entity:O.AnnotationMembers,id:e,customContext:t})]}))}))},addMention:function(e,n){return u(void 0,void 0,void 0,(function(){return s(this,(function(r){return[2,P({from:"Mutation.addMention",entity:O.Mentions,data:e,customContext:n,operationType:t.MutationOperationType.CREATE})]}))}))},deleteMention:function(e,t){return u(void 0,void 0,void 0,(function(){return s(this,(function(n){return[2,L({from:"Mutation.deleteMention",entity:O.Mentions,id:e,customContext:t})]}))}))}}};return O.Snapshots&&(Q.Query.snapshots=function(e,t){return u(void 0,void 0,void 0,(function(){var n,r,o,i,a,u,d,l,c,f;return s(this,(function(s){switch(s.label){case 0:return n=e.ids,r=e.documentId,o=e.filters,i=void 0===o?{}:o,a=O.Snapshots,u=a.selectFields,d=void 0===u?[]:u,l=a.table,c=a.columns,f={from:"Query.Snapshots",entityInformation:O.Snapshots,customContext:t},[4,E(l).queryContext(f).select(d).where((function(e){n&&e.whereIn(c.id.nameWithTable,n),r&&e.where(c.documentId.nameWithTable,r),v.buildFilterQuery(e,i,c,w)})).modify((function(e){v.buildModifyQuery(e,i,c)}))];case 1:return[2,s.sent()]}}))}))},Q.Mutation.addSnapshot=function(e,n){return u(void 0,void 0,void 0,(function(){return s(this,(function(r){return[2,P({from:"Mutation.addSnapshot",entity:O.Snapshots,data:e,customContext:n,operationType:t.MutationOperationType.CREATE})]}))}))},Q.Mutation.editSnapshot=function(e,n,r){return u(void 0,void 0,void 0,(function(){var o,i;return s(this,(function(a){return o=n.name,i=n.updatedAt,[2,P({from:"Mutation.editSnapshot",customContext:r,entity:O.Snapshots,id:e,data:{name:o,updatedAt:i},operationType:t.MutationOperationType.UPDATE})]}))}))},Q.Mutation.deleteSnapshot=function(e,t){return u(void 0,void 0,void 0,(function(){return s(this,(function(n){switch(n.label){case 0:return[4,L({from:"Mutation.deleteSnapshot",entity:O.Snapshots,id:e,customContext:t})];case 1:return[2,n.sent()]}}))}))}),O.SnapshotAssets&&(Q.Query.snapshotAssets=function(e,t){return u(void 0,void 0,void 0,(function(){var n,r,o,i,a,u,d,l;return s(this,(function(s){switch(s.label){case 0:return n=e.ids,r=e.snapshotId,o=O.SnapshotAssets,i=o.selectFields,a=void 0===i?[]:i,u=o.table,d=o.columns,l={from:"Query.SnapshotAssets",entityInformation:O.SnapshotAssets,customContext:t},[4,E(u).queryContext(l).select(a).where((function(e){n&&e.whereIn(d.id.nameWithTable,n),r&&e.where(d.snapshotId.nameWithTable,r)}))];case 1:return[2,s.sent()]}}))}))},Q.Mutation.addSnapshotAsset=function(e,n){return u(void 0,void 0,void 0,(function(){return s(this,(function(r){return[2,P({from:"Mutation.addSnapshotAsset",entity:O.SnapshotAssets,data:e,customContext:n,operationType:t.MutationOperationType.CREATE})]}))}))},Q.Mutation.editSnapshotAsset=function(e,n,r){return u(void 0,void 0,void 0,(function(){var o,i;return s(this,(function(a){return o=n.snapshotId,i=n.updatedAt,[2,P({from:"Mutation.editSnapshotAsset",customContext:r,entity:O.SnapshotAssets,id:e,data:{snapshotId:o,updatedAt:i},operationType:t.MutationOperationType.UPDATE})]}))}))},Q.Mutation.deleteSnapshotAsset=function(e,t){return u(void 0,void 0,void 0,(function(){return s(this,(function(n){switch(n.label){case 0:return[4,L({from:"Mutation.deleteSnapshotAsset",entity:O.SnapshotAssets,id:e,customContext:t})];case 1:return[2,n.sent()]}}))}))}),Q}},function(e,t){e.exports=require("knex")},function(e,t,n){"use strict";var r=this&&this.__assign||function(){return(r=Object.assign||function(e){for(var t,n=1,r=arguments.length;n<r;n++)for(var o in t=arguments[n])Object.prototype.hasOwnProperty.call(t,o)&&(e[o]=t[o]);return e}).apply(this,arguments)},o=this&&this.__read||function(e,t){var n="function"==typeof Symbol&&e[Symbol.iterator];if(!n)return e;var r,o,i=n.call(e),a=[];try{for(;(void 0===t||t-- >0)&&!(r=i.next()).done;)a.push(r.value)}catch(e){o={error:e}}finally{try{r&&!r.done&&(n=i.return)&&n.call(i)}finally{if(o)throw o.error}}return a},i=this&&this.__spreadArray||function(e,t){for(var n=0,r=t.length,o=e.length;n<r;n++,o++)e[o]=t[n];return e},a=this&&this.__values||function(e){var t="function"==typeof Symbol&&Symbol.iterator,n=t&&e[t],r=0;if(n)return n.call(e);if(e&&"number"==typeof e.length)return{next:function(){return e&&r>=e.length&&(e=void 0),{value:e&&e[r++],done:!e}}};throw new TypeError(t?"Object is not iterable.":"Symbol.iterator is not defined.")};Object.defineProperty(t,"__esModule",{value:!0}),t.attachAdditionalInfo=t.transformToApolloFormat=t.keysToCamel=t.toUnixTimestamp=t.testTimeTransformFunctions=t.defaultGetDatabaseTimestamp=t.defaultParseToUnixTimestamp=t.toDatabaseFormat=t.removeJoinedData=t.applyMissingData=t.buildModifyQuery=t.buildJoinQuery=t.buildFilterQuery=void 0;var u=n(6),s=n(1);t.buildFilterQuery=function(e,t,n,r){t.createdBefore&&e.where(n.createdAt.nameWithTable,"<",r(t.createdBefore)),t.createdAfter&&e.where(n.createdAt.nameWithTable,">",r(t.createdAfter)),t.updatedBefore&&e.where(n.updatedAt.nameWithTable,"<",r(t.updatedBefore)),t.updatedAfter&&e.where(n.updatedAt.nameWithTable,">",r(t.updatedAfter))};t.buildJoinQuery=function(e,t){var n=t.columns,r=Object.keys(n).reduce((function(e,t){var r=n[t];if("string"==typeof r)return e;if(!r.join)return e;var i=o(r.join,1)[0];return e[i]||(e[i]=[]),e[i].push(r.join),e}),{}),a=Object.keys(r);a.length>0&&e.distinct(),a.forEach((function(t){var n=r[t];if(1===n.length){var a=o(n,1)[0],u=o(a,2),s=u[0],d=u[1];"string"==typeof d?e.join.apply(e,i([],o(a))):e.join(s,(function(){d(this)}))}else e.join(t,(function(){this.on((function(){var e=this;n.forEach((function(t,n){var r=0===n?e.on:e.orOn,a=o(t,2)[1];"string"==typeof a?r.call.apply(r,i([e],o(t.slice(1)))):r((function(){a(this)}))}))}))}))}))};t.buildModifyQuery=function(e,t,n){var r=t.limit,o=t.orderBy,i=t.orderDirection,a=void 0===i?"DESC":i;o&&e.orderBy(n[o].nameWithTable,a),r&&e.limit(r)};t.applyMissingData=function(e,t,n){var r,o,i={},u=Object.keys(n);try{for(var s=a(u),d=s.next();!d.done;d=s.next()){var l=d.value;i[l]=t[l],void 0===i[l]&&void 0!==e[l]&&(i[l]=e[l])}}catch(e){r={error:e}}finally{try{d&&!d.done&&(o=s.return)&&o.call(s)}finally{if(r)throw r.error}}return i};t.removeJoinedData=function(e,t){var n,o,i=r({},e),u=Object.keys(t);try{for(var s=a(u),d=s.next();!d.done;d=s.next()){var l=d.value,c=t[l];c.skipWrite&&(delete i[l],delete i[c.name],delete i[c.nameWithTable])}}catch(e){n={error:e}}finally{try{d&&!d.done&&(o=s.return)&&o.call(s)}finally{if(n)throw n.error}}return i};t.toDatabaseFormat=function(e){var t=e.data,n=e.columns,r=e.getDatabaseTimestamp,o=e.knex,i={};for(var a in t)n[a]&&(u.TimestampProperties.includes(a)?u.NowTimestampProperties.includes(a)?i[n[a].name]=o.raw(t[a]):i[n[a].name]=r(t[a]):i[n[a].name]=t[a]);return i};t.defaultParseToUnixTimestamp=function(e){return new Date(e).getTime()};t.defaultGetDatabaseTimestamp=function(e){return new Date(e).toISOString()};t.testTimeTransformFunctions=function(e,t){var n=Date.now();if(e(t(n))!==n)throw new Error('Configuration error: "getDatabaseTimestamp" and "parseToUnixTimestamp" functions are not compatible. The result of "parseUnixFunc" must be equal to the input of "getDatabaseTimestampFunc". For example, the following must be true: parseUnixFunc(getDatabaseTimestamp('+n+")) === "+n)};t.toUnixTimestamp=function(e,t){return Object.keys(e).forEach((function(n){u.TimestampProperties.includes(n)&&(e[n]=t(e[n]))})),e};t.keysToCamel=function(e,t,n){var r={};return Object.keys(n).forEach((function(o){var i;if(n[o]){var a=n[o],s=e[o],d=void 0;d="string"!=typeof t[a]&&!!(null===(i=t[a])||void 0===i?void 0:i.transform)&&void 0!==s?t[a].transform(s):e[o],u.StringIdProperties.includes(a)&&"number"==typeof d&&(d=""+d),void 0===r[a]&&void 0!==d&&(r[a]=d)}})),r};t.transformToApolloFormat=function(e){var n=e.result,r=e.columns,o=e.columnMap,i=e.parseToUnixTimestamp,a=[];return n.forEach((function(e){var n=t.keysToCamel(e,r,o),u=t.toUnixTimestamp(n,i);a.push(u)})),a};t.attachAdditionalInfo=function(e){var t=function(e){return r(r({},e),{columnMap:{},selectFields:[],returnFields:[]})},n=r({Users:t(e.Users),Annotations:t(e.Annotations),Documents:t(e.Documents),AnnotationMembers:t(e.AnnotationMembers),DocumentMembers:t(e.DocumentMembers),Mentions:t(e.Mentions)},e.SnapshotAssets&&e.Snapshots&&{Snapshots:t(e.Snapshots),SnapshotAssets:t(e.SnapshotAssets)});for(var a in n){var u=n[a],d=u.table,l=u.columns;for(var c in l){var f=l[c];"string"==typeof f&&(f=l[c]={name:f,nameWithTable:""});var m=f.join,p=f.name;if(m||p||s.throwError("SQL Resolver Generator","Expected column object to have either 'name' or 'join' property"),m){var v=o(m),h=v[0],y=v.slice(1),b=o(h.split("."),2),T=b[0],M=b[1];T&&M||s.throwError("SQL Resolver Generator","First item in join query must be formatted as {TableName}.{ColumnName} - received "+h),f.skipWrite=!0,f.nameWithTable=T+"."+M,f.name=M,f.join=i([T],o(y)),u.selectFields.push(T+"."+M),u.columnMap[f.nameWithTable]=f.name,u.columnMap[M]=f.name}else f.nameWithTable=d+"."+f.name,u.selectFields.push(d+"."+f.name),u.returnFields.push(d+"."+f.name);u.columnMap[f.name]=c,u.columnMap[d+"."+f.name]=c}}return n}},function(e,t,n){"use strict";Object.defineProperty(t,"__esModule",{value:!0}),t.StringIdProperties=t.NowTimestampProperties=t.TimestampProperties=void 0,t.TimestampProperties=["createdAt","updatedAt","lastRead","annotationCreatedAt"],t.NowTimestampProperties=["createdAt","updatedAt","lastRead"],t.StringIdProperties=["id","userId","snapshotId","authorId","documentId","annotationId"]},function(e,t,n){"use strict";var r=this&&this.__createBinding||(Object.create?function(e,t,n,r){void 0===r&&(r=n),Object.defineProperty(e,r,{enumerable:!0,get:function(){return t[n]}})}:function(e,t,n,r){void 0===r&&(r=n),e[r]=t[n]}),o=this&&this.__setModuleDefault||(Object.create?function(e,t){Object.defineProperty(e,"default",{enumerable:!0,value:t})}:function(e,t){e.default=t}),i=this&&this.__importStar||function(e){if(e&&e.__esModule)return e;var t={};if(null!=e)for(var n in e)"default"!==n&&Object.prototype.hasOwnProperty.call(e,n)&&r(t,e,n);return o(t,e),t};Object.defineProperty(t,"__esModule",{value:!0}),t.addTransports=t.addConsoleTransport=void 0;var a=i(n(2)),u=n(0);t.addConsoleTransport=function(e,t,n){void 0===t&&(t=u.LogLevels.INFO),e.add(new a.default.transports.Console({level:t,format:a.format.combine(a.format((function(e){return(!n||e.tag===n)&&e}))(),a.format.colorize(),a.format.printf((function(e){var t=s(e.message),n=e.tag?" ["+e.tag+"]":"",r=s(e.meta);return e.timestamp+" "+e.level+n+": "+t+" "+r})),a.format.metadata({fillExcept:["message","level","timestamp","label"]}))}))};t.addTransports=function(e,t){t.forEach((function(t){return e.add(t)}))};var s=function(e){var t=e||"";return"object"==typeof e&&null!==e&&(t=JSON.stringify(e,null,2)),t}},function(e,t,n){"use strict";var r=this&&this.__read||function(e,t){var n="function"==typeof Symbol&&e[Symbol.iterator];if(!n)return e;var r,o,i=n.call(e),a=[];try{for(;(void 0===t||t-- >0)&&!(r=i.next()).done;)a.push(r.value)}catch(e){o={error:e}}finally{try{r&&!r.done&&(n=i.return)&&n.call(i)}finally{if(o)throw o.error}}return a},o=this&&this.__spreadArray||function(e,t){for(var n=0,r=t.length,o=e.length;n<r;n++,o++)e[o]=t[n];return e},i=this&&this.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(t,"__esModule",{value:!0}),t.validateSchema=void 0;var a=i(n(9)),u=a.default.alternatives().try(a.default.object({name:a.default.string(),transform:a.default.function(),join:a.default.array(),resolve:a.default.func()}),a.default.string());t.validateSchema=function(e,t,n){var i,s,d;return a.default.object({client:(i=a.default.string()).valid.apply(i,o([],r(Object.values(n)))).required(),connection:a.default.object().required(),pool:{min:a.default.number(),max:a.default.number()},getDatabaseTimestamp:a.default.func(),parseToUnixTimestamp:a.default.func(),getNow:a.default.func(),logLevel:(s=a.default.string()).valid.apply(s,o([],r(Object.values(e)))),filterLogsByTag:(d=a.default.string()).valid.apply(d,o([],r(Object.values(t)))),transports:a.default.array(),info:a.default.object({Users:a.default.object({table:a.default.string().required(),writeMiddleware:a.default.array().items(a.default.function()),afterWrite:a.default.function(),columns:a.default.object({id:u.required(),type:u.required(),email:u.required(),userName:u,createdAt:u.required(),updatedAt:u.required()}).required()}).required(),Annotations:a.default.object({table:a.default.string().required(),writeMiddleware:a.default.array().items(a.default.function()),afterWrite:a.default.function(),columns:a.default.object({id:u.required(),xfdf:u.required(),authorId:u.required(),annotationId:u.required(),documentId:u.required(),pageNumber:u.required(),createdAt:u.required(),updatedAt:u.required(),inReplyTo:u.required(),annotContents:u}).required()}).required(),Documents:a.default.object({table:a.default.string().required(),writeMiddleware:a.default.array().items(a.default.function()),afterWrite:a.default.function(),columns:a.default.object({id:u.required(),authorId:u.required(),createdAt:u.required(),updatedAt:u.required(),isPublic:u.required(),name:u}).required()}).required(),AnnotationMembers:a.default.object({table:a.default.string().required(),writeMiddleware:a.default.array().items(a.default.function()),afterWrite:a.default.function(),columns:a.default.object({id:u.required(),userId:u.required(),documentId:u.required(),annotationId:u.required(),lastRead:u.required(),createdAt:u.required(),updatedAt:u.required(),annotationCreatedAt:u.required()}).required()}),DocumentMembers:a.default.object({table:a.default.string().required(),writeMiddleware:a.default.array().items(a.default.function()),afterWrite:a.default.function(),columns:a.default.object({id:u.required(),userId:u.required(),documentId:u.required(),lastRead:u.required(),createdAt:u.required(),updatedAt:u.required()}).required()}).required(),Mentions:a.default.object({table:a.default.string().required(),writeMiddleware:a.default.array().items(a.default.function()),afterWrite:a.default.function(),columns:a.default.object({id:u.required(),userId:u.required(),documentId:u.required(),annotationId:u.required(),createdAt:u.required(),updatedAt:u.required()}).required()}).required(),Snapshots:a.default.object({table:a.default.string().required(),writeMiddleware:a.default.array().items(a.default.function()),afterWrite:a.default.function(),columns:a.default.object({id:u.required(),authorId:u.required(),documentId:u.required(),xfdf:u.required(),name:u.required(),createdAt:u.required(),updatedAt:u.required()}).required()}),SnapshotAssets:a.default.object({table:a.default.string().required(),writeMiddleware:a.default.array().items(a.default.function()),afterWrite:a.default.function(),columns:a.default.object({id:u.required(),snapshotId:u.required(),data:u.required(),createdAt:u.required(),updatedAt:u.required()}).required()})}).required()})}},function(e,t){e.exports=require("joi")}]).default}));

package.json

@@ -6,7 +6,9 @@ {
   "types": "types/packages/collab-sql-resolver-generator/src/index.d.ts",
-  "version": "2.0.0-alpha.15",
+  "version": "2.0.0-alpha.17",
   "typedocMain": "src/index.ts",
   "scripts": {
     "test-dev": "jest --watch",
-    "test": "jest",
+    "test:sql": "ENV=sql jest",
+    "test:postgresql": "ENV=postgresql jest",
+    "test:hatch": "ENV=hatch jest",
     "api": "typedoc --out docs"
@@ -37,3 +39,3 @@ },
   },
-  "gitHead": "9b8b2196beb14f2bac04260b4451dc0f2d5fc93a"
+  "gitHead": "d19e861ff8b75e0aef4aad4e8470bb41c9e1b9d4"
 }

types/global.config.d.ts

 export declare const TimestampProperties: string[];
 export declare const NowTimestampProperties: string[];
+export declare const StringIdProperties: string[];

types/packages/collab-server/src/entities/Document.d.ts

@@ -30,5 +30,5 @@ import { PubSub } from 'graphql-subscriptions';
         id: string;
+        documentId: string;
         createdAt: any;
         updatedAt: any;
-        documentId: string;
         lastRead: any;
@@ -35,0 +35,0 @@ } & {

types/packages/collab-server/src/types/CustomContext.d.ts

@@ -1,1 +0,3 @@
-export declare type CustomContext = Record<string, any>;
+export declare type CustomContext = Record<string, any> & {
+    userId?: string;
+};

types/packages/collab-server/src/util/ConnectedUserMap.d.ts

@@ -63,3 +63,3 @@ declare type ScrollPosition = {
      */
-    disconnectUser(userId: string): void;
+    disconnectUser(userId: string): any;
     /**
@@ -66,0 +66,0 @@ * Used to be .keys()

types/packages/collab-server/src/util/resolverContext.d.ts

@@ -17,3 +17,3 @@ import { Actions, PermissionSetting } from '..';
     dangerousTransaction<T_1>(cb: () => T_1 | Promise<T_1>): Promise<T_1>;
-    callQueryResolver<T_2 extends "documents" | "mentions" | "annotations" | "user" | "userWithEmail" | "annotationMembers" | "documentMembers" | "annotationCount" | "annotationMemberCount" | "snapshots" | "snapshotAssets">(name: T_2, { nullable, from }: CallQueryResolverParams): (...params: Parameters<{
+    callQueryResolver<T_2 extends "mentions" | "user" | "annotations" | "documents" | "userWithEmail" | "annotationMembers" | "documentMembers" | "annotationCount" | "annotationMemberCount" | "snapshots" | "snapshotAssets">(name: T_2, { nullable, from }: CallQueryResolverParams): (...params: Parameters<{
         user: (id: string, context: CustomContext) => (import("../types/DatabaseTypes").DatabaseUser & {
@@ -31,10 +31,10 @@ id: string;
             id: string;
-            createdAt: any;
-            updatedAt: any;
             xfdf: string;
+            annotContents?: string;
             annotationId: string;
             documentId: string;
             pageNumber: number;
+            createdAt: any;
+            updatedAt: any;
             inReplyTo?: string;
-            annotContents?: string;
         } & {
@@ -46,10 +46,10 @@ authorId: string;
             id: string;
-            createdAt: any;
-            updatedAt: any;
             xfdf: string;
+            annotContents?: string;
             annotationId: string;
             documentId: string;
             pageNumber: number;
+            createdAt: any;
+            updatedAt: any;
             inReplyTo?: string;
-            annotContents?: string;
         } & {
@@ -61,3 +61,2 @@ authorId: string;
         documents: (query: import("../types/Params").DocumentsQuery, context: CustomContext) => ({
-            name?: string;
             id: string;
@@ -67,2 +66,3 @@ createdAt: any;
             isPublic?: boolean;
+            name?: string;
         } & {
@@ -73,3 +73,2 @@ authorId: string;
         })[] | Promise<({
-            name?: string;
             id: string;
@@ -79,2 +78,3 @@ createdAt: any;
             isPublic?: boolean;
+            name?: string;
         } & {
@@ -87,6 +87,6 @@ authorId: string;
             id: string;
+            annotationId: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            annotationId: string;
-            documentId: string;
             lastRead: any;
@@ -101,6 +101,6 @@ annotationCreatedAt: any;
             id: string;
+            annotationId: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            annotationId: string;
-            documentId: string;
             lastRead: any;
@@ -116,5 +116,5 @@ annotationCreatedAt: any;
             id: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            documentId: string;
             lastRead: any;
@@ -127,5 +127,5 @@ } & {
             id: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            documentId: string;
             lastRead: any;
@@ -141,6 +141,6 @@ } & {
             id: string;
+            annotationId: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            annotationId: string;
-            documentId: string;
         } & {
@@ -152,6 +152,6 @@ userId: string;
             id: string;
+            annotationId: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            annotationId: string;
-            documentId: string;
         } & {
@@ -163,8 +163,8 @@ userId: string;
         snapshots?: (query: import("../types/Params").SnapshotsQuery, context: CustomContext) => ({
-            name?: string;
             id: string;
+            xfdf: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            xfdf: string;
-            documentId: string;
+            name?: string;
         } & {
@@ -175,8 +175,8 @@ authorId: string;
         })[] | Promise<({
-            name?: string;
             id: string;
+            xfdf: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            xfdf: string;
-            documentId: string;
+            name?: string;
         } & {
@@ -205,10 +205,10 @@ authorId: string;
             id: string;
-            createdAt: any;
-            updatedAt: any;
             xfdf: string;
+            annotContents?: string;
             annotationId: string;
             documentId: string;
             pageNumber: number;
+            createdAt: any;
+            updatedAt: any;
             inReplyTo?: string;
-            annotContents?: string;
         } & {
@@ -220,10 +220,10 @@ authorId: string;
             id: string;
-            createdAt: any;
-            updatedAt: any;
             xfdf: string;
+            annotContents?: string;
             annotationId: string;
             documentId: string;
             pageNumber: number;
+            createdAt: any;
+            updatedAt: any;
             inReplyTo?: string;
-            annotContents?: string;
         } & {
@@ -235,3 +235,2 @@ authorId: string;
         documents: (query: import("../types/Params").DocumentsQuery, context: CustomContext) => ({
-            name?: string;
             id: string;
@@ -241,2 +240,3 @@ createdAt: any;
             isPublic?: boolean;
+            name?: string;
         } & {
@@ -247,3 +247,2 @@ authorId: string;
         })[] | Promise<({
-            name?: string;
             id: string;
@@ -253,2 +252,3 @@ createdAt: any;
             isPublic?: boolean;
+            name?: string;
         } & {
@@ -261,6 +261,6 @@ authorId: string;
             id: string;
+            annotationId: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            annotationId: string;
-            documentId: string;
             lastRead: any;
@@ -275,6 +275,6 @@ annotationCreatedAt: any;
             id: string;
+            annotationId: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            annotationId: string;
-            documentId: string;
             lastRead: any;
@@ -290,5 +290,5 @@ annotationCreatedAt: any;
             id: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            documentId: string;
             lastRead: any;
@@ -301,5 +301,5 @@ } & {
             id: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            documentId: string;
             lastRead: any;
@@ -315,6 +315,6 @@ } & {
             id: string;
+            annotationId: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            annotationId: string;
-            documentId: string;
         } & {
@@ -326,6 +326,6 @@ userId: string;
             id: string;
+            annotationId: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            annotationId: string;
-            documentId: string;
         } & {
@@ -337,8 +337,8 @@ userId: string;
         snapshots?: (query: import("../types/Params").SnapshotsQuery, context: CustomContext) => ({
-            name?: string;
             id: string;
+            xfdf: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            xfdf: string;
-            documentId: string;
+            name?: string;
         } & {
@@ -349,8 +349,8 @@ authorId: string;
         })[] | Promise<({
-            name?: string;
             id: string;
+            xfdf: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            xfdf: string;
-            documentId: string;
+            name?: string;
         } & {
@@ -375,10 +375,10 @@ authorId: string;
             id: string;
-            createdAt: any;
-            updatedAt: any;
             xfdf: string;
+            annotContents?: string;
             annotationId: string;
             documentId: string;
             pageNumber: number;
+            createdAt: any;
+            updatedAt: any;
             inReplyTo?: string;
-            annotContents?: string;
         } & {
@@ -390,10 +390,10 @@ authorId: string;
             id: string;
-            createdAt: any;
-            updatedAt: any;
             xfdf: string;
+            annotContents?: string;
             annotationId: string;
             documentId: string;
             pageNumber: number;
+            createdAt: any;
+            updatedAt: any;
             inReplyTo?: string;
-            annotContents?: string;
         } & {
@@ -406,10 +406,10 @@ authorId: string;
             id: string;
-            createdAt: any;
-            updatedAt: any;
             xfdf: string;
+            annotContents?: string;
             annotationId: string;
             documentId: string;
             pageNumber: number;
+            createdAt: any;
+            updatedAt: any;
             inReplyTo?: string;
-            annotContents?: string;
         } & {
@@ -421,10 +421,10 @@ authorId: string;
             id: string;
-            createdAt: any;
-            updatedAt: any;
             xfdf: string;
+            annotContents?: string;
             annotationId: string;
             documentId: string;
             pageNumber: number;
+            createdAt: any;
+            updatedAt: any;
             inReplyTo?: string;
-            annotContents?: string;
         } & {
@@ -437,3 +437,2 @@ authorId: string;
         addDocument: (document: import("../../../../types/resolvers-types").NewDocumentInput, context: CustomContext) => ({
-            name?: string;
             id: string;
@@ -443,2 +442,3 @@ createdAt: any;
             isPublic?: boolean;
+            name?: string;
         } & {
@@ -449,3 +449,2 @@ authorId: string;
         }) | Promise<{
-            name?: string;
             id: string;
@@ -455,2 +454,3 @@ createdAt: any;
             isPublic?: boolean;
+            name?: string;
         } & {
@@ -462,3 +462,2 @@ authorId: string;
         editDocument: (id: string, input: import("../../../../types/global-graphql-types").EditDocumentInput, context: CustomContext) => ({
-            name?: string;
             id: string;
@@ -468,2 +467,3 @@ createdAt: any;
             isPublic?: boolean;
+            name?: string;
         } & {
@@ -474,3 +474,2 @@ authorId: string;
         }) | Promise<{
-            name?: string;
             id: string;
@@ -480,2 +479,3 @@ createdAt: any;
             isPublic?: boolean;
+            name?: string;
         } & {
@@ -489,5 +489,5 @@ authorId: string;
             id: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            documentId: string;
             lastRead: any;
@@ -500,5 +500,5 @@ } & {
             id: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            documentId: string;
             lastRead: any;
@@ -512,5 +512,5 @@ } & {
             id: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            documentId: string;
             lastRead: any;
@@ -523,5 +523,5 @@ } & {
             id: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            documentId: string;
             lastRead: any;
@@ -536,6 +536,6 @@ } & {
             id: string;
+            annotationId: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            annotationId: string;
-            documentId: string;
             lastRead: any;
@@ -550,6 +550,6 @@ annotationCreatedAt: any;
             id: string;
+            annotationId: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            annotationId: string;
-            documentId: string;
             lastRead: any;
@@ -565,6 +565,6 @@ annotationCreatedAt: any;
             id: string;
+            annotationId: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            annotationId: string;
-            documentId: string;
             lastRead: any;
@@ -579,6 +579,6 @@ annotationCreatedAt: any;
             id: string;
+            annotationId: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            annotationId: string;
-            documentId: string;
             lastRead: any;
@@ -595,6 +595,6 @@ annotationCreatedAt: any;
             id: string;
+            annotationId: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            annotationId: string;
-            documentId: string;
         } & {
@@ -606,6 +606,6 @@ userId: string;
             id: string;
+            annotationId: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            annotationId: string;
-            documentId: string;
         } & {
@@ -620,8 +620,8 @@ userId: string;
         }, context: CustomContext) => ({
-            name?: string;
             id: string;
+            xfdf: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            xfdf: string;
-            documentId: string;
+            name?: string;
         } & {
@@ -632,8 +632,8 @@ authorId: string;
         }) | Promise<{
-            name?: string;
             id: string;
+            xfdf: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            xfdf: string;
-            documentId: string;
+            name?: string;
         } & {
@@ -645,8 +645,8 @@ authorId: string;
         editSnapshot?: (id: string, input: import("../../../../types/resolvers-types").EditSnapshotInput, context: CustomContext) => ({
-            name?: string;
             id: string;
+            xfdf: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            xfdf: string;
-            documentId: string;
+            name?: string;
         } & {
@@ -657,8 +657,8 @@ authorId: string;
         }) | Promise<{
-            name?: string;
             id: string;
+            xfdf: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            xfdf: string;
-            documentId: string;
+            name?: string;
         } & {
@@ -689,10 +689,10 @@ authorId: string;
             id: string;
-            createdAt: any;
-            updatedAt: any;
             xfdf: string;
+            annotContents?: string;
             annotationId: string;
             documentId: string;
             pageNumber: number;
+            createdAt: any;
+            updatedAt: any;
             inReplyTo?: string;
-            annotContents?: string;
         } & {
@@ -704,10 +704,10 @@ authorId: string;
             id: string;
-            createdAt: any;
-            updatedAt: any;
             xfdf: string;
+            annotContents?: string;
             annotationId: string;
             documentId: string;
             pageNumber: number;
+            createdAt: any;
+            updatedAt: any;
             inReplyTo?: string;
-            annotContents?: string;
         } & {
@@ -720,10 +720,10 @@ authorId: string;
             id: string;
-            createdAt: any;
-            updatedAt: any;
             xfdf: string;
+            annotContents?: string;
             annotationId: string;
             documentId: string;
             pageNumber: number;
+            createdAt: any;
+            updatedAt: any;
             inReplyTo?: string;
-            annotContents?: string;
         } & {
@@ -735,10 +735,10 @@ authorId: string;
             id: string;
-            createdAt: any;
-            updatedAt: any;
             xfdf: string;
+            annotContents?: string;
             annotationId: string;
             documentId: string;
             pageNumber: number;
+            createdAt: any;
+            updatedAt: any;
             inReplyTo?: string;
-            annotContents?: string;
         } & {
@@ -751,3 +751,2 @@ authorId: string;
         addDocument: (document: import("../../../../types/resolvers-types").NewDocumentInput, context: CustomContext) => ({
-            name?: string;
             id: string;
@@ -757,2 +756,3 @@ createdAt: any;
             isPublic?: boolean;
+            name?: string;
         } & {
@@ -763,3 +763,2 @@ authorId: string;
         }) | Promise<{
-            name?: string;
             id: string;
@@ -769,2 +768,3 @@ createdAt: any;
             isPublic?: boolean;
+            name?: string;
         } & {
@@ -776,3 +776,2 @@ authorId: string;
         editDocument: (id: string, input: import("../../../../types/global-graphql-types").EditDocumentInput, context: CustomContext) => ({
-            name?: string;
             id: string;
@@ -782,2 +781,3 @@ createdAt: any;
             isPublic?: boolean;
+            name?: string;
         } & {
@@ -788,3 +788,2 @@ authorId: string;
         }) | Promise<{
-            name?: string;
             id: string;
@@ -794,2 +793,3 @@ createdAt: any;
             isPublic?: boolean;
+            name?: string;
         } & {
@@ -803,5 +803,5 @@ authorId: string;
             id: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            documentId: string;
             lastRead: any;
@@ -814,5 +814,5 @@ } & {
             id: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            documentId: string;
             lastRead: any;
@@ -826,5 +826,5 @@ } & {
             id: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            documentId: string;
             lastRead: any;
@@ -837,5 +837,5 @@ } & {
             id: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            documentId: string;
             lastRead: any;
@@ -850,6 +850,6 @@ } & {
             id: string;
+            annotationId: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            annotationId: string;
-            documentId: string;
             lastRead: any;
@@ -864,6 +864,6 @@ annotationCreatedAt: any;
             id: string;
+            annotationId: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            annotationId: string;
-            documentId: string;
             lastRead: any;
@@ -879,6 +879,6 @@ annotationCreatedAt: any;
             id: string;
+            annotationId: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            annotationId: string;
-            documentId: string;
             lastRead: any;
@@ -893,6 +893,6 @@ annotationCreatedAt: any;
             id: string;
+            annotationId: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            annotationId: string;
-            documentId: string;
             lastRead: any;
@@ -909,6 +909,6 @@ annotationCreatedAt: any;
             id: string;
+            annotationId: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            annotationId: string;
-            documentId: string;
         } & {
@@ -920,6 +920,6 @@ userId: string;
             id: string;
+            annotationId: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            annotationId: string;
-            documentId: string;
         } & {
@@ -934,8 +934,8 @@ userId: string;
         }, context: CustomContext) => ({
-            name?: string;
             id: string;
+            xfdf: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            xfdf: string;
-            documentId: string;
+            name?: string;
         } & {
@@ -946,8 +946,8 @@ authorId: string;
         }) | Promise<{
-            name?: string;
             id: string;
+            xfdf: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            xfdf: string;
-            documentId: string;
+            name?: string;
         } & {
@@ -959,8 +959,8 @@ authorId: string;
         editSnapshot?: (id: string, input: import("../../../../types/resolvers-types").EditSnapshotInput, context: CustomContext) => ({
-            name?: string;
             id: string;
+            xfdf: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            xfdf: string;
-            documentId: string;
+            name?: string;
         } & {
@@ -971,8 +971,8 @@ authorId: string;
         }) | Promise<{
-            name?: string;
             id: string;
+            xfdf: string;
+            documentId: string;
             createdAt: any;
             updatedAt: any;
-            xfdf: string;
-            documentId: string;
+            name?: string;
         } & {
@@ -979,0 +979,0 @@ authorId: string;

types/packages/collab-sql-resolver-generator/src/index.d.ts

@@ -1,2 +0,2 @@
-import type { CollabSQLResolverGeneratorOptions } from './types';
+import { CollabSQLResolverGeneratorOptions } from './types';
 import { UserResolvers } from '../../collab-server/src/types/UserResolvers';
@@ -24,3 +24,3 @@ export declare const SQLClient: {
 export { LogLevels, LogTags } from '../../../shared/log/logger';
-export type { CollabSQLResolverGeneratorOptions, EntityInfo, SQLClientOptions, ConnectionOptions, GetDatabaseTimestamp } from './types';
+export type { CollabSQLResolverGeneratorOptions, EntityInfo, SQLClientOptions, ConnectionOptions, GetDatabaseTimestamp, Middleware, MiddlewareFunction } from './types';
 export default SQLResolverGenerator;

types/packages/collab-sql-resolver-generator/src/types.d.ts

@@ -6,20 +6,37 @@ import { Knex } from 'knex';
 export declare type AsyncOrSync<T> = Promise<T> | T;
+declare type Omit<T, K extends keyof T> = Pick<T, Exclude<keyof T, K>>;
+declare type PartialBy<T, K extends keyof T> = Omit<T, K> & Partial<Pick<T, K>>;
+export declare type OptionalId<T extends Entity> = PartialBy<T, 'id'>;
+export declare type Entity = DatabaseAnnotation | DatabaseAnnotationMember | DatabaseDocument | DatabaseDocumentMember | DatabaseMention | DatabaseSnapshot | DatabaseSnapshotAsset | DatabaseUser;
+export declare type UserDatabaseEntity = Record<string, any>;
+export declare type JoinFromArray = [tableName: string, first: string, joinOperator: string, second: string];
+export declare type JoinFromBuilder = [tableName: string, build: (builder: Knex.JoinClause) => any];
 export declare type GeneratorColumnsOptionsObject = {
-    name: string;
+    name?: string;
     transform?: (data: any) => any;
+    join?: JoinFromArray | JoinFromBuilder;
 };
+export declare type TransformedGeneratorColumnsOptionsObject = GeneratorColumnsOptionsObject & {
+    skipWrite?: boolean;
+    nameWithTable: string;
+};
 export declare type GeneratorColumnsOptions = GeneratorColumnsOptionsObject | string;
-export declare type OptionsColumns<T> = {
+export declare type DataWithTransform<T> = T & Record<string, any>;
+export declare type OptionsColumns<T extends Partial<Entity>> = {
     [Property in keyof T]: GeneratorColumnsOptions;
 };
+export declare type TransformedOptionsColumns<T extends Partial<Entity>> = {
+    [Property in keyof T]: TransformedGeneratorColumnsOptionsObject;
+};
 export declare type ColumnLookupMap = Record<keyof CollabSQLResolverGeneratorOptions['info'], Record<string, string>>;
 export declare type MutationOperations = 'create' | 'update' | 'delete';
-export declare type MiddlewareParams = {
-    data: Record<string, any>;
+export declare type MiddlewareParams<T extends UserDatabaseEntity> = {
+    data: T;
     type: MutationOperations;
     ctx: Record<any, any>;
     knex: Knex;
-    next: (data: Record<string, any>, ctx: Record<any, any>) => void;
+    next: (data: DataWithTransform<T>, ctx: Record<any, any>) => void;
 };
-export declare type Middleware = ((info: MiddlewareParams) => AsyncOrSync<void>)[];
+export declare type MiddlewareFunction<T> = ((info: MiddlewareParams<T>) => AsyncOrSync<void>);
+export declare type Middleware<T extends UserDatabaseEntity> = MiddlewareFunction<T>[];
 export interface EntityInfo {
@@ -45,15 +62,29 @@ Users: GeneratorEntity<DatabaseUser>;
 }
-export declare type GeneratorEntity<T> = {
+export declare type QueryContext = {
+    from: string;
+    entityInformation: GeneratorEntityWithMap<any>;
+    isCountQuery?: boolean;
+    customContext: Record<any, any>;
+};
+export declare type GeneratorEntity<T extends Partial<Entity>> = {
     table: string;
-    writeMiddleware?: Middleware;
+    writeMiddleware?: Middleware<UserDatabaseEntity>;
+    afterWrite?: (params: {
+        knex: Knex;
+        data: T;
+        context: Record<any, any>;
+        operation: MutationOperations;
+    }) => Promise<T> | void | T | Promise<void>;
     columns: OptionsColumns<T>;
 };
-export declare type GeneratorEntityWithMap<T> = GeneratorEntity<T> & {
-    columnsMap: Record<string, keyof T>;
+export declare type GeneratorEntityWithMap<T extends Partial<Entity>> = GeneratorEntity<T> & {
+    columnMap: Record<string, string>;
     selectFields: string[];
+    returnFields: string[];
+    columns: TransformedOptionsColumns<T>;
 };
-export interface DataOption<EntityType, DataType> {
+export interface MutateDataParameters<EntityType extends Partial<Entity>> {
     from: string;
     entity: GeneratorEntityWithMap<EntityType>;
-    data: DataType;
+    data: Partial<EntityType>;
     id?: string;
@@ -63,3 +94,3 @@ customContext: Record<any, any>;
 }
-export interface MutationWithoutRerturnOption<EntityType> {
+export interface MutationWithoutReturnOption<EntityType extends Partial<Entity>> {
     from: string;
@@ -70,11 +101,13 @@ id?: string;
     dbDataMap: Record<string, any>;
+    customContext: Record<any, any>;
 }
-export interface TransformToApolloFormatOption<T> {
+export interface TransformToApolloFormatOption {
     result: Record<string, any>;
-    columns: OptionsColumns<T>;
-    columnsMap: Record<string, keyof T>;
+    columns: TransformedOptionsColumns<any>;
+    columnMap: Record<string, string>;
     parseToUnixTimestamp: ParseToUnixTimestamp;
+    from?: string;
 }
-export interface ApplyMiddlewareOption<T> {
-    writeMiddleware: Middleware;
+export interface ApplyMiddlewareOption<T extends UserDatabaseEntity> {
+    writeMiddleware: Middleware<T>;
     dbDataMap: Record<string, keyof T>;
@@ -86,6 +119,6 @@ operationType: 'create' | 'update' | 'delete';
 export declare type ParseToUnixTimestamp = (timestamp: string | number) => number;
-export interface ToDatabaseFormatOption<T> {
+export interface ToDatabaseFormatOption<T extends Entity> {
     data: Record<string, any>;
     table: string;
-    columns: OptionsColumns<T>;
+    columns: OptionsColumns<Partial<T>>;
     getDatabaseTimestamp: GetDatabaseTimestamp;
@@ -148,1 +181,2 @@ knex: Knex;
 };
+export {};

types/packages/collab-sql-resolver-generator/src/util.d.ts

@@ -1,8 +0,10 @@
-import { ToDatabaseFormatOption, TransformToApolloFormatOption, ParseToUnixTimestamp, EntityInfo, OptionsColumns, EntityInfoWithMap, GeneratorColumnsOptions, GetDatabaseTimestamp } from './types';
-import type { Knex } from 'knex';
-import { QueryParams } from '../../collab-server/src/types/Params';
-export declare const buildFilterQuery: <T>(builder: Knex.QueryBuilder, filters: QueryParams, columns: OptionsColumns<T>, getDatabaseTimestamp: GetDatabaseTimestamp) => void;
-export declare const getColumnName: (column: GeneratorColumnsOptions) => string;
-export declare const buildModifyQuery: <T>(builder: Knex.QueryBuilder, filters: QueryParams, columns: OptionsColumns<T>) => void;
-export declare const toDatabaseFormat: <T>({ data, table, columns, getDatabaseTimestamp, knex }: ToDatabaseFormatOption<T>) => {};
+import { ToDatabaseFormatOption, TransformToApolloFormatOption, ParseToUnixTimestamp, EntityInfo, EntityInfoWithMap, GetDatabaseTimestamp, GeneratorEntityWithMap, Entity, TransformedOptionsColumns, OptionsColumns } from "./types";
+import type { Knex } from "knex";
+import { QueryParams } from "../../collab-server/src/types/Params";
+export declare const buildFilterQuery: <T extends Entity>(builder: Knex.QueryBuilder, filters: QueryParams, columns: TransformedOptionsColumns<T>, getDatabaseTimestamp: GetDatabaseTimestamp) => void;
+export declare const buildJoinQuery: <T extends Entity>(builder: Knex.QueryBuilder, info: GeneratorEntityWithMap<T>) => void;
+export declare const buildModifyQuery: <T extends Entity>(builder: Knex.QueryBuilder, filters: QueryParams, columns: TransformedOptionsColumns<T>) => void;
+export declare const applyMissingData: <T extends Entity>(originalData: T, returnData: T, columns: TransformedOptionsColumns<T>) => T;
+export declare const removeJoinedData: (data: any, columns: OptionsColumns<any>) => any;
+export declare const toDatabaseFormat: <T extends Entity>({ data, columns, getDatabaseTimestamp, knex, }: ToDatabaseFormatOption<T>) => Record<string, any>;
 export declare const defaultParseToUnixTimestamp: (timestamp: string) => number;
@@ -12,4 +14,4 @@ export declare const defaultGetDatabaseTimestamp: (date: number) => any;
 export declare const toUnixTimestamp: (data: Record<string, any>, parseToUnixTimestamp: ParseToUnixTimestamp) => Record<string, any>;
-export declare const keysToCamel: <T>(data: Record<string, any>, columns: OptionsColumns<T>, columnsMap: Record<string, keyof T>) => Record<keyof T, any>;
-export declare const transformToApolloFormat: <T>({ result, columns, columnsMap, parseToUnixTimestamp, }: TransformToApolloFormatOption<T>) => Record<string, any>;
+export declare const keysToCamel: <T extends Entity>(data: Record<string, any>, columns: TransformedOptionsColumns<T>, columnsMap: Record<string, string>) => Record<keyof T, any>;
+export declare const transformToApolloFormat: <T extends Entity>({ result, columns, columnMap, parseToUnixTimestamp, }: TransformToApolloFormatOption) => T[];
 export declare const attachAdditionalInfo: (info: EntityInfo) => EntityInfoWithMap;

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

211926

increased by1.16%

Worsened metrics

Number of package files

83

decreased by-11.7%

Lines of code

3908

decreased by-2.23%

No dependency changes