remove old log and finish metrics for scrapePart

Co-authored-by: William Oldham <github@binaryoverload.co.uk>

src/backend/helpers/report.ts

@@ -1,8 +1,10 @@
+import { ScrapeMedia } from "@movie-web/providers";
 import { ofetch } from "ofetch";
 import { useCallback } from "react";
 
-import { useBackendUrl } from "@/hooks/auth/useBackendUrl";
-import { ScrapingSegment } from "@/hooks/useProviderScrape";
+import { ScrapingItems, ScrapingSegment } from "@/hooks/useProviderScrape";
+
+const metricsEndpoint = "https://backend.movie-web.app/metrics/providers";
 
 export type ProviderMetric = {
   tmdbId: string;
@@ -15,37 +17,93 @@ export type ProviderMetric = {
   embedId?: string;
   errorMessage?: string;
   fullError?: string;
+  hostname?: string;
 };
 
-export async function reportProviders(
-  url: string,
-  items: ProviderMetric[]
-): Promise<void> {
-  return ofetch("/metrics/providers", {
+export async function reportProviders(items: ProviderMetric[]): Promise<void> {
+  return ofetch(metricsEndpoint, {
     method: "POST",
     body: {
-      items,
+      items: items.map((v) => ({
+        ...v,
+        hostname: window.location.hostname,
+      })),
     },
-    baseURL: url,
   });
 }
 
-export function scrapSegmentToProviderMetric(
-  _segment: ScrapingSegment
-): ProviderMetric {
-  // TODO actually convert this
-  return {} as any;
+const segmentStatusMap: Record<
+  ScrapingSegment["status"],
+  ProviderMetric["status"] | null
+> = {
+  success: "success",
+  notfound: "notfound",
+  failure: "failed",
+  pending: null,
+  waiting: null,
+};
+
+export function scrapeSegmentToProviderMetric(
+  media: ScrapeMedia,
+  providerId: string,
+  segment: ScrapingSegment
+): ProviderMetric | null {
+  const status = segmentStatusMap[segment.status];
+  if (!status) return null;
+  let episodeId: string | undefined;
+  let seasonId: string | undefined;
+  if (media.type === "show") {
+    episodeId = media.episode.tmdbId;
+    seasonId = media.season.tmdbId;
+  }
+  let error: undefined | Error;
+  if (segment.error instanceof Error) error = segment.error;
+
+  return {
+    status,
+    providerId,
+    title: media.title,
+    tmdbId: media.tmdbId,
+    type: media.type,
+    embedId: segment.embedId,
+    episodeId,
+    seasonId,
+    errorMessage: segment.reason ?? error?.message,
+    fullError: error
+      ? `${error.toString()}\n\n${error.stack ?? ""}`
+      : undefined,
+  };
+}
+
+export function scrapePartsToProviderMetric(
+  media: ScrapeMedia,
+  order: ScrapingItems[],
+  sources: Record<string, ScrapingSegment>
+): ProviderMetric[] {
+  const output: ProviderMetric[] = [];
+
+  order.forEach((orderItem) => {
+    const source = sources[orderItem.id];
+    orderItem.children.forEach((embedId) => {
+      const embed = sources[embedId];
+      if (!embed.embedId) return;
+      const metric = scrapeSegmentToProviderMetric(media, source.id, embed);
+      if (!metric) return;
+      output.push(metric);
+    });
+
+    const metric = scrapeSegmentToProviderMetric(media, source.id, source);
+    if (!metric) return;
+    output.push(metric);
+  });
+
+  return output;
 }
 
 export function useReportProviders() {
-  const url = useBackendUrl();
-  // TODO constant url
-  const report = useCallback(
-    (items: ProviderMetric[]) => {
-      reportProviders(url, items);
-    },
-    [url]
-  );
+  const report = useCallback((items: ProviderMetric[]) => {
+    reportProviders(items);
+  }, []);
 
   return { report };
 }

src/hooks/useProviderScrape.tsx

@@ -11,6 +11,7 @@ export interface ScrapingItems {
 export interface ScrapingSegment {
   name: string;
   id: string;
+  embedId?: string;
   status: "failure" | "pending" | "notfound" | "success" | "waiting";
   reason?: string;
   error?: unknown;
@@ -73,6 +74,7 @@ export function useScrape() {
                 const source = providers.getMetadata(v.embedScraperId);
                 if (!source) throw new Error("invalid source id");
                 const out: ScrapingSegment = {
+                  embedId: v.embedScraperId,
                   name: source.name,
                   id: v.id,
                   status: "waiting",

src/pages/parts/player/ScrapingPart.tsx

@@ -4,7 +4,7 @@ import { useEffect, useRef } from "react";
 import type { AsyncReturnType } from "type-fest";
 
 import {
-  scrapSegmentToProviderMetric,
+  scrapePartsToProviderMetric,
   useReportProviders,
 } from "@/backend/helpers/report";
 import { usePlayer } from "@/components/player/hooks/usePlayer";
@@ -64,8 +64,10 @@ export function ScrapingPart(props: ScrapingProps) {
         resultRef.current.sourceOrder
       );
       report(
-        Object.values(resultRef.current.sources).map((v) =>
-          scrapSegmentToProviderMetric(v)
+        scrapePartsToProviderMetric(
+          props.media,
+          resultRef.current.sourceOrder,
+          resultRef.current.sources
         )
       );
       props.onGetStream?.(output);

src/stores/__old/watched/migrations/v4.ts

@@ -73,6 +73,5 @@ export function migrateV4Videos(old: WatchedStoreData) {
     }
   }
 
-  console.log(newItems);
   return newItems;
 }