fix(nice-grpc-client-middleware-deadline): Skip deadline when signal …

…is already aborted (#472)

packages/nice-grpc-client-middleware-deadline/src/index.test.ts

@@ -107,3 +107,39 @@ test('relative deadline', async () => {
 
   await server.shutdown();
 });
+
+test('already aborted', async () => {
+  const server = createServer();
+
+  server.add(TestService, {
+    async testUnary(request: TestRequest, {signal}) {
+      return new TestResponse();
+    },
+    testServerStream: throwUnimplemented,
+    testClientStream: throwUnimplemented,
+    testBidiStream: throwUnimplemented,
+  });
+
+  const port = await server.listen('127.0.0.1:0');
+
+  const channel = createChannel(`127.0.0.1:${port}`);
+  const client = createClientFactory()
+    .use(deadlineMiddleware)
+    .create(TestService, channel);
+
+  const abortController = new AbortController();
+  abortController.abort();
+
+  const promise = client.testUnary(new TestRequest(), {
+    deadline: new Date(Date.now() + 500),
+    signal: abortController.signal,
+  });
+
+  await expect(promise).rejects.toMatchInlineSnapshot(
+    `[AbortError: The operation has been aborted]`,
+  );
+
+  channel.close();
+
+  await server.shutdown();
+});

packages/nice-grpc-client-middleware-deadline/src/index.ts

@@ -18,7 +18,7 @@ export type DeadlineOptions = {
  */
 export const deadlineMiddleware: ClientMiddleware<DeadlineOptions> =
   async function* deadlineMiddleware(call, options) {
-    if (options.deadline == null) {
+    if (options.deadline == null || options.signal?.aborted) {
       return yield* call.next(call.request, options);
     }