Skip to content

Mdblist support #488

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
ProdigyV21 merged 6 commits into from
Jul 24, 2026
Merged

Mdblist support #488

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
74cdb4e
mdblist
silentbil Jul 24, 2026
9c113c7
web
silentbil Jul 24, 2026
c7107db
Merge remote-tracking branch 'upstream/main' into mdblist
silentbil Jul 24, 2026
c46871c
mark as watched
silentbil Jul 24, 2026
5c2c7db
mark as watched
silentbil Jul 24, 2026
45edbc5
fixes
silentbil Jul 24, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
269 changes: 269 additions & 0 deletions app/src/main/kotlin/com/arflix/tv/data/api/MdbListApi.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,269 @@
package com.arflix.tv.data.api

import com.google.gson.annotations.SerializedName
import retrofit2.http.Body
import retrofit2.http.GET
import retrofit2.http.Headers
import retrofit2.http.POST
import retrofit2.http.Path
import retrofit2.http.Query

/**
* MDBList API (https://api.mdblist.com). Per-profile alternative to Trakt.
*
* Auth is a static user API key passed as the `apikey` query param on every
* call. Shapes below are verified against the live API (see the
* project_mdblist_api memory). Progress is 0-100 and comes back as a String
* ("30.00") — parse tolerantly.
*/
interface MdbListApi {

@GET("user")
suspend fun getUser(@Query("apikey") apiKey: String): MdbUser

@GET("sync/last_activities")
suspend fun getLastActivities(@Query("apikey") apiKey: String): MdbLastActivities

// ===== Watchlist =====

/** Unified flat array of movies + shows. */
@GET("watchlist/items")
suspend fun getWatchlistItems(
@Query("apikey") apiKey: String,
@Query("limit") limit: Int = 1000,
@Query("offset") offset: Int = 0,
@Query("unified") unified: String = "true"
): List<MdbWatchlistItem>

/** action = "add" | "remove". Body uses flat tmdb refs. */
@POST("watchlist/items/{action}")
@Headers("Content-Type: application/json")
suspend fun modifyWatchlist(
@Path("action") action: String,
@Query("apikey") apiKey: String,
@Body body: MdbWatchlistModifyBody
): MdbCountResponse

// ===== Watched (Trakt-style ids objects) =====

@GET("sync/watched")
suspend fun getWatched(
@Query("apikey") apiKey: String,
@Query("limit") limit: Int = 1000,
@Query("offset") offset: Int = 0
): MdbWatchedResponse

@POST("sync/watched")
@Headers("Content-Type: application/json")
suspend fun addWatched(
@Query("apikey") apiKey: String,
@Body body: MdbWatchedBody
): MdbCountResponse

@POST("sync/watched/remove")
@Headers("Content-Type: application/json")
suspend fun removeWatched(
@Query("apikey") apiKey: String,
@Body body: MdbWatchedBody
): MdbCountResponse

// ===== Scrobble / Continue Watching =====

/** Paused sessions that power Continue Watching. */
@GET("sync/playback")
suspend fun getPlayback(@Query("apikey") apiKey: String): List<MdbPlaybackItem>

/** action = "start" | "pause" | "stop". */
@POST("scrobble/{action}")
@Headers("Content-Type: application/json")
suspend fun scrobble(
@Path("action") action: String,
@Query("apikey") apiKey: String,
@Body body: MdbScrobbleBody
): MdbScrobbleResponse

/** Clear a paused session (by playback id or by media ids). */
@POST("scrobble/clear")
@Headers("Content-Type: application/json")
suspend fun scrobbleClear(
@Query("apikey") apiKey: String,
@Body body: MdbScrobbleClearBody
): MdbScrobbleClearResponse
}

// ========== Shared ids ==========

data class MdbIds(
val tmdb: Int? = null,
val imdb: String? = null,
val trakt: Int? = null,
val tvdb: Int? = null,
val mdblist: String? = null
)

// ========== User / activities ==========

data class MdbUser(
val username: String? = null,
@SerializedName("user_id") val userId: Long? = null,
val name: String? = null
)

data class MdbLastActivities(
@SerializedName("watchlisted_at") val watchlistedAt: String? = null,
@SerializedName("watched_at") val watchedAt: String? = null,
@SerializedName("season_watched_at") val seasonWatchedAt: String? = null,
@SerializedName("episode_watched_at") val episodeWatchedAt: String? = null,
@SerializedName("paused_at") val pausedAt: String? = null,
@SerializedName("episode_paused_at") val episodePausedAt: String? = null,
@SerializedName("rated_at") val ratedAt: String? = null
)

// ========== Watchlist ==========

data class MdbWatchlistItem(
val id: Int? = null,
val mediatype: String? = null, // "movie" | "show"
val ids: MdbIds? = null,
val title: String? = null,
@SerializedName("release_year") val releaseYear: Int? = null,
@SerializedName("release_date") val releaseDate: String? = null,
@SerializedName("watchlist_at") val watchlistAt: String? = null
)

data class MdbWatchlistModifyBody(
val movies: List<MdbTmdbRef>? = null,
val shows: List<MdbTmdbRef>? = null
)

data class MdbTmdbRef(val tmdb: Int)

// ========== Watched ==========

data class MdbWatchedBody(
val movies: List<MdbIdsItem>? = null,
val shows: List<MdbWatchedShowRef>? = null
)

data class MdbIdsItem(val ids: MdbIds)

data class MdbWatchedShowRef(
val ids: MdbIds,
val seasons: List<MdbWatchedSeasonRef>? = null
)

data class MdbWatchedSeasonRef(
val number: Int,
val episodes: List<MdbWatchedEpisodeRef>? = null
)

data class MdbWatchedEpisodeRef(val number: Int)

data class MdbWatchedResponse(
val movies: List<MdbWatchedMovieRow>? = null,
val episodes: List<MdbWatchedEpisodeRow>? = null,
val pagination: MdbPagination? = null
)

data class MdbWatchedMovieRow(
@SerializedName("last_watched_at") val lastWatchedAt: String? = null,
val movie: MdbMovieInfo? = null
)

data class MdbWatchedEpisodeRow(
@SerializedName("last_watched_at") val lastWatchedAt: String? = null,
val episode: MdbEpisodeInfo? = null
)

data class MdbPagination(
val offset: Int = 0,
val limit: Int = 0,
@SerializedName("has_more") val hasMore: Boolean = false
)

// ========== Playback / scrobble ==========

data class MdbMovieInfo(
val title: String? = null,
val year: Int? = null,
val ids: MdbIds? = null
)

data class MdbShowInfo(
val title: String? = null,
val year: Int? = null,
val ids: MdbIds? = null
)

data class MdbEpisodeInfo(
val season: Int? = null,
val number: Int? = null,
val name: String? = null,
val ids: MdbIds? = null,
val show: MdbShowInfo? = null
)

data class MdbPlaybackItem(
val id: Long? = null,
val progress: String? = null, // "30.00"
@SerializedName("updated_at") val updatedAt: String? = null,
@SerializedName("updated_at_ts") val updatedAtTs: Long? = null,
@SerializedName("paused_at") val pausedAt: String? = null,
val runtime: Int? = null, // minutes
val type: String? = null, // "movie" | "episode"
val movie: MdbMovieInfo? = null,
val show: MdbShowInfo? = null,
val episode: MdbEpisodeInfo? = null
)

data class MdbScrobbleBody(
val progress: Int,
val movie: MdbScrobbleMovie? = null,
val show: MdbScrobbleShow? = null
)

data class MdbScrobbleMovie(val ids: MdbIds)

data class MdbScrobbleShow(
val ids: MdbIds,
val season: MdbScrobbleSeason
)

data class MdbScrobbleSeason(
val number: Int,
val episode: MdbScrobbleEpisodeNumber
)

data class MdbScrobbleEpisodeNumber(val number: Int)

data class MdbScrobbleResponse(
val action: String? = null,
val progress: String? = null
)

data class MdbScrobbleClearBody(
val id: Long? = null,
val movie: MdbScrobbleMovie? = null,
val show: MdbScrobbleShow? = null
)

data class MdbScrobbleClearResponse(
val action: String? = null,
val deleted: Boolean? = null
)

// ========== Generic count response ==========

data class MdbCountResponse(
val added: MdbCounts? = null,
val removed: MdbCounts? = null,
val updated: MdbCounts? = null,
val existing: MdbCounts? = null
)

data class MdbCounts(
val movies: Int = 0,
val shows: Int = 0,
val seasons: Int = 0,
val episodes: Int = 0
)
21 changes: 20 additions & 1 deletion app/src/main/kotlin/com/arflix/tv/data/repository/CloudSyncRepository.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -100,7 +100,8 @@ class CloudSyncRepository @Inject constructor(
private val watchlistRepository: WatchlistRepository,
private val profileAvatarImageManager: ProfileAvatarImageManager,
private val invalidationBus: CloudSyncInvalidationBus,
private val pluginDataStore: com.arflix.tv.data.local.PluginDataStore
private val pluginDataStore: com.arflix.tv.data.local.PluginDataStore,
private val syncProviderStore: com.arflix.tv.data.repository.sync.SyncProviderStore
) {
private val TAG = "CloudSync"
private val gson = Gson()
Expand Down Expand Up @@ -694,6 +695,10 @@ class CloudSyncRepository @Inject constructor(
val traktTokens = traktRepository.exportTokensForProfiles(profiles.map { it.id })
root.put("traktTokens", JSONObject(gson.toJson(traktTokens)))

// MDBList selection (provider + API key) per profile
val mdbListSyncByProfile = syncProviderStore.exportForProfiles(profiles.map { it.id })
root.put("mdbListSyncByProfile", JSONObject(gson.toJson(mdbListSyncByProfile)))

// Dismissed Continue Watching keys per profile (persist hide/remove state)
val dismissedContinueWatchingByProfile =
traktRepository.exportDismissedContinueWatchingForProfiles(profiles.map { it.id })
Expand Down Expand Up @@ -1474,6 +1479,20 @@ class CloudSyncRepository @Inject constructor(
}
}.onFailure { AppLogger.recordException(it, mapOf("error_area" to "CloudSync", "cloud_flow" to "apply_trakt_tokens")) }

// ── MDBList selection (provider + API key) ──
runCatching {
root.optJSONObject("mdbListSyncByProfile")?.toString()?.takeIf { it.isNotBlank() }?.let { json ->
val type = TypeToken.getParameterized(
Map::class.java,
String::class.java,
com.arflix.tv.data.repository.sync.SyncProviderStore.ProfileSyncSelection::class.java
).type
val map: Map<String, com.arflix.tv.data.repository.sync.SyncProviderStore.ProfileSyncSelection> =
gson.fromJson(json, type) ?: emptyMap()
syncProviderStore.importForProfiles(map)
}
}.onFailure { AppLogger.recordException(it, mapOf("error_area" to "CloudSync", "cloud_flow" to "apply_mdblist_sync")) }

// ── Addons ──
runCatching {
val cloudAddonsTs = root.optLong("addonsUpdatedAt", 0L)
Expand Down
Loading
Loading