mirror of
https://github.com/missuo/FreeGPT35.git
synced 2025-10-13 13:58:14 +00:00
style: format code
This commit is contained in:
Vincent Yang
445
app.js
445
app.js
@@ -19,232 +19,245 @@ let oaiDeviceId;
|
||||
const wait = (ms) => new Promise((resolve) => setTimeout(resolve, ms));
|
||||
|
||||
function GenerateCompletionId(prefix = "cmpl-") {
|
||||
const characters = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789";
|
||||
const length = 28;
|
||||
const characters =
|
||||
"abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789";
|
||||
const length = 28;
|
||||
|
||||
for (let i = 0; i < length; i++) {
|
||||
prefix += characters.charAt(Math.floor(Math.random() * characters.length));
|
||||
}
|
||||
for (let i = 0; i < length; i++) {
|
||||
prefix += characters.charAt(Math.floor(Math.random() * characters.length));
|
||||
}
|
||||
|
||||
return prefix;
|
||||
return prefix;
|
||||
}
|
||||
|
||||
async function* chunksToLines(chunksAsync) {
|
||||
let previous = "";
|
||||
for await (const chunk of chunksAsync) {
|
||||
const bufferChunk = Buffer.isBuffer(chunk) ? chunk : Buffer.from(chunk);
|
||||
previous += bufferChunk;
|
||||
let eolIndex;
|
||||
while ((eolIndex = previous.indexOf("\n")) >= 0) {
|
||||
// line includes the EOL
|
||||
const line = previous.slice(0, eolIndex + 1).trimEnd();
|
||||
if (line === "data: [DONE]") break;
|
||||
if (line.startsWith("data: ")) yield line;
|
||||
previous = previous.slice(eolIndex + 1);
|
||||
}
|
||||
}
|
||||
let previous = "";
|
||||
for await (const chunk of chunksAsync) {
|
||||
const bufferChunk = Buffer.isBuffer(chunk) ? chunk : Buffer.from(chunk);
|
||||
previous += bufferChunk;
|
||||
let eolIndex;
|
||||
while ((eolIndex = previous.indexOf("\n")) >= 0) {
|
||||
// line includes the EOL
|
||||
const line = previous.slice(0, eolIndex + 1).trimEnd();
|
||||
if (line === "data: [DONE]") break;
|
||||
if (line.startsWith("data: ")) yield line;
|
||||
previous = previous.slice(eolIndex + 1);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
async function* linesToMessages(linesAsync) {
|
||||
for await (const line of linesAsync) {
|
||||
const message = line.substring("data :".length);
|
||||
for await (const line of linesAsync) {
|
||||
const message = line.substring("data :".length);
|
||||
|
||||
yield message;
|
||||
}
|
||||
yield message;
|
||||
}
|
||||
}
|
||||
|
||||
async function* StreamCompletion(data) {
|
||||
yield* linesToMessages(chunksToLines(data));
|
||||
yield* linesToMessages(chunksToLines(data));
|
||||
}
|
||||
|
||||
// Setup axios instance for API requests with predefined configurations
|
||||
const axiosInstance = axios.create({
|
||||
httpsAgent: new https.Agent({ rejectUnauthorized: false }),
|
||||
headers: {
|
||||
accept: "*/*",
|
||||
"accept-language": "en-US,en;q=0.9",
|
||||
"cache-control": "no-cache",
|
||||
"content-type": "application/json",
|
||||
"oai-language": "en-US",
|
||||
origin: baseUrl,
|
||||
pragma: "no-cache",
|
||||
referer: baseUrl,
|
||||
"sec-ch-ua": '"Google Chrome";v="123", "Not:A-Brand";v="8", "Chromium";v="123"',
|
||||
"sec-ch-ua-mobile": "?0",
|
||||
"sec-ch-ua-platform": '"Windows"',
|
||||
"sec-fetch-dest": "empty",
|
||||
"sec-fetch-mode": "cors",
|
||||
"sec-fetch-site": "same-origin",
|
||||
"user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/123.0.0.0 Safari/537.36",
|
||||
},
|
||||
httpsAgent: new https.Agent({ rejectUnauthorized: false }),
|
||||
headers: {
|
||||
accept: "*/*",
|
||||
"accept-language": "en-US,en;q=0.9",
|
||||
"cache-control": "no-cache",
|
||||
"content-type": "application/json",
|
||||
"oai-language": "en-US",
|
||||
origin: baseUrl,
|
||||
pragma: "no-cache",
|
||||
referer: baseUrl,
|
||||
"sec-ch-ua":
|
||||
'"Google Chrome";v="123", "Not:A-Brand";v="8", "Chromium";v="123"',
|
||||
"sec-ch-ua-mobile": "?0",
|
||||
"sec-ch-ua-platform": '"Windows"',
|
||||
"sec-fetch-dest": "empty",
|
||||
"sec-fetch-mode": "cors",
|
||||
"sec-fetch-site": "same-origin",
|
||||
"user-agent":
|
||||
"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/123.0.0.0 Safari/537.36",
|
||||
},
|
||||
});
|
||||
|
||||
// Function to get a new session ID and token from the OpenAI API
|
||||
async function getNewSessionId() {
|
||||
let newDeviceId = randomUUID();
|
||||
const response = await axiosInstance.post(
|
||||
`${baseUrl}/backend-anon/sentinel/chat-requirements`,
|
||||
{},
|
||||
{
|
||||
headers: { "oai-device-id": newDeviceId },
|
||||
}
|
||||
);
|
||||
console.log(`System: Successfully refreshed session ID and token. ${!token ? "(Now it's ready to process requests)" : ""}`);
|
||||
oaiDeviceId = newDeviceId;
|
||||
token = response.data.token;
|
||||
let newDeviceId = randomUUID();
|
||||
const response = await axiosInstance.post(
|
||||
`${baseUrl}/backend-anon/sentinel/chat-requirements`,
|
||||
{},
|
||||
{
|
||||
headers: { "oai-device-id": newDeviceId },
|
||||
}
|
||||
);
|
||||
console.log(
|
||||
`System: Successfully refreshed session ID and token. ${
|
||||
!token ? "(Now it's ready to process requests)" : ""
|
||||
}`
|
||||
);
|
||||
oaiDeviceId = newDeviceId;
|
||||
token = response.data.token;
|
||||
|
||||
// console.log("New Token:", token);
|
||||
// console.log("New Device ID:", oaiDeviceId);
|
||||
// console.log("New Token:", token);
|
||||
// console.log("New Device ID:", oaiDeviceId);
|
||||
}
|
||||
|
||||
// Middleware to enable CORS and handle pre-flight requests
|
||||
function enableCORS(req, res, next) {
|
||||
res.header("Access-Control-Allow-Origin", "*");
|
||||
res.header("Access-Control-Allow-Headers", "*");
|
||||
res.header("Access-Control-Allow-Methods", "GET, POST, OPTIONS");
|
||||
if (req.method === "OPTIONS") {
|
||||
return res.status(200).end();
|
||||
}
|
||||
next();
|
||||
res.header("Access-Control-Allow-Origin", "*");
|
||||
res.header("Access-Control-Allow-Headers", "*");
|
||||
res.header("Access-Control-Allow-Methods", "GET, POST, OPTIONS");
|
||||
if (req.method === "OPTIONS") {
|
||||
return res.status(200).end();
|
||||
}
|
||||
next();
|
||||
}
|
||||
|
||||
// Middleware to handle chat completions
|
||||
async function handleChatCompletion(req, res) {
|
||||
console.log("Request:", `${req.method} ${req.originalUrl}`, `${(req.body?.messages?.length || 0)} messages`, req.body.stream ? "(stream-enabled)" : "(stream-disabled)");
|
||||
try {
|
||||
const body = {
|
||||
action: "next",
|
||||
messages: req.body.messages.map((message) => ({
|
||||
author: { role: message.role },
|
||||
content: { content_type: "text", parts: [message.content] },
|
||||
})),
|
||||
parent_message_id: randomUUID(),
|
||||
model: "text-davinci-002-render-sha",
|
||||
timezone_offset_min: -180,
|
||||
suggestions: [],
|
||||
history_and_training_disabled: true,
|
||||
conversation_mode: { kind: "primary_assistant" },
|
||||
websocket_request_id: randomUUID(),
|
||||
};
|
||||
console.log(
|
||||
"Request:",
|
||||
`${req.method} ${req.originalUrl}`,
|
||||
`${req.body?.messages?.length || 0} messages`,
|
||||
req.body.stream ? "(stream-enabled)" : "(stream-disabled)"
|
||||
);
|
||||
try {
|
||||
const body = {
|
||||
action: "next",
|
||||
messages: req.body.messages.map((message) => ({
|
||||
author: { role: message.role },
|
||||
content: { content_type: "text", parts: [message.content] },
|
||||
})),
|
||||
parent_message_id: randomUUID(),
|
||||
model: "text-davinci-002-render-sha",
|
||||
timezone_offset_min: -180,
|
||||
suggestions: [],
|
||||
history_and_training_disabled: true,
|
||||
conversation_mode: { kind: "primary_assistant" },
|
||||
websocket_request_id: randomUUID(),
|
||||
};
|
||||
|
||||
const response = await axiosInstance.post(apiUrl, body, {
|
||||
responseType: "stream",
|
||||
headers: {
|
||||
"oai-device-id": oaiDeviceId,
|
||||
"openai-sentinel-chat-requirements-token": token,
|
||||
},
|
||||
});
|
||||
const response = await axiosInstance.post(apiUrl, body, {
|
||||
responseType: "stream",
|
||||
headers: {
|
||||
"oai-device-id": oaiDeviceId,
|
||||
"openai-sentinel-chat-requirements-token": token,
|
||||
},
|
||||
});
|
||||
|
||||
// Set the response headers based on the request type
|
||||
if (req.body.stream) {
|
||||
res.setHeader("Content-Type", "text/event-stream");
|
||||
res.setHeader("Cache-Control", "no-cache");
|
||||
res.setHeader("Connection", "keep-alive");
|
||||
} else {
|
||||
res.setHeader("Content-Type", "application/json");
|
||||
}
|
||||
// Set the response headers based on the request type
|
||||
if (req.body.stream) {
|
||||
res.setHeader("Content-Type", "text/event-stream");
|
||||
res.setHeader("Cache-Control", "no-cache");
|
||||
res.setHeader("Connection", "keep-alive");
|
||||
} else {
|
||||
res.setHeader("Content-Type", "application/json");
|
||||
}
|
||||
|
||||
let fullContent = "";
|
||||
let requestId = GenerateCompletionId("chatcmpl-");
|
||||
let created = Date.now();
|
||||
let fullContent = "";
|
||||
let requestId = GenerateCompletionId("chatcmpl-");
|
||||
let created = Date.now();
|
||||
|
||||
for await (const message of StreamCompletion(response.data)) {
|
||||
const parsed = JSON.parse(message);
|
||||
for await (const message of StreamCompletion(response.data)) {
|
||||
const parsed = JSON.parse(message);
|
||||
|
||||
let content = parsed?.message?.content?.parts[0] || "";
|
||||
let content = parsed?.message?.content?.parts[0] || "";
|
||||
|
||||
for (let message of req.body.messages) {
|
||||
if (message.content === content) {
|
||||
content = "";
|
||||
break;
|
||||
}
|
||||
}
|
||||
for (let message of req.body.messages) {
|
||||
if (message.content === content) {
|
||||
content = "";
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
if (content === "") continue;
|
||||
if (content === "") continue;
|
||||
|
||||
if (req.body.stream) {
|
||||
let response = {
|
||||
id: requestId,
|
||||
created: created,
|
||||
object: "chat.completion.chunk",
|
||||
model: "gpt-3.5-turbo",
|
||||
choices: [
|
||||
{
|
||||
delta: {
|
||||
content: content.replace(fullContent, ""),
|
||||
},
|
||||
index: 0,
|
||||
finish_reason: null,
|
||||
},
|
||||
],
|
||||
};
|
||||
if (req.body.stream) {
|
||||
let response = {
|
||||
id: requestId,
|
||||
created: created,
|
||||
object: "chat.completion.chunk",
|
||||
model: "gpt-3.5-turbo",
|
||||
choices: [
|
||||
{
|
||||
delta: {
|
||||
content: content.replace(fullContent, ""),
|
||||
},
|
||||
index: 0,
|
||||
finish_reason: null,
|
||||
},
|
||||
],
|
||||
};
|
||||
|
||||
res.write(`data: ${JSON.stringify(response)}\n\n`);
|
||||
}
|
||||
res.write(`data: ${JSON.stringify(response)}\n\n`);
|
||||
}
|
||||
|
||||
fullContent = content.length > fullContent.length ? content : fullContent;
|
||||
}
|
||||
fullContent = content.length > fullContent.length ? content : fullContent;
|
||||
}
|
||||
|
||||
if (req.body.stream) {
|
||||
res.write(
|
||||
`data: ${JSON.stringify({
|
||||
id: requestId,
|
||||
created: created,
|
||||
object: "chat.completion.chunk",
|
||||
model: "gpt-3.5-turbo",
|
||||
choices: [
|
||||
{
|
||||
delta: {
|
||||
content: "",
|
||||
},
|
||||
index: 0,
|
||||
finish_reason: "stop",
|
||||
},
|
||||
],
|
||||
})}\n\n`
|
||||
);
|
||||
} else {
|
||||
res.write(
|
||||
JSON.stringify({
|
||||
id: requestId,
|
||||
created: created,
|
||||
model: "gpt-3.5-turbo",
|
||||
object: "chat.completion",
|
||||
choices: [
|
||||
{
|
||||
finish_reason: "stop",
|
||||
index: 0,
|
||||
message: {
|
||||
content: fullContent,
|
||||
role: "assistant",
|
||||
},
|
||||
},
|
||||
],
|
||||
usage: {
|
||||
prompt_tokens: 0,
|
||||
completion_tokens: 0,
|
||||
total_tokens: 0,
|
||||
},
|
||||
})
|
||||
);
|
||||
}
|
||||
if (req.body.stream) {
|
||||
res.write(
|
||||
`data: ${JSON.stringify({
|
||||
id: requestId,
|
||||
created: created,
|
||||
object: "chat.completion.chunk",
|
||||
model: "gpt-3.5-turbo",
|
||||
choices: [
|
||||
{
|
||||
delta: {
|
||||
content: "",
|
||||
},
|
||||
index: 0,
|
||||
finish_reason: "stop",
|
||||
},
|
||||
],
|
||||
})}\n\n`
|
||||
);
|
||||
} else {
|
||||
res.write(
|
||||
JSON.stringify({
|
||||
id: requestId,
|
||||
created: created,
|
||||
model: "gpt-3.5-turbo",
|
||||
object: "chat.completion",
|
||||
choices: [
|
||||
{
|
||||
finish_reason: "stop",
|
||||
index: 0,
|
||||
message: {
|
||||
content: fullContent,
|
||||
role: "assistant",
|
||||
},
|
||||
},
|
||||
],
|
||||
usage: {
|
||||
prompt_tokens: 0,
|
||||
completion_tokens: 0,
|
||||
total_tokens: 0,
|
||||
},
|
||||
})
|
||||
);
|
||||
}
|
||||
|
||||
res.end();
|
||||
} catch (error) {
|
||||
// console.log('Error:', error.response?.data ?? error.message);
|
||||
if (!res.headersSent) res.setHeader("Content-Type", "application/json");
|
||||
// console.error('Error handling chat completion:', error);
|
||||
res.write(
|
||||
JSON.stringify({
|
||||
status: false,
|
||||
error: {
|
||||
message: "An error happened, please make sure your request is SFW, or use a jailbreak to bypass the filter.",
|
||||
type: "invalid_request_error",
|
||||
},
|
||||
})
|
||||
);
|
||||
res.end();
|
||||
}
|
||||
res.end();
|
||||
} catch (error) {
|
||||
// console.log('Error:', error.response?.data ?? error.message);
|
||||
if (!res.headersSent) res.setHeader("Content-Type", "application/json");
|
||||
// console.error('Error handling chat completion:', error);
|
||||
res.write(
|
||||
JSON.stringify({
|
||||
status: false,
|
||||
error: {
|
||||
message:
|
||||
"An error happened, please make sure your request is SFW, or use a jailbreak to bypass the filter.",
|
||||
type: "invalid_request_error",
|
||||
},
|
||||
})
|
||||
);
|
||||
res.end();
|
||||
}
|
||||
}
|
||||
|
||||
// Initialize Express app and use middlewares
|
||||
@@ -257,37 +270,43 @@ app.post("/v1/chat/completions", handleChatCompletion);
|
||||
|
||||
// 404 handler for unmatched routes
|
||||
app.use((req, res) =>
|
||||
res.status(404).send({
|
||||
status: false,
|
||||
error: {
|
||||
message: `The requested endpoint was not found. please make sure to use "http://localhost:3040/v1" as the base URL.`,
|
||||
type: "invalid_request_error",
|
||||
},
|
||||
})
|
||||
res.status(404).send({
|
||||
status: false,
|
||||
error: {
|
||||
message: `The requested endpoint was not found. please make sure to use "http://localhost:3040/v1" as the base URL.`,
|
||||
type: "invalid_request_error",
|
||||
},
|
||||
})
|
||||
);
|
||||
|
||||
// Start the server and the session ID refresh loop
|
||||
app.listen(port, () => {
|
||||
console.log(`💡 Server is running at http://localhost:${port}`);
|
||||
console.log();
|
||||
console.log(`🔗 Base URL: http://localhost:${port}/v1`);
|
||||
console.log(`🔗 ChatCompletion Endpoint: http://localhost:${port}/v1/chat/completions`);
|
||||
console.log();
|
||||
console.log("📝 Original TS Source By: Pawan.Krd");
|
||||
console.log("📝 Modified Into JavaScript By: Adam");
|
||||
console.log();
|
||||
console.log(`💡 Server is running at http://localhost:${port}`);
|
||||
console.log();
|
||||
console.log(`🔗 Base URL: http://localhost:${port}/v1`);
|
||||
console.log(
|
||||
`🔗 ChatCompletion Endpoint: http://localhost:${port}/v1/chat/completions`
|
||||
);
|
||||
console.log();
|
||||
console.log("📝 Original TS Source By: Pawan.Krd");
|
||||
console.log("📝 Modified Into JavaScript By: Adam");
|
||||
console.log();
|
||||
|
||||
setTimeout(async () => {
|
||||
while (true) {
|
||||
try {
|
||||
await getNewSessionId();
|
||||
await wait(refreshInterval);
|
||||
} catch (error) {
|
||||
console.error("Error refreshing session ID, retrying in 1 minute...");
|
||||
console.error("If this error persists, your country may not be supported yet.");
|
||||
console.error("If your country was the issue, please consider using a U.S. VPN.");
|
||||
await wait(errorWait);
|
||||
}
|
||||
}
|
||||
}, 0);
|
||||
setTimeout(async () => {
|
||||
while (true) {
|
||||
try {
|
||||
await getNewSessionId();
|
||||
await wait(refreshInterval);
|
||||
} catch (error) {
|
||||
console.error("Error refreshing session ID, retrying in 1 minute...");
|
||||
console.error(
|
||||
"If this error persists, your country may not be supported yet."
|
||||
);
|
||||
console.error(
|
||||
"If your country was the issue, please consider using a U.S. VPN."
|
||||
);
|
||||
await wait(errorWait);
|
||||
}
|
||||
}
|
||||
}, 0);
|
||||
});
|
||||
|
||||
12
example.js
12
example.js
@@ -1,18 +1,18 @@
|
||||
const axios = require('axios');
|
||||
const axios = require("axios");
|
||||
|
||||
const API_URL = 'http://localhost:3040/v1/chat/completions';
|
||||
const API_URL = "http://localhost:3040/v1/chat/completions";
|
||||
|
||||
const prompt = 'Hello, how are you?';
|
||||
const prompt = "Hello, how are you?";
|
||||
|
||||
const data = {
|
||||
model: 'gpt-3.5-turbo',
|
||||
messages: [{ role: 'user', content: prompt }],
|
||||
model: "gpt-3.5-turbo",
|
||||
messages: [{ role: "user", content: prompt }],
|
||||
temperature: 0.7,
|
||||
};
|
||||
|
||||
const config = {
|
||||
headers: {
|
||||
'Content-Type': 'application/json',
|
||||
"Content-Type": "application/json",
|
||||
},
|
||||
};
|
||||
|
||||
|
||||
Reference in New Issue
Block a user