This commit is contained in:
Nathan Bierema 2022-06-12 20:56:18 -04:00
parent ebf3625311
commit 8926238b35
3 changed files with 10 additions and 16 deletions

View File

@ -167,8 +167,7 @@ function handleConnection() {
authState: socket.authState,
socketState: socket.state,
},
// TODO Fix
// @ts-expect-error Because
// @ts-expect-error Is this legitimate?
error: data.authError,
});
if (socket.authState !== actions.AUTHENTICATED) {

View File

@ -90,11 +90,7 @@ if (argv.injectserver) {
// eslint-disable-next-line @typescript-eslint/no-floating-promises
server(argv).then(async function (r) {
if (argv.open && argv.open !== 'false') {
await r
.listener('ready')
.once()
.then(async () => {
await openApp(argv.open as string, options);
});
await r.listener('ready').once();
await openApp(argv.open as string, options);
}
});

View File

@ -17,7 +17,7 @@ export interface ExtendedOptions extends Options {
export default function (argv: { [arg: string]: any }): Promise<{
portAlreadyUsed?: boolean;
listener: (eventName: 'ready') => { once(): Promise<unknown> };
listener: (eventName: 'ready') => { once(): Promise<void> };
}> {
const options = Object.assign(getOptions(argv), {
allowClientPublish: false,
@ -135,19 +135,18 @@ export default function (argv: { [arg: string]: any }): Promise<{
for await (const data of socket.receiver('disconnect')) {
const channel = agServer.exchange.channel('sc-' + socket.id);
channel.unsubscribe();
// TODO
// void agServer.exchange.transmitPublish(channelToEmit, {
// id: socket.id,
// type: 'DISCONNECTED',
// });
// eslint-disable-next-line @typescript-eslint/no-non-null-assertion
void agServer.exchange.transmitPublish(channelToEmit!, {
id: socket.id,
type: 'DISCONNECTED',
});
}
})();
}
})();
httpServer.listen(options.port);
// TODO Fix
// @ts-expect-error Because
// @ts-expect-error Shouldn't there be a 'ready' event?
resolve(agServer);
}
/* eslint-enable no-console */