V6 upgrade (#856)

* fix(ts-utils): remove hoisted variables

* build(backend): upgrade deps

* feat(backend): update to new apalis version

* chore(backend): remove comment

* refactor(backend): do not have star import

* feat(backend): change to memory storage

* feat(*): remaining cleanup for new storage

* ci(backend): hoist dep to workspace

* feat(database): start migration collection data

* feat(database): migrate all collection ids

* chore(backend): change the type of collection id

* chore(frontend): migrate to new collection id data type

* chore(database): split steps

* fix(backend): do not associate when no entity to associate to

* chore(database): change migration script name

* feat(database): change primary key values of review

* chore(backend): adapt to new db schema

* feat(*): adapt to new gql schema

* fix(backend): generate new id for creating review

* chore(backend): do not create ids incorrectly

* feat(backend): setup correct triggers

* fix(database): rebuild correct primary keys and indices

* feat(database): change existing migrations

* feat(database): change primary key for seen table

* feat(backend): adapt to new gql schema

* chore(frontend): adapt to new gql schema

* chore(database): change order of new migrations

* feat(database): change default value for calendar event

* feat(backend): adapt to new database schema

* chore(backend): remove useless binding

* chore(database): change order of migrations

* fix(database): change default prefix

* feat(database): migrate data of import report

* Revert "fix(database): change default prefix"

This reverts commit 7c99a19.

* fix(frontend): add a data import attribute to html

* chore(backend): adapt to new db schema

* fix(backend): use correct prefix for table

* feat(database): migrate genre data

* chore(database): change column types

* fix(database): change name of constraint

* chore(backend): additional attributes

* feat(backend): adapt to new database schema

* chore(frontend): adapt to new gql schema

* fix(backend): cast into correct type

* feat(backend): remove useless genre

* fix(backend): add relation between entities

* build(backend): bump version

* chore(backend): remove un-needed deps

* feat(database): migration for metadata group

* feat(backend): adapt to new database schema

* chore(frontend): adapt to new gql schema

* fix(backend): create unqiue index again

* feat(database): migration to change person PK

* feat(backend): adapt to new database schema

* chore(frontend): adapt to new gql schema

* chore(frontend): remove useless event

* feat(database): perform migration only when necessary

* feat(database): add checks before migration

* fix(database): change column types for tables

* feat(database): perform migration only when necessary

* feat(database): add checks before migration

* fix(database): change column types for tables

* fix(database): change more column types

* fix(database): migrate 2 schemas

* feat(database): migrate most of the tables

* fix(database): set correct default values

* feat(database): change order of seen table columns

* chore(database): change order of columns

* feat(database): change order of columns

* chore(database): order of columns

* feat(database): recreate constraint

* chore(database): change order of columns

* chore(database): change order of migrations

* chore(database): change name of migration

* feat(database): migration to change metadata id to text

* refactor(database): change location of function

* fix(database): do not set to not null

* feat(database): change types of columns

* chore(backend): remove sql cast

* chore(database): change order of columns

* chore(database): more ordering of columns

* feat(database): create indices

* chore(backend): adjust to new backend schema

* feat(database): add reset summary migration

* refactor(database): change order of fns

* chore(graphql): generate new types

* chore(frontend): adapt to new gql schema

* fix(backend): modify partial selects

* chore(backend): remove outdated volume

* fix(frontend): use correct input

* chore(docs): remove warning

* chore(database): change name of migration

* chore(backend): change wording

* chore(database/migrations): show trace warnings and infos

* refactor(backend): change location of enum

* feat(database): add migration to change enums

* chore(database): change names of migrations

* feat(*): upgrade sea-orm version

* fix(frontend): revert to old sort by

* fix(frontend): correct filter type

* fix(backend): correct types for filter

* fix(backend): use correct filter for seen state

* chore(backend): remove state

* fix(database): remove useless attribute

* feat(backend): prefix new workouts with `wor_`

* feat(database): new prefix for workouts

* feat(backend): do not generate workout id in hook

* chore(database): change name of migration

* fix(backend): correct logic for last updated and id

* fix(backend): no more useless processing of old workouts

* build(backend): remove dependency on git branch

* chore: change name of migrations

* feat(database): change casing of core enum

* fix(database): update one enum correctly

* fix(database): do not set summary

* feat(database,backend): change casing of stuff

* fix(database): more casing handling

* fix(database): update bests correctly

* build(backend): bump version

* fix(database): reset state changes for people

* Revert "build(backend): bump version"

This reverts commit 380b68e.

* chore(database): add logging to chaning enum

* chore(database): remove comment

* feat(database,backend): change migration names

* build(backend): bump version

* feat(database): add new v6 migration

* feat(database,backend): change order of migrations

* chore(database): remove useless function

* fix(database): add first v6 migration

* chore(database): remove useless files

* feat(database): migration to change boolean columns

* feat(backend): change names of boolean columns

* chore(frontend): adapt to new gql schema

* fix(database): change migration to take boolean column into account

* fix(frontend): do not show collection entity

* feat(backend): change type of user primary key

* feat(database): change primary keys of stuff

* fix(database): add new indices and constraints

* chore(database): change order of columns

* merge main

* fix(backend): use correct value of last migration

* feat(backend): adapt to new database schema

* refactor(backend): move model into mod

* feat(database): start implementing user changes for reviews

* chore(database): start reviews

* chore(backend): hardcode correct values

* fix(backend): take out of reference

* chore(docs): update included file

* feat(database): reviews almost done

* fix(database): get comments working

* feat(database): add index for sink integrations

* build(backend): remove hashing deps

* feat(config): remove useless config param

* refactor(backend): adjust to new database schema

* feat(backend): use new url

* chore: remove clippy errors

* docs: change integrations url

* fix(frontend): adjust to new integration urls

* build(backend): un-bump version

* Revert "feat(database): add index for sink integrations"

This reverts commit 0cbdc80.

* feat(database): add integrations table

* feat(backend): generate entities for new models

* build(backend,database): move dep

* Revert "build(backend,database): move dep"

This reverts commit fbfde51.

* feat(database,backend): add enum for integration lot

* feat(backend,database): add integration lot and source

* refactor(backend): move import

* chore(database,backend): change name of column

* feat(backend): add specific for integrations

* feat(backend): async graphql types

* feat(database,backend): make column nullable

* feat(backend): allow creating user integration

* feat(backend): mutation to delete an integration

* feat(frontend): slightly adapt to new schema

* chore(backend,frontend): change name of mutations

* chore(backend): change name of property

* feat(frontend): adapt to new gql schema

* chore(databases): remove index

* feat(database): add two indices

* feat(backend): sync users table to new integrations

* feat(backend): use new integration source

* feat(backend): remove old integrations code

* feat(backend): get integrations query working

* feat(backend): update integration when triggered

* feat(frontend): display integrations

* feat(frontend): close eyes when opened

* chore(frontend): add space

* chore(frontend): adapt to new gql schema

* feat(ci): add shortcut for integrations

* docs: update new webhook url

* chore(frontend): adapt to new webhook format

* docs: add migration instructions

* docs: tell about deleted integrations

* refactor(frontend): change name of variable

* fix(frontend): change case of integrations

* fix(frontend): deleting should not reset filter

* feat(backend): add template for monitoring column

* feat(frontend): respect new configuration variable

* feat(database): add information template for existing user's monitoring collection

* fix(frontend): data type for number input

* feat(backend): remove dependency on `uuid`

* chore(backend): add todo comment

* chore(database): remove useless comment

* feat(backend): remove entities from monitoring correctly

* fix(backend): remove is_empty check for arrays

* chore(backend): remove development mutation call

* docs: new migration information

* build(backend): minor upgrade deps

* build(ts): upgrade deps

* chore: enable single fetch

* feat(frontend): add generics to meta types

* chore(frontend): do not return bare responses from API routes

* build(backend): update deps

* chore(docs): update include

* build(backend): pin dependency versions

* chore(database): change name of migration

* fix(backend): change workout related calculations

* docs: change plugins to integrations

* feat(database): add collection_to_entity.created_on column

* chore(config): change number of days to remove from monitoring

* chore(database): remove migration for monitoring

* fix(backend): add trait for checking updation

* feat(backend): send timezone details to tmdb

* feat(backend): basic stuff

* refactor(backend): move client to base

* refactor(backend): change name of struct

* refactor(backend): remove extra impls

* feat(backend): take additional args to check for force update

* feat(backend): upgrade `cached` deps

* feat(backend): do not update when no changes in upstream

* feat(backend): work for tmdb tv shows

* feat(backend): change function to remove stuff from monitoring

* fix(backend): calculate abs days before removing

* feat(config): change number of days

* build(backend): bump version

* chore(backend): remove function invocation

* docs: better link

* chore(config): order of impls

Author: IgnisDa

Cargo.lock

@@ -3,17 +3,16 @@ members = ["apps/backend", "libs/config", "libs/database", "libs/rs-utils"]
 resolver = "2"
 
 [workspace.dependencies]
-anyhow = "1.0.82"
-async-graphql = { version = "7.0.5", features = [
+anyhow = "=1.0.82"
+async-graphql = { version = "=7.0.5", features = [
     "chrono",
     "decimal",
     "log",
     "tracing",
-    "uuid",
 ] }
-chrono = "0.4.38"
-nanoid = "0.4.0"
-schematic = { version = "0.16", features = [
+chrono = "=0.4.38"
+nanoid = "=0.4.0"
+schematic = { version = "=0.16.4", features = [
     "config",
     "json",
     "schema",
@@ -25,7 +24,7 @@ schematic = { version = "0.16", features = [
     "renderer_template",
     "yaml",
 ], default-features = false }
-sea-orm = { version = "1.0.0-rc.5", features = [
+sea-orm = { version = "=1.0.0-rc.5", features = [
     "debug-print",
     "postgres-array",
     "macros",
@@ -34,10 +33,9 @@ sea-orm = { version = "1.0.0-rc.5", features = [
     "with-chrono",
     "with-json",
     "with-rust_decimal",
-    "with-uuid",
 ], default-features = false }
-sea-orm-migration = "1.0.0-rc.5"
-serde = { version = "1.0.202", features = ["derive"] }
-serde_json = "1.0.116"
-strum = { version = "0.26.2", features = ["derive"] }
-tracing = { version = "0.1.40", features = ["attributes"] }
+sea-orm-migration = "=1.0.0-rc.5"
+serde = { version = "=1.0.202", features = ["derive"] }
+serde_json = "=1.0.117"
+strum = { version = "=0.26.2", features = ["derive"] }
+tracing = { version = "=0.1.40", features = ["attributes"] }

Cargo.toml

@@ -31,6 +31,11 @@
 Ryot (**R**oll **Y**our **O**wn **T**racker), pronounced "riot", aims to be the only self
 hosted tracker you will ever need!
 
+## IMPORTANT NOTE FOR `v5.*` USERS
+
+If you were using `v5.*` of Ryot, please read the
+[migration guide](https://docs.ryot.io/migration.html#from-v5-v6) for instructions.
+
 ## 💻 Demo
 
 You can use the demo account on the Ryot website. Login with the username `demo` and

README.md

@@ -1,81 +1,79 @@
 [package]
 name = "ryot"
-version = "5.5.6"
+version = "6.0.0"
 edition = "2021"
 repository = "https://github.com/IgnisDa/ryot"
 license = "GPL-3.0"
 
 [dependencies]
 anyhow = { workspace = true }
-apalis = { version = "0.5.3", features = ["cron", "limit"] }
-argon2 = "0.5.3"
+apalis = { version = "=0.5.3", features = ["cron", "limit"] }
+argon2 = "=0.6.0-pre.0"
 async-graphql = { workspace = true }
-async-graphql-axum = "7.0.3"
-async-trait = "0.1.80"
-aws-sdk-s3 = { version = "1.23.0", features = ["behavior-version-latest"] }
-axum = { version = "0.7.5", features = ["macros", "multipart"] }
-boilermates = "0.3.0"
-cached = { version = "0.49.3", features = ["disk_store"] }
+async-graphql-axum = "=7.0.5"
+async-trait = "=0.1.80"
+aws-sdk-s3 = { version = "=1.34.0", features = ["behavior-version-latest"] }
+axum = { version = "=0.7.5", features = ["macros", "multipart"] }
+boilermates = "=0.3.0"
+cached = { version = "=0.51.4", features = ["disk_store"] }
 chrono = { workspace = true }
-chrono-tz = "0.9.0"
+chrono-tz = "=0.9.0"
 config = { path = "../../libs/config" }
-convert_case = "0.6.0"
-const-str = "0.5.7"
-csv = "1.3.0"
+convert_case = "=0.6.0"
+const-str = "=0.5.7"
+csv = "=1.3.0"
 database = { path = "../../libs/database" }
-data-encoding = "2.5.0"
-derive_more = { version = "1.0.0-beta.6", features = [
+data-encoding = "=2.6.0"
+derive_more = { version = "=1.0.0-beta.6", features = [
     "add",
     "sum",
     "add_assign",
 ], default-features = false }
-dotenvy = "0.15.7"
-enum_meta = "0.6.0"
-flate2 = "1.0.28"
-futures = "0.3.30"
-graphql_client = "0.14.0"
-harsh = "0.2.2"
-hashbag = "0.1.12"
-http = "1.1.0"
-http-types = "2.12.0"
-isolang = { version = "2.4.0", features = ["list_languages"] }
-itertools = "0.12.1"
-jsonwebtoken = { version = "9.3.0", default-features = false }
-kinded = "0.3.0"
-lettre = { version = "0.11.6", features = [
+dotenvy = "=0.15.7"
+enum_meta = "=0.6.0"
+flate2 = "=1.0.30"
+futures = "=0.3.30"
+graphql_client = "=0.14.0"
+hashbag = "=0.1.12"
+http = "=1.1.0"
+http-types = "=2.12.0"
+isolang = { version = "=2.4.0", features = ["list_languages"] }
+itertools = "=0.13.0"
+jsonwebtoken = { version = "=9.3.0", default-features = false }
+kinded = "=0.3.0"
+lettre = { version = "=0.11.7", features = [
     "rustls-tls",
     "smtp-transport",
     "builder",
 ], default-features = false }
-markdown = "1.0.0-alpha.15"
+markdown = "=1.0.0-alpha.17"
 nanoid = { workspace = true }
-openidconnect = "3.5.0"
-paginate = "1.1.11"
-rand = "0.8.5"
-regex = "1.10.4"
+openidconnect = "=3.5.0"
+paginate = "=1.1.11"
+rand = "=0.9.0-alpha.1"
+regex = "=1.10.4"
 rs-utils = { path = "../../libs/rs-utils" }
-rust_decimal = "1.35.0"
-rust_decimal_macros = "1.34.2"
-rust_iso3166 = "0.1.12"
+rust_decimal = "=1.35.0"
+rust_decimal_macros = "=1.34.2"
+rust_iso3166 = "=0.1.13"
 schematic = { workspace = true }
-scraper = "0.19.0"
+scraper = "=0.19.0"
 sea-orm = { workspace = true }
 sea-orm-migration = { workspace = true }
-sea-query = "0.31.0-rc.6"
+sea-query = "=0.31.0-rc.7"
 serde = { workspace = true }
 serde_json = { workspace = true }
-serde_with = { version = "3.7.0", features = ["chrono_0_4"] }
-serde-xml-rs = "0.6.0"
-slug = "0.1.5"
+serde_with = { version = "=3.8.1", features = ["chrono_0_4"] }
+serde-xml-rs = "=0.6.0"
+slug = "=0.1.5"
 strum = { workspace = true }
-struson = { version = "0.5.0", features = ["serde"] }
-surf = { version = "2.3.2", features = [
+struson = { version = "=0.5.0", features = ["serde"] }
+surf = { version = "=2.3.2", features = [
     "h1-client-rustls",
 ], default-features = false }
-tokio = { version = "1.37.0", features = ["full"] }
-tower = { version = "0.4.13", features = ["buffer"] }
-tower-http = { version = "0.5.2", features = ["catch-panic", "cors", "trace"] }
+tokio = { version = "=1.38.0", features = ["full"] }
+tower = { version = "=0.4.13", features = ["buffer"] }
+tower-http = { version = "=0.5.2", features = ["catch-panic", "cors", "trace"] }
 tracing = { workspace = true }
-tracing-subscriber = "0.3.18"
-logs-wheel = "0.3.1"
-uuid = "1.8.0"
+tracing-subscriber = "=0.3.18"
+logs-wheel = "=0.3.1"

apps/backend/Cargo.toml

@@ -63,8 +63,8 @@ pub async fn yank_integrations_data(
 // The background jobs which cannot be throttled.
 #[derive(Debug, Deserialize, Serialize, Display)]
 pub enum CoreApplicationJob {
-    YankIntegrationsData(i32),
-    BulkProgressUpdate(i32, Vec<ProgressUpdateInput>),
+    YankIntegrationsData(String),
+    BulkProgressUpdate(String, Vec<ProgressUpdateInput>),
 }
 
 impl Message for CoreApplicationJob {
@@ -80,7 +80,7 @@ pub async fn perform_core_application_job(
     let start = Instant::now();
     let status = match information {
         CoreApplicationJob::YankIntegrationsData(user_id) => misc_service
-            .yank_integrations_data_for_user(user_id)
+            .yank_integrations_data_for_user(&user_id)
             .await
             .is_ok(),
         CoreApplicationJob::BulkProgressUpdate(user_id, input) => misc_service
@@ -100,16 +100,16 @@ pub async fn perform_core_application_job(
 // The background jobs which can be deployed by the application.
 #[derive(Debug, Deserialize, Serialize, Display)]
 pub enum ApplicationJob {
-    ImportFromExternalSource(i32, Box<DeployImportJobInput>),
-    ReEvaluateUserWorkouts(i32),
-    UpdateMetadata(String),
+    ImportFromExternalSource(String, Box<DeployImportJobInput>),
+    ReEvaluateUserWorkouts(String),
+    UpdateMetadata(String, bool),
     UpdateGithubExerciseJob(Exercise),
     UpdatePerson(String),
     RecalculateCalendarEvents,
     AssociateGroupWithMetadata(MediaLot, MediaSource, String),
     ReviewPosted(ReviewPostedEvent),
-    PerformExport(i32, Vec<ExportItem>),
-    RecalculateUserSummary(i32),
+    PerformExport(String, Vec<ExportItem>),
+    RecalculateUserSummary(String),
     PerformBackgroundTasks,
 }
 
@@ -133,15 +133,15 @@ pub async fn perform_application_job(
             .await
             .is_ok(),
         ApplicationJob::RecalculateUserSummary(user_id) => misc_service
-            .calculate_user_summary(user_id, true)
+            .calculate_user_summary(&user_id, true)
             .await
             .is_ok(),
         ApplicationJob::ReEvaluateUserWorkouts(user_id) => exercise_service
             .re_evaluate_user_workouts(user_id)
             .await
             .is_ok(),
-        ApplicationJob::UpdateMetadata(metadata_id) => misc_service
-            .update_metadata_and_notify_users(&metadata_id)
+        ApplicationJob::UpdateMetadata(metadata_id, force_update) => misc_service
+            .update_metadata_and_notify_users(&metadata_id, force_update)
             .await
             .is_ok(),
         ApplicationJob::UpdatePerson(person_id) => misc_service

apps/backend/src/background.rs

@@ -19,7 +19,7 @@ pub struct Model {
     pub last_updated_on: DateTimeUtc,
     pub name: String,
     pub description: Option<String>,
-    pub user_id: i32,
+    pub user_id: String,
     #[sea_orm(column_type = "Json")]
     pub information_template: Option<Vec<CollectionExtraInformation>>,
 }

apps/backend/src/entities/collection.rs

@@ -8,6 +8,7 @@ use serde::{Deserialize, Serialize};
 pub struct Model {
     #[sea_orm(primary_key)]
     pub id: i32,
+    pub created_on: DateTimeUtc,
     pub last_updated_on: DateTimeUtc,
     pub collection_id: String,
     pub metadata_id: Option<String>,

apps/backend/src/entities/collection_to_entity.rs

@@ -46,7 +46,7 @@ pub struct Model {
     pub muscles: Vec<ExerciseMuscle>,
     pub attributes: ExerciseAttributes,
     #[graphql(skip_input)]
-    pub created_by_user_id: Option<i32>,
+    pub created_by_user_id: Option<String>,
 }
 
 #[async_trait]

apps/backend/src/entities/exercise.rs

@@ -15,12 +15,12 @@ use crate::importer::ImportResultResponse;
 pub struct Model {
     #[sea_orm(primary_key, auto_increment = false)]
     pub id: String,
-    pub user_id: i32,
+    pub user_id: String,
     pub source: ImportSource,
     pub started_on: DateTimeUtc,
     pub finished_on: Option<DateTimeUtc>,
     pub details: Option<ImportResultResponse>,
-    pub success: Option<bool>,
+    pub was_success: Option<bool>,
 }
 
 #[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]

apps/backend/src/entities/import_report.rs

@@ -0,0 +1,59 @@
+//! `SeaORM` Entity. Generated by sea-orm-codegen 0.12.15
+
+use async_graphql::{InputObject, SimpleObject};
+use async_trait::async_trait;
+use database::{IntegrationLot, IntegrationSource};
+use nanoid::nanoid;
+use sea_orm::{entity::prelude::*, ActiveValue};
+
+use crate::models::media::IntegrationSourceSpecifics;
+
+#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq, SimpleObject, InputObject)]
+#[sea_orm(table_name = "integration")]
+#[graphql(name = "Integration", input_name = "IntegrationInput")]
+pub struct Model {
+    #[sea_orm(primary_key, auto_increment = false)]
+    #[graphql(skip_input)]
+    pub id: String,
+    #[graphql(skip)]
+    pub user_id: String,
+    pub lot: IntegrationLot,
+    pub source: IntegrationSource,
+    #[graphql(skip_input)]
+    pub created_on: DateTimeUtc,
+    #[graphql(skip_input)]
+    pub last_triggered_on: Option<DateTimeUtc>,
+    #[sea_orm(column_type = "Json")]
+    pub source_specifics: Option<IntegrationSourceSpecifics>,
+}
+
+#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
+pub enum Relation {
+    #[sea_orm(
+        belongs_to = "super::user::Entity",
+        from = "Column::UserId",
+        to = "super::user::Column::Id",
+        on_update = "Cascade",
+        on_delete = "Cascade"
+    )]
+    User,
+}
+
+impl Related<super::user::Entity> for Entity {
+    fn to() -> RelationDef {
+        Relation::User.def()
+    }
+}
+
+#[async_trait]
+impl ActiveModelBehavior for ActiveModel {
+    async fn before_save<C>(mut self, _db: &C, insert: bool) -> Result<Self, DbErr>
+    where
+        C: ConnectionTrait,
+    {
+        if insert {
+            self.id = ActiveValue::Set(format!("int_{}", nanoid!(12)));
+        }
+        Ok(self)
+    }
+}

apps/backend/src/entities/integration.rs

@@ -8,6 +8,7 @@ pub mod collection_to_entity;
 pub mod exercise;
 pub mod genre;
 pub mod import_report;
+pub mod integration;
 pub mod metadata;
 pub mod metadata_group;
 pub mod metadata_to_genre;

apps/backend/src/entities/mod.rs

@@ -6,6 +6,7 @@ pub use super::collection_to_entity::Entity as CollectionToEntity;
 pub use super::exercise::Entity as Exercise;
 pub use super::genre::Entity as Genre;
 pub use super::import_report::Entity as ImportReport;
+pub use super::integration::Entity as Integration;
 pub use super::metadata::Entity as Metadata;
 pub use super::metadata_group::Entity as MetadataGroup;
 pub use super::metadata_to_genre::Entity as MetadataToGenre;

apps/backend/src/entities/prelude.rs

@@ -10,7 +10,7 @@ pub struct Model {
     #[sea_orm(primary_key, auto_increment = false)]
     pub id: String,
     pub message: String,
-    pub user_id: i32,
+    pub user_id: String,
 }
 
 #[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]

apps/backend/src/entities/queued_notification.rs

@@ -24,8 +24,8 @@ pub struct Model {
     pub rating: Option<Decimal>,
     pub text: Option<String>,
     pub visibility: Visibility,
-    pub spoiler: bool,
-    pub user_id: i32,
+    pub is_spoiler: bool,
+    pub user_id: String,
     pub metadata_id: Option<String>,
     pub person_id: Option<String>,
     pub metadata_group_id: Option<String>,

apps/backend/src/entities/review.rs

@@ -30,7 +30,7 @@ pub struct Model {
     pub progress: Decimal,
     pub started_on: Option<NaiveDate>,
     pub finished_on: Option<NaiveDate>,
-    pub user_id: i32,
+    pub user_id: String,
     pub metadata_id: String,
     pub state: SeenState,
     pub provider_watched_on: Option<String>,