refactor: packets
This commit is contained in:
parent
865cd7a933
commit
4bdc0d9452
|
@ -1,19 +1,8 @@
|
||||||
import {gather} from '@latus/core';
|
|
||||||
|
|
||||||
import badPacketsCheck from '../packet/bad-packets-check';
|
|
||||||
import SocketClient from './socket';
|
import SocketClient from './socket';
|
||||||
|
|
||||||
export default {
|
export default {
|
||||||
hooks: {
|
hooks: {
|
||||||
'@latus/http/client/up': (latus) => {
|
'@latus/http/client/up': (latus) => {
|
||||||
// eslint-disable-next-line no-param-reassign
|
|
||||||
latus.config['%packets'] = gather(
|
|
||||||
latus,
|
|
||||||
'@latus/socket/packets',
|
|
||||||
'id',
|
|
||||||
'name',
|
|
||||||
badPacketsCheck,
|
|
||||||
);
|
|
||||||
const socket = new SocketClient(latus);
|
const socket = new SocketClient(latus);
|
||||||
socket.on('packet', (packet) => {
|
socket.on('packet', (packet) => {
|
||||||
if ('Refresh' === packet.constructor.name) {
|
if ('Refresh' === packet.constructor.name) {
|
||||||
|
|
|
@ -1,3 +1,6 @@
|
||||||
|
import {gather} from '@latus/core';
|
||||||
|
|
||||||
|
import badPacketsCheck from './packet/bad-packets-check';
|
||||||
import Bundle from './packet/bundle';
|
import Bundle from './packet/bundle';
|
||||||
import Refresh from './packet/refresh';
|
import Refresh from './packet/refresh';
|
||||||
|
|
||||||
|
@ -13,6 +16,16 @@ export default {
|
||||||
authenticate: [],
|
authenticate: [],
|
||||||
connect: [],
|
connect: [],
|
||||||
}),
|
}),
|
||||||
|
'@latus/core/starting': (latus) => {
|
||||||
|
// eslint-disable-next-line no-param-reassign
|
||||||
|
latus.config['%packets'] = gather(
|
||||||
|
latus,
|
||||||
|
'@latus/socket/packets',
|
||||||
|
'id',
|
||||||
|
'name',
|
||||||
|
badPacketsCheck,
|
||||||
|
);
|
||||||
|
},
|
||||||
'@latus/socket/packets': (latus) => ({
|
'@latus/socket/packets': (latus) => ({
|
||||||
Bundle: Bundle(latus),
|
Bundle: Bundle(latus),
|
||||||
Refresh,
|
Refresh,
|
||||||
|
|
|
@ -1,7 +1,5 @@
|
||||||
import {gather} from '@latus/core';
|
|
||||||
|
|
||||||
import {createSocketServer} from './lifecycle';
|
import {createSocketServer} from './lifecycle';
|
||||||
import badPacketsCheck from './packet/bad-packets-check';
|
|
||||||
import {fromName} from './packet/packets';
|
import {fromName} from './packet/packets';
|
||||||
|
|
||||||
const {
|
const {
|
||||||
|
@ -11,14 +9,6 @@ const {
|
||||||
export default {
|
export default {
|
||||||
hooks: {
|
hooks: {
|
||||||
'@latus/http/server/up': async (httpServer, latus) => {
|
'@latus/http/server/up': async (httpServer, latus) => {
|
||||||
// eslint-disable-next-line no-param-reassign
|
|
||||||
latus.config['%packets'] = gather(
|
|
||||||
latus,
|
|
||||||
'@latus/socket/packets',
|
|
||||||
'id',
|
|
||||||
'name',
|
|
||||||
badPacketsCheck,
|
|
||||||
);
|
|
||||||
createSocketServer(httpServer, latus);
|
createSocketServer(httpServer, latus);
|
||||||
},
|
},
|
||||||
'@latus/repl/context': (latus) => ({
|
'@latus/repl/context': (latus) => ({
|
||||||
|
|
Loading…
Reference in New Issue
Block a user