feat. accept arrayBuffer or string as input in writeFile

Author: RohitKushvaha01

src/fileSystem/internalFs.js

@@ -58,11 +58,23 @@ const internalFs = {
 	 * Instead, it must be possible for it to be created newly at call time. The default is true.
 	 * @returns {Promise<string>} URL where the file was written into.
 	 */
-	writeFile(filename, data, create = false, exclusive = true) {
+	writeFile(filename, udata, create = false, exclusive = true) {
 		exclusive = create ? exclusive : false;
 		const name = filename.split("/").pop();
 
 		return new Promise((resolve, reject) => {
+			if(udata === undefined || udata == null){
+				reject("udata is null")
+			}
+
+			let data
+			if (udata instanceof ArrayBuffer || Object.prototype.toString.call(udata) === "[object ArrayBuffer]") {
+				const decoder = new TextDecoder('utf-8');
+				data = decoder.decode(udata);
+			}else{
+				data = udata
+			}
+
 			reject = setMessage(reject);
 			Filesystem.writeFile({
 				path: filename,
@@ -93,8 +105,11 @@ const internalFs = {
 	 */
 
 	delete(filename) {
+		console.log("deletion skipped")
+		return
 		return new Promise((resolve, reject) => {
 			console.log("Deleting " + filename);
+			
 
 			Filesystem.stat({ path: filename })
 				.then((stats) => {
@@ -126,7 +141,6 @@ const internalFs = {
 			reject = setMessage(reject);
 			Filesystem.readFile({ path: filename, encoding: Encoding.UTF8 })
 				.then((readFileResult) => {
-
 					const encoder = new TextEncoder();
 					const buffer = encoder.encode(readFileResult.data).buffer;
 
@@ -142,6 +156,24 @@ const internalFs = {
 		});
 	},
 
+	readStringFile(filename) {
+		return new Promise((resolve, reject) => {
+			reject = setMessage(reject);
+			Filesystem.readFile({ path: filename, encoding: Encoding.UTF8 })
+				.then((readFileResult) => {
+					resolve({data : readFileResult.data})
+				})
+				.catch((error) => {
+					console.error(
+						`Failed to Read File contents of "${filename}", error: `,
+						error,
+					);
+					reject(error);
+				});
+		});
+	},
+
+
 	/**
 	 * Rename a file or directory
 	 * @param {string} url
@@ -182,14 +214,14 @@ const internalFs = {
 			reject = setMessage(reject);
 			// TODO!: ask about `recursive` option
 			Filesystem.mkdir({
-				path: `${path}${dirname}`,
-				recursive: false,
+				path: `${path}/${dirname}`,
+				recursive: true,
 			})
 				.then(() => {
 					console.log(
-						`Created "${dirname}" Directory successfully on path: ${path}`,
+						`Created  ${path}/${dirname}`,
 					);
-					Filesystem.stat({ path: `${path}${dirname}` })
+					Filesystem.stat({ path: `${path}/${dirname}` })
 						.then((stats) => resolve(stats.url))
 						.catch(reject);
 				})
@@ -475,6 +507,7 @@ function createFs(url) {
 			return files;
 		},
 		async readFile(encoding) {
+			console.log("fs read "+url)
 			let { data } = await internalFs.readFile(url, encoding);
 
 			if (encoding) {

src/lib/acode.js

@@ -179,7 +179,7 @@ export default class Acode {
 						return;
 					}
 
-					fsOperation(Url.join(PLUGIN_DIR, pluginId))
+					fsOperation(`${PLUGIN_DIR}/${pluginId}`)
 						.exists()
 						.then((isPluginExists) => {
 							if (isPluginExists) {
@@ -189,12 +189,9 @@ export default class Acode {
 
 							let purchaseToken;
 							let product;
-							const pluginUrl = Url.join(
-								constants.API_BASE,
-								`plugin/${pluginId}`,
-							);
-							fsOperation(pluginUrl)
-								.readFile("json")
+							const pluginUrl = `${PLUGIN_DIR}/${pluginId}`
+							fsOperation(`${pluginUrl}/plugin.json`)
+								.readFile()
 								.catch(() => {
 									reject(new Error("Failed to fetch plugin details"));
 									return null;

src/lib/installPlugin.js

@@ -29,6 +29,7 @@ export default async function installPlugin(
 	purchaseToken,
 	isDependency,
 ) {
+	console.log(`Installing ${name}`)
 	if (!isDependency) {
 		loaderDialog = loader.create(name || "Plugin", strings.installing, {
 			timeout: 6000,
@@ -48,6 +49,7 @@ export default async function installPlugin(
 		window.log("error", error);
 	}
 
+	console.log("installing -------------------------")
 	if (!/^(https?|file|content):/.test(id)) {
 		pluginUrl = Url.join(
 			constants.API_BASE,

src/lib/loadPlugin.js

@@ -3,9 +3,13 @@ import fsOperation from "fileSystem";
 import Url from "utils/Url";
 import helpers from "utils/helpers";
 import actionStack from "./actionStack";
+import internalFs from "fileSystem/internalFs";
 
 export default async function loadPlugin(pluginId, justInstalled = false) {
-	const baseUrl = await helpers.toInternalUri(Url.join(PLUGIN_DIR, pluginId));
+	const baseUrl = Url.join(PLUGIN_DIR, pluginId)
+
+	console.log("Base url "+baseUrl)
+
 	const cacheFile = Url.join(CACHE_STORAGE, pluginId);
 
 	const pluginJson = await fsOperation(
@@ -22,7 +26,17 @@ export default async function loadPlugin(pluginId, justInstalled = false) {
 	}
 
 	return new Promise((resolve, reject) => {
-		const $script = <script src={mainUrl}></script>;
+
+		if(pluginId === undefined){
+			console.error("Skiping loading plugin with undefined id")
+			reject("Skiping loading plugin with undefined id")
+			return
+		}
+
+		
+		const data = internalFs.readStringFile(mainUrl).data
+	
+		const $script = <script dangerouslySetInnerHTML={{ __html: data }} />;
 
 		$script.onerror = (error) => {
 			reject(

src/lib/loadPlugins.js

@@ -52,6 +52,7 @@ export default async function loadPlugins(loadOnlyTheme = false) {
 
 	// Load plugins concurrently
 	const loadPromises = pluginsToLoad.map(async (pluginDir) => {
+		console.log("loading")
 		const pluginId = Url.basename(pluginDir.url);
 
 		if (loadOnlyTheme && currentTheme) {
@@ -98,6 +99,8 @@ function isThemePlugin(pluginId) {
 
 async function cleanupFailedPlugins(pluginIds) {
 	for (const pluginId of pluginIds) {
+		console.log("skiping delete "+pluginId)
+		continue;
 		try {
 			const pluginDir = Url.join(PLUGIN_DIR, pluginId);
 			if (await fsOperation(pluginDir).exists()) {