☰

JavDB Filter

JavDB 过滤插件，用于过滤不感兴趣的标签、演员等

  1. // ==UserScript==
  2.  
  3. // @name              JavDB Filter
  4. // @name:zh-CN        JavDB 过滤插件
  5.  
  6. // @description       JavDB 过滤插件，用于过滤不感兴趣的标签、演员等
  7.  
  8. // @namespace         https://sleazyfork.org/users/263018
  9. // @version           1.1.1
  10. // @author            snyssss
  11. // @license           MIT
  12.  
  13. // @match             https://javdb.com/*
  14. // @include           /^https:\/\/(\w*\.)?javdb(\d)*\.com.*$/
  15. // @icon              https://javdb.com/favicon-32x32.png
  16. // @grant             none
  17.  
  18. // ==/UserScript==
  19.  
  20. // https://cdn.jsdelivr.net/npm/idb@8/build/umd.js
  21. !function(e,t){"object"==typeof exports&&"undefined"!=typeof module?t(exports):"function"==typeof define&&define.amd?define(["exports"],t):t((e="undefined"!=typeof globalThis?globalThis:e||self).idb={})}(this,(function(e){"use strict";const t=(e,t)=>t.some((t=>e instanceof t));let n,r;const o=new WeakMap,s=new WeakMap,i=new WeakMap;let a={get(e,t,n){if(e instanceof IDBTransaction){if("done"===t)return o.get(e);if("store"===t)return n.objectStoreNames[1]?void 0:n.objectStore(n.objectStoreNames[0])}return f(e[t])},set:(e,t,n)=>(e[t]=n,!0),has:(e,t)=>e instanceof IDBTransaction&&("done"===t||"store"===t)||t in e};function c(e){a=e(a)}function u(e){return(r||(r=[IDBCursor.prototype.advance,IDBCursor.prototype.continue,IDBCursor.prototype.continuePrimaryKey])).includes(e)?function(...t){return e.apply(l(this),t),f(this.request)}:function(...t){return f(e.apply(l(this),t))}}function d(e){return"function"==typeof e?u(e):(e instanceof IDBTransaction&&function(e){if(o.has(e))return;const t=new Promise(((t,n)=>{const r=()=>{e.removeEventListener("complete",o),e.removeEventListener("error",s),e.removeEventListener("abort",s)},o=()=>{t(),r()},s=()=>{n(e.error||new DOMException("AbortError","AbortError")),r()};e.addEventListener("complete",o),e.addEventListener("error",s),e.addEventListener("abort",s)}));o.set(e,t)}(e),t(e,n||(n=[IDBDatabase,IDBObjectStore,IDBIndex,IDBCursor,IDBTransaction]))?new Proxy(e,a):e)}function f(e){if(e instanceof IDBRequest)return function(e){const t=new Promise(((t,n)=>{const r=()=>{e.removeEventListener("success",o),e.removeEventListener("error",s)},o=()=>{t(f(e.result)),r()},s=()=>{n(e.error),r()};e.addEventListener("success",o),e.addEventListener("error",s)}));return i.set(t,e),t}(e);if(s.has(e))return s.get(e);const t=d(e);return t!==e&&(s.set(e,t),i.set(t,e)),t}const l=e=>i.get(e);const p=["get","getKey","getAll","getAllKeys","count"],D=["put","add","delete","clear"],I=new Map;function y(e,t){if(!(e instanceof IDBDatabase)||t in e||"string"!=typeof t)return;if(I.get(t))return I.get(t);const n=t.replace(/FromIndex$/,""),r=t!==n,o=D.includes(n);if(!(n in(r?IDBIndex:IDBObjectStore).prototype)||!o&&!p.includes(n))return;const s=async function(e,...t){const s=this.transaction(e,o?"readwrite":"readonly");let i=s.store;return r&&(i=i.index(t.shift())),(await Promise.all([i[n](...t),o&&s.done]))[0]};return I.set(t,s),s}c((e=>({...e,get:(t,n,r)=>y(t,n)||e.get(t,n,r),has:(t,n)=>!!y(t,n)||e.has(t,n)})));const B=["continue","continuePrimaryKey","advance"],b={},g=new WeakMap,v=new WeakMap,h={get(e,t){if(!B.includes(t))return e[t];let n=b[t];return n||(n=b[t]=function(...e){g.set(this,v.get(this)[t](...e))}),n}};async function*m(...e){let t=this;if(t instanceof IDBCursor||(t=await t.openCursor(...e)),!t)return;const n=new Proxy(t,h);for(v.set(n,t),i.set(n,l(t));t;)yield n,t=await(g.get(n)||t.continue()),g.delete(n)}function w(e,n){return n===Symbol.asyncIterator&&t(e,[IDBIndex,IDBObjectStore,IDBCursor])||"iterate"===n&&t(e,[IDBIndex,IDBObjectStore])}c((e=>({...e,get:(t,n,r)=>w(t,n)?m:e.get(t,n,r),has:(t,n)=>w(t,n)||e.has(t,n)}))),e.deleteDB=function(e,{blocked:t}={}){const n=indexedDB.deleteDatabase(e);return t&&n.addEventListener("blocked",(e=>t(e.oldVersion,e))),f(n).then((()=>{}))},e.openDB=function(e,t,{blocked:n,upgrade:r,blocking:o,terminated:s}={}){const i=indexedDB.open(e,t),a=f(i);return r&&i.addEventListener("upgradeneeded",(e=>{r(f(i.result),e.oldVersion,e.newVersion,f(i.transaction),e)})),n&&i.addEventListener("blocked",(e=>n(e.oldVersion,e.newVersion,e))),a.then((e=>{s&&e.addEventListener("close",(()=>s())),o&&e.addEventListener("versionchange",(e=>o(e.oldVersion,e.newVersion,e)))})).catch((()=>{})),a},e.unwrap=l,e.wrap=f}));
  22.  
  23. (async () => {
  24.   // 初始化 idb
  25.   const db = await idb.openDB("JavDB-Filter", 1, {
  26.     upgrade(db) {
  27.       db.createObjectStore("videos", {
  28.         keyPath: "id",
  29.       });
  30.       db.createObjectStore("idPrefixs", {
  31.         keyPath: "value",
  32.       });
  33.       db.createObjectStore("directors", {
  34.         keyPath: "value",
  35.       });
  36.       db.createObjectStore("makers", {
  37.         keyPath: "value",
  38.       });
  39.       db.createObjectStore("series", {
  40.         keyPath: "value",
  41.       });
  42.       db.createObjectStore("tags", {
  43.         keyPath: "value",
  44.       });
  45.       db.createObjectStore("actors", {
  46.         keyPath: "value",
  47.       });
  48.     },
  49.   }); // 超时时间
  50.  
  51.   const expiry = 24 * 60 * 60 * 1000; // 获取当前页面的 URL
  52.  
  53.   const url = window.location.href; // 检查 URL 是否为详情页
  54.  
  55.   const isDetailPage = url.startsWith("https://javdb.com/v/"); // 检查是否包含屏蔽项
  56.  
  57.   const isBlocked = async (type, value) => {
  58.     if (value) {
  59.       const data = await db.get(type, value);
  60.  
  61.       return data !== undefined;
  62.     }
  63.  
  64.     return false;
  65.   }; // 提取当前页面数据
  66.  
  67.   const getInfo = (doc) => {
  68.     const info = doc.querySelector(".movie-panel-info");
  69.  
  70.     if (info === null) {
  71.       return null;
  72.     }
  73.  
  74.     const links = [...info.querySelectorAll("A")];
  75.  
  76.     const idPrefix = links
  77.       .filter((link) => link.href.includes("/video_codes"))
  78.       .map((link) => link.href.match(/(\w+)(\?f=\w+)?$/)[1]);
  79.  
  80.     const director = links
  81.       .filter((link) => link.href.includes("/directors"))
  82.       .map((link) => link.href.match(/(\w+)(\?f=\w+)?$/)[1]);
  83.  
  84.     const maker = links
  85.       .filter((link) => link.href.includes("/makers"))
  86.       .map((link) => link.href.match(/(\w+)(\?f=\w+)?$/)[1]);
  87.  
  88.     const series = links
  89.       .filter((link) => link.href.includes("/series"))
  90.       .map((link) => link.href.match(/(\w+)(\?f=\w+)?$/)[1]);
  91.  
  92.     const tags = links
  93.       .filter((link) => link.href.includes("/tags"))
  94.       .map((link) => link.href.match(/c\d=\d+/)[0]);
  95.  
  96.     const actors = links
  97.       .filter((link) => link.href.includes("/actors"))
  98.       .map((link) => link.href.match(/\w+$/)[0]);
  99.  
  100.     return {
  101.       idPrefix: idPrefix.length > 0 ? idPrefix[0] : null,
  102.       director: director.length > 0 ? director[0] : null,
  103.       maker: maker.length > 0 ? maker[0] : null,
  104.       series: series.length > 0 ? series[0] : null,
  105.       tags,
  106.       actors,
  107.     };
  108.   }; // 绑定事件
  109.  
  110.   const bindEvents = (doc) => {
  111.     const info = doc.querySelector(".movie-panel-info");
  112.  
  113.     if (info === null) {
  114.       return null;
  115.     }
  116.  
  117.     const links = [...info.querySelectorAll("A")];
  118.  
  119.     const bindEvent = (element, type, value) => {
  120.       let timer = null;
  121.  
  122.       const check = async () => {
  123.         const result = await isBlocked(type, value);
  124.  
  125.         if (result) {
  126.           element.style.color = "red";
  127.         } else {
  128.           element.style.removeProperty("color");
  129.         }
  130.  
  131.         return result;
  132.       };
  133.  
  134.       element.addEventListener("mousedown", () => {
  135.         timer = setTimeout(async () => {
  136.           const isBlocked = await check();
  137.  
  138.           if (isBlocked) {
  139.             await db.delete(type, value);
  140.           } else {
  141.             await db.put(type, { value });
  142.           }
  143.  
  144.           await check();
  145.  
  146.           timer = null;
  147.         }, 1000);
  148.       });
  149.  
  150.       element.addEventListener("mouseup", () => {
  151.         if (timer === null) {
  152.           return;
  153.         }
  154.  
  155.         clearTimeout(timer);
  156.  
  157.         window.location.href = element.href;
  158.       });
  159.  
  160.       element.addEventListener("click", (e) => {
  161.         e.preventDefault();
  162.       });
  163.  
  164.       check();
  165.     };
  166.  
  167.     links
  168.       .filter((link) => link.href.includes("/video_codes"))
  169.       .forEach((link) => {
  170.         const value = link.href.match(/(\w+)(\?f=\w+)?$/)[1];
  171.  
  172.         bindEvent(link, "idPrefixs", value);
  173.       });
  174.  
  175.     links
  176.       .filter((link) => link.href.includes("/directors"))
  177.       .forEach((link) => {
  178.         const value = link.href.match(/(\w+)(\?f=\w+)?$/)[1];
  179.  
  180.         bindEvent(link, "directors", value);
  181.       });
  182.  
  183.     links
  184.       .filter((link) => link.href.includes("/makers"))
  185.       .forEach((link) => {
  186.         const value = link.href.match(/(\w+)(\?f=\w+)?$/)[1];
  187.  
  188.         bindEvent(link, "makers", value);
  189.       });
  190.  
  191.     links
  192.       .filter((link) => link.href.includes("/series"))
  193.       .forEach((link) => {
  194.         const value = link.href.match(/(\w+)(\?f=\w+)?$/)[1];
  195.  
  196.         bindEvent(link, "series", value);
  197.       });
  198.  
  199.     links
  200.       .filter((link) => link.href.includes("/tags"))
  201.       .forEach((link) => {
  202.         const value = link.href.match(/c\d=\d+/)[0];
  203.  
  204.         bindEvent(link, "tags", value);
  205.       });
  206.  
  207.     links
  208.       .filter((link) => link.href.includes("/actors"))
  209.       .forEach((link) => {
  210.         const value = link.href.match(/\w+$/)[0];
  211.  
  212.         bindEvent(link, "actors", value);
  213.       });
  214.   }; // 非详情页的情况下，尝试过滤列表
  215.  
  216.   if (isDetailPage === false) {
  217.     // 列表容器
  218.     const list = document.querySelector(".movie-list"); // 过滤函数
  219.  
  220.     const filter = (() => {
  221.       let isRunning = false;
  222.  
  223.       const queue = [];
  224.  
  225.       const getIsBlocked = async (data) => {
  226.         const items = [
  227.           () => isBlocked("idPrefixs", data.idPrefix),
  228.           () => isBlocked("directors", data.directors),
  229.           () => isBlocked("makers", data.maker),
  230.           () => isBlocked("series", data.series),
  231.           ...data.tags.map((tag) => () => isBlocked("tags", tag)),
  232.           ...data.actors.map((actor) => () => isBlocked("actors", actor)),
  233.         ];
  234.  
  235.         for (const fn of items) {
  236.           if (await fn()) {
  237.             return true;
  238.           }
  239.         }
  240.  
  241.         return false;
  242.       };
  243.  
  244.       const dequeue = async () => {
  245.         if (isRunning) {
  246.           return;
  247.         }
  248.  
  249.         if (queue.length === 0) {
  250.           return;
  251.         }
  252.  
  253.         isRunning = true;
  254.  
  255.         await queue.shift()();
  256.  
  257.         isRunning = false;
  258.  
  259.         dequeue();
  260.       };
  261.  
  262.       const run = async () => {
  263.         // 查找列表下所有视频
  264.         const items = list.querySelectorAll(".item"); // 过滤视频
  265.  
  266.         for (const item of items) {
  267.           // 获取链接、标题
  268.           const { href, title } = item.querySelector("A"); // 获取番号
  269.  
  270.           const id = item.querySelector("STRONG").textContent; // 过滤
  271.  
  272.           const check = async (data) => {
  273.             const items = [
  274.               () => isBlocked("idPrefixs", data.idPrefix),
  275.               () => isBlocked("directors", data.directors),
  276.               () => isBlocked("makers", data.maker),
  277.               () => isBlocked("series", data.series),
  278.               ...data.tags.map((tag) => () => isBlocked("tags", tag)),
  279.               ...data.actors.map((actor) => () => isBlocked("actors", actor)),
  280.             ];
  281.  
  282.             for (const fn of items) {
  283.               if (await fn()) {
  284.                 item.remove();
  285.                 break;
  286.               }
  287.             }
  288.           }; // 从缓存中查找
  289.  
  290.           const data = await db.get("videos", id); // 有缓存，直接过滤
  291.  
  292.           if (data) {
  293.             await check(data); // 缓存没有过期，无需更新
  294.  
  295.             if (Date.now() - data.timestamp < expiry) {
  296.               continue;
  297.             }
  298.           }
  299.  
  300.           // 请求后过滤
  301.           const task = () =>
  302.             new Promise(async (resolve) => {
  303.               // 从缓存中查找
  304.               const cache = await db.get("videos", id);
  305.  
  306.               // 有缓存且没有过期，返回结果
  307.               if (cache && Date.now() - cache.timestamp < expiry) {
  308.                 resolve(cache);
  309.                 return;
  310.               }
  311.  
  312.               // 请求数据
  313.               const response = await fetch(href);
  314.  
  315.               const parser = new DOMParser();
  316.  
  317.               const responseText = await response.text();
  318.  
  319.               const doc = parser.parseFromString(responseText, "text/html");
  320.  
  321.               const info = getInfo(doc);
  322.  
  323.               if (info === null) {
  324.                 // 防止爬虫检测
  325.                 await new Promise((resolve) => setTimeout(resolve, 1600));
  326.  
  327.                 resolve();
  328.                 return;
  329.               }
  330.  
  331.               const result = {
  332.                 id,
  333.                 title: title.trim(),
  334.                 timestamp: Date.now(),
  335.                 ...info,
  336.               };
  337.  
  338.               await db.put("videos", result);
  339.               await new Promise((resolve) => setTimeout(resolve, 160));
  340.  
  341.               resolve(result);
  342.             }).then((data) => {
  343.               if (data) {
  344.                 return check(data);
  345.               }
  346.             }); // 加入任务队列
  347.  
  348.           queue.push(task);
  349.         } // 执行队列
  350.  
  351.         dequeue();
  352.       };
  353.  
  354.       return run;
  355.     })(); // 有列表的情况下，开始过滤
  356.  
  357.     if (list) {
  358.       const observer = new MutationObserver(filter);
  359.  
  360.       observer.observe(list, {
  361.         childList: true,
  362.       });
  363.  
  364.       filter();
  365.     }
  366.     return;
  367.   } // 详情页的情况下，获取数据
  368.  
  369.   const info = getInfo(document);
  370.  
  371.   if (info === null) {
  372.     return;
  373.   } // 获取番号
  374.  
  375.   const id = document.querySelector(".title > STRONG").textContent.trim();
  376.   const title = document.querySelector(".title > .current-title").textContent; // 更新缓存
  377.  
  378.   await db.put("videos", {
  379.     id,
  380.     title: title.trim(),
  381.     timestamp: Date.now(),
  382.     ...info,
  383.   }); // 绑定事件
  384.  
  385.   bindEvents(document);
  386. })();