diff --git a/src/jobs/SomeJob.ts b/src/jobs/SomeJob.ts index f547f4c..9009868 100644 --- a/src/jobs/SomeJob.ts +++ b/src/jobs/SomeJob.ts @@ -6,7 +6,6 @@ export default class SomeJob { async execute(io: SocketServer, socket?: TSocket) { // Handle the event - console.log('Event params:', this.params) if (socket) { socket.emit('notification', { message: 'Something happened with socket' }) } diff --git a/src/managers/queueManager.ts b/src/managers/queueManager.ts index c0bb095..ab54911 100644 --- a/src/managers/queueManager.ts +++ b/src/managers/queueManager.ts @@ -49,7 +49,6 @@ class QueueManager { } private async processJob(job: Job) { - console.log('Processing job:', job.data.jobName) const { jobName, params, socketId } = job.data try { diff --git a/src/socketEvents/character/connect.ts b/src/socketEvents/character/connect.ts index 3be6b4a..7527efc 100644 --- a/src/socketEvents/character/connect.ts +++ b/src/socketEvents/character/connect.ts @@ -2,7 +2,6 @@ import { Server } from 'socket.io' import { TSocket, ExtendedCharacter } from '../../utilities/types' import CharacterRepository from '../../repositories/characterRepository' import CharacterManager from '../../managers/characterManager' -import QueueManager from '../../managers/queueManager' type SocketResponseT = { character_id: number @@ -15,7 +14,7 @@ export default function (io: Server, socket: TSocket) { const character = await CharacterRepository.getByUserAndId(socket?.user?.id as number, data.character_id) if (!character) return socket.characterId = character.id - await QueueManager.newJob('SomeJob', { someParam: 'value' }, socket) + CharacterManager.initCharacter(character as ExtendedCharacter) socket.emit('character:connect', character) } catch (error: any) {