Dispark/edgetunnel
1
0
Fork 0
mirror of https://github.com/lush2020/edgetunnel.git synced 2026-03-24 09:08:16 +08:00
Code Issues Packages Projects Releases Wiki Activity

change node vless

Browse Source
This commit is contained in:
zizifn
2023-01-19 16:19:42 +00:00
committed by zizifn
parent 620c57e602
commit 23f7c46ac3
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
apps/node-vless/src/main.ts
View File

@@ -38,6 +38,9 @@ const server = createServer((req, resp) => {
// index page
if (url.pathname.includes(userID)) {
const index = 'dist/apps/cf-page/index.html';
resp.writeHead(200, {
'Content-Type': 'text/html,charset=UTF-8',
});
return createReadStream(index).pipe(resp);
}
if (req.method === 'GET' && url.pathname.startsWith('/assets')) {
@@ -82,11 +85,12 @@ vlessWServer.on('connection', async function connection(ws) {
.pipeTo(
new WritableStream({
async write(chunk: Buffer, controller) {
const vlessBuffer = chunk.buffer.slice(chunk.byteOffset);
if (remoteConnection) {
await wsAsyncWrite(remoteConnection, vlessBuffer);
await wsAsyncWrite(remoteConnection, chunk);
// remoteConnection.write(chunk);
return;
}
const vlessBuffer = chunk.buffer.slice(chunk.byteOffset);
const {
hasError,
message,
@@ -206,7 +210,7 @@ async function connect2Remote(port, host, log: Function): Promise<Socket> {
});
}
async function wsAsyncWrite(ws: Socket, chunk: ArrayBuffer) {
async function wsAsyncWrite(ws: Socket, chunk: Buffer) {
return new Promise((resolve, reject) => {
ws.write(Buffer.from(chunk), (error) => {
if (error) {