add plugin api?

This commit is contained in:
C10udburst 2022-08-04 12:51:11 +02:00
parent 0ec61bae8e
commit f90f91cea5
6 changed files with 143 additions and 1 deletions

View file

@ -7,6 +7,7 @@
<uses-permission android:name="android.permission.INTERNET" /> <!-- unless you only use cs3 as a player for downloaded stuff, you need this -->
<uses-permission android:name="android.permission.READ_EXTERNAL_STORAGE" /> <!-- Downloads -->
<uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE" /> <!-- Downloads on low api devices-->
<uses-permission android:name="android.permission.MANAGE_EXTERNAL_STORAGE" /> <!-- Plugin API -->
<uses-permission android:name="android.permission.RECEIVE_BOOT_COMPLETED" /> <!-- some dependency needs this -->
<uses-permission android:name="android.permission.MODIFY_AUDIO_SETTINGS" /> <!-- Used for player vertical slide-->
<uses-permission android:name="android.permission.REQUEST_INSTALL_PACKAGES" /> <!--Used for app update-->

View file

@ -88,6 +88,7 @@ import org.schabi.newpipe.extractor.NewPipe
import java.io.File
import kotlin.concurrent.thread
import kotlin.reflect.KClass
import com.lagradost.cloudstream3.plugins.PluginManager
const val VLC_PACKAGE = "org.videolan.vlc"
@ -398,6 +399,8 @@ class MainActivity : AppCompatActivity(), ColorPickerDialogListener {
}
override fun onCreate(savedInstanceState: Bundle?) {
PluginManager.loadAllPlugins(applicationContext)
// init accounts
for (api in accountManagers) {
api.init()

View file

@ -0,0 +1,6 @@
package com.lagradost.cloudstream3.plugins
@Suppress("unused")
@Target(AnnotationTarget.CLASS)
annotation class CloudstreamPlugin(
)

View file

@ -0,0 +1,24 @@
package com.lagradost.cloudstream3.plugins;
import android.content.Context;
import android.content.res.Resources;
public abstract class Plugin {
public Plugin() {}
/**
* Called when your Plugin is loaded
* @param context Context
*/
public void load(Context context) throws Throwable {}
public static class Manifest {
public String name;
public String pluginClassName;
}
public Resources resources;
public boolean needsResources = false;
public String __filename;
}

View file

@ -0,0 +1,109 @@
package com.lagradost.cloudstream3.plugins;
import android.content.Context;
import android.content.res.AssetManager;
import android.content.res.Resources;
import java.io.File;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.lang.reflect.Field;
import java.lang.reflect.Method;
import java.util.*;
import android.os.Environment;
import com.google.gson.Gson;
import dalvik.system.PathClassLoader;
public class PluginManager {
public static final String PLUGINS_PATH = Environment.getExternalStorageDirectory().getAbsolutePath() + "/Cloudstream3/plugins";
public static final Map<String, Plugin> plugins = new LinkedHashMap<>();
public static final Map<PathClassLoader, Plugin> classLoaders = new HashMap<>();
public static final Map<File, Object> failedToLoad = new LinkedHashMap<>();
public static boolean loadedPlugins = false;
private static final Gson gson = new Gson();
public static void loadAllPlugins(Context context) {
File dir = new File(PLUGINS_PATH);
if (!dir.exists()) {
boolean res = dir.mkdirs();
if (!res) {
//logger.error("Failed to create directories!", null);
return;
}
}
File[] sortedPlugins = dir.listFiles();
// Always sort plugins alphabetically for reproducible results
Arrays.sort(sortedPlugins, Comparator.comparing(File::getName));
for (File f : sortedPlugins) {
String name = f.getName();
if (name.endsWith(".zip")) {
PluginManager.loadPlugin(context, f);
} else if (!name.equals("oat")) { // Some roms create this
if (f.isDirectory()) {
//Utils.showToast(String.format("Found directory %s in your plugins folder. DO NOT EXTRACT PLUGIN ZIPS!", name), true);
} else if (name.equals("classes.dex") || name.endsWith(".json")) {
//Utils.showToast(String.format("Found extracted plugin file %s in your plugins folder. DO NOT EXTRACT PLUGIN ZIPS!", name), true);
}
//rmrf(f);
}
}
loadedPlugins = true;
//if (!PluginManager.failedToLoad.isEmpty())
//Utils.showToast("Some plugins failed to load.");
}
@SuppressWarnings({ "JavaReflectionMemberAccess", "unchecked" })
public static void loadPlugin(Context context, File file) {
String fileName = file.getName().replace(".zip", "");
//logger.info("Loading plugin: " + fileName);
try {
PathClassLoader loader = new PathClassLoader(file.getAbsolutePath(), context.getClassLoader());
Plugin.Manifest manifest;
try (InputStream stream = loader.getResourceAsStream("manifest.json")) {
if (stream == null) {
failedToLoad.put(file, "No manifest found");
//logger.error("Failed to load plugin " + fileName + ": No manifest found", null);
return;
}
try (InputStreamReader reader = new InputStreamReader(stream)) {
manifest = gson.fromJson(reader, Plugin.Manifest.class);
}
}
String name = manifest.name;
Class pluginClass = (Class<? extends Plugin>) loader.loadClass(manifest.pluginClassName);
Plugin pluginInstance = (Plugin)pluginClass.newInstance();
if (plugins.containsKey(name)) {
//logger.error("Plugin with name " + name + " already exists", null);
return;
}
pluginInstance.__filename = fileName;
if (pluginInstance.needsResources) {
// based on https://stackoverflow.com/questions/7483568/dynamic-resource-loading-from-other-apk
AssetManager assets = AssetManager.class.newInstance();
Method addAssetPath = AssetManager.class.getMethod("addAssetPath", String.class);
addAssetPath.invoke(assets, file.getAbsolutePath());
pluginInstance.resources = new Resources(assets, context.getResources().getDisplayMetrics(), context.getResources().getConfiguration());
}
plugins.put(name, pluginInstance);
classLoaders.put(loader, pluginInstance);
pluginInstance.load(context);
} catch (Throwable e) {
failedToLoad.put(file, e);
//logger.error("Failed to load plugin " + fileName + ":\n", e);
}
}
}

View file

@ -5,7 +5,6 @@ import com.lagradost.cloudstream3.SubtitleFile
import com.lagradost.cloudstream3.TvType
import com.lagradost.cloudstream3.USER_AGENT
import com.lagradost.cloudstream3.app
import com.lagradost.cloudstream3.extractors.*
import com.lagradost.cloudstream3.mvvm.logError
import kotlinx.coroutines.delay
import org.jsoup.Jsoup