temp fix of issue of overwriting
This commit is contained in:
parent
88fddfc3bc
commit
6fa2e3bdf4
3 changed files with 3 additions and 5 deletions
|
@ -139,7 +139,7 @@ export const doSitesTasks=async function (client: telegram.TelegramClient,worker
|
||||||
}))[0];
|
}))[0];
|
||||||
if (afterTask!=null){
|
if (afterTask!=null){
|
||||||
if (afterTask.message.includes(settings.botMessages.taskComplete)==true){
|
if (afterTask.message.includes(settings.botMessages.taskComplete)==true){
|
||||||
logger.debug(`Site task complete | ${worker.phoneNumber}`);
|
logger.info(`Site task complete | ${worker.phoneNumber}`);
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -347,7 +347,7 @@ export const doChatsTasks=async function (client: telegram.TelegramClient,worker
|
||||||
groupID:(await client.getPeerId(group!))
|
groupID:(await client.getPeerId(group!))
|
||||||
}
|
}
|
||||||
);
|
);
|
||||||
logger.debug(`Chat task complete | ${worker.phoneNumber}`);
|
logger.info(`Chat task complete | ${worker.phoneNumber}`);
|
||||||
continue;
|
continue;
|
||||||
} else if (afterTask.message.includes(settings.botMessages.notInGroup)==true){
|
} else if (afterTask.message.includes(settings.botMessages.notInGroup)==true){
|
||||||
logger.warn(`User joined but hk says not. Skipping...`)
|
logger.warn(`User joined but hk says not. Skipping...`)
|
||||||
|
|
2
index.ts
2
index.ts
|
@ -146,7 +146,7 @@ const farm: () => Promise<void> = async () => {
|
||||||
|
|
||||||
workersLoop:
|
workersLoop:
|
||||||
for (const worker of workersGroups) {
|
for (const worker of workersGroups) {
|
||||||
logger.debug(`Current worker:${worker.phoneNumber}\nBalance:${worker.balance}`);
|
logger.info(`Current worker:${worker.phoneNumber}\nBalance:${worker.balance}`);
|
||||||
|
|
||||||
{
|
{
|
||||||
const torConnection = await connect({
|
const torConnection = await connect({
|
||||||
|
|
2
utils.ts
2
utils.ts
|
@ -117,9 +117,7 @@ export const startNewTorDocker=async function(proxyPort: number,socksPort: numbe
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
logger.debug(`Creating container with this ports ${proxyPort} ${socksPort} ${controlPort}`);
|
|
||||||
const container=await docker.createContainer(options);
|
const container=await docker.createContainer(options);
|
||||||
|
|
||||||
await container.start();
|
await container.start();
|
||||||
|
|
||||||
const progressBar=mainProgressBar.create(timeout/2, 0,{status:`Starting docker${(settings.logLevel=='debug') ? ` ${proxyPort} ${socksPort} ${controlPort}` : ''}`});
|
const progressBar=mainProgressBar.create(timeout/2, 0,{status:`Starting docker${(settings.logLevel=='debug') ? ` ${proxyPort} ${socksPort} ${controlPort}` : ''}`});
|
||||||
|
|
Loading…
Reference in a new issue