mirror of
https://github.com/tiramisulabs/seyfert.git
synced 2025-07-01 20:46:08 +00:00
fix: make handlePayload partial in workers
This commit is contained in:
parent
13c79bdc19
commit
10d66a221e
@ -24,6 +24,9 @@
|
||||
"correctness": {
|
||||
"noUnusedVariables": "off"
|
||||
},
|
||||
"nursery": {
|
||||
"useImportRestrictions": "off"
|
||||
},
|
||||
"complexity": {
|
||||
"noUselessLoneBlockStatements": "warn",
|
||||
"noBannedTypes": "off",
|
||||
|
@ -24,9 +24,7 @@ const ShardManagerDefaults: Partial<ShardManagerOptions> = {
|
||||
const WorkerManagerDefaults: Partial<WorkerManagerOptions> = {
|
||||
...ShardManagerDefaults,
|
||||
shardsPerWorker: 32,
|
||||
handlePayload: (shardId: number, workerId: number, packet: GatewayDispatchPayload): void => {
|
||||
console.info(`Packet ${packet.t} on shard ${shardId} worker ${workerId}`);
|
||||
},
|
||||
handlePayload: (_shardId: number, _workerId: number, _packet: GatewayDispatchPayload): void => {},
|
||||
};
|
||||
|
||||
export interface IdentifyProperties {
|
||||
|
@ -5,10 +5,10 @@ import { MemoryAdapter, type Adapter } from '../../cache';
|
||||
import { BaseClient, type InternalRuntimeConfig } from '../../client/base';
|
||||
import {
|
||||
Logger,
|
||||
type MakePartial,
|
||||
MergeOptions,
|
||||
type GatewayPresenceUpdateData,
|
||||
type GatewaySendPayload,
|
||||
type MakePartial,
|
||||
} from '../../common';
|
||||
import { WorkerManagerDefaults } from '../constants';
|
||||
import { SequentialBucket } from '../structures';
|
||||
@ -26,7 +26,7 @@ export class WorkerManager extends Map<number, Worker & { ready?: boolean }> {
|
||||
memberUpdateHandler = new MemberUpdateHandler();
|
||||
presenceUpdateHandler = new PresenceUpdateHandler();
|
||||
rest!: ApiHandler;
|
||||
constructor(options: MakePartial<WorkerManagerOptions, 'token' | 'intents' | 'info'>) {
|
||||
constructor(options: MakePartial<WorkerManagerOptions, 'token' | 'intents' | 'info' | 'handlePayload'>) {
|
||||
super();
|
||||
this.options = MergeOptions<Required<WorkerManagerOptions>>(WorkerManagerDefaults, options);
|
||||
this.cacheAdapter = new MemoryAdapter();
|
||||
|
Loading…
x
Reference in New Issue
Block a user