feat: api for episode colleciton (#836)

drizzle/orm.ts

@@ -10,6 +10,7 @@ export type ISubject = typeof schema.chiiSubjects.$inferSelect;
 export type ISubjectFields = typeof schema.chiiSubjectFields.$inferSelect;
 export type ISubjectInterest = typeof schema.chiiSubjectInterests.$inferSelect;
 export type ISubjectRelation = typeof schema.chiiSubjectRelations.$inferSelect;
+export type ISubjectEpStatus = typeof schema.chiiEpStatus.$inferSelect;
 
 export type IEpisode = typeof schema.chiiEpisodes.$inferSelect;
 

drizzle/schema.ts

@@ -222,16 +222,17 @@ export const chiiEpRevisions = mysqlTable(
 export const chiiEpStatus = mysqlTable(
   'chii_ep_status',
   {
-    epSttId: mediumint('ep_stt_id').autoincrement().notNull(),
-    epSttUid: mediumint('ep_stt_uid').notNull(),
-    epSttSid: mediumint('ep_stt_sid').notNull(),
-    epSttOnPrg: tinyint('ep_stt_on_prg').default(0).notNull(),
-    epSttStatus: mediumtext('ep_stt_status').notNull(),
+    id: mediumint('ep_stt_id').autoincrement().notNull(),
+    uid: mediumint('ep_stt_uid').notNull(),
+    sid: mediumint('ep_stt_sid').notNull(),
+    // 未使用
+    // onProgress: tinyint('ep_stt_on_prg').default(0).notNull(),
+    status: mediumtext('ep_stt_status').notNull(),
     updatedAt: int('ep_stt_lasttouch').notNull(),
   },
   (table) => {
     return {
-      epSttUniq: unique('ep_stt_uniq').on(table.epSttUid, table.epSttSid),
+      epSttUniq: unique('ep_stt_uniq').on(table.uid, table.sid),
     };
   },
 );

lib/subject/type.ts

@@ -19,6 +19,18 @@ export enum CollectionType {
 export const CollectionTypeValues = new Set([1, 2, 3, 4, 5]);
 export const CollectionTypeProfileValues = new Set([1, 2]);
 
+export enum EpisodeCollectionStatus {
+  None = 0, // 撤消/删除
+  Wish = 1, // 想看
+  Done = 2, // 看过
+  Dropped = 3, // 抛弃
+}
+
+export interface UserEpisodeCollection {
+  id: number;
+  type: EpisodeCollectionStatus;
+}
+
 export enum PersonType {
   Character = 'crt',
   Person = 'prsn',

lib/types/convert.ts

@@ -5,7 +5,7 @@ import * as php from '@trim21/php-serialize';
 import type * as orm from '@app/drizzle/orm.ts';
 import type * as ormold from '@app/lib/orm/index.ts';
 import { avatar, personImages, subjectCover } from '@app/lib/response.ts';
-import { CollectionType } from '@app/lib/subject/type';
+import { CollectionType, type UserEpisodeCollection } from '@app/lib/subject/type';
 import type * as res from '@app/lib/types/res.ts';
 import {
   findSubjectPlatform,
@@ -168,6 +168,7 @@ function toSubjectRating(fields: orm.ISubjectFields): res.ISubjectRating {
   const total = ratingCount.reduce((a, b) => a + b, 0);
   const totalScore = ratingCount.reduce((a, b, i) => a + b * (i + 1), 0);
   const rating = {
+    rank: fields.fieldRank,
     total: total,
     score: total === 0 ? 0 : Math.round((totalScore * 100) / total) / 100,
     count: ratingCount,
@@ -259,6 +260,24 @@ export function toEpisode(episode: orm.IEpisode): res.IEpisode {
   };
 }
 
+export function toSubjectEpStatus(
+  status: orm.ISubjectEpStatus,
+): Record<number, UserEpisodeCollection> {
+  const result: Record<number, UserEpisodeCollection> = {};
+  if (!status.status) {
+    return result;
+  }
+  const epStatusList = php.parse(status.status) as Record<number, { eid: string; type: number }>;
+  for (const [eid, x] of Object.entries(epStatusList)) {
+    const episodeId = Number.parseInt(eid);
+    if (Number.isNaN(episodeId)) {
+      continue;
+    }
+    result[episodeId] = { id: episodeId, type: x.type };
+  }
+  return result;
+}
+
 export function toSlimCharacter(character: orm.ICharacter): res.ISlimCharacter {
   return {
     id: character.id,

lib/types/fetcher.ts

@@ -1,5 +1,6 @@
 import { db, op } from '@app/drizzle/db.ts';
 import * as schema from '@app/drizzle/schema';
+import type { UserEpisodeCollection } from '@app/lib/subject/type.ts';
 
 import * as convert from './convert.ts';
 import type * as res from './res.ts';
@@ -83,6 +84,23 @@ export async function fetchSubjectsByIDs(
   return map;
 }
 
+export async function fetchSubjectEpStatus(
+  userID: number,
+  subjectID: number,
+): Promise<Record<number, UserEpisodeCollection> | null> {
+  const data = await db
+    .select()
+    .from(schema.chiiEpStatus)
+    .where(
+      op.and(op.eq(schema.chiiEpStatus.uid, userID), op.eq(schema.chiiEpStatus.sid, subjectID)),
+    )
+    .execute();
+  for (const d of data) {
+    return convert.toSubjectEpStatus(d);
+  }
+  return null;
+}
+
 export async function fetchSlimCharacterByID(
   id: number,
   allowNsfw = false,

lib/types/res.ts

@@ -132,6 +132,7 @@ export const SubjectPlatform = t.Object(
 export type ISubjectRating = Static<typeof SubjectRating>;
 export const SubjectRating = t.Object(
   {
+    rank: t.Integer(),
     count: t.Array(t.Integer()),
     score: t.Number(),
     total: t.Integer(),