modularize grpc controller and main into main_grpcController

Author: h15200

main.js

@@ -51,8 +51,9 @@ const protoParserFunc = require("./src/client/protoParser.js");
 require("./menu/mainMenu");
 // require http controller file
 
-require("./httpMainController.js")();
+require("./main_httpController.js")();
 // require('./SSEController.js')();
+require("./main_grpcController.js")();
 
 // configure logging
 // autoUpdater.logger = log;
@@ -546,211 +547,6 @@ ipcMain.on("protoParserFunc-request", (event, data) => {
     );
 });
 
-// ======================= grpcController.openGrpcConnection
-
-ipcMain.on("fetch-meta-and-client", (event, data) => {
-  const { reqResObj } = data;
-  const { rpcType } = data;
-  const PROTO_PATH = reqResObj.protoPath;
-  const { packageName, service, url, rpc, queryArr } = data.reqResObj;
-  const packageDefinition = protoLoader.loadSync(PROTO_PATH, {
-    keepCase: true,
-    longs: String,
-    enums: String,
-    defaults: true,
-    oneofs: true,
-  });
-  // create client credentials
-  const serverName = grpc.loadPackageDefinition(packageDefinition)[packageName];
-  const client = new serverName[service](
-    url,
-    grpc.credentials.createInsecure()
-  );
-
-  // create client requested metadata key and value pair for each type of streaming
-  const meta = new grpc.Metadata();
-  // this is doing nothing right now
-  const metaArr = reqResObj.request.headers;
-  for (let i = 0; i < metaArr.length; i += 1) {
-    const currentHeader = metaArr[i];
-    meta.add(currentHeader.key, currentHeader.value);
-  }
-
-  if (rpcType === "UNARY") {
-    console.log("\n \n inside UNARY if statement");
-    const query = reqResObj.queryArr[0];
-    const time = {};
-
-    // Open Connection and set time sent for Unary
-    reqResObj.connection = "open";
-
-    time.timeSent = Date.now();
-    // make Unary call
-    client[rpc](query, meta, (err, data) => {
-      if (err) {
-        console.log("unary error", err);
-      }
-      // Close Connection and set time received for Unary
-      reqResObj.timeSent = time.timeSent;
-
-      time.timeReceived = Date.now();
-      reqResObj.timeReceived = time.timeReceived;
-
-      reqResObj.connection = "closed";
-      reqResObj.response.events.push(data);
-      reqResObj.response.times.push(time);
-      // send stuff back for store
-      mainWindow.webContents.send("reqResUpdate", reqResObj);
-    }) // metadata from server
-      .on("metadata", (data) => {
-        // metadata is a Map, not an object
-        const metadata = data.internalRepr;
-        // set metadata Map as headers
-        metadata.forEach((value, key) => {
-          reqResObj.response.headers[key] = value[0];
-        });
-        mainWindow.webContents.send("reqResUpdate", reqResObj);
-      });
-  } else if (rpcType === "SERVER STREAM") {
-    console.log("SERVER STREAM inside gRPC");
-    const timesArr = [];
-    // Open Connection for SERVER Stream
-    reqResObj.connection = "open";
-    reqResObj.timeSent = Date.now();
-    const call = client[rpc](reqResObj.queryArr[0], meta);
-    call.on("data", (resp) => {
-      const time = {};
-      time.timeReceived = Date.now();
-      time.timeSent = reqResObj.timeSent;
-      // add server response to reqResObj and dispatch to state/store
-      reqResObj.response.events.push(resp);
-      reqResObj.response.times.push(time);
-      reqResObj.timeReceived = time.timeReceived; //  overwritten on each call to get the final value
-
-      mainWindow.webContents.send("reqResUpdate", reqResObj);
-    });
-    call.on("error", () => {
-      // for fatal error from server
-      console.log("server side stream error");
-    });
-    call.on("end", () => {
-      // Close Connection for SERVER Stream
-      reqResObj.connection = "closed";
-      // no need to push response to reqResObj, no event expected from on 'end'
-      mainWindow.webContents.send("reqResUpdate", reqResObj);
-    });
-    call.on("metadata", (data) => {
-      const metadata = data.internalRepr;
-      // set metadata Map as headers
-      metadata.forEach((value, key) => {
-        reqResObj.response.headers[key] = value[0];
-      });
-      mainWindow.webContents.send("reqResUpdate", reqResObj);
-    });
-  } else if (rpcType === "CLIENT STREAM") {
-    console.log("CLIENT STREAM inside gRPC");
-    // create call and open client stream connection
-    reqResObj.connection = "open";
-    const timeSent = Date.now();
-    reqResObj.timeSent = timeSent;
-    const call = client[rpc](meta, function (error, response) {
-      if (error) {
-        console.log("error in client stream", error);
-      }
-      //Close Connection for client Stream
-      reqResObj.connection = "closed";
-      const curTime = Date.now();
-      reqResObj.response.times.forEach((time) => {
-        time.timeReceived = curTime;
-        reqResObj.timeReceived = time.timeReceived;
-      });
-      reqResObj.response.events.push(response);
-      // update state
-      mainWindow.webContents.send("reqResUpdate", reqResObj);
-    }).on("metadata", (data) => {
-      // metadata is a Map, not an object
-      const metadata = data.internalRepr;
-
-      metadata.forEach((value, key) => {
-        reqResObj.response.headers[key] = value[0];
-      });
-      mainWindow.webContents.send("reqResUpdate", reqResObj);
-    });
-
-    for (let i = 0; i < queryArr.length; i++) {
-      const query = queryArr[i];
-      // Open Connection for client Stream
-      // this needs additional work to provide correct sent time for each
-      // request without overwrite
-      const time = {};
-
-      reqResObj.connection = "pending";
-
-      time.timeSent = timeSent;
-      reqResObj.response.times.push(time);
-
-      //reqResObj.connectionType = 'plain';
-      // reqResObj.timeSent = Date.now();
-
-      call.write(query);
-    }
-    call.end();
-  }
-
-  //else BIDIRECTIONAL
-  else {
-    console.log("BIDIRECTIONAL gRPC");
-    let counter = 0;
-    const call = client[rpc](meta);
-    call.on("data", (response) => {
-      const curTimeObj = reqResObj.response.times[counter];
-      counter++;
-      //Close Individual Server Response for BIDIRECTIONAL Stream
-      reqResObj.connection = "pending";
-      curTimeObj.timeReceived = Date.now();
-      reqResObj.timeReceived = curTimeObj.timeReceived;
-      reqResObj.response.events.push(response);
-      reqResObj.response.times.push(curTimeObj);
-      // update redux store
-      mainWindow.webContents.send("reqResUpdate", reqResObj);
-    }); // metadata from server
-    call.on("metadata", (data) => {
-      const metadata = data.internalRepr;
-
-      metadata.forEach((value, key) => {
-        reqResObj.response.headers[key] = value[0];
-      });
-      mainWindow.webContents.send("reqResUpdate", reqResObj);
-    });
-    call.on("error", () => {
-      console.log("server ended connection with error");
-    });
-    call.on("end", (data) => {
-      //Close Final Server Connection for BIDIRECTIONAL Stream
-      reqResObj.connection = "closed";
-      // no need to push response to reqResObj, no event expected from on 'end'
-      mainWindow.webContents.send("reqResUpdate", reqResObj);
-    });
-
-    for (let i = 0; i < queryArr.length; i++) {
-      const time = {};
-      const query = queryArr[i];
-      //Open Connection for BIDIRECTIONAL Stream
-      if (i === 0) {
-        reqResObj.connection = "open";
-      } else {
-        reqResObj.connection = "pending";
-      }
-      time.timeSent = Date.now();
-      reqResObj.timeSent = time.timeSent;
-      reqResObj.response.times.push(time);
-      call.write(query);
-    }
-    call.end();
-  }
-  mainWindow.webContents.send("reqResUpdate", reqResObj);
-});
-
 // ====================== OLDER STUFF =======================
 
 // ipcMain listener that