pyth-network_pyth-crosschain/third_party/pyth/p2w-terra-relay/src/index.ts

import { setDefaultWasm } from "@certusone/wormhole-sdk/lib/cjs/solana/wasm";

import * as listen from "./listen";
import * as worker from "./worker";
import * as rest from "./rest";
import * as helpers from "./helpers";
import { logger } from "./helpers";
import { PromHelper } from "./promHelpers";

import { Relay } from "./relay/iface";
import { TerraRelay } from "./relay/terra";

let configFile: string = ".env";
if (process.env.PYTH_RELAY_CONFIG) {
  configFile = process.env.PYTH_RELAY_CONFIG;
}

console.log("Loading config file [%s]", configFile);
require("dotenv").config({ path: configFile });

setDefaultWasm("node");

// Set up the logger.
helpers.initLogger();

let error: boolean = false;
let listenOnly: boolean = false;
let relayImpl: Relay;
for (let idx = 0; idx < process.argv.length; ++idx) {
  if (process.argv[idx] === "--listen_only") {
    logger.info("running in listen only mode, will not relay anything!");
    listenOnly = true;
  }
}

relayImpl = new TerraRelay({
  nodeUrl: helpers.envOrErr("TERRA_NODE_URL"),
  terraChainId: helpers.envOrErr("TERRA_CHAIN_ID"),
  walletPrivateKey: helpers.envOrErr("TERRA_PRIVATE_KEY"),
  coin: helpers.envOrErr("TERRA_COIN"),
  contractAddress: helpers.envOrErr("TERRA_PYTH_CONTRACT_ADDRESS"),
});

if (
  !error &&
  listen.init(listenOnly) &&
  worker.init(!listenOnly, relayImpl) &&
  rest.init(!listenOnly)
) {
  // Start the Prometheus client with the app name and http port
  let promPort = 8081;
  if (process.env.PROM_PORT) {
    promPort = parseInt(process.env.PROM_PORT);
  }
  logger.info("prometheus client listening on port " + promPort);
  const promClient = new PromHelper("pyth_relay", promPort);

  listen.run(promClient);
  if (!listenOnly) {
    worker.run(promClient);
    rest.run();
  }

  if (process.env.READINESS_PORT) {
    const readinessPort: number = parseInt(process.env.READINESS_PORT);
    const Net = require("net");
    const readinessServer = new Net.Server();
    readinessServer.listen(readinessPort, function () {
      logger.info("listening for readiness requests on port " + readinessPort);
    });

    readinessServer.on("connection", function (socket: any) {
      //logger.debug("readiness connection");
    });
  }
}