Add episode logic

hibernate.cfg.xml

@@ -8,7 +8,7 @@
         <property name="connection.url">jdbc:postgresql://localhost:5432/shikkanime</property>
         <property name="connection.username">postgres</property>
         <property name="connection.password">mysecretpassword</property>
-        <property name="show_sql">false</property>
+        <property name="show_sql">true</property>
         <property name="hibernate.current_session_context_class">org.hibernate.context.internal.ThreadLocalSessionContext</property>
     </session-factory>
 </hibernate-configuration>

src/main/kotlin/fr/shikkanime/caches/FromToZonedDateTimeKeyCache.kt

@@ -21,8 +21,4 @@ data class FromToZonedDateTimeKeyCache(
         result = 31 * result + to.hashCode()
         return result
     }
-
-    override fun toString(): String {
-        return "FromToZonedDateTimeKeyCache(from=$from, to=$to)"
-    }
 }

src/main/kotlin/fr/shikkanime/controllers/AdminController.kt

@@ -30,6 +30,7 @@ class AdminController {
     @Path("/platforms")
     @Post
     private fun postPlatform(@BodyParam parameters: Parameters): Response {
+        println(parameters)
         val redirectResponse = RedirectResponse("/admin/platforms")
 
         val platformName = parameters["platform"] ?: return redirectResponse

src/main/kotlin/fr/shikkanime/entities/Anime.kt

@@ -0,0 +1,21 @@
+package fr.shikkanime.entities
+
+import jakarta.persistence.*
+import java.time.ZonedDateTime
+import java.util.*
+
+@Entity
+@Table(name = "anime")
+data class Anime(
+    override val uuid: UUID? = null,
+    @ManyToOne(optional = false, fetch = FetchType.LAZY)
+    val country: Country? = null,
+    @Column(nullable = false)
+    val name: String? = null,
+    @Column(nullable = false, name = "release_date")
+    val releaseDate: ZonedDateTime = ZonedDateTime.now(),
+    @Column(nullable = false)
+    var image: String? = null,
+    @Column(nullable = true, columnDefinition = "TEXT")
+    var description: String? = null,
+) : ShikkEntity(uuid)

src/main/kotlin/fr/shikkanime/entities/Country.kt

@@ -2,45 +2,15 @@ package fr.shikkanime.entities
 
 import jakarta.persistence.Column
 import jakarta.persistence.Entity
-import jakarta.persistence.Index
 import jakarta.persistence.Table
 import java.util.*
 
 @Entity
-@Table(
-    name = "country",
-    indexes = [
-        Index(name = "idx_country_country_code", columnList = "country_code")
-    ]
-)
+@Table(name = "country")
 data class Country(
     override val uuid: UUID? = null,
     @Column(nullable = false, unique = true)
     val name: String? = null,
     @Column(nullable = false, unique = true, name = "country_code")
     val countryCode: String? = null,
-) : ShikkEntity(uuid) {
-    override fun equals(other: Any?): Boolean {
-        if (this === other) return true
-        if (other !is Country) return false
-        if (!super.equals(other)) return false
-
-        if (uuid != other.uuid) return false
-        if (name != other.name) return false
-        if (countryCode != other.countryCode) return false
-
-        return true
-    }
-
-    override fun hashCode(): Int {
-        var result = super.hashCode()
-        result = 31 * result + (uuid?.hashCode() ?: 0)
-        result = 31 * result + (name?.hashCode() ?: 0)
-        result = 31 * result + (countryCode?.hashCode() ?: 0)
-        return result
-    }
-
-    override fun toString(): String {
-        return "Country(uuid=$uuid, name=$name, countryCode=$countryCode)"
-    }
-}
+) : ShikkEntity(uuid)

src/main/kotlin/fr/shikkanime/entities/Episode.kt

@@ -0,0 +1,39 @@
+package fr.shikkanime.entities
+
+import fr.shikkanime.entities.enums.EpisodeType
+import fr.shikkanime.entities.enums.LangType
+import jakarta.persistence.*
+import java.time.ZonedDateTime
+import java.util.*
+
+@Entity
+@Table(name = "episode")
+data class Episode(
+    override val uuid: UUID? = null,
+    @ManyToOne(optional = false, fetch = FetchType.LAZY)
+    var platform: Platform? = null,
+    @ManyToOne(optional = false, fetch = FetchType.LAZY)
+    var anime: Anime? = null,
+    @Column(nullable = false, name = "episode_type")
+    @Enumerated(EnumType.STRING)
+    val episodeType: EpisodeType? = null,
+    @Column(nullable = false, name = "lang_type")
+    @Enumerated(EnumType.STRING)
+    val langType: LangType? = null,
+    @Column(nullable = false)
+    val hash: String? = null,
+    @Column(nullable = false, name = "release_date")
+    val releaseDate: ZonedDateTime = ZonedDateTime.now(),
+    @Column(nullable = false)
+    var season: Int? = null,
+    @Column(nullable = false)
+    var number: Int? = null,
+    @Column(nullable = true, columnDefinition = "TEXT")
+    var title: String? = null,
+    @Column(nullable = false, columnDefinition = "TEXT")
+    var url: String? = null,
+    @Column(nullable = false, columnDefinition = "TEXT")
+    var image: String? = null,
+    @Column(nullable = false)
+    var duration: Long = -1
+) : ShikkEntity(uuid)

src/main/kotlin/fr/shikkanime/entities/Metric.kt

@@ -2,18 +2,12 @@ package fr.shikkanime.entities
 
 import jakarta.persistence.Column
 import jakarta.persistence.Entity
-import jakarta.persistence.Index
 import jakarta.persistence.Table
 import java.time.ZonedDateTime
 import java.util.*
 
 @Entity
-@Table(
-    name = "metric",
-    indexes = [
-        Index(name = "idx_metrics_date", columnList = "date")
-    ]
-)
+@Table(name = "metric")
 data class Metric(
     override val uuid: UUID? = null,
     @Column(name = "cpu_load")
@@ -22,32 +16,6 @@ data class Metric(
     val memoryUsage: Long = 0,
     @Column(name = "database_size")
     val databaseSize: Long = 0,
-    @Column(name = "date")
+    @Column(nullable = false)
     val date: ZonedDateTime = ZonedDateTime.now(),
-) : ShikkEntity(uuid) {
-    override fun equals(other: Any?): Boolean {
-        if (this === other) return true
-        if (other !is Metric) return false
-
-        if (uuid != other.uuid) return false
-        if (cpuLoad != other.cpuLoad) return false
-        if (memoryUsage != other.memoryUsage) return false
-        if (databaseSize != other.databaseSize) return false
-        if (date != other.date) return false
-
-        return true
-    }
-
-    override fun hashCode(): Int {
-        var result = uuid?.hashCode() ?: 0
-        result = 31 * result + cpuLoad.hashCode()
-        result = 31 * result + memoryUsage.hashCode()
-        result = 31 * result + databaseSize.hashCode()
-        result = 31 * result + date.hashCode()
-        return result
-    }
-
-    override fun toString(): String {
-        return "Metric(uuid=$uuid, cpuLoad=$cpuLoad, memoryUsage=$memoryUsage, databaseSize=$databaseSize, date=$date)"
-    }
-}
+) : ShikkEntity(uuid)

src/main/kotlin/fr/shikkanime/entities/Platform.kt

@@ -12,33 +12,7 @@ data class Platform(
     @Column(nullable = false, unique = true)
     val name: String? = null,
     @Column(nullable = false)
-    val url: String? = null,
+    var url: String? = null,
     @Column(nullable = false)
-    val image: String? = null
-) : ShikkEntity(uuid) {
-    override fun equals(other: Any?): Boolean {
-        if (this === other) return true
-        if (javaClass != other?.javaClass) return false
-
-        other as Platform
-
-        if (uuid != other.uuid) return false
-        if (name != other.name) return false
-        if (url != other.url) return false
-        if (image != other.image) return false
-
-        return true
-    }
-
-    override fun hashCode(): Int {
-        var result = uuid?.hashCode() ?: 0
-        result = 31 * result + (name?.hashCode() ?: 0)
-        result = 31 * result + (url?.hashCode() ?: 0)
-        result = 31 * result + (image?.hashCode() ?: 0)
-        return result
-    }
-
-    override fun toString(): String {
-        return "Platform(uuid=$uuid, name=$name, url=$url, image=$image)"
-    }
-}
+    var image: String? = null
+) : ShikkEntity(uuid)

src/main/kotlin/fr/shikkanime/entities/ShikkEntity.kt

@@ -11,21 +11,4 @@ open class ShikkEntity(
     @Id
     @UuidGenerator
     open val uuid: UUID? = null,
-) : Serializable {
-    override fun equals(other: Any?): Boolean {
-        if (this === other) return true
-        if (other !is ShikkEntity) return false
-
-        if (uuid != other.uuid) return false
-
-        return true
-    }
-
-    override fun hashCode(): Int {
-        return uuid?.hashCode() ?: 0
-    }
-
-    override fun toString(): String {
-        return "ShikkEntity(uuid=$uuid)"
-    }
-}
+) : Serializable

src/main/kotlin/fr/shikkanime/entities/enums/EpisodeType.kt

@@ -0,0 +1,8 @@
+package fr.shikkanime.entities.enums
+
+enum class EpisodeType {
+    EPISODE,
+    SPECIAL,
+    FILM,
+    ;
+}

src/main/kotlin/fr/shikkanime/entities/enums/LangType.kt

@@ -0,0 +1,7 @@
+package fr.shikkanime.entities.enums
+
+enum class LangType {
+    SUBTITLES,
+    VOICE,
+    ;
+}

src/main/kotlin/fr/shikkanime/jobs/FetchEpisodesJob.kt

@@ -1,21 +1,30 @@
 package fr.shikkanime.jobs
 
+import fr.shikkanime.entities.Episode
+import fr.shikkanime.services.EpisodeService
 import fr.shikkanime.utils.Constant
+import jakarta.inject.Inject
 import java.time.ZonedDateTime
 
 class FetchEpisodesJob : AbstractJob() {
+    @Inject
+    private lateinit var episodeService: EpisodeService
+
     override fun run() {
         val zonedDateTime = ZonedDateTime.now().withNano(0)
+        val episodes = mutableListOf<Episode>()
 
         Constant.abstractPlatforms.forEach { abstractPlatform ->
             println("Fetching episodes for ${abstractPlatform.getPlatform().name}...")
 
             try {
-                abstractPlatform.fetchEpisodes(zonedDateTime)
+                episodes.addAll(abstractPlatform.fetchEpisodes(zonedDateTime))
             } catch (e: Exception) {
                 println("Error while fetching episodes for ${abstractPlatform.getPlatform().name}: ${e.message}")
                 e.printStackTrace()
             }
         }
+
+        episodes.forEach { episodeService.saveOrUpdate(it) }
     }
 }

src/main/kotlin/fr/shikkanime/platforms/AbstractPlatform.kt

@@ -1,9 +1,9 @@
 package fr.shikkanime.platforms
 
 import fr.shikkanime.entities.Country
+import fr.shikkanime.entities.Episode
 import fr.shikkanime.entities.Platform
 import fr.shikkanime.services.CountryService
-import fr.shikkanime.services.PlatformService
 import fr.shikkanime.utils.Constant
 import jakarta.inject.Inject
 import kotlinx.coroutines.runBlocking
@@ -16,9 +16,6 @@ abstract class AbstractPlatform<C : PlatformConfiguration> {
         val content: Map<String, String> = emptyMap(),
     )
 
-    @Inject
-    protected lateinit var platformService: PlatformService
-
     @Inject
     protected lateinit var countryService: CountryService
 
@@ -28,7 +25,7 @@ abstract class AbstractPlatform<C : PlatformConfiguration> {
     protected abstract fun getConfigurationClass(): Class<C>
     abstract fun getPlatform(): Platform
     abstract suspend fun fetchApiContent(zonedDateTime: ZonedDateTime): Api
-    abstract fun fetchEpisodes(zonedDateTime: ZonedDateTime): List<String>
+    abstract fun fetchEpisodes(zonedDateTime: ZonedDateTime): List<Episode>
     abstract fun reset()
 
     protected fun getCountries() = countryService.findAllByCode(configuration!!.availableCountries)