ajax.js

/*
 * Copyright 2012 LinkedIn Corp.
 *
 * Licensed under the Apache License, Version 2.0 (the "License"); you may not
 * use this file except in compliance with the License. You may obtain a copy of
 * the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
 * License for the specific language governing permissions and limitations under
 * the License.
 */

function ajaxCall(requestURL, data, callback) {
  var successHandler = function(data) {
    if (data.error == "session") {
      // We need to relogin.
      var errorDialog = document.getElementById("invalid-session");
      if (errorDialog) {
        $(errorDialog).modal({
          closeHTML: "<a href='#' title='Close' class='modal-close'>x</a>",
          position: ["20%",],
          containerId: 'confirm-container',
          containerCss: {
            'height': '220px',
            'width': '565px'
          },
          onClose: function (dialog) {
            window.location.reload();
          }
        });
      }
    }
    else {
      callback.call(this,data);
    }
  };
  $.get(requestURL, data, successHandler, "json");
}

function executeFlow(executingData) {
  executeURL = contextURL + "/executor";
  var successHandler = function(data) {
    if (data.error) {
      flowExecuteDialogView.hideExecutionOptionPanel();
      messageDialogView.show("Error Executing Flow", data.error);
    }
    else {
      flowExecuteDialogView.hideExecutionOptionPanel();
      messageDialogView.show("Flow submitted", data.message,
        function() {
          var redirectURL = contextURL + "/executor?execid=" + data.execid;
          window.location.href = redirectURL;
        }
      );
    }
  };

  $.get(executeURL, executingData, successHandler, "json");
}

function fetchFlowInfo(model, projectName, flowId, execId) {
  var fetchData = {"project": projectName, "ajax":"flowInfo", "flow":flowId};
  if (execId) {
    fetchData.execid = execId;
  }

  var executeURL = contextURL + "/executor";
  var successHandler = function(data) {
    if (data.error) {
      alert(data.error);
    }
    else {
      model.set({
        "successEmails": data.successEmails,
        "failureEmails": data.failureEmails,
        "failureAction": data.failureAction,
        "notifyFailure": {
          "first": data.notifyFailureFirst,
          "last": data.notifyFailureLast
        },
        "flowParams": data.flowParam,
        "isRunning": data.running,
        "nodeStatus": data.nodeStatus,
        "concurrentOption": data.concurrentOptions,
        "pipelineLevel": data.pipelineLevel,
        "pipelineExecution": data.pipelineExecution,
        "queueLevel":data.queueLevel
      });
    }
    model.trigger("change:flowinfo");
  };

  $.ajax({
    url: executeURL,
    data: fetchData,
    success: successHandler,
    dataType: "json",
    async: false
  });
}

function fetchFlow(model, projectName, flowId, sync) {
  // Just in case people don't set sync
  sync = sync ? true : false;
  var managerUrl = contextURL + "/manager";
  var fetchData = {
    "ajax" : "fetchflowgraph",
    "project" : projectName,
    "flow" : flowId
  };
  var successHandler = function(data) {
    if (data.error) {
      alert(data.error);
    }
    else {
      var disabled = data.disabled ? data.disabled : {};
      model.set({
        flowId: data.flowId,
        data: data,
        disabled: disabled
      });

      var nodeMap = {};
      for (var i = 0; i < data.nodes.length; ++i) {
        var node = data.nodes[i];
        nodeMap[node.id] = node;
      }

      for (var i = 0; i < data.edges.length; ++i) {
         var edge = data.edges[i];

         if (!nodeMap[edge.target].in) {
          nodeMap[edge.target].in = {};
         }
         var targetInMap = nodeMap[edge.target].in;
         targetInMap[edge.from] = nodeMap[edge.from];

         if (!nodeMap[edge.from].out) {
          nodeMap[edge.from].out = {};
         }
         var sourceOutMap = nodeMap[edge.from].out;
         sourceOutMap[edge.target] = nodeMap[edge.target];
      }

      model.set({nodeMap: nodeMap});
    }
  };

  $.ajax({
    url: managerUrl,
    data: fetchData,
    success: successHandler,
    dataType: "json",
    async: !sync
  });
}

/**
* Checks to see if a flow is running.
*
*/
function flowExecutingStatus(projectName, flowId) {
  var requestURL = contextURL + "/executor";

  var executionIds;
  var successHandler = function(data) {
    if (data.error == "session") {
      // We need to relogin.
      var errorDialog = document.getElementById("invalid-session");
      if (errorDialog) {
        $(errorDialog).modal({
          closeHTML: "<a href='#' title='Close' class='modal-close'>x</a>",
          position: ["20%",],
          containerId: 'confirm-container',
          containerCss: {
            'height': '220px',
            'width': '565px'
          },
          onClose: function (dialog) {
            window.location.reload();
          }
        });
      }
    }
    else {
      executionIds = data.execIds;
    }
  };
  $.ajax({
    url: requestURL,
    async: false,
    data: {
      "ajax": "getRunning",
      "project": projectName,
      "flow": flowId
    },
    error: function(data) {},
    success: successHandler
  });

  return executionIds;
}