WebSocket dữ liệu giao dịch (CS+PS)

const io = require("socket.io-client");

const SUB_ACCOUNT = "0301001425"; // Tiểu khoản — KHÔNG phải username đăng nhập
const accessToken = "..."; // Lấy từ API đăng nhập, không hardcode

const socket = io("https://flashapi.phs.vn", {
  path: "/realtime/eqt/socket.io", // đổi thành /realtime/fno/socket.io cho phái sinh
  transports: ["websocket"],
});

socket.on("connect", () => {
  console.log("Đã kết nối:", socket.id);

  socket.emit("get", {
    data: {
      args: [`account:${SUB_ACCOUNT}`],
      op: "subscribe",
      token: accessToken,
    },
    method: "get",
    url: "/client/send",
  });
});

// Các kênh dữ liệu chính
socket.on("OM", (data) => console.log("Lệnh (Order Management):", data));
socket.on("CI", (data) => console.log("Sức mua (Cash Info):", data));
socket.on("SE", (data) => console.log("Danh mục (Securities Equity):", data));

socket.on("connect_error", (err) => {
  console.error("Lỗi kết nối:", err.message);
});

socket.on("disconnect", (reason) => {
  console.log("Mất kết nối:", reason);
});

{
  "type": "account",
  "channel": "account",
  "label": "Account",
  "data": {
    "ACC": "0102009737",
    "DT": {
      "MSGTYPE": "R",
      "EVENTTYPE": "CI",
      "AUTOID": "0102009737",
      "ACCTNO": "0102009737",
      "AFACCTNO": "0102009737",
      "LOGTIME": "20260825-02:08:24",
      "APPLYTIME": "20260731-12:07:00",
      "PPREF": "10810",
      "PP": "10810",
      "BALANCE": "10858",
      "BALDEFOVD": "10810.264",
      "AVLWITHDRAW": "10810",
      "AVLADVANCE": "0"
    }
  }
}