import { VersionedTransaction, Connection, Keypair } from '@solana/web3.js';
import bs58 from "bs58";

const RPC_ENDPOINT = "Your RPC Endpoint";
const web3Connection = new Connection(
    RPC_ENDPOINT,
    'confirmed',
  );

async function sendPortalTransaction(){
      const response = await fetch(`https://pumpportal.fun/api/trade-local`, {
          method: "POST",
          headers: {
              "Content-Type": "application/json"
          },
          body: JSON.stringify({
              "publicKey": "your-public-key",  // Your wallet public key
              "action": "buy",                 // "buy" or "sell"
              "mint": "token-ca-here",         // contract address of the token you want to trade
              "denominatedInSol": "false",     // "true" if amount is amount of SOL, "false" if amount is number of tokens
              "amount": 1000,                  // amount of SOL or tokens
              "slippage": 1,                   // percent slippage allowed
              "priorityFee": 0.00001,          // priority fee
              "pool": "pump"                   // exchange to trade on. "pump" or "raydium"
          })
      });
      if(response.status === 200){ // successfully generated transaction
          const data = await response.arrayBuffer();
          const tx = VersionedTransaction.deserialize(new Uint8Array(data));
          const signerKeyPair = Keypair.fromSecretKey(bs58.decode("your-wallet-private-key"));
          tx.sign([signerKeyPair]);
          const signature = await web3Connection.sendTransaction(tx)
          console.log("Transaction: https://solscan.io/tx/" + signature);
      } else {
          console.log(response.statusText); // log error
      }
}

sendPortalTransaction();

import WebSocket from 'ws';

const ws = new WebSocket('wss:https://pumpportal.fun/api/data');

ws.on('open', function open() {

      // Subscribing to token creation events
      let payload = {
          method: "subscribeNewToken", 
        }
      ws.send(JSON.stringify(payload));

      // Subscribing to trades made by accounts
      payload = {
          method: "subscribeAccountTrade",
          keys: ["AArPXm8JatJiuyEffuC1un2Sc835SULa4uQqDcaGpAjV"] // array of accounts to watch
        }
      ws.send(JSON.stringify(payload));

      // Subscribing to trades on tokens
      payload = {
          method: "subscribeTokenTrade",
          keys: ["91WNez8D22NwBssQbkzjy4s2ipFrzpmn5hfvWVe2aY5p"] // array of token CAs to watch
        }
      ws.send(JSON.stringify(payload));
});

ws.on('message', function message(data) {
      console.log(JSON.parse(data));
});