fix(server): hata yönetimini ve dayanıklılığı iyileştir

Loop scheduler ve timer worker için hata yakalama ekle. qBit client'ta
geçici ağ hatalarını tanıyarak login durumunu sıfırla. Scheduler
hatalarında durum güncellemesi gönder ve timer worker crash önle.

apps/server/src/loop/loop.scheduler.ts

@@ -1,7 +1,7 @@
 import { QbitClient } from "../qbit/qbit.client"
 import { tickLoopJobs } from "./loop.engine"
-import { getStatusSnapshot, refreshJobsStatus, setTorrentsStatus } from "../status/status.service"
-import { emitStatusUpdate } from "../realtime/emitter"
+import { getStatusSnapshot, refreshJobsStatus, setQbitStatus, setTorrentsStatus } from "../status/status.service"
+import { emitQbitHealth, emitStatusUpdate } from "../realtime/emitter"
 import { logger } from "../utils/logger"
 
 export const startLoopScheduler = (qbit: QbitClient, intervalMs: number) => {
@@ -20,7 +20,19 @@ export const startLoopScheduler = (qbit: QbitClient, intervalMs: number) => {
         jobs,
       });
     } catch (error) {
+      const message = error instanceof Error ? error.message : "Unknown error";
       logger.error({ error }, "Loop scheduler tick failed");
+      setQbitStatus({ ok: false, lastError: message });
+      emitQbitHealth({ ok: false, lastError: message });
+      try {
+        const current = await getStatusSnapshot();
+        emitStatusUpdate({
+          ...current,
+          qbit: { ...current.qbit, ok: false, lastError: message },
+        });
+      } catch {
+        // Swallow secondary status errors to keep scheduler alive.
+      }
     }
   }, intervalMs);
 };

apps/server/src/qbit/qbit.client.ts

@@ -48,6 +48,18 @@ export class QbitClient {
       }
       return await fn();
     } catch (error) {
+      if (axios.isAxiosError(error)) {
+        const code = error.code ?? "";
+        const transient =
+          code === "EAI_AGAIN" ||
+          code === "ENOTFOUND" ||
+          code === "ECONNREFUSED" ||
+          code === "ECONNRESET" ||
+          code === "ETIMEDOUT";
+        if (transient) {
+          this.loggedIn = false;
+        }
+      }
       if (
         axios.isAxiosError(error) &&
         (error.response?.status === 401 || error.response?.status === 403)

apps/server/src/timer/timer.worker.ts

@@ -4,6 +4,7 @@ import { readDb, writeDb } from "../storage/jsondb";
 import { TimerLog, TimerSummary } from "../types";
 import { emitTimerLog, emitTimerSummary } from "../realtime/emitter";
 import { nowIso } from "../utils/time";
+import { logger } from "../utils/logger";
 
 const MAX_LOGS = 2000;
 
@@ -17,76 +18,80 @@ const normalizeTags = (tags?: string, category?: string) => {
 
 export const startTimerWorker = (qbit: QbitClient, intervalMs: number) => {
   setInterval(async () => {
-    const db = await readDb();
-    const rules = db.timerRules ?? [];
-    if (rules.length === 0) {
-      return;
-    }
-    const torrents = await qbit.getTorrentsInfo();
-    let summary: TimerSummary =
-      db.timerSummary ?? {
-        totalDeleted: 0,
-        totalSeededSeconds: 0,
-        totalUploadedBytes: 0,
-        updatedAt: nowIso(),
-      };
-
-    const logs: TimerLog[] = [];
-
-    for (const torrent of torrents) {
-      const tags = normalizeTags(torrent.tags, torrent.category);
-      const matchingRules = rules.filter((rule) => {
-        return rule.tags.some((tag) => tags.includes(tag.toLowerCase()));
-      });
-      if (matchingRules.length === 0) {
-        continue;
+    try {
+      const db = await readDb();
+      const rules = db.timerRules ?? [];
+      if (rules.length === 0) {
+        return;
       }
-      const matchingRule = matchingRules.reduce((best, current) =>
-        current.seedLimitSeconds < best.seedLimitSeconds ? current : best
-      );
-      const addedOnMs = Number(torrent.added_on ?? 0) * 1000;
-      const elapsedSeconds =
-        addedOnMs > 0
-          ? Math.max(0, (Date.now() - addedOnMs) / 1000)
-          : Number(torrent.seeding_time ?? 0);
-      const seedingSeconds = Number(torrent.seeding_time ?? 0);
-      if (elapsedSeconds < matchingRule.seedLimitSeconds) {
-        continue;
+      const torrents = await qbit.getTorrentsInfo();
+      let summary: TimerSummary =
+        db.timerSummary ?? {
+          totalDeleted: 0,
+          totalSeededSeconds: 0,
+          totalUploadedBytes: 0,
+          updatedAt: nowIso(),
+        };
+
+      const logs: TimerLog[] = [];
+
+      for (const torrent of torrents) {
+        const tags = normalizeTags(torrent.tags, torrent.category);
+        const matchingRules = rules.filter((rule) => {
+          return rule.tags.some((tag) => tags.includes(tag.toLowerCase()));
+        });
+        if (matchingRules.length === 0) {
+          continue;
+        }
+        const matchingRule = matchingRules.reduce((best, current) =>
+          current.seedLimitSeconds < best.seedLimitSeconds ? current : best
+        );
+        const addedOnMs = Number(torrent.added_on ?? 0) * 1000;
+        const elapsedSeconds =
+          addedOnMs > 0
+            ? Math.max(0, (Date.now() - addedOnMs) / 1000)
+            : Number(torrent.seeding_time ?? 0);
+        const seedingSeconds = Number(torrent.seeding_time ?? 0);
+        if (elapsedSeconds < matchingRule.seedLimitSeconds) {
+          continue;
+        }
+
+        try {
+          await qbit.deleteTorrent(torrent.hash, matchingRule.deleteFiles ?? true);
+        } catch (error) {
+          continue;
+        }
+
+        const logEntry: TimerLog = {
+          id: randomUUID(),
+          hash: torrent.hash,
+          name: torrent.name,
+          sizeBytes: torrent.size,
+          tracker: torrent.tracker,
+          tags,
+          category: torrent.category,
+          seedingTimeSeconds: seedingSeconds,
+          uploadedBytes: torrent.uploaded ?? 0,
+          deletedAt: nowIso(),
+        };
+        logs.push(logEntry);
+        summary = {
+          totalDeleted: summary.totalDeleted + 1,
+          totalSeededSeconds: summary.totalSeededSeconds + seedingSeconds,
+          totalUploadedBytes: summary.totalUploadedBytes + (torrent.uploaded ?? 0),
+          updatedAt: nowIso(),
+        };
+        emitTimerLog(logEntry);
+        emitTimerSummary(summary);
       }
 
-      try {
-        await qbit.deleteTorrent(torrent.hash, matchingRule.deleteFiles ?? true);
-      } catch (error) {
-        continue;
+      if (logs.length > 0) {
+        db.timerLogs = [...(db.timerLogs ?? []), ...logs].slice(-MAX_LOGS);
+        db.timerSummary = summary;
+        await writeDb(db);
       }
-
-      const logEntry: TimerLog = {
-        id: randomUUID(),
-        hash: torrent.hash,
-        name: torrent.name,
-        sizeBytes: torrent.size,
-        tracker: torrent.tracker,
-        tags,
-        category: torrent.category,
-        seedingTimeSeconds: seedingSeconds,
-        uploadedBytes: torrent.uploaded ?? 0,
-        deletedAt: nowIso(),
-      };
-      logs.push(logEntry);
-      summary = {
-        totalDeleted: summary.totalDeleted + 1,
-        totalSeededSeconds: summary.totalSeededSeconds + seedingSeconds,
-        totalUploadedBytes: summary.totalUploadedBytes + (torrent.uploaded ?? 0),
-        updatedAt: nowIso(),
-      };
-      emitTimerLog(logEntry);
-      emitTimerSummary(summary);
-    }
-
-    if (logs.length > 0) {
-      db.timerLogs = [...(db.timerLogs ?? []), ...logs].slice(-MAX_LOGS);
-      db.timerSummary = summary;
-      await writeDb(db);
+    } catch (error) {
+      logger.error({ error }, "Timer worker tick failed");
     }
   }, intervalMs);
 };

apps/web/package.json

@@ -13,6 +13,7 @@
     "@fortawesome/react-fontawesome": "^0.2.2",
     "@radix-ui/react-alert-dialog": "^1.1.2",
     "@radix-ui/react-select": "^2.1.2",
+    "@radix-ui/react-scroll-area": "^1.2.2",
     "axios": "^1.7.7",
     "clsx": "^2.1.1",
     "react": "^18.3.1",

apps/web/src/components/ui/ScrollArea.tsx

@@ -0,0 +1,27 @@
+import * as React from "react";
+import * as ScrollAreaPrimitive from "@radix-ui/react-scroll-area";
+import clsx from "clsx";
+
+export const ScrollArea = React.forwardRef<
+  React.ElementRef<typeof ScrollAreaPrimitive.Root>,
+  React.ComponentPropsWithoutRef<typeof ScrollAreaPrimitive.Root>
+>(({ className, children, ...props }, ref) => (
+  <ScrollAreaPrimitive.Root
+    ref={ref}
+    className={clsx("relative overflow-hidden", className)}
+    {...props}
+  >
+    <ScrollAreaPrimitive.Viewport className="h-full w-full overflow-y-auto rounded-[inherit]">
+      {children}
+    </ScrollAreaPrimitive.Viewport>
+    <ScrollAreaPrimitive.Scrollbar
+      orientation="vertical"
+      className="flex w-2.5 touch-none select-none rounded-full bg-transparent p-0.5 opacity-100"
+    >
+      <ScrollAreaPrimitive.Thumb className="relative flex-1 rounded-full bg-slate-200" />
+    </ScrollAreaPrimitive.Scrollbar>
+    <ScrollAreaPrimitive.Corner />
+  </ScrollAreaPrimitive.Root>
+));
+
+ScrollArea.displayName = "ScrollArea";

apps/web/src/pages/TimerPage.tsx

@@ -2,6 +2,7 @@ import React, { useEffect, useMemo, useState } from "react";
 import { Card, CardContent, CardHeader, CardTitle } from "../components/ui/Card";
 import { Button } from "../components/ui/Button";
 import { Input } from "../components/ui/Input";
+import { ScrollArea } from "../components/ui/ScrollArea";
 import { api } from "../api/client";
 import { useAppStore } from "../store/useAppStore";
 import { useUiStore } from "../store/useUiStore";
@@ -360,13 +361,21 @@ export const TimerPage = () => {
                     <SelectItem
                       key={option.value}
                       value={option.value}
-                      onClick={() => {
+                      onPointerDown={() => {
                         if (option.value === sortKey) {
                           setSortDirection((current) =>
                             current === "asc" ? "desc" : "asc"
                           );
                         }
                       }}
+                      onKeyDown={(event) => {
+                        if (option.value !== sortKey) return;
+                        if (event.key === "Enter" || event.key === " ") {
+                          setSortDirection((current) =>
+                            current === "asc" ? "desc" : "asc"
+                          );
+                        }
+                      }}
                     >
                       {option.label}
                     </SelectItem>
@@ -435,39 +444,43 @@ export const TimerPage = () => {
               Silinen Torrent Logları
             </CardTitle>
           </CardHeader>
-          <CardContent className="space-y-3">
+          <CardContent className="space-y-3 overflow-hidden">
             {timerLogs.length === 0 ? (
               <div className="text-sm text-slate-500">Henüz log yok.</div>
             ) : (
-              <div className="space-y-3">
-                {timerLogs.map((log) => (
-                  <div
-                    key={log.id}
-                    className="rounded-lg border border-slate-200 bg-white px-3 py-2"
-                  >
-                    <div className="flex items-start justify-between gap-3">
-                      <div>
-                        <div className="text-sm font-semibold text-slate-900">
-                          {log.name}
+              <div className="overflow-hidden" style={{ height: 560 }}>
+                <ScrollArea className="h-full w-full" type="always">
+                  <div className="space-y-3 pr-3">
+                    {timerLogs.map((log) => (
+                      <div
+                        key={log.id}
+                        className="rounded-lg border border-slate-200 bg-white px-3 py-2"
+                      >
+                        <div className="flex items-start justify-between gap-3">
+                          <div>
+                            <div className="text-sm font-semibold text-slate-900">
+                              {log.name}
+                            </div>
+                            <div className="text-xs text-slate-500">
+                              {formatBytes(log.sizeBytes)} •{" "}
+                              {trackerLabel(log.tracker)}
+                            </div>
+                          </div>
+                          <div className="text-xs text-slate-400">
+                            {new Date(log.deletedAt).toLocaleString()}
+                          </div>
                         </div>
-                        <div className="text-xs text-slate-500">
-                          {formatBytes(log.sizeBytes)} •{" "}
-                          {trackerLabel(log.tracker)}
+                        <div className="mt-2 flex flex-wrap gap-2 text-xs text-slate-600">
+                          <span>Seed: {formatDuration(log.seedingTimeSeconds)}</span>
+                          <span>Upload: {formatBytes(log.uploadedBytes)}</span>
+                          {log.tags?.length ? (
+                            <span>Tags: {log.tags.join(", ")}</span>
+                          ) : null}
                         </div>
                       </div>
-                      <div className="text-xs text-slate-400">
-                        {new Date(log.deletedAt).toLocaleString()}
-                      </div>
-                    </div>
-                    <div className="mt-2 flex flex-wrap gap-2 text-xs text-slate-600">
-                      <span>Seed: {formatDuration(log.seedingTimeSeconds)}</span>
-                      <span>Upload: {formatBytes(log.uploadedBytes)}</span>
-                      {log.tags?.length ? (
-                        <span>Tags: {log.tags.join(", ")}</span>
-                      ) : null}
-                    </div>
+                    ))}
                   </div>
-                ))}
+                </ScrollArea>
               </div>
             )}
           </CardContent>