mfx/tk-ws-scrcpy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

刷直播

Browse Source
This commit is contained in:
没复习
2025-08-04 13:14:26 +08:00
parent d1f2452b28
commit 2b7d48e807
1 changed files with 22 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
src/server/mw/WebsocketProxy.ts
View File

@@ -289,6 +289,8 @@ export class WebsocketProxy extends Mw {
time = 2
} else if (parsedMessage.type == 'CommentText') {
time = 5
} else if (parsedMessage.type == 'isHead') {
time = 20
}
console.log("time", time)
@@ -343,6 +345,9 @@ export class WebsocketProxy extends Mw {
} else if (parsedMessage.type == 'hostVideo') {
console.log('第' + parsedMessage.num + '个节点')
bounds = targetNodeList[parsedMessage.num].bounds; // 选择节点列表中的第一个节点
} else if (parsedMessage.type == 'isHead') {
this.ws.send(JSON.stringify({ type: parsedMessage.type, status: 'success', message: 1, udid: parsedMessage.udid, index: parsedMessage.index }));
return;
} else {
console.log('第一个节点')
bounds = targetNodeList[0].bounds; // 选择节点列表中的第一个节点
@@ -363,6 +368,12 @@ export class WebsocketProxy extends Mw {
this.ws.send(JSON.stringify({ type: parsedMessage.type, status: 'success', message: '坐标返回', udid: parsedMessage.udid, index: parsedMessage.index, x: clickX, y: clickY }));
return;
}
if (parsedMessage.type == 'isOneLive') {
console.log('复制坐标');
this.ws.send(JSON.stringify({ type: parsedMessage.type, status: 'success', message: 1, udid: parsedMessage.udid, index: parsedMessage.index, x: clickX, y: clickY }));
return;
}
exec(`adb -s ${parsedMessage.udid} shell input tap ${clickX} ${clickY}`, (clickErr: Error | null) => {
if (clickErr) {
// this.ws.send(JSON.stringify({ status: 'error', message: '点击失败：' + clickErr.message }));
@@ -390,9 +401,16 @@ export class WebsocketProxy extends Mw {
if (parsedMessage.type == 'isHost') {
this.ws.send(JSON.stringify({ type: parsedMessage.type, status: 'success', message: 0, udid: parsedMessage.udid, index: parsedMessage.index }));
return;
} else if (parsedMessage.type == 'isOneLive') {
this.ws.send(JSON.stringify({ type: parsedMessage.type, status: 'success', message: 0, udid: parsedMessage.udid, index: parsedMessage.index }));
return;
} else if (parsedMessage.type == 'isHead') {
this.ws.send(JSON.stringify({ type: parsedMessage.type, status: 'success', message: 0, udid: parsedMessage.udid, index: parsedMessage.index }));
return;
} else {
this.ws.send(JSON.stringify({ status: 'error', type: parsedMessage.type, message: '未找到按钮' }));
console.log('未找到按钮')
console.log('未找到按钮', parsedMessage.index, parsedMessage.type)
}
}
@@ -482,6 +500,7 @@ export class WebsocketProxy extends Mw {
this.ws.send(JSON.stringify({ type: parsedMessage.type, status: 'success', message: '坐标返回', udid: parsedMessage.udid, index: parsedMessage.index, x: clickX, y: clickY }));
return;
}
exec(`adb -s ${parsedMessage.udid} shell input tap ${clickX} ${clickY}`, (clickErr: Error | null) => {
if (clickErr) {
// this.ws.send(JSON.stringify({ status: 'error', message: '点击失败：' + clickErr.message }));
@@ -511,7 +530,8 @@ export class WebsocketProxy extends Mw {
return;
} else {
this.ws.send(JSON.stringify({ status: 'error', type: parsedMessage.type, message: '未找到按钮' }));
console.log('未找到按钮')
console.log('未找到按钮', parsedMessage.index, parsedMessage.type)
}
}