Added database for plugins

package.json

@@ -41,7 +41,7 @@
     "i18n-js": "^3.8.0",
     "lodash-es": "^4.17.21",
     "protobufjs": "^7.2.6",
-    "qs": "^6.11.2",
+    "qs": "^6.12.0",
     "react": "18.2.0",
     "react-native": "0.72.10",
     "react-native-background-actions": "^3.0.1",
@@ -61,7 +61,7 @@
     "react-native-tab-view": "^3.5.2",
     "react-native-vector-icons": "^9.0.0",
     "react-native-webview": "^13.2.2",
-    "sanitize-html": "^2.7.0",
+    "sanitize-html": "^2.13.0",
     "urlencode": "^2.0.0"
   },
   "devDependencies": {
@@ -75,7 +75,7 @@
     "@types/lodash-es": "^4.17.6",
     "@types/react": "^18.0.24",
     "@types/react-native-vector-icons": "^6.4.10",
-    "@types/sanitize-html": "^2.6.2",
+    "@types/sanitize-html": "^2.11.0",
     "@typescript-eslint/eslint-plugin": "^5.10.2",
     "@typescript-eslint/parser": "^5.10.2",
     "babel-plugin-module-resolver": "^4.1.0",

src/hooks/persisted/usePlugins.ts

@@ -101,7 +101,7 @@ export default function usePlugins() {
    */
 
   const installPlugin = (plugin: PluginItem) => {
-    return _install(plugin.url).then(_plg => {
+    return _install(plugin.id, plugin.url).then(_plg => {
       if (_plg) {
         const installedPlugins =
           getMMKVObject<PluginItem[]>(INSTALLED_PLUGINS) || [];

src/navigators/types/index.ts

@@ -30,7 +30,7 @@ export type RootStackParamList = {
   WebviewScreen: {
     name: string;
     url: string;
-    pluginId?: string;
+    pluginId: string;
     isNovel?: boolean;
   };
 };

src/plugins/helpers/constants.ts

@@ -0,0 +1,2 @@
+export const defaultCover =
+  'https://github.com/LNReader/lnreader-plugins/blob/master/icons/coverNotAvailable.webp?raw=true';

src/plugins/helpers/storage.ts

@@ -0,0 +1,123 @@
+import { MMKV } from 'react-native-mmkv';
+
+const store = new MMKV({ id: 'plugin_db' });
+
+const PLUGIN_STORAGE = '_DB_';
+const WEBVIEW_LOCAL_STORAGE = '_LocalStorage';
+const WEBVIEW_SESSION_STORAGE = '_SessionStorage';
+
+interface StoredItem {
+  created: Date;
+  value: any;
+  expires?: number; // timestamp (miliseconds)
+}
+
+class Storage {
+  #pluginID: string;
+
+  constructor(pluginID: string) {
+    this.#pluginID = pluginID;
+  }
+
+  /**
+   * Sets a key-value pair in storage.
+   *
+   * @param {string} key - The key to set.
+   * @param {any} value - The value to set.
+   * @param {Date | number} [expires] - Optional expiry date or time in milliseconds.
+   */
+  set(key: string, value: any, expires?: Date | number): void {
+    const item: StoredItem = {
+      created: new Date(),
+      value,
+      expires: expires instanceof Date ? expires.getTime() : expires,
+    };
+    store.set(this.#pluginID + PLUGIN_STORAGE + key, JSON.stringify(item));
+  }
+
+  /**
+   * Retrieves the value for a given key from storage.
+   *
+   * @param {string} key - The key to retrieve the value for.
+   * @param {boolean} [raw] - Optional flag to return the raw stored item.
+   * @returns {any} The stored value or undefined if key is not found.
+   */
+  get(key: string, raw?: boolean): any {
+    const storedItem = store.getString(this.#pluginID + PLUGIN_STORAGE + key);
+    if (storedItem) {
+      const item: StoredItem = JSON.parse(storedItem);
+      if (item.expires) {
+        if (Date.now() > item.expires) {
+          this.delete(key);
+          return undefined;
+        }
+        if (raw) {
+          item.expires = new Date(item.expires).getTime();
+        }
+      }
+      return raw ? item : item.value;
+    }
+    return undefined;
+  }
+
+  /**
+   * Deletes a key from storage.
+   *
+   * @param {string} key - The key to delete.
+   */
+  delete(key: string): void {
+    store.delete(this.#pluginID + PLUGIN_STORAGE + key);
+  }
+
+  /**
+   * Clears all stored items from storage.
+   */
+  clearAll(): void {
+    const keysToRemove = this.getAllKeys();
+    keysToRemove.forEach(key => this.delete(key));
+  }
+
+  /**
+   * Retrieves all keys set by the `set` method.
+   *
+   * @returns {string[]} An array of keys.
+   */
+  getAllKeys(): string[] {
+    const keys = store
+      .getAllKeys()
+      .filter(key => key.startsWith(this.#pluginID + PLUGIN_STORAGE))
+      .map(key => key.replace(this.#pluginID + PLUGIN_STORAGE, ''));
+    return keys;
+  }
+}
+
+class LocalStorage {
+  #pluginID: string;
+
+  constructor(pluginID: string) {
+    this.#pluginID = pluginID;
+  }
+
+  get(): StoredItem['value'] | undefined {
+    const data = store.getString(this.#pluginID + WEBVIEW_LOCAL_STORAGE);
+    return data ? JSON.parse(data) : undefined;
+  }
+}
+
+class SessionStorage {
+  #pluginID: string;
+
+  constructor(pluginID: string) {
+    this.#pluginID = pluginID;
+  }
+
+  get(): StoredItem['value'] | undefined {
+    const data = store.getString(this.#pluginID + WEBVIEW_SESSION_STORAGE);
+    return data ? JSON.parse(data) : undefined;
+  }
+}
+
+export { Storage, LocalStorage, SessionStorage };
+
+//to record data from the web view
+export { WEBVIEW_LOCAL_STORAGE, WEBVIEW_SESSION_STORAGE, store };

src/plugins/pluginManager.ts

@@ -2,6 +2,7 @@ import RNFS from 'react-native-fs';
 import { reverse, uniqBy } from 'lodash-es';
 import { PluginDownloadFolder } from '@utils/constants/download';
 import { newer } from '@utils/compareVersion';
+import { store } from './helpers/storage';
 
 // packages for plugins
 import { load } from 'cheerio';
@@ -12,6 +13,7 @@ import { FilterTypes } from './types/filterTypes';
 import { isUrlAbsolute } from './helpers/isAbsoluteUrl';
 import { fetchApi, fetchFile, fetchProto, fetchText } from './helpers/fetch';
 import { defaultCover } from './helpers/constants';
+import { Storage, LocalStorage, SessionStorage } from './helpers/storage';
 import { encode, decode } from 'urlencode';
 import { Parser } from 'htmlparser2';
 import TextFile from '@native/TextFile';
@@ -33,12 +35,18 @@ const packages: Record<string, any> = {
   '@libs/defaultCover': { defaultCover },
 };
 
-const _require = (packageName: string) => {
-  return packages[packageName];
-};
-
-const initPlugin = (rawCode: string) => {
+const initPlugin = (pluginId: string, rawCode: string) => {
   try {
+    const _require = (packageName: string) => {
+      if (packageName === '@libs/storage') {
+        return {
+          storage: new Storage(pluginId),
+          localStorage: new LocalStorage(pluginId),
+          sessionStorage: new SessionStorage(pluginId),
+        };
+      }
+      return packages[packageName];
+    };
     /* eslint no-new-func: "off", curly: "error" */
     const plugin: Plugin = Function(
       'require',
@@ -84,26 +92,31 @@ const deserializePlugins = () => {
   return TextFile.readFile(pluginsFilePath)
     .then(content => {
       serializedPlugins = JSON.parse(content);
-      for (const script of Object.values(serializedPlugins)) {
-        const plugin = initPlugin(script as string);
-        if (plugin) {
-          plugins[plugin.id] = plugin;
+      Object.entries(serializedPlugins).forEach(([pluginId, script]) => {
+        if (script) {
+          const plugin = initPlugin(pluginId, script);
+          if (plugin) {
+            plugins[plugin.id] = plugin;
+          }
         }
-      }
+      });
     })
     .catch(() => {
       // nothing to read
     });
 };
 
-const installPlugin = async (url: string): Promise<Plugin | undefined> => {
+const installPlugin = async (
+  pluginId: string,
+  url: string,
+): Promise<Plugin | undefined> => {
   try {
     return await fetch(url, {
       headers: { 'pragma': 'no-cache', 'cache-control': 'no-cache' },
     })
       .then(res => res.text())
       .then(async rawCode => {
-        const plugin = initPlugin(rawCode);
+        const plugin = initPlugin(pluginId, rawCode);
         if (!plugin) {
           return undefined;
         }
@@ -122,11 +135,16 @@ const installPlugin = async (url: string): Promise<Plugin | undefined> => {
 
 const uninstallPlugin = async (_plugin: PluginItem) => {
   plugins[_plugin.id] = undefined;
+  store.getAllKeys().forEach(key => {
+    if (key.startsWith(_plugin.id)) {
+      store.delete(key);
+    }
+  });
   return serializePlugin(_plugin.id, '', false);
 };
 
 const updatePlugin = async (plugin: PluginItem) => {
-  return installPlugin(plugin.url);
+  return installPlugin(plugin.id, plugin.url);
 };
 
 const fetchPlugins = async (): Promise<PluginItem[]> => {

src/plugins/types/filterTypes.ts

@@ -43,13 +43,13 @@ type ExcludableCheckboxFilter = {
 
 export type Filters = Record<
   string,
-  | { label: string } & (
-      | PickerFilter
-      | CheckboxFilter
-      | TextFilter
-      | SwitchFilter
-      | ExcludableCheckboxFilter
-    )
+  { label: string } & (
+    | PickerFilter
+    | CheckboxFilter
+    | TextFilter
+    | SwitchFilter
+    | ExcludableCheckboxFilter
+  )
 >;
 
 export type FilterToValues<

src/plugins/types/index.ts

@@ -67,4 +67,5 @@ export interface Plugin extends PluginItem {
   searchNovels: (searchTerm: string, pageNo: number) => Promise<NovelItem[]>;
   fetchImage: (url: string) => Promise<string>;
   resolveUrl?: (path: string, isNovel?: boolean) => string;
+  webStorageUtilized?: boolean;
 }

src/screens/BrowseSourceScreen/BrowseSourceScreen.tsx

@@ -64,6 +64,7 @@ const BrowseSourceScreen = ({ route, navigation }: BrowseSourceScreenProps) => {
     navigation.navigate('WebviewScreen', {
       name: pluginName,
       url: site,
+      pluginId,
     });
   };