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

Comparing version 2.0.0-alpha.4 to 2.0.0-alpha.9

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.Tags=void 0;var u=i(n(1)),a=n(7);!function(e){e.STANDARD="STANDARD",e.ENTITY="ENTITY",e.QUERY="QUERY",e.RESPONSE="RESPONSE"}(t.Tags||(t.Tags={})),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){e===t.LogLevels.NONE?s.silent=!0:(a.addConsoleTransport(s,e),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])}}},l=this&&this.__await||function(e){return this instanceof l?(this.v=e,this):new l(e)},d=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 l?Promise.resolve(n.value.v).then(s,d):c(i[0][2],n)}catch(e){c(i[0][3],e)}var n}function s(e){a("next",e)}function d(e){a("throw",e)}function c(e,t){e(t),i.shift(),i.length&&a(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),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.LogLevels=t.MutationOperationType=t.SQLClient=void 0;var p=m(n(3)),v=n(4),b=u(n(0)),y=n(8);t.SQLClient={Postgres:"pg",MSSQL:"mssql",SQLite3:"sqlite3",Oracle:"oracledb",MySQL:"mysql"},t.MutationOperationType={CREATE:"create",UPDATE:"update"};var h=n(0);Object.defineProperty(t,"LogLevels",{enumerable:!0,get:function(){return h.LogLevels}}),t.default=function(e){var n=e.client,o=e.version,i=void 0===o?"":o,u=e.connection,m=e.pool,h=void 0===m?{min:2,max:10}:m,g=e.getDatabaseTimestamp,w=void 0===g?v.defaultGetDatabaseTimestamp:g,M=e.parseToUnixTimestamp,T=void 0===M?v.defaultParseToUnixTimestamp:M,C=e.logLevel,A=void 0===C?b.LogLevels.ERROR:C,_=e.transports,x=void 0===_?[]:_;v.testTimeTransformFunctions(T,w),b.setupLogger(A,x),b.default.info("Collab SQL Resolver Generator version 2.0.0-alpha.4");var q=y.validateSchema(b.LogLevels,t.SQLClient).validate(e).error;if(q)throw b.default.error(q.details),new Error(""+q);var N=v.attachAdditionalInfo(e.info),O=p.default({client:n,version:i,connection:u,pool:r({afterCreate:function(e,t){b.default.info("--\x3e Database connected"),t(null,e)}},h),postProcessResponse:function(e,t){return t?(null==t?void 0:t.isCountQuery)||0===e.length?e:v.transformToApolloFormat({result:e,columns:null==t?void 0:t.columns,columnsMap:null==t?void 0:t.columnsMap,parseToUnixTimestamp:T}):e},debug:A===b.LogLevels.DEBUG,log:{warn:function(e){b.default.warn(e)},error:function(e){b.default.error(e)},deprecate:function(e){b.default.warn(e)},debug:function(e){b.default.debug(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,b,y;return s(this,(function(h){switch(h.label){case 0:if(e=r({},u),i=r({},n),0===t.length)return[2,i];f=function(){return d(this,arguments,(function(){var n,r,u=this;return s(this,(function(d){switch(d.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,next:function(n,r){n&&(i=n),r&&(e=r),t()}})}))]:[2];case 1:return u.sent(),[2]}}))}))},d.label=1;case 1:return n<t.length?[4,l(r())]:[3,5];case 2:return d.sent(),n++,[4,l(void 0)];case 3:return[4,d.sent()];case 4:return d.sent(),[3,1];case 5:return[4,l(void 0)];case 6:return[2,d.sent()]}}))}))}(),h.label=1;case 1:h.trys.push([1,6,7,12]),m=c(f),h.label=2;case 2:return[4,m.next()];case 3:if((p=h.sent()).done)return[3,5];p.value,f.next(),h.label=4;case 4:return[3,2];case 5:return[3,12];case 6:return v=h.sent(),b={error:v},[3,12];case 7:return h.trys.push([7,,10,11]),p&&!p.done&&(y=m.return)?[4,y.call(m)]:[3,9];case 8:h.sent(),h.label=9;case 9:return[3,11];case 10:if(b)throw b.error;return[7];case 11:return[7];case 12:return[2,i]}}))}))},I=function(e){var r=e.id,o=e.operationType,i=e.entity,u=e.dbDataMap;return a(void 0,void 0,void 0,(function(){var e,a,l,d,c,m,p,b;return s(this,(function(s){switch(s.label){case 0:return e=i.table,a=i.selectFields,l=i.columns,d=i.columnsMap,o!==t.MutationOperationType.CREATE?[3,2]:[4,O(e).queryContext({columns:l,columnsMap:d}).insert(u)];case 1:return s.sent(),[3,4];case 2:return o!==t.MutationOperationType.UPDATE?[3,4]:[4,O(e).queryContext({columns:l,columnsMap:d}).where(v.getColumnName(l.id),r).update(u)];case 3:s.sent(),s.label=4;case 4:return c=n===t.SQLClient.SQLite3?"last_insert_rowid() as id":"LAST_INSERT_ID() as id",[4,O.select(O.raw(c))];case 5:return m=f.apply(void 0,[s.sent(),1]),p=m[0],b=p.id,n===t.SQLClient.SQLite3&&a.push("rowid"),[4,O(e).select(a).queryContext({columns:l,columnsMap:d}).where(v.getColumnName(l.id),b)];case 6:return[2,s.sent()]}}))}))},j=function(e){var r=e.id,o=e.entity,i=e.data,u=e.customContext,l=e.operationType;return a(void 0,void 0,void 0,(function(){var e,a,d,c,f,m,p,y,h;return s(this,(function(s){switch(s.label){case 0:e=o.table,a=o.writeMiddleware,d=void 0===a?[]:a,c=o.selectFields,f=o.columns,m=o.columnsMap,s.label=1;case 1:return s.trys.push([1,9,,10]),[4,D({writeMiddleware:d,dbDataMap:v.toDatabaseFormat({data:i,table:e,columns:f,getDatabaseTimestamp:w,knex:O}),operationType:l,customContext:u})];case 2:return p=s.sent(),y=[],n!==t.SQLClient.SQLite3&&n!==t.SQLClient.MySQL?[3,4]:[4,I({id:r,operationType:l,entity:o,dbDataMap:p})];case 3:return y=s.sent(),[3,8];case 4:return l!==t.MutationOperationType.CREATE?[3,6]:[4,O(e).queryContext({columns:f,columnsMap:m}).insert(p).returning(c)];case 5:return y=s.sent(),[3,8];case 6:return[4,O(e).queryContext({columns:f,columnsMap:m}).where(v.getColumnName(f.id),r).update(p).returning(c)];case 7:y=s.sent(),s.label=8;case 8:return[2,y[0]||null];case 9:return h=s.sent(),b.default.error(h),[3,10];case 10:return[2]}}))}))},P=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(),b.default.error(o),[2,{id:n,successful:!1}];case 4:return[2]}}))}))};return{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=N.Users,n=t.selectFields,r=void 0===n?[]:n,o=t.table,i=t.columns,u=t.columnsMap,[4,O(o).queryContext({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=N.Users,n=t.selectFields,r=void 0===n?[]:n,o=t.table,i=t.columns,u=t.columnsMap,[4,O(o).queryContext({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,l,d,c,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,l=N.Annotations,d=l.selectFields,c=void 0===d?[]:d,f=l.table,m=l.columns,p=l.columnsMap,[4,O(f).queryContext({columns:m,columnsMap:p}).select(c).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,w)})).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,l,d,c;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=N.Documents,u=i.selectFields,a=void 0===u?[]:u,l=i.table,d=i.columns,c=i.columnsMap,[4,O(l).queryContext({columns:d,columnsMap:c}).select(a).where((function(e){t&&e.whereIn(v.getColumnName(d.id),t),n&&e.whereIn(v.getColumnName(d.id),(function(){this.select(v.getColumnName(N.DocumentMembers.columns.documentId)).from(N.DocumentMembers.table).where(v.getColumnName(N.DocumentMembers.columns.userId),n)})),v.buildFilterQuery(e,o,d,w)})).modify((function(e){v.buildModifyQuery(e,o,d)}))];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,l,d,c,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=N.AnnotationMembers,a=u.selectFields,l=void 0===a?[]:a,d=u.table,c=u.columns,f=u.columnsMap,[4,O(d).queryContext({columns:c,columnsMap:f}).select(l).where((function(e){n&&e.whereIn(v.getColumnName(c.id),n),t&&e.where(v.getColumnName(c.annotationId),t),r&&e.where(v.getColumnName(c.userId),r),v.buildFilterQuery(e,i,c,w)})).modify((function(e){v.buildModifyQuery(e,i,c)}))];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,l,d,c,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=N.DocumentMembers,a=u.selectFields,l=void 0===a?[]:a,d=u.table,c=u.columns,f=u.columnsMap,[4,O(d).queryContext({columns:c,columnsMap:f}).select(l).where((function(e){n&&e.whereIn(v.getColumnName(c.id),n),t&&e.where(v.getColumnName(c.documentId),t),r&&e.where(v.getColumnName(c.userId),r),v.buildFilterQuery(e,i,c,w)})).modify((function(e){v.buildModifyQuery(e,i,c)}))];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,l,d,c,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=N.Mentions,l=a.selectFields,d=void 0===l?[]:l,c=a.table,f=a.columns,m=a.columnsMap,[4,O(c).queryContext({columns:f,columnsMap:m}).select(d).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,w)})).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=N.Annotations,o=r.table,i=r.columns,u=r.columnsMap,[4,O(o).queryContext({columns:i,columnsMap:u,isCountQuery:!0}).count({count:[v.getColumnName(i.id)]}).where(v.getColumnName(i.documentId),n).where(v.getColumnName(i.createdAt),">",w(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,l;return s(this,(function(s){switch(s.label){case 0:return t=e.userId,n=e.documentId,r=e.since,o=N.AnnotationMembers,i=o.table,u=o.columns,a=o.columnsMap,[4,O(i).queryContext({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),">",w(r))];case 1:return l=s.sent(),[2,Number(l[0].count||0)]}}))}))}},Mutation:{addUser:function(e,n){return a(void 0,void 0,void 0,(function(){return s(this,(function(r){return[2,j({entity:N.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,j({entity:N.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,j({customContext:r,entity:N.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,P({entity:N.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,j({entity:N.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,j({entity:N.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,P({entity:N.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,j({entity:N.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,j({entity:N.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,P({entity:N.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,j({entity:N.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,j({entity:N.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,P({entity:N.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,j({entity:N.Mentions,data:e,customContext:n,operationType:t.MutationOperationType.CREATE})]}))}))},editMention:function(e,n,r){return a(void 0,void 0,void 0,(function(){var o,i;return s(this,(function(u){return o=n.readBeforeMention,i=n.updatedAt,[2,j({entity:N.Mentions,id:e,data:{readBeforeMention:o,updatedAt:i},customContext:r,operationType:t.MutationOperationType.UPDATE})]}))}))},deleteMention:function(e,t){return a(void 0,void 0,void 0,(function(){return s(this,(function(n){return[2,P({entity:N.Mentions,id:e,customContext:t})]}))}))}}}}},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)};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 o=n(5),i=n(6);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,u=e.columns,a=e.getDatabaseTimestamp,s=e.knex,l={};for(var d in n)void 0===u[d]?i.throwError("SQL Resolver Generator","Please add "+d+" column info to info."+r+".columns"):o.TimestampProperties.includes(d)?o.NowTimestampProperties.includes(d)?l[t.getColumnName(u[d])]=s.raw(n[d]):l[t.getColumnName(u[d])]=a(n[d]):l[t.getColumnName(u[d])]=n[d];return l};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){o.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:[]})};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.__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.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(t,"__esModule",{value:!0}),t.validateParams=t.throwError=void 0;var i=o(n(0));t.throwError=function(e,t,n){var r=e+" - "+t;throw i.default.error(r),n?new n(r):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)},u=function(t,n,r){var o=e+' - Paramater "'+t+'" expected type "'+r+'" but got "'+n+'"';throw i.default.error(o),new Error(o)};for(var a in t){var s=r(t[a],3),l=s[0],d=s[1],c=void 0===d?"any":d,f=s[2],m=void 0===f||f;if(null!=l&&""!==l){if("any"!==c){var p=typeof l;if("string"!==c){if("number"!==c){if("array"!==c){if("blob"!==c){if("boolean"!==c){if("object"!==c){if("function"!==c);else if(!(n=l)||"[object Function]"!=={}.toString.call(n))return u(a,p,c)}else if("object"!==p)return u(a,p,c)}else if("boolean"!==p)return u(a,p,c)}else if(!(l instanceof Blob))return u(a,p,c)}else if(!Array.isArray(l))return u(a,p,c)}else if("number"!==p)return u(a,p,c)}else if("string"!==p)return u(a,p,c)}}else if(m)return o(a)}}},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){void 0===t&&(t=a.LogLevels.INFO),e.add(new u.default.transports.Console({level:t,format:u.format.combine(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(9)),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){var n,i;return u.default.object({client:(n=u.default.string()).valid.apply(n,o([],r(Object.values(t)))).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:(i=u.default.string()).valid.apply(i,o([],r(Object.values(e)))),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(),readBeforeMention:a.required(),createdAt:a.required(),updatedAt:a.required()}).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=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.Tags=void 0;var u=i(n(1)),a=n(7);!function(e){e.STANDARD="STANDARD",e.ENTITY="ENTITY",e.QUERY="QUERY",e.RESPONSE="RESPONSE",e.AUTH="AUTH"}(t.Tags||(t.Tags={})),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)},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={},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,l):c(i[0][2],n)}catch(e){c(i[0][3],e)}var n}function s(e){a("next",e)}function l(e){a("throw",e)}function c(e,t){e(t),i.shift(),i.length&&a(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),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.LogLevels=t.MutationOperationType=t.SQLClient=void 0;var p=m(n(3)),v=n(4),b=u(n(0)),y=n(8);t.SQLClient={Postgres:"pg",MSSQL:"mssql",SQLite3:"sqlite3",Oracle:"oracledb",MySQL:"mysql"},t.MutationOperationType={CREATE:"create",UPDATE:"update"};var h=n(0);Object.defineProperty(t,"LogLevels",{enumerable:!0,get:function(){return h.LogLevels}}),t.default=function(e){var n=e.client,o=e.version,i=void 0===o?"":o,u=e.connection,m=e.pool,h=void 0===m?{min:2,max:10}:m,M=e.getDatabaseTimestamp,g=void 0===M?v.defaultGetDatabaseTimestamp:M,w=e.parseToUnixTimestamp,T=void 0===w?v.defaultParseToUnixTimestamp:w,C=e.logLevel,A=void 0===C?b.LogLevels.ERROR:C,_=e.transports,x=void 0===_?[]:_;v.testTimeTransformFunctions(T,g),b.setupLogger(A,x),b.default.info("Collab SQL Resolver Generator version 2.0.0-alpha.9");var q=y.validateSchema(b.LogLevels,t.SQLClient).validate(e).error;if(q)throw b.default.error(q.details),new Error(""+q);var D=v.attachAdditionalInfo(e.info),N=p.default({client:n,version:i,connection:u,pool:r({afterCreate:function(e,t){b.default.info("--\x3e Database connected"),t(null,e)}},h),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:T});return b.default.log({level:b.LogLevels.DEBUG,tag:b.Tags.RESPONSE,message:"["+t.from+"]: "+JSON.stringify(n)}),n},debug:A===b.LogLevels.DEBUG,log:{warn:function(e){b.default.warn(e)},error:function(e){b.default.error(e)},deprecate:function(e){b.default.warn(e)},debug:function(e){b.default.log({level:b.LogLevels.DEBUG,tag:b.Tags.QUERY,message:e})}}}),O=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,b,y;return s(this,(function(h){switch(h.label){case 0:if(e=r({},u),i=r({},n),0===t.length)return[2,i];f=function(){return l(this,arguments,(function(){var n,r,u=this;return s(this,(function(l){switch(l.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,next:function(n,r){n&&(i=n),r&&(e=r),t()}})}))]:[2];case 1:return u.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()]}}))}))}(),h.label=1;case 1:h.trys.push([1,6,7,12]),m=c(f),h.label=2;case 2:return[4,m.next()];case 3:if((p=h.sent()).done)return[3,5];p.value,f.next(),h.label=4;case 4:return[3,2];case 5:return[3,12];case 6:return v=h.sent(),b={error:v},[3,12];case 7:return h.trys.push([7,,10,11]),p&&!p.done&&(y=m.return)?[4,y.call(m)]:[3,9];case 8:h.sent(),h.label=9;case 9:return[3,11];case 10:if(b)throw b.error;return[7];case 11:return[7];case 12:return[2,i]}}))}))},E=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,l,c,m,p,b,y;return s(this,(function(s){switch(s.label){case 0:return e=u.table,a=u.selectFields,l=u.columns,c=u.columnsMap,i!==t.MutationOperationType.CREATE?[3,2]:[4,N(e).queryContext({from:r,columns:l,columnsMap:c}).insert(d)];case 1:return s.sent(),[3,4];case 2:return i!==t.MutationOperationType.UPDATE?[3,4]:[4,N(e).queryContext({from:r,columns:l,columnsMap:c}).where(v.getColumnName(l.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,N.select(N.raw(m))];case 5:return p=f.apply(void 0,[s.sent(),1]),b=p[0],y=b.id,n===t.SQLClient.SQLite3&&a.push("rowid"),[4,N(e).select(a).queryContext({from:r,columns:l,columnsMap:c}).where(v.getColumnName(l.id),y)];case 6:return[2,s.sent()]}}))}))},I=function(e){var r=e.from,o=e.id,i=e.entity,u=e.data,d=e.customContext,l=e.operationType;return a(void 0,void 0,void 0,(function(){var e,a,c,f,m,p,y,h,M;return s(this,(function(s){switch(s.label){case 0:e=i.table,a=i.writeMiddleware,c=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,O({writeMiddleware:c,dbDataMap:v.toDatabaseFormat({data:u,table:e,columns:m,getDatabaseTimestamp:g,knex:N}),operationType:l,customContext:d})];case 2:return y=s.sent(),h=[],n!==t.SQLClient.SQLite3&&n!==t.SQLClient.MySQL?[3,4]:[4,E({from:r,id:o,operationType:l,entity:i,dbDataMap:y})];case 3:return h=s.sent(),[3,8];case 4:return l!==t.MutationOperationType.CREATE?[3,6]:[4,N(e).queryContext({from:r,columns:m,columnsMap:p}).insert(y).returning(f)];case 5:return h=s.sent(),[3,8];case 6:return[4,N(e).queryContext({from:r,columns:m,columnsMap:p}).where(v.getColumnName(m.id),o).update(y).returning(f)];case 7:h=s.sent(),s.label=8;case 8:return[2,h[0]||null];case 9:return M=s.sent(),b.default.error(M),[3,10];case 10:return[2]}}))}))},P=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,N(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(),b.default.error(o),[2,{id:n,successful:!1}];case 4:return[2]}}))}))};return{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=D.Users,n=t.selectFields,r=void 0===n?[]:n,o=t.table,i=t.columns,u=t.columnsMap,[4,N(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=D.Users,n=t.selectFields,r=void 0===n?[]:n,o=t.table,i=t.columns,u=t.columnsMap,[4,N(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,l,c,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=D.Annotations,l=d.selectFields,c=void 0===l?[]:l,f=d.table,m=d.columns,p=d.columnsMap,[4,N(f).queryContext({from:"Query.annotations",columns:m,columnsMap:p}).select(c).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,l,c;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=D.Documents,u=i.selectFields,a=void 0===u?[]:u,d=i.table,l=i.columns,c=i.columnsMap,[4,N(d).queryContext({from:"Query.documents",columns:l,columnsMap:c}).select(a).where((function(e){t&&e.whereIn(v.getColumnName(l.id),t),n&&e.whereIn(v.getColumnName(l.id),(function(){this.select(v.getColumnName(D.DocumentMembers.columns.documentId)).from(D.DocumentMembers.table).where(v.getColumnName(D.DocumentMembers.columns.userId),n)})),v.buildFilterQuery(e,o,l,g)})).modify((function(e){v.buildModifyQuery(e,o,l)}))];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,l,c,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=D.AnnotationMembers,a=u.selectFields,d=void 0===a?[]:a,l=u.table,c=u.columns,f=u.columnsMap,[4,N(l).queryContext({from:"Query.annotationMembers",columns:c,columnsMap:f}).select(d).where((function(e){n&&e.whereIn(v.getColumnName(c.id),n),t&&e.where(v.getColumnName(c.annotationId),t),r&&e.where(v.getColumnName(c.userId),r),v.buildFilterQuery(e,i,c,g)})).modify((function(e){v.buildModifyQuery(e,i,c)}))];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,l,c,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=D.DocumentMembers,a=u.selectFields,d=void 0===a?[]:a,l=u.table,c=u.columns,f=u.columnsMap,[4,N(l).queryContext({from:"Query.documentMembers",columns:c,columnsMap:f}).select(d).where((function(e){n&&e.whereIn(v.getColumnName(c.id),n),t&&e.where(v.getColumnName(c.documentId),t),r&&e.where(v.getColumnName(c.userId),r),v.buildFilterQuery(e,i,c,g)})).modify((function(e){v.buildModifyQuery(e,i,c)}))];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,l,c,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=D.Mentions,d=a.selectFields,l=void 0===d?[]:d,c=a.table,f=a.columns,m=a.columnsMap,[4,N(c).queryContext({from:"Query.mentions",columns:f,columnsMap:m}).select(l).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=D.Annotations,o=r.table,i=r.columns,u=r.columnsMap,[4,N(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=D.AnnotationMembers,i=o.table,u=o.columns,a=o.columnsMap,[4,N(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,I({from:"Mutation.addUser",entity:D.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,I({from:"Mutation.addAnnotation",entity:D.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,I({from:"Mutation.editAnnotation",customContext:r,entity:D.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,P({from:"Mutation.deleteAnnotation",entity:D.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,I({from:"Mutation.addDocument",entity:D.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,I({from:"Mutation.editDocument",entity:D.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,P({from:"Mutation.deleteDocument",entity:D.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,I({from:"Mutation.addDocumentMember",entity:D.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,I({from:"Mutation.editDocumentMember",entity:D.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,P({from:"Mutation.deleteDocumentMember",entity:D.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,I({from:"Mutation.addAnnotationMember",entity:D.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,I({from:"Mutation.editAnnotationMember",entity:D.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,P({from:"Mutation.deleteAnnotationMember",entity:D.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,I({from:"Mutation.addMention",entity:D.Mentions,data:e,customContext:n,operationType:t.MutationOperationType.CREATE})]}))}))},editMention:function(e,n,r){return a(void 0,void 0,void 0,(function(){var o,i;return s(this,(function(u){return o=n.readBeforeMention,i=n.updatedAt,[2,I({from:"Mutation.editMention",entity:D.Mentions,id:e,data:{readBeforeMention:o,updatedAt:i},customContext:r,operationType:t.MutationOperationType.UPDATE})]}))}))},deleteMention:function(e,t){return a(void 0,void 0,void 0,(function(){return s(this,(function(n){return[2,P({from:"Mutation.deleteMention",entity:D.Mentions,id:e,customContext:t})]}))}))}}}}},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)};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 o=n(5),i=n(6);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,u=e.columns,a=e.getDatabaseTimestamp,s=e.knex,d={};for(var l in n)void 0===u[l]?i.throwError("SQL Resolver Generator","Please add "+l+" column info to info."+r+".columns"):o.TimestampProperties.includes(l)?o.NowTimestampProperties.includes(l)?d[t.getColumnName(u[l])]=s.raw(n[l]):d[t.getColumnName(u[l])]=a(n[l]):d[t.getColumnName(u[l])]=n[l];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){o.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:[]})};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.__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.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(t,"__esModule",{value:!0}),t.validateParams=t.throwError=void 0;var i=o(n(0));t.throwError=function(e,t,n){var r=e+" - "+t;throw i.default.error(r),n?new n(r):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)},u=function(t,n,r){var o=e+' - Paramater "'+t+'" expected type "'+r+'" but got "'+n+'"';throw i.default.error(o),new Error(o)};for(var a in t){var s=r(t[a],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 u(a,p,c)}else if("object"!==p)return u(a,p,c)}else if("boolean"!==p)return u(a,p,c)}else if(!(d instanceof Blob))return u(a,p,c)}else if(!Array.isArray(d))return u(a,p,c)}else if("number"!==p)return u(a,p,c)}else if("string"!==p)return u(a,p,c)}}else if(m)return o(a)}}},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(9)),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){var n,i;return u.default.object({client:(n=u.default.string()).valid.apply(n,o([],r(Object.values(t)))).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:(i=u.default.string()).valid.apply(i,o([],r(Object.values(e)))),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(),readBeforeMention:a.required(),createdAt:a.required(),updatedAt:a.required()}).required()}).required()}).required()})}},function(e,t){e.exports=require("joi")}]).default}));

package.json

@@ -6,3 +6,3 @@ {
   "types": "types/packages/collab-sql-resolver-generator/src/index.d.ts",
-  "version": "2.0.0-alpha.4",
+  "version": "2.0.0-alpha.9",
   "scripts": {
@@ -36,3 +36,3 @@ "test-dev": "jest --watch",
   },
-  "gitHead": "ce02c56bf295cde3b9ee9aa961e8a2e401e04be9"
+  "gitHead": "be43d839181faf826acf5055db7766babd823459"
 }

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

@@ -1,2 +0,2 @@
-import { PubSub } from 'apollo-server';
+import { PubSub } from 'graphql-subscriptions';
 import { ApolloDatabaseAnnotation } from './../resolvers';
@@ -3,0 +3,0 @@ import { User } from './User';

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

@@ -1,2 +0,2 @@
-import { PubSub } from 'apollo-server';
+import { PubSub } from 'graphql-subscriptions';
 import { ApolloDatabaseDocument, ApolloDatabaseDocumentMember, ApolloDatabaseUser } from './../resolvers';
@@ -3,0 +3,0 @@ import { Document as ApolloDocument, InvitedUserInput, NewDocumentInput, NewAnnotationInput, ChangeEventTypes, DocumentSubscriptionEvent } from './../../../../types/resolvers-types';

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

@@ -0,1 +1,2 @@
+import { PubSub } from 'graphql-subscriptions';
 import { ApolloDatabaseMention } from './../resolvers';
@@ -6,3 +7,2 @@ import { User } from './User';
 import { Base } from './Base';
-import { PubSub } from 'apollo-server';
 export declare class Mention extends Base<ApolloDatabaseMention, ApolloMention, {
@@ -9,0 +9,0 @@ mentionedUser: User;

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

@@ -0,15 +1,20 @@
+/// <reference types="cors" />
+/// <reference types="node" />
+import { Tags } from './../../../shared/log/logger';
+import { Response } from 'express';
+import { PubSub } from 'graphql-subscriptions';
 import { TimestampGetter } from './util/TimestampManager';
 import ConnectedUserMap from './util/ConnectedUserMap';
 import { UserResolvers, CustomContext } from './resolvers';
-import { CorsOptions, PubSub } from 'apollo-server';
-import type winston from 'winston';
-import type { CookieOptions } from 'express';
 import { Logging } from '../../../shared/log/logger';
-import { PermissionSetting, UserPermissionSetting } from './util/permission';
-import { InvitedUserInput, XfdfTypes } from '../../../types/resolvers-types';
-import { Response } from 'express';
 import { EmailManager } from './email/EmailManager';
 import ContextCache from './cache/ContextCache';
+import { PermissionSetting, UserPermissionSetting } from './util/permission';
 import RequestStats from './util/RequestStats';
 import { RequestedFields } from './util/getRequestedFields';
+import type { Server as HttpServer } from 'http';
+import type { CorsOptions } from 'apollo-server-express';
+import type winston from 'winston';
+import type { CookieOptions } from 'express';
+import { InvitedUserInput, XfdfTypes } from '../../../types/resolvers-types';
 export declare type UserAuth = {
@@ -29,3 +34,2 @@ id: string;
     cookieOptions: CookieOptions;
-    jwtCookieName: string;
     cache: ContextCache;
@@ -41,6 +45,5 @@ resolvers: UserResolvers;
     subscriptionFields: Record<string, RequestedFields>;
-    customContextCookieName: string;
-    customContextJWT: string | null;
-    customContext: Record<any, any>;
+    customContext: CustomContext;
     xfdfFormat?: XfdfTypes;
+    cookies: Record<any, any>;
 };
@@ -58,3 +61,3 @@ /**
  */
-export declare type GetUserFromToken = (token: string, context: CustomContext) => Promise<UserAuth> | UserAuth;
+export declare type GetUserFromToken = (token: string, context: CustomContext, cookies: Record<any, any>) => Promise<UserAuth> | UserAuth;
 /**
@@ -111,2 +114,3 @@ * @ignore
     logLevel?: Logging;
+    filterLogsByTag?: Tags;
     logTransports?: Array<winston.transport>;
@@ -117,3 +121,2 @@ customQueries?: CollabServerCustomQueriesOptions;
     getUserFromToken?: GetUserFromToken;
-    jwtCookieName?: string;
     cookieOptions?: CookieOptions;
@@ -125,2 +128,6 @@ permissions?: UserPermissionSetting;
     private server;
+    private subscriptionServer;
+    private httpServer;
+    private corsOption;
+    private app;
     constructor(options: CollabServerOptions);
@@ -137,2 +144,3 @@ static LogLevels: {
     };
+    static LogTags: typeof Tags;
     static sendGridEmailHandler: (emailServiceOptions: import("./email/sendGridEmailHandler").EmailServiceOptions) => EmailFunction;
@@ -158,4 +166,4 @@ static Permissions: {
     };
-    start(port?: number): Promise<void>;
-    stop(): Promise<void>;
+    start(port?: number): Promise<HttpServer>;
+    stop(): void;
 }
@@ -162,0 +170,0 @@ export default CollabServer;

types/packages/collab-server/src/resolvers/Mutation/Context.d.ts

@@ -1,11 +0,7 @@
-import { MutationSetContextArgs, MutationUpdateContextArgs } from './../../../../../types/resolvers-types';
 import { Context } from '../..';
-export declare const readContext: (jwtString?: string) => Promise<unknown>;
 declare const _default: {
-    setContext: (_: any, args: MutationSetContextArgs, context: Context) => any;
-    updateContext: (_: any, args: MutationUpdateContextArgs, context: Context) => Promise<{
-        data: any;
+    encodeContext: (p: any, args: any, context: Context) => Promise<{
+        token: string;
     }>;
-    deleteContext: (_: any, __: any, context: Context) => boolean;
 };
 export default _default;

types/packages/collab-server/src/resolvers/Mutation/Mutation.d.ts

 declare const Mutation: {
-    setContext: (_: any, args: import("../../../../../types/resolvers-types").MutationSetContextArgs, context: import("../..").Context) => any;
-    updateContext: (_: any, args: import("../../../../../types/resolvers-types").MutationUpdateContextArgs, context: import("../..").Context) => Promise<{
-        data: any;
+    encodeContext: (p: any, args: any, context: import("../..").Context) => Promise<{
+        token: string;
     }>;
-    deleteContext: (_: any, __: any, context: import("../..").Context) => boolean;
     editScrollSync: (p: any, args: any, context: import("../..").Context) => {
@@ -56,8 +54,9 @@ position: any;
         user: import("../..").ApolloUser;
+        token: string;
     }>;
     login: (p: any, args: any, context: import("../..").Context) => Promise<{
         user: import("../..").ApolloDatabaseUser;
+        token: string;
     }>;
-    endSession: (p: any, args: any, context: import("../..").Context) => Promise<boolean>;
 };
 export default Mutation;

types/packages/collab-server/src/resolvers/Mutation/User.d.ts

@@ -6,8 +6,9 @@ import { Context } from './../../index';
         user: import("./../../index").ApolloUser;
+        token: string;
     }>;
     login: (p: any, args: any, context: Context) => Promise<{
         user: import("../../resolvers").ApolloDatabaseUser;
+        token: string;
     }>;
-    endSession: (p: any, args: any, context: Context) => Promise<boolean>;
 };
 export default _default;

types/packages/collab-server/src/resolvers/Subscription.d.ts

@@ -7,18 +7,18 @@ import type { AnnotationChangedPayload } from '../entities/Annotation';
         resolve: (payload: AnnotationChangedPayload, variables: SubscriptionAnnotationChangedArgs) => import("../../../../types/resolvers-types").AnnotationSubscriptionEvent;
-        subscribe: import("apollo-server").ResolverFn;
+        subscribe: import("graphql-subscriptions").ResolverFn;
     };
     documentChanged: {
         resolve: (payload: DocumentChangedPayload, variables: SubscriptionDocumentChangedArgs) => import("../../../../types/resolvers-types").DocumentSubscriptionEvent;
-        subscribe: import("apollo-server").ResolverFn;
+        subscribe: import("graphql-subscriptions").ResolverFn;
     };
     scrollPositionChanged: {
-        subscribe: import("apollo-server").ResolverFn;
+        subscribe: import("graphql-subscriptions").ResolverFn;
     };
     connectedDocUsersChanged: {
-        subscribe: import("apollo-server").ResolverFn;
+        subscribe: import("graphql-subscriptions").ResolverFn;
     };
     mentionChanged: {
-        subscribe: import("apollo-server").ResolverFn;
+        subscribe: import("graphql-subscriptions").ResolverFn;
     };
 };
 export default _default;

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

 import ConnectedUserMap from '../util/ConnectedUserMap';
-import type { PubSub } from 'apollo-server';
+import type { PubSub } from 'graphql-subscriptions';
 export declare const leaveScrollSyncEvent: (disconnectedUserId: string, pubsub: PubSub, connectedUsers: ConnectedUserMap) => void;
 export declare const leaveConnectedDocUsersMap: (disconnectedUserId: string, pubsub: PubSub, connectedUsers: ConnectedUserMap) => void;

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

@@ -1,1 +0,1 @@
-export declare const retrieveCookie: (cookieStr: string, jwtCookieName: string) => string;
+export declare const retrieveCookie: (cookieStr: string, cookieName: string) => string;

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

@@ -49,2 +49,3 @@ import { Knex } from 'knex';
 export interface DataOption<EntityType, DataType> {
+    from: string;
     entity: GeneratorEntityWithMap<EntityType>;
@@ -57,2 +58,3 @@ data: DataType;
 export interface MutationWithoutRerturnOption<EntityType> {
+    from: string;
     id?: string;
@@ -59,0 +61,0 @@ entity: GeneratorEntityWithMap<EntityType>;

types/shared/log/logger.d.ts

@@ -6,3 +6,4 @@ import winston from 'winston';
     QUERY = "QUERY",
-    RESPONSE = "RESPONSE"
+    RESPONSE = "RESPONSE",
+    AUTH = "AUTH"
 }
@@ -21,3 +22,3 @@ export declare type Logging = 'error' | 'warn' | 'info' | 'http' | 'verbose' | 'debug' | 'silly' | 'none';
 declare const logger: winston.Logger;
-export declare const setupLogger: (logLevel: Logging, logTransports: Array<winston.transport>) => void;
+export declare const setupLogger: (logLevel: Logging, logTransports: Array<winston.transport>, filterByTag?: Tags) => void;
 export default logger;

types/shared/log/transports.d.ts

 import winston from 'winston';
-import { Logging } from './logger';
-export declare const addConsoleTransport: (logger: winston.Logger, level?: Logging) => void;
+import { Logging, Tags } from './logger';
+export declare const addConsoleTransport: (logger: winston.Logger, level?: Logging, filterByTag?: Tags) => void;
 export declare const addTransports: (logger: winston.Logger, transports: Array<winston.transport>) => void;

types/types/global-graphql-types.d.ts

@@ -7,2 +7,6 @@ export declare enum ChangeEventTypes {
 }
+export declare enum EncodeContextActions {
+    MERGE = "MERGE",
+    SET = "SET"
+}
 export declare enum OrderDirections {
@@ -20,2 +24,8 @@ ASC = "ASC",
 }
+export declare enum XFDFTypes {
+    COMMAND_ADD = "COMMAND_ADD",
+    COMMAND_ALL = "COMMAND_ALL",
+    COMMAND_MODIFY = "COMMAND_MODIFY",
+    RAW = "RAW"
+}
 export interface DeleteAnnotationMemberInput {
@@ -112,1 +122,4 @@ memberId?: string | null;
 }
+export interface QuerySettings {
+    xfdfFormat?: XFDFTypes | null;
+}

types/types/resolvers-types.d.ts

@@ -108,2 +108,6 @@ import { GraphQLResolveInfo, GraphQLScalarType, GraphQLScalarTypeConfig } from 'graphql';
 };
+export declare type ContextResult = {
+    __typename?: 'ContextResult';
+    token: Scalars['String'];
+};
 export declare type ConnectResult = {
@@ -323,3 +327,2 @@ __typename?: 'ConnectResult';
     loginAnonymous: AuthPayload;
-    endSession?: Maybe<Scalars['Boolean']>;
     addMention: Mention;
@@ -334,5 +337,3 @@ editMention: Mention;
     deleteConnectedDocUser: DeleteResult;
-    setContext: ContextResult;
-    updateContext: ContextResult;
-    deleteContext: Scalars['Boolean'];
+    encodeContext: ContextResult;
 };
@@ -444,12 +445,10 @@ export declare type MutationAddAnnotationArgs = {
 };
-export declare type MutationSetContextArgs = {
-    data?: Maybe<Scalars['JSON']>;
+export declare type MutationEncodeContextArgs = {
+    context: Scalars['String'];
+    action: EncodeContextActions;
 };
-export declare type MutationUpdateContextArgs = {
-    data: Scalars['JSON'];
-};
-export declare type ContextResult = {
-    __typename?: 'ContextResult';
-    data?: Maybe<Scalars['JSON']>;
-};
+export declare enum EncodeContextActions {
+    Set = "SET",
+    Merge = "MERGE"
+}
 export declare enum ChangeEventTypes {
@@ -519,2 +518,3 @@ Add = "ADD",
     user?: Maybe<User>;
+    token?: Maybe<Scalars['String']>;
 };
@@ -585,2 +585,3 @@ export declare type IgnoreMembership = {
     DeleteResult: ResolverTypeWrapper<DeleteResult>;
+    ContextResult: ResolverTypeWrapper<ContextResult>;
     ConnectResult: ResolverTypeWrapper<ConnectResult>;
@@ -613,3 +614,3 @@ Mention: ResolverTypeWrapper<Mention>;
     Mutation: ResolverTypeWrapper<{}>;
-    ContextResult: ResolverTypeWrapper<ContextResult>;
+    EncodeContextActions: EncodeContextActions;
     ChangeEventTypes: ChangeEventTypes;
@@ -642,2 +643,3 @@ AnnotationSubscriptionEvent: ResolverTypeWrapper<AnnotationSubscriptionEvent>;
     DeleteResult: DeleteResult;
+    ContextResult: ContextResult;
     ConnectResult: ConnectResult;
@@ -670,3 +672,2 @@ Mention: Mention;
     Mutation: {};
-    ContextResult: ContextResult;
     AnnotationSubscriptionEvent: AnnotationSubscriptionEvent;
@@ -757,2 +758,6 @@ DocumentSubscriptionEvent: DocumentSubscriptionEvent;
 }>;
+export declare type ContextResultResolvers<ContextType = any, ParentType extends ResolversParentTypes['ContextResult'] = ResolversParentTypes['ContextResult']> = ResolversObject<{
+    token?: Resolver<ResolversTypes['String'], ParentType, ContextType>;
+    __isTypeOf?: IsTypeOfResolverFn<ParentType>;
+}>;
 export declare type ConnectResultResolvers<ContextType = any, ParentType extends ResolversParentTypes['ConnectResult'] = ResolversParentTypes['ConnectResult']> = ResolversObject<{
@@ -824,3 +829,2 @@ userId?: Resolver<Maybe<ResolversTypes['ID']>, ParentType, ContextType>;
     loginAnonymous?: Resolver<ResolversTypes['AuthPayload'], ParentType, ContextType, RequireFields<MutationLoginAnonymousArgs, never>>;
-    endSession?: Resolver<Maybe<ResolversTypes['Boolean']>, ParentType, ContextType>;
     addMention?: Resolver<ResolversTypes['Mention'], ParentType, ContextType, RequireFields<MutationAddMentionArgs, never>>;
@@ -835,10 +839,4 @@ editMention?: Resolver<ResolversTypes['Mention'], ParentType, ContextType, RequireFields<MutationEditMentionArgs, 'userId' | 'annotationId'>>;
     deleteConnectedDocUser?: Resolver<ResolversTypes['DeleteResult'], ParentType, ContextType, RequireFields<MutationDeleteConnectedDocUserArgs, 'input'>>;
-    setContext?: Resolver<ResolversTypes['ContextResult'], ParentType, ContextType, RequireFields<MutationSetContextArgs, never>>;
-    updateContext?: Resolver<ResolversTypes['ContextResult'], ParentType, ContextType, RequireFields<MutationUpdateContextArgs, 'data'>>;
-    deleteContext?: Resolver<ResolversTypes['Boolean'], ParentType, ContextType>;
+    encodeContext?: Resolver<ResolversTypes['ContextResult'], ParentType, ContextType, RequireFields<MutationEncodeContextArgs, 'context' | 'action'>>;
 }>;
-export declare type ContextResultResolvers<ContextType = any, ParentType extends ResolversParentTypes['ContextResult'] = ResolversParentTypes['ContextResult']> = ResolversObject<{
-    data?: Resolver<Maybe<ResolversTypes['JSON']>, ParentType, ContextType>;
-    __isTypeOf?: IsTypeOfResolverFn<ParentType>;
-}>;
 export declare type AnnotationSubscriptionEventResolvers<ContextType = any, ParentType extends ResolversParentTypes['AnnotationSubscriptionEvent'] = ResolversParentTypes['AnnotationSubscriptionEvent']> = ResolversObject<{
@@ -883,2 +881,3 @@ annotation?: Resolver<ResolversTypes['Annotation'], ParentType, ContextType>;
     user?: Resolver<Maybe<ResolversTypes['User']>, ParentType, ContextType>;
+    token?: Resolver<Maybe<ResolversTypes['String']>, ParentType, ContextType>;
     __isTypeOf?: IsTypeOfResolverFn<ParentType>;
@@ -909,2 +908,3 @@ }>;
     DeleteResult?: DeleteResultResolvers<ContextType>;
+    ContextResult?: ContextResultResolvers<ContextType>;
     ConnectResult?: ConnectResultResolvers<ContextType>;
@@ -918,3 +918,2 @@ Mention?: MentionResolvers<ContextType>;
     Mutation?: MutationResolvers<ContextType>;
-    ContextResult?: ContextResultResolvers<ContextType>;
     AnnotationSubscriptionEvent?: AnnotationSubscriptionEventResolvers<ContextType>;
@@ -921,0 +920,0 @@ DocumentSubscriptionEvent?: DocumentSubscriptionEventResolvers<ContextType>;

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

141569

increased by0.8%

Number of package files

62

increased by3.33%

Lines of code

2373

increased by0.98%

No dependency changes