Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| aea4aef4b2 |
@@ -1,49 +0,0 @@
|
|||||||
---
|
|
||||||
description: Новые React-компоненты — папка kebab-case, TSX + CSS module, index.ts (furumi-node-player/client/src)
|
|
||||||
globs: furumi-node-player/client/src/**/*
|
|
||||||
alwaysApply: false
|
|
||||||
---
|
|
||||||
|
|
||||||
# Структура новых компонентов (furumi-node-player/client)
|
|
||||||
|
|
||||||
**Область:** при добавлении **нового** компонента в `furumi-node-player/client/src/` используйте расположение и файлы ниже.
|
|
||||||
|
|
||||||
## Расположение
|
|
||||||
|
|
||||||
- Базовая папка: `furumi-node-player/client/src/components/`
|
|
||||||
- Для каждого компонента — **отдельная подпапка** с именем в **kebab-case** (например `play-button`, `search-dropdown`).
|
|
||||||
|
|
||||||
## Файлы внутри папки компонента
|
|
||||||
|
|
||||||
1. **Компонент:** `components/<имя-kebab>/<имя-kebab>.tsx` — реализация компонента; к нему подключён CSS-модуль (`import styles from './<имя-kebab>.module.css'`).
|
|
||||||
2. **Стили:** `components/<имя-kebab>/<имя-kebab>.module.css` — модульные стили для этого компонента.
|
|
||||||
3. **Баррель:** `components/<имя-kebab>/index.ts` — **реэкспорт всего** из файла компонента: `export * from './<имя-kebab>'`.
|
|
||||||
|
|
||||||
Импорт снаружи: `import { MyWidget } from './components/my-widget'` (относительный путь к папке), без указания `index.ts`.
|
|
||||||
|
|
||||||
## Пример (`my-widget`)
|
|
||||||
|
|
||||||
```
|
|
||||||
components/my-widget/
|
|
||||||
my-widget.tsx
|
|
||||||
my-widget.module.css
|
|
||||||
index.ts
|
|
||||||
```
|
|
||||||
|
|
||||||
```typescript
|
|
||||||
// my-widget.tsx
|
|
||||||
import styles from './my-widget.module.css'
|
|
||||||
|
|
||||||
export function MyWidget() {
|
|
||||||
return <div className={styles.root}>…</div>
|
|
||||||
}
|
|
||||||
```
|
|
||||||
|
|
||||||
```typescript
|
|
||||||
// index.ts
|
|
||||||
export * from './my-widget'
|
|
||||||
```
|
|
||||||
|
|
||||||
## Примечание
|
|
||||||
|
|
||||||
Существующие файлы-компоненты в корне `components/` (один файл без папки) — наследие; **новые** компоненты добавляйте только по структуре выше.
|
|
||||||
@@ -1,40 +0,0 @@
|
|||||||
name: Publish Node Player Image (dev)
|
|
||||||
|
|
||||||
on:
|
|
||||||
push:
|
|
||||||
branches:
|
|
||||||
- DEV
|
|
||||||
|
|
||||||
env:
|
|
||||||
REGISTRY: docker.io
|
|
||||||
IMAGE_NAME: ${{ secrets.DOCKERHUB_USERNAME }}/furumi-node-player
|
|
||||||
|
|
||||||
jobs:
|
|
||||||
build-and-push-image:
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
permissions:
|
|
||||||
contents: read
|
|
||||||
packages: write
|
|
||||||
|
|
||||||
steps:
|
|
||||||
- name: Checkout repository
|
|
||||||
uses: actions/checkout@v4
|
|
||||||
|
|
||||||
- name: Set up Docker Buildx
|
|
||||||
uses: docker/setup-buildx-action@v3
|
|
||||||
|
|
||||||
- name: Log in to Docker Hub
|
|
||||||
uses: docker/login-action@v3
|
|
||||||
with:
|
|
||||||
username: ${{ secrets.DOCKERHUB_USERNAME }}
|
|
||||||
password: ${{ secrets.DOCKERHUB_TOKEN }}
|
|
||||||
|
|
||||||
- name: Build and push Docker image
|
|
||||||
uses: docker/build-push-action@v5
|
|
||||||
with:
|
|
||||||
context: .
|
|
||||||
file: docker/Dockerfile.node-player
|
|
||||||
push: true
|
|
||||||
tags: ${{ env.REGISTRY }}/${{ env.IMAGE_NAME }}:dev
|
|
||||||
cache-from: type=gha
|
|
||||||
cache-to: type=gha,mode=max
|
|
||||||
@@ -1,57 +0,0 @@
|
|||||||
name: Publish Node Player Image
|
|
||||||
|
|
||||||
on:
|
|
||||||
push:
|
|
||||||
branches:
|
|
||||||
- '**'
|
|
||||||
- '!DEV'
|
|
||||||
tags:
|
|
||||||
- 'v*.*.*'
|
|
||||||
|
|
||||||
env:
|
|
||||||
REGISTRY: docker.io
|
|
||||||
IMAGE_NAME: ${{ secrets.DOCKERHUB_USERNAME }}/furumi-node-player
|
|
||||||
|
|
||||||
jobs:
|
|
||||||
build-and-push-image:
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
permissions:
|
|
||||||
contents: read
|
|
||||||
packages: write
|
|
||||||
|
|
||||||
steps:
|
|
||||||
- name: Checkout repository
|
|
||||||
uses: actions/checkout@v4
|
|
||||||
|
|
||||||
- name: Set up Docker Buildx
|
|
||||||
uses: docker/setup-buildx-action@v3
|
|
||||||
|
|
||||||
- name: Log in to Docker Hub
|
|
||||||
uses: docker/login-action@v3
|
|
||||||
with:
|
|
||||||
username: ${{ secrets.DOCKERHUB_USERNAME }}
|
|
||||||
password: ${{ secrets.DOCKERHUB_TOKEN }}
|
|
||||||
|
|
||||||
- name: Determine version and tags
|
|
||||||
id: info
|
|
||||||
run: |
|
|
||||||
IMAGE="${{ env.REGISTRY }}/${{ env.IMAGE_NAME }}"
|
|
||||||
SHORT_SHA="$(echo '${{ github.sha }}' | cut -c1-7)"
|
|
||||||
|
|
||||||
if [[ "${{ github.ref }}" == refs/tags/v* ]]; then
|
|
||||||
TAG="${{ github.ref_name }}"
|
|
||||||
VERSION="${TAG#v}"
|
|
||||||
echo "tags=${IMAGE}:${VERSION},${IMAGE}:latest" >> "$GITHUB_OUTPUT"
|
|
||||||
else
|
|
||||||
echo "tags=${IMAGE}:trunk,${IMAGE}:${SHORT_SHA}" >> "$GITHUB_OUTPUT"
|
|
||||||
fi
|
|
||||||
|
|
||||||
- name: Build and push Docker image
|
|
||||||
uses: docker/build-push-action@v5
|
|
||||||
with:
|
|
||||||
context: .
|
|
||||||
file: docker/Dockerfile.node-player
|
|
||||||
push: true
|
|
||||||
tags: ${{ steps.info.outputs.tags }}
|
|
||||||
cache-from: type=gha
|
|
||||||
cache-to: type=gha,mode=max
|
|
||||||
+2
-2
@@ -1,4 +1,4 @@
|
|||||||
/target
|
/target
|
||||||
/docker/inbox
|
/inbox
|
||||||
/docker/storage
|
/storage
|
||||||
.env
|
.env
|
||||||
|
|||||||
Generated
+1
-18
@@ -1114,7 +1114,7 @@ dependencies = [
|
|||||||
"futures-core",
|
"futures-core",
|
||||||
"futures-util",
|
"futures-util",
|
||||||
"hmac",
|
"hmac",
|
||||||
"jsonwebtoken 10.3.0",
|
"jsonwebtoken",
|
||||||
"libc",
|
"libc",
|
||||||
"mime_guess",
|
"mime_guess",
|
||||||
"ogg",
|
"ogg",
|
||||||
@@ -1152,7 +1152,6 @@ dependencies = [
|
|||||||
"base64 0.22.1",
|
"base64 0.22.1",
|
||||||
"clap",
|
"clap",
|
||||||
"hmac",
|
"hmac",
|
||||||
"jsonwebtoken 9.3.1",
|
|
||||||
"mime_guess",
|
"mime_guess",
|
||||||
"openidconnect",
|
"openidconnect",
|
||||||
"rand 0.8.5",
|
"rand 0.8.5",
|
||||||
@@ -1166,7 +1165,6 @@ dependencies = [
|
|||||||
"tokio",
|
"tokio",
|
||||||
"tokio-util",
|
"tokio-util",
|
||||||
"tower 0.4.13",
|
"tower 0.4.13",
|
||||||
"tower-http",
|
|
||||||
"tracing",
|
"tracing",
|
||||||
"tracing-subscriber",
|
"tracing-subscriber",
|
||||||
"urlencoding",
|
"urlencoding",
|
||||||
@@ -1866,21 +1864,6 @@ dependencies = [
|
|||||||
"wasm-bindgen",
|
"wasm-bindgen",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "jsonwebtoken"
|
|
||||||
version = "9.3.1"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "5a87cc7a48537badeae96744432de36f4be2b4a34a05a5ef32e9dd8a1c169dde"
|
|
||||||
dependencies = [
|
|
||||||
"base64 0.22.1",
|
|
||||||
"js-sys",
|
|
||||||
"pem",
|
|
||||||
"ring",
|
|
||||||
"serde",
|
|
||||||
"serde_json",
|
|
||||||
"simple_asn1",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "jsonwebtoken"
|
name = "jsonwebtoken"
|
||||||
version = "10.3.0"
|
version = "10.3.0"
|
||||||
|
|||||||
@@ -8,35 +8,8 @@ RUN apt-get update && apt-get install -y \
|
|||||||
&& rm -rf /var/lib/apt/lists/*
|
&& rm -rf /var/lib/apt/lists/*
|
||||||
|
|
||||||
WORKDIR /usr/src/app
|
WORKDIR /usr/src/app
|
||||||
|
|
||||||
# 1. Copy workspace manifests and lock file (changes rarely → cached layer)
|
|
||||||
COPY Cargo.toml Cargo.lock ./
|
|
||||||
COPY furumi-common/Cargo.toml furumi-common/Cargo.toml
|
|
||||||
COPY furumi-server/Cargo.toml furumi-server/Cargo.toml
|
|
||||||
COPY furumi-client-core/Cargo.toml furumi-client-core/Cargo.toml
|
|
||||||
COPY furumi-mount-linux/Cargo.toml furumi-mount-linux/Cargo.toml
|
|
||||||
COPY furumi-mount-macos/Cargo.toml furumi-mount-macos/Cargo.toml
|
|
||||||
COPY furumi-agent/Cargo.toml furumi-agent/Cargo.toml
|
|
||||||
COPY furumi-web-player/Cargo.toml furumi-web-player/Cargo.toml
|
|
||||||
|
|
||||||
# 2. Create dummy sources so cargo can resolve and build dependencies
|
|
||||||
RUN mkdir -p furumi-common/src && echo "pub fn _dummy(){}" > furumi-common/src/lib.rs \
|
|
||||||
&& mkdir -p furumi-server/src && echo "fn main(){}" > furumi-server/src/main.rs \
|
|
||||||
&& mkdir -p furumi-client-core/src && echo "pub fn _dummy(){}" > furumi-client-core/src/lib.rs \
|
|
||||||
&& mkdir -p furumi-mount-linux/src && echo "fn main(){}" > furumi-mount-linux/src/main.rs \
|
|
||||||
&& mkdir -p furumi-mount-macos/src && echo "fn main(){}" > furumi-mount-macos/src/main.rs \
|
|
||||||
&& mkdir -p furumi-agent/src && echo "fn main(){}" > furumi-agent/src/main.rs \
|
|
||||||
&& mkdir -p furumi-web-player/src && echo "fn main(){}" > furumi-web-player/src/main.rs
|
|
||||||
|
|
||||||
# 3. Build dependencies only (this layer is cached until Cargo.toml/lock change)
|
|
||||||
RUN cargo build --release --bin furumi-agent 2>/dev/null || true
|
|
||||||
|
|
||||||
# 4. Copy real source code
|
|
||||||
COPY . .
|
COPY . .
|
||||||
|
|
||||||
# 5. Touch sources to invalidate cargo's fingerprint for our crates (not deps)
|
|
||||||
RUN touch furumi-common/src/lib.rs furumi-agent/src/main.rs
|
|
||||||
|
|
||||||
ARG FURUMI_VERSION=dev
|
ARG FURUMI_VERSION=dev
|
||||||
RUN FURUMI_VERSION=${FURUMI_VERSION} cargo build --release --bin furumi-agent
|
RUN FURUMI_VERSION=${FURUMI_VERSION} cargo build --release --bin furumi-agent
|
||||||
|
|
||||||
|
|||||||
@@ -1,38 +0,0 @@
|
|||||||
FROM node:22-alpine AS build
|
|
||||||
|
|
||||||
WORKDIR /app
|
|
||||||
|
|
||||||
# 1. Install server dependencies (cached layer)
|
|
||||||
COPY furumi-node-player/server/package.json furumi-node-player/server/package-lock.json ./server/
|
|
||||||
RUN cd server && npm ci
|
|
||||||
|
|
||||||
# 2. Install client dependencies (cached layer)
|
|
||||||
COPY furumi-node-player/client/package.json furumi-node-player/client/package-lock.json ./client/
|
|
||||||
RUN cd client && npm ci
|
|
||||||
|
|
||||||
# 3. Build server
|
|
||||||
COPY furumi-node-player/server/ ./server/
|
|
||||||
RUN cd server && npm run build
|
|
||||||
|
|
||||||
# 4. Build client (VITE_FURUMI_API_URL empty = relative /api on same origin)
|
|
||||||
COPY furumi-node-player/client/ ./client/
|
|
||||||
RUN cd client && npm run build
|
|
||||||
|
|
||||||
FROM node:22-alpine
|
|
||||||
|
|
||||||
WORKDIR /app
|
|
||||||
|
|
||||||
# Server runtime
|
|
||||||
COPY --from=build /app/server/dist ./server/dist
|
|
||||||
COPY --from=build /app/server/node_modules ./server/node_modules
|
|
||||||
COPY --from=build /app/server/package.json ./server/
|
|
||||||
|
|
||||||
# Client static files
|
|
||||||
COPY --from=build /app/client/dist ./client/dist
|
|
||||||
|
|
||||||
ENV NODE_ENV=production
|
|
||||||
ENV PORT=3001
|
|
||||||
|
|
||||||
EXPOSE 3001
|
|
||||||
|
|
||||||
CMD ["node", "server/dist/index.js"]
|
|
||||||
@@ -8,35 +8,8 @@ RUN apt-get update && apt-get install -y \
|
|||||||
&& rm -rf /var/lib/apt/lists/*
|
&& rm -rf /var/lib/apt/lists/*
|
||||||
|
|
||||||
WORKDIR /usr/src/app
|
WORKDIR /usr/src/app
|
||||||
|
|
||||||
# 1. Copy workspace manifests and lock file (changes rarely → cached layer)
|
|
||||||
COPY Cargo.toml Cargo.lock ./
|
|
||||||
COPY furumi-common/Cargo.toml furumi-common/Cargo.toml
|
|
||||||
COPY furumi-server/Cargo.toml furumi-server/Cargo.toml
|
|
||||||
COPY furumi-client-core/Cargo.toml furumi-client-core/Cargo.toml
|
|
||||||
COPY furumi-mount-linux/Cargo.toml furumi-mount-linux/Cargo.toml
|
|
||||||
COPY furumi-mount-macos/Cargo.toml furumi-mount-macos/Cargo.toml
|
|
||||||
COPY furumi-agent/Cargo.toml furumi-agent/Cargo.toml
|
|
||||||
COPY furumi-web-player/Cargo.toml furumi-web-player/Cargo.toml
|
|
||||||
|
|
||||||
# 2. Create dummy sources so cargo can resolve and build dependencies
|
|
||||||
RUN mkdir -p furumi-common/src && echo "pub fn _dummy(){}" > furumi-common/src/lib.rs \
|
|
||||||
&& mkdir -p furumi-server/src && echo "fn main(){}" > furumi-server/src/main.rs \
|
|
||||||
&& mkdir -p furumi-client-core/src && echo "pub fn _dummy(){}" > furumi-client-core/src/lib.rs \
|
|
||||||
&& mkdir -p furumi-mount-linux/src && echo "fn main(){}" > furumi-mount-linux/src/main.rs \
|
|
||||||
&& mkdir -p furumi-mount-macos/src && echo "fn main(){}" > furumi-mount-macos/src/main.rs \
|
|
||||||
&& mkdir -p furumi-agent/src && echo "fn main(){}" > furumi-agent/src/main.rs \
|
|
||||||
&& mkdir -p furumi-web-player/src && echo "fn main(){}" > furumi-web-player/src/main.rs
|
|
||||||
|
|
||||||
# 3. Build dependencies only (this layer is cached until Cargo.toml/lock change)
|
|
||||||
RUN cargo build --release --bin furumi-web-player 2>/dev/null || true
|
|
||||||
|
|
||||||
# 4. Copy real source code
|
|
||||||
COPY . .
|
COPY . .
|
||||||
|
|
||||||
# 5. Touch sources to invalidate cargo's fingerprint for our crates (not deps)
|
|
||||||
RUN touch furumi-common/src/lib.rs furumi-web-player/src/main.rs
|
|
||||||
|
|
||||||
ARG FURUMI_VERSION=dev
|
ARG FURUMI_VERSION=dev
|
||||||
RUN FURUMI_VERSION=${FURUMI_VERSION} cargo build --release --bin furumi-web-player
|
RUN FURUMI_VERSION=${FURUMI_VERSION} cargo build --release --bin furumi-web-player
|
||||||
|
|
||||||
|
|||||||
@@ -16,8 +16,8 @@ services:
|
|||||||
|
|
||||||
agent:
|
agent:
|
||||||
build:
|
build:
|
||||||
context: ..
|
context: .
|
||||||
dockerfile: docker/Dockerfile.agent
|
dockerfile: Dockerfile.agent
|
||||||
container_name: furumi-agent
|
container_name: furumi-agent
|
||||||
depends_on:
|
depends_on:
|
||||||
db:
|
db:
|
||||||
@@ -25,12 +25,10 @@ services:
|
|||||||
ports:
|
ports:
|
||||||
- "8090:8090"
|
- "8090:8090"
|
||||||
environment:
|
environment:
|
||||||
RUST_LOG: info
|
|
||||||
FURUMI_AGENT_DATABASE_URL: "postgres://${POSTGRES_USER:-furumi}:${POSTGRES_PASSWORD:-furumi}@db:5432/${POSTGRES_DB:-furumi}"
|
FURUMI_AGENT_DATABASE_URL: "postgres://${POSTGRES_USER:-furumi}:${POSTGRES_PASSWORD:-furumi}@db:5432/${POSTGRES_DB:-furumi}"
|
||||||
FURUMI_AGENT_INBOX_DIR: "/inbox"
|
FURUMI_AGENT_INBOX_DIR: "/inbox"
|
||||||
FURUMI_AGENT_STORAGE_DIR: "/storage"
|
FURUMI_AGENT_STORAGE_DIR: "/storage"
|
||||||
FURUMI_AGENT_OLLAMA_URL: "${OLLAMA_URL:-http://host.docker.internal:11434}"
|
FURUMI_AGENT_OLLAMA_URL: "${OLLAMA_URL:-http://host.docker.internal:11434}"
|
||||||
FURUMI_AGENT_OLLAMA_MODEL: "${OLLAMA_MODEL:-qwen3:14b}"
|
|
||||||
FURUMI_AGENT_OLLAMA_AUTH: "${OLLAMA_AUTH:-CHANGE-ME}"
|
FURUMI_AGENT_OLLAMA_AUTH: "${OLLAMA_AUTH:-CHANGE-ME}"
|
||||||
FURUMI_PLAYER_BIND: "0.0.0.0:8090"
|
FURUMI_PLAYER_BIND: "0.0.0.0:8090"
|
||||||
FURUMI_AGENT_POLL_INTERVAL_SECS: 5
|
FURUMI_AGENT_POLL_INTERVAL_SECS: 5
|
||||||
@@ -43,8 +41,8 @@ services:
|
|||||||
|
|
||||||
web-player:
|
web-player:
|
||||||
build:
|
build:
|
||||||
context: ..
|
context: .
|
||||||
dockerfile: docker/Dockerfile.web-player
|
dockerfile: Dockerfile.web-player
|
||||||
container_name: furumi-web-player
|
container_name: furumi-web-player
|
||||||
depends_on:
|
depends_on:
|
||||||
db:
|
db:
|
||||||
@@ -55,11 +53,7 @@ services:
|
|||||||
FURUMI_PLAYER_DATABASE_URL: "postgres://${POSTGRES_USER:-furumi}:${POSTGRES_PASSWORD:-furumi}@db:5432/${POSTGRES_DB:-furumi}"
|
FURUMI_PLAYER_DATABASE_URL: "postgres://${POSTGRES_USER:-furumi}:${POSTGRES_PASSWORD:-furumi}@db:5432/${POSTGRES_DB:-furumi}"
|
||||||
FURUMI_PLAYER_STORAGE_DIR: "/storage"
|
FURUMI_PLAYER_STORAGE_DIR: "/storage"
|
||||||
FURUMI_PLAYER_BIND: "0.0.0.0:8085"
|
FURUMI_PLAYER_BIND: "0.0.0.0:8085"
|
||||||
FURUMI_PLAYER_OIDC_ISSUER_URL: "${OIDC_ISSUER_URL}"
|
FURUMI_PLAYER_API_KEY: "node-player-api-key"
|
||||||
FURUMI_PLAYER_OIDC_CLIENT_ID: "${OIDC_CLIENT_ID}"
|
|
||||||
FURUMI_PLAYER_OIDC_CLIENT_SECRET: "${OIDC_CLIENT_SECRET}"
|
|
||||||
FURUMI_PLAYER_OIDC_REDIRECT_URL: "${OIDC_REDIRECT_URL}"
|
|
||||||
FURUMI_PLAYER_OIDC_SESSION_SECRET: "${OIDC_SESSION_SECRET}"
|
|
||||||
volumes:
|
volumes:
|
||||||
- ./storage:/storage
|
- ./storage:/storage
|
||||||
restart: always
|
restart: always
|
||||||
|
|||||||
@@ -64,7 +64,7 @@ You are a music metadata normalization assistant. Your job is to take raw metada
|
|||||||
|
|
||||||
10. **Consistency**: When the database already contains entries for an artist or album, your output MUST match the existing canonical names. Do not introduce new variations.
|
10. **Consistency**: When the database already contains entries for an artist or album, your output MUST match the existing canonical names. Do not introduce new variations.
|
||||||
|
|
||||||
11. **Confidence**: MUST be a decimal number between 0.0 and 1.0 (e.g., 0.95, 0.7, 0.3). NEVER use words like "high", "medium", "low" — only a numeric float value.
|
11. **Confidence**: Rate your confidence from 0.0 to 1.0.
|
||||||
- 1.0: All fields are clear and unambiguous.
|
- 1.0: All fields are clear and unambiguous.
|
||||||
- 0.8+: Minor inferences made (e.g., year from path), but high certainty.
|
- 0.8+: Minor inferences made (e.g., year from path), but high certainty.
|
||||||
- 0.5-0.8: Some guesswork involved, human review recommended.
|
- 0.5-0.8: Some guesswork involved, human review recommended.
|
||||||
|
|||||||
@@ -25,37 +25,16 @@ pub async fn normalize(
|
|||||||
) -> anyhow::Result<NormalizedFields> {
|
) -> anyhow::Result<NormalizedFields> {
|
||||||
let user_message = build_user_message(raw, hints, similar_artists, similar_albums, folder_ctx);
|
let user_message = build_user_message(raw, hints, similar_artists, similar_albums, folder_ctx);
|
||||||
|
|
||||||
let schema = normalize_schema();
|
|
||||||
let response = call_ollama(
|
let response = call_ollama(
|
||||||
&state.config.ollama_url,
|
&state.config.ollama_url,
|
||||||
&state.config.ollama_model,
|
&state.config.ollama_model,
|
||||||
&state.system_prompt,
|
&state.system_prompt,
|
||||||
&user_message,
|
&user_message,
|
||||||
state.config.ollama_auth.as_deref(),
|
state.config.ollama_auth.as_deref(),
|
||||||
0.5,
|
|
||||||
512,
|
|
||||||
Some(("normalized_metadata", schema.clone())),
|
|
||||||
)
|
)
|
||||||
.await?;
|
.await?;
|
||||||
|
|
||||||
match parse_response(&response) {
|
parse_response(&response)
|
||||||
Ok(fields) => Ok(fields),
|
|
||||||
Err(e) => {
|
|
||||||
tracing::warn!(error = %e, "LLM parse failed, retrying with higher frequency_penalty");
|
|
||||||
let response2 = call_ollama(
|
|
||||||
&state.config.ollama_url,
|
|
||||||
&state.config.ollama_model,
|
|
||||||
&state.system_prompt,
|
|
||||||
&user_message,
|
|
||||||
state.config.ollama_auth.as_deref(),
|
|
||||||
1.5,
|
|
||||||
512,
|
|
||||||
Some(("normalized_metadata", schema)),
|
|
||||||
)
|
|
||||||
.await?;
|
|
||||||
parse_response(&response2)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
fn build_user_message(
|
fn build_user_message(
|
||||||
@@ -134,49 +113,32 @@ fn build_user_message(
|
|||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Serialize)]
|
#[derive(Serialize)]
|
||||||
struct ChatRequest {
|
struct OllamaRequest {
|
||||||
model: String,
|
model: String,
|
||||||
messages: Vec<ChatMessage>,
|
messages: Vec<OllamaMessage>,
|
||||||
#[serde(skip_serializing_if = "Option::is_none")]
|
format: String,
|
||||||
response_format: Option<ChatResponseFormat>,
|
|
||||||
stream: bool,
|
stream: bool,
|
||||||
temperature: f64,
|
options: OllamaOptions,
|
||||||
max_tokens: u32,
|
|
||||||
frequency_penalty: f64,
|
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Serialize)]
|
#[derive(Serialize)]
|
||||||
struct ChatMessage {
|
struct OllamaMessage {
|
||||||
role: String,
|
role: String,
|
||||||
content: String,
|
content: String,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Serialize)]
|
#[derive(Serialize)]
|
||||||
struct ChatResponseFormat {
|
struct OllamaOptions {
|
||||||
#[serde(rename = "type")]
|
temperature: f64,
|
||||||
kind: String,
|
|
||||||
json_schema: JsonSchemaWrapper,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Serialize)]
|
|
||||||
struct JsonSchemaWrapper {
|
|
||||||
name: String,
|
|
||||||
strict: bool,
|
|
||||||
schema: serde_json::Value,
|
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Deserialize)]
|
#[derive(Deserialize)]
|
||||||
struct ChatResponse {
|
struct OllamaResponse {
|
||||||
choices: Vec<ChatChoice>,
|
message: OllamaResponseMessage,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Deserialize)]
|
#[derive(Deserialize)]
|
||||||
struct ChatChoice {
|
struct OllamaResponseMessage {
|
||||||
message: ChatResponseMessage,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Deserialize)]
|
|
||||||
struct ChatResponseMessage {
|
|
||||||
content: String,
|
content: String,
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -186,40 +148,30 @@ pub async fn call_ollama(
|
|||||||
system_prompt: &str,
|
system_prompt: &str,
|
||||||
user_message: &str,
|
user_message: &str,
|
||||||
auth: Option<&str>,
|
auth: Option<&str>,
|
||||||
frequency_penalty: f64,
|
|
||||||
max_tokens: u32,
|
|
||||||
schema: Option<(&str, serde_json::Value)>,
|
|
||||||
) -> anyhow::Result<String> {
|
) -> anyhow::Result<String> {
|
||||||
let client = reqwest::Client::builder()
|
let client = reqwest::Client::builder()
|
||||||
.timeout(std::time::Duration::from_secs(120))
|
.timeout(std::time::Duration::from_secs(120))
|
||||||
.build()?;
|
.build()?;
|
||||||
|
|
||||||
let response_format = schema.map(|(name, schema)| ChatResponseFormat {
|
let request = OllamaRequest {
|
||||||
kind: "json_schema".to_owned(),
|
|
||||||
json_schema: JsonSchemaWrapper { name: name.to_owned(), strict: true, schema },
|
|
||||||
});
|
|
||||||
|
|
||||||
let request = ChatRequest {
|
|
||||||
model: model.to_owned(),
|
model: model.to_owned(),
|
||||||
messages: vec![
|
messages: vec![
|
||||||
ChatMessage {
|
OllamaMessage {
|
||||||
role: "system".to_owned(),
|
role: "system".to_owned(),
|
||||||
content: system_prompt.to_owned(),
|
content: system_prompt.to_owned(),
|
||||||
},
|
},
|
||||||
ChatMessage {
|
OllamaMessage {
|
||||||
role: "user".to_owned(),
|
role: "user".to_owned(),
|
||||||
content: user_message.to_owned(),
|
content: user_message.to_owned(),
|
||||||
},
|
},
|
||||||
],
|
],
|
||||||
response_format,
|
format: "json".to_owned(),
|
||||||
stream: false,
|
stream: false,
|
||||||
temperature: 0.1,
|
options: OllamaOptions { temperature: 0.1 },
|
||||||
max_tokens,
|
|
||||||
frequency_penalty,
|
|
||||||
};
|
};
|
||||||
|
|
||||||
let url = format!("{}/v1/chat/completions", base_url.trim_end_matches('/'));
|
let url = format!("{}/api/chat", base_url.trim_end_matches('/'));
|
||||||
tracing::info!(%url, model, prompt_len = user_message.len(), "Calling LLM API...");
|
tracing::info!(%url, model, prompt_len = user_message.len(), "Calling Ollama API...");
|
||||||
|
|
||||||
let start = std::time::Instant::now();
|
let start = std::time::Instant::now();
|
||||||
let mut req = client.post(&url).json(&request);
|
let mut req = client.post(&url).json(&request);
|
||||||
@@ -232,45 +184,18 @@ pub async fn call_ollama(
|
|||||||
if !resp.status().is_success() {
|
if !resp.status().is_success() {
|
||||||
let status = resp.status();
|
let status = resp.status();
|
||||||
let body = resp.text().await.unwrap_or_default();
|
let body = resp.text().await.unwrap_or_default();
|
||||||
tracing::error!(%status, body = &body[..body.len().min(500)], "LLM API error");
|
tracing::error!(%status, body = &body[..body.len().min(500)], "Ollama API error");
|
||||||
anyhow::bail!("LLM returned {}: {}", status, body);
|
anyhow::bail!("Ollama returned {}: {}", status, body);
|
||||||
}
|
}
|
||||||
|
|
||||||
let chat_resp: ChatResponse = resp.json().await?;
|
let ollama_resp: OllamaResponse = resp.json().await?;
|
||||||
let content = chat_resp
|
|
||||||
.choices
|
|
||||||
.into_iter()
|
|
||||||
.next()
|
|
||||||
.ok_or_else(|| anyhow::anyhow!("LLM returned empty choices"))?
|
|
||||||
.message
|
|
||||||
.content;
|
|
||||||
tracing::info!(
|
tracing::info!(
|
||||||
elapsed_ms = elapsed.as_millis() as u64,
|
elapsed_ms = elapsed.as_millis() as u64,
|
||||||
response_len = content.len(),
|
response_len = ollama_resp.message.content.len(),
|
||||||
"LLM response received"
|
"Ollama response received"
|
||||||
);
|
);
|
||||||
tracing::debug!(raw_response = %content, "LLM raw output");
|
tracing::debug!(raw_response = %ollama_resp.message.content, "LLM raw output");
|
||||||
Ok(content)
|
Ok(ollama_resp.message.content)
|
||||||
}
|
|
||||||
|
|
||||||
fn normalize_schema() -> serde_json::Value {
|
|
||||||
serde_json::json!({
|
|
||||||
"type": "object",
|
|
||||||
"properties": {
|
|
||||||
"artist": { "type": ["string", "null"] },
|
|
||||||
"album": { "type": ["string", "null"] },
|
|
||||||
"title": { "type": ["string", "null"] },
|
|
||||||
"year": { "type": ["integer", "null"] },
|
|
||||||
"track_number": { "type": ["integer", "null"] },
|
|
||||||
"genre": { "type": ["string", "null"] },
|
|
||||||
"featured_artists": { "type": "array", "items": { "type": "string" } },
|
|
||||||
"release_kind": { "type": ["string", "null"] },
|
|
||||||
"confidence": { "type": ["number", "null"] },
|
|
||||||
"notes": { "type": ["string", "null"] }
|
|
||||||
},
|
|
||||||
"required": ["artist", "album", "title", "year", "track_number", "genre", "featured_artists", "release_kind", "confidence", "notes"],
|
|
||||||
"additionalProperties": false
|
|
||||||
})
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Parse the LLM JSON response into NormalizedFields.
|
/// Parse the LLM JSON response into NormalizedFields.
|
||||||
@@ -297,7 +222,6 @@ fn parse_response(response: &str) -> anyhow::Result<NormalizedFields> {
|
|||||||
genre: Option<String>,
|
genre: Option<String>,
|
||||||
#[serde(default)]
|
#[serde(default)]
|
||||||
featured_artists: Vec<String>,
|
featured_artists: Vec<String>,
|
||||||
#[serde(rename = "release_kind")]
|
|
||||||
release_type: Option<String>,
|
release_type: Option<String>,
|
||||||
confidence: Option<f64>,
|
confidence: Option<f64>,
|
||||||
notes: Option<String>,
|
notes: Option<String>,
|
||||||
|
|||||||
@@ -35,39 +35,12 @@ pub async fn propose_merge(state: &Arc<AppState>, merge_id: Uuid) -> anyhow::Res
|
|||||||
|
|
||||||
let user_message = build_merge_message(&artists_data);
|
let user_message = build_merge_message(&artists_data);
|
||||||
|
|
||||||
let schema = serde_json::json!({
|
|
||||||
"type": "object",
|
|
||||||
"properties": {
|
|
||||||
"canonical_artist_name": { "type": "string" },
|
|
||||||
"winner_artist_id": { "type": "integer" },
|
|
||||||
"album_mappings": {
|
|
||||||
"type": "array",
|
|
||||||
"items": {
|
|
||||||
"type": "object",
|
|
||||||
"properties": {
|
|
||||||
"source_album_id": { "type": "integer" },
|
|
||||||
"canonical_name": { "type": "string" },
|
|
||||||
"merge_into_album_id": { "type": ["integer", "null"] }
|
|
||||||
},
|
|
||||||
"required": ["source_album_id", "canonical_name", "merge_into_album_id"],
|
|
||||||
"additionalProperties": false
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"notes": { "type": "string" }
|
|
||||||
},
|
|
||||||
"required": ["canonical_artist_name", "winner_artist_id", "album_mappings", "notes"],
|
|
||||||
"additionalProperties": false
|
|
||||||
});
|
|
||||||
|
|
||||||
let response = call_ollama(
|
let response = call_ollama(
|
||||||
&state.config.ollama_url,
|
&state.config.ollama_url,
|
||||||
&state.config.ollama_model,
|
&state.config.ollama_model,
|
||||||
&state.merge_prompt,
|
&state.merge_prompt,
|
||||||
&user_message,
|
&user_message,
|
||||||
state.config.ollama_auth.as_deref(),
|
state.config.ollama_auth.as_deref(),
|
||||||
0.5,
|
|
||||||
4096,
|
|
||||||
Some(("artist_merge", schema)),
|
|
||||||
).await?;
|
).await?;
|
||||||
|
|
||||||
let proposal = parse_merge_response(&response)?;
|
let proposal = parse_merge_response(&response)?;
|
||||||
|
|||||||
@@ -1 +1,2 @@
|
|||||||
VITE_FURUMI_API_URL=http://localhost:8085
|
VITE_API_BASE_URL=http://localhost:8085
|
||||||
|
VITE_API_KEY=
|
||||||
@@ -1,6 +1,5 @@
|
|||||||
import { useEffect, useState } from 'react'
|
import { useEffect, useMemo, useState } from 'react'
|
||||||
import { FurumiPlayer } from './FurumiPlayer'
|
import { FurumiPlayer } from './FurumiPlayer'
|
||||||
import { setAuthToken, clearAuthToken } from './furumiApi'
|
|
||||||
import './App.css'
|
import './App.css'
|
||||||
|
|
||||||
type UserProfile = {
|
type UserProfile = {
|
||||||
@@ -23,7 +22,7 @@ function App() {
|
|||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
|
||||||
const apiBase = ''
|
const apiBase = useMemo(() => import.meta.env.VITE_API_BASE_URL ?? '', [])
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
if (runWithoutAuth) {
|
if (runWithoutAuth) {
|
||||||
@@ -35,13 +34,12 @@ function App() {
|
|||||||
|
|
||||||
const loadMe = async () => {
|
const loadMe = async () => {
|
||||||
try {
|
try {
|
||||||
const response = await fetch(`${apiBase}/auth/me`, {
|
const response = await fetch(`${apiBase}/api/me`, {
|
||||||
credentials: 'include',
|
credentials: 'include',
|
||||||
})
|
})
|
||||||
|
|
||||||
if (response.status === 401) {
|
if (response.status === 401) {
|
||||||
setUser(null)
|
setUser(null)
|
||||||
clearAuthToken()
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -51,23 +49,6 @@ function App() {
|
|||||||
|
|
||||||
const data = await response.json()
|
const data = await response.json()
|
||||||
setUser(data.user ?? null)
|
setUser(data.user ?? null)
|
||||||
|
|
||||||
// Fetch OIDC access token for Rust API Bearer auth
|
|
||||||
if (data.user) {
|
|
||||||
try {
|
|
||||||
const tokenRes = await fetch(`${apiBase}/auth/token`, {
|
|
||||||
credentials: 'include',
|
|
||||||
})
|
|
||||||
if (tokenRes.ok) {
|
|
||||||
const tokenData = await tokenRes.json()
|
|
||||||
if (tokenData.access_token) {
|
|
||||||
setAuthToken(tokenData.access_token)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
} catch {
|
|
||||||
// Token fetch failed — API calls will fall back to other auth methods
|
|
||||||
}
|
|
||||||
}
|
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
setError(err instanceof Error ? err.message : 'Failed to load session')
|
setError(err instanceof Error ? err.message : 'Failed to load session')
|
||||||
} finally {
|
} finally {
|
||||||
@@ -76,10 +57,10 @@ function App() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
void loadMe()
|
void loadMe()
|
||||||
}, [runWithoutAuth])
|
}, [apiBase, runWithoutAuth])
|
||||||
|
|
||||||
const loginUrl = `${apiBase}/auth/login`
|
const loginUrl = `${apiBase}/api/login`
|
||||||
const logoutUrl = `${apiBase}/auth/logout`
|
const logoutUrl = `${apiBase}/api/logout`
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<>
|
<>
|
||||||
|
|||||||
@@ -1,32 +1,21 @@
|
|||||||
import { useEffect, useRef, useState, type MouseEvent as ReactMouseEvent } from 'react'
|
import { useEffect, useRef, useState, type MouseEvent as ReactMouseEvent } from 'react'
|
||||||
import './furumi-player.css'
|
import './furumi-player.css'
|
||||||
import { API_ROOT, searchTracks, preloadStream } from './furumiApi'
|
import {
|
||||||
import { store, useAppDispatch, useAppSelector } from './store'
|
API_ROOT,
|
||||||
|
searchTracks,
|
||||||
|
preloadStream,
|
||||||
|
} from './furumiApi'
|
||||||
|
import { useAppDispatch, useAppSelector } from './store'
|
||||||
import { fetchArtists } from './store/slices/artistsSlice'
|
import { fetchArtists } from './store/slices/artistsSlice'
|
||||||
import { fetchArtistAlbums } from './store/slices/albumsSlice'
|
import { fetchArtistAlbums } from './store/slices/albumsSlice'
|
||||||
import { fetchArtistTracks } from './store/slices/artistTracksSlice'
|
import { fetchArtistTracks } from './store/slices/artistTracksSlice'
|
||||||
import { fetchAlbumTracks } from './store/slices/albumTracksSlice'
|
import { fetchAlbumTracks } from './store/slices/albumTracksSlice'
|
||||||
import { fetchTrackDetail } from './store/slices/trackDetailSlice'
|
import { fetchTrackDetail } from './store/slices/trackDetailSlice'
|
||||||
import {
|
|
||||||
addTrack,
|
|
||||||
addTracksBatch,
|
|
||||||
replaceQueue,
|
|
||||||
clearQueue,
|
|
||||||
playAtIndex,
|
|
||||||
removeFromQueueAt,
|
|
||||||
moveQueueItemInOrder,
|
|
||||||
rebuildShuffleOrder,
|
|
||||||
selectQueueOrder,
|
|
||||||
selectPlayingOrigIdx,
|
|
||||||
selectQueueScrollSignal,
|
|
||||||
selectNowPlayingTrack,
|
|
||||||
selectQueueItems,
|
|
||||||
} from './store/slices/queueSlice'
|
|
||||||
import { attachAudioPlayback } from './audioPlaybackService'
|
|
||||||
import { fmt } from './utils'
|
import { fmt } from './utils'
|
||||||
import { Header } from './components/header'
|
import { Header } from './components/Header'
|
||||||
import { MainPanel, type Crumb } from './components/MainPanel'
|
import { MainPanel, type Crumb } from './components/MainPanel'
|
||||||
import { PlayerBar } from './components/PlayerBar'
|
import { PlayerBar } from './components/PlayerBar'
|
||||||
|
import type { QueueItem } from './components/QueueList'
|
||||||
import type { Track } from './types'
|
import type { Track } from './types'
|
||||||
|
|
||||||
export function FurumiPlayer() {
|
export function FurumiPlayer() {
|
||||||
@@ -37,13 +26,6 @@ export function FurumiPlayer() {
|
|||||||
const albumsError = useAppSelector((s) => s.albums.error)
|
const albumsError = useAppSelector((s) => s.albums.error)
|
||||||
const albumTracksLoading = useAppSelector((s) => s.albumTracks.loading)
|
const albumTracksLoading = useAppSelector((s) => s.albumTracks.loading)
|
||||||
const albumTracksError = useAppSelector((s) => s.albumTracks.error)
|
const albumTracksError = useAppSelector((s) => s.albumTracks.error)
|
||||||
|
|
||||||
const queueItemsView = useAppSelector(selectQueueItems)
|
|
||||||
const queueOrderView = useAppSelector(selectQueueOrder)
|
|
||||||
const queuePlayingOrigIdxView = useAppSelector(selectPlayingOrigIdx)
|
|
||||||
const queueScrollSignal = useAppSelector(selectQueueScrollSignal)
|
|
||||||
const nowPlayingTrack = useAppSelector(selectNowPlayingTrack)
|
|
||||||
|
|
||||||
const [breadcrumbs, setBreadcrumbs] = useState<Crumb[]>(
|
const [breadcrumbs, setBreadcrumbs] = useState<Crumb[]>(
|
||||||
[],
|
[],
|
||||||
)
|
)
|
||||||
@@ -63,56 +45,81 @@ export function FurumiPlayer() {
|
|||||||
Array<{ result_type: string; slug: string; name: string; detail?: string }>
|
Array<{ result_type: string; slug: string; name: string; detail?: string }>
|
||||||
>([])
|
>([])
|
||||||
const [searchOpen, setSearchOpen] = useState(false)
|
const [searchOpen, setSearchOpen] = useState(false)
|
||||||
const searchSelectRef = useRef<(type: string, slug: string) => void>(() => { })
|
const searchSelectRef = useRef<(type: string, slug: string) => void>(() => {})
|
||||||
|
|
||||||
|
const [nowPlayingTrack, setNowPlayingTrack] = useState<QueueItem | null>(null)
|
||||||
|
const [queueItemsView, setQueueItemsView] = useState<QueueItem[]>([])
|
||||||
|
const [queueOrderView, setQueueOrderView] = useState<number[]>([])
|
||||||
|
const [queuePlayingOrigIdxView, setQueuePlayingOrigIdxView] = useState<number>(-1)
|
||||||
|
const [queueScrollSignal, setQueueScrollSignal] = useState(0)
|
||||||
|
const [queue, setQueue] = useState<QueueItem[]>([])
|
||||||
|
|
||||||
const queueActionsRef = useRef<{
|
const queueActionsRef = useRef<{
|
||||||
playIndex: (i: number) => void
|
playIndex: (i: number) => void
|
||||||
removeFromQueue: (idx: number) => void
|
removeFromQueue: (idx: number) => void
|
||||||
moveQueueItem: (fromPos: number, toPos: number) => void
|
moveQueueItem: (fromPos: number, toPos: number) => void
|
||||||
clearQueue: () => void
|
|
||||||
} | null>(null)
|
} | null>(null)
|
||||||
|
|
||||||
const audioRef = useRef<HTMLAudioElement>(null)
|
const audioRef = useRef<HTMLAudioElement>(null)
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
if (!nowPlayingTrack) {
|
// --- Original player script adapted for React environment ---
|
||||||
document.title = 'Furumi Player'
|
|
||||||
return
|
|
||||||
}
|
|
||||||
document.title = `${nowPlayingTrack.title} — Furumi`
|
|
||||||
const coverUrl = `${API_ROOT}/tracks/${nowPlayingTrack.slug}/cover`
|
|
||||||
if ('mediaSession' in navigator) {
|
|
||||||
try {
|
|
||||||
// eslint-disable-next-line @typescript-eslint/ban-ts-comment
|
|
||||||
navigator.mediaSession.metadata = new window.MediaMetadata({
|
|
||||||
title: nowPlayingTrack.title,
|
|
||||||
artist: nowPlayingTrack.artist || '',
|
|
||||||
album: '',
|
|
||||||
artwork: [{ src: coverUrl, sizes: '512x512' }],
|
|
||||||
})
|
|
||||||
} catch {
|
|
||||||
// ignore
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}, [nowPlayingTrack])
|
|
||||||
|
|
||||||
useEffect(() => {
|
|
||||||
const audioEl = audioRef.current
|
const audioEl = audioRef.current
|
||||||
if (!audioEl) return
|
if (!audioEl) return
|
||||||
const audio = audioEl
|
const audio = audioEl
|
||||||
|
|
||||||
|
let queueIndex = -1
|
||||||
|
let shuffle = false
|
||||||
|
let repeatAll = true
|
||||||
|
let shuffleOrder: number[] = []
|
||||||
let searchTimer: number | null = null
|
let searchTimer: number | null = null
|
||||||
let toastTimer: number | null = null
|
let toastTimer: number | null = null
|
||||||
|
let muted = false
|
||||||
|
|
||||||
function showToast(msg: string) {
|
// Restore prefs
|
||||||
const t = document.getElementById('toast')
|
try {
|
||||||
if (!t) return
|
const v = window.localStorage.getItem('furumi_vol')
|
||||||
t.textContent = msg
|
const volSlider = document.getElementById('volSlider') as HTMLInputElement | null
|
||||||
t.classList.add('show')
|
if (v !== null && volSlider) {
|
||||||
if (toastTimer) window.clearTimeout(toastTimer)
|
audio.volume = Number(v) / 100
|
||||||
toastTimer = window.setTimeout(() => t.classList.remove('show'), 2500)
|
volSlider.value = v
|
||||||
|
}
|
||||||
|
const btnShuffle = document.getElementById('btnShuffle')
|
||||||
|
const btnRepeat = document.getElementById('btnRepeat')
|
||||||
|
shuffle = window.localStorage.getItem('furumi_shuffle') === '1'
|
||||||
|
repeatAll = window.localStorage.getItem('furumi_repeat') !== '0'
|
||||||
|
btnShuffle?.classList.toggle('active', shuffle)
|
||||||
|
btnRepeat?.classList.toggle('active', repeatAll)
|
||||||
|
} catch {
|
||||||
|
// ignore
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// --- Audio events ---
|
||||||
|
audio.addEventListener('timeupdate', () => {
|
||||||
|
if (audio.duration) {
|
||||||
|
const fill = document.getElementById('progressFill')
|
||||||
|
const timeElapsed = document.getElementById('timeElapsed')
|
||||||
|
const timeDuration = document.getElementById('timeDuration')
|
||||||
|
if (fill) fill.style.width = `${(audio.currentTime / audio.duration) * 100}%`
|
||||||
|
if (timeElapsed) timeElapsed.textContent = fmt(audio.currentTime)
|
||||||
|
if (timeDuration) timeDuration.textContent = fmt(audio.duration)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
audio.addEventListener('ended', () => nextTrack())
|
||||||
|
audio.addEventListener('play', () => {
|
||||||
|
const btn = document.getElementById('btnPlayPause')
|
||||||
|
if (btn) btn.innerHTML = '⏸'
|
||||||
|
})
|
||||||
|
audio.addEventListener('pause', () => {
|
||||||
|
const btn = document.getElementById('btnPlayPause')
|
||||||
|
if (btn) btn.innerHTML = '▶'
|
||||||
|
})
|
||||||
|
audio.addEventListener('error', () => {
|
||||||
|
showToast('Playback error')
|
||||||
|
nextTrack()
|
||||||
|
})
|
||||||
|
|
||||||
|
// --- Library navigation ---
|
||||||
async function showArtists() {
|
async function showArtists() {
|
||||||
setBreadcrumb([{ label: 'Artists', action: showArtists }])
|
setBreadcrumb([{ label: 'Artists', action: showArtists }])
|
||||||
try {
|
try {
|
||||||
@@ -224,6 +231,7 @@ export function FurumiPlayer() {
|
|||||||
setBreadcrumbs(parts)
|
setBreadcrumbs(parts)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// --- Queue management ---
|
||||||
function addTrackToQueue(
|
function addTrackToQueue(
|
||||||
track: {
|
track: {
|
||||||
slug: string
|
slug: string
|
||||||
@@ -234,11 +242,15 @@ export function FurumiPlayer() {
|
|||||||
},
|
},
|
||||||
playNow?: boolean,
|
playNow?: boolean,
|
||||||
) {
|
) {
|
||||||
const prevIdx = store.getState().queue.currentIndex
|
const existing = queue.findIndex((t) => t.slug === track.slug)
|
||||||
dispatch(addTrack({ track, playNow }))
|
if (existing !== -1) {
|
||||||
const q = store.getState().queue
|
if (playNow) playIndex(existing)
|
||||||
if (q.currentIndex !== -1 && (playNow || q.currentIndex !== prevIdx)) {
|
return
|
||||||
playIndex(q.currentIndex)
|
}
|
||||||
|
setQueue((q) => [...q, track]);
|
||||||
|
updateQueueModel()
|
||||||
|
if (playNow || (queueIndex === -1 && queue.length === 1)) {
|
||||||
|
playIndex(queue.length - 1)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -247,19 +259,23 @@ export function FurumiPlayer() {
|
|||||||
if (result.meta.requestStatus === 'rejected') return
|
if (result.meta.requestStatus === 'rejected') return
|
||||||
const { tracks } = result.payload as { albumSlug: string; tracks: Track[] }
|
const { tracks } = result.payload as { albumSlug: string; tracks: Track[] }
|
||||||
if (!tracks || !tracks.length) return
|
if (!tracks || !tracks.length) return
|
||||||
const list = tracks.map((t) => ({
|
const list = tracks
|
||||||
slug: t.slug,
|
let firstIdx = queue.length
|
||||||
title: t.title,
|
list.forEach((t) => {
|
||||||
artist: t.artist_name,
|
if (queue.find((q) => q.slug === t.slug)) return
|
||||||
album_slug: t.album_slug,
|
setQueue((q) => [
|
||||||
duration: t.duration_secs,
|
...q,
|
||||||
}))
|
{
|
||||||
const prevIdx = store.getState().queue.currentIndex
|
slug: t.slug,
|
||||||
dispatch(addTracksBatch({ tracks: list, playFirst }))
|
title: t.title,
|
||||||
const q = store.getState().queue
|
artist: t.artist_name,
|
||||||
if (q.currentIndex !== -1 && q.currentIndex !== prevIdx) {
|
album_slug: t.album_slug,
|
||||||
playIndex(q.currentIndex)
|
duration: t.duration_secs,
|
||||||
}
|
},
|
||||||
|
])
|
||||||
|
})
|
||||||
|
updateQueueModel()
|
||||||
|
if (playFirst || queueIndex === -1) playIndex(firstIdx)
|
||||||
showToast(`Added ${list.length} tracks`)
|
showToast(`Added ${list.length} tracks`)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -268,30 +284,29 @@ export function FurumiPlayer() {
|
|||||||
if (result.meta.requestStatus === 'rejected') return
|
if (result.meta.requestStatus === 'rejected') return
|
||||||
const { tracks } = result.payload as { artistSlug: string; tracks: Track[] }
|
const { tracks } = result.payload as { artistSlug: string; tracks: Track[] }
|
||||||
if (!tracks || !tracks.length) return
|
if (!tracks || !tracks.length) return
|
||||||
const list = tracks.map((t) => ({
|
const list = tracks
|
||||||
|
clearQueue()
|
||||||
|
setQueue(list.map((t) => ({
|
||||||
slug: t.slug,
|
slug: t.slug,
|
||||||
title: t.title,
|
title: t.title,
|
||||||
artist: t.artist_name,
|
artist: t.artist_name,
|
||||||
album_slug: t.album_slug,
|
album_slug: t.album_slug,
|
||||||
duration: t.duration_secs,
|
duration: t.duration_secs,
|
||||||
}))
|
})))
|
||||||
dispatch(replaceQueue({ items: list, playFromIndex: 0 }))
|
updateQueueModel()
|
||||||
playIndex(0)
|
playIndex(0)
|
||||||
showToast(`Added ${list.length} tracks`)
|
showToast(`Added ${list.length} tracks`)
|
||||||
}
|
}
|
||||||
|
|
||||||
const playback = attachAudioPlayback(audio, {
|
|
||||||
onEnded: nextTrack,
|
|
||||||
onErrorSkip: nextTrack,
|
|
||||||
onToast: showToast,
|
|
||||||
})
|
|
||||||
|
|
||||||
function playIndex(i: number) {
|
function playIndex(i: number) {
|
||||||
const q = store.getState().queue
|
if (i < 0 || i >= queue.length) return
|
||||||
if (i < 0 || i >= q.items.length) return
|
queueIndex = i
|
||||||
dispatch(playAtIndex(i))
|
const track = queue[i]
|
||||||
const track = store.getState().queue.items[i]
|
audio.src = `${API_ROOT}/stream/${track.slug}`
|
||||||
void playback.loadStreamForTrack(track.slug)
|
void audio.play().catch(() => {})
|
||||||
|
updateNowPlaying(track)
|
||||||
|
updateQueueModel()
|
||||||
|
setQueueScrollSignal((s) => s + 1)
|
||||||
if (window.history && window.history.replaceState) {
|
if (window.history && window.history.replaceState) {
|
||||||
const url = new URL(window.location.href)
|
const url = new URL(window.location.href)
|
||||||
url.searchParams.set('t', track.slug)
|
url.searchParams.set('t', track.slug)
|
||||||
@@ -299,58 +314,181 @@ export function FurumiPlayer() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
function removeFromQueue(idx: number) {
|
function updateNowPlaying(track: QueueItem | null) {
|
||||||
const wasPlaying = store.getState().queue.currentIndex === idx
|
setNowPlayingTrack(track)
|
||||||
dispatch(removeFromQueueAt(idx))
|
if (!track) return
|
||||||
if (wasPlaying) playback.pauseAndClearSource()
|
|
||||||
}
|
|
||||||
|
|
||||||
function moveQueueItem(fromPos: number, toPos: number) {
|
document.title = `${track.title} — Furumi`
|
||||||
dispatch(moveQueueItemInOrder({ fromPos, toPos }))
|
|
||||||
}
|
|
||||||
|
|
||||||
function clearQueuePlayback() {
|
const coverUrl = `${API_ROOT}/tracks/${track.slug}/cover`
|
||||||
dispatch(clearQueue())
|
if ('mediaSession' in navigator) {
|
||||||
playback.pauseAndClearSource()
|
// eslint-disable-next-line @typescript-eslint/ban-ts-comment
|
||||||
}
|
navigator.mediaSession.metadata = new window.MediaMetadata({
|
||||||
|
title: track.title,
|
||||||
function nextTrack() {
|
artist: track.artist || '',
|
||||||
const q = store.getState().queue
|
album: '',
|
||||||
if (!q.items.length) return
|
artwork: [{ src: coverUrl, sizes: '512x512' }],
|
||||||
const order = selectQueueOrder(store.getState())
|
})
|
||||||
const pos = order.indexOf(q.currentIndex)
|
|
||||||
if (pos < order.length - 1) playIndex(order[pos + 1])
|
|
||||||
else if (q.repeatAll) {
|
|
||||||
if (q.shuffle) dispatch(rebuildShuffleOrder())
|
|
||||||
const first = selectQueueOrder(store.getState())[0]
|
|
||||||
if (first !== undefined) playIndex(first)
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
function prevTrack() {
|
function currentOrder() {
|
||||||
const q = store.getState().queue
|
if (!shuffle) return [...Array(queue.length).keys()]
|
||||||
if (!q.items.length) return
|
if (shuffleOrder.length !== queue.length) buildShuffleOrder()
|
||||||
if (playback.rewindCurrentTrackIfPastThreshold()) return
|
return shuffleOrder
|
||||||
const order = selectQueueOrder(store.getState())
|
|
||||||
const pos = order.indexOf(q.currentIndex)
|
|
||||||
if (pos > 0) playIndex(order[pos - 1])
|
|
||||||
else if (q.repeatAll) playIndex(order[order.length - 1])
|
|
||||||
}
|
}
|
||||||
|
|
||||||
function togglePlay() {
|
function buildShuffleOrder() {
|
||||||
const q = store.getState().queue
|
shuffleOrder = [...Array(queue.length).keys()]
|
||||||
playback.togglePlay(() => {
|
for (let i = shuffleOrder.length - 1; i > 0; i--) {
|
||||||
playIndex(q.currentIndex === -1 ? 0 : q.currentIndex)
|
const j = Math.floor(Math.random() * (i + 1))
|
||||||
})
|
;[shuffleOrder[i], shuffleOrder[j]] = [shuffleOrder[j], shuffleOrder[i]]
|
||||||
|
}
|
||||||
|
if (queueIndex !== -1) {
|
||||||
|
const ci = shuffleOrder.indexOf(queueIndex)
|
||||||
|
if (ci > 0) {
|
||||||
|
shuffleOrder.splice(ci, 1)
|
||||||
|
shuffleOrder.unshift(queueIndex)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
function updateQueueModel() {
|
||||||
|
const order = currentOrder()
|
||||||
|
setQueueItemsView(queue)
|
||||||
|
setQueueOrderView(order.slice())
|
||||||
|
setQueuePlayingOrigIdxView(queueIndex)
|
||||||
|
}
|
||||||
|
|
||||||
|
function removeFromQueue(idx: number) {
|
||||||
|
if (idx === queueIndex) {
|
||||||
|
queueIndex = -1
|
||||||
|
audio.pause()
|
||||||
|
audio.src = ''
|
||||||
|
updateNowPlaying(null)
|
||||||
|
} else if (queueIndex > idx) {
|
||||||
|
queueIndex--
|
||||||
|
}
|
||||||
|
|
||||||
|
// queue.splice(idx, 1)
|
||||||
|
setQueue((q) => q.filter((_, i) => i !== idx));
|
||||||
|
|
||||||
|
if (shuffle) {
|
||||||
|
const si = shuffleOrder.indexOf(idx)
|
||||||
|
if (si !== -1) shuffleOrder.splice(si, 1)
|
||||||
|
for (let i = 0; i < shuffleOrder.length; i++) {
|
||||||
|
if (shuffleOrder[i] > idx) shuffleOrder[i]--
|
||||||
|
}
|
||||||
|
}
|
||||||
|
updateQueueModel()
|
||||||
|
}
|
||||||
|
|
||||||
|
function moveQueueItem(from: number, to: number) {
|
||||||
|
if (from === to) return
|
||||||
|
if (shuffle) {
|
||||||
|
const item = shuffleOrder.splice(from, 1)[0]
|
||||||
|
shuffleOrder.splice(to, 0, item)
|
||||||
|
} else {
|
||||||
|
const item = queue.splice(from, 1)[0]
|
||||||
|
queue.splice(to, 0, item)
|
||||||
|
if (queueIndex === from) queueIndex = to
|
||||||
|
else if (from < queueIndex && to >= queueIndex) queueIndex--
|
||||||
|
else if (from > queueIndex && to <= queueIndex) queueIndex++
|
||||||
|
}
|
||||||
|
updateQueueModel()
|
||||||
}
|
}
|
||||||
|
|
||||||
queueActionsRef.current = {
|
queueActionsRef.current = {
|
||||||
playIndex,
|
playIndex,
|
||||||
removeFromQueue,
|
removeFromQueue,
|
||||||
moveQueueItem,
|
moveQueueItem,
|
||||||
clearQueue: clearQueuePlayback,
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
function clearQueue() {
|
||||||
|
setQueue([]);
|
||||||
|
queueIndex = -1
|
||||||
|
shuffleOrder = []
|
||||||
|
audio.pause()
|
||||||
|
audio.src = ''
|
||||||
|
updateNowPlaying(null)
|
||||||
|
document.title = 'Furumi Player'
|
||||||
|
updateQueueModel()
|
||||||
|
}
|
||||||
|
|
||||||
|
// --- Playback controls ---
|
||||||
|
function togglePlay() {
|
||||||
|
if (!audio.src && queue.length) {
|
||||||
|
playIndex(queueIndex === -1 ? 0 : queueIndex)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
if (audio.paused) void audio.play()
|
||||||
|
else audio.pause()
|
||||||
|
}
|
||||||
|
|
||||||
|
function nextTrack() {
|
||||||
|
if (!queue.length) return
|
||||||
|
const order = currentOrder()
|
||||||
|
const pos = order.indexOf(queueIndex)
|
||||||
|
if (pos < order.length - 1) playIndex(order[pos + 1])
|
||||||
|
else if (repeatAll) {
|
||||||
|
if (shuffle) buildShuffleOrder()
|
||||||
|
playIndex(currentOrder()[0])
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
function prevTrack() {
|
||||||
|
if (!queue.length) return
|
||||||
|
if (audio.currentTime > 3) {
|
||||||
|
audio.currentTime = 0
|
||||||
|
return
|
||||||
|
}
|
||||||
|
const order = currentOrder()
|
||||||
|
const pos = order.indexOf(queueIndex)
|
||||||
|
if (pos > 0) playIndex(order[pos - 1])
|
||||||
|
else if (repeatAll) playIndex(order[order.length - 1])
|
||||||
|
}
|
||||||
|
|
||||||
|
function toggleShuffle() {
|
||||||
|
shuffle = !shuffle
|
||||||
|
if (shuffle) buildShuffleOrder()
|
||||||
|
const btn = document.getElementById('btnShuffle')
|
||||||
|
btn?.classList.toggle('active', shuffle)
|
||||||
|
window.localStorage.setItem('furumi_shuffle', shuffle ? '1' : '0')
|
||||||
|
updateQueueModel()
|
||||||
|
}
|
||||||
|
|
||||||
|
function toggleRepeat() {
|
||||||
|
repeatAll = !repeatAll
|
||||||
|
const btn = document.getElementById('btnRepeat')
|
||||||
|
btn?.classList.toggle('active', repeatAll)
|
||||||
|
window.localStorage.setItem('furumi_repeat', repeatAll ? '1' : '0')
|
||||||
|
}
|
||||||
|
|
||||||
|
// --- Seek & Volume ---
|
||||||
|
function seekTo(e: MouseEvent) {
|
||||||
|
if (!audio.duration) return
|
||||||
|
const bar = document.getElementById('progressBar') as HTMLDivElement | null
|
||||||
|
if (!bar) return
|
||||||
|
const rect = bar.getBoundingClientRect()
|
||||||
|
const pct = (e.clientX - rect.left) / rect.width
|
||||||
|
audio.currentTime = pct * audio.duration
|
||||||
|
}
|
||||||
|
|
||||||
|
function toggleMute() {
|
||||||
|
muted = !muted
|
||||||
|
audio.muted = muted
|
||||||
|
const volIcon = document.getElementById('volIcon')
|
||||||
|
if (volIcon) volIcon.innerHTML = muted ? '🔇' : '🔊'
|
||||||
|
}
|
||||||
|
|
||||||
|
function setVolume(v: number) {
|
||||||
|
audio.volume = v / 100
|
||||||
|
const volIcon = document.getElementById('volIcon')
|
||||||
|
if (volIcon) volIcon.innerHTML = v === 0 ? '🔇' : '🔊'
|
||||||
|
window.localStorage.setItem('furumi_vol', String(v))
|
||||||
|
}
|
||||||
|
|
||||||
|
// --- Search ---
|
||||||
function onSearch(q: string) {
|
function onSearch(q: string) {
|
||||||
if (searchTimer) {
|
if (searchTimer) {
|
||||||
window.clearTimeout(searchTimer)
|
window.clearTimeout(searchTimer)
|
||||||
@@ -389,6 +527,16 @@ export function FurumiPlayer() {
|
|||||||
}
|
}
|
||||||
searchSelectRef.current = onSearchSelect
|
searchSelectRef.current = onSearchSelect
|
||||||
|
|
||||||
|
// --- Helpers ---
|
||||||
|
function showToast(msg: string) {
|
||||||
|
const t = document.getElementById('toast')
|
||||||
|
if (!t) return
|
||||||
|
t.textContent = msg
|
||||||
|
t.classList.add('show')
|
||||||
|
if (toastTimer) window.clearTimeout(toastTimer)
|
||||||
|
toastTimer = window.setTimeout(() => t.classList.remove('show'), 2500)
|
||||||
|
}
|
||||||
|
|
||||||
function toggleSidebar() {
|
function toggleSidebar() {
|
||||||
const sidebar = document.getElementById('sidebar')
|
const sidebar = document.getElementById('sidebar')
|
||||||
const overlay = document.getElementById('sidebarOverlay')
|
const overlay = document.getElementById('sidebarOverlay')
|
||||||
@@ -396,101 +544,100 @@ export function FurumiPlayer() {
|
|||||||
overlay?.classList.toggle('show')
|
overlay?.classList.toggle('show')
|
||||||
}
|
}
|
||||||
|
|
||||||
const onMediaSeekTo = (d: { seekTime?: number }) => {
|
// --- MediaSession ---
|
||||||
if (typeof d.seekTime === 'number') {
|
|
||||||
playback.seekToTime(d.seekTime)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if ('mediaSession' in navigator) {
|
if ('mediaSession' in navigator) {
|
||||||
try {
|
try {
|
||||||
navigator.mediaSession.setActionHandler('play', togglePlay)
|
navigator.mediaSession.setActionHandler('play', togglePlay)
|
||||||
navigator.mediaSession.setActionHandler('pause', togglePlay)
|
navigator.mediaSession.setActionHandler('pause', togglePlay)
|
||||||
navigator.mediaSession.setActionHandler('previoustrack', prevTrack)
|
navigator.mediaSession.setActionHandler('previoustrack', prevTrack)
|
||||||
navigator.mediaSession.setActionHandler('nexttrack', nextTrack)
|
navigator.mediaSession.setActionHandler('nexttrack', nextTrack)
|
||||||
navigator.mediaSession.setActionHandler('seekto', onMediaSeekTo as (d: any) => void)
|
navigator.mediaSession.setActionHandler('seekto', (d: any) => {
|
||||||
|
if (typeof d.seekTime === 'number') {
|
||||||
|
audio.currentTime = d.seekTime
|
||||||
|
}
|
||||||
|
})
|
||||||
} catch {
|
} catch {
|
||||||
// ignore
|
// ignore
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
const onMenuClick = () => toggleSidebar()
|
// --- Wire DOM events that were inline in HTML ---
|
||||||
const btnMenu = document.querySelector('.btn-menu')
|
const btnMenu = document.querySelector('.btn-menu')
|
||||||
btnMenu?.addEventListener('click', onMenuClick)
|
btnMenu?.addEventListener('click', () => toggleSidebar())
|
||||||
|
|
||||||
const onSidebarOverlayClick = () => toggleSidebar()
|
|
||||||
const sidebarOverlay = document.getElementById('sidebarOverlay')
|
const sidebarOverlay = document.getElementById('sidebarOverlay')
|
||||||
sidebarOverlay?.addEventListener('click', onSidebarOverlayClick)
|
sidebarOverlay?.addEventListener('click', () => toggleSidebar())
|
||||||
|
|
||||||
const searchInput = document.getElementById('searchInput') as HTMLInputElement | null
|
const searchInput = document.getElementById('searchInput') as HTMLInputElement | null
|
||||||
const onSearchInput = (e: Event) => {
|
|
||||||
onSearch((e.target as HTMLInputElement).value)
|
|
||||||
}
|
|
||||||
const onSearchKeydown = (e: KeyboardEvent) => {
|
|
||||||
if (e.key === 'Escape') closeSearch()
|
|
||||||
}
|
|
||||||
if (searchInput) {
|
if (searchInput) {
|
||||||
searchInput.addEventListener('input', onSearchInput)
|
searchInput.addEventListener('input', (e) => {
|
||||||
searchInput.addEventListener('keydown', onSearchKeydown)
|
onSearch((e.target as HTMLInputElement).value)
|
||||||
|
})
|
||||||
|
searchInput.addEventListener('keydown', (e: KeyboardEvent) => {
|
||||||
|
if (e.key === 'Escape') closeSearch()
|
||||||
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
const onPrevClick = () => prevTrack()
|
const btnShuffle = document.getElementById('btnShuffle')
|
||||||
const onPlayClick = () => togglePlay()
|
btnShuffle?.addEventListener('click', () => toggleShuffle())
|
||||||
const onNextClick = () => nextTrack()
|
const btnRepeat = document.getElementById('btnRepeat')
|
||||||
|
btnRepeat?.addEventListener('click', () => toggleRepeat())
|
||||||
|
const btnClear = document.getElementById('btnClearQueue')
|
||||||
|
btnClear?.addEventListener('click', () => clearQueue())
|
||||||
|
|
||||||
const btnPrev = document.getElementById('btnPrev')
|
const btnPrev = document.getElementById('btnPrev')
|
||||||
btnPrev?.addEventListener('click', onPrevClick)
|
btnPrev?.addEventListener('click', () => prevTrack())
|
||||||
const btnPlay = document.getElementById('btnPlayPause')
|
const btnPlay = document.getElementById('btnPlayPause')
|
||||||
btnPlay?.addEventListener('click', onPlayClick)
|
btnPlay?.addEventListener('click', () => togglePlay())
|
||||||
const btnNext = document.getElementById('btnNext')
|
const btnNext = document.getElementById('btnNext')
|
||||||
btnNext?.addEventListener('click', onNextClick)
|
btnNext?.addEventListener('click', () => nextTrack())
|
||||||
|
|
||||||
; (async () => {
|
const progressBar = document.getElementById('progressBar')
|
||||||
const url = new URL(window.location.href)
|
progressBar?.addEventListener('click', (e) => seekTo(e as MouseEvent))
|
||||||
const urlSlug = url.searchParams.get('t')
|
|
||||||
if (urlSlug) {
|
|
||||||
try {
|
|
||||||
const { detail } = await dispatch(fetchTrackDetail(urlSlug)).unwrap()
|
|
||||||
addTrackToQueue(
|
|
||||||
{
|
|
||||||
slug: detail.slug,
|
|
||||||
title: detail.title,
|
|
||||||
artist: detail.artist_name,
|
|
||||||
album_slug: detail.album_slug,
|
|
||||||
duration: detail.duration_secs,
|
|
||||||
},
|
|
||||||
true,
|
|
||||||
)
|
|
||||||
} catch {
|
|
||||||
// fetchTrackDetail rejected — track not found or error
|
|
||||||
}
|
|
||||||
}
|
|
||||||
void showArtists()
|
|
||||||
})()
|
|
||||||
|
|
||||||
return () => {
|
const volIcon = document.getElementById('volIcon')
|
||||||
queueActionsRef.current = null
|
volIcon?.addEventListener('click', () => toggleMute())
|
||||||
playback.dispose()
|
const volSlider = document.getElementById('volSlider') as HTMLInputElement | null
|
||||||
btnMenu?.removeEventListener('click', onMenuClick)
|
if (volSlider) {
|
||||||
sidebarOverlay?.removeEventListener('click', onSidebarOverlayClick)
|
volSlider.addEventListener('input', (e) => {
|
||||||
searchInput?.removeEventListener('input', onSearchInput)
|
const v = Number((e.target as HTMLInputElement).value)
|
||||||
searchInput?.removeEventListener('keydown', onSearchKeydown)
|
setVolume(v)
|
||||||
btnPrev?.removeEventListener('click', onPrevClick)
|
})
|
||||||
btnPlay?.removeEventListener('click', onPlayClick)
|
}
|
||||||
btnNext?.removeEventListener('click', onNextClick)
|
|
||||||
if ('mediaSession' in navigator) {
|
const clearQueueBtn = document.getElementById('btnClearQueue')
|
||||||
|
clearQueueBtn?.addEventListener('click', () => clearQueue())
|
||||||
|
|
||||||
|
// --- Init ---
|
||||||
|
;(async () => {
|
||||||
|
const url = new URL(window.location.href)
|
||||||
|
const urlSlug = url.searchParams.get('t')
|
||||||
|
if (urlSlug) {
|
||||||
try {
|
try {
|
||||||
navigator.mediaSession.setActionHandler('play', null)
|
const { detail } = await dispatch(fetchTrackDetail(urlSlug)).unwrap()
|
||||||
navigator.mediaSession.setActionHandler('pause', null)
|
addTrackToQueue(
|
||||||
navigator.mediaSession.setActionHandler('previoustrack', null)
|
{
|
||||||
navigator.mediaSession.setActionHandler('nexttrack', null)
|
slug: detail.slug,
|
||||||
navigator.mediaSession.setActionHandler('seekto', null)
|
title: detail.title,
|
||||||
|
artist: detail.artist_name,
|
||||||
|
album_slug: detail.album_slug,
|
||||||
|
duration: detail.duration_secs,
|
||||||
|
},
|
||||||
|
true,
|
||||||
|
)
|
||||||
} catch {
|
} catch {
|
||||||
// ignore
|
// fetchTrackDetail rejected — track not found or error
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
void showArtists()
|
||||||
|
})()
|
||||||
|
|
||||||
|
// Cleanup: best-effort remove listeners on unmount
|
||||||
|
return () => {
|
||||||
|
queueActionsRef.current = null
|
||||||
|
audio.pause()
|
||||||
}
|
}
|
||||||
}, [dispatch])
|
}, [])
|
||||||
|
|
||||||
const libraryLoading =
|
const libraryLoading =
|
||||||
breadcrumbs.length === 1
|
breadcrumbs.length === 1
|
||||||
@@ -519,6 +666,10 @@ export function FurumiPlayer() {
|
|||||||
libraryLoading={libraryLoading}
|
libraryLoading={libraryLoading}
|
||||||
libraryError={libraryError}
|
libraryError={libraryError}
|
||||||
libraryItems={libraryItems}
|
libraryItems={libraryItems}
|
||||||
|
queueItemsView={queueItemsView}
|
||||||
|
queueOrderView={queueOrderView}
|
||||||
|
queuePlayingOrigIdxView={queuePlayingOrigIdxView}
|
||||||
|
queueScrollSignal={queueScrollSignal}
|
||||||
onQueuePlay={(origIdx) => queueActionsRef.current?.playIndex(origIdx)}
|
onQueuePlay={(origIdx) => queueActionsRef.current?.playIndex(origIdx)}
|
||||||
onQueueRemove={(origIdx) =>
|
onQueueRemove={(origIdx) =>
|
||||||
queueActionsRef.current?.removeFromQueue(origIdx)
|
queueActionsRef.current?.removeFromQueue(origIdx)
|
||||||
@@ -526,26 +677,13 @@ export function FurumiPlayer() {
|
|||||||
onQueueMove={(fromPos, toPos) =>
|
onQueueMove={(fromPos, toPos) =>
|
||||||
queueActionsRef.current?.moveQueueItem(fromPos, toPos)
|
queueActionsRef.current?.moveQueueItem(fromPos, toPos)
|
||||||
}
|
}
|
||||||
onClearQueue={() => queueActionsRef.current?.clearQueue()}
|
|
||||||
/>
|
/>
|
||||||
|
|
||||||
<PlayerBar
|
<PlayerBar track={nowPlayingTrack} />
|
||||||
track={nowPlayingTrack}
|
|
||||||
queue={queueItemsView}
|
|
||||||
order={queueOrderView}
|
|
||||||
playingOrigIdx={queuePlayingOrigIdxView}
|
|
||||||
scrollSignal={queueScrollSignal}
|
|
||||||
onQueuePlay={(origIdx) => queueActionsRef.current?.playIndex(origIdx)}
|
|
||||||
onQueueRemove={(origIdx) =>
|
|
||||||
queueActionsRef.current?.removeFromQueue(origIdx)
|
|
||||||
}
|
|
||||||
onQueueMove={(fromPos, toPos) =>
|
|
||||||
queueActionsRef.current?.moveQueueItem(fromPos, toPos)
|
|
||||||
}
|
|
||||||
/>
|
|
||||||
|
|
||||||
<div className="toast" id="toast" />
|
<div className="toast" id="toast" />
|
||||||
<audio ref={audioRef} />
|
<audio ref={audioRef} />
|
||||||
</div>
|
</div>
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,190 +0,0 @@
|
|||||||
import { preloadStream } from './furumiApi'
|
|
||||||
import { fmt } from './utils'
|
|
||||||
|
|
||||||
const MAX_PLAYBACK_ERROR_SKIPS = 5
|
|
||||||
|
|
||||||
/** Seconds from track start above which "previous" rewinds current track instead. */
|
|
||||||
const PREV_TRACK_REWIND_THRESHOLD_SEC = 3
|
|
||||||
|
|
||||||
export interface AudioPlaybackCallbacks {
|
|
||||||
onEnded: () => void
|
|
||||||
/** Called after a recoverable playback error (to advance queue). */
|
|
||||||
onErrorSkip: () => void
|
|
||||||
onToast: (msg: string) => void
|
|
||||||
}
|
|
||||||
|
|
||||||
export interface AudioPlaybackHandle {
|
|
||||||
loadStreamForTrack(slug: string): Promise<void>
|
|
||||||
pauseAndClearSource(): void
|
|
||||||
togglePlay(whenNoSource: () => void): void
|
|
||||||
seekFromProgressBarClick(e: MouseEvent): void
|
|
||||||
toggleMute(): void
|
|
||||||
setVolume(percent: number): void
|
|
||||||
seekToTime(seconds: number): void
|
|
||||||
/** If current time is past the threshold, seeks to 0 and returns true (caller should skip prev-track logic). */
|
|
||||||
rewindCurrentTrackIfPastThreshold(): boolean
|
|
||||||
dispose(): void
|
|
||||||
}
|
|
||||||
|
|
||||||
function syncVolumeFromStorage(audio: HTMLAudioElement) {
|
|
||||||
try {
|
|
||||||
const v = window.localStorage.getItem('furumi_vol')
|
|
||||||
const volSlider = document.getElementById('volSlider') as HTMLInputElement | null
|
|
||||||
if (v !== null && volSlider) {
|
|
||||||
audio.volume = Number(v) / 100
|
|
||||||
volSlider.value = v
|
|
||||||
}
|
|
||||||
} catch {
|
|
||||||
// ignore
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
export function attachAudioPlayback(
|
|
||||||
audio: HTMLAudioElement,
|
|
||||||
callbacks: AudioPlaybackCallbacks,
|
|
||||||
): AudioPlaybackHandle {
|
|
||||||
let muted = false
|
|
||||||
let playbackErrorSkips = 0
|
|
||||||
|
|
||||||
syncVolumeFromStorage(audio)
|
|
||||||
|
|
||||||
function onTimeUpdate() {
|
|
||||||
if (!audio.duration) return
|
|
||||||
const fill = document.getElementById('progressFill')
|
|
||||||
const timeElapsed = document.getElementById('timeElapsed')
|
|
||||||
const timeDuration = document.getElementById('timeDuration')
|
|
||||||
if (fill) fill.style.width = `${(audio.currentTime / audio.duration) * 100}%`
|
|
||||||
if (timeElapsed) timeElapsed.textContent = fmt(audio.currentTime)
|
|
||||||
if (timeDuration) timeDuration.textContent = fmt(audio.duration)
|
|
||||||
}
|
|
||||||
|
|
||||||
function setPlayPauseButtonPlaying(playing: boolean) {
|
|
||||||
const btn = document.getElementById('btnPlayPause')
|
|
||||||
if (btn) btn.innerHTML = playing ? '⏸' : '▶'
|
|
||||||
}
|
|
||||||
|
|
||||||
function onPlaying() {
|
|
||||||
playbackErrorSkips = 0
|
|
||||||
}
|
|
||||||
|
|
||||||
function onPlay() {
|
|
||||||
setPlayPauseButtonPlaying(true)
|
|
||||||
}
|
|
||||||
|
|
||||||
function onPause() {
|
|
||||||
setPlayPauseButtonPlaying(false)
|
|
||||||
}
|
|
||||||
|
|
||||||
function onError() {
|
|
||||||
callbacks.onToast('Playback error')
|
|
||||||
if (playbackErrorSkips >= MAX_PLAYBACK_ERROR_SKIPS) return
|
|
||||||
playbackErrorSkips += 1
|
|
||||||
callbacks.onErrorSkip()
|
|
||||||
}
|
|
||||||
|
|
||||||
function onEnded() {
|
|
||||||
callbacks.onEnded()
|
|
||||||
}
|
|
||||||
|
|
||||||
audio.addEventListener('timeupdate', onTimeUpdate)
|
|
||||||
audio.addEventListener('ended', onEnded)
|
|
||||||
audio.addEventListener('playing', onPlaying)
|
|
||||||
audio.addEventListener('play', onPlay)
|
|
||||||
audio.addEventListener('pause', onPause)
|
|
||||||
audio.addEventListener('error', onError)
|
|
||||||
|
|
||||||
const progressBar = document.getElementById('progressBar')
|
|
||||||
const onProgressClick = (e: Event) => seekFromProgressBarClick(e as MouseEvent)
|
|
||||||
progressBar?.addEventListener('click', onProgressClick)
|
|
||||||
|
|
||||||
const volIcon = document.getElementById('volIcon')
|
|
||||||
const onVolIconClick = () => toggleMute()
|
|
||||||
volIcon?.addEventListener('click', onVolIconClick)
|
|
||||||
|
|
||||||
const volSlider = document.getElementById('volSlider') as HTMLInputElement | null
|
|
||||||
const onVolInput = (e: Event) => {
|
|
||||||
const v = Number((e.target as HTMLInputElement).value)
|
|
||||||
setVolume(v)
|
|
||||||
}
|
|
||||||
volSlider?.addEventListener('input', onVolInput)
|
|
||||||
|
|
||||||
async function loadStreamForTrack(slug: string) {
|
|
||||||
const response = await preloadStream(slug)
|
|
||||||
audio.src = URL.createObjectURL(response?.data)
|
|
||||||
await audio.play().catch(() => { })
|
|
||||||
}
|
|
||||||
|
|
||||||
function pauseAndClearSource() {
|
|
||||||
audio.pause()
|
|
||||||
audio.src = ''
|
|
||||||
}
|
|
||||||
|
|
||||||
function togglePlay(whenNoSource: () => void) {
|
|
||||||
if (!audio.src) {
|
|
||||||
whenNoSource()
|
|
||||||
return
|
|
||||||
}
|
|
||||||
if (audio.paused) void audio.play()
|
|
||||||
else audio.pause()
|
|
||||||
}
|
|
||||||
|
|
||||||
function seekFromProgressBarClick(e: MouseEvent) {
|
|
||||||
if (!audio.duration) return
|
|
||||||
const bar = document.getElementById('progressBar') as HTMLDivElement | null
|
|
||||||
if (!bar) return
|
|
||||||
const rect = bar.getBoundingClientRect()
|
|
||||||
const pct = (e.clientX - rect.left) / rect.width
|
|
||||||
audio.currentTime = pct * audio.duration
|
|
||||||
}
|
|
||||||
|
|
||||||
function toggleMute() {
|
|
||||||
muted = !muted
|
|
||||||
audio.muted = muted
|
|
||||||
const icon = document.getElementById('volIcon')
|
|
||||||
if (icon) icon.innerHTML = muted ? '🔇' : '🔊'
|
|
||||||
}
|
|
||||||
|
|
||||||
function setVolume(percent: number) {
|
|
||||||
audio.volume = percent / 100
|
|
||||||
const icon = document.getElementById('volIcon')
|
|
||||||
if (icon) icon.innerHTML = percent === 0 ? '🔇' : '🔊'
|
|
||||||
window.localStorage.setItem('furumi_vol', String(percent))
|
|
||||||
}
|
|
||||||
|
|
||||||
function seekToTime(seconds: number) {
|
|
||||||
audio.currentTime = seconds
|
|
||||||
}
|
|
||||||
|
|
||||||
function rewindCurrentTrackIfPastThreshold(): boolean {
|
|
||||||
if (audio.currentTime > PREV_TRACK_REWIND_THRESHOLD_SEC) {
|
|
||||||
audio.currentTime = 0
|
|
||||||
return true
|
|
||||||
}
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
|
|
||||||
function dispose() {
|
|
||||||
audio.removeEventListener('timeupdate', onTimeUpdate)
|
|
||||||
audio.removeEventListener('ended', onEnded)
|
|
||||||
audio.removeEventListener('playing', onPlaying)
|
|
||||||
audio.removeEventListener('play', onPlay)
|
|
||||||
audio.removeEventListener('pause', onPause)
|
|
||||||
audio.removeEventListener('error', onError)
|
|
||||||
progressBar?.removeEventListener('click', onProgressClick)
|
|
||||||
volIcon?.removeEventListener('click', onVolIconClick)
|
|
||||||
volSlider?.removeEventListener('input', onVolInput)
|
|
||||||
audio.pause()
|
|
||||||
}
|
|
||||||
|
|
||||||
return {
|
|
||||||
loadStreamForTrack,
|
|
||||||
pauseAndClearSource,
|
|
||||||
togglePlay,
|
|
||||||
seekFromProgressBarClick,
|
|
||||||
toggleMute,
|
|
||||||
setVolume,
|
|
||||||
seekToTime,
|
|
||||||
rewindCurrentTrackIfPastThreshold,
|
|
||||||
dispose,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
+4
-5
@@ -1,5 +1,4 @@
|
|||||||
import { SearchDropdown } from '../SearchDropdown'
|
import { SearchDropdown } from './SearchDropdown'
|
||||||
import styles from './header.module.css'
|
|
||||||
|
|
||||||
type SearchResultItem = {
|
type SearchResultItem = {
|
||||||
result_type: string
|
result_type: string
|
||||||
@@ -20,8 +19,8 @@ export function Header({
|
|||||||
onSearchSelect,
|
onSearchSelect,
|
||||||
}: HeaderProps) {
|
}: HeaderProps) {
|
||||||
return (
|
return (
|
||||||
<header className={styles.header}>
|
<header className="header">
|
||||||
<div className={styles.headerLogo}>
|
<div className="header-logo">
|
||||||
<button className="btn-menu">☰</button>
|
<button className="btn-menu">☰</button>
|
||||||
<svg viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="2">
|
<svg viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="2">
|
||||||
<circle cx="9" cy="18" r="3" />
|
<circle cx="9" cy="18" r="3" />
|
||||||
@@ -29,7 +28,7 @@ export function Header({
|
|||||||
<path d="M12 18V6l9-3v3" />
|
<path d="M12 18V6l9-3v3" />
|
||||||
</svg>
|
</svg>
|
||||||
Furumi
|
Furumi
|
||||||
<span className={styles.headerVersion}>v</span>
|
<span className="header-version">v</span>
|
||||||
</div>
|
</div>
|
||||||
<div style={{ display: 'flex', alignItems: 'center', gap: '1rem' }}>
|
<div style={{ display: 'flex', alignItems: 'center', gap: '1rem' }}>
|
||||||
<div className="search-wrap">
|
<div className="search-wrap">
|
||||||
@@ -1,18 +1,7 @@
|
|||||||
import type { MouseEvent as ReactMouseEvent } from 'react'
|
import type { MouseEvent as ReactMouseEvent } from 'react'
|
||||||
import { useAppDispatch, useAppSelector } from '../store'
|
|
||||||
import {
|
|
||||||
selectPlayingOrigIdx,
|
|
||||||
selectQueueItems,
|
|
||||||
selectQueueOrder,
|
|
||||||
selectQueueScrollSignal,
|
|
||||||
selectRepeatAll,
|
|
||||||
selectShuffle,
|
|
||||||
toggleRepeat,
|
|
||||||
toggleShuffle,
|
|
||||||
} from '../store/slices/queueSlice'
|
|
||||||
import { Breadcrumbs } from './Breadcrumbs'
|
import { Breadcrumbs } from './Breadcrumbs'
|
||||||
import { LibraryList } from './LibraryList'
|
import { LibraryList } from './LibraryList'
|
||||||
import { QueueList } from './QueueList'
|
import { QueueList, type QueueItem } from './QueueList'
|
||||||
|
|
||||||
export type Crumb = { label: string; action?: () => void }
|
export type Crumb = { label: string; action?: () => void }
|
||||||
|
|
||||||
@@ -32,10 +21,13 @@ type MainPanelProps = {
|
|||||||
libraryLoading: boolean
|
libraryLoading: boolean
|
||||||
libraryError: string | null
|
libraryError: string | null
|
||||||
libraryItems: LibraryListItem[]
|
libraryItems: LibraryListItem[]
|
||||||
|
queueItemsView: QueueItem[]
|
||||||
|
queueOrderView: number[]
|
||||||
|
queuePlayingOrigIdxView: number
|
||||||
|
queueScrollSignal: number
|
||||||
onQueuePlay: (origIdx: number) => void
|
onQueuePlay: (origIdx: number) => void
|
||||||
onQueueRemove: (origIdx: number) => void
|
onQueueRemove: (origIdx: number) => void
|
||||||
onQueueMove: (fromPos: number, toPos: number) => void
|
onQueueMove: (fromPos: number, toPos: number) => void
|
||||||
onClearQueue: () => void
|
|
||||||
}
|
}
|
||||||
|
|
||||||
export function MainPanel({
|
export function MainPanel({
|
||||||
@@ -43,19 +35,14 @@ export function MainPanel({
|
|||||||
libraryLoading,
|
libraryLoading,
|
||||||
libraryError,
|
libraryError,
|
||||||
libraryItems,
|
libraryItems,
|
||||||
|
queueItemsView,
|
||||||
|
queueOrderView,
|
||||||
|
queuePlayingOrigIdxView,
|
||||||
|
queueScrollSignal,
|
||||||
onQueuePlay,
|
onQueuePlay,
|
||||||
onQueueRemove,
|
onQueueRemove,
|
||||||
onQueueMove,
|
onQueueMove,
|
||||||
onClearQueue,
|
|
||||||
}: MainPanelProps) {
|
}: MainPanelProps) {
|
||||||
const dispatch = useAppDispatch()
|
|
||||||
const queueItemsView = useAppSelector(selectQueueItems)
|
|
||||||
const queueOrderView = useAppSelector(selectQueueOrder)
|
|
||||||
const queuePlayingOrigIdxView = useAppSelector(selectPlayingOrigIdx)
|
|
||||||
const queueScrollSignal = useAppSelector(selectQueueScrollSignal)
|
|
||||||
const shuffle = useAppSelector(selectShuffle)
|
|
||||||
const repeatAll = useAppSelector(selectRepeatAll)
|
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<div className="main">
|
<div className="main">
|
||||||
<div className="sidebar-overlay" id="sidebarOverlay" />
|
<div className="sidebar-overlay" id="sidebarOverlay" />
|
||||||
@@ -71,21 +58,13 @@ export function MainPanel({
|
|||||||
<div className="queue-header">
|
<div className="queue-header">
|
||||||
<span>Queue</span>
|
<span>Queue</span>
|
||||||
<div className="queue-actions">
|
<div className="queue-actions">
|
||||||
<button
|
<button className="queue-btn active" id="btnShuffle">
|
||||||
type="button"
|
|
||||||
className={`queue-btn${shuffle ? ' active' : ''}`}
|
|
||||||
onClick={() => dispatch(toggleShuffle())}
|
|
||||||
>
|
|
||||||
Shuffle
|
Shuffle
|
||||||
</button>
|
</button>
|
||||||
<button
|
<button className="queue-btn active" id="btnRepeat">
|
||||||
type="button"
|
|
||||||
className={`queue-btn${repeatAll ? ' active' : ''}`}
|
|
||||||
onClick={() => dispatch(toggleRepeat())}
|
|
||||||
>
|
|
||||||
Repeat
|
Repeat
|
||||||
</button>
|
</button>
|
||||||
<button type="button" className="queue-btn" onClick={onClearQueue}>
|
<button className="queue-btn" id="btnClearQueue">
|
||||||
Clear
|
Clear
|
||||||
</button>
|
</button>
|
||||||
</div>
|
</div>
|
||||||
|
|||||||
@@ -1,28 +1,7 @@
|
|||||||
import { NowPlaying } from './NowPlaying'
|
import { NowPlaying } from './NowPlaying'
|
||||||
import { QueuePopover } from './queue-popover'
|
|
||||||
import type { QueueItem } from './QueueList'
|
import type { QueueItem } from './QueueList'
|
||||||
|
|
||||||
type PlayerBarProps = {
|
export function PlayerBar({ track }: { track: QueueItem | null }) {
|
||||||
track: QueueItem | null
|
|
||||||
queue: QueueItem[]
|
|
||||||
order: number[]
|
|
||||||
playingOrigIdx: number
|
|
||||||
scrollSignal: number
|
|
||||||
onQueuePlay: (origIdx: number) => void
|
|
||||||
onQueueRemove: (origIdx: number) => void
|
|
||||||
onQueueMove: (fromPos: number, toPos: number) => void
|
|
||||||
}
|
|
||||||
|
|
||||||
export function PlayerBar({
|
|
||||||
track,
|
|
||||||
queue,
|
|
||||||
order,
|
|
||||||
playingOrigIdx,
|
|
||||||
scrollSignal,
|
|
||||||
onQueuePlay,
|
|
||||||
onQueueRemove,
|
|
||||||
onQueueMove,
|
|
||||||
}: PlayerBarProps) {
|
|
||||||
return (
|
return (
|
||||||
<div className="player-bar">
|
<div className="player-bar">
|
||||||
<NowPlaying track={track} />
|
<NowPlaying track={track} />
|
||||||
@@ -51,15 +30,6 @@ export function PlayerBar({
|
|||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
<div className="volume-row">
|
<div className="volume-row">
|
||||||
<QueuePopover
|
|
||||||
queue={queue}
|
|
||||||
order={order}
|
|
||||||
playingOrigIdx={playingOrigIdx}
|
|
||||||
scrollSignal={scrollSignal}
|
|
||||||
onPlay={onQueuePlay}
|
|
||||||
onRemove={onQueueRemove}
|
|
||||||
onMove={onQueueMove}
|
|
||||||
/>
|
|
||||||
<span className="vol-icon" id="volIcon">
|
<span className="vol-icon" id="volIcon">
|
||||||
🔊
|
🔊
|
||||||
</span>
|
</span>
|
||||||
|
|||||||
@@ -1,35 +0,0 @@
|
|||||||
.header {
|
|
||||||
display: flex;
|
|
||||||
align-items: center;
|
|
||||||
justify-content: space-between;
|
|
||||||
padding: 0.75rem 1.5rem;
|
|
||||||
background: var(--bg-panel);
|
|
||||||
border-bottom: 1px solid var(--border);
|
|
||||||
flex-shrink: 0;
|
|
||||||
z-index: 10;
|
|
||||||
}
|
|
||||||
|
|
||||||
.headerLogo {
|
|
||||||
display: flex;
|
|
||||||
align-items: center;
|
|
||||||
gap: 0.75rem;
|
|
||||||
font-weight: 700;
|
|
||||||
font-size: 1.1rem;
|
|
||||||
color: #ffffff;
|
|
||||||
}
|
|
||||||
|
|
||||||
.headerLogo svg {
|
|
||||||
width: 22px;
|
|
||||||
height: 22px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.headerVersion {
|
|
||||||
font-size: 0.7rem;
|
|
||||||
color: var(--text-muted);
|
|
||||||
background: rgba(255, 255, 255, 0.05);
|
|
||||||
padding: 0.1rem 0.4rem;
|
|
||||||
border-radius: 4px;
|
|
||||||
margin-left: 0.25rem;
|
|
||||||
font-weight: 500;
|
|
||||||
text-decoration: none;
|
|
||||||
}
|
|
||||||
@@ -1 +0,0 @@
|
|||||||
export * from './Header'
|
|
||||||
@@ -1 +0,0 @@
|
|||||||
export * from './queue-popover'
|
|
||||||
@@ -1,68 +0,0 @@
|
|||||||
.root {
|
|
||||||
position: relative;
|
|
||||||
display: flex;
|
|
||||||
align-items: center;
|
|
||||||
}
|
|
||||||
|
|
||||||
.trigger {
|
|
||||||
display: flex;
|
|
||||||
align-items: center;
|
|
||||||
justify-content: center;
|
|
||||||
padding: 0.35rem;
|
|
||||||
margin: 0;
|
|
||||||
border: none;
|
|
||||||
border-radius: 6px;
|
|
||||||
background: transparent;
|
|
||||||
color: var(--text-muted);
|
|
||||||
cursor: pointer;
|
|
||||||
font: inherit;
|
|
||||||
line-height: 1;
|
|
||||||
}
|
|
||||||
|
|
||||||
.trigger:hover {
|
|
||||||
color: var(--text);
|
|
||||||
background: var(--bg-hover);
|
|
||||||
}
|
|
||||||
|
|
||||||
.triggerIcon {
|
|
||||||
font-size: 0.95rem;
|
|
||||||
}
|
|
||||||
|
|
||||||
.popover {
|
|
||||||
position: absolute;
|
|
||||||
bottom: calc(100% + 0.5rem);
|
|
||||||
right: 0;
|
|
||||||
z-index: 60;
|
|
||||||
display: flex;
|
|
||||||
flex-direction: column;
|
|
||||||
min-width: min(100vw - 2rem, 320px);
|
|
||||||
max-width: min(100vw - 2rem, 360px);
|
|
||||||
max-height: min(50vh, 360px);
|
|
||||||
border-radius: 8px;
|
|
||||||
border: 1px solid var(--border);
|
|
||||||
background: var(--bg-card);
|
|
||||||
box-shadow: 0 8px 28px rgba(0, 0, 0, 0.45);
|
|
||||||
}
|
|
||||||
|
|
||||||
.header {
|
|
||||||
flex-shrink: 0;
|
|
||||||
padding: 0.55rem 0.75rem;
|
|
||||||
font-size: 0.75rem;
|
|
||||||
font-weight: 600;
|
|
||||||
letter-spacing: 0.04em;
|
|
||||||
text-transform: uppercase;
|
|
||||||
color: var(--text-muted);
|
|
||||||
border-bottom: 1px solid var(--border);
|
|
||||||
}
|
|
||||||
|
|
||||||
.body {
|
|
||||||
flex: 1;
|
|
||||||
min-height: 0;
|
|
||||||
overflow: auto;
|
|
||||||
padding: 0.35rem 0.5rem;
|
|
||||||
}
|
|
||||||
|
|
||||||
.body :global(.queue-empty) {
|
|
||||||
padding: 1.25rem 0.75rem;
|
|
||||||
font-size: 0.8rem;
|
|
||||||
}
|
|
||||||
@@ -1,86 +0,0 @@
|
|||||||
import { useEffect, useId, useRef, useState } from 'react'
|
|
||||||
import { QueueList, type QueueItem } from '../QueueList'
|
|
||||||
import styles from './queue-popover.module.css'
|
|
||||||
|
|
||||||
export type QueuePopoverProps = {
|
|
||||||
queue: QueueItem[]
|
|
||||||
order: number[]
|
|
||||||
playingOrigIdx: number
|
|
||||||
scrollSignal: number
|
|
||||||
onPlay: (origIdx: number) => void
|
|
||||||
onRemove: (origIdx: number) => void
|
|
||||||
onMove: (fromPos: number, toPos: number) => void
|
|
||||||
}
|
|
||||||
|
|
||||||
export function QueuePopover({
|
|
||||||
queue,
|
|
||||||
order,
|
|
||||||
playingOrigIdx,
|
|
||||||
scrollSignal,
|
|
||||||
onPlay,
|
|
||||||
onRemove,
|
|
||||||
onMove,
|
|
||||||
}: QueuePopoverProps) {
|
|
||||||
const [open, setOpen] = useState(false)
|
|
||||||
const rootRef = useRef<HTMLDivElement>(null)
|
|
||||||
const titleId = useId()
|
|
||||||
const panelId = useId()
|
|
||||||
|
|
||||||
useEffect(() => {
|
|
||||||
if (!open) return
|
|
||||||
function onDocMouseDown(e: MouseEvent) {
|
|
||||||
const el = rootRef.current
|
|
||||||
if (el && !el.contains(e.target as Node)) setOpen(false)
|
|
||||||
}
|
|
||||||
function onKey(e: KeyboardEvent) {
|
|
||||||
if (e.key === 'Escape') setOpen(false)
|
|
||||||
}
|
|
||||||
document.addEventListener('mousedown', onDocMouseDown)
|
|
||||||
document.addEventListener('keydown', onKey)
|
|
||||||
return () => {
|
|
||||||
document.removeEventListener('mousedown', onDocMouseDown)
|
|
||||||
document.removeEventListener('keydown', onKey)
|
|
||||||
}
|
|
||||||
}, [open])
|
|
||||||
|
|
||||||
return (
|
|
||||||
<div className={styles.root} ref={rootRef}>
|
|
||||||
<button
|
|
||||||
type="button"
|
|
||||||
className={styles.trigger}
|
|
||||||
title="Playback queue"
|
|
||||||
aria-expanded={open}
|
|
||||||
aria-haspopup="dialog"
|
|
||||||
aria-controls={open ? panelId : undefined}
|
|
||||||
onClick={() => setOpen((v) => !v)}
|
|
||||||
>
|
|
||||||
<span className={styles.triggerIcon} aria-hidden>
|
|
||||||
☰
|
|
||||||
</span>
|
|
||||||
</button>
|
|
||||||
{open && (
|
|
||||||
<div
|
|
||||||
id={panelId}
|
|
||||||
className={styles.popover}
|
|
||||||
role="dialog"
|
|
||||||
aria-labelledby={titleId}
|
|
||||||
>
|
|
||||||
<div className={styles.header} id={titleId}>
|
|
||||||
Queue
|
|
||||||
</div>
|
|
||||||
<div className={styles.body}>
|
|
||||||
<QueueList
|
|
||||||
queue={queue}
|
|
||||||
order={order}
|
|
||||||
playingOrigIdx={playingOrigIdx}
|
|
||||||
scrollSignal={scrollSignal}
|
|
||||||
onPlay={onPlay}
|
|
||||||
onRemove={onRemove}
|
|
||||||
onMove={onMove}
|
|
||||||
/>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
)}
|
|
||||||
</div>
|
|
||||||
)
|
|
||||||
}
|
|
||||||
@@ -31,6 +31,40 @@
|
|||||||
--danger: #f87171;
|
--danger: #f87171;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
.header {
|
||||||
|
display: flex;
|
||||||
|
align-items: center;
|
||||||
|
justify-content: space-between;
|
||||||
|
padding: 0.75rem 1.5rem;
|
||||||
|
background: var(--bg-panel);
|
||||||
|
border-bottom: 1px solid var(--border);
|
||||||
|
flex-shrink: 0;
|
||||||
|
z-index: 10;
|
||||||
|
}
|
||||||
|
|
||||||
|
.header-logo {
|
||||||
|
display: flex;
|
||||||
|
align-items: center;
|
||||||
|
gap: 0.75rem;
|
||||||
|
font-weight: 700;
|
||||||
|
font-size: 1.1rem;
|
||||||
|
}
|
||||||
|
|
||||||
|
.header-logo svg {
|
||||||
|
width: 22px;
|
||||||
|
height: 22px;
|
||||||
|
}
|
||||||
|
|
||||||
|
.header-version {
|
||||||
|
font-size: 0.7rem;
|
||||||
|
color: var(--text-muted);
|
||||||
|
background: rgba(255, 255, 255, 0.05);
|
||||||
|
padding: 0.1rem 0.4rem;
|
||||||
|
border-radius: 4px;
|
||||||
|
margin-left: 0.25rem;
|
||||||
|
font-weight: 500;
|
||||||
|
text-decoration: none;
|
||||||
|
}
|
||||||
|
|
||||||
.btn-menu {
|
.btn-menu {
|
||||||
display: none;
|
display: none;
|
||||||
@@ -344,10 +378,6 @@
|
|||||||
color: var(--accent);
|
color: var(--accent);
|
||||||
}
|
}
|
||||||
|
|
||||||
.qi-title {
|
|
||||||
color: #ffffff;
|
|
||||||
}
|
|
||||||
|
|
||||||
.queue-item .qi-index {
|
.queue-item .qi-index {
|
||||||
font-size: 0.75rem;
|
font-size: 0.75rem;
|
||||||
color: var(--text-muted);
|
color: var(--text-muted);
|
||||||
@@ -501,7 +531,6 @@
|
|||||||
overflow: hidden;
|
overflow: hidden;
|
||||||
text-overflow: ellipsis;
|
text-overflow: ellipsis;
|
||||||
white-space: nowrap;
|
white-space: nowrap;
|
||||||
color: #ffffff;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
.np-artist {
|
.np-artist {
|
||||||
|
|||||||
@@ -1,21 +1,16 @@
|
|||||||
import axios from 'axios'
|
import axios from 'axios'
|
||||||
import type { Album, Artist, SearchResult, Track, TrackDetail } from './types'
|
import type { Album, Artist, SearchResult, Track, TrackDetail } from './types'
|
||||||
|
|
||||||
const FURUMI_API_BASE = import.meta.env.VITE_FURUMI_API_URL ?? ''
|
const API_BASE = import.meta.env.VITE_API_BASE_URL ?? ''
|
||||||
export const API_ROOT = `${FURUMI_API_BASE}/api`
|
export const API_ROOT = `${API_BASE}/api`
|
||||||
|
|
||||||
|
const API_KEY = import.meta.env.VITE_API_KEY
|
||||||
|
|
||||||
export const furumiApi = axios.create({
|
export const furumiApi = axios.create({
|
||||||
baseURL: API_ROOT,
|
baseURL: API_ROOT,
|
||||||
|
headers: API_KEY ? { 'x-api-key': API_KEY } : {},
|
||||||
})
|
})
|
||||||
|
|
||||||
export function setAuthToken(token: string) {
|
|
||||||
furumiApi.defaults.headers.common['Authorization'] = `Bearer ${token}`
|
|
||||||
}
|
|
||||||
|
|
||||||
export function clearAuthToken() {
|
|
||||||
delete furumiApi.defaults.headers.common['Authorization']
|
|
||||||
}
|
|
||||||
|
|
||||||
export async function getArtists(): Promise<Artist[] | null> {
|
export async function getArtists(): Promise<Artist[] | null> {
|
||||||
const res = await furumiApi.get<Artist[]>('/artists').catch(() => null)
|
const res = await furumiApi.get<Artist[]>('/artists').catch(() => null)
|
||||||
return res?.data ?? null
|
return res?.data ?? null
|
||||||
@@ -49,6 +44,6 @@ export async function getTrackInfo(trackSlug: string): Promise<TrackDetail | nul
|
|||||||
}
|
}
|
||||||
|
|
||||||
export async function preloadStream(trackSlug: string) {
|
export async function preloadStream(trackSlug: string) {
|
||||||
return await furumiApi.get(`/stream/${trackSlug}`, { responseType: 'blob' }).catch(() => null)
|
await furumiApi.get(`/stream/${trackSlug}`).catch(() => null)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -5,7 +5,6 @@ import albumsReducer from './slices/albumsSlice'
|
|||||||
import albumTracksReducer from './slices/albumTracksSlice'
|
import albumTracksReducer from './slices/albumTracksSlice'
|
||||||
import artistTracksReducer from './slices/artistTracksSlice'
|
import artistTracksReducer from './slices/artistTracksSlice'
|
||||||
import trackDetailReducer from './slices/trackDetailSlice'
|
import trackDetailReducer from './slices/trackDetailSlice'
|
||||||
import queueReducer from './slices/queueSlice'
|
|
||||||
|
|
||||||
export const store = configureStore({
|
export const store = configureStore({
|
||||||
reducer: {
|
reducer: {
|
||||||
@@ -14,7 +13,6 @@ export const store = configureStore({
|
|||||||
albumTracks: albumTracksReducer,
|
albumTracks: albumTracksReducer,
|
||||||
artistTracks: artistTracksReducer,
|
artistTracks: artistTracksReducer,
|
||||||
trackDetail: trackDetailReducer,
|
trackDetail: trackDetailReducer,
|
||||||
queue: queueReducer,
|
|
||||||
},
|
},
|
||||||
})
|
})
|
||||||
|
|
||||||
|
|||||||
@@ -1,274 +0,0 @@
|
|||||||
import { createSlice, type PayloadAction } from '@reduxjs/toolkit'
|
|
||||||
import type { QueueItem } from '../../components/QueueList'
|
|
||||||
|
|
||||||
export interface QueueState {
|
|
||||||
items: QueueItem[]
|
|
||||||
currentIndex: number
|
|
||||||
shuffle: boolean
|
|
||||||
repeatAll: boolean
|
|
||||||
shuffleOrder: number[]
|
|
||||||
scrollSignal: number
|
|
||||||
}
|
|
||||||
|
|
||||||
function readShufflePref(): boolean {
|
|
||||||
try {
|
|
||||||
return window.localStorage.getItem('furumi_shuffle') === '1'
|
|
||||||
} catch {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
function readRepeatPref(): boolean {
|
|
||||||
try {
|
|
||||||
return window.localStorage.getItem('furumi_repeat') !== '0'
|
|
||||||
} catch {
|
|
||||||
return true
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
function buildShuffleOrder(state: QueueState) {
|
|
||||||
const n = state.items.length
|
|
||||||
if (n === 0) {
|
|
||||||
state.shuffleOrder = []
|
|
||||||
return
|
|
||||||
}
|
|
||||||
const order = [...Array(n).keys()]
|
|
||||||
for (let i = order.length - 1; i > 0; i--) {
|
|
||||||
const j = Math.floor(Math.random() * (i + 1))
|
|
||||||
;[order[i], order[j]] = [order[j], order[i]]
|
|
||||||
}
|
|
||||||
if (state.currentIndex !== -1) {
|
|
||||||
const ci = order.indexOf(state.currentIndex)
|
|
||||||
if (ci > 0) {
|
|
||||||
order.splice(ci, 1)
|
|
||||||
order.unshift(state.currentIndex)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
state.shuffleOrder = order
|
|
||||||
}
|
|
||||||
|
|
||||||
function ensureShuffleOrder(state: QueueState) {
|
|
||||||
if (!state.shuffle) return
|
|
||||||
if (state.shuffleOrder.length !== state.items.length) {
|
|
||||||
buildShuffleOrder(state)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
const initialState: QueueState = {
|
|
||||||
items: [],
|
|
||||||
currentIndex: -1,
|
|
||||||
shuffle: typeof window !== 'undefined' ? readShufflePref() : false,
|
|
||||||
repeatAll: typeof window !== 'undefined' ? readRepeatPref() : true,
|
|
||||||
shuffleOrder: [],
|
|
||||||
scrollSignal: 0,
|
|
||||||
}
|
|
||||||
|
|
||||||
const queueSlice = createSlice({
|
|
||||||
name: 'queue',
|
|
||||||
initialState,
|
|
||||||
reducers: {
|
|
||||||
addTrack(
|
|
||||||
state,
|
|
||||||
action: PayloadAction<{
|
|
||||||
track: QueueItem
|
|
||||||
playNow?: boolean
|
|
||||||
}>,
|
|
||||||
) {
|
|
||||||
const { track, playNow } = action.payload
|
|
||||||
const existing = state.items.findIndex((t) => t.slug === track.slug)
|
|
||||||
if (existing !== -1) {
|
|
||||||
if (playNow) {
|
|
||||||
state.currentIndex = existing
|
|
||||||
state.scrollSignal += 1
|
|
||||||
}
|
|
||||||
return
|
|
||||||
}
|
|
||||||
const oldLen = state.items.length
|
|
||||||
const idle = state.currentIndex === -1
|
|
||||||
state.items.push(track)
|
|
||||||
ensureShuffleOrder(state)
|
|
||||||
if (playNow || (oldLen === 0 && idle)) {
|
|
||||||
state.currentIndex = state.items.length - 1
|
|
||||||
state.scrollSignal += 1
|
|
||||||
}
|
|
||||||
},
|
|
||||||
|
|
||||||
addTracksBatch(
|
|
||||||
state,
|
|
||||||
action: PayloadAction<{
|
|
||||||
tracks: QueueItem[]
|
|
||||||
playFirst?: boolean
|
|
||||||
}>,
|
|
||||||
) {
|
|
||||||
const { tracks, playFirst } = action.payload
|
|
||||||
let firstNewIdx: number | null = null
|
|
||||||
for (const t of tracks) {
|
|
||||||
if (state.items.some((q) => q.slug === t.slug)) continue
|
|
||||||
if (firstNewIdx === null) firstNewIdx = state.items.length
|
|
||||||
state.items.push(t)
|
|
||||||
}
|
|
||||||
ensureShuffleOrder(state)
|
|
||||||
if (firstNewIdx === null) return
|
|
||||||
if (playFirst || state.currentIndex === -1) {
|
|
||||||
state.currentIndex = firstNewIdx
|
|
||||||
state.scrollSignal += 1
|
|
||||||
}
|
|
||||||
},
|
|
||||||
|
|
||||||
replaceQueue(
|
|
||||||
state,
|
|
||||||
action: PayloadAction<{
|
|
||||||
items: QueueItem[]
|
|
||||||
playFromIndex?: number
|
|
||||||
}>,
|
|
||||||
) {
|
|
||||||
const { items, playFromIndex = 0 } = action.payload
|
|
||||||
state.items = items
|
|
||||||
state.currentIndex =
|
|
||||||
items.length > 0 ? Math.min(playFromIndex, items.length - 1) : -1
|
|
||||||
state.shuffleOrder = []
|
|
||||||
ensureShuffleOrder(state)
|
|
||||||
},
|
|
||||||
|
|
||||||
clearQueue(state) {
|
|
||||||
state.items = []
|
|
||||||
state.currentIndex = -1
|
|
||||||
state.shuffleOrder = []
|
|
||||||
state.scrollSignal += 1
|
|
||||||
},
|
|
||||||
|
|
||||||
playAtIndex(state, action: PayloadAction<number>) {
|
|
||||||
const i = action.payload
|
|
||||||
if (i < 0 || i >= state.items.length) return
|
|
||||||
state.currentIndex = i
|
|
||||||
state.scrollSignal += 1
|
|
||||||
},
|
|
||||||
|
|
||||||
removeFromQueueAt(state, action: PayloadAction<number>) {
|
|
||||||
const idx = action.payload
|
|
||||||
if (idx < 0 || idx >= state.items.length) return
|
|
||||||
|
|
||||||
if (idx === state.currentIndex) {
|
|
||||||
state.currentIndex = -1
|
|
||||||
} else if (state.currentIndex > idx) {
|
|
||||||
state.currentIndex -= 1
|
|
||||||
}
|
|
||||||
|
|
||||||
state.items.splice(idx, 1)
|
|
||||||
|
|
||||||
if (state.shuffle) {
|
|
||||||
const si = state.shuffleOrder.indexOf(idx)
|
|
||||||
if (si !== -1) state.shuffleOrder.splice(si, 1)
|
|
||||||
for (let i = 0; i < state.shuffleOrder.length; i++) {
|
|
||||||
if (state.shuffleOrder[i] > idx) state.shuffleOrder[i] -= 1
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
ensureShuffleOrder(state)
|
|
||||||
},
|
|
||||||
|
|
||||||
moveQueueItemInOrder(
|
|
||||||
state,
|
|
||||||
action: PayloadAction<{ fromPos: number; toPos: number }>,
|
|
||||||
) {
|
|
||||||
const { fromPos, toPos } = action.payload
|
|
||||||
if (fromPos === toPos) return
|
|
||||||
|
|
||||||
if (state.shuffle) {
|
|
||||||
const order = state.shuffleOrder
|
|
||||||
if (fromPos < 0 || fromPos >= order.length) return
|
|
||||||
if (toPos < 0 || toPos >= order.length) return
|
|
||||||
const item = order.splice(fromPos, 1)[0]
|
|
||||||
order.splice(toPos, 0, item)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
const items = state.items
|
|
||||||
if (fromPos < 0 || fromPos >= items.length) return
|
|
||||||
if (toPos < 0 || toPos >= items.length) return
|
|
||||||
const qIdx = state.currentIndex
|
|
||||||
const item = items.splice(fromPos, 1)[0]
|
|
||||||
items.splice(toPos, 0, item)
|
|
||||||
if (qIdx === fromPos) state.currentIndex = toPos
|
|
||||||
else if (fromPos < qIdx && toPos >= qIdx) state.currentIndex -= 1
|
|
||||||
else if (fromPos > qIdx && toPos <= qIdx) state.currentIndex += 1
|
|
||||||
},
|
|
||||||
|
|
||||||
toggleShuffle(state) {
|
|
||||||
state.shuffle = !state.shuffle
|
|
||||||
try {
|
|
||||||
window.localStorage.setItem('furumi_shuffle', state.shuffle ? '1' : '0')
|
|
||||||
} catch {
|
|
||||||
// ignore
|
|
||||||
}
|
|
||||||
if (state.shuffle) buildShuffleOrder(state)
|
|
||||||
else state.shuffleOrder = []
|
|
||||||
},
|
|
||||||
|
|
||||||
toggleRepeat(state) {
|
|
||||||
state.repeatAll = !state.repeatAll
|
|
||||||
try {
|
|
||||||
window.localStorage.setItem('furumi_repeat', state.repeatAll ? '1' : '0')
|
|
||||||
} catch {
|
|
||||||
// ignore
|
|
||||||
}
|
|
||||||
},
|
|
||||||
|
|
||||||
rebuildShuffleOrder(state) {
|
|
||||||
if (state.shuffle) buildShuffleOrder(state)
|
|
||||||
},
|
|
||||||
},
|
|
||||||
})
|
|
||||||
|
|
||||||
export const {
|
|
||||||
addTrack,
|
|
||||||
addTracksBatch,
|
|
||||||
replaceQueue,
|
|
||||||
clearQueue,
|
|
||||||
playAtIndex,
|
|
||||||
removeFromQueueAt,
|
|
||||||
moveQueueItemInOrder,
|
|
||||||
toggleShuffle,
|
|
||||||
toggleRepeat,
|
|
||||||
rebuildShuffleOrder,
|
|
||||||
} = queueSlice.actions
|
|
||||||
|
|
||||||
type QueueSliceRoot = { queue: QueueState }
|
|
||||||
|
|
||||||
export function selectQueueItems(state: QueueSliceRoot) {
|
|
||||||
return state.queue.items
|
|
||||||
}
|
|
||||||
|
|
||||||
// TODO: toggle shuffle should rebuild the shuffle order
|
|
||||||
export function selectQueueOrder(state: QueueSliceRoot): number[] {
|
|
||||||
const q = state.queue
|
|
||||||
if (!q.shuffle) return q.items.map((_, i) => i)
|
|
||||||
if (q.shuffleOrder.length !== q.items.length) {
|
|
||||||
return q.items.map((_, i) => i)
|
|
||||||
}
|
|
||||||
return q.shuffleOrder
|
|
||||||
}
|
|
||||||
|
|
||||||
export function selectPlayingOrigIdx(state: QueueSliceRoot) {
|
|
||||||
return state.queue.currentIndex
|
|
||||||
}
|
|
||||||
|
|
||||||
export function selectQueueScrollSignal(state: QueueSliceRoot) {
|
|
||||||
return state.queue.scrollSignal
|
|
||||||
}
|
|
||||||
|
|
||||||
export function selectNowPlayingTrack(state: QueueSliceRoot): QueueItem | null {
|
|
||||||
const q = state.queue
|
|
||||||
if (q.currentIndex < 0 || q.currentIndex >= q.items.length) return null
|
|
||||||
return q.items[q.currentIndex]
|
|
||||||
}
|
|
||||||
|
|
||||||
export function selectShuffle(state: QueueSliceRoot) {
|
|
||||||
return state.queue.shuffle
|
|
||||||
}
|
|
||||||
|
|
||||||
export function selectRepeatAll(state: QueueSliceRoot) {
|
|
||||||
return state.queue.repeatAll
|
|
||||||
}
|
|
||||||
|
|
||||||
export default queueSlice.reducer
|
|
||||||
@@ -6,11 +6,7 @@ export default defineConfig({
|
|||||||
plugins: [react()],
|
plugins: [react()],
|
||||||
server: {
|
server: {
|
||||||
proxy: {
|
proxy: {
|
||||||
'/auth': {
|
'/api': {
|
||||||
target: 'http://localhost:3001',
|
|
||||||
changeOrigin: true,
|
|
||||||
},
|
|
||||||
'/callback': {
|
|
||||||
target: 'http://localhost:3001',
|
target: 'http://localhost:3001',
|
||||||
changeOrigin: true,
|
changeOrigin: true,
|
||||||
},
|
},
|
||||||
|
|||||||
@@ -1,6 +1,5 @@
|
|||||||
import 'dotenv/config';
|
import 'dotenv/config';
|
||||||
|
|
||||||
import path from 'path';
|
|
||||||
import cors from 'cors';
|
import cors from 'cors';
|
||||||
import express from 'express';
|
import express from 'express';
|
||||||
import { auth } from 'express-openid-connect';
|
import { auth } from 'express-openid-connect';
|
||||||
@@ -29,6 +28,7 @@ const oidcConfig = {
|
|||||||
};
|
};
|
||||||
|
|
||||||
if (!disableAuth && (!oidcConfig.clientID || !oidcConfig.issuerBaseURL || !oidcConfig.clientSecret)) {
|
if (!disableAuth && (!oidcConfig.clientID || !oidcConfig.issuerBaseURL || !oidcConfig.clientSecret)) {
|
||||||
|
// Keep a clear startup failure if OIDC is not configured.
|
||||||
throw new Error(
|
throw new Error(
|
||||||
'OIDC config is missing. Set OIDC_ISSUER_BASE_URL, OIDC_CLIENT_ID, OIDC_CLIENT_SECRET in server/.env (or set DISABLE_AUTH=true)',
|
'OIDC config is missing. Set OIDC_ISSUER_BASE_URL, OIDC_CLIENT_ID, OIDC_CLIENT_SECRET in server/.env (or set DISABLE_AUTH=true)',
|
||||||
);
|
);
|
||||||
@@ -46,11 +46,11 @@ if (!disableAuth) {
|
|||||||
app.use(auth(oidcConfig));
|
app.use(auth(oidcConfig));
|
||||||
}
|
}
|
||||||
|
|
||||||
app.get('/auth/health', (_req, res) => {
|
app.get('/api/health', (_req, res) => {
|
||||||
res.json({ ok: true });
|
res.json({ ok: true });
|
||||||
});
|
});
|
||||||
|
|
||||||
app.get('/auth/me', (req, res) => {
|
app.get('/api/me', (req, res) => {
|
||||||
if (disableAuth) {
|
if (disableAuth) {
|
||||||
res.json({
|
res.json({
|
||||||
authenticated: false,
|
authenticated: false,
|
||||||
@@ -74,32 +74,7 @@ app.get('/auth/me', (req, res) => {
|
|||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
app.get('/auth/token', (req, res) => {
|
app.get('/api/login', (req, res) => {
|
||||||
if (disableAuth) {
|
|
||||||
res.status(204).end();
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!req.oidc.isAuthenticated()) {
|
|
||||||
res.status(401).json({ authenticated: false });
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const accessToken = req.oidc.accessToken?.access_token;
|
|
||||||
const expiresAt = req.oidc.accessToken?.expires_in;
|
|
||||||
if (!accessToken) {
|
|
||||||
res.status(500).json({ error: 'no access token in session' });
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
res.json({
|
|
||||||
access_token: accessToken,
|
|
||||||
token_type: 'Bearer',
|
|
||||||
expires_in: expiresAt,
|
|
||||||
});
|
|
||||||
});
|
|
||||||
|
|
||||||
app.get('/auth/login', (req, res) => {
|
|
||||||
if (disableAuth) {
|
if (disableAuth) {
|
||||||
res.status(204).end();
|
res.status(204).end();
|
||||||
return;
|
return;
|
||||||
@@ -110,7 +85,7 @@ app.get('/auth/login', (req, res) => {
|
|||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
app.get('/auth/logout', (req, res) => {
|
app.get('/api/logout', (req, res) => {
|
||||||
if (disableAuth) {
|
if (disableAuth) {
|
||||||
res.status(204).end();
|
res.status(204).end();
|
||||||
return;
|
return;
|
||||||
@@ -121,13 +96,6 @@ app.get('/auth/logout', (req, res) => {
|
|||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
// Production: serve Vite-built client as static files
|
|
||||||
const clientDist = path.resolve(import.meta.dirname, '../../client/dist');
|
|
||||||
app.use(express.static(clientDist));
|
|
||||||
app.get('/{*path}', (_req, res) => {
|
|
||||||
res.sendFile(path.join(clientDist, 'index.html'));
|
|
||||||
});
|
|
||||||
|
|
||||||
app.listen(port, () => {
|
app.listen(port, () => {
|
||||||
console.log(
|
console.log(
|
||||||
`${disableAuth ? 'NO-AUTH' : 'OIDC auth'} server listening on http://localhost:${port}`,
|
`${disableAuth ? 'NO-AUTH' : 'OIDC auth'} server listening on http://localhost:${port}`,
|
||||||
|
|||||||
@@ -18,8 +18,7 @@ mime_guess = "2.0"
|
|||||||
symphonia = { version = "0.5", default-features = false, features = ["mp3", "aac", "flac", "vorbis", "wav", "alac", "adpcm", "pcm", "mpa", "isomp4", "ogg", "aiff", "mkv"] }
|
symphonia = { version = "0.5", default-features = false, features = ["mp3", "aac", "flac", "vorbis", "wav", "alac", "adpcm", "pcm", "mpa", "isomp4", "ogg", "aiff", "mkv"] }
|
||||||
tokio-util = { version = "0.7", features = ["io"] }
|
tokio-util = { version = "0.7", features = ["io"] }
|
||||||
openidconnect = "3.4"
|
openidconnect = "3.4"
|
||||||
reqwest = { version = "0.12", default-features = false, features = ["rustls-tls", "json"] }
|
reqwest = { version = "0.12", default-features = false, features = ["rustls-tls"] }
|
||||||
jsonwebtoken = "9"
|
|
||||||
sha2 = "0.10"
|
sha2 = "0.10"
|
||||||
hmac = "0.12"
|
hmac = "0.12"
|
||||||
base64 = "0.22"
|
base64 = "0.22"
|
||||||
|
|||||||
@@ -40,6 +40,9 @@ struct Args {
|
|||||||
#[arg(long, env = "FURUMI_PLAYER_OIDC_SESSION_SECRET")]
|
#[arg(long, env = "FURUMI_PLAYER_OIDC_SESSION_SECRET")]
|
||||||
oidc_session_secret: Option<String>,
|
oidc_session_secret: Option<String>,
|
||||||
|
|
||||||
|
/// API key for x-api-key header auth (alternative to OIDC session)
|
||||||
|
#[arg(long, env = "FURUMI_PLAYER_API_KEY")]
|
||||||
|
api_key: Option<String>,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[tokio::main]
|
#[tokio::main]
|
||||||
@@ -91,10 +94,15 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
|
|||||||
std::process::exit(1);
|
std::process::exit(1);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
if args.api_key.is_some() {
|
||||||
|
tracing::info!("x-api-key auth: enabled");
|
||||||
|
}
|
||||||
|
|
||||||
let state = Arc::new(web::AppState {
|
let state = Arc::new(web::AppState {
|
||||||
pool,
|
pool,
|
||||||
storage_dir: Arc::new(args.storage_dir),
|
storage_dir: Arc::new(args.storage_dir),
|
||||||
oidc: oidc_state,
|
oidc: oidc_state,
|
||||||
|
api_key: args.api_key,
|
||||||
});
|
});
|
||||||
|
|
||||||
tracing::info!("Web player: http://{}", bind_addr);
|
tracing::info!("Web player: http://{}", bind_addr);
|
||||||
|
|||||||
@@ -3,9 +3,10 @@ use axum::{
|
|||||||
extract::{Request, State},
|
extract::{Request, State},
|
||||||
http::{header, HeaderMap, StatusCode},
|
http::{header, HeaderMap, StatusCode},
|
||||||
middleware::Next,
|
middleware::Next,
|
||||||
response::{IntoResponse, Redirect, Response},
|
response::{Html, IntoResponse, Redirect, Response},
|
||||||
};
|
};
|
||||||
|
|
||||||
|
const X_API_KEY: &str = "x-api-key";
|
||||||
use openidconnect::{
|
use openidconnect::{
|
||||||
core::{CoreClient, CoreProviderMetadata, CoreResponseType},
|
core::{CoreClient, CoreProviderMetadata, CoreResponseType},
|
||||||
reqwest::async_http_client,
|
reqwest::async_http_client,
|
||||||
@@ -17,26 +18,17 @@ use serde::Deserialize;
|
|||||||
|
|
||||||
use base64::Engine;
|
use base64::Engine;
|
||||||
use hmac::{Hmac, Mac};
|
use hmac::{Hmac, Mac};
|
||||||
use jsonwebtoken::{decode, decode_header, DecodingKey, Validation as JwtValidation};
|
|
||||||
use jsonwebtoken::jwk::JwkSet;
|
|
||||||
use std::time::{Duration, Instant};
|
|
||||||
use tokio::sync::RwLock;
|
|
||||||
|
|
||||||
use super::AppState;
|
use super::AppState;
|
||||||
use std::sync::Arc;
|
use std::sync::Arc;
|
||||||
|
|
||||||
const SESSION_COOKIE: &str = "furumi_session";
|
const SESSION_COOKIE: &str = "furumi_session";
|
||||||
const JWKS_CACHE_TTL: Duration = Duration::from_secs(3600);
|
|
||||||
|
|
||||||
type HmacSha256 = Hmac<sha2::Sha256>;
|
type HmacSha256 = Hmac<sha2::Sha256>;
|
||||||
|
|
||||||
pub struct OidcState {
|
pub struct OidcState {
|
||||||
pub client: CoreClient,
|
pub client: CoreClient,
|
||||||
pub session_secret: Vec<u8>,
|
pub session_secret: Vec<u8>,
|
||||||
jwks_uri: String,
|
|
||||||
issuer_url: String,
|
|
||||||
jwks_cache: RwLock<Option<(JwkSet, Instant)>>,
|
|
||||||
http_client: reqwest::Client,
|
|
||||||
}
|
}
|
||||||
|
|
||||||
pub async fn oidc_init(
|
pub async fn oidc_init(
|
||||||
@@ -52,9 +44,6 @@ pub async fn oidc_init(
|
|||||||
)
|
)
|
||||||
.await?;
|
.await?;
|
||||||
|
|
||||||
let jwks_uri = provider_metadata.jwks_uri().to_string();
|
|
||||||
let issuer_url = provider_metadata.issuer().to_string();
|
|
||||||
|
|
||||||
let client = CoreClient::from_provider_metadata(
|
let client = CoreClient::from_provider_metadata(
|
||||||
provider_metadata,
|
provider_metadata,
|
||||||
ClientId::new(client_id),
|
ClientId::new(client_id),
|
||||||
@@ -73,70 +62,12 @@ pub async fn oidc_init(
|
|||||||
b
|
b
|
||||||
};
|
};
|
||||||
|
|
||||||
let http_client = reqwest::Client::new();
|
|
||||||
|
|
||||||
tracing::info!("JWKS URI: {}", jwks_uri);
|
|
||||||
|
|
||||||
Ok(OidcState {
|
Ok(OidcState {
|
||||||
client,
|
client,
|
||||||
session_secret,
|
session_secret,
|
||||||
jwks_uri,
|
|
||||||
issuer_url,
|
|
||||||
jwks_cache: RwLock::new(None),
|
|
||||||
http_client,
|
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
impl OidcState {
|
|
||||||
async fn get_jwks(&self) -> anyhow::Result<JwkSet> {
|
|
||||||
{
|
|
||||||
let cache = self.jwks_cache.read().await;
|
|
||||||
if let Some((ref jwks, fetched_at)) = *cache {
|
|
||||||
if fetched_at.elapsed() < JWKS_CACHE_TTL {
|
|
||||||
return Ok(jwks.clone());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
self.refresh_jwks().await
|
|
||||||
}
|
|
||||||
|
|
||||||
async fn refresh_jwks(&self) -> anyhow::Result<JwkSet> {
|
|
||||||
tracing::debug!("Fetching JWKS from {}", self.jwks_uri);
|
|
||||||
let jwks: JwkSet = self.http_client.get(&self.jwks_uri).send().await?.json().await?;
|
|
||||||
let mut cache = self.jwks_cache.write().await;
|
|
||||||
*cache = Some((jwks.clone(), Instant::now()));
|
|
||||||
Ok(jwks)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug, serde::Deserialize)]
|
|
||||||
struct BearerClaims {
|
|
||||||
sub: String,
|
|
||||||
}
|
|
||||||
|
|
||||||
async fn validate_bearer_token(oidc: &OidcState, token: &str) -> Option<String> {
|
|
||||||
let header = decode_header(token).ok()?;
|
|
||||||
let kid = header.kid.as_ref()?;
|
|
||||||
|
|
||||||
let mut jwks = oidc.get_jwks().await.ok()?;
|
|
||||||
let mut jwk = jwks.find(kid);
|
|
||||||
|
|
||||||
// Handle key rotation: refresh JWKS if kid not found
|
|
||||||
if jwk.is_none() {
|
|
||||||
jwks = oidc.refresh_jwks().await.ok()?;
|
|
||||||
jwk = jwks.find(kid);
|
|
||||||
}
|
|
||||||
|
|
||||||
let key = DecodingKey::from_jwk(jwk?).ok()?;
|
|
||||||
|
|
||||||
let mut validation = JwtValidation::new(header.alg);
|
|
||||||
validation.set_issuer(&[&oidc.issuer_url]);
|
|
||||||
validation.validate_aud = false;
|
|
||||||
|
|
||||||
let data = decode::<BearerClaims>(token, &key, &validation).ok()?;
|
|
||||||
Some(data.claims.sub)
|
|
||||||
}
|
|
||||||
|
|
||||||
fn generate_sso_cookie(secret: &[u8], user_id: &str) -> String {
|
fn generate_sso_cookie(secret: &[u8], user_id: &str) -> String {
|
||||||
let mut mac = HmacSha256::new_from_slice(secret).unwrap();
|
let mut mac = HmacSha256::new_from_slice(secret).unwrap();
|
||||||
mac.update(user_id.as_bytes());
|
mac.update(user_id.as_bytes());
|
||||||
@@ -163,22 +94,20 @@ fn verify_sso_cookie(secret: &[u8], cookie_val: &str) -> Option<String> {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Auth middleware: requires valid Bearer JWT or SSO session cookie.
|
/// Auth middleware: requires valid SSO session cookie or x-api-key header.
|
||||||
pub async fn require_auth(
|
pub async fn require_auth(
|
||||||
State(state): State<Arc<AppState>>,
|
State(state): State<Arc<AppState>>,
|
||||||
req: Request,
|
req: Request,
|
||||||
next: Next,
|
next: Next,
|
||||||
) -> Response {
|
) -> Response {
|
||||||
// 1. Check Bearer token — JWT from OIDC provider
|
// 1. Check x-api-key header (if configured)
|
||||||
if let Some(ref oidc) = state.oidc {
|
if let Some(ref expected) = state.api_key {
|
||||||
if let Some(token) = req
|
if let Some(val) = req
|
||||||
.headers()
|
.headers()
|
||||||
.get(header::AUTHORIZATION)
|
.get(X_API_KEY)
|
||||||
.and_then(|v| v.to_str().ok())
|
.and_then(|v| v.to_str().ok())
|
||||||
.and_then(|v| v.strip_prefix("Bearer "))
|
|
||||||
{
|
{
|
||||||
if let Some(user_id) = validate_bearer_token(oidc, token).await {
|
if val == expected {
|
||||||
tracing::debug!("Bearer auth OK for user: {}", user_id);
|
|
||||||
return next.run(req).await;
|
return next.run(req).await;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -202,7 +131,36 @@ pub async fn require_auth(
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
(StatusCode::UNAUTHORIZED, "Unauthorized").into_response()
|
let uri = req.uri().to_string();
|
||||||
|
if uri.starts_with("/api/") {
|
||||||
|
(StatusCode::UNAUTHORIZED, "Unauthorized").into_response()
|
||||||
|
} else if state.oidc.is_some() {
|
||||||
|
Redirect::to("/login").into_response()
|
||||||
|
} else {
|
||||||
|
// Only API key configured — no web login available
|
||||||
|
(StatusCode::UNAUTHORIZED, "Unauthorized").into_response()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// GET /login — show SSO login page.
|
||||||
|
pub async fn login_page(State(state): State<Arc<AppState>>) -> impl IntoResponse {
|
||||||
|
if state.oidc.is_none() {
|
||||||
|
return Redirect::to("/").into_response();
|
||||||
|
}
|
||||||
|
|
||||||
|
Html(LOGIN_HTML).into_response()
|
||||||
|
}
|
||||||
|
|
||||||
|
/// GET /logout — clear session cookie.
|
||||||
|
pub async fn logout() -> impl IntoResponse {
|
||||||
|
let cookie = format!(
|
||||||
|
"{}=; HttpOnly; SameSite=Strict; Path=/; Expires=Thu, 01 Jan 1970 00:00:00 GMT",
|
||||||
|
SESSION_COOKIE
|
||||||
|
);
|
||||||
|
let mut headers = HeaderMap::new();
|
||||||
|
headers.insert(header::SET_COOKIE, cookie.parse().unwrap());
|
||||||
|
headers.insert(header::LOCATION, "/login".parse().unwrap());
|
||||||
|
(StatusCode::FOUND, headers, Body::empty()).into_response()
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Deserialize)]
|
#[derive(Deserialize)]
|
||||||
@@ -377,9 +335,9 @@ pub async fn oidc_callback(
|
|||||||
.unwrap_or(false);
|
.unwrap_or(false);
|
||||||
|
|
||||||
let session_attrs = if is_https {
|
let session_attrs = if is_https {
|
||||||
"SameSite=Lax; Secure"
|
"SameSite=Strict; Secure"
|
||||||
} else {
|
} else {
|
||||||
"SameSite=Lax"
|
"SameSite=Strict"
|
||||||
};
|
};
|
||||||
|
|
||||||
let session_cookie = format!(
|
let session_cookie = format!(
|
||||||
@@ -396,3 +354,47 @@ pub async fn oidc_callback(
|
|||||||
|
|
||||||
(StatusCode::FOUND, headers, Body::empty()).into_response()
|
(StatusCode::FOUND, headers, Body::empty()).into_response()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
const LOGIN_HTML: &str = r#"<!DOCTYPE html>
|
||||||
|
<html lang="en">
|
||||||
|
<head>
|
||||||
|
<meta charset="UTF-8">
|
||||||
|
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
||||||
|
<title>Furumi Player — Login</title>
|
||||||
|
<style>
|
||||||
|
* { box-sizing: border-box; margin: 0; padding: 0; }
|
||||||
|
body {
|
||||||
|
min-height: 100vh;
|
||||||
|
display: flex; align-items: center; justify-content: center;
|
||||||
|
background: #0d0f14;
|
||||||
|
font-family: 'Inter', system-ui, sans-serif;
|
||||||
|
color: #e2e8f0;
|
||||||
|
}
|
||||||
|
.card {
|
||||||
|
background: #161b27;
|
||||||
|
border: 1px solid #2a3347;
|
||||||
|
border-radius: 16px;
|
||||||
|
padding: 2.5rem 3rem;
|
||||||
|
width: 360px;
|
||||||
|
box-shadow: 0 20px 60px rgba(0,0,0,0.5);
|
||||||
|
text-align: center;
|
||||||
|
}
|
||||||
|
.logo { font-size: 1.8rem; font-weight: 700; color: #7c6af7; margin-bottom: 0.25rem; }
|
||||||
|
.subtitle { font-size: 0.85rem; color: #64748b; margin-bottom: 2rem; }
|
||||||
|
.btn-sso {
|
||||||
|
display: block; width: 100%; padding: 0.75rem; text-align: center;
|
||||||
|
background: #7c6af7; border: none; border-radius: 8px;
|
||||||
|
color: #fff; font-size: 0.95rem; font-weight: 600; text-decoration: none;
|
||||||
|
cursor: pointer; transition: background 0.2s;
|
||||||
|
}
|
||||||
|
.btn-sso:hover { background: #6b58e8; }
|
||||||
|
</style>
|
||||||
|
</head>
|
||||||
|
<body>
|
||||||
|
<div class="card">
|
||||||
|
<div class="logo">Furumi</div>
|
||||||
|
<div class="subtitle">Sign in to continue</div>
|
||||||
|
<a href="/auth/login" class="btn-sso">SSO Login</a>
|
||||||
|
</div>
|
||||||
|
</body>
|
||||||
|
</html>"#;
|
||||||
|
|||||||
@@ -16,6 +16,7 @@ pub struct AppState {
|
|||||||
#[allow(dead_code)]
|
#[allow(dead_code)]
|
||||||
pub storage_dir: Arc<PathBuf>,
|
pub storage_dir: Arc<PathBuf>,
|
||||||
pub oidc: Option<Arc<auth::OidcState>>,
|
pub oidc: Option<Arc<auth::OidcState>>,
|
||||||
|
pub api_key: Option<String>,
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn build_router(state: Arc<AppState>) -> Router {
|
pub fn build_router(state: Arc<AppState>) -> Router {
|
||||||
@@ -31,27 +32,37 @@ pub fn build_router(state: Arc<AppState>) -> Router {
|
|||||||
.route("/stream/:slug", get(api::stream_track))
|
.route("/stream/:slug", get(api::stream_track))
|
||||||
.route("/search", get(api::search));
|
.route("/search", get(api::search));
|
||||||
|
|
||||||
let api = Router::new()
|
let authed = Router::new()
|
||||||
|
.route("/", get(player_html))
|
||||||
.nest("/api", library);
|
.nest("/api", library);
|
||||||
|
|
||||||
let requires_auth = state.oidc.is_some();
|
let requires_auth = state.oidc.is_some();
|
||||||
|
|
||||||
let app = if requires_auth {
|
let app = if requires_auth {
|
||||||
api.route_layer(middleware::from_fn_with_state(state.clone(), auth::require_auth))
|
authed
|
||||||
|
.route_layer(middleware::from_fn_with_state(state.clone(), auth::require_auth))
|
||||||
} else {
|
} else {
|
||||||
api
|
authed
|
||||||
};
|
};
|
||||||
|
|
||||||
let cors = CorsLayer::new()
|
let cors = CorsLayer::new()
|
||||||
.allow_origin(Any)
|
.allow_origin(Any)
|
||||||
.allow_methods([Method::GET, Method::OPTIONS, Method::HEAD])
|
.allow_methods([Method::GET, Method::OPTIONS, Method::HEAD])
|
||||||
.allow_headers([header::ACCEPT, header::CONTENT_TYPE, header::AUTHORIZATION])
|
.allow_headers([header::ACCEPT, header::CONTENT_TYPE, header::HeaderName::from_static("x-api-key")])
|
||||||
.max_age(Duration::from_secs(600));
|
.max_age(Duration::from_secs(600));
|
||||||
|
|
||||||
Router::new()
|
Router::new()
|
||||||
|
.route("/login", get(auth::login_page))
|
||||||
|
.route("/logout", get(auth::logout))
|
||||||
.route("/auth/login", get(auth::oidc_login))
|
.route("/auth/login", get(auth::oidc_login))
|
||||||
.route("/auth/callback", get(auth::oidc_callback))
|
.route("/auth/callback", get(auth::oidc_callback))
|
||||||
.merge(app)
|
.merge(app)
|
||||||
.layer(cors)
|
.layer(cors)
|
||||||
.with_state(state)
|
.with_state(state)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async fn player_html() -> axum::response::Html<String> {
|
||||||
|
let html = include_str!("player.html")
|
||||||
|
.replace("<!-- VERSION_PLACEHOLDER -->", option_env!("FURUMI_VERSION").unwrap_or(env!("CARGO_PKG_VERSION")));
|
||||||
|
axum::response::Html(html)
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user