open new websocket if model changes
This commit is contained in:
		
							parent
							
								
									47f96c0bb9
								
							
						
					
					
						commit
						872e6c8566
					
				| 
						 | 
					@ -42,6 +42,8 @@ export const chatRequest = async (
 | 
				
			||||||
      const signal = chatRequest.controller.signal
 | 
					      const signal = chatRequest.controller.signal
 | 
				
			||||||
      const providerData = chatRequest.providerData.petals || {}
 | 
					      const providerData = chatRequest.providerData.petals || {}
 | 
				
			||||||
      chatRequest.providerData.petals = providerData
 | 
					      chatRequest.providerData.petals = providerData
 | 
				
			||||||
 | 
					      const modelChanged = model !== providerData.lastModel
 | 
				
			||||||
 | 
					      providerData.lastModel = model
 | 
				
			||||||
      let ws: WebSocket = providerData.ws
 | 
					      let ws: WebSocket = providerData.ws
 | 
				
			||||||
      const abortListener = (e:Event) => {
 | 
					      const abortListener = (e:Event) => {
 | 
				
			||||||
        chatRequest.updating = false
 | 
					        chatRequest.updating = false
 | 
				
			||||||
| 
						 | 
					@ -221,7 +223,8 @@ export const chatRequest = async (
 | 
				
			||||||
        const kb = providerData.knownBuffer.replace(rgxp, '')
 | 
					        const kb = providerData.knownBuffer.replace(rgxp, '')
 | 
				
			||||||
        const lp = lastPrompt.replace(rgxp, '')
 | 
					        const lp = lastPrompt.replace(rgxp, '')
 | 
				
			||||||
        const lm = kb === lp
 | 
					        const lm = kb === lp
 | 
				
			||||||
        if (!lm || countTokens(model, providerData.knownBuffer + inputPrompt) >= maxTokens) {
 | 
					        if (!chatSettings.holdSocket || modelChanged || !lm ||
 | 
				
			||||||
 | 
					            countTokens(model, providerData.knownBuffer + inputPrompt) >= maxTokens) {
 | 
				
			||||||
          wsOpen && ws.close()
 | 
					          wsOpen && ws.close()
 | 
				
			||||||
          ws = await getNewWs()
 | 
					          ws = await getNewWs()
 | 
				
			||||||
        }
 | 
					        }
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
		Loading…
	
		Reference in New Issue