apis.ts

import axios from "axios";
import { Notice } from "obsidian";

export const ApiSdk = axios.create({
	baseURL: "http://openapi.inner.foldspace.cn",

	timeout: 1000 * 60 * 8,
	headers: {
		"Content-type": "application/json",
		Accept: "text/json",
	},
});


export const uploadOneAttachments = async (file: File, fileName: string,
	setMassage: (message: string) => void
) => {
	const formData = new FormData();
	formData.append("files", file, fileName);
	const url = `http://openapi.inner.foldspace.cn/bff/v1/apps/obsidian/attachments/upload`;
	setMassage(`开始Ajax上传文件: ${fileName} size:${file.size} =>${url}`);
	//const response = await uploadFile(formData, url);
	const response = await await axios.post(url, formData, {
		headers: {
			'Content-Type': 'multipart/form-data', // 设置请求头
		},
		onDownloadProgress: (progressEvent) => {
			const { loaded, total } = progressEvent;
			const percentCompleted = Math.round((loaded * 100) / total);

			setMassage(`上传文件: ${fileName} 进度 ${percentCompleted}%`);
		},
	}).catch(err => {
		setMassage(`上传文件: ${fileName} 失败 ${err}`);
	});
	//@ts-ignore
	setMassage(`上传文件: ${fileName} 完成 ${JSON.stringify(response.data)}`);
	//@ts-ignore
	return response.data;
};

export const getChannels = async () => {
	const response = await ApiSdk.get("/bff/v1/apps/block-cutter/channels/");
	return response.data;
};

export const getObsidianToThinkGeneratePromptList = async () => {
	const response = await ApiSdk.get("/bff/v1/apps/block-cutter/get-studio-obsidian-to-think-generate-prompt-list/");
	return response.data;
};

export const runDifyFlow = async (values: any, setMassage: (message: string) => void) => {
	values.channel_id = parseInt(values.channel_id);
	values.prompt_id = parseInt(values.prompt_id);
	values.knowledge_is_required = parseInt(values.knowledge_is_required);
	values.documents = values.documents || [];

	values.if_run_doc_intro_workflow = parseInt(values.if_run_doc_intro_workflow);
	values.if_create_vector_db = parseInt(values.if_create_vector_db);
	values.knowledge_is_required = values.if_create_vector_db > 0 ? 1 : 0;
	const valuesTmp = { ...values }
	valuesTmp.doc_content = undefined
	new Notice(`开始运行流程 参数\n${JSON.stringify(valuesTmp)}`);
	setMassage(`开始运行流程 /bff/v1/apps/dify/tasks/do-obsidian-to-think-workflow`);
	setTimeout(() => {
		setMassage(`开始运行流程 .... 1 秒`);
	}, 500);
	setTimeout(() => {
		setMassage(`开始运行流程 .... 5 秒`);
	}, 5*1000);
	setTimeout(() => {
		setMassage(`开始运行流程 .... 8 秒`);
	}, 8*1000);
	const response = await ApiSdk.post("/bff/v1/apps/dify/tasks/do-obsidian-to-think-workflow", values,);
	const difyOut = response.data;
	setMassage(`运行流程完成 结果\n${JSON.stringify(difyOut,null,4)}`);
	return difyOut;
};