rename file

src/builder.js

@@ -0,0 +1,40 @@
+const crypto = require("crypto");
+
+const scenario = require("./scenario");
+const config = require("./config");
+
+function builder(scenarioName, scenarioConfig) {
+  const scenes = [];
+
+  const builtScenario = scenario[scenarioName](scenarioConfig);
+  const sessionId = crypto.randomBytes(16).toString("hex");
+
+  for (const scene of builtScenario) {
+    scene.sessionId = sessionId;
+    Object.assign(scene, config);
+
+    scenes.push(scene);
+  }
+
+  return scenes;
+}
+
+function parseScenario(scenarioString) {
+  const [scenarioName, scrnarioConfig] = scenarioString.split(" ");
+
+  return builder(scenarioName, parseScenarioConfig(scrnarioConfig));
+}
+
+function parseScenarioConfig(scenarioConfigString) {
+  const configs = scenarioConfigString.split(",");
+  const configObject = {};
+
+  for (const conf of configs) {
+    [key, value] = conf.split("=");
+    configObject[key] = value;
+  }
+
+  return configObject;
+}
+
+module.exports = { parseScenario };

src/config.js

@@ -0,0 +1,13 @@
+module.exports = {
+  ussd: {
+    serviceCode: "*483*061#",
+    endpoint: "https://ussd.grassecon.net",
+    timeout: 3000,
+  },
+  test: {
+    waitNextMenu: 3000,
+  },
+  user: {
+    ussdPhone: "254711777734",
+  },
+};

src/parser.js

@@ -0,0 +1,25 @@
+const setTimeout = require("timers/promises").setTimeout;
+const readFile = require("fs").readFile;
+
+const parseScenario = require("./builder").parseScenario;
+const request = require("./request").request;
+
+readFile(process.argv[2], "utf8", (err, data) => {
+  if (err) {
+    return console.log(err);
+  }
+  execute(data);
+});
+
+async function execute(input) {
+  const parsedScenarioFile = input.split("\n");
+
+  for (const work of parsedScenarioFile) {
+    const parsedWork = parseScenario(work);
+
+    for (const requestJob of parsedWork) {
+      await request(requestJob);
+      await setTimeout(requestJob.test.waitNextMenu);
+    }
+  }
+}

src/request.js

@@ -0,0 +1,34 @@
+const phin = require("phin");
+const rangi = require("rangi");
+
+async function request(builtObject) {
+  const requestOptions = {
+    url: builtObject.ussd.endpoint,
+    method: "POST",
+    parse: "string",
+    timeout: builtObject.ussd.timeout,
+    form: {
+      sessionId: builtObject.sessionId,
+      phoneNumber: builtObject.user.ussdPhone,
+      serviceCode: builtObject.ussd.serviceCode,
+      text: builtObject.input,
+    },
+  };
+
+  try {
+    console.log(rangi.yellow(`${builtObject.input}\n-------------`));
+    const { body } = await phin(requestOptions);
+
+    if (body.length > 1) {
+      console.log(rangi.cyan(`${body.slice(4)}\n-------------`));
+
+      return;
+    }
+
+    throw new Error("EMPTY_BODY");
+  } catch (error) {
+    console.log(error);
+  }
+}
+
+module.exports = { request };

src/sample

@@ -0,0 +1,4 @@
+reset_pin current_pin=2222,new_pin=3333
+reset_pin current_pin=3333,new_pin=2222
+send_tx to=0727806655,amount=1,pin=2222
+send_tx to=0706533739,amount=1,pin=2222

src/scenario.js

@@ -0,0 +1,26 @@
+module.exports = {
+  reset_pin: function (input) {
+    return [
+      { input: `` },
+      { input: `3` },
+      { input: `3*5` },
+      { input: `3*5*1` },
+      { input: `3*5*1*${input.current_pin}` },
+      { input: `3*5*1*${input.current_pin}*${input.new_pin}` },
+      { input: `3*5*1*${input.current_pin}*${input.new_pin}*${input.new_pin}` },
+      {
+        input: `3*5*1*${input.current_pin}*${input.new_pin}*${input.new_pin}*99`,
+      },
+    ];
+  },
+  send_tx: function (input) {
+    return [
+      { input: `` },
+      { input: `1` },
+      { input: `1*${input.to}` },
+      { input: `1*${input.to}*${input.amount}` },
+      { input: `1*${input.to}*${input.amount}*${input.pin}` },
+      { input: `1*${input.to}*${input.amount}*${input.pin}*99` },
+    ];
+  },
+};