db-rn-request

React Native 通用请求核心库，提供 HTTP（fetch / axios 双引擎） 与 SSE（流式推送） 能力，供主应用与子应用共用。

设计上参考了 node-fetch 的极简思路，但优先 React Native 环境：默认使用 fetch 引擎，axios 为可选引擎。

特性

• 🚀 默认 fetch 引擎，RN 原生友好；axios 作为可选引擎（按需安装）
• 🔌 依赖注入：取 Token、401 处理、错误提示均由使用者传入，核心库零业务耦合
• 🧩 请求 / 响应 / 错误 三类拦截器
• ⏱️ 超时控制与失败重试
• 📦 统一响应结构 ApiResponse<T> 与统一错误 HttpError
• 📡 SSE 客户端，兼容 RN 的响应体读取限制，支持打字机式输出
• 🧾 统一日志开关，生产环境默认静默

安装

npm install db-rn-request
# 如需使用 axios 引擎，再安装 axios（可选）
npm install axios

react-native 为 peer 依赖；axios 为可选 peer 依赖。

设计说明：为什么用「使用者传入」而非「项目配置」

核心库要被主应用和子应用共用，因此不能耦合任何具体项目的实现（如某个 UserStorage、clearUserData、DbToast）。 本库将以下能力全部改为依赖注入（使用者传入）：

| 能力 | 注入方式 | 说明 | | --- | --- | --- | | 获取 Token | getToken | 由使用者从自己的存储中读取 | | 鉴权头格式 | authHeaderName / authScheme | 默认 Authorization + Bearer | | 401 未授权处理 | onUnauthorized | 由使用者清理登录态、跳转登录页 | | 错误提示 | onError | 由使用者决定是否 Toast，核心库不依赖任何 UI 库 | | 错误上报 | setErrorReporter | 由使用者对接监控平台 |

这样既保证核心库纯净可移植，又能让每个应用按需接入自己的 storage / auth / UI。

快速开始（HTTP）

在应用入口处初始化一次（注入业务能力）：

import { http } from 'db-rn-request';
import { UserStorage } from '@/utils/storage-service';
import { clearUserData } from '@/api/auth';
import { DbToast } from 'db-rn-ui';

http.init({
  baseUrl: 'https://api.example.com',
  timeout: 30000,
  engine: 'fetch', // 默认即 fetch，可选 'axios'

  // 注入取 Token 逻辑
  getToken: () => UserStorage.getToken(),

  // 注入 401 处理逻辑
  onUnauthorized: async () => {
    await UserStorage.removeToken();
    await clearUserData();
    // 跳转登录页...
  },

  // 注入错误提示逻辑（核心库不直接依赖 db-rn-ui）
  onError: (error) => {
    if (error.status === 404) DbToast.info('资源不存在');
  },
});

发起请求：

import { http, get, post } from 'db-rn-request';

// 使用单例
const res = await http.get<UserInfo>('/user/info');
if (res.success) {
  console.log(res.data);
}

// 或使用便捷方法
await post('/order/create', { skuId: 1 });

拦截器

import { http } from 'db-rn-request';

// 请求拦截器
const removeReq = http.addRequestInterceptor((config) => {
  config.headers = { ...config.headers, 'X-Trace-Id': genTraceId() };
  return config;
});

// 响应拦截器
http.addResponseInterceptor((data) => data);

// 错误拦截器（返回非 undefined 即作为兜底结果）
http.addErrorInterceptor((err) => {
  if (err.status === 0) return { code: -1, data: null, message: '网络异常', success: false };
});

文件上传

await http.upload('/upload', [
  { uri: 'file:///path/photo.jpg', type: 'image/jpeg', name: 'photo.jpg' },
], 'file', { bizType: 'avatar' });

快速开始（SSE）

import { sseClient } from 'db-rn-request';

const cancel = await sseClient.connect('https://api.example.com/ai/chat', {
  method: 'POST',
  headers: { Authorization: `Bearer ${token}` },
  body: { prompt: '你好' },
  onOpen: () => console.log('连接已建立'),
  onMessage: (msg) => appendText(msg.data),
  onComplete: () => console.log('输出完成'),
  onError: (e) => console.warn(e.message),
});

// 需要时主动断开
cancel();

构建与发布

npm run build   # 通过 rollup 输出 lib/（cjs + esm + d.ts）
npm run release # 构建并发布到 npm

目录结构

src/
  core/
    types.ts        # 核心类型定义
    errors.ts       # HttpError
    logger.ts       # 统一日志工具
    http-client.ts  # HTTP 核心客户端（fetch / axios）
    sse-client.ts   # SSE 客户端
  index.ts          # 唯一对外出口