uni-network

import { createUniNetwork } from '@uni-helper/uni-network';

// 创建实例
const http = createUniNetwork({
  baseUrl: 'https://api.example.com',
  timeout: 10000,
  headers: {
    'Content-Type': 'application/json'
  }
});

// 请求拦截器：统一鉴权
http.interceptors.request.use((config) => {
  const token = uni.getStorageSync('token');
  if (token) {
    config.headers.Authorization = `Bearer ${token}`;
  }
  return config;
});

// 响应拦截器：统一错误处理
http.interceptors.response.use(
  (response) => response.data,
  (error) => {
    if (error.statusCode === 401) {
      uni.navigateTo({ url: '/pages/login/index' });
    }
    return Promise.reject(error);
  }
);

// TypeScript 泛型请求
interface User { id: number; name: string }
const { data } = await http.get<User>('/user/1');
// data 自动推断为 User 类型

npm install @uni-helper/uni-network
# 或
pnpm add @uni-helper/uni-network
# 或
yarn add @uni-helper/uni-network

import { createUniNetwork } from '@uni-helper/uni-network';

const http = createUniNetwork({
  baseUrl: 'https://api.example.com'
});

// GET 请求
const { data: users } = await http.get('/users', {
  params: { page: 1, size: 20 }
});

// POST 请求
const { data: result } = await http.post('/users', {
  name: '张三',
  email: 'zhangsan@example.com'
});

// PUT 请求
await http.put('/users/1', { name: '李四' });

// DELETE 请求
await http.delete('/users/1');

// 文件上传
const { data } = await http.upload('/upload', {
  filePath: tempFilePath,
  name: 'file',
  formData: {
    userId: '123'
  }
});

// 文件下载
const { data: fileData } = await http.download('/files/report.pdf', {
  params: { token: 'xxx' }
});

// 并发控制：限制同时请求数
let activeRequests = 0;
const MAX_CONCURRENT = 5;

http.interceptors.request.use((config) => {
  if (activeRequests >= MAX_CONCURRENT) {
    return new Promise((resolve) => {
      const timer = setInterval(() => {
        if (activeRequests < MAX_CONCURRENT) {
          clearInterval(timer);
          activeRequests++;
          resolve(config);
        }
      }, 100);
    });
  }
  activeRequests++;
  return config;
});

http.interceptors.response.use(
  (response) => {
    activeRequests--;
    return response;
  },
  (error) => {
    activeRequests--;
    return Promise.reject(error);
  }
);

// 自动重试（网络错误时）
http.interceptors.response.use(null, async (error) => {
  const config = error.config;
  if (!config.__retryCount) config.__retryCount = 0;
  if (config.__retryCount >= 3) return Promise.reject(error);
  config.__retryCount++;
  await new Promise(r => setTimeout(r, 1000 * config.__retryCount));
  return http(config);
});