dan92 commited on
Commit
42aa48d
·
verified ·
1 Parent(s): 9ea3088

Upload 2 files

Browse files
Files changed (1) hide show
  1. src/index.js +26 -8
src/index.js CHANGED
@@ -10,8 +10,11 @@ const router = new Router()
10
 
11
  // 添加重定向中间件
12
  app.use(async (ctx, next) => {
 
13
  if (ctx.path.startsWith('/v1/')) {
 
14
  ctx.path = '/hf' + ctx.path
 
15
  }
16
  await next()
17
  })
@@ -29,7 +32,7 @@ app.use(bodyParser({
29
 
30
 
31
  const makeRequest = async (session_id, requestModel, messages) => {
32
- // console.log(session_id, requestModel, messages)
33
  try {
34
  // 设置请求头
35
  const myHeaders = new Headers()
@@ -40,7 +43,6 @@ const makeRequest = async (session_id, requestModel, messages) => {
40
  myHeaders.append("Host", "www.genspark.ai")
41
  myHeaders.append("Connection", "keep-alive")
42
 
43
-
44
  // 设置请求体
45
  var body = JSON.stringify({
46
  "type": "COPILOT_MOA_CHAT",
@@ -56,6 +58,12 @@ const makeRequest = async (session_id, requestModel, messages) => {
56
  }
57
  })
58
 
 
 
 
 
 
 
59
  const requestConfig = {
60
  method: 'POST',
61
  headers: myHeaders,
@@ -63,8 +71,12 @@ const makeRequest = async (session_id, requestModel, messages) => {
63
  redirect: 'follow'
64
  };
65
 
66
- // console.log(requestConfig)
67
  const response = await fetch("https://www.genspark.ai/api/copilot/ask", requestConfig)
 
 
 
 
 
68
 
69
  if (!response.ok) {
70
  throw new Error(`HTTP error! status: ${response.status}`)
@@ -72,8 +84,8 @@ const makeRequest = async (session_id, requestModel, messages) => {
72
 
73
  return response
74
  } catch (error) {
75
- console.log('error1', error)
76
- throw error // 重新抛出错误,让调用者处理
77
  }
78
  }
79
 
@@ -391,7 +403,7 @@ router.post('/hf/v1/chat/completions', async (ctx) => {
391
  }
392
  })
393
 
394
- // 获取models的v1路��
395
  router.get('/v1/models', async (ctx) => {
396
  ctx.body = {
397
  object: "list",
@@ -437,5 +449,11 @@ app.use(async (ctx, next) => {
437
  // 启动服务器
438
  const PORT = process.env.PORT || 3000
439
  app.listen(PORT, '0.0.0.0', () => {
440
- console.log(`服务器运行在 http://0.0.0.0:${PORT}`);
441
- })
 
 
 
 
 
 
 
10
 
11
  // 添加重定向中间件
12
  app.use(async (ctx, next) => {
13
+ console.log('收到请求:', ctx.method, ctx.path, ctx.query)
14
  if (ctx.path.startsWith('/v1/')) {
15
+ console.log('重定向前路径:', ctx.path)
16
  ctx.path = '/hf' + ctx.path
17
+ console.log('重定向后路径:', ctx.path)
18
  }
19
  await next()
20
  })
 
32
 
33
 
34
  const makeRequest = async (session_id, requestModel, messages) => {
35
+ console.log('开始请求 genspark.ai:', { session_id, requestModel })
36
  try {
37
  // 设置请求头
38
  const myHeaders = new Headers()
 
43
  myHeaders.append("Host", "www.genspark.ai")
44
  myHeaders.append("Connection", "keep-alive")
45
 
 
46
  // 设置请求体
47
  var body = JSON.stringify({
48
  "type": "COPILOT_MOA_CHAT",
 
58
  }
59
  })
60
 
61
+ console.log('请求配置:', {
62
+ url: "https://www.genspark.ai/api/copilot/ask",
63
+ headers: Object.fromEntries(myHeaders.entries()),
64
+ body: JSON.parse(body)
65
+ })
66
+
67
  const requestConfig = {
68
  method: 'POST',
69
  headers: myHeaders,
 
71
  redirect: 'follow'
72
  };
73
 
 
74
  const response = await fetch("https://www.genspark.ai/api/copilot/ask", requestConfig)
75
+ console.log('收到响应:', {
76
+ status: response.status,
77
+ statusText: response.statusText,
78
+ headers: Object.fromEntries(response.headers.entries())
79
+ })
80
 
81
  if (!response.ok) {
82
  throw new Error(`HTTP error! status: ${response.status}`)
 
84
 
85
  return response
86
  } catch (error) {
87
+ console.error('请求出错:', error)
88
+ throw error
89
  }
90
  }
91
 
 
403
  }
404
  })
405
 
406
+ // 获取models的v1路由
407
  router.get('/v1/models', async (ctx) => {
408
  ctx.body = {
409
  object: "list",
 
449
  // 启动服务器
450
  const PORT = process.env.PORT || 3000
451
  app.listen(PORT, '0.0.0.0', () => {
452
+ console.log('='.repeat(50))
453
+ console.log(`服务器启动于 http://0.0.0.0:${PORT}`)
454
+ console.log('环境变量:', {
455
+ PORT: process.env.PORT,
456
+ NODE_ENV: process.env.NODE_ENV
457
+ })
458
+ console.log('='.repeat(50))
459
+ });