Commit f62fa98d authored by Leo Iannacone's avatar Leo Iannacone

renamed socket_debug in debug_socket - use debug_socket for emit events

parent d2978822
...@@ -31,10 +31,10 @@ var debug = function() { ...@@ -31,10 +31,10 @@ var debug = function() {
/* /*
An helper debug function for socket events An helper debug function for socket events
usage: socket_debug("emit"|"received", event_name, data) usage: debug_socket("emit"|"received", event_name, data)
*/ */
var socket_debug = function() { var debug_socket = function() {
if (arguments.length != 3) if (arguments.length != 3)
return return
var level = 3; var level = 3;
......
...@@ -107,6 +107,7 @@ function Page_Distrubion(socket) ...@@ -107,6 +107,7 @@ function Page_Distrubion(socket)
if (Utils.check_view_distribution(view)) { if (Utils.check_view_distribution(view)) {
var query_data = {} var query_data = {}
query_data.distribution = view.distribution query_data.distribution = view.distribution
debug_socket("emit", _e.distribution_packages.get, query_data)
socket.emit(_e.distribution_packages.get, query_data) socket.emit(_e.distribution_packages.get, query_data)
} }
}, },
...@@ -195,6 +196,7 @@ function Page_Distrubion(socket) ...@@ -195,6 +196,7 @@ function Page_Distrubion(socket)
var query_data = {} var query_data = {}
query_data.distribution = view.distribution query_data.distribution = view.distribution
query_data.package = view.package query_data.package = view.package
debug_socket("emit", _e.package_files_list.get, query_data)
socket.emit(_e.package_files_list.get, query_data) socket.emit(_e.package_files_list.get, query_data)
} }
}, },
...@@ -246,6 +248,7 @@ function Page_Distrubion(socket) ...@@ -246,6 +248,7 @@ function Page_Distrubion(socket)
query_data.package = view.package query_data.package = view.package
query_data.file = view.file query_data.file = view.file
query_data.file.content = null query_data.file.content = null
debug_socket("emit", _e.file.get, query_data)
socket.emit(_e.file.get, query_data) socket.emit(_e.file.get, query_data)
} }
} }
...@@ -434,17 +437,17 @@ function Page_Distrubion(socket) ...@@ -434,17 +437,17 @@ function Page_Distrubion(socket)
this.start = function () { this.start = function () {
socket.on(config.events.error, function(socket_error) { socket.on(config.events.error, function(socket_error) {
socket_debug("received", config.events.error, socket_error) debug_socket("received", config.events.error, socket_error)
error.set(socket_error) error.set(socket_error)
}) })
socket.on(_e.distribution_packages.set, function (socket_data){ socket.on(_e.distribution_packages.set, function (socket_data){
socket_debug("received", _e.distribution_packages.set, socket_data) debug_socket("received", _e.distribution_packages.set, socket_data)
packages.set(socket_data) packages.set(socket_data)
}) })
socket.on(_e.distribution_packages.status, function (socket_data){ socket.on(_e.distribution_packages.status, function (socket_data){
socket_debug("received", _e.distribution_packages.set, socket_data) debug_socket("received", _e.distribution_packages.set, socket_data)
packages.set_status(socket_data) packages.set_status(socket_data)
sticky.set_status(socket_data) sticky.set_status(socket_data)
}) })
...@@ -455,17 +458,17 @@ function Page_Distrubion(socket) ...@@ -455,17 +458,17 @@ function Page_Distrubion(socket)
}) })
socket.on(_e.package_files_list.set, function (socket_data){ socket.on(_e.package_files_list.set, function (socket_data){
socket_debug("received", _e.package_files_list.set, socket_data) debug_socket("received", _e.package_files_list.set, socket_data)
files.set(socket_data) files.set(socket_data)
}) })
socket.on(_e.file.set, function (socket_data) { socket.on(_e.file.set, function (socket_data) {
socket_debug("received", _e.file.set, socket_data) debug_socket("received", _e.file.set, socket_data)
file.set(socket_data) file.set(socket_data)
}) })
socket.on(_e.file_newcontent, function (socket_data) { socket.on(_e.file_newcontent, function (socket_data) {
socket_debug("received", _e.file_newcontent, socket_data) debug_socket("received", _e.file_newcontent, socket_data)
new_lines.push(socket_data.file.new_content) new_lines.push(socket_data.file.new_content)
}) })
......
...@@ -95,17 +95,17 @@ function Page_Generic() ...@@ -95,17 +95,17 @@ function Page_Generic()
// update distributions // update distributions
socket.on(_e.broadcast.distributions, function(socket_distributions) { socket.on(_e.broadcast.distributions, function(socket_distributions) {
socket_debug("received", _e.broadcast.distributions, socket_distributions) debug_socket("received", _e.broadcast.distributions, socket_distributions)
distributions.set(socket_distributions) distributions.set(socket_distributions)
}); });
socket.on(_e.client.status, function(packages_status) { socket.on(_e.client.status, function(packages_status) {
socket_debug("received", _e.client.status, packages_status) debug_socket("received", _e.client.status, packages_status)
status.set(packages_status) status.set(packages_status)
}) })
socket.on(_e.broadcast.status_update, function(package_status) { socket.on(_e.broadcast.status_update, function(package_status) {
socket_debug("received", _e.broadcast.status_update, packages_status) debug_socket("received", _e.broadcast.status_update, packages_status)
status.update(package_status) status.update(package_status)
}) })
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment