409 lines
17 KiB
JavaScript
409 lines
17 KiB
JavaScript
import { invoke } from "@tauri-apps/api/tauri";
|
|
import { IS_PLUGIN_PATH_DEV_MODE, getPluginsList } from "@ui_configs";
|
|
import {
|
|
createAtomWithHook,
|
|
useStore_SavedPluginsStatus,
|
|
useStore_PluginsData,
|
|
useStore_IsPluginsInitialized,
|
|
useStore_IsInitializedLoadPlugin,
|
|
useStore_IsFetchedPluginsInfo,
|
|
|
|
useStore_FetchedPluginsInfo,
|
|
useStore_LoadedPlugins,
|
|
} from "@store";
|
|
import { useStdoutToPython } from "@logics/useStdoutToPython";
|
|
|
|
import { transform } from "@babel/standalone";
|
|
import { writeFile, createDir, exists, removeDir, readDir, BaseDirectory, readTextFile } from "@tauri-apps/api/fs";
|
|
import { dev_plugins } from "@plugins_index";
|
|
const imported_dev_plugins = [];
|
|
dev_plugins.forEach(async ({entry_path}) => {
|
|
imported_dev_plugins.push({
|
|
index: await import(`@plugins_path/${entry_path}/index.jsx`),
|
|
downloaded_plugin_info: await import(`@plugins_path/${entry_path}/plugin_info.json`),
|
|
});
|
|
})
|
|
|
|
import JSZip from "jszip";
|
|
|
|
import { useFetch, useSoftwareVersion } from "@logics_common";
|
|
|
|
import * as logics_configs from "@logics_configs";
|
|
import * as logics_main from "@logics_main";
|
|
import * as logics_common from "@logics_common";
|
|
|
|
|
|
// PLUGIN_LIST_URL は中央リポジトリにある、各プラグインの plugin_info.json への URL の配列を保持する JSON の URL
|
|
const PLUGIN_LIST_URL = getPluginsList();
|
|
|
|
export const usePlugins = () => {
|
|
const { asyncStdoutToPython } = useStdoutToPython();
|
|
|
|
const { currentIsInitializedLoadPlugin, updateIsInitializedLoadPlugin, pendingIsInitializedLoadPlugin } = useStore_IsInitializedLoadPlugin();
|
|
const { currentIsFetchedPluginsInfo, updateIsFetchedPluginsInfo, pendingIsFetchedPluginsInfo } = useStore_IsFetchedPluginsInfo();
|
|
|
|
const { currentFetchedPluginsInfo, updateFetchedPluginsInfo, pendingFetchedPluginsInfo } = useStore_FetchedPluginsInfo();
|
|
const { currentLoadedPlugins, updateLoadedPlugins, pendingLoadedPlugins } = useStore_LoadedPlugins();
|
|
|
|
const { currentSavedPluginsStatus, updateSavedPluginsStatus, pendingSavedPluginsStatus } = useStore_SavedPluginsStatus();
|
|
const { currentPluginsData, updatePluginsData, pendingPluginsData } = useStore_PluginsData();
|
|
const { currentIsPluginsInitialized, updateIsPluginsInitialized, pendingIsPluginsInitialized } = useStore_IsPluginsInitialized();
|
|
const { checkVrctVerCompatibility } = useSoftwareVersion();
|
|
|
|
const { asyncTauriFetchGithub } = useFetch();
|
|
|
|
|
|
|
|
const generatePluginContext = (downloaded_plugin_info) => {
|
|
const plugin_context = {
|
|
registerComponent: (component) => {
|
|
if (!downloaded_plugin_info.plugin_id || !downloaded_plugin_info.location || !component) {
|
|
return console.error("An invalid plugin was detected.", downloaded_plugin_info.plugin_id, downloaded_plugin_info.location, component);
|
|
}
|
|
|
|
updateLoadedPlugins(prev => {
|
|
const prev_map = new Map(prev.data.map(item => [item.plugin_id, item]));
|
|
prev_map.set(downloaded_plugin_info.plugin_id, {
|
|
...downloaded_plugin_info,
|
|
component: component,
|
|
});
|
|
return Array.from(prev_map.values());
|
|
});
|
|
|
|
},
|
|
createAtomWithHook: (...args) => createAtomWithHook(...args),
|
|
logics: { ...logics_common, ...logics_configs, ...logics_main }
|
|
};
|
|
return plugin_context;
|
|
}
|
|
|
|
const asyncLoadPlugin = async (plugin_folder_relative_path) => {
|
|
const init_path = "plugins/" + plugin_folder_relative_path + "/index.esm.js";
|
|
const downloaded_plugin_info_path = "plugins/" + plugin_folder_relative_path + "/plugin_info.json";
|
|
const plugin_css_path = "plugins/" + plugin_folder_relative_path + "/main.css";
|
|
try {
|
|
const downloaded_plugin_info_json = await readTextFile(downloaded_plugin_info_path, { dir: BaseDirectory.Resource, recursive: true });
|
|
const downloaded_plugin_info = JSON.parse(downloaded_plugin_info_json);
|
|
|
|
const plugin_code = await readTextFile(init_path, { dir: BaseDirectory.Resource, recursive: true });
|
|
const cleaned_code = removeImportStatements(plugin_code);
|
|
const transpiled_code = transform(cleaned_code, {
|
|
presets: [
|
|
["env", { modules: false }],
|
|
"react",
|
|
],
|
|
sourceType: "module"
|
|
}).code;
|
|
const blob = new Blob([transpiled_code], { type: "text/javascript" });
|
|
const blob_url = URL.createObjectURL(blob);
|
|
const plugin_module = await import(/* @vite-ignore */ blob_url);
|
|
URL.revokeObjectURL(blob_url);
|
|
|
|
if (plugin_module && plugin_module.init) {
|
|
plugin_module.init(generatePluginContext(downloaded_plugin_info));
|
|
}
|
|
await loadPluginCSS(plugin_css_path);
|
|
|
|
} catch (error) {
|
|
console.error("Failed to load plugin from", plugin_folder_relative_path, error);
|
|
}
|
|
};
|
|
|
|
const asyncLoadAllPlugins = async () => {
|
|
if (IS_PLUGIN_PATH_DEV_MODE) {
|
|
imported_dev_plugins.forEach(({ index, downloaded_plugin_info }) => {
|
|
if (!index || !downloaded_plugin_info) {
|
|
console.error("Invalid development plugin detected", index, downloaded_plugin_info);
|
|
return;
|
|
}
|
|
const plugin_context = generatePluginContext(downloaded_plugin_info);
|
|
if (index.init) {
|
|
index.init(plugin_context);
|
|
} else {
|
|
console.error("Plugin missing init function", downloaded_plugin_info);
|
|
}
|
|
});
|
|
} else {
|
|
try {
|
|
const plugin_entries = await readDir("plugins", { dir: BaseDirectory.Resource, recursive: true });
|
|
const plugin_files = plugin_entries.filter(entry => entry.children && Array.isArray(entry.children));
|
|
|
|
for (const target_dir of plugin_files) {
|
|
const target_path = target_dir.name;
|
|
await asyncLoadPlugin(target_path);
|
|
}
|
|
} catch (error) {
|
|
console.error("Error loading plugins:", error);
|
|
}
|
|
}
|
|
};
|
|
|
|
const downloadAndExtractPlugin = async (plugin) => {
|
|
const latest_plugin_info = plugin.latest_plugin_info;
|
|
try {
|
|
const plugin_zip_url = await fetchLatestPluginZipUrl(latest_plugin_info);
|
|
console.log("start download", plugin_zip_url);
|
|
// Rust コマンド経由で ZIP をダウンロード
|
|
const base64_zip = await invoke("download_zip_asset", { url: plugin_zip_url });
|
|
// base64_zip をデコードして Uint8Array に変換
|
|
const binary_string = atob(base64_zip);
|
|
const len = binary_string.length;
|
|
const bytes = new Uint8Array(len);
|
|
for (let i = 0; i < len; i++) {
|
|
bytes[i] = binary_string.charCodeAt(i);
|
|
}
|
|
|
|
// JSZip で ZIP を解凍
|
|
const zip = await JSZip.loadAsync(bytes);
|
|
|
|
// 展開先ディレクトリのパス（例："plugins/<plugin_id>" とする）
|
|
const target_plugin_path = "plugins/" + latest_plugin_info.plugin_id;
|
|
// 既に存在する場合は削除してから新規作成
|
|
if (await exists(target_plugin_path, { dir: BaseDirectory.Resource, recursive: true })) {
|
|
await removeDir(target_plugin_path, { dir: BaseDirectory.Resource, recursive: true });
|
|
}
|
|
await createDir(target_plugin_path, { dir: BaseDirectory.Resource, recursive: true });
|
|
|
|
const file_promises = [];
|
|
zip.forEach((relative_path, zip_entry) => {
|
|
// .git 以下のファイルはスキップ
|
|
if (relative_path.startsWith(".git") || relative_path.includes("/.git/")) {
|
|
return;
|
|
}
|
|
const file_path = target_plugin_path + "/" + relative_path;
|
|
if (zip_entry.dir) {
|
|
file_promises.push(
|
|
createDir(file_path, { dir: BaseDirectory.Resource, recursive: true }).catch((err) => {
|
|
if (!err.message?.includes("already exists")) {
|
|
console.error("Failed to create directory:", file_path, err);
|
|
}
|
|
})
|
|
);
|
|
} else {
|
|
const dir_path = file_path.substring(0, file_path.lastIndexOf("/"));
|
|
const promise = createDir(dir_path, { dir: BaseDirectory.Resource, recursive: true })
|
|
.catch((err) => {
|
|
if (!err.message?.includes("already exists")) {
|
|
console.error("Failed to create parent directory:", dir_path, err);
|
|
}
|
|
})
|
|
.then(() => zip_entry.async("text"))
|
|
.then(async (file_data) => {
|
|
await writeFile(file_path, file_data, { dir: BaseDirectory.Resource, recursive: true });
|
|
});
|
|
file_promises.push(promise);
|
|
}
|
|
});
|
|
|
|
await Promise.all(file_promises);
|
|
console.log("Plugin downloaded successfully.");
|
|
|
|
const index_file_relative_path = plugin.plugin_id;
|
|
await asyncLoadPlugin(index_file_relative_path);
|
|
|
|
console.log("Plugin loaded successfully.");
|
|
} catch (error) {
|
|
console.error("Error downloading and extracting plugin:", error);
|
|
}
|
|
};
|
|
|
|
const fetchLatestPluginZipUrl = async (plugin) => {
|
|
const api_url = plugin.url;
|
|
const response = await asyncTauriFetchGithub(api_url);
|
|
if (response.status !== 200) {
|
|
throw new Error("Failed to fetch latest release info, status: " + response.status);
|
|
}
|
|
const release_info = response.data;
|
|
const asset = release_info.assets.find((a) => a.name === plugin.asset_name);
|
|
if (!asset) {
|
|
throw new Error(`Asset ${plugin.asset_name} not found in the latest release`);
|
|
}
|
|
return asset.browser_download_url;
|
|
};
|
|
|
|
|
|
const asyncFetchPluginsInfo = async () => {
|
|
if (currentIsFetchedPluginsInfo.data) return;
|
|
try {
|
|
const response = await asyncTauriFetchGithub(PLUGIN_LIST_URL);
|
|
if (response.status !== 200) {
|
|
throw new Error("Failed to fetch plugins list, status: " + response.status);
|
|
}
|
|
const plugins_data = response.data;
|
|
const updated_list = await Promise.all(
|
|
plugins_data.map(async (plugin_data) => {
|
|
try {
|
|
const plugin_info = await asyncFetchPluginInfo(plugin_data.url);
|
|
return plugin_info;
|
|
} catch (error) {
|
|
console.error("Error fetching plugin info for URL: ", plugin_data.url, error);
|
|
return {
|
|
title: plugin_data.title,
|
|
plugin_id: plugin_data.plugin_id || plugin_data.title,
|
|
is_error: true,
|
|
error_message: error.message,
|
|
url: plugin_data.url
|
|
};
|
|
}
|
|
})
|
|
);
|
|
updateFetchedPluginsInfo(updated_list);
|
|
updateIsFetchedPluginsInfo(true);
|
|
} catch (error) {
|
|
console.error("Error fetching plugin info list: ", error);
|
|
}
|
|
}
|
|
|
|
const asyncFetchPluginInfo = async (plugin_info_asset_url) => {
|
|
|
|
const release_response = await asyncTauriFetchGithub(plugin_info_asset_url);
|
|
if (release_response.status !== 200) {
|
|
throw new Error(`Failed to fetch release info from ${plugin_info_asset_url}`);
|
|
}
|
|
const plugin_info_json = release_response.data.assets.find(asset => asset.name === "plugin_info.json");
|
|
if (!plugin_info_json) {
|
|
throw new Error("plugin_info.json not found in release assets");
|
|
}
|
|
const plugin_info_json_response = await asyncTauriFetchGithub(plugin_info_json.browser_download_url);
|
|
if (plugin_info_json_response.status !== 200) {
|
|
throw new Error(`Failed to fetch plugin_info.json from ${plugin_info_json.browser_download_url}`);
|
|
}
|
|
const plugin_info = plugin_info_json_response.data;
|
|
|
|
|
|
const { is_plugin_supported, is_plugin_supported_latest_vrct } = checkVrctVerCompatibility(plugin_info.min_supported_vrct_version, plugin_info.max_supported_vrct_version);
|
|
|
|
return {
|
|
title: plugin_info.title,
|
|
plugin_id: plugin_info.plugin_id,
|
|
plugin_version: plugin_info.plugin_version,
|
|
min_supported_vrct_version: plugin_info.min_supported_vrct_version,
|
|
max_supported_vrct_version: plugin_info.max_supported_vrct_version,
|
|
is_plugin_supported: is_plugin_supported,
|
|
is_plugin_supported_latest_vrct: is_plugin_supported_latest_vrct,
|
|
asset_name: plugin_info.asset_name,
|
|
url: plugin_info_asset_url
|
|
};
|
|
}
|
|
|
|
const handlePendingPlugin = (target_plugin_id, is_pending) => {
|
|
updatePluginsData((old_value) => {
|
|
const new_value = old_value.data.map((d) => {
|
|
if (d.plugin_id === target_plugin_id) {
|
|
d.is_pending = is_pending;
|
|
}
|
|
return d;
|
|
});
|
|
return new_value;
|
|
});
|
|
};
|
|
|
|
const toggleSavedPluginStatus = (target_plugin_id) => {
|
|
const is_exists = currentSavedPluginsStatus.data.some(
|
|
(d) => d.plugin_id === target_plugin_id
|
|
);
|
|
let new_value = [];
|
|
if (is_exists) {
|
|
new_value = currentSavedPluginsStatus.data.map((d) => {
|
|
if (d.plugin_id === target_plugin_id) {
|
|
d.is_enabled = !d.is_enabled;
|
|
}
|
|
return d;
|
|
});
|
|
} else {
|
|
new_value.push(...currentSavedPluginsStatus.data);
|
|
new_value.push({
|
|
plugin_id: target_plugin_id,
|
|
is_enabled: true,
|
|
});
|
|
}
|
|
|
|
// 「currentPluginsData.data」でis_downloadedがtrueのものだけ残す
|
|
new_value = new_value.filter((item) =>
|
|
currentPluginsData.data.some(
|
|
(plugin) => plugin.plugin_id === item.plugin_id && plugin.is_downloaded
|
|
)
|
|
);
|
|
|
|
setSavedPluginsStatus(new_value);
|
|
};
|
|
|
|
const setSavedPluginsStatus = (plugins_status) => {
|
|
pendingSavedPluginsStatus();
|
|
asyncStdoutToPython("/set/data/plugins_status", plugins_status);
|
|
};
|
|
|
|
const isAnyPluginEnabled = () => {
|
|
return currentPluginsData.data.some(plugin => plugin.is_enabled);
|
|
};
|
|
|
|
const enabledPluginsList = () => {
|
|
return currentPluginsData.data.filter(plugin => plugin.is_enabled);
|
|
}
|
|
|
|
|
|
|
|
return {
|
|
asyncFetchPluginsInfo,
|
|
|
|
isAnyPluginEnabled,
|
|
enabledPluginsList,
|
|
|
|
asyncLoadAllPlugins,
|
|
downloadAndExtractPlugin,
|
|
|
|
currentSavedPluginsStatus,
|
|
updateSavedPluginsStatus,
|
|
|
|
currentPluginsData,
|
|
updatePluginsData,
|
|
|
|
currentIsPluginsInitialized,
|
|
updateIsPluginsInitialized,
|
|
|
|
currentIsInitializedLoadPlugin,
|
|
updateIsInitializedLoadPlugin,
|
|
currentIsFetchedPluginsInfo,
|
|
updateIsFetchedPluginsInfo,
|
|
|
|
currentFetchedPluginsInfo,
|
|
updateFetchedPluginsInfo,
|
|
|
|
currentLoadedPlugins,
|
|
updateLoadedPlugins,
|
|
|
|
toggleSavedPluginStatus,
|
|
setSavedPluginsStatus,
|
|
|
|
handlePendingPlugin,
|
|
};
|
|
};
|
|
|
|
const removeImportStatements = (code) => {
|
|
return code
|
|
.split("\n")
|
|
.filter(line => !line.match(/^import\s+.*['"]react['"]/))
|
|
.join("\n");
|
|
};
|
|
|
|
// import { readTextFile, BaseDirectory } from "@tauri-apps/api/fs";
|
|
|
|
const loadPluginCSS = async (plugin_css_path) => {
|
|
if (!await exists(plugin_css_path, { dir: BaseDirectory.Resource, recursive: true })) return;
|
|
try {
|
|
// プラグインフォルダのルートにある main.css を読み込む
|
|
const css_content = await readTextFile(plugin_css_path, { dir: BaseDirectory.Resource });
|
|
|
|
// style タグを作成して head に挿入する
|
|
const style_tag = document.createElement("style");
|
|
style_tag.id = `plugin-css-${plugin_css_path.replace(/[^a-zA-Z0-9_-]/g, "")}`;
|
|
style_tag.textContent = css_content;
|
|
document.head.appendChild(style_tag);
|
|
console.log("Plugin CSS loaded for:", plugin_css_path);
|
|
} catch (error) {
|
|
console.error("Failed to load plugin CSS from", plugin_css_path, error);
|
|
}
|
|
};
|
|
|
|
export { loadPluginCSS };
|