Token Creations

const WebSocket = require("ws");

class TokenCreationMonitor {
  constructor(apiKey) {
    this.apiKey = apiKey;
    this.ws = null;
    this.tokens = {};
    this.creatorStats = {};
  }

  connect() {
    this.ws = new WebSocket(
      `wss://api.nolimitnodes.com/socket?apikey=${this.apiKey}`
    );
    this.setupHandlers();
  }

  setupHandlers() {
    this.ws.on("open", () => {
      console.log("Connected to Token Creations stream");
      this.subscribe();
    });

    this.ws.on("message", (data) => {
      const message = JSON.parse(data);
      if (message.method === "tokenCreationsSubscribe") {
        this.processToken(message.result);
      } else {
        console.log("Info:", JSON.stringify(message));
      }
    });

    this.ws.on("error", (error) => {
      console.error("WebSocket error:", error.message);
    });

    this.ws.on("close", () => {
      console.log("Connection closed. Reconnecting in 5s...");
      setTimeout(() => this.connect(), 5000);
    });
  }

  subscribe(filters = {}) {
    this.ws.send(
      JSON.stringify({
        method: "dataSubscribe",
        params: {
          referenceId: "TOKEN_CREATIONS",
          streams: [
            {
              stream: "tokenCreationsSubscribe",
              params: filters,
            },
          ],
        },
        id: 1,
      })
    );
  }

  processToken(token) {
    // Store token data
    this.tokens[token.mint_address] = token;

    // Track creator activity
    const creator = token.mint_authority || "unknown";
    if (!this.creatorStats[creator]) {
      this.creatorStats[creator] = { count: 0, tokens: [] };
    }
    this.creatorStats[creator].count++;
    this.creatorStats[creator].tokens.push(token.mint_address);

    // Risk assessment
    const risks = [];
    if (token.mint_authority) risks.push("mint_authority_active");
    if (token.freeze_authority) risks.push("freeze_authority_active");
    if (this.creatorStats[creator].count > 5) risks.push("prolific_creator");

    const riskLevel = risks.length === 0 ? "LOW" : risks.length === 1 ? "MEDIUM" : "HIGH";

    console.log(`\nNew Token Created [Risk: ${riskLevel}]`);
    console.log(`  Mint: ${token.mint_address}`);
    console.log(`  Decimals: ${token.decimals}`);
    console.log(`  Mint Authority: ${token.mint_authority || "Renounced"}`);
    console.log(`  Freeze Authority: ${token.freeze_authority || "Renounced"}`);
    console.log(`  Type: ${token.creation_type}`);
    console.log(`  Program: ${token.program_id}`);
    console.log(`  Block: ${token.block_num} | Time: ${token.block_time}`);
    if (risks.length > 0) {
      console.log(`  Risks: ${risks.join(", ")}`);
    }
  }
}

// Usage
const monitor = new TokenCreationMonitor("YOUR_API_KEY");
monitor.connect();