#z(
zC-%=x(?ha3&&_oK3j`2h_CM9TSDca!LojXxy?{IIjZL#}eRL{w^#?aDFyu3M8kHGu
zVYwfdOC<7*go`eW_h7fgv;lI#B|b2E4BcmNf7L6FZ0+>$)dEulSa~*hG+}4z^7GJk`zd@ef!Aw2s8v-P|76`J@+*XAldx
zj>CP}s{9Fa;C}F2g3si}B}#CVZ~)d>OlY_?V?SrU=a*Iu(6;|qfn~1Q_zEiYM}xzc
zS^fFuKxLxgVCxJE>}at3N7VP#dZY*4^t_?{zf_f(Rgg!Ma15pF|(PutCRKG4n8852dwO7cd$z>r3`WxPH`
z5?wys?MsReUZVL@MSve>$v5*|)IRs>m<}Ogzou1BV#Qt>D6TwCszmxhx!@f!&xm$D
zN=j`2Lp-dG?Da5Y{R=HI;@~dj04kP3ucy8nEY)`U;46Pb6ZZSOdzW~pv%tP#@H2eR
zR5W3z&--G(>Kj?3;2B$u{@hRz>cRX8m?cVH)=Qos_}8a<(@#4%W4G<+MDhOgId5Ht
zlVr&y;xq@sZDP4UOXvf)Po@O+L)_OMovlD1Hdv1N@hatZ-QYf6^O`Hfne_>`#&BfD
zt`Xl`>ti9iK@Fnxq1eI=I`ER(8}jNvCR$L&yY)7w%&l7!Mc$VXmj=ki;X~YlO0F{n
zt9P5+>Dt0~=sZ^06?Pjev+A0r%QTGlubw=9e1;#|duz)Ehe1&ctuvPa^58aeb?Dml
z8VHab1JtlR_y!61?eJ2P2KR9XnLQt)=_#hU;bU5gzw+5hckPe`zpuAooDkGwNg_X*
zKCJ?Iwy6afk)tl7o#?iwhX1N%77cl(E1-WL$bV7xH*@makpg}~byh?NUTDXChVR64_~t@4cV!~?pU7?OvpdkuyEA0TLtKts
zeOxTD4I2}5?+M??PH_0_q?LY0rhlxxqDo0}Z)9Ji5OZv1i$PnjZdqKv^X%l~D^LU@
zeW1;x`Ih*8mDrtxe_EgAC~M7RbGni1ICD(21Z>QeJ$J78*6VXAD%{l7emp8aqtX#r
z#Tu-o}Fu{NFKhyk}FF(?M*Fo|-T}hDNJ@OHFl$baIh}Iu@5+Pox
zX8yU37oVS}vX&WH$o`7fF7k-;^O(ln$x)u=>YRdQz-;Sn6}A;;p$fx0$eAJ*R|~7)
z_6tUtt+Ddmaut|kI;57*llBh%vO)Po#$w}*X$;jDihCNP95v8k#;i$(2587`&F_WD
zj&?6z+#j5G{iCM~k|$JuTdmd{a0sMUBe#Z8nG=XJNhEnsoDDI@buHC#hKWKG|JnFA=_{IUb!JQT~-~dT<38|(%oU$zWkwE
z```-+Z$u5#$T3BT(cQW4ds+j!wy_2Z`Bo{nMr9i1`rD=3%0U)dOjCd
z7d`ojZW7`6QRWE(%z4$^!nIBBH+e&JSd#)1VeDfh0|-g00uTvPhv@8v2-3Sf&o+NM
zG6YB#+#io+n3hgf@lS&1&%Arcenchl$jqt)whvK0AL0UII7+5uz*xtCDVboafR5d0
z@1|hQLtJf@IK2LY5gWJRENN%Mw3T&0R4`2q0i0AD9JI0!$uWpOKgLZqf}5k^rv@`q
z3>z5*vQ+<;@p%g_wG2sc_!M`M%e$?PtA@Nw`BeOwyyvzJ*-&#hf%9m(Q^0njeDbp5+Zc(iQ)YQ-e7edMYy<@`*>@LbzV
z_;iT2<9m*UU+OM!<5T&t%Sz~q3e%*kR_nA-vwQxQ&t(ckJWfM3)7O#k13MldH_^W5
znttg!Ca@E5`LmgTnJ9@Sa4c`lIKQQv!M4MPZkq3DKtEM|&8`EdHah~v{m#aM*xAPj
zHd5^MIFI-3w|ZT{6=3D}l|QM!FvUP68`Fpsqq418Bc`dokRvVy%w-5t!4~vElxTLs
zClm|el$5}{Y;-0B7}m-qqq;m%`+Ahj53pX^b$a^gPK6HiVKql?`&{@=W%cY}#~PLu
zcNA^0=$e)52$R{FDuzAX|GuKU6NH}P8(Zh)6blW#RC*$#IMVmsXYSn*wdE&t*_^WZ
zYK5^(DW@}!PUQt4Jb5WvjMmAl<9n;UErsuhuP+`G*DNj#*Ej%4aH+WaN{yZR+XHce
z9W}miy&M+aiFB2mw%CCv2VzmSlb@M{zFk!6>OuTAu+B#KTmH5Lwd3-$z=~j+LotHj
zp_0s23_lO52*HvxO03$-fyhp@Aj
zU`#XH>1h1UQ90vOnCYjpzD;6pfvdl68@Wp=tG#YlQqnL
zNXYva+Tv{qbR(@{g`x3U?n~YnXadmvasq^s=^LK4&VrS6!H|814wTTB7JowjIF~ld
zYP!%~7X$c~yadOQ`fc9QIa0sESPwpDfL2kT@f-F;?$`Zeq3EP
zC&c5Queia}a3%yZ=h@n95i8|W&M~6=IiLWkyvhUVS3U_fR_*6h9^?ETq#iikjEsiq
zcA!&ur)MsA)6agEYL266S}hrSE8kM?B^~@N-BEle7{C1
zO@Mzg4bMq<1V`_;{4Vd{Sw(JjYpyG`8|l$Jmuc7eMq3DkaC3(-V1eop4oP8wH+HrB
zR#gE_y5ni3aE3OT%6KeV8hCONd@(`o`MW=xO462UR)GZ6ZsFC
z?}0|?X7`L+o&+Wwp!5h1(a}u_^A^}3l3b~7q-^|-yWwnj{GmGgEm}&d-sDH^xJ9uQW^d$EXeV_46hTYHhrVQ8qf~EglK(ZYTLtk595+*=>qrA
zXGQzj)<~?CPHbT8Z52KbGy=iY>BK>TU?al>{lQG)FRVG#S}F31Fv0cATEQJ&Ufbs;_2+RbTpBFwT>?~M&2+yZ!|ZmFf00Y>=ll2dDk)uG>fs3lD`_Nx(wBE
zDGr&emKu7qT!KF*m
zdz-y|-UC>0q|n*gzF_$Dbs2{rPz?@`H|J@;aG{aOUIu3_MDqsc7_hiM3UC=(nSn1;
z8l-WV|F1N>rx;6qB0Db0?6lOZngR*b?gB_QB8MpR?g33~tgLbj{@+(uz70~na@sn@w
zI|=OFW0WgN
z%#DLN>HE)Ql~-Aq6HX}YO6+U+9)_xWN_4oqwM#Tg#5x%DqBLEmPhWlv*Ril
z`hN8^(8A8LO7$)!H%0F-Staa0a{di&q#UnL2@t+osZXQ=Ima1oFcn-V32)f~cCKnV
zw)ZbNaGSc6bMS4tS>e*Z#P1;SxesE%^wet2wnu=6deg|2J^l0)Bs@H(ekJ?hd$Vho
z!OMf?=8*Q6Iyth-(y6XtZ6gRO?BmW-RKIDphSVBLHB&OrrL;c0hvGvM4?1&X{3?hJ
z^<3GEIf;oea}{rHw+H!t4=R5sPqM4~E^D52{C-I#jvDKwu;I^XMhXbBzp1{^Wk)hr
zKgb(322BaLzE@sm56V0zj%ke!cKzkUCf8b5zEN?}q(dlkwz8l0Bk_?;!@kto)Y*e*
zY!05h;&D%B_R}RSldffP0*ePUtt6{_|94KXX6|zy9sqE$X%DcIaQow=Zd}6TOW2Ee
z(kfO!g2flAiKNixLFBc}k<2m3$2B5f=pP2FaCqXH5ixsv-bX-d=#*Tz7!_bJ*LPcj
zDih0JobJ)eGyny`q_FMP8|WKPq-hk{xjhWCIV(xG`r`w1z7QR$-u!PFSf#XnZ%L>T
z#JOiSY}+XTz9>lfnI$TzP|t`ZBA&S;%&8A_u@%PgCinOw!zUYV07#j0Lb@>xq)7fn
zzAjT+fnE`il%#!3P}B;onwP11GPd0}+|rTh3`!PAM)|cvy1M&x3y&6KlHhhRN$)fz
zk5*b|_#Qw8`7hUby(JV0RR`9WJeNPmF-`M_nQU!@xv-7iq?i2a`KSMbiL6#DHaJ7)4S%#tyu15
z#WFZmq+jMt=<)a>gPAmWHSTNw&IZJ|Cp5vsCN}o^S
zU(Fb^0KH!~6geyt@`(a=wu6xV6-{ITEszy@>bO>gV2`?>V06UUl`*==Wn|x$ux>NA
zK+=!7=A>yPKV>M@x&&hB1>b{e$^6Ra>|0VL#u%OlNyeMYDJ25}Q1hRF+1a6=hJ#5A
zSVYTz+ME)f+LA-bl~}%gZs(j(0P?swpp}zJClFE2DgCeC0kkAd(~wI}N(~fDxB7tc
zdfm@WygyZn@BB6d51=)jpkh@osS;lvXi+A@+%ZM|u(V}WL)M;9dbwwh1#WfVkeuX@
zm>z?+HMflpKCKH$g0AUj@#~joUIl)m6Gts-LQL+ZU!lN$1xSR_FxwevRo~Z~
z?fKgNjVCEZtHVEvW4ARIuLV#wA9p*Om}$u*I;%(5MfuW)D}9m|uHQ55VR|M{??80i
z`5fK}bs?TjRN19?MyG?Z7dGx02P(&PDX7nlHFeVZqO@a4+wOxM;13f~ZCc=Z51@AL
zSF};VVL=U)KRWkG3{CBhO4?*^9JV_0%dZ_V{41X&l7?3-ZISTiKFAAZgQ?7WIRy-F
zg=|Lm=EOZ=KuB|5CgytZNJI@+JBr;V)ydJJFZr6!3pB*#sb%Mt7x~`$Ekiq2y$wJI
zm07Bl)%04nvXuK*T~5=Su#@cDNv$j8hInyBEN5o+Xy6tVkTO6^a9*9(`B^c5P60hi
zBDJWnZNb^_gu^fs`1FsM_B;s1WA>Lf-{dh1%rj;et8D!HYeUDF#4*1IYzf<@6WO;_
z5OWs(Mx|Qw*|&LBQN)-v1`1#6v8w$~2Qy#24B_t1s_bsaAs1(SW%=|fQzxsuT1+eJ
zdBC>F&oQkGOt)ga;qI5GXVl+=%9=E6hpR{5?CIX8LrB*mo#xbSEgzU(Rpo<&r(#&ukZ)H1djU0D&YeYUI}l`QL>#
z+t%M-7qF**YfX?H{pJNgb%A$aV+KY|Tx&_L0|=+UlzO^FnCQLOruu^+4rww~{5+6a
z{gda6_|%yko0*UDtj}jU!5t0)#i$O>37_g1EmbcouJw|QK3SkCETl=JyW`qpR=T~N
z+PS$?O3wso0i&?Mf;?$Iply8dM=AFM*vtb)b~TpktYvyi*?DJty#h&+N|pTUSgP4wMgU^nutDd7<%~DcOzsZ65r{upBJ)k0
zi9cTmPRcEN8Fj>}Jqo#e-fZKAl5_M)$xkTq3dP_coP&a+VYP{SEwg4wQ>&sV3Avcp;{sVk
z5K!ORS(qZB{^lagc_)8}eueWr(0HXZ2$*5Z;O}yyN8_{Cj-7PrtUpq7zK=C%B>WTV
zU0)^WN>v7XG**r6^~>hXK$cvlYUor^ucm8Put9VJ;{Iw|UY5!Hm}TDG*~=IsR`qZg
zXftTcE&i=MJD&IF$nIv$#!dR_YIBS5TS*>rG5Aj3{ligl#Z!mw%Uha%cd5Q@GY&k0
z-tq7haCxU`MYJ0J3U0N;-BWGREE&jQ#?VGZvvT*dVepgsnmUj~ahKoZmQK!lDS<&Q
z=&gTSpx%~bY%v(uI>c5s?T)O#wIFW>PkwH{U9)~l%}H~whP(kACC}k;S;mdL_)!tq
zHD$xKm#wq@?WYFAuckXKR=c;k&
z?Joj1b-|bw+yiT0oD%CnV4}@xev8WgG6!viNjd722T}?!S$O>*D|cxeY6OIxJ4CjKjn2a8^O8M3oJmjl!R~orZ*GXpnperkf
z?)1I~(9^)_%A(H;*e~>jPoNx3O+lt3Snn`iLs({+Z{Iai*+awQg@@*F>cPo*j}ub}
zIj5Zna|U^7=(XQWkfU*7%(h(M=|{%_Lt&bNh$dwv7!e7!Wtmm+?mp?Oj(IZrDl%Wk
zbqa*^rYJDKez4KFF5Wz0UnAk>LBmHaiw8yNLAx4NLe+VGMN+_nV^Sr}yiKz6kF&^<
zg#;PJIB8yxydbe?SRJ{aXyUzF4S_G8X#^K!jm&%*7f8<_ApZQQ+FCJmqt#A;mTKQl
z2Oc{(^7_{aYub~9RZ*{*|2z)-H4XxiXkG0WutRmO?Tf51ad0%8-NqGaU(5*O2KrIK
z`0b+fU_BYall>RRU!9K}u}#kFJx+`YEtx_>g=Bf54xP-tokuLe0rMZ@+YfSYQwMo;
zUc5~Yg2D}qVDQVba;B<|ZD!NpwQ+`Sas!wbE%M`2o~Opp%CAZ6)h!cGDVu)z#nD_e
zC&r%|nb*GyPczD?Y_7rnVxTkjKV+IOkXm7QajfFXhRD>LHmmP*sInjAZt`lgzDccM
zG@&5IN23+~B3>aJvK-Z^Q7v9NZ%_Fd!5UDyeCWq&(H+RnRA^q||;vWMF3|3*UaZR;^Z>0-8Gt|O~R;OXiS)={(3
zY!B2<;*?N`7-dafsC@`?sbK}V@Mcs*H+Yt{U-NZ?5ST=B&vOBjt&@FZHNY{zJ;1LB
z*u|r+lCgiyqN*bF!NejdjlO^(2{PeY%UwkY;~utoML7xQtT{bcD0n_>Pq@ZP(c=M^
zX3*8y1CO`{q+m~hM`>$7Vqs#OHRODoqM_s#5YiSkMG0`^l-%~+^EaFB@|Yg^ZY#wU
z2#XCEBc3i+LOSrcj7ZKDReqDQS}yk,
+)
+
+@Serializable
+class RankingTitleId(
+ val id: Int,
+)
+
+@Serializable
+class TitleListResponse(
+ @SerialName("title_list") val titleList: List,
+)
+
+@Serializable
+class TitleDetail(
+ @SerialName("title_id") val titleId: Int,
+ @SerialName("title_name") val titleName: String,
+ @SerialName("thumbnail_image_url") val thumbnailImageUrl: String? = null,
+ @SerialName("banner_image_url") val bannerImageUrl: String? = null,
+)
+
+@Serializable
+class BirthdayCookie(val value: String, val expires: Long)
+
+@Serializable
+class EpisodeListResponse(
+ @SerialName("episode_list") val episodeList: List,
+)
+
+@Serializable
+class Episode(
+ @SerialName("episode_id") val episodeId: Int,
+ @SerialName("episode_name") val episodeName: String,
+ @SerialName("start_time") val startTime: String,
+ val point: Int,
+ @SerialName("title_id") val titleId: Int,
+ val badge: Int,
+ @SerialName("rental_finish_time") val rentalFinishTime: String? = null,
+)
+
+@Serializable
+class ViewerApiResponse(
+ @SerialName("page_list") val pageList: List,
+ @SerialName("scramble_seed") val scrambleSeed: Long,
+)
+
+@Serializable
+class SearchApiResponse(
+ @SerialName("title_list") val titleList: List,
+)
+
+@Serializable
+class SearchTitleDetail(
+ @SerialName("title_id") val titleId: Int,
+ @SerialName("title_name") val titleName: String,
+ @SerialName("thumbnail_image_url") val thumbnailImageUrl: String? = null,
+)
diff --git a/src/en/kmanga/src/eu/kanade/tachiyomi/extension/en/kmanga/ImageInterceptor.kt b/src/en/kmanga/src/eu/kanade/tachiyomi/extension/en/kmanga/ImageInterceptor.kt
new file mode 100644
index 000000000..ab4257950
--- /dev/null
+++ b/src/en/kmanga/src/eu/kanade/tachiyomi/extension/en/kmanga/ImageInterceptor.kt
@@ -0,0 +1,95 @@
+package eu.kanade.tachiyomi.extension.en.kmanga
+
+import android.graphics.Bitmap
+import android.graphics.BitmapFactory
+import android.graphics.Canvas
+import android.graphics.Rect
+import okhttp3.Interceptor
+import okhttp3.MediaType.Companion.toMediaType
+import okhttp3.Response
+import okhttp3.ResponseBody
+import okhttp3.ResponseBody.Companion.toResponseBody
+import java.io.ByteArrayOutputStream
+
+// https://greasyfork.org/en/scripts/467901-k-manga-ripper
+class ImageInterceptor : Interceptor {
+ override fun intercept(chain: Interceptor.Chain): Response {
+ val request = chain.request()
+ val fragment = request.url.fragment
+ if (fragment.isNullOrEmpty() || !fragment.startsWith("scramble_seed=")) {
+ return chain.proceed(request)
+ }
+
+ val seed = fragment.substringAfter("scramble_seed=").toLong()
+ val response = chain.proceed(request)
+ val descrambledBody = descrambleImage(response.body, seed)
+
+ return response.newBuilder().body(descrambledBody).build()
+ }
+
+ private class Coord(val x: Int, val y: Int)
+ private class CoordPair(val source: Coord, val dest: Coord)
+
+ private fun xorshift32(seed: UInt): UInt {
+ var n = seed
+ n = n xor (n shl 13)
+ n = n xor (n shr 17)
+ n = n xor (n shl 5)
+ return n
+ }
+
+ private fun getUnscrambledCoords(seed: Long): List {
+ var seed32 = seed.toUInt()
+ val pairs = mutableListOf>()
+
+ for (i in 0 until 16) {
+ seed32 = xorshift32(seed32)
+ pairs.add(seed32 to i)
+ }
+
+ pairs.sortBy { it.first }
+ val sortedVal = pairs.map { it.second }
+
+ return sortedVal.mapIndexed { i, e ->
+ CoordPair(
+ source = Coord(x = e % 4, y = e / 4),
+ dest = Coord(x = i % 4, y = i / 4),
+ )
+ }
+ }
+
+ private fun descrambleImage(responseBody: ResponseBody, seed: Long): ResponseBody {
+ val unscrambledCoords = getUnscrambledCoords(seed)
+ val originalBitmap = BitmapFactory.decodeStream(responseBody.byteStream())
+ ?: throw Exception("Failed to decode image stream")
+
+ val originalWidth = originalBitmap.width
+ val originalHeight = originalBitmap.height
+
+ val descrambledBitmap = Bitmap.createBitmap(originalWidth, originalHeight, originalBitmap.config)
+ val canvas = Canvas(descrambledBitmap)
+
+ val getTileDimension = { size: Int -> (size / 8 * 8) / 4 }
+ val tileWidth = getTileDimension(originalWidth)
+ val tileHeight = getTileDimension(originalHeight)
+
+ unscrambledCoords.forEach { coord ->
+ val sx = coord.source.x * tileWidth
+ val sy = coord.source.y * tileHeight
+ val dx = coord.dest.x * tileWidth
+ val dy = coord.dest.y * tileHeight
+
+ val srcRect = Rect(sx, sy, sx + tileWidth, sy + tileHeight)
+ val destRect = Rect(dx, dy, dx + tileWidth, dy + tileHeight)
+
+ canvas.drawBitmap(originalBitmap, srcRect, destRect, null)
+ }
+ originalBitmap.recycle()
+
+ val outputStream = ByteArrayOutputStream()
+ descrambledBitmap.compress(Bitmap.CompressFormat.JPEG, 90, outputStream)
+ descrambledBitmap.recycle()
+
+ return outputStream.toByteArray().toResponseBody("image/jpeg".toMediaType())
+ }
+}
diff --git a/src/en/kmanga/src/eu/kanade/tachiyomi/extension/en/kmanga/KManga.kt b/src/en/kmanga/src/eu/kanade/tachiyomi/extension/en/kmanga/KManga.kt
new file mode 100644
index 000000000..5446fb077
--- /dev/null
+++ b/src/en/kmanga/src/eu/kanade/tachiyomi/extension/en/kmanga/KManga.kt
@@ -0,0 +1,394 @@
+package eu.kanade.tachiyomi.extension.en.kmanga
+
+import eu.kanade.tachiyomi.network.GET
+import eu.kanade.tachiyomi.network.POST
+import eu.kanade.tachiyomi.network.asObservable
+import eu.kanade.tachiyomi.network.interceptor.rateLimitHost
+import eu.kanade.tachiyomi.source.model.Filter
+import eu.kanade.tachiyomi.source.model.FilterList
+import eu.kanade.tachiyomi.source.model.MangasPage
+import eu.kanade.tachiyomi.source.model.Page
+import eu.kanade.tachiyomi.source.model.SChapter
+import eu.kanade.tachiyomi.source.model.SManga
+import eu.kanade.tachiyomi.source.online.HttpSource
+import eu.kanade.tachiyomi.util.asJsoup
+import keiyoushi.utils.firstInstance
+import keiyoushi.utils.parseAs
+import keiyoushi.utils.tryParse
+import kotlinx.serialization.json.JsonArray
+import kotlinx.serialization.json.JsonElement
+import kotlinx.serialization.json.JsonObject
+import kotlinx.serialization.json.jsonArray
+import kotlinx.serialization.json.jsonObject
+import kotlinx.serialization.json.jsonPrimitive
+import okhttp3.FormBody
+import okhttp3.HttpUrl
+import okhttp3.HttpUrl.Companion.toHttpUrl
+import okhttp3.OkHttpClient
+import okhttp3.Request
+import okhttp3.Response
+import okio.ByteString.Companion.encodeUtf8
+import rx.Observable
+import java.net.URLDecoder
+import java.text.SimpleDateFormat
+import java.util.Locale
+
+class KManga : HttpSource() {
+
+ override val name = "K Manga"
+ override val baseUrl = "https://kmanga.kodansha.com"
+ override val lang = "en"
+ override val supportsLatest = false
+
+ private val apiUrl = "https://api.kmanga.kodansha.com"
+ private val dateFormat = SimpleDateFormat("yyyy-MM-dd HH:mm:ss", Locale.US)
+ private val pageLimit = 25
+ private val searchLimit = 25
+
+ override fun headersBuilder() = super.headersBuilder()
+ .add("Referer", "$baseUrl/")
+ .add("X-Requested-With", "XMLHttpRequest")
+ .add("x-kmanga-platform", "3")
+
+ override val client: OkHttpClient = network.cloudflareClient.newBuilder()
+ .addInterceptor(ImageInterceptor())
+ .rateLimitHost(apiUrl.toHttpUrl(), 1)
+ .build()
+
+ // Popular
+ override fun popularMangaRequest(page: Int): Request {
+ val offset = (page - 1) * pageLimit
+ val url = apiUrl.toHttpUrl().newBuilder()
+ .addPathSegments("ranking/all")
+ .addQueryParameter("ranking_id", "12")
+ .addQueryParameter("offset", offset.toString())
+ .addQueryParameter("limit", (pageLimit + 1).toString())
+ .build()
+
+ return hashedGet(url)
+ }
+
+ override fun popularMangaParse(response: Response): MangasPage {
+ val rankingResult = response.parseAs()
+ val titleIds = rankingResult.rankingTitleList.map { it.id.toString() }
+
+ if (titleIds.isEmpty()) {
+ return MangasPage(emptyList(), false)
+ }
+
+ val hasNextPage = titleIds.size > pageLimit
+ val mangaIdsToFetch = if (hasNextPage) titleIds.dropLast(1) else titleIds
+
+ val detailsUrl = apiUrl.toHttpUrl().newBuilder()
+ .addPathSegments("title/list")
+ .addQueryParameter("title_id_list", mangaIdsToFetch.joinToString(","))
+ .build()
+
+ val detailsRequest = hashedGet(detailsUrl)
+ val detailsResponse = client.newCall(detailsRequest).execute()
+
+ if (!detailsResponse.isSuccessful) {
+ throw Exception("Failed to fetch title details: ${detailsResponse.code} - ${detailsResponse.body.string()}")
+ }
+
+ val detailsResult = detailsResponse.parseAs()
+ val mangas = detailsResult.titleList.map { manga ->
+ SManga.create().apply {
+ url = "/title/${manga.titleId}"
+ title = manga.titleName
+ thumbnail_url = manga.thumbnailImageUrl ?: manga.bannerImageUrl
+ }
+ }
+ return MangasPage(mangas, hasNextPage)
+ }
+
+ // Search
+ override fun fetchSearchManga(page: Int, query: String, filters: FilterList): Observable {
+ return if (query.startsWith(PREFIX_SEARCH)) {
+ val titleId = query.removePrefix(PREFIX_SEARCH)
+ fetchMangaDetails(
+ SManga.create().apply { url = "/title/$titleId" },
+ ).map { manga ->
+ MangasPage(listOf(manga.apply { url = "/title/$titleId" }), false)
+ }
+ } else {
+ super.fetchSearchManga(page, query, filters)
+ }
+ }
+
+ override fun searchMangaRequest(page: Int, query: String, filters: FilterList): Request {
+ val genreFilter = filters.firstInstance()
+
+ if (query.isNotBlank()) {
+ val offset = (page - 1) * searchLimit
+ val url = apiUrl.toHttpUrl().newBuilder()
+ .addPathSegments("search/title")
+ .addQueryParameter("keyword", query)
+ .addQueryParameter("offset", offset.toString())
+ .addQueryParameter("limit", searchLimit.toString())
+ .build()
+ return hashedGet(url)
+ }
+
+ if (genreFilter.state != 0) {
+ val url = baseUrl.toHttpUrl().newBuilder()
+ .addPathSegments(genreFilter.toUriPart().removePrefix("/"))
+ .build()
+ return GET(url, headers)
+ }
+ return popularMangaRequest(page)
+ }
+
+ override fun searchMangaParse(response: Response): MangasPage {
+ if (response.request.url.host.contains("api.")) {
+ val result = response.parseAs()
+ val mangas = result.titleList.map { manga ->
+ SManga.create().apply {
+ url = "/title/${manga.titleId}"
+ title = manga.titleName
+ thumbnail_url = manga.thumbnailImageUrl
+ }
+ }
+ return MangasPage(mangas, mangas.size >= searchLimit)
+ }
+
+ if (response.request.url.toString().contains("/search/genre/")) {
+ val document = response.asJsoup()
+ val nuxtData = document.selectFirst("script#__NUXT_DATA__")?.data()
+ ?: return MangasPage(emptyList(), false)
+
+ val rootArray = nuxtData.parseAs()
+ fun resolve(ref: JsonElement): JsonElement = rootArray[ref.jsonPrimitive.content.toInt()]
+
+ val genreResultObject = rootArray.firstOrNull { it is JsonObject && "title_list" in it.jsonObject }
+ ?: return MangasPage(emptyList(), false)
+
+ val mangaRefs = resolve(genreResultObject.jsonObject["title_list"]!!).jsonArray
+
+ val mangas = mangaRefs.map { ref ->
+ val mangaObject = resolve(ref).jsonObject
+ SManga.create().apply {
+ url = "/title/${resolve(mangaObject["title_id"]!!).jsonPrimitive.content}"
+ title = resolve(mangaObject["title_name"]!!).jsonPrimitive.content
+ thumbnail_url = mangaObject["thumbnail_image_url"]?.let { resolve(it).jsonPrimitive.content }
+ }
+ }
+ return MangasPage(mangas, false)
+ }
+ return popularMangaParse(response)
+ }
+
+ // Details
+ override fun mangaDetailsParse(response: Response): SManga {
+ val document = response.asJsoup()
+ val nuxtData = document.selectFirst("script#__NUXT_DATA__")?.data()
+ ?: throw Exception("Could not find Nuxt data")
+
+ val rootArray = nuxtData.parseAs()
+ fun resolve(ref: JsonElement): JsonElement = rootArray[ref.jsonPrimitive.content.toInt()]
+
+ val titleDetailsObject = rootArray.first { it is JsonObject && it.jsonObject.containsKey("title_in_japanese") }.jsonObject
+
+ val genreMap = buildMap {
+ rootArray.forEach { element ->
+ if (element is JsonObject && element.jsonObject.containsKey("genre_id")) {
+ val genreObject = element.jsonObject
+ val id = resolve(genreObject["genre_id"]!!).jsonPrimitive.content.toInt()
+ val name = resolve(genreObject["genre_name"]!!).jsonPrimitive.content
+ put(id, name)
+ }
+ }
+ }
+
+ return SManga.create().apply {
+ title = resolve(titleDetailsObject["title_name"]!!).jsonPrimitive.content
+ author = resolve(titleDetailsObject["author_text"]!!).jsonPrimitive.content
+ description = resolve(titleDetailsObject["introduction_text"]!!).jsonPrimitive.content
+ thumbnail_url = titleDetailsObject["thumbnail_image_url"]?.let { resolve(it).jsonPrimitive.content }
+ val genreIdRefs = resolve(titleDetailsObject["genre_id_list"]!!).jsonArray
+ val genreIds = genreIdRefs.map { resolve(it).jsonPrimitive.content.toInt() }
+ genre = genreIds.mapNotNull { genreMap[it] }.joinToString()
+ }
+ }
+
+ // Chapters
+ override fun chapterListRequest(manga: SManga): Request {
+ return GET(baseUrl + manga.url, headers)
+ }
+
+ override fun chapterListParse(response: Response): List {
+ val document = response.asJsoup()
+ val nuxtData = document.selectFirst("script#__NUXT_DATA__")?.data()
+ ?: throw Exception("Could not find Nuxt data")
+
+ val rootArray = nuxtData.parseAs()
+ fun resolve(ref: JsonElement): JsonElement = rootArray[ref.jsonPrimitive.content.toInt()]
+
+ val titleDetailsObject = rootArray.first { it is JsonObject && it.jsonObject.containsKey("episode_id_list") }.jsonObject
+ val episodeIdRefs = resolve(titleDetailsObject["episode_id_list"]!!).jsonArray
+ val episodeIds = episodeIdRefs.map { resolve(it).jsonPrimitive.content }
+
+ val (birthday, expires) = getBirthdayCookie(response.request.url)
+
+ val formBody = FormBody.Builder()
+ .add("episode_id_list", episodeIds.joinToString(","))
+ .build()
+
+ val params = (0 until formBody.size).associate { formBody.name(it) to formBody.value(it) }
+ val hash = generateHash(params, birthday, expires)
+
+ val postHeaders = headersBuilder()
+ .add("Accept", "application/json")
+ .add("Content-Type", "application/x-www-form-urlencoded")
+ .add("Origin", baseUrl)
+ .add("x-kmanga-is-crawler", "false")
+ .add("x-kmanga-hash", hash)
+ .build()
+
+ val apiRequest = POST("$apiUrl/episode/list", postHeaders, formBody)
+ val apiResponse = client.newCall(apiRequest).execute()
+
+ if (!apiResponse.isSuccessful) {
+ throw Exception("API request failed with code ${apiResponse.code}: ${apiResponse.body.string()}")
+ }
+
+ val result = apiResponse.parseAs()
+
+ return result.episodeList.map { chapter ->
+ SChapter.create().apply {
+ url = "/title/${chapter.titleId}/episode/${chapter.episodeId}"
+ name = if (chapter.point > 0 && chapter.badge != 3 && chapter.rentalFinishTime == null) {
+ "🔒 ${chapter.episodeName}"
+ } else {
+ chapter.episodeName
+ }
+ date_upload = dateFormat.tryParse(chapter.startTime)
+ }
+ }.reversed()
+ }
+
+ private fun getBirthdayCookie(url: HttpUrl): Pair {
+ val cookies = client.cookieJar.loadForRequest(url)
+ val birthdayCookie = cookies.firstOrNull { it.name == "birthday" }?.value
+
+ return if (birthdayCookie != null) {
+ try {
+ val decoded = URLDecoder.decode(birthdayCookie, "UTF-8")
+ val cookieData = decoded.parseAs