diff --git a/src/de/aniworld/AndroidManifest.xml b/src/de/aniworld/AndroidManifest.xml
new file mode 100644
index 000000000..acb4de356
--- /dev/null
+++ b/src/de/aniworld/AndroidManifest.xml
@@ -0,0 +1,2 @@
+<?xml version="1.0" encoding="utf-8"?>
+<manifest package="eu.kanade.tachiyomi.animeextension" />
\ No newline at end of file
diff --git a/src/de/aniworld/build.gradle b/src/de/aniworld/build.gradle
new file mode 100644
index 000000000..3bd1f09f0
--- /dev/null
+++ b/src/de/aniworld/build.gradle
@@ -0,0 +1,13 @@
+apply plugin: 'com.android.application'
+apply plugin: 'kotlin-android'
+apply plugin: 'kotlinx-serialization'
+
+ext {
+    extName = 'AniWorld'
+    pkgNameSuffix = 'de.aniworld'
+    extClass = '.AniWorld'
+    extVersionCode = 2
+    libVersion = '12'
+}
+
+apply from: "$rootDir/common.gradle"
diff --git a/src/de/aniworld/res/mipmap-hdpi/ic_launcher.png b/src/de/aniworld/res/mipmap-hdpi/ic_launcher.png
new file mode 100644
index 000000000..1b7176e56
Binary files /dev/null and b/src/de/aniworld/res/mipmap-hdpi/ic_launcher.png differ
diff --git a/src/de/aniworld/res/mipmap-hdpi/ic_launcher_adaptive_back.png b/src/de/aniworld/res/mipmap-hdpi/ic_launcher_adaptive_back.png
new file mode 100644
index 000000000..8dc560dd4
Binary files /dev/null and b/src/de/aniworld/res/mipmap-hdpi/ic_launcher_adaptive_back.png differ
diff --git a/src/de/aniworld/res/mipmap-hdpi/ic_launcher_adaptive_fore.png b/src/de/aniworld/res/mipmap-hdpi/ic_launcher_adaptive_fore.png
new file mode 100644
index 000000000..9ec035354
Binary files /dev/null and b/src/de/aniworld/res/mipmap-hdpi/ic_launcher_adaptive_fore.png differ
diff --git a/src/de/aniworld/res/mipmap-mdpi/ic_launcher.png b/src/de/aniworld/res/mipmap-mdpi/ic_launcher.png
new file mode 100644
index 000000000..47c2a251f
Binary files /dev/null and b/src/de/aniworld/res/mipmap-mdpi/ic_launcher.png differ
diff --git a/src/de/aniworld/res/mipmap-mdpi/ic_launcher_adaptive_back.png b/src/de/aniworld/res/mipmap-mdpi/ic_launcher_adaptive_back.png
new file mode 100644
index 000000000..f8feb6e59
Binary files /dev/null and b/src/de/aniworld/res/mipmap-mdpi/ic_launcher_adaptive_back.png differ
diff --git a/src/de/aniworld/res/mipmap-mdpi/ic_launcher_adaptive_fore.png b/src/de/aniworld/res/mipmap-mdpi/ic_launcher_adaptive_fore.png
new file mode 100644
index 000000000..86df8abdb
Binary files /dev/null and b/src/de/aniworld/res/mipmap-mdpi/ic_launcher_adaptive_fore.png differ
diff --git a/src/de/aniworld/res/mipmap-xhdpi/ic_launcher.png b/src/de/aniworld/res/mipmap-xhdpi/ic_launcher.png
new file mode 100644
index 000000000..af7c05577
Binary files /dev/null and b/src/de/aniworld/res/mipmap-xhdpi/ic_launcher.png differ
diff --git a/src/de/aniworld/res/mipmap-xhdpi/ic_launcher_adaptive_back.png b/src/de/aniworld/res/mipmap-xhdpi/ic_launcher_adaptive_back.png
new file mode 100644
index 000000000..1b560124d
Binary files /dev/null and b/src/de/aniworld/res/mipmap-xhdpi/ic_launcher_adaptive_back.png differ
diff --git a/src/de/aniworld/res/mipmap-xhdpi/ic_launcher_adaptive_fore.png b/src/de/aniworld/res/mipmap-xhdpi/ic_launcher_adaptive_fore.png
new file mode 100644
index 000000000..3cb79f27e
Binary files /dev/null and b/src/de/aniworld/res/mipmap-xhdpi/ic_launcher_adaptive_fore.png differ
diff --git a/src/de/aniworld/res/mipmap-xxhdpi/ic_launcher.png b/src/de/aniworld/res/mipmap-xxhdpi/ic_launcher.png
new file mode 100644
index 000000000..f0dbfec2a
Binary files /dev/null and b/src/de/aniworld/res/mipmap-xxhdpi/ic_launcher.png differ
diff --git a/src/de/aniworld/res/mipmap-xxhdpi/ic_launcher_adaptive_back.png b/src/de/aniworld/res/mipmap-xxhdpi/ic_launcher_adaptive_back.png
new file mode 100644
index 000000000..369383ac8
Binary files /dev/null and b/src/de/aniworld/res/mipmap-xxhdpi/ic_launcher_adaptive_back.png differ
diff --git a/src/de/aniworld/res/mipmap-xxhdpi/ic_launcher_adaptive_fore.png b/src/de/aniworld/res/mipmap-xxhdpi/ic_launcher_adaptive_fore.png
new file mode 100644
index 000000000..366f1f424
Binary files /dev/null and b/src/de/aniworld/res/mipmap-xxhdpi/ic_launcher_adaptive_fore.png differ
diff --git a/src/de/aniworld/res/mipmap-xxxhdpi/ic_launcher.png b/src/de/aniworld/res/mipmap-xxxhdpi/ic_launcher.png
new file mode 100644
index 000000000..d181b6e32
Binary files /dev/null and b/src/de/aniworld/res/mipmap-xxxhdpi/ic_launcher.png differ
diff --git a/src/de/aniworld/res/mipmap-xxxhdpi/ic_launcher_adaptive_back.png b/src/de/aniworld/res/mipmap-xxxhdpi/ic_launcher_adaptive_back.png
new file mode 100644
index 000000000..de26e98f5
Binary files /dev/null and b/src/de/aniworld/res/mipmap-xxxhdpi/ic_launcher_adaptive_back.png differ
diff --git a/src/de/aniworld/res/mipmap-xxxhdpi/ic_launcher_adaptive_fore.png b/src/de/aniworld/res/mipmap-xxxhdpi/ic_launcher_adaptive_fore.png
new file mode 100644
index 000000000..aaad5a4cf
Binary files /dev/null and b/src/de/aniworld/res/mipmap-xxxhdpi/ic_launcher_adaptive_fore.png differ
diff --git a/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/AWConstants.kt b/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/AWConstants.kt
new file mode 100644
index 000000000..432dac5f4
--- /dev/null
+++ b/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/AWConstants.kt
@@ -0,0 +1,40 @@
+package eu.kanade.tachiyomi.animeextension.de.aniworld
+
+import android.content.SharedPreferences
+
+object AWConstants {
+    const val NAME_DOOD = "Doodstream"
+    const val NAME_STAPE = "Streamtape"
+    const val NAME_VOE = "VOE"
+
+    const val URL_DOOD = "https://dood"
+    const val URL_STAPE = "https://streamtape.com"
+    const val URL_VOE = "https://voe"
+
+    val HOSTER_NAMES = arrayOf(NAME_VOE, NAME_DOOD, NAME_STAPE)
+    val HOSTER_URLS = arrayOf(URL_VOE, URL_DOOD, URL_STAPE)
+
+    const val KEY_GER_DUB = 1
+    const val KEY_ENG_SUB = 2
+    const val KEY_GER_SUB = 3
+
+    const val LANG_GER_SUB = "Deutscher Sub"
+    const val LANG_GER_DUB = "Deutscher Dub"
+    const val LANG_ENG_SUB = "Englischer Sub"
+
+    val LANGS = arrayOf(LANG_GER_SUB, LANG_GER_DUB, LANG_ENG_SUB)
+
+    const val PREFERRED_HOSTER = "preferred_hoster"
+    const val PREFERRED_LANG = "preferred_lang"
+    const val HOSTER_SELECTION = "hoster_selection"
+
+    const val LOGIN_TITLE = "E-Mail-Adresse"
+    const val LOGIN_DEFAULT = ""
+    const val PASSWORD_TITLE = "Passwort"
+    const val PASSWORD_DEFAULT = ""
+
+    const val LOGIN_URL = "https://aniworld.to/login"
+
+    fun getPrefBaseLogin(preferences: SharedPreferences): String = preferences.getString(LOGIN_TITLE, LOGIN_DEFAULT)!!
+    fun getPrefBasePassword(preferences: SharedPreferences): String = preferences.getString(PASSWORD_TITLE, PASSWORD_DEFAULT)!!
+}
diff --git a/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/AniWorld.kt b/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/AniWorld.kt
new file mode 100644
index 000000000..cc55f7978
--- /dev/null
+++ b/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/AniWorld.kt
@@ -0,0 +1,445 @@
+package eu.kanade.tachiyomi.animeextension.de.aniworld
+
+import android.app.Application
+import android.content.SharedPreferences
+import android.text.InputType
+import android.util.Log
+import android.widget.Toast
+import androidx.preference.EditTextPreference
+import androidx.preference.ListPreference
+import androidx.preference.MultiSelectListPreference
+import androidx.preference.PreferenceScreen
+import eu.kanade.tachiyomi.animeextension.de.aniworld.extractors.DoodExtractor
+import eu.kanade.tachiyomi.animeextension.de.aniworld.extractors.StreamTapeExtractor
+import eu.kanade.tachiyomi.animeextension.de.aniworld.extractors.VoeExtractor
+import eu.kanade.tachiyomi.animesource.ConfigurableAnimeSource
+import eu.kanade.tachiyomi.animesource.model.AnimeFilterList
+import eu.kanade.tachiyomi.animesource.model.AnimesPage
+import eu.kanade.tachiyomi.animesource.model.SAnime
+import eu.kanade.tachiyomi.animesource.model.SEpisode
+import eu.kanade.tachiyomi.animesource.model.Video
+import eu.kanade.tachiyomi.animesource.online.ParsedAnimeHttpSource
+import eu.kanade.tachiyomi.network.GET
+import eu.kanade.tachiyomi.network.POST
+import eu.kanade.tachiyomi.util.asJsoup
+import kotlinx.serialization.decodeFromString
+import kotlinx.serialization.json.Json
+import kotlinx.serialization.json.JsonArray
+import kotlinx.serialization.json.JsonObject
+import kotlinx.serialization.json.jsonObject
+import kotlinx.serialization.json.jsonPrimitive
+import okhttp3.FormBody
+import okhttp3.Headers
+import okhttp3.OkHttpClient
+import okhttp3.Request
+import okhttp3.Response
+import org.jsoup.nodes.Document
+import org.jsoup.nodes.Element
+import uy.kohesive.injekt.Injekt
+import uy.kohesive.injekt.api.get
+import uy.kohesive.injekt.injectLazy
+
+class AniWorld : ConfigurableAnimeSource, ParsedAnimeHttpSource() {
+
+    override val name = "AniWorld"
+
+    override val baseUrl = "https://aniworld.to"
+
+    private val baseLogin by lazy { AWConstants.getPrefBaseLogin(preferences) }
+    private val basePassword by lazy { AWConstants.getPrefBasePassword(preferences) }
+
+    override val lang = "de"
+
+    override val supportsLatest = true
+
+    private val preferences: SharedPreferences by lazy {
+        Injekt.get<Application>().getSharedPreferences("source_$id", 0x0000)
+    }
+
+    override val client: OkHttpClient = network.client.newBuilder()
+        .addInterceptor(DdosGuardInterceptor(network.client))
+        .build()
+
+    private val authClient = network.client.newBuilder()
+        .addInterceptor(AniWorldInterceptor(client, preferences))
+        .build()
+
+    private val json: Json by injectLazy()
+
+    val context = Injekt.get<Application>()
+
+    // ===== POPULAR ANIME =====
+    override fun popularAnimeSelector(): String = "div.seriesListContainer div"
+
+    override fun popularAnimeNextPageSelector(): String? = null
+
+    override fun popularAnimeRequest(page: Int): Request {
+        val headers = Headers.Builder()
+            .add("Referer", baseUrl)
+            .add("Upgrade-Insecure-Requests", "1")
+            .build()
+        return GET("$baseUrl/beliebte-animes")
+    }
+
+    override fun popularAnimeFromElement(element: Element): SAnime {
+        context
+        val anime = SAnime.create()
+        val linkElement = element.selectFirst("a")
+        anime.url = linkElement.attr("href")
+        anime.thumbnail_url = baseUrl + linkElement.selectFirst("img").attr("data-src")
+        anime.title = element.selectFirst("h3").text()
+        return anime
+    }
+
+    // ===== LATEST ANIME =====
+    override fun latestUpdatesSelector(): String = "div.seriesListContainer div"
+
+    override fun latestUpdatesNextPageSelector(): String? = null
+
+    override fun latestUpdatesRequest(page: Int): Request = GET("$baseUrl/neu")
+
+    override fun latestUpdatesFromElement(element: Element): SAnime {
+        val anime = SAnime.create()
+        val linkElement = element.selectFirst("a")
+        anime.url = linkElement.attr("href")
+        anime.thumbnail_url = baseUrl + linkElement.selectFirst("img").attr("data-src")
+        anime.title = element.selectFirst("h3").text()
+        return anime
+    }
+
+    // ===== SEARCH =====
+
+    override fun searchAnimeRequest(page: Int, query: String, filters: AnimeFilterList): Request {
+        val headers = Headers.Builder()
+            .add("Referer", "https://aniworld.to/search")
+            .add("origin", baseUrl)
+            .add("connection", "keep-alive")
+            .add("user-agent", "Mozilla/5.0 (Linux; Android 12; Pixel 5 Build/SP2A.220405.004; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/100.0.4896.127 Safari/537.36")
+            .add("Upgrade-Insecure-Requests", "1")
+            .add("content-length", query.length.plus(8).toString())
+            .add("cache-control", "")
+            .add("accept", "*/*")
+            .add("content-type", "application/x-www-form-urlencoded; charset=UTF-8")
+            .add("x-requested-with", "XMLHttpRequest")
+            .build()
+        return POST("$baseUrl/ajax/search", body = FormBody.Builder().add("keyword", query).build(), headers = headers)
+    }
+    override fun searchAnimeSelector() = throw UnsupportedOperationException("Not used.")
+
+    override fun searchAnimeNextPageSelector() = throw UnsupportedOperationException("Not used.")
+
+    override fun searchAnimeParse(response: Response): AnimesPage {
+        val body = response.body!!.string()
+        val results = json.decodeFromString<JsonArray>(body)
+        val animes = results.filter {
+            val link = it.jsonObject["link"]!!.jsonPrimitive.content
+            link.startsWith("/anime/stream/") &&
+                link.count { c -> c == '/' } == 3
+        }.map {
+            animeFromSearch(it.jsonObject)
+        }
+        return AnimesPage(animes, false)
+    }
+
+    private fun animeFromSearch(result: JsonObject): SAnime {
+        val anime = SAnime.create()
+        val title = result["title"]!!.jsonPrimitive.content
+        val link = result["link"]!!.jsonPrimitive.content
+        anime.title = title.replace("<em>", "").replace("</em>", "")
+        anime.url = link
+        return anime
+    }
+
+    override fun searchAnimeFromElement(element: Element) = throw UnsupportedOperationException("Not used.")
+
+    // ===== ANIME DETAILS =====
+    override fun animeDetailsParse(document: Document): SAnime {
+        val anime = SAnime.create()
+        anime.title = document.selectFirst("div.series-title h1 span").text()
+        anime.thumbnail_url = baseUrl +
+            document.selectFirst("div.seriesCoverBox img").attr("data-src")
+        anime.genre = document.select("div.genres ul li").joinToString { it.text() }
+        anime.description = document.selectFirst("p.seri_des").attr("data-full-description")
+        document.selectFirst("div.cast li:contains(Produzent:) ul")?.let {
+            val author = it.select("li").joinToString { li -> li.text() }
+            anime.author = author
+        }
+        anime.status = SAnime.UNKNOWN
+        return anime
+    }
+
+    // ===== EPISODE =====
+    override fun episodeListSelector() = throw UnsupportedOperationException("Not used.")
+
+    override fun episodeListParse(response: Response): List<SEpisode> {
+        val document = response.asJsoup()
+        val episodeList = mutableListOf<SEpisode>()
+        val seasonsElements = document.select("#stream > ul:nth-child(1) > li > a")
+        if (seasonsElements.attr("href").contains("/filme")) {
+            seasonsElements.forEach {
+                val seasonEpList = parseMoviesFromSeries(it)
+                episodeList.addAll(seasonEpList)
+            }
+        } else {
+            seasonsElements.forEach {
+                val seasonEpList = parseEpisodesFromSeries(it)
+                episodeList.addAll(seasonEpList)
+            }
+        }
+        return episodeList.reversed()
+    }
+
+    private fun parseEpisodesFromSeries(element: Element): List<SEpisode> {
+        val seasonId = element.attr("abs:href")
+        val episodesHtml = authClient.newCall(GET(seasonId)).execute().asJsoup()
+        val episodeElements = episodesHtml.select("table.seasonEpisodesList tbody tr")
+        return episodeElements.map { episodeFromElement(it) }
+    }
+
+    private fun parseMoviesFromSeries(element: Element): List<SEpisode> {
+        val seasonId = element.attr("abs:href")
+        val episodesHtml = authClient.newCall(GET(seasonId)).execute().asJsoup()
+        val episodeElements = episodesHtml.select("table.seasonEpisodesList tbody tr")
+        return episodeElements.map { episodeFromElement(it) }
+    }
+
+    override fun episodeFromElement(element: Element): SEpisode {
+        val episode = SEpisode.create()
+        if (element.select("td.seasonEpisodeTitle a").attr("href").contains("/film")) {
+            val num = element.attr("data-episode-season-id")
+            episode.name = "Film $num" + " : " + element.select("td.seasonEpisodeTitle a span").text()
+            episode.episode_number = element.attr("data-episode-season-id").toFloat()
+            episode.url = element.selectFirst("td.seasonEpisodeTitle a").attr("href")
+        } else {
+            val season = element.select("td.seasonEpisodeTitle a").attr("href")
+                .substringAfter("staffel-").substringBefore("/episode")
+            val num = element.attr("data-episode-season-id")
+            episode.name = "Staffel $season Folge $num" + " : " + element.select("td.seasonEpisodeTitle a span").text()
+            episode.episode_number = element.select("td meta").attr("content").toFloat()
+            episode.url = element.selectFirst("td.seasonEpisodeTitle a").attr("href")
+        }
+        return episode
+    }
+
+    // ===== VIDEO SOURCES =====
+    override fun videoListSelector() = throw UnsupportedOperationException("Not used.")
+
+    override fun videoListParse(response: Response): List<Video> {
+        val document = response.asJsoup()
+        val gerSubs = getRedirectLinks(document, AWConstants.KEY_GER_SUB)
+        val gerDubs = getRedirectLinks(document, AWConstants.KEY_GER_DUB)
+        val engSubs = getRedirectLinks(document, AWConstants.KEY_ENG_SUB)
+        val videoList = mutableListOf<Video>()
+        val hosterSelection = preferences.getStringSet(AWConstants.HOSTER_SELECTION, null)
+        val redirectInterceptor = client.newBuilder().addInterceptor(RedirectInterceptor()).build()
+        gerSubs.forEach {
+            val redirectgs = baseUrl + it.selectFirst("a.watchEpisode").attr("href")
+            val redirectsgs = redirectInterceptor.newCall(GET(redirectgs)).execute().request.url.toString()
+            if (hosterSelection != null) {
+                when {
+                    redirectsgs.contains("https://voe.sx") || redirectsgs.contains("https://launchreliantcleaverriver") && hosterSelection.contains(AWConstants.NAME_VOE) -> {
+                        val quality = "Voe Deutscher Sub"
+                        val video = VoeExtractor(client).videoFromUrl(redirectsgs, quality)
+                        if (video != null) {
+                            videoList.add(video)
+                        }
+                    }
+                    redirectsgs.contains("https://dood") && hosterSelection.contains(AWConstants.NAME_DOOD) -> {
+                        val quality = "Doodstream Deutscher Sub"
+                        val video = DoodExtractor(client).videoFromUrl(redirectsgs, quality)
+                        if (video != null) {
+                            videoList.add(video)
+                        }
+                    }
+                    redirectsgs.contains("https://streamtape") && hosterSelection.contains(AWConstants.NAME_STAPE) -> {
+                        val quality = "Streamtape Deutscher Sub"
+                        val video = StreamTapeExtractor(client).videoFromUrl(redirectsgs, quality)
+                        if (video != null) {
+                            videoList.add(video)
+                        }
+                    }
+                }
+            }
+        }
+        gerDubs.forEach {
+            val redirectgd = baseUrl + it.selectFirst("a.watchEpisode").attr("href")
+            val redirectsgd = redirectInterceptor.newCall(GET(redirectgd)).execute().request.url.toString()
+            if (hosterSelection != null) {
+                when {
+                    redirectsgd.contains("https://voe.sx") || redirectsgd.contains("https://launchreliantcleaverriver") && hosterSelection.contains(AWConstants.NAME_VOE) -> {
+                        val quality = "Voe Deutscher Dub"
+                        val video = VoeExtractor(client).videoFromUrl(redirectsgd, quality)
+                        if (video != null) {
+                            videoList.add(video)
+                        }
+                    }
+                    redirectsgd.contains("https://dood") && hosterSelection.contains(AWConstants.NAME_DOOD) -> {
+                        val quality = "Doodstream Deutscher Dub"
+                        val video = DoodExtractor(client).videoFromUrl(redirectsgd, quality)
+                        if (video != null) {
+                            videoList.add(video)
+                        }
+                    }
+                    redirectsgd.contains("https://streamtape") && hosterSelection.contains(AWConstants.NAME_STAPE) -> {
+                        val quality = "Streamtape Deutscher Dub"
+                        val video = StreamTapeExtractor(client).videoFromUrl(redirectsgd, quality)
+                        if (video != null) {
+                            videoList.add(video)
+                        }
+                    }
+                }
+            }
+        }
+        engSubs.forEach {
+            val redirecten = baseUrl + it.selectFirst("a.watchEpisode").attr("href")
+            val redirectsen = redirectInterceptor.newCall(GET(redirecten)).execute().request.url.toString()
+            if (hosterSelection != null) {
+                when {
+                    redirectsen.contains("https://voe.sx") || redirectsen.contains("https://launchreliantcleaverriver") && hosterSelection.contains(AWConstants.NAME_VOE) -> {
+                        val quality = "Voe Englischer Sub"
+                        val video = VoeExtractor(client).videoFromUrl(redirectsen, quality)
+                        if (video != null) {
+                            videoList.add(video)
+                        }
+                    }
+                    redirectsen.contains("https://dood") && hosterSelection.contains(AWConstants.NAME_DOOD) -> {
+                        val quality = "Doodstream Englischer Sub"
+                        val video = DoodExtractor(client).videoFromUrl(redirectsen, quality)
+                        if (video != null) {
+                            videoList.add(video)
+                        }
+                    }
+                    redirectsen.contains("https://streamtape") && hosterSelection.contains(AWConstants.NAME_STAPE) -> {
+                        val quality = "Streamtape Englischer Sub"
+                        val video = StreamTapeExtractor(client).videoFromUrl(redirectsen, quality)
+                        if (video != null) {
+                            videoList.add(video)
+                        }
+                    }
+                }
+            }
+        }
+        return videoList
+    }
+
+    private fun getRedirectLinks(document: Document, key: Int): List<Element> {
+        val hosterSelection = preferences.getStringSet(AWConstants.HOSTER_SELECTION, null)
+        val selector = "li[class*=episodeLink][data-lang-key="
+        return document.select("$selector$key]")
+            .filter { hosterSelection?.contains(it.select("div > a > h4").text()) == true }
+    }
+
+    override fun videoFromElement(element: Element): Video = throw Exception("not Used")
+
+    override fun List<Video>.sort(): List<Video> {
+        val hoster = preferences.getString(AWConstants.PREFERRED_HOSTER, null)
+        val subPreference = preferences.getString(AWConstants.PREFERRED_LANG, "Sub")!!
+        val hosterList = mutableListOf<Video>()
+        val otherList = mutableListOf<Video>()
+        if (hoster != null) {
+            for (video in this) {
+                if (video.url.contains(hoster)) {
+                    hosterList.add(video)
+                } else {
+                    otherList.add(video)
+                }
+            }
+        } else otherList += this
+        val newList = mutableListOf<Video>()
+        var preferred = 0
+        for (video in hosterList) {
+            if (video.quality.contains(subPreference)) {
+                newList.add(preferred, video)
+                preferred++
+            } else newList.add(video)
+        }
+        for (video in otherList) {
+            if (video.quality.contains(subPreference)) {
+                newList.add(preferred, video)
+                preferred++
+            } else newList.add(video)
+        }
+
+        return newList
+    }
+
+    override fun videoUrlParse(document: Document): String = throw UnsupportedOperationException("Not used.")
+
+    // ===== PREFERENCES ======
+    @Suppress("UNCHECKED_CAST")
+    override fun setupPreferenceScreen(screen: PreferenceScreen) {
+        val hosterPref = ListPreference(screen.context).apply {
+            key = AWConstants.PREFERRED_HOSTER
+            title = "Standard-Hoster"
+            entries = AWConstants.HOSTER_NAMES
+            entryValues = AWConstants.HOSTER_URLS
+            setDefaultValue(AWConstants.URL_STAPE)
+            summary = "%s"
+
+            setOnPreferenceChangeListener { _, newValue ->
+                val selected = newValue as String
+                val index = findIndexOfValue(selected)
+                val entry = entryValues[index] as String
+                preferences.edit().putString(key, entry).commit()
+            }
+        }
+        val subPref = ListPreference(screen.context).apply {
+            key = AWConstants.PREFERRED_LANG
+            title = "Bevorzugte Sprache"
+            entries = AWConstants.LANGS
+            entryValues = AWConstants.LANGS
+            setDefaultValue(AWConstants.LANG_GER_SUB)
+            summary = "%s"
+
+            setOnPreferenceChangeListener { _, newValue ->
+                val selected = newValue as String
+                val index = findIndexOfValue(selected)
+                val entry = entryValues[index] as String
+                preferences.edit().putString(key, entry).commit()
+            }
+        }
+        val hosterSelection = MultiSelectListPreference(screen.context).apply {
+            key = AWConstants.HOSTER_SELECTION
+            title = "Hoster auswählen"
+            entries = AWConstants.HOSTER_NAMES
+            entryValues = AWConstants.HOSTER_NAMES
+            setDefaultValue(AWConstants.HOSTER_NAMES.toSet())
+
+            setOnPreferenceChangeListener { _, newValue ->
+                preferences.edit().putStringSet(key, newValue as Set<String>).commit()
+            }
+        }
+        screen.addPreference(screen.editTextPreference(AWConstants.LOGIN_TITLE, AWConstants.LOGIN_DEFAULT, baseLogin, false, ""))
+        screen.addPreference(screen.editTextPreference(AWConstants.PASSWORD_TITLE, AWConstants.PASSWORD_DEFAULT, basePassword, true, ""))
+        screen.addPreference(subPref)
+        screen.addPreference(hosterPref)
+        screen.addPreference(hosterSelection)
+    }
+
+    private fun PreferenceScreen.editTextPreference(title: String, default: String, value: String, isPassword: Boolean = false, placeholder: String): EditTextPreference {
+        return EditTextPreference(context).apply {
+            key = title
+            this.title = title
+            summary = value.ifEmpty { placeholder }
+            this.setDefaultValue(default)
+            dialogTitle = title
+
+            if (isPassword) {
+                setOnBindEditTextListener {
+                    it.inputType = InputType.TYPE_CLASS_TEXT or InputType.TYPE_TEXT_VARIATION_PASSWORD
+                }
+            }
+
+            setOnPreferenceChangeListener { _, newValue ->
+                try {
+                    val res = preferences.edit().putString(title, newValue as String).commit()
+                    Toast.makeText(context, "Starte Aniyomi neu, um die Einstellungen zu übernehmen.", Toast.LENGTH_LONG).show()
+                    res
+                } catch (e: Exception) {
+                    Log.e("Anicloud", "Fehler beim festlegen der Einstellung.", e)
+                    false
+                }
+            }
+        }
+    }
+}
diff --git a/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/AniWorldInterceptor.kt b/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/AniWorldInterceptor.kt
new file mode 100644
index 000000000..73914a2e5
--- /dev/null
+++ b/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/AniWorldInterceptor.kt
@@ -0,0 +1,78 @@
+package eu.kanade.tachiyomi.animeextension.de.aniworld
+
+import android.content.SharedPreferences
+import android.util.Log
+import android.webkit.CookieManager
+import eu.kanade.tachiyomi.network.POST
+import okhttp3.Cookie
+import okhttp3.FormBody
+import okhttp3.Headers
+import okhttp3.HttpUrl
+import okhttp3.Interceptor
+import okhttp3.OkHttpClient
+import okhttp3.Response
+
+class AniWorldInterceptor(private val client: OkHttpClient, private val preferences: SharedPreferences) : Interceptor {
+
+    private val cookieManager by lazy { CookieManager.getInstance() }
+
+    override fun intercept(chain: Interceptor.Chain): Response {
+        val originalRequest = chain.request()
+        val cookies = cookieManager.getCookie(originalRequest.url.toString())
+        val oldCookie = if (cookies != null && cookies.isNotEmpty()) {
+            cookies.split(";").mapNotNull { Cookie.parse(originalRequest.url, it) }
+        } else {
+            emptyList()
+        }
+        val sessionCookie = oldCookie.firstOrNull { it.name == "rememberLogin" }
+        if (!sessionCookie?.value.isNullOrEmpty()) {
+            return chain.proceed(originalRequest)
+        }
+
+        val newCookie = getNewCookie(originalRequest.url)
+            ?: throw Exception("Bitte im Browser oder in den Erweiterungs-Einstellungen einloggen.")
+        val newCookieHeader = buildString {
+            (oldCookie + newCookie).forEachIndexed { index, cookie ->
+                if (index > 0) append("; ")
+                append(cookie.name).append('=').append(cookie.value)
+            }
+        }
+
+        return chain.proceed(
+            originalRequest
+                .newBuilder()
+                .addHeader("cookie", newCookieHeader)
+                .build()
+        )
+    }
+
+    private fun getNewCookie(url: HttpUrl): Cookie? {
+        val cookies = cookieManager.getCookie(url.toString())
+        val oldCookie = if (cookies != null && cookies.isNotEmpty()) {
+            cookies.split(";").mapNotNull { Cookie.parse(url, it) }
+        } else {
+            emptyList()
+        }
+        val sessionCookie = oldCookie.firstOrNull { it.name == "rememberLogin" }
+        if (!sessionCookie?.value.isNullOrEmpty()) {
+            return sessionCookie
+        }
+        val email = AWConstants.getPrefBaseLogin(preferences)
+        val password = AWConstants.getPrefBasePassword(preferences)
+        if (email.isEmpty() || password.isEmpty()) return null
+        val payload = FormBody.Builder()
+            .add("email", email)
+            .add("password", password)
+            .add("autoLogin", "on")
+            .build()
+        val headers = Headers.Builder()
+            .add("Upgrade-Insecure-Requests", "1")
+            .add("Referer", "https://aniworld.to")
+            // .add("user-agent", "Mozilla/5.0 (Linux; Android 12; Pixel 5 Build/SP2A.220405.004; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/100.0.4896.127 Safari/537.36")
+            .build()
+        return client.newCall(POST(AWConstants.LOGIN_URL, body = payload, headers = headers)).execute().header("set-cookie")?.let {
+            Log.i("bruh", it)
+            Cookie.parse(url, it)
+        }
+    }
+}
diff --git a/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/DdosGuardInterceptor.kt b/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/DdosGuardInterceptor.kt
new file mode 100644
index 000000000..473e1d8fc
--- /dev/null
+++ b/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/DdosGuardInterceptor.kt
@@ -0,0 +1,72 @@
+package eu.kanade.tachiyomi.animeextension.de.aniworld
+
+import android.webkit.CookieManager
+import eu.kanade.tachiyomi.network.GET
+import okhttp3.Cookie
+import okhttp3.HttpUrl
+import okhttp3.Interceptor
+import okhttp3.OkHttpClient
+import okhttp3.Response
+
+class DdosGuardInterceptor(private val client: OkHttpClient) : Interceptor {
+
+    private val cookieManager by lazy { CookieManager.getInstance() }
+
+    override fun intercept(chain: Interceptor.Chain): Response {
+        val originalRequest = chain.request()
+        val response = chain.proceed(originalRequest)
+
+        // Check if DDos-GUARD is on
+        if (response.code !in ERROR_CODES || response.header("Server") !in SERVER_CHECK) {
+            return response
+        }
+
+        response.close()
+        val cookies = cookieManager.getCookie(originalRequest.url.toString())
+        val oldCookie = if (cookies != null && cookies.isNotEmpty()) {
+            cookies.split(";").mapNotNull { Cookie.parse(originalRequest.url, it) }
+        } else {
+            emptyList()
+        }
+        val ddg2Cookie = oldCookie.firstOrNull { it.name == "__ddg2_" }
+        if (!ddg2Cookie?.value.isNullOrEmpty()) {
+            return chain.proceed(originalRequest)
+        }
+
+        val newCookie = getNewCookie(originalRequest.url) ?: return chain.proceed(originalRequest)
+        val newCookieHeader = buildString {
+            (oldCookie + newCookie).forEachIndexed { index, cookie ->
+                if (index > 0) append("; ")
+                append(cookie.name).append('=').append(cookie.value)
+            }
+        }
+
+        return chain.proceed(originalRequest.newBuilder().addHeader("cookie", newCookieHeader).build())
+    }
+
+    fun getNewCookie(url: HttpUrl): Cookie? {
+        val cookies = cookieManager.getCookie(url.toString())
+        val oldCookie = if (cookies != null && cookies.isNotEmpty()) {
+            cookies.split(";").mapNotNull { Cookie.parse(url, it) }
+        } else {
+            emptyList()
+        }
+        val ddg2Cookie = oldCookie.firstOrNull { it.name == "__ddg2_" }
+        if (!ddg2Cookie?.value.isNullOrEmpty()) {
+            return ddg2Cookie
+        }
+        val wellKnown = client.newCall(GET("https://check.ddos-guard.net/check.js"))
+            .execute().body!!.string()
+            .substringAfter("'", "")
+            .substringBefore("'", "")
+        val checkUrl = "${url.scheme}://${url.host + wellKnown}"
+        return client.newCall(GET(checkUrl)).execute().header("set-cookie")?.let {
+            Cookie.parse(url, it)
+        }
+    }
+
+    companion object {
+        private val ERROR_CODES = listOf(403)
+        private val SERVER_CHECK = listOf("ddos-guard")
+    }
+}
diff --git a/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/RedirectInterceptor.kt b/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/RedirectInterceptor.kt
new file mode 100644
index 000000000..09c9631a2
--- /dev/null
+++ b/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/RedirectInterceptor.kt
@@ -0,0 +1,89 @@
+package eu.kanade.tachiyomi.animeextension.de.aniworld
+
+import android.annotation.SuppressLint
+import android.app.Application
+import android.os.Handler
+import android.os.Looper
+import android.webkit.WebResourceRequest
+import android.webkit.WebResourceResponse
+import android.webkit.WebView
+import android.webkit.WebViewClient
+import eu.kanade.tachiyomi.network.GET
+import okhttp3.Headers.Companion.toHeaders
+import okhttp3.Interceptor
+import okhttp3.Request
+import okhttp3.Response
+import uy.kohesive.injekt.Injekt
+import uy.kohesive.injekt.api.get
+import java.util.concurrent.CountDownLatch
+import java.util.concurrent.TimeUnit
+
+class RedirectInterceptor : Interceptor {
+
+    private val context = Injekt.get<Application>()
+    private val handler by lazy { Handler(Looper.getMainLooper()) }
+
+    override fun intercept(chain: Interceptor.Chain): Response {
+        val originalRequest = chain.request()
+
+        val newRequest = resolveWithWebView(originalRequest) ?: throw Exception("Bitte Captcha in WebView lösen")
+
+        return chain.proceed(newRequest)
+    }
+
+    @SuppressLint("SetJavaScriptEnabled")
+    private fun resolveWithWebView(request: Request): Request? {
+        // We need to lock this thread until the WebView finds the challenge solution url, because
+        // OkHttp doesn't support asynchronous interceptors.
+        val latch = CountDownLatch(1)
+
+        var webView: WebView? = null
+
+        val origRequestUrl = request.url.toString()
+        val headers = request.headers.toMultimap().mapValues { it.value.getOrNull(0) ?: "" }.toMutableMap()
+
+        var newRequest: Request? = null
+
+        handler.post {
+            val webview = WebView(context)
+            webView = webview
+            with(webview.settings) {
+                javaScriptEnabled = true
+                domStorageEnabled = true
+                databaseEnabled = true
+                useWideViewPort = false
+                loadWithOverviewMode = false
+                userAgentString = // request.header("User-Agent")
+                    // ?: "\"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/88.0.4324.150 Safari/537.36 Edg/88.0.705.63\""
+                    "Mozilla/5.0 (Linux; Android 12; Pixel 5 Build/SP2A.220405.004; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/100.0.4896.127 Safari/537.36"
+            }
+
+            webview.webViewClient = object : WebViewClient() {
+                override fun shouldInterceptRequest(
+                    view: WebView,
+                    request: WebResourceRequest,
+                ): WebResourceResponse? {
+                    if (request.url.toString().contains("token") || request.url.toString().contains("dood") || request.url.toString().contains("streamtape") || request.url.toString().contains("voe")) {
+                        newRequest = GET(request.url.toString(), request.requestHeaders.toHeaders())
+                        latch.countDown()
+                    }
+                    return super.shouldInterceptRequest(view, request)
+                }
+            }
+
+            webView?.loadUrl(origRequestUrl, headers)
+        }
+
+        // Wait a reasonable amount of time to retrieve the solution. The minimum should be
+        // around 4 seconds but it can take more due to slow networks or server issues.
+        latch.await(12, TimeUnit.SECONDS)
+
+        handler.post {
+            webView?.stopLoading()
+            webView?.destroy()
+            webView = null
+        }
+
+        return newRequest
+    }
+}
diff --git a/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/extractors/DoodExtractor.kt b/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/extractors/DoodExtractor.kt
new file mode 100644
index 000000000..ad9899987
--- /dev/null
+++ b/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/extractors/DoodExtractor.kt
@@ -0,0 +1,42 @@
+package eu.kanade.tachiyomi.animeextension.de.aniworld.extractors
+
+import eu.kanade.tachiyomi.animesource.model.Video
+import eu.kanade.tachiyomi.network.GET
+import okhttp3.Headers
+import okhttp3.OkHttpClient
+
+class DoodExtractor(private val client: OkHttpClient) {
+    fun videoFromUrl(url: String, quality: String): Video? {
+        val response = client.newCall(GET(url)).execute()
+        // Overwrite url to the redirected one
+        val url = response.request.url.toString()
+        val doodTld = url.substringAfter("https://dood.").substringBefore("/")
+        val content = response.body!!.string()
+        if (!content.contains("'/pass_md5/")) return null
+        val md5 = content.substringAfter("'/pass_md5/").substringBefore("',")
+        val token = md5.substringAfterLast("/")
+        val randomString = getRandomString()
+        val expiry = System.currentTimeMillis()
+        val videoUrlStart = client.newCall(
+            GET(
+                "https://dood.$doodTld/pass_md5/$md5",
+                Headers.headersOf("referer", url)
+            )
+        ).execute().body!!.string()
+        val videoUrl = "$videoUrlStart$randomString?token=$token&expiry=$expiry"
+
+        return Video(url, quality, videoUrl, null, doodHeaders(doodTld))
+    }
+
+    private fun getRandomString(length: Int = 10): String {
+        val allowedChars = ('A'..'Z') + ('a'..'z') + ('0'..'9')
+        return (1..length)
+            .map { allowedChars.random() }
+            .joinToString("")
+    }
+
+    private fun doodHeaders(tld: String) = Headers.Builder().apply {
+        add("User-Agent", "Aniyomi")
+        add("Referer", "https://dood.$tld/")
+    }.build()
+}
diff --git a/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/extractors/StreamTapeExtractor.kt b/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/extractors/StreamTapeExtractor.kt
new file mode 100644
index 000000000..7421bd15d
--- /dev/null
+++ b/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/extractors/StreamTapeExtractor.kt
@@ -0,0 +1,18 @@
+package eu.kanade.tachiyomi.animeextension.de.aniworld.extractors
+
+import eu.kanade.tachiyomi.animesource.model.Video
+import eu.kanade.tachiyomi.network.GET
+import eu.kanade.tachiyomi.util.asJsoup
+import okhttp3.OkHttpClient
+
+class StreamTapeExtractor(private val client: OkHttpClient) {
+    fun videoFromUrl(url: String, quality: String): Video? {
+        val document = client.newCall(GET(url)).execute().asJsoup()
+        val script = document.select("script:containsData(document.getElementById('robotlink'))")
+            .firstOrNull()?.data()?.substringAfter("document.getElementById('robotlink').innerHTML = '")
+            ?: return null
+        val videoUrl = "https:" + script.substringBefore("'") +
+            script.substringAfter("+ ('xcd").substringBefore("'")
+        return Video(url, quality, videoUrl, null)
+    }
+}
diff --git a/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/extractors/VoeExtractor.kt b/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/extractors/VoeExtractor.kt
new file mode 100644
index 000000000..5760f22e5
--- /dev/null
+++ b/src/de/aniworld/src/eu/kanade/tachiyomi/animeextension/de/aniworld/extractors/VoeExtractor.kt
@@ -0,0 +1,17 @@
+package eu.kanade.tachiyomi.animeextension.de.aniworld.extractors
+
+import eu.kanade.tachiyomi.animesource.model.Video
+import eu.kanade.tachiyomi.network.GET
+import eu.kanade.tachiyomi.util.asJsoup
+import okhttp3.OkHttpClient
+
+class VoeExtractor(private val client: OkHttpClient) {
+
+    fun videoFromUrl(url: String, quality: String): Video? {
+        val document = client.newCall(GET(url)).execute().asJsoup()
+        val script = document.select("script:containsData(function d04ad2e48229ae25a282e15c7c2f69a2(dea04c5949242bfd216e35def894b930))")
+            .firstOrNull()?.data()?.substringAfter("\"hls\": \"") ?: return null
+        val videoUrl = script.substringAfter("\"hls\": \"").substringBefore("\",")
+        return Video(url, quality, videoUrl, null)
+    }
+}