typesense-päivitysnappula admin-näkymään

Author: ArttKan

backend/src/app.ts

@@ -10,6 +10,7 @@ import { getLatestStatusEntry, getAllStatusEntries, clearAllStatusEntries } from
 import { addStatusRow, createTables, dropTables } from './db/db.js';
 import { yearFrom, yearTo } from './util/config.js';
 import { getRecentLogs, pushLog } from './util/logBuffer.js';
+import { deleteCollection, syncStatutes, syncJudgments } from './search.js';
 
 const app = express()
 const __filename = fileURLToPath(import.meta.url);
@@ -164,6 +165,54 @@ app.delete('/api/delete-database', async (req: express.Request, res: express.Res
   }
 });
 
+app.post('/api/rebuild-typesense', async (req: express.Request, res: express.Response): Promise<void> => {
+  try {
+    res.status(200).json({ status: 'started', message: 'Typesense rebuild started in background' });
+    setImmediate(async () => {
+      try {
+        console.info('Typesense rebuild started');
+        await addStatusRow({ action: 'typesense_rebuild_start', startedAt: new Date().toISOString() }, true);
+
+        // Delete and recreate collections for both languages
+        await deleteCollection('statutes', 'fin');
+        await deleteCollection('statutes', 'swe');
+        await deleteCollection('judgments', 'fin');
+        await deleteCollection('judgments', 'swe');
+        console.log('Old Typesense collections deleted');
+
+        // Rebuild indexes from database
+        await syncStatutes('fin');
+        await syncStatutes('swe');
+        await syncJudgments('fin');
+        await syncJudgments('swe');
+        console.log('Typesense collections rebuilt');
+
+        await addStatusRow({ action: 'typesense_rebuild_complete', completedAt: new Date().toISOString() }, false);
+        console.info('Typesense rebuild completed');
+      } catch (error) {
+        console.error('[REBUILD] Typesense rebuild failed with error:', error);
+        const errorMessage = error instanceof Error ? error.message : String(error);
+        try {
+          await addStatusRow(
+            { 
+              message: 'typesense_rebuild_failed', 
+              error: errorMessage,
+              timestamp: new Date().toISOString()
+            }, 
+            false
+          );
+          console.log('[REBUILD] Wrote error status to database');
+        } catch (dbError) {
+          console.error('[REBUILD] Failed to write error status to database:', dbError);
+        }
+      }
+    });
+  } catch (error) {
+    console.error('[REBUILD] Rebuild endpoint error:', error);
+    res.status(500).json({ error: 'Failed to start typesense rebuild' });
+  }
+});
+
 app.get('/favicon.ico', (request: express.Request, response: express.Response): void => {
   response.status(204).end();
 })

frontend/src/components/AdminPage.tsx

@@ -15,11 +15,13 @@ interface StatusEntry {
 const AdminPage = ({ language }: AdminPageProps) => {
   const [isUpdating, setIsUpdating] = useState(false)
   const [isClearing, setIsClearing] = useState(false)
+  const [isRebuilding, setIsRebuilding] = useState(false)
   const [message, setMessage] = useState('')
   const [error, setError] = useState('')
   const [latestStatus, setLatestStatus] = useState<StatusEntry | null>(null)
   const [hasStartedUpdate, setHasStartedUpdate] = useState(false)
   const [startYearInput, setStartYearInput] = useState<string>('')
+  const [hasStartedRebuild, setHasStartedRebuild] = useState(false)
   const intervalRef = useRef<NodeJS.Timeout | null>(null)
   const [defaultStartYear, setDefaultStartYear] = useState<number | null>(null)
 
@@ -129,11 +131,41 @@ const AdminPage = ({ language }: AdminPageProps) => {
     }
   }
 
+  const handleRebuildTypesense = async () => {
+    setIsRebuilding(true)
+    setMessage('')
+    setError('')
+    setLatestStatus(null)
+    setHasStartedRebuild(true)
+
+    try {
+      const response = await axios.post('/api/rebuild-typesense')
+      setMessage(language === 'fin'
+        ? 'Typesense-indeksien uudelleenrakentaminen aloitettu!'
+        : 'Typesense-indexombyggnad startad!'
+      )
+      console.log('Rebuild response:', response.data)
+
+      // Start polling for status updates
+      startPolling()
+
+    } catch (err) {
+      console.error('Rebuild failed:', err)
+      setError(language === 'fin'
+        ? 'Indeksien uudelleenrakentaminen epäonnistui. Tarkista konsoli lisätiedoille.'
+        : 'Ombyggnad av index misslyckades. Kontrollera konsolen för mer information.'
+      )
+      setIsRebuilding(false)
+    }
+  }
+
   // Stop polling and updating state when updating becomes false (only if we started an update)
   useEffect(() => {
-    if (latestStatus && hasStartedUpdate && !latestStatus.updating) {
+    if (latestStatus && (hasStartedUpdate || hasStartedRebuild) && !latestStatus.updating) {
       setIsUpdating(false)
+      setIsRebuilding(false)
       setHasStartedUpdate(false)
+      setHasStartedRebuild(false)
       stopPolling()
 
       // Check the action to determine success or failure
@@ -148,15 +180,25 @@ const AdminPage = ({ language }: AdminPageProps) => {
           ? 'Päivitys epäonnistui.'
           : 'Uppdatering misslyckades.'
         )
+      } else if (action === 'typesense_rebuild_complete') {
+        setMessage(language === 'fin'
+          ? 'Indeksien uudelleenrakentaminen valmistui onnistuneesti!'
+          : 'Ombyggnad av indexen slutfördes framgångsrikt!'
+        )
+      } else if (action === 'typesense_rebuild_failed') {
+        setError(language === 'fin'
+          ? 'Indeksien uudelleenrakentaminen epäonnistui.'
+          : 'Ombyggnad av indexen misslyckades.'
+        )
       } else {
         // Generic completion message if no specific action
         setMessage(language === 'fin'
-          ? 'Päivitys valmistui!'
-          : 'Uppdatering slutförd!'
+          ? 'Operaatio valmistui!'
+          : 'Operationen slutfördes!'
         )
       }
     }
-  }, [latestStatus, hasStartedUpdate, language])
+  }, [latestStatus, hasStartedUpdate, hasStartedRebuild, language])
 
   const containerStyle: React.CSSProperties = {
     display: 'flex',
@@ -191,6 +233,18 @@ const AdminPage = ({ language }: AdminPageProps) => {
     margin: '0 10px 20px 10px'
   }
 
+  const rebuildButtonStyle: React.CSSProperties = {
+    backgroundColor: '#FFA500',
+    color: 'white',
+    border: 'none',
+    padding: '12px 24px',
+    fontSize: '16px',
+    borderRadius: '4px',
+    cursor: (isUpdating || isRebuilding) ? 'not-allowed' : 'pointer',
+    opacity: (isUpdating || isRebuilding) ? 0.6 : 1,
+    margin: '0 10px 20px 10px'
+  }
+
   const messageStyle: React.CSSProperties = {
     padding: '10px',
     borderRadius: '4px',
@@ -248,7 +302,7 @@ const AdminPage = ({ language }: AdminPageProps) => {
 
       <div style={{ marginTop: '50px' }}>
         <div style={containerStyle}>
-          <h2>{language === 'fin' ? 'Järjestelmän ylläpito' : 'Systemunderhåll'}</h2>
+          <h2>{language === 'fin' ? 'Järjestelmän jee ylläpito' : 'Systemunderhåll'}</h2>
 
           <p style={{ textAlign: 'center', marginBottom: '30px', color: '#666' }}>
             {language === 'fin'
@@ -290,6 +344,17 @@ const AdminPage = ({ language }: AdminPageProps) => {
                 : (language === 'fin' ? 'Tyhjennä tilat' : 'Rensa status')
               }
             </button>
+
+            <button
+              style={rebuildButtonStyle}
+              onClick={handleRebuildTypesense}
+              disabled={isUpdating || isRebuilding}
+            >
+              {isRebuilding
+                ? (language === 'fin' ? 'Rakennetaan uudelleen...' : 'Bygger om...')
+                : (language === 'fin' ? 'Uudelleen rakenna Typesense' : 'Bygga om Typesense')
+              }
+            </button>
           </div>
 
           {message && (