fix: added aggressive connection keepalive timeout

Author: divmgl

dist/cjs/index.cjs

@@ -7306,6 +7306,8 @@ var require_dist = __commonJS({
 var index_exports = {};
 __export(index_exports, {
   JackdClient: () => JackdClient,
+  JackdError: () => JackdError,
+  JackdErrorCode: () => JackdErrorCode,
   default: () => index_default
 });
 module.exports = __toCommonJS(index_exports);
@@ -7415,6 +7417,23 @@ function camelCase(input, options) {
 
 // src/types.ts
 var DELIMITER = "\r\n";
+var JackdErrorCode = /* @__PURE__ */ ((JackdErrorCode2) => {
+  JackdErrorCode2["OUT_OF_MEMORY"] = "OUT_OF_MEMORY";
+  JackdErrorCode2["INTERNAL_ERROR"] = "INTERNAL_ERROR";
+  JackdErrorCode2["BAD_FORMAT"] = "BAD_FORMAT";
+  JackdErrorCode2["UNKNOWN_COMMAND"] = "UNKNOWN_COMMAND";
+  JackdErrorCode2["EXPECTED_CRLF"] = "EXPECTED_CRLF";
+  JackdErrorCode2["JOB_TOO_BIG"] = "JOB_TOO_BIG";
+  JackdErrorCode2["DRAINING"] = "DRAINING";
+  JackdErrorCode2["TIMED_OUT"] = "TIMED_OUT";
+  JackdErrorCode2["DEADLINE_SOON"] = "DEADLINE_SOON";
+  JackdErrorCode2["NOT_FOUND"] = "NOT_FOUND";
+  JackdErrorCode2["NOT_IGNORED"] = "NOT_IGNORED";
+  JackdErrorCode2["INVALID_RESPONSE"] = "INVALID_RESPONSE";
+  JackdErrorCode2["NOT_CONNECTED"] = "NOT_CONNECTED";
+  JackdErrorCode2["FATAL_CONNECTION_ERROR"] = "FATAL_CONNECTION_ERROR";
+  return JackdErrorCode2;
+})(JackdErrorCode || {});
 var JackdError = class extends Error {
   /** Error code indicating the type of error */
   code;
@@ -7495,7 +7514,7 @@ var JackdClient = class {
   }
   createSocket() {
     this.socket = new import_net.Socket();
-    this.socket.setKeepAlive(true);
+    this.socket.setKeepAlive(true, 3e4);
     this.socket.on("ready", () => {
       this.connected = true;
       void this.processNextCommand();
@@ -8273,5 +8292,7 @@ function findIndex(array, subarray) {
 }
 // Annotate the CommonJS export names for ESM import in node:
 0 && (module.exports = {
-  JackdClient
+  JackdClient,
+  JackdError,
+  JackdErrorCode
 });

dist/esm/index.js

@@ -7409,6 +7409,23 @@ function camelCase(input, options) {
 
 // src/types.ts
 var DELIMITER = "\r\n";
+var JackdErrorCode = /* @__PURE__ */ ((JackdErrorCode2) => {
+  JackdErrorCode2["OUT_OF_MEMORY"] = "OUT_OF_MEMORY";
+  JackdErrorCode2["INTERNAL_ERROR"] = "INTERNAL_ERROR";
+  JackdErrorCode2["BAD_FORMAT"] = "BAD_FORMAT";
+  JackdErrorCode2["UNKNOWN_COMMAND"] = "UNKNOWN_COMMAND";
+  JackdErrorCode2["EXPECTED_CRLF"] = "EXPECTED_CRLF";
+  JackdErrorCode2["JOB_TOO_BIG"] = "JOB_TOO_BIG";
+  JackdErrorCode2["DRAINING"] = "DRAINING";
+  JackdErrorCode2["TIMED_OUT"] = "TIMED_OUT";
+  JackdErrorCode2["DEADLINE_SOON"] = "DEADLINE_SOON";
+  JackdErrorCode2["NOT_FOUND"] = "NOT_FOUND";
+  JackdErrorCode2["NOT_IGNORED"] = "NOT_IGNORED";
+  JackdErrorCode2["INVALID_RESPONSE"] = "INVALID_RESPONSE";
+  JackdErrorCode2["NOT_CONNECTED"] = "NOT_CONNECTED";
+  JackdErrorCode2["FATAL_CONNECTION_ERROR"] = "FATAL_CONNECTION_ERROR";
+  return JackdErrorCode2;
+})(JackdErrorCode || {});
 var JackdError = class extends Error {
   /** Error code indicating the type of error */
   code;
@@ -7489,7 +7506,7 @@ var JackdClient = class {
   }
   createSocket() {
     this.socket = new Socket();
-    this.socket.setKeepAlive(true);
+    this.socket.setKeepAlive(true, 3e4);
     this.socket.on("ready", () => {
       this.connected = true;
       void this.processNextCommand();
@@ -8267,5 +8284,7 @@ function findIndex(array, subarray) {
 }
 export {
   JackdClient,
+  JackdError,
+  JackdErrorCode,
   index_default as default
 };

dist/types/index.d.ts

@@ -232,3 +232,4 @@ export declare class JackdClient {
     listTubeUsed: () => Promise<string>;
 }
 export default JackdClient;
+export { JackdError, JackdErrorCode } from "./types";

package.json

@@ -1,6 +1,6 @@
 {
   "name": "jackd",
-  "version": "4.0.5",
+  "version": "4.0.7",
   "description": "Modern beanstalkd client for Node.js",
   "type": "module",
   "exports": {

src/index.ts

@@ -115,7 +115,7 @@ export class JackdClient {
 
   private createSocket() {
     this.socket = new Socket()
-    this.socket.setKeepAlive(true)
+    this.socket.setKeepAlive(true, 30_000)
 
     this.socket.on("ready", () => {
       this.connected = true
@@ -1012,3 +1012,5 @@ function findIndex(array: Uint8Array, subarray: Uint8Array): number {
   }
   return -1
 }
+
+export { JackdError, JackdErrorCode } from "./types"