diff options
Diffstat (limited to 'js/demo/Ice/hello/browser')
| -rw-r--r-- | js/demo/Ice/hello/browser/Client.js | 265 |
1 files changed, 265 insertions, 0 deletions
diff --git a/js/demo/Ice/hello/browser/Client.js b/js/demo/Ice/hello/browser/Client.js new file mode 100644 index 00000000000..23a720cca9e --- /dev/null +++ b/js/demo/Ice/hello/browser/Client.js @@ -0,0 +1,265 @@ +// ********************************************************************** +// +// Copyright (c) 2003-2014 ZeroC, Inc. All rights reserved. +// +// This copy of Ice is licensed to you under the terms described in the +// ICE_LICENSE file included in this distribution. +// +// ********************************************************************** + +(function(){ + +var communicator = Ice.initialize(); + +var flushEnabled = false; +var batch = 0; + +// +// Create the hello proxy. +// +function createProxy() +{ + var hostname = document.location.hostname || "127.0.0.1"; + var proxy = communicator.stringToProxy("hello" + + ":ws -h " + hostname + " -p 8080 -r /demows" + + ":wss -h " + hostname + " -p 9090 -r /demowss"); + + // + // Set or clear the timeout. + // + var timeout = $("#timeout").val(); + proxy = proxy.ice_timeout(timeout > 0 ? timeout : -1); + + // + // Set the mode and protocol + // + var mode = $("#mode").val(); + if(mode == "twoway") + { + proxy = proxy.ice_twoway(); + } + else if(mode == "twoway-secure") + { + proxy = proxy.ice_twoway().ice_secure(true); + } + else if(mode == "oneway") + { + proxy = proxy.ice_oneway(); + } + else if(mode == "oneway-secure") + { + proxy = proxy.ice_oneway().ice_secure(true); + } + else if(mode == "oneway-batch") + { + proxy = proxy.ice_batchOneway(); + } + else if(mode == "oneway-batch-secure") + { + proxy = proxy.ice_batchOneway().ice_secure(true); + } + return Demo.HelloPrx.uncheckedCast(proxy); +} + +// +// Invoke sayHello. +// +function sayHello() +{ + setState(State.SendRequest); + + var proxy = createProxy(); + if(proxy.ice_isBatchOneway()) + { + batch++; + } + + return proxy.sayHello($("#delay").val()); +} + +// +// Flush batch requests. +// +function flush() +{ + batch = 0; + setState(State.FlushBatchRequests); + return communicator.flushBatchRequests(); +} + +// +// Shutdown the server. +// +function shutdown() +{ + setState(State.SendRequest); + + var proxy = createProxy(); + if(proxy.ice_isBatchOneway()) + { + batch++; + } + + return proxy.shutdown(); +} + +// +// Return an event handler suitable for "click" methods. The +// event handler calls the given function, handles exceptions +// and resets the state to Idle when the promise returned by +// the function is fulfilled. +// +var performEventHandler = function(fn) +{ + return function() + { + Ice.Promise.try( + function() + { + return fn.call(); + } + ).exception( + function(ex) + { + $("#output").val(ex.toString()); + } + ).finally( + function() + { + setState(State.Idle); + } + ); + return false; + } +} +var sayHelloClickHandler = performEventHandler(sayHello); +var shutdownClickHandler = performEventHandler(shutdown); +var flushClickHandler = performEventHandler(flush); + +// +// Handle the client state. +// +var State = { + Idle:0, + SendRequest:1, + FlushBatchRequests:2 +}; + +var state; + +function setState(newState, ex) +{ + function assert(v) + { + if(!v) + { + throw new Error("Assertion failed"); + } + } + + assert(state !== newState); + + switch(newState) + { + case State.Idle: + { + assert(state === undefined || state === State.SendRequest || state === State.FlushBatchRequests); + + // + // Hide the progress indicator. + // + $("#progress").hide(); + $("body").removeClass("waiting"); + + // + // Enable buttons. + // + $("#hello").removeClass("disabled").click(sayHelloClickHandler); + $("#shutdown").removeClass("disabled").click(shutdownClickHandler); + if(batch > 0) + { + $("#flush").removeClass("disabled").click(flushClickHandler); + } + break; + } + case State.SendRequest: + case State.FlushBatchRequests: + { + assert(state === State.Idle); + + // + // Reset the output. + // + $("#output").val(""); + + // + // Disable buttons. + // + $("#hello").addClass("disabled").off("click"); + $("#shutdown").addClass("disabled").off("click"); + $("#flush").addClass("disabled").off("click"); + + // + // Display the progress indicator and set the wait cursor. + // + $("#progress .message").text( + newState === State.SendRequest ? "Sending Request..." : "Flush Batch Requests..."); + $("#progress").show(); + $("body").addClass("waiting"); + break; + } + } + state = newState; +}; + +// +// Start in the idle state +// +setState(State.Idle); + +// +// Extract the url GET variables and put them in the _GET object. +// +var _GET = {}; +if(window.location.search.length > 1) +{ + window.location.search.substr(1).split("&").forEach( + function(pair) + { + pair = pair.split("="); + if(pair.length > 0) + { + _GET[decodeURIComponent(pair[0])] = pair.length > 1 ? decodeURIComponent(pair[1]) : ""; + } + }); +} + +// +// If the mode param is set, initialize the mode select box with that value. +// +if(_GET["mode"]) +{ + $("#mode").val(_GET["mode"]); +} + +// +// If the user selects a secure mode, ensure that the page is loaded over HTTPS +// so the web server SSL certificate is obtained. +// +$("#mode").on("change", + function(e) + { + var newMode = $(this).val(); + + if(document.location.protocol === "http:" && + (newMode === "twoway-secure" || newMode === "oneway-secure" || newMode === "oneway-batch-secure")) + { + var href = document.location.protocol + "//" + document.location.host + + document.location.pathname + "?mode=" + newMode; + href = href.replace("http", "https"); + href = href.replace("8080", "9090"); + document.location.assign(href); + } + }); + +}()); |