Flutter数据聚合插件jupiter_aggregator的使用

Jupiter Aggregator 是一个用于在 Flutter 应用中实现数据聚合的插件。它允许开发者通过简单的 API 调用获取路由信息、报价以及交易序列化等数据。本文将介绍如何在 Flutter 项目中使用 jupiter_aggregator 插件，并提供完整的示例代码。

安装插件

首先，在项目的 pubspec.yaml 文件中添加 jupiter_aggregator 依赖：

dependencies:
  jupiter_aggregator: ^版本号

然后运行以下命令安装依赖：

flutter pub get

使用示例

获取路由映射表

getIndexedRouteMap() 方法可以返回一个哈希表，其中输入代币作为键，有效的输出代币数组作为值。这有助于减少文件大小并提高查询效率。

示例代码

import 'package:flutter/material.dart';
import 'package:jupiter_aggregator/jupiter_aggregator.dart';

void main() {
  runApp(App());
}

class App extends StatelessWidget {
  final client = JupiterAggregatorClient();

  [@override](/user/override)
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(title: Text('Jupiter Aggregator 示例')),
        body: FutureBuilder<JupiterIndexedRouteMap>(
          future: client.getIndexedRouteMap(), // 异步调用获取路由映射表
          builder: (context, snapshot) {
            if (snapshot.connectionState == ConnectionState.waiting) {
              return Center(child: CircularProgressIndicator()); // 加载中
            } else if (snapshot.hasError) {
              return Center(child: Text('加载失败: ${snapshot.error}')); // 错误处理
            } else if (!snapshot.hasData) {
              return Center(child: Text('无数据')); // 没有数据
            }
            final data = snapshot.data!;
            return Column(
              children: [
                Text('成功获取路由映射表！'),
                Text('输入代币数量: ${data.mintKeys.length}'), // 显示输入代币数量
              ],
            );
          },
        ),
      ),
    );
  }
}

效果图

获取报价

通过 /v1/quote 接口，可以获取从输入代币到输出代币的报价信息。

示例代码

import 'package:flutter/material.dart';
import 'package:jupiter_aggregator/jupiter_aggregator.dart';

void main() {
  runApp(App());
}

class App extends StatelessWidget {
  final client = JupiterAggregatorClient();

  [@override](/user/override)
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(title: Text('Jupiter Aggregator 报价示例')),
        body: FutureBuilder<QuoteResponse>(
          future: client.getQuote(
            inputMint: 'SOL', // 输入代币（例如 SOL）
            outputMint: 'USDC', // 输出代币（例如 USDC）
            amount: 1000000000, // 输入金额（单位为最小单位，例如 1 SOL = 10^9 最小单位）
          ),
          builder: (context, snapshot) {
            if (snapshot.connectionState == ConnectionState.waiting) {
              return Center(child: CircularProgressIndicator());
            } else if (snapshot.hasError) {
              return Center(child: Text('加载失败: ${snapshot.error}'));
            } else if (!snapshot.hasData) {
              return Center(child: Text('无数据'));
            }
            final data = snapshot.data!;
            return Column(
              mainAxisAlignment: MainAxisAlignment.center,
              children: [
                Text('输出金额: ${data.outputAmount}'), // 显示输出金额
                Text('滑点: ${data.slippage}'), // 显示滑点
              ],
            );
          },
        ),
      ),
    );
  }
}

效果图

执行交换操作

通过 /v1/swap 接口，可以获取交换所需的交易序列化信息。

示例代码

import 'package:flutter/material.dart';
import 'package:jupiter_aggregator/jupiter_aggregator.dart';

void main() {
  runApp(App());
}

class App extends StatelessWidget {
  final client = JupiterAggregatorClient();

  [@override](/user/override)
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(title: Text('Jupiter Aggregator 交换示例')),
        body: FutureBuilder<SwapResponse>(
          future: client.swap(
            SwapRequestBody(
              inputMint: 'SOL',
              outputMint: 'USDC',
              amount: 1000000000,
            ),
          ),
          builder: (context, snapshot) {
            if (snapshot.connectionState == ConnectionState.waiting) {
              return Center(child: CircularProgressIndicator());
            } else if (snapshot.hasError) {
              return Center(child: Text('加载失败: ${snapshot.error}'));
            } else if (!snapshot.hasData) {
              return Center(child: Text('无数据'));
            }
            final data = snapshot.data!;
            return Column(
              mainAxisAlignment: MainAxisAlignment.center,
              children: [
                Text('Setup Transaction: ${data.setupTx}'), // 显示 setup 交易
                Text('Swap Transaction: ${data.swapTx}'), // 显示 swap 交易
                Text('Cleanup Transaction: ${data.cleanupTx}'), // 显示 cleanup 交易
              ],
            );
          },
        ),
      ),
    );
  }
}