Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More →
@trpc/server
Advanced tools
@trpc/server - npm Package Compare versions
Comparing version 1.3.1 to 1.4.0-alpha.0
@@ -47,3 +47,10 @@ /// <reference types="node" /> | ||
| subscriptions?: { | ||
| timeout?: number; | ||
| /** | ||
| * Time in milliseconds before `408` is sent | ||
| */ | ||
| requestTimeoutMs?: number; | ||
| /** | ||
| * Allow for some backpressure and batch send events every X ms | ||
| */ | ||
| backpressureMs?: number; | ||
| }; | ||
@@ -50,0 +57,0 @@ teardown?: () => Promise<void>; |
@@ -44,7 +44,2 @@ import { Subscription } from './subscription'; | ||
| query<TPath extends string, TInput, TOutput>(path: TPath, route: Route<TContext, TInput, TOutput>): Router<TContext, TQueries & Record<TPath, typeof route>, TMutations, TSubscriptions>; | ||
| /** | ||
| * FIXME | ||
| * Would like to get `queries()`, etc, in place instead of `query()` | ||
| * Does not infer `input` in the resolver fn, needs some love | ||
| */ | ||
| mutation<TPath extends string, TInput, TOutput>(path: TPath, route: Route<TContext, TInput, TOutput>): Router<TContext, TQueries, TMutations & Record<TPath, typeof route>, TSubscriptions>; | ||
@@ -51,0 +46,0 @@ subscription<TPath extends string, TInput, TOutput extends Subscription>(path: TPath, route: Route<TContext, TInput, TOutput>): Router<TContext, TQueries, TMutations, TSubscriptions & Record<TPath, typeof route>>; |
@@ -7,4 +7,4 @@ 'use strict'; | ||
| var url = _interopDefault(require('url')); | ||
| var events = require('events'); | ||
| var url = _interopDefault(require('url')); | ||
| var http = _interopDefault(require('http')); | ||
@@ -926,269 +926,2 @@ | ||
| var SubscriptionDestroyError = /*#__PURE__*/function (_Error) { | ||
| _inheritsLoose(SubscriptionDestroyError, _Error); | ||
| function SubscriptionDestroyError(reason) { | ||
| var _this; | ||
| _this = _Error.call(this, reason) || this; | ||
| _this.reason = reason; | ||
| Object.setPrototypeOf(_assertThisInitialized(_this), SubscriptionDestroyError.prototype); | ||
| return _this; | ||
| } | ||
| return SubscriptionDestroyError; | ||
| }( /*#__PURE__*/_wrapNativeSuper(Error)); // eslint-disable-next-line @typescript-eslint/no-unused-vars | ||
| var SubscriptionEventEmitter = /*#__PURE__*/function (_EventEmitter) { | ||
| _inheritsLoose(SubscriptionEventEmitter, _EventEmitter); | ||
| function SubscriptionEventEmitter() { | ||
| return _EventEmitter.apply(this, arguments) || this; | ||
| } | ||
| return SubscriptionEventEmitter; | ||
| }(events.EventEmitter); | ||
| var Subscription = /*#__PURE__*/function () { | ||
| function Subscription(opts) { | ||
| this.isDestroyed = false; | ||
| this.events = new SubscriptionEventEmitter(); | ||
| this.opts = _extends({ | ||
| getInitialOutput: function getInitialOutput() {// no-op | ||
| } | ||
| }, opts); | ||
| } | ||
| var _proto = Subscription.prototype; | ||
| _proto.destroy = function destroy(reason) { | ||
| if (this.isDestroyed) { | ||
| return; | ||
| } // debug('Subscription.destroy()', reason); | ||
| this.isDestroyed = true; | ||
| this.events.emit('destroy', reason); | ||
| this.events.removeAllListeners(); | ||
| }; | ||
| _proto.start = /*#__PURE__*/function () { | ||
| var _start = /*#__PURE__*/_asyncToGenerator( /*#__PURE__*/runtime_1.mark(function _callee() { | ||
| var _this2 = this; | ||
| var emit, cancel; | ||
| return runtime_1.wrap(function _callee$(_context) { | ||
| while (1) { | ||
| switch (_context.prev = _context.next) { | ||
| case 0: | ||
| if (!this.isDestroyed) { | ||
| _context.next = 2; | ||
| break; | ||
| } | ||
| throw new Error('Called start() on a destroyed subscription'); | ||
| case 2: | ||
| _context.prev = 2; | ||
| emit = { | ||
| error: function error(err) { | ||
| return _this2.emitError(err); | ||
| }, | ||
| data: function data(_data) { | ||
| return _this2.emitOutput(_data); | ||
| } | ||
| }; | ||
| _context.next = 6; | ||
| return this.opts.getInitialOutput(emit); | ||
| case 6: | ||
| cancel = this.opts.start(emit); | ||
| this.events.on('destroy', function () { | ||
| cancel(); | ||
| }); | ||
| _context.next = 13; | ||
| break; | ||
| case 10: | ||
| _context.prev = 10; | ||
| _context.t0 = _context["catch"](2); | ||
| this.emitError(_context.t0); | ||
| case 13: | ||
| case "end": | ||
| return _context.stop(); | ||
| } | ||
| } | ||
| }, _callee, this, [[2, 10]]); | ||
| })); | ||
| function start() { | ||
| return _start.apply(this, arguments); | ||
| } | ||
| return start; | ||
| }(); | ||
| _proto.onceOutputAndStop = /*#__PURE__*/function () { | ||
| var _onceOutputAndStop = /*#__PURE__*/_asyncToGenerator( /*#__PURE__*/runtime_1.mark(function _callee3() { | ||
| var _this3 = this; | ||
| return runtime_1.wrap(function _callee3$(_context3) { | ||
| while (1) { | ||
| switch (_context3.prev = _context3.next) { | ||
| case 0: | ||
| return _context3.abrupt("return", new Promise( /*#__PURE__*/function () { | ||
| var _ref = _asyncToGenerator( /*#__PURE__*/runtime_1.mark(function _callee2(resolve, reject) { | ||
| var onDestroy, onOutput, onError, cleanup; | ||
| return runtime_1.wrap(function _callee2$(_context2) { | ||
| while (1) { | ||
| switch (_context2.prev = _context2.next) { | ||
| case 0: | ||
| onDestroy = function onDestroy(reason) { | ||
| reject(new SubscriptionDestroyError(reason)); | ||
| cleanup(); | ||
| }; | ||
| onOutput = function onOutput(data) { | ||
| resolve(data); | ||
| cleanup(); | ||
| _this3.destroy('stopped'); | ||
| }; | ||
| onError = function onError(err) { | ||
| reject(err); | ||
| cleanup(); | ||
| _this3.destroy('stopped'); | ||
| }; | ||
| cleanup = function cleanup() { | ||
| _this3.events.off('data', onOutput); | ||
| _this3.events.off('destroy', onDestroy); | ||
| _this3.events.off('error', onError); | ||
| }; | ||
| _this3.events.once('data', onOutput); | ||
| _this3.events.once('destroy', onDestroy); | ||
| _this3.events.once('error', onError); | ||
| _this3.start()["catch"](function () {// is handled through event | ||
| }); | ||
| case 8: | ||
| case "end": | ||
| return _context2.stop(); | ||
| } | ||
| } | ||
| }, _callee2); | ||
| })); | ||
| return function (_x, _x2) { | ||
| return _ref.apply(this, arguments); | ||
| }; | ||
| }())); | ||
| case 1: | ||
| case "end": | ||
| return _context3.stop(); | ||
| } | ||
| } | ||
| }, _callee3); | ||
| })); | ||
| function onceOutputAndStop() { | ||
| return _onceOutputAndStop.apply(this, arguments); | ||
| } | ||
| return onceOutputAndStop; | ||
| }() | ||
| /** | ||
| * Emit data | ||
| */ | ||
| ; | ||
| _proto.emitOutput = function emitOutput(data) { | ||
| this.events.emit('data', data); | ||
| } | ||
| /** | ||
| * Emit error | ||
| */ | ||
| ; | ||
| _proto.emitError = function emitError(err) { | ||
| this.events.emit('error', err); | ||
| }; | ||
| return Subscription; | ||
| }(); | ||
| function subscriptionPullFatory(opts) { | ||
| // eslint-disable-next-line @typescript-eslint/no-explicit-any | ||
| var timer; | ||
| var stopped = false; | ||
| function _pull(_x3) { | ||
| return _pull2.apply(this, arguments); | ||
| } | ||
| function _pull2() { | ||
| _pull2 = _asyncToGenerator( /*#__PURE__*/runtime_1.mark(function _callee4(emit) { | ||
| return runtime_1.wrap(function _callee4$(_context4) { | ||
| while (1) { | ||
| switch (_context4.prev = _context4.next) { | ||
| case 0: | ||
| if (!stopped) { | ||
| _context4.next = 2; | ||
| break; | ||
| } | ||
| return _context4.abrupt("return"); | ||
| case 2: | ||
| _context4.prev = 2; | ||
| _context4.next = 5; | ||
| return opts.pull(emit); | ||
| case 5: | ||
| _context4.next = 10; | ||
| break; | ||
| case 7: | ||
| _context4.prev = 7; | ||
| _context4.t0 = _context4["catch"](2); | ||
| emit.error(_context4.t0); | ||
| case 10: | ||
| if (!stopped) { | ||
| timer = setTimeout(function () { | ||
| return _pull(emit); | ||
| }, opts.interval); | ||
| } | ||
| case 11: | ||
| case "end": | ||
| return _context4.stop(); | ||
| } | ||
| } | ||
| }, _callee4, null, [[2, 7]]); | ||
| })); | ||
| return _pull2.apply(this, arguments); | ||
| } | ||
| return new Subscription({ | ||
| start: function start(emit) { | ||
| _pull(emit); | ||
| return function () { | ||
| clearTimeout(timer); | ||
| stopped = true; | ||
| }; | ||
| } | ||
| }); | ||
| } | ||
| assertNotBrowser(); | ||
@@ -1325,3 +1058,3 @@ var HTTPError = /*#__PURE__*/function (_Error) { | ||
| _requestHandler = _asyncToGenerator( /*#__PURE__*/runtime_1.mark(function _callee2(_ref2) { | ||
| var req, res, router, endpoint, subscriptions, createContext, teardown, _ref2$transformer, transformer, maxBodySize, _req$method, _res$statusCode, output, ctx, method, deserializeInput, body, input, query, _input, _subscriptions$timeou, _body, _input2, sub, onClose, timeout, timer, json, _json; | ||
| var req, res, router, endpoint, subscriptions, createContext, teardown, _ref2$transformer, transformer, maxBodySize, _req$method, _res$statusCode, output, ctx, method, deserializeInput, body, input, query, _input, _body, _input2, sub, json, _json; | ||
@@ -1389,3 +1122,3 @@ return runtime_1.wrap(function _callee2$(_context2) { | ||
| output = _context2.sent; | ||
| _context2.next = 57; | ||
| _context2.next = 42; | ||
| break; | ||
@@ -1412,3 +1145,3 @@ | ||
| output = _context2.sent; | ||
| _context2.next = 57; | ||
| _context2.next = 42; | ||
| break; | ||
@@ -1418,3 +1151,3 @@ | ||
| if (!(method === 'PATCH')) { | ||
| _context2.next = 56; | ||
| _context2.next = 41; | ||
| break; | ||
@@ -1442,54 +1175,84 @@ } | ||
| sub = _context2.sent; | ||
| _context2.next = 38; | ||
| return new Promise(function (resolve, reject) { | ||
| var _subscriptions$reques, _subscriptions$backpr; | ||
| onClose = function onClose() { | ||
| sub.destroy('closed'); | ||
| }; // FIXME - refactor | ||
| // this is a bit complex | ||
| // needs to handle a few cases: | ||
| // - ok subscription | ||
| // - error subscription | ||
| // - request got prematurely closed | ||
| // - request timed out | ||
| var startTime = Date.now(); | ||
| var buffer = []; | ||
| var requestTimeoutMs = (_subscriptions$reques = subscriptions == null ? void 0 : subscriptions.requestTimeoutMs) != null ? _subscriptions$reques : 9000; // 10s is vercel's api timeout | ||
| var backpressureMs = (_subscriptions$backpr = subscriptions == null ? void 0 : subscriptions.backpressureMs) != null ? _subscriptions$backpr : 0; // timers | ||
| res.once('close', onClose); | ||
| timeout = (_subscriptions$timeou = subscriptions == null ? void 0 : subscriptions.timeout) != null ? _subscriptions$timeou : 9000; // 10s is vercel's api timeout | ||
| var backpressureTimer = null; | ||
| var requestTimeoutTimer = null; | ||
| timer = setTimeout(function () { | ||
| sub.destroy('timeout'); | ||
| }, timeout); | ||
| _context2.prev = 40; | ||
| _context2.next = 43; | ||
| return sub.onceOutputAndStop(); | ||
| function cleanup() { | ||
| sub.off('data', onData); | ||
| sub.off('error', onError); | ||
| sub.off('destroy', onDestroy); | ||
| req.off('close', onClose); | ||
| clearTimeout(requestTimeoutTimer); | ||
| clearTimeout(backpressureTimer); | ||
| sub.destroy(); | ||
| } | ||
| case 43: | ||
| output = _context2.sent; | ||
| res.off('close', onClose); | ||
| _context2.next = 54; | ||
| break; | ||
| function onData(data) { | ||
| buffer.push(data); | ||
| var requestTimeLeft = requestTimeoutMs - (Date.now() - startTime); | ||
| case 47: | ||
| _context2.prev = 47; | ||
| _context2.t1 = _context2["catch"](40); | ||
| res.off('close', onClose); | ||
| clearTimeout(timer); | ||
| var success = function success() { | ||
| cleanup(); | ||
| resolve(buffer); | ||
| }; | ||
| if (!(_context2.t1 instanceof SubscriptionDestroyError && _context2.t1.reason === 'timeout')) { | ||
| _context2.next = 53; | ||
| break; | ||
| } | ||
| if (requestTimeLeft >= backpressureMs) { | ||
| // will timeout before next backpressure tick | ||
| success(); | ||
| return; | ||
| } | ||
| throw new HTTPError(408, "Subscription exceeded " + timeout + "ms - please reconnect."); | ||
| if (!backpressureTimer) { | ||
| backpressureTimer = setTimeout(success, backpressureMs); | ||
| return; | ||
| } | ||
| } | ||
| case 53: | ||
| throw _context2.t1; | ||
| function onError(err) { | ||
| cleanup(); // maybe if `buffer` has length here we should just return instead? | ||
| case 54: | ||
| _context2.next = 57; | ||
| reject(err); | ||
| } | ||
| function onClose() { | ||
| cleanup(); | ||
| reject(new HTTPError(499, "Client Closed Request")); | ||
| } | ||
| function onRequestTimeout() { | ||
| cleanup(); | ||
| reject(new HTTPError(408, "Subscription exceeded " + requestTimeoutMs + "ms - please reconnect.")); | ||
| } | ||
| function onDestroy() { | ||
| reject(new HTTPError(500, "Subscription was destroyed prematurely")); | ||
| cleanup(); | ||
| } | ||
| sub.on('data', onData); | ||
| sub.on('error', onError); | ||
| sub.on('destroy', onDestroy); | ||
| req.once('close', onClose); | ||
| requestTimeoutTimer = setTimeout(onRequestTimeout, requestTimeoutMs); | ||
| sub.start(); | ||
| }); | ||
| case 38: | ||
| output = _context2.sent; | ||
| _context2.next = 42; | ||
| break; | ||
| case 56: | ||
| case 41: | ||
| throw httpError.badRequest("Unexpected request method " + method); | ||
| case 57: | ||
| case 42: | ||
| json = { | ||
@@ -1503,9 +1266,9 @@ ok: true, | ||
| res.end(JSON.stringify(transformer.serialize(json))); | ||
| _context2.next = 69; | ||
| _context2.next = 54; | ||
| break; | ||
| case 63: | ||
| _context2.prev = 63; | ||
| _context2.t2 = _context2["catch"](1); | ||
| _json = getErrorResponseEnvelope(_context2.t2); | ||
| case 48: | ||
| _context2.prev = 48; | ||
| _context2.t1 = _context2["catch"](1); | ||
| _json = getErrorResponseEnvelope(_context2.t1); | ||
| res.statusCode = _json.statusCode; | ||
@@ -1515,24 +1278,24 @@ res.setHeader('Content-Type', 'application/json'); | ||
| case 69: | ||
| _context2.prev = 69; | ||
| _context2.t3 = teardown; | ||
| case 54: | ||
| _context2.prev = 54; | ||
| _context2.t2 = teardown; | ||
| if (!_context2.t3) { | ||
| _context2.next = 74; | ||
| if (!_context2.t2) { | ||
| _context2.next = 59; | ||
| break; | ||
| } | ||
| _context2.next = 74; | ||
| _context2.next = 59; | ||
| return teardown(); | ||
| case 74: | ||
| _context2.next = 79; | ||
| case 59: | ||
| _context2.next = 64; | ||
| break; | ||
| case 76: | ||
| _context2.prev = 76; | ||
| _context2.t4 = _context2["catch"](69); | ||
| console.error('Teardown failed', _context2.t4); | ||
| case 61: | ||
| _context2.prev = 61; | ||
| _context2.t3 = _context2["catch"](54); | ||
| console.error('Teardown failed', _context2.t3); | ||
| case 79: | ||
| case 64: | ||
| case "end": | ||
@@ -1542,3 +1305,3 @@ return _context2.stop(); | ||
| } | ||
| }, _callee2, null, [[1, 63], [40, 47], [69, 76]]); | ||
| }, _callee2, null, [[1, 48], [54, 61]]); | ||
| })); | ||
@@ -1579,17 +1342,12 @@ return _requestHandler.apply(this, arguments); | ||
| return this.merge(router); | ||
| } | ||
| /** | ||
| * FIXME | ||
| * Would like to get `queries()`, etc, in place instead of `query()` | ||
| * Does not infer `input` in the resolver fn, needs some love | ||
| */ | ||
| // public queries( | ||
| // routes: RouteRecord<TContext, any, any>, | ||
| // ): Router<TContext, TQueries & typeof routes, TMutations, TSubscriptions> { | ||
| // const router = new Router({ | ||
| // queries: routes as any, | ||
| } // TODO / help: https://github.com/trpc/trpc/pull/37 | ||
| // public queries<TRoutes extends RouteRecord<TContext, any, any>>( | ||
| // routes: TRoutes, | ||
| // ): Router<TContext, TQueries & TRoutes, TMutations, TSubscriptions> { | ||
| // const router = new Router<TContext, any, {}, {}>({ | ||
| // queries: routes, | ||
| // mutations: {}, | ||
| // subscriptions: {}, | ||
| // }); | ||
| // return this.merge(router); | ||
| // return this.merge(router) as any; | ||
| // } | ||
@@ -1733,2 +1491,214 @@ ; | ||
| var SubscriptionEventEmitter = /*#__PURE__*/function (_EventEmitter) { | ||
| _inheritsLoose(SubscriptionEventEmitter, _EventEmitter); | ||
| function SubscriptionEventEmitter() { | ||
| return _EventEmitter.apply(this, arguments) || this; | ||
| } | ||
| return SubscriptionEventEmitter; | ||
| }(events.EventEmitter); | ||
| var Subscription = /*#__PURE__*/function () { | ||
| function Subscription(opts) { | ||
| this.isDestroyed = false; | ||
| this.events = new SubscriptionEventEmitter(); | ||
| this.opts = _extends({ | ||
| getInitialOutput: function getInitialOutput() {// no-op | ||
| } | ||
| }, opts); | ||
| } | ||
| var _proto = Subscription.prototype; | ||
| _proto.destroy = function destroy() { | ||
| if (this.isDestroyed) { | ||
| return; | ||
| } // debug('Subscription.destroy()', reason); | ||
| this.isDestroyed = true; | ||
| this.events.emit('destroy'); | ||
| this.events.removeAllListeners(); | ||
| }; | ||
| _proto.start = /*#__PURE__*/function () { | ||
| var _start = /*#__PURE__*/_asyncToGenerator( /*#__PURE__*/runtime_1.mark(function _callee() { | ||
| var _this = this; | ||
| var emit, cancel; | ||
| return runtime_1.wrap(function _callee$(_context) { | ||
| while (1) { | ||
| switch (_context.prev = _context.next) { | ||
| case 0: | ||
| if (!this.isDestroyed) { | ||
| _context.next = 2; | ||
| break; | ||
| } | ||
| throw new Error('Called start() on a destroyed subscription'); | ||
| case 2: | ||
| _context.prev = 2; | ||
| emit = { | ||
| error: function error(err) { | ||
| return _this.emitError(err); | ||
| }, | ||
| data: function data(_data) { | ||
| return _this.emitOutput(_data); | ||
| } | ||
| }; | ||
| _context.next = 6; | ||
| return this.opts.start(emit); | ||
| case 6: | ||
| cancel = _context.sent; | ||
| if (this.isDestroyed) { | ||
| cancel(); | ||
| } else { | ||
| this.events.on('destroy', cancel); | ||
| } | ||
| _context.next = 13; | ||
| break; | ||
| case 10: | ||
| _context.prev = 10; | ||
| _context.t0 = _context["catch"](2); | ||
| this.emitError(_context.t0); | ||
| case 13: | ||
| case "end": | ||
| return _context.stop(); | ||
| } | ||
| } | ||
| }, _callee, this, [[2, 10]]); | ||
| })); | ||
| function start() { | ||
| return _start.apply(this, arguments); | ||
| } | ||
| 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; | ||
| }() | ||
| /** | ||
| * Emit data | ||
| */ | ||
| ; | ||
| _proto.emitOutput = function emitOutput(data) { | ||
| this.events.emit('data', data); | ||
| } | ||
| /** | ||
| * Emit error | ||
| */ | ||
| ; | ||
| _proto.emitError = function emitError(err) { | ||
| this.events.emit('error', err); | ||
| }; | ||
| _proto.on = function on() { | ||
| var _this$events; | ||
| return (_this$events = this.events).on.apply(_this$events, arguments); | ||
| }; | ||
| _proto.off = function off() { | ||
| var _this$events2; | ||
| return (_this$events2 = this.events).off.apply(_this$events2, arguments); | ||
| }; | ||
| return Subscription; | ||
| }(); | ||
| function subscriptionPullFatory(opts) { | ||
| // eslint-disable-next-line @typescript-eslint/no-explicit-any | ||
| var timer; | ||
| var stopped = false; | ||
| function _pull(_x) { | ||
| return _pull2.apply(this, arguments); | ||
| } | ||
| function _pull2() { | ||
| _pull2 = _asyncToGenerator( /*#__PURE__*/runtime_1.mark(function _callee3(emit) { | ||
| return runtime_1.wrap(function _callee3$(_context3) { | ||
| while (1) { | ||
| switch (_context3.prev = _context3.next) { | ||
| case 0: | ||
| if (!stopped) { | ||
| _context3.next = 2; | ||
| break; | ||
| } | ||
| return _context3.abrupt("return"); | ||
| case 2: | ||
| _context3.prev = 2; | ||
| _context3.next = 5; | ||
| return opts.pull(emit); | ||
| case 5: | ||
| _context3.next = 10; | ||
| break; | ||
| case 7: | ||
| _context3.prev = 7; | ||
| _context3.t0 = _context3["catch"](2); | ||
| emit.error(_context3.t0); | ||
| case 10: | ||
| if (!stopped) { | ||
| timer = setTimeout(function () { | ||
| return _pull(emit); | ||
| }, opts.interval); | ||
| } | ||
| case 11: | ||
| case "end": | ||
| return _context3.stop(); | ||
| } | ||
| } | ||
| }, _callee3, null, [[2, 7]]); | ||
| })); | ||
| return _pull2.apply(this, arguments); | ||
| } | ||
| return new Subscription({ | ||
| start: function start(emit) { | ||
| _pull(emit); | ||
| return function () { | ||
| clearTimeout(timer); | ||
| stopped = true; | ||
| }; | ||
| } | ||
| }); | ||
| } | ||
| function createExpressMiddleware(opts) { | ||
@@ -1835,3 +1805,2 @@ return function (req, res) { | ||
| exports.Subscription = Subscription; | ||
| exports.SubscriptionDestroyError = SubscriptionDestroyError; | ||
| exports.assertNotBrowser = assertNotBrowser; | ||
@@ -1838,0 +1807,0 @@ exports.createExpressMiddleware = createExpressMiddleware; |
@@ -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=require("events"),r=t(require("url")),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)),x=function(t){function e(r){var n;return(n=t.call(this,r)||this).reason=r,Object.setPrototypeOf(d(n),e.prototype),n}return s(e,t),e}(h(Error)),g=function(t){function e(){return t.apply(this,arguments)||this}return s(e,t),e}(e.EventEmitter),b=function(){function t(t){this.isDestroyed=!1,this.events=new g,this.opts=a({getInitialOutput:function(){}},t)}var e=t.prototype;return e.destroy=function(t){this.isDestroyed||(this.isDestroyed=!0,this.events.emit("destroy",t),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.getInitialOutput(e);case 6:r=this.opts.start(e),this.events.on("destroy",(function(){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(){var e=this;return y.wrap((function(t){for(;;)switch(t.prev=t.next){case 0:return t.abrupt("return",new Promise(function(){var t=u(y.mark((function t(r,n){var o,i,u,a;return y.wrap((function(t){for(;;)switch(t.prev=t.next){case 0:o=function(t){n(new x(t)),a()},i=function(t){r(t),a(),e.destroy("stopped")},u=function(t){n(t),a(),e.destroy("stopped")},a=function(){e.events.off("data",i),e.events.off("destroy",o),e.events.off("error",u)},e.events.once("data",i),e.events.once("destroy",o),e.events.once("error",u),e.start().catch((function(){}));case 8:case"end":return t.stop()}}),t)})));return function(e,r){return t.apply(this,arguments)}}()));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)},t}();o();var E=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)),O={forbidden:function(t){return new E(403,null!=t?t:"Forbidden")},unauthorized:function(t){return new E(401,null!=t?t:"Unauthorized")},badRequest:function(t){return new E(400,null!=t?t:"Bad Request")},notFound:function(t){return new E(404,null!=t?t:"Not found")},payloadTooLarge:function(t){return new E(413,null!=t?t:"Payload Too Large")}};function k(t){var e,r,n=t;return n instanceof m?n=O.badRequest(n.message):n instanceof w&&(n=O.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 _(t){var e=void 0,r=t.input;if(!r)return e;if("string"!=typeof r)throw O.badRequest("Expected query.input to be a JSON string");try{e=JSON.parse(r)}catch(t){throw O.badRequest("Expected query.input to be a JSON string")}return e}function q(t){return j.apply(this,arguments)}function j(){return(j=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(O.payloadTooLarge()),r.connection.destroy())})),r.on("end",(function(){try{var r=JSON.parse(o);t(r)}catch(t){e(O.badRequest("Body couldn't be parsed as json"))}}))}})));case 2:case"end":return t.stop()}}),t)})))).apply(this,arguments)}function L(t){return S.apply(this,arguments)}function S(){return(S=u(y.mark((function t(e){var n,o,i,u,a,s,c,f,p,l,h,d,v,m,w,g,b,j,L,S,P,R,T,N,C,F,I;return y.wrap((function(t){for(;;)switch(t.prev=t.next){case 0:if(n=e.req,o=e.res,i=e.router,u=e.endpoint,a=e.subscriptions,s=e.createContext,c=e.teardown,p=void 0===(f=e.transformer)?{serialize:function(t){return t},deserialize:function(t){return t}}:f,l=e.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",g=function(t){return t?p.deserialize(t):t},"POST"!==w){t.next=20;break}return t.next=13,q({req:n,maxBodySize:l});case 13:return b=g(t.sent.input),t.next=17,i.invoke({target:"mutations",input:b,ctx:m,path:u});case 17:v=t.sent,t.next=57;break;case 20:if("GET"!==w){t.next=28;break}return j=n.query?n.query:r.parse(n.url,!0).query,L=g(_(j)),t.next=25,i.invoke({target:"queries",input:L,ctx:m,path:u});case 25:v=t.sent,t.next=57;break;case 28:if("PATCH"!==w){t.next=56;break}return t.next=31,q({req:n,maxBodySize:l});case 31:return P=g(t.sent.input),t.next=35,i.invoke({target:"subscriptions",input:P,ctx:m,path:u});case 35:return R=t.sent,o.once("close",T=function(){R.destroy("closed")}),N=null!=(S=null==a?void 0:a.timeout)?S:9e3,C=setTimeout((function(){R.destroy("timeout")}),N),t.prev=40,t.next=43,R.onceOutputAndStop();case 43:v=t.sent,o.off("close",T),t.next=54;break;case 47:if(t.prev=47,t.t1=t.catch(40),o.off("close",T),clearTimeout(C),!(t.t1 instanceof x&&"timeout"===t.t1.reason)){t.next=53;break}throw new E(408,"Subscription exceeded "+N+"ms - please reconnect.");case 53:throw t.t1;case 54:t.next=57;break;case 56:throw O.badRequest("Unexpected request method "+w);case 57:F={ok:!0,statusCode:null!=(d=o.statusCode)?d:200,data:v},o.statusCode=F.statusCode,o.setHeader("Content-Type","application/json"),o.end(JSON.stringify(p.serialize(F))),t.next=69;break;case 63:t.prev=63,t.t2=t.catch(1),I=k(t.t2),o.statusCode=I.statusCode,o.setHeader("Content-Type","application/json"),o.end(JSON.stringify(p.serialize(I)));case 69:if(t.prev=69,t.t3=c,!t.t3){t.next=74;break}return t.next=74,c();case 74:t.next=79;break;case 76:t.prev=76,t.t4=t.catch(69),console.error("Teardown failed",t.t4);case 79:case"end":return t.stop()}}),t,null,[[1,63],[40,47],[69,76]])})))).apply(this,arguments)}o();var P=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}();function R(t){return function(){var e=u(y.mark((function e(n,o){var i;return y.wrap((function(e){for(;;)switch(e.prev=e.next){case 0:return i=r.parse(n.url).pathname.substr(1),e.next=3,L(a({},t,{req:n,res:o,endpoint:i}));case 3:case"end":return e.stop()}}),e)})));return function(t,r){return e.apply(this,arguments)}}()}exports.HTTPError=E,exports.Router=P,exports.Subscription=b,exports.SubscriptionDestroyError=x,exports.assertNotBrowser=o,exports.createExpressMiddleware=function(t){return function(e,r){var n=e.path.substr(1);L(a({},t,{req:e,res:r,endpoint:n}))}},exports.createHttpHandler=R,exports.createHttpServer=function(t){var e=R(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=k(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,L(a({},t,{req:r,res:n,endpoint:o}));case 7:case"end":return e.stop()}}),e)})));return function(t,r){return e.apply(this,arguments)}}()},exports.getErrorResponseEnvelope=k,exports.getQueryInput=_,exports.httpError=O,exports.requestHandler=L,exports.router=function(){return new P},exports.subscriptionPullFatory=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.interval));case 11:case"end":return o.stop()}}),o,null,[[2,7]])})))).apply(this,arguments)}return new b({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(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.endpoint,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({getInitialOutput:function(){}},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,endpoint: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,endpoint: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,endpoint: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.subscriptionPullFatory=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.interval));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 |
@@ -0,3 +1,3 @@ | ||
| import url from 'url'; | ||
| import { EventEmitter } from 'events'; | ||
| import url from 'url'; | ||
| import http from 'http'; | ||
@@ -919,269 +919,2 @@ | ||
| var SubscriptionDestroyError = /*#__PURE__*/function (_Error) { | ||
| _inheritsLoose(SubscriptionDestroyError, _Error); | ||
| function SubscriptionDestroyError(reason) { | ||
| var _this; | ||
| _this = _Error.call(this, reason) || this; | ||
| _this.reason = reason; | ||
| Object.setPrototypeOf(_assertThisInitialized(_this), SubscriptionDestroyError.prototype); | ||
| return _this; | ||
| } | ||
| return SubscriptionDestroyError; | ||
| }( /*#__PURE__*/_wrapNativeSuper(Error)); // eslint-disable-next-line @typescript-eslint/no-unused-vars | ||
| var SubscriptionEventEmitter = /*#__PURE__*/function (_EventEmitter) { | ||
| _inheritsLoose(SubscriptionEventEmitter, _EventEmitter); | ||
| function SubscriptionEventEmitter() { | ||
| return _EventEmitter.apply(this, arguments) || this; | ||
| } | ||
| return SubscriptionEventEmitter; | ||
| }(EventEmitter); | ||
| var Subscription = /*#__PURE__*/function () { | ||
| function Subscription(opts) { | ||
| this.isDestroyed = false; | ||
| this.events = new SubscriptionEventEmitter(); | ||
| this.opts = _extends({ | ||
| getInitialOutput: function getInitialOutput() {// no-op | ||
| } | ||
| }, opts); | ||
| } | ||
| var _proto = Subscription.prototype; | ||
| _proto.destroy = function destroy(reason) { | ||
| if (this.isDestroyed) { | ||
| return; | ||
| } // debug('Subscription.destroy()', reason); | ||
| this.isDestroyed = true; | ||
| this.events.emit('destroy', reason); | ||
| this.events.removeAllListeners(); | ||
| }; | ||
| _proto.start = /*#__PURE__*/function () { | ||
| var _start = /*#__PURE__*/_asyncToGenerator( /*#__PURE__*/runtime_1.mark(function _callee() { | ||
| var _this2 = this; | ||
| var emit, cancel; | ||
| return runtime_1.wrap(function _callee$(_context) { | ||
| while (1) { | ||
| switch (_context.prev = _context.next) { | ||
| case 0: | ||
| if (!this.isDestroyed) { | ||
| _context.next = 2; | ||
| break; | ||
| } | ||
| throw new Error('Called start() on a destroyed subscription'); | ||
| case 2: | ||
| _context.prev = 2; | ||
| emit = { | ||
| error: function error(err) { | ||
| return _this2.emitError(err); | ||
| }, | ||
| data: function data(_data) { | ||
| return _this2.emitOutput(_data); | ||
| } | ||
| }; | ||
| _context.next = 6; | ||
| return this.opts.getInitialOutput(emit); | ||
| case 6: | ||
| cancel = this.opts.start(emit); | ||
| this.events.on('destroy', function () { | ||
| cancel(); | ||
| }); | ||
| _context.next = 13; | ||
| break; | ||
| case 10: | ||
| _context.prev = 10; | ||
| _context.t0 = _context["catch"](2); | ||
| this.emitError(_context.t0); | ||
| case 13: | ||
| case "end": | ||
| return _context.stop(); | ||
| } | ||
| } | ||
| }, _callee, this, [[2, 10]]); | ||
| })); | ||
| function start() { | ||
| return _start.apply(this, arguments); | ||
| } | ||
| return start; | ||
| }(); | ||
| _proto.onceOutputAndStop = /*#__PURE__*/function () { | ||
| var _onceOutputAndStop = /*#__PURE__*/_asyncToGenerator( /*#__PURE__*/runtime_1.mark(function _callee3() { | ||
| var _this3 = this; | ||
| return runtime_1.wrap(function _callee3$(_context3) { | ||
| while (1) { | ||
| switch (_context3.prev = _context3.next) { | ||
| case 0: | ||
| return _context3.abrupt("return", new Promise( /*#__PURE__*/function () { | ||
| var _ref = _asyncToGenerator( /*#__PURE__*/runtime_1.mark(function _callee2(resolve, reject) { | ||
| var onDestroy, onOutput, onError, cleanup; | ||
| return runtime_1.wrap(function _callee2$(_context2) { | ||
| while (1) { | ||
| switch (_context2.prev = _context2.next) { | ||
| case 0: | ||
| onDestroy = function onDestroy(reason) { | ||
| reject(new SubscriptionDestroyError(reason)); | ||
| cleanup(); | ||
| }; | ||
| onOutput = function onOutput(data) { | ||
| resolve(data); | ||
| cleanup(); | ||
| _this3.destroy('stopped'); | ||
| }; | ||
| onError = function onError(err) { | ||
| reject(err); | ||
| cleanup(); | ||
| _this3.destroy('stopped'); | ||
| }; | ||
| cleanup = function cleanup() { | ||
| _this3.events.off('data', onOutput); | ||
| _this3.events.off('destroy', onDestroy); | ||
| _this3.events.off('error', onError); | ||
| }; | ||
| _this3.events.once('data', onOutput); | ||
| _this3.events.once('destroy', onDestroy); | ||
| _this3.events.once('error', onError); | ||
| _this3.start()["catch"](function () {// is handled through event | ||
| }); | ||
| case 8: | ||
| case "end": | ||
| return _context2.stop(); | ||
| } | ||
| } | ||
| }, _callee2); | ||
| })); | ||
| return function (_x, _x2) { | ||
| return _ref.apply(this, arguments); | ||
| }; | ||
| }())); | ||
| case 1: | ||
| case "end": | ||
| return _context3.stop(); | ||
| } | ||
| } | ||
| }, _callee3); | ||
| })); | ||
| function onceOutputAndStop() { | ||
| return _onceOutputAndStop.apply(this, arguments); | ||
| } | ||
| return onceOutputAndStop; | ||
| }() | ||
| /** | ||
| * Emit data | ||
| */ | ||
| ; | ||
| _proto.emitOutput = function emitOutput(data) { | ||
| this.events.emit('data', data); | ||
| } | ||
| /** | ||
| * Emit error | ||
| */ | ||
| ; | ||
| _proto.emitError = function emitError(err) { | ||
| this.events.emit('error', err); | ||
| }; | ||
| return Subscription; | ||
| }(); | ||
| function subscriptionPullFatory(opts) { | ||
| // eslint-disable-next-line @typescript-eslint/no-explicit-any | ||
| var timer; | ||
| var stopped = false; | ||
| function _pull(_x3) { | ||
| return _pull2.apply(this, arguments); | ||
| } | ||
| function _pull2() { | ||
| _pull2 = _asyncToGenerator( /*#__PURE__*/runtime_1.mark(function _callee4(emit) { | ||
| return runtime_1.wrap(function _callee4$(_context4) { | ||
| while (1) { | ||
| switch (_context4.prev = _context4.next) { | ||
| case 0: | ||
| if (!stopped) { | ||
| _context4.next = 2; | ||
| break; | ||
| } | ||
| return _context4.abrupt("return"); | ||
| case 2: | ||
| _context4.prev = 2; | ||
| _context4.next = 5; | ||
| return opts.pull(emit); | ||
| case 5: | ||
| _context4.next = 10; | ||
| break; | ||
| case 7: | ||
| _context4.prev = 7; | ||
| _context4.t0 = _context4["catch"](2); | ||
| emit.error(_context4.t0); | ||
| case 10: | ||
| if (!stopped) { | ||
| timer = setTimeout(function () { | ||
| return _pull(emit); | ||
| }, opts.interval); | ||
| } | ||
| case 11: | ||
| case "end": | ||
| return _context4.stop(); | ||
| } | ||
| } | ||
| }, _callee4, null, [[2, 7]]); | ||
| })); | ||
| return _pull2.apply(this, arguments); | ||
| } | ||
| return new Subscription({ | ||
| start: function start(emit) { | ||
| _pull(emit); | ||
| return function () { | ||
| clearTimeout(timer); | ||
| stopped = true; | ||
| }; | ||
| } | ||
| }); | ||
| } | ||
| assertNotBrowser(); | ||
@@ -1318,3 +1051,3 @@ var HTTPError = /*#__PURE__*/function (_Error) { | ||
| _requestHandler = _asyncToGenerator( /*#__PURE__*/runtime_1.mark(function _callee2(_ref2) { | ||
| var req, res, router, endpoint, subscriptions, createContext, teardown, _ref2$transformer, transformer, maxBodySize, _req$method, _res$statusCode, output, ctx, method, deserializeInput, body, input, query, _input, _subscriptions$timeou, _body, _input2, sub, onClose, timeout, timer, json, _json; | ||
| var req, res, router, endpoint, subscriptions, createContext, teardown, _ref2$transformer, transformer, maxBodySize, _req$method, _res$statusCode, output, ctx, method, deserializeInput, body, input, query, _input, _body, _input2, sub, json, _json; | ||
@@ -1382,3 +1115,3 @@ return runtime_1.wrap(function _callee2$(_context2) { | ||
| output = _context2.sent; | ||
| _context2.next = 57; | ||
| _context2.next = 42; | ||
| break; | ||
@@ -1405,3 +1138,3 @@ | ||
| output = _context2.sent; | ||
| _context2.next = 57; | ||
| _context2.next = 42; | ||
| break; | ||
@@ -1411,3 +1144,3 @@ | ||
| if (!(method === 'PATCH')) { | ||
| _context2.next = 56; | ||
| _context2.next = 41; | ||
| break; | ||
@@ -1435,54 +1168,84 @@ } | ||
| sub = _context2.sent; | ||
| _context2.next = 38; | ||
| return new Promise(function (resolve, reject) { | ||
| var _subscriptions$reques, _subscriptions$backpr; | ||
| onClose = function onClose() { | ||
| sub.destroy('closed'); | ||
| }; // FIXME - refactor | ||
| // this is a bit complex | ||
| // needs to handle a few cases: | ||
| // - ok subscription | ||
| // - error subscription | ||
| // - request got prematurely closed | ||
| // - request timed out | ||
| var startTime = Date.now(); | ||
| var buffer = []; | ||
| var requestTimeoutMs = (_subscriptions$reques = subscriptions == null ? void 0 : subscriptions.requestTimeoutMs) != null ? _subscriptions$reques : 9000; // 10s is vercel's api timeout | ||
| var backpressureMs = (_subscriptions$backpr = subscriptions == null ? void 0 : subscriptions.backpressureMs) != null ? _subscriptions$backpr : 0; // timers | ||
| res.once('close', onClose); | ||
| timeout = (_subscriptions$timeou = subscriptions == null ? void 0 : subscriptions.timeout) != null ? _subscriptions$timeou : 9000; // 10s is vercel's api timeout | ||
| var backpressureTimer = null; | ||
| var requestTimeoutTimer = null; | ||
| timer = setTimeout(function () { | ||
| sub.destroy('timeout'); | ||
| }, timeout); | ||
| _context2.prev = 40; | ||
| _context2.next = 43; | ||
| return sub.onceOutputAndStop(); | ||
| function cleanup() { | ||
| sub.off('data', onData); | ||
| sub.off('error', onError); | ||
| sub.off('destroy', onDestroy); | ||
| req.off('close', onClose); | ||
| clearTimeout(requestTimeoutTimer); | ||
| clearTimeout(backpressureTimer); | ||
| sub.destroy(); | ||
| } | ||
| case 43: | ||
| output = _context2.sent; | ||
| res.off('close', onClose); | ||
| _context2.next = 54; | ||
| break; | ||
| function onData(data) { | ||
| buffer.push(data); | ||
| var requestTimeLeft = requestTimeoutMs - (Date.now() - startTime); | ||
| case 47: | ||
| _context2.prev = 47; | ||
| _context2.t1 = _context2["catch"](40); | ||
| res.off('close', onClose); | ||
| clearTimeout(timer); | ||
| var success = function success() { | ||
| cleanup(); | ||
| resolve(buffer); | ||
| }; | ||
| if (!(_context2.t1 instanceof SubscriptionDestroyError && _context2.t1.reason === 'timeout')) { | ||
| _context2.next = 53; | ||
| break; | ||
| } | ||
| if (requestTimeLeft >= backpressureMs) { | ||
| // will timeout before next backpressure tick | ||
| success(); | ||
| return; | ||
| } | ||
| throw new HTTPError(408, "Subscription exceeded " + timeout + "ms - please reconnect."); | ||
| if (!backpressureTimer) { | ||
| backpressureTimer = setTimeout(success, backpressureMs); | ||
| return; | ||
| } | ||
| } | ||
| case 53: | ||
| throw _context2.t1; | ||
| function onError(err) { | ||
| cleanup(); // maybe if `buffer` has length here we should just return instead? | ||
| case 54: | ||
| _context2.next = 57; | ||
| reject(err); | ||
| } | ||
| function onClose() { | ||
| cleanup(); | ||
| reject(new HTTPError(499, "Client Closed Request")); | ||
| } | ||
| function onRequestTimeout() { | ||
| cleanup(); | ||
| reject(new HTTPError(408, "Subscription exceeded " + requestTimeoutMs + "ms - please reconnect.")); | ||
| } | ||
| function onDestroy() { | ||
| reject(new HTTPError(500, "Subscription was destroyed prematurely")); | ||
| cleanup(); | ||
| } | ||
| sub.on('data', onData); | ||
| sub.on('error', onError); | ||
| sub.on('destroy', onDestroy); | ||
| req.once('close', onClose); | ||
| requestTimeoutTimer = setTimeout(onRequestTimeout, requestTimeoutMs); | ||
| sub.start(); | ||
| }); | ||
| case 38: | ||
| output = _context2.sent; | ||
| _context2.next = 42; | ||
| break; | ||
| case 56: | ||
| case 41: | ||
| throw httpError.badRequest("Unexpected request method " + method); | ||
| case 57: | ||
| case 42: | ||
| json = { | ||
@@ -1496,9 +1259,9 @@ ok: true, | ||
| res.end(JSON.stringify(transformer.serialize(json))); | ||
| _context2.next = 69; | ||
| _context2.next = 54; | ||
| break; | ||
| case 63: | ||
| _context2.prev = 63; | ||
| _context2.t2 = _context2["catch"](1); | ||
| _json = getErrorResponseEnvelope(_context2.t2); | ||
| case 48: | ||
| _context2.prev = 48; | ||
| _context2.t1 = _context2["catch"](1); | ||
| _json = getErrorResponseEnvelope(_context2.t1); | ||
| res.statusCode = _json.statusCode; | ||
@@ -1508,24 +1271,24 @@ res.setHeader('Content-Type', 'application/json'); | ||
| case 69: | ||
| _context2.prev = 69; | ||
| _context2.t3 = teardown; | ||
| case 54: | ||
| _context2.prev = 54; | ||
| _context2.t2 = teardown; | ||
| if (!_context2.t3) { | ||
| _context2.next = 74; | ||
| if (!_context2.t2) { | ||
| _context2.next = 59; | ||
| break; | ||
| } | ||
| _context2.next = 74; | ||
| _context2.next = 59; | ||
| return teardown(); | ||
| case 74: | ||
| _context2.next = 79; | ||
| case 59: | ||
| _context2.next = 64; | ||
| break; | ||
| case 76: | ||
| _context2.prev = 76; | ||
| _context2.t4 = _context2["catch"](69); | ||
| console.error('Teardown failed', _context2.t4); | ||
| case 61: | ||
| _context2.prev = 61; | ||
| _context2.t3 = _context2["catch"](54); | ||
| console.error('Teardown failed', _context2.t3); | ||
| case 79: | ||
| case 64: | ||
| case "end": | ||
@@ -1535,3 +1298,3 @@ return _context2.stop(); | ||
| } | ||
| }, _callee2, null, [[1, 63], [40, 47], [69, 76]]); | ||
| }, _callee2, null, [[1, 48], [54, 61]]); | ||
| })); | ||
@@ -1572,17 +1335,12 @@ return _requestHandler.apply(this, arguments); | ||
| return this.merge(router); | ||
| } | ||
| /** | ||
| * FIXME | ||
| * Would like to get `queries()`, etc, in place instead of `query()` | ||
| * Does not infer `input` in the resolver fn, needs some love | ||
| */ | ||
| // public queries( | ||
| // routes: RouteRecord<TContext, any, any>, | ||
| // ): Router<TContext, TQueries & typeof routes, TMutations, TSubscriptions> { | ||
| // const router = new Router({ | ||
| // queries: routes as any, | ||
| } // TODO / help: https://github.com/trpc/trpc/pull/37 | ||
| // public queries<TRoutes extends RouteRecord<TContext, any, any>>( | ||
| // routes: TRoutes, | ||
| // ): Router<TContext, TQueries & TRoutes, TMutations, TSubscriptions> { | ||
| // const router = new Router<TContext, any, {}, {}>({ | ||
| // queries: routes, | ||
| // mutations: {}, | ||
| // subscriptions: {}, | ||
| // }); | ||
| // return this.merge(router); | ||
| // return this.merge(router) as any; | ||
| // } | ||
@@ -1726,2 +1484,214 @@ ; | ||
| var SubscriptionEventEmitter = /*#__PURE__*/function (_EventEmitter) { | ||
| _inheritsLoose(SubscriptionEventEmitter, _EventEmitter); | ||
| function SubscriptionEventEmitter() { | ||
| return _EventEmitter.apply(this, arguments) || this; | ||
| } | ||
| return SubscriptionEventEmitter; | ||
| }(EventEmitter); | ||
| var Subscription = /*#__PURE__*/function () { | ||
| function Subscription(opts) { | ||
| this.isDestroyed = false; | ||
| this.events = new SubscriptionEventEmitter(); | ||
| this.opts = _extends({ | ||
| getInitialOutput: function getInitialOutput() {// no-op | ||
| } | ||
| }, opts); | ||
| } | ||
| var _proto = Subscription.prototype; | ||
| _proto.destroy = function destroy() { | ||
| if (this.isDestroyed) { | ||
| return; | ||
| } // debug('Subscription.destroy()', reason); | ||
| this.isDestroyed = true; | ||
| this.events.emit('destroy'); | ||
| this.events.removeAllListeners(); | ||
| }; | ||
| _proto.start = /*#__PURE__*/function () { | ||
| var _start = /*#__PURE__*/_asyncToGenerator( /*#__PURE__*/runtime_1.mark(function _callee() { | ||
| var _this = this; | ||
| var emit, cancel; | ||
| return runtime_1.wrap(function _callee$(_context) { | ||
| while (1) { | ||
| switch (_context.prev = _context.next) { | ||
| case 0: | ||
| if (!this.isDestroyed) { | ||
| _context.next = 2; | ||
| break; | ||
| } | ||
| throw new Error('Called start() on a destroyed subscription'); | ||
| case 2: | ||
| _context.prev = 2; | ||
| emit = { | ||
| error: function error(err) { | ||
| return _this.emitError(err); | ||
| }, | ||
| data: function data(_data) { | ||
| return _this.emitOutput(_data); | ||
| } | ||
| }; | ||
| _context.next = 6; | ||
| return this.opts.start(emit); | ||
| case 6: | ||
| cancel = _context.sent; | ||
| if (this.isDestroyed) { | ||
| cancel(); | ||
| } else { | ||
| this.events.on('destroy', cancel); | ||
| } | ||
| _context.next = 13; | ||
| break; | ||
| case 10: | ||
| _context.prev = 10; | ||
| _context.t0 = _context["catch"](2); | ||
| this.emitError(_context.t0); | ||
| case 13: | ||
| case "end": | ||
| return _context.stop(); | ||
| } | ||
| } | ||
| }, _callee, this, [[2, 10]]); | ||
| })); | ||
| function start() { | ||
| return _start.apply(this, arguments); | ||
| } | ||
| 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; | ||
| }() | ||
| /** | ||
| * Emit data | ||
| */ | ||
| ; | ||
| _proto.emitOutput = function emitOutput(data) { | ||
| this.events.emit('data', data); | ||
| } | ||
| /** | ||
| * Emit error | ||
| */ | ||
| ; | ||
| _proto.emitError = function emitError(err) { | ||
| this.events.emit('error', err); | ||
| }; | ||
| _proto.on = function on() { | ||
| var _this$events; | ||
| return (_this$events = this.events).on.apply(_this$events, arguments); | ||
| }; | ||
| _proto.off = function off() { | ||
| var _this$events2; | ||
| return (_this$events2 = this.events).off.apply(_this$events2, arguments); | ||
| }; | ||
| return Subscription; | ||
| }(); | ||
| function subscriptionPullFatory(opts) { | ||
| // eslint-disable-next-line @typescript-eslint/no-explicit-any | ||
| var timer; | ||
| var stopped = false; | ||
| function _pull(_x) { | ||
| return _pull2.apply(this, arguments); | ||
| } | ||
| function _pull2() { | ||
| _pull2 = _asyncToGenerator( /*#__PURE__*/runtime_1.mark(function _callee3(emit) { | ||
| return runtime_1.wrap(function _callee3$(_context3) { | ||
| while (1) { | ||
| switch (_context3.prev = _context3.next) { | ||
| case 0: | ||
| if (!stopped) { | ||
| _context3.next = 2; | ||
| break; | ||
| } | ||
| return _context3.abrupt("return"); | ||
| case 2: | ||
| _context3.prev = 2; | ||
| _context3.next = 5; | ||
| return opts.pull(emit); | ||
| case 5: | ||
| _context3.next = 10; | ||
| break; | ||
| case 7: | ||
| _context3.prev = 7; | ||
| _context3.t0 = _context3["catch"](2); | ||
| emit.error(_context3.t0); | ||
| case 10: | ||
| if (!stopped) { | ||
| timer = setTimeout(function () { | ||
| return _pull(emit); | ||
| }, opts.interval); | ||
| } | ||
| case 11: | ||
| case "end": | ||
| return _context3.stop(); | ||
| } | ||
| } | ||
| }, _callee3, null, [[2, 7]]); | ||
| })); | ||
| return _pull2.apply(this, arguments); | ||
| } | ||
| return new Subscription({ | ||
| start: function start(emit) { | ||
| _pull(emit); | ||
| return function () { | ||
| clearTimeout(timer); | ||
| stopped = true; | ||
| }; | ||
| } | ||
| }); | ||
| } | ||
| function createExpressMiddleware(opts) { | ||
@@ -1825,3 +1795,3 @@ return function (req, res) { | ||
| export { HTTPError, Router, Subscription, SubscriptionDestroyError, assertNotBrowser, createExpressMiddleware, createHttpHandler, createHttpServer, createNextApiHandler, getErrorResponseEnvelope, getQueryInput, httpError, requestHandler, router, subscriptionPullFatory }; | ||
| export { HTTPError, Router, Subscription, assertNotBrowser, createExpressMiddleware, createHttpHandler, createHttpServer, createNextApiHandler, getErrorResponseEnvelope, getQueryInput, httpError, requestHandler, router, subscriptionPullFatory }; | ||
| //# sourceMappingURL=server.esm.js.map |
@@ -1,6 +0,15 @@ | ||
| declare type SubscriptionDestroyReason = 'timeout' | 'stopped' | 'startError' | 'closed'; | ||
| export declare class SubscriptionDestroyError extends Error { | ||
| readonly reason: SubscriptionDestroyReason; | ||
| constructor(reason: SubscriptionDestroyReason); | ||
| /// <reference types="node" /> | ||
| import { EventEmitter } from 'events'; | ||
| interface SubscriptionEvents<TOutput> { | ||
| data: (data: TOutput) => void; | ||
| destroy: () => void; | ||
| error: (error: Error) => void; | ||
| } | ||
| declare interface SubscriptionEventEmitter<TOutput> { | ||
| on<U extends keyof SubscriptionEvents<TOutput>>(event: U, listener: SubscriptionEvents<TOutput>[U]): this; | ||
| once<U extends keyof SubscriptionEvents<TOutput>>(event: U, listener: SubscriptionEvents<TOutput>[U]): this; | ||
| emit<U extends keyof SubscriptionEvents<TOutput>>(event: U, ...args: Parameters<SubscriptionEvents<TOutput>[U]>): boolean; | ||
| } | ||
| declare class SubscriptionEventEmitter<TOutput> extends EventEmitter { | ||
| } | ||
| declare type UnsubscribeFn = () => void; | ||
@@ -14,3 +23,3 @@ declare type EmitFn<TOutput> = (data: TOutput) => void; | ||
| getInitialOutput?: (emit: SubscriptionEmit<TOutput>) => void | Promise<void>; | ||
| start: (emit: SubscriptionEmit<TOutput>) => UnsubscribeFn; | ||
| start: (emit: SubscriptionEmit<TOutput>) => UnsubscribeFn | Promise<UnsubscribeFn>; | ||
| } | ||
@@ -22,3 +31,3 @@ export declare class Subscription<TOutput = unknown> { | ||
| constructor(opts: SubscriptionOptions<TOutput>); | ||
| destroy(reason: SubscriptionDestroyReason): void; | ||
| destroy(): void; | ||
| start(): Promise<void>; | ||
@@ -34,2 +43,4 @@ onceOutputAndStop(): Promise<TOutput>; | ||
| emitError(err: Error): void; | ||
| on(...args: Parameters<SubscriptionEventEmitter<TOutput>['on']>): SubscriptionEventEmitter<TOutput>; | ||
| off(...args: Parameters<SubscriptionEventEmitter<TOutput>['off']>): SubscriptionEventEmitter<TOutput>; | ||
| } | ||
@@ -36,0 +47,0 @@ export declare function subscriptionPullFatory<TOutput>(opts: { |
| { | ||
| "name": "@trpc/server", | ||
| "version": "1.3.1", | ||
| "version": "1.4.0-alpha.0", | ||
| "description": "TRPC Server", | ||
@@ -46,3 +46,3 @@ "author": "KATT", | ||
| }, | ||
| "gitHead": "8b352b18cd900c5707afe6201c749c84625041d0" | ||
| "gitHead": "fc8af2d36a840ca91dc7e2bbd311d8d948f78fe4" | ||
| } |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
New alerts
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
No v1
QualityPackage is not semver >=1. This means it is not stable and does not support ^ ranges.
Found 1 instance in 1 package
Fixed alerts
License Policy Violation
LicenseThis 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
- decreased by-0.27%
396496
- Lines of code
- decreased by-1.11%
3306
- Number of low quality alerts
- increased by50%
3
No dependency changes