Move websocket to top level events

This commit is contained in:
Nicolas Mowen 2024-02-26 13:47:16 -07:00
parent 44fa0805f0
commit aa12244425
3 changed files with 67 additions and 22 deletions

View File

@ -1,3 +1,4 @@
import { useFrigateEvents } from "@/api/ws";
import useApiFilter from "@/hooks/use-api-filter"; import useApiFilter from "@/hooks/use-api-filter";
import useOverlayState from "@/hooks/use-overlay-state"; import useOverlayState from "@/hooks/use-overlay-state";
import { ReviewFilter, ReviewSegment } from "@/types/review"; import { ReviewFilter, ReviewSegment } from "@/types/review";
@ -5,7 +6,7 @@ import DesktopEventView from "@/views/events/DesktopEventView";
import DesktopRecordingView from "@/views/events/DesktopRecordingView"; import DesktopRecordingView from "@/views/events/DesktopRecordingView";
import MobileEventView from "@/views/events/MobileEventView"; import MobileEventView from "@/views/events/MobileEventView";
import axios from "axios"; import axios from "axios";
import { useCallback, useMemo } from "react"; import { useCallback, useEffect, useMemo, useState } from "react";
import { isMobile } from "react-device-detect"; import { isMobile } from "react-device-detect";
import useSWR from "swr"; import useSWR from "swr";
import useSWRInfinite from "swr/infinite"; import useSWRInfinite from "swr/infinite";
@ -183,6 +184,25 @@ export default function Events() {
}; };
}, [selectedReviewId, reviewPages]); }, [selectedReviewId, reviewPages]);
// review updates
const { payload: eventUpdate } = useFrigateEvents();
const [hasUpdate, setHasUpdate] = useState(false);
useEffect(() => {
if (!eventUpdate) {
return;
}
// if event is ended and was saved, update events list
if (
eventUpdate.type == "end" &&
(eventUpdate.after.has_clip || eventUpdate.after.has_snapshot)
) {
setHasUpdate(true);
return;
}
}, [eventUpdate]);
if (selectedData) { if (selectedData) {
return ( return (
<DesktopRecordingView <DesktopRecordingView
@ -199,8 +219,11 @@ export default function Events() {
relevantPreviews={allPreviews} relevantPreviews={allPreviews}
reachedEnd={isDone} reachedEnd={isDone}
isValidating={isValidating} isValidating={isValidating}
hasUpdate={hasUpdate}
setHasUpdate={setHasUpdate}
loadNextPage={onLoadNextPage} loadNextPage={onLoadNextPage}
markItemAsReviewed={markItemAsReviewed} markItemAsReviewed={markItemAsReviewed}
pullLatestData={updateSegments}
/> />
); );
} }
@ -213,6 +236,8 @@ export default function Events() {
reachedEnd={isDone} reachedEnd={isDone}
isValidating={isValidating} isValidating={isValidating}
filter={reviewFilter} filter={reviewFilter}
hasUpdate={hasUpdate}
setHasUpdate={setHasUpdate}
loadNextPage={onLoadNextPage} loadNextPage={onLoadNextPage}
markItemAsReviewed={markItemAsReviewed} markItemAsReviewed={markItemAsReviewed}
onSelectReview={setSelectedReviewId} onSelectReview={setSelectedReviewId}

View File

@ -1,4 +1,3 @@
import { useFrigateEvents } from "@/api/ws";
import ReviewFilterGroup from "@/components/filter/ReviewFilterGroup"; import ReviewFilterGroup from "@/components/filter/ReviewFilterGroup";
import PreviewThumbnailPlayer from "@/components/player/PreviewThumbnailPlayer"; import PreviewThumbnailPlayer from "@/components/player/PreviewThumbnailPlayer";
import EventReviewTimeline from "@/components/timeline/EventReviewTimeline"; import EventReviewTimeline from "@/components/timeline/EventReviewTimeline";
@ -19,6 +18,8 @@ type DesktopEventViewProps = {
reachedEnd: boolean; reachedEnd: boolean;
isValidating: boolean; isValidating: boolean;
filter?: ReviewFilter; filter?: ReviewFilter;
hasUpdate: boolean;
setHasUpdate: (hasUpdated: boolean) => void;
loadNextPage: () => void; loadNextPage: () => void;
markItemAsReviewed: (reviewId: string) => void; markItemAsReviewed: (reviewId: string) => void;
onSelectReview: (reviewId: string) => void; onSelectReview: (reviewId: string) => void;
@ -32,6 +33,8 @@ export default function DesktopEventView({
reachedEnd, reachedEnd,
isValidating, isValidating,
filter, filter,
hasUpdate,
setHasUpdate,
loadNextPage, loadNextPage,
markItemAsReviewed, markItemAsReviewed,
onSelectReview, onSelectReview,
@ -177,25 +180,6 @@ export default function DesktopEventView({
return data; return data;
}, [minimap]); }, [minimap]);
// new data alert
const { payload: eventUpdate } = useFrigateEvents();
const [hasUpdate, setHasUpdate] = useState(false);
useEffect(() => {
if (!eventUpdate) {
return;
}
// if event is ended and was saved, update events list
if (
eventUpdate.type == "end" &&
(eventUpdate.after.has_clip || eventUpdate.after.has_snapshot)
) {
setHasUpdate(true);
return;
}
}, [eventUpdate]);
if (!config) { if (!config) {
return <ActivityIndicator />; return <ActivityIndicator />;
} }
@ -305,7 +289,7 @@ export default function DesktopEventView({
review={value} review={value}
relevantPreview={relevantPreview} relevantPreview={relevantPreview}
setReviewed={markItemAsReviewed} setReviewed={markItemAsReviewed}
onClick={onSelectReview(value.id} onClick={onSelectReview}
/> />
</div> </div>
{lastRow && !reachedEnd && <ActivityIndicator />} {lastRow && !reachedEnd && <ActivityIndicator />}

View File

@ -1,9 +1,11 @@
import PreviewThumbnailPlayer from "@/components/player/PreviewThumbnailPlayer"; import PreviewThumbnailPlayer from "@/components/player/PreviewThumbnailPlayer";
import ActivityIndicator from "@/components/ui/activity-indicator"; import ActivityIndicator from "@/components/ui/activity-indicator";
import { Button } from "@/components/ui/button";
import { ToggleGroup, ToggleGroupItem } from "@/components/ui/toggle-group"; import { ToggleGroup, ToggleGroupItem } from "@/components/ui/toggle-group";
import { FrigateConfig } from "@/types/frigateConfig"; import { FrigateConfig } from "@/types/frigateConfig";
import { ReviewSegment, ReviewSeverity } from "@/types/review"; import { ReviewSegment, ReviewSeverity } from "@/types/review";
import { useCallback, useEffect, useMemo, useRef, useState } from "react"; import { useCallback, useEffect, useMemo, useRef, useState } from "react";
import { LuRefreshCcw } from "react-icons/lu";
import { MdCircle } from "react-icons/md"; import { MdCircle } from "react-icons/md";
import useSWR from "swr"; import useSWR from "swr";
@ -12,16 +14,22 @@ type MobileEventViewProps = {
relevantPreviews?: Preview[]; relevantPreviews?: Preview[];
reachedEnd: boolean; reachedEnd: boolean;
isValidating: boolean; isValidating: boolean;
hasUpdate: boolean;
setHasUpdate: (hasUpdated: boolean) => void;
loadNextPage: () => void; loadNextPage: () => void;
markItemAsReviewed: (reviewId: string) => void; markItemAsReviewed: (reviewId: string) => void;
pullLatestData: () => void;
}; };
export default function MobileEventView({ export default function MobileEventView({
reviewPages, reviewPages,
relevantPreviews, relevantPreviews,
reachedEnd, reachedEnd,
isValidating, isValidating,
hasUpdate,
setHasUpdate,
loadNextPage, loadNextPage,
markItemAsReviewed, markItemAsReviewed,
pullLatestData,
}: MobileEventViewProps) { }: MobileEventViewProps) {
const { data: config } = useSWR<FrigateConfig>("config"); const { data: config } = useSWR<FrigateConfig>("config");
const [severity, setSeverity] = useState<ReviewSeverity>("alert"); const [severity, setSeverity] = useState<ReviewSeverity>("alert");
@ -198,6 +206,34 @@ export default function MobileEventView({
</ToggleGroupItem> </ToggleGroupItem>
</ToggleGroup> </ToggleGroup>
{hasUpdate && (
<div className="absolute w-full z-30">
<div className="flex justify-center items-center">
<Button
className={`${
hasUpdate
? "animate-in slide-in-from-top duration-500"
: "invisible"
} text-center mt-5 mx-auto bg-gray-400 text-white`}
variant="secondary"
onClick={() => {
setHasUpdate(false);
pullLatestData();
if (contentRef.current) {
contentRef.current.scrollTo({
top: 0,
behavior: "smooth",
});
}
}}
>
<LuRefreshCcw className="w-4 h-4 mr-2" />
New Items To Review
</Button>
</div>
</div>
)}
<div <div
ref={contentRef} ref={contentRef}
className="w-full h-full grid grid-cols-1 sm:grid-cols-2 mt-2 gap-2 overflow-y-auto" className="w-full h-full grid grid-cols-1 sm:grid-cols-2 mt-2 gap-2 overflow-y-auto"