Function parseConversationEvent

internal/chatgpt/request.go:1530–1578

(line string, state *conversationPatchState, model string)

}

func parseConversationEvent(line string, state *conversationPatchState, model string) (conversationStreamEvent, bool) {
	var raw map[string]interface{}
	if err := json.Unmarshal([]byte(line), &raw); err != nil {
		return conversationStreamEvent{}, false
	}

	if chunk, ok := chatCompletionChunkFromRaw(raw, model); ok {
		event := conversationStreamEvent{
			chunk:          &chunk,
			text:           firstChunkContent(chunk),
			role:           firstChunkRole(chunk),
			conversationID: chunk.ConversationID,
			channel:        channelFromValue(raw),
			finishReason:   firstChunkFinishReason(chunk),
		}
		event.isStop = event.finishReason != ""
		return event, true
	}

	var direct chatgpt_types.ChatGPTResponse
	if err := json.Unmarshal([]byte(line), &direct); err == nil && isUsableConversationResponse(direct) {
		channel := channelFromValue(raw)
		state.channel = firstNonEmpty(channel, state.channel)
		return conversationStreamEvent{response: direct, messageID: direct.Message.ID, channel: state.channel}, true
	}

	if response, ok := responseFromValue(raw["v"]); ok {
		state.response = response
		if channel := channelFromValue(raw["v"]); channel != "" {
			state.channel = channel
		}
		return conversationStreamEvent{response: state.response, messageID: state.response.Message.ID, channel: state.channel}, true
	}
	if text, ok := raw["v"].(string); ok && raw["p"] == nil && raw["o"] == nil {
		ensureConversationPatchDefaults(state)
		current, _ := state.response.Message.Content.Parts[0].(string)
		state.response.Message.Content.Parts[0] = current + text
		return conversationStreamEvent{response: state.response, messageID: state.response.Message.ID, channel: state.channel}, true
	}

	if patchPath, ok := raw["p"].(string); ok {
		patchOperation, _ := raw["o"].(string)
		if applyConversationPatch(state, patchPath, patchOperation, raw["v"]) {
			return conversationStreamEvent{response: state.response, messageID: state.response.Message.ID, channel: state.channel}, true
		}
	}

	return conversationStreamEvent{}, false
}

func chatCompletionChunkFromRaw(raw map[string]interface{}, model string) (official_types.ChatCompletionChunk, bool) {
	choices, ok := raw["choices"].([]interface{})