zhangjian
2023-06-05 0976d2d0f90cff460cedfdc8bd74e98c2c31a58c
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
"use strict";
 
const execa = require("execa");
 
const db2util = "/QOpenSys/pkgs/bin/db2util";
const sql = "select NEXT_HOP, LOCAL_BINDING_INTERFACE from QSYS2.NETSTAT_ROUTE_INFO where ROUTE_TYPE='DFTROUTE' and NEXT_HOP!='*DIRECT' and CONNECTION_TYPE=?";
 
const parse = stdout => {
  let result;
  try {
    const resultObj = JSON.parse(stdout);
    const gateway = resultObj.records[0].NEXT_HOP;
    const iface = resultObj.records[0].LOCAL_BINDING_INTERFACE;
    result = {gateway, iface};
  } catch (err) {}
  if (!result) {
    throw new Error("Unable to determine default gateway");
  }
  return result;
};
 
const promise = async family => {
  const {stdout} = await execa(db2util, [sql, "-p", family, "-o", "json"]);
  return parse(stdout);
};
 
const sync = family => {
  const {stdout} = execa.sync(db2util, [sql, "-p", family, "-o", "json"]);
  return parse(stdout);
};
 
module.exports.v4 = () => promise("IPV4");
module.exports.v6 = () => promise("IPV6");
 
module.exports.v4.sync = () => sync("IPV4");
module.exports.v6.sync = () => sync("IPV6");