Class Videos

packages/web-backend/src/Videos/index.ts:97–673

>;

export class Videos extends Effect.Service<Videos>()("Videos", {
	effect: Effect.gen(function* () {
		const db = yield* Database;
		const repo = yield* VideosRepo;
		const policy = yield* VideosPolicy;
		const storage = yield* StorageService;
		const tinybird = yield* Tinybird;

		const getByIdForViewing = (id: Video.VideoId) =>
			repo
				.getById(id)
				.pipe(
					Policy.withPublicPolicy(policy.canView(id)),
					Effect.withSpan("Videos.getById"),
				);

		const getAnalyticsBulkInternal = Effect.fn("Videos.getAnalyticsBulk")(
			function* (videoIds: ReadonlyArray<Video.VideoId>) {
				if (videoIds.length === 0)
					return [] as Array<Exit.Exit<{ count: number }, unknown>>;

				const now = new Date();
				const from = new Date(
					now.getTime() - DEFAULT_ANALYTICS_RANGE_DAYS * 24 * 60 * 60 * 1000,
				);

				const videoExits = yield* Effect.forEach(
					videoIds,
					(videoId) =>
						getByIdForViewing(videoId).pipe(
							Effect.map((video) => video),
							Effect.exit,
						),
					{ concurrency: 10 },
				);

				const successfulVideos: Array<{
					index: number;
					videoId: Video.VideoId;
					video: Video.Video;
				}> = [];

				for (let index = 0; index < videoExits.length; index++) {
					const exit = videoExits[index];
					if (!exit) continue;
					if (Exit.isSuccess(exit)) {
						const maybeVideo = exit.value;
						if (Option.isSome(maybeVideo)) {
							const [video] = maybeVideo.value;
							successfulVideos.push({
								index,
								videoId: videoIds[index] ?? "",
								video,
							});
						}
					}
				}