message-bridge-js
Advanced tools
Comparing version 0.1.4 to 0.1.5
@@ -1,8 +0,11 @@ | ||
import { v4 as uuidv4 } from "uuid"; | ||
import { MessageDirection, MessageType } from "./MessageBridgeInterfaces"; | ||
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.Message = void 0; | ||
var uuid_1 = require("uuid"); | ||
var MessageBridgeInterfaces_1 = require("./MessageBridgeInterfaces"); | ||
var Message = /** @class */ (function () { | ||
function Message(name, type, payload, schema, trackId, created, direction) { | ||
if (trackId === void 0) { trackId = uuidv4(); } | ||
if (trackId === void 0) { trackId = uuid_1.v4(); } | ||
if (created === void 0) { created = new Date(Date.now()).toJSON(); } | ||
if (direction === void 0) { direction = MessageDirection.ToServer; } | ||
if (direction === void 0) { direction = MessageBridgeInterfaces_1.MessageDirection.ToServer; } | ||
this.name = name; | ||
@@ -15,3 +18,3 @@ this.type = type; | ||
this.direction = direction; | ||
this.isError = type === MessageType.Error; | ||
this.isError = type === MessageBridgeInterfaces_1.MessageType.Error; | ||
} | ||
@@ -22,3 +25,3 @@ Message.create = function (opt) { | ||
Message.fromDto = function (msg, direction) { | ||
if (direction === void 0) { direction = MessageDirection.ToClient; } | ||
if (direction === void 0) { direction = MessageBridgeInterfaces_1.MessageDirection.ToClient; } | ||
return new Message(msg.name, msg.type, msg.payload, msg.schema, msg.trackId, msg.created, direction); | ||
@@ -28,3 +31,3 @@ }; | ||
}()); | ||
export { Message }; | ||
exports.Message = Message; | ||
//# sourceMappingURL=Message.js.map |
@@ -1,2 +0,5 @@ | ||
export var MessageType; | ||
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.MessageDirection = exports.MessageType = void 0; | ||
var MessageType; | ||
(function (MessageType) { | ||
@@ -9,8 +12,8 @@ MessageType["Command"] = "Command"; | ||
MessageType["Error"] = "Error"; | ||
})(MessageType || (MessageType = {})); | ||
export var MessageDirection; | ||
})(MessageType = exports.MessageType || (exports.MessageType = {})); | ||
var MessageDirection; | ||
(function (MessageDirection) { | ||
MessageDirection["ToClient"] = "ToClient"; | ||
MessageDirection["ToServer"] = "ToServer"; | ||
})(MessageDirection || (MessageDirection = {})); | ||
})(MessageDirection = exports.MessageDirection || (exports.MessageDirection = {})); | ||
//# sourceMappingURL=MessageBridgeInterfaces.js.map |
@@ -1,3 +0,8 @@ | ||
export { SignalRMessageBridgeService as MessageBridgeService } from "./SignalRMessageBridgeService"; | ||
export { WebsocketMessageBridgeService } from "./WebsocketMessageBridgeService"; | ||
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.WebsocketMessageBridgeService = exports.MessageBridgeService = void 0; | ||
var SignalRMessageBridgeService_1 = require("./SignalRMessageBridgeService"); | ||
Object.defineProperty(exports, "MessageBridgeService", { enumerable: true, get: function () { return SignalRMessageBridgeService_1.SignalRMessageBridgeService; } }); | ||
var WebsocketMessageBridgeService_1 = require("./WebsocketMessageBridgeService"); | ||
Object.defineProperty(exports, "WebsocketMessageBridgeService", { enumerable: true, get: function () { return WebsocketMessageBridgeService_1.WebsocketMessageBridgeService; } }); | ||
//# sourceMappingURL=MessageBridgeService.js.map |
@@ -1,3 +0,6 @@ | ||
import { Message } from "./Message"; | ||
import { MessageDirection, MessageType, } from "./MessageBridgeInterfaces"; | ||
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.MessageBridgeServiceBase = void 0; | ||
var Message_1 = require("./Message"); | ||
var MessageBridgeInterfaces_1 = require("./MessageBridgeInterfaces"); | ||
var MessageBridgeServiceBase = /** @class */ (function () { | ||
@@ -13,2 +16,3 @@ function MessageBridgeServiceBase(wsUri) { | ||
} | ||
// return this.connection.start(); | ||
MessageBridgeServiceBase.prototype.onMessage = function (messageString) { | ||
@@ -28,3 +32,3 @@ var messageDto; | ||
try { | ||
var msg = Message.fromDto(messageDto); | ||
var msg = Message_1.Message.fromDto(messageDto); | ||
this.handleIncomingMessage(msg); | ||
@@ -37,3 +41,3 @@ } | ||
MessageBridgeServiceBase.prototype.sendMessage = function (msg, onSuccess, onError) { | ||
msg.direction = MessageDirection.ToServer; | ||
msg.direction = MessageBridgeInterfaces_1.MessageDirection.ToServer; | ||
if (onSuccess || onError) { | ||
@@ -60,6 +64,6 @@ this.subscriptionTrackIdList[msg.trackId] = { onSuccess: onSuccess, onError: onError }; | ||
MessageBridgeServiceBase.prototype.createCommandMessage = function (name, payload, direction) { | ||
if (direction === void 0) { direction = MessageDirection.ToServer; } | ||
return Message.create({ | ||
if (direction === void 0) { direction = MessageBridgeInterfaces_1.MessageDirection.ToServer; } | ||
return Message_1.Message.create({ | ||
name: name, | ||
type: MessageType.Command, | ||
type: MessageBridgeInterfaces_1.MessageType.Command, | ||
payload: payload, | ||
@@ -70,6 +74,6 @@ direction: direction, | ||
MessageBridgeServiceBase.prototype.createQueryMessage = function (name, payload, direction) { | ||
if (direction === void 0) { direction = MessageDirection.ToServer; } | ||
return Message.create({ | ||
if (direction === void 0) { direction = MessageBridgeInterfaces_1.MessageDirection.ToServer; } | ||
return Message_1.Message.create({ | ||
name: name, | ||
type: MessageType.Query, | ||
type: MessageBridgeInterfaces_1.MessageType.Query, | ||
payload: payload, | ||
@@ -80,6 +84,6 @@ direction: direction, | ||
MessageBridgeServiceBase.prototype.createEventMessage = function (name, payload, direction) { | ||
if (direction === void 0) { direction = MessageDirection.ToServer; } | ||
return Message.create({ | ||
if (direction === void 0) { direction = MessageBridgeInterfaces_1.MessageDirection.ToServer; } | ||
return Message_1.Message.create({ | ||
name: name, | ||
type: MessageType.Event, | ||
type: MessageBridgeInterfaces_1.MessageType.Event, | ||
payload: payload, | ||
@@ -133,3 +137,3 @@ direction: direction, | ||
if (this.subscriptionTrackIdList[msg.trackId]) { | ||
if (msg.type === MessageType.Error) { | ||
if (msg.type === MessageBridgeInterfaces_1.MessageType.Error) { | ||
(_b = (_a = this.subscriptionTrackIdList[msg.trackId]).onError) === null || _b === void 0 ? void 0 : _b.call(_a, msg.payload, msg); | ||
@@ -142,3 +146,3 @@ } | ||
} | ||
if (msg.type === MessageType.Event) { | ||
if (msg.type === MessageBridgeInterfaces_1.MessageType.Event) { | ||
this.receiveEventMessage(msg); | ||
@@ -163,3 +167,3 @@ } | ||
}()); | ||
export { MessageBridgeServiceBase }; | ||
exports.MessageBridgeServiceBase = MessageBridgeServiceBase; | ||
//# sourceMappingURL=MessageBridgeServiceBase.js.map |
@@ -0,1 +1,2 @@ | ||
"use strict"; | ||
var __extends = (this && this.__extends) || (function () { | ||
@@ -16,4 +17,25 @@ var extendStatics = function (d, b) { | ||
})(); | ||
import * as signalR from "@microsoft/signalr"; | ||
import { MessageBridgeServiceBase } from "./MessageBridgeServiceBase"; | ||
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) { | ||
if (k2 === undefined) k2 = k; | ||
Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } }); | ||
}) : (function(o, m, k, k2) { | ||
if (k2 === undefined) k2 = k; | ||
o[k2] = m[k]; | ||
})); | ||
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) { | ||
Object.defineProperty(o, "default", { enumerable: true, value: v }); | ||
}) : function(o, v) { | ||
o["default"] = v; | ||
}); | ||
var __importStar = (this && this.__importStar) || function (mod) { | ||
if (mod && mod.__esModule) return mod; | ||
var result = {}; | ||
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k); | ||
__setModuleDefault(result, mod); | ||
return result; | ||
}; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.SignalRMessageBridgeService = void 0; | ||
var signalR = __importStar(require("@microsoft/signalr")); | ||
var MessageBridgeServiceBase_1 = require("./MessageBridgeServiceBase"); | ||
var SignalRMessageBridgeService = /** @class */ (function (_super) { | ||
@@ -53,4 +75,4 @@ __extends(SignalRMessageBridgeService, _super); | ||
return SignalRMessageBridgeService; | ||
}(MessageBridgeServiceBase)); | ||
export { SignalRMessageBridgeService }; | ||
}(MessageBridgeServiceBase_1.MessageBridgeServiceBase)); | ||
exports.SignalRMessageBridgeService = SignalRMessageBridgeService; | ||
//# sourceMappingURL=SignalRMessageBridgeService.js.map |
@@ -0,1 +1,2 @@ | ||
"use strict"; | ||
var __extends = (this && this.__extends) || (function () { | ||
@@ -16,3 +17,5 @@ var extendStatics = function (d, b) { | ||
})(); | ||
import { MessageBridgeServiceBase } from "./MessageBridgeServiceBase"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.WebsocketMessageBridgeService = void 0; | ||
var MessageBridgeServiceBase_1 = require("./MessageBridgeServiceBase"); | ||
var WebsocketMessageBridgeService = /** @class */ (function (_super) { | ||
@@ -45,4 +48,4 @@ __extends(WebsocketMessageBridgeService, _super); | ||
return WebsocketMessageBridgeService; | ||
}(MessageBridgeServiceBase)); | ||
export { WebsocketMessageBridgeService }; | ||
}(MessageBridgeServiceBase_1.MessageBridgeServiceBase)); | ||
exports.WebsocketMessageBridgeService = WebsocketMessageBridgeService; | ||
//# sourceMappingURL=WebsocketMessageBridgeService.js.map |
@@ -0,1 +1,5 @@ | ||
## 0.1.4 | ||
publish a commonjs build under tag @commonjs | ||
## 0.1.0-4 | ||
@@ -2,0 +6,0 @@ |
{ | ||
"name": "message-bridge-js", | ||
"version": "0.1.4", | ||
"version": "0.1.5", | ||
"homepage": "https://github.com/alfnielsen/MessageBridgeJS", | ||
@@ -5,0 +5,0 @@ "repository": { |
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
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
Sorry, the diff of this file is not supported yet
53272
789