'+
- '
';
-
-
- GW.process.createJSFrameDialog(720, 640, content, "About");
-
- },
-
- showTerms: function(){
-
- var content = `
+ dependency:
+ "d3.js, bootstrap, jquery, codemirror, directed-graph-creator, dmuploader",
+
+ content:
+ "thanks to Colorado Reed (https://github.com/cjrd) for making the fantastic D3.js graph creator.",
+
+ showDialog: function () {
+ var content =
+ 'Geoweaver is a web system to allow users to easily compose and execute full-stack deep learning workflows in web browsers by ad hoc integrating the distributed spatial data facilities, high-performance computation platforms, and open-source deep learning libraries.
'+ - - 'Geoweaver (version '+ GW.version+') is currently supported by ESIPLab, NSF geoinformatics program #1947893 and #1947875 and '+ - 'NASA ACCESS-19. The source code is on Github.
'+ - - 'Geoweaver logo is designed by Dr. Annie Burgess contact.
'+ - - 'Geoweaver is a community effort and welcome all contributors. If you have any questions, please create a new issue in GitHub or directly contact us
' +
+ '
';
+
+ GW.process.createJSFrameDialog(720, 640, content, "About");
+ },
+
+ showTerms: function () {
+ var content = `
Geoweaver is a web system to allow users to easily compose and execute full-stack deep learning workflows in web browsers by ad hoc integrating the distributed spatial data facilities, high-performance computation platforms, and open-source deep learning libraries.
' + + 'Geoweaver (version ' + + GW.version + + ') is currently supported by ESIPLab, NSF geoinformatics program #1947893 and #1947875 and ' + + 'NASA ACCESS-19. The source code is on Github.
' + + 'Geoweaver logo is designed by Dr. Annie Burgess contact.
' + + 'Geoweaver is a community effort and welcome all contributors. If you have any questions, please create a new issue in GitHub or directly contact us
1. Scope
@@ -103,10 +100,8 @@ GW.about = {12.1. Any supplementary agreement requires the written form.
12.2. The individual pages of the Geoweaver software are normally self operated and administered by Geoweaver users. The pages comply with the law applicable in the country where the responsible company has its business residence. Geoweaver provider makes no representation that information, software and/or documentation on the Geoweaver software are appropriate or available for viewing or downloading at locations outside such country. If Users access Geoweaver software from outside such country, they are exclusively responsible for compliance with all applicable local laws. Access to Geoweaver software's information, software and/or documentation from countries where such content is unlawful is prohibited. In this case and where User seeks to do business with Geoweaver provider, the User should contact the Geoweaver provider representative for the particular country for country specific business.
12.3. These Terms of Use shall be governed by - and all disputes relating to or in connection with these Terms of Use or their subject matter shall be resolved in accordance with - the laws of U.S.A, to the exclusion of its conflict of laws rules. The application of the United Nations Convention on Contracts for the International Sales of Goods (CISG) of 11 April 1980 is excluded.
-'+
-
- '
';
-
- content += '';
-
-// console.log(content);
-
- GW.comparison.compare_frame = GW.process.createJSFrameDialog(800, 600, content, "History Comparison " + GW.comparison.list_hist_ids[0] +
- " vs " + GW.comparison.list_hist_ids[1]);
-
- $("#compare-download-btn").click(function(){
-
- GW.host.downloadJupyter(GW.comparison.list_hist_ids[0]);
- GW.host.downloadJupyter(GW.comparison.list_hist_ids[1]);
-
- })
-
- $("#compare-cancel-btn").click(function(){
-
- GW.comparison.compare_frame.closeFrame();
-
- });
-
- }
-
-
-}
+ list_hist_ids: [],
+
+ list_history: [],
+
+ compare_frame: null,
+
+ show: function () {
+ this.list_hist_ids = [];
+
+ this.list_history = []; //clear the current comparison
+
+ var count = 0;
+
+ $(".hist-checkbox:checked").each(function () {
+ var histid = $(this).attr("id").substring(9);
+
+ count += 1;
+
+ if (count > 2) {
+ return;
+ }
+
+ // console.log("Removing "+histid);
+
+ // GW.host.deleteJupyterDirectly(histid.substring(9));
+
+ $.ajax({
+ url: "log",
+
+ method: "POST",
+
+ data: "type=host&id=" + histid,
+ })
+ .done(function (msg) {
+ if (msg == "") {
+ alert("Cannot find the host history in the database.");
+
+ return;
+ }
+
+ msg = $.parseJSON(msg);
+
+ var code = msg.output;
+
+ if (code != null && typeof code != "undefined") {
+ if (typeof code != "object") {
+ code = $.parseJSON(code);
+ }
+
+ GW.comparison.list_history.push(code);
+
+ GW.comparison.list_hist_ids.push(histid);
+
+ if (GW.comparison.list_history.length == 2) {
+ GW.comparison.showDialog();
+ }
+ }
+ })
+ .fail(function (e) {
+ console.error(e);
+ });
+ });
+ },
+
+ showDialog: function () {
+ var notebook1 = nb.parse(GW.comparison.list_history[0].content);
+
+ var notebook2 = nb.parse(GW.comparison.list_history[1].content);
+
+ var rendered1 = notebook1.render();
+
+ var rendered2 = notebook2.render();
+
+ var content =
+ ''+
-
- '
'+
-
- ''+
-
- $(rendered1).html()+
-
- '
'+
-
- ' '+
-
- $(rendered2).html()+
-
- '
'+
-
- ' ' +
+ '
";
+
+ content +=
+ '";
+
+ // console.log(content);
+
+ GW.comparison.compare_frame = GW.process.createJSFrameDialog(
+ 800,
+ 600,
+ content,
+ "History Comparison " +
+ GW.comparison.list_hist_ids[0] +
+ " vs " +
+ GW.comparison.list_hist_ids[1],
+ );
+
+ $("#compare-download-btn").click(function () {
+ GW.host.downloadJupyter(GW.comparison.list_hist_ids[0]);
+ GW.host.downloadJupyter(GW.comparison.list_hist_ids[1]);
+ });
+
+ $("#compare-cancel-btn").click(function () {
+ GW.comparison.compare_frame.closeFrame();
+ });
+ },
+};
diff --git a/src/main/resources/static/js/gw.dashboard.js b/src/main/resources/static/js/gw.dashboard.js
index 7a6e0f2c4..62c2f1f61 100644
--- a/src/main/resources/static/js/gw.dashboard.js
+++ b/src/main/resources/static/js/gw.dashboard.js
@@ -1,340 +1,326 @@
/**
- *
+ *
* Dashboard tab
- *
+ *
*/
GW.board = {
+ real_time_status_chart: null,
+ time_cost_chart: null,
+ /**
+ * Initialize the tab panel, this function should be only called when app is loaded
+ * after that, call refresh() directly.
+ */
+ init: function () {
+ this.display();
+
+ this.refresh();
+ },
+
+ /**
+ * Add values to those charts and tables
+ */
+ refresh: function () {
+ $.ajax({
+ url: "dashboard",
+
+ method: "POST",
+
+ data: "",
+ })
+ .done(function (msg) {
+ if (!msg.length) {
+ console.error("no dashboard info found");
+
+ return;
+ }
- real_time_status_chart: null,
- time_cost_chart: null,
- /**
- * Initialize the tab panel, this function should be only called when app is loaded
- * after that, call refresh() directly.
- */
- init: function(){
-
- this.display();
-
- this.refresh();
-
- },
-
- /**
- * Add values to those charts and tables
- */
- refresh: function(){
-
- $.ajax({
-
- url: "dashboard",
-
- method: "POST",
-
- data: ""
-
- }).done(function(msg){
-
- if(!msg.length){
-
- console.error("no dashboard info found");
-
- return;
-
- }
-
- msg = $.parseJSON(msg);
-
- console.log(msg);
-
- // { "process_num":12,"history_num":99,"host_num":1,"workflow_num":4,"environment_num":39,"process_shell_num":3,"process_notebook_num":0,"process_python_num":4,"process_builtin_num":3,"host_ssh_num":1,"host_jupyter_num":0,"host_jupyterlab_num":0,"host_jupyterhub_num":0,"host_gee_num":0,"running_process_num":2,"failed_process_num":15,"success_process_num":47,"running_workflow_num":0,"failed_workflow_num":0,"success_workflow_num":0}
-
- $("#host_num").html(msg.host_num)
-
- $("#host_ssh_num").html(msg.host_ssh_num)
-
- $("#host_jupyter_num").html(msg.host_jupyter_num)
-
- $("#host_jupyterlab_num").html(msg.host_jupyterlab_num)
-
- $("#host_jupyterhub_num").html(msg.host_jupyterhub_num)
-
- $("#host_gee_num").html(msg.host_gee_num)
-
- $("#process_num").html(msg.process_num)
-
- $("#process_shell_num").html(msg.process_shell_num)
-
- $("#process_notebook_num").html(msg.process_notebook_num)
-
- $("#process_python_num").html(msg.process_python_num)
-
- $("#process_builtin_num").html(msg.process_builtin_num)
-
- $("#workflow_num").html(msg.workflow_num);
-
- $("#running_workflow_num").html(msg.running_workflow_num)
-
- $("#failed_workflow_num").html(msg.failed_workflow_num)
-
- $("#success_workflow_num").html(msg.success_workflow_num)
-
- GW.board.real_time_status_chart.data.datasets[0].data = [
- msg.running_process_num, msg.failed_process_num, msg.success_process_num,
- msg.running_workflow_num, msg.failed_workflow_num, msg.success_workflow_num
- ]
-
- GW.board.real_time_status_chart.update();
+ msg = $.parseJSON(msg);
- var time_costs = msg.time_costs.map(x=>+x);
+ console.log(msg);
- time_costs = GW.board.removeMinusOne(time_costs);
+ // { "process_num":12,"history_num":99,"host_num":1,"workflow_num":4,"environment_num":39,"process_shell_num":3,"process_notebook_num":0,"process_python_num":4,"process_builtin_num":3,"host_ssh_num":1,"host_jupyter_num":0,"host_jupyterlab_num":0,"host_jupyterhub_num":0,"host_gee_num":0,"running_process_num":2,"failed_process_num":15,"success_process_num":47,"running_workflow_num":0,"failed_workflow_num":0,"success_workflow_num":0}
- var maxmin = GW.board.findMaxMin(time_costs);
+ $("#host_num").html(msg.host_num);
- var max_value = maxmin[0].toFixed();
+ $("#host_ssh_num").html(msg.host_ssh_num);
- var min_value = maxmin[1].toFixed();
+ $("#host_jupyter_num").html(msg.host_jupyter_num);
- var first_splitter = (max_value-min_value)/3 + min_value; first_splitter = Number(first_splitter).toFixed();
+ $("#host_jupyterlab_num").html(msg.host_jupyterlab_num);
- var second_splitter = (max_value-min_value)*2/3 + min_value;second_splitter = Number(second_splitter).toFixed();
+ $("#host_jupyterhub_num").html(msg.host_jupyterhub_num);
- GW.board.time_cost_chart.data.labels = [min_value + " - " + first_splitter + " ms", first_splitter +
- " - " + second_splitter + " ms", second_splitter + " - " + max_value + " ms"]
+ $("#host_gee_num").html(msg.host_gee_num);
- GW.board.time_cost_chart.data.datasets[0].data = GW.board.calculateFrequency(time_costs, first_splitter, second_splitter);
+ $("#process_num").html(msg.process_num);
- // GW.board.time_cost_chart.title.text = "Time Cost (unit: milliseconds)";
+ $("#process_shell_num").html(msg.process_shell_num);
- GW.board.time_cost_chart.update();
+ $("#process_notebook_num").html(msg.process_notebook_num);
- }).fail(function(jxr, status){
-
- console.error(status);
-
- });;
+ $("#process_python_num").html(msg.process_python_num);
- },
+ $("#process_builtin_num").html(msg.process_builtin_num);
- calculateFrequency: function(thearr, first_splitter, second_splitter){
+ $("#workflow_num").html(msg.workflow_num);
- var lvl1 = 0;
- var lvl2 = 0;
- var lvl3 = 0;
+ $("#running_workflow_num").html(msg.running_workflow_num);
- for(var i=0;i' +
+ '
" +
+ "' +
+ $(rendered1).html() +
+ "
" +
+ ' ' +
+ $(rendered2).html() +
+ "
" +
+ " '+
- '
';
-
- //list the statistics of each categories of hosts, processes, and workflows
- cont += ''+
- '
'+
-
- ' '+
- ' '+
- '
'+
- ' '+
- '
'+
- ' Host
'+ - '- '+
- '
hosts
'+
- ' SSH hosts
'+
- ' Jupyter Notebook hosts
'+
- ' JupyterHub hosts
'+
- ' JupyterLab hosts
'+
- ' Earth Engine hosts
'+
- '
'+
- '
'+
- ' '+
- ' '+
- '
'+
- ' '+
- '
'+
- ' Process
'+ - '- '+
- '
processes
'+
- ' Shell processes
'+
- ' Jupyter notebooks
'+
- ' builtin processes
'+
- ' python processes
'+
- '
'+
- '
'+
-
- ''+
- ' '+
- '
'+
- ' '+
- '
'+
- ' Workflows
'+ - '- '+
- '
workflows
'+
- ' pending workflow runs
'+
- ' failed workflow runs
'+
- ' successful workflow runs
'+
- '
'+
- '
';
-
- //list the status of processes and workflows
- cont += "";
-
- //show the average time cost and history recorded
-
-
- $("#main-dashboard-content").html(cont);
-
- this.renderRealTimeStatusChart();
-
- this.renderTimeCostChart();
+ removeMinusOne: function (thearr) {
+ var newarr = [];
+ for (var i = 0; i < thearr.length; i++) {
+ if (Number(thearr[i]) != -1) {
+ newarr.push(Number(thearr[i]));
+ }
}
-}
\ No newline at end of file
+ return newarr;
+ },
+
+ renderRealTimeStatusChart: function () {
+ var ctx = document
+ .getElementById("real_time_status_canvas")
+ .getContext("2d");
+ this.real_time_status_chart = new Chart(ctx, {
+ type: "bar",
+ data: {
+ labels: [
+ "Running Process",
+ "Failed Process",
+ "Done Process",
+ "Running Workflow",
+ "Failed Workflow",
+ "Done Workflow",
+ ],
+ datasets: [
+ {
+ label: "# of Processes/Workflows",
+ data: [0, 0, 0, 0, 0, 0],
+ backgroundColor: [
+ "rgba(255, 99, 132, 0.2)",
+ "rgba(54, 162, 235, 0.2)",
+ "rgba(255, 206, 86, 0.2)",
+ "rgba(75, 192, 192, 0.2)",
+ "rgba(153, 102, 255, 0.2)",
+ "rgba(255, 159, 64, 0.2)",
+ ],
+ borderColor: [
+ "rgba(255, 99, 132, 1)",
+ "rgba(54, 162, 235, 1)",
+ "rgba(255, 206, 86, 1)",
+ "rgba(75, 192, 192, 1)",
+ "rgba(153, 102, 255, 1)",
+ "rgba(255, 159, 64, 1)",
+ ],
+ borderWidth: 1,
+ },
+ ],
+ },
+ options: {
+ scales: {
+ y: {
+ beginAtZero: true,
+ },
+ },
+ },
+ });
+ },
+
+ renderTimeCostChart: function () {
+ var ctx = document.getElementById("time_cost_canvas").getContext("2d");
+ this.time_cost_chart = new Chart(ctx, {
+ type: "doughnut",
+ data: {
+ labels: ["Red", "Blue", "Yellow"],
+ datasets: [
+ {
+ label: "My First Dataset",
+ data: [300, 50, 100],
+ backgroundColor: [
+ "rgb(255, 99, 132)",
+ "rgb(54, 162, 235)",
+ "rgb(255, 205, 86)",
+ ],
+ hoverOffset: 4,
+ },
+ ],
+ },
+ });
+ },
+
+ /**
+ * Show all the charts and tables (empty)
+ */
+ display: function () {
+ var cont = "";
+
+ //list the number of hosts, processes, and workflows
+ cont +=
+ ''+
- '
'+
- ' '+
- '
'+
- ' '+
- '
'+
- ' Real Time Status
'+ - ''+
- ' '+
- '
'+
- ' '+
- '
'+
- ''+
- '
'+
- ' '+
- '
'+
- ' Time Cost
'+ - ''+
- ' '+
- '
'+
- ' ' +
+ '
";
+
+ //list the statistics of each categories of hosts, processes, and workflows
+ cont +=
+ '' +
+ '
" +
+ ' ' +
+ ' " +
+ "
" +
+ " ' +
+ '
" +
+ ' Host
' + + "- ' +
+ '
hosts
' +
+ ' SSH hosts
' +
+ ' Jupyter Notebook hosts
' +
+ ' JupyterHub hosts
' +
+ ' JupyterLab hosts
' +
+ ' Earth Engine hosts
' +
+ "
' +
+ '
" +
+ ' ' +
+ ' " +
+ "
" +
+ " ' +
+ '
" +
+ ' Process
' + + "- ' +
+ '
processes
' +
+ ' Shell processes
' +
+ ' Jupyter notebooks
' +
+ ' builtin processes
' +
+ ' python processes
' +
+ "
' +
+ '
" +
+ "' +
+ ' " +
+ "
" +
+ " ' +
+ '
" +
+ ' Workflows
' + + "- ' +
+ '
workflows
' +
+ ' pending workflow runs
' +
+ ' failed workflow runs
' +
+ ' successful workflow runs
' +
+ "
' +
+ '
";
+
+ //list the status of processes and workflows
+ cont += "";
+
+ //show the average time cost and history recorded
+
+ $("#main-dashboard-content").html(cont);
+
+ this.renderRealTimeStatusChart();
+
+ this.renderTimeCostChart();
+ },
+};
diff --git a/src/main/resources/static/js/gw.editor.js b/src/main/resources/static/js/gw.editor.js
index d10a47984..91d298d81 100644
--- a/src/main/resources/static/js/gw.editor.js
+++ b/src/main/resources/static/js/gw.editor.js
@@ -1,78 +1,75 @@
-
-
GW.editor = {
-
- beforeFullscreen: {},
-
- isfullscreen: false,
-
- switchSidePanelFullScreen: function(){
-
- var sidepanel = $('.cd-panel__container') //.cd-panel__container
- if (!sidepanel.hasClass('fullscreen')) {
- // this.beforeFullscreen = { height: sidepanel.height(), width: sidepanel.width() }
- sidepanel.addClass('fullscreen');
- sidepanel.height('100vh');
- sidepanel.width('100vw');
- sidepanel.css('top', '0');
- $('#prompt-panel-main').height('calc(100% - 55px)')
- $('#prompt-panel-main-process-info-code').height('100%')
- $('#prompt-panel-main-process-info-history').height('100%')
- GW.process.sidepanel.leftDock()
- this.isfullscreen = true;
- }else {
- sidepanel.removeClass('fullscreen');
- // sidepanel.height(this.beforeFullscreen.height);
- // sidepanel.width(this.beforeFullscreen.width);
- sidepanel.css('top', '52px');
- // subtabCodeDiv.height('calc(100% - 150px)');
- // subtabHistoryDiv.height('calc(100% - 150px)');
- sidepanel.height('100%')
- sidepanel.width('40%')
- $('#prompt-panel-main').height('calc(100% - 105px)')
- $('#prompt-panel-main-process-info-code').height('100%')
- $('#prompt-panel-main-process-info-history').height('100%')
- GW.process.sidepanel.bottomDock()
- // editor.refresh();
- this.isfullscreen = false;
- }
-
- GW.process.util.refreshCodeEditor();
-
- },
-
- switchFullScreen: function(){
-
- this.switchFullScreenUtil('#editor-history-tab-panel',
- '#main-process-info-code',
- '#main-process-info-history')
-
- },
-
- switchFullScreenUtil: function(editor_history_tab_panel_id, main_process_info_code_id, main_process_info_history_id){
-
- var editorDiv = $(editor_history_tab_panel_id);
- var subtabCodeDiv = $(main_process_info_code_id);
- var subtabHistoryDiv = $(main_process_info_history_id);
- if (!editorDiv.hasClass('fullscreen')) {
- this.beforeFullscreen = { height: editorDiv.height(), width: editorDiv.width() }
- editorDiv.addClass('fullscreen');
- editorDiv.height('100vh');
- editorDiv.width('100vw');
- subtabCodeDiv.height('calc(100% - 40px)');
- subtabHistoryDiv.height('calc(100% - 40px)');
- this.isfullscreen = true;
- }
- else {
- editorDiv.removeClass('fullscreen');
- editorDiv.height(this.beforeFullscreen.height);
- editorDiv.width(this.beforeFullscreen.width);
- subtabCodeDiv.height('calc(100% - 150px)');
- subtabHistoryDiv.height('calc(100% - 150px)');
- this.isfullscreen = false;
- }
-
+ beforeFullscreen: {},
+
+ isfullscreen: false,
+
+ switchSidePanelFullScreen: function () {
+ var sidepanel = $(".cd-panel__container"); //.cd-panel__container
+ if (!sidepanel.hasClass("fullscreen")) {
+ // this.beforeFullscreen = { height: sidepanel.height(), width: sidepanel.width() }
+ sidepanel.addClass("fullscreen");
+ sidepanel.height("100vh");
+ sidepanel.width("100vw");
+ sidepanel.css("top", "0");
+ $("#prompt-panel-main").height("calc(100% - 55px)");
+ $("#prompt-panel-main-process-info-code").height("100%");
+ $("#prompt-panel-main-process-info-history").height("100%");
+ GW.process.sidepanel.leftDock();
+ this.isfullscreen = true;
+ } else {
+ sidepanel.removeClass("fullscreen");
+ // sidepanel.height(this.beforeFullscreen.height);
+ // sidepanel.width(this.beforeFullscreen.width);
+ sidepanel.css("top", "52px");
+ // subtabCodeDiv.height('calc(100% - 150px)');
+ // subtabHistoryDiv.height('calc(100% - 150px)');
+ sidepanel.height("100%");
+ sidepanel.width("40%");
+ $("#prompt-panel-main").height("calc(100% - 105px)");
+ $("#prompt-panel-main-process-info-code").height("100%");
+ $("#prompt-panel-main-process-info-history").height("100%");
+ GW.process.sidepanel.bottomDock();
+ // editor.refresh();
+ this.isfullscreen = false;
}
-
-}
\ No newline at end of file
+ GW.process.util.refreshCodeEditor();
+ },
+
+ switchFullScreen: function () {
+ this.switchFullScreenUtil(
+ "#editor-history-tab-panel",
+ "#main-process-info-code",
+ "#main-process-info-history",
+ );
+ },
+
+ switchFullScreenUtil: function (
+ editor_history_tab_panel_id,
+ main_process_info_code_id,
+ main_process_info_history_id,
+ ) {
+ var editorDiv = $(editor_history_tab_panel_id);
+ var subtabCodeDiv = $(main_process_info_code_id);
+ var subtabHistoryDiv = $(main_process_info_history_id);
+ if (!editorDiv.hasClass("fullscreen")) {
+ this.beforeFullscreen = {
+ height: editorDiv.height(),
+ width: editorDiv.width(),
+ };
+ editorDiv.addClass("fullscreen");
+ editorDiv.height("100vh");
+ editorDiv.width("100vw");
+ subtabCodeDiv.height("calc(100% - 40px)");
+ subtabHistoryDiv.height("calc(100% - 40px)");
+ this.isfullscreen = true;
+ } else {
+ editorDiv.removeClass("fullscreen");
+ editorDiv.height(this.beforeFullscreen.height);
+ editorDiv.width(this.beforeFullscreen.width);
+ subtabCodeDiv.height("calc(100% - 150px)");
+ subtabHistoryDiv.height("calc(100% - 150px)");
+ this.isfullscreen = false;
+ }
+ },
+};
diff --git a/src/main/resources/static/js/gw.feedback.js b/src/main/resources/static/js/gw.feedback.js
index 5ca4deb27..972d33b0e 100644
--- a/src/main/resources/static/js/gw.feedback.js
+++ b/src/main/resources/static/js/gw.feedback.js
@@ -1,15 +1,11 @@
GW.feedback = {
-
- showDialog: function () {
-
- var content = `' +
+ '
" +
+ ' ' +
+ '
" +
+ " ' +
+ '
" +
+ ' Real Time Status
' + + "' +
+ ' ' +
+ "
" +
+ " ' +
+ '
" +
+ "' +
+ '
" +
+ " ' +
+ '
" +
+ ' Time Cost
' + + "' +
+ ' ' +
+ "
" +
+ "
+ showDialog: function () {
+ var content = `
'+parentfolder+' '+
- ' '+
- ' '+
- ' '+
- ' ';
-
- for(var i=0;i' +msg.array[i].name+'';
-
- }else{
-
- cont += ' ' +msg.array[i].name+' ';
-
- }
-
- cont += ' '+GW.filebrowser.s2Date(msg.array[i].mtime)+' '+
- ' '+msg.array[i].size+' '+
- ' '+msg.array[i].mode+' '+
- ' ';
-
- }
-
- $("#directory_table > tbody").html(cont);
-
- },
-
- sortTable: function (n) {
-
- var table, rows, switching, i, x, y, shouldSwitch, dir, switchcount = 0;
- table = document.getElementById("directory_table");
- switching = true;
- // Set the sorting direction to ascending:
- dir = "asc";
- /* Make a loop that will continue until
+ current_path: null,
+
+ current_hid: null,
+
+ editor: null,
+
+ edit_file: 0,
+
+ openFileEditor: function (file_name) {
+ $.ajax({
+ url: "retrievefile",
+
+ method: "POST",
+
+ data: { filepath: GW.filebrowser.current_path + file_name },
+ }).done(function (msg) {
+ msg = $.parseJSON(msg);
+
+ if (msg.ret == "success") {
+ GW.filebrowser.edit_file = 1;
+
+ var content =
+ '" +
+ ' " +
+ parentfolder +
+ " " +
+ " " +
+ " " +
+ " " +
+ " ";
+
+ for (var i = 0; i < msg.array.length; i++) {
+ cont += "";
+
+ if (msg.array[i].isdirectory) {
+ cont +=
+ ' " +
+ msg.array[i].name +
+ " ";
+ } else {
+ cont +=
+ ' " +
+ msg.array[i].name +
+ " ";
+ }
+
+ cont +=
+ " " +
+ GW.filebrowser.s2Date(msg.array[i].mtime) +
+ " " +
+ " " +
+ msg.array[i].size +
+ " " +
+ " " +
+ msg.array[i].mode +
+ " " +
+ " ";
+ }
+
+ $("#directory_table > tbody").html(cont);
+ },
+
+ sortTable: function (n) {
+ var table,
+ rows,
+ switching,
+ i,
+ x,
+ y,
+ shouldSwitch,
+ dir,
+ switchcount = 0;
+ table = document.getElementById("directory_table");
+ switching = true;
+ // Set the sorting direction to ascending:
+ dir = "asc";
+ /* Make a loop that will continue until
no switching has been done: */
- while (switching) {
- // Start by saying: no switching is done:
- switching = false;
- rows = table.rows;
- /* Loop through all table rows (except the
+ while (switching) {
+ // Start by saying: no switching is done:
+ switching = false;
+ rows = table.rows;
+ /* Loop through all table rows (except the
first, which contains table headers): */
- for (i = 1; i < (rows.length - 1); i++) {
- // Start by saying there should be no switching:
- shouldSwitch = false;
- /* Get the two elements you want to compare,
+ for (i = 1; i < rows.length - 1; i++) {
+ // Start by saying there should be no switching:
+ shouldSwitch = false;
+ /* Get the two elements you want to compare,
one from current row and one from the next: */
- x = rows[i].getElementsByTagName("TD")[n];
- y = rows[i + 1].getElementsByTagName("TD")[n];
- /* Check if the two rows should switch place,
+ x = rows[i].getElementsByTagName("TD")[n];
+ y = rows[i + 1].getElementsByTagName("TD")[n];
+ /* Check if the two rows should switch place,
based on the direction, asc or desc: */
- if (dir == "asc") {
- if (x.innerHTML.toLowerCase() > y.innerHTML.toLowerCase()) {
- // If so, mark as a switch and break the loop:
- shouldSwitch = true;
- break;
- }
- } else if (dir == "desc") {
- if (x.innerHTML.toLowerCase() < y.innerHTML.toLowerCase()) {
- // If so, mark as a switch and break the loop:
- shouldSwitch = true;
- break;
- }
- }
- }
- if (shouldSwitch) {
- /* If a switch has been marked, make the switch
+ if (dir == "asc") {
+ if (x.innerHTML.toLowerCase() > y.innerHTML.toLowerCase()) {
+ // If so, mark as a switch and break the loop:
+ shouldSwitch = true;
+ break;
+ }
+ } else if (dir == "desc") {
+ if (x.innerHTML.toLowerCase() < y.innerHTML.toLowerCase()) {
+ // If so, mark as a switch and break the loop:
+ shouldSwitch = true;
+ break;
+ }
+ }
+ }
+ if (shouldSwitch) {
+ /* If a switch has been marked, make the switch
and mark that a switch has been done: */
- rows[i].parentNode.insertBefore(rows[i + 1], rows[i]);
- switching = true;
- // Each time a switch is done, increase this count by 1:
- switchcount ++;
- } else {
- /* If no switching has been done AND the direction is "asc",
+ rows[i].parentNode.insertBefore(rows[i + 1], rows[i]);
+ switching = true;
+ // Each time a switch is done, increase this count by 1:
+ switchcount++;
+ } else {
+ /* If no switching has been done AND the direction is "asc",
set the direction to "desc" and run the while loop again. */
- if (switchcount == 0 && dir == "asc") {
- dir = "desc";
- switching = true;
- }
- }
- }
- },
-
- closeBrowser: function(){
-
- if(GW.filebrowser.edit_file==0){
-
- //only close connection when the file editor is not present
- $.ajax({
-
- url: "closefilebrowser",
-
- method: "POST"
-
- }).done(function(msg){
-
- console.log(msg);
-
- });
-
- }
-
- $("#host-file-browser").html("");
-
- },
-
- showFolderBrowserDialog: function(msg){
-
- var cont = '';
-
- content += '';
-
- var frame = GW.process.createJSFrameDialog(360, 360, content, "Host Password");
-
- frame.on('#pswd-cancel', 'click', (_frame, evt) => {
-
- _frame.closeFrame()
-
- })
-
- frame.on('#pswd-confirm', 'click', (_frame, evt) => {
-
- var filled = true;
-
- $.each( $( "input[type='password']" ), function() {
- if(!$(this).val()){
-
- filled = false;
-
- alert("Please input password. ");
-
- return;
-
- }
- });
-
- if(!filled) return;
-
- var $button = $(this);
-//
-// $button.spin();
-
- var shortpasswds = [];
-
- for(var i=0;i0){
-
- GW.host.enter_pswd_m(newhosts, hosts, req, business_callback);
-
- }else{
-
- var passwds = GW.host.extendList([], newhosts, hosts);
-
- GW.host.encrypt_m(hosts, passwds, req, null, null, business_callback);
- }
-
- },
-
- turnHosts2Ids: function(hosts){
-
- var ids = [];
-
- for(var i=0; i", "SSH Command Line")
-
- var frame = ""+msg[i].name+"");
-
- }
-
- }
-
- //show the environment of the first host
- if($(".environmentselector")){
-
- $(".environmentselector").append('');
-
- var envs = msg[0].envs
-
- for(var i=0;i"+envs[i].name+"");
-
- }
-
- }
-
- $(".hostselector").change(function(){
-
- //get the corresponding environmentselector
- // var corenvelelist = $(this).closest('div').next().find('.environmentselector');
- var hostselectid = $(this).attr("id");
-
- var envselectid = "environmentforprocess_" + hostselectid.split("_")[1];
-
- //change the environment selector options
- var envselect = $("#" + envselectid);
-
- var selectedhostid = $(this).children("option:selected").attr("id");
-
- envselect.empty().append('');
-
- //add new options to the environment selector
- var theenv = GW.host.findEnvironmentByHostId(selectedhostid);
-
- if(theenv != null){
-
- for(var i=0;i"+theenv[i].name+"");
-
- }
-
- }
-
- });
-
- }
-
- }).fail(function(jxr, status){
-
- console.error("fail to list host");
-
- });
-
- },
-
- findEnvironmentByHostId: function(hostid){
-
- var theenv = null;
-
- if(GW.host.host_environment_list_cache!=null){
-
- for(var i=0;i ` +
-
- one.name + ``;
-
- $("#host_folder_"+one.type+"_target").append(one_item);
-
- },
-
- expand: function(one){
-
- console.log("EXPAND host type")
-
- $("#host_folder_"+one.type+"_target").collapse("show");
- },
-
- list: function(msg){
-
- GW.host.cleanMenu();
-
- for(var i=0;i";
-
- if( hosttype=="ssh" || hosttype == null || hosttype == "null" ){
-
- // ""+ //this is a problematic function
-
-// ""+
-
- content += ""+
-
- ""+
-
- " ";
-
- }else if(hosttype=="jupyter" || hosttype=="jupyterhub" || hosttype=="jupyterlab" ){
-
- content += "" +
-
- "";
-
- }else if(hosttype=="gee"){
-
- content += "" +
-
- "";
-
- }
-
- return content;
-
- },
-
-
-
- showEnvironmentTable: function(msg){
-
- var content = "
Have feedback? We'd love to hear it!
Let us know what you think of Geoweaver and how we can improve your Geoweaver experience.
`; - - GW.process.createJSFrameDialog(460, 320, content, "Feedback"); - - }, -} \ No newline at end of file + GW.process.createJSFrameDialog(460, 320, content, "Feedback"); + }, +}; diff --git a/src/main/resources/static/js/gw.filebrowser.js b/src/main/resources/static/js/gw.filebrowser.js index e12f46099..e23549fa4 100644 --- a/src/main/resources/static/js/gw.filebrowser.js +++ b/src/main/resources/static/js/gw.filebrowser.js @@ -1,532 +1,487 @@ - GW.filebrowser = { - - current_path: null, - - current_hid: null, - - editor: null, - - edit_file: 0, - - openFileEditor: function(file_name){ - - $.ajax({ - - url: "retrievefile", - - method: "POST", - - data: { "filepath" : GW.filebrowser.current_path + file_name} - - }).done(function(msg){ - - msg = $.parseJSON(msg); - - if(msg.ret == "success"){ - - GW.filebrowser.edit_file = 1; - - var content = ""+
- "
" +
- ''
-
- var frame = GW.process.createJSFrameDialog(800, 640, content, 'File Editor')
-
- $("#codearea").append('');
-
- GW.filebrowser.editor = CodeMirror.fromTextArea(document.getElementById("code_editor"), {
-
- lineNumbers: true,
- lineWrapping: true
- });
-
- var url_path = msg.path;
-
- //prevent it loading from cache
- $.ajaxSetup ({
- // Disable caching of AJAX responses
- cache: false
- });
-
- $.get( "../" + url_path, function( data ) {
-
- GW.filebrowser.editor.setValue(data);
-
- $("#loading_btn").hide();
-
- });
-
- $.ajaxSetup ({
- // Enable caching of AJAX responses
- cache: true
- });
-
- frame.on('closeButton', 'click', (_frame, evt) => {
-
- $.ajax({
-
- url: "closefilebrowser",
-
- method: "POST"
-
- }).done(function(msg){
-
- console.log(msg);
-
- });
-
- _frame.closeFrame();
-
- });
-
- $("#browser-save").click(function(){
-
- $.ajax({
-
- url: "updatefile",
-
- method: "POST",
-
- data: { filepath: GW.filebrowser.current_path + file_name,
- content: GW.filebrowser.editor.getValue()}
-
- }).done(function(msg){
-
- msg = $.parseJSON(msg);
-
- if(msg.ret == "success"){
-
- console.log("file updated");
-
- alert("Saved!!");
-
- }else{
-
- alert("Failed!!" + msg.reason);
- }
-
- });
-
-
- });
-
- $("#browser-run").click(function(){
-
- var patt1 = /\.([0-9a-z]+)(?:[\?#]|$)/i;
-
- var suffix = file_name.match(patt1);
-
- if(GW.filebrowser.isIn(suffix[1],["py", "sh"])){
-
- //step 1: add the file as a new process
-
- //step 2: pop-up the run dialog of the process
-
- var type = "shell";
-
- if("py"==suffix[1]){
-
- type = "python";
-
- }
-
- var req = {
-
- name: file_name,
-
- filepath: GW.filebrowser.current_path + file_name,
-
- hid: GW.filebrowser.current_hid,
-
- type: type,
-
- content: GW.filebrowser.editor.getValue()
-
- };
-
- $.ajax({
-
- url: "addLocalFile",
-
- method: "POST",
-
- data: req
-
- }).done(function(msg){
-
- msg = $.parseJSON(msg);
-
- var pid = msg.id;
-
- GW.process.addMenuItem(msg, type);
-
- GW.process.executeProcess(pid, GW.filebrowser.current_hid, type);
-
- GW.ssh.addlog("The process " + msg.name + " is added to the process list.");
- GW.ssh.addlog("Pop up authorization dialog to initiate the run of the process : " + pid);
-
- });
-
- }else{
-
- alert("Only Python and Shell script can run!");
-
- }
-
-
- });
-
-
- }else{
-
- alert("Fail to retrieve file: " + msg.reason);
-
- }
-
- });
-
- },
-
- downloadFile: function(file_name){
-
- var path = GW.filebrowser.current_path + file_name;
-
- var req = {filepath : path};
-
- $.ajax({
-
- url: "retrievefile",
-
- data: req,
-
- method: "POST"
-
- }).done(function(msg){
-
- msg = $.parseJSON(msg);
-
- if(msg.ret == "success"){
-
- var fileurl = msg.path;
-
- GW.result.download_path("../" + fileurl, file_name); //remove web from Geoweaver/web
-
- }else{
-
- alert("Fail to download!");
-
- }
-
- }).fail(function(jqXHR, textStatus, errorThrown){
-
- console.error(textStatus + errorThrown);
-
- });
-
- },
-
- isIn: function(target, array) {
- for(var i=0; i' +
+ '
' +
+ '";
+
+ var frame = GW.process.createJSFrameDialog(
+ 800,
+ 640,
+ content,
+ "File Editor",
+ );
+
+ $("#codearea").append(
+ '',
+ );
+
+ GW.filebrowser.editor = CodeMirror.fromTextArea(
+ document.getElementById("code_editor"),
+ {
+ lineNumbers: true,
+ lineWrapping: true,
+ },
+ );
+
+ var url_path = msg.path;
+
+ //prevent it loading from cache
+ $.ajaxSetup({
+ // Disable caching of AJAX responses
+ cache: false,
+ });
+
+ $.get("../" + url_path, function (data) {
+ GW.filebrowser.editor.setValue(data);
+
+ $("#loading_btn").hide();
+ });
+
+ $.ajaxSetup({
+ // Enable caching of AJAX responses
+ cache: true,
+ });
+
+ frame.on("closeButton", "click", (_frame, evt) => {
+ $.ajax({
+ url: "closefilebrowser",
+
+ method: "POST",
+ }).done(function (msg) {
+ console.log(msg);
+ });
+
+ _frame.closeFrame();
+ });
+
+ $("#browser-save").click(function () {
+ $.ajax({
+ url: "updatefile",
+
+ method: "POST",
+
+ data: {
+ filepath: GW.filebrowser.current_path + file_name,
+ content: GW.filebrowser.editor.getValue(),
+ },
+ }).done(function (msg) {
+ msg = $.parseJSON(msg);
+
+ if (msg.ret == "success") {
+ console.log("file updated");
+
+ alert("Saved!!");
+ } else {
+ alert("Failed!!" + msg.reason);
+ }
+ });
+ });
+
+ $("#browser-run").click(function () {
+ var patt1 = /\.([0-9a-z]+)(?:[\?#]|$)/i;
+
+ var suffix = file_name.match(patt1);
+
+ if (GW.filebrowser.isIn(suffix[1], ["py", "sh"])) {
+ //step 1: add the file as a new process
+
+ //step 2: pop-up the run dialog of the process
+
+ var type = "shell";
+
+ if ("py" == suffix[1]) {
+ type = "python";
+ }
+
+ var req = {
+ name: file_name,
+
+ filepath: GW.filebrowser.current_path + file_name,
+
+ hid: GW.filebrowser.current_hid,
+
+ type: type,
+
+ content: GW.filebrowser.editor.getValue(),
+ };
+
+ $.ajax({
+ url: "addLocalFile",
+
+ method: "POST",
+
+ data: req,
+ }).done(function (msg) {
+ msg = $.parseJSON(msg);
+
+ var pid = msg.id;
+
+ GW.process.addMenuItem(msg, type);
+
+ GW.process.executeProcess(pid, GW.filebrowser.current_hid, type);
+
+ GW.ssh.addlog(
+ "The process " + msg.name + " is added to the process list.",
+ );
+ GW.ssh.addlog(
+ "Pop up authorization dialog to initiate the run of the process : " +
+ pid,
+ );
+ });
+ } else {
+ alert("Only Python and Shell script can run!");
+ }
+ });
+ } else {
+ alert("Fail to retrieve file: " + msg.reason);
+ }
+ });
+ },
+
+ downloadFile: function (file_name) {
+ var path = GW.filebrowser.current_path + file_name;
+
+ var req = { filepath: path };
+
+ $.ajax({
+ url: "retrievefile",
+
+ data: req,
+
+ method: "POST",
+ })
+ .done(function (msg) {
+ msg = $.parseJSON(msg);
+
+ if (msg.ret == "success") {
+ var fileurl = msg.path;
+
+ GW.result.download_path("../" + fileurl, file_name); //remove web from Geoweaver/web
+ } else {
+ alert("Fail to download!");
+ }
+ })
+ .fail(function (jqXHR, textStatus, errorThrown) {
+ console.error(textStatus + errorThrown);
+ });
+ },
+
+ isIn: function (target, array) {
+ for (var i = 0; i < array.length; i++) {
+ if (array[i] == target) return true;
+ }
+ return false;
+ },
+
+ operatefile: function (file_name, file_size) {
+ GW.general.showToasts("Preparing the file, please wait..");
+
+ var patt1 = /\.([0-9a-z]+)(?:[\?#]|$)/i;
+
+ var suffix = file_name.match(patt1);
+
+ if (suffix !== null) {
+ if (
+ Number(file_size) < 10 * 1024 * 1024 &&
+ GW.filebrowser.isIn(suffix[1], [
+ "txt",
+ "py",
+ "sh",
+ "java",
+ "log",
+ "js",
+ "r",
+ "c",
+ "cpp",
+ "f",
+ "go",
+ "sql",
+ "php",
+ "perl",
+ "js",
+ ])
+ ) {
+ //edit the file
+ GW.filebrowser.openFileEditor(file_name);
+ } else {
+ //directly download the file
+ GW.filebrowser.downloadFile(file_name);
+ }
+ } else {
+ //directly download the file
+ GW.filebrowser.downloadFile(file_name);
+ }
+ },
+
+ continuebrowser: function (file_name) {
+ $.ajax({
+ url: "openfilebrowser",
+
+ data: { init_path: GW.filebrowser.current_path + file_name + "/" },
+
+ method: "POST",
+ })
+ .done(function (msg) {
+ msg = $.parseJSON(msg);
+
+ if (msg.ret != "failure") GW.filebrowser.updateBrowser(msg);
+ else alert("Fail to open the directory: " + msg.msg);
+ })
+ .fail(function (error) {
+ alert("Fail to send request to continue file browser" + error);
+ });
+ },
+
+ s2Date: function (seconds) {
+ var m = new Date(Number(seconds) * 1000);
+
+ var dateString =
+ m.getUTCFullYear() +
+ "/" +
+ ("0" + (m.getUTCMonth() + 1)).slice(-2) +
+ "/" +
+ ("0" + m.getUTCDate()).slice(-2) +
+ " " +
+ ("0" + m.getUTCHours()).slice(-2) +
+ ":" +
+ ("0" + m.getUTCMinutes()).slice(-2) +
+ ":" +
+ ("0" + m.getUTCSeconds()).slice(-2);
+
+ return dateString;
+ },
+
+ updateBrowser: function (msg) {
+ GW.filebrowser.current_path = msg.current;
+
+ var parentfolder = "..";
+
+ if (GW.filebrowser.current_path == "/") parentfolder = ".";
+
+ var cont =
+ "'+
-
- '
';
-
- cont ="';
-
- cont += ' '+
- ' '+
- '
'+
-
- '| Name | '+ - 'Last Modified | '+ - 'Size | '+ - 'Mode | '+ - '
|---|
File Browser Section
"+ cont; - - -// var frame = GW.process.createJSFrameDialog(800, 640, cont, 'File Browser') - - $("#host-file-browser").html(cont); - - GW.filebrowser.updateBrowser(msg); - - GW.filebrowser.edit_file = 0; - - $("#closeFileBrowser").click(this.closeBrowser); - - }, - - connect_folder: function(encrypt, req, dialog, button){ - - req.pswd = encrypt; - - $.ajax({ - - url: "openfilebrowser", - - data: req, - - method: "POST" - - }).done(function(msg){ - - msg = $.parseJSON(msg); - - if(msg.current.length){ - - GW.filebrowser.showFolderBrowserDialog(msg); - - }else{ - - alert("Fail to open file browser"); - - } - - dialog.closeFrame(); - - }).fail(function(error){ - - alert("Fail to send folder open request"); - - button.enable(); - - button.stopSpin(); - - }); - - }, - - start: function(hid){ - - var req = { hid: hid, init_path: "/home/"} - - if(this.current_hid == hid){ - - req.init_path = this.current_path; - - } - - this.current_hid = hid; - - GW.host.start_auth_single(hid, req, GW.filebrowser.connect_folder); - - } - -} + if (switchcount == 0 && dir == "asc") { + dir = "desc"; + switching = true; + } + } + } + }, + + closeBrowser: function () { + if (GW.filebrowser.edit_file == 0) { + //only close connection when the file editor is not present + $.ajax({ + url: "closefilebrowser", + + method: "POST", + }).done(function (msg) { + console.log(msg); + }); + } + + $("#host-file-browser").html(""); + }, + + showFolderBrowserDialog: function (msg) { + var cont = + '' +
+ '
";
+
+ cont =
+ '';
+
+ cont +=
+ ' ' +
+ " " +
+ "
" +
+ "| Name | ' + + 'Last Modified | ' + + 'Size | ' + + 'Mode | ' + + "
|---|
File Browser Section
' + + cont; + + // var frame = GW.process.createJSFrameDialog(800, 640, cont, 'File Browser') + + $("#host-file-browser").html(cont); + + GW.filebrowser.updateBrowser(msg); + + GW.filebrowser.edit_file = 0; + + $("#closeFileBrowser").click(this.closeBrowser); + }, + + connect_folder: function (encrypt, req, dialog, button) { + req.pswd = encrypt; + + $.ajax({ + url: "openfilebrowser", + + data: req, + + method: "POST", + }) + .done(function (msg) { + msg = $.parseJSON(msg); + + if (msg.current.length) { + GW.filebrowser.showFolderBrowserDialog(msg); + } else { + alert("Fail to open file browser"); + } + + dialog.closeFrame(); + }) + .fail(function (error) { + alert("Fail to send folder open request"); + + button.enable(); + + button.stopSpin(); + }); + }, + + start: function (hid) { + var req = { hid: hid, init_path: "/home/" }; + + if (this.current_hid == hid) { + req.init_path = this.current_path; + } + + this.current_hid = hid; + + GW.host.start_auth_single(hid, req, GW.filebrowser.connect_folder); + }, +}; diff --git a/src/main/resources/static/js/gw.fileupload.js b/src/main/resources/static/js/gw.fileupload.js index af79e0b55..a99fe6840 100644 --- a/src/main/resources/static/js/gw.fileupload.js +++ b/src/main/resources/static/js/gw.fileupload.js @@ -1,557 +1,543 @@ /** * Plugin for uploading files to the remote host - * + * * Code comes from https://danielmg.org/demo/java-script/uploader/no-queue (by Daniel Morales) MIT license */ GW.fileupload = { - - uploader: null, - - hid : null, - - password: null, - - password_frame: null, - - clean: function(){ - - console.log("clean everything"); - - hid = null; - - encrypted = null; - - }, - - uploadfile: function(hid){ - - //it is divided into two steps - //let users input credentials of the selected host - - GW.fileupload.hid = hid; - - $.ajax({ - - url: "detail", - - method: "POST", - - data: "type=host&id=" + hid - - }).done(function(msg){ - - //open the login page - - msg = $.parseJSON(msg); - - if(GW.host.findCache(hid)==null){ - - if(GW.fileupload.password_frame != null){ - - try{ - - GW.fileupload.password_frame.closeFrame(); - - }catch(e){ - - console.error("Fail to close the frame. Probably it is already closed."); - - } - - GW.fileupload.password_frame = null; - - } - - var content = ''+
- "
";
-
- content += '';
-
- GW.fileupload.password_frame = GW.process.createJSFrameDialog(350, 250, content, "Authorization")
-
- GW.fileupload.password_frame.on('closeButton', 'click', (_frame, evt) => {
-
- _frame.closeFrame();
-
- });
-
- //Show the window
-// GW.fileupload.password_frame.show();
-//
-// GW.fileupload.password_frame.setPosition((window.innerWidth - width) / 2, (window.innerHeight -height) / 2, 'LEFT_TOP');
-
- $("#pswd-confirm-btn").click(function(){
-
-// var $button = this;
-//
-// $button.spin();
-
-// GW.fileupload.password_frame.enableButtons(false);
-
- GW.fileupload.password = $('#inputpswd').val()
-
- if(GW.fileupload.password == ""){
-
- alert("Please input correct password.");
-
- return;
-
- }
-
- if(document.getElementById('upload-remember').checked) {
-
- GW.host.setCache(hid, GW.fileupload.password);
-
- }
-
- GW.fileupload.showUploadDialog();
-
- GW.fileupload.password_frame.closeFrame();
-
- });
-
- $("#pswd-cancel-btn").click(function(){
-
- GW.fileupload.password_frame.closeFrame();
-
- });
-
-
- }else{
-
- GW.fileupload.password = GW.host.findCache(hid);
-
- if(GW.fileupload.password == ""){
-
- alert("Please clean the cache and try again.");
-
- return;
-
- }
-
- GW.fileupload.showUploadDialog();
-
- GW.fileupload.password_frame.closeFrame();
-
- }
-
-
- });
-
- },
-
- getUploadDialogContent: function(hasdebug){
-
- var content = ""+
- "
Input Host Password :
"+
- ""+
- " "+
- "
"+
- " "+
- " "+
- " "+
- "
"+
- ""+
- "
";
-
- content += '';
-
-
-
- return content;
-
- },
-
- closeUploaderJSFrame: function(){
-
- if(this.uploader!=null){
-
- try{ this.uploader.closeFrame(); }catch(e){ console.error("Probably it is already closed."); }
-
- this.uploader = null;
-
- }
-
- },
-
- showUploadWorkflowDialog: function(){
-
- this.closeUploaderJSFrame();
-
- let content = GW.fileupload.getUploadDialogContent(false);
-
- this.uploader = GW.process.createJSFrameDialog(550, 450, content, "Upload Workflow");
-
- this.listenUploadButtons(false, true);
-
- },
-
- showUploadDialog: function(){
-
- //once validated, show a dialog for users to select a file or multiple files to upload
- //click the submit button, the files are first uploaded to Geoweaver host
- //once received the complete response, send another request to upload the files to remote host
-
- let content = GW.fileupload.getUploadDialogContent(true);
-
- content = " "+
- "
";
-
- if(hasdebug)
- content += " "+
- " "+
- "
"+
- " "+
- "
"+
- " Drag & drop files here
"+ - - " "+
- " Open the file Browser "+
- " "+
- "
"+
- " "+
- "
"+
- " "+
- "
"+
- " "+
- " File List "+
- "
"+
- " - "+
- "
- No files uploaded. "+ - "
"+
- "
";
-
- content += " "+
- " "+
- " "+
- "
"+
- " "+
- "
"+
- " "+
- " Debug Messages "+
- "
"+
- " - "+
- "
- Loading plugin.... "+ - "
File Uploader Section
"+content; - - $("#host-file-uploader").html(content); - - $("#closeFileUploader").click(function(){ - - $("#host-file-uploader").html(""); - - }); - - this.listenUploadButtons(true, false); - - }, - - listenUploadButtons: function(iftransfer, ifworkflow){ - - $('#drag-and-drop-zone').dmUploader({ - url: '../FileUploadServlet', - maxFileSize: 3000000000, // 3000 Megs max - auto: false, - queue: true, - onDragEnter: function(){ - // Happens when dragging something over the DnD area - this.addClass('active'); - }, - onDragLeave: function(){ - // Happens when dragging something OUT of the DnD area - this.removeClass('active'); - }, - onInit: function(){ - // Plugin is ready to use - GW.fileupload.ui_add_log('Uploader initialized :)', 'info'); - }, - onComplete: function(){ - // All files in the queue are processed (success or error) -// GW.fileupload.ui_add_log('All pending tranfers finished'); - }, - onNewFile: function(id, file){ - // When a new file is added using the file selector or the DnD area - GW.fileupload.ui_add_log('New file added #' + id); - GW.fileupload.ui_multi_add_file(id, file); - }, - onBeforeUpload: function(id){ - // about tho start uploading a file - GW.fileupload.ui_add_log('Starting the upload of #' + id); - GW.fileupload.ui_multi_update_file_progress(id, 0, '', true); - GW.fileupload.ui_multi_update_file_status(id, 'uploading', 'Uploading...'); - }, - onUploadProgress: function(id, percent){ - // Updating file progress - GW.fileupload.ui_multi_update_file_progress(id, percent); - }, - onUploadSuccess: function(id, data){ - // A file was successfully uploaded - GW.fileupload.ui_add_log('Server Response for file #' + id + ': ' + data); - GW.fileupload.ui_add_log('Upload of file #' + id + ' COMPLETED', 'success'); - data = $.parseJSON(data); - if(iftransfer){ - GW.fileupload.ui_multi_update_file_progress(id, 90, '', true); - GW.fileupload.transfer(id, data.url); - } - - if(ifworkflow){ - GW.fileupload.closeUploaderJSFrame(); - GW.workflow.parseUploadedWorkflow(id, data.filename); - } - - }, - onUploadError: function(id, xhr, status, message){ - GW.fileupload.ui_multi_update_file_status(id, 'danger', message); - GW.fileupload.ui_multi_update_file_progress(id, 0, 'danger', false); - }, - onFallbackMode: function(){ - // When the browser doesn't support this plugin :( - GW.fileupload.ui_add_log('Plugin cant be used here, running Fallback callback', 'danger'); - }, - onFileSizeError: function(file){ - GW.fileupload.ui_add_log('File \'' + file.name + '\' cannot be added: size excess limit', 'danger'); - } - }); - - $("#upload-start").click(function(){ - - $('#drag-and-drop-zone').dmUploader('start'); - - var $button = $("#upload-start"); // 'this' here is a jQuery object that wrapping theSSH Terminal Section
"+ - - "" - - $("#ssh-terminal-iframe").html(frame); - - $("#closeSSHTerminal").click(function(){ - - GW.host.closeSSH(token); - - $("#ssh-terminal-iframe").html(""); //double remove to make sure it clears every time - - }) - - }, - - /** - * Open the SSH Connection Dialog if the host is a remote server - */ - openssh: function(hostid){ - - //get the host information - - $.ajax({ - - url: "detail", - - method: "POST", - - data: "type=host&id=" + hostid - - }).done(function(msg){ - - //open the login page - - hostmsg = $.parseJSON(msg); - - if(GW.host.ssh_password_frame != null){ - - try{ - - GW.host.ssh_password_frame.closeFrame(); - - }catch(e){ - - console.log("Probably it is closed already."); - - } - - GW.host.ssh_password_frame = null; - - } - - if(GW.host.findCache(hostid)==null){ - - var cont = ''+
- "
";
-
- cont += '';
-
- GW.host.ssh_password_frame = GW.process.createJSFrameDialog(500, 340, cont, "Open SSH session")
-
- $("#ssh-connect-btn").click(function(){
-
- $("#ssh-connect-btn").prop("disabled", true);
-
- $.ajax({
-
- url: "key",
-
- type: "POST",
-
- data: ""
-
- }).done(function(msg){
-
- //encrypt the password using the received rsa key
- msg = $.parseJSON(msg);
-
- var encrypt = new JSEncrypt();
-
- encrypt.setPublicKey(msg.rsa_public);
-
- var encrypted = encrypt.encrypt($("#passwd").val());
-
- var req = {
- host: hostmsg.ip,
- port: hostmsg.port,
- username: hostmsg.username,
- password: encrypted
- }
-
- $.ajax({
-
- url: "geoweaver-ssh-login-inbox",
-
- method: "POST",
-
- data: req
-
- }).done(function(msg){
-
- msg = $.parseJSON(msg);
-
- if(msg.token!=null){
-
- //open a dialog to show the SSH command line interface
-
- GW.host.showSSHCmd(msg.token);
-
- if(document.getElementById('ssh-remember').checked) {
-
- GW.host.setCache(hostid, $('#passwd').val()); //only remember password if users check the box the the login is successful.
-
- }
-
- }else{
-
- alert("Username or Password is wrong or the server is not accessible");
-
- }
- try{
- GW.host.ssh_password_frame.closeFrame();
- }catch(e){console.log(e)}
-
-
- }).fail(function(status){
-
- alert("Username or Password is wrong or the server is not accessible" + status);
-
- $("#ssh-connect-btn").prop("disabled", false);
-
- });
-
-
- });
-
- });
-
- $("#ssh-cancel-btn").click(function(){
-
- GW.host.ssh_password_frame.closeFrame();
-
- });
-
- }else{
-
- //if the login attempt failed once, the password will be removed and users need input again.
- var pswd = GW.host.findCache(hostid);
-
- $.ajax({
-
- url: "key",
-
- type: "POST",
-
- data: ""
-
- }).done(function(msg){
-
- //encrypt the password using the received rsa key
- msg = $.parseJSON(msg);
-
- var encrypt = new JSEncrypt();
-
- encrypt.setPublicKey(msg.rsa_public);
-
- var encrypted = encrypt.encrypt(pswd);
-
- var req = {
- host: hostmsg.ip,
- port: hostmsg.port,
- username: hostmsg.username,
- password: encrypted
- }
-
- $.ajax({
-
- url: "geoweaver-ssh-login-inbox",
-
- method: "POST",
-
- data: req
-
- }).done(function(msg){
-
- msg = $.parseJSON(msg);
-
- if(msg.token!=null){
-
- //open a dialog to show the SSH command line interface
-
- GW.host.showSSHCmd(msg.token);
-
- }else{
-
- alert("Username or Password is wrong or the server is not accessible");
-
- GW.host.setCache(hostid, null);
-
- }
-
- }).fail(function(status){
-
- alert("Username or Password is wrong or the server is not accessible" + status);
-
- GW.host.setCache(hostid, null);
- //$("#ssh-connect-btn").prop("disabled", false);
-
- });
-
- });
-
- }
-
- });
-
- },
-
- cleanMenu: function(){
-
- $("#host_folder_ssh_target").html("");
-
- $("#host_folder_jupyter_target").html("");
-
- $("#host_folder_jupyterhub_target").html("");
-
- $("#host_folder_gee_target").html("");
-
- },
-
- refreshHostListForExecution:function(){
-
- $.ajax({
-
- url: "listhostwithenvironments",
-
- method: "POST",
-
- data: "type=host"
-
- }).done(function(msg){
-
- msg = $.parseJSON(msg);
-
- GW.host.host_environment_list_cache = msg;
-
- console.log("Start to refresh the host list..");
-
- GW.host.list(msg);
-
- if($(".hostselector")) {
-
- for(var i=0;i";
-
- cont += "
IP
" + hostmsg.ip + "
";
-
- cont += "Port
" + hostmsg.port + "
";
-
- cont += "User
" + hostmsg.username + "
";
-
- cont += "Password
";
-
- cont += " "+
- " "+
- " "+
- "
";
-
- cont += "Environment List
"+ - ""+
- " "+
- " "+
- "
"+
- "
";
-
- $("#environment-iframe").html(content);
-
- $("#closeEnvironmentPanel").click(function(){
-
- $("#environment-iframe").html("");
-
- });
-
- },
-
- readEnvironmentCallback: function(encrypt, req, dialogItself, button){
-
- req.pswd = encrypt;
-
- req.token = GW.general.CLIENT_TOKEN;
-
- $.ajax({
-
- url: "readEnvironment",
-
- type: "POST",
-
- data: req
-
- }).done(function(msg){
-
- if(msg){
-
- msg = GW.general.parseResponse(msg);
-
- if(msg.status == "failed"){
-
- alert("Fail to read python environment.");
-
- console.error("fail to execute the process " + msg.reason);
-
- }else{
-
- GW.host.showEnvironmentTable(msg);
-
- }
-
-
-
- }else{
-
- console.warn("Return Response is Empty");
-
- GW.host.showEnvironmentTable([]);
-
- }
-
- if(dialogItself) {
-
- try{dialogItself.closeFrame(); }catch(e){}
-
- }
-
-
- }).fail(function(jxr, status){
-
- alert("Error: unable to log on. Check if your password or the configuration of host is correct.");
-
- if($("#inputpswd").length) $("#inputpswd").val("");
-
- if ($("#pswd-confirm-btn").prop("disabled")) {
- $("#pswd-confirm-btn").prop("disabled", false);
- }
-
- console.error("fail to execute the process " + req.processId);
-
- });
- },
-
- readEnvironment: function(hid){
-
- var req = {
-
- hostid: hid,
-
- }
-
- GW.host.start_auth_single(hid, req, GW.host.readEnvironmentCallback );
-
- },
-
- display: function(msg){
-
- GW.process.editOn = false;
-
- var content = "| Name | "+ - "Bin Path | "+ - "PyEnv | "+ - "Base Directory | "+ - "Settings | "+ - ""+msg[i].bin+" | "+ - ""+msg[i].pyenv+" | "+ - ""+msg[i].basedir+" | "+ - ""+msg[i].settings+" | "+ - " "; - - } - - content += "
|---|
";
-
- content += "
";
-
-
- $("#main-host-content").html(content);
-
- GW.ssh.current_process_log_length = 0;
-
- GW.general.switchTab("host");
-
-
- },
-
- viewJupyter: function(history_id){
-
- $.ajax({
-
- url: "log",
-
- method: "POST",
-
- data: "type=host&id=" + history_id
-
- }).done(function(msg){
-
- if(msg==""){
-
- alert("Cannot find the host history in the database.");
-
- return;
-
- }
-
- msg = $.parseJSON(msg);
-
- var code = msg.output;
-
- if(code!=null && typeof code != 'undefined'){
-
- if(typeof code != 'object'){
-
- code = $.parseJSON(code);
-
- }
-
- var notebook = nb.parse(code.content);
-
- var rendered = notebook.render();
-
- var content = '";
- content += ""
-
- var delbtn = "";
-
-// if(hostip!="127.0.0.1")
- if(msg.id!="100001")
- delbtn = "";
-
- content += "
"+
-
- ""+
-
- "
"+
-
- ""+ - - this.getToolbar(hostid, hosttype) + - - delbtn + - - "
"+ - - ""+
-
- "
"+
-
- ""+
-
- "
"+
-
- ""+
-
- "
"+
-
- ""+
-
- "
"+
-
- ""+
-
- "
"+
-
- "'+$(rendered).html()+'
';
-
- content += '';
-
-// console.log(content);
-
- GW.host.his_frame = GW.process.createJSFrameDialog(800, 600, content, "History Jupyter Notebook " + history_id);
-
- $("#host-history-download-btn").click(function(){
-
- GW.host.downloadJupyter(history_id);
-
- })
-
- $("#host-history-cancel-btn").click(function(){
-
- GW.host.his_frame.closeFrame();
-
- });
-
- }
-
- }).fail(function(e){
-
- console.error(e);
-
- });
-
- },
-
-
- deleteSelectedJupyter: function(){
-
- if(confirm("Are you sure to remove all the selected history? This is permanent.")){
-
- $(".hist-checkbox:checked").each(function() {
-
- var histid = $(this).attr('id');
-
- console.log("Removing "+histid);
-
- GW.host.deleteJupyterDirectly(histid.substring(9));
-
- });
-
- }
-
- },
-
- deleteJupyterDirectly: function(history_id){
-
- $.ajax({
-
- url: "del",
-
- method: "POST",
-
- data: "type=history&id=" + history_id
-
- }).done(function(msg){
-
- if(msg==""){
-
- alert("Cannot find the host history in the database.");
-
- return;
-
- }else if(msg=="done"){
-
- console.log("The history " + history_id + " is removed")
-
- $("#host_history_row_" + history_id).remove()
-
- }else{
-
- alert("Fail to delete the jupyter notebook")
-
- console.error("Fail to delete jupyter: " + msg);
-
- }
-
- })
-
- },
-
- deleteJupyter: function(history_id){
-
- if(confirm("Are you sure to remove this history? This is permanent.")){
-
- this.deleteJupyterDirectly(history_id);
-
- }
-
- },
-
- downloadJupyter: function(history_id){
-
- $.ajax({
-
- url: "log",
-
- method: "POST",
-
- data: "type=host&id=" + history_id
-
- }).done(function(msg){
-
- if(msg==""){
-
- alert("Cannot find the host history in the database.");
-
- return;
-
- }
-
- msg = $.parseJSON(msg);
-
- var code = msg.output;
-
- if(code!=null && typeof code != 'undefined'){
-
- if(typeof code != 'object'){
-
- code = $.parseJSON(code);
-
- }
-
-// function download(content, fileName, contentType) {
-
- var a = document.createElement("a");
-
- var file = new Blob([JSON.stringify(code.content)], {type: "application/json"});
-
- a.href = URL.createObjectURL(file);
-
- a.target = "_blank"
-
- a.download = "jupyter-"+history_id + ".ipynb";
-
- a.click();
-
-// }
-
- }
-
-// download(jsonData, 'json.txt', 'text/plain');
-
-
-
- })
-
- },
-
- historyTableCellUpdateCallBack: function(updatedCell, updatedRow, oldValue){
-
- console.log("The new value for the cell is: " + updatedCell.data());
- console.log("The old value for that cell was: " + oldValue);
- console.log("The values for each cell in that row are: " + updatedRow.data());
-
- // The values for each cell in that row are: ,http://localhost:8888/api/contents/work/GMU%20workspace/COVID/covid_win_laptop.ipynb,xyz,2021-03-03 22:00:32.913,View Download Delete
-
- var thecheckbox = updatedRow.data()[0]
-
- var hisid = $(thecheckbox).attr("id").substring(9)
-
- console.log("history id: " + hisid)
-
- var newvalue = updatedRow.data()[2]
-
- GW.history.updateNotesOfAHistory(hisid, newvalue);
-
- },
-
-
- recent: function(hid){
-
- console.log("Show the history of all previously executed scripts/jupyter notebok");
-
- $.ajax({
-
- url: "recent",
-
- method: "POST",
-
- data: "type=host&hostid=" + hid + "&number=100"
-
- }).done(function(msg){
-
- if(!msg.length){
-
- alert("no history found");
-
- return;
-
- }
-
- msg = $.parseJSON(msg);
-
- var content = "Recent History
"+ - ""+
-
- " "+
- " "+
- "
"+
- " "+
- " "+
- " "+
- "
"+
-
- "| "+ - " | Process | "+ - "Notes (Click to Edit) | "+ - "Begin Time | "+ - "End Time | "+ -// "Status | "+ - "Action | "+ - "
|---|---|---|---|---|---|---|
| "+ - " | "+msg[i].name+" | "+ - ""+msg[i].notes+" | "+ - ""+msg[i].begin_time+" | "+ - ""+msg[i].end_time+" | "+ -// status_col + - detailbtn + - "
| Name | ' + + 'Bin Path | ' + + 'PyEnv | ' + + 'Base Directory | ' + + 'Settings | ' + + "
|---|---|---|---|---|
| " + + msg[i].name + + " | " + + "" + + msg[i].bin + + " | " + + "" + + msg[i].pyenv + + " | " + + "" + + msg[i].basedir + + " | " + + "" + + msg[i].settings + + " | " + + "
';
+
+ content += '
";
+
+ $("#main-host-content").html(content);
+
+ GW.ssh.current_process_log_length = 0;
+
+ GW.general.switchTab("host");
+ },
+
+ viewJupyter: function (history_id) {
+ $.ajax({
+ url: "log",
+
+ method: "POST",
+
+ data: "type=host&id=" + history_id,
+ })
+ .done(function (msg) {
+ if (msg == "") {
+ alert("Cannot find the host history in the database.");
+
+ return;
+ }
+
+ msg = $.parseJSON(msg);
+
+ var code = msg.output;
+
+ if (code != null && typeof code != "undefined") {
+ if (typeof code != "object") {
+ code = $.parseJSON(code);
+ }
+
+ var notebook = nb.parse(code.content);
+
+ var rendered = notebook.render();
+
+ var content =
+ '';
+ content += '";
+
+ var delbtn = "";
+
+ // if(hostip!="127.0.0.1")
+ if (msg.id != "100001")
+ delbtn =
+ '";
+
+ content +=
+ "
" +
+ '' +
+ '
" +
+ '' + + this.getToolbar(hostid, hosttype) + + delbtn + + "
" + + "' +
+ "
" +
+ '' +
+ "
" +
+ '' +
+ "
" +
+ '' +
+ "
" +
+ '' +
+ "
" +
+ "' + $(rendered).html() + "
";
+
+ content +=
+ '";
+
+ // console.log(content);
+
+ GW.host.his_frame = GW.process.createJSFrameDialog(
+ 800,
+ 600,
+ content,
+ "History Jupyter Notebook " + history_id,
+ );
+
+ $("#host-history-download-btn").click(function () {
+ GW.host.downloadJupyter(history_id);
+ });
+
+ $("#host-history-cancel-btn").click(function () {
+ GW.host.his_frame.closeFrame();
+ });
+ }
+ })
+ .fail(function (e) {
+ console.error(e);
+ });
+ },
+
+ deleteSelectedJupyter: function () {
+ if (
+ confirm(
+ "Are you sure to remove all the selected history? This is permanent.",
+ )
+ ) {
+ $(".hist-checkbox:checked").each(function () {
+ var histid = $(this).attr("id");
+
+ console.log("Removing " + histid);
+
+ GW.host.deleteJupyterDirectly(histid.substring(9));
+ });
+ }
+ },
+
+ deleteJupyterDirectly: function (history_id) {
+ $.ajax({
+ url: "del",
+
+ method: "POST",
+
+ data: "type=history&id=" + history_id,
+ }).done(function (msg) {
+ if (msg == "") {
+ alert("Cannot find the host history in the database.");
+
+ return;
+ } else if (msg == "done") {
+ console.log("The history " + history_id + " is removed");
+
+ $("#host_history_row_" + history_id).remove();
+ } else {
+ alert("Fail to delete the jupyter notebook");
+
+ console.error("Fail to delete jupyter: " + msg);
+ }
+ });
+ },
+
+ deleteJupyter: function (history_id) {
+ if (confirm("Are you sure to remove this history? This is permanent.")) {
+ this.deleteJupyterDirectly(history_id);
+ }
+ },
+
+ downloadJupyter: function (history_id) {
+ $.ajax({
+ url: "log",
+
+ method: "POST",
+
+ data: "type=host&id=" + history_id,
+ }).done(function (msg) {
+ if (msg == "") {
+ alert("Cannot find the host history in the database.");
+
+ return;
+ }
+
+ msg = $.parseJSON(msg);
+
+ var code = msg.output;
+
+ if (code != null && typeof code != "undefined") {
+ if (typeof code != "object") {
+ code = $.parseJSON(code);
+ }
+
+ // function download(content, fileName, contentType) {
+
+ var a = document.createElement("a");
+
+ var file = new Blob([JSON.stringify(code.content)], {
+ type: "application/json",
+ });
+
+ a.href = URL.createObjectURL(file);
+
+ a.target = "_blank";
+
+ a.download = "jupyter-" + history_id + ".ipynb";
+
+ a.click();
+
+ // }
+ }
+
+ // download(jsonData, 'json.txt', 'text/plain');
+ });
+ },
+
+ historyTableCellUpdateCallBack: function (updatedCell, updatedRow, oldValue) {
+ console.log("The new value for the cell is: " + updatedCell.data());
+ console.log("The old value for that cell was: " + oldValue);
+ console.log(
+ "The values for each cell in that row are: " + updatedRow.data(),
+ );
+
+ // The values for each cell in that row are: ,http://localhost:8888/api/contents/work/GMU%20workspace/COVID/covid_win_laptop.ipynb,xyz,2021-03-03 22:00:32.913,View Download Delete
+
+ var thecheckbox = updatedRow.data()[0];
+
+ var hisid = $(thecheckbox).attr("id").substring(9);
+
+ console.log("history id: " + hisid);
+
+ var newvalue = updatedRow.data()[2];
+
+ GW.history.updateNotesOfAHistory(hisid, newvalue);
+ },
+
+ recent: function (hid) {
+ console.log(
+ "Show the history of all previously executed scripts/jupyter notebok",
+ );
+
+ $.ajax({
+ url: "recent",
+
+ method: "POST",
+
+ data: "type=host&hostid=" + hid + "&number=100",
+ })
+ .done(function (msg) {
+ if (!msg.length) {
+ alert("no history found");
+
+ return;
+ }
+
+ msg = $.parseJSON(msg);
+
+ var content =
+ 'Recent History
' + + '' +
+ ' ' +
+ " " +
+ "
' +
+ ' ' +
+ ' ' +
+ ' ' +
+ '
' +
+ '| ' + + ' | Process | ' + + 'Notes (Click to Edit) | ' + + 'Begin Time | ' + + 'End Time | ' + + // "Status | "+ + 'Action | ' + + "View Download Delete | "; + + content += + '
|---|---|---|---|---|---|---|
| ' + + " | " + + msg[i].name + + " | " + + "" + + msg[i].notes + + " | " + + "" + + msg[i].begin_time + + " | " + + "" + + msg[i].end_time + + " | " + + // status_col + + detailbtn + + "
| Process | ' + + 'Begin Time | ' + + 'End Time | ' + + 'Status | ' + + 'Action | ' + + "Details | "; + // viewChanges = "View Changes | "; + } else { + detailbtn = + "Details | "; + // viewChanges = "View Changes | "; + } + + // detailbtn = "Details | "; + + content += + "
|---|---|---|---|---|
| " + + msg[i].name + + " | " + + "" + + msg[i].begin_time + + " | " + + "" + + msg[i].end_time + + " | " + + status_col + + detailbtn + + // viewChanges + + "
| Process | "+ - "Begin Time | "+ - "End Time | "+ - "Status | "+ - "Action | "+ - "View Changes | "; - - }else{ - - detailbtn = "Details | "; - // viewChanges = "View Changes | "; - - } - -// detailbtn = "Details | "; - - content += "
|---|---|---|---|---|
| "+msg[i].name+" | "+ - ""+msg[i].begin_time+" | "+ - ""+msg[i].end_time+" | "+ - status_col + - detailbtn + - // viewChanges + - "
@@ -1456,1030 +1411,960 @@ GW.process = {
| Name | "+ - "Description | "+ - "Type | "+ - ""+data[i].desc+" | "+ - ""+data[i].type+" | "+ - " "; - - } - - content += "
|---|
"+
- " "+
- "
"+
- "
| Name | ' + + 'Description | ' + + 'Type | ' + + "
|---|---|---|
| " + + data[i].name + + " | " + + "" + + data[i].desc + + " | " + + "" + + data[i].type + + " | " + + "
' +
+ ' ' +
+ '
" +
+ "
' +
+ ' ' +
+ " Clear Connection between Process and Host " +
+ ' ' +
+ ' ' +
+ ' ' +
+ " " +
+ " " +
+ " " +
+ ' ' +
+ " Clear Connection between Workflow and Host " +
+ ' ' +
+ ' ' +
+ ' ' +
+ " " +
+ " " +
+ " " +
+ ' ' +
+ " Clear Passwords Only" +
+ ' ' +
+ ' ' +
+ ' ' +
+ " " +
+ " " +
+ " " +
+ ' ' +
+ " Clear All Cached Information " +
+ ' ' +
+ ' ' +
+ ' ' +
+ " " +
+ " " +
+ " " +
+ "
";
- alert("Cache cleared.");
-
- }
-
- },
-
- clearProcessConnections: function(){
-
- if(confirm("Do you want to clear the remembered mappings between processes and hosts?")){
-
- GW.process.clearCache();
+ var frame = GW.process.createJSFrameDialog(360, 320, content, "Settings");
- alert("Cache cleared.");
- }
-
- },
-
- clearWorkflowConnections: function(){
-
- if(confirm("Do you want to clear the remembered mappings between workflows and hosts?")){
-
- GW.workflow.clearCache();
-
- alert("Cache cleared.");
-
- }
-
- },
-
- showDialog: function(){
-
- var content = " "+
- " "+
- " Clear Connection between Process and Host "+
- " "+
- " "+
- " "+
- " "+
- " "+
- " "+
- " "+
- " Clear Connection between Workflow and Host "+
- " "+
- " "+
- " "+
- " "+
- " "+
- " "+
- " "+
- " Clear Passwords Only"+
- " "+
- " "+
- " "+
- " "+
- " "+
- " "+
- " "+
- " Clear All Cached Information "+
- " "+
- " "+
- " "+
- " "+
- " "+
- " "+
- "
";
-
- var frame = GW.process.createJSFrameDialog(360, 320, content, "Settings");
-
-// BootstrapDialog.show({
-//
-// title: "Settings",
-//
-// message: function(){
-//
-// var content = " "+
-// " "+
-// " Clear Connection between Process and Host "+
-// " "+
-// " "+
-// " "+
-// " "+
-// " "+
-// " "+
-// " "+
-// " Clear Connection between Workflow and Host "+
-// " "+
-// " "+
-// " "+
-// " "+
-// " "+
-// " "+
-// " "+
-// " Clear Passwords Only"+
-// " "+
-// " "+
-// " "+
-// " "+
-// " "+
-// " "+
-// " "+
-// " Clear All Cached Information "+
-// " "+
-// " "+
-// " "+
-// " "+
-// " "+
-// " "+
-// "
";
-//
-// return content;
-//
-// },
-//
-// buttons: [{
-//
-// label: "Close",
-//
-// action: function(dialogItself){
-//
-// dialogItself.close();
-//
-// }
-//
-// }]
-//
-// });
-
- }
-
-}
\ No newline at end of file
+ // BootstrapDialog.show({
+ //
+ // title: "Settings",
+ //
+ // message: function(){
+ //
+ // var content = " "+
+ // " "+
+ // " Clear Connection between Process and Host "+
+ // " "+
+ // " "+
+ // " "+
+ // " "+
+ // " "+
+ // " "+
+ // " "+
+ // " Clear Connection between Workflow and Host "+
+ // " "+
+ // " "+
+ // " "+
+ // " "+
+ // " "+
+ // " "+
+ // " "+
+ // " Clear Passwords Only"+
+ // " "+
+ // " "+
+ // " "+
+ // " "+
+ // " "+
+ // " "+
+ // " "+
+ // " Clear All Cached Information "+
+ // " "+
+ // " "+
+ // " "+
+ // " "+
+ // " "+
+ // " "+
+ // "
";
+ //
+ // return content;
+ //
+ // },
+ //
+ // buttons: [{
+ //
+ // label: "Close",
+ //
+ // action: function(dialogItself){
+ //
+ // dialogItself.close();
+ //
+ // }
+ //
+ // }]
+ //
+ // });
+ },
+};
diff --git a/src/main/resources/static/js/gw.sidenav.js b/src/main/resources/static/js/gw.sidenav.js
index 5a508eb67..7b728323a 100644
--- a/src/main/resources/static/js/gw.sidenav.js
+++ b/src/main/resources/static/js/gw.sidenav.js
@@ -1,48 +1,59 @@
window.sidenavContext = undefined;
GW.sidenav = {
+ setSidenavWindowObjects: (
+ code,
+ owner,
+ confidentialField,
+ category,
+ codeType,
+ processId,
+ processName,
+ ) => {
+ window.sidenavContext.code = code;
+ window.sidenavContext.confidentialField = confidentialField;
+ window.sidenavContext.category = category;
+ window.sidenavContext.codeType = codeType;
+ window.sidenavContext.processId = processId;
+ window.sidenavContext.processName = processName;
+ },
- setSidenavWindowObjects: (
- code, owner, confidentialField, category, codeType, processId, processName
- ) => {
- window.sidenavContext.code = code;
- window.sidenavContext.confidentialField = confidentialField;
- window.sidenavContext.category = category;
- window.sidenavContext.codeType = codeType;
- window.sidenavContext.processId = processId;
- window.sidenavContext.processName = processName;
- },
+ getData: (id) => {
+ const TYPE = "process";
+ let code,
+ owner,
+ confidentialField,
+ category,
+ codeType,
+ processId,
+ processName;
- getData: (id) => {
- const TYPE = "process";
- let code, owner, confidentialField, category, codeType, processId, processName;
+ $.ajax({
+ url: "detail",
+ method: "POST",
+ data: "type=" + TYPE + "&id=" + id,
+ }).done((response) => {
+ let parsedMessage = GW.general.parseResponse(response);
+ codeType = parsedMessage.lang.equals(null)
+ ? parsedMessage.description
+ : parsedMessage.lang;
+ code = parsedMessage.code;
+ if (code && code.includes('\\"')) {
+ code = GW.process.unescape(code);
+ }
+ processId = parsedMessage.id;
+ processName = parsedMessage.name;
+ owner = parsedMessage.owner;
+ confidentialField = parsedMessage.confidential !== "FALSE";
- $.ajax({
- url: "detail",
- method: "POST",
- data: "type=" + TYPE + "&id=" + id
- }).done((response) => {
- let parsedMessage = GW.general.parseResponse(response);
- codeType = parsedMessage.lang.equals(null) ? parsedMessage.description : parsedMessage.lang
- code = parsedMessage.code;
- if (code && code.includes("\\\"")) {
- code = GW.process.unescape(code);
- }
- processId = parsedMessage.id;
- processName = parsedMessage.name;
- owner = parsedMessage.owner;
- confidentialField = parsedMessage.confidential !== "FALSE";
-
- this.setSidenavWindowObjects(
- code,
- owner,
- confidentialField,
- category,
- codeType,
- processId,
- processName
- )
-
- })
- }
-
-}
\ No newline at end of file
+ this.setSidenavWindowObjects(
+ code,
+ owner,
+ confidentialField,
+ category,
+ codeType,
+ processId,
+ processName,
+ );
+ });
+ },
+};
diff --git a/src/main/resources/static/js/gw.ssh.js b/src/main/resources/static/js/gw.ssh.js
index 7c5e30eec..f8c0ff75d 100644
--- a/src/main/resources/static/js/gw.ssh.js
+++ b/src/main/resources/static/js/gw.ssh.js
@@ -1,414 +1,344 @@
-
/**
- *
+ *
* SSH client
- *
- * Create a shared websocket shell to stream all the results from server to the client.
- *
+ *
+ * Create a shared websocket shell to stream all the results from server to the client.
+ *
* Distinguish the outputs of different sessions using tokens.
- *
- * Only one ssh session is allowed at one time.
- *
- * Only one running workflow is allowed at one time.
- *
+ *
+ * Only one ssh session is allowed at one time.
+ *
+ * Only one running workflow is allowed at one time.
+ *
*/
GW.ssh = {
-
- shell: null,
-
- sshConnected : false,
-
- passwordPhase : false,
-
- user : null,
-
- host : null,
-
- port : null,
-
- token : null,
-
- output_div_id: null,
-
- process_output_id: "process-log-window",
-
- ws: null,
-
- all_ws: null, //future websocket session for all the traffic between client and server
-
- last_prompt: null,
-
- password_cout: 0,
-
- key : '',
-
- checker_swich: false,
-
- current_log_length: 0, // length of log in log-window
-
- current_process_log_length: 0, // length of log in process and prompt log-window
-
- username : '') - - this.addlog(content); - - // trigger the builtin process - - if(GW.general.isJSON(content)){ - - try{ - - var returnmsg = $.parseJSON(content); - - console.log(returnmsg); - - if(returnmsg.ret == "success"){ - - setTimeout(function (){ - - GW.process.callback(returnmsg); - - }, 2000); - - - } - - if(returnmsg.builtin){ - - GW.process.callback(returnmsg); - - }else{ - - // GW.workspace.updateStatus(returnmsg); // the workflow status message should only come from the workflow-socket - - } - - }catch(errors){ - - console.error(errors) - - } - - } - - } - - }, - - error: function(content){ - - content = content.replace(/\n/g,'
') - - this.addlog(content); - - }, - - send: function (data) { - - if(this.ws != null){ - - this.ws.send(data); - - } else { - - if(data!=this.token){ - - this.error('not connected!'); - - } - - } - }, - - checkSessionStatus: function(){ - // console.log("Current WS status: " + GW.ssh.all_ws.readyState); - // return GW.ssh.all_ws.readyState; - - GW.ssh.checker_swich = true; - - GW.ssh.send("token:"+GW.general.CLIENT_TOKEN); - - setTimeout(() => { - - if(GW.ssh.checker_swich){ - - //restart the websocket if the switch is still true two seconds later - GW.ssh.startLogSocket(GW.ssh.token); - GW.ssh.checker_swich = false; - - } - - }, 2000); - - }, - - ws_onopen: function (e) { - - console.log("WebSocket Channel is Openned"); - - this.echo("connected"); - - setTimeout(() => { GW.ssh.send("token:" + GW.general.CLIENT_TOKEN) }, 1000); //create a chance for the server side to register the session if it didn't when it is openned - - }, - - - ws_onclose: function (e) { - - try{ - - this.echo("disconnected"); - - GW.ssh.all_ws = null; - GW.ssh.ws = null; - GW.ssh.token = null; - - }catch(e){ - - console.error(e); - - this.echo("Reconnection failed. " + e) - - } - - console.log("the logging out websocket has been closed"); - - }, - - ws_onerror: function (e) { - - this.error("The process execution failed.") - - this.error("Reason: " + e); - - }, - - ws_onmessage: function (e) { - - try { - if(e.data.indexOf("Session_Status:Active")!=-1){ - GW.ssh.checker_swich = false; - }else if(e.data.indexOf(this.special.prompt) == -1 && - - e.data.indexOf(this.special.ready) == -1 && - - e.data.indexOf("No SSH connection is active") == -1) { - - this.echo(e.data); - - }else{ - - //the websocket is already closed. try the history query - - // this.echo("It ends too quickly. Go to history to check the logs out."); - - } - - - - //if (e.data.indexOf(special.ready) != -1) { - - // shell.resume(); - - //} - - } catch(err) { - - console.log(err); - - this.error("** Invalid server response : " + e.data); - - } - - }, - - addlog: function(content){ - var dt = new Date(); - var time = dt.getHours() + ":" + dt.getMinutes() + ":" + dt.getSeconds(); - - cont_splits = content.split("*_*") - - log_history_id = null - - if(cont_splits.length>1){ - log_history_id = cont_splits[0] - let newArray = cont_splits.slice(1); - content = newArray.join(" ") - } - - var style1 = ""; - if(content.includes("Start to execute")){ - - style1 = "color: blue; font-weight: bold; text-decoration: underline;"; - - $(".dot-flashing").removeClass("invisible") - $(".dot-flashing").addClass("visible") - - }else if(content.includes("===== Process")){ - - style1 = "color: blue; font-weight: bold; text-decoration: underline;"; - - $(".dot-flashing").removeClass("visible") - $(".dot-flashing").addClass("invisible") - - }else if(content=="disconnected"){ - $(".dot-flashing").removeClass("visible") - $(".dot-flashing").addClass("invisible") - }else if(log_history_id == GW.process.history_id){ - $(".dot-flashing").removeClass("invisible") - $(".dot-flashing").addClass("visible") - }else{ - $(".dot-flashing").removeClass("visible") - $(".dot-flashing").addClass("invisible") - } - - var newline = `
` + content + `
`; - - this.current_log_length += 1 //line number plus 1 - - if(this.current_log_length > 5000){ - $("#log-window").find('p:first').remove(); - this.current_log_length -= 1 - } - - $("#log-window").append(newline); - - //don't output log to process log if the current executed is workflow - if(GW.process.last_executed_process_id==GW.process.process_id){ - - if($("#"+GW.ssh.process_output_id).length){ - - if(this.current_process_log_length > 5000){ - - $("#"+GW.ssh.process_output_id).find('p:first').remove(); - - this.current_process_log_length -= 1 - - } - - if(GW.process.history_id == log_history_id){ - - // only display the log if the current history id is the correct one - $("#"+GW.ssh.process_output_id).append(newline); - - } - - - this.current_process_log_length += 1 - - } - - } - - - }, - - clearProcessLog: function(){ - - $("#"+GW.ssh.process_output_id).html(""); - - }, - - clearMain: function(){ - - $("#log-window").html(""); - - }, - - getWsPrefixURL: function(){ - - var s = ((window.location.protocol === "https:") ? "wss://" : "ws://") + window.location.host + "/Geoweaver/"; - -// s += "Geoweaver/"; //this is gone in spring boot - - console.log("Ws URL Prefix: ", s) - - return s; - - }, - - startLogSocket: function(token){ - - if(GW.ssh.all_ws) GW.ssh.all_ws.close(); - - GW.ssh.all_ws = new WebSocket(this.getWsPrefixURL() + "command-socket"); - - GW.ssh.ws = GW.ssh.all_ws; - - GW.ssh.output_div_id = "log_box_id"; - - GW.ssh.token = token; //token is the jsession id - -// this.echo("Running process " + token) - - GW.ssh.all_ws.onopen = function(e) { GW.ssh.ws_onopen(e) }; - - GW.ssh.all_ws.onclose = function(e) { GW.ssh.ws_onclose(e) }; - - GW.ssh.all_ws.onmessage = function(e) { GW.ssh.ws_onmessage(e) }; - - GW.ssh.all_ws.onerror = function(e) { GW.ssh.ws_onerror(e) }; - - }, - - connectWsSessionWithExecution: function(msg){ - - - - }, - - openLog: function(msg){ - - //check if the websocket session is alive, otherwise, restore the connection - - if (GW.ssh.all_ws!=null && (GW.ssh.all_ws.readyState === WebSocket.CLOSED || GW.ssh.all_ws.readyState === WebSocket.CLOSING) ) { - - // GW.ssh.all_ws.close(); - - console.log("The command websocket connection is detected to be closed. Try to reconnect..."); - - GW.ssh.startLogSocket(msg.token); - - console.log("The console websocket connection is restored.."); - - }else{ - - GW.ssh.checkSessionStatus(); - - } - - if(msg.history_id.length==12) - this.addlog("=======\nStart to execute Process " + msg.history_id); - else - this.addlog("=======\nStart to execute Workflow " + msg.history_id); - - }, - - openTerminal: function(token, terminal_div_id){ - - } - -} \ No newline at end of file + shell: null, + + sshConnected: false, + + passwordPhase: false, + + user: null, + + host: null, + + port: null, + + token: null, + + output_div_id: null, + + process_output_id: "process-log-window", + + ws: null, + + all_ws: null, //future websocket session for all the traffic between client and server + + last_prompt: null, + + password_cout: 0, + + key: "", + + checker_swich: false, + + current_log_length: 0, // length of log in log-window + + current_process_log_length: 0, // length of log in process and prompt log-window + + username: '"); + + this.addlog(content); + + // trigger the builtin process + + if (GW.general.isJSON(content)) { + try { + var returnmsg = $.parseJSON(content); + + console.log(returnmsg); + + if (returnmsg.ret == "success") { + setTimeout(function () { + GW.process.callback(returnmsg); + }, 2000); + } + + if (returnmsg.builtin) { + GW.process.callback(returnmsg); + } else { + // GW.workspace.updateStatus(returnmsg); // the workflow status message should only come from the workflow-socket + } + } catch (errors) { + console.error(errors); + } + } + } + }, + + error: function (content) { + content = content.replace(/\n/g, "
"); + + this.addlog(content); + }, + + send: function (data) { + if (this.ws != null) { + this.ws.send(data); + } else { + if (data != this.token) { + this.error("not connected!"); + } + } + }, + + checkSessionStatus: function () { + // console.log("Current WS status: " + GW.ssh.all_ws.readyState); + // return GW.ssh.all_ws.readyState; + + GW.ssh.checker_swich = true; + + GW.ssh.send("token:" + GW.general.CLIENT_TOKEN); + + setTimeout(() => { + if (GW.ssh.checker_swich) { + //restart the websocket if the switch is still true two seconds later + GW.ssh.startLogSocket(GW.ssh.token); + GW.ssh.checker_swich = false; + } + }, 2000); + }, + + ws_onopen: function (e) { + console.log("WebSocket Channel is Openned"); + + this.echo("connected"); + + setTimeout(() => { + GW.ssh.send("token:" + GW.general.CLIENT_TOKEN); + }, 1000); //create a chance for the server side to register the session if it didn't when it is openned + }, + + ws_onclose: function (e) { + try { + this.echo("disconnected"); + + GW.ssh.all_ws = null; + GW.ssh.ws = null; + GW.ssh.token = null; + } catch (e) { + console.error(e); + + this.echo("Reconnection failed. " + e); + } + + console.log("the logging out websocket has been closed"); + }, + + ws_onerror: function (e) { + this.error("The process execution failed."); + + this.error("Reason: " + e); + }, + + ws_onmessage: function (e) { + try { + if (e.data.indexOf("Session_Status:Active") != -1) { + GW.ssh.checker_swich = false; + } else if ( + e.data.indexOf(this.special.prompt) == -1 && + e.data.indexOf(this.special.ready) == -1 && + e.data.indexOf("No SSH connection is active") == -1 + ) { + this.echo(e.data); + } else { + //the websocket is already closed. try the history query + // this.echo("It ends too quickly. Go to history to check the logs out."); + } + + //if (e.data.indexOf(special.ready) != -1) { + + // shell.resume(); + + //} + } catch (err) { + console.log(err); + + this.error("** Invalid server response : " + e.data); + } + }, + + addlog: function (content) { + var dt = new Date(); + var time = dt.getHours() + ":" + dt.getMinutes() + ":" + dt.getSeconds(); + + cont_splits = content.split("*_*"); + + log_history_id = null; + + if (cont_splits.length > 1) { + log_history_id = cont_splits[0]; + let newArray = cont_splits.slice(1); + content = newArray.join(" "); + } + + var style1 = ""; + if (content.includes("Start to execute")) { + style1 = "color: blue; font-weight: bold; text-decoration: underline;"; + + $(".dot-flashing").removeClass("invisible"); + $(".dot-flashing").addClass("visible"); + } else if (content.includes("===== Process")) { + style1 = "color: blue; font-weight: bold; text-decoration: underline;"; + + $(".dot-flashing").removeClass("visible"); + $(".dot-flashing").addClass("invisible"); + } else if (content == "disconnected") { + $(".dot-flashing").removeClass("visible"); + $(".dot-flashing").addClass("invisible"); + } else if (log_history_id == GW.process.history_id) { + $(".dot-flashing").removeClass("invisible"); + $(".dot-flashing").addClass("visible"); + } else { + $(".dot-flashing").removeClass("visible"); + $(".dot-flashing").addClass("invisible"); + } + + var newline = + `
` + + content + + `
`; + + this.current_log_length += 1; //line number plus 1 + + if (this.current_log_length > 5000) { + $("#log-window").find("p:first").remove(); + this.current_log_length -= 1; + } + + $("#log-window").append(newline); + + //don't output log to process log if the current executed is workflow + if (GW.process.last_executed_process_id == GW.process.process_id) { + if ($("#" + GW.ssh.process_output_id).length) { + if (this.current_process_log_length > 5000) { + $("#" + GW.ssh.process_output_id) + .find("p:first") + .remove(); + + this.current_process_log_length -= 1; + } + + if (GW.process.history_id == log_history_id) { + // only display the log if the current history id is the correct one + $("#" + GW.ssh.process_output_id).append(newline); + } + + this.current_process_log_length += 1; + } + } + }, + + clearProcessLog: function () { + $("#" + GW.ssh.process_output_id).html(""); + }, + + clearMain: function () { + $("#log-window").html(""); + }, + + getWsPrefixURL: function () { + var s = + (window.location.protocol === "https:" ? "wss://" : "ws://") + + window.location.host + + "/Geoweaver/"; + + // s += "Geoweaver/"; //this is gone in spring boot + + console.log("Ws URL Prefix: ", s); + + return s; + }, + + startLogSocket: function (token) { + if (GW.ssh.all_ws) GW.ssh.all_ws.close(); + + GW.ssh.all_ws = new WebSocket(this.getWsPrefixURL() + "command-socket"); + + GW.ssh.ws = GW.ssh.all_ws; + + GW.ssh.output_div_id = "log_box_id"; + + GW.ssh.token = token; //token is the jsession id + + // this.echo("Running process " + token) + + GW.ssh.all_ws.onopen = function (e) { + GW.ssh.ws_onopen(e); + }; + + GW.ssh.all_ws.onclose = function (e) { + GW.ssh.ws_onclose(e); + }; + + GW.ssh.all_ws.onmessage = function (e) { + GW.ssh.ws_onmessage(e); + }; + + GW.ssh.all_ws.onerror = function (e) { + GW.ssh.ws_onerror(e); + }; + }, + + connectWsSessionWithExecution: function (msg) {}, + + openLog: function (msg) { + //check if the websocket session is alive, otherwise, restore the connection + + if ( + GW.ssh.all_ws != null && + (GW.ssh.all_ws.readyState === WebSocket.CLOSED || + GW.ssh.all_ws.readyState === WebSocket.CLOSING) + ) { + // GW.ssh.all_ws.close(); + + console.log( + "The command websocket connection is detected to be closed. Try to reconnect...", + ); + + GW.ssh.startLogSocket(msg.token); + + console.log("The console websocket connection is restored.."); + } else { + GW.ssh.checkSessionStatus(); + } + + if (msg.history_id.length == 12) + this.addlog("=======\nStart to execute Process " + msg.history_id); + else this.addlog("=======\nStart to execute Workflow " + msg.history_id); + }, + + openTerminal: function (token, terminal_div_id) {}, +}; diff --git a/src/main/resources/static/js/gw.sshterm.js b/src/main/resources/static/js/gw.sshterm.js index add901068..74ab35e0d 100644 --- a/src/main/resources/static/js/gw.sshterm.js +++ b/src/main/resources/static/js/gw.sshterm.js @@ -9,118 +9,96 @@ var password_cout = 0; var port = window.location.port; var pcol = window.location.protocol; */ var root = getContextURLPath(); -var key = '${key}'; +var key = "${key}"; var completable = false; var username = '