tg-live-game-web/src/api/stream.ts

/**
 * 视频流管理 API（通过后端代理）
 *
 * 推荐使用这个封装，通过后端代理调用 Cloudflare API
 * 避免在前端暴露 API Token
 */

import { get, post, put, del } from '@/utils/request'
import type { ApiResponse } from '@/types'
import type {
  CloudflareVideo,
  CloudflareLiveInput,
  CreateLiveInputParams,
  CreateUploadUrlParams,
  VideoPlaybackInfo
} from '@/types/cloudflare'

// ==================== 视频管理 ====================

/**
 * 获取视频列表
 */
export function listVideos(params?: {
  pageNum?: number
  pageSize?: number
  search?: string
  status?: string
}): Promise<ApiResponse<{ rows: CloudflareVideo[]; total: number }>> {
  return get('/stream/video/list', params)
}

/**
 * 获取视频详情
 */
export function getVideo(videoId: string): Promise<ApiResponse<CloudflareVideo>> {
  return get(`/stream/video/${videoId}`)
}

/**
 * 删除视频
 */
export function deleteVideo(videoId: string): Promise<ApiResponse<null>> {
  return del(`/stream/video/${videoId}`)
}

/**
 * 从 URL 导入视频
 */
export function importVideoFromUrl(data: {
  url: string
  name?: string
  meta?: Record<string, any>
}): Promise<ApiResponse<CloudflareVideo>> {
  return post('/stream/video/import', data)
}

/**
 * 获取上传 URL
 */
export function getUploadUrl(params?: CreateUploadUrlParams): Promise<ApiResponse<{
  uploadURL: string
  uid: string
}>> {
  return post('/stream/video/upload-url', params)
}

/**
 * 获取视频播放信息
 */
export function getVideoPlayback(videoId: string): Promise<ApiResponse<VideoPlaybackInfo>> {
  return get(`/stream/video/${videoId}/playback`)
}

// ==================== 直播管理 ====================

/**
 * 获取直播输入列表
 */
export function listLiveInputs(params?: {
  pageNum?: number
  pageSize?: number
}): Promise<ApiResponse<{ rows: CloudflareLiveInput[]; total: number }>> {
  return get('/stream/live/list', params)
}

/**
 * 创建直播输入
 */
export function createLiveInput(data?: CreateLiveInputParams): Promise<ApiResponse<CloudflareLiveInput>> {
  return post('/stream/live', data)
}

/**
 * 获取直播输入详情
 */
export function getLiveInput(liveInputId: string): Promise<ApiResponse<CloudflareLiveInput>> {
  return get(`/stream/live/${liveInputId}`)
}

/**
 * 更新直播输入
 */
export function updateLiveInput(liveInputId: string, data: CreateLiveInputParams): Promise<ApiResponse<CloudflareLiveInput>> {
  return put(`/stream/live/${liveInputId}`, data)
}

/**
 * 删除直播输入
 */
export function deleteLiveInput(liveInputId: string): Promise<ApiResponse<null>> {
  return del(`/stream/live/${liveInputId}`)
}

/**
 * 获取直播播放信息
 */
export function getLivePlayback(liveInputId: string): Promise<ApiResponse<VideoPlaybackInfo>> {
  return get(`/stream/live/${liveInputId}/playback`)
}

/**
 * 获取直播录像列表
 */
export function listLiveRecordings(liveInputId: string, params?: {
  pageNum?: number
  pageSize?: number
}): Promise<ApiResponse<{ rows: CloudflareVideo[]; total: number }>> {
  return get(`/stream/live/${liveInputId}/recordings`, params)
}

// ==================== 转推管理 ====================

/**
 * 获取转推输出列表
 */
export function listLiveOutputs(liveInputId: string): Promise<ApiResponse<any[]>> {
  return get(`/stream/live/${liveInputId}/outputs`)
}

/**
 * 创建转推输出
 */
export function createLiveOutput(liveInputId: string, data: {
  url: string
  streamKey: string
  enabled?: boolean
}): Promise<ApiResponse<any>> {
  return post(`/stream/live/${liveInputId}/outputs`, data)
}

/**
 * 删除转推输出
 */
export function deleteLiveOutput(liveInputId: string, outputId: string): Promise<ApiResponse<null>> {
  return del(`/stream/live/${liveInputId}/outputs/${outputId}`)
}