minicx/hk_bot
1
0
Fork 0
Code Issues 3 Pull requests Releases 1 Activity
hk_bot/automatization.ts

547 lines
28 KiB
TypeScript
Raw Normal View History

some changes
2022-12-02 16:41:38 +01:00
import Hero from "@ulixee/hero";
vertification
2022-12-02 18:38:40 +01:00
import * as telegram from 'telegram';
import { sleep } from "telegram/Helpers";
some changes
2022-12-02 16:41:38 +01:00
import { AccountInterface } from "./interfaces/databaseInterface";
many test changes
2022-12-03 15:43:20 +01:00
import { prevTaskInterface } from "./interfaces/otherInterfaces";
...
2022-12-02 19:42:03 +01:00
import logger from "./logger";
add bot tasks support
2022-12-11 22:44:05 +01:00
import { getMessagesByEntity, NoNewMessages, waitNewMessages } from "./utils";
1.Fixed database issue of overwriting accounts? 2.Fixed issue with unblocking hkbot 3.Fixed logic of getting messages modified: automatization.ts modified: database.ts modified: index.ts modified: interfaces/databaseInterface.d.ts modified: utils.ts
2022-12-07 18:46:23 +01:00
import {settings} from './database'
add verifing of settings
2022-12-06 12:24:13 +01:00
import { isNull } from "lodash";
some changes
2022-12-02 16:41:38 +01:00
multiple fixes of generating groups
2022-12-04 16:52:54 +01:00
export const vertification=async function (client: telegram.TelegramClient,worker: AccountInterface,hero: Hero,url: string,botEntity: telegram.Api.Chat | telegram.Api.User,idOfLastMessage: number) {
add bot tasks support
2022-12-11 22:44:05 +01:00
await hero.goto(url,{timeoutMs:2_000_000});
1.Fixed database issue of overwriting accounts? 2.Fixed issue with unblocking hkbot 3.Fixed logic of getting messages modified: automatization.ts modified: database.ts modified: index.ts modified: interfaces/databaseInterface.d.ts modified: utils.ts
2022-12-07 18:46:23 +01:00
await hero.waitForLoad('AllContentLoaded',{timeoutMs:1180_000});
vertification
2022-12-02 18:38:40 +01:00
const captchaButton=hero.document.querySelector('button.g-recaptcha.btn.btn-primary');
if (captchaButton!=null){
let verify=hero.document.querySelector('body > section > h2');
while (verify!=null && (await verify.textContent)!.includes('All right!')==false){
...
2022-12-02 19:42:03 +01:00
const isCaptchaPassed=hero.document.querySelector("input[id='recaptcha-token']");
temp
2022-12-03 06:37:20 +01:00
if (isCaptchaPassed==null || await isCaptchaPassed.$isVisible==false){
...
2022-12-02 19:42:03 +01:00
await hero.interact({click:{element: captchaButton, verification: 'exactElement'}});
await sleep(5000);
verify=hero.document.querySelector('body > section > h2');
} else {
logger.error("catpcha detected");
throw new Error("Auhtung captcha detected");
}
vertification
2022-12-02 18:38:40 +01:00
}
} else {
throw new Error('Cant find captcha button');
}
...
2022-12-02 19:42:03 +01:00
}
chats task
2022-12-05 19:07:39 +01:00
export const doSitesTasks=async function (client: telegram.TelegramClient,worker: AccountInterface,hero: Hero,botEntity: telegram.Api.Chat | telegram.Api.User,tasksSelector: telegram.Api.Message) {
...
2022-12-02 19:42:03 +01:00
const taskSitesButton=tasksSelector.buttons![1][0];
many test changes
2022-12-03 15:43:20 +01:00
let prevTask: prevTaskInterface={
...
2022-12-02 19:42:03 +01:00
task:tasksSelector,
lastMessage:tasksSelector
};
multiple fixes of generating groups
2022-12-04 16:52:54 +01:00
mainLoop:
...
2022-12-02 19:42:03 +01:00
while (true){
many fixes
2022-12-06 15:11:23 +01:00
await sleep(2000);
...
2022-12-02 19:42:03 +01:00
await taskSitesButton.click({sharePhone: false});
await waitNewMessages(client,worker,botEntity,prevTask.lastMessage.id);
const task=(await client.getMessages(botEntity,{
minId:prevTask.lastMessage.id,
// search: (await settings.botMessages()).tasksSelector,
}))[0];
if (task.buttonCount==2){
add verifing of settings
2022-12-06 12:24:13 +01:00
temp
2022-12-03 06:37:20 +01:00
logger.debug(`New ad task | ${worker.phoneNumber}`);
add verifing of settings
2022-12-06 12:24:13 +01:00
temp
2022-12-03 06:37:20 +01:00
const urlButton=task.buttons![0][0];
const skipButton=task.buttons![0][1];
add bot tasks support
2022-12-11 22:44:05 +01:00
await hero.goto(urlButton.url!,{timeoutMs:2_000_000});
1.Fixed database issue of overwriting accounts? 2.Fixed issue with unblocking hkbot 3.Fixed logic of getting messages modified: automatization.ts modified: database.ts modified: index.ts modified: interfaces/databaseInterface.d.ts modified: utils.ts
2022-12-07 18:46:23 +01:00
await hero.waitForLoad('AllContentLoaded',{timeoutMs:1180_000});
add verifing of settings
2022-12-06 12:24:13 +01:00
new logic of site tasks
2022-12-10 23:27:49 +01:00
temp
2022-12-03 06:37:20 +01:00
let captchaButton=hero.document.querySelector('button.g-recaptcha.btn.btn-primary');
new logic of site tasks
2022-12-10 23:27:49 +01:00
if (isNull(captchaButton) && (await hero.activeTab.url).includes('hkbots')){
add verifing of settings
2022-12-06 12:24:13 +01:00
if (prevTask.task.message==task.message){
logger.warn(`Same tasks detected on ${worker.phoneNumber}... Skipping due captcha isnt detected......`);
await skipButton.click({sharePhone: false});
fixes of fixes
2022-12-09 17:38:09 +01:00
await waitNewMessages(client,worker,botEntity,task.id);
prevTask.task=task;
prevTask.lastMessage=(await client.getMessages(botEntity,{
new logic of site tasks
2022-12-10 23:27:49 +01:00
minId:task.id
}))[0];
add verifing of settings
2022-12-06 12:24:13 +01:00
} else {
prevTask.task=task;
logger.warn(`Captcha isnt detected... | ${worker.phoneNumber}`);
new logic of site tasks
2022-12-10 23:27:49 +01:00
}
} else {
prevTask.task=task;
if ((await hero.activeTab.url).includes('hkbots')){
if (await captchaButton.$isClickable!=true){
// timer page
logger.warn(`Found timer... | ${worker.phoneNumber}`);
if (settings.bypassMode==true){
logger.warn(`Bypassing timer... | ${worker.phoneNumber}`);
try{
await hero.executeJs("document.getElementById('form').setAttribute('style', '')");
} catch (err){
logger.error(`Something went wrong due bypass`);
}
} else {
while (hero.document.querySelector("i[id='timer']")!=null && await captchaButton.$isClickable!=true){
await sleep(1000);
}
temp
2022-12-03 06:37:20 +01:00
}
}
new logic of site tasks
2022-12-10 23:27:49 +01:00
const now=new Date();
while (await hero.activeTab.url==urlButton.url!){
if ((+(new Date())-+now)/1000>2*60){
1.Fixed database issue of overwriting accounts? 2.Fixed issue with unblocking hkbot 3.Fixed logic of getting messages modified: automatization.ts modified: database.ts modified: index.ts modified: interfaces/databaseInterface.d.ts modified: utils.ts
2022-12-07 18:46:23 +01:00
await skipButton.click({sharePhone: false});
await waitNewMessages(client,worker,botEntity,task.id);
prevTask.task=task;
prevTask.lastMessage=(await client.getMessages(botEntity,{
new logic of site tasks
2022-12-10 23:27:49 +01:00
minId:task.id
}))[0];
logger.warn(`Anomaly activity in browser. Please checkout`);
1.Fixed database issue of overwriting accounts? 2.Fixed issue with unblocking hkbot 3.Fixed logic of getting messages modified: automatization.ts modified: database.ts modified: index.ts modified: interfaces/databaseInterface.d.ts modified: utils.ts
2022-12-07 18:46:23 +01:00
continue mainLoop;
new logic of site tasks
2022-12-10 23:27:49 +01:00
} else {
const isCaptchaPassed=hero.document.querySelector("input[id='recaptcha-token']");
if ((isNull(isCaptchaPassed) || (await isCaptchaPassed.$isVisible)==false) ){
if (await captchaButton.$isClickable){
try{
await hero.interact({click:{element: captchaButton, verification: 'exactElement'}});
} catch (err){
logger.warn(`Some error due clicking | ${worker.phoneNumber}`);
continue mainLoop;
}
}
await sleep(1000);
captchaButton=hero.document.querySelector('button.g-recaptcha.btn.btn-primary');
} else {
logger.error(`Captcha detected | ${worker.phoneNumber}`);
throw new Error("Captcha detected");
temp
2022-12-03 06:37:20 +01:00
}
1.Fixed database issue of overwriting accounts? 2.Fixed issue with unblocking hkbot 3.Fixed logic of getting messages modified: automatization.ts modified: database.ts modified: index.ts modified: interfaces/databaseInterface.d.ts modified: utils.ts
2022-12-07 18:46:23 +01:00
}
}
temp
2022-12-03 06:37:20 +01:00
}
1.Fixed database issue of overwriting accounts? 2.Fixed issue with unblocking hkbot 3.Fixed logic of getting messages modified: automatization.ts modified: database.ts modified: index.ts modified: interfaces/databaseInterface.d.ts modified: utils.ts
2022-12-07 18:46:23 +01:00
await waitNewMessages(client,worker,botEntity,task.id);
const afterTask:telegram.Api.Message=(await client.getMessages(botEntity,{
minId:task.id,
limit:100
})).filter((value)=>{return value.message.includes(settings.botMessages.taskComplete)})[0];
prevTask.lastMessage=(await client.getMessages(botEntity,{
new logic of site tasks
2022-12-10 23:27:49 +01:00
minId:task.id
temp
2022-12-03 06:37:20 +01:00
}))[0];
new logic of site tasks
2022-12-10 23:27:49 +01:00
if (afterTask!=null){ // need update
temp
2022-12-03 06:37:20 +01:00
if (afterTask.message.includes(settings.botMessages.taskComplete)==true){
temp fix of issue of overwriting
2022-12-07 19:36:04 +01:00
logger.info(`Site task complete | ${worker.phoneNumber}`);
temp
2022-12-03 06:37:20 +01:00
continue
}
}
}
...
2022-12-02 19:42:03 +01:00
} else if (task.message.includes(settings.botMessages.taskOver)==true){
1.Fixed database issue of overwriting accounts? 2.Fixed issue with unblocking hkbot 3.Fixed logic of getting messages modified: automatization.ts modified: database.ts modified: index.ts modified: interfaces/databaseInterface.d.ts modified: utils.ts
2022-12-07 18:46:23 +01:00
logger.info(`Ad tasks completed | ${worker.phoneNumber}`);
...
2022-12-02 19:42:03 +01:00
break
} else {
logger.error(`Check out last message of ${worker.phoneNumber}`);
throw new Error(`Check out last message of ${worker.phoneNumber}`)
}
}
chats task
2022-12-05 19:07:39 +01:00
}
export const doChatsTasks=async function (client: telegram.TelegramClient,worker: AccountInterface,hero: Hero,botEntity: telegram.Api.Chat | telegram.Api.User,tasksSelector: telegram.Api.Message){
const taskChatsButton=tasksSelector.buttons![1][1];
let prevTask: prevTaskInterface={
task:tasksSelector,
lastMessage:tasksSelector
};
mainLoop:
while (true){
many fixes
2022-12-06 15:11:23 +01:00
await sleep(2000);
chats task
2022-12-05 19:07:39 +01:00
await taskChatsButton.click({sharePhone: false});
await waitNewMessages(client,worker,botEntity,prevTask.lastMessage.id);
const task=(await client.getMessages(botEntity,{
minId:prevTask.lastMessage.id,
// search: (await settings.botMessages()).tasksSelector,
}))[0];
if (task.buttonCount==3){
add verifing of settings
2022-12-06 12:24:13 +01:00
chats task
2022-12-05 19:07:39 +01:00
logger.info(`New chat task | ${worker.phoneNumber}`);
add verifing of settings
2022-12-06 12:24:13 +01:00
chats task
2022-12-05 19:07:39 +01:00
const urlButton=task.buttons![0][0];
const confirmButton=task.buttons![0][1];
const skipButton=task.buttons![0][2];
let groupLink='';
if (urlButton.url?.includes('hkbot')==true){
add bot tasks support
2022-12-11 22:44:05 +01:00
await hero.goto(urlButton.url,{timeoutMs:2_000_000});
1.Fixed database issue of overwriting accounts? 2.Fixed issue with unblocking hkbot 3.Fixed logic of getting messages modified: automatization.ts modified: database.ts modified: index.ts modified: interfaces/databaseInterface.d.ts modified: utils.ts
2022-12-07 18:46:23 +01:00
await hero.waitForLoad('AllContentLoaded',{timeoutMs:1180_000});
chats task
2022-12-05 19:07:39 +01:00
let captchaButton=hero.document.querySelector('button.g-recaptcha.btn.btn-primary');
add verifing of settings
2022-12-06 12:24:13 +01:00
if (isNull(captchaButton)){
if (prevTask.task.message==task.message){
logger.warn(`Same tasks detected on ${worker.phoneNumber}... Skipping due captcha isnt detected......`);
await skipButton.click({sharePhone: false});
1.Fixed database issue of overwriting accounts? 2.Fixed issue with unblocking hkbot 3.Fixed logic of getting messages modified: automatization.ts modified: database.ts modified: index.ts modified: interfaces/databaseInterface.d.ts modified: utils.ts
2022-12-07 18:46:23 +01:00
await waitNewMessages(client,worker,botEntity,task.id);
prevTask.task=task;
prevTask.lastMessage=(await client.getMessages(botEntity,{
minId:task.id
}))[0];
add verifing of settings
2022-12-06 12:24:13 +01:00
} else {
prevTask.task=task;
1.Fixed database issue of overwriting accounts? 2.Fixed issue with unblocking hkbot 3.Fixed logic of getting messages modified: automatization.ts modified: database.ts modified: index.ts modified: interfaces/databaseInterface.d.ts modified: utils.ts
2022-12-07 18:46:23 +01:00
prevTask.lastMessage=task;
add verifing of settings
2022-12-06 12:24:13 +01:00
logger.warn(`Captcha isnt detected... | ${worker.phoneNumber}`);
}
continue mainLoop;
}
1.Fixed database issue of overwriting accounts? 2.Fixed issue with unblocking hkbot 3.Fixed logic of getting messages modified: automatization.ts modified: database.ts modified: index.ts modified: interfaces/databaseInterface.d.ts modified: utils.ts
2022-12-07 18:46:23 +01:00
const now=new Date()
chats task
2022-12-05 19:07:39 +01:00
while (captchaButton!=null && await hero.activeTab.url==urlButton.url!){
1.Fixed database issue of overwriting accounts? 2.Fixed issue with unblocking hkbot 3.Fixed logic of getting messages modified: automatization.ts modified: database.ts modified: index.ts modified: interfaces/databaseInterface.d.ts modified: utils.ts
2022-12-07 18:46:23 +01:00
if ((+(new Date())-+now)/1000>2*60){
if ( (await captchaButton.$isClickable)==false){
await skipButton.click({sharePhone: false});
await waitNewMessages(client,worker,botEntity,task.id);
prevTask.task=task;
prevTask.lastMessage=(await client.getMessages(botEntity,{
minId:task.id
}))[0];
continue mainLoop;
}
logger.warn(`Anomaly activity in browser. Please checkout`);
await hero.reload();
}
chats task
2022-12-05 19:07:39 +01:00
const isCaptchaPassed=hero.document.querySelector("input[id='recaptcha-token']");
if ((isCaptchaPassed==null || await isCaptchaPassed.$isVisible==false) ){
if (await captchaButton.$isClickable){
try {
await hero.interact({click:{element: captchaButton, verification: 'exactElement'}});
} catch( err){
logger.warn(`Some error due clicking | ${worker.phoneNumber}`);
continue mainLoop;
}
}
await sleep(1000);
captchaButton=hero.document.querySelector('button.g-recaptcha.btn.btn-primary');
} else {
logger.error("catpcha detected");
throw new Error("Auhtung captcha detected");
}
}
groupLink=await hero.url;
} else {
groupLink=urlButton.url!;
}
// https://gram.js.org/tl/messages/GetFullChat
// hash checking
let group:telegram.Api.Channel | undefined;
if (!/(^\w+:|^)\/\/(?:t|telegram)\.(?:me|dog)\/(joinchat\/|\+)([\w-]+)/i.test(groupLink)){
groupLink=groupLink.replace(/(^\w+:|^)\/\/(?:t|telegram)\.(?:me|dog)\//i,'');
try {
group=(((await client.invoke(
new telegram.Api.channels.JoinChannel({
channel:groupLink
})
)) as telegram.Api.Updates).chats[0] as telegram.Api.Channel)
} catch (err: unknown){
if (err instanceof telegram.errors.RPCError){
switch (err.errorMessage) {
case 'CHANNELS_TOO_MUCH':
logger.warn(`Too much groups | ${worker.phoneNumber}`);
return;
case 'USER_ALREADY_PARTICIPANT':
logger.warn(`Already in group | ${worker.phoneNumber}`)
group=(await client.invoke(
new telegram.Api.channels.GetChannels({
id:[groupLink]
})
))[0]
break;
default:
logger.warn(`Something wrong with chat ${err.errorMessage} | ${worker.phoneNumber}`)
await skipButton.click({sharePhone: false});
await waitNewMessages(client,worker,botEntity,task.id);
1.Fixed database issue of overwriting accounts? 2.Fixed issue with unblocking hkbot 3.Fixed logic of getting messages modified: automatization.ts modified: database.ts modified: index.ts modified: interfaces/databaseInterface.d.ts modified: utils.ts
2022-12-07 18:46:23 +01:00
prevTask.task=task;
prevTask.lastMessage=(await client.getMessages(botEntity,{
minId:task.id
}))[0];
chats task
2022-12-05 19:07:39 +01:00
continue mainLoop;
}
}
}
} else {
// hash
groupLink=groupLink.replace(/(^\w+:|^)\/\/(?:t|telegram)\.(?:me|dog)\/(joinchat\/|\+)/i,'');
try {
group=(((await client.invoke(
new telegram.Api.messages.ImportChatInvite({
hash:groupLink
})
)) as telegram.Api.Updates).chats[0] as telegram.Api.Channel)
} catch (err: unknown){
if (err instanceof telegram.errors.RPCError){
switch (err.errorMessage) {
case 'CHANNELS_TOO_MUCH':
logger.warn(`Too much groups | ${worker.phoneNumber}`);
return;
case 'USER_ALREADY_PARTICIPANT':
logger.warn(`Already in group | ${worker.phoneNumber}`)
group=((await client.invoke(
new telegram.Api.messages.CheckChatInvite({
hash:groupLink
})
)) as telegram.Api.ChatInviteAlready).chat as telegram.Api.Channel
break;
default:
logger.warn(`Something wrong with chat ${err.errorMessage} | ${worker.phoneNumber}`)
await skipButton.click({sharePhone: false});
await waitNewMessages(client,worker,botEntity,task.id);
1.Fixed database issue of overwriting accounts? 2.Fixed issue with unblocking hkbot 3.Fixed logic of getting messages modified: automatization.ts modified: database.ts modified: index.ts modified: interfaces/databaseInterface.d.ts modified: utils.ts
2022-12-07 18:46:23 +01:00
prevTask.task=task;
prevTask.lastMessage=(await client.getMessages(botEntity,{
minId:task.id
}))[0];
chats task
2022-12-05 19:07:39 +01:00
continue mainLoop;
}
}
}
}
await confirmButton.click({sharePhone: false});
1.Fixed database issue of overwriting accounts? 2.Fixed issue with unblocking hkbot 3.Fixed logic of getting messages modified: automatization.ts modified: database.ts modified: index.ts modified: interfaces/databaseInterface.d.ts modified: utils.ts
2022-12-07 18:46:23 +01:00
await waitNewMessages(client,worker,botEntity,task.id);
const afterTask=(await client.getMessages(botEntity,{
minId: task.id,
limit:100
})).filter((value)=>{
if (value.message.includes(settings.botMessages.notInGroup) || value.message.includes(settings.botMessages.taskComplete)){
return true
} else {
return false
}
})[0];
const lastMessage=(await client.getMessages(botEntity,{
minId: task.id
chats task
2022-12-05 19:07:39 +01:00
}))[0];
1.Fixed database issue of overwriting accounts? 2.Fixed issue with unblocking hkbot 3.Fixed logic of getting messages modified: automatization.ts modified: database.ts modified: index.ts modified: interfaces/databaseInterface.d.ts modified: utils.ts
2022-12-07 18:46:23 +01:00
prevTask.task=task;
prevTask.lastMessage=(lastMessage!==undefined) ? lastMessage: afterTask ;
if (afterTask.message.includes(settings.botMessages.taskComplete)==true){
worker.completedGroupsTasks.push(
{
timeToLeave: +(new Date())+Number(afterTask.message.replace(/\D/g,''))*3600*1_000,
groupID:(await client.getPeerId(group!))
}
);
temp fix of issue of overwriting
2022-12-07 19:36:04 +01:00
logger.info(`Chat task complete | ${worker.phoneNumber}`);
1.Fixed database issue of overwriting accounts? 2.Fixed issue with unblocking hkbot 3.Fixed logic of getting messages modified: automatization.ts modified: database.ts modified: index.ts modified: interfaces/databaseInterface.d.ts modified: utils.ts
2022-12-07 18:46:23 +01:00
continue;
} else if (afterTask.message.includes(settings.botMessages.notInGroup)==true){
logger.warn(`User joined but hk says not. Skipping...`)
await skipButton.click({sharePhone: false});
await waitNewMessages(client,worker,botEntity,task.id);
add verifing of settings
2022-12-06 12:24:13 +01:00
prevTask.task=task;
1.Fixed database issue of overwriting accounts? 2.Fixed issue with unblocking hkbot 3.Fixed logic of getting messages modified: automatization.ts modified: database.ts modified: index.ts modified: interfaces/databaseInterface.d.ts modified: utils.ts
2022-12-07 18:46:23 +01:00
prevTask.lastMessage=(await client.getMessages(botEntity,{
minId:task.id,
chats task
2022-12-05 19:07:39 +01:00
// search: (await settings.botMessages()).tasksSelector,
1.Fixed database issue of overwriting accounts? 2.Fixed issue with unblocking hkbot 3.Fixed logic of getting messages modified: automatization.ts modified: database.ts modified: index.ts modified: interfaces/databaseInterface.d.ts modified: utils.ts
2022-12-07 18:46:23 +01:00
}))[0];
worker.completedGroupsTasks.push(
{
timeToLeave: 1,
groupID:(await client.getPeerId(group!))
}
);
} else {
logger.debug(`Anomaly | ${worker.phoneNumber}`);
logger.debug(task.message);
chats task
2022-12-05 19:07:39 +01:00
}
}else if (task.message.includes(settings.botMessages.taskOver)==true){
logger.info(`Chats tasks completed | ${worker.phoneNumber}`)
break
} else {
logger.error(`Check out last message of ${worker.phoneNumber}`);
throw new Error(`Check out last message of ${worker.phoneNumber}`)
}
}
add bot tasks support
2022-12-11 22:44:05 +01:00
}
export const doBotTasks=async function(client: telegram.TelegramClient,worker: AccountInterface,hero: Hero,botEntity: telegram.Api.Chat | telegram.Api.User,tasksSelector: telegram.Api.Message) {
const taskBotsButton=tasksSelector.buttons![1][2];
let prevTask: prevTaskInterface={
task:tasksSelector,
lastMessage:tasksSelector
};
mainLoop:
while (true){
await sleep(2000);
await taskBotsButton.click({sharePhone: false});
await waitNewMessages(client,worker,botEntity,prevTask.lastMessage.id);
let task: telegram.Api.Message;
[(prevTask.lastMessage),task]=(await client.getMessages(botEntity,{
minId:prevTask.lastMessage.id,
limit:2
}));
if (task===undefined){
task=prevTask.lastMessage
}
if (task.buttonCount==3){
logger.info(`New bot task | ${worker.phoneNumber}`);
const urlButton=task.buttons![0][0];
const skipButton=task.buttons![0][1];
let botLink='@';
if (urlButton.url?.includes('hkbot')==true){
await hero.goto(urlButton.url,{timeoutMs:2_000_000});
await hero.waitForLoad('AllContentLoaded',{timeoutMs:1180_000});
let captchaButton=hero.document.querySelector('button.g-recaptcha.btn.btn-primary');
if (isNull(captchaButton)){
if (prevTask.task.message==task.message){
logger.warn(`Same tasks detected on ${worker.phoneNumber}... Skipping due captcha isnt detected......`);
await skipButton.click({sharePhone: false});
} else {
logger.warn(`Captcha isnt detected... | ${worker.phoneNumber}`);
}
await waitNewMessages(client,worker,botEntity,prevTask.lastMessage.id);
const cancelMessage=(await client.sendMessage(botEntity,{message:'/cancel'}));
await waitNewMessages(client,worker,botEntity,cancelMessage.id);
prevTask.lastMessage=(await client.getMessages(botEntity,{
minId:cancelMessage.id
}))[0];
prevTask.task=task;
continue mainLoop;
}
const now=new Date()
while (captchaButton!=null && await hero.activeTab.url==urlButton.url!){
if ((+(new Date())-+now)/1000>2*60){
if ( (await captchaButton.$isClickable)==false){
await skipButton.click({sharePhone: false});
await waitNewMessages(client,worker,botEntity,prevTask.lastMessage.id);
const cancelMessage=(await client.sendMessage(botEntity,{message:'/cancel'}));
await waitNewMessages(client,worker,botEntity,cancelMessage.id);
prevTask.lastMessage=(await client.getMessages(botEntity,{
minId:cancelMessage.id
}))[0];
prevTask.task=task;
continue mainLoop;
}
logger.warn(`Anomaly activity in browser. Please checkout`);
await hero.reload();
}
const isCaptchaPassed=hero.document.querySelector("input[id='recaptcha-token']");
if ((isCaptchaPassed==null || await isCaptchaPassed.$isVisible==false) ){
if (await captchaButton.$isClickable){
try {
await hero.interact({click:{element: captchaButton, verification: 'exactElement'}});
} catch( err){
logger.warn(`Some error due clicking | ${worker.phoneNumber}`);
continue mainLoop;
}
}
await sleep(1000);
captchaButton=hero.document.querySelector('button.g-recaptcha.btn.btn-primary');
} else {
logger.error("catpcha detected");
throw new Error("Auhtung captcha detected");
}
}
botLink+=(await hero.url).replace(/(^\w+:|^)\/\/(?:t|telegram)\.(?:me|dog)\//i,'')!.replace(/(?:\?start=)[A-Za-z0-9]+/i,'')!
} else {
botLink+=urlButton.url?.replace(/(^\w+:|^)\/\/(?:t|telegram)\.(?:me|dog)\//i,'')!.replace(/(?:\?start=)[A-Za-z0-9]+/i,'')!
}
await client.invoke(
new telegram.Api.contacts.Unblock({
id: botLink
}));
try{
await waitNewMessages(client,worker,botLink,(await client.sendMessage(botLink,{message:'/start'})).id);
} catch( err){
if (err instanceof NoNewMessages){
await skipButton.click({sharePhone: false});
await waitNewMessages(client,worker,botEntity,prevTask.lastMessage.id);
const cancelMessage=(await client.sendMessage(botEntity,{message:'/cancel'}));
await waitNewMessages(client,worker,botEntity,cancelMessage.id);
prevTask.lastMessage=(await client.getMessages(botEntity,{
minId:cancelMessage.id
}))[0];
prevTask.task=task;
continue mainLoop;
} else {
throw err
}
}
added handler of forwarding massges
2022-12-12 12:04:23 +01:00
let forwardMessage: telegram.Api.Message;
try{
forwardMessage=(await (await getMessagesByEntity(client,botLink,botLink,{
limit:1000
}))[0].forwardTo(botEntity))![0];
} catch (err){
if (err instanceof telegram.errors.RPCError){
await skipButton.click({sharePhone: false});
await waitNewMessages(client,worker,botEntity,prevTask.lastMessage.id);
const cancelMessage=(await client.sendMessage(botEntity,{message:'/cancel'}));
await waitNewMessages(client,worker,botEntity,cancelMessage.id);
prevTask.lastMessage=(await client.getMessages(botEntity,{
minId:cancelMessage.id
}))[0];
prevTask.task=task;
continue mainLoop;
} else {
throw err
}
}
add bot tasks support
2022-12-11 22:44:05 +01:00
logger.debug(`Forwarded ID is ${forwardMessage.id}`)
await waitNewMessages(client,worker,botEntity,prevTask.lastMessage.id);
const afterTask=(await client.getMessages(botEntity,{
minId: prevTask.lastMessage.id,
limit:10
})).filter((value)=>{
if (value.message.includes(settings.botMessages.taskComplete) || value.message.includes(settings.botMessages.oldMessage)){
return true
} else {
return false
}
})[0];
if (afterTask.message.includes(settings.botMessages.taskComplete)==true){
await client.invoke(new telegram.Api.messages.DeleteHistory({
justClear:true,
peer:botLink
}))
await client.invoke(
new telegram.Api.contacts.Block({
id: botLink,
})
);
logger.info(`Bot task complete | ${worker.phoneNumber}`);
} else if (afterTask.message.includes(settings.botMessages.oldMessage)){
logger.warn(`Forwarded message was old | ${worker.phoneNumber}`);
}
const cancelMessage=(await client.sendMessage(botEntity,{message:'/cancel'}));
await waitNewMessages(client,worker,botEntity,cancelMessage.id);
const lastMessage=(await client.getMessages(botEntity,{
minId: cancelMessage.id
}))[0];
prevTask.task=task;
prevTask.lastMessage=(lastMessage!==undefined) ? lastMessage: afterTask ;
continue;
} else if (task.message.includes(settings.botMessages.taskOver)==true){
logger.info(`Bots tasks completed | ${worker.phoneNumber}`)
break
} else {
logger.error(`Check out last message of ${worker.phoneNumber}`);
throw new Error(`Check out last message of ${worker.phoneNumber}`)
}
}
some changes
2022-12-02 16:41:38 +01:00
}
Reference in a new issue Copy permalink