mirror of
https://github.com/ngthanhvu/kr-phim.git
synced 2026-08-10 18:07:47 +00:00
ngthanhvu
d982449464
- Implemented AuthModal.vue for user login and registration with form handling. - Created useAuth composable for managing user state and authentication requests. - Added admin route middleware to protect admin routes. - Developed admin login page with authentication checks. - Implemented API endpoints for user management (login, logout, fetch user, register). - Created database migrations for users table and updated movies table. - Added utility functions for password hashing and JWT token management.
107 lines
3.2 KiB
TypeScript
107 lines
3.2 KiB
TypeScript
import { movies } from '../../database/schema'
|
|
import { eq, and } from 'drizzle-orm'
|
|
import { getOphimKoreanMovies, getNguoncKoreanMovies, getKkphimKoreanMovies } from '../../utils/movies'
|
|
|
|
const SYNC_PAGES = 10
|
|
const ALL_SOURCES = ['ophim', 'nguonc', 'kkphim'] as const
|
|
|
|
export default defineEventHandler(async (event) => {
|
|
const db = useDb()
|
|
const body = await readBody(event).catch(() => ({})) || {}
|
|
const requestedSources = Array.isArray(body.sources) ? body.sources : ALL_SOURCES
|
|
const sources = requestedSources.filter((s: string) => ALL_SOURCES.includes(s as any))
|
|
|
|
if (!sources.length) {
|
|
throw createError({ statusCode: 400, message: 'Nguồn không hợp lệ' })
|
|
}
|
|
|
|
const allMovies: any[] = []
|
|
const fetchers: Record<string, (page: number) => Promise<any>> = {
|
|
ophim: getOphimKoreanMovies,
|
|
nguonc: getNguoncKoreanMovies,
|
|
kkphim: getKkphimKoreanMovies,
|
|
}
|
|
|
|
for (const sourceName of sources) {
|
|
const fetcher = fetchers[sourceName]
|
|
if (!fetcher) continue
|
|
for (let page = 1; page <= SYNC_PAGES; page++) {
|
|
try {
|
|
const result = await fetcher(page)
|
|
for (const movie of result.items) {
|
|
allMovies.push({ ...movie, source: sourceName })
|
|
}
|
|
if (!result.items.length) break
|
|
} catch {
|
|
break
|
|
}
|
|
}
|
|
}
|
|
|
|
let created = 0
|
|
let updated = 0
|
|
|
|
for (const movie of allMovies) {
|
|
const existing = await db
|
|
.select()
|
|
.from(movies)
|
|
.where(and(eq(movies.source, movie.source), eq(movies.slug, movie.slug)))
|
|
.limit(1)
|
|
|
|
if (existing.length) {
|
|
await db
|
|
.update(movies)
|
|
.set({
|
|
name: movie.name,
|
|
originName: movie.originName || null,
|
|
thumb: movie.thumb || null,
|
|
poster: movie.poster || null,
|
|
year: movie.year || null,
|
|
time: movie.time || null,
|
|
episode: movie.episode || null,
|
|
quality: movie.quality || null,
|
|
lang: movie.lang || null,
|
|
type: movie.type || null,
|
|
rating: movie.rating || null,
|
|
categories: movie.categories || null,
|
|
countries: movie.countries || null,
|
|
sources: movie.sources || null,
|
|
apiUpdatedAt: movie.updatedAt ? new Date(movie.updatedAt) : null,
|
|
syncedAt: new Date(),
|
|
})
|
|
.where(eq(movies.id, existing[0].id))
|
|
updated++
|
|
} else {
|
|
await db.insert(movies).values({
|
|
source: movie.source,
|
|
slug: movie.slug,
|
|
name: movie.name,
|
|
originName: movie.originName || null,
|
|
thumb: movie.thumb || null,
|
|
poster: movie.poster || null,
|
|
year: movie.year || null,
|
|
time: movie.time || null,
|
|
episode: movie.episode || null,
|
|
quality: movie.quality || null,
|
|
lang: movie.lang || null,
|
|
type: movie.type || null,
|
|
rating: movie.rating || null,
|
|
categories: movie.categories || null,
|
|
countries: movie.countries || null,
|
|
sources: movie.sources || null,
|
|
apiUpdatedAt: movie.updatedAt ? new Date(movie.updatedAt) : null,
|
|
active: false,
|
|
})
|
|
created++
|
|
}
|
|
}
|
|
|
|
return {
|
|
success: true,
|
|
sources,
|
|
total: allMovies.length,
|
|
created,
|
|
updated,
|
|
}
|
|
})
|