nxbat/discordbot-ng
1
0
Fork 0
mirror of https://github.com/nx-bat/discordbot-ng.git synced 2026-09-22 10:29:10 -04:00
Code Issues Packages Projects Releases Wiki Activity

Fix line endings

Browse Source
This commit is contained in:
Tarrgon
2026-05-29 08:43:48 -04:00
parent 66d4bd4926
commit 6ad3ee5f23
98 changed files with 6528 additions and 6528 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/shared/RedisClient.ts
+49 -49
View File
@@ -1,50 +1,50 @@
import { createClient, SocketClosedUnexpectedlyError } from '@redis/client';
import { Client } from 'discord.js';
import { banUpdateHandler, ticketUpdateHandler } from '../utils';
let discordClient: Client;
export async function openRedisClient(url: string, discClient: Client) {
const client = await createClient({
url: `redis://${url}`,
socket: {
reconnectStrategy: 60000
}
});
client.on('error', (error) => {
if (error.code == 'ECONNREFUSED') {
console.error("Couldn't connect to redis database: Connection refused (is redis on? is the port reachable?)");
} else if (error instanceof SocketClosedUnexpectedlyError) {
console.error('Redis server closed unexpectedly. Attempting reconnect every 60 seconds.');
} else {
console.error('Redis error:');
console.error(error);
}
});
client.on('connect', () => {
console.log('Connected to redis database');
});
client.on('reconnecting', () => {
console.log('Attempting to reconnect to redis database');
});
client.once('connect', () => {
client.subscribe(['ticket_updates', 'ban_updates'], updateHandler);
});
client.connect();
discordClient = discClient;
}
function updateHandler(data: string, channel: string) {
switch (channel) {
case 'ticket_updates':
return ticketUpdateHandler(discordClient, data);
case 'ban_updates':
return banUpdateHandler(discordClient, data);
}
import { createClient, SocketClosedUnexpectedlyError } from '@redis/client';
import { Client } from 'discord.js';
import { banUpdateHandler, ticketUpdateHandler } from '../utils';
let discordClient: Client;
export async function openRedisClient(url: string, discClient: Client) {
const client = await createClient({
url: `redis://${url}`,
socket: {
reconnectStrategy: 60000
}
});
client.on('error', (error) => {
if (error.code == 'ECONNREFUSED') {
console.error("Couldn't connect to redis database: Connection refused (is redis on? is the port reachable?)");
} else if (error instanceof SocketClosedUnexpectedlyError) {
console.error('Redis server closed unexpectedly. Attempting reconnect every 60 seconds.');
} else {
console.error('Redis error:');
console.error(error);
}
});
client.on('connect', () => {
console.log('Connected to redis database');
});
client.on('reconnecting', () => {
console.log('Attempting to reconnect to redis database');
});
client.once('connect', () => {
client.subscribe(['ticket_updates', 'ban_updates'], updateHandler);
});
client.connect();
discordClient = discClient;
}
function updateHandler(data: string, channel: string) {
switch (channel) {
case 'ticket_updates':
return ticketUpdateHandler(discordClient, data);
case 'ban_updates':
return banUpdateHandler(discordClient, data);
}
}