fix(*): handle createChannel command timeout (#30)

src/commands/create-channel.ts

@@ -1,8 +1,9 @@
-import { PermissionDeniedError } from '@/errors';
+import { CommandTimeout } from '@/config';
+import { CommandTimedOutError, PermissionDeniedError } from '@/errors';
 import { MumbleSocket } from '@/mumble-socket';
 import { filterPacket } from '@/rxjs-operators/filter-packet';
 import { ChannelState, PermissionDenied } from '@proto/Mumble';
-import { filter, race, take } from 'rxjs';
+import { filter, race, take, timer } from 'rxjs';
 
 export const createChannel = async (
   socket: MumbleSocket,
@@ -21,11 +22,14 @@ export const createChannel = async (
         take(1),
       ),
       socket.packet.pipe(filterPacket(PermissionDenied), take(1)),
+      timer(CommandTimeout),
     ).subscribe(packet => {
       if (PermissionDenied.is(packet)) {
         reject(new PermissionDeniedError(packet));
-      } else {
+      } else if (ChannelState.is(packet)) {
         resolve(packet.channelId as number);
+      } else {
+        reject(new CommandTimedOutError('createChannel'));
       }
     });
 

src/config.ts

@@ -0,0 +1 @@
+export const CommandTimeout = 5000;

src/errors/command-timed-out.error.ts

@@ -0,0 +1,5 @@
+export class CommandTimedOutError extends Error {
+  constructor(commandName: string) {
+    super(`command ${commandName} has timed out`);
+  }
+}

src/errors/index.ts

@@ -1,3 +1,4 @@
+export { CommandTimedOutError } from './command-timed-out.error';
 export { ConnectionRejectedError } from './connection-rejected.error';
 export { InsufficientPermissionsError } from './insufficient-permissions.error';
 export { NoSuchChannelError } from './no-such-channel.error';