mirror of
https://github.com/thedrewen/protojx-manager.git
synced 2026-03-21 09:48:56 +01:00
276 lines
9.3 KiB
TypeScript
276 lines
9.3 KiB
TypeScript
import ping from "ping";
|
||
import * as cron from 'cron';
|
||
import { ActivityType, Client, ContainerBuilder, MessageFlags } from "discord.js";
|
||
import { Host, InfraType } from "../type";
|
||
import { AppDataSource } from "../data-source";
|
||
import { HostsLog } from "../entity/hostslog.entity";
|
||
import { Repository } from "typeorm";
|
||
import { Follow } from "../entity/follow.entity";
|
||
|
||
export class StatusService {
|
||
|
||
public hosts: Host[] = [
|
||
{
|
||
'host': 'https://protojx.com',
|
||
'name': 'Protojx Website',
|
||
alive: false,
|
||
ping_type: 'website',
|
||
type: 'website',
|
||
notify: false
|
||
},
|
||
{
|
||
'host': 'https://manager.protojx.com',
|
||
'name': 'Espace Client',
|
||
alive: false,
|
||
ping_type: 'website',
|
||
type: 'website',
|
||
notify: false
|
||
},
|
||
{
|
||
host: '5.178.99.4',
|
||
name: 'RYZEN 01',
|
||
alive: false,
|
||
ping_type: 'ping',
|
||
type: 'ryzen',
|
||
notify: true
|
||
},
|
||
{
|
||
host: '5.178.99.6',
|
||
name: 'RYZEN 02',
|
||
alive: false,
|
||
ping_type: 'ping',
|
||
type: 'ryzen',
|
||
notify: true
|
||
},
|
||
{
|
||
host: '5.178.99.5',
|
||
name: 'RYZEN 03',
|
||
alive: false,
|
||
ping_type: 'ping',
|
||
type: 'ryzen',
|
||
notify: true
|
||
},
|
||
{
|
||
host: '154.16.254.10',
|
||
name: 'RYZEN7 04',
|
||
alive: false,
|
||
ping_type: 'ping',
|
||
type: 'ryzen',
|
||
notify: true
|
||
},
|
||
{
|
||
host: '5.178.99.177',
|
||
name: 'XEON 01 (2697A V4)',
|
||
alive: false,
|
||
ping_type: 'ping',
|
||
type: 'xeon',
|
||
notify: true
|
||
},
|
||
{
|
||
host: '5.178.99.248',
|
||
name: 'XEON 02 (2687W V4)',
|
||
alive: false,
|
||
ping_type: 'ping',
|
||
type: 'xeon',
|
||
notify: true
|
||
},
|
||
{
|
||
host: '5.178.99.53',
|
||
name: 'RYZEN-GAME 01',
|
||
alive: false,
|
||
ping_type: 'ping',
|
||
type: 'games',
|
||
notify: true
|
||
},
|
||
{
|
||
host: '5.178.99.63',
|
||
name: 'XEON-GAME 01',
|
||
alive: false,
|
||
ping_type: 'ping',
|
||
type: 'games',
|
||
notify: true
|
||
}
|
||
];
|
||
|
||
private client: Client | null = null;
|
||
private hostsLogRepo: Repository<HostsLog>;
|
||
private followRepo: Repository<Follow>;
|
||
|
||
constructor() {
|
||
|
||
this.hostsLogRepo = AppDataSource.getRepository(HostsLog);
|
||
this.followRepo = AppDataSource.getRepository(Follow);
|
||
|
||
setTimeout(async () => {
|
||
await this.fetch()
|
||
this.updateClientStatus();
|
||
}, 3000);
|
||
const cronJob = new cron.CronJob('*/2 * * * *', async () => {
|
||
|
||
// ? cleanup logs
|
||
const oneMonthAgo = new Date();
|
||
oneMonthAgo.setMonth(oneMonthAgo.getMonth() - 1);
|
||
this.hostsLogRepo.
|
||
createQueryBuilder()
|
||
.delete()
|
||
.from(HostsLog)
|
||
.where("created_at < :date", { date: oneMonthAgo })
|
||
.execute();
|
||
|
||
// ? Get status
|
||
try {
|
||
await this.fetch();
|
||
await this.updateClientStatus();
|
||
console.log('Status check completed at:', new Date().toISOString());
|
||
} catch (error) {
|
||
console.error('Error during status check:', error);
|
||
}
|
||
});
|
||
cronJob.start();
|
||
console.log('Status monitoring started - checking every 2 minutes');
|
||
}
|
||
|
||
setClient(client: Client) {
|
||
this.client = client;
|
||
this.client.user?.setActivity({ name: '💭 Server load and status...' })
|
||
}
|
||
|
||
private async updateClientStatus() {
|
||
if (this.client) {
|
||
const hosts = this.hosts.length;
|
||
const hostsAlive = this.hosts.filter((h) => h.alive).length;
|
||
|
||
this.client.user?.setActivity({
|
||
name: (
|
||
hosts == hostsAlive ? '✅ All services are online.' : `📛 ${hosts - hostsAlive} service${hosts - hostsAlive > 1 ? 's' : ''} offline.`
|
||
), type: ActivityType.Watching
|
||
});
|
||
}
|
||
}
|
||
|
||
private async fetchAlive(host: Host) {
|
||
|
||
const latestLog = await this.hostsLogRepo.findOne({ where: { host: host.host }, order: { created_at: 'DESC' } });
|
||
|
||
// ? Ping and Request Hosts
|
||
if (host.ping_type === 'ping') {
|
||
let res = await ping.promise.probe(host.host, { timeout: 10 });
|
||
host.alive = res.alive;
|
||
} else if (host.ping_type === 'website') {
|
||
try {
|
||
const response = await fetch(host.host, { method: 'HEAD', signal: AbortSignal.timeout(10000) });
|
||
host.alive = response.ok;
|
||
} catch (error) {
|
||
host.alive = false;
|
||
}
|
||
}
|
||
|
||
// ? Notification System :
|
||
if (!latestLog || latestLog.status != host.alive) {
|
||
const log = new HostsLog();
|
||
log.host = host.host;
|
||
log.status = host.alive;
|
||
|
||
this.hostsLogRepo.save(log);
|
||
|
||
if(latestLog) {
|
||
const users = await this.followRepo.find({where: {enable: true}});
|
||
users.forEach(async (user) => {
|
||
try {
|
||
const userdc = await this.client?.users.fetch(user.user_discord);
|
||
if(userdc) {
|
||
|
||
const container = new ContainerBuilder()
|
||
.setAccentColor(host.alive ? 0x00FF00 : 0xFF0000)
|
||
.addTextDisplayComponents((t) => t.setContent(`### 🔔 Status change alert`))
|
||
.addSeparatorComponents((s) => s)
|
||
.addTextDisplayComponents((t) => t.setContent(`${host.alive ? process.env.EMOJI_STATUS_ONLINE : process.env.EMOJI_STATUS_OFFLINE} **${host.name}** is now **${host.alive ? 'online' : 'offline'}**\n🏷️ Type : ${host.type}\n🕒 Time : <t:${Math.round(new Date().getTime()/1000)}:R>`));
|
||
|
||
userdc.send({components: [container], flags: [MessageFlags.IsComponentsV2]})
|
||
}
|
||
} catch (error) {}
|
||
});
|
||
}
|
||
}
|
||
|
||
return host;
|
||
}
|
||
|
||
private async fetch(max = 1): Promise<Host[]> {
|
||
|
||
const max_ping = 3;
|
||
|
||
const hosts = this.hosts.filter((value, index) => index < max * max_ping && index >= (max - 1) * max_ping);
|
||
|
||
const fetchPromises = hosts.map(host => this.fetchAlive(host));
|
||
const updatedHosts = await Promise.all(fetchPromises);
|
||
|
||
updatedHosts.forEach((updatedHost, index) => {
|
||
const originalIndex = (max - 1) * max_ping + index;
|
||
if (originalIndex < this.hosts.length) {
|
||
this.hosts[originalIndex] = updatedHost;
|
||
}
|
||
});
|
||
|
||
if (this.hosts.length > max * max_ping) {
|
||
await this.fetch(max + 1);
|
||
}
|
||
|
||
return this.hosts;
|
||
}
|
||
|
||
public getUpdatedContainer(): ContainerBuilder {
|
||
const hostTexts = this.hosts.map((s) => {
|
||
return { type: s.type, value: `- ${s.name} : ${s.alive ? `${process.env.EMOJI_STATUS_ONLINE} Online` : `${process.env.EMOJI_STATUS_OFFLINE} Offline`}` };
|
||
});
|
||
|
||
const container = new ContainerBuilder()
|
||
.setAccentColor(0x0000ed)
|
||
.addTextDisplayComponents((text) => text.setContent('# Status of protojx services'));
|
||
|
||
const sections: { title: string, type: InfraType, thumbnail: string }[] = [
|
||
{
|
||
title: 'Websites',
|
||
type: 'website',
|
||
thumbnail: 'https://protojx.com/assets/img/home2/agent.png'
|
||
},
|
||
{
|
||
title: 'Ryzens',
|
||
type: 'ryzen',
|
||
thumbnail: 'https://iconape.com/wp-content/png_logo_vector/ryzen.png'
|
||
},
|
||
{
|
||
title: 'Xeons',
|
||
type: 'xeon',
|
||
thumbnail: 'https://upload.wikimedia.org/wikipedia/commons/3/31/Intel-Xeon-Badge-2024.jpg'
|
||
},
|
||
{
|
||
title: 'Games',
|
||
type: 'games',
|
||
thumbnail: 'https://protojx.com/assets/img/hero-img.png'
|
||
}
|
||
]
|
||
|
||
sections.map((sectionData) => {
|
||
container.addSeparatorComponents((s) => s)
|
||
container.addSectionComponents(
|
||
(section) =>
|
||
section.addTextDisplayComponents(
|
||
(text) =>
|
||
text.setContent('## ' + sectionData.title + '\n' + hostTexts.filter((v) => v.type == sectionData.type).map((v) => v.value).join('\n'))
|
||
)
|
||
.setThumbnailAccessory(
|
||
(acc) =>
|
||
acc.setURL(sectionData.thumbnail)
|
||
)
|
||
)
|
||
});
|
||
|
||
const now = new Date();
|
||
container.addTextDisplayComponents((text) => text.setContent(`${now.getDate()}-${now.getMonth() + 1}-${now.getFullYear()} ${(now.getHours() + '').padStart(2, "0")}:${(now.getMinutes() + '').padStart(2, "0")} - Receive automatic notifications when there is an outage with /follow !`));
|
||
|
||
return container;
|
||
}
|
||
}
|
||
|
||
export default new StatusService(); |