mercurius-chat
Advanced tools
Comparing version 0.2.0 to 0.3.0
@@ -6,3 +6,6 @@ import { IUser } from './IUser'; | ||
data: unknown; | ||
persistData?: boolean; | ||
persistData?: { | ||
connection: string; | ||
topic: string; | ||
}; | ||
} |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiSVNlbmQuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi8uLi9zcmMvaW50ZXJmYWNlcy9JU2VuZC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiIiwic291cmNlc0NvbnRlbnQiOlsiaW1wb3J0IHsgSVVzZXIgfSBmcm9tICcuL0lVc2VyJztcblxuZXhwb3J0IGludGVyZmFjZSBJU2VuZCB7XG4gIGZyb206IElVc2VyO1xuICByb29tOiB1bmtub3duO1xuICBkYXRhOiB1bmtub3duO1xuICBwZXJzaXN0RGF0YT86IGJvb2xlYW47XG59XG4iXX0= | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiSVNlbmQuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi8uLi9zcmMvaW50ZXJmYWNlcy9JU2VuZC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiIiwic291cmNlc0NvbnRlbnQiOlsiaW1wb3J0IHsgSVVzZXIgfSBmcm9tICcuL0lVc2VyJztcblxuZXhwb3J0IGludGVyZmFjZSBJU2VuZCB7XG4gIGZyb206IElVc2VyO1xuICByb29tOiB1bmtub3duO1xuICBkYXRhOiB1bmtub3duO1xuICBwZXJzaXN0RGF0YT86IHtcbiAgICBjb25uZWN0aW9uOiBzdHJpbmc7XG4gICAgdG9waWM6IHN0cmluZztcbiAgfTtcbn1cbiJdfQ== |
import { Server } from 'socket.io'; | ||
export declare const persistData: (params: any) => Promise<void>; | ||
export declare const connection: (io: Server, listener: Function) => void; | ||
export declare const join: (io: Server, callback: Function) => void; | ||
export declare const typing: (io: Server, callback: Function) => void; | ||
export declare const send: (io: Server, callback: Function) => void; | ||
export declare const join: (io: Server, callback?: Function) => void; | ||
export declare const typing: (io: Server, callback?: Function) => void; | ||
export declare const send: (io: Server, callback?: Function) => void; | ||
export declare const disconnect: (io: Server, callback?: Function) => void; | ||
declare const _default: { | ||
connection: (io: Server<import("socket.io/dist/typed-events").DefaultEventsMap, import("socket.io/dist/typed-events").DefaultEventsMap, import("socket.io/dist/typed-events").DefaultEventsMap, any>, listener: Function) => void; | ||
join: (io: Server<import("socket.io/dist/typed-events").DefaultEventsMap, import("socket.io/dist/typed-events").DefaultEventsMap, import("socket.io/dist/typed-events").DefaultEventsMap, any>, callback: Function) => void; | ||
send: (io: Server<import("socket.io/dist/typed-events").DefaultEventsMap, import("socket.io/dist/typed-events").DefaultEventsMap, import("socket.io/dist/typed-events").DefaultEventsMap, any>, callback: Function) => void; | ||
join: (io: Server<import("socket.io/dist/typed-events").DefaultEventsMap, import("socket.io/dist/typed-events").DefaultEventsMap, import("socket.io/dist/typed-events").DefaultEventsMap, any>, callback?: Function) => void; | ||
send: (io: Server<import("socket.io/dist/typed-events").DefaultEventsMap, import("socket.io/dist/typed-events").DefaultEventsMap, import("socket.io/dist/typed-events").DefaultEventsMap, any>, callback?: Function) => void; | ||
typing: (io: Server<import("socket.io/dist/typed-events").DefaultEventsMap, import("socket.io/dist/typed-events").DefaultEventsMap, import("socket.io/dist/typed-events").DefaultEventsMap, any>, callback?: Function) => void; | ||
disconnect: (io: Server<import("socket.io/dist/typed-events").DefaultEventsMap, import("socket.io/dist/typed-events").DefaultEventsMap, import("socket.io/dist/typed-events").DefaultEventsMap, any>, callback?: Function) => void; | ||
}; | ||
export default _default; |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.send = exports.typing = exports.join = exports.connection = exports.persistData = void 0; | ||
exports.disconnect = exports.send = exports.typing = exports.join = exports.connection = exports.persistData = void 0; | ||
const tslib_1 = require("tslib"); | ||
@@ -23,3 +23,3 @@ const sentry = (0, tslib_1.__importStar)(require("@sentry/node")); | ||
const join = (io, callback) => (0, exports.connection)(io, socket => { | ||
socket.on('join', async (payload) => { | ||
socket.on('join', (payload) => { | ||
socket.join(String(payload.room)); | ||
@@ -31,4 +31,4 @@ callback && callback(payload); | ||
const typing = (io, callback) => (0, exports.connection)(io, socket => { | ||
socket.on('typing', async (payload) => { | ||
io.to(String(payload.room)).emit('typing', payload); | ||
socket.on('typing', (payload) => { | ||
socket.to(String(payload.room)).emit('typing', payload); | ||
callback && callback(payload); | ||
@@ -39,6 +39,6 @@ }); | ||
const send = (io, callback) => (0, exports.connection)(io, socket => { | ||
socket.on('send', async (payload) => { | ||
io.to(String(payload.room)).emit('receive', payload.data); | ||
socket.on('send', (payload) => { | ||
socket.to(String(payload.room)).emit('receive', payload.data); | ||
if (!!payload.persistData) { | ||
(0, exports.persistData)({ connection: '', topic: '', payload }); | ||
(0, exports.persistData)(Object.assign(Object.assign({}, payload.persistData), { payload: payload.data })); | ||
} | ||
@@ -49,3 +49,10 @@ callback && callback(payload); | ||
exports.send = send; | ||
exports.default = { connection: exports.connection, join: exports.join, send: exports.send }; | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic29ja2V0LmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vc3JjL3NvY2tldC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7O0FBQUEsa0VBQXVDO0FBSXZDLHlDQUFpRDtBQUUxQyxNQUFNLFdBQVcsR0FBRyxLQUFLLEVBQUMsTUFBTSxFQUFDLEVBQUU7SUFDeEMsSUFBSTtRQUNGLE1BQU0sSUFBQSw4QkFBbUIsRUFBQyxNQUFNLENBQUMsQ0FBQztLQUNuQztJQUFDLE9BQU8sS0FBSyxFQUFFO1FBQ2QsTUFBTSxDQUFDLGdCQUFnQixDQUFDLEtBQUssQ0FBQyxDQUFDO0tBQ2hDO0FBQ0gsQ0FBQyxDQUFDO0FBTlcsUUFBQSxXQUFXLGVBTXRCO0FBRUssTUFBTSxVQUFVLEdBQUcsQ0FBQyxFQUFVLEVBQUUsUUFBa0IsRUFBRSxFQUFFO0lBQzNELEVBQUUsQ0FBQyxFQUFFLENBQUMsWUFBWSxFQUFFLE1BQU0sQ0FBQyxFQUFFO1FBQzNCLFFBQVEsQ0FBQyxNQUFNLENBQUMsQ0FBQztJQUNuQixDQUFDLENBQUMsQ0FBQztBQUNMLENBQUMsQ0FBQztBQUpXLFFBQUEsVUFBVSxjQUlyQjtBQUVLLE1BQU0sSUFBSSxHQUFHLENBQUMsRUFBVSxFQUFFLFFBQWtCLEVBQUUsRUFBRSxDQUNyRCxJQUFBLGtCQUFVLEVBQUMsRUFBRSxFQUFFLE1BQU0sQ0FBQyxFQUFFO0lBQ3RCLE1BQU0sQ0FBQyxFQUFFLENBQUMsTUFBTSxFQUFFLEtBQUssRUFBRSxPQUFjLEVBQUUsRUFBRTtRQUN6QyxNQUFNLENBQUMsSUFBSSxDQUFDLE1BQU0sQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLENBQUMsQ0FBQztRQUVsQyxRQUFRLElBQUksUUFBUSxDQUFDLE9BQU8sQ0FBQyxDQUFDO0lBQ2hDLENBQUMsQ0FBQyxDQUFDO0FBQ0wsQ0FBQyxDQUFDLENBQUM7QUFQUSxRQUFBLElBQUksUUFPWjtBQUVFLE1BQU0sTUFBTSxHQUFHLENBQUMsRUFBVSxFQUFFLFFBQWtCLEVBQUUsRUFBRSxDQUN2RCxJQUFBLGtCQUFVLEVBQUMsRUFBRSxFQUFFLE1BQU0sQ0FBQyxFQUFFO0lBQ3RCLE1BQU0sQ0FBQyxFQUFFLENBQUMsUUFBUSxFQUFFLEtBQUssRUFBRSxPQUFjLEVBQUUsRUFBRTtRQUMzQyxFQUFFLENBQUMsRUFBRSxDQUFDLE1BQU0sQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLENBQUMsQ0FBQyxJQUFJLENBQUMsUUFBUSxFQUFFLE9BQU8sQ0FBQyxDQUFDO1FBRXBELFFBQVEsSUFBSSxRQUFRLENBQUMsT0FBTyxDQUFDLENBQUM7SUFDaEMsQ0FBQyxDQUFDLENBQUM7QUFDTCxDQUFDLENBQUMsQ0FBQztBQVBRLFFBQUEsTUFBTSxVQU9kO0FBRUUsTUFBTSxJQUFJLEdBQUcsQ0FBQyxFQUFVLEVBQUUsUUFBa0IsRUFBRSxFQUFFLENBQ3JELElBQUEsa0JBQVUsRUFBQyxFQUFFLEVBQUUsTUFBTSxDQUFDLEVBQUU7SUFDdEIsTUFBTSxDQUFDLEVBQUUsQ0FBQyxNQUFNLEVBQUUsS0FBSyxFQUFFLE9BQWMsRUFBRSxFQUFFO1FBQ3pDLEVBQUUsQ0FBQyxFQUFFLENBQUMsTUFBTSxDQUFDLE9BQU8sQ0FBQyxJQUFJLENBQUMsQ0FBQyxDQUFDLElBQUksQ0FBQyxTQUFTLEVBQUUsT0FBTyxDQUFDLElBQUksQ0FBQyxDQUFDO1FBRTFELElBQUksQ0FBQyxDQUFDLE9BQU8sQ0FBQyxXQUFXLEVBQUU7WUFDekIsSUFBQSxtQkFBVyxFQUFDLEVBQUUsVUFBVSxFQUFFLEVBQUUsRUFBRSxLQUFLLEVBQUUsRUFBRSxFQUFFLE9BQU8sRUFBRSxDQUFDLENBQUM7U0FDckQ7UUFFRCxRQUFRLElBQUksUUFBUSxDQUFDLE9BQU8sQ0FBQyxDQUFDO0lBQ2hDLENBQUMsQ0FBQyxDQUFDO0FBQ0wsQ0FBQyxDQUFDLENBQUM7QUFYUSxRQUFBLElBQUksUUFXWjtBQUVMLGtCQUFlLEVBQUUsVUFBVSxFQUFWLGtCQUFVLEVBQUUsSUFBSSxFQUFKLFlBQUksRUFBRSxJQUFJLEVBQUosWUFBSSxFQUFFLENBQUMiLCJzb3VyY2VzQ29udGVudCI6WyJpbXBvcnQgKiBhcyBzZW50cnkgZnJvbSAnQHNlbnRyeS9ub2RlJztcblxuaW1wb3J0IHsgU2VydmVyIH0gZnJvbSAnc29ja2V0LmlvJztcbmltcG9ydCB7IElTZW5kIH0gZnJvbSAnLi9pbnRlcmZhY2VzL0lTZW5kJztcbmltcG9ydCB7IHNlbmRNZXNzYWdlVG9SYWJiaXQgfSBmcm9tICcuL3JhYmJpdG1xJztcblxuZXhwb3J0IGNvbnN0IHBlcnNpc3REYXRhID0gYXN5bmMgcGFyYW1zID0+IHtcbiAgdHJ5IHtcbiAgICBhd2FpdCBzZW5kTWVzc2FnZVRvUmFiYml0KHBhcmFtcyk7XG4gIH0gY2F0Y2ggKGVycm9yKSB7XG4gICAgc2VudHJ5LmNhcHR1cmVFeGNlcHRpb24oZXJyb3IpO1xuICB9XG59O1xuXG5leHBvcnQgY29uc3QgY29ubmVjdGlvbiA9IChpbzogU2VydmVyLCBsaXN0ZW5lcjogRnVuY3Rpb24pID0+IHtcbiAgaW8ub24oJ2Nvbm5lY3Rpb24nLCBzb2NrZXQgPT4ge1xuICAgIGxpc3RlbmVyKHNvY2tldCk7XG4gIH0pO1xufTtcblxuZXhwb3J0IGNvbnN0IGpvaW4gPSAoaW86IFNlcnZlciwgY2FsbGJhY2s6IEZ1bmN0aW9uKSA9PlxuICBjb25uZWN0aW9uKGlvLCBzb2NrZXQgPT4ge1xuICAgIHNvY2tldC5vbignam9pbicsIGFzeW5jIChwYXlsb2FkOiBJU2VuZCkgPT4ge1xuICAgICAgc29ja2V0LmpvaW4oU3RyaW5nKHBheWxvYWQucm9vbSkpO1xuXG4gICAgICBjYWxsYmFjayAmJiBjYWxsYmFjayhwYXlsb2FkKTtcbiAgICB9KTtcbiAgfSk7XG5cbmV4cG9ydCBjb25zdCB0eXBpbmcgPSAoaW86IFNlcnZlciwgY2FsbGJhY2s6IEZ1bmN0aW9uKSA9PlxuICBjb25uZWN0aW9uKGlvLCBzb2NrZXQgPT4ge1xuICAgIHNvY2tldC5vbigndHlwaW5nJywgYXN5bmMgKHBheWxvYWQ6IElTZW5kKSA9PiB7XG4gICAgICBpby50byhTdHJpbmcocGF5bG9hZC5yb29tKSkuZW1pdCgndHlwaW5nJywgcGF5bG9hZCk7XG5cbiAgICAgIGNhbGxiYWNrICYmIGNhbGxiYWNrKHBheWxvYWQpO1xuICAgIH0pO1xuICB9KTtcblxuZXhwb3J0IGNvbnN0IHNlbmQgPSAoaW86IFNlcnZlciwgY2FsbGJhY2s6IEZ1bmN0aW9uKSA9PlxuICBjb25uZWN0aW9uKGlvLCBzb2NrZXQgPT4ge1xuICAgIHNvY2tldC5vbignc2VuZCcsIGFzeW5jIChwYXlsb2FkOiBJU2VuZCkgPT4ge1xuICAgICAgaW8udG8oU3RyaW5nKHBheWxvYWQucm9vbSkpLmVtaXQoJ3JlY2VpdmUnLCBwYXlsb2FkLmRhdGEpO1xuXG4gICAgICBpZiAoISFwYXlsb2FkLnBlcnNpc3REYXRhKSB7XG4gICAgICAgIHBlcnNpc3REYXRhKHsgY29ubmVjdGlvbjogJycsIHRvcGljOiAnJywgcGF5bG9hZCB9KTtcbiAgICAgIH1cblxuICAgICAgY2FsbGJhY2sgJiYgY2FsbGJhY2socGF5bG9hZCk7XG4gICAgfSk7XG4gIH0pO1xuXG5leHBvcnQgZGVmYXVsdCB7IGNvbm5lY3Rpb24sIGpvaW4sIHNlbmQgfTtcbiJdfQ== | ||
const disconnect = (io, callback) => (0, exports.connection)(io, socket => { | ||
socket.on('disconnect', (payload) => { | ||
socket.to(String(payload.room)).emit('disconnect', payload); | ||
callback && callback(payload); | ||
}); | ||
}); | ||
exports.disconnect = disconnect; | ||
exports.default = { connection: exports.connection, join: exports.join, send: exports.send, typing: exports.typing, disconnect: exports.disconnect }; | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic29ja2V0LmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vc3JjL3NvY2tldC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7O0FBQUEsa0VBQXVDO0FBSXZDLHlDQUFpRDtBQUUxQyxNQUFNLFdBQVcsR0FBRyxLQUFLLEVBQUMsTUFBTSxFQUFDLEVBQUU7SUFDeEMsSUFBSTtRQUNGLE1BQU0sSUFBQSw4QkFBbUIsRUFBQyxNQUFNLENBQUMsQ0FBQztLQUNuQztJQUFDLE9BQU8sS0FBSyxFQUFFO1FBQ2QsTUFBTSxDQUFDLGdCQUFnQixDQUFDLEtBQUssQ0FBQyxDQUFDO0tBQ2hDO0FBQ0gsQ0FBQyxDQUFDO0FBTlcsUUFBQSxXQUFXLGVBTXRCO0FBRUssTUFBTSxVQUFVLEdBQUcsQ0FBQyxFQUFVLEVBQUUsUUFBa0IsRUFBRSxFQUFFO0lBQzNELEVBQUUsQ0FBQyxFQUFFLENBQUMsWUFBWSxFQUFFLE1BQU0sQ0FBQyxFQUFFO1FBQzNCLFFBQVEsQ0FBQyxNQUFNLENBQUMsQ0FBQztJQUNuQixDQUFDLENBQUMsQ0FBQztBQUNMLENBQUMsQ0FBQztBQUpXLFFBQUEsVUFBVSxjQUlyQjtBQUVLLE1BQU0sSUFBSSxHQUFHLENBQUMsRUFBVSxFQUFFLFFBQW1CLEVBQUUsRUFBRSxDQUN0RCxJQUFBLGtCQUFVLEVBQUMsRUFBRSxFQUFFLE1BQU0sQ0FBQyxFQUFFO0lBQ3RCLE1BQU0sQ0FBQyxFQUFFLENBQUMsTUFBTSxFQUFFLENBQUMsT0FBYyxFQUFFLEVBQUU7UUFDbkMsTUFBTSxDQUFDLElBQUksQ0FBQyxNQUFNLENBQUMsT0FBTyxDQUFDLElBQUksQ0FBQyxDQUFDLENBQUM7UUFFbEMsUUFBUSxJQUFJLFFBQVEsQ0FBQyxPQUFPLENBQUMsQ0FBQztJQUNoQyxDQUFDLENBQUMsQ0FBQztBQUNMLENBQUMsQ0FBQyxDQUFDO0FBUFEsUUFBQSxJQUFJLFFBT1o7QUFFRSxNQUFNLE1BQU0sR0FBRyxDQUFDLEVBQVUsRUFBRSxRQUFtQixFQUFFLEVBQUUsQ0FDeEQsSUFBQSxrQkFBVSxFQUFDLEVBQUUsRUFBRSxNQUFNLENBQUMsRUFBRTtJQUN0QixNQUFNLENBQUMsRUFBRSxDQUFDLFFBQVEsRUFBRSxDQUFDLE9BQWMsRUFBRSxFQUFFO1FBQ3JDLE1BQU0sQ0FBQyxFQUFFLENBQUMsTUFBTSxDQUFDLE9BQU8sQ0FBQyxJQUFJLENBQUMsQ0FBQyxDQUFDLElBQUksQ0FBQyxRQUFRLEVBQUUsT0FBTyxDQUFDLENBQUM7UUFFeEQsUUFBUSxJQUFJLFFBQVEsQ0FBQyxPQUFPLENBQUMsQ0FBQztJQUNoQyxDQUFDLENBQUMsQ0FBQztBQUNMLENBQUMsQ0FBQyxDQUFDO0FBUFEsUUFBQSxNQUFNLFVBT2Q7QUFFRSxNQUFNLElBQUksR0FBRyxDQUFDLEVBQVUsRUFBRSxRQUFtQixFQUFFLEVBQUUsQ0FDdEQsSUFBQSxrQkFBVSxFQUFDLEVBQUUsRUFBRSxNQUFNLENBQUMsRUFBRTtJQUN0QixNQUFNLENBQUMsRUFBRSxDQUFDLE1BQU0sRUFBRSxDQUFDLE9BQWMsRUFBRSxFQUFFO1FBQ25DLE1BQU0sQ0FBQyxFQUFFLENBQUMsTUFBTSxDQUFDLE9BQU8sQ0FBQyxJQUFJLENBQUMsQ0FBQyxDQUFDLElBQUksQ0FBQyxTQUFTLEVBQUUsT0FBTyxDQUFDLElBQUksQ0FBQyxDQUFDO1FBRTlELElBQUksQ0FBQyxDQUFDLE9BQU8sQ0FBQyxXQUFXLEVBQUU7WUFDekIsSUFBQSxtQkFBVyxrQ0FBTSxPQUFPLENBQUMsV0FBVyxLQUFFLE9BQU8sRUFBRSxPQUFPLENBQUMsSUFBSSxJQUFHLENBQUM7U0FDaEU7UUFFRCxRQUFRLElBQUksUUFBUSxDQUFDLE9BQU8sQ0FBQyxDQUFDO0lBQ2hDLENBQUMsQ0FBQyxDQUFDO0FBQ0wsQ0FBQyxDQUFDLENBQUM7QUFYUSxRQUFBLElBQUksUUFXWjtBQUVFLE1BQU0sVUFBVSxHQUFHLENBQUMsRUFBVSxFQUFFLFFBQW1CLEVBQUUsRUFBRSxDQUM1RCxJQUFBLGtCQUFVLEVBQUMsRUFBRSxFQUFFLE1BQU0sQ0FBQyxFQUFFO0lBQ3RCLE1BQU0sQ0FBQyxFQUFFLENBQUMsWUFBWSxFQUFFLENBQUMsT0FBYyxFQUFFLEVBQUU7UUFDekMsTUFBTSxDQUFDLEVBQUUsQ0FBQyxNQUFNLENBQUMsT0FBTyxDQUFDLElBQUksQ0FBQyxDQUFDLENBQUMsSUFBSSxDQUFDLFlBQVksRUFBRSxPQUFPLENBQUMsQ0FBQztRQUU1RCxRQUFRLElBQUksUUFBUSxDQUFDLE9BQU8sQ0FBQyxDQUFDO0lBQ2hDLENBQUMsQ0FBQyxDQUFDO0FBQ0wsQ0FBQyxDQUFDLENBQUM7QUFQUSxRQUFBLFVBQVUsY0FPbEI7QUFFTCxrQkFBZSxFQUFFLFVBQVUsRUFBVixrQkFBVSxFQUFFLElBQUksRUFBSixZQUFJLEVBQUUsSUFBSSxFQUFKLFlBQUksRUFBRSxNQUFNLEVBQU4sY0FBTSxFQUFFLFVBQVUsRUFBVixrQkFBVSxFQUFFLENBQUMiLCJzb3VyY2VzQ29udGVudCI6WyJpbXBvcnQgKiBhcyBzZW50cnkgZnJvbSAnQHNlbnRyeS9ub2RlJztcblxuaW1wb3J0IHsgU2VydmVyIH0gZnJvbSAnc29ja2V0LmlvJztcbmltcG9ydCB7IElTZW5kIH0gZnJvbSAnLi9pbnRlcmZhY2VzL0lTZW5kJztcbmltcG9ydCB7IHNlbmRNZXNzYWdlVG9SYWJiaXQgfSBmcm9tICcuL3JhYmJpdG1xJztcblxuZXhwb3J0IGNvbnN0IHBlcnNpc3REYXRhID0gYXN5bmMgcGFyYW1zID0+IHtcbiAgdHJ5IHtcbiAgICBhd2FpdCBzZW5kTWVzc2FnZVRvUmFiYml0KHBhcmFtcyk7XG4gIH0gY2F0Y2ggKGVycm9yKSB7XG4gICAgc2VudHJ5LmNhcHR1cmVFeGNlcHRpb24oZXJyb3IpO1xuICB9XG59O1xuXG5leHBvcnQgY29uc3QgY29ubmVjdGlvbiA9IChpbzogU2VydmVyLCBsaXN0ZW5lcjogRnVuY3Rpb24pID0+IHtcbiAgaW8ub24oJ2Nvbm5lY3Rpb24nLCBzb2NrZXQgPT4ge1xuICAgIGxpc3RlbmVyKHNvY2tldCk7XG4gIH0pO1xufTtcblxuZXhwb3J0IGNvbnN0IGpvaW4gPSAoaW86IFNlcnZlciwgY2FsbGJhY2s/OiBGdW5jdGlvbikgPT5cbiAgY29ubmVjdGlvbihpbywgc29ja2V0ID0+IHtcbiAgICBzb2NrZXQub24oJ2pvaW4nLCAocGF5bG9hZDogSVNlbmQpID0+IHtcbiAgICAgIHNvY2tldC5qb2luKFN0cmluZyhwYXlsb2FkLnJvb20pKTtcblxuICAgICAgY2FsbGJhY2sgJiYgY2FsbGJhY2socGF5bG9hZCk7XG4gICAgfSk7XG4gIH0pO1xuXG5leHBvcnQgY29uc3QgdHlwaW5nID0gKGlvOiBTZXJ2ZXIsIGNhbGxiYWNrPzogRnVuY3Rpb24pID0+XG4gIGNvbm5lY3Rpb24oaW8sIHNvY2tldCA9PiB7XG4gICAgc29ja2V0Lm9uKCd0eXBpbmcnLCAocGF5bG9hZDogSVNlbmQpID0+IHtcbiAgICAgIHNvY2tldC50byhTdHJpbmcocGF5bG9hZC5yb29tKSkuZW1pdCgndHlwaW5nJywgcGF5bG9hZCk7XG5cbiAgICAgIGNhbGxiYWNrICYmIGNhbGxiYWNrKHBheWxvYWQpO1xuICAgIH0pO1xuICB9KTtcblxuZXhwb3J0IGNvbnN0IHNlbmQgPSAoaW86IFNlcnZlciwgY2FsbGJhY2s/OiBGdW5jdGlvbikgPT5cbiAgY29ubmVjdGlvbihpbywgc29ja2V0ID0+IHtcbiAgICBzb2NrZXQub24oJ3NlbmQnLCAocGF5bG9hZDogSVNlbmQpID0+IHtcbiAgICAgIHNvY2tldC50byhTdHJpbmcocGF5bG9hZC5yb29tKSkuZW1pdCgncmVjZWl2ZScsIHBheWxvYWQuZGF0YSk7XG5cbiAgICAgIGlmICghIXBheWxvYWQucGVyc2lzdERhdGEpIHtcbiAgICAgICAgcGVyc2lzdERhdGEoeyAuLi5wYXlsb2FkLnBlcnNpc3REYXRhLCBwYXlsb2FkOiBwYXlsb2FkLmRhdGEgfSk7XG4gICAgICB9XG5cbiAgICAgIGNhbGxiYWNrICYmIGNhbGxiYWNrKHBheWxvYWQpO1xuICAgIH0pO1xuICB9KTtcblxuZXhwb3J0IGNvbnN0IGRpc2Nvbm5lY3QgPSAoaW86IFNlcnZlciwgY2FsbGJhY2s/OiBGdW5jdGlvbikgPT5cbiAgY29ubmVjdGlvbihpbywgc29ja2V0ID0+IHtcbiAgICBzb2NrZXQub24oJ2Rpc2Nvbm5lY3QnLCAocGF5bG9hZDogSVNlbmQpID0+IHtcbiAgICAgIHNvY2tldC50byhTdHJpbmcocGF5bG9hZC5yb29tKSkuZW1pdCgnZGlzY29ubmVjdCcsIHBheWxvYWQpO1xuXG4gICAgICBjYWxsYmFjayAmJiBjYWxsYmFjayhwYXlsb2FkKTtcbiAgICB9KTtcbiAgfSk7XG5cbmV4cG9ydCBkZWZhdWx0IHsgY29ubmVjdGlvbiwgam9pbiwgc2VuZCwgdHlwaW5nLCBkaXNjb25uZWN0IH07XG4iXX0= |
{ | ||
"name": "mercurius-chat", | ||
"version": "0.2.0", | ||
"version": "0.3.0", | ||
"description": "Micro service chat", | ||
@@ -5,0 +5,0 @@ "main": "dist/index.js", |
23520
326