reduce no-explicit-any

src/modules/AbstractModule.ts

@@ -61,18 +61,19 @@ export abstract class AbstractModule<
         return this.testDone(false);
     }
 
-    async _test(key: string, process: () => Promise<any>) {
+    async _test(key: string, process: () => Promise<unknown>) {
         this._log(`Testing ${key}`, LOG_LEVEL_VERBOSE);
         try {
             const ret = await process();
             if (ret !== true) {
-                this.addTestResult(key, false, ret.toString());
-                return this.testFail(`${key} failed: ${ret}`);
+                this.addTestResult(key, false, String(ret));
+                return this.testFail(`${key} failed: ${String(ret)}`);
             }
             this.addTestResult(key, true, "");
-        } catch (ex: any) {
-            this.addTestResult(key, false, "Failed by Exception", ex.toString());
-            return this.testFail(`${key} failed: ${ex}`);
+        } catch (ex) {
+            const exStr = String(ex);
+            this.addTestResult(key, false, "Failed by Exception", exStr);
+            return this.testFail(`${key} failed: ${exStr}`);
         }
         return this.testDone();
     }

src/modules/ModuleTypes.ts

@@ -7,7 +7,8 @@ export type OverridableFunctionsKeys<T> = {
 
 export type ChainableExecuteFunction<T> = {
     [K in keyof T as K extends `$${string}`
-        ? T[K] extends (...args: any) => ChainableFunctionResult
+        ? // eslint-disable-next-line @typescript-eslint/no-explicit-any
+          T[K] extends (...args: any) => ChainableFunctionResult
             ? K
             : never
         : never]: T[K];
@@ -26,26 +27,30 @@ export type ChainableFunctionResultOrAll = Promise<boolean | undefined | string
 
 type AllExecuteFunction<T> = {
     [K in keyof T as K extends `$all${string}`
-        ? T[K] extends (...args: any[]) => ChainableFunctionResultOrAll
+        ? // eslint-disable-next-line @typescript-eslint/no-explicit-any
+          T[K] extends (...args: any[]) => ChainableFunctionResultOrAll
             ? K
             : never
         : never]: T[K];
 };
 type EveryExecuteFunction<T> = {
     [K in keyof T as K extends `$every${string}`
-        ? T[K] extends (...args: any[]) => ChainableFunctionResult
+        ? // eslint-disable-next-line @typescript-eslint/no-explicit-any
+          T[K] extends (...args: any[]) => ChainableFunctionResult
             ? K
             : never
         : never]: T[K];
 };
 type AnyExecuteFunction<T> = {
     [K in keyof T as K extends `$any${string}`
-        ? T[K] extends (...args: any[]) => ChainableFunctionResult
+        ? // eslint-disable-next-line @typescript-eslint/no-explicit-any
+          T[K] extends (...args: any[]) => ChainableFunctionResult
             ? K
             : never
         : never]: T[K];
 };
 type InjectableFunction<T> = {
+    // eslint-disable-next-line @typescript-eslint/no-explicit-any
     [K in keyof T as K extends `$$${string}` ? (T[K] extends (...args: any[]) => any ? K : never) : never]: T[K];
 };
 export type AllExecuteProps = AllExecuteFunction<LiveSyncCore>;

src/modules/core/ModuleReplicator.ts

@@ -21,7 +21,7 @@ import { MARK_LOG_NETWORK_ERROR } from "@lib/services/lib/logUtils";
 
 function isOnlineAndCanReplicate(
     errorManager: UnresolvedErrorManager,
-    host: NecessaryServices<"API", any>,
+    host: NecessaryServices<"API", never>,
     showMessage: boolean
 ): Promise<boolean> {
     const errorMessage = "Network is offline";
@@ -34,7 +34,7 @@ function isOnlineAndCanReplicate(
 }
 async function canReplicateWithPBKDF2(
     errorManager: UnresolvedErrorManager,
-    host: NecessaryServices<"replicator" | "setting", any>,
+    host: NecessaryServices<"replicator" | "setting", never>,
     showMessage: boolean
 ): Promise<boolean> {
     const currentSettings = host.services.setting.currentSettings();

src/modules/core/ReplicateResultProcessor.ts

@@ -18,6 +18,7 @@ import {
     type LOG_LEVEL,
 } from "@lib/common/logger";
 import { fireAndForget, isAnyNote, throttle } from "@lib/common/utils";
+import { isNotFoundError } from "@lib/common/utils.doc.ts";
 import { Semaphore } from "octagonal-wheels/concurrency/semaphore_v2";
 import { serialized } from "octagonal-wheels/concurrency/lock";
 import type { ReactiveSource } from "octagonal-wheels/dataobject/reactive_v2";
@@ -39,7 +40,7 @@ export class ReplicateResultProcessor {
     private log(message: string, level: LOG_LEVEL = LOG_LEVEL_INFO) {
         Logger(`[ReplicateResultProcessor] ${message}`, level);
     }
-    private logError(e: any) {
+    private logError(e: unknown) {
         Logger(e, LOG_LEVEL_VERBOSE);
     }
     private replicator: ModuleReplicator;
@@ -466,8 +467,8 @@ export class ReplicateResultProcessor {
                 return false; // This means that the document already processed (While no conflict existed).
             }
             return true; // This mostly should not happen, but we have to process it just in case.
-        } catch (e: any) {
-            if ("status" in e && e.status == 404) {
+        } catch (e: unknown) {
+            if (e && typeof e === "object" && isNotFoundError(e)) {
                 // getRaw failed due to not existing, it may not be happened normally especially on replication.
                 // If the process caused by some other reason, we **probably** have to process it.
                 // Note that this is not a common case.

src/modules/coreFeatures/ModuleResolveMismatchedTweaks.ts

@@ -18,14 +18,14 @@ import type { InjectableServiceHub } from "../../lib/src/services/InjectableServ
 import type { LiveSyncCore } from "../../main.ts";
 import { REMOTE_P2P } from "@lib/common/models/setting.const.ts";
 
-function valueToString(value: any) {
+function valueToString(value: unknown) {
     if (typeof value === "boolean") {
         return value ? "true" : "false";
     }
-    if (typeof value === "object") {
+    if (typeof value === "object" && value !== null) {
         return JSON.stringify(value);
     }
-    return `${value}`;
+    return String(value);
 }
 
 export class ModuleResolvingMismatchedTweaks extends AbstractModule {

src/modules/essentialObsidian/APILib/ObsHttpHandler.ts

@@ -68,9 +68,13 @@ export class ObsHttpHandler extends FetchHttpHandler {
             contentType = transformedHeaders["content-type"];
         }
 
-        let transformedBody: any = body;
-        if (ArrayBuffer.isView(body)) {
-            transformedBody = new Uint8Array(body.buffer).buffer;
+        let transformedBody: string | ArrayBuffer | undefined = undefined;
+        if (typeof body === "string" || body instanceof ArrayBuffer) {
+            transformedBody = body;
+        } else if (ArrayBuffer.isView(body)) {
+            transformedBody = body.buffer as ArrayBuffer;
+        } else if (body != null) {
+            transformedBody = body as string | ArrayBuffer;
         }
 
         const param: RequestUrlParam = {

src/modules/essentialObsidian/ModuleObsidianEvents.ts

@@ -36,13 +36,14 @@ export class ModuleObsidianEvents extends AbstractObsidianModule {
         this.services.appLifecycle.performRestart();
     }
 
-    initialCallback: any;
+    initialCallback: (() => unknown) | undefined;
 
     swapSaveCommand() {
         this._log("Modifying callback of the save command", LOG_LEVEL_VERBOSE);
-        const saveCommandDefinition = (this.app as any).commands?.commands?.["editor:save-file"];
+        const app = this.app as unknown as { commands?: { commands?: Record<string, { callback?: () => unknown }> } };
+        const saveCommandDefinition = app.commands?.commands?.["editor:save-file"];
         const save = saveCommandDefinition?.callback;
-        if (typeof save === "function") {
+        if (typeof save === "function" && saveCommandDefinition) {
             this.initialCallback = save;
             saveCommandDefinition.callback = () => {
                 scheduleTask("syncOnEditorSave", 250, () => {

src/modules/extras/devUtil/testUtils.ts

@@ -6,7 +6,7 @@ let plugin: ObsidianLiveSyncPlugin;
 export function enableTestFunction(plugin_: ObsidianLiveSyncPlugin) {
     plugin = plugin_;
 }
-export function addDebugFileLog(message: any, stackLog = false) {
+export function addDebugFileLog(message: unknown, stackLog = false) {
     fireAndForget(
         serialized("debug-log", async () => {
             const now = new Date();
@@ -16,7 +16,7 @@ export function addDebugFileLog(message: any, stackLog = false) {
             // const messageContent = typeof message == "string" ? message : message instanceof Error ? `${message.name}:${message.message}` : JSON.stringify(message, null, 2);
             const timestamp = now.toLocaleString();
             const timestampEpoch = now;
-            let out = { timestamp: timestamp, epoch: timestampEpoch } as Record<string, any>;
+            let out = { timestamp: timestamp, epoch: timestampEpoch } as Record<string, unknown>;
             if (message instanceof Error) {
                 // debugger;
                 // console.dir(message.stack);

src/modules/features/DocumentHistory/DocumentHistoryModal.ts

@@ -139,7 +139,7 @@ export class DocumentHistoryModal extends Modal {
                 this.range.value = `${this.revs_info.length - 1 - rIndex}`;
             }
         }
-        const index = this.revs_info.length - 1 - (this.range.value as any) / 1;
+        const index = this.revs_info.length - 1 - Number(this.range.value);
         const rev = this.revs_info[index];
         await this.showExactRev(rev.rev);
     }
@@ -251,7 +251,7 @@ export class DocumentHistoryModal extends Modal {
             }
             let rendered = false;
             if (this.showDiff) {
-                const prevRevIdx = this.revs_info.length - 1 - ((this.range.value as any) / 1 - 1);
+                const prevRevIdx = this.revs_info.length - 1 - (Number(this.range.value) - 1);
                 if (prevRevIdx >= 0 && prevRevIdx < this.revs_info.length) {
                     const oldRev = this.revs_info[prevRevIdx].rev;
                     const w2 = await db.getDBEntry(this.file, { rev: oldRev }, false, false, true);
@@ -550,7 +550,7 @@ export class DocumentHistoryModal extends Modal {
                 if (this.showDiff) {
                     checkbox.checked = true;
                 }
-                checkbox.addEventListener("input", (evt: any) => {
+                checkbox.addEventListener("input", (evt) => {
                     this.showDiff = checkbox.checked;
                     this.app.saveLocalStorage("ols-history-highlightdiff", this.showDiff == true ? "1" : null);
                     this.updateDiffNavVisibility();
@@ -565,7 +565,7 @@ export class DocumentHistoryModal extends Modal {
             if (this.diffOnly) {
                 checkbox.checked = true;
             }
-            checkbox.addEventListener("input", (evt: any) => {
+            checkbox.addEventListener("input", (evt) => {
                 this.diffOnly = checkbox.checked;
                 this.app.saveLocalStorage("ols-history-diffonly", this.diffOnly == true ? "1" : null);
                 void scheduleOnceIfDuplicated("loadRevs", () => this.loadRevs());

src/modules/features/ModuleLog.ts

@@ -48,7 +48,7 @@ import { generateReport } from "@/common/reportTool.ts";
 
 // DI the log again.
 const recentLogEntries = reactiveSource<LogEntry[]>([]);
-const globalLogFunction = (message: any, level?: number, key?: string) => {
+const globalLogFunction = (message: unknown, level?: number, key?: string) => {
     const messageX =
         message instanceof Error
             ? new LiveSyncError("[Error Logged]: " + message.message, { cause: message })
@@ -501,7 +501,7 @@ ${stringifyYaml(info)}
             })
         );
     }
-    __addLog(message: any, level: LOG_LEVEL = LOG_LEVEL_INFO, key = ""): void {
+    __addLog(message: unknown, level: LOG_LEVEL = LOG_LEVEL_INFO, key = ""): void {
         if (level == LOG_LEVEL_DEBUG && !showDebugLog) {
             return;
         }

src/modules/features/SettingDialogue/LiveSyncSetting.ts

@@ -35,7 +35,7 @@ export class LiveSyncSetting extends Setting {
     hasPassword: boolean = false;
 
     invalidateValue?: () => void;
-    setValue?: (value: any) => void;
+    setValue?: (value: unknown) => void;
     constructor(containerEl: HTMLElement) {
         super(containerEl);
         LiveSyncSetting.env.settingComponents.push(this);
@@ -102,6 +102,7 @@ export class LiveSyncSetting extends Setting {
         }
         return conf;
     }
+    // eslint-disable-next-line @typescript-eslint/no-explicit-any
     autoWireComponent(component: ValueComponent<any>, conf?: ConfigurationItem, opt?: AutoWireOption) {
         this.placeHolderBuf = conf?.placeHolder || opt?.placeHolder || "";
         if (conf?.level == LEVEL_ADVANCED) {

src/modules/features/SettingDialogue/ObsidianLiveSyncSettingTab.ts

@@ -287,6 +287,7 @@ export class ObsidianLiveSyncSettingTab extends PluginSettingTab {
     // UI Element Wrapper -->
     settingComponents = [] as Setting[];
     controlledElementFunc = [] as UpdateFunction[];
+    // eslint-disable-next-line @typescript-eslint/no-explicit-any
     onSavedHandlers = [] as OnSavedHandler<any>[];
 
     inWizard: boolean = false;

src/modules/features/SettingDialogue/PaneHatch.ts

@@ -442,7 +442,9 @@ export function paneHatch(this: ObsidianLiveSyncSettingTab, paneEl: HTMLElement,
                         ...e.doc,
                         _deleted: true,
                     }));
-                    const r = await this.core.localDatabase.bulkDocsRaw(newData as any[]);
+                    const r = await this.core.localDatabase.bulkDocsRaw(
+                        newData as Parameters<typeof this.core.localDatabase.bulkDocsRaw>[0]
+                    );
                     // Do not care about the result.
                     Logger(
                         `${r.length} items have been removed, to confirm how many items are left, please perform it again.`,

src/modules/features/SettingDialogue/PaneRemoteConfig.ts

@@ -7,7 +7,7 @@ import {
     type ObsidianLiveSyncSettings,
     LOG_LEVEL_VERBOSE,
 } from "../../../lib/src/common/types.ts";
-import { Menu } from "@/deps.ts";
+import { Menu, ButtonComponent } from "@/deps.ts";
 import { $msg } from "../../../lib/src/common/i18n.ts";
 import { LiveSyncSetting as Setting } from "./LiveSyncSetting.ts";
 import type { ObsidianLiveSyncSettingTab } from "./ObsidianLiveSyncSettingTab.ts";
@@ -39,7 +39,7 @@ function getSettingsFromEditingSettings(editingSettings: AllSettings): ObsidianL
     const workObj = { ...editingSettings } as ObsidianLiveSyncSettings;
     const keys = Object.keys(OnDialogSettingsDefault);
     for (const k of keys) {
-        delete (workObj as any)[k];
+        delete (workObj as unknown as Record<string, unknown>)[k];
     }
     return workObj;
 }
@@ -72,7 +72,7 @@ function serializeRemoteConfiguration(settings: ObsidianLiveSyncSettings): strin
     return ConnectionStringParser.serialize({ type: "couchdb", settings });
 }
 
-function setEmojiButton(button: any, emoji: string, tooltip: string) {
+function setEmojiButton(button: ButtonComponent, emoji: string, tooltip: string) {
     button.setButtonText(emoji);
     button.setTooltip(tooltip, { delay: 10, placement: "top" });
     // button.buttonEl.addClass("clickable-icon");

src/modules/features/SettingDialogue/PaneSetup.ts

@@ -145,8 +145,8 @@ export function paneSetup(
             let remoteTroubleShootMDSrc = "";
             try {
                 remoteTroubleShootMDSrc = await request(`${rawRepoURI}${basePath}/${filename}`);
-            } catch (ex: any) {
-                remoteTroubleShootMDSrc = `${$msg("obsidianLiveSyncSettingTab.logErrorOccurred")}\n${ex.toString()}`;
+            } catch (ex) {
+                remoteTroubleShootMDSrc = `${$msg("obsidianLiveSyncSettingTab.logErrorOccurred")}\n${String(ex)}`;
             }
             const remoteTroubleShootMD = remoteTroubleShootMDSrc.replace(
                 /\((.*?(.png)|(.jpg))\)/g,

src/modules/features/SettingDialogue/SveltePanel.ts

@@ -5,7 +5,7 @@ import { type Writable, writable, get } from "svelte/store";
  * Props passed to Svelte panels, containing a writable port
  * to communicate with the panel
  */
-export type SveltePanelProps<T = any> = {
+export type SveltePanelProps<T = unknown> = {
     port: Writable<T | undefined>;
 };
 
@@ -13,7 +13,7 @@ export type SveltePanelProps<T = any> = {
  * A class to manage a Svelte panel within Obsidian
  * Especially useful for settings panels
  */
-export class SveltePanel<T = any> {
+export class SveltePanel<T = unknown> {
     private _mountedComponent: ReturnType<typeof mount>;
     private _componentValue = writable<T | undefined>(undefined);
     /**

src/modules/features/SettingDialogue/settingUtils.ts

@@ -13,6 +13,8 @@ import {
 } from "../../../lib/src/common/utils";
 import { getConfig, type AllSettingItemKey } from "./settingConstants";
 import { LOG_LEVEL_NOTICE, Logger } from "octagonal-wheels/common/logger";
+import { isNotFoundError } from "@lib/common/utils.doc.ts";
+import { LiveSyncError } from "@lib/common/LSError.ts";
 
 /**
  * Generates a summary of P2P configuration settings
@@ -95,13 +97,13 @@ export function getSummaryFromPartialSettings(setting: Partial<ObsidianLiveSyncS
 export async function copyMigrationDocs(docName: string, dbFrom: PouchDB.Database, dbTo: PouchDB.Database) {
     try {
         const doc = await dbFrom.get(docName);
-        delete (doc as any)._rev;
+        delete (doc as { _rev?: string })._rev;
         await dbTo.put(doc);
-    } catch (e) {
-        if ((e as any).status === 404) {
+    } catch (e: unknown) {
+        if (e && typeof e === "object" && isNotFoundError(e)) {
             return;
         }
-        throw e;
+        throw LiveSyncError.fromError(e);
     }
 }
 

src/modules/features/SettingDialogue/utilFixCouchDBSetting.ts

@@ -259,8 +259,8 @@ export const checkConfig = async (
         addResult($msg("obsidianLiveSyncSettingTab.msgDone"), ["ob-btn-config-head"]);
         addResult($msg("obsidianLiveSyncSettingTab.msgConnectionProxyNote"), ["ob-btn-config-info"]);
         Logger($msg("obsidianLiveSyncSettingTab.logCheckingConfigDone"), LOG_LEVEL_INFO);
-    } catch (ex: any) {
-        if (ex?.status == 401) {
+    } catch (ex) {
+        if (ex && typeof ex === "object" && "status" in ex && ex.status == 401) {
             isSuccessful = false;
             addResult($msg("obsidianLiveSyncSettingTab.errAccessForbidden"));
             addResult($msg("obsidianLiveSyncSettingTab.errCannotContinueTest"));

src/modules/features/SetupWizard/dialogs/utilCheckCouchDB.ts

@@ -7,8 +7,14 @@ import { isCloudantURI } from "../../../../lib/src/pouchdb/utils_couchdb";
 import { generateCredentialObject } from "../../../../lib/src/replication/httplib";
 export type ResultMessage = { message: string; classes: string[] };
 export type ResultErrorMessage = { message: string; result: "error"; classes: string[] };
-export type ResultOk = { message: string; result: "ok"; value?: any };
-export type ResultError = { message: string; result: "error"; value: any; fixMessage: string; fix(): Promise<void> };
+export type ResultOk = { message: string; result: "ok"; value?: unknown };
+export type ResultError = {
+    message: string;
+    result: "error";
+    value?: string;
+    fixMessage: string;
+    fix(): Promise<void>;
+};
 export type ConfigCheckResult = ResultOk | ResultError | ResultMessage | ResultErrorMessage;
 /**
  * Compares two version strings to determine if the baseVersion is greater than or equal to the version.
@@ -35,7 +41,7 @@ function isGreaterThanOrEqual(baseVersion: string, version: string) {
  * @param value setting value to update
  * @returns true if the update was successful, false otherwise
  */
-async function updateRemoteSetting(setting: ObsidianLiveSyncSettings, key: string, value: any) {
+async function updateRemoteSetting(setting: ObsidianLiveSyncSettings, key: string, value: string) {
     const customHeaders = parseHeaderValues(setting.couchDB_CustomHeaders);
     const credential = generateCredentialObject(setting);
     const res = await requestToCouchDBWithCredentials(
@@ -64,17 +70,17 @@ export const checkConfig = async (editingSettings: ObsidianLiveSyncSettings) =>
     const addMessage = (msg: string, classes: string[] = []) => {
         result.push({ message: msg, classes });
     };
-    const addSuccess = (msg: string, value?: any) => {
+    const addSuccess = (msg: string, value?: unknown) => {
         result.push({ message: msg, result: "ok", value });
     };
-    const _addError = (message: string, fixMessage: string, fix: () => Promise<void>, value?: any) => {
+    const _addError = (message: string, fixMessage: string, fix: () => Promise<void>, value?: string) => {
         result.push({ message, result: "error", fixMessage, fix, value });
     };
     const addErrorMessage = (msg: string, classes: string[] = []) => {
         result.push({ message: msg, result: "error", classes });
     };
 
-    const addError = (message: string, fixMessage: string, key: string, expected: any) => {
+    const addError = (message: string, fixMessage: string, key: string, expected: string) => {
         _addError(message, fixMessage, async () => {
             await updateRemoteSetting(editingSettings, key, expected);
         });
@@ -279,8 +285,8 @@ export const checkConfig = async (editingSettings: ObsidianLiveSyncSettings) =>
         addMessage($msg("obsidianLiveSyncSettingTab.msgDone"), ["ob-btn-config-head"]);
         addMessage($msg("obsidianLiveSyncSettingTab.msgConnectionProxyNote"), ["ob-btn-config-info"]);
         addMessage($msg("obsidianLiveSyncSettingTab.logCheckingConfigDone"));
-    } catch (ex: any) {
-        if (ex?.status == 401) {
+    } catch (ex) {
+        if (ex && typeof ex === "object" && "status" in ex && ex.status == 401) {
             addErrorMessage($msg("obsidianLiveSyncSettingTab.errAccessForbidden"));
             addErrorMessage($msg("obsidianLiveSyncSettingTab.errCannotContinueTest"));
             addMessage($msg("obsidianLiveSyncSettingTab.logCheckingConfigDone"));

src/modules/services/ObsidianAPIService.ts

@@ -125,11 +125,11 @@ export class ObsidianAPIService extends InjectableAPIService<ObsidianServiceCont
     registerWindow(type: string, factory: ViewCreator): void {
         return this.context.plugin.registerView(type, factory);
     }
-    addRibbonIcon(icon: string, title: string, callback: (evt: MouseEvent) => any): HTMLElement {
+    addRibbonIcon(icon: string, title: string, callback: (evt: MouseEvent) => void): HTMLElement {
         return this.context.plugin.addRibbonIcon(icon, title, callback);
     }
 
-    registerProtocolHandler(action: string, handler: (params: Record<string, string>) => any): void {
+    registerProtocolHandler(action: string, handler: (params: Record<string, string>) => void): void {
         return this.context.plugin.registerObsidianProtocolHandler(action, handler);
     }