///
(function ($, window) {
///
"use strict";
if (typeof ($) !== "function") {
// no jQuery!
throw "SignalR: jQuery not found. Please ensure jQuery is referenced before the SignalR.js file.";
}
if (!window.JSON) {
// no JSON!
throw "SignalR: No JSON parser found. Please ensure json2.js is referenced before the SignalR.js file if you need to support clients without native JSON parsing support, e.g. IE<8.";
}
var signalR, _connection;
signalR = function (url) {
/// Creates a new SignalR connection for the given url
/// The URL of the long polling endpoint
///
return new signalR.fn.init(url);
};
signalR.fn = signalR.prototype = {
init: function (url) {
this.url = url;
},
start: function (options, callback) {
/// Starts the connection
/// Options map
/// A callback function to execute when the connection has started
///
var connection = this,
config = {
transport: "auto"
},
initialize;
if (connection.transport) {
// Already started, just return
return connection;
}
if ($.type(options) === "function") {
// Support calling with single callback parameter
callback = options;
} else if ($.type(options) === "object") {
$.extend(config, options);
if ($.type(config.callback) === "function") {
callback = config.callback;
}
}
if ($.type(callback) === "function") {
$(connection).bind("onStart", function (e, data) {
callback.call(connection);
});
}
initialize = function (transports, index) {
index = index || 0;
if (index >= transports.length) {
if (!connection.transport) {
// No transport initialized successfully
throw "SignalR: No transport could be initialized successfully. Try specifying a different transport or none at all for auto initialization.";
}
return;
}
var transportName = transports[index],
transport = $.type(transportName) === "object" ? transportName : signalR.transports[transportName];
transport.start(connection, function () {
connection.transport = transport;
$(connection).trigger("onStart");
}, function () {
initialize(transports, index + 1);
});
};
window.setTimeout(function () {
$.post(connection.url + '/negotiate', {}, function (res) {
connection.appRelativeUrl = res.Url;
connection.clientId = res.ClientId;
$(connection).trigger("onStarting");
var transports = [],
supportedTransports = [];
$.each(signalR.transports, function (key) {
supportedTransports.push(key);
});
if ($.isArray(config.transport)) {
// ordered list provided
$.each(config.transport, function () {
var transport = this;
if ($.type(transport) === "object" || ($.type(transport) === "string" && $.inArray("" + transport, supportedTransports) >= 0)) {
transports.push($.type(transport) === "string" ? "" + transport : transport);
}
});
} else if ($.type(config.transport) === "object" ||
$.inArray(config.transport, supportedTransports) >= 0) {
// specific transport provided, as object or a named transport, e.g. "longPolling"
transports.push(config.transport);
} else { // default "auto"
transports = supportedTransports;
}
initialize(transports);
});
}, 0);
return connection;
},
starting: function (callback) {
/// Adds a callback that will be invoked before the connection is started
/// A callback function to execute when the connection is starting
///
var connection = this;
$(connection).bind("onStarting", function (e, data) {
callback.call(connection);
});
return connection;
},
send: function (data) {
/// Sends data over the connection
/// The data to send over the connection
///
var connection = this;
if (!connection.transport) {
// Connection hasn't been started yet
throw "ChatR: Connection must be started before data can be sent. Call .start() before .send()";
}
connection.transport.send(connection, data);
return connection;
},
sending: function (callback) {
/// Adds a callback that will be invoked before anything is sent over the connection
/// A callback function to execute before each time data is sent on the connection
///
var connection = this;
$(connection).bind("onSending", function (e, data) {
callback.call(connection);
});
return connection;
},
received: function (callback) {
/// Adds a callback that will be invoked after anything is received over the connection
/// A callback function to execute when any data is received on the connection
///
var connection = this;
$(connection).bind("onReceived", function (e, data) {
callback.call(connection, data);
});
return connection;
},
error: function (callback) {
/// Adds a callback that will be invoked after an error occurs with the connection
/// A callback function to execute when an error occurs on the connection
///
var connection = this;
$(connection).bind("onError", function (e, data) {
callback.call(connection);
});
return connection;
},
stop: function () {
/// Stops listening
///
var connection = this;
if (connection.transport) {
connection.transport.stop(connection);
connection.transport = null;
}
return connection;
}
};
signalR.fn.init.prototype = signalR.fn;
// Transports
signalR.transports = {
webSockets: {
send: function (connection, data) {
connection.socket.send(data);
},
start: function (connection, onSuccess, onFailed) {
var url,
opened = false;
if (window.MozWebSocket) {
window.WebSocket = window.MozWebSocket;
}
if (!window.WebSocket) {
onFailed();
return;
}
if (!connection.socket) {
// Build the url
url = document.location.host + connection.appRelativeUrl;
$(connection).trigger("onSending");
if (connection.data) {
url += "?data=" + connection.data + "&transport=webSockets&clientId=" + connection.clientId;
} else {
url += "?transport=webSockets&clientId=" + connection.clientId;
}
connection.socket = new window.WebSocket("ws://" + url);
connection.socket.onopen = function () {
opened = true;
if (onSuccess) {
onSuccess();
}
};
connection.socket.onclose = function (event) {
if (!opened) {
if (onFailed) {
onFailed();
}
}
connection.socket = null;
};
connection.socket.onmessage = function (event) {
var data = window.JSON.parse(event.data);
if (data) {
if (data.Messages) {
$.each(data.Messages, function () {
$(connection).trigger("onReceived", [this]);
});
} else {
$(connection).trigger("onReceived", [data]);
}
}
};
}
},
stop: function (connection) {
if (connection.socket !== null) {
connection.socket.close();
connection.socket = null;
}
}
},
longPolling: {
start: function (connection, onSuccess, onFailed) {
/// Starts the long polling connection
/// The SignalR connection to start
if (connection.pollXhr) {
connection.stop();
}
connection.messageId = null;
window.setTimeout(function () {
(function poll(instance) {
$(instance).trigger("onSending");
var messageId = instance.messageId,
connect = (messageId === null),
url = instance.url + (connect ? "/connect" : "");
instance.pollXhr = $.ajax(url, {
type: "POST",
data: {
clientId: instance.clientId,
messageId: messageId,
data: instance.data,
transport: "longPolling",
groups: (instance.groups || []).toString()
},
dataType: "json",
success: function (data) {
var delay = 0;
if (data) {
if (data.Messages) {
$.each(data.Messages, function () {
try {
$(instance).trigger("onReceived", [this]);
}
catch (e) {
if (console && console.log) {
console.log('Error raising received ' + e);
}
}
});
}
instance.messageId = data.MessageId;
if ($.type(data.TransportData.LongPollDelay) === "number") {
delay = data.TransportData.LongPollDelay;
}
instance.groups = data.TransportData.Groups;
}
if (delay > 0) {
window.setTimeout(function () {
poll(instance);
}, delay);
} else {
poll(instance);
}
},
error: function (data, textStatus) {
if (textStatus === "abort") {
return;
}
$(instance).trigger("onError", [data]);
window.setTimeout(function () {
poll(instance);
}, 2 * 1000);
}
});
} (connection));
// Now connected
// There's no good way know when the long poll has actually started so
// we and assume it only takes around 150ms (max) to start connection
// to start.
setTimeout(onSuccess, 150);
}, 250); // Have to delay initial poll so Chrome doesn't show loader spinner in tab
},
send: function (connection, data) {
/// Sends data over this connection
/// The SignalR connection to send data over
/// The data to send
/// A callback to be invoked when the send has completed
$.ajax(connection.url + '/send', {
type: "POST",
dataType: "json",
data: {
data: data,
transport: "longPolling",
clientId: connection.clientId
},
success: function (result) {
if (result) {
$(connection).trigger("onReceived", [result]);
}
},
error: function (data, textStatus) {
if (textStatus === "abort") {
return;
}
$(connection).trigger("onError", [data]);
}
});
},
stop: function (connection) {
/// Stops the long polling connection
/// The SignalR connection to stop
if (connection.pollXhr) {
connection.pollXhr.abort();
connection.pollXhr = null;
}
}
}
};
signalR.noConflict = function () {
/// Reinstates the original value of $.connection and returns the signalR object for manual assignment
///
if ($.connection === signalR) {
$.connection = _connection;
}
return signalR;
};
if ($.connection) {
_connection = $.connection;
}
$.connection = $.signalR = signalR;
} (window.jQuery, window));