JE-66124

Author: sych74

addons/promote-new-primary-wo-proxy/scripts/promote-master.js

@@ -44,6 +44,9 @@ function promoteNewPrimary() {
  resp = this.setContainerVar();
  if (resp.result != 0) return resp;
 
+ resp = this.setNewMasterNode();
+ if (resp.result != 0) return resp; 
+ 
  resp = this.addNode();
  if (resp.result != 0) return resp;
 
@@ -114,6 +117,13 @@ function promoteNewPrimary() {
  return this.cmdByGroup("touch " + TMP_FILE, SQLDB, 3);
  };
 
+ this.setNewMasterNode = function() {
+ return jelastic.dev.scripting.Eval("ext", session, "api.env.control.SetMasterNode", { 
+ envName: envName, 
+ nodeId: this.getNewPrimaryNode().id 
+ });
+ };
+ 
  this.setContainerVar = function() {
  let resp = this.setDomains();
  if (resp.result != 0) return resp;
@@ -355,21 +365,24 @@ function promoteNewPrimary() {
  if (resp.result != 0) return resp;
 
  let nodes = this.getParsedNodes();
+ 
+ this.log("getParsedNodes resp->" + nodes);
 
  if (nodes) {
  for (let i = 0, n = nodes.length; i < n; i++) {
  if (nodes[i]) {
- if (nodes[i].type == SECONDARY && !alreadySetNewPrimary) {
+ if (nodes[i].type == "secondary" && !alreadySetNewPrimary) {
  this.setNewPrimaryNode(nodes[i]);
  alreadySetNewPrimary = true;
- } else {
+ } 
+ if (nodes[i].type == "primary" ) {
  resp = api.env.control.SetNodeDisplayName(envName, session, nodes[i].id, PRIMARY + " - " + FAILED);
  if (resp.result != 0) return resp;
 
  resp = this.getSQLNodeById(nodes[i].id);
  if (resp.result != 0) return resp;
 
- if (resp.node && !resp.node.ismaster) {
+ if (resp.node) {
  this.setFailedPrimary(resp.node);
  }
  }
@@ -388,15 +401,24 @@ function promoteNewPrimary() {
  let resp = this.cmdById(newPrimary.id, command, 20);
  if (resp.result != 0) return resp;
 
+ 
+ 
  return api.env.control.SetNodeDisplayName(envName, session, newPrimary.id, PRIMARY);
  };
 
  this.restoreNodes = function() {
  let nodes = this.getParsedNodes();
+ 
+ this.log("restoreNodes: getParsedNodes resp->" + nodes);
 
  let newPrimary = this.getNewPrimaryNode();
+ 
+ this.log("restoreNodes: getNewPrimaryNode resp->" + newPrimary);
 
- let command = "/bash /tmp/db_recovery.sh --scenario restore_secondary_from_primary --donor-ip " + newPrimary.address;
+ let command = "bash /tmp/db_recovery.sh --scenario restore_secondary_from_primary --donor-ip " + newPrimary.address;
+ 
+ this.log("restoreNodes: command resp->" + command);
+ 
  for (let i = 0, n = nodes.length; i < n; i++) {
  if (nodes[i].id != newPrimary.id && nodes[i].type == SECONDARY) {
  let resp = this.cmdById(nodes[i].id, command);
@@ -494,6 +516,7 @@ function promoteNewPrimary() {
 
  this.removeFailedPrimary = function() {
  let failedPrimary = this.getFailedPrimary();
+ this.log("diagnosticNodes Primary ->" + failedPrimary);
  if (failedPrimary && !failedPrimary.ismaster) {
  return api.env.control.RemoveNode(envName, session, failedPrimary.id);
  }