b0f5751e11
Refactor some functions. Try to fetch functions from github api just once when vrct started.(It used to every time plugin tab has opened so easy to reach to the api limit)
259 lines
12 KiB
JavaScript
259 lines
12 KiB
JavaScript
import semver from "semver";
|
|
|
|
import { invoke } from "@tauri-apps/api/tauri";
|
|
import {
|
|
createAtomWithHook,
|
|
useStore_LoadedPluginsList,
|
|
useStore_PluginsInfoList,
|
|
} from "@store";
|
|
|
|
import { transform } from "@babel/standalone";
|
|
import { writeFile, createDir, exists, removeDir, readDir, BaseDirectory, readTextFile } from "@tauri-apps/api/fs";
|
|
const dev_plugin_mapping = import.meta.glob("/src-tauri/plugins/**/index.jsx", { eager: true });
|
|
import JSZip from "jszip";
|
|
|
|
import { useFetch } from "@logics_common";
|
|
import { useSoftwareVersion } from "@logics_configs";
|
|
|
|
|
|
// PLUGIN_LIST_URL は中央リポジトリにある、各プラグインの plugin_info.json への URL の配列を保持する JSON の URL
|
|
const PLUGIN_LIST_URL = "https://raw.githubusercontent.com/ShiinaSakamoto/vrct_plugins_list/main/vrct_plugins_list.json";
|
|
|
|
export const usePlugins = () => {
|
|
const { currentLoadedPluginsList, updateLoadedPluginsList } = useStore_LoadedPluginsList();
|
|
const { currentPluginsInfoList, updatePluginsInfoList, pendingPluginsInfoList } = useStore_PluginsInfoList();
|
|
const { currentSoftwareVersion } = useSoftwareVersion();
|
|
|
|
const { asyncTauriFetchGithub } = useFetch();
|
|
|
|
const plugin_context = {
|
|
registerComponent: ({ plugin_id, location, component }) => {
|
|
if (!plugin_id || !location || !component) {
|
|
return console.error("An invalid plugin was detected.", plugin_id, location, component);
|
|
}
|
|
updateLoadedPluginsList((prev) => {
|
|
const filtered = prev.data.filter(item => item.plugin_id !== plugin_id);
|
|
return [...filtered, { plugin_id, location, component }];
|
|
});
|
|
},
|
|
createAtomWithHook: (...args) => createAtomWithHook(...args)
|
|
};
|
|
|
|
const asyncLoadPlugin = async (plugin_relative_path) => {
|
|
plugin_relative_path = "plugins/" + plugin_relative_path;
|
|
try {
|
|
const plugin_code = await readTextFile(plugin_relative_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(plugin_context);
|
|
}
|
|
} catch (error) {
|
|
console.error("Failed to load plugin from", plugin_relative_path, error);
|
|
}
|
|
};
|
|
|
|
const loadAllPlugins = async () => {
|
|
if (import.meta.env.DEV) {
|
|
// 開発時: ホットリロード対応、src-tauri以下のpluginsから直接読み込み
|
|
Object.entries(dev_plugin_mapping).forEach(([key, plugin_module]) => {
|
|
if (plugin_module && plugin_module.init) {
|
|
plugin_module.init(plugin_context);
|
|
}
|
|
});
|
|
} else {
|
|
try {
|
|
const plugin_files = await readDir("plugins", { dir: BaseDirectory.Resource, recursive: true });
|
|
for (const target_dir of plugin_files) {
|
|
const target_path = target_dir.name + "/index.esm.js";
|
|
await asyncLoadPlugin(target_path, plugin_context);
|
|
}
|
|
} catch (error) {
|
|
console.error("Error loading plugins:", error);
|
|
}
|
|
}
|
|
};
|
|
|
|
const downloadAndExtractPlugin = async (plugin) => {
|
|
try {
|
|
const plugin_zip_url = await fetchLatestPluginZipUrl(plugin);
|
|
// 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/" + plugin.asset_name.replace(".zip", "");
|
|
// 既に存在する場合は削除してから新規作成
|
|
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.asset_name.replace(".zip", "") + "/index.esm.js";
|
|
await asyncLoadPlugin(index_file_relative_path, plugin_context);
|
|
|
|
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 asyncUpdatePluginInfoList = async () => {
|
|
pendingPluginsInfoList();
|
|
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);
|
|
// エラー発生時は、plugin_data.title とエラーメッセージを返す
|
|
return {
|
|
title: plugin_data.title,
|
|
plugin_id: plugin_data.plugin_id || plugin_data.title,
|
|
error: error.message,
|
|
url: plugin_data.url
|
|
};
|
|
}
|
|
})
|
|
);
|
|
updatePluginsInfoList(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 isPluginCompatible = (main_version, lower_version, upper_version) => {
|
|
console.log(main_version, lower_version, upper_version);
|
|
|
|
// lower_version 以上かつ upper_version 以下なら互換性ありと判定
|
|
return semver.gte(main_version, lower_version) && semver.lte(main_version, upper_version);
|
|
};
|
|
|
|
const is_plugin_supported = isPluginCompatible(currentSoftwareVersion.data, 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,
|
|
asset_name: plugin_info.asset_name,
|
|
url: plugin_info_asset_url
|
|
};
|
|
}
|
|
|
|
|
|
|
|
return {
|
|
asyncUpdatePluginInfoList,
|
|
|
|
loadAllPlugins,
|
|
downloadAndExtractPlugin,
|
|
|
|
currentLoadedPluginsList,
|
|
updateLoadedPluginsList,
|
|
|
|
currentPluginsInfoList,
|
|
updatePluginsInfoList,
|
|
};
|
|
};
|
|
|
|
const removeImportStatements = (code) => {
|
|
return code
|
|
.split("\n")
|
|
.filter(line => !line.match(/^import\s+.*['"]react['"]/))
|
|
.join("\n");
|
|
};
|