Upload 12 files

.gitignore

@@ -13,6 +13,9 @@ yarn-error.log*
 cookies.json
 cookies.js
 cookies.ini
+lib/bin/cfg
+lib/bin/hdr
+lib/bin/pyld
 config.js
 log.txt
 

clewd.js

@@ -7,12 +7,13 @@
 const {createServer: Server, IncomingMessage, ServerResponse} = require('node:http'), {createHash: Hash, randomUUID, randomInt, randomBytes} = require('node:crypto'), {TransformStream, ReadableStream} = require('node:stream/web'), {Readable, Writable} = require('node:stream'), {Blob} = require('node:buffer'), {existsSync: exists, writeFileSync: write, createWriteStream} = require('node:fs'), {join: joinP} = require('node:path'), {ClewdSuperfetch: Superfetch, SuperfetchAvailable} = require('./lib/clewd-superfetch'), {AI, fileName, genericFixes, bytesToSize, setTitle, checkResErr, Replacements, Main} = require('./lib/clewd-utils'), ClewdStream = require('./lib/clewd-stream');
 
 /******************************************************* */
-let currentIndex, Firstlogin = true, changeflag = 0, changetime = 0, totaltime, uuidOrgArray = [];
+let currentIndex, Firstlogin = true, changeflag = 0, changetime = 0, totaltime, uuidOrgArray = [], model;
 
 const events = require('events'), CookieChanger = new events.EventEmitter();
 require('events').EventEmitter.defaultMaxListeners = 0;
 
 CookieChanger.on('ChangeCookie', () => {
+    changeflag = 0;
     Proxy && Proxy.close();
     console.log(`Changing Cookie...\n`);
     Proxy.listen(Config.Port, Config.Ip, onListen);
@@ -21,117 +22,114 @@ CookieChanger.on('ChangeCookie', () => {
     }));
 });
 
-const simpletokenizer = (prompt) => {
-    let byteLength = 0;
-    for (let i = 0; i < prompt.length; i++) {
-        let code = prompt.charCodeAt(i);
-        if (code <= 0xFF) {
-            byteLength += 0.6;
-        } else if (code <= 0xFFFF) {
-            byteLength += 1;
-        } else {
-            byteLength += 1.5;
-        }
-    }
-    return byteLength;
-}, padtxt = (content) => {
-    if (Config.padtxt_placeholder.length > 0) {
-        var placeholder = Config.padtxt_placeholder;
-    } else {
-        const bytes = randomInt(5, 15);
-        var placeholder = randomBytes(bytes).toString('hex');
-    }
-    let count = Math.floor((Config.Settings.padtxt - simpletokenizer(content)) / simpletokenizer(placeholder)); 
-
-    // 生成占位符字符串
+const CookieCleaner = () => {
+    Config.CookieArray = Config.CookieArray.filter(item => item !== Config.Cookie);
+    !process.env.Cookie && !process.env.CookieArray && writeSettings(Config);
+    currentIndex = (currentIndex - 1 + Config.CookieArray.length) % Config.CookieArray.length;
+}, padtxt = content => {
+    const {encode} = require('gpt-tokenizer');
+    const placeholder = Config.padtxt_placeholder || randomBytes(randomInt(5, 15)).toString('hex');
+    let count = Math.floor(Math.max(1000, Config.Settings.padtxt - encode(content).length) / encode(placeholder).length); 
     let padding = '';
     for (let i = 0; i < count; i++) {
         padding += placeholder;
     }
-
-    // 在prompt前面添加占位符, 在末尾增加空行然后添加prompt
     content = padding + '\n\n\n' + content;
-
     return content.trim();
-}, xmlPlot = (content) => {
+}, xmlPlot = content => {
     // 检查内容中是否包含"<card>"
-    if (!content.includes('<card>')) {
-        content = content.replace(/(\n\n|^)xmlPlot:\s*/gm, '$1');
-        content = content.replace(/(<reply>\n|\n<\/reply>)/g, '');
-        return content.replace(/<customname>(.*?)<\/customname>/gm, '$1');
+    const card = content.includes('<card>');
+    //<card>越狱倒置
+    if (card) {
+        let segcontentHuman = content.split('\n\nHuman:');
+        const seglength = segcontentHuman.length;
+        if (/Assistant: *.$/.test(content) && seglength > 1 && !segcontentHuman[seglength - 2].includes('\n\nAssistant:')) {
+            segcontentHuman[seglength - 2] = segcontentHuman.splice(seglength - 1, 1, segcontentHuman[seglength - 2])[0];
+        }
+        content = segcontentHuman.join('\n\nHuman:');
     }
-
-    //群组
-    content = content.replace(/(<reply>\n|\n<\/reply>)\1*/g, '$1');
-    content = content.replace(/<customname>(.*?)<\/customname>:/gm, '$1:\n');
-
     //role合并
-    if (!content.includes('<\!-- Merge Disable -->')) {
-        if (!content.includes('<\!-- Merge Human Disable -->')) {
-            content = content.replace(/(\n\n|^)xmlPlot:/g, '$1Human:');
-            content = content.replace(/(?:\n\n|^)Human:(.*?(?:\n\nAssistant:|$))/gs, function(match, p1) {return '\n\nHuman:' + p1.replace(/\n\nHuman:\s*/g, '\n\n')});
+    const MergeDisable = content.includes('<\!-- Merge Disable -->');
+    const MergeHumanDisable = content.includes('<\!-- Merge Human Disable -->');
+    const MergeAssistantDisable = content.includes('<\!-- Merge Assistant Disable -->');
+    if (!MergeDisable) {
+        if (content.includes('<\!-- Merge System Disable -->') || !card) {
+            content = content.replace(/(\n\n|^\s*)xmlPlot:\s*/gm, '$1');
+        }
+        if (!MergeHumanDisable) {
+            content = content.replace(/(\n\n|^\s*)xmlPlot:/g, '$1Human:');
+            content = content.replace(/(?:\n\n|^\s*)Human:(.*?(?:\n\nAssistant:|$))/gs, function(match, p1) {return '\n\nHuman:' + p1.replace(/\n\nHuman:\s*/g, '\n\n')});
             content = content.replace(/^\s*Human:\s*/, '');
         }
-        if (!content.includes('<\!-- Merge Assistant Disable -->')) {
+        if (!MergeAssistantDisable) {
             content = content.replace(/\n\nAssistant:(.*?(?:\n\nHuman:|$))/gs, function(match, p1) {return '\n\nAssistant:' + p1.replace(/\n\nAssistant:\s*/g, '\n\n')});
         }
     }
-    content = content.replace(/(\n\n|^)xmlPlot:\s*/gm, '$1');
+    content = content.replace(/(\n\n|^\s*)xmlPlot:\s*/gm, '$1');
     content = content.replace(/<\!-- Merge.*?Disable -->/gm, '');
-
-    //格式顺序交换&越狱倒置
-    content = content.replace(/<Prev(Assistant|Human)>.*?<\/Prev\1>/gs, function(match) {return match.replace(/\n\n(Assistant|Human):/g, '\n\ntemp$1:')});
-    let segcontentAssistant = content.split('\n\nAssistant:');
-    let processedsegAssistant = segcontentAssistant.map(seg => {
-        return seg.replace(/(\n\nHuman:.*?)<PrevAssistant>(.*?)<\/PrevAssistant>/gs, '\n\n$2$1');
-    });
-    content = processedsegAssistant.join('\n\nAssistant:');
-    let segcontentHuman = content.split('\n\nHuman:');
-    const seglength = segcontentHuman.length;
-    for (let i = 1; i < seglength; i++) {
-        const match = segcontentHuman[i].match(/<PrevHuman>.*?<\/PrevHuman>/s);
-        if (match) {
-            segcontentHuman[i - 1] += match[0].replace(/<PrevHuman>(.*?)<\/PrevHuman>/s, '\n\n$1');
-            segcontentHuman[i] = segcontentHuman[i].replace(match[0], '');
+    //自定义插入
+    content = content.replace(/(<\/?)PrevAssistant>/gm, '$1@1>');
+    content = content.replace(/(<\/?)PrevHuman>/gm, '$1@2>');
+    let splitContent = content.split(/\n\n(?=Assistant:|Human:)/g);
+    let match;
+    while ((match = /<@(\d+)>(.*?)<\/@\1>/gs.exec(content)) !== null) {
+        let index = splitContent.length - parseInt(match[1]) - 1;
+        if (index >= 0) {
+            splitContent[index] += '\n\n' + match[2];
         }
+        content = content.replace(match[0], '');
     }
-    if (/Assistant: *.$/.test(content) && seglength > 1 && !segcontentHuman[seglength - 2].includes('\n\nAssistant:')) {
-        segcontentHuman[seglength - 2] = segcontentHuman.splice(seglength - 1, 1, segcontentHuman[seglength - 2])[0];
+    content = splitContent.join('\n\n');
+    content = content.replace(/<@(\d+)>.*?<\/@\1>/gs, '');
+    //正则
+    while ((match = /<regex>"(\/?)(.*)\1(.*)" *: *"(.*?)"<\/regex>/gm.exec(content)) !== null) {
+        try {
+            content = content.replace(new RegExp(match[2], match[3]), match[4]);
+        } catch (error) {}
+        content = content.replace(match[0], '');
     }
-    content = segcontentHuman.join('\n\nHuman:');
-    content = content.replace(/\n\ntemp(Assistant|Human):/g, '\n\n$1:');
-
-    //给开头加上</file-attachment-contents>用于截断附加文件标识
-    content.includes('<file-attachment-contents>') && (content = '</file-attachment-contents>\n\n' + content);
-
-    // 在第一个"[Start a new"前面加上"<example>"，在最后一个"[Start a new"前面加上"</example>\n\n<plot>\n\n"
-    const exampleNote = content.match(/(?<=<example-note>).*(?=<\/example-note>)/) || '';
+    content = content.replace(/(\r\n|\r|\\n)/gm, '\n');
+    //二次role合并
+    if (!MergeDisable) {
+        if (!MergeHumanDisable) {
+            content = content.replace(/(?:\n\n|^\s*)Human:(.*?(?:\n\nAssistant:|$))/gs, function(match, p1) {return '\n\nHuman:' + p1.replace(/\n\nHuman:\s*/g, '\n\n')});
+        }
+        if (!MergeAssistantDisable) {
+            content = content.replace(/\n\nAssistant:(.*?(?:\n\nHuman:|$))/gs, function(match, p1) {return '\n\nAssistant:' + p1.replace(/\n\nAssistant:\s*/g, '\n\n')});
+        }
+    }
+    //Plain Prompt
+    let segcontentHuman = content.split('\n\nHuman:');
+    let segcontentlastIndex = segcontentHuman.length - 1;
+    if (segcontentlastIndex >= 2 && segcontentHuman[segcontentlastIndex].includes('<!-- Plain Prompt Enable -->') && !content.includes('\n\nPlainPrompt:')) {
+        content = segcontentHuman.slice(0, segcontentlastIndex).join('\n\nHuman:') + '\n\nPlainPrompt:' + segcontentHuman.slice(segcontentlastIndex).join('\n\nHuman:');
+    }
+    content = content.replace(/<\!-- Plain Prompt Enable -->/gm, '');
+    content = content.replace(/\n\nHuman: *PlainPrompt:/, '\n\nPlainPrompt:');
+    //<card>群组
+    if (!card) {
+        content = content.replace(/(<reply>\n|\n<\/reply>)/g, '');
+        return content.replace(/<customname>(.*?)<\/customname>/gm, '$1');
+    } else {
+        content = content.replace(/(<reply>\n|\n<\/reply>)\1*/g, '$1');
+        content = content.replace(/<customname>(.*?)<\/customname>:/gm, '$1:\n');
+    }
+    //<card>在第一个"[Start a new"前面加上"<example>"，在最后一个"[Start a new"前面加上"</example>\n\n<plot>\n\n"
     const cardtag = content.match(/(?=\n\n<\/card>)/) || '</card>';
     const exampletag = content.match(/(?=\n\n<\/example>)/) || '</example>';
     const plot = content.includes('</plot>') ? '<plot>' : '';
-    content = content.replace(/<example-note>.*<\/example-note>/, '');
     const firstChatStart = content.indexOf('\n\n[Start a new');
     const lastChatStart = content.lastIndexOf('\n\n[Start a new');
     firstChatStart != -1 && firstChatStart === lastChatStart && (content = content.slice(0, firstChatStart) + `\n\n${cardtag}` + content.slice(firstChatStart));
-    firstChatStart != lastChatStart && (content = content.slice(0, firstChatStart) + `\n\n${cardtag}\n\n${exampleNote}\n<example>` + content.slice(firstChatStart, lastChatStart) + `\n\n${exampletag}\n\n${plot}` + content.slice(lastChatStart));
-
-    //Plain Prompt
-    segcontentHuman = content.split('\n\nHuman:');
-    let segcontentlastIndex = segcontentHuman.length - 1;
-    if (segcontentlastIndex >= 2 && segcontentHuman[segcontentlastIndex].includes('<!-- Plain Prompt Enable -->') && !content.includes('\n\nPlainPrompt:')) {
-        content = segcontentHuman.slice(0, segcontentlastIndex).join('\n\nHuman:') + '\n\nPlainPrompt:' + segcontentHuman.slice(segcontentlastIndex).join('\n\nHuman:');
-    }
-    content = content.replace(/<\!-- Plain Prompt Enable -->/, '');
-    content = content.replace(/\n\nHuman:.*PlainPrompt:/, '\n\nPlainPrompt:');
-
-    //消除空XML tags或多余的\n
-    content = content.replace(/\n<\/(hidden|META)>\s+?<\1>\n/g, '');
-    content = content.replace(/\n<(card|example|hidden|plot|META)>\s+?<\1>/g, '\n<$1>');
+    firstChatStart != lastChatStart && (content = content.slice(0, firstChatStart) + `\n\n${cardtag}\n<example>` + content.slice(firstChatStart, lastChatStart) + `\n\n${exampletag}\n\n${plot}` + content.slice(lastChatStart));
+    //<card>消除空XML tags、两端空白符和多余的\n
+    content = content.replace(/\s*<\|curtail\|>\s*/g, '\n');
+    content = content.replace(/\n<\/(card|hidden|META)>\s+?<\1>\n/g, '\n');
+    content = content.replace(/\n<(\/?card|example|hidden|plot|META)>\s+?<\1>/g, '\n<$1>');
     content = content.replace(/(?:<!--.*?-->)?\n<(card|example|hidden|plot|META)>\s+?<\/\1>/g, '');
-    content = content.replace(/(?<=(: |\n)<(card|hidden|example|plot|META)>\n)\s*/g, '');
-    content = content.replace(/\s*(?=\n<\/(card|hidden|example|plot|META)>(\n|$))/g, '');
+    content = content.replace(/(?<=(: |\n)<(card|hidden|example|plot|META|EOT)>\n)\s*/g, '');
+    content = content.replace(/\s*(?=\n<\/(card|hidden|example|plot|META|EOT)>(\n|$))/g, '');
     content = content.replace(/(?<=\n)\n(?=\n)/g, '');
-
     return content.trim();
 };
 /******************************************************* */
@@ -147,8 +145,9 @@ const ConfigPath = joinP(__dirname, './config.js'), LogPath = joinP(__dirname, '
 let uuidOrg, curPrompt = {}, prevPrompt = {}, prevMessages = [], prevImpersonated = false, Config = {
     Cookie: '',
     CookieArray: [],
-    Cookiecounter: 0,
+    Cookiecounter: 3,
     CookieIndex: 0,
+    ProxyPassword: '',
     Ip: (process.env.Cookie || process.env.CookieArray) ? '0.0.0.0' : '127.0.0.1',
     Port: process.env.PORT || 8444,
     localtunnel: false,
@@ -172,10 +171,10 @@ let uuidOrg, curPrompt = {}, prevPrompt = {}, prevMessages = [], prevImpersonate
         StripHuman: false,
         PassParams: false,
         ClearFlags: true,
-        PreserveChats: true,
+        PreserveChats: false,
         LogMessages: true,
         FullColon: true,
-        padtxt: 13500,
+        padtxt: 15000,
         xmlPlot: true,
         Superfetch: true
     }
@@ -222,14 +221,18 @@ const updateParams = res => {
     if (Config.Settings.PreserveChats) {
         return;
     }
-    const res = await fetch(`${Config.rProxy}/api/organizations/${uuidOrg}/chat_conversations/${uuid}`, {
-        headers: {
-            ...AI.hdr(),
-            Cookie: getCookies()
-        },
-        method: 'DELETE'
-    });
-    updateParams(res);
+    try { //
+        const res = await fetch(`${Config.rProxy}/api/organizations/${uuidOrg}/chat_conversations/${uuid}`, {
+            headers: {
+                ...AI.hdr(),
+                Cookie: getCookies()
+            },
+            method: 'DELETE'
+        });
+        updateParams(res);
+    } catch (err) { //
+        console.log(`deleteChat failed`); //
+    } //
 }, onListen = async () => {
 /***************************** */
     if (Firstlogin) {
@@ -250,7 +253,7 @@ const updateParams = res => {
         currentIndex = (currentIndex + 1) % Config.CookieArray.length;
         changetime += 1;
     }
-    let percentage = ((changetime + Config.CookieIndex) / totaltime) * 100
+    let percentage = ((changetime + Math.max(Config.CookieIndex - 1, 0)) / totaltime) * 100
     if (Config.Cookiecounter < 0 && percentage > 100) {
         console.log(`\n※※※Cookie cleanup completed※※※\n\n`);
         return process.exit();
@@ -259,6 +262,7 @@ const updateParams = res => {
     if ('SET YOUR COOKIE HERE' === Config.Cookie || Config.Cookie?.length < 1) {
         throw Error('Set your cookie inside config.js');
     }
+    !/^sessionKey=/.test(Config.Cookie) && (Config.Cookie += 'sessionKey='); //
     updateCookies(Config.Cookie);
     //console.log(`${Main}\nhttp://${Config.Ip}:${Config.Port}/v1\n\n${Object.keys(Config.Settings).map((setting => UnknownSettings.includes(setting) ? `??? ${setting}: ${Config.Settings[setting]}` : `${setting}: ${ChangedSettings.includes(setting) ? '' : ''}${Config.Settings[setting]}`)).sort().join('\n')}\n`);
     //Config.Settings.Superfetch && SuperfetchAvailable(true);
@@ -271,9 +275,7 @@ const updateParams = res => {
     });
 /**************************** */
     if (accRes.statusText === 'Forbidden' && Config.CookieArray?.length > 0) {
-        Config.CookieArray = Config.CookieArray.filter(item => item !== Config.Cookie);
-        !process.env.Cookie && !process.env.CookieArray && writeSettings(Config);
-        currentIndex = (currentIndex - 1 + Config.CookieArray.length) % Config.CookieArray.length;
+        CookieCleaner();
         console.log(`Expired!`);
         Config.Cookiecounter < 0 && console.log(`[progress]: ${percentage.toFixed(2)}%\n[length]: ${Config.CookieArray.length}\n`);
         CookieChanger.emit('ChangeCookie');
@@ -290,38 +292,64 @@ const updateParams = res => {
     }
     setTitle('ok');
     updateParams(accRes);
+/**************************** */
+    const accountRes = await fetch(Config.rProxy + '/api/auth/current_account', {
+        method: 'GET',
+        headers: {
+            ...AI.hdr(),
+            Cookie: getCookies()
+        }
+    });
+    await checkResErr(accountRes);
+    const accountInfo = (await accountRes.json());
+/**************************** */
     console.log(Config.CookieArray?.length > 0 ? `(index: ${currentIndex || Config.CookieArray.length}) Logged in %o` : 'Logged in %o', { //console.log('Logged in %o', {
         name: accInfo.name?.split('@')?.[0],
+        mail: accountInfo.account.email_address, //
         capabilities: accInfo.capabilities,
     });
     uuidOrg = accInfo?.uuid;
 /************************* */
-    if (uuidOrgArray.includes(uuidOrg)) {
-        console.log(`Overlap!`);
-        currentIndex = (currentIndex - 1 + Config.CookieArray.length) % Config.CookieArray.length;
+    model = accountInfo.account.statsig.values.dynamic_configs["6zA9wvTedwkzjLxWy9PVe7yydI00XDQ6L5Fejjq/2o8="]?.value?.model;
+    model != AI.mdl() && console.log(`${model}`);
+    if (model != AI.mdl() && Config.Cookiecounter === -2) {
+        CookieCleaner();
+        return CookieChanger.emit('ChangeCookie');
+    }
+    const Overlap = uuidOrgArray.includes(uuidOrg) && percentage <= 100 && Config.CookieArray?.length > 0;
+    !Overlap && uuidOrgArray.push(uuidOrg);
+    const Unverified = !accountInfo.account.completed_verification_at;
+    const abuseTag = accountInfo.account.statsig.values.feature_gates["4fDxNAVXgvks8yzKUoU+T+w3Qr3oYVqoJJVNYh04Mik="]?.secondary_exposures[0];
+    const Banned = abuseTag.gateValue === 'true' && abuseTag.gate === 'segment:abuse';
+    const Remain = accountInfo.messageLimit?.remaining;
+    const Exceededlimit = (accountInfo.messageLimit?.type === 'approaching_limit' && Remain === 0) || accountInfo.messageLimit?.type === 'exceeded_limit';
+    if (Remain) {
+        changeflag = Math.max(Config.Cookiecounter - Remain, changeflag);
+        console.log(`ApproachingLimit!: Remain ${Remain}`);
+    }
+    if ((Overlap || Unverified || Banned) && Config.CookieArray?.length > 0) {
+        Overlap ? console.log(`Overlap!`) : Unverified ? console.log(`Unverified!`) : Banned && console.log(`Banned!`);
+        CookieCleaner();
         Config.Cookiecounter < 0 && console.log(`[progress]: ${percentage.toFixed(2)}%\n[length]: ${Config.CookieArray.length}\n`);
-        Config.CookieArray = Config.CookieArray.filter(item => item !== Config.Cookie);
-        !process.env.Cookie && !process.env.CookieArray && writeSettings(Config);
-        CookieChanger.emit('ChangeCookie');
-        return;
-    } else {
-        uuidOrgArray.push(uuidOrg);
+        return CookieChanger.emit('ChangeCookie');
     }
 /************************* */
     if (accInfo?.active_flags.length > 0) {
+        let flagtype; //
         const now = new Date, formattedFlags = accInfo.active_flags.map((flag => {
             const days = ((new Date(flag.expires_at).getTime() - now.getTime()) / 864e5).toFixed(2);
+            flagtype = flag.type; //
             return {
                 type: flag.type,
                 remaining_days: days
             };
         }));
-        console.warn('Your account has warnings %o', formattedFlags); //console.warn('Your account has warnings %o', formattedFlags);
+        console.warn(`${'consumer_banned' === flagtype ? '' : ''}Your account has warnings %o`, formattedFlags); //console.warn('Your account has warnings %o', formattedFlags);
         await Promise.all(accInfo.active_flags.map((flag => (async type => {
             if (!Config.Settings.ClearFlags) {
                 return;
             }
-            if ('consumer_restricted_mode' === type) {
+            if ('consumer_restricted_mode' === type || 'consumer_banned' === type) { //if ('consumer_restricted_mode' === type) {
                 return;
             }
             const req = await (Config.Settings.Superfetch ? Superfetch : fetch)(`${Config.rProxy}/api/organizations/${uuidOrg}/flags/${type}/dismiss`, {
@@ -337,40 +365,18 @@ const updateParams = res => {
         })(flag.type))));
 /***************************** */
         if (Config.CookieArray?.length > 0) {
-            console.log(`Restricted!`);
+            console.log(`${'consumer_banned' === flagtype ? 'Banned' : 'Restricted'}!`);
+            'consumer_banned' === flagtype && CookieCleaner();
             Config.Cookiecounter < 0 && console.log(`[progress]: ${percentage.toFixed(2)}%\n[length]: ${Config.CookieArray.length}\n`);
-            CookieChanger.emit('ChangeCookie');
-            return;
+            return CookieChanger.emit('ChangeCookie');
         }
     }
-    if (Config.CookieArray.length > 0) {
-        const allres = await fetch(`${Config.rProxy}`, {
-            headers: {
-                ...AI.hdr(),
-                Cookie: getCookies()
-            },
-            method: 'GET'
-        }), accountinfo = await allres.text();
-        updateParams(allres);
-        const Unverified = accountinfo.includes('\\"completed_verification_at\\":null');
-        const Banned = accountinfo.includes('\\"gate\":\\"segment:abuse\\",\\"gateValue\\":\\"true\\",');
-        const Exceededlimit = /\\"messageLimit\\":{\\"type\\":\\"(approaching_limit\\",\\"remaining\\":0|exceeded_limit)\\",/.test(accountinfo);
-        const Remain = /\\"messageLimit\\":{\\"type\\":\\"approaching_limit\\",\\"remaining\\":\d+\\",/.exec(accountinfo);
-        Remain && (changeflag = Math.max(Config.Cookiecounter - Remain[0], changeflag));
-        if (Unverified || Banned) {
-            Config.CookieArray = Config.CookieArray.filter(item => item !== Config.Cookie);
-            !process.env.Cookie && !process.env.CookieArray && writeSettings(Config);
-            currentIndex = (currentIndex - 1 + Config.CookieArray.length) % Config.CookieArray.length;
-        }
-        Unverified && console.log(`Unverified!`);
-        Banned && console.log(`Banned!`);
-        Exceededlimit && console.log(`Exceeded limit!`);
-        Config.Cookiecounter < 0 && console.log(`[progress]: ${percentage.toFixed(2)}%\n[length]: ${Config.CookieArray.length}`);
-        if (Unverified || Banned || Exceededlimit || Config.Cookiecounter < 0) {
-            console.log('');
-            CookieChanger.emit('ChangeCookie');
-            return;
-        }
+    if (Config.Cookiecounter < 0) {
+        console.log(`[progress]: ${percentage.toFixed(2)}%\n[length]: ${Config.CookieArray.length}\n`);
+        return CookieChanger.emit('ChangeCookie');
+    } else if (Exceededlimit) {
+        console.log(`Exceeded limit!\n`);
+        return CookieChanger.emit('ChangeCookie');
 /***************************** */
     }
     const convRes = await fetch(`${Config.rProxy}/api/organizations/${uuidOrg}/chat_conversations`, {
@@ -424,6 +430,12 @@ const updateParams = res => {
                 try {
                     const body = JSON.parse(Buffer.concat(buffer).toString()), temperature = Math.max(.1, Math.min(1, body.temperature));
                     let {messages} = body;
+/************************* */
+                    const authorization = Object.fromEntries(Object.entries(req.headers).map(([key, value]) => [key, value])).authorization;
+                    if (Config.ProxyPassword != '' && authorization != 'Bearer ' + Config.ProxyPassword) {
+                        throw Error('ProxyPassword Wrong');
+                    }
+/************************* */
                     if (messages?.length < 1) {
                         throw Error('Select OpenAI as completion source');
                     }
@@ -454,7 +466,7 @@ const updateParams = res => {
                         console.log('having AllSamples and NoSamples both set to true is not supported');
                         throw Error('Only one can be used at the same time: AllSamples/NoSamples');
                     }
-                    const model = AI.mdl();
+                    //const model = AI.mdl();
                     curPrompt = {
                         firstUser: messages.find((message => 'user' === message.role)),
                         firstSystem: messages.find((message => 'system' === message.role)),
@@ -624,38 +636,38 @@ const updateParams = res => {
                                 return message.content;
                             }
                             let spacing = '';
-/****************************************************************/
+/******************************** */
                             if (Config.Settings.xmlPlot) {
                                 idx > 0 && (spacing = '\n\n');
                                 const prefix = message.customname ? message.role + ': <customname>' + message.name + '</customname>: ' : 'system' !== message.role || message.name ? Replacements[message.name || message.role] + ': ' : 'xmlPlot: ' + Replacements[message.role];
                                 return `${spacing}${prefix}${message.customname ? '<reply>\n' + message.content.trim() + '\n</reply>' : message.content}`;
                             } else {
-/****************************************************************/
+/******************************** */
                                 idx > 0 && (spacing = systemMessages.includes(message) ? '\n' : '\n\n');
                                 const prefix = message.customname ? message.name + ': ' : 'system' !== message.role || message.name ? Replacements[message.name || message.role] + ': ' : '' + Replacements[message.role];
                                 return `${spacing}${message.strip ? '' : prefix}${'system' === message.role ? message.content : message.content.trim()}`;
                             } //
                         }));
                         return {
-                            prompt: genericFixes(prompt.join('')).trim(),
+                            prompt: prompt.join('').trim(),//genericFixes(prompt.join('')).trim(),
                             systems
                         };
                     })(messages, type);
                     console.log(`${model} [${type}]${!retryRegen && systems.length > 0 ? ' ' + systems.join(' / ') : ''}`);
                     'R' !== type || prompt || (prompt = '...regen...');
-/****************************************************************/
-                    Config.Settings.xmlPlot && (prompt = xmlPlot(prompt));
+/******************************** */
+                    prompt = Config.Settings.xmlPlot ? xmlPlot(prompt) : genericFixes(prompt);
                     Config.Settings.FullColon && (prompt = prompt.replace(/(?<=\n\n(H(?:uman)?|A(?:ssistant)?)):[ ]?/g, '： '));
                     Config.Settings.padtxt && (prompt = padtxt(prompt));
-/****************************************************************/
+/******************************** */
                     Logger?.write(`\n\n-------\n[${(new Date).toLocaleString()}]\n####### PROMPT (${type}):\n${prompt}\n--\n####### REPLY:\n`);
                     retryRegen || (fetchAPI = await (async (signal, model, prompt, temperature, type) => {
                         const attachments = [];
                         if (Config.Settings.PromptExperiments) {
-/****************************************************************/
+/******************************** */
                             let splitedprompt = prompt.split('\n\nPlainPrompt:');
                             prompt = splitedprompt[0];
-/****************************************************************/
+/******************************** */
                             attachments.push({
                                 extracted_content: (prompt),
                                 file_name: 'paste.txt',  //fileName(),
@@ -663,9 +675,9 @@ const updateParams = res => {
                                 file_type: 'txt'  //'text/plain'
                             });
                             prompt = 'r' === type ? Config.PromptExperimentFirst : Config.PromptExperimentNext;
-/****************************************************************/                            
+/******************************** */
                             splitedprompt.length > 1 && (prompt = prompt + splitedprompt[1]);
-/****************************************************************/                            
+/******************************** */
                         }
                         let res;
                         const body = {
@@ -695,7 +707,7 @@ const updateParams = res => {
                             headers
                         });
                         updateParams(res);
-                        await checkResErr(res);
+                        await checkResErr(res, CookieChanger); //await checkResErr(res);
                         return res;
                     })(signal, model, prompt, temperature, type));
                     const response = Writable.toWeb(res);
@@ -725,14 +737,13 @@ const updateParams = res => {
                         });
                     }
                 }
-                clearInterval(titleTimer);              
+                clearInterval(titleTimer);
                 if (clewdStream) {
                     clewdStream.censored && console.warn('likely your account is hard-censored');
                     prevImpersonated = clewdStream.impersonated;
                     setTitle('ok ' + bytesToSize(clewdStream.size));
-                    //console.log(`${200 == fetchAPI.status ? '' : ''}${fetchAPI.status}!\n`);
-/******************************** */                    
-                    429 == fetchAPI.status ? console.log(`Exceeded limit!\n`) : console.log(`${200 == fetchAPI.status ? '' : ''}${fetchAPI.status}!\n`);
+                    429 == fetchAPI.status ? console.log(`Exceeded limit!\n`) : console.log(`${200 == fetchAPI.status ? '' : ''}${fetchAPI.status}!\n`); //console.log(`${200 == fetchAPI.status ? '' : ''}${fetchAPI.status}!\n`);
+/******************************** */
                     changeflag += 1;
                     if (Config.CookieArray?.length > 0 && (429 == fetchAPI.status || (Config.Cookiecounter && changeflag >= Config.Cookiecounter))) {
                         changeflag = 0;
@@ -741,12 +752,11 @@ const updateParams = res => {
 /******************************** */
                     clewdStream.empty();
                 }
-                if (prevImpersonated) {
-                    try {
-                        await deleteChat(Conversation.uuid);
-                    } catch (err) {}
-                }
+                /*if (prevImpersonated) {
+                    await deleteChat(Conversation.uuid);
+                }*/
 /******************************** */
+                await deleteChat(Conversation.uuid);
                 changer && CookieChanger.emit('ChangeCookie');
 /******************************** */
             }));
@@ -762,15 +772,19 @@ const updateParams = res => {
         break;
 
       default:
-        req.url !== '/' && (console.log('unknown request: ' + req.url)); //console.log('unknown request: ' + req.url);
-        res.json({
+        !['/', '/v1', '/favicon.ico'].includes(req.url) && (console.log('unknown request: ' + req.url)); //console.log('unknown request: ' + req.url);
+        res.writeHead(200, {'Content-Type': 'text/html'});
+        res.write(`<!DOCTYPE html>\n<html>\n<head>\n<meta charset="utf-8">\n<script>\nfunction copyToClipboard(text) {\n  var textarea = document.createElement("textarea");\n  textarea.textContent = text;\n  textarea.style.position = "fixed";\n  document.body.appendChild(textarea);\n  textarea.select();\n  try {\n    return document.execCommand("copy");\n  } catch (ex) {\n    console.warn("Copy to clipboard failed.", ex);\n    return false;\n  } finally {\n    document.body.removeChild(textarea);\n  }\n}\nfunction copyLink(event) {\n  event.preventDefault();\n  const url = new URL(window.location.href);\n  const link = url.protocol + '//' + url.host + '/v1';\n  copyToClipboard(link);\n  alert('链接已复制: ' + link);\n}\n</script>\n</head>\n<body>\n${Main}<br/><br/>完全开源、免费且禁止商用<br/><br/>反向代理: <a href="v1" onclick="copyLink(event)">点击复制链接</a><br/>填入OpenAI API反向代理并选择OpenAI分类中的claude-2模型（酒馆需打开Show "External" models）<br/><br/>教程与FAQ: <a href="https://rentry.org/teralomaniac_clewd" target="FAQ">https://rentry.org/teralomaniac_clewd</a>\n</body>\n</html>`);
+        res.end();
+        /*res.json(
+            {
             error: {
                 message: '404 Not Found',
                 type: 404,
                 param: null,
                 code: 404
             }
-        }, 200);
+        }, 404);*/
     }
 }));
 
@@ -828,6 +842,7 @@ const updateParams = res => {
     Config.rProxy.endsWith('/') && (Config.rProxy = Config.rProxy.slice(0, -1));
     let uniqueArr = [], seen = new Set();
     for (let Cookie of Config.CookieArray) {
+        !/^sessionKey=/.test(Cookie) && (Cookie += 'sessionKey=');
         if (!seen.has(Cookie)) {
             uniqueArr.push(Cookie);
             seen.add(Cookie);

lib/clewd-stream.js

@@ -42,8 +42,6 @@ class ClewdStream extends TransformStream {
     #stopReason=void 0;
     #hardCensor=false;
     #impersonated=false;
-    #cookiechange=false;
-    #readonly=false;
     get size() {
         return this.#recvLength;
     }
@@ -68,7 +66,7 @@ class ClewdStream extends TransformStream {
     }
     #err(err, controller) {
         this.#logger?.write(JSON.stringify(err, null, 4));
-        const message = `## ${this.#version}\n**${AI.mdl()} error**:\n${err.status || err.code || err.type}\n\n\`\`\`${err.message}\`\`\``;
+        const message = `## ${this.#version}\n**${AI.mdl()} error**:\n${err.status || err.code || err.type}\n\n\`\`\`${err.message}\`\`\`\n\nFAQ: https://rentry.org/teralomaniac_clewd`;
         this.#enqueue(this.#build(message), controller);
         return this.#endEarly(controller);
     }
@@ -98,7 +96,7 @@ class ClewdStream extends TransformStream {
         this.#streaming ? this.#compOK.length > 0 && this.#enqueue(this.#build(this.#compOK), controller) : this.#enqueue(this.#build(this.#compAll.join('')), controller);
         this.#compAll?.[0] === Buffer.from([ 73, 32, 97, 112, 111, 108, 111, 103, 105, 122, 101, 44, 32, 98, 117, 116, 32, 73, 32, 119, 105, 108, 108, 32, 110, 111, 116, 32, 112, 114, 111, 118, 105, 100, 101, 32, 97, 110, 121, 32, 114, 101, 115, 112, 111, 110, 115, 101, 115, 32, 116, 104, 97, 116, 32, 118, 105, 111, 108, 97, 116, 101, 32, 65, 110, 116, 104, 114, 111, 112, 105, 99, 39, 115, 32, 65, 99, 99, 101, 112, 116, 97, 98, 108, 101, 32, 85, 115, 101, 32, 80, 111, 108, 105, 99, 121, 32, 111, 114, 32, 99, 111, 117, 108, 100, 32, 112, 114, 111, 109, 111, 116, 101, 32, 104, 97, 114, 109, 46 ]).toString() && (this.#hardCensor = true);
         if (!this.#ended && 0 === this.total) {
-            const err = `## ${this.#version}\n**error**:\n\n\`\`\`Received no valid replies at all\`\`\``;
+            const err = `## ${this.#version}\n**error**:\n\n\`\`\`Received no valid replies at all\`\`\`\n\nFAQ: https://rentry.org/teralomaniac_clewd`;
             this.#enqueue(this.#build(err), controller);
         }
         this.#streaming && this.#enqueue('data: [DONE]\n\n', controller);
@@ -157,7 +155,7 @@ class ClewdStream extends TransformStream {
                     },
                     status: this.#source.status,
                     superfetch: this.#source.superfetch
-                }), false);
+                }), false, false); //}), false);
                 delete err.stack;
                 return this.#err(err, controller);
             }

lib/clewd-utils.js

@@ -5,7 +5,7 @@
 'use strict';
 
 const {randomInt, randomBytes} = require('node:crypto'), {version: Version} = require('../package.json'), Encoder = (new TextDecoder, 
-new TextEncoder), Main = 'clewd v' + Version + '修改版 by tera', Replacements = {
+new TextEncoder), Main = 'clewd修改版 v' + Version + '(10) by tera', Replacements = {
     user: 'Human',
     assistant: 'Assistant',
     system: '',
@@ -13,8 +13,8 @@ new TextEncoder), Main = 'clewd v' + Version + '修改版 by tera', Replacements
     example_assistant: 'A'
 }, DangerChars = [ ...new Set([ ...Object.values(Replacements).join(''), ...'\n', ...':', ...'\\n' ]) ].filter((char => ' ' !== char)).sort(), AI = {
     end: () => Buffer.from([ 104, 116, 116, 112, 115, 58, 47, 47, 99, 108, 97, 117, 100, 101, 46, 97, 105 ]).toString(),
-    mdl: () => Buffer.from([ 99, 108, 97, 117, 100, 101, 45, 50 ]).toString(),
-    zone: () => Buffer.from([ 65, 109, 101, 114, 105, 99, 97, 47, 78, 101, 119, 95, 89, 111, 114, 107 ]).toString(),
+    mdl: () => Buffer.from([ 99, 108, 97, 117, 100, 101, 45, 50, 46, 49 ]).toString(),
+    zone: () => Buffer.from([ 65, 115, 105, 97, 47, 83, 104, 97, 110, 103, 104, 97, 105 ]).toString(), //Buffer.from([ 65, 109, 101, 114, 105, 99, 97, 47, 78, 101, 119, 95, 89, 111, 114, 107 ]).toString(),
     agent: () => Buffer.from([ 77, 111, 122, 105, 108, 108, 97, 47, 53, 46, 48, 32, 40, 77, 97, 99, 105, 110, 116, 111, 115, 104, 59, 32, 73, 110, 116, 101, 108, 32, 77, 97, 99, 32, 79, 83, 32, 88, 32, 49, 48, 95, 49, 53, 95, 55, 41, 32, 65, 112, 112, 108, 101, 87, 101, 98, 75, 105, 116, 47, 53, 51, 55, 46, 51, 54, 32, 40, 75, 72, 84, 77, 76, 44, 32, 108, 105, 107, 101, 32, 71, 101, 99, 107, 111, 41, 32, 67, 104, 114, 111, 109, 101, 47, 49, 49, 52, 46, 48, 46, 48, 46, 48, 32, 83, 97, 102, 97, 114, 105, 47, 53, 51, 55, 46, 51, 54, 32, 69, 100, 103, 47, 49, 49, 52, 46, 48, 46, 49, 56, 50, 51, 46, 55, 57 ]).toString(),
     cp: () => Buffer.from([ 55, 55, 49, 44, 52, 56, 54, 53, 45, 52, 56, 54, 54, 45, 52, 56, 54, 55, 45, 52, 57, 49, 57, 53, 45, 52, 57, 49, 57, 57, 45, 52, 57, 49, 57, 54, 45, 52, 57, 50, 48, 48, 45, 53, 50, 51, 57, 51, 45, 53, 50, 51, 57, 50, 45, 52, 57, 49, 55, 49, 45, 52, 57, 49, 55, 50, 45, 49, 53, 54, 45, 49, 53, 55, 45, 52, 55, 45, 53, 51, 44, 48, 45, 50, 51, 45, 54, 53, 50, 56, 49, 45, 49, 48, 45, 49, 49, 45, 51, 53, 45, 49, 54, 45, 53, 45, 49, 51, 45, 49, 56, 45, 53, 49, 45, 52, 53, 45, 52, 51, 45, 50, 55, 45, 49, 55, 53, 49, 51, 45, 50, 49, 44, 50, 57, 45, 50, 51, 45, 50, 52, 44, 48 ]).toString(),
     hdr: refPath => ({
@@ -42,7 +42,7 @@ module.exports.Replacements = Replacements;
 
 module.exports.DangerChars = DangerChars;
 
-module.exports.checkResErr = async (res, throwIt = true) => {
+module.exports.checkResErr = async (res, CookieChanger, throwIt = true) => { //module.exports.checkResErr = async (res, throwIt = true) => {
     let err, json, errAPI;
     if ('string' == typeof res) {
         json = JSON.parse(res);
@@ -61,6 +61,12 @@ module.exports.checkResErr = async (res, throwIt = true) => {
         if ((429 === res.status || 429 === json.status) && errAPI.resets_at) {
             const hours = ((new Date(1e3 * errAPI.resets_at).getTime() - Date.now()) / 1e3 / 60 / 60).toFixed(1);
             err.message += `, expires in ${hours} hours`;
+/************************** */
+            if (CookieChanger) {
+                console.log(`Exceeded limit!\n`);
+                CookieChanger && CookieChanger.emit('ChangeCookie');
+            }
+/************************** */
         }
         if (throwIt) {
             throw err;

package.json

@@ -1,7 +1,7 @@
 {
   "name": "clewd",
   "version": "4.6",
-  "description": ":^)",
+  "description": "<div align=\"center\"> <a href=\"https://github.com/teralomaniac/clewd\"> <h1>Clewd</h1>   <img     height=\"120\"     width=\"120\"     alt=\"Clewd\"     title=\"Clewd\"     src=\"https://gitgud.io/ahsk/clewd/-/raw/master/media/logo.png\"     align=\"left\"   />",
   "main": "clewd.js",
   "engines": {
     "node": ">=20.4.0"
@@ -35,5 +35,8 @@
   "bugs": {
     "url": "https://gitgud.io/ahsk/clewd/-/issues"
   },
-  "dependencies": {"localtunnel": "^2.0.2"}
+  "dependencies": {
+    "localtunnel": "^2.0.2",
+    "gpt-tokenizer": "^2.1.2"
+  }
 }