TypeScript examples

socket/main.ts

import {readFile} from "node:fs/promises";
import http from "node:http";
import https from "node:https";
import {URNetwork, type DeviceRemote} from "@urnetwork/sdk";
import {Agent, fetch} from "undici";
import axios from "axios";
import {openDevice} from "./device.mjs";
import {directSocketEcho} from "./direct-sockets.js";
import {connector} from "./ur_node_socket.mjs";
import {clientConfig} from "../integration/client.mjs";

if (process.argv.includes("--self-test")) {
  const sdk = await URNetwork.init();
  console.log("Real SDK WASM loaded from a typed Node program:", sdk.isInitialized());
  sdk.close();
} else {
  const file = process.env.URNETWORK_DEVICE_CONFIG;
  if (!file) throw new Error("Set URNETWORK_DEVICE_CONFIG to the hosted Device JSON file described in README.md.");
  const session: {device: DeviceRemote; close(): void} = await openDevice(clientConfig(process.env, JSON.parse(await readFile(file, "utf8"))));
  const httpAgent = new http.Agent({keepAlive: true});
  const httpsAgent = new https.Agent({keepAlive: true});
  // The adapter implements Node's Duplex callback contract over async Conn I/O.
  httpAgent.createConnection = connector(session.device, false) as typeof httpAgent.createConnection;
  httpsAgent.createConnection = connector(session.device, true) as typeof httpsAgent.createConnection;
  const dispatcher = new Agent({connect: connector(session.device)});
  try {
    const url = process.env.URNETWORK_HTTP_URL || "https://example.com/";
    const response = await fetch(url, {dispatcher, signal: AbortSignal.timeout(30000)});
    console.log("Undici:", response.status, (await response.text()).slice(0, 500));
    const other = await axios.get(url, {httpAgent, httpsAgent, proxy: false, timeout: 30000});
    console.log("Axios:", other.status, other.data);
    if (process.env.URNETWORK_UDP_ECHO) console.log(await directSocketEcho(session.device, "udp", process.env.URNETWORK_UDP_ECHO));
    if (process.env.URNETWORK_TCP_ECHO) console.log(await directSocketEcho(session.device, "tcp", process.env.URNETWORK_TCP_ECHO));
  } finally {await dispatcher.destroy(); httpAgent.destroy(); httpsAgent.destroy(); session.close();}
}