Update src/index.js

src/index.js

@@ -10,6 +10,16 @@ app.use(bodyParser.json())
 app.use(bodyParser.json({ limit: '50mb' }))
 app.use(bodyParser.urlencoded({ limit: '50mb', extended: true }))
 
+
+const isJson = (str) => {
+  try {
+    JSON.parse(str)
+    return true
+  } catch (error) {
+    return false
+  }
+}
+
 app.get('/api/v1/models', async (req, res) => {
   try {
     const response = await axios.get('https://chat.qwenlm.ai/api/models',
@@ -82,7 +92,12 @@ app.post('/api/v1/chat/completions', async (req, res) => {
 
       const lists = decodeText.split('\n').filter(item => item.trim() !== '')
       for (const item of lists) {
-        const decodeJson = JSON.parse(item.replace(/^data: /, ''))
+        const decodeJson = isJson(item.replace(/^data: /, '')) ? JSON.parse(item.replace(/^data: /, '')) : null
+
+        if (decodeJson === null) {
+          continue
+        }
+        
         let content = decodeJson.choices[0].delta.content
 
         if (backContent === null) {