Fix timeout

Author: zyc9012

src/errors.ts

@@ -13,3 +13,10 @@ export class InvalidTimeoutError extends Error {
     Object.setPrototypeOf(this, InvalidTimeoutError.prototype);
   }
 }
+
+export class RequestTimeoutError extends Error {
+  constructor() {
+    super("The request was timed out");
+    Object.setPrototypeOf(this, RequestTimeoutError.prototype);
+  }
+}

src/utils.ts

@@ -2,6 +2,7 @@ import type { EngineName, EngineParameters } from "./types.ts";
 import { version } from "../version.ts";
 import https from "node:https";
 import qs from "node:querystring";
+import { RequestTimeoutError } from "./errors.ts";
 
 /**
  * This `_internals` object is needed to support stubbing/spying of
@@ -103,7 +104,7 @@ export function execute(
     source: getSource(),
   });
   return new Promise((resolve, reject) => {
-    https.get(url, { timeout }, (resp) => {
+    const req = https.get(url, (resp) => {
       let data = "";
 
       // A chunk of data has been recieved.
@@ -126,5 +127,12 @@ export function execute(
     }).on("error", (err) => {
       reject(err);
     });
+
+    if (timeout > 0) {
+      setTimeout(() => {
+        reject(new RequestTimeoutError());
+        req.destroy();
+      }, timeout);
+    }
   });
 }

tests/utils_test.ts

@@ -8,8 +8,8 @@ import {
 import { Stub, stub } from "https://deno.land/std@0.170.0/testing/mock.ts";
 import {
   assertEquals,
+  assertInstanceOf,
   assertMatch,
-  assertRejects,
 } from "https://deno.land/std@0.170.0/testing/asserts.ts";
 import {
   _internals,
@@ -19,6 +19,7 @@ import {
   getSource,
   haveParametersChanged,
 } from "../src/utils.ts";
+import { RequestTimeoutError } from "../src/errors.ts";
 
 loadSync({ export: true });
 const BASE_URL = Deno.env.get("ENV_TYPE") === "local"
@@ -230,9 +231,11 @@ describe("execute", {
     urlStub.restore();
   });
 
-  it("with short timeout", () => {
-    assertRejects(async () =>
-      await execute("/search", { q: "coffee", gl: "us" }, 1)
-    );
+  it("with short timeout", async () => {
+    try {
+      await execute("/search", { q: "coffee", gl: "us" }, 1);
+    } catch (e) {
+      assertInstanceOf(e, RequestTimeoutError);
+    }
   });
 });