ddc6408828
Fix handling flag 'is_latest_version_already' that was overrode unexpectedly. Add some patterns to plugin list. it shows update-able if the user update vrct. Add auto update function if the plugin is enabled. Add safety that turn to disable the plugin if it's not supported with current vrct version.
393 lines
18 KiB
JavaScript
393 lines
18 KiB
JavaScript
import { invoke } from "@tauri-apps/api/tauri";
|
|
import { IS_PLUGIN_DEV_MODE, getPluginsList } from "@ui_configs";
|
|
import {
|
|
createAtomWithHook,
|
|
useStore_SavedPluginsStatus,
|
|
useStore_PluginsData,
|
|
useStore_IsPluginsInitialized,
|
|
} 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 { 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);
|
|
}
|
|
updatePluginsData(prev => {
|
|
const prev_map = new Map(prev.data.map(item => [item.plugin_id, item]));
|
|
const new_data = [];
|
|
let new_value = {};
|
|
const { is_plugin_supported, is_plugin_supported_latest_vrct } = checkVrctVerCompatibility(downloaded_plugin_info.min_supported_vrct_version, downloaded_plugin_info.max_supported_vrct_version);
|
|
|
|
const target_plugin = prev_map.get(downloaded_plugin_info.plugin_id);
|
|
if (!target_plugin) { // 未ダウンロード 新規登録
|
|
new_value = {
|
|
plugin_id: downloaded_plugin_info.plugin_id,
|
|
component: component,
|
|
is_downloaded: true,
|
|
is_latest_version_available: false,
|
|
is_latest_version_already: true,
|
|
downloaded_plugin_info: {
|
|
...downloaded_plugin_info,
|
|
component: component,
|
|
is_plugin_supported: is_plugin_supported,
|
|
is_plugin_supported_latest_vrct: is_plugin_supported_latest_vrct,
|
|
},
|
|
};
|
|
return [...prev.data, new_value];
|
|
}
|
|
|
|
for (const old_plugin_data of prev.data) {
|
|
|
|
if (old_plugin_data.plugin_id === downloaded_plugin_info.plugin_id) { // ダウンロード済み or 登録済 アップデート
|
|
const target_prev_plugin = prev_map.get(downloaded_plugin_info.plugin_id);
|
|
const is_latest_version_available = (target_prev_plugin.is_downloaded) && !(downloaded_plugin_info.plugin_version === target_prev_plugin.latest_plugin_info.plugin_version);
|
|
|
|
new_value = {
|
|
...target_prev_plugin,
|
|
plugin_id: downloaded_plugin_info.plugin_id,
|
|
component: component,
|
|
is_downloaded: true,
|
|
is_latest_version_available: is_latest_version_available,
|
|
is_latest_version_already: (target_plugin.plugin_version === old_plugin_data.latest_plugin_info?.plugin_info),
|
|
downloaded_plugin_info: {
|
|
...downloaded_plugin_info,
|
|
component: component,
|
|
is_plugin_supported: is_plugin_supported,
|
|
is_plugin_supported_latest_vrct: is_plugin_supported_latest_vrct,
|
|
},
|
|
};
|
|
} else {
|
|
new_value = old_plugin_data;
|
|
}
|
|
new_data.push(new_value);
|
|
}
|
|
return new_data;
|
|
});
|
|
},
|
|
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_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 () => {
|
|
try {
|
|
const response = await asyncTauriFetchGithub(PLUGIN_LIST_URL);
|
|
if (response.status !== 200) {
|
|
throw new Error("Failed to fetch plugin 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
|
|
};
|
|
}
|
|
})
|
|
);
|
|
return updated_list;
|
|
} 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 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,
|
|
|
|
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 };
|