forked from noxious/server
Removed debugging code
This commit is contained in:
parent
9f7c48f2c2
commit
50d13af5d6
@ -6,7 +6,6 @@ export default class SomeJob {
|
|||||||
|
|
||||||
async execute(io: SocketServer, socket?: TSocket) {
|
async execute(io: SocketServer, socket?: TSocket) {
|
||||||
// Handle the event
|
// Handle the event
|
||||||
console.log('Event params:', this.params)
|
|
||||||
if (socket) {
|
if (socket) {
|
||||||
socket.emit('notification', { message: 'Something happened with socket' })
|
socket.emit('notification', { message: 'Something happened with socket' })
|
||||||
}
|
}
|
||||||
|
@ -49,7 +49,6 @@ class QueueManager {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private async processJob(job: Job) {
|
private async processJob(job: Job) {
|
||||||
console.log('Processing job:', job.data.jobName)
|
|
||||||
const { jobName, params, socketId } = job.data
|
const { jobName, params, socketId } = job.data
|
||||||
|
|
||||||
try {
|
try {
|
||||||
|
@ -2,7 +2,6 @@ import { Server } from 'socket.io'
|
|||||||
import { TSocket, ExtendedCharacter } from '../../utilities/types'
|
import { TSocket, ExtendedCharacter } from '../../utilities/types'
|
||||||
import CharacterRepository from '../../repositories/characterRepository'
|
import CharacterRepository from '../../repositories/characterRepository'
|
||||||
import CharacterManager from '../../managers/characterManager'
|
import CharacterManager from '../../managers/characterManager'
|
||||||
import QueueManager from '../../managers/queueManager'
|
|
||||||
|
|
||||||
type SocketResponseT = {
|
type SocketResponseT = {
|
||||||
character_id: number
|
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)
|
const character = await CharacterRepository.getByUserAndId(socket?.user?.id as number, data.character_id)
|
||||||
if (!character) return
|
if (!character) return
|
||||||
socket.characterId = character.id
|
socket.characterId = character.id
|
||||||
await QueueManager.newJob('SomeJob', { someParam: 'value' }, socket)
|
|
||||||
CharacterManager.initCharacter(character as ExtendedCharacter)
|
CharacterManager.initCharacter(character as ExtendedCharacter)
|
||||||
socket.emit('character:connect', character)
|
socket.emit('character:connect', character)
|
||||||
} catch (error: any) {
|
} catch (error: any) {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user