server_ste_metadata.model_slug
${state.serverModel ? `${esc(state.serverModel)}` : '等待捕获…'}
request.model
${pending(state.requestModel)}
request.thinking_effort
${pending(state.thinkingEffort)}
`;
const btn = panel.querySelector("#__cg_rc_collapse_btn__");
if (btn) {
btn.onclick = (e) => {
e.stopPropagation();
state.isCollapsed = true;
render();
};
}
}
function extractTurnKey(req) {
try {
const msgs = Array.isArray(req?.messages) ? req.messages : [];
for (let i = msgs.length - 1; i >= 0; i--) {
if (msgs[i]?.author?.role === "user" && msgs[i]?.id) return msgs[i].id;
}
if (req?.message?.author?.role === "user") return req.message.id || null;
} catch {}
return null;
}
function resetTurn(key) {
state.active = true;
state.turnKey = key || `turn-${Date.now()}`;
state.serverModel = null;
}
function beginOrUpdateTurn(req) {
const newKey = extractTurnKey(req);
if (!state.active || (newKey && newKey !== state.turnKey)) {
resetTurn(newKey);
}
if (typeof req?.model === "string") state.requestModel = req.model;
if (typeof req?.thinking_effort === "string") state.thinkingEffort = req.thinking_effort;
render();
}
function applyServerMetadata(meta) {
if (!meta || typeof meta !== "object") return;
if (typeof meta.model_slug === "string") {
state.serverModel = meta.model_slug;
render();
}
}
function scanObject(obj, depth = 0, seen = new WeakSet()) {
if (obj == null || depth > 16) return;
if (typeof obj === "string") {
const t = obj.trim();
if ((t.startsWith("{") || t.startsWith("[")) && (t.includes("model_slug") || t.includes("server_ste_metadata"))) {
try { scanObject(JSON.parse(t), depth + 1, seen); } catch {}
}
return;
}
if (typeof obj !== "object" || seen.has(obj)) return;
seen.add(obj);
if (obj.type === "server_ste_metadata" && obj.metadata) applyServerMetadata(obj.metadata);
if (obj.server_ste_metadata && typeof obj.server_ste_metadata === "object") applyServerMetadata(obj.server_ste_metadata);
if (obj.turn_analytics?.server_ste_metadata) applyServerMetadata(obj.turn_analytics.server_ste_metadata);
for (const val of Object.values(obj)) {
scanObject(val, depth + 1, seen);
}
}
function parseJSONCandidate(text) {
if (!text) return;
const val = text.trim();
if (!val || val === "[DONE]") return;
try { scanObject(JSON.parse(val)); } catch {}
}
function scanWholeText(text) {
if (!text || typeof text !== "string") return;
try { scanObject(JSON.parse(text)); } catch {}
for (let line of text.split(/\r?\n/)) {
line = line.trim();
if (line.startsWith("data:")) line = line.slice(5).trim();
parseJSONCandidate(line);
}
}
async function watchStream(response) {
if (!response?.body) {
try { scanWholeText(await response.text()); } catch {}
return;
}
const reader = response.body.getReader();
const decoder = new TextDecoder();
let buffer = "";
let eventData = [];
try {
while (true) {
const { value, done } = await reader.read();
if (done) break;
buffer += decoder.decode(value, { stream: true });
let idx;
while ((idx = buffer.indexOf("\n")) !== -1) {
let line = buffer.slice(0, idx);
buffer = buffer.slice(idx + 1);
if (line.endsWith("\r")) line = line.slice(0, -1);
if (line === "") {
if (eventData.length) {
parseJSONCandidate(eventData.join("\n"));
eventData = [];
}
continue;
}
if (line.startsWith("data:")) {
eventData.push(line.slice(5).trimStart());
continue;
}
const trimmed = line.trim();
if (trimmed.startsWith("{") || trimmed.startsWith("[")) {
parseJSONCandidate(trimmed);
}
}
}
} catch {}
}
async function bodyToText(body) {
try {
if (body == null) return "";
if (typeof body === "string") return body;
if (body instanceof Blob) return await body.text();
if (body instanceof URLSearchParams) return body.toString();
if (body instanceof ArrayBuffer) return new TextDecoder().decode(body);
if (ArrayBuffer.isView(body)) return new TextDecoder().decode(body);
} catch {}
return "";
}
async function getRequestText(input, init) {
if (init?.body != null) return await bodyToText(init.body);
if (input instanceof Request) {
try { return await input.clone().text(); } catch {}
}
return "";
}
const isConversation = (u, m) => m === "POST" && /\/backend-api\/f\/conversation(?:\?|$)/.test(u);
const isTelemetry = (u, m) => m === "POST" && /\/ces\/v1\/telemetry\/intake(?:\?|$)/.test(u);
window.fetch = async function(input, init = {}) {
const url = typeof input === "string" ? input : input?.url || "";
const method = String(init.method || input?.method || "GET").toUpperCase();
if (isConversation(url, method) || isTelemetry(url, method)) {
const text = await getRequestText(input, init);
if (isConversation(url, method)) {
try { beginOrUpdateTurn(JSON.parse(text)); } catch {}
} else {
scanWholeText(text);
}
}
const response = await nativeFetch(input, init);
if (isConversation(url, method)) {
try { watchStream(response.clone()); } catch {}
}
return response;
};
NativeXHR.prototype.open = function(method, url, ...rest) {
this.__rcMethod = String(method || "GET").toUpperCase();
this.__rcUrl = String(url || "");
return nativeXHROpen.call(this, method, url, ...rest);
};
NativeXHR.prototype.send = function(body) {
const url = this.__rcUrl || "";
const method = this.__rcMethod || "GET";
bodyToText(body).then(text => {
if (isConversation(url, method)) {
try { beginOrUpdateTurn(JSON.parse(text)); } catch {}
} else if (isTelemetry(url, method)) {
scanWholeText(text);
}
});
return nativeXHRSend.call(this, body);
};
render();
console.log(`ChatGPT Route Checker v${VERSION} 已启动`);
})();