diff --git a/automatization.ts b/automatization.ts index 8c93140..bd8e082 100644 --- a/automatization.ts +++ b/automatization.ts @@ -467,6 +467,7 @@ export const doBotTasks=async function(client: telegram.TelegramClient,worker: A } catch( err){ if (err instanceof NoNewMessages){ logger.warn(`Target bot doesnt work | ${worker.phoneNumber}`); + logger.debug(err.message); await skipButton.click({sharePhone: false}); await waitNewMessages(client,worker,botEntity,prevTask.lastMessage.id); const cancelMessage=(await client.sendMessage(botEntity,{message:'/cancel'})); @@ -487,7 +488,18 @@ export const doBotTasks=async function(client: telegram.TelegramClient,worker: A }))[0].forwardTo(botEntity))![0]; } catch (err){ if (err instanceof telegram.errors.RPCError){ + + client.invoke(new telegram.Api.messages.DeleteHistory({ + justClear:true, + peer:botLink + })); + client.invoke( + new telegram.Api.contacts.Block({ + id: botLink, + })); + logger.warn(`Error when forwarding a message. Skipping task... | ${worker.phoneNumber}`); + logger.debug(err.message); await skipButton.click({sharePhone: false}); await waitNewMessages(client,worker,botEntity,prevTask.lastMessage.id); const cancelMessage=(await client.sendMessage(botEntity,{message:'/cancel'})); @@ -530,6 +542,16 @@ export const doBotTasks=async function(client: telegram.TelegramClient,worker: A logger.warn(`Forwarded message was old | ${worker.phoneNumber}`); } } else { + + client.invoke(new telegram.Api.messages.DeleteHistory({ + justClear:true, + peer:botLink + })); + client.invoke( + new telegram.Api.contacts.Block({ + id: botLink, + })); + logger.warn(`Message that i found is unknown | ${worker.phoneNumber}`); await skipButton.click({sharePhone: false}); await waitNewMessages(client,worker,botEntity,prevTask.lastMessage.id);