Mohammed Foud commited on
Commit ·
4857c79
1
Parent(s): 1336397
all
Browse files- src/bots/services/auth.ts +1 -0
- src/services.ts +1 -28
src/bots/services/auth.ts
CHANGED
|
@@ -82,6 +82,7 @@ import {
|
|
| 82 |
}
|
| 83 |
}
|
| 84 |
|
|
|
|
| 85 |
private loggedInUsers: Map<number, boolean> = new Map();
|
| 86 |
|
| 87 |
public setUserLoggedIn(telegramId: number, isLoggedIn: boolean = true): void {
|
|
|
|
| 82 |
}
|
| 83 |
}
|
| 84 |
|
| 85 |
+
|
| 86 |
private loggedInUsers: Map<number, boolean> = new Map();
|
| 87 |
|
| 88 |
public setUserLoggedIn(telegramId: number, isLoggedIn: boolean = true): void {
|
src/services.ts
CHANGED
|
@@ -831,34 +831,7 @@ async function stopTaskProcess(taskId: string) {
|
|
| 831 |
}
|
| 832 |
}
|
| 833 |
|
| 834 |
-
//
|
| 835 |
-
async function setupMonitorTask(task: any) {
|
| 836 |
-
const interval = setInterval(async () => {
|
| 837 |
-
try {
|
| 838 |
-
const { senderUsernames, receiverUsernames } = task.taskData;
|
| 839 |
-
|
| 840 |
-
// Your monitoring logic here
|
| 841 |
-
for (const sender of senderUsernames) {
|
| 842 |
-
for (const receiver of receiverUsernames) {
|
| 843 |
-
// Implement your monitoring logic
|
| 844 |
-
await checkUserActivity(sender, receiver);
|
| 845 |
-
}
|
| 846 |
-
}
|
| 847 |
-
|
| 848 |
-
} catch (error) {
|
| 849 |
-
console.error(`Monitor task ${task.id} error:`, error);
|
| 850 |
-
// Handle error - maybe stop task if error is critical
|
| 851 |
-
}
|
| 852 |
-
}, 60000); // Adjust interval as needed
|
| 853 |
-
|
| 854 |
-
return {
|
| 855 |
-
interval,
|
| 856 |
-
cleanup: async () => {
|
| 857 |
-
// Any additional cleanup needed
|
| 858 |
-
}
|
| 859 |
-
};
|
| 860 |
-
}
|
| 861 |
-
|
| 862 |
// Example message task setup
|
| 863 |
async function setupMessageTask(task: any) {
|
| 864 |
// Implement message task logic
|
|
|
|
| 831 |
}
|
| 832 |
}
|
| 833 |
|
| 834 |
+
//
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 835 |
// Example message task setup
|
| 836 |
async function setupMessageTask(task: any) {
|
| 837 |
// Implement message task logic
|