Move server connections to lib

src/lib/jellyfin-apiclient/ServerConnections.js

@@ -0,0 +1,158 @@
+// NOTE: This is used for jsdoc return type
+// eslint-disable-next-line @typescript-eslint/no-unused-vars
+import { Api } from '@jellyfin/sdk';
+import { Credentials, ApiClient } from 'jellyfin-apiclient';
+
+import { appHost } from 'components/apphost';
+import ConnectionManager from 'lib/jellyfin-apiclient/connectionManager';
+import appSettings from 'scripts/settings/appSettings';
+import { setUserInfo } from 'scripts/settings/userSettings';
+import Dashboard from 'utils/dashboard';
+import Events from 'utils/events.ts';
+import { toApi } from 'utils/jellyfin-apiclient/compat';
+
+const normalizeImageOptions = options => {
+    if (!options.quality && (options.maxWidth || options.width || options.maxHeight || options.height || options.fillWidth || options.fillHeight)) {
+        options.quality = 90;
+    }
+};
+
+const getMaxBandwidth = () => {
+    if (navigator.connection) {
+        let max = navigator.connection.downlinkMax;
+        if (max && max > 0 && max < Number.POSITIVE_INFINITY) {
+            max /= 8;
+            max *= 1000000;
+            max *= 0.7;
+            return parseInt(max, 10);
+        }
+    }
+
+    return null;
+};
+
+class ServerConnections extends ConnectionManager {
+    constructor() {
+        super(...arguments);
+        this.localApiClient = null;
+        this.firstConnection = null;
+
+        Events.on(this, 'localusersignedout', (_e, logoutInfo) => {
+            setUserInfo(null, null);
+            // Ensure the updated credentials are persisted to storage
+            credentialProvider.credentials(credentialProvider.credentials());
+
+            if (window.NativeShell && typeof window.NativeShell.onLocalUserSignedOut === 'function') {
+                window.NativeShell.onLocalUserSignedOut(logoutInfo);
+            }
+        });
+
+        Events.on(this, 'apiclientcreated', (_e, apiClient) => {
+            apiClient.getMaxBandwidth = getMaxBandwidth;
+            apiClient.normalizeImageOptions = normalizeImageOptions;
+        });
+    }
+
+    initApiClient(server) {
+        console.debug('creating ApiClient singleton');
+
+        const apiClient = new ApiClient(
+            server,
+            appHost.appName(),
+            appHost.appVersion(),
+            appHost.deviceName(),
+            appHost.deviceId()
+        );
+
+        apiClient.enableAutomaticNetworking = false;
+        apiClient.manualAddressOnly = true;
+
+        this.addApiClient(apiClient);
+
+        this.setLocalApiClient(apiClient);
+
+        console.debug('loaded ApiClient singleton');
+    }
+
+    connect(options) {
+        return super.connect({
+            enableAutoLogin: appSettings.enableAutoLogin(),
+            ...options
+        });
+    }
+
+    setLocalApiClient(apiClient) {
+        if (apiClient) {
+            this.localApiClient = apiClient;
+            window.ApiClient = apiClient;
+        }
+    }
+
+    getLocalApiClient() {
+        return this.localApiClient;
+    }
+
+    /**
+     * Gets the ApiClient that is currently connected.
+     * @returns {ApiClient|undefined} apiClient
+     */
+    currentApiClient() {
+        let apiClient = this.getLocalApiClient();
+
+        if (!apiClient) {
+            const server = this.getLastUsedServer();
+
+            if (server) {
+                apiClient = this.getApiClient(server.Id);
+            }
+        }
+
+        return apiClient;
+    }
+
+    /**
+     * Gets the Api that is currently connected.
+     * @returns {Api|undefined} The current Api instance.
+     */
+    getCurrentApi() {
+        const apiClient = this.currentApiClient();
+        if (!apiClient) return;
+
+        return toApi(apiClient);
+    }
+
+    /**
+     * Gets the ApiClient that is currently connected or throws if not defined.
+     * @async
+     * @returns {Promise<ApiClient>} The current ApiClient instance.
+     */
+    async getCurrentApiClientAsync() {
+        const apiClient = this.currentApiClient();
+        if (!apiClient) throw new Error('[ServerConnection] No current ApiClient instance');
+
+        return apiClient;
+    }
+
+    onLocalUserSignedIn(user) {
+        const apiClient = this.getApiClient(user.ServerId);
+        this.setLocalApiClient(apiClient);
+        return setUserInfo(user.Id, apiClient).then(() => {
+            if (window.NativeShell && typeof window.NativeShell.onLocalUserSignedIn === 'function') {
+                return window.NativeShell.onLocalUserSignedIn(user, apiClient.accessToken());
+            }
+            return Promise.resolve();
+        });
+    }
+}
+
+const credentialProvider = new Credentials();
+
+const capabilities = Dashboard.capabilities(appHost);
+
+export default new ServerConnections(
+    credentialProvider,
+    appHost.appName(),
+    appHost.appVersion(),
+    appHost.deviceName(),
+    appHost.deviceId(),
+    capabilities);