generated and updated

bin/argumentTypes.js

@@ -1,3 +1,5 @@
+"use strict";
+
 const typeMaps = require("./typeMaps");
 
 module.exports = {

bin/index.js

@@ -1,9 +1,11 @@
+"use strict";
+
 const returnTypes = require("./returnTypes");
 const argumentTypes = require("./argumentTypes");
 const sortArguments = require("./sortArguments");
 const typeMaps = require("./typeMaps");
 const overrides = require("./overrides");
-const { getCommanderInterface } = require("@ioredis/interface-generator");
+const { getCommanderInterface } = require("@iovalkey/interface-generator");
 
 const HEADER = `/**
  * This file is generated by @ioredis/interface-generator.
@@ -13,7 +15,7 @@ const HEADER = `/**
 
 `;
 
-const ignoredCommands = ["monitor", "multi"];
+const ignoredCommands = ["monitor", "multi", "function"];
 const commands = require("@iovalkey/commands")
   .list.filter((name) => !ignoredCommands.includes(name))
   .sort();
@@ -24,7 +26,7 @@ const path = require("path");
 const template = fs.readFileSync(path.join(__dirname, "/template.ts"), "utf8");
 
 async function main() {
-  const interface = await getCommanderInterface({
+  const i = await getCommanderInterface({
     commands,
     complexityLimit: 50,
     redisOpts: {
@@ -49,7 +51,7 @@ async function main() {
 
   fs.writeFileSync(
     path.join(__dirname, "..", "lib/utils/RedisCommander.ts"),
-    HEADER + template.replace("////", () => interface)
+    HEADER + template.replace("////", () => i)
   );
 }
 

bin/overrides.js

@@ -1,3 +1,5 @@
+"use strict";
+
 const msetOverrides = {
   overwrite: false,
   defs: [

bin/returnTypes.js

@@ -1,3 +1,5 @@
+"use strict";
+
 const hasToken = (types, token) => {
   if (Array.isArray(token)) return token.some((t) => hasToken(types, t));
   return types.find((type) => type.includes(token));

lib/Command.ts

@@ -1,4 +1,4 @@
-import { exists, getKeyIndexes } from "@ioredis/commands";
+import { exists, getKeyIndexes } from "@iovalkey/commands";
 import * as calculateSlot from "cluster-key-slot";
 import asCallback from "standard-as-callback";
 import {

lib/Pipeline.ts

@@ -1,5 +1,5 @@
 import * as calculateSlot from "cluster-key-slot";
-import { exists, hasFlag } from "@ioredis/commands";
+import { exists, hasFlag } from "@iovalkey/commands";
 import asCallback from "standard-as-callback";
 import { deprecate } from "util";
 import Redis from "./Redis";

lib/Redis.ts

@@ -22,12 +22,7 @@
   ScanStreamOptions,
   WriteableStream,
 } from "./types";
-import {
-  CONNECTION_CLOSED_ERROR_MSG,
-  Debug,
-  isInt,
-  parseURL,
-} from "./utils";
+import { CONNECTION_CLOSED_ERROR_MSG, Debug, isInt, parseURL } from "./utils";
 import applyMixin from "./utils/applyMixin";
 import Commander from "./utils/Commander";
 import { defaults, noop } from "./utils/lodash";
@@ -524,7 +519,10 @@
         this.manuallyClosing = true;
       }
 
-      if (this.options.socketTimeout !== undefined && this.socketTimeoutTimer === undefined) {
+      if (
+        this.options.socketTimeout !== undefined &&
+        this.socketTimeoutTimer === undefined
+      ) {
         this.setSocketTimeout();
       }
     }
@@ -543,7 +541,11 @@
 
   private setSocketTimeout() {
     this.socketTimeoutTimer = setTimeout(() => {
-      this.stream.destroy(new Error(`Socket timeout. Expecting data, but didn't receive any in ${this.options.socketTimeout}ms.`));
+      this.stream.destroy(
+        new Error(
+          `Socket timeout. Expecting data, but didn't receive any in ${this.options.socketTimeout}ms.`
+        )
+      );
       this.socketTimeoutTimer = undefined;
     }, this.options.socketTimeout);
 
@@ -557,35 +559,35 @@
     });
   }
 
   scanStream(options?: ScanStreamOptions) {
     return this.createScanStream("scan", { options });
   }
 
   scanBufferStream(options?: ScanStreamOptions) {
     return this.createScanStream("scanBuffer", { options });
   }
 
   sscanStream(key: string, options?: ScanStreamOptions) {
     return this.createScanStream("sscan", { key, options });
   }
 
   sscanBufferStream(key: string, options?: ScanStreamOptions) {
     return this.createScanStream("sscanBuffer", { key, options });
   }
 
   hscanStream(key: string, options?: ScanStreamOptions) {
     return this.createScanStream("hscan", { key, options });
   }
 
   hscanBufferStream(key: string, options?: ScanStreamOptions) {
     return this.createScanStream("hscanBuffer", { key, options });
   }
 
   zscanStream(key: string, options?: ScanStreamOptions) {
     return this.createScanStream("zscan", { key, options });
   }
 
   zscanBufferStream(key: string, options?: ScanStreamOptions) {
     return this.createScanStream("zscanBuffer", { key, options });
   }
 
@@ -594,7 +596,7 @@
    *
    * @ignore
    */
   silentEmit(eventName: string, arg?: unknown): boolean {
     let error: unknown;
     if (eventName === "error") {
       error = arg;
@@ -629,7 +631,7 @@
   /**
    * @ignore
    */
   recoverFromFatalError(
     _commandError: Error,
     err: Error,
     options: FlushQueueOptions

lib/connectors/SentinelConnector/index.ts

@@ -169,7 +169,10 @@ export default class SentinelConnector extends AbstractConnector {
         if (this.options.enableTLSForSentinelMode && this.options.tls) {
           Object.assign(resolved, this.options.tls);
           this.stream = createTLSConnection(resolved);
-          this.stream.once("secureConnect", this.initFailoverDetector.bind(this));
+          this.stream.once(
+            "secureConnect",
+            this.initFailoverDetector.bind(this)
+          );
         } else {
           this.stream = createConnection(resolved);
           this.stream.once("connect", this.initFailoverDetector.bind(this));