// ==UserScript==
// @name Kemono zip download
// @name:zh-CN Kemono 下载为ZIP文件
// @namespace https://greasyfork.org/users/667968-pyudng
// @version 0.13.1
// @description Download kemono post in a zip file
// @description:zh-CN 下载Kemono的内容为ZIP压缩文档
// @author PY-DNG
// @license MIT
// @match http*://*.kemono.su/*
// @match http*://*.kemono.party/*
// @require data:application/javascript,window.setImmediate%20%3D%20window.setImmediate%20%7C%7C%20((f%2C%20...args)%20%3D%3E%20window.setTimeout(()%20%3D%3E%20f(args)%2C%200))%3B
// @require https://update.greasyfork.org/scripts/456034/1558509/Basic%20Functions%20%28For%20userscripts%29.js
// @require https://cdnjs.cloudflare.com/ajax/libs/jszip/3.10.1/jszip.min.js
// @require https://update.greasyfork.org/scripts/458132/1138364/ItemSelector.js
// @resource vue-js https://unpkg.com/[email protected]/dist/vue.global.prod.js
// @resource quasar-icon https://fonts.googleapis.com/css?family=Roboto:100,300,400,500,700,900|Material+Icons
// @resource quasar-css https://cdn.jsdelivr.net/npm/[email protected]/dist/quasar.prod.css
// @resource quasar-js https://cdn.jsdelivr.net/npm/[email protected]/dist/quasar.umd.prod.js
// @connect kemono.su
// @connect kemono.party
// @icon https://kemono.su/favicon.ico
// @grant GM_xmlhttpRequest
// @grant GM_registerMenuCommand
// @grant GM_addElement
// @grant GM_getResourceText
// @grant GM_setValue
// @grant GM_getValue
// @grant GM_addValueChangeListener
// @run-at document-start
// ==/UserScript==
/* eslint-disable no-multi-spaces */
/* eslint-disable no-return-assign */
/* global LogLevel DoLog Err Assert $ $All $CrE $AEL $$CrE addStyle detectDom destroyEvent copyProp copyProps parseArgs escJsStr replaceText getUrlArgv dl_browser dl_GM AsyncManager queueTask FunctionLoader loadFuncs require isLoaded */
/* global setImmediate JSZip ItemSelector Vue Quasar */
(function __MAIN__() {
'use strict';
const CONST = {
TextAllLang: {
DEFAULT: 'en-US',
'zh-CN': {
DownloadZip: '下载为ZIP文件',
DownloadPost: '下载当前作品为ZIP文件',
DownloadCreator: '下载当前创作者为ZIP文件',
DownloadCustom: '自定义下载',
Downloading: '正在下载...',
FetchingCreatorPosts: '正在获取创作者作品列表...',
SelectAll: '全选',
TotalProgress: '总进度',
ProgressBoardTitle: '下载进度',
Settings: '设置',
SaveContent: '保存文字内容到html文件',
SaveApijson: '保存api结果到json文件',
NoPrefix: '保存文件时不添加文件名前缀',
FlattenFiles: '保存主文件和附件到同一级文件夹',
FlattenFilesCaption: '主文件一般是封面图',
CustomDownload: {
PopupTitle: '自定义下载',
TypeLabel: '下载...',
ServiceLabel: '发布平台',
CreatorLabel: '创作者ID',
PostLabel: '内容ID',
ExtFilterLabel: '只下载以下扩展名的文件',
ExtFilterTooltip: '留空以下载所有文件',
NoPrefixLabel: '保存文件时不添加文件名前缀',
FlattenFilesLabel: '保存主文件和附件到同一级文件夹',
FlattenFilesTooltip: '主文件一般是封面图',
Type: {
Post: '单篇内容',
Creator: '创作者的多篇内容'
},
Cancel: '取消',
Download: '开始下载',
},
PostsSelector: {
Title: '选择内容',
OK: '确定',
Cancel: '取消',
SelectAll: '全选',
},
},
'en-US': {
DownloadZip: 'Download as ZIP file',
DownloadPost: 'Download post as ZIP file',
DownloadCreator: 'Download creator as ZIP file',
DownloadCustom: 'Custom download',
Downloading: 'Downloading...',
FetchingCreatorPosts: 'Fetching creator posts list...',
SelectAll: 'Select All',
TotalProgress: 'Total Progress',
ProgressBoardTitle: 'Download Progress',
Settings: 'Settings',
SaveContent: 'Save text content',
SaveApijson: 'Save api result',
NoPrefix: 'Do not add filename prefix',
FlattenFiles: 'Save main file and attachments to same folder',
FlattenFilesCaption: '"Main file" is usually the cover image',
CustomDownload: {
PopupTitle: 'Custom download',
TypeLabel: 'Download ...',
ServiceLabel: 'Service Name',
CreatorLabel: 'Creator ID',
PostLabel: '内容',
ExtFilterLabel: 'Download files with these extensions only',
ExtFilterTooltip: 'Leave blank to download all files',
NoPrefixLabel: 'Do not add filename prefix',
FlattenFilesLabel: 'Save main file and attachments to same folder',
FlattenFilesTooltip: '"Main file" is usually the cover image',
Type: {
Post: 'single post',
Creator: 'creator posts'
},
Cancel: 'Cancel',
Download: 'Download',
},
PostsSelector: {
Title: 'Select posts',
OK: 'OK',
Cancel: 'Cancel',
SelectAll: 'Select All',
},
}
}
};
// Init language
const i18n = Object.keys(CONST.TextAllLang).includes(navigator.language) ? navigator.language : CONST.TextAllLang.DEFAULT;
CONST.Text = CONST.TextAllLang[i18n];
loadFuncs([{
id: 'utils',
async func() {
const win = typeof unsafeWindow !== 'undefined' ? unsafeWindow : window;
function fillNumber(number, length) {
const str = number.toString();
return '0'.repeat(length - str.length) + str;
}
/**
* Async task progress manager \
* when awaiting async tasks, replace `await task` with `await manager.progress(task)` \
* suppoerts sub-tasks, just `manager.sub(sub_steps, sub_callback)`
*/
class ProgressManager {
/** @type {*} */
info;
/** @type {number} */
steps;
/** @type {progressCallback} */
callback;
/** @type {number} */
finished;
/** @type {ProgressManager[]} */
#children;
/** @type {ProgressManager} */
#parent;
/**
* This callback is called each time a promise resolves
* @callback progressCallback
* @param {number} resolved_count
* @param {number} total_count
* @param {ProgressManager} manager
*/
/**
* @param {number} [steps=0] - total steps count of the task
* @param {progressCallback} [callback] - callback each time progress updates
* @param {*} [info] - attach any data about this manager if need
*/
constructor(steps=0, callback=function() {}, info=undefined) {
this.steps = steps;
this.callback = callback;
this.info = info;
this.finished = 0;
this.#children = [];
this.#callCallback();
}
add() { this.steps++; }
/**
* @template {Promise | null} task
* @param {task} [promise] - task to await, null is acceptable if no task to await
* @param {number} [finished] - set this.finished to this value, defaults to this.finished+1
* @returns {Awaited<task>}
*/
async progress(promise, finished) {
const val = await Promise.resolve(promise);
try {
this.finished = typeof finished === 'number' ? finished : this.finished + 1;
this.#callCallback();
//this.finished === this.steps && this.#parent && this.#parent.progress();
} finally {
return val;
}
}
/**
* Creates a new ProgressManager as a sub-progress of this
* @param {number} [steps=0] - total steps count of the task
* @param {progressCallback} [callback] - callback each time progress updates, defaulting to parent.callback
* @param {*} [info] - attach any data about the sub-manager if need
*/
sub(steps, callback, info) {
const manager = new ProgressManager(steps ?? 0, callback ?? this.callback, info);
manager.#parent = this;
this.#children.push(manager);
return manager;
}
#callCallback() {
this.callback(this.finished, this.steps, this);
}
get children() {
return [...this.#children];
}
get parent() {
return this.#parent;
}
/**
* Resolves after all promise resolved, and callback each time one of them resolves
* @param {Array<Promise>} promises
* @param {progressCallback} callback
*/
static async all(promises, callback) {
const manager = new ProgressManager(promises.length, callback);
await Promise.all(promises.map(promise => manager.progress(promise, callback)));
}
}
const PerformanceManager = (function() {
class RunRecord {
static #id = 0;
/** @typedef {'initialized' | 'running' | 'finished'} run_status */
/** @type {number} */
id;
/** @type {number} */
start;
/** @type {number} */
end;
/** @type {number} */
duration;
/** @type {run_status} */
status;
/**
* Anything for programmers to mark and read, uses as a description for this run
* @type {*}
*/
info;
/**
* @param {*} [info] - Anything for programmers to mark and read, uses as a description for this run
*/
constructor(info) {
this.id = RunRecord.#id++;
this.status = 'initialized';
this.info = info;
}
run() {
const time = performance.now();
this.start = time;
this.status = 'running';
return this;
}
stop() {
const time = performance.now();
this.end = time;
this.duration = this.end - this.start;
this.status = 'finished';
return this;
}
}
class Task {
/** @typedef {number | string | symbol} task_id */
/** @type {task_id} */
id;
/** @type {RunRecord[]} */
runs;
/**
* @param {task_id} id
*/
constructor(id) {
this.id = id;
this.runs = [];
}
run(info) {
const record = new RunRecord(info);
record.run();
this.runs.push(record);
return record;
}
get time() {
return this.runs.reduce((time, record) => {
if (record.status === 'finished') {
time += record.duration;
}
return time;
}, 0)
}
}
class PerformanceManager {
/** @type {Task[]} */
tasks;
constructor() {
this.tasks = [];
}
/**
* @param {task_id} id
* @returns {Task | null}
*/
getTask(id) {
return this.tasks.find(task => task.id === id);
}
/**
* Creates a new task
* @param {task_id} id
* @returns {Task}
*/
newTask(id) {
Assert(!this.getTask(id), `given task id ${escJsStr(id)} is already in use`, TypeError);
const task = new Task(id);
this.tasks.push(task);
return task;
}
/**
* Runs a task
* @param {task_id} id
* @param {*} run_info - Anything for programmers to mark and read, uses as a description for this run
* @returns {RunRecord}
*/
run(task_id, run_info) {
const task = this.getTask(task_id);
Assert(task, `task of id ${escJsStr(task_id)} not found`, TypeError);
return task.run(run_info);
}
totalTime(id) {
if (id) {
return this.getTask(id).time;
} else {
return this.tasks.reduce((timetable, task) => {
timetable[task.id] = task.time;
return timetable;
}, {});
}
}
meanTime(id) {
if (id) {
const task = this.getTask(id);
return task.time / task.runs.length;
} else {
return this.tasks.reduce((timetable, task) => {
timetable[task.id] = task.time / task.runs.length;
return timetable;
}, {});
}
}
}
return PerformanceManager;
}) ();
return {
window: win,
fillNumber, ProgressManager, PerformanceManager
}
}
}, {
id: 'dependencies',
desc: 'load dependencies like vue into the page',
detectDom: ['head', 'body'],
async func() {
const deps = [{
name: 'vue-js',
type: 'script',
}, {
name: 'quasar-icon',
type: 'style'
}, {
name: 'quasar-css',
type: 'style'
}, {
name: 'quasar-js',
type: 'script'
}];
await Promise.all(deps.map(dep => {
return new Promise((resolve, reject) => {
switch (dep.type) {
case 'script': {
// Once load, dispatch load event on messager
const evt_name = `load:${dep.name};${Date.now()}`;
const rand = Math.random().toString();
const messager = new EventTarget();
const load_code = [
'\n;',
`window[${escJsStr(rand)}].dispatchEvent(new Event(${escJsStr(evt_name)}));`,
`delete window[${escJsStr(rand)}];\n`
].join('\n');
unsafeWindow[rand] = messager;
$AEL(messager, evt_name, resolve);
GM_addElement(document.head, 'script', {
textContent: GM_getResourceText(dep.name) + load_code,
});
break;
}
case 'style': {
GM_addElement(document.head, 'style', {
textContent: GM_getResourceText(dep.name),
});
resolve();
break;
}
}
});
}));
Quasar.setCssVar('primary', 'orange');
setTimeout(() => Quasar.Dark.set(true));
}
}, {
id: 'api',
desc: 'api for kemono',
async func() {
let api_key = null;
const Posts = {
/**
* Get a list of creator posts
* @param {string} service - The service where the post is located
* @param {number | string} creator_id - The ID of the creator
* @param {string} [q] - Search query
* @param {number} [o] - Result offset, stepping of 50 is enforced
*/
posts(service, creator_id, q, o) {
const search = {};
q && (search.q = q);
o && (search.o = o);
return callApi({
endpoint: `/${service}/user/${creator_id}`,
search
});
},
/**
* Get a specific post
* @param {string} service
* @param {number | string} creator_id
* @param {number | string} post_id
* @returns {Promise<Object>}
*/
post(service, creator_id, post_id) {
return callApi({
endpoint: `/${service}/user/${creator_id}/post/${post_id}`
});
}
};
const Creators = {
/**
* Get a creator
* @param {string} service - The service where the creator is located
* @param {number | string} creator_id - The ID of the creator
* @returns
*/
profile(service, creator_id) {
return callApi({
endpoint: `/${service}/user/${creator_id}/profile`
});
}
};
const Custom = {
/**
* Get a list of creator's ALL posts, calling Post.posts for multiple times and joins the results
* @param {string} service - The service where the post is located
* @param {number | string} creator_id - The ID of the creator
* @param {string} [q] - Search query
*/
async all_posts(service, creator_id, q) {
const posts = [];
let offset = 0;
let api_result = null;
while (!api_result || api_result.length === 50) {
api_result = await Posts.posts(service, creator_id, q, offset);
posts.push(...api_result);
offset += 50;
}
return posts;
}
};
const API = {
get key() { return api_key; },
set key(val) { api_key = val; },
Posts, Creators,
Custom,
callApi
};
return API;
/**
* callApi detail object
* @typedef {Object} api_detail
* @property {string} endpoint - api endpoint
* @property {Object} [search] - search params
* @property {string} [method='GET']
* @property {boolean | string} [auth=false] - whether to use api-key in this request; true for send, false for not, and string for sending a specific key (instead of pre-configured `api_key`); defaults to false
*/
/**
* Do basic kemono api request
* This is the queued version of _callApi
* @param {api_detail} detail
* @returns
*/
function callApi(...args) {
return queueTask(() => _callApi(...args), 'callApi');
}
/**
* Do basic kemono api request
* @param {api_detail} detail
* @returns
*/
function _callApi(detail) {
const search_string = new URLSearchParams(detail.search).toString();
const url = `https://kemono.su/api/v1/${detail.endpoint.replace(/^\//, '')}` + (search_string ? '?' + search_string : '');
const method = detail.method ?? 'GET';
const auth = detail.auth ?? false;
return new Promise((resolve, reject) => {
auth && api_key === null && reject('api key not found');
const options = {
method, url,
headers: {
accept: 'application/json'
},
onload(e) {
try {
e.status === 200 ? resolve(JSON.parse(e.responseText)) : reject(e.responseText);
} catch(err) {
reject(err);
}
},
onerror: err => reject(err)
}
if (typeof auth === 'string') {
options.headers.Cookie = auth;
} else if (auth === true) {
options.headers.Cookie = api_key;
}
GM_xmlhttpRequest(options);
});
}
}
}, {
id: 'gui',
desc: 'reusable GUI components',
dependencies: 'dependencies',
async func() {
class ProgressBoard {
/** @type {Vue} */
app;
/** Vue component instance */
instance;
/** @typedef {{ finished: number, total: number }} progress */
/** @typedef {{ name: string, progress: progress }} item */
/** @type {item[]} */
items;
constructor() {
const that = this;
this.items = [];
// GUI
const container = $$CrE({ tagName: 'div', styles: { position: 'fixed', zIndex: '-1' } });
const board = $$CrE({
tagName: 'div',
classes: 'board'
});
board.innerHTML = `
<q-layout view="hhh lpr fff">
<q-dialog v-model="show" :class="{ mobile: $q.platform.is.mobile }" :position="$q.platform.is.mobile ? 'standard' : 'bottom'" seamless :full-width="$q.platform.is.mobile" :full-height="$q.platform.is.mobile">
<q-card class="container-card">
<q-card-section class="header row">
<div class="text-h6">${ CONST.Text.ProgressBoardTitle }</div>
<q-space></q-space>
<q-btn :icon="minimized ? 'expand_less' : 'expand_more'" flat round dense @click="minimized = !minimized"></q-btn>
<q-btn icon="close" flat round dense v-close-popup></q-btn>
</q-card-section>
<q-slide-transition>
<q-card-section class="body" v-show="!minimized">
<q-list class="list" :class="{ minimized: minimized }">
<q-item tag="div" v-for="item of items">
<q-item-section>
<q-item-label>{{ item.name }}</q-item-label>
</q-item-section>
<q-item-section>
<q-linear-progress animation-speed="500" :indeterminate="item.progress.total === 0" :value="item.progress.total > 0 ? item.progress.finished / item.progress.total : 0" :color="item.progress.total > 0 && item.progress.total === item.progress.finished ? 'green' : 'blue'"></q-linear-progress>
</q-item-section>
</q-item>
</q-list>
</q-card-section>
</q-slide-transition>
</q-card>
</q-dialog>
</q-layout>
`;
container.append(board);
detectDom('html').then(html => html.append(container));
detectDom('head').then(head => addStyle(`
:is(.container-card):not(.mobile *) {
max-width: 45vw;
}
.container-card :is(.header, .body):not(.mobile *) {
width: 40vw;
}
.container-card :is(.body .list):not(.mobile *) {
height: 40vh;
overflow-y: auto;
}
.container-card :is(.body .list.minimized):not(.mobile *) {
overflow-y: hidden;
}
`, 'progress-board-style'));
this.app = Vue.createApp({
data() {
return {
items: that.items,
minimized: false,
show: false
}
},
methods: {
debug() {
debugger;
}
},
mounted() {
that.instance = this;
}
});
this.app.use(Quasar);
this.app.mount(board);
}
/**
* update item's progress display on progress_board
* @param {string} name - must be unique among all items
* @param {progress} progress
*/
update(name, progress) {
let item = this.instance.items.find(item => item.name === name);
if (!item) {
item = { name, progress };
this.instance.items.push(item);
}
item.progress = progress;
}
/**
* remove an item
* @param {string} name
*/
remove(name) {
let item_index = this.instance.items.findIndex(item => item.name === name);
if (item_index === -1) { return null; }
return this.instance.items.splice(item_index, 1)[0];
}
/**
* remove all existing items
*/
clear() {
this.instance.items.splice(0, this.instance.items.length);
}
get minimized() {
return this.instance.minimized;
}
set minimized(val) {
this.instance.minimized = !!val;
}
get closed() {
return !this.instance.show;
}
set closed(val) {
this.instance.show = !val;
}
}
const board = new ProgressBoard();
class CustomDownloadPanel {
app;
instance;
#promise; // Promise to be created on show() call, and resolved on user submit
#resolve; // resolve function for the promise above
constructor() {
const that = this;
// GUI
const container = $$CrE({ tagName: 'div', styles: { position: 'fixed', zIndex: '-1' } });
const panel = $$CrE({
tagName: 'div',
classes: 'panel'
});
panel.innerHTML = `
<q-layout view="hhh lpr fff">
<q-dialog v-model="show" :class="{ mobile: $q.platform.is.mobile }" :full-width="$q.platform.is.mobile" :full-height="$q.platform.is.mobile" @hide="cancel">
<q-card class="container-card-custom-dl">
<q-card-section class="header row">
<div class="text-h6">${ CONST.Text.CustomDownload.PopupTitle }</div>
<q-space></q-space>
<q-btn icon="close" flat round dense v-close-popup></q-btn>
</q-card-section>
<q-card-section class="body q-pa-md scroll">
<q-list>
<q-item>
<q-item-section>
<q-select hide-bottom-space filled v-model="download_type" :options="avail_dl_types" label="${ CONST.Text.CustomDownload.TypeLabel }" ref="dltype_ref" :rules="[ val => !!val ]" lazy-rules></q-select>
</q-item-section>
</q-item>
<q-item>
<q-item-section>
<q-select hide-bottom-space filled v-model="service" :options="avail_services" label="${ CONST.Text.CustomDownload.ServiceLabel }" ref="service_ref" :rules="[ val => !!val ]" lazy-rules></q-select>
</q-item-section>
</q-item>
<q-item>
<q-item-section>
<q-input hide-bottom-space filled type="number" v-model.number="creator_id" label="${ CONST.Text.CustomDownload.CreatorLabel }" ref="creator_ref" :rules="[ val => !!val ]" lazy-rules></q-input>
</q-item-section>
</q-item>
<q-item v-if="download_type.value === 'post'">
<q-item-section>
<q-input hide-bottom-space filled type="number" v-model.number="post_id" label="${ CONST.Text.CustomDownload.PostLabel }" ref="post_ref" :rules="[ val => download_type.value !== 'post' || !!val ]" lazy-rules></q-input>
</q-item-section>
</q-item>
<q-item>
<q-item-section>
<q-input hide-bottom-space filled v-model="ext_filter" label-slot>
<template v-slot:label>
<div class="row items-center all-pointer-events">
${ CONST.Text.CustomDownload.ExtFilterLabel }
<q-tooltip class="bg-grey-8" anchor="top left" self="bottom left" :offset="[0, 8]">
${ CONST.Text.CustomDownload.ExtFilterTooltip }
</q-tooltip>
</div>
</template>
</q-input>
</q-item-section>
</q-item>
<q-item tag="label" clickable>
<q-item-section>
<q-item-label>${ CONST.Text.CustomDownload.NoPrefixLabel }</q-item-label>
</q-item-section>
<q-item-section side top>
<q-checkbox left-label v-model="no_prefix"></q-checkbox>
</q-item-section>
</q-item>
<q-item tag="label" clickable>
<q-item-section>
<q-item-label>${ CONST.Text.CustomDownload.FlattenFilesLabel }</q-item-label>
<q-item-label caption>${ CONST.Text.CustomDownload.FlattenFilesTooltip }</q-item-label>
</q-item-section>
<q-item-section side top>
<q-checkbox left-label v-model="flatten_files"></q-checkbox>
</q-item-section>
</q-item>
</q-list>
</q-card-section>
<q-card-actions :align="$q.platform.is.mobile ? 'center' : 'right'">
<q-btn flat v-close-popup>${ CONST.Text.CustomDownload.Cancel }</q-btn>
<q-btn flat @click="submit" :loading="loading" color="primary">${ CONST.Text.CustomDownload.Download }</q-btn>
</q-card-action>
</q-card>
</q-dialog>
</q-layout>
`;
container.append(panel);
detectDom('html').then(html => html.append(container));
detectDom('head').then(head => addStyle(`
.container-card-custom-dl :is([type=text], input[type=password], input[type=number]) {
box-shadow: unset;
background: unset;
}
.container-card-custom-dl :is(.header, .body):not(.mobile *) {
width: 30vw;
min-width: 175px;
}
.container-card-custom-dl .body {
max-height: 75vh;
}
`));
this.app = Vue.createApp({
data() {
return {
panel: that,
show: false,
autoclose: true,
download_type: null,
service: '',
creator_id: 0,
post_id: 0,
ext_filter: '',
no_prefix: false,
flatten_files: false,
loading: false,
avail_dl_types: [{
label: CONST.Text.CustomDownload.Type.Post,
value: 'post'
}, {
label: CONST.Text.CustomDownload.Type.Creator,
value: 'creator'
}],
avail_services: [{
"label": "Patreon",
"value": "patreon"
}, {
"label": "Pixiv Fanbox",
"value": "fanbox"
}, {
"label": "Discord",
"value": "discord"
}, {
"label": "Fantia",
"value": "fantia"
}, {
"label": "Afdian",
"value": "afdian"
}, {
"label": "Boosty",
"value": "boosty"
}, {
"label": "Gumroad",
"value": "gumroad"
}, {
"label": "SubscribeStar",
"value": "subscribestar"
}, {
"label": "DLsite",
"value": "dlsite"
}]
}
},
methods: {
submit() {
if (!this.validate()) { return; }
this.show = !this.autoclose;
this.resolve({
download_type: this.download_type.value,
service: this.service.value,
creator_id: this.creator_id,
post_id: this.post_id,
ext_filter: this.ext_filter.split(/[, ]+/).map(ext => ext.replace(/^\.+/, '')).filter(ext => ext.length),
no_prefix: this.no_prefix,
flatten_files: this.flatten_files,
});
},
cancel() {
// This will also be invoked after download button clicked
// Because the dialog popup will be closed after download button clicked
// Since only the first call to the resolve function takes effect to the promise
// This does not make anything wrong
this.resolve(null);
},
validate() {
const refs = ['dltype_ref', 'service_ref', 'creator_ref', 'post_ref'].map(ref_name => this.$refs[ref_name]).filter(ref => !!ref);
refs.forEach(ref => ref.validate());
return !refs.some(ref => ref.hasError);
}
},
mounted() {
that.instance = this;
}
});
this.app.use(Quasar);
this.app.mount(panel);
}
get loading() {
return this.instance.loading;
}
set loading(val) {
this.instance.loading = !!val;
}
get showing() {
return this.instance.show;
}
/** @typedef {'post' | 'creator'} download_type */
/** @typedef {'patreon' | 'fanbox' | 'discord' | 'fantia' | 'afdian' | 'boosty' | 'gumroad' | 'subscribestar' | 'dlsite'} kemono_service */
/**
* Display and wait for user submit
* @param {Object} defaultValue
* @param {download_type} defaultValue.download_type
* @param {kemono_service} defaultValue.service
* @param {number | string} defaultValue.creator_id
* @param {number | string} [defaultValue.post_id]
* @returns {Promise<null | { download_type: download_type, service: kemono_service, creator_id: number, post_id?: number, autoclose: boolean }>}
*/
show({
download_type = 'post', no_prefix = false, flatten_files = false,
service = 'patreon', creator_id = null, post_id = null,
autoclose = true
} = {}) {
if (this.showing) { return this.#promise; }
({ promise: this.#promise, resolve: this.#resolve } = Promise.withResolvers());
this.instance.resolve = this.#resolve;
this.instance.download_type = this.instance.avail_dl_types.find(obj => obj.value === download_type);
this.instance.service = this.instance.avail_services.find(obj => obj.value === service);
this.instance.creator_id = parseInt(creator_id, 10);
this.instance.post_id = parseInt(post_id, 10);
this.instance.autoclose = autoclose;
this.instance.no_prefix = no_prefix;
this.instance.flatten_files = flatten_files;
this.instance.show = true;
return this.#promise;
}
close() {
this.instance.show = false;
}
}
const panel = new CustomDownloadPanel();
class PostsSelector {
app;
instance;
posts;
#promise; // Promise to be created on show() call, and resolved on user submit
#resolve; // resolve function for the promise above
/**
* @typedef {Object} post
* @property {number} id
* @property {number} user
* @property {string} service
* @property {string} title
* @property {string} content
* @property {Object} embed
* @property {boolean} shared_file
* @property {string} added
* @property {string} published
* @property {string} edited
* @property {Object} file
* @property {Object} attachments
* @property {*} poll
* @property {*} captions
* @property {*} tags
*/
constructor() {
const that = this;
// GUI
const container = $$CrE({ tagName: 'div', styles: { position: 'fixed', zIndex: '-1' } });
const panel = $$CrE({
tagName: 'div',
classes: 'panel'
});
panel.innerHTML = `
<q-layout view="hhh lpr fff">
<q-dialog v-model="show" :class="{ mobile: $q.platform.is.mobile }" :full-width="$q.platform.is.mobile" :full-height="$q.platform.is.mobile" @hide="cancel">
<q-card class="container-card-posts-selector">
<q-card-section class="header row">
<div class="text-h6">${ CONST.Text.PostsSelector.Title }</div>
<q-space></q-space>
<q-btn icon="close" flat round dense v-close-popup></q-btn>
</q-card-section>
<q-card-section class="body q-pa-md scroll">
<q-list separator>
<q-item tag="label" clickable v-ripple>
<q-item-section>
<q-item-label lines="1">
<div class="text-subtitle1">${ CONST.Text.PostsSelector.SelectAll }</div>
</q-item-label>
</q-item-section>
<q-item-section side>
<q-checkbox v-model="select_all" @update:model-value="val => selectAll(val)"></q-checkbox>
</q-item-section>
</q-item>
<q-item v-for="post of posts" tag="label" clickable v-ripple>
<q-item-section avatar>
<q-avatar square>
<q-img loading="lazy" ratio="1" fit="cover" :src="post.file.path" v-if="!!post.file?.path"></q-img>
</q-avatar>
</q-item-section>
<q-item-section>
<q-item-label lines="1">{{ post.title }}</q-item-label>
</q-item-section>
<q-item-section side>
<q-checkbox v-model="selected_posts" :val="post" @update:model-value="onSelect"></q-checkbox>
</q-item-section>
</q-item>
</q-list>
</q-card-section>
<q-card-actions :align="$q.platform.is.mobile ? 'center' : 'right'">
<q-btn flat v-close-popup>${ CONST.Text.PostsSelector.Cancel }</q-btn>
<q-btn flat @click="submit" color="primary">${ CONST.Text.PostsSelector.OK }</q-btn>
</q-card-action>
</q-card>
</q-dialog>
</q-layout>
`;
container.append(panel);
detectDom('html').then(html => html.append(container));
detectDom('head').then(head => addStyle(`
.container-card-posts-selector :is(.header, .body):not(.mobile *) {
min-width: 175px;
}
.container-card-posts-selector .body {
max-height: 75vh;
}
`));
this.app = Vue.createApp({
data() {
return {
selector: that,
show: false,
select_all: false,
/** @type {post[]} */
posts: [],
/** @type {post[]} */
selected_posts: [],
}
},
methods: {
submit() {
if (!this.validate()) { return; }
this.show = false;
this.resolve(this.selected_posts.map(
post => this.selector.posts.find(p => p.id === post.id)
));
},
cancel() {
// This will also be invoked after submit button clicked
// Because the dialog popup will be closed after download button clicked
// Since only the first call to the resolve function takes effect to the promise
// This does not make anything wrong
this.selected_posts.splice(0, this.selected_posts.length);
this.resolve(null);
},
validate() {
const refs = [].map(ref_name => this.$refs[ref_name]).filter(ref => !!ref);
refs.forEach(ref => ref.validate());
return !refs.some(ref => ref.hasError);
},
selectAll(selected) {
if (selected ? this.selected_posts.length === this.posts.length : !this.selected_posts.length) { return; }
this.selected_posts.splice(0, this.selected_posts.length);
selected && this.selected_posts.push(...this.posts);
selected && !this.select_all && (this.select_all = true);
},
onSelect() {
// Sort selected_posts by posts
this.selected_posts.sort((p1, p2) => this.posts.indexOf(p2) - this.posts.indexOf(p1));
// Update select_all status
const select_all = this.selected_posts.length === this.posts.length ? true : (this.selected_posts.length ? null : false);
select_all !== this.select_all && (this.select_all = select_all);
}
},
mounted() {
that.instance = this;
}
});
this.app.use(Quasar);
this.app.mount(panel);
}
/**
*
* @param {Object} detail
* @param {post[]} detail.posts
* @param {post[]} [detail.select_all] - whether all posts to be selected by default, true if omitted
* @returns
*/
show({ posts, select_all = true }) {
if (this.showing) { return this.#promise; }
({ promise: this.#promise, resolve: this.#resolve } = Promise.withResolvers());
this.posts = posts;
this.instance.resolve = this.#resolve;
this.instance.posts = posts;
this.instance.selectAll(select_all);
this.instance.show = true;
return this.#promise;
}
}
const selector = new PostsSelector();
return { ProgressBoard, board, CustomDownloadPanel, panel, PostsSelector, selector };
}
}, {
id: 'downloader',
desc: 'core zip download utils',
dependencies: ['utils', 'api', 'settings'],
async func() {
const utils = require('utils');
const API = require('api');
const settings = require('settings');
// Performance record
const perfmon = new utils.PerformanceManager();
perfmon.newTask('fetchPost');
perfmon.newTask('saveAs');
perfmon.newTask('_fetchBlob');
class DownloaderItem {
/** @typedef {'file' | 'folder'} downloader_item_type */
/**
* Name of the item, CANNOT BE PATH
* @type {string}
*/
name;
/** @type {downloader_item_type} */
type;
/**
* @param {string} name
* @param {downloader_item_type} type
*/
constructor(name, type) {
this.name = name;
this.type = type;
}
}
class DownloaderFile extends DownloaderItem{
/** @type {Blob} */
data;
/** @type {Date} */
date;
/** @type {string} */
comment;
/**
* @param {string} name - name only, CANNOT BE PATH
* @param {Blob} data
* @param {Object} detail
* @property {Date} [date]
* @property {string} [comment]
*/
constructor(name, data, detail) {
super(name, 'file');
this.data = data;
Object.assign(this, detail);
}
zip(jszip_instance) {
const z = jszip_instance ?? new JSZip();
const options = {};
this.date && (options.date = this.date);
this.comment && (options.comment = this.comment);
z.file(this.name, this.data, options);
return z;
}
}
class DownloaderFolder extends DownloaderItem {
/** @type {Array<DownloaderFile | DownloaderFolder>} */
children;
/**
* @param {string} name - name only, CANNOT BE PATH
* @param {Array<DownloaderFile | DownloaderFolder>} [children]
*/
constructor(name, children) {
super(name, 'folder');
this.children = children && children.length ? children : [];
}
zip(jszip_instance) {
const z = jszip_instance ?? new JSZip();
for (const child of this.children) {
switch (child.type) {
case 'file': {
child.zip(z);
break;
}
case 'folder': {
const sub_z = z.folder(child.name);
child.zip(sub_z);
}
}
}
return z;
}
}
/**
* @typedef {Object} JSZip
*/
/**
* @typedef {Object} zipObject
*/
/**
* Download one post in zip file
* @param {Object} detail
* @param {string} detail.service
* @param {number | string} detail.creator_id
* @param {number | string} detail.post_id
* @param {function} [detail.callback] - called each time made some progress, with two numeric arguments: finished_steps and total_steps
* @param {boolean} [detail.flatten_files]
* @param {boolean} [detail.no_prefix]
* @param {string[]} [detail.ext_filter]
*/
async function downloadPost({
service, creator_id, post_id,
callback = function() {},
flatten_files, no_prefix, ext_filter
} = {}) {
const manager = new utils.ProgressManager(3, callback, {
layer: 'root', service, creator_id, post_id
});
const data = await manager.progress(API.Posts.post(service, creator_id, post_id));
const folder = await manager.progress(fetchPost({ api_data: data, manager, flatten_files, no_prefix, ext_filter }));
const zip = folder.zip();
const filename = `${data.post.title}.zip`;
manager.progress(await saveAs(filename, zip, manager));
}
/**
* @typedef {Object} PostInfo
* @property {string} service,
* @property {number} creator_id
* @property {number} post_id
*/
/**
* Download one or multiple posts in zip file, one folder for each post
* @param {Object} detail
* @param {PostInfo | PostInfo[]} detail.posts
* @param {string} detail.filename - file name of final zip file to be delivered to the user
* @param {*} detail.callback - Progress callback, like downloadPost's callback param
* @param {boolean} [detail.flatten_files]
* @param {boolean} [detail.no_prefix]
* @param {string[]} [detail.ext_filter]
*/
async function downloadPosts({
posts, filename,
callback = function() {},
flatten_files, no_prefix, ext_filter
} = {}) {
Array.isArray(posts) || (posts = [posts]);
const manager = new utils.ProgressManager(posts.length + 1, callback, {
layer: 'root', posts, filename
});
// Fetch posts
const post_folders = await Promise.all(
posts.map(async post => {
const data = await API.Posts.post(post.service, post.creator_id, post.post_id);
const folder = await fetchPost({ api_data: data, manager, flatten_files, no_prefix, ext_filter });
await manager.progress();
return folder;
})
);
// Merge all post's folders into one
const folder = new DownloaderFolder(filename);
post_folders.map(async post_folder => {
folder.children.push(post_folder);
})
// Convert folder to zip
const zip = folder.zip();
// Deliver to user
await manager.progress(saveAs(filename, zip, manager));
}
/**
* Fetch one post
* @param {Object} detail
* @param {Object} detail.api_data - kemono post api returned data object
* @param {utils.ProgressManager} detail.manager
* @param {boolean} [detail.flatten_files]
* @param {boolean} [detail.no_prefix]
* @param {string[]} [detail.ext_filter]
* @returns {Promise<DownloaderFolder>}
*/
async function fetchPost({ api_data, manager, flatten_files, no_prefix, ext_filter }) {
const perfmon_run = perfmon.run('fetchPost', api_data);
const sub_manager = manager.sub(0, manager.callback, {
layer: 'post', data: api_data
});
flatten_files = flatten_files !== undefined ? flatten_files : settings.flatten_files;
no_prefix = no_prefix !== undefined ? no_prefix : settings.no_prefix;
const date = new Date(api_data.post.edited);
const folder = new DownloaderFolder(escapePath(api_data.post.title), [
...settings.save_apijson ? [new DownloaderFile('data.json', JSON.stringify(api_data))] : [],
...settings.save_content ? [new DownloaderFile('content.html', api_data.post.content, { date })] : []
]);
let attachments_folder = folder;
if (api_data.post.attachments.length && !flatten_files) {
attachments_folder = new DownloaderFolder('attachments');
folder.children.push(attachments_folder);
}
const tasks = [
// api_data.post.file
(async function(file) {
if (!file.path) { return; }
const ext = getFileExt(file);
if (ext_filter && ext_filter.length && !ext_filter.includes(ext)) { return; }
sub_manager.add();
const prefix = no_prefix ? '' : 'file-';
const ori_name = getFileName(file);
const name = escapePath(prefix + ori_name);
const url = getFileUrl(file);
const blob = await sub_manager.progress(fetchBlob(url, sub_manager));
folder.children.push(new DownloaderFile(
name, blob, {
date,
comment: JSON.stringify(file)
}
));
}) (api_data.post.file),
// api_data.post.attachments
...api_data.post.attachments.map(async (attachment, i) => {
if (!attachment.path) { return; }
const ext = getFileExt(attachment);
if (ext_filter && ext_filter.length && !ext_filter.includes(ext)) { return; }
sub_manager.add();
const prefix = no_prefix ? '' : `${ utils.fillNumber(i+1, api_data.post.attachments.length.toString().length) }-`;
const ori_name = getFileName(attachment);
const name = escapePath(prefix + ori_name);
const url = getFileUrl(attachment);
const blob = await sub_manager.progress(fetchBlob(url, sub_manager));
attachments_folder.children.push(new DownloaderFile(
name, blob, {
date,
comment: JSON.stringify(attachment)
}
));
}),
];
await Promise.all(tasks);
// Make sure sub_manager finishes even when no async tasks
if (sub_manager.steps === 0) {
sub_manager.steps = 1;
await sub_manager.progress();
}
perfmon_run.stop();
return folder;
/**
* @typedef {Object} kemono_file
* @property {string} path
* @property {string} [name]
*/
/**
* @param {kemono_file} file
* @returns {string}
*/
function getFileName(file) {
return file.name || file.path.slice(file.path.lastIndexOf('/')+1);
}
/**
* @param {kemono_file} file
* @returns {string}
*/
function getFileUrl(file) {
return (file.server ?? 'https://n1.kemono.su') + '/data' + file.path;
}
/**
* @param {kemono_file} file
* @returns {string} file extension name, not including '.'
*/
function getFileExt(file) {
const name = getFileName(file);
return name.slice(name.lastIndexOf('.') + 1);
}
}
/**
* Deliver zip file to user
* @param {string} filename - filename (with extension, e.g. "file.zip")
* @param {JSZip} zip,
* @param {string | null} comment - zip file comment
*/
async function saveAs(filename, zip, manager, comment=null) {
const perfmon_run = perfmon.run('saveAs', filename);
const sub_manager = manager.sub(100, manager.callback, {
layer: 'zip', filename, zip
});
const options = { type: 'blob' };
comment !== null && (options.comment = comment);
const blob = await zip.generateAsync(options, metadata => sub_manager.progress(null, metadata.percent));
const url = URL.createObjectURL(blob);
const a = $$CrE({
tagName: 'a',
attrs: {
download: filename,
href: url
}
});
a.click();
perfmon_run.stop();
}
/**
* Fetch blob data from given url \
* Queued function of _fetchBlob
* @param {string} url
* @param {utils.ProgressManager} [manager]
* @returns {Promise<Blob>}
*/
function fetchBlob(...args) {
if (!fetchBlob.initialized) {
queueTask.fetchBlob = {
max: 3,
sleep: 0
};
fetchBlob.initialized = true;
}
return queueTask(() => _fetchBlob(...args), 'fetchBlob');
}
/**
* Fetch blob data from given url
* @param {string} url
* @param {utils.ProgressManager} [manager]
* @param {number} [retry=3] - times to retry before throwing an error
* @returns {Promise<Blob>}
*/
async function _fetchBlob(url, manager, retry = 3) {
const perfmon_run = perfmon.run('_fetchBlob', url);
const sub_manager = manager.sub(0, manager.callback, {
layer: 'file', url
});
const blob = await new Promise((resolve, reject) => {
GM_xmlhttpRequest({
method: 'GET', url,
responseType: 'blob',
async onprogress(e) {
sub_manager.steps = e.total;
await sub_manager.progress(null, e.loaded);
},
onload(e) {
e.status === 200 ? resolve(e.response) : onerror(e)
},
onerror
});
async function onerror(err) {
if (retry) {
await sub_manager.progress(null, -1);
const result = await _fetchBlob(url, manager, retry - 1);
resolve(result);
} else {
reject(err)
}
}
});
perfmon_run.stop();
return blob;
}
/**
* Replace unallowed special characters in a path part
* @param {string} path - a part of path, such as a folder name / file name
*/
function escapePath(path) {
// Replace special characters
const chars_bank = {
'\\': '＼',
'/': '／',
':': '：',
'*': '＊',
'?': '？',
'"': "'",
'<': '＜',
'>': '＞',
'|': '｜'
};
for (const [char, replacement] of Object.entries(chars_bank)) {
path = path.replaceAll(char, replacement);
}
// Disallow ending with dots
path.endsWith('.') && (path += '_');
return path;
}
return {
downloadPost, downloadPosts,
fetchPost, saveAs,
perfmon
};
}
}, {
id: 'settings',
detectDom: 'html',
dependencies: 'dependencies',
params: ['GM_setValue', 'GM_getValue'],
async func(GM_setValue, GM_getValue) {
// settings 数据，所有设置项在这里配置
/**
* @typedef {Object} setting
* @property {string} title - 设置项名称
* @property {string | null} [caption] - 设置项副标题，可以省略；为假值时不渲染副标题元素
* @property {string} key - 用作settings 读/写对象的prop名称，也用作v-model值
* @property {string} storage - GM存储key
* @property {*} default - 用户未设置过时的默认值（初始值）
*/
/** @type {setting[]} */
const settings_data = [{
title: CONST.Text.SaveContent,
caption: 'content.html',
key: 'save_content',
storage: 'save_content',
default: true,
}, {
title: CONST.Text.SaveApijson,
caption: 'data.json',
key: 'save_apijson',
storage: 'save_apijson',
default: true,
}, {
title: CONST.Text.NoPrefix,
key: 'no_prefix',
storage: 'no_prefix',
default: false,
}, {
title: CONST.Text.FlattenFiles,
caption: CONST.Text.FlattenFilesCaption,
key: 'flatten_files',
storage: 'flatten_files',
default: false
}];
// settings 读/写对象，既用于oFunc内读写，也直接作为oFunc返回值提供给其他功能函数
const settings = {};
settings_data.forEach(setting => {
Object.defineProperty(settings, setting.key, {
get() {
return GM_getValue(setting.storage, setting.default);
},
set(val) {
GM_setValue(setting.storage, !!val);
}
});
});
// 创建设置界面
const container = $$CrE({
tagName: 'div',
styles: { all: 'initial', position: 'fixed' }
})
const app_elm = $CrE('div');
app_elm.innerHTML = `
<q-layout view="hhh lpr fff">
<q-dialog v-model="show">
<q-card>
<q-card-section>
<div class="text-h6">${ CONST.Text.Settings }</div>
</q-card-section>
<q-card-section style="max-height: 75vh;" class="scroll">
<q-list>
<q-item tag="label" v-for="setting of settings_data" v-ripple>
<q-item-section>
<q-item-label>{{ setting.title }}</q-item-label>
<q-item-label caption v-if="setting.caption">{{ setting.caption }}</q-item-label>
</q-item-section>
<q-item-section avatar>
<q-toggle color="primary" v-model="settings[setting.key]" @update:model-value="val => settings[setting.key] = val"></q-toggle>
</q-item-section>
</q-item>
</q-list>
</q-card-section>
</q-card>
</q-dialog>
</q-layout>
`;
container.append(app_elm);
$('html').append(container);
const app = Vue.createApp({
data() {
return {
show: false,
settings_data,
settings
};
},
mounted() {
GM_registerMenuCommand(CONST.Text.Settings, e => this.show = true);
GM_addValueChangeListener('settings', () => {
this.save_content = settings.save_content;
this.save_apijson = settings.save_apijson;
});
}
});
app.use(Quasar);
app.mount(app_elm);
return settings;
}
}, {
id: 'user-interface',
dependencies: ['utils', 'api', 'downloader', 'gui', 'settings'],
async func() {
const utils = require('utils');
const api = require('api');
const downloader = require('downloader');
const settings = require('settings');
const gui = require('gui');
let downloading = false;
let selector = null;
// Console User Interface
const ConsoleUI = utils.window.ZIP = {
version: GM_info.script.version,
require,
api, downloader,
get ui() { return require('user-interface') },
downloadCurrentPost, downloadCurrentCreator, userDownload, getPageType
};
// Menu User Interface
GM_registerMenuCommand(CONST.Text.DownloadPost, downloadCurrentPost);
GM_registerMenuCommand(CONST.Text.DownloadCreator, downloadCurrentCreator);
GM_registerMenuCommand(CONST.Text.DownloadCustom, downloadCustom);
// Graphical User Interface
// Make button
const dlbtn = $$CrE({
tagName: 'button',
styles: {
'background-color': 'transparent',
'color': 'white',
'border': 'transparent'
},
listeners: [['click', userDownload]]
});
const dltext = $$CrE({
tagName: 'span',
props: {
innerText: CONST.Text.DownloadZip
}
});
const dlprogress = $$CrE({
tagName: 'span',
styles: {
display: 'none',
'margin-left': '10px'
}
});
dlbtn.append(dltext);
dlbtn.append(dlprogress);
const board = gui.board;
// Place button each time a new action panel appears (meaning navigating into a post page)
let observer;
detectDom({
selector: '.post__actions, .user-header__actions',
callback: action_panel => {
// Hide dlprogress, its content is still for previous page
dlprogress.style.display = 'none';
// Append to action panel
action_panel.append(dlbtn);
// Disconnect old observer
observer?.disconnect();
// Observe action panel content change, always put download button in last place
observer = detectDom({
root: action_panel,
selector: 'button',
callback: btn => btn !== dlbtn && action_panel.append(dlbtn)
});
}
});
return {
ConsoleUI,
dlbtn, dltext,
get ['selector']() { return selector; },
downloadCurrentPost, downloadCurrentCreator,
getCurrentPost, getCurrentCreator, getPageType
}
function userDownload() {
const page_type = getPageType();
const func = ({
post: downloadCurrentPost,
creator: downloadCurrentCreator
})[page_type] ?? function() {};
return func();
}
async function downloadCurrentPost() {
const post_info = getCurrentPost();
if (downloading) { return; }
if (!post_info) { return; }
try {
downloading = true;
dlprogress.style.display = 'inline';
dltext.innerText = CONST.Text.Downloading;
board.minimized = false;
board.closed = false;
board.clear();
await downloader.downloadPost({
service: post_info.service,
creator_id: post_info.creator_id,
post_id: post_info.post_id,
callback: on_progress
});
} finally {
downloading = false;
dltext.innerText = CONST.Text.DownloadZip;
}
function on_progress(finished_steps, total_steps, manager) {
const info = manager.info;
info.layer === 'root' && (dlprogress.innerText = `(${finished_steps}/${total_steps})`);
const progress = { finished: finished_steps, total: total_steps };
info.layer === 'root' && board.update(CONST.Text.TotalProgress, progress);
info.layer === 'post' && board.update(info.data.post.title, progress);
info.layer === 'file' && board.update(info.url, progress);
info.layer === 'zip' && board.update(info.filename, progress);
board.closed = false;
}
}
async function downloadCurrentCreator() {
const creator_info = getCurrentCreator();
if (downloading) { return; }
if (!creator_info) { return; }
try {
downloading = true;
Quasar.Loading.show({ message: CONST.Text.FetchingCreatorPosts });
const [profile, selected_posts] = await Promise.all([
api.Creators.profile(creator_info.service, creator_info.creator_id),
selectCreatorPosts(creator_info, () => Quasar.Loading.hide())
]);
if (selected_posts) {
dlprogress.style.display = 'inline';
dltext.innerText = CONST.Text.Downloading;
board.minimized = false;
board.closed = false;
board.clear();
await downloader.downloadPosts({
posts: selected_posts.map(post => ({
service: creator_info.service,
creator_id: creator_info.creator_id,
post_id: post.id
})),
filename: `${profile.name}.zip`,
callback: on_progress
});
}
} finally {
downloading = false;
dltext.innerText = CONST.Text.DownloadZip;
}
function on_progress(finished_steps, total_steps, manager) {
const info = manager.info;
info.layer === 'root' && (dlprogress.innerText = `(${finished_steps}/${total_steps})`);
const progress = { finished: finished_steps, total: total_steps };
info.layer === 'root' && board.update(CONST.Text.TotalProgress, progress);
info.layer === 'post' && board.update(info.data.post.title, progress);
info.layer === 'file' && board.update(info.url, progress);
info.layer === 'zip' && board.update(info.filename, progress);
board.closed = false;
}
}
async function downloadCustom() {
if (downloading) { return; }
try {
const post_info = getCurrentPost();
const creator_info = getCurrentCreator();
const info = post_info ?? creator_info ?? {};
const dl_info = await gui.panel.show({
download_type: post_info ? 'post' : (creator_info ? 'creator' : undefined),
service: info.service ?? undefined,
creator_id: info.creator_id ?? undefined,
post_id: info.post_id ?? undefined,
autoclose: false,
no_prefix: settings.no_prefix,
flatten_files: settings.flatten_files
});
if (dl_info !== null) {
downloading = true;
if (dl_info.download_type === 'post') {
gui.panel.close();
board.minimized = false;
board.closed = false;
board.clear();
await downloader.downloadPost({
service: dl_info.service,
creator_id: dl_info.creator_id,
post_id: dl_info.post_id,
no_prefix: dl_info.no_prefix,
flatten_files: dl_info.flatten_files,
ext_filter: dl_info.ext_filter,
callback: on_progress
});
} else if (dl_info.download_type === 'creator') {
gui.panel.loading = true;
Assert(creator_info !== null, 'dl_info.download_type === "creator" but creator_info is null', TypeError);
const [profile, selected_posts] = await Promise.all([
api.Creators.profile(creator_info.service, creator_info.creator_id),
selectCreatorPosts(creator_info, () => {
gui.panel.loading = false;
gui.panel.close();
})
]);
if (selected_posts) {
dlprogress.style.display = 'inline';
dltext.innerText = CONST.Text.Downloading;
board.minimized = false;
board.closed = false;
board.clear();
await downloader.downloadPosts({
posts: selected_posts.map(post => ({
service: creator_info.service,
creator_id: creator_info.creator_id,
post_id: post.id,
})),
no_prefix: dl_info.no_prefix,
flatten_files: dl_info.flatten_files,
ext_filter: dl_info.ext_filter,
filename: `${profile.name}.zip`,
callback: on_progress
});
}
}
}
} finally {
downloading = false;
dltext.innerText = CONST.Text.DownloadZip;
}
function on_progress(finished_steps, total_steps, manager) {
const info = manager.info;
const progress = { finished: finished_steps, total: total_steps };
info.layer === 'root' && board.update(CONST.Text.TotalProgress, progress);
info.layer === 'post' && board.update(info.data.post.title, progress);
info.layer === 'file' && board.update(info.url, progress);
info.layer === 'zip' && board.update(info.filename, progress);
board.closed = false;
}
}
/**
* User select creator's posts
* @param {CreatorInfo} creator_info
* @param {function} onAjaxLoad - callback when api ajax loaded
* @returns
*/
async function selectCreatorPosts(creator_info, onAjaxLoad=function() {}) {
const posts = await api.Custom.all_posts(creator_info.service, creator_info.creator_id);
typeof onAjaxLoad === 'function' && onAjaxLoad();
const selected_posts = await gui.selector.show({ posts });
return selected_posts;
}
/**
* User select creator's posts
* @param {CreatorInfo} creator_info
* @param {function} onAjaxLoad - callback when api ajax loaded
* @returns
*/
async function _selectCreatorPosts(creator_info, onAjaxLoad=function() {}) {
const posts = await api.Custom.all_posts(creator_info.service, creator_info.creator_id);
typeof onAjaxLoad === 'function' && onAjaxLoad();
const selected_posts = await new Promise((resolve, reject) => {
if (!selector) {
selector = new ItemSelector();
selector.setTheme('dark');
selector.elements.container.style.setProperty('z-index', '1');
}
selector.show({
text: CONST.Text.SelectAll,
children: posts.map(post => ({
post,
text: post.title
}))
}, {
title: CONST.Text.DownloadCreator,
onok(e, json) {
const posts = json.children.map(obj => obj.post);
resolve(posts);
},
oncancel: e => resolve(null),
onclose: e => resolve(null)
});
});
return selected_posts;
}
/**
* @typedef {Object} PostInfo
* @property {string} service,
* @property {number} creator_id
* @property {number} post_id
*/
/**
* Get post info in current page
* @returns {PostInfo | null}
*/
function getCurrentPost() {
const regpath = /^\/([a-zA-Z]+)\/user\/(\d+)\/post\/(\d+)/;
const match = location.pathname.match(regpath);
if (!match) {
return null;
} else {
return {
service: match[1],
creator_id: parseInt(match[2], 10),
post_id: parseInt(match[3], 10)
}
}
}
/**
* @typedef {Object} CreatorInfo
* @property {string} service
* @property {number} creator_id
*/
/**
* Get creator info in current page
* @returns {CreatorInfo | null}
*/
function getCurrentCreator() {
const regpath = /^\/([a-zA-Z]+)\/user\/(\d+)/;
const match = location.pathname.match(regpath);
if (!match) {
return null;
} else {
return {
service: match[1],
creator_id: parseInt(match[2], 10)
}
}
}
/** @typedef { 'post' | 'creator' } page_type */
/**
* @returns {page_type}
*/
function getPageType() {
const matchers = {
post: {
type: 'regpath',
value: /^\/([a-zA-Z]+)\/user\/(\d+)\/post\/(\d+)/
},
creator: {
type: 'func',
value: () => /^\/([a-zA-Z]+)\/user\/(\d+)/.test(location.pathname) && !location.pathname.includes('/post/')
},
}
for (const [type, matcher] of Object.entries(matchers)) {
if (FunctionLoader.testCheckers(matcher)) {
return type;
}
}
}
},
}]);
}) ();
