@trpc/server - npm Package Compare versions

Comparing version 1.4.1 to 1.4.3

dist/http.d.ts

@@ -16,3 +16,2 @@ /// <reference types="node" />
     notFound: (message?: string | undefined) => HTTPError;
-    payloadTooLarge: (message?: string | undefined) => HTTPError;
 };
@@ -19,0 +18,0 @@ export declare type HTTPSuccessResponseEnvelope<TOutput> = {

dist/router.d.ts

@@ -28,3 +28,3 @@ import { Subscription } from './subscription';
 export declare type inferRouteOutput<TRoute extends Route> = inferAsyncReturnType<TRoute['resolve']>;
-export declare type inferSubscriptionOutput<TRouter extends AnyRouter, TPath extends keyof TRouter['_def']['subscriptions']> = TRouter[TPath] extends Subscription<infer TData> ? TData : never;
+export declare type inferSubscriptionOutput<TRouter extends AnyRouter, TPath extends keyof TRouter['_def']['subscriptions']> = ReturnType<inferAsyncReturnType<TRouter['_def']['subscriptions'][TPath]['resolve']>['output']>;
 export declare type inferHandlerFn<TRoutes extends RouteRecord<any, any, any>> = <TPath extends keyof TRoutes & string, TRoute extends TRoutes[TPath]>(path: TPath, ...args: TRoute extends RouteWithInput<any, any, any> ? [inferRouteInput<TRoute>] : [undefined?]) => Promise<inferRouteOutput<TRoutes[TPath]>>;
@@ -31,0 +31,0 @@ export declare type AnyRouter<TContext = any> = Router<TContext, any, any, any>;

dist/server.cjs.development.js

@@ -952,5 +952,2 @@ 'use strict';
     return new HTTPError(404, message != null ? message : 'Not found');
-  },
-  payloadTooLarge: function payloadTooLarge(message) {
-    return new HTTPError(413, message != null ? message : 'Payload Too Large');
   }
@@ -1027,3 +1024,3 @@ };
                 if (typeof maxBodySize === 'number' && body.length > maxBodySize) {
-                  reject(httpError.payloadTooLarge());
+                  reject(new HTTPError(413, 'Payload Too Large'));
                   req.connection.destroy();
@@ -1203,3 +1200,3 @@ }
 
-                if (requestTimeLeft >= backpressureMs) {
+                if (requestTimeLeft <= backpressureMs) {
                   // will timeout before next backpressure tick
@@ -1572,27 +1569,12 @@ success();
     return start;
-  }();
-
-  _proto.onceOutputAndStop = /*#__PURE__*/function () {
-    var _onceOutputAndStop = /*#__PURE__*/_asyncToGenerator( /*#__PURE__*/runtime_1.mark(function _callee2() {
-      return runtime_1.wrap(function _callee2$(_context2) {
-        while (1) {
-          switch (_context2.prev = _context2.next) {
-            case 0:
-              throw new Error('Legacy');
-
-            case 1:
-            case "end":
-              return _context2.stop();
-          }
-        }
-      }, _callee2);
-    }));
-
-    function onceOutputAndStop() {
-      return _onceOutputAndStop.apply(this, arguments);
-    }
-
-    return onceOutputAndStop;
   }()
   /**
+   * This method is just here to help with `inferSubscriptionOutput` which I can't get working without it
+   */
+  ;
+
+  _proto.output = function output() {
+    throw new Error('Legacy');
+  }
+  /**
    * Emit data
@@ -1638,27 +1620,27 @@ */
   function _pull2() {
-    _pull2 = _asyncToGenerator( /*#__PURE__*/runtime_1.mark(function _callee3(emit) {
-      return runtime_1.wrap(function _callee3$(_context3) {
+    _pull2 = _asyncToGenerator( /*#__PURE__*/runtime_1.mark(function _callee2(emit) {
+      return runtime_1.wrap(function _callee2$(_context2) {
         while (1) {
-          switch (_context3.prev = _context3.next) {
+          switch (_context2.prev = _context2.next) {
             case 0:
               if (!stopped) {
-                _context3.next = 2;
+                _context2.next = 2;
                 break;
               }
 
-              return _context3.abrupt("return");
+              return _context2.abrupt("return");
 
             case 2:
-              _context3.prev = 2;
-              _context3.next = 5;
+              _context2.prev = 2;
+              _context2.next = 5;
               return opts.pull(emit);
 
             case 5:
-              _context3.next = 10;
+              _context2.next = 10;
               break;
 
             case 7:
-              _context3.prev = 7;
-              _context3.t0 = _context3["catch"](2);
-              emit.error(_context3.t0);
+              _context2.prev = 7;
+              _context2.t0 = _context2["catch"](2);
+              emit.error(_context2.t0);
 
@@ -1674,6 +1656,6 @@ case 10:
             case "end":
-              return _context3.stop();
+              return _context2.stop();
           }
         }
-      }, _callee3, null, [[2, 7]]);
+      }, _callee2, null, [[2, 7]]);
     }));
@@ -1680,0 +1662,0 @@ return _pull2.apply(this, arguments);

dist/server.cjs.production.min.js

@@ -1,2 +0,2 @@
-"use strict";function t(t){return t&&"object"==typeof t&&"default"in t?t.default:t}Object.defineProperty(exports,"__esModule",{value:!0});var e=t(require("url")),r=require("events"),n=t(require("http"));function o(){if("undefined"!=typeof window&&void 0===process.env.JEST_WORKER_ID)throw new Error("Imported server-only code in the broowser")}function i(t,e,r,n,o,i,u){try{var a=t[i](u),s=a.value}catch(t){return void r(t)}a.done?e(s):Promise.resolve(s).then(n,o)}function u(t){return function(){var e=this,r=arguments;return new Promise((function(n,o){var u=t.apply(e,r);function a(t){i(u,n,o,a,s,"next",t)}function s(t){i(u,n,o,a,s,"throw",t)}a(void 0)}))}}function a(){return(a=Object.assign||function(t){for(var e=1;e<arguments.length;e++){var r=arguments[e];for(var n in r)Object.prototype.hasOwnProperty.call(r,n)&&(t[n]=r[n])}return t}).apply(this,arguments)}function s(t,e){t.prototype=Object.create(e.prototype),t.prototype.constructor=t,t.__proto__=e}function c(t){return(c=Object.setPrototypeOf?Object.getPrototypeOf:function(t){return t.__proto__||Object.getPrototypeOf(t)})(t)}function f(t,e){return(f=Object.setPrototypeOf||function(t,e){return t.__proto__=e,t})(t,e)}function p(){if("undefined"==typeof Reflect||!Reflect.construct)return!1;if(Reflect.construct.sham)return!1;if("function"==typeof Proxy)return!0;try{return Date.prototype.toString.call(Reflect.construct(Date,[],(function(){}))),!0}catch(t){return!1}}function l(t,e,r){return(l=p()?Reflect.construct:function(t,e,r){var n=[null];n.push.apply(n,e);var o=new(Function.bind.apply(t,n));return r&&f(o,r.prototype),o}).apply(null,arguments)}function h(t){var e="function"==typeof Map?new Map:void 0;return(h=function(t){if(null===t||-1===Function.toString.call(t).indexOf("[native code]"))return t;if("function"!=typeof t)throw new TypeError("Super expression must either be null or a function");if(void 0!==e){if(e.has(t))return e.get(t);e.set(t,r)}function r(){return l(t,arguments,c(this).constructor)}return r.prototype=Object.create(t.prototype,{constructor:{value:r,enumerable:!1,writable:!0,configurable:!0}}),f(r,t)})(t)}function d(t){if(void 0===t)throw new ReferenceError("this hasn't been initialised - super() hasn't been called");return t}function v(t,e){return t(e={exports:{}},e.exports),e.exports}var y=v((function(t){var e=function(t){var e=Object.prototype,r=e.hasOwnProperty,n="function"==typeof Symbol?Symbol:{},o=n.iterator||"@@iterator",i=n.asyncIterator||"@@asyncIterator",u=n.toStringTag||"@@toStringTag";function a(t,e,r){return Object.defineProperty(t,e,{value:r,enumerable:!0,configurable:!0,writable:!0}),t[e]}try{a({},"")}catch(t){a=function(t,e,r){return t[e]=r}}function s(t,e,r,n){var o=Object.create((e&&e.prototype instanceof p?e:p).prototype),i=new O(n||[]);return o._invoke=function(t,e,r){var n="suspendedStart";return function(o,i){if("executing"===n)throw new Error("Generator is already running");if("completed"===n){if("throw"===o)throw i;return{value:void 0,done:!0}}for(r.method=o,r.arg=i;;){var u=r.delegate;if(u){var a=g(u,r);if(a){if(a===f)continue;return a}}if("next"===r.method)r.sent=r._sent=r.arg;else if("throw"===r.method){if("suspendedStart"===n)throw n="completed",r.arg;r.dispatchException(r.arg)}else"return"===r.method&&r.abrupt("return",r.arg);n="executing";var s=c(t,e,r);if("normal"===s.type){if(n=r.done?"completed":"suspendedYield",s.arg===f)continue;return{value:s.arg,done:r.done}}"throw"===s.type&&(n="completed",r.method="throw",r.arg=s.arg)}}}(t,r,i),o}function c(t,e,r){try{return{type:"normal",arg:t.call(e,r)}}catch(t){return{type:"throw",arg:t}}}t.wrap=s;var f={};function p(){}function l(){}function h(){}var d={};d[o]=function(){return this};var v=Object.getPrototypeOf,y=v&&v(v(k([])));y&&y!==e&&r.call(y,o)&&(d=y);var m=h.prototype=p.prototype=Object.create(d);function w(t){["next","throw","return"].forEach((function(e){a(t,e,(function(t){return this._invoke(e,t)}))}))}function x(t,e){var n;this._invoke=function(o,i){function u(){return new e((function(n,u){!function n(o,i,u,a){var s=c(t[o],t,i);if("throw"!==s.type){var f=s.arg,p=f.value;return p&&"object"==typeof p&&r.call(p,"__await")?e.resolve(p.__await).then((function(t){n("next",t,u,a)}),(function(t){n("throw",t,u,a)})):e.resolve(p).then((function(t){f.value=t,u(f)}),(function(t){return n("throw",t,u,a)}))}a(s.arg)}(o,i,n,u)}))}return n=n?n.then(u,u):u()}}function g(t,e){var r=t.iterator[e.method];if(void 0===r){if(e.delegate=null,"throw"===e.method){if(t.iterator.return&&(e.method="return",e.arg=void 0,g(t,e),"throw"===e.method))return f;e.method="throw",e.arg=new TypeError("The iterator does not provide a 'throw' method")}return f}var n=c(r,t.iterator,e.arg);if("throw"===n.type)return e.method="throw",e.arg=n.arg,e.delegate=null,f;var o=n.arg;return o?o.done?(e[t.resultName]=o.value,e.next=t.nextLoc,"return"!==e.method&&(e.method="next",e.arg=void 0),e.delegate=null,f):o:(e.method="throw",e.arg=new TypeError("iterator result is not an object"),e.delegate=null,f)}function b(t){var e={tryLoc:t[0]};1 in t&&(e.catchLoc=t[1]),2 in t&&(e.finallyLoc=t[2],e.afterLoc=t[3]),this.tryEntries.push(e)}function E(t){var e=t.completion||{};e.type="normal",delete e.arg,t.completion=e}function O(t){this.tryEntries=[{tryLoc:"root"}],t.forEach(b,this),this.reset(!0)}function k(t){if(t){var e=t[o];if(e)return e.call(t);if("function"==typeof t.next)return t;if(!isNaN(t.length)){var n=-1,i=function e(){for(;++n<t.length;)if(r.call(t,n))return e.value=t[n],e.done=!1,e;return e.value=void 0,e.done=!0,e};return i.next=i}}return{next:_}}function _(){return{value:void 0,done:!0}}return l.prototype=m.constructor=h,h.constructor=l,l.displayName=a(h,u,"GeneratorFunction"),t.isGeneratorFunction=function(t){var e="function"==typeof t&&t.constructor;return!!e&&(e===l||"GeneratorFunction"===(e.displayName||e.name))},t.mark=function(t){return Object.setPrototypeOf?Object.setPrototypeOf(t,h):(t.__proto__=h,a(t,u,"GeneratorFunction")),t.prototype=Object.create(m),t},t.awrap=function(t){return{__await:t}},w(x.prototype),x.prototype[i]=function(){return this},t.AsyncIterator=x,t.async=function(e,r,n,o,i){void 0===i&&(i=Promise);var u=new x(s(e,r,n,o),i);return t.isGeneratorFunction(r)?u:u.next().then((function(t){return t.done?t.value:u.next()}))},w(m),a(m,u,"Generator"),m[o]=function(){return this},m.toString=function(){return"[object Generator]"},t.keys=function(t){var e=[];for(var r in t)e.push(r);return e.reverse(),function r(){for(;e.length;){var n=e.pop();if(n in t)return r.value=n,r.done=!1,r}return r.done=!0,r}},t.values=k,O.prototype={constructor:O,reset:function(t){if(this.prev=0,this.next=0,this.sent=this._sent=void 0,this.done=!1,this.delegate=null,this.method="next",this.arg=void 0,this.tryEntries.forEach(E),!t)for(var e in this)"t"===e.charAt(0)&&r.call(this,e)&&!isNaN(+e.slice(1))&&(this[e]=void 0)},stop:function(){this.done=!0;var t=this.tryEntries[0].completion;if("throw"===t.type)throw t.arg;return this.rval},dispatchException:function(t){if(this.done)throw t;var e=this;function n(r,n){return u.type="throw",u.arg=t,e.next=r,n&&(e.method="next",e.arg=void 0),!!n}for(var o=this.tryEntries.length-1;o>=0;--o){var i=this.tryEntries[o],u=i.completion;if("root"===i.tryLoc)return n("end");if(i.tryLoc<=this.prev){var a=r.call(i,"catchLoc"),s=r.call(i,"finallyLoc");if(a&&s){if(this.prev<i.catchLoc)return n(i.catchLoc,!0);if(this.prev<i.finallyLoc)return n(i.finallyLoc)}else if(a){if(this.prev<i.catchLoc)return n(i.catchLoc,!0)}else{if(!s)throw new Error("try statement without catch or finally");if(this.prev<i.finallyLoc)return n(i.finallyLoc)}}}},abrupt:function(t,e){for(var n=this.tryEntries.length-1;n>=0;--n){var o=this.tryEntries[n];if(o.tryLoc<=this.prev&&r.call(o,"finallyLoc")&&this.prev<o.finallyLoc){var i=o;break}}i&&("break"===t||"continue"===t)&&i.tryLoc<=e&&e<=i.finallyLoc&&(i=null);var u=i?i.completion:{};return u.type=t,u.arg=e,i?(this.method="next",this.next=i.finallyLoc,f):this.complete(u)},complete:function(t,e){if("throw"===t.type)throw t.arg;return"break"===t.type||"continue"===t.type?this.next=t.arg:"return"===t.type?(this.rval=this.arg=t.arg,this.method="return",this.next="end"):"normal"===t.type&&e&&(this.next=e),f},finish:function(t){for(var e=this.tryEntries.length-1;e>=0;--e){var r=this.tryEntries[e];if(r.finallyLoc===t)return this.complete(r.completion,r.afterLoc),E(r),f}},catch:function(t){for(var e=this.tryEntries.length-1;e>=0;--e){var r=this.tryEntries[e];if(r.tryLoc===t){var n=r.completion;if("throw"===n.type){var o=n.arg;E(r)}return o}}throw new Error("illegal catch attempt")},delegateYield:function(t,e,r){return this.delegate={iterator:k(t),resultName:e,nextLoc:r},"next"===this.method&&(this.arg=void 0),f}},t}(t.exports);try{regeneratorRuntime=e}catch(t){Function("r","regeneratorRuntime = r")(e)}})),m=function(t){function e(r){var n;return(n=t.call(this,r.message)||this).originalError=r,Object.setPrototypeOf(d(n),e.prototype),n}return s(e,t),e}(h(Error)),w=function(t){function e(r){var n;return n=t.call(this,r)||this,Object.setPrototypeOf(d(n),e.prototype),n}return s(e,t),e}(h(Error));o();var x=function(t){function e(r,n){var o;return(o=t.call(this,n)||this).statusCode=r,Object.setPrototypeOf(d(o),e.prototype),o}return s(e,t),e}(h(Error)),g={forbidden:function(t){return new x(403,null!=t?t:"Forbidden")},unauthorized:function(t){return new x(401,null!=t?t:"Unauthorized")},badRequest:function(t){return new x(400,null!=t?t:"Bad Request")},notFound:function(t){return new x(404,null!=t?t:"Not found")},payloadTooLarge:function(t){return new x(413,null!=t?t:"Payload Too Large")}};function b(t){var e,r,n=t;return n instanceof m?n=g.badRequest(n.message):n instanceof w&&(n=g.notFound(n.message)),{ok:!1,statusCode:"number"==typeof(null==(e=n)?void 0:e.statusCode)?n.statusCode:500,error:{message:"string"==typeof(null==(r=n)?void 0:r.message)?n.message:"Internal Server Error",stack:void 0}}}function E(t){var e=void 0,r=t.input;if(!r)return e;if("string"!=typeof r)throw g.badRequest("Expected query.input to be a JSON string");try{e=JSON.parse(r)}catch(t){throw g.badRequest("Expected query.input to be a JSON string")}return e}function O(t){return k.apply(this,arguments)}function k(){return(k=u(y.mark((function t(e){var r,n;return y.wrap((function(t){for(;;)switch(t.prev=t.next){case 0:return r=e.req,n=e.maxBodySize,t.abrupt("return",new Promise((function(t,e){if(r.body)t(r.body);else{var o="";r.on("data",(function(t){o+=t,"number"==typeof n&&o.length>n&&(e(g.payloadTooLarge()),r.connection.destroy())})),r.on("end",(function(){try{var r=JSON.parse(o);t(r)}catch(t){e(g.badRequest("Body couldn't be parsed as json"))}}))}})));case 2:case"end":return t.stop()}}),t)})))).apply(this,arguments)}function _(t){return q.apply(this,arguments)}function q(){return(q=u(y.mark((function t(r){var n,o,i,u,a,s,c,f,p,l,h,d,v,m,w,k,_,q,j,L,S,T,P;return y.wrap((function(t){for(;;)switch(t.prev=t.next){case 0:if(n=r.req,o=r.res,i=r.router,u=r.path,a=r.subscriptions,s=r.createContext,c=r.teardown,p=void 0===(f=r.transformer)?{serialize:function(t){return t},deserialize:function(t){return t}}:f,l=r.maxBodySize,t.prev=1,t.t0=s,!t.t0){t.next=7;break}return t.next=6,s({req:n,res:o});case 6:t.t0=t.sent;case 7:if(m=t.t0,w=null!=(h=n.method)?h:"GET",k=function(t){return t?p.deserialize(t):t},"POST"!==w){t.next=20;break}return t.next=13,O({req:n,maxBodySize:l});case 13:return _=k(t.sent.input),t.next=17,i.invoke({target:"mutations",input:_,ctx:m,path:u});case 17:v=t.sent,t.next=42;break;case 20:if("GET"!==w){t.next=28;break}return q=n.query?n.query:e.parse(n.url,!0).query,j=k(E(q)),t.next=25,i.invoke({target:"queries",input:j,ctx:m,path:u});case 25:v=t.sent,t.next=42;break;case 28:if("PATCH"!==w){t.next=41;break}return t.next=31,O({req:n,maxBodySize:l});case 31:return L=k(t.sent.input),t.next=35,i.invoke({target:"subscriptions",input:L,ctx:m,path:u});case 35:return S=t.sent,t.next=38,new Promise((function(t,e){var r,o,i=Date.now(),u=[],s=null!=(r=null==a?void 0:a.requestTimeoutMs)?r:9e3,c=null!=(o=null==a?void 0:a.backpressureMs)?o:0,f=null,p=null;function l(){S.off("data",h),S.off("error",d),S.off("destroy",y),n.off("close",v),clearTimeout(p),clearTimeout(f),S.destroy()}function h(e){u.push(e);var r=function(){l(),t(u)};s-(Date.now()-i)>=c?r():f||(f=setTimeout(r,c))}function d(t){l(),e(t)}function v(){l(),e(new x(499,"Client Closed Request"))}function y(){e(new x(500,"Subscription was destroyed prematurely")),l()}S.on("data",h),S.on("error",d),S.on("destroy",y),n.once("close",v),p=setTimeout((function(){l(),e(new x(408,"Subscription exceeded "+s+"ms - please reconnect."))}),s),S.start()}));case 38:v=t.sent,t.next=42;break;case 41:throw g.badRequest("Unexpected request method "+w);case 42:T={ok:!0,statusCode:null!=(d=o.statusCode)?d:200,data:v},o.statusCode=T.statusCode,o.setHeader("Content-Type","application/json"),o.end(JSON.stringify(p.serialize(T))),t.next=54;break;case 48:t.prev=48,t.t1=t.catch(1),P=b(t.t1),o.statusCode=P.statusCode,o.setHeader("Content-Type","application/json"),o.end(JSON.stringify(p.serialize(P)));case 54:if(t.prev=54,t.t2=c,!t.t2){t.next=59;break}return t.next=59,c();case 59:t.next=64;break;case 61:t.prev=61,t.t3=t.catch(54),console.error("Teardown failed",t.t3);case 64:case"end":return t.stop()}}),t,null,[[1,48],[54,61]])})))).apply(this,arguments)}o();var j=function(){function t(t){this._def=null!=t?t:{queries:{},mutations:{},subscriptions:{}}}t.prefixRoutes=function(t,e){var r={};for(var n in t)r[e+n]=t[n];return r};var e=t.prototype;return e.query=function(e,r){var n,o=new t({queries:(n={},n[e]=r,n),mutations:{},subscriptions:{}});return this.merge(o)},e.mutation=function(e,r){var n,o=new t({queries:{},mutations:(n={},n[e]=r,n),subscriptions:{}});return this.merge(o)},e.subscription=function(e,r){var n,o=new t({queries:{},mutations:{},subscriptions:(n={},n[e]=r,n)});return this.merge(o)},e.merge=function(e,r){var n,o=this,i="";if("string"==typeof e&&r instanceof t)i=e,n=r;else{if(!(e instanceof t))throw new Error("Invalid args");n=e}var u=Object.keys(n._def.queries).filter((function(t){return o.has("queries",t)})),s=Object.keys(n._def.mutations).filter((function(t){return o.has("mutations",t)})),c=Object.keys(n._def.subscriptions).filter((function(t){return o.has("subscriptions",t)})),f=[].concat(u,s,c);if(f.length)throw new Error("Duplicate endpoint(s): "+f.join(", "));return new t({queries:a({},this._def.queries,t.prefixRoutes(n._def.queries,i)),mutations:a({},this._def.mutations,t.prefixRoutes(n._def.mutations,i)),subscriptions:a({},this._def.subscriptions,t.prefixRoutes(n._def.subscriptions,i))})},t.getInput=function(t,e){if(t.input)try{var r=t.input;if("function"==typeof r.parse)return r.parse(e);if("function"==typeof r)return r(e);if("function"==typeof r.validateSync)return r.validateSync(e);throw new Error("Could not find a validator fn")}catch(t){throw new m(t)}},e.invoke=function(){var e=u(y.mark((function e(r){var n,o;return y.wrap((function(e){for(;;)switch(e.prev=e.next){case 0:if(this.has(r.target,r.path)){e.next=2;break}throw new w('No such route "'+r.path+'"');case 2:return o=t.getInput(n=this._def[r.target][r.path],r.input),e.abrupt("return",n.resolve({ctx:r.ctx,input:o}));case 7:case"end":return e.stop()}}),e,this)})));return function(t){return e.apply(this,arguments)}}(),e.has=function(t,e){return!!this._def[t][e]},t}(),L=function(t){function e(){return t.apply(this,arguments)||this}return s(e,t),e}(r.EventEmitter),S=function(){function t(t){this.isDestroyed=!1,this.events=new L,this.opts=a({},t)}var e=t.prototype;return e.destroy=function(){this.isDestroyed||(this.isDestroyed=!0,this.events.emit("destroy"),this.events.removeAllListeners())},e.start=function(){var t=u(y.mark((function t(){var e,r,n=this;return y.wrap((function(t){for(;;)switch(t.prev=t.next){case 0:if(!this.isDestroyed){t.next=2;break}throw new Error("Called start() on a destroyed subscription");case 2:return t.prev=2,e={error:function(t){return n.emitError(t)},data:function(t){return n.emitOutput(t)}},t.next=6,this.opts.start(e);case 6:r=t.sent,this.isDestroyed?r():this.events.on("destroy",r),t.next=13;break;case 10:t.prev=10,t.t0=t.catch(2),this.emitError(t.t0);case 13:case"end":return t.stop()}}),t,this,[[2,10]])})));return function(){return t.apply(this,arguments)}}(),e.onceOutputAndStop=function(){var t=u(y.mark((function t(){return y.wrap((function(t){for(;;)switch(t.prev=t.next){case 0:throw new Error("Legacy");case 1:case"end":return t.stop()}}),t)})));return function(){return t.apply(this,arguments)}}(),e.emitOutput=function(t){this.events.emit("data",t)},e.emitError=function(t){this.events.emit("error",t)},e.on=function(){var t;return(t=this.events).on.apply(t,arguments)},e.off=function(){var t;return(t=this.events).off.apply(t,arguments)},t}();function T(t){return function(){var r=u(y.mark((function r(n,o){var i;return y.wrap((function(r){for(;;)switch(r.prev=r.next){case 0:return i=e.parse(n.url).pathname.substr(1),r.next=3,_(a({},t,{req:n,res:o,path:i}));case 3:case"end":return r.stop()}}),r)})));return function(t,e){return r.apply(this,arguments)}}()}exports.HTTPError=x,exports.Router=j,exports.Subscription=S,exports.assertNotBrowser=o,exports.createExpressMiddleware=function(t){return function(e,r){var n=e.path.substr(1);_(a({},t,{req:e,res:r,path:n}))}},exports.createHttpHandler=T,exports.createHttpServer=function(t){var e=T(t),r=n.createServer((function(t,r){return e(t,r)}));return{server:r,listen:function(t){return r.listen(t),{port:0===t?r.address().port:t}}}},exports.createNextApiHandler=function(t){return function(){var e=u(y.mark((function e(r,n){var o,i;return y.wrap((function(e){for(;;)switch(e.prev=e.next){case 0:if(null!==(o=Array.isArray(r.query.trpc)?r.query.trpc.join("/"):null)){e.next=5;break}return i=b(new Error('Query "trpc" not found - is the file named [...trpc].ts?')),n.status(i.statusCode).json(i),e.abrupt("return");case 5:return e.next=7,_(a({},t,{req:r,res:n,path:o}));case 7:case"end":return e.stop()}}),e)})));return function(t,r){return e.apply(this,arguments)}}()},exports.getErrorResponseEnvelope=b,exports.getQueryInput=E,exports.httpError=g,exports.requestHandler=_,exports.router=function(){return new j},exports.subscriptionPullFactory=function(t){var e,r=!1;function n(t){return o.apply(this,arguments)}function o(){return(o=u(y.mark((function o(i){return y.wrap((function(o){for(;;)switch(o.prev=o.next){case 0:if(!r){o.next=2;break}return o.abrupt("return");case 2:return o.prev=2,o.next=5,t.pull(i);case 5:o.next=10;break;case 7:o.prev=7,o.t0=o.catch(2),i.error(o.t0);case 10:r||(e=setTimeout((function(){return n(i)}),t.intervalMs));case 11:case"end":return o.stop()}}),o,null,[[2,7]])})))).apply(this,arguments)}return new S({start:function(t){return n(t),function(){clearTimeout(e),r=!0}}})};
+"use strict";function t(t){return t&&"object"==typeof t&&"default"in t?t.default:t}Object.defineProperty(exports,"__esModule",{value:!0});var e=t(require("url")),r=require("events"),n=t(require("http"));function o(){if("undefined"!=typeof window&&void 0===process.env.JEST_WORKER_ID)throw new Error("Imported server-only code in the broowser")}function i(t,e,r,n,o,i,u){try{var a=t[i](u),s=a.value}catch(t){return void r(t)}a.done?e(s):Promise.resolve(s).then(n,o)}function u(t){return function(){var e=this,r=arguments;return new Promise((function(n,o){var u=t.apply(e,r);function a(t){i(u,n,o,a,s,"next",t)}function s(t){i(u,n,o,a,s,"throw",t)}a(void 0)}))}}function a(){return(a=Object.assign||function(t){for(var e=1;e<arguments.length;e++){var r=arguments[e];for(var n in r)Object.prototype.hasOwnProperty.call(r,n)&&(t[n]=r[n])}return t}).apply(this,arguments)}function s(t,e){t.prototype=Object.create(e.prototype),t.prototype.constructor=t,t.__proto__=e}function c(t){return(c=Object.setPrototypeOf?Object.getPrototypeOf:function(t){return t.__proto__||Object.getPrototypeOf(t)})(t)}function f(t,e){return(f=Object.setPrototypeOf||function(t,e){return t.__proto__=e,t})(t,e)}function p(){if("undefined"==typeof Reflect||!Reflect.construct)return!1;if(Reflect.construct.sham)return!1;if("function"==typeof Proxy)return!0;try{return Date.prototype.toString.call(Reflect.construct(Date,[],(function(){}))),!0}catch(t){return!1}}function l(t,e,r){return(l=p()?Reflect.construct:function(t,e,r){var n=[null];n.push.apply(n,e);var o=new(Function.bind.apply(t,n));return r&&f(o,r.prototype),o}).apply(null,arguments)}function h(t){var e="function"==typeof Map?new Map:void 0;return(h=function(t){if(null===t||-1===Function.toString.call(t).indexOf("[native code]"))return t;if("function"!=typeof t)throw new TypeError("Super expression must either be null or a function");if(void 0!==e){if(e.has(t))return e.get(t);e.set(t,r)}function r(){return l(t,arguments,c(this).constructor)}return r.prototype=Object.create(t.prototype,{constructor:{value:r,enumerable:!1,writable:!0,configurable:!0}}),f(r,t)})(t)}function d(t){if(void 0===t)throw new ReferenceError("this hasn't been initialised - super() hasn't been called");return t}function v(t,e){return t(e={exports:{}},e.exports),e.exports}var y=v((function(t){var e=function(t){var e=Object.prototype,r=e.hasOwnProperty,n="function"==typeof Symbol?Symbol:{},o=n.iterator||"@@iterator",i=n.asyncIterator||"@@asyncIterator",u=n.toStringTag||"@@toStringTag";function a(t,e,r){return Object.defineProperty(t,e,{value:r,enumerable:!0,configurable:!0,writable:!0}),t[e]}try{a({},"")}catch(t){a=function(t,e,r){return t[e]=r}}function s(t,e,r,n){var o=Object.create((e&&e.prototype instanceof p?e:p).prototype),i=new O(n||[]);return o._invoke=function(t,e,r){var n="suspendedStart";return function(o,i){if("executing"===n)throw new Error("Generator is already running");if("completed"===n){if("throw"===o)throw i;return{value:void 0,done:!0}}for(r.method=o,r.arg=i;;){var u=r.delegate;if(u){var a=g(u,r);if(a){if(a===f)continue;return a}}if("next"===r.method)r.sent=r._sent=r.arg;else if("throw"===r.method){if("suspendedStart"===n)throw n="completed",r.arg;r.dispatchException(r.arg)}else"return"===r.method&&r.abrupt("return",r.arg);n="executing";var s=c(t,e,r);if("normal"===s.type){if(n=r.done?"completed":"suspendedYield",s.arg===f)continue;return{value:s.arg,done:r.done}}"throw"===s.type&&(n="completed",r.method="throw",r.arg=s.arg)}}}(t,r,i),o}function c(t,e,r){try{return{type:"normal",arg:t.call(e,r)}}catch(t){return{type:"throw",arg:t}}}t.wrap=s;var f={};function p(){}function l(){}function h(){}var d={};d[o]=function(){return this};var v=Object.getPrototypeOf,y=v&&v(v(_([])));y&&y!==e&&r.call(y,o)&&(d=y);var m=h.prototype=p.prototype=Object.create(d);function w(t){["next","throw","return"].forEach((function(e){a(t,e,(function(t){return this._invoke(e,t)}))}))}function x(t,e){var n;this._invoke=function(o,i){function u(){return new e((function(n,u){!function n(o,i,u,a){var s=c(t[o],t,i);if("throw"!==s.type){var f=s.arg,p=f.value;return p&&"object"==typeof p&&r.call(p,"__await")?e.resolve(p.__await).then((function(t){n("next",t,u,a)}),(function(t){n("throw",t,u,a)})):e.resolve(p).then((function(t){f.value=t,u(f)}),(function(t){return n("throw",t,u,a)}))}a(s.arg)}(o,i,n,u)}))}return n=n?n.then(u,u):u()}}function g(t,e){var r=t.iterator[e.method];if(void 0===r){if(e.delegate=null,"throw"===e.method){if(t.iterator.return&&(e.method="return",e.arg=void 0,g(t,e),"throw"===e.method))return f;e.method="throw",e.arg=new TypeError("The iterator does not provide a 'throw' method")}return f}var n=c(r,t.iterator,e.arg);if("throw"===n.type)return e.method="throw",e.arg=n.arg,e.delegate=null,f;var o=n.arg;return o?o.done?(e[t.resultName]=o.value,e.next=t.nextLoc,"return"!==e.method&&(e.method="next",e.arg=void 0),e.delegate=null,f):o:(e.method="throw",e.arg=new TypeError("iterator result is not an object"),e.delegate=null,f)}function b(t){var e={tryLoc:t[0]};1 in t&&(e.catchLoc=t[1]),2 in t&&(e.finallyLoc=t[2],e.afterLoc=t[3]),this.tryEntries.push(e)}function E(t){var e=t.completion||{};e.type="normal",delete e.arg,t.completion=e}function O(t){this.tryEntries=[{tryLoc:"root"}],t.forEach(b,this),this.reset(!0)}function _(t){if(t){var e=t[o];if(e)return e.call(t);if("function"==typeof t.next)return t;if(!isNaN(t.length)){var n=-1,i=function e(){for(;++n<t.length;)if(r.call(t,n))return e.value=t[n],e.done=!1,e;return e.value=void 0,e.done=!0,e};return i.next=i}}return{next:k}}function k(){return{value:void 0,done:!0}}return l.prototype=m.constructor=h,h.constructor=l,l.displayName=a(h,u,"GeneratorFunction"),t.isGeneratorFunction=function(t){var e="function"==typeof t&&t.constructor;return!!e&&(e===l||"GeneratorFunction"===(e.displayName||e.name))},t.mark=function(t){return Object.setPrototypeOf?Object.setPrototypeOf(t,h):(t.__proto__=h,a(t,u,"GeneratorFunction")),t.prototype=Object.create(m),t},t.awrap=function(t){return{__await:t}},w(x.prototype),x.prototype[i]=function(){return this},t.AsyncIterator=x,t.async=function(e,r,n,o,i){void 0===i&&(i=Promise);var u=new x(s(e,r,n,o),i);return t.isGeneratorFunction(r)?u:u.next().then((function(t){return t.done?t.value:u.next()}))},w(m),a(m,u,"Generator"),m[o]=function(){return this},m.toString=function(){return"[object Generator]"},t.keys=function(t){var e=[];for(var r in t)e.push(r);return e.reverse(),function r(){for(;e.length;){var n=e.pop();if(n in t)return r.value=n,r.done=!1,r}return r.done=!0,r}},t.values=_,O.prototype={constructor:O,reset:function(t){if(this.prev=0,this.next=0,this.sent=this._sent=void 0,this.done=!1,this.delegate=null,this.method="next",this.arg=void 0,this.tryEntries.forEach(E),!t)for(var e in this)"t"===e.charAt(0)&&r.call(this,e)&&!isNaN(+e.slice(1))&&(this[e]=void 0)},stop:function(){this.done=!0;var t=this.tryEntries[0].completion;if("throw"===t.type)throw t.arg;return this.rval},dispatchException:function(t){if(this.done)throw t;var e=this;function n(r,n){return u.type="throw",u.arg=t,e.next=r,n&&(e.method="next",e.arg=void 0),!!n}for(var o=this.tryEntries.length-1;o>=0;--o){var i=this.tryEntries[o],u=i.completion;if("root"===i.tryLoc)return n("end");if(i.tryLoc<=this.prev){var a=r.call(i,"catchLoc"),s=r.call(i,"finallyLoc");if(a&&s){if(this.prev<i.catchLoc)return n(i.catchLoc,!0);if(this.prev<i.finallyLoc)return n(i.finallyLoc)}else if(a){if(this.prev<i.catchLoc)return n(i.catchLoc,!0)}else{if(!s)throw new Error("try statement without catch or finally");if(this.prev<i.finallyLoc)return n(i.finallyLoc)}}}},abrupt:function(t,e){for(var n=this.tryEntries.length-1;n>=0;--n){var o=this.tryEntries[n];if(o.tryLoc<=this.prev&&r.call(o,"finallyLoc")&&this.prev<o.finallyLoc){var i=o;break}}i&&("break"===t||"continue"===t)&&i.tryLoc<=e&&e<=i.finallyLoc&&(i=null);var u=i?i.completion:{};return u.type=t,u.arg=e,i?(this.method="next",this.next=i.finallyLoc,f):this.complete(u)},complete:function(t,e){if("throw"===t.type)throw t.arg;return"break"===t.type||"continue"===t.type?this.next=t.arg:"return"===t.type?(this.rval=this.arg=t.arg,this.method="return",this.next="end"):"normal"===t.type&&e&&(this.next=e),f},finish:function(t){for(var e=this.tryEntries.length-1;e>=0;--e){var r=this.tryEntries[e];if(r.finallyLoc===t)return this.complete(r.completion,r.afterLoc),E(r),f}},catch:function(t){for(var e=this.tryEntries.length-1;e>=0;--e){var r=this.tryEntries[e];if(r.tryLoc===t){var n=r.completion;if("throw"===n.type){var o=n.arg;E(r)}return o}}throw new Error("illegal catch attempt")},delegateYield:function(t,e,r){return this.delegate={iterator:_(t),resultName:e,nextLoc:r},"next"===this.method&&(this.arg=void 0),f}},t}(t.exports);try{regeneratorRuntime=e}catch(t){Function("r","regeneratorRuntime = r")(e)}})),m=function(t){function e(r){var n;return(n=t.call(this,r.message)||this).originalError=r,Object.setPrototypeOf(d(n),e.prototype),n}return s(e,t),e}(h(Error)),w=function(t){function e(r){var n;return n=t.call(this,r)||this,Object.setPrototypeOf(d(n),e.prototype),n}return s(e,t),e}(h(Error));o();var x=function(t){function e(r,n){var o;return(o=t.call(this,n)||this).statusCode=r,Object.setPrototypeOf(d(o),e.prototype),o}return s(e,t),e}(h(Error)),g={forbidden:function(t){return new x(403,null!=t?t:"Forbidden")},unauthorized:function(t){return new x(401,null!=t?t:"Unauthorized")},badRequest:function(t){return new x(400,null!=t?t:"Bad Request")},notFound:function(t){return new x(404,null!=t?t:"Not found")}};function b(t){var e,r,n=t;return n instanceof m?n=g.badRequest(n.message):n instanceof w&&(n=g.notFound(n.message)),{ok:!1,statusCode:"number"==typeof(null==(e=n)?void 0:e.statusCode)?n.statusCode:500,error:{message:"string"==typeof(null==(r=n)?void 0:r.message)?n.message:"Internal Server Error",stack:void 0}}}function E(t){var e=void 0,r=t.input;if(!r)return e;if("string"!=typeof r)throw g.badRequest("Expected query.input to be a JSON string");try{e=JSON.parse(r)}catch(t){throw g.badRequest("Expected query.input to be a JSON string")}return e}function O(t){return _.apply(this,arguments)}function _(){return(_=u(y.mark((function t(e){var r,n;return y.wrap((function(t){for(;;)switch(t.prev=t.next){case 0:return r=e.req,n=e.maxBodySize,t.abrupt("return",new Promise((function(t,e){if(r.body)t(r.body);else{var o="";r.on("data",(function(t){o+=t,"number"==typeof n&&o.length>n&&(e(new x(413,"Payload Too Large")),r.connection.destroy())})),r.on("end",(function(){try{var r=JSON.parse(o);t(r)}catch(t){e(g.badRequest("Body couldn't be parsed as json"))}}))}})));case 2:case"end":return t.stop()}}),t)})))).apply(this,arguments)}function k(t){return q.apply(this,arguments)}function q(){return(q=u(y.mark((function t(r){var n,o,i,u,a,s,c,f,p,l,h,d,v,m,w,_,k,q,j,L,S,P,R;return y.wrap((function(t){for(;;)switch(t.prev=t.next){case 0:if(n=r.req,o=r.res,i=r.router,u=r.path,a=r.subscriptions,s=r.createContext,c=r.teardown,p=void 0===(f=r.transformer)?{serialize:function(t){return t},deserialize:function(t){return t}}:f,l=r.maxBodySize,t.prev=1,t.t0=s,!t.t0){t.next=7;break}return t.next=6,s({req:n,res:o});case 6:t.t0=t.sent;case 7:if(m=t.t0,w=null!=(h=n.method)?h:"GET",_=function(t){return t?p.deserialize(t):t},"POST"!==w){t.next=20;break}return t.next=13,O({req:n,maxBodySize:l});case 13:return k=_(t.sent.input),t.next=17,i.invoke({target:"mutations",input:k,ctx:m,path:u});case 17:v=t.sent,t.next=42;break;case 20:if("GET"!==w){t.next=28;break}return q=n.query?n.query:e.parse(n.url,!0).query,j=_(E(q)),t.next=25,i.invoke({target:"queries",input:j,ctx:m,path:u});case 25:v=t.sent,t.next=42;break;case 28:if("PATCH"!==w){t.next=41;break}return t.next=31,O({req:n,maxBodySize:l});case 31:return L=_(t.sent.input),t.next=35,i.invoke({target:"subscriptions",input:L,ctx:m,path:u});case 35:return S=t.sent,t.next=38,new Promise((function(t,e){var r,o,i=Date.now(),u=[],s=null!=(r=null==a?void 0:a.requestTimeoutMs)?r:9e3,c=null!=(o=null==a?void 0:a.backpressureMs)?o:0,f=null,p=null;function l(){S.off("data",h),S.off("error",d),S.off("destroy",y),n.off("close",v),clearTimeout(p),clearTimeout(f),S.destroy()}function h(e){u.push(e);var r=function(){l(),t(u)};s-(Date.now()-i)<=c?r():f||(f=setTimeout(r,c))}function d(t){l(),e(t)}function v(){l(),e(new x(499,"Client Closed Request"))}function y(){e(new x(500,"Subscription was destroyed prematurely")),l()}S.on("data",h),S.on("error",d),S.on("destroy",y),n.once("close",v),p=setTimeout((function(){l(),e(new x(408,"Subscription exceeded "+s+"ms - please reconnect."))}),s),S.start()}));case 38:v=t.sent,t.next=42;break;case 41:throw g.badRequest("Unexpected request method "+w);case 42:P={ok:!0,statusCode:null!=(d=o.statusCode)?d:200,data:v},o.statusCode=P.statusCode,o.setHeader("Content-Type","application/json"),o.end(JSON.stringify(p.serialize(P))),t.next=54;break;case 48:t.prev=48,t.t1=t.catch(1),R=b(t.t1),o.statusCode=R.statusCode,o.setHeader("Content-Type","application/json"),o.end(JSON.stringify(p.serialize(R)));case 54:if(t.prev=54,t.t2=c,!t.t2){t.next=59;break}return t.next=59,c();case 59:t.next=64;break;case 61:t.prev=61,t.t3=t.catch(54),console.error("Teardown failed",t.t3);case 64:case"end":return t.stop()}}),t,null,[[1,48],[54,61]])})))).apply(this,arguments)}o();var j=function(){function t(t){this._def=null!=t?t:{queries:{},mutations:{},subscriptions:{}}}t.prefixRoutes=function(t,e){var r={};for(var n in t)r[e+n]=t[n];return r};var e=t.prototype;return e.query=function(e,r){var n,o=new t({queries:(n={},n[e]=r,n),mutations:{},subscriptions:{}});return this.merge(o)},e.mutation=function(e,r){var n,o=new t({queries:{},mutations:(n={},n[e]=r,n),subscriptions:{}});return this.merge(o)},e.subscription=function(e,r){var n,o=new t({queries:{},mutations:{},subscriptions:(n={},n[e]=r,n)});return this.merge(o)},e.merge=function(e,r){var n,o=this,i="";if("string"==typeof e&&r instanceof t)i=e,n=r;else{if(!(e instanceof t))throw new Error("Invalid args");n=e}var u=Object.keys(n._def.queries).filter((function(t){return o.has("queries",t)})),s=Object.keys(n._def.mutations).filter((function(t){return o.has("mutations",t)})),c=Object.keys(n._def.subscriptions).filter((function(t){return o.has("subscriptions",t)})),f=[].concat(u,s,c);if(f.length)throw new Error("Duplicate endpoint(s): "+f.join(", "));return new t({queries:a({},this._def.queries,t.prefixRoutes(n._def.queries,i)),mutations:a({},this._def.mutations,t.prefixRoutes(n._def.mutations,i)),subscriptions:a({},this._def.subscriptions,t.prefixRoutes(n._def.subscriptions,i))})},t.getInput=function(t,e){if(t.input)try{var r=t.input;if("function"==typeof r.parse)return r.parse(e);if("function"==typeof r)return r(e);if("function"==typeof r.validateSync)return r.validateSync(e);throw new Error("Could not find a validator fn")}catch(t){throw new m(t)}},e.invoke=function(){var e=u(y.mark((function e(r){var n,o;return y.wrap((function(e){for(;;)switch(e.prev=e.next){case 0:if(this.has(r.target,r.path)){e.next=2;break}throw new w('No such route "'+r.path+'"');case 2:return o=t.getInput(n=this._def[r.target][r.path],r.input),e.abrupt("return",n.resolve({ctx:r.ctx,input:o}));case 7:case"end":return e.stop()}}),e,this)})));return function(t){return e.apply(this,arguments)}}(),e.has=function(t,e){return!!this._def[t][e]},t}(),L=function(t){function e(){return t.apply(this,arguments)||this}return s(e,t),e}(r.EventEmitter),S=function(){function t(t){this.isDestroyed=!1,this.events=new L,this.opts=a({},t)}var e=t.prototype;return e.destroy=function(){this.isDestroyed||(this.isDestroyed=!0,this.events.emit("destroy"),this.events.removeAllListeners())},e.start=function(){var t=u(y.mark((function t(){var e,r,n=this;return y.wrap((function(t){for(;;)switch(t.prev=t.next){case 0:if(!this.isDestroyed){t.next=2;break}throw new Error("Called start() on a destroyed subscription");case 2:return t.prev=2,e={error:function(t){return n.emitError(t)},data:function(t){return n.emitOutput(t)}},t.next=6,this.opts.start(e);case 6:r=t.sent,this.isDestroyed?r():this.events.on("destroy",r),t.next=13;break;case 10:t.prev=10,t.t0=t.catch(2),this.emitError(t.t0);case 13:case"end":return t.stop()}}),t,this,[[2,10]])})));return function(){return t.apply(this,arguments)}}(),e.output=function(){throw new Error("Legacy")},e.emitOutput=function(t){this.events.emit("data",t)},e.emitError=function(t){this.events.emit("error",t)},e.on=function(){var t;return(t=this.events).on.apply(t,arguments)},e.off=function(){var t;return(t=this.events).off.apply(t,arguments)},t}();function P(t){return function(){var r=u(y.mark((function r(n,o){var i;return y.wrap((function(r){for(;;)switch(r.prev=r.next){case 0:return i=e.parse(n.url).pathname.substr(1),r.next=3,k(a({},t,{req:n,res:o,path:i}));case 3:case"end":return r.stop()}}),r)})));return function(t,e){return r.apply(this,arguments)}}()}exports.HTTPError=x,exports.Router=j,exports.Subscription=S,exports.assertNotBrowser=o,exports.createExpressMiddleware=function(t){return function(e,r){var n=e.path.substr(1);k(a({},t,{req:e,res:r,path:n}))}},exports.createHttpHandler=P,exports.createHttpServer=function(t){var e=P(t),r=n.createServer((function(t,r){return e(t,r)}));return{server:r,listen:function(t){return r.listen(t),{port:0===t?r.address().port:t}}}},exports.createNextApiHandler=function(t){return function(){var e=u(y.mark((function e(r,n){var o,i;return y.wrap((function(e){for(;;)switch(e.prev=e.next){case 0:if(null!==(o=Array.isArray(r.query.trpc)?r.query.trpc.join("/"):null)){e.next=5;break}return i=b(new Error('Query "trpc" not found - is the file named [...trpc].ts?')),n.status(i.statusCode).json(i),e.abrupt("return");case 5:return e.next=7,k(a({},t,{req:r,res:n,path:o}));case 7:case"end":return e.stop()}}),e)})));return function(t,r){return e.apply(this,arguments)}}()},exports.getErrorResponseEnvelope=b,exports.getQueryInput=E,exports.httpError=g,exports.requestHandler=k,exports.router=function(){return new j},exports.subscriptionPullFactory=function(t){var e,r=!1;function n(t){return o.apply(this,arguments)}function o(){return(o=u(y.mark((function o(i){return y.wrap((function(o){for(;;)switch(o.prev=o.next){case 0:if(!r){o.next=2;break}return o.abrupt("return");case 2:return o.prev=2,o.next=5,t.pull(i);case 5:o.next=10;break;case 7:o.prev=7,o.t0=o.catch(2),i.error(o.t0);case 10:r||(e=setTimeout((function(){return n(i)}),t.intervalMs));case 11:case"end":return o.stop()}}),o,null,[[2,7]])})))).apply(this,arguments)}return new S({start:function(t){return n(t),function(){clearTimeout(e),r=!0}}})};
 //# sourceMappingURL=server.cjs.production.min.js.map

dist/server.esm.js

@@ -946,5 +946,2 @@ import url from 'url';
     return new HTTPError(404, message != null ? message : 'Not found');
-  },
-  payloadTooLarge: function payloadTooLarge(message) {
-    return new HTTPError(413, message != null ? message : 'Payload Too Large');
   }
@@ -1021,3 +1018,3 @@ };
                 if (typeof maxBodySize === 'number' && body.length > maxBodySize) {
-                  reject(httpError.payloadTooLarge());
+                  reject(new HTTPError(413, 'Payload Too Large'));
                   req.connection.destroy();
@@ -1197,3 +1194,3 @@ }
 
-                if (requestTimeLeft >= backpressureMs) {
+                if (requestTimeLeft <= backpressureMs) {
                   // will timeout before next backpressure tick
@@ -1566,27 +1563,12 @@ success();
     return start;
-  }();
-
-  _proto.onceOutputAndStop = /*#__PURE__*/function () {
-    var _onceOutputAndStop = /*#__PURE__*/_asyncToGenerator( /*#__PURE__*/runtime_1.mark(function _callee2() {
-      return runtime_1.wrap(function _callee2$(_context2) {
-        while (1) {
-          switch (_context2.prev = _context2.next) {
-            case 0:
-              throw new Error('Legacy');
-
-            case 1:
-            case "end":
-              return _context2.stop();
-          }
-        }
-      }, _callee2);
-    }));
-
-    function onceOutputAndStop() {
-      return _onceOutputAndStop.apply(this, arguments);
-    }
-
-    return onceOutputAndStop;
   }()
   /**
+   * This method is just here to help with `inferSubscriptionOutput` which I can't get working without it
+   */
+  ;
+
+  _proto.output = function output() {
+    throw new Error('Legacy');
+  }
+  /**
    * Emit data
@@ -1632,27 +1614,27 @@ */
   function _pull2() {
-    _pull2 = _asyncToGenerator( /*#__PURE__*/runtime_1.mark(function _callee3(emit) {
-      return runtime_1.wrap(function _callee3$(_context3) {
+    _pull2 = _asyncToGenerator( /*#__PURE__*/runtime_1.mark(function _callee2(emit) {
+      return runtime_1.wrap(function _callee2$(_context2) {
         while (1) {
-          switch (_context3.prev = _context3.next) {
+          switch (_context2.prev = _context2.next) {
             case 0:
               if (!stopped) {
-                _context3.next = 2;
+                _context2.next = 2;
                 break;
               }
 
-              return _context3.abrupt("return");
+              return _context2.abrupt("return");
 
             case 2:
-              _context3.prev = 2;
-              _context3.next = 5;
+              _context2.prev = 2;
+              _context2.next = 5;
               return opts.pull(emit);
 
             case 5:
-              _context3.next = 10;
+              _context2.next = 10;
               break;
 
             case 7:
-              _context3.prev = 7;
-              _context3.t0 = _context3["catch"](2);
-              emit.error(_context3.t0);
+              _context2.prev = 7;
+              _context2.t0 = _context2["catch"](2);
+              emit.error(_context2.t0);
 
@@ -1668,6 +1650,6 @@ case 10:
             case "end":
-              return _context3.stop();
+              return _context2.stop();
           }
         }
-      }, _callee3, null, [[2, 7]]);
+      }, _callee2, null, [[2, 7]]);
     }));
@@ -1674,0 +1656,0 @@ return _pull2.apply(this, arguments);

dist/subscription.d.ts

@@ -31,4 +31,7 @@ /// <reference types="node" />
     start(): Promise<void>;
-    onceOutputAndStop(): Promise<TOutput>;
     /**
+     * This method is just here to help with `inferSubscriptionOutput` which I can't get working without it
+     */
+    protected output(): TOutput;
+    /**
      * Emit data
@@ -35,0 +38,0 @@ */

package.json

 {
   "name": "@trpc/server",
-  "version": "1.4.1",
+  "version": "1.4.3",
   "description": "TRPC Server",
@@ -46,3 +46,3 @@ "author": "KATT",
   },
-  "gitHead": "6c17f0dba789204be6386a2632f6073440e8604a"
+  "gitHead": "3102802183e37cb08e1d48f636eb5bfef9a813e7"
 }

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

Worsened metrics

Total package byte prevSize

393970

decreased by-0.42%

Lines of code

3273

decreased by-0.88%

No dependency changes