Shreds-CHY-Client

一个用于连接Jito Shredstream服务并订阅Solana交易的Node.js客户端库。

功能特点

• 连接到Jito Shredstream服务并接收交易数据
• 通过Rust实现高性能解析和处理
• 实时订阅PUMP、PUMP_AMM和BOOP类型的交易
• 支持Node.js回调机制，将交易数据传递到JavaScript层

安装

npm install shreds-chy-client
# 或
yarn add shreds-chy-client

使用方法

使用JavaScript

const { subscribeJitoTransactions } = require('shreds-chy-client');

// 定义回调函数处理接收到的交易数据
function transactionCallback(jsonStr) {
  // 解析JSON字符串
  const data = JSON.parse(jsonStr);
  
  console.log(`接收到Slot #${data.slot}的交易`);
  console.log(`- PUMP交易: ${data.pump_transactions.length}个`);
  console.log(`- PUMP_AMM交易: ${data.pumpamm_transactions.length}个`);
  console.log(`- BOOP交易: ${data.boop_transactions.length}个`);
  
  // 处理交易数据...
}

// Jito服务器URL
const jitoUrl = "http://your-jito-server:8100";

// 订阅交易流
subscribeJitoTransactions(jitoUrl, transactionCallback);

使用TypeScript

import { subscribeJitoTransactions, TransactionResults } from 'shreds-chy-client';

// 定义回调函数处理接收到的交易数据
function transactionCallback(jsonStr: string) {
  // 解析JSON字符串
  const data: TransactionResults = JSON.parse(jsonStr);
  
  console.log(`接收到Slot #${data.slot}的交易`);
  console.log(`- PUMP交易: ${data.pump_transactions.length}个`);
  console.log(`- PUMP_AMM交易: ${data.pumpamm_transactions.length}个`);
  console.log(`- BOOP交易: ${data.boop_transactions.length}个`);
  
  // 处理交易数据...
}

// Jito服务器URL
const jitoUrl = "http://your-jito-server:8100";

// 订阅交易流
subscribeJitoTransactions(jitoUrl, transactionCallback);

示例

在examples目录下有完整的示例代码：

• examples/subscribe-transactions.js - JavaScript示例

运行示例：

# JavaScript示例
node examples/subscribe-transactions.js

开发

构建

# 安装依赖
yarn install

# 开发构建
yarn build:debug

# 生产构建
yarn build

测试

yarn test

许可证

MIT