search: working on refactoring to also support tasks

Author: williamstein

src/packages/frontend/frame-editors/chat-editor/actions.ts

@@ -23,6 +23,7 @@ import { redux_name } from "@cocalc/frontend/app-framework";
 import { aux_file } from "@cocalc/util/misc";
 import type { FragmentId } from "@cocalc/frontend/misc/fragment-id";
 import { delay } from "awaiting";
+import { getSearchData } from "@cocalc/frontend/chat/filter-messages";
 
 const FRAME_TYPE = "chatroom";
 
@@ -157,4 +158,12 @@ export class Actions extends CodeEditorActions<ChatEditorState> {
       await delay(d);
     }
   }
+
+  getSearchData = () => {
+    const messages = this.store?.get("messages");
+    if (messages == null) {
+      return {};
+    }
+    return getSearchData({ messages, threads: false });
+  };
 }

src/packages/frontend/frame-editors/chat-editor/use-search-index.ts

@@ -1,17 +1,27 @@
 import { useFrameContext } from "@cocalc/frontend/frame-editors/frame-tree/frame-context";
-import { useEffect, useState } from "react";
+import { useEffect, useRef, useState } from "react";
 import { create, search, insertMultiple } from "@orama/orama";
-import { getSearchData } from "@cocalc/frontend/chat/filter-messages";
 import useCounter from "@cocalc/frontend/app-framework/counter-hook";
 
 export default function useSearchIndex() {
   const { actions, project_id, path } = useFrameContext();
+  const contextRef = useRef<{ project_id: string; path: string }>({
+    project_id,
+    path,
+  });
   const [index, setIndex] = useState<null | SearchIndex>(null);
   const [error, setError] = useState<string>("");
   const { val: refresh, inc: doRefresh } = useCounter();
   const [indexTime, setIndexTime] = useState<number>(0);
 
   useEffect(() => {
+    if (
+      contextRef.current.project_id != project_id ||
+      contextRef.current.path != path
+    ) {
+      contextRef.current = { project_id, path };
+      setIndex(null);
+    }
     (async () => {
       try {
         setError("");
@@ -57,19 +67,17 @@ class SearchIndex {
       },
     });
 
-    const messages = this.actions.store?.get("messages");
-    if (messages == null) {
-      return;
-    }
-    const searchData = getSearchData({ messages, threads: false });
-    const docs: { time: number; message: string }[] = [];
-    for (const time in searchData) {
-      docs.push({
-        time: parseInt(time),
-        message: searchData[time]?.content ?? "",
-      });
+    const searchData = this.actions.getSearchData();
+    if (searchData != null) {
+      const docs: { time: number; message: string }[] = [];
+      for (const time in searchData) {
+        docs.push({
+          time: parseInt(time),
+          message: searchData[time]?.content ?? "",
+        });
+      }
+      await insertMultiple(this.db, docs);
     }
-    await insertMultiple(this.db, docs);
     this.state = "ready";
   };
 }