21 lines
691 B
JavaScript
21 lines
691 B
JavaScript
|
const { err } = require("../logger");
|
||
|
|
const { fetchRouter, pipeSSE } = require("./base");
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Intercept Antigravity (Gemini) request — replace model and forward to router
|
||
|
|
*/
|
||
|
|
async function intercept(req, res, bodyBuffer, mappedModel) {
|
||
|
|
try {
|
||
|
|
const body = JSON.parse(bodyBuffer.toString());
|
||
|
|
body.model = mappedModel;
|
||
|
|
const routerRes = await fetchRouter(body);
|
||
|
|
await pipeSSE(routerRes, res);
|
||
|
|
} catch (error) {
|
||
|
|
err(`[antigravity] ${error.message}`);
|
||
|
|
if (!res.headersSent) res.writeHead(500, { "Content-Type": "application/json" });
|
||
|
|
res.end(JSON.stringify({ error: { message: error.message, type: "mitm_error" } }));
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
module.exports = { intercept };
|