Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| feb2d26c5b |
+4
-6
@@ -1,10 +1,5 @@
|
|||||||
# Server Configuration
|
# Server Configuration
|
||||||
PORT=3001
|
PORT=3001
|
||||||
LOG_LEVEL=info
|
|
||||||
|
|
||||||
# Background polling interval in ms (default: 5000)
|
|
||||||
# Set to 0 or "off" to disable and fetch on-demand instead
|
|
||||||
# POLL_INTERVAL=5000
|
|
||||||
|
|
||||||
# Emby Configuration (single instance)
|
# Emby Configuration (single instance)
|
||||||
EMBY_URL=http://localhost:8096
|
EMBY_URL=http://localhost:8096
|
||||||
@@ -21,4 +16,7 @@ SONARR_INSTANCES=[{"name": "Primary", "url": "http://localhost:8989", "apiKey":
|
|||||||
RADARR_INSTANCES=[{"name": "Primary", "url": "http://localhost:7878", "apiKey": "your_api_key"}]
|
RADARR_INSTANCES=[{"name": "Primary", "url": "http://localhost:7878", "apiKey": "your_api_key"}]
|
||||||
|
|
||||||
# qBittorrent Instances (JSON array)
|
# qBittorrent Instances (JSON array)
|
||||||
QBITTORRENT_INSTANCES=[{"name": "main", "url": "http://localhost:8080", "username": "admin", "password": "your_password"}]
|
QBITTORRENT_INSTANCES=[
|
||||||
|
{"name": "ransackedcrew", "url": "https://qbittorrent.ransackedcrew.info", "username": "gronod", "password": "K32D&JDjtHA&mC"},
|
||||||
|
{"name": "i3omb", "url": "https://qbittorrent.i3omb.com", "username": "admin", "password": "b053288369XX!"}
|
||||||
|
]
|
||||||
|
|||||||
@@ -14,14 +14,6 @@ PORT=3001
|
|||||||
# - silent: No logging
|
# - silent: No logging
|
||||||
LOG_LEVEL=info
|
LOG_LEVEL=info
|
||||||
|
|
||||||
# Background polling interval in milliseconds (default: 5000)
|
|
||||||
# sofarr polls all services in the background and caches results so
|
|
||||||
# dashboard requests are near-instant.
|
|
||||||
# Set to 0, "off", "false", or "disabled" to disable background polling.
|
|
||||||
# When disabled, data is fetched on-demand when a user opens the dashboard
|
|
||||||
# and cached for 30 seconds so other users benefit from the same fetch.
|
|
||||||
# POLL_INTERVAL=5000
|
|
||||||
|
|
||||||
# =============================================================================
|
# =============================================================================
|
||||||
# EMBY (Authentication - Required)
|
# EMBY (Authentication - Required)
|
||||||
# =============================================================================
|
# =============================================================================
|
||||||
@@ -82,5 +74,4 @@ RADARR_INSTANCES=[{"name":"main","url":"https://radarr.example.com","apiKey":"yo
|
|||||||
# 3. URLs should include protocol (http:// or https://)
|
# 3. URLs should include protocol (http:// or https://)
|
||||||
# 4. For qBittorrent, ensure Web UI is enabled in settings
|
# 4. For qBittorrent, ensure Web UI is enabled in settings
|
||||||
# 5. User downloads are matched by tags in Sonarr/Radarr - tag your media!
|
# 5. User downloads are matched by tags in Sonarr/Radarr - tag your media!
|
||||||
# 6. Background polling keeps data fresh; disable it for low-resource setups
|
|
||||||
# =============================================================================
|
# =============================================================================
|
||||||
|
|||||||
@@ -4,7 +4,6 @@ on:
|
|||||||
push:
|
push:
|
||||||
branches:
|
branches:
|
||||||
- 'release/**'
|
- 'release/**'
|
||||||
- 'develop'
|
|
||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
build:
|
build:
|
||||||
@@ -13,31 +12,32 @@ jobs:
|
|||||||
- name: Checkout
|
- name: Checkout
|
||||||
uses: actions/checkout@v4
|
uses: actions/checkout@v4
|
||||||
|
|
||||||
- name: Compute image tags
|
- name: Extract version from package.json
|
||||||
id: meta
|
id: version
|
||||||
run: |
|
run: |
|
||||||
VERSION=$(node -p "require('./package.json').version")
|
VERSION=$(node -p "require('./package.json').version")
|
||||||
BRANCH=${GITHUB_REF#refs/heads/}
|
BRANCH=${GITHUB_REF#refs/heads/}
|
||||||
|
RELEASE_NAME=${BRANCH#release/}
|
||||||
echo "version=${VERSION}" >> $GITHUB_OUTPUT
|
echo "version=${VERSION}" >> $GITHUB_OUTPUT
|
||||||
|
echo "release=${RELEASE_NAME}" >> $GITHUB_OUTPUT
|
||||||
|
echo "Building version ${VERSION} from branch ${BRANCH}"
|
||||||
|
|
||||||
if [ "$BRANCH" = "develop" ]; then
|
- name: Set up QEMU
|
||||||
echo "tags=reg.i3omb.com/sofarr:develop" >> $GITHUB_OUTPUT
|
uses: docker/setup-qemu-action@v3
|
||||||
echo "Building develop image (version ${VERSION})"
|
|
||||||
else
|
- name: Set up Docker Buildx
|
||||||
RELEASE_NAME=${BRANCH#release/}
|
uses: docker/setup-buildx-action@v3
|
||||||
TAGS="reg.i3omb.com/sofarr:${VERSION}"
|
|
||||||
TAGS="${TAGS},reg.i3omb.com/sofarr:${RELEASE_NAME}"
|
|
||||||
TAGS="${TAGS},reg.i3omb.com/sofarr:latest"
|
|
||||||
echo "tags=${TAGS}" >> $GITHUB_OUTPUT
|
|
||||||
echo "Building release image ${VERSION} from branch ${BRANCH}"
|
|
||||||
fi
|
|
||||||
|
|
||||||
- name: Build and push Docker image
|
- name: Build and push Docker image
|
||||||
uses: docker/build-push-action@v5
|
uses: docker/build-push-action@v5
|
||||||
with:
|
with:
|
||||||
context: .
|
context: .
|
||||||
push: true
|
push: true
|
||||||
tags: ${{ steps.meta.outputs.tags }}
|
platforms: linux/amd64,linux/arm64,linux/arm/v7
|
||||||
|
tags: |
|
||||||
|
reg.i3omb.com/sofarr:${{ steps.version.outputs.version }}
|
||||||
|
reg.i3omb.com/sofarr:${{ steps.version.outputs.release }}
|
||||||
|
reg.i3omb.com/sofarr:latest
|
||||||
labels: |
|
labels: |
|
||||||
org.opencontainers.image.version=${{ steps.meta.outputs.version }}
|
org.opencontainers.image.version=${{ steps.version.outputs.version }}
|
||||||
org.opencontainers.image.created=${{ github.event.head_commit.timestamp }}
|
org.opencontainers.image.created=${{ github.event.head_commit.timestamp }}
|
||||||
|
|||||||
@@ -108,7 +108,6 @@ docker run -d \
|
|||||||
-e SABNZBD_INSTANCES='[{"name":"main","url":"http://sabnzbd:8080","apiKey":"your-key"}]' \
|
-e SABNZBD_INSTANCES='[{"name":"main","url":"http://sabnzbd:8080","apiKey":"your-key"}]' \
|
||||||
-e QBITTORRENT_INSTANCES='[{"name":"main","url":"http://qbit:8080","username":"admin","password":"pass"}]' \
|
-e QBITTORRENT_INSTANCES='[{"name":"main","url":"http://qbit:8080","username":"admin","password":"pass"}]' \
|
||||||
-e LOG_LEVEL=info \
|
-e LOG_LEVEL=info \
|
||||||
-e POLL_INTERVAL=5000 \
|
|
||||||
docker.i3omb.com/sofarr:latest
|
docker.i3omb.com/sofarr:latest
|
||||||
```
|
```
|
||||||
|
|
||||||
@@ -131,7 +130,6 @@ services:
|
|||||||
- SABNZBD_INSTANCES=[{"name":"main","url":"http://sabnzbd:8080","apiKey":"your-key"}]
|
- SABNZBD_INSTANCES=[{"name":"main","url":"http://sabnzbd:8080","apiKey":"your-key"}]
|
||||||
- QBITTORRENT_INSTANCES=[{"name":"main","url":"http://qbit:8080","username":"admin","password":"pass"}]
|
- QBITTORRENT_INSTANCES=[{"name":"main","url":"http://qbit:8080","username":"admin","password":"pass"}]
|
||||||
- LOG_LEVEL=info
|
- LOG_LEVEL=info
|
||||||
- POLL_INTERVAL=5000
|
|
||||||
```
|
```
|
||||||
|
|
||||||
> **Tip:** You can also use a combination — mount a `.env` file for base config, and override specific values with `-e` flags. Environment variables always take precedence.
|
> **Tip:** You can also use a combination — mount a `.env` file for base config, and override specific values with `-e` flags. Environment variables always take precedence.
|
||||||
@@ -183,8 +181,6 @@ Open `http://localhost:3001` in your browser
|
|||||||
```bash
|
```bash
|
||||||
PORT=3001 # Server port
|
PORT=3001 # Server port
|
||||||
LOG_LEVEL=info # Logging: debug, info, warn, error, silent
|
LOG_LEVEL=info # Logging: debug, info, warn, error, silent
|
||||||
POLL_INTERVAL=5000 # Background polling interval in ms (default: 5000)
|
|
||||||
# Set to 0 or "off" to disable (on-demand mode)
|
|
||||||
```
|
```
|
||||||
|
|
||||||
### Service Instances (JSON Array Format)
|
### Service Instances (JSON Array Format)
|
||||||
@@ -235,18 +231,6 @@ To see your downloads, you need to tag your media in Sonarr/Radarr:
|
|||||||
|
|
||||||
## Features in Detail
|
## Features in Detail
|
||||||
|
|
||||||
### Background Polling
|
|
||||||
|
|
||||||
sofarr polls all configured services in the background and caches the results. Dashboard requests read from cache, making them near-instant regardless of how many services you have.
|
|
||||||
|
|
||||||
| Setting | Behaviour |
|
|
||||||
|---------|----------|
|
|
||||||
| `POLL_INTERVAL=5000` (default) | Background poller fetches every 5s. Dashboard reads from cache instantly. |
|
|
||||||
| `POLL_INTERVAL=10000` | Poll every 10 seconds. |
|
|
||||||
| `POLL_INTERVAL=0` / `off` / `disabled` | No background polling. Data fetched on-demand when a user opens the dashboard, then cached for 30 seconds. |
|
|
||||||
|
|
||||||
**On-demand mode** is useful for low-resource setups. When one user's browser refreshes, the fetched data is cached and served to all other users until it expires. A user with a faster refresh rate effectively keeps the cache warm for everyone.
|
|
||||||
|
|
||||||
### Real-Time Updates
|
### Real-Time Updates
|
||||||
- Auto-refresh every 5 seconds (configurable: 1s, 5s, 10s, or off)
|
- Auto-refresh every 5 seconds (configurable: 1s, 5s, 10s, or off)
|
||||||
- In-place DOM updates for smooth UI (no flickering)
|
- In-place DOM updates for smooth UI (no flickering)
|
||||||
|
|||||||
@@ -1,609 +0,0 @@
|
|||||||
# sofarr — Architecture Documentation
|
|
||||||
|
|
||||||
Comprehensive technical documentation covering the full architecture of the **sofarr** application: a personal media download dashboard that aggregates downloads from SABnzbd, Sonarr, Radarr, and qBittorrent, filtered by Emby user identity.
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
## Table of Contents
|
|
||||||
|
|
||||||
1. [System Overview](#1-system-overview)
|
|
||||||
2. [Technology Stack](#2-technology-stack)
|
|
||||||
3. [Directory Structure](#3-directory-structure)
|
|
||||||
4. [Component Architecture](#4-component-architecture)
|
|
||||||
5. [Data Flow](#5-data-flow)
|
|
||||||
6. [Authentication & Authorisation](#6-authentication--authorisation)
|
|
||||||
7. [Background Polling & Caching](#7-background-polling--caching)
|
|
||||||
8. [Download Matching Pipeline](#8-download-matching-pipeline)
|
|
||||||
9. [API Reference](#9-api-reference)
|
|
||||||
10. [Frontend Architecture](#10-frontend-architecture)
|
|
||||||
11. [Configuration](#11-configuration)
|
|
||||||
12. [Deployment](#12-deployment)
|
|
||||||
13. [UML Diagrams (PlantUML)](#13-uml-diagrams-plantuml)
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
## 1. System Overview
|
|
||||||
|
|
||||||
sofarr is a **single-page web application** with a Node.js/Express backend. It provides a personalised view of media downloads by:
|
|
||||||
|
|
||||||
1. **Authenticating** users against an Emby/Jellyfin media server.
|
|
||||||
2. **Aggregating** download data from multiple *arr service instances and download clients.
|
|
||||||
3. **Filtering** downloads by user — each user only sees media tagged with their username in Sonarr/Radarr.
|
|
||||||
4. **Presenting** a real-time dashboard with progress, speeds, cover art, and status.
|
|
||||||
|
|
||||||
Admin users can view all users' downloads, see server status, cache statistics, and poll timings.
|
|
||||||
|
|
||||||
### High-Level Architecture
|
|
||||||
|
|
||||||
```
|
|
||||||
┌─────────────────────────────────────────────────────┐
|
|
||||||
│ Browser (SPA) │
|
|
||||||
│ ┌──────────┐ ┌──────────┐ ┌───────────────────┐ │
|
|
||||||
│ │ Login │ │Dashboard │ │ Status Panel │ │
|
|
||||||
│ │ Form │ │ Cards │ │ (Admin only) │ │
|
|
||||||
│ └────┬─────┘ └────┬─────┘ └───────┬───────────┘ │
|
|
||||||
│ │ │ │ │
|
|
||||||
└───────┼──────────────┼────────────────┼──────────────┘
|
|
||||||
│ POST /login │ GET /user- │ GET /status
|
|
||||||
│ │ downloads │
|
|
||||||
▼ ▼ ▼
|
|
||||||
┌─────────────────────────────────────────────────────┐
|
|
||||||
│ Express Server (:3001) │
|
|
||||||
│ ┌────────┐ ┌──────────┐ ┌────────┐ ┌────────────┐ │
|
|
||||||
│ │ Auth │ │Dashboard │ │ Emby │ │ Static │ │
|
|
||||||
│ │ Routes │ │ Routes │ │ Routes │ │ Files │ │
|
|
||||||
│ └────┬───┘ └────┬─────┘ └────┬───┘ └────────────┘ │
|
|
||||||
│ │ │ │ │
|
|
||||||
│ ┌────┴──────────┴────────────┴──────────────────┐ │
|
|
||||||
│ │ Utilities Layer │ │
|
|
||||||
│ │ ┌────────┐ ┌────────┐ ┌──────┐ ┌──────────┐ │ │
|
|
||||||
│ │ │ Poller │ │ Cache │ │Config│ │qBittorrent│ │ │
|
|
||||||
│ │ └───┬────┘ └────────┘ └──────┘ └──────────┘ │ │
|
|
||||||
│ └──────┼────────────────────────────────────────┘ │
|
|
||||||
└─────────┼────────────────────────────────────────────┘
|
|
||||||
│ HTTP/API calls
|
|
||||||
▼
|
|
||||||
┌──────────────────────────────────────────────────────┐
|
|
||||||
│ External Services │
|
|
||||||
│ ┌──────────┐ ┌────────┐ ┌────────┐ ┌────────────┐ │
|
|
||||||
│ │ SABnzbd │ │ Sonarr │ │ Radarr │ │qBittorrent │ │
|
|
||||||
│ │ (Usenet) │ │ (TV) │ │(Movie) │ │ (Torrent) │ │
|
|
||||||
│ └──────────┘ └────────┘ └────────┘ └────────────┘ │
|
|
||||||
│ ┌──────────────────────────────────────────────┐ │
|
|
||||||
│ │ Emby / Jellyfin │ │
|
|
||||||
│ │ (Authentication + User DB) │ │
|
|
||||||
│ └──────────────────────────────────────────────┘ │
|
|
||||||
└──────────────────────────────────────────────────────┘
|
|
||||||
```
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
## 2. Technology Stack
|
|
||||||
|
|
||||||
| Layer | Technology | Purpose |
|
|
||||||
|-------|-----------|---------|
|
|
||||||
| **Runtime** | Node.js 18+ | Server runtime |
|
|
||||||
| **Framework** | Express 4.x | HTTP server, routing, middleware |
|
|
||||||
| **HTTP Client** | axios 1.x | External API communication |
|
|
||||||
| **Frontend** | Vanilla JS + CSS | Single-page app, no build step |
|
|
||||||
| **Auth** | Emby API + httpOnly cookies | Session management |
|
|
||||||
| **Caching** | In-memory Map with TTL | Reduce external API load |
|
|
||||||
| **Scheduling** | `setInterval` | Background polling |
|
|
||||||
| **Containerisation** | Docker (Alpine) | Production deployment |
|
|
||||||
| **Logging** | Custom logger + `console.*` | File + stdout logging with levels |
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
## 3. Directory Structure
|
|
||||||
|
|
||||||
```
|
|
||||||
sofarr/
|
|
||||||
├── server/ # Backend application
|
|
||||||
│ ├── index.js # Entry point: Express setup, middleware, startup
|
|
||||||
│ ├── routes/
|
|
||||||
│ │ ├── auth.js # POST /login, GET /me, POST /logout
|
|
||||||
│ │ ├── dashboard.js # GET /user-downloads, /user-summary, /status
|
|
||||||
│ │ ├── emby.js # Proxy routes to Emby API
|
|
||||||
│ │ ├── sabnzbd.js # Proxy routes to SABnzbd API
|
|
||||||
│ │ ├── sonarr.js # Proxy routes to Sonarr API
|
|
||||||
│ │ └── radarr.js # Proxy routes to Radarr API
|
|
||||||
│ └── utils/
|
|
||||||
│ ├── cache.js # MemoryCache class (Map + TTL + stats)
|
|
||||||
│ ├── config.js # Multi-instance service configuration parser
|
|
||||||
│ ├── logger.js # File logger (server.log)
|
|
||||||
│ ├── poller.js # Background polling engine + timing
|
|
||||||
│ └── qbittorrent.js # qBittorrent client with auth + torrent mapping
|
|
||||||
├── public/ # Static frontend (served by Express)
|
|
||||||
│ ├── index.html # HTML shell: splash, login, dashboard
|
|
||||||
│ ├── app.js # All frontend logic (auth, rendering, status)
|
|
||||||
│ ├── style.css # Themes, layout, responsive design
|
|
||||||
│ └── images/ # Logo / splash screen assets
|
|
||||||
├── Dockerfile # Production container image
|
|
||||||
├── docker-compose.yaml # Example compose deployment
|
|
||||||
├── package.json # Dependencies and scripts
|
|
||||||
├── .env.sample # Annotated environment variable template
|
|
||||||
└── README.md # User-facing documentation
|
|
||||||
```
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
## 4. Component Architecture
|
|
||||||
|
|
||||||
### 4.1 Server Entry Point (`server/index.js`)
|
|
||||||
|
|
||||||
Responsibilities:
|
|
||||||
- Load environment variables via `dotenv`
|
|
||||||
- Configure structured logging with level filtering (`LOG_LEVEL`)
|
|
||||||
- Redirect `console.*` to both stdout and `server.log`
|
|
||||||
- Mount Express middleware (CORS, cookie-parser, JSON, static files)
|
|
||||||
- Mount route modules under `/api/*`
|
|
||||||
- Start the background poller
|
|
||||||
|
|
||||||
### 4.2 Route Modules
|
|
||||||
|
|
||||||
| Module | Mount Point | Auth Required | Purpose |
|
|
||||||
|--------|------------|---------------|---------|
|
|
||||||
| `auth.js` | `/api/auth` | No | Login, session check, logout |
|
|
||||||
| `dashboard.js` | `/api/dashboard` | Yes (cookie) | Aggregated download data, status |
|
|
||||||
| `emby.js` | `/api/emby` | No | Proxy to Emby API |
|
|
||||||
| `sabnzbd.js` | `/api/sabnzbd` | No | Proxy to SABnzbd API |
|
|
||||||
| `sonarr.js` | `/api/sonarr` | No | Proxy to Sonarr API |
|
|
||||||
| `radarr.js` | `/api/radarr` | No | Proxy to Radarr API |
|
|
||||||
|
|
||||||
> **Note:** The proxy routes (`emby`, `sabnzbd`, `sonarr`, `radarr`) use legacy single-instance env vars and are largely unused by the dashboard — they exist for direct API access. The dashboard reads from the poller cache.
|
|
||||||
|
|
||||||
### 4.3 Utility Modules
|
|
||||||
|
|
||||||
**`config.js`** — Parses service instances from environment variables. Supports both JSON array format (`SONARR_INSTANCES=[{...}]`) and legacy single-instance format (`SONARR_URL` + `SONARR_API_KEY`). Each instance gets an `id` derived from `name` or index.
|
|
||||||
|
|
||||||
**`cache.js`** — Singleton `MemoryCache` backed by a `Map`. Each entry has an expiration timestamp. Provides `get`, `set`, `invalidate`, `clear`, and `getStats` (returns per-key size, item count, TTL remaining).
|
|
||||||
|
|
||||||
**`poller.js`** — Background polling engine. Fetches data from all configured service instances in parallel with per-task timing. Stores results in the cache with a configurable TTL. Can be disabled entirely (`POLL_INTERVAL=0`), in which case data is fetched on-demand per dashboard request.
|
|
||||||
|
|
||||||
**`qbittorrent.js`** — `QBittorrentClient` class with cookie-based authentication, automatic re-auth on 403, and persistent client instances. Includes torrent-to-download mapping (`mapTorrentToDownload`) and formatting utilities.
|
|
||||||
|
|
||||||
**`logger.js`** — Simple file appender writing timestamped messages to `server.log`.
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
## 5. Data Flow
|
|
||||||
|
|
||||||
### 5.1 Polling Cycle
|
|
||||||
|
|
||||||
Every `POLL_INTERVAL` ms (default 5000), the poller fetches from all services in parallel:
|
|
||||||
|
|
||||||
| Task | API Call | Params |
|
|
||||||
|------|----------|--------|
|
|
||||||
| SABnzbd Queue | `GET /api?mode=queue` | `output=json` |
|
|
||||||
| SABnzbd History | `GET /api?mode=history` | `limit=10` |
|
|
||||||
| Sonarr Tags | `GET /api/v3/tag` | — |
|
|
||||||
| Sonarr Queue | `GET /api/v3/queue` | `includeSeries=true` |
|
|
||||||
| Sonarr History | `GET /api/v3/history` | `pageSize=10` |
|
|
||||||
| Radarr Queue | `GET /api/v3/queue` | `includeMovie=true` |
|
|
||||||
| Radarr History | `GET /api/v3/history` | `pageSize=10` |
|
|
||||||
| Radarr Tags | `GET /api/v3/tag` | — |
|
|
||||||
| qBittorrent | `GET /api/v2/torrents/info` | — |
|
|
||||||
|
|
||||||
Results are stored in the cache under `poll:*` keys with a TTL of `POLL_INTERVAL × 3`.
|
|
||||||
|
|
||||||
### 5.2 Dashboard Request
|
|
||||||
|
|
||||||
When a user requests `/api/dashboard/user-downloads`:
|
|
||||||
|
|
||||||
1. Read all `poll:*` keys from cache
|
|
||||||
2. Build `seriesMap` and `moviesMap` from embedded objects in queue records
|
|
||||||
3. Build `sonarrTagMap` and `radarrTagMap` from tag data
|
|
||||||
4. For each SABnzbd queue slot → try to match against Sonarr/Radarr queue records by title
|
|
||||||
5. For each SABnzbd history slot → try to match against Sonarr/Radarr history records
|
|
||||||
6. For each qBittorrent torrent → try to match against Sonarr/Radarr queue, then history
|
|
||||||
7. For each match, resolve the series/movie, extract the user tag, check if it belongs to the requesting user
|
|
||||||
8. Return only the user's downloads (or all, if admin with `showAll=true`)
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
## 6. Authentication & Authorisation
|
|
||||||
|
|
||||||
### Flow
|
|
||||||
|
|
||||||
1. User submits credentials via the login form
|
|
||||||
2. Backend calls Emby `POST /Users/authenticatebyname`
|
|
||||||
3. On success, fetches full user profile to determine admin status
|
|
||||||
4. Sets an `httpOnly` cookie (`emby_user`) containing: `{ id, name, isAdmin, token }`
|
|
||||||
5. Cookie expires after 24 hours
|
|
||||||
6. All subsequent dashboard requests read this cookie for identity
|
|
||||||
|
|
||||||
### Authorisation Matrix
|
|
||||||
|
|
||||||
| Feature | Regular User | Admin |
|
|
||||||
|---------|:----------:|:-----:|
|
|
||||||
| View own downloads | ✓ | ✓ |
|
|
||||||
| View all users' downloads | ✗ | ✓ (`showAll`) |
|
|
||||||
| See download/target paths | ✗ | ✓ |
|
|
||||||
| See Sonarr/Radarr links | ✗ | ✓ |
|
|
||||||
| View status panel | ✗ | ✓ |
|
|
||||||
|
|
||||||
### Tag Matching
|
|
||||||
|
|
||||||
Users are matched to downloads via tags in Sonarr/Radarr:
|
|
||||||
|
|
||||||
1. **Exact match**: tag label (lowercased) === username (lowercased)
|
|
||||||
2. **Sanitised match**: handles Ombi's tag mangling — `sanitizeTagLabel()` converts to lowercase, replaces non-alphanumeric with hyphens, collapses, trims
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
## 7. Background Polling & Caching
|
|
||||||
|
|
||||||
### Polling Modes
|
|
||||||
|
|
||||||
| Mode | `POLL_INTERVAL` | Behaviour |
|
|
||||||
|------|----------------|-----------|
|
|
||||||
| **Background** | `> 0` (e.g. `5000`) | Periodic fetch every N ms |
|
|
||||||
| **On-demand** | `0` / `off` / `false` | Fetch triggered by first user request when cache is empty |
|
|
||||||
|
|
||||||
### Cache Keys
|
|
||||||
|
|
||||||
| Key | Content | Source |
|
|
||||||
|-----|---------|--------|
|
|
||||||
| `poll:sab-queue` | `{ slots, status, speed, kbpersec }` | SABnzbd queue |
|
|
||||||
| `poll:sab-history` | `{ slots }` | SABnzbd history |
|
|
||||||
| `poll:sonarr-tags` | `[{ instance, data: [{id, label}] }]` | Sonarr tag API |
|
|
||||||
| `poll:sonarr-queue` | `{ records }` — includes embedded `series` objects | Sonarr queue (includeSeries) |
|
|
||||||
| `poll:sonarr-history` | `{ records }` — lightweight, no embedded objects | Sonarr history |
|
|
||||||
| `poll:radarr-queue` | `{ records }` — includes embedded `movie` objects | Radarr queue (includeMovie) |
|
|
||||||
| `poll:radarr-history` | `{ records }` — lightweight, no embedded objects | Radarr history |
|
|
||||||
| `poll:radarr-tags` | `[{id, label}]` | Radarr tag API |
|
|
||||||
| `poll:qbittorrent` | `[torrent, ...]` | qBittorrent all torrents |
|
|
||||||
|
|
||||||
### TTL Strategy
|
|
||||||
|
|
||||||
- **Polling enabled**: `POLL_INTERVAL × 3` — ensures data survives between polls even if one poll is slow
|
|
||||||
- **Polling disabled**: `30000` ms — stale after 30s, next request triggers a fresh fetch
|
|
||||||
|
|
||||||
### Active Client Tracking
|
|
||||||
|
|
||||||
Each dashboard request reports the client's refresh rate. The server tracks active clients in a `Map<username, { user, refreshRateMs, lastSeen }>`, pruning entries older than 30 seconds. This data powers the admin status panel's "effective refresh mode" display.
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
## 8. Download Matching Pipeline
|
|
||||||
|
|
||||||
The core logic in `dashboard.js` matches raw download client data to *arr service metadata to determine which user each download belongs to.
|
|
||||||
|
|
||||||
### Matching Strategy
|
|
||||||
|
|
||||||
For each download item (SABnzbd slot or qBittorrent torrent):
|
|
||||||
|
|
||||||
```
|
|
||||||
1. Try Sonarr QUEUE match (by title substring)
|
|
||||||
→ resolve series via seriesMap (embedded in queue record)
|
|
||||||
→ extract user tag → check tag matches requesting user
|
|
||||||
|
|
||||||
2. Try Radarr QUEUE match (by title substring)
|
|
||||||
→ resolve movie via moviesMap (embedded in queue record)
|
|
||||||
→ extract user tag → check tag matches requesting user
|
|
||||||
|
|
||||||
3. Try Sonarr HISTORY match (by title substring)
|
|
||||||
→ resolve series via seriesMap (from queue) using seriesId
|
|
||||||
→ extract user tag → check tag matches requesting user
|
|
||||||
|
|
||||||
4. Try Radarr HISTORY match (by title substring)
|
|
||||||
→ resolve movie via moviesMap (from queue) using movieId
|
|
||||||
→ extract user tag → check tag matches requesting user
|
|
||||||
```
|
|
||||||
|
|
||||||
### Title Matching
|
|
||||||
|
|
||||||
Matches are **bidirectional substring matches** (case-insensitive):
|
|
||||||
```javascript
|
|
||||||
rTitle.includes(downloadTitle) || downloadTitle.includes(rTitle)
|
|
||||||
```
|
|
||||||
|
|
||||||
### Download Object Structure
|
|
||||||
|
|
||||||
Each matched download produces an object with:
|
|
||||||
|
|
||||||
| Field | Type | Description |
|
|
||||||
|-------|------|-------------|
|
|
||||||
| `type` | `'series'` / `'movie'` / `'torrent'` | Media type |
|
|
||||||
| `title` | string | Raw download title |
|
|
||||||
| `coverArt` | string / null | Poster URL from *arr |
|
|
||||||
| `status` | string | Download status |
|
|
||||||
| `progress` | string | Percentage complete |
|
|
||||||
| `size` / `mb` / `mbmissing` | string / number | Size info |
|
|
||||||
| `speed` | string | Current download speed |
|
|
||||||
| `eta` | string | Estimated time remaining |
|
|
||||||
| `seriesName` / `movieName` | string | Friendly media title |
|
|
||||||
| `episodeInfo` / `movieInfo` | object | Full *arr queue/history record |
|
|
||||||
| `userTag` | string | Matched user tag |
|
|
||||||
| `importIssues` | string[] / null | Import warning/error messages |
|
|
||||||
| `downloadPath` | string / null | (Admin) Download client path |
|
|
||||||
| `targetPath` | string / null | (Admin) *arr target path |
|
|
||||||
| `arrLink` | string / null | (Admin) Link to *arr web UI |
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
## 9. API Reference
|
|
||||||
|
|
||||||
### `POST /api/auth/login`
|
|
||||||
|
|
||||||
Authenticate a user via Emby.
|
|
||||||
|
|
||||||
**Request Body:**
|
|
||||||
```json
|
|
||||||
{ "username": "string", "password": "string" }
|
|
||||||
```
|
|
||||||
|
|
||||||
**Response (200):**
|
|
||||||
```json
|
|
||||||
{
|
|
||||||
"success": true,
|
|
||||||
"user": { "id": "string", "name": "string", "isAdmin": true }
|
|
||||||
}
|
|
||||||
```
|
|
||||||
|
|
||||||
**Response (401):**
|
|
||||||
```json
|
|
||||||
{ "success": false, "error": "Invalid username or password" }
|
|
||||||
```
|
|
||||||
|
|
||||||
**Side Effect:** Sets `emby_user` httpOnly cookie (24h TTL).
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
### `GET /api/auth/me`
|
|
||||||
|
|
||||||
Check current session.
|
|
||||||
|
|
||||||
**Response:**
|
|
||||||
```json
|
|
||||||
{
|
|
||||||
"authenticated": true,
|
|
||||||
"user": { "id": "string", "name": "string", "isAdmin": false }
|
|
||||||
}
|
|
||||||
```
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
### `POST /api/auth/logout`
|
|
||||||
|
|
||||||
Clear session cookie.
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
### `GET /api/dashboard/user-downloads`
|
|
||||||
|
|
||||||
Fetch downloads for the authenticated user.
|
|
||||||
|
|
||||||
**Query Parameters:**
|
|
||||||
| Param | Type | Description |
|
|
||||||
|-------|------|-------------|
|
|
||||||
| `showAll` | `"true"` | (Admin) Show all users' downloads |
|
|
||||||
| `refreshRate` | number (ms) | Client's current refresh rate for tracking |
|
|
||||||
|
|
||||||
**Response (200):**
|
|
||||||
```json
|
|
||||||
{
|
|
||||||
"user": "string",
|
|
||||||
"isAdmin": true,
|
|
||||||
"downloads": [ /* download objects */ ]
|
|
||||||
}
|
|
||||||
```
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
### `GET /api/dashboard/status`
|
|
||||||
|
|
||||||
Admin-only server status.
|
|
||||||
|
|
||||||
**Response (200):**
|
|
||||||
```json
|
|
||||||
{
|
|
||||||
"server": {
|
|
||||||
"uptimeSeconds": 3600,
|
|
||||||
"nodeVersion": "v18.19.0",
|
|
||||||
"memoryUsageMB": 45.2,
|
|
||||||
"heapUsedMB": 28.1,
|
|
||||||
"heapTotalMB": 35.0
|
|
||||||
},
|
|
||||||
"polling": {
|
|
||||||
"enabled": true,
|
|
||||||
"intervalMs": 5000,
|
|
||||||
"lastPoll": {
|
|
||||||
"totalMs": 1234,
|
|
||||||
"timestamp": "2026-05-16T00:00:00.000Z",
|
|
||||||
"tasks": [
|
|
||||||
{ "label": "SABnzbd Queue", "ms": 120 },
|
|
||||||
{ "label": "Sonarr Queue", "ms": 890 }
|
|
||||||
]
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"cache": {
|
|
||||||
"entryCount": 9,
|
|
||||||
"totalSizeBytes": 51200,
|
|
||||||
"entries": [
|
|
||||||
{ "key": "poll:sab-queue", "sizeBytes": 1024, "itemCount": 3, "ttlRemainingMs": 12000, "expired": false }
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"clients": [
|
|
||||||
{ "user": "Alice", "refreshRateMs": 5000, "lastSeen": 1715817600000 }
|
|
||||||
]
|
|
||||||
}
|
|
||||||
```
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
### `GET /api/dashboard/user-summary`
|
|
||||||
|
|
||||||
Admin-only per-user download counts (fetches live from APIs, not cached).
|
|
||||||
|
|
||||||
**Response (200):**
|
|
||||||
```json
|
|
||||||
[
|
|
||||||
{ "username": "Alice", "seriesCount": 12, "movieCount": 5 }
|
|
||||||
]
|
|
||||||
```
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
## 10. Frontend Architecture
|
|
||||||
|
|
||||||
The frontend is a **vanilla JavaScript SPA** with no build step. All logic resides in `app.js` (754 lines), styled by `style.css`, and structured by `index.html`.
|
|
||||||
|
|
||||||
### UI States
|
|
||||||
|
|
||||||
```
|
|
||||||
┌──────────────┐ ┌──────────────┐ ┌──────────────┐
|
|
||||||
│ Splash Screen│────▶│ Login Form │────▶│ Dashboard │
|
|
||||||
│ (on load) │ │ (if no │ │ (after auth) │
|
|
||||||
│ │ │ session) │ │ │
|
|
||||||
└──────────────┘ └──────────────┘ └──────────────┘
|
|
||||||
│
|
|
||||||
┌─────┴─────┐
|
|
||||||
│ Status │
|
|
||||||
│ Panel │
|
|
||||||
│ (admin) │
|
|
||||||
└───────────┘
|
|
||||||
```
|
|
||||||
|
|
||||||
### Key Frontend Functions
|
|
||||||
|
|
||||||
| Function | Purpose |
|
|
||||||
|----------|---------|
|
|
||||||
| `checkAuthentication()` | On load: check session → show dashboard or login |
|
|
||||||
| `handleLogin()` | Authenticate, fade login → splash → dashboard |
|
|
||||||
| `fetchUserDownloads()` | GET `/user-downloads`, update state, re-render |
|
|
||||||
| `renderDownloads()` | Diff-based card rendering (create/update/remove) |
|
|
||||||
| `createDownloadCard()` | Build DOM for a single download card |
|
|
||||||
| `updateDownloadCard()` | Update existing card in-place (progress, speed, etc.) |
|
|
||||||
| `toggleStatusPanel()` | Show/hide admin status panel |
|
|
||||||
| `renderStatusPanel()` | Build status HTML (server, polling, cache, clients) |
|
|
||||||
| `startAutoRefresh()` | Start periodic `fetchUserDownloads` |
|
|
||||||
| `initThemeSwitcher()` | Light / Dark / Mono theme support |
|
|
||||||
|
|
||||||
### Themes
|
|
||||||
|
|
||||||
Three CSS themes via `data-theme` attribute on `<html>`:
|
|
||||||
- **Light** — Purple gradient header, white cards
|
|
||||||
- **Dark** — Dark surfaces, muted accents
|
|
||||||
- **Mono** — Monochrome, minimal colour
|
|
||||||
|
|
||||||
Theme selection persists in `localStorage`.
|
|
||||||
|
|
||||||
### Auto-Refresh
|
|
||||||
|
|
||||||
The dashboard polls the server at the user-selected interval (1s, 5s, 10s, or Off). The status panel auto-refreshes in sync. Client refresh rate is sent to the server on each request for active-client tracking.
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
## 11. Configuration
|
|
||||||
|
|
||||||
### Environment Variables
|
|
||||||
|
|
||||||
| Variable | Required | Default | Description |
|
|
||||||
|----------|:--------:|---------|-------------|
|
|
||||||
| `PORT` | No | `3001` | Server listen port |
|
|
||||||
| `EMBY_URL` | Yes | — | Emby/Jellyfin server URL |
|
|
||||||
| `EMBY_API_KEY` | Yes | — | Emby API key |
|
|
||||||
| `SONARR_INSTANCES` | Yes* | — | JSON array of Sonarr instances |
|
|
||||||
| `SONARR_URL` | Yes* | — | Legacy single Sonarr URL |
|
|
||||||
| `SONARR_API_KEY` | Yes* | — | Legacy single Sonarr API key |
|
|
||||||
| `RADARR_INSTANCES` | Yes* | — | JSON array of Radarr instances |
|
|
||||||
| `RADARR_URL` | Yes* | — | Legacy single Radarr URL |
|
|
||||||
| `RADARR_API_KEY` | Yes* | — | Legacy single Radarr API key |
|
|
||||||
| `SABNZBD_INSTANCES` | Yes* | — | JSON array of SABnzbd instances |
|
|
||||||
| `SABNZBD_URL` | Yes* | — | Legacy single SABnzbd URL |
|
|
||||||
| `SABNZBD_API_KEY` | Yes* | — | Legacy single SABnzbd API key |
|
|
||||||
| `QBITTORRENT_INSTANCES` | No | — | JSON array of qBittorrent instances |
|
|
||||||
| `POLL_INTERVAL` | No | `5000` | Poll interval in ms, or `off`/`0` to disable |
|
|
||||||
| `LOG_LEVEL` | No | `info` | `debug`, `info`, `warn`, `error`, `silent` |
|
|
||||||
|
|
||||||
\* Either `*_INSTANCES` (JSON array) or legacy `*_URL` + `*_API_KEY` format is required.
|
|
||||||
|
|
||||||
### Instance JSON Format
|
|
||||||
|
|
||||||
```json
|
|
||||||
[
|
|
||||||
{
|
|
||||||
"name": "main",
|
|
||||||
"url": "https://sonarr.example.com",
|
|
||||||
"apiKey": "your-api-key"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"name": "4k",
|
|
||||||
"url": "https://sonarr4k.example.com",
|
|
||||||
"apiKey": "your-4k-api-key"
|
|
||||||
}
|
|
||||||
]
|
|
||||||
```
|
|
||||||
|
|
||||||
qBittorrent instances use `username` and `password` instead of `apiKey`.
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
## 12. Deployment
|
|
||||||
|
|
||||||
### Docker
|
|
||||||
|
|
||||||
```dockerfile
|
|
||||||
FROM node:18-alpine
|
|
||||||
WORKDIR /app
|
|
||||||
COPY package.json package-lock.json ./
|
|
||||||
RUN npm ci --omit=dev
|
|
||||||
COPY server/ ./server/
|
|
||||||
COPY public/ ./public/
|
|
||||||
EXPOSE 3001
|
|
||||||
ENV NODE_ENV=production
|
|
||||||
CMD ["node", "server/index.js"]
|
|
||||||
```
|
|
||||||
|
|
||||||
### Docker Compose
|
|
||||||
|
|
||||||
```yaml
|
|
||||||
version: "3"
|
|
||||||
services:
|
|
||||||
sofarr:
|
|
||||||
image: docker.i3omb.com/sofarr:latest
|
|
||||||
container_name: sofarr
|
|
||||||
restart: unless-stopped
|
|
||||||
ports:
|
|
||||||
- "3001:3001"
|
|
||||||
environment:
|
|
||||||
- EMBY_URL=https://emby.example.com
|
|
||||||
- EMBY_API_KEY=your-emby-api-key
|
|
||||||
- SONARR_INSTANCES=[{"name":"main","url":"...","apiKey":"..."}]
|
|
||||||
- RADARR_INSTANCES=[{"name":"main","url":"...","apiKey":"..."}]
|
|
||||||
- SABNZBD_INSTANCES=[{"name":"main","url":"...","apiKey":"..."}]
|
|
||||||
- QBITTORRENT_INSTANCES=[{"name":"main","url":"...","username":"...","password":"..."}]
|
|
||||||
- POLL_INTERVAL=5000
|
|
||||||
- LOG_LEVEL=info
|
|
||||||
```
|
|
||||||
|
|
||||||
---
|
|
||||||
|
|
||||||
## 13. UML Diagrams (PlantUML)
|
|
||||||
|
|
||||||
All diagrams below are in PlantUML syntax. Render with any PlantUML tool or VS Code extension.
|
|
||||||
|
|
||||||
### 13.1 Component Diagram
|
|
||||||
|
|
||||||
See [`diagrams/component.puml`](diagrams/component.puml)
|
|
||||||
|
|
||||||
### 13.2 Sequence Diagrams
|
|
||||||
|
|
||||||
- **Authentication**: [`diagrams/seq-auth.puml`](diagrams/seq-auth.puml)
|
|
||||||
- **Dashboard Request**: [`diagrams/seq-dashboard.puml`](diagrams/seq-dashboard.puml)
|
|
||||||
- **Polling Cycle**: [`diagrams/seq-polling.puml`](diagrams/seq-polling.puml)
|
|
||||||
|
|
||||||
### 13.3 Class / Entity Diagrams
|
|
||||||
|
|
||||||
- **Server Classes**: [`diagrams/class-server.puml`](diagrams/class-server.puml)
|
|
||||||
- **Data Model**: [`diagrams/class-data.puml`](diagrams/class-data.puml)
|
|
||||||
|
|
||||||
### 13.4 State Diagrams
|
|
||||||
|
|
||||||
- **Frontend UI States**: [`diagrams/state-ui.puml`](diagrams/state-ui.puml)
|
|
||||||
- **Poller States**: [`diagrams/state-poller.puml`](diagrams/state-poller.puml)
|
|
||||||
|
|
||||||
### 13.5 Activity Diagram
|
|
||||||
|
|
||||||
- **Download Matching**: [`diagrams/activity-matching.puml`](diagrams/activity-matching.puml)
|
|
||||||
@@ -1,128 +0,0 @@
|
|||||||
@startuml activity-matching
|
|
||||||
!theme plain
|
|
||||||
title sofarr — Download Matching Activity Diagram
|
|
||||||
|
|
||||||
start
|
|
||||||
|
|
||||||
:Read cached data from MemoryCache;
|
|
||||||
note right
|
|
||||||
poll:sab-queue, poll:sab-history,
|
|
||||||
poll:sonarr-queue, poll:sonarr-history,
|
|
||||||
poll:radarr-queue, poll:radarr-history,
|
|
||||||
poll:sonarr-tags, poll:radarr-tags,
|
|
||||||
poll:qbittorrent
|
|
||||||
end note
|
|
||||||
|
|
||||||
:Build **seriesMap** from Sonarr queue records
|
|
||||||
(seriesId → embedded series object);
|
|
||||||
|
|
||||||
:Build **moviesMap** from Radarr queue records
|
|
||||||
(movieId → embedded movie object);
|
|
||||||
|
|
||||||
:Build **sonarrTagMap** (tagId → label)
|
|
||||||
Build **radarrTagMap** (tagId → label);
|
|
||||||
|
|
||||||
:Initialise **userDownloads** = [];
|
|
||||||
|
|
||||||
partition "Process SABnzbd Queue Slots" {
|
|
||||||
while (More queue slots?) is (yes)
|
|
||||||
:Get slot filename (nzbName);
|
|
||||||
:nzbNameLower = nzbName.toLowerCase();
|
|
||||||
|
|
||||||
if (Title matches Sonarr **queue** record?) then (yes)
|
|
||||||
:series = seriesMap.get(match.seriesId)\n|| match.series;
|
|
||||||
if (series exists?) then (yes)
|
|
||||||
:userTag = extractUserTag(series.tags, sonarrTagMap);
|
|
||||||
if (showAll OR tagMatchesUser?) then (yes)
|
|
||||||
:Build download object (type=series)
|
|
||||||
Add coverArt, status, progress, speed, eta
|
|
||||||
Add importIssues if any
|
|
||||||
Add admin fields (paths, arrLink);
|
|
||||||
:Push to **userDownloads**;
|
|
||||||
endif
|
|
||||||
endif
|
|
||||||
endif
|
|
||||||
|
|
||||||
if (Title matches Radarr **queue** record?) then (yes)
|
|
||||||
:movie = moviesMap.get(match.movieId)\n|| match.movie;
|
|
||||||
if (movie exists?) then (yes)
|
|
||||||
:userTag = extractUserTag(movie.tags, radarrTagMap);
|
|
||||||
if (showAll OR tagMatchesUser?) then (yes)
|
|
||||||
:Build download object (type=movie)
|
|
||||||
Add coverArt, status, progress, speed, eta
|
|
||||||
Add importIssues if any
|
|
||||||
Add admin fields (paths, arrLink);
|
|
||||||
:Push to **userDownloads**;
|
|
||||||
endif
|
|
||||||
endif
|
|
||||||
endif
|
|
||||||
endwhile (no)
|
|
||||||
}
|
|
||||||
|
|
||||||
partition "Process SABnzbd History Slots" {
|
|
||||||
while (More history slots?) is (yes)
|
|
||||||
:Get slot name (nzbName);
|
|
||||||
:nzbNameLower = nzbName.toLowerCase();
|
|
||||||
|
|
||||||
if (Title matches Sonarr **history** record?) then (yes)
|
|
||||||
:series = seriesMap.get(match.seriesId)\n|| match.series;
|
|
||||||
if (series found?) then (yes)
|
|
||||||
:Check user tag, build download\n(type=series, with completedAt);
|
|
||||||
:Push to **userDownloads** if tag matches;
|
|
||||||
endif
|
|
||||||
endif
|
|
||||||
|
|
||||||
if (Title matches Radarr **history** record?) then (yes)
|
|
||||||
:movie = moviesMap.get(match.movieId)\n|| match.movie;
|
|
||||||
if (movie found?) then (yes)
|
|
||||||
:Check user tag, build download\n(type=movie, with completedAt);
|
|
||||||
:Push to **userDownloads** if tag matches;
|
|
||||||
endif
|
|
||||||
endif
|
|
||||||
endwhile (no)
|
|
||||||
}
|
|
||||||
|
|
||||||
partition "Process qBittorrent Torrents" {
|
|
||||||
while (More torrents?) is (yes)
|
|
||||||
:Get torrent name;
|
|
||||||
:torrentNameLower = name.toLowerCase();
|
|
||||||
|
|
||||||
if (Matches Sonarr **queue**?) then (yes)
|
|
||||||
:Resolve series → check tag;
|
|
||||||
:mapTorrentToDownload() + enrich;
|
|
||||||
:Push if matches → **continue**;
|
|
||||||
elseif (Matches Radarr **queue**?) then (yes)
|
|
||||||
:Resolve movie → check tag;
|
|
||||||
:mapTorrentToDownload() + enrich;
|
|
||||||
:Push if matches → **continue**;
|
|
||||||
elseif (Matches Sonarr **history**?) then (yes)
|
|
||||||
:Resolve series via seriesMap;
|
|
||||||
:mapTorrentToDownload() + enrich;
|
|
||||||
:Push if matches → **continue**;
|
|
||||||
elseif (Matches Radarr **history**?) then (yes)
|
|
||||||
:Resolve movie via moviesMap;
|
|
||||||
:mapTorrentToDownload() + enrich;
|
|
||||||
:Push if matches → **continue**;
|
|
||||||
else (no match)
|
|
||||||
:Skip torrent (unmatched);
|
|
||||||
endif
|
|
||||||
endwhile (no)
|
|
||||||
}
|
|
||||||
|
|
||||||
:Return JSON response
|
|
||||||
{ user, isAdmin, downloads: userDownloads };
|
|
||||||
|
|
||||||
stop
|
|
||||||
|
|
||||||
legend right
|
|
||||||
**Title Matching Logic**
|
|
||||||
(bidirectional substring, case-insensitive):
|
|
||||||
""rTitle.includes(dlTitle) || dlTitle.includes(rTitle)""
|
|
||||||
|
|
||||||
**Tag Matching Logic**:
|
|
||||||
1. Exact: tag.toLowerCase() === username
|
|
||||||
2. Sanitised: sanitizeTagLabel(tag) === sanitizeTagLabel(username)
|
|
||||||
(handles Ombi-mangled email-style usernames)
|
|
||||||
end legend
|
|
||||||
|
|
||||||
@enduml
|
|
||||||
@@ -1,221 +0,0 @@
|
|||||||
@startuml class-data
|
|
||||||
!theme plain
|
|
||||||
title sofarr — Data Model Diagram
|
|
||||||
|
|
||||||
skinparam classAttributeIconSize 0
|
|
||||||
|
|
||||||
package "External API Responses" {
|
|
||||||
class "SABnzbd Queue Slot" as sabq {
|
|
||||||
+ filename : string
|
|
||||||
+ nzbname : string
|
|
||||||
+ percentage : string
|
|
||||||
+ mb : string
|
|
||||||
+ mbmissing : string
|
|
||||||
+ size : string
|
|
||||||
+ timeleft : string
|
|
||||||
+ status : string
|
|
||||||
+ storage : string
|
|
||||||
}
|
|
||||||
|
|
||||||
class "SABnzbd History Slot" as sabh {
|
|
||||||
+ name : string
|
|
||||||
+ nzb_name : string
|
|
||||||
+ nzbname : string
|
|
||||||
+ status : string
|
|
||||||
+ size : string
|
|
||||||
+ completed_time : string
|
|
||||||
+ storage : string
|
|
||||||
}
|
|
||||||
|
|
||||||
class "Sonarr Queue Record" as sqr {
|
|
||||||
+ id : number
|
|
||||||
+ seriesId : number
|
|
||||||
+ series : SonarrSeries
|
|
||||||
+ title : string
|
|
||||||
+ sourceTitle : string
|
|
||||||
+ trackedDownloadStatus : string
|
|
||||||
+ trackedDownloadState : string
|
|
||||||
+ statusMessages : StatusMessage[]
|
|
||||||
+ errorMessage : string
|
|
||||||
}
|
|
||||||
|
|
||||||
class "Sonarr History Record" as shr {
|
|
||||||
+ id : number
|
|
||||||
+ seriesId : number
|
|
||||||
+ title : string
|
|
||||||
+ sourceTitle : string
|
|
||||||
+ eventType : string
|
|
||||||
}
|
|
||||||
|
|
||||||
class "SonarrSeries" as ss {
|
|
||||||
+ id : number
|
|
||||||
+ title : string
|
|
||||||
+ titleSlug : string
|
|
||||||
+ path : string
|
|
||||||
+ tags : number[]
|
|
||||||
+ images : Image[]
|
|
||||||
+ _instanceUrl : string
|
|
||||||
}
|
|
||||||
|
|
||||||
class "Radarr Queue Record" as rqr {
|
|
||||||
+ id : number
|
|
||||||
+ movieId : number
|
|
||||||
+ movie : RadarrMovie
|
|
||||||
+ title : string
|
|
||||||
+ sourceTitle : string
|
|
||||||
+ trackedDownloadStatus : string
|
|
||||||
+ trackedDownloadState : string
|
|
||||||
+ statusMessages : StatusMessage[]
|
|
||||||
+ errorMessage : string
|
|
||||||
}
|
|
||||||
|
|
||||||
class "Radarr History Record" as rhr {
|
|
||||||
+ id : number
|
|
||||||
+ movieId : number
|
|
||||||
+ title : string
|
|
||||||
+ sourceTitle : string
|
|
||||||
+ eventType : string
|
|
||||||
}
|
|
||||||
|
|
||||||
class "RadarrMovie" as rm {
|
|
||||||
+ id : number
|
|
||||||
+ title : string
|
|
||||||
+ titleSlug : string
|
|
||||||
+ path : string
|
|
||||||
+ tags : number[]
|
|
||||||
+ images : Image[]
|
|
||||||
+ _instanceUrl : string
|
|
||||||
}
|
|
||||||
|
|
||||||
class "Tag" as tag {
|
|
||||||
+ id : number
|
|
||||||
+ label : string
|
|
||||||
}
|
|
||||||
|
|
||||||
class "Image" as img {
|
|
||||||
+ coverType : string
|
|
||||||
+ remoteUrl : string
|
|
||||||
+ url : string
|
|
||||||
}
|
|
||||||
|
|
||||||
class "StatusMessage" as sm {
|
|
||||||
+ title : string
|
|
||||||
+ messages : string[]
|
|
||||||
}
|
|
||||||
|
|
||||||
class "qBittorrent Torrent" as qbt {
|
|
||||||
+ name : string
|
|
||||||
+ hash : string
|
|
||||||
+ size : number
|
|
||||||
+ completed : number
|
|
||||||
+ progress : number (0-1)
|
|
||||||
+ state : string
|
|
||||||
+ dlspeed : number
|
|
||||||
+ eta : number
|
|
||||||
+ num_seeds : number
|
|
||||||
+ num_leechs : number
|
|
||||||
+ availability : number
|
|
||||||
+ category : string
|
|
||||||
+ tags : string
|
|
||||||
+ save_path : string
|
|
||||||
+ content_path : string
|
|
||||||
+ instanceId : string
|
|
||||||
+ instanceName : string
|
|
||||||
}
|
|
||||||
|
|
||||||
class "Emby User" as eu {
|
|
||||||
+ Id : string
|
|
||||||
+ Name : string
|
|
||||||
+ Policy : { IsAdministrator: boolean }
|
|
||||||
}
|
|
||||||
|
|
||||||
sqr *-- ss : embedded\n(includeSeries)
|
|
||||||
rqr *-- rm : embedded\n(includeMovie)
|
|
||||||
sqr *-- sm
|
|
||||||
rqr *-- sm
|
|
||||||
ss *-- img
|
|
||||||
rm *-- img
|
|
||||||
}
|
|
||||||
|
|
||||||
package "sofarr Internal Models" {
|
|
||||||
class "Download Object" as dl {
|
|
||||||
+ type : 'series' | 'movie' | 'torrent'
|
|
||||||
+ title : string
|
|
||||||
+ coverArt : string | null
|
|
||||||
+ status : string
|
|
||||||
+ progress : string
|
|
||||||
+ mb : string
|
|
||||||
+ mbmissing : string
|
|
||||||
+ size : string
|
|
||||||
+ speed : string
|
|
||||||
+ eta : string
|
|
||||||
+ seriesName : string | null
|
|
||||||
+ movieName : string | null
|
|
||||||
+ episodeInfo : object | null
|
|
||||||
+ movieInfo : object | null
|
|
||||||
+ userTag : string
|
|
||||||
+ importIssues : string[] | null
|
|
||||||
+ downloadPath : string | null
|
|
||||||
+ targetPath : string | null
|
|
||||||
+ arrLink : string | null
|
|
||||||
+ qbittorrent : boolean
|
|
||||||
+ seeds : number
|
|
||||||
+ peers : number
|
|
||||||
+ availability : string
|
|
||||||
+ rawSize : number
|
|
||||||
+ rawSpeed : number
|
|
||||||
+ rawEta : number
|
|
||||||
+ hash : string
|
|
||||||
+ category : string
|
|
||||||
+ completedAt : string
|
|
||||||
}
|
|
||||||
|
|
||||||
class "API Response\n/user-downloads" as apir {
|
|
||||||
+ user : string
|
|
||||||
+ isAdmin : boolean
|
|
||||||
+ downloads : Download[]
|
|
||||||
}
|
|
||||||
|
|
||||||
class "Status Response\n/status" as statr {
|
|
||||||
+ server : ServerInfo
|
|
||||||
+ polling : PollingInfo
|
|
||||||
+ cache : CacheStats
|
|
||||||
+ clients : ClientInfo[]
|
|
||||||
}
|
|
||||||
|
|
||||||
class "ServerInfo" as si {
|
|
||||||
+ uptimeSeconds : number
|
|
||||||
+ nodeVersion : string
|
|
||||||
+ memoryUsageMB : number
|
|
||||||
+ heapUsedMB : number
|
|
||||||
+ heapTotalMB : number
|
|
||||||
}
|
|
||||||
|
|
||||||
class "PollingInfo" as pi {
|
|
||||||
+ enabled : boolean
|
|
||||||
+ intervalMs : number
|
|
||||||
+ lastPoll : PollTimings
|
|
||||||
}
|
|
||||||
|
|
||||||
class "Session Cookie\nemby_user" as cookie {
|
|
||||||
+ id : string
|
|
||||||
+ name : string
|
|
||||||
+ isAdmin : boolean
|
|
||||||
+ token : string
|
|
||||||
}
|
|
||||||
|
|
||||||
apir *-- dl
|
|
||||||
statr *-- si
|
|
||||||
statr *-- pi
|
|
||||||
}
|
|
||||||
|
|
||||||
' Data flow connections
|
|
||||||
sabq ..> dl : matched &\ntransformed
|
|
||||||
sabh ..> dl : matched &\ntransformed
|
|
||||||
qbt ..> dl : mapTorrentToDownload()
|
|
||||||
ss ..> dl : coverArt, seriesName,\npath, tags
|
|
||||||
rm ..> dl : coverArt, movieName,\npath, tags
|
|
||||||
tag ..> dl : userTag resolution
|
|
||||||
eu ..> cookie : login creates
|
|
||||||
|
|
||||||
@enduml
|
|
||||||
@@ -1,197 +0,0 @@
|
|||||||
@startuml class-server
|
|
||||||
!theme plain
|
|
||||||
title sofarr — Server Class / Module Diagram
|
|
||||||
|
|
||||||
package "server/index.js" as entry {
|
|
||||||
class "EntryPoint" as ep <<module>> {
|
|
||||||
- LOG_LEVELS : Object
|
|
||||||
- currentLevel : number
|
|
||||||
- logFile : WriteStream
|
|
||||||
+ shouldLog(level) : boolean
|
|
||||||
--
|
|
||||||
Configures Express app,
|
|
||||||
mounts routes, starts poller
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
package "server/routes" {
|
|
||||||
class "auth.js" as auth <<router>> {
|
|
||||||
+ POST /login
|
|
||||||
+ GET /me
|
|
||||||
+ POST /logout
|
|
||||||
--
|
|
||||||
Authenticates via Emby API
|
|
||||||
Sets/reads httpOnly cookie
|
|
||||||
}
|
|
||||||
|
|
||||||
class "dashboard.js" as dashboard <<router>> {
|
|
||||||
- activeClients : Map<string, ClientInfo>
|
|
||||||
- CLIENT_STALE_MS : 30000
|
|
||||||
--
|
|
||||||
+ GET /user-downloads
|
|
||||||
+ GET /user-summary
|
|
||||||
+ GET /status
|
|
||||||
--
|
|
||||||
- getCoverArt(item) : string|null
|
|
||||||
- extractUserTag(tags, tagMap) : string|null
|
|
||||||
- sanitizeTagLabel(input) : string
|
|
||||||
- tagMatchesUser(tag, username) : boolean
|
|
||||||
- getImportIssues(record) : string[]|null
|
|
||||||
- getSonarrLink(series) : string|null
|
|
||||||
- getRadarrLink(movie) : string|null
|
|
||||||
- getActiveClients() : ClientInfo[]
|
|
||||||
}
|
|
||||||
|
|
||||||
class "emby.js" as emby_r <<router>> {
|
|
||||||
+ GET /sessions
|
|
||||||
+ GET /users/:id
|
|
||||||
+ GET /users
|
|
||||||
+ GET /session/:sessionId/user
|
|
||||||
}
|
|
||||||
|
|
||||||
class "sabnzbd.js" as sab_r <<router>> {
|
|
||||||
+ GET /queue
|
|
||||||
+ GET /history
|
|
||||||
}
|
|
||||||
|
|
||||||
class "sonarr.js" as sonarr_r <<router>> {
|
|
||||||
+ GET /queue
|
|
||||||
+ GET /history
|
|
||||||
+ GET /series/:id
|
|
||||||
+ GET /series
|
|
||||||
}
|
|
||||||
|
|
||||||
class "radarr.js" as radarr_r <<router>> {
|
|
||||||
+ GET /queue
|
|
||||||
+ GET /history
|
|
||||||
+ GET /movies/:id
|
|
||||||
+ GET /movies
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
package "server/utils" {
|
|
||||||
class "MemoryCache" as cache {
|
|
||||||
- store : Map<string, CacheEntry>
|
|
||||||
+ get(key) : any|null
|
|
||||||
+ set(key, value, ttlMs) : void
|
|
||||||
+ invalidate(key) : void
|
|
||||||
+ clear() : void
|
|
||||||
+ getStats() : CacheStats
|
|
||||||
}
|
|
||||||
|
|
||||||
class "CacheEntry" as ce <<value>> {
|
|
||||||
+ value : any
|
|
||||||
+ expiresAt : number
|
|
||||||
}
|
|
||||||
|
|
||||||
class "CacheStats" as cs <<value>> {
|
|
||||||
+ entryCount : number
|
|
||||||
+ totalSizeBytes : number
|
|
||||||
+ entries : CacheEntryStats[]
|
|
||||||
}
|
|
||||||
|
|
||||||
class "Poller" as poller <<module>> {
|
|
||||||
- POLL_INTERVAL : number
|
|
||||||
- POLLING_ENABLED : boolean
|
|
||||||
- polling : boolean
|
|
||||||
- lastPollTimings : PollTimings|null
|
|
||||||
- intervalHandle : number|null
|
|
||||||
--
|
|
||||||
+ startPoller() : void
|
|
||||||
+ stopPoller() : void
|
|
||||||
+ pollAllServices() : Promise<void>
|
|
||||||
+ getLastPollTimings() : PollTimings|null
|
|
||||||
--
|
|
||||||
- timed(label, fn) : TimedResult
|
|
||||||
}
|
|
||||||
|
|
||||||
class "PollTimings" as pt <<value>> {
|
|
||||||
+ totalMs : number
|
|
||||||
+ timestamp : string (ISO)
|
|
||||||
+ tasks : { label, ms }[]
|
|
||||||
}
|
|
||||||
|
|
||||||
class "Config" as config <<module>> {
|
|
||||||
+ getSABnzbdInstances() : Instance[]
|
|
||||||
+ getSonarrInstances() : Instance[]
|
|
||||||
+ getRadarrInstances() : Instance[]
|
|
||||||
+ getQbittorrentInstances() : Instance[]
|
|
||||||
--
|
|
||||||
- parseInstances(envVar, ...) : Instance[]
|
|
||||||
}
|
|
||||||
|
|
||||||
class "Instance" as inst <<value>> {
|
|
||||||
+ id : string
|
|
||||||
+ name : string
|
|
||||||
+ url : string
|
|
||||||
+ apiKey : string
|
|
||||||
+ username? : string
|
|
||||||
+ password? : string
|
|
||||||
}
|
|
||||||
|
|
||||||
class "QBittorrentClient" as qbt {
|
|
||||||
- id : string
|
|
||||||
- name : string
|
|
||||||
- url : string
|
|
||||||
- username : string
|
|
||||||
- password : string
|
|
||||||
- authCookie : string|null
|
|
||||||
--
|
|
||||||
+ login() : Promise<boolean>
|
|
||||||
+ makeRequest(endpoint, config) : Promise<Response>
|
|
||||||
+ getTorrents() : Promise<Torrent[]>
|
|
||||||
}
|
|
||||||
|
|
||||||
class "qbittorrent.js" as qbt_mod <<module>> {
|
|
||||||
- persistedClients : QBittorrentClient[]|null
|
|
||||||
--
|
|
||||||
+ getTorrents() : Promise<Torrent[]>
|
|
||||||
+ getClients() : QBittorrentClient[]
|
|
||||||
+ mapTorrentToDownload(torrent) : Download
|
|
||||||
+ formatBytes(bytes) : string
|
|
||||||
+ formatSpeed(bps) : string
|
|
||||||
+ formatEta(seconds) : string
|
|
||||||
}
|
|
||||||
|
|
||||||
class "Logger" as logger <<module>> {
|
|
||||||
- logFile : WriteStream
|
|
||||||
+ logToFile(message) : void
|
|
||||||
}
|
|
||||||
|
|
||||||
class "ClientInfo" as ci <<value>> {
|
|
||||||
+ user : string
|
|
||||||
+ refreshRateMs : number
|
|
||||||
+ lastSeen : number (timestamp)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
' Relationships
|
|
||||||
ep --> auth
|
|
||||||
ep --> dashboard
|
|
||||||
ep --> emby_r
|
|
||||||
ep --> sab_r
|
|
||||||
ep --> sonarr_r
|
|
||||||
ep --> radarr_r
|
|
||||||
ep --> poller : startPoller()
|
|
||||||
|
|
||||||
dashboard --> cache : read/write
|
|
||||||
dashboard --> poller : pollAllServices()
|
|
||||||
dashboard --> qbt_mod : mapTorrentToDownload()
|
|
||||||
dashboard --> config
|
|
||||||
|
|
||||||
poller --> cache : set poll:* keys
|
|
||||||
poller --> config : get instances
|
|
||||||
poller --> qbt_mod : getTorrents()
|
|
||||||
|
|
||||||
qbt_mod --> config : getQbittorrentInstances()
|
|
||||||
qbt_mod *-- qbt : creates
|
|
||||||
qbt --> logger
|
|
||||||
|
|
||||||
cache *-- ce : stores
|
|
||||||
cache ..> cs : returns from getStats()
|
|
||||||
poller ..> pt : stores/returns
|
|
||||||
dashboard *-- ci : stores in activeClients
|
|
||||||
|
|
||||||
config ..> inst : returns
|
|
||||||
|
|
||||||
@enduml
|
|
||||||
@@ -1,94 +0,0 @@
|
|||||||
@startuml component
|
|
||||||
!theme plain
|
|
||||||
title sofarr — Component Diagram
|
|
||||||
|
|
||||||
skinparam componentStyle rectangle
|
|
||||||
skinparam packageStyle frame
|
|
||||||
|
|
||||||
package "Browser" as browser {
|
|
||||||
[index.html] as html
|
|
||||||
[app.js] as appjs
|
|
||||||
[style.css] as css
|
|
||||||
html ..> appjs : loads
|
|
||||||
html ..> css : loads
|
|
||||||
}
|
|
||||||
|
|
||||||
package "Express Server" as server {
|
|
||||||
|
|
||||||
package "Middleware" {
|
|
||||||
[CORS] as cors
|
|
||||||
[cookie-parser] as cp
|
|
||||||
[express.json] as ej
|
|
||||||
[express.static] as es
|
|
||||||
}
|
|
||||||
|
|
||||||
package "Routes" as routes {
|
|
||||||
[auth.js\n/api/auth] as auth
|
|
||||||
[dashboard.js\n/api/dashboard] as dashboard
|
|
||||||
[emby.js\n/api/emby] as emby_route
|
|
||||||
[sabnzbd.js\n/api/sabnzbd] as sab_route
|
|
||||||
[sonarr.js\n/api/sonarr] as sonarr_route
|
|
||||||
[radarr.js\n/api/radarr] as radarr_route
|
|
||||||
}
|
|
||||||
|
|
||||||
package "Utilities" as utils {
|
|
||||||
[poller.js] as poller
|
|
||||||
[cache.js\nMemoryCache] as cache
|
|
||||||
[config.js] as config
|
|
||||||
[qbittorrent.js\nQBittorrentClient] as qbt
|
|
||||||
[logger.js] as logger
|
|
||||||
}
|
|
||||||
|
|
||||||
[index.js\nEntry Point] as entry
|
|
||||||
|
|
||||||
entry --> cors
|
|
||||||
entry --> cp
|
|
||||||
entry --> ej
|
|
||||||
entry --> es
|
|
||||||
entry --> auth
|
|
||||||
entry --> dashboard
|
|
||||||
entry --> emby_route
|
|
||||||
entry --> sab_route
|
|
||||||
entry --> sonarr_route
|
|
||||||
entry --> radarr_route
|
|
||||||
entry --> poller : startPoller()
|
|
||||||
|
|
||||||
dashboard --> cache : read poll:* keys
|
|
||||||
dashboard --> poller : pollAllServices()\n(on-demand mode)
|
|
||||||
dashboard --> config : getSonarrInstances()\ngetRadarrInstances()
|
|
||||||
dashboard --> qbt : mapTorrentToDownload()
|
|
||||||
|
|
||||||
poller --> cache : set poll:* keys
|
|
||||||
poller --> config : get all instances
|
|
||||||
poller --> qbt : getTorrents()
|
|
||||||
poller --> logger
|
|
||||||
|
|
||||||
qbt --> config : getQbittorrentInstances()
|
|
||||||
qbt --> logger
|
|
||||||
}
|
|
||||||
|
|
||||||
cloud "External Services" as external {
|
|
||||||
[Emby / Jellyfin] as emby
|
|
||||||
[SABnzbd] as sab
|
|
||||||
[Sonarr] as sonarr
|
|
||||||
[Radarr] as radarr
|
|
||||||
[qBittorrent] as qbit
|
|
||||||
}
|
|
||||||
|
|
||||||
auth --> emby : authenticate\nuser profile
|
|
||||||
dashboard ..> emby : /user-summary\n(live fetch)
|
|
||||||
emby_route --> emby
|
|
||||||
sab_route --> sab
|
|
||||||
sonarr_route --> sonarr
|
|
||||||
radarr_route --> radarr
|
|
||||||
|
|
||||||
poller --> sab : queue + history
|
|
||||||
poller --> sonarr : tags + queue + history
|
|
||||||
poller --> radarr : tags + queue + history
|
|
||||||
qbt --> qbit : login + torrents/info
|
|
||||||
|
|
||||||
appjs --> auth : POST /login\nGET /me
|
|
||||||
appjs --> dashboard : GET /user-downloads\nGET /status
|
|
||||||
es --> html : serve static
|
|
||||||
|
|
||||||
@enduml
|
|
||||||
@@ -1,67 +0,0 @@
|
|||||||
@startuml seq-auth
|
|
||||||
!theme plain
|
|
||||||
title sofarr — Authentication Sequence
|
|
||||||
|
|
||||||
actor User as user
|
|
||||||
participant "Browser\n(app.js)" as browser
|
|
||||||
participant "Express\n/api/auth" as auth
|
|
||||||
participant "Emby\nServer" as emby
|
|
||||||
|
|
||||||
== Page Load ==
|
|
||||||
user -> browser : Navigate to sofarr
|
|
||||||
activate browser
|
|
||||||
browser -> auth : GET /api/auth/me
|
|
||||||
activate auth
|
|
||||||
auth -> auth : Read emby_user cookie
|
|
||||||
alt Cookie exists and valid
|
|
||||||
auth --> browser : { authenticated: true, user: { name, isAdmin } }
|
|
||||||
browser -> browser : showDashboard()
|
|
||||||
browser -> browser : fetchUserDownloads(true)
|
|
||||||
browser -> browser : startAutoRefresh()
|
|
||||||
browser -> browser : dismissSplash()
|
|
||||||
else No cookie
|
|
||||||
auth --> browser : { authenticated: false }
|
|
||||||
browser -> browser : dismissSplash()
|
|
||||||
browser -> browser : showLogin()
|
|
||||||
end
|
|
||||||
deactivate auth
|
|
||||||
|
|
||||||
== Login ==
|
|
||||||
user -> browser : Enter username + password
|
|
||||||
browser -> auth : POST /api/auth/login\n{ username, password }
|
|
||||||
activate auth
|
|
||||||
auth -> emby : POST /Users/authenticatebyname\n{ Username, Pw }
|
|
||||||
activate emby
|
|
||||||
alt Valid credentials
|
|
||||||
emby --> auth : { User: { Id, ... }, AccessToken }
|
|
||||||
auth -> emby : GET /Users/{userId}
|
|
||||||
emby --> auth : { Name, Policy: { IsAdministrator } }
|
|
||||||
deactivate emby
|
|
||||||
auth -> auth : Set httpOnly cookie\nemby_user = { id, name, isAdmin, token }\n(24h TTL)
|
|
||||||
auth --> browser : { success: true, user: { name, isAdmin } }
|
|
||||||
browser -> browser : fadeOutLogin()
|
|
||||||
browser -> browser : showSplash()
|
|
||||||
browser -> browser : showDashboard()
|
|
||||||
browser -> browser : fetchUserDownloads(true)
|
|
||||||
browser -> browser : startAutoRefresh()
|
|
||||||
browser -> browser : dismissSplash()
|
|
||||||
else Invalid credentials
|
|
||||||
emby --> auth : 401 Error
|
|
||||||
deactivate emby
|
|
||||||
auth --> browser : { success: false, error: "Invalid..." }
|
|
||||||
browser -> browser : showLoginError()
|
|
||||||
end
|
|
||||||
deactivate auth
|
|
||||||
|
|
||||||
== Logout ==
|
|
||||||
user -> browser : Click Logout
|
|
||||||
browser -> browser : stopAutoRefresh()
|
|
||||||
browser -> auth : POST /api/auth/logout
|
|
||||||
activate auth
|
|
||||||
auth -> auth : Clear emby_user cookie
|
|
||||||
auth --> browser : { success: true }
|
|
||||||
deactivate auth
|
|
||||||
browser -> browser : showLogin()
|
|
||||||
|
|
||||||
deactivate browser
|
|
||||||
@enduml
|
|
||||||
@@ -1,85 +0,0 @@
|
|||||||
@startuml seq-dashboard
|
|
||||||
!theme plain
|
|
||||||
title sofarr — Dashboard Request Sequence
|
|
||||||
|
|
||||||
actor User as user
|
|
||||||
participant "Browser\n(app.js)" as browser
|
|
||||||
participant "Express\n/api/dashboard" as dashboard
|
|
||||||
participant "MemoryCache" as cache
|
|
||||||
participant "Poller" as poller
|
|
||||||
participant "External\nServices" as ext
|
|
||||||
|
|
||||||
== Periodic Refresh (or Initial Load) ==
|
|
||||||
user -> browser : (auto-refresh fires)
|
|
||||||
activate browser
|
|
||||||
browser -> dashboard : GET /api/dashboard/user-downloads\n?refreshRate=5000&showAll=false
|
|
||||||
activate dashboard
|
|
||||||
|
|
||||||
dashboard -> dashboard : Parse emby_user cookie\nExtract username, isAdmin
|
|
||||||
dashboard -> dashboard : Track client refresh rate\nin activeClients Map
|
|
||||||
|
|
||||||
alt Polling disabled AND cache empty
|
|
||||||
dashboard -> poller : pollAllServices()
|
|
||||||
activate poller
|
|
||||||
poller -> ext : Parallel API calls\n(SAB, Sonarr, Radarr, qBit)
|
|
||||||
ext --> poller : Raw data
|
|
||||||
poller -> cache : set poll:* keys\n(TTL = 30s)
|
|
||||||
deactivate poller
|
|
||||||
end
|
|
||||||
|
|
||||||
dashboard -> cache : get('poll:sab-queue')
|
|
||||||
cache --> dashboard : { slots, status, speed }
|
|
||||||
dashboard -> cache : get('poll:sab-history')
|
|
||||||
cache --> dashboard : { slots }
|
|
||||||
dashboard -> cache : get('poll:sonarr-tags')
|
|
||||||
cache --> dashboard : [{ instance, data }]
|
|
||||||
dashboard -> cache : get('poll:sonarr-queue')
|
|
||||||
cache --> dashboard : { records } (with embedded series)
|
|
||||||
dashboard -> cache : get('poll:sonarr-history')
|
|
||||||
cache --> dashboard : { records }
|
|
||||||
dashboard -> cache : get('poll:radarr-queue')
|
|
||||||
cache --> dashboard : { records } (with embedded movie)
|
|
||||||
dashboard -> cache : get('poll:radarr-history')
|
|
||||||
cache --> dashboard : { records }
|
|
||||||
dashboard -> cache : get('poll:radarr-tags')
|
|
||||||
cache --> dashboard : [{id, label}]
|
|
||||||
dashboard -> cache : get('poll:qbittorrent')
|
|
||||||
cache --> dashboard : [torrent, ...]
|
|
||||||
|
|
||||||
dashboard -> dashboard : Build seriesMap from\nSonarr queue records
|
|
||||||
dashboard -> dashboard : Build moviesMap from\nRadarr queue records
|
|
||||||
dashboard -> dashboard : Build tag maps\n(id → label)
|
|
||||||
|
|
||||||
group SABnzbd Queue Matching
|
|
||||||
loop each queue slot
|
|
||||||
dashboard -> dashboard : Match title vs Sonarr queue
|
|
||||||
dashboard -> dashboard : Match title vs Radarr queue
|
|
||||||
dashboard -> dashboard : Resolve series/movie\n→ extract user tag\n→ filter by username
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
group SABnzbd History Matching
|
|
||||||
loop each history slot
|
|
||||||
dashboard -> dashboard : Match title vs Sonarr history
|
|
||||||
dashboard -> dashboard : Match title vs Radarr history
|
|
||||||
dashboard -> dashboard : Resolve via seriesMap/moviesMap\n→ extract user tag\n→ filter
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
group qBittorrent Matching
|
|
||||||
loop each torrent
|
|
||||||
dashboard -> dashboard : 1. Match vs Sonarr queue
|
|
||||||
dashboard -> dashboard : 2. Match vs Radarr queue
|
|
||||||
dashboard -> dashboard : 3. Match vs Sonarr history
|
|
||||||
dashboard -> dashboard : 4. Match vs Radarr history
|
|
||||||
dashboard -> dashboard : mapTorrentToDownload()\n→ enrich with series/movie info
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
dashboard --> browser : { user, isAdmin,\ndownloads: [...] }
|
|
||||||
deactivate dashboard
|
|
||||||
|
|
||||||
browser -> browser : renderDownloads()\n(diff-based update)
|
|
||||||
deactivate browser
|
|
||||||
|
|
||||||
@enduml
|
|
||||||
@@ -1,89 +0,0 @@
|
|||||||
@startuml seq-polling
|
|
||||||
!theme plain
|
|
||||||
title sofarr — Background Polling Cycle
|
|
||||||
|
|
||||||
participant "index.js\n(startup)" as entry
|
|
||||||
participant "Poller" as poller
|
|
||||||
participant "Config" as config
|
|
||||||
participant "SABnzbd\n(per instance)" as sab
|
|
||||||
participant "Sonarr\n(per instance)" as sonarr
|
|
||||||
participant "Radarr\n(per instance)" as radarr
|
|
||||||
participant "qBittorrent\nClient" as qbt
|
|
||||||
participant "MemoryCache" as cache
|
|
||||||
|
|
||||||
== Startup ==
|
|
||||||
entry -> poller : startPoller()
|
|
||||||
activate poller
|
|
||||||
|
|
||||||
alt POLL_INTERVAL > 0
|
|
||||||
poller -> poller : pollAllServices() (immediate)
|
|
||||||
poller -> poller : setInterval(pollAllServices,\nPOLL_INTERVAL)
|
|
||||||
else POLL_INTERVAL = 0
|
|
||||||
poller --> entry : "Polling disabled, on-demand mode"
|
|
||||||
end
|
|
||||||
|
|
||||||
== Poll Cycle ==
|
|
||||||
poller -> poller : Check: polling flag?\n(skip if concurrent)
|
|
||||||
poller -> poller : polling = true
|
|
||||||
poller -> poller : start = Date.now()
|
|
||||||
|
|
||||||
poller -> config : getSABnzbdInstances()
|
|
||||||
config --> poller : [{ id, url, apiKey }]
|
|
||||||
poller -> config : getSonarrInstances()
|
|
||||||
config --> poller : [{ id, url, apiKey }]
|
|
||||||
poller -> config : getRadarrInstances()
|
|
||||||
config --> poller : [{ id, url, apiKey }]
|
|
||||||
|
|
||||||
note over poller : All fetches run in\nparallel via Promise.all,\neach wrapped in timed()
|
|
||||||
|
|
||||||
par SABnzbd Queue
|
|
||||||
poller -> sab : GET /api?mode=queue
|
|
||||||
sab --> poller : { queue: { slots, status, speed } }
|
|
||||||
and SABnzbd History
|
|
||||||
poller -> sab : GET /api?mode=history&limit=10
|
|
||||||
sab --> poller : { history: { slots } }
|
|
||||||
and Sonarr Tags
|
|
||||||
poller -> sonarr : GET /api/v3/tag
|
|
||||||
sonarr --> poller : [{ id, label }]
|
|
||||||
and Sonarr Queue
|
|
||||||
poller -> sonarr : GET /api/v3/queue\n?includeSeries=true
|
|
||||||
sonarr --> poller : { records: [{ seriesId, series, ... }] }
|
|
||||||
and Sonarr History
|
|
||||||
poller -> sonarr : GET /api/v3/history\n?pageSize=10
|
|
||||||
sonarr --> poller : { records: [{ seriesId, ... }] }
|
|
||||||
and Radarr Queue
|
|
||||||
poller -> radarr : GET /api/v3/queue\n?includeMovie=true
|
|
||||||
radarr --> poller : { records: [{ movieId, movie, ... }] }
|
|
||||||
and Radarr History
|
|
||||||
poller -> radarr : GET /api/v3/history\n?pageSize=10
|
|
||||||
radarr --> poller : { records: [{ movieId, ... }] }
|
|
||||||
and Radarr Tags
|
|
||||||
poller -> radarr : GET /api/v3/tag
|
|
||||||
radarr --> poller : [{ id, label }]
|
|
||||||
and qBittorrent
|
|
||||||
poller -> qbt : getTorrents()
|
|
||||||
qbt --> poller : [{ name, progress, ... }]
|
|
||||||
end
|
|
||||||
|
|
||||||
poller -> poller : Record per-task timings\nlastPollTimings = { totalMs,\ntimestamp, tasks: [{label, ms}] }
|
|
||||||
|
|
||||||
poller -> poller : cacheTTL = POLL_INTERVAL × 3
|
|
||||||
|
|
||||||
poller -> cache : set('poll:sab-queue', ..., cacheTTL)
|
|
||||||
poller -> cache : set('poll:sab-history', ..., cacheTTL)
|
|
||||||
poller -> cache : set('poll:sonarr-tags', ..., cacheTTL)
|
|
||||||
|
|
||||||
note over poller : Tag queue records with\n_instanceUrl on embedded\nseries/movie objects
|
|
||||||
|
|
||||||
poller -> cache : set('poll:sonarr-queue', ..., cacheTTL)
|
|
||||||
poller -> cache : set('poll:sonarr-history', ..., cacheTTL)
|
|
||||||
poller -> cache : set('poll:radarr-queue', ..., cacheTTL)
|
|
||||||
poller -> cache : set('poll:radarr-history', ..., cacheTTL)
|
|
||||||
poller -> cache : set('poll:radarr-tags', ..., cacheTTL)
|
|
||||||
poller -> cache : set('poll:qbittorrent', ..., cacheTTL)
|
|
||||||
|
|
||||||
poller -> poller : polling = false\nlog elapsed time
|
|
||||||
|
|
||||||
deactivate poller
|
|
||||||
|
|
||||||
@enduml
|
|
||||||
@@ -1,65 +0,0 @@
|
|||||||
@startuml state-poller
|
|
||||||
!theme plain
|
|
||||||
title sofarr — Poller State Diagram
|
|
||||||
|
|
||||||
[*] --> CheckConfig : startPoller()
|
|
||||||
|
|
||||||
state CheckConfig <<choice>>
|
|
||||||
CheckConfig --> Disabled : POLL_INTERVAL = 0\nor 'off' / 'false'
|
|
||||||
CheckConfig --> Idle : POLL_INTERVAL > 0
|
|
||||||
|
|
||||||
state Disabled {
|
|
||||||
state "On-demand mode\nNo background timer" as od
|
|
||||||
od : Data fetched only when\na dashboard request\nfinds empty cache
|
|
||||||
}
|
|
||||||
|
|
||||||
Disabled --> Polling : pollAllServices()\n(triggered by dashboard request)
|
|
||||||
Polling --> Disabled : Poll complete\n(return to on-demand)
|
|
||||||
|
|
||||||
state Idle {
|
|
||||||
state "Waiting for\nnext interval" as waiting
|
|
||||||
}
|
|
||||||
|
|
||||||
Idle --> Polling : setInterval fires\nor immediate first poll
|
|
||||||
|
|
||||||
state Polling {
|
|
||||||
state "polling = true" as lock
|
|
||||||
state "Fetching all services\n(Promise.all)" as fetching
|
|
||||||
state "Storing results\nin cache" as storing
|
|
||||||
state "Recording timings" as timing
|
|
||||||
|
|
||||||
[*] --> lock
|
|
||||||
lock --> fetching
|
|
||||||
fetching --> storing : All promises resolved
|
|
||||||
fetching --> ErrorState : Any individual service\nerror (caught per-service)
|
|
||||||
storing --> timing
|
|
||||||
timing --> [*] : polling = false
|
|
||||||
}
|
|
||||||
|
|
||||||
state ErrorState as "Handle Error" {
|
|
||||||
state "Log error\npolling = false" as err
|
|
||||||
}
|
|
||||||
|
|
||||||
ErrorState --> Idle : Next interval
|
|
||||||
Polling --> Idle : Poll complete\n(back to waiting)
|
|
||||||
|
|
||||||
state "Concurrent Poll\nAttempt" as skip {
|
|
||||||
state "polling === true\n→ skip" as sk
|
|
||||||
}
|
|
||||||
|
|
||||||
Idle --> skip : Interval fires while\nprevious still running
|
|
||||||
skip --> Idle : Log "still running,\nskipping"
|
|
||||||
|
|
||||||
note right of Polling
|
|
||||||
**Cache TTL**: POLL_INTERVAL × 3
|
|
||||||
Ensures data survives between polls
|
|
||||||
even if one cycle is slow.
|
|
||||||
end note
|
|
||||||
|
|
||||||
note right of Disabled
|
|
||||||
**Cache TTL**: 30000ms (30s)
|
|
||||||
After expiry, next dashboard
|
|
||||||
request triggers a fresh poll.
|
|
||||||
end note
|
|
||||||
|
|
||||||
@enduml
|
|
||||||
@@ -1,79 +0,0 @@
|
|||||||
@startuml state-ui
|
|
||||||
!theme plain
|
|
||||||
title sofarr — Frontend UI State Diagram
|
|
||||||
|
|
||||||
[*] --> SplashScreen : Page load
|
|
||||||
|
|
||||||
state SplashScreen {
|
|
||||||
state "Showing splash\n(min 1.2s)" as showing
|
|
||||||
}
|
|
||||||
|
|
||||||
SplashScreen --> CheckAuth : checkAuthentication()
|
|
||||||
|
|
||||||
state CheckAuth <<choice>>
|
|
||||||
CheckAuth --> LoginForm : No session cookie
|
|
||||||
CheckAuth --> Dashboard : Valid session
|
|
||||||
|
|
||||||
state LoginForm {
|
|
||||||
state "Idle" as lf_idle
|
|
||||||
state "Submitting" as lf_submit
|
|
||||||
state "Error" as lf_error
|
|
||||||
|
|
||||||
lf_idle --> lf_submit : Submit form
|
|
||||||
lf_submit --> lf_error : Auth failed
|
|
||||||
lf_error --> lf_submit : Re-submit
|
|
||||||
lf_submit --> FadeOutLogin : Auth success
|
|
||||||
}
|
|
||||||
|
|
||||||
state FadeOutLogin {
|
|
||||||
state "CSS transition\n(opacity → 0)" as fade
|
|
||||||
}
|
|
||||||
|
|
||||||
FadeOutLogin --> SplashScreen2 : Show splash\nwhile loading
|
|
||||||
|
|
||||||
state SplashScreen2 as "Splash (loading data)" {
|
|
||||||
state "fetchUserDownloads()" as fetching
|
|
||||||
}
|
|
||||||
|
|
||||||
SplashScreen2 --> Dashboard : Data loaded\ndismissSplash()
|
|
||||||
|
|
||||||
state Dashboard {
|
|
||||||
state "Rendering Cards" as rendering
|
|
||||||
state "Auto Refreshing" as refreshing
|
|
||||||
state "Status Panel Open" as status_open
|
|
||||||
state "Status Panel Closed" as status_closed
|
|
||||||
|
|
||||||
[*] --> rendering
|
|
||||||
rendering --> refreshing : startAutoRefresh()
|
|
||||||
refreshing --> rendering : fetchUserDownloads()\n→ renderDownloads()
|
|
||||||
rendering --> rendering : Theme change
|
|
||||||
|
|
||||||
status_closed --> status_open : Click "Status" btn\n(admin only)
|
|
||||||
status_open --> status_closed : Click close (×)
|
|
||||||
status_open --> status_open : Auto-refresh\nrenderStatusPanel()
|
|
||||||
|
|
||||||
[*] --> status_closed
|
|
||||||
|
|
||||||
state "Refresh Rate" as rr {
|
|
||||||
state "1s" as r1
|
|
||||||
state "5s (default)" as r5
|
|
||||||
state "10s" as r10
|
|
||||||
state "Off" as roff
|
|
||||||
r5 --> r1 : User selects
|
|
||||||
r5 --> r10
|
|
||||||
r5 --> roff
|
|
||||||
r1 --> r5
|
|
||||||
r1 --> r10
|
|
||||||
r1 --> roff
|
|
||||||
r10 --> r1
|
|
||||||
r10 --> r5
|
|
||||||
r10 --> roff
|
|
||||||
roff --> r1
|
|
||||||
roff --> r5
|
|
||||||
roff --> r10
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
Dashboard --> LoginForm : Logout\n(clear cookie,\nstopAutoRefresh)
|
|
||||||
|
|
||||||
@enduml
|
|
||||||
+1
-1
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "sofarr",
|
"name": "sofarr",
|
||||||
"version": "0.1.3",
|
"version": "0.1.2",
|
||||||
"description": "A personal media download dashboard that shows your downloads 'so far' while you relax on the sofa waiting for your *arr services to finish",
|
"description": "A personal media download dashboard that shows your downloads 'so far' while you relax on the sofa waiting for your *arr services to finish",
|
||||||
"main": "server/index.js",
|
"main": "server/index.js",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
|
|||||||
+5
-235
@@ -4,7 +4,6 @@ let refreshInterval = null;
|
|||||||
let currentRefreshRate = 5000; // default 5 seconds
|
let currentRefreshRate = 5000; // default 5 seconds
|
||||||
let isAdmin = false;
|
let isAdmin = false;
|
||||||
let showAll = false;
|
let showAll = false;
|
||||||
const SPLASH_MIN_MS = 1200; // minimum splash display time
|
|
||||||
|
|
||||||
// Apply saved theme immediately (before DOMContentLoaded to avoid flash)
|
// Apply saved theme immediately (before DOMContentLoaded to avoid flash)
|
||||||
(function() {
|
(function() {
|
||||||
@@ -21,7 +20,6 @@ document.addEventListener('DOMContentLoaded', () => {
|
|||||||
document.getElementById('logout-btn').addEventListener('click', handleLogout);
|
document.getElementById('logout-btn').addEventListener('click', handleLogout);
|
||||||
document.getElementById('refresh-rate').addEventListener('change', handleRefreshRateChange);
|
document.getElementById('refresh-rate').addEventListener('change', handleRefreshRateChange);
|
||||||
document.getElementById('show-all-toggle').addEventListener('change', handleShowAllToggle);
|
document.getElementById('show-all-toggle').addEventListener('change', handleShowAllToggle);
|
||||||
document.getElementById('status-btn').addEventListener('click', toggleStatusPanel);
|
|
||||||
});
|
});
|
||||||
|
|
||||||
function initThemeSwitcher() {
|
function initThemeSwitcher() {
|
||||||
@@ -51,14 +49,6 @@ function handleRefreshRateChange(e) {
|
|||||||
const rate = parseInt(e.target.value);
|
const rate = parseInt(e.target.value);
|
||||||
currentRefreshRate = rate;
|
currentRefreshRate = rate;
|
||||||
startAutoRefresh();
|
startAutoRefresh();
|
||||||
// Restart status panel refresh if it's open
|
|
||||||
const statusPanel = document.getElementById('status-panel');
|
|
||||||
if (statusPanel && statusPanel.style.display !== 'none') {
|
|
||||||
if (statusRefreshHandle) { clearInterval(statusRefreshHandle); statusRefreshHandle = null; }
|
|
||||||
if (currentRefreshRate > 0) {
|
|
||||||
statusRefreshHandle = setInterval(refreshStatusPanel, currentRefreshRate);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
function handleShowAllToggle(e) {
|
function handleShowAllToggle(e) {
|
||||||
@@ -73,42 +63,7 @@ function stopAutoRefresh() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
function fadeOutLogin() {
|
|
||||||
return new Promise(resolve => {
|
|
||||||
const login = document.getElementById('login-container');
|
|
||||||
login.classList.add('fade-out');
|
|
||||||
login.addEventListener('transitionend', () => {
|
|
||||||
login.style.display = 'none';
|
|
||||||
login.classList.remove('fade-out');
|
|
||||||
resolve();
|
|
||||||
}, { once: true });
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
function showSplash() {
|
|
||||||
const splash = document.getElementById('splash-screen');
|
|
||||||
splash.style.display = 'flex';
|
|
||||||
splash.style.opacity = '1';
|
|
||||||
splash.classList.remove('fade-out');
|
|
||||||
}
|
|
||||||
|
|
||||||
function dismissSplash(startTime) {
|
|
||||||
return new Promise(resolve => {
|
|
||||||
const elapsed = Date.now() - (startTime || 0);
|
|
||||||
const remaining = Math.max(0, SPLASH_MIN_MS - elapsed);
|
|
||||||
setTimeout(() => {
|
|
||||||
const splash = document.getElementById('splash-screen');
|
|
||||||
splash.classList.add('fade-out');
|
|
||||||
splash.addEventListener('transitionend', () => {
|
|
||||||
splash.style.display = 'none';
|
|
||||||
resolve();
|
|
||||||
}, { once: true });
|
|
||||||
}, remaining);
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
async function checkAuthentication() {
|
async function checkAuthentication() {
|
||||||
const splashStart = Date.now();
|
|
||||||
try {
|
try {
|
||||||
const response = await fetch('/api/auth/me');
|
const response = await fetch('/api/auth/me');
|
||||||
const data = await response.json();
|
const data = await response.json();
|
||||||
@@ -117,16 +72,13 @@ async function checkAuthentication() {
|
|||||||
currentUser = data.user;
|
currentUser = data.user;
|
||||||
isAdmin = !!data.user.isAdmin;
|
isAdmin = !!data.user.isAdmin;
|
||||||
showDashboard();
|
showDashboard();
|
||||||
await fetchUserDownloads(true);
|
fetchUserDownloads(true);
|
||||||
startAutoRefresh();
|
startAutoRefresh();
|
||||||
await dismissSplash(splashStart);
|
|
||||||
} else {
|
} else {
|
||||||
await dismissSplash(splashStart);
|
|
||||||
showLogin();
|
showLogin();
|
||||||
}
|
}
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
console.error('Authentication check failed:', err);
|
console.error('Authentication check failed:', err);
|
||||||
await dismissSplash(splashStart);
|
|
||||||
showLogin();
|
showLogin();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -151,14 +103,9 @@ async function handleLogin(e) {
|
|||||||
if (data.success) {
|
if (data.success) {
|
||||||
currentUser = data.user;
|
currentUser = data.user;
|
||||||
isAdmin = !!data.user.isAdmin;
|
isAdmin = !!data.user.isAdmin;
|
||||||
// Fade out login, then show splash while loading data
|
|
||||||
await fadeOutLogin();
|
|
||||||
showSplash();
|
|
||||||
showDashboard();
|
showDashboard();
|
||||||
const splashStart = Date.now();
|
fetchUserDownloads(true);
|
||||||
await fetchUserDownloads(true);
|
|
||||||
startAutoRefresh();
|
startAutoRefresh();
|
||||||
await dismissSplash(splashStart);
|
|
||||||
} else {
|
} else {
|
||||||
showLoginError(data.error || 'Login failed');
|
showLoginError(data.error || 'Login failed');
|
||||||
}
|
}
|
||||||
@@ -213,10 +160,7 @@ async function fetchUserDownloads(isInitialLoad = false) {
|
|||||||
hideError();
|
hideError();
|
||||||
|
|
||||||
try {
|
try {
|
||||||
const params = new URLSearchParams();
|
const url = showAll ? '/api/dashboard/user-downloads?showAll=true' : '/api/dashboard/user-downloads';
|
||||||
if (showAll) params.set('showAll', 'true');
|
|
||||||
params.set('refreshRate', currentRefreshRate);
|
|
||||||
const url = '/api/dashboard/user-downloads?' + params.toString();
|
|
||||||
const response = await fetch(url);
|
const response = await fetch(url);
|
||||||
const data = await response.json();
|
const data = await response.json();
|
||||||
|
|
||||||
@@ -396,14 +340,6 @@ function createDownloadCard(download) {
|
|||||||
|
|
||||||
header.appendChild(type);
|
header.appendChild(type);
|
||||||
header.appendChild(status);
|
header.appendChild(status);
|
||||||
|
|
||||||
if (download.importIssues && download.importIssues.length > 0) {
|
|
||||||
const issueBadge = document.createElement('span');
|
|
||||||
issueBadge.className = 'import-issue-badge';
|
|
||||||
issueBadge.textContent = 'Import Pending';
|
|
||||||
issueBadge.setAttribute('data-tooltip', download.importIssues.join('\n'));
|
|
||||||
header.appendChild(issueBadge);
|
|
||||||
}
|
|
||||||
|
|
||||||
const title = document.createElement('h3');
|
const title = document.createElement('h3');
|
||||||
title.className = 'download-title';
|
title.className = 'download-title';
|
||||||
@@ -415,22 +351,14 @@ function createDownloadCard(download) {
|
|||||||
if (download.seriesName) {
|
if (download.seriesName) {
|
||||||
const series = document.createElement('p');
|
const series = document.createElement('p');
|
||||||
series.className = 'download-series';
|
series.className = 'download-series';
|
||||||
if (isAdmin && download.arrLink) {
|
series.textContent = `Series: ${download.seriesName}`;
|
||||||
series.innerHTML = 'Series: <a href="' + escapeHtml(download.arrLink) + '" target="_blank" class="arr-link">' + escapeHtml(download.seriesName) + '</a>';
|
|
||||||
} else {
|
|
||||||
series.textContent = `Series: ${download.seriesName}`;
|
|
||||||
}
|
|
||||||
infoDiv.appendChild(series);
|
infoDiv.appendChild(series);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (download.movieName) {
|
if (download.movieName) {
|
||||||
const movie = document.createElement('p');
|
const movie = document.createElement('p');
|
||||||
movie.className = 'download-movie';
|
movie.className = 'download-movie';
|
||||||
if (isAdmin && download.arrLink) {
|
movie.textContent = `Movie: ${download.movieName}`;
|
||||||
movie.innerHTML = 'Movie: <a href="' + escapeHtml(download.arrLink) + '" target="_blank" class="arr-link">' + escapeHtml(download.movieName) + '</a>';
|
|
||||||
} else {
|
|
||||||
movie.textContent = `Movie: ${download.movieName}`;
|
|
||||||
}
|
|
||||||
infoDiv.appendChild(movie);
|
infoDiv.appendChild(movie);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -530,24 +458,6 @@ function createDownloadCard(download) {
|
|||||||
const completed = createDetailItem('Completed', formatDate(download.completedAt));
|
const completed = createDetailItem('Completed', formatDate(download.completedAt));
|
||||||
details.appendChild(completed);
|
details.appendChild(completed);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (isAdmin && (download.downloadPath || download.targetPath)) {
|
|
||||||
const pathsDiv = document.createElement('div');
|
|
||||||
pathsDiv.className = 'download-paths';
|
|
||||||
if (download.downloadPath) {
|
|
||||||
const dlPath = document.createElement('div');
|
|
||||||
dlPath.className = 'path-item';
|
|
||||||
dlPath.innerHTML = '<span class="path-label">Download:</span> <span class="path-value">' + escapeHtml(download.downloadPath) + '</span>';
|
|
||||||
pathsDiv.appendChild(dlPath);
|
|
||||||
}
|
|
||||||
if (download.targetPath) {
|
|
||||||
const tgtPath = document.createElement('div');
|
|
||||||
tgtPath.className = 'path-item';
|
|
||||||
tgtPath.innerHTML = '<span class="path-label">Target:</span> <span class="path-value">' + escapeHtml(download.targetPath) + '</span>';
|
|
||||||
pathsDiv.appendChild(tgtPath);
|
|
||||||
}
|
|
||||||
details.appendChild(pathsDiv);
|
|
||||||
}
|
|
||||||
|
|
||||||
infoDiv.appendChild(details);
|
infoDiv.appendChild(details);
|
||||||
card.appendChild(infoDiv);
|
card.appendChild(infoDiv);
|
||||||
@@ -574,146 +484,6 @@ function createDetailItem(label, value) {
|
|||||||
return item;
|
return item;
|
||||||
}
|
}
|
||||||
|
|
||||||
function escapeHtml(str) {
|
|
||||||
const div = document.createElement('div');
|
|
||||||
div.textContent = str;
|
|
||||||
return div.innerHTML;
|
|
||||||
}
|
|
||||||
|
|
||||||
let statusRefreshHandle = null;
|
|
||||||
|
|
||||||
async function toggleStatusPanel() {
|
|
||||||
const panel = document.getElementById('status-panel');
|
|
||||||
if (panel.style.display !== 'none') {
|
|
||||||
panel.style.display = 'none';
|
|
||||||
if (statusRefreshHandle) { clearInterval(statusRefreshHandle); statusRefreshHandle = null; }
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
panel.style.display = 'block';
|
|
||||||
await refreshStatusPanel();
|
|
||||||
// Auto-refresh in sync with dashboard refresh rate
|
|
||||||
if (statusRefreshHandle) clearInterval(statusRefreshHandle);
|
|
||||||
if (currentRefreshRate > 0) {
|
|
||||||
statusRefreshHandle = setInterval(refreshStatusPanel, currentRefreshRate);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
function closeStatusPanel() {
|
|
||||||
document.getElementById('status-panel').style.display = 'none';
|
|
||||||
if (statusRefreshHandle) { clearInterval(statusRefreshHandle); statusRefreshHandle = null; }
|
|
||||||
}
|
|
||||||
|
|
||||||
async function refreshStatusPanel() {
|
|
||||||
const panel = document.getElementById('status-panel');
|
|
||||||
if (!panel || panel.style.display === 'none') return;
|
|
||||||
try {
|
|
||||||
const res = await fetch('/api/dashboard/status');
|
|
||||||
if (!res.ok) throw new Error('Failed to fetch status');
|
|
||||||
const data = await res.json();
|
|
||||||
renderStatusPanel(data, panel);
|
|
||||||
} catch (err) {
|
|
||||||
// Don't overwrite panel on transient error during auto-refresh
|
|
||||||
if (!panel.innerHTML || panel.innerHTML.includes('status-loading')) {
|
|
||||||
panel.innerHTML = '<p class="status-error">Failed to load status.</p>';
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
function renderStatusPanel(data, panel) {
|
|
||||||
const s = data.server;
|
|
||||||
const hrs = Math.floor(s.uptimeSeconds / 3600);
|
|
||||||
const mins = Math.floor((s.uptimeSeconds % 3600) / 60);
|
|
||||||
const secs = s.uptimeSeconds % 60;
|
|
||||||
const uptime = `${hrs}h ${mins}m ${secs}s`;
|
|
||||||
|
|
||||||
const totalKB = (data.cache.totalSizeBytes / 1024).toFixed(1);
|
|
||||||
|
|
||||||
let html = `
|
|
||||||
<div class="status-header">
|
|
||||||
<h3>Server Status</h3>
|
|
||||||
<button class="status-close" onclick="closeStatusPanel()">×</button>
|
|
||||||
</div>
|
|
||||||
<div class="status-grid">
|
|
||||||
<div class="status-card">
|
|
||||||
<div class="status-card-title">Server</div>
|
|
||||||
<div class="status-row"><span>Uptime</span><span>${uptime}</span></div>
|
|
||||||
<div class="status-row"><span>Node</span><span>${escapeHtml(s.nodeVersion)}</span></div>
|
|
||||||
<div class="status-row"><span>Memory (RSS)</span><span>${s.memoryUsageMB} MB</span></div>
|
|
||||||
<div class="status-row"><span>Heap</span><span>${s.heapUsedMB} / ${s.heapTotalMB} MB</span></div>
|
|
||||||
</div>
|
|
||||||
<div class="status-card">
|
|
||||||
<div class="status-card-title">Data Refresh</div>`;
|
|
||||||
|
|
||||||
const pollIntervalMs = data.polling.intervalMs;
|
|
||||||
const clients = data.clients || [];
|
|
||||||
const activeRefreshers = clients.filter(c => c.refreshRateMs > 0);
|
|
||||||
const fastestClient = activeRefreshers.length > 0
|
|
||||||
? activeRefreshers.reduce((min, c) => c.refreshRateMs < min.refreshRateMs ? c : min)
|
|
||||||
: null;
|
|
||||||
const hasForegroundClient = fastestClient && data.polling.enabled && fastestClient.refreshRateMs < pollIntervalMs;
|
|
||||||
|
|
||||||
if (data.polling.enabled) {
|
|
||||||
html += `<div class="status-row"><span>Background poll</span><span>${pollIntervalMs / 1000}s</span></div>`;
|
|
||||||
} else {
|
|
||||||
html += `<div class="status-row"><span>Background poll</span><span>Disabled</span></div>`;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (hasForegroundClient) {
|
|
||||||
html += `<div class="status-row"><span>Effective mode</span><span class="status-fg-badge">Foreground ${fastestClient.refreshRateMs / 1000}s</span></div>`;
|
|
||||||
} else if (activeRefreshers.length > 0) {
|
|
||||||
html += `<div class="status-row"><span>Effective mode</span><span>${data.polling.enabled ? 'Background' : 'On-demand'}</span></div>`;
|
|
||||||
} else {
|
|
||||||
html += `<div class="status-row"><span>Effective mode</span><span>Idle (no active clients)</span></div>`;
|
|
||||||
}
|
|
||||||
|
|
||||||
html += `<div class="status-row"><span>Active clients</span><span>${clients.length}</span></div>`;
|
|
||||||
for (const c of clients) {
|
|
||||||
const rate = c.refreshRateMs > 0 ? (c.refreshRateMs / 1000) + 's' : 'Off';
|
|
||||||
const age = Math.round((Date.now() - c.lastSeen) / 1000);
|
|
||||||
html += `<div class="status-row status-row-sub"><span>${escapeHtml(c.user)}</span><span>${rate} (${age}s ago)</span></div>`;
|
|
||||||
}
|
|
||||||
|
|
||||||
html += `</div>`;
|
|
||||||
|
|
||||||
// Poll timings card
|
|
||||||
const lp = data.polling.lastPoll;
|
|
||||||
if (lp) {
|
|
||||||
const pollAge = Math.round((Date.now() - new Date(lp.timestamp).getTime()) / 1000);
|
|
||||||
html += `
|
|
||||||
<div class="status-card status-card-wide">
|
|
||||||
<div class="status-card-title">Last Poll (${lp.totalMs}ms total, ${pollAge}s ago)</div>
|
|
||||||
<div class="status-timings">`;
|
|
||||||
for (const t of lp.tasks) {
|
|
||||||
const barWidth = lp.totalMs > 0 ? Math.max(2, (t.ms / lp.totalMs) * 100) : 0;
|
|
||||||
html += `
|
|
||||||
<div class="timing-row">
|
|
||||||
<span class="timing-label">${escapeHtml(t.label)}</span>
|
|
||||||
<div class="timing-bar-bg"><div class="timing-bar" style="width:${barWidth.toFixed(1)}%"></div></div>
|
|
||||||
<span class="timing-value">${t.ms}ms</span>
|
|
||||||
</div>`;
|
|
||||||
}
|
|
||||||
html += `</div></div>`;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Cache table
|
|
||||||
html += `
|
|
||||||
<div class="status-card status-card-wide">
|
|
||||||
<div class="status-card-title">Cache (${data.cache.entryCount} entries, ${totalKB} KB)</div>
|
|
||||||
<table class="status-table">
|
|
||||||
<thead><tr><th>Key</th><th>Items</th><th>Size</th><th>TTL</th></tr></thead>
|
|
||||||
<tbody>`;
|
|
||||||
|
|
||||||
for (const e of data.cache.entries) {
|
|
||||||
const sizeStr = e.sizeBytes > 1024 ? (e.sizeBytes / 1024).toFixed(1) + ' KB' : e.sizeBytes + ' B';
|
|
||||||
const ttlStr = e.expired ? '<span class="status-expired">expired</span>' : (e.ttlRemainingMs / 1000).toFixed(0) + 's';
|
|
||||||
const items = e.itemCount !== null ? e.itemCount : '—';
|
|
||||||
html += `<tr><td><code>${escapeHtml(e.key)}</code></td><td>${items}</td><td>${sizeStr}</td><td>${ttlStr}</td></tr>`;
|
|
||||||
}
|
|
||||||
|
|
||||||
html += `</tbody></table></div></div>`;
|
|
||||||
panel.innerHTML = html;
|
|
||||||
}
|
|
||||||
|
|
||||||
function formatSize(size) {
|
function formatSize(size) {
|
||||||
if (!size) return 'N/A';
|
if (!size) return 'N/A';
|
||||||
// If already a formatted string (e.g., "21.5 GB"), return as-is
|
// If already a formatted string (e.g., "21.5 GB"), return as-is
|
||||||
|
|||||||
Binary file not shown.
|
Before Width: | Height: | Size: 85 KiB |
+1
-10
@@ -7,17 +7,11 @@
|
|||||||
<link rel="stylesheet" href="style.css">
|
<link rel="stylesheet" href="style.css">
|
||||||
</head>
|
</head>
|
||||||
<body>
|
<body>
|
||||||
<!-- Splash Screen -->
|
|
||||||
<div id="splash-screen" class="splash-screen">
|
|
||||||
<img src="images/sofarr-flashscreen.png" alt="sofarr" class="splash-logo">
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div class="app">
|
<div class="app">
|
||||||
<!-- Login Form -->
|
<!-- Login Form -->
|
||||||
<div id="login-container" class="login-container" style="display: none;">
|
<div id="login-container" class="login-container" style="display: none;">
|
||||||
<div class="login-box">
|
<div class="login-box">
|
||||||
<img src="images/sofarr-flashscreen.png" alt="sofarr" class="login-logo">
|
<h2>Login to Emby</h2>
|
||||||
<p class="login-subtitle">Login with your Emby credentials</p>
|
|
||||||
<form id="login-form">
|
<form id="login-form">
|
||||||
<div class="form-group">
|
<div class="form-group">
|
||||||
<label for="username">Username:</label>
|
<label for="username">Username:</label>
|
||||||
@@ -57,7 +51,6 @@
|
|||||||
<input type="checkbox" id="show-all-toggle">
|
<input type="checkbox" id="show-all-toggle">
|
||||||
<span>Show all users</span>
|
<span>Show all users</span>
|
||||||
</label>
|
</label>
|
||||||
<button id="status-btn" class="status-btn">Status</button>
|
|
||||||
</div>
|
</div>
|
||||||
<div class="user-info">
|
<div class="user-info">
|
||||||
<span class="user-label">Current User:</span>
|
<span class="user-label">Current User:</span>
|
||||||
@@ -67,8 +60,6 @@
|
|||||||
</div>
|
</div>
|
||||||
</header>
|
</header>
|
||||||
|
|
||||||
<div id="status-panel" class="status-panel" style="display: none;"></div>
|
|
||||||
|
|
||||||
<div id="error-message" class="error-message" style="display: none;"></div>
|
<div id="error-message" class="error-message" style="display: none;"></div>
|
||||||
|
|
||||||
<div id="loading" class="loading" style="display: none;">Loading downloads...</div>
|
<div id="loading" class="loading" style="display: none;">Loading downloads...</div>
|
||||||
|
|||||||
+4
-332
@@ -1,34 +1,3 @@
|
|||||||
/* ===== Splash Screen ===== */
|
|
||||||
.splash-screen {
|
|
||||||
position: fixed;
|
|
||||||
top: 0;
|
|
||||||
left: 0;
|
|
||||||
width: 100%;
|
|
||||||
height: 100%;
|
|
||||||
display: flex;
|
|
||||||
align-items: center;
|
|
||||||
justify-content: center;
|
|
||||||
background: #f8f9fa;
|
|
||||||
z-index: 9999;
|
|
||||||
opacity: 1;
|
|
||||||
transition: opacity 0.4s ease-out;
|
|
||||||
}
|
|
||||||
|
|
||||||
.splash-screen.fade-out {
|
|
||||||
opacity: 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
.splash-logo {
|
|
||||||
max-width: 280px;
|
|
||||||
width: 60%;
|
|
||||||
animation: splashPulse 1.8s ease-in-out infinite;
|
|
||||||
}
|
|
||||||
|
|
||||||
@keyframes splashPulse {
|
|
||||||
0%, 100% { transform: scale(1); opacity: 1; }
|
|
||||||
50% { transform: scale(1.03); opacity: 0.85; }
|
|
||||||
}
|
|
||||||
|
|
||||||
/* ===== Theme Variables ===== */
|
/* ===== Theme Variables ===== */
|
||||||
:root, [data-theme="light"] {
|
:root, [data-theme="light"] {
|
||||||
--bg-gradient-start: #667eea;
|
--bg-gradient-start: #667eea;
|
||||||
@@ -545,12 +514,6 @@ body {
|
|||||||
align-items: center;
|
align-items: center;
|
||||||
min-height: 100vh;
|
min-height: 100vh;
|
||||||
padding: 20px;
|
padding: 20px;
|
||||||
opacity: 1;
|
|
||||||
transition: opacity 0.3s ease-out;
|
|
||||||
}
|
|
||||||
|
|
||||||
.login-container.fade-out {
|
|
||||||
opacity: 0;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
.login-box {
|
.login-box {
|
||||||
@@ -561,24 +524,17 @@ body {
|
|||||||
width: 100%;
|
width: 100%;
|
||||||
max-width: 380px;
|
max-width: 380px;
|
||||||
transition: background 0.3s;
|
transition: background 0.3s;
|
||||||
text-align: center;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
.login-logo {
|
.login-box h2 {
|
||||||
max-width: 180px;
|
color: var(--text-primary);
|
||||||
width: 60%;
|
|
||||||
margin-bottom: 12px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.login-subtitle {
|
|
||||||
color: var(--text-secondary);
|
|
||||||
margin-bottom: 24px;
|
margin-bottom: 24px;
|
||||||
font-size: 0.85rem;
|
text-align: center;
|
||||||
|
font-size: 1.5rem;
|
||||||
}
|
}
|
||||||
|
|
||||||
.form-group {
|
.form-group {
|
||||||
margin-bottom: 16px;
|
margin-bottom: 16px;
|
||||||
text-align: left;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
.form-group label {
|
.form-group label {
|
||||||
@@ -646,80 +602,6 @@ body {
|
|||||||
accent-color: var(--accent);
|
accent-color: var(--accent);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* ===== Arr Links (Admin) ===== */
|
|
||||||
.arr-link {
|
|
||||||
color: var(--accent);
|
|
||||||
text-decoration: none;
|
|
||||||
border-bottom: 1px dotted var(--accent);
|
|
||||||
}
|
|
||||||
|
|
||||||
.arr-link:hover {
|
|
||||||
opacity: 0.8;
|
|
||||||
border-bottom-style: solid;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* ===== Download Paths (Admin) ===== */
|
|
||||||
.download-paths {
|
|
||||||
flex-basis: 100%;
|
|
||||||
display: flex;
|
|
||||||
flex-direction: column;
|
|
||||||
gap: 2px;
|
|
||||||
margin-top: 2px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.path-item {
|
|
||||||
font-size: 0.7rem;
|
|
||||||
font-family: 'SF Mono', 'Fira Code', 'Fira Mono', Menlo, Consolas, monospace;
|
|
||||||
color: var(--text-muted);
|
|
||||||
white-space: nowrap;
|
|
||||||
overflow: hidden;
|
|
||||||
text-overflow: ellipsis;
|
|
||||||
}
|
|
||||||
|
|
||||||
.path-label {
|
|
||||||
font-weight: 600;
|
|
||||||
color: var(--text-secondary);
|
|
||||||
font-size: 0.65rem;
|
|
||||||
text-transform: uppercase;
|
|
||||||
letter-spacing: 0.3px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.path-value {
|
|
||||||
color: var(--text-muted);
|
|
||||||
}
|
|
||||||
|
|
||||||
/* ===== Import Issue Badge ===== */
|
|
||||||
.import-issue-badge {
|
|
||||||
padding: 2px 8px;
|
|
||||||
border-radius: 10px;
|
|
||||||
font-size: 0.65rem;
|
|
||||||
font-weight: 600;
|
|
||||||
background: #ffebee;
|
|
||||||
color: #c62828;
|
|
||||||
cursor: help;
|
|
||||||
position: relative;
|
|
||||||
white-space: nowrap;
|
|
||||||
}
|
|
||||||
|
|
||||||
.import-issue-badge:hover::after {
|
|
||||||
content: attr(data-tooltip);
|
|
||||||
position: absolute;
|
|
||||||
top: calc(100% + 6px);
|
|
||||||
left: 0;
|
|
||||||
background: #424242;
|
|
||||||
color: #fff;
|
|
||||||
padding: 8px 12px;
|
|
||||||
border-radius: 6px;
|
|
||||||
font-size: 0.7rem;
|
|
||||||
font-weight: 400;
|
|
||||||
white-space: pre-line;
|
|
||||||
max-width: 320px;
|
|
||||||
z-index: 100;
|
|
||||||
box-shadow: 0 2px 8px rgba(0,0,0,0.25);
|
|
||||||
line-height: 1.4;
|
|
||||||
pointer-events: none;
|
|
||||||
}
|
|
||||||
|
|
||||||
.download-user-badge {
|
.download-user-badge {
|
||||||
padding: 2px 8px;
|
padding: 2px 8px;
|
||||||
border-radius: 10px;
|
border-radius: 10px;
|
||||||
@@ -731,212 +613,6 @@ body {
|
|||||||
margin-left: auto;
|
margin-left: auto;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* ===== Status Button ===== */
|
|
||||||
.status-btn {
|
|
||||||
padding: 4px 12px;
|
|
||||||
border: 1px solid var(--border);
|
|
||||||
border-radius: 5px;
|
|
||||||
background: var(--surface);
|
|
||||||
color: var(--text-secondary);
|
|
||||||
cursor: pointer;
|
|
||||||
font-size: 0.8rem;
|
|
||||||
font-weight: 500;
|
|
||||||
transition: background 0.2s, color 0.2s;
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-btn:hover {
|
|
||||||
background: var(--accent);
|
|
||||||
color: white;
|
|
||||||
border-color: var(--accent);
|
|
||||||
}
|
|
||||||
|
|
||||||
/* ===== Status Panel ===== */
|
|
||||||
.status-panel {
|
|
||||||
background: var(--surface);
|
|
||||||
border: 1px solid var(--border);
|
|
||||||
border-radius: 10px;
|
|
||||||
padding: 20px;
|
|
||||||
margin-bottom: 16px;
|
|
||||||
box-shadow: 0 2px 4px var(--shadow);
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-header {
|
|
||||||
display: flex;
|
|
||||||
justify-content: space-between;
|
|
||||||
align-items: center;
|
|
||||||
margin-bottom: 16px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-header h3 {
|
|
||||||
margin: 0;
|
|
||||||
color: var(--text-primary);
|
|
||||||
font-size: 1.1rem;
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-close {
|
|
||||||
background: none;
|
|
||||||
border: none;
|
|
||||||
font-size: 1.4rem;
|
|
||||||
color: var(--text-secondary);
|
|
||||||
cursor: pointer;
|
|
||||||
padding: 0 4px;
|
|
||||||
line-height: 1;
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-close:hover {
|
|
||||||
color: var(--text-primary);
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-grid {
|
|
||||||
display: grid;
|
|
||||||
grid-template-columns: 1fr 1fr;
|
|
||||||
gap: 16px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-card {
|
|
||||||
background: var(--background);
|
|
||||||
border: 1px solid var(--border);
|
|
||||||
border-radius: 8px;
|
|
||||||
padding: 14px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-card-wide {
|
|
||||||
grid-column: 1 / -1;
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-card-title {
|
|
||||||
font-weight: 600;
|
|
||||||
font-size: 0.85rem;
|
|
||||||
color: var(--text-primary);
|
|
||||||
margin-bottom: 10px;
|
|
||||||
padding-bottom: 6px;
|
|
||||||
border-bottom: 1px solid var(--border);
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-row {
|
|
||||||
display: flex;
|
|
||||||
justify-content: space-between;
|
|
||||||
padding: 3px 0;
|
|
||||||
font-size: 0.8rem;
|
|
||||||
color: var(--text-secondary);
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-row span:last-child {
|
|
||||||
font-weight: 500;
|
|
||||||
color: var(--text-primary);
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-table {
|
|
||||||
width: 100%;
|
|
||||||
border-collapse: collapse;
|
|
||||||
font-size: 0.78rem;
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-table th {
|
|
||||||
text-align: left;
|
|
||||||
padding: 4px 8px;
|
|
||||||
color: var(--text-secondary);
|
|
||||||
font-weight: 600;
|
|
||||||
font-size: 0.7rem;
|
|
||||||
text-transform: uppercase;
|
|
||||||
letter-spacing: 0.3px;
|
|
||||||
border-bottom: 1px solid var(--border);
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-table td {
|
|
||||||
padding: 5px 8px;
|
|
||||||
color: var(--text-primary);
|
|
||||||
border-bottom: 1px solid var(--border);
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-table code {
|
|
||||||
font-size: 0.75rem;
|
|
||||||
background: var(--surface);
|
|
||||||
padding: 1px 4px;
|
|
||||||
border-radius: 3px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-expired {
|
|
||||||
color: #c62828;
|
|
||||||
font-weight: 600;
|
|
||||||
font-size: 0.7rem;
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-fg-badge {
|
|
||||||
background: #fff3e0;
|
|
||||||
color: #e65100;
|
|
||||||
padding: 1px 8px;
|
|
||||||
border-radius: 8px;
|
|
||||||
font-size: 0.75rem;
|
|
||||||
font-weight: 600;
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-row-sub {
|
|
||||||
padding-left: 12px;
|
|
||||||
font-size: 0.75rem;
|
|
||||||
opacity: 0.8;
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-row-sub span:first-child {
|
|
||||||
font-style: italic;
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-timings {
|
|
||||||
display: flex;
|
|
||||||
flex-direction: column;
|
|
||||||
gap: 6px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.timing-row {
|
|
||||||
display: flex;
|
|
||||||
align-items: center;
|
|
||||||
gap: 8px;
|
|
||||||
font-size: 0.78rem;
|
|
||||||
}
|
|
||||||
|
|
||||||
.timing-label {
|
|
||||||
width: 110px;
|
|
||||||
flex-shrink: 0;
|
|
||||||
color: var(--text-secondary);
|
|
||||||
white-space: nowrap;
|
|
||||||
}
|
|
||||||
|
|
||||||
.timing-bar-bg {
|
|
||||||
flex: 1;
|
|
||||||
height: 8px;
|
|
||||||
background: var(--border);
|
|
||||||
border-radius: 4px;
|
|
||||||
overflow: hidden;
|
|
||||||
}
|
|
||||||
|
|
||||||
.timing-bar {
|
|
||||||
height: 100%;
|
|
||||||
background: var(--accent);
|
|
||||||
border-radius: 4px;
|
|
||||||
min-width: 2px;
|
|
||||||
transition: width 0.3s ease;
|
|
||||||
}
|
|
||||||
|
|
||||||
.timing-value {
|
|
||||||
width: 50px;
|
|
||||||
flex-shrink: 0;
|
|
||||||
text-align: right;
|
|
||||||
color: var(--text-primary);
|
|
||||||
font-weight: 500;
|
|
||||||
font-size: 0.75rem;
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-loading, .status-error {
|
|
||||||
text-align: center;
|
|
||||||
padding: 20px;
|
|
||||||
color: var(--text-secondary);
|
|
||||||
font-size: 0.9rem;
|
|
||||||
}
|
|
||||||
|
|
||||||
.status-error {
|
|
||||||
color: #c62828;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* ===== Mobile ===== */
|
/* ===== Mobile ===== */
|
||||||
@media (max-width: 768px) {
|
@media (max-width: 768px) {
|
||||||
.app-header {
|
.app-header {
|
||||||
@@ -966,8 +642,4 @@ body {
|
|||||||
.progress-container {
|
.progress-container {
|
||||||
flex-wrap: wrap;
|
flex-wrap: wrap;
|
||||||
}
|
}
|
||||||
|
|
||||||
.status-grid {
|
|
||||||
grid-template-columns: 1fr;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -54,7 +54,6 @@ const radarrRoutes = require('./routes/radarr');
|
|||||||
const embyRoutes = require('./routes/emby');
|
const embyRoutes = require('./routes/emby');
|
||||||
const dashboardRoutes = require('./routes/dashboard');
|
const dashboardRoutes = require('./routes/dashboard');
|
||||||
const authRoutes = require('./routes/auth');
|
const authRoutes = require('./routes/auth');
|
||||||
const { startPoller, POLL_INTERVAL, POLLING_ENABLED } = require('./utils/poller');
|
|
||||||
|
|
||||||
const app = express();
|
const app = express();
|
||||||
const PORT = process.env.PORT || 3001;
|
const PORT = process.env.PORT || 3001;
|
||||||
@@ -80,7 +79,5 @@ app.listen(PORT, () => {
|
|||||||
console.log(` sofarr - Your Downloads Dashboard`);
|
console.log(` sofarr - Your Downloads Dashboard`);
|
||||||
console.log(` Server running on port ${PORT}`);
|
console.log(` Server running on port ${PORT}`);
|
||||||
console.log(` Log level: ${process.env.LOG_LEVEL || 'info'}`);
|
console.log(` Log level: ${process.env.LOG_LEVEL || 'info'}`);
|
||||||
console.log(` Polling: ${POLLING_ENABLED ? POLL_INTERVAL + 'ms' : 'disabled (on-demand)'}`);
|
|
||||||
console.log(`=================================`);
|
console.log(`=================================`);
|
||||||
startPoller();
|
|
||||||
});
|
});
|
||||||
|
|||||||
+226
-236
@@ -1,11 +1,13 @@
|
|||||||
const express = require('express');
|
const express = require('express');
|
||||||
|
const axios = require('axios');
|
||||||
const router = express.Router();
|
const router = express.Router();
|
||||||
|
|
||||||
const axios = require('axios');
|
const { getTorrents, mapTorrentToDownload } = require('../utils/qbittorrent');
|
||||||
const { mapTorrentToDownload } = require('../utils/qbittorrent');
|
const {
|
||||||
const cache = require('../utils/cache');
|
getSABnzbdInstances,
|
||||||
const { pollAllServices, getLastPollTimings, POLLING_ENABLED } = require('../utils/poller');
|
getSonarrInstances,
|
||||||
const { getSonarrInstances, getRadarrInstances } = require('../utils/config');
|
getRadarrInstances
|
||||||
|
} = require('../utils/config');
|
||||||
|
|
||||||
const EMBY_URL = process.env.EMBY_URL;
|
const EMBY_URL = process.env.EMBY_URL;
|
||||||
const EMBY_API_KEY = process.env.EMBY_API_KEY;
|
const EMBY_API_KEY = process.env.EMBY_API_KEY;
|
||||||
@@ -40,71 +42,6 @@ function extractUserTag(tags, tagMap) {
|
|||||||
return userTag ? userTag.label : null;
|
return userTag ? userTag.label : null;
|
||||||
}
|
}
|
||||||
|
|
||||||
// Replicate Ombi's StringHelper.SanitizeTagLabel: lowercase, replace non-alphanumeric with hyphen, collapse, trim
|
|
||||||
function sanitizeTagLabel(input) {
|
|
||||||
if (!input) return '';
|
|
||||||
return input.toLowerCase().replace(/[^a-z0-9]+/g, '-').replace(/-+/g, '-').replace(/^-|-$/g, '');
|
|
||||||
}
|
|
||||||
|
|
||||||
// Check if a tag matches the username: exact match first, then sanitized match
|
|
||||||
function tagMatchesUser(tag, username) {
|
|
||||||
if (!tag || !username) return false;
|
|
||||||
const tagLower = tag.toLowerCase();
|
|
||||||
// Exact match (handles users whose tags weren't mangled)
|
|
||||||
if (tagLower === username) return true;
|
|
||||||
// Sanitized match (handles Ombi-mangled tags for email-style usernames)
|
|
||||||
if (tagLower === sanitizeTagLabel(username)) return true;
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Extract import issues from a Sonarr/Radarr queue record
|
|
||||||
function getImportIssues(queueRecord) {
|
|
||||||
if (!queueRecord) return null;
|
|
||||||
const state = queueRecord.trackedDownloadState;
|
|
||||||
const status = queueRecord.trackedDownloadStatus;
|
|
||||||
if (state !== 'importPending' && status !== 'warning' && status !== 'error') return null;
|
|
||||||
const messages = [];
|
|
||||||
if (queueRecord.statusMessages && queueRecord.statusMessages.length > 0) {
|
|
||||||
for (const sm of queueRecord.statusMessages) {
|
|
||||||
if (sm.messages && sm.messages.length > 0) {
|
|
||||||
messages.push(...sm.messages);
|
|
||||||
} else if (sm.title) {
|
|
||||||
messages.push(sm.title);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (queueRecord.errorMessage) {
|
|
||||||
messages.push(queueRecord.errorMessage);
|
|
||||||
}
|
|
||||||
if (messages.length === 0) return null;
|
|
||||||
return messages;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Helper to build Sonarr web UI link for a series
|
|
||||||
function getSonarrLink(series) {
|
|
||||||
if (!series || !series._instanceUrl || !series.titleSlug) return null;
|
|
||||||
return `${series._instanceUrl}/series/${series.titleSlug}`;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Helper to build Radarr web UI link for a movie
|
|
||||||
function getRadarrLink(movie) {
|
|
||||||
if (!movie || !movie._instanceUrl || !movie.titleSlug) return null;
|
|
||||||
return `${movie._instanceUrl}/movie/${movie.titleSlug}`;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Track active dashboard clients: Map<username, { refreshRateMs, lastSeen }>
|
|
||||||
const activeClients = new Map();
|
|
||||||
const CLIENT_STALE_MS = 30000; // consider client gone after 30s of no requests
|
|
||||||
|
|
||||||
function getActiveClients() {
|
|
||||||
const now = Date.now();
|
|
||||||
// Prune stale clients
|
|
||||||
for (const [key, client] of activeClients.entries()) {
|
|
||||||
if (now - client.lastSeen > CLIENT_STALE_MS) activeClients.delete(key);
|
|
||||||
}
|
|
||||||
return Array.from(activeClients.values());
|
|
||||||
}
|
|
||||||
|
|
||||||
// Get user downloads for authenticated user
|
// Get user downloads for authenticated user
|
||||||
router.get('/user-downloads', async (req, res) => {
|
router.get('/user-downloads', async (req, res) => {
|
||||||
try {
|
try {
|
||||||
@@ -116,70 +53,211 @@ router.get('/user-downloads', async (req, res) => {
|
|||||||
|
|
||||||
const user = JSON.parse(userCookie);
|
const user = JSON.parse(userCookie);
|
||||||
const username = user.name.toLowerCase();
|
const username = user.name.toLowerCase();
|
||||||
const usernameSanitized = sanitizeTagLabel(user.name);
|
|
||||||
const isAdmin = !!user.isAdmin;
|
const isAdmin = !!user.isAdmin;
|
||||||
const showAll = isAdmin && req.query.showAll === 'true';
|
const showAll = isAdmin && req.query.showAll === 'true';
|
||||||
console.log(`[Dashboard] Serving downloads for user: ${user.name} (${username}), isAdmin: ${isAdmin}, showAll: ${showAll}`);
|
console.log(`[Dashboard] Fetching downloads for authenticated user: ${user.name} (${username}), isAdmin: ${isAdmin}, showAll: ${showAll}`);
|
||||||
|
|
||||||
// Track this client's refresh rate
|
// Get all service instances
|
||||||
const clientRefreshRate = parseInt(req.query.refreshRate, 10);
|
const sabInstances = getSABnzbdInstances();
|
||||||
if (clientRefreshRate > 0) {
|
const sonarrInstances = getSonarrInstances();
|
||||||
activeClients.set(username, { user: user.name, refreshRateMs: clientRefreshRate, lastSeen: Date.now() });
|
const radarrInstances = getRadarrInstances();
|
||||||
} else {
|
|
||||||
// Client has refresh off or didn't send — still mark as seen but with no rate
|
console.log(`[Dashboard] Fetching data from all services...`);
|
||||||
activeClients.set(username, { user: user.name, refreshRateMs: 0, lastSeen: Date.now() });
|
console.log(`[Dashboard] SABnzbd instances: ${sabInstances.length}`);
|
||||||
}
|
console.log(`[Dashboard] Sonarr instances: ${sonarrInstances.length}`);
|
||||||
|
console.log(`[Dashboard] Radarr instances: ${radarrInstances.length}`);
|
||||||
// When polling is disabled, fetch on-demand if cache has expired
|
|
||||||
// The fetched data is cached (30s TTL) so subsequent requests from any user reuse it
|
// Fetch from all SABnzbd instances
|
||||||
if (!POLLING_ENABLED && !cache.get('poll:sab-queue')) {
|
const sabQueuePromises = sabInstances.map(inst =>
|
||||||
console.log(`[Dashboard] Cache expired and polling disabled, fetching on-demand...`);
|
axios.get(`${inst.url}/api`, {
|
||||||
await pollAllServices();
|
params: { mode: 'queue', apikey: inst.apiKey, output: 'json' }
|
||||||
}
|
}).then(res => ({ instance: inst.id, data: res.data })).catch(err => {
|
||||||
|
console.error(`[Dashboard] SABnzbd ${inst.id} queue error:`, err.message);
|
||||||
// Read all data from cache
|
return { instance: inst.id, data: { queue: { slots: [] } } };
|
||||||
const sabQueueData = cache.get('poll:sab-queue') || { slots: [] };
|
})
|
||||||
const sabHistoryData = cache.get('poll:sab-history') || { slots: [] };
|
);
|
||||||
const sonarrTagsResults = cache.get('poll:sonarr-tags') || [];
|
|
||||||
const sonarrQueueData = cache.get('poll:sonarr-queue') || { records: [] };
|
const sabHistoryPromises = sabInstances.map(inst =>
|
||||||
const sonarrHistoryData = cache.get('poll:sonarr-history') || { records: [] };
|
axios.get(`${inst.url}/api`, {
|
||||||
const radarrQueueData = cache.get('poll:radarr-queue') || { records: [] };
|
params: { mode: 'history', apikey: inst.apiKey, output: 'json', limit: 100 }
|
||||||
const radarrHistoryData = cache.get('poll:radarr-history') || { records: [] };
|
}).then(res => ({ instance: inst.id, data: res.data })).catch(err => {
|
||||||
const radarrTagsData = cache.get('poll:radarr-tags') || [];
|
console.error(`[Dashboard] SABnzbd ${inst.id} history error:`, err.message);
|
||||||
const qbittorrentTorrents = cache.get('poll:qbittorrent') || [];
|
return { instance: inst.id, data: { history: { slots: [] } } };
|
||||||
|
})
|
||||||
// Wrap in the structure the rest of the code expects
|
);
|
||||||
const sabnzbdQueue = { data: { queue: sabQueueData } };
|
|
||||||
const sabnzbdHistory = { data: { history: sabHistoryData } };
|
// Fetch from all Sonarr instances
|
||||||
const sonarrQueue = { data: sonarrQueueData };
|
const sonarrTagsPromises = sonarrInstances.map(inst =>
|
||||||
const sonarrHistory = { data: sonarrHistoryData };
|
axios.get(`${inst.url}/api/v3/tag`, {
|
||||||
const radarrQueue = { data: radarrQueueData };
|
headers: { 'X-Api-Key': inst.apiKey }
|
||||||
const radarrHistory = { data: radarrHistoryData };
|
}).then(res => ({ instance: inst.id, data: res.data })).catch(err => {
|
||||||
const radarrTags = { data: radarrTagsData };
|
console.error(`[Dashboard] Sonarr ${inst.id} tags error:`, err.message);
|
||||||
|
return { instance: inst.id, data: [] };
|
||||||
// Build series/movie maps from embedded objects in queue records
|
})
|
||||||
// (history is fetched without includeSeries/includeMovie for speed;
|
);
|
||||||
// history matches fall back to the queue-built map via seriesId/movieId)
|
|
||||||
const seriesMap = new Map();
|
const sonarrQueuePromises = sonarrInstances.map(inst =>
|
||||||
for (const r of sonarrQueue.data.records) {
|
axios.get(`${inst.url}/api/v3/queue`, {
|
||||||
if (r.series && r.seriesId) seriesMap.set(r.seriesId, r.series);
|
headers: { 'X-Api-Key': inst.apiKey },
|
||||||
}
|
params: { includeSeries: true, includeEpisode: true }
|
||||||
for (const r of sonarrHistory.data.records) {
|
}).then(res => ({ instance: inst.id, data: res.data })).catch(err => {
|
||||||
if (r.series && r.seriesId && !seriesMap.has(r.seriesId)) seriesMap.set(r.seriesId, r.series);
|
console.error(`[Dashboard] Sonarr ${inst.id} queue error:`, err.message);
|
||||||
}
|
return { instance: inst.id, data: { records: [] } };
|
||||||
const moviesMap = new Map();
|
})
|
||||||
for (const r of radarrQueue.data.records) {
|
);
|
||||||
if (r.movie && r.movieId) moviesMap.set(r.movieId, r.movie);
|
|
||||||
}
|
const sonarrHistoryPromises = sonarrInstances.map(inst =>
|
||||||
for (const r of radarrHistory.data.records) {
|
axios.get(`${inst.url}/api/v3/history`, {
|
||||||
if (r.movie && r.movieId && !moviesMap.has(r.movieId)) moviesMap.set(r.movieId, r.movie);
|
headers: { 'X-Api-Key': inst.apiKey },
|
||||||
}
|
params: { pageSize: 100, includeSeries: true, includeEpisode: true }
|
||||||
|
}).then(res => ({ instance: inst.id, data: res.data })).catch(err => {
|
||||||
|
console.error(`[Dashboard] Sonarr ${inst.id} history error:`, err.message);
|
||||||
|
return { instance: inst.id, data: { records: [] } };
|
||||||
|
})
|
||||||
|
);
|
||||||
|
|
||||||
|
const sonarrSeriesPromises = sonarrInstances.map(inst =>
|
||||||
|
axios.get(`${inst.url}/api/v3/series`, {
|
||||||
|
headers: { 'X-Api-Key': inst.apiKey }
|
||||||
|
}).then(res => ({ instance: inst.id, data: res.data })).catch(err => {
|
||||||
|
console.error(`[Dashboard] Sonarr ${inst.id} series error:`, err.message);
|
||||||
|
return { instance: inst.id, data: [] };
|
||||||
|
})
|
||||||
|
);
|
||||||
|
|
||||||
|
// Fetch from all Radarr instances
|
||||||
|
const radarrQueuePromises = radarrInstances.map(inst =>
|
||||||
|
axios.get(`${inst.url}/api/v3/queue`, {
|
||||||
|
headers: { 'X-Api-Key': inst.apiKey },
|
||||||
|
params: { includeMovie: true }
|
||||||
|
}).then(res => ({ instance: inst.id, data: res.data })).catch(err => {
|
||||||
|
console.error(`[Dashboard] Radarr ${inst.id} queue error:`, err.message);
|
||||||
|
return { instance: inst.id, data: { records: [] } };
|
||||||
|
})
|
||||||
|
);
|
||||||
|
|
||||||
|
const radarrHistoryPromises = radarrInstances.map(inst =>
|
||||||
|
axios.get(`${inst.url}/api/v3/history`, {
|
||||||
|
headers: { 'X-Api-Key': inst.apiKey },
|
||||||
|
params: { pageSize: 100, includeMovie: true }
|
||||||
|
}).then(res => ({ instance: inst.id, data: res.data })).catch(err => {
|
||||||
|
console.error(`[Dashboard] Radarr ${inst.id} history error:`, err.message);
|
||||||
|
return { instance: inst.id, data: { records: [] } };
|
||||||
|
})
|
||||||
|
);
|
||||||
|
|
||||||
|
const radarrMoviesPromises = radarrInstances.map(inst =>
|
||||||
|
axios.get(`${inst.url}/api/v3/movie`, {
|
||||||
|
headers: { 'X-Api-Key': inst.apiKey }
|
||||||
|
}).then(res => ({ instance: inst.id, data: res.data })).catch(err => {
|
||||||
|
console.error(`[Dashboard] Radarr ${inst.id} movies error:`, err.message);
|
||||||
|
return { instance: inst.id, data: [] };
|
||||||
|
})
|
||||||
|
);
|
||||||
|
|
||||||
|
const radarrTagsPromises = radarrInstances.map(inst =>
|
||||||
|
axios.get(`${inst.url}/api/v3/tag`, {
|
||||||
|
headers: { 'X-Api-Key': inst.apiKey }
|
||||||
|
}).then(res => ({ instance: inst.id, data: res.data })).catch(err => {
|
||||||
|
console.error(`[Dashboard] Radarr ${inst.id} tags error:`, err.message);
|
||||||
|
return { instance: inst.id, data: [] };
|
||||||
|
})
|
||||||
|
);
|
||||||
|
|
||||||
|
// Execute all requests
|
||||||
|
const [
|
||||||
|
sabQueues, sabHistories, sonarrTagsResults, sonarrQueues, sonarrHistories, sonarrSeriesResults,
|
||||||
|
radarrQueues, radarrHistories, radarrMoviesResults, radarrTagsResults,
|
||||||
|
qbittorrentTorrents
|
||||||
|
] = await Promise.all([
|
||||||
|
Promise.all(sabQueuePromises),
|
||||||
|
Promise.all(sabHistoryPromises),
|
||||||
|
Promise.all(sonarrTagsPromises),
|
||||||
|
Promise.all(sonarrQueuePromises),
|
||||||
|
Promise.all(sonarrHistoryPromises),
|
||||||
|
Promise.all(sonarrSeriesPromises),
|
||||||
|
Promise.all(radarrQueuePromises),
|
||||||
|
Promise.all(radarrHistoryPromises),
|
||||||
|
Promise.all(radarrMoviesPromises),
|
||||||
|
Promise.all(radarrTagsPromises),
|
||||||
|
getTorrents().catch(err => {
|
||||||
|
console.error(`[Dashboard] qBittorrent error:`, err.message);
|
||||||
|
return [];
|
||||||
|
})
|
||||||
|
]);
|
||||||
|
|
||||||
|
// Aggregate data from all instances
|
||||||
|
const firstSabQueue = sabQueues[0] && sabQueues[0].data && sabQueues[0].data.queue;
|
||||||
|
const sabnzbdQueue = {
|
||||||
|
data: {
|
||||||
|
queue: {
|
||||||
|
slots: sabQueues.flatMap(q => (q.data.queue && q.data.queue.slots) || []),
|
||||||
|
status: firstSabQueue && firstSabQueue.status,
|
||||||
|
speed: firstSabQueue && firstSabQueue.speed,
|
||||||
|
kbpersec: firstSabQueue && firstSabQueue.kbpersec
|
||||||
|
}
|
||||||
|
}
|
||||||
|
};
|
||||||
|
const sabnzbdHistory = {
|
||||||
|
data: {
|
||||||
|
history: {
|
||||||
|
slots: sabHistories.flatMap(h => (h.data.history && h.data.history.slots) || [])
|
||||||
|
}
|
||||||
|
}
|
||||||
|
};
|
||||||
|
const sonarrQueue = {
|
||||||
|
data: {
|
||||||
|
records: sonarrQueues.flatMap(q => q.data.records || [])
|
||||||
|
}
|
||||||
|
};
|
||||||
|
const sonarrHistory = {
|
||||||
|
data: {
|
||||||
|
records: sonarrHistories.flatMap(h => h.data.records || [])
|
||||||
|
}
|
||||||
|
};
|
||||||
|
const sonarrSeries = {
|
||||||
|
data: sonarrSeriesResults.flatMap(s => s.data || [])
|
||||||
|
};
|
||||||
|
const radarrQueue = {
|
||||||
|
data: {
|
||||||
|
records: radarrQueues.flatMap(q => q.data.records || [])
|
||||||
|
}
|
||||||
|
};
|
||||||
|
const radarrHistory = {
|
||||||
|
data: {
|
||||||
|
records: radarrHistories.flatMap(h => h.data.records || [])
|
||||||
|
}
|
||||||
|
};
|
||||||
|
const radarrMovies = {
|
||||||
|
data: radarrMoviesResults.flatMap(m => m.data || [])
|
||||||
|
};
|
||||||
|
const radarrTags = {
|
||||||
|
data: radarrTagsResults.flatMap(t => t.data || [])
|
||||||
|
};
|
||||||
|
|
||||||
|
console.log(`[Dashboard] Data fetched successfully`);
|
||||||
|
console.log(`[Dashboard] Sonarr series: ${sonarrSeries.data.length}`);
|
||||||
|
console.log(`[Dashboard] Radarr movies: ${radarrMovies.data.length}`);
|
||||||
|
console.log(`[Dashboard] Radarr queue records: ${radarrQueue.data.records.length}`);
|
||||||
|
console.log(`[Dashboard] Radarr history records: ${radarrHistory.data.records.length}`);
|
||||||
|
console.log(`[Dashboard] SABnzbd queue slots: ${sabnzbdQueue.data.queue ? sabnzbdQueue.data.queue.slots.length : 0}`);
|
||||||
|
console.log(`[Dashboard] SABnzbd history slots: ${sabnzbdHistory.data.history ? sabnzbdHistory.data.history.slots.length : 0}`);
|
||||||
|
console.log(`[Dashboard] qBittorrent torrents: ${qbittorrentTorrents.length}`);
|
||||||
|
console.log(`[Dashboard] Radarr queue:`, JSON.stringify(radarrQueue.data.records));
|
||||||
|
console.log(`[Dashboard] Radarr history:`, JSON.stringify(radarrHistory.data.records));
|
||||||
|
|
||||||
|
// Create maps for quick lookup
|
||||||
|
const seriesMap = new Map(sonarrSeries.data.map(s => [s.id, s]));
|
||||||
|
const moviesMap = new Map(radarrMovies.data.map(m => [m.id, m]));
|
||||||
|
|
||||||
// Create tag maps (id -> label)
|
// Create tag maps (id -> label)
|
||||||
const sonarrTagMap = new Map(sonarrTagsResults.flatMap(t => t.data || []).map(t => [t.id, t.label]));
|
const sonarrTagMap = new Map(sonarrTagsResults.flatMap(t => t.data || []).map(t => [t.id, t.label]));
|
||||||
const radarrTagMap = new Map(radarrTags.data.map(t => [t.id, t.label]));
|
const radarrTagMap = new Map(radarrTags.data.map(t => [t.id, t.label]));
|
||||||
|
console.log(`[Dashboard] Radarr tags:`, JSON.stringify(radarrTags.data));
|
||||||
console.log(`[Dashboard] Cache data - Series: ${seriesMap.size}, Movies: ${moviesMap.size}, qBit: ${qbittorrentTorrents.length}`);
|
console.log(`[Dashboard] Movies map keys:`, Array.from(moviesMap.keys()).slice(0, 10));
|
||||||
|
console.log(`[Dashboard] Looking for movieId: 2962`);
|
||||||
|
console.log(`[Dashboard] Movie 2962:`, JSON.stringify(moviesMap.get(2962)));
|
||||||
|
console.log(`[Dashboard] Sample movie structure:`, JSON.stringify(radarrMovies.data[0]));
|
||||||
|
|
||||||
// Match SABnzbd downloads to Sonarr/Radarr activity
|
// Match SABnzbd downloads to Sonarr/Radarr activity
|
||||||
const userDownloads = [];
|
const userDownloads = [];
|
||||||
@@ -225,8 +303,8 @@ router.get('/user-downloads', async (req, res) => {
|
|||||||
const series = seriesMap.get(sonarrMatch.seriesId) || sonarrMatch.series;
|
const series = seriesMap.get(sonarrMatch.seriesId) || sonarrMatch.series;
|
||||||
if (series) {
|
if (series) {
|
||||||
const userTag = extractUserTag(series.tags, sonarrTagMap);
|
const userTag = extractUserTag(series.tags, sonarrTagMap);
|
||||||
if (userTag && (showAll || tagMatchesUser(userTag, username))) {
|
if (userTag && (showAll || userTag.toLowerCase() === username)) {
|
||||||
const dlObj = {
|
userDownloads.push({
|
||||||
type: 'series',
|
type: 'series',
|
||||||
title: nzbName,
|
title: nzbName,
|
||||||
coverArt: getCoverArt(series),
|
coverArt: getCoverArt(series),
|
||||||
@@ -240,15 +318,7 @@ router.get('/user-downloads', async (req, res) => {
|
|||||||
seriesName: series.title,
|
seriesName: series.title,
|
||||||
episodeInfo: sonarrMatch,
|
episodeInfo: sonarrMatch,
|
||||||
userTag: userTag
|
userTag: userTag
|
||||||
};
|
});
|
||||||
const issues = getImportIssues(sonarrMatch);
|
|
||||||
if (issues) dlObj.importIssues = issues;
|
|
||||||
if (isAdmin) {
|
|
||||||
dlObj.downloadPath = slot.storage || null;
|
|
||||||
dlObj.targetPath = series.path || null;
|
|
||||||
dlObj.arrLink = getSonarrLink(series);
|
|
||||||
}
|
|
||||||
userDownloads.push(dlObj);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -263,8 +333,8 @@ router.get('/user-downloads', async (req, res) => {
|
|||||||
const movie = moviesMap.get(radarrMatch.movieId) || radarrMatch.movie;
|
const movie = moviesMap.get(radarrMatch.movieId) || radarrMatch.movie;
|
||||||
if (movie) {
|
if (movie) {
|
||||||
const userTag = extractUserTag(movie.tags, radarrTagMap);
|
const userTag = extractUserTag(movie.tags, radarrTagMap);
|
||||||
if (userTag && (showAll || tagMatchesUser(userTag, username))) {
|
if (userTag && (showAll || userTag.toLowerCase() === username)) {
|
||||||
const dlObj = {
|
userDownloads.push({
|
||||||
type: 'movie',
|
type: 'movie',
|
||||||
title: nzbName,
|
title: nzbName,
|
||||||
coverArt: getCoverArt(movie),
|
coverArt: getCoverArt(movie),
|
||||||
@@ -278,15 +348,7 @@ router.get('/user-downloads', async (req, res) => {
|
|||||||
movieName: movie.title,
|
movieName: movie.title,
|
||||||
movieInfo: radarrMatch,
|
movieInfo: radarrMatch,
|
||||||
userTag: userTag
|
userTag: userTag
|
||||||
};
|
});
|
||||||
const issues = getImportIssues(radarrMatch);
|
|
||||||
if (issues) dlObj.importIssues = issues;
|
|
||||||
if (isAdmin) {
|
|
||||||
dlObj.downloadPath = slot.storage || null;
|
|
||||||
dlObj.targetPath = movie.path || null;
|
|
||||||
dlObj.arrLink = getRadarrLink(movie);
|
|
||||||
}
|
|
||||||
userDownloads.push(dlObj);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -318,8 +380,8 @@ router.get('/user-downloads', async (req, res) => {
|
|||||||
const series = seriesMap.get(sonarrMatch.seriesId) || sonarrMatch.series;
|
const series = seriesMap.get(sonarrMatch.seriesId) || sonarrMatch.series;
|
||||||
if (series) {
|
if (series) {
|
||||||
const userTag = extractUserTag(series.tags, sonarrTagMap);
|
const userTag = extractUserTag(series.tags, sonarrTagMap);
|
||||||
if (userTag && (showAll || tagMatchesUser(userTag, username))) {
|
if (userTag && (showAll || userTag.toLowerCase() === username)) {
|
||||||
const dlObj = {
|
userDownloads.push({
|
||||||
type: 'series',
|
type: 'series',
|
||||||
title: nzbName,
|
title: nzbName,
|
||||||
coverArt: getCoverArt(series),
|
coverArt: getCoverArt(series),
|
||||||
@@ -329,13 +391,7 @@ router.get('/user-downloads', async (req, res) => {
|
|||||||
seriesName: series.title,
|
seriesName: series.title,
|
||||||
episodeInfo: sonarrMatch,
|
episodeInfo: sonarrMatch,
|
||||||
userTag: userTag
|
userTag: userTag
|
||||||
};
|
});
|
||||||
if (isAdmin) {
|
|
||||||
dlObj.downloadPath = slot.storage || null;
|
|
||||||
dlObj.targetPath = series.path || null;
|
|
||||||
dlObj.arrLink = getSonarrLink(series);
|
|
||||||
}
|
|
||||||
userDownloads.push(dlObj);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -350,8 +406,8 @@ router.get('/user-downloads', async (req, res) => {
|
|||||||
const movie = moviesMap.get(radarrMatch.movieId) || radarrMatch.movie;
|
const movie = moviesMap.get(radarrMatch.movieId) || radarrMatch.movie;
|
||||||
if (movie) {
|
if (movie) {
|
||||||
const userTag = extractUserTag(movie.tags, radarrTagMap);
|
const userTag = extractUserTag(movie.tags, radarrTagMap);
|
||||||
if (userTag && (showAll || tagMatchesUser(userTag, username))) {
|
if (userTag && (showAll || userTag.toLowerCase() === username)) {
|
||||||
const dlObj = {
|
userDownloads.push({
|
||||||
type: 'movie',
|
type: 'movie',
|
||||||
title: nzbName,
|
title: nzbName,
|
||||||
coverArt: getCoverArt(movie),
|
coverArt: getCoverArt(movie),
|
||||||
@@ -361,13 +417,7 @@ router.get('/user-downloads', async (req, res) => {
|
|||||||
movieName: movie.title,
|
movieName: movie.title,
|
||||||
movieInfo: radarrMatch,
|
movieInfo: radarrMatch,
|
||||||
userTag: userTag
|
userTag: userTag
|
||||||
};
|
});
|
||||||
if (isAdmin) {
|
|
||||||
dlObj.downloadPath = slot.storage || null;
|
|
||||||
dlObj.targetPath = movie.path || null;
|
|
||||||
dlObj.arrLink = getRadarrLink(movie);
|
|
||||||
}
|
|
||||||
userDownloads.push(dlObj);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -386,14 +436,14 @@ router.get('/user-downloads', async (req, res) => {
|
|||||||
console.log(`[Dashboard] Sonarr tag map:`, Array.from(sonarrTagMap.entries()));
|
console.log(`[Dashboard] Sonarr tag map:`, Array.from(sonarrTagMap.entries()));
|
||||||
console.log(`[Dashboard] Radarr tag map:`, Array.from(radarrTagMap.entries()));
|
console.log(`[Dashboard] Radarr tag map:`, Array.from(radarrTagMap.entries()));
|
||||||
|
|
||||||
// Show movies/series tagged for this user (from embedded objects in queue/history)
|
// Show movies/series tagged for this user
|
||||||
const userMovies = Array.from(moviesMap.values()).filter(m => {
|
const userMovies = radarrMovies.data.filter(m => {
|
||||||
const tag = extractUserTag(m.tags, radarrTagMap);
|
const tag = extractUserTag(m.tags, radarrTagMap);
|
||||||
return tag && tagMatchesUser(tag, username);
|
return tag && tag.toLowerCase() === username;
|
||||||
});
|
});
|
||||||
const userSeries = Array.from(seriesMap.values()).filter(s => {
|
const userSeries = sonarrSeries.data.filter(s => {
|
||||||
const tag = extractUserTag(s.tags, sonarrTagMap);
|
const tag = extractUserTag(s.tags, sonarrTagMap);
|
||||||
return tag && tagMatchesUser(tag, username);
|
return tag && tag.toLowerCase() === username;
|
||||||
});
|
});
|
||||||
console.log(`[Dashboard] Movies tagged for ${username}:`, userMovies.map(m => m.title));
|
console.log(`[Dashboard] Movies tagged for ${username}:`, userMovies.map(m => m.title));
|
||||||
console.log(`[Dashboard] Series tagged for ${username}:`, userSeries.map(s => s.title));
|
console.log(`[Dashboard] Series tagged for ${username}:`, userSeries.map(s => s.title));
|
||||||
@@ -418,7 +468,7 @@ router.get('/user-downloads', async (req, res) => {
|
|||||||
const series = seriesMap.get(sonarrMatch.seriesId) || sonarrMatch.series;
|
const series = seriesMap.get(sonarrMatch.seriesId) || sonarrMatch.series;
|
||||||
if (series) {
|
if (series) {
|
||||||
const userTag = extractUserTag(series.tags, sonarrTagMap);
|
const userTag = extractUserTag(series.tags, sonarrTagMap);
|
||||||
if (userTag && (showAll || tagMatchesUser(userTag, username))) {
|
if (userTag && (showAll || userTag.toLowerCase() === username)) {
|
||||||
console.log(`[Dashboard] Matched torrent "${torrentName}" to Sonarr series "${series.title}"`);
|
console.log(`[Dashboard] Matched torrent "${torrentName}" to Sonarr series "${series.title}"`);
|
||||||
const download = mapTorrentToDownload(torrent);
|
const download = mapTorrentToDownload(torrent);
|
||||||
download.type = 'series';
|
download.type = 'series';
|
||||||
@@ -426,13 +476,6 @@ router.get('/user-downloads', async (req, res) => {
|
|||||||
download.seriesName = series.title;
|
download.seriesName = series.title;
|
||||||
download.episodeInfo = sonarrMatch;
|
download.episodeInfo = sonarrMatch;
|
||||||
download.userTag = userTag;
|
download.userTag = userTag;
|
||||||
const sonarrIssues = getImportIssues(sonarrMatch);
|
|
||||||
if (sonarrIssues) download.importIssues = sonarrIssues;
|
|
||||||
if (isAdmin) {
|
|
||||||
download.downloadPath = download.savePath || null;
|
|
||||||
download.targetPath = series.path || null;
|
|
||||||
download.arrLink = getSonarrLink(series);
|
|
||||||
}
|
|
||||||
userDownloads.push(download);
|
userDownloads.push(download);
|
||||||
continue; // Skip to next torrent
|
continue; // Skip to next torrent
|
||||||
}
|
}
|
||||||
@@ -449,7 +492,7 @@ router.get('/user-downloads', async (req, res) => {
|
|||||||
const movie = moviesMap.get(radarrMatch.movieId) || radarrMatch.movie;
|
const movie = moviesMap.get(radarrMatch.movieId) || radarrMatch.movie;
|
||||||
if (movie) {
|
if (movie) {
|
||||||
const userTag = extractUserTag(movie.tags, radarrTagMap);
|
const userTag = extractUserTag(movie.tags, radarrTagMap);
|
||||||
if (userTag && (showAll || tagMatchesUser(userTag, username))) {
|
if (userTag && (showAll || userTag.toLowerCase() === username)) {
|
||||||
console.log(`[Dashboard] Matched torrent "${torrentName}" to Radarr movie "${movie.title}"`);
|
console.log(`[Dashboard] Matched torrent "${torrentName}" to Radarr movie "${movie.title}"`);
|
||||||
const download = mapTorrentToDownload(torrent);
|
const download = mapTorrentToDownload(torrent);
|
||||||
download.type = 'movie';
|
download.type = 'movie';
|
||||||
@@ -457,13 +500,6 @@ router.get('/user-downloads', async (req, res) => {
|
|||||||
download.movieName = movie.title;
|
download.movieName = movie.title;
|
||||||
download.movieInfo = radarrMatch;
|
download.movieInfo = radarrMatch;
|
||||||
download.userTag = userTag;
|
download.userTag = userTag;
|
||||||
const radarrIssues = getImportIssues(radarrMatch);
|
|
||||||
if (radarrIssues) download.importIssues = radarrIssues;
|
|
||||||
if (isAdmin) {
|
|
||||||
download.downloadPath = download.savePath || null;
|
|
||||||
download.targetPath = movie.path || null;
|
|
||||||
download.arrLink = getRadarrLink(movie);
|
|
||||||
}
|
|
||||||
userDownloads.push(download);
|
userDownloads.push(download);
|
||||||
continue; // Skip to next torrent
|
continue; // Skip to next torrent
|
||||||
}
|
}
|
||||||
@@ -480,7 +516,7 @@ router.get('/user-downloads', async (req, res) => {
|
|||||||
const series = seriesMap.get(sonarrHistoryMatch.seriesId) || sonarrHistoryMatch.series;
|
const series = seriesMap.get(sonarrHistoryMatch.seriesId) || sonarrHistoryMatch.series;
|
||||||
if (series) {
|
if (series) {
|
||||||
const userTag = extractUserTag(series.tags, sonarrTagMap);
|
const userTag = extractUserTag(series.tags, sonarrTagMap);
|
||||||
if (userTag && (showAll || tagMatchesUser(userTag, username))) {
|
if (userTag && (showAll || userTag.toLowerCase() === username)) {
|
||||||
console.log(`[Dashboard] Matched torrent "${torrentName}" to Sonarr history "${series.title}"`);
|
console.log(`[Dashboard] Matched torrent "${torrentName}" to Sonarr history "${series.title}"`);
|
||||||
const download = mapTorrentToDownload(torrent);
|
const download = mapTorrentToDownload(torrent);
|
||||||
download.type = 'series';
|
download.type = 'series';
|
||||||
@@ -488,11 +524,6 @@ router.get('/user-downloads', async (req, res) => {
|
|||||||
download.seriesName = series.title;
|
download.seriesName = series.title;
|
||||||
download.episodeInfo = sonarrHistoryMatch;
|
download.episodeInfo = sonarrHistoryMatch;
|
||||||
download.userTag = userTag;
|
download.userTag = userTag;
|
||||||
if (isAdmin) {
|
|
||||||
download.downloadPath = download.savePath || null;
|
|
||||||
download.targetPath = series.path || null;
|
|
||||||
download.arrLink = getSonarrLink(series);
|
|
||||||
}
|
|
||||||
userDownloads.push(download);
|
userDownloads.push(download);
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
@@ -509,7 +540,7 @@ router.get('/user-downloads', async (req, res) => {
|
|||||||
const movie = moviesMap.get(radarrHistoryMatch.movieId) || radarrHistoryMatch.movie;
|
const movie = moviesMap.get(radarrHistoryMatch.movieId) || radarrHistoryMatch.movie;
|
||||||
if (movie) {
|
if (movie) {
|
||||||
const userTag = extractUserTag(movie.tags, radarrTagMap);
|
const userTag = extractUserTag(movie.tags, radarrTagMap);
|
||||||
if (userTag && (showAll || tagMatchesUser(userTag, username))) {
|
if (userTag && (showAll || userTag.toLowerCase() === username)) {
|
||||||
console.log(`[Dashboard] Matched torrent "${torrentName}" to Radarr history "${movie.title}"`);
|
console.log(`[Dashboard] Matched torrent "${torrentName}" to Radarr history "${movie.title}"`);
|
||||||
const download = mapTorrentToDownload(torrent);
|
const download = mapTorrentToDownload(torrent);
|
||||||
download.type = 'movie';
|
download.type = 'movie';
|
||||||
@@ -517,11 +548,6 @@ router.get('/user-downloads', async (req, res) => {
|
|||||||
download.movieName = movie.title;
|
download.movieName = movie.title;
|
||||||
download.movieInfo = radarrHistoryMatch;
|
download.movieInfo = radarrHistoryMatch;
|
||||||
download.userTag = userTag;
|
download.userTag = userTag;
|
||||||
if (isAdmin) {
|
|
||||||
download.downloadPath = download.savePath || null;
|
|
||||||
download.targetPath = movie.path || null;
|
|
||||||
download.arrLink = getRadarrLink(movie);
|
|
||||||
}
|
|
||||||
userDownloads.push(download);
|
userDownloads.push(download);
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
@@ -629,40 +655,4 @@ router.get('/user-summary', async (req, res) => {
|
|||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
// Admin-only status page with cache stats
|
|
||||||
router.get('/status', (req, res) => {
|
|
||||||
try {
|
|
||||||
const userCookie = req.cookies.emby_user;
|
|
||||||
if (!userCookie) {
|
|
||||||
return res.status(401).json({ error: 'Not authenticated' });
|
|
||||||
}
|
|
||||||
const user = JSON.parse(userCookie);
|
|
||||||
if (!user.isAdmin) {
|
|
||||||
return res.status(403).json({ error: 'Admin access required' });
|
|
||||||
}
|
|
||||||
|
|
||||||
const cacheStats = cache.getStats();
|
|
||||||
const uptime = process.uptime();
|
|
||||||
|
|
||||||
res.json({
|
|
||||||
server: {
|
|
||||||
uptimeSeconds: Math.floor(uptime),
|
|
||||||
nodeVersion: process.version,
|
|
||||||
memoryUsageMB: Math.round(process.memoryUsage().rss / 1024 / 1024 * 10) / 10,
|
|
||||||
heapUsedMB: Math.round(process.memoryUsage().heapUsed / 1024 / 1024 * 10) / 10,
|
|
||||||
heapTotalMB: Math.round(process.memoryUsage().heapTotal / 1024 / 1024 * 10) / 10
|
|
||||||
},
|
|
||||||
polling: {
|
|
||||||
enabled: POLLING_ENABLED,
|
|
||||||
intervalMs: POLLING_ENABLED ? require('../utils/poller').POLL_INTERVAL : 0,
|
|
||||||
lastPoll: getLastPollTimings()
|
|
||||||
},
|
|
||||||
cache: cacheStats,
|
|
||||||
clients: getActiveClients()
|
|
||||||
});
|
|
||||||
} catch (err) {
|
|
||||||
res.status(500).json({ error: 'Failed to get status', details: err.message });
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
module.exports = router;
|
module.exports = router;
|
||||||
|
|||||||
@@ -1,70 +0,0 @@
|
|||||||
const { logToFile } = require('./logger');
|
|
||||||
|
|
||||||
class MemoryCache {
|
|
||||||
constructor() {
|
|
||||||
this.store = new Map();
|
|
||||||
}
|
|
||||||
|
|
||||||
get(key) {
|
|
||||||
const entry = this.store.get(key);
|
|
||||||
if (!entry) return null;
|
|
||||||
if (Date.now() > entry.expiresAt) {
|
|
||||||
this.store.delete(key);
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
return entry.value;
|
|
||||||
}
|
|
||||||
|
|
||||||
set(key, value, ttlMs) {
|
|
||||||
this.store.set(key, {
|
|
||||||
value,
|
|
||||||
expiresAt: Date.now() + ttlMs
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
invalidate(key) {
|
|
||||||
this.store.delete(key);
|
|
||||||
}
|
|
||||||
|
|
||||||
clear() {
|
|
||||||
this.store.clear();
|
|
||||||
}
|
|
||||||
|
|
||||||
getStats() {
|
|
||||||
const now = Date.now();
|
|
||||||
const entries = [];
|
|
||||||
let totalSize = 0;
|
|
||||||
|
|
||||||
for (const [key, entry] of this.store.entries()) {
|
|
||||||
const json = JSON.stringify(entry.value);
|
|
||||||
const sizeBytes = Buffer.byteLength(json, 'utf8');
|
|
||||||
totalSize += sizeBytes;
|
|
||||||
const ttlRemaining = Math.max(0, entry.expiresAt - now);
|
|
||||||
const expired = now > entry.expiresAt;
|
|
||||||
let itemCount = null;
|
|
||||||
if (Array.isArray(entry.value)) {
|
|
||||||
itemCount = entry.value.length;
|
|
||||||
} else if (entry.value && typeof entry.value === 'object') {
|
|
||||||
if (Array.isArray(entry.value.records)) itemCount = entry.value.records.length;
|
|
||||||
else if (Array.isArray(entry.value.slots)) itemCount = entry.value.slots.length;
|
|
||||||
}
|
|
||||||
entries.push({
|
|
||||||
key,
|
|
||||||
sizeBytes,
|
|
||||||
itemCount,
|
|
||||||
ttlRemainingMs: ttlRemaining,
|
|
||||||
expired
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
return {
|
|
||||||
entryCount: this.store.size,
|
|
||||||
totalSizeBytes: totalSize,
|
|
||||||
entries
|
|
||||||
};
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
const cache = new MemoryCache();
|
|
||||||
|
|
||||||
module.exports = cache;
|
|
||||||
@@ -1,219 +0,0 @@
|
|||||||
const axios = require('axios');
|
|
||||||
const cache = require('./cache');
|
|
||||||
const { getTorrents } = require('./qbittorrent');
|
|
||||||
const {
|
|
||||||
getSABnzbdInstances,
|
|
||||||
getSonarrInstances,
|
|
||||||
getRadarrInstances
|
|
||||||
} = require('./config');
|
|
||||||
|
|
||||||
const rawPollInterval = (process.env.POLL_INTERVAL || '').toLowerCase();
|
|
||||||
const POLL_INTERVAL = (rawPollInterval === 'off' || rawPollInterval === 'false' || rawPollInterval === 'disabled')
|
|
||||||
? 0
|
|
||||||
: (parseInt(process.env.POLL_INTERVAL, 10) || 5000);
|
|
||||||
const POLLING_ENABLED = POLL_INTERVAL > 0;
|
|
||||||
|
|
||||||
let polling = false;
|
|
||||||
let lastPollTimings = null;
|
|
||||||
|
|
||||||
// Timed fetch helper: runs a fetch and records how long it took
|
|
||||||
async function timed(label, fn) {
|
|
||||||
const t0 = Date.now();
|
|
||||||
const result = await fn();
|
|
||||||
return { label, result, ms: Date.now() - t0 };
|
|
||||||
}
|
|
||||||
|
|
||||||
async function pollAllServices() {
|
|
||||||
if (polling) {
|
|
||||||
console.log('[Poller] Previous poll still running, skipping');
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
polling = true;
|
|
||||||
const start = Date.now();
|
|
||||||
|
|
||||||
try {
|
|
||||||
const sabInstances = getSABnzbdInstances();
|
|
||||||
const sonarrInstances = getSonarrInstances();
|
|
||||||
const radarrInstances = getRadarrInstances();
|
|
||||||
|
|
||||||
// All fetches in parallel, each individually timed
|
|
||||||
const results = await Promise.all([
|
|
||||||
timed('SABnzbd Queue', () => Promise.all(sabInstances.map(inst =>
|
|
||||||
axios.get(`${inst.url}/api`, {
|
|
||||||
params: { mode: 'queue', apikey: inst.apiKey, output: 'json' }
|
|
||||||
}).then(res => ({ instance: inst.id, data: res.data })).catch(err => {
|
|
||||||
console.error(`[Poller] SABnzbd ${inst.id} queue error:`, err.message);
|
|
||||||
return { instance: inst.id, data: { queue: { slots: [] } } };
|
|
||||||
})
|
|
||||||
))),
|
|
||||||
timed('SABnzbd History', () => Promise.all(sabInstances.map(inst =>
|
|
||||||
axios.get(`${inst.url}/api`, {
|
|
||||||
params: { mode: 'history', apikey: inst.apiKey, output: 'json', limit: 10 }
|
|
||||||
}).then(res => ({ instance: inst.id, data: res.data })).catch(err => {
|
|
||||||
console.error(`[Poller] SABnzbd ${inst.id} history error:`, err.message);
|
|
||||||
return { instance: inst.id, data: { history: { slots: [] } } };
|
|
||||||
})
|
|
||||||
))),
|
|
||||||
timed('Sonarr Tags', () => Promise.all(sonarrInstances.map(inst =>
|
|
||||||
axios.get(`${inst.url}/api/v3/tag`, {
|
|
||||||
headers: { 'X-Api-Key': inst.apiKey }
|
|
||||||
}).then(res => ({ instance: inst.id, data: res.data })).catch(err => {
|
|
||||||
console.error(`[Poller] Sonarr ${inst.id} tags error:`, err.message);
|
|
||||||
return { instance: inst.id, data: [] };
|
|
||||||
})
|
|
||||||
))),
|
|
||||||
timed('Sonarr Queue', () => Promise.all(sonarrInstances.map(inst =>
|
|
||||||
axios.get(`${inst.url}/api/v3/queue`, {
|
|
||||||
headers: { 'X-Api-Key': inst.apiKey },
|
|
||||||
params: { includeSeries: true }
|
|
||||||
}).then(res => ({ instance: inst.id, data: res.data })).catch(err => {
|
|
||||||
console.error(`[Poller] Sonarr ${inst.id} queue error:`, err.message);
|
|
||||||
return { instance: inst.id, data: { records: [] } };
|
|
||||||
})
|
|
||||||
))),
|
|
||||||
timed('Sonarr History', () => Promise.all(sonarrInstances.map(inst =>
|
|
||||||
axios.get(`${inst.url}/api/v3/history`, {
|
|
||||||
headers: { 'X-Api-Key': inst.apiKey },
|
|
||||||
params: { pageSize: 10 }
|
|
||||||
}).then(res => ({ instance: inst.id, data: res.data })).catch(err => {
|
|
||||||
console.error(`[Poller] Sonarr ${inst.id} history error:`, err.message);
|
|
||||||
return { instance: inst.id, data: { records: [] } };
|
|
||||||
})
|
|
||||||
))),
|
|
||||||
timed('Radarr Queue', () => Promise.all(radarrInstances.map(inst =>
|
|
||||||
axios.get(`${inst.url}/api/v3/queue`, {
|
|
||||||
headers: { 'X-Api-Key': inst.apiKey },
|
|
||||||
params: { includeMovie: true }
|
|
||||||
}).then(res => ({ instance: inst.id, data: res.data })).catch(err => {
|
|
||||||
console.error(`[Poller] Radarr ${inst.id} queue error:`, err.message);
|
|
||||||
return { instance: inst.id, data: { records: [] } };
|
|
||||||
})
|
|
||||||
))),
|
|
||||||
timed('Radarr History', () => Promise.all(radarrInstances.map(inst =>
|
|
||||||
axios.get(`${inst.url}/api/v3/history`, {
|
|
||||||
headers: { 'X-Api-Key': inst.apiKey },
|
|
||||||
params: { pageSize: 10 }
|
|
||||||
}).then(res => ({ instance: inst.id, data: res.data })).catch(err => {
|
|
||||||
console.error(`[Poller] Radarr ${inst.id} history error:`, err.message);
|
|
||||||
return { instance: inst.id, data: { records: [] } };
|
|
||||||
})
|
|
||||||
))),
|
|
||||||
timed('Radarr Tags', () => Promise.all(radarrInstances.map(inst =>
|
|
||||||
axios.get(`${inst.url}/api/v3/tag`, {
|
|
||||||
headers: { 'X-Api-Key': inst.apiKey }
|
|
||||||
}).then(res => ({ instance: inst.id, data: res.data })).catch(err => {
|
|
||||||
console.error(`[Poller] Radarr ${inst.id} tags error:`, err.message);
|
|
||||||
return { instance: inst.id, data: [] };
|
|
||||||
})
|
|
||||||
))),
|
|
||||||
timed('qBittorrent', () => getTorrents().catch(err => {
|
|
||||||
console.error(`[Poller] qBittorrent error:`, err.message);
|
|
||||||
return [];
|
|
||||||
}))
|
|
||||||
]);
|
|
||||||
|
|
||||||
const [
|
|
||||||
{ result: sabQueues }, { result: sabHistories },
|
|
||||||
{ result: sonarrTagsResults }, { result: sonarrQueues },
|
|
||||||
{ result: sonarrHistories },
|
|
||||||
{ result: radarrQueues }, { result: radarrHistories },
|
|
||||||
{ result: radarrTagsResults },
|
|
||||||
{ result: qbittorrentTorrents }
|
|
||||||
] = results;
|
|
||||||
|
|
||||||
// Store per-task timings
|
|
||||||
const totalMs = Date.now() - start;
|
|
||||||
lastPollTimings = {
|
|
||||||
totalMs,
|
|
||||||
timestamp: new Date().toISOString(),
|
|
||||||
tasks: results.map(r => ({ label: r.label, ms: r.ms }))
|
|
||||||
};
|
|
||||||
|
|
||||||
// When polling is active, TTL is 3x interval to avoid gaps between polls
|
|
||||||
// When polling is disabled (on-demand), use 30s so data refreshes on next request after expiry
|
|
||||||
const cacheTTL = POLLING_ENABLED ? POLL_INTERVAL * 3 : 30000;
|
|
||||||
|
|
||||||
// SABnzbd
|
|
||||||
const firstSabQueue = sabQueues[0] && sabQueues[0].data && sabQueues[0].data.queue;
|
|
||||||
cache.set('poll:sab-queue', {
|
|
||||||
slots: sabQueues.flatMap(q => (q.data.queue && q.data.queue.slots) || []),
|
|
||||||
status: firstSabQueue && firstSabQueue.status,
|
|
||||||
speed: firstSabQueue && firstSabQueue.speed,
|
|
||||||
kbpersec: firstSabQueue && firstSabQueue.kbpersec
|
|
||||||
}, cacheTTL);
|
|
||||||
|
|
||||||
cache.set('poll:sab-history', {
|
|
||||||
slots: sabHistories.flatMap(h => (h.data.history && h.data.history.slots) || [])
|
|
||||||
}, cacheTTL);
|
|
||||||
|
|
||||||
// Sonarr
|
|
||||||
cache.set('poll:sonarr-tags', sonarrTagsResults, cacheTTL);
|
|
||||||
// Tag queue/history records with _instanceUrl so embedded series/movie objects can build links
|
|
||||||
cache.set('poll:sonarr-queue', {
|
|
||||||
records: sonarrQueues.flatMap(q => {
|
|
||||||
const inst = sonarrInstances.find(i => i.id === q.instance);
|
|
||||||
const url = inst ? inst.url : null;
|
|
||||||
return (q.data.records || []).map(r => {
|
|
||||||
if (r.series) r.series._instanceUrl = url;
|
|
||||||
return r;
|
|
||||||
});
|
|
||||||
})
|
|
||||||
}, cacheTTL);
|
|
||||||
cache.set('poll:sonarr-history', {
|
|
||||||
records: sonarrHistories.flatMap(h => h.data.records || [])
|
|
||||||
}, cacheTTL);
|
|
||||||
|
|
||||||
// Radarr
|
|
||||||
cache.set('poll:radarr-queue', {
|
|
||||||
records: radarrQueues.flatMap(q => {
|
|
||||||
const inst = radarrInstances.find(i => i.id === q.instance);
|
|
||||||
const url = inst ? inst.url : null;
|
|
||||||
return (q.data.records || []).map(r => {
|
|
||||||
if (r.movie) r.movie._instanceUrl = url;
|
|
||||||
return r;
|
|
||||||
});
|
|
||||||
})
|
|
||||||
}, cacheTTL);
|
|
||||||
cache.set('poll:radarr-history', {
|
|
||||||
records: radarrHistories.flatMap(h => h.data.records || [])
|
|
||||||
}, cacheTTL);
|
|
||||||
cache.set('poll:radarr-tags', radarrTagsResults.flatMap(t => t.data || []), cacheTTL);
|
|
||||||
|
|
||||||
// qBittorrent
|
|
||||||
cache.set('poll:qbittorrent', qbittorrentTorrents, cacheTTL);
|
|
||||||
|
|
||||||
const elapsed = Date.now() - start;
|
|
||||||
console.log(`[Poller] Poll complete in ${elapsed}ms`);
|
|
||||||
} catch (err) {
|
|
||||||
console.error(`[Poller] Poll error:`, err.message);
|
|
||||||
} finally {
|
|
||||||
polling = false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
let intervalHandle = null;
|
|
||||||
|
|
||||||
function startPoller() {
|
|
||||||
if (!POLLING_ENABLED) {
|
|
||||||
console.log(`[Poller] Background polling disabled (POLL_INTERVAL=${process.env.POLL_INTERVAL || 'not set'}). Data will be fetched on-demand.`);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
console.log(`[Poller] Starting background poller (interval: ${POLL_INTERVAL}ms)`);
|
|
||||||
// Run immediately, then on interval
|
|
||||||
pollAllServices();
|
|
||||||
intervalHandle = setInterval(pollAllServices, POLL_INTERVAL);
|
|
||||||
}
|
|
||||||
|
|
||||||
function stopPoller() {
|
|
||||||
if (intervalHandle) {
|
|
||||||
clearInterval(intervalHandle);
|
|
||||||
intervalHandle = null;
|
|
||||||
console.log('[Poller] Stopped');
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
function getLastPollTimings() {
|
|
||||||
return lastPollTimings;
|
|
||||||
}
|
|
||||||
|
|
||||||
module.exports = { startPoller, stopPoller, pollAllServices, getLastPollTimings, POLL_INTERVAL, POLLING_ENABLED };
|
|
||||||
@@ -96,19 +96,14 @@ class QBittorrentClient {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Persist clients so auth cookies survive between requests
|
|
||||||
let persistedClients = null;
|
|
||||||
|
|
||||||
function getClients() {
|
function getClients() {
|
||||||
if (persistedClients) return persistedClients;
|
|
||||||
const instances = getQbittorrentInstances();
|
const instances = getQbittorrentInstances();
|
||||||
if (instances.length === 0) {
|
if (instances.length === 0) {
|
||||||
logToFile('[qBittorrent] No instances configured');
|
logToFile('[qBittorrent] No instances configured');
|
||||||
return [];
|
return [];
|
||||||
}
|
}
|
||||||
logToFile(`[qBittorrent] Created ${instances.length} persistent client(s)`);
|
logToFile(`[qBittorrent] Created ${instances.length} client(s)`);
|
||||||
persistedClients = instances.map(inst => new QBittorrentClient(inst));
|
return instances.map(inst => new QBittorrentClient(inst));
|
||||||
return persistedClients;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
async function getAllTorrents() {
|
async function getAllTorrents() {
|
||||||
@@ -203,7 +198,6 @@ function mapTorrentToDownload(torrent) {
|
|||||||
hash: torrent.hash,
|
hash: torrent.hash,
|
||||||
category: torrent.category,
|
category: torrent.category,
|
||||||
tags: torrent.tags,
|
tags: torrent.tags,
|
||||||
savePath: torrent.content_path || torrent.save_path || null,
|
|
||||||
qbittorrent: true
|
qbittorrent: true
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user