obsidian-douban/src/org/wanxp/utils/HttpUtil.ts

import SettingsManager from "../douban/setting/SettingsManager";
import {Platform, RequestUrlResponse} from "obsidian";
import DesktopHttpUtil from "./desktop/DesktopHttpUtil";
import MobileHttpUtil from "./mobile/MobileHttpUtil";
import {HttpResponse} from "./model/HttpResponse";


export default class HttpUtil {

	private static readonly IMAGE_REQUEST_HEADERS_TO_DROP = new Set([
		'authority',
		'content-length',
		'content-type',
		'host',
		'origin',
		'referer',
		'sec-fetch-dest',
		'sec-fetch-mode',
		'sec-fetch-site',
		'sec-fetch-user',
	]);



	/**
	 * get请求
	 * @param url 请求地址
	 * @param headers 请求参数
	 * @param settingsManager 设置管理器
	 */
	// Cookie: 'll="108296"; bid=xHRJLeWBrjQ; _pk_id.100001.8cb4=f8f83e81ec224a1a.1691572669.; __utmv=30149280.13103; __yadk_uid=ce95W7OsgT0iKFceWgbMSUdw1oOqxNTk; __gads=ID=62585f60f3f637d0-2234f63fc6e200a5:T=1691572672:RT=1691572672:S=ALNI_MaIqTxSWHsfpnX9nAmMHcPQEsaezg; __gpi=UID=00000c29a9f98e5b:T=1691572672:RT=1691572672:S=ALNI_MbLAq8XNoKrRPKNqGCMdgXSPZvidw; ap_v=0,6.0; __utma=30149280.135860784.1691572641.1691572641.1694509646.2; __utmc=30149280; __utmz=30149280.1694509646.2.2.utmcsr=baidu|utmccn=(organic)|utmcmd=organic; _pk_ref.100001.8cb4=%5B%22%22%2C%22%22%2C1694509648%2C%22https%3A%2F%2Fmovie.douban.com%2Ftv%2F%22%5D; _pk_ses.100001.8cb4=1; __utmt=1; dbcl2="131038721:LUssju34QFw"; ck=dCQj; push_noty_num=0; push_doumail_num=0; __utmb=30149280.3.10.1694509646'
	public static async httpRequest(url: string, headers: any, settingsManager?: SettingsManager, options?: any): Promise<HttpResponse> {
		const {['Accept-Encoding']: acceptEncoding, ...headersInner} = headers;
		settingsManager.debug(`Obsidian-Douban:从网络获取json开始:\nurl:${url}\nheaders:${JSON.stringify(headers)}`);
		if (Platform.isDesktopApp) {
			return DesktopHttpUtil.request(url, headers, settingsManager, options)
		} else {
			const response = await MobileHttpUtil.httpRequestGet(url, headers, settingsManager);
			return new HttpResponse(response.status, response.headers, response.text);
		}
	}

	/**
	 * get请求
	 * @param url 请求地址
	 * @param headers 请求参数
	 * @param settingsManager 设置管理器
	 */
	public static async getText(url: string, headers: any, settingsManager?: SettingsManager): Promise<HttpResponse> {
		const {['Accept-Encoding']: acceptEncoding, ...headersInner} = headers;
		settingsManager.debug(`Obsidian-Douban:从网络获取json开始:\nurl:${url}\nheaders:${JSON.stringify(headers)}`);
		if (Platform.isDesktopApp) {
			return DesktopHttpUtil.request(url, headers, settingsManager, {method: 'GET'})
		} else {
			const response = await MobileHttpUtil.httpRequestGet(url, headers, settingsManager);
			return new HttpResponse(response.status, response.headers, response.text);
		}
	}

	/**
	 * get请求
	 * @param url 请求地址
	 * @param headers 请求参数
	 * @param settingsManager 设置管理器
	 */
	public static httpRequestBuffer(url: string, headers: any, settingsManager?: SettingsManager): Promise<HttpResponse> {
		if (Platform.isDesktopApp) {
			return DesktopHttpUtil.requestBuffer(url, headers, settingsManager)
		}else {
			return MobileHttpUtil.httpRequestGet(url, headers,  settingsManager).then((response: RequestUrlResponse) => {
				return new HttpResponse(response.status, response.headers, response.arrayBuffer);
			});
		}
	}

	public static buildImageRequestHeaders(headers: Record<string, any> = {}, referer?: string): Record<string, string> {
		const nextHeaders: Record<string, string> = {};
		Object.entries(headers || {}).forEach(([key, value]) => {
			if (value == null || value === '') {
				return;
			}
			const lowerKey = key.toLowerCase();
			if (lowerKey === 'referer') {
				return;
			}
			if (this.IMAGE_REQUEST_HEADERS_TO_DROP.has(lowerKey) || lowerKey.startsWith('sec-ch-ua')) {
				return;
			}
			nextHeaders[key] = String(value);
		});
		if (referer) {
			nextHeaders.Referer = referer;
		}
		return nextHeaders;
	}


	public static parse(url: string): { protocol: string, host: string, port: string, path: string } {
		const regex = /^(.*?):\/\/([^\/:]+)(?::(\d+))?([^?]*)$/;
		const matches = url.match(regex);

		if (matches) {
			const protocol = matches[1];
			const host = matches[2];
			const port = matches[3] || '';
			const path = matches[4];

			return { protocol, host, port, path };
		}

		throw new Error('Invalid URL');
	}

	public static replaceUrlPath(url: string, newPath: string): string {
		const regex = /^(https?:\/\/[^\/]+)(:\d+)?(\/.*)$/;
		const matches = url.match(regex);
		if (matches && matches.length === 4) {
			return matches[1] + (matches[2] || '') + newPath;
		}
		return url;
	}

	/**
	 * 提取url
	 * @param str
	 */
	public static extractURLFromString(str: string): string  {
		const urlRegex = /(?:!\[.*?\]\()?(https?:\/\/[^\s)]+)/g;
		const matches = str.match(urlRegex);
		if (matches && matches.length > 0) {
			return matches[0];
		}
		return str;
	}

	/**
	 * 将字符进行url编码
	 * @param keyword
	 */
	static encodeUrl(keyword: string) {
		if (!keyword) {
			return '';
		}
		return encodeURIComponent(keyword);
	}
}