Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 | 1x 1x 1x 1x 1x 1x 2x 2x 2x 2x 1x 12x 12x 12x 12x 2x 10x 10x | "use strict";
var fluid = require("infusion");
var gpii = fluid.registerNamespace("gpii");
fluid.registerNamespace("gpii.flowManager");
fluid.defaults("gpii.flowManager.browserChannel", {
gradeNames: ["fluid.modelComponent"]
});
fluid.defaults("gpii.flowManager.browserChannel.handler", {
gradeNames: ["kettle.request.ws", "gpii.flowManager.sessionAware"],
listeners: {
onReceiveMessage: {
funcName: "gpii.flowManager.browserChannel.receiveMessage",
args: ["{that}",
"{arguments}.1",
"{flowManager}.solutionsRegistryDataSource",
"{deviceReporter}.platformReporter"]
}
}
});
gpii.flowManager.browserChannel.sendError = function (request, message) {
fluid.log("Sending browserChannel error ", message);
var error = {
isError: true,
message: message
};
request.sendMessage(error);
// These codes bizarrely are not HTTP codes, but listed here: https://developer.mozilla.org/en-US/docs/Web/API/CloseEvent
request.ws.close(1008, "Solution id not authorized");
};
gpii.flowManager.browserChannel.receiveMessage = function (that, message, solutionsRegistryDataSource, platformReporter) {
var solutionId = message.payload.solutionId;
Iif (that.established) {
gpii.flowManager.browserChannel.sendError(that, "Connection already established - cannot send a second connect message");
}
solutionsRegistryDataSource.get({os: platformReporter.reportPlatform().id}, function onSuccess(entries) {
if (!(solutionId in entries)) {
gpii.flowManager.browserChannel.sendError(that, "Rejecting a connection request from '" + solutionId +
"'. The solution id was not found in the solutions registry");
} else {
gpii.settingsHandlers.webSockets.instance.addClient(solutionId, that);
that.established = true;
}
}, function (error) {
gpii.flowManager.browserChannel.sendError(that, error.message);
});
};
|