openclaw - 💡(How to fix) Fix [Guide] SiliconFlow provider for Chinese users — DeepSeek + Qwen smart routing proxy [1 comments, 1 participants]

const express = require('express');
const axios = require('axios');
const app = express();

app.use(express.json({ limit: '10mb' }));

app.post('/api/:model', async (req, res) => {
  const { model } = req.params;
  const { text, image } = req.body;

  if (text) {
    // Route text requests to DeepSeek-V3
    const response = await axios.post(process.env.DEESEEK_API_URL, { text });
    res.json(response.data);
  } else if (image) {
    // Route image requests to Qwen vision model
    const response = await axios.post(process.env.QWEN_API_URL, { image });
    res.json(response.data);
  } else {
    res.status(400).json({ error: 'Invalid request' });
  }
});

const { PassThrough } = require('stream');

app.post('/api/:model/stream', async (req, res) => {
  const { model } = req.params;
  const { text, image } = req.body;

  if (text) {
    // Stream text requests to DeepSeek-V3
    const passThrough = new PassThrough();
    const response = await axios.post(process.env.DEESEEK_API_URL, { text }, { responseType: 'stream' });
    response.data.pipe(passThrough);
    res.pipe(passThrough);
  } else if (image) {
    // Stream image requests to Qwen vision model
    const passThrough = new PassThrough();
    const response = await axios.post(process.env.QWEN_API_URL, { image }, { responseType: 'stream' });
    response.data.pipe(passThrough);
    res.pipe(passThrough);
  } else {
    res.status(400).json({ error: 'Invalid request' });
  }
});

app.use((req, res, next) => {
  req.setTimeout(120000); // 120s timeout
  next();
});