Compare commits
No commits in common. "main" and "v0.9.14" have entirely different histories.
16 changed files with 96 additions and 297 deletions
|
|
@ -31,11 +31,8 @@ jobs:
|
||||||
|
|
||||||
- name: Run goreleaser
|
- name: Run goreleaser
|
||||||
env:
|
env:
|
||||||
# Forgejo runner auto-injects GITHUB_TOKEN (a per-job, instance-scoped
|
# Forgejo runner injects GITHUB_TOKEN — but goreleaser uses it to talk to
|
||||||
# token usable against the Forgejo REST API). goreleaser only accepts
|
# the *Forgejo* API thanks to the gitea_urls override in .goreleaser.yml.
|
||||||
# one token; with both GITHUB_TOKEN + GITEA_TOKEN set it errors out
|
|
||||||
# ("multiple tokens"). Unset GITHUB_TOKEN before invoking goreleaser so
|
|
||||||
# it picks the Gitea code path + the gitea_urls block in .goreleaser.yml.
|
|
||||||
GITEA_TOKEN: ${{ secrets.GITHUB_TOKEN }}
|
GITEA_TOKEN: ${{ secrets.GITHUB_TOKEN }}
|
||||||
SENTRY_DSN: ${{ secrets.SENTRY_DSN }}
|
SENTRY_DSN: ${{ secrets.SENTRY_DSN }}
|
||||||
# Empty when RELEASE_SIGNING_PUBKEY variable is unset — goreleaser
|
# Empty when RELEASE_SIGNING_PUBKEY variable is unset — goreleaser
|
||||||
|
|
@ -44,9 +41,7 @@ jobs:
|
||||||
# RELEASE_SIGNING_PUBKEY (variable) + RELEASE_SIGNING_KEY (secret)
|
# RELEASE_SIGNING_PUBKEY (variable) + RELEASE_SIGNING_KEY (secret)
|
||||||
# to turn verification on.
|
# to turn verification on.
|
||||||
RELEASE_SIGNING_PUBKEY: ${{ vars.RELEASE_SIGNING_PUBKEY }}
|
RELEASE_SIGNING_PUBKEY: ${{ vars.RELEASE_SIGNING_PUBKEY }}
|
||||||
run: |
|
run: goreleaser release --clean
|
||||||
unset GITHUB_TOKEN
|
|
||||||
goreleaser release --clean
|
|
||||||
|
|
||||||
- name: Sign checksums.txt with ed25519
|
- name: Sign checksums.txt with ed25519
|
||||||
if: ${{ vars.RELEASE_SIGNING_PUBKEY != '' && secrets.RELEASE_SIGNING_KEY != '' }}
|
if: ${{ vars.RELEASE_SIGNING_PUBKEY != '' && secrets.RELEASE_SIGNING_KEY != '' }}
|
||||||
|
|
@ -58,7 +53,7 @@ jobs:
|
||||||
# forgejo (hostname `forgejo`), so the in-cluster hostname is fastest, but the
|
# forgejo (hostname `forgejo`), so the in-cluster hostname is fastest, but the
|
||||||
# Tailscale IP is the documented fallback.
|
# Tailscale IP is the documented fallback.
|
||||||
FORGEJO_API: http://forgejo:3000/api/v1
|
FORGEJO_API: http://forgejo:3000/api/v1
|
||||||
REPO: torrentclaw/unarr
|
REPO: deivid/unarr
|
||||||
run: |
|
run: |
|
||||||
set -euo pipefail
|
set -euo pipefail
|
||||||
go run ./scripts/sign-checksums \
|
go run ./scripts/sign-checksums \
|
||||||
|
|
|
||||||
17
.gitignore
vendored
17
.gitignore
vendored
|
|
@ -43,5 +43,18 @@ tmp/
|
||||||
config/
|
config/
|
||||||
dist-ffbinaries/
|
dist-ffbinaries/
|
||||||
|
|
||||||
# Claude Code: keep entirely local, do not track
|
# Claude Code: global ~/.gitignore excludes .claude/ by default, which hides
|
||||||
.claude/
|
# project-shared agents/commands/hooks. Override here to commit the shared
|
||||||
|
# pieces (agents, commands, hooks, settings.json). Keep per-user state local.
|
||||||
|
!.claude/
|
||||||
|
!.claude/agents/
|
||||||
|
!.claude/agents/**
|
||||||
|
!.claude/commands/
|
||||||
|
!.claude/commands/**
|
||||||
|
!.claude/hooks/
|
||||||
|
!.claude/hooks/**
|
||||||
|
!.claude/settings.json
|
||||||
|
.claude/settings.local.json
|
||||||
|
.claude/projects/
|
||||||
|
.claude/scheduled_tasks.lock
|
||||||
|
.claude/skills/
|
||||||
102
CHANGELOG.md
102
CHANGELOG.md
|
|
@ -5,63 +5,61 @@ All notable changes to this project will be documented in this file.
|
||||||
The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.1.0/),
|
The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.1.0/),
|
||||||
and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
|
and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
|
||||||
|
|
||||||
## [0.9.15] - 2026-05-27
|
## [0.9.14] - 2026-05-27
|
||||||
|
|
||||||
|
|
||||||
### Added
|
|
||||||
|
|
||||||
- **sentry**: enhance error handling by skipping user input errors in CaptureError
|
|
||||||
|
|
||||||
### Changed
|
### Changed
|
||||||
|
|
||||||
- **ci**: point Forgejo URLs at torrentclaw org (post-transfer)
|
- **VAAPI encode path now ships proper GPU surfaces**. Adds
|
||||||
- **sentry**: decouple agent import via string-match, rename predicate
|
`-vaapi_device /dev/dri/renderD128` so the encoder doesn't fall
|
||||||
|
back to a NULL device on multi-GPU hosts (the dev box that
|
||||||
|
validated this has an NVIDIA dGPU on renderD129 + an AMD iGPU on
|
||||||
|
renderD128 — without the explicit device the encoder picked the
|
||||||
|
wrong node). Filter chain switches to `format=nv12,hwupload`
|
||||||
|
(was `format=yuv420p`) so frames arrive at the encoder as VAAPI
|
||||||
|
surfaces. Color-metadata `setparams=` block is dropped on the
|
||||||
|
VAAPI path because VAAPI surfaces don't expose VUI fields the
|
||||||
|
same way libx264 does — the encoder records its own.
|
||||||
|
Intentionally avoids `scale_vaapi`: mesa 25 + AMD Raphael iGPU
|
||||||
|
emit "Cannot allocate memory" per session start, polluting logs
|
||||||
|
even though encode succeeds. CPU scale + hwupload is the safe
|
||||||
|
hybrid that works across all VAAPI-capable hosts.
|
||||||
|
- **Unit tests** lock the argv shape: TestBuildHLSFFmpegArgsVAAPI
|
||||||
|
asserts the new VAAPI flags + absence of scale_vaapi /
|
||||||
|
format=yuv420p; TestBuildHLSFFmpegArgsLibx264NoRegression
|
||||||
|
ensures the libx264 path keeps its `setparams` + `yuv420p` and
|
||||||
|
doesn't accidentally inherit the VAAPI shape.
|
||||||
|
|
||||||
### Documentation
|
|
||||||
|
|
||||||
- **positioning**: reframe unarr around download/stream/transcode, drop misleading search-first wording
|
|
||||||
|
|
||||||
### Fixed
|
|
||||||
|
|
||||||
- **ci**: unset GITHUB_TOKEN so goreleaser uses GITEA_TOKEN
|
|
||||||
- **sentry**: skip "daemon not running" stop/reload errors
|
|
||||||
|
|
||||||
### Other
|
|
||||||
|
|
||||||
- **scripts**: harden release.sh against double-release and inline version bumps
|
|
||||||
- untrack .claude/ (private local config)
|
|
||||||
## [0.9.14] - 2026-05-27
|
|
||||||
|
|
||||||
|
|
||||||
### Added
|
|
||||||
|
|
||||||
- **vaapi**: hybrid CPU-scale + hwupload encode path (QW2, 0.9.14)
|
|
||||||
|
|
||||||
### CI/CD
|
|
||||||
|
|
||||||
- port workflows from .github/ to .forgejo/ (Forgejo Actions)
|
|
||||||
|
|
||||||
### Fixed
|
|
||||||
|
|
||||||
- **daemon**: defensive IsClosed check in watchSessionReady poll loop
|
|
||||||
- **daemon**: use parent ctx for MarkSessionReady so cancel propagates
|
|
||||||
- **release**: move gitea_urls to top-level (goreleaser v2 schema)
|
|
||||||
## [0.9.13] - 2026-05-27
|
## [0.9.13] - 2026-05-27
|
||||||
|
|
||||||
|
### Added
|
||||||
|
|
||||||
|
- **Session-ready webhook** (`/api/internal/agent/session-ready`). Daemon
|
||||||
|
watches every new HLSSession's segment counter and, the moment seg-0 +
|
||||||
|
init.mp4 land on disk, POSTs the sessionId to the server. The web side
|
||||||
|
flips `streaming_session.ready_at = NOW()`, which its new SSE endpoint
|
||||||
|
pushes to subscribed players so the "Preparando…" UI flips to
|
||||||
|
"Stream listo" without waiting for the player's HEAD-probe retry loop
|
||||||
|
to discover it. Cache-HIT sessions fire the webhook immediately on
|
||||||
|
StartHLSSession return.
|
||||||
|
- `engine.HLSSession.ReadyCount()` + `FromCache()` accessors so the
|
||||||
|
ready-watcher goroutine doesn't reach into private state.
|
||||||
|
|
||||||
|
## [0.9.12] - 2026-05-27
|
||||||
|
|
||||||
### Added
|
### Added
|
||||||
|
|
||||||
- **agent**: session-ready webhook for SSE-driven player handshake (0.9.13)
|
- **transcoder diagnostic in register payload**: daemon now sends the full
|
||||||
- **agent**: send full transcoder diagnostic in register payload (0.9.12)
|
HWAccel diagnostic (ffmpeg version, resolved binary path, list of HW
|
||||||
|
encoders compiled in, list of device files / drivers present) up to the
|
||||||
|
server on register. The web "Diagnose transcoder" modal surfaces these
|
||||||
|
so a user stuck on software libx264 can see *why* (e.g. ffmpeg shipped
|
||||||
|
without `--enable-nvenc`, or `/dev/nvidia0` missing inside a container)
|
||||||
|
without SSHing into their machine + running `unarr probe-hwaccel`.
|
||||||
|
- **`[transcode]` startup log line**: daemon prints a single one-line
|
||||||
|
summary of the picked backend + version + binary path + devices at
|
||||||
|
start. Same data the web shows; convenient for `journalctl --user -u
|
||||||
|
unarr | grep transcode`.
|
||||||
|
|
||||||
### Fixed
|
|
||||||
|
|
||||||
- **daemon**: defer probeCancel so a panic mid-diagnostic still releases ctx
|
|
||||||
|
|
||||||
### Other
|
|
||||||
|
|
||||||
- **release**: add ship.sh end-to-end pipeline as GH Actions backup
|
|
||||||
- **skills**: add /publish slash command + allow .claude/ in git
|
|
||||||
## [0.9.11] - 2026-05-27
|
## [0.9.11] - 2026-05-27
|
||||||
|
|
||||||
|
|
||||||
|
|
@ -79,10 +77,6 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
|
||||||
- **cors**: allow play from .to / staging / onion mirrors
|
- **cors**: allow play from .to / staging / onion mirrors
|
||||||
- **library**: classify resolution by width + height, not height alone
|
- **library**: classify resolution by width + height, not height alone
|
||||||
- **transcode**: make preset libx264-only + restore quality opt-in
|
- **transcode**: make preset libx264-only + restore quality opt-in
|
||||||
|
|
||||||
### Other
|
|
||||||
|
|
||||||
- **release**: 0.9.11
|
|
||||||
## [0.9.8] - 2026-05-27
|
## [0.9.8] - 2026-05-27
|
||||||
|
|
||||||
|
|
||||||
|
|
@ -545,9 +539,9 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
|
||||||
### Build
|
### Build
|
||||||
|
|
||||||
- add -s -w -trimpath to Makefile, add build-small target with UPX
|
- add -s -w -trimpath to Makefile, add build-small target with UPX
|
||||||
[0.9.15]: https://github.com/torrentclaw/unarr/compare/v0.9.14...v0.9.15
|
[0.9.11]: https://github.com/torrentclaw/unarr/compare/v0.9.8...v0.9.11
|
||||||
[0.9.14]: https://github.com/torrentclaw/unarr/compare/v0.9.13...v0.9.14
|
[0.9.8]: https://github.com/torrentclaw/unarr/compare/v0.9.7...v0.9.8
|
||||||
[0.9.13]: https://github.com/torrentclaw/unarr/compare/v0.9.11...v0.9.13
|
[0.9.12]: https://github.com/torrentclaw/unarr/compare/v0.9.11...v0.9.12
|
||||||
[0.9.11]: https://github.com/torrentclaw/unarr/compare/v0.9.8...v0.9.11
|
[0.9.11]: https://github.com/torrentclaw/unarr/compare/v0.9.8...v0.9.11
|
||||||
[0.9.8]: https://github.com/torrentclaw/unarr/compare/v0.9.7...v0.9.8
|
[0.9.8]: https://github.com/torrentclaw/unarr/compare/v0.9.7...v0.9.8
|
||||||
[0.9.7]: https://github.com/torrentclaw/unarr/compare/v0.9.6...v0.9.7
|
[0.9.7]: https://github.com/torrentclaw/unarr/compare/v0.9.6...v0.9.7
|
||||||
|
|
|
||||||
|
|
@ -1,9 +1,8 @@
|
||||||
# unarr
|
# unarr
|
||||||
|
|
||||||
**The single binary that replaces your whole *arr stack.** Built-in torrent,
|
**The single binary that replaces your whole *arr stack.** Search 30+ torrent
|
||||||
debrid, and usenet engines. Stream, transcode, and organize your library from
|
sources, inspect real quality before you download, grab subtitles, and manage
|
||||||
one terminal — or run it as a headless daemon with a web dashboard, WireGuard
|
your media library — all from one terminal tool or a headless daemon.
|
||||||
split-tunnel, and Cloudflare Funnel remote access.
|
|
||||||
|
|
||||||
**[Website & docs](https://torrentclaw.com/unarr)** · **[Install guide](https://torrentclaw.com/cli)** · **[Get an API key](https://torrentclaw.com)**
|
**[Website & docs](https://torrentclaw.com/unarr)** · **[Install guide](https://torrentclaw.com/cli)** · **[Get an API key](https://torrentclaw.com)**
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -11,9 +11,9 @@
|
||||||
[](LICENSE)
|
[](LICENSE)
|
||||||
[](go.mod)
|
[](go.mod)
|
||||||
|
|
||||||
The single-binary terminal client for torrent, debrid, and usenet downloads. **Free and open source.**
|
Powerful terminal tool for torrent search and management. **Free and open source.**
|
||||||
|
|
||||||
Built-in torrent engine, debrid (Real-Debrid / AllDebrid), and NZB support. Stream to mpv/vlc, transcode on the fly with hardware acceleration, and manage your library — one binary or a headless daemon with WireGuard split-tunnel and Cloudflare Funnel remote access.
|
Search 30+ torrent sources, inspect torrent quality, discover popular content, find streaming providers, and manage your media collection — all from your terminal.
|
||||||
|
|
||||||
<!-- GIF demo placeholder -->
|
<!-- GIF demo placeholder -->
|
||||||
<!--  -->
|
<!--  -->
|
||||||
|
|
|
||||||
|
|
@ -2,8 +2,6 @@ package agent
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"errors"
|
|
||||||
"fmt"
|
|
||||||
"os"
|
"os"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
"time"
|
"time"
|
||||||
|
|
@ -11,13 +9,6 @@ import (
|
||||||
"github.com/torrentclaw/unarr/internal/config"
|
"github.com/torrentclaw/unarr/internal/config"
|
||||||
)
|
)
|
||||||
|
|
||||||
// ErrDaemonNotRunning is returned when no daemon state file exists on disk.
|
|
||||||
// Callers may wrap it with %w; downstream code uses errors.Is to detect it.
|
|
||||||
// NOTE: the message text is matched by the sentry package (string-match, to
|
|
||||||
// avoid an import cycle). Keep the prefix "daemon does not appear to be
|
|
||||||
// running" stable, or update sentry.daemonNotRunningMarker accordingly.
|
|
||||||
var ErrDaemonNotRunning = errors.New("daemon does not appear to be running (state file not found)")
|
|
||||||
|
|
||||||
// DaemonState is written to disk every heartbeat for external tools to read.
|
// DaemonState is written to disk every heartbeat for external tools to read.
|
||||||
type DaemonState struct {
|
type DaemonState struct {
|
||||||
AgentID string `json:"agentId"`
|
AgentID string `json:"agentId"`
|
||||||
|
|
@ -78,31 +69,17 @@ func WriteState(state *DaemonState) {
|
||||||
os.Rename(tmp, path)
|
os.Rename(tmp, path)
|
||||||
}
|
}
|
||||||
|
|
||||||
// ReadState reads the daemon state from disk. Returns nil if not found or
|
// ReadState reads the daemon state from disk. Returns nil if not found.
|
||||||
// unreadable. Use LoadState when callers need to distinguish "not running"
|
|
||||||
// from "state file corrupted".
|
|
||||||
func ReadState() *DaemonState {
|
func ReadState() *DaemonState {
|
||||||
state, _ := LoadState()
|
|
||||||
return state
|
|
||||||
}
|
|
||||||
|
|
||||||
// LoadState reads the daemon state and returns explicit errors:
|
|
||||||
// - ErrDaemonNotRunning when the state file does not exist
|
|
||||||
// - a wrapped json error when the file exists but cannot be decoded
|
|
||||||
// (a real bug worth reporting to Sentry)
|
|
||||||
func LoadState() (*DaemonState, error) {
|
|
||||||
data, err := os.ReadFile(StateFilePath())
|
data, err := os.ReadFile(StateFilePath())
|
||||||
if err != nil {
|
if err != nil {
|
||||||
if errors.Is(err, os.ErrNotExist) {
|
return nil
|
||||||
return nil, ErrDaemonNotRunning
|
|
||||||
}
|
|
||||||
return nil, err
|
|
||||||
}
|
}
|
||||||
var state DaemonState
|
var state DaemonState
|
||||||
if err := json.Unmarshal(data, &state); err != nil {
|
if json.Unmarshal(data, &state) != nil {
|
||||||
return nil, fmt.Errorf("decode daemon state %s: %w", StateFilePath(), err)
|
return nil
|
||||||
}
|
}
|
||||||
return &state, nil
|
return &state
|
||||||
}
|
}
|
||||||
|
|
||||||
// RemoveState deletes the state file (called on clean shutdown).
|
// RemoveState deletes the state file (called on clean shutdown).
|
||||||
|
|
|
||||||
|
|
@ -1,7 +1,6 @@
|
||||||
package agent
|
package agent
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"errors"
|
|
||||||
"os"
|
"os"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
@ -105,39 +104,3 @@ func TestReadStateCorruptedJSON(t *testing.T) {
|
||||||
t.Errorf("ReadState() should return nil for corrupted JSON, got %+v", state)
|
t.Errorf("ReadState() should return nil for corrupted JSON, got %+v", state)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestLoadStateNotFound(t *testing.T) {
|
|
||||||
tmpDir := t.TempDir()
|
|
||||||
origFn := stateFilePathFn
|
|
||||||
stateFilePathFn = func() string { return filepath.Join(tmpDir, "nonexistent.json") }
|
|
||||||
defer func() { stateFilePathFn = origFn }()
|
|
||||||
|
|
||||||
state, err := LoadState()
|
|
||||||
if state != nil {
|
|
||||||
t.Errorf("LoadState() state = %+v, want nil", state)
|
|
||||||
}
|
|
||||||
if !errors.Is(err, ErrDaemonNotRunning) {
|
|
||||||
t.Errorf("LoadState() err = %v, want ErrDaemonNotRunning", err)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestLoadStateCorruptedJSON(t *testing.T) {
|
|
||||||
tmpDir := t.TempDir()
|
|
||||||
origFn := stateFilePathFn
|
|
||||||
path := filepath.Join(tmpDir, "daemon.state.json")
|
|
||||||
stateFilePathFn = func() string { return path }
|
|
||||||
defer func() { stateFilePathFn = origFn }()
|
|
||||||
|
|
||||||
os.WriteFile(path, []byte("not valid json{{{"), 0o644)
|
|
||||||
|
|
||||||
state, err := LoadState()
|
|
||||||
if state != nil {
|
|
||||||
t.Errorf("LoadState() state = %+v, want nil", state)
|
|
||||||
}
|
|
||||||
if err == nil {
|
|
||||||
t.Fatal("LoadState() err = nil, want decode error")
|
|
||||||
}
|
|
||||||
if errors.Is(err, ErrDaemonNotRunning) {
|
|
||||||
t.Error("corrupt state must not be reported as ErrDaemonNotRunning — it would be filtered from Sentry")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
|
||||||
|
|
@ -1,7 +1,6 @@
|
||||||
package cmd
|
package cmd
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"errors"
|
|
||||||
"fmt"
|
"fmt"
|
||||||
"os"
|
"os"
|
||||||
"os/exec"
|
"os/exec"
|
||||||
|
|
@ -263,12 +262,9 @@ func runDaemonReload() error {
|
||||||
// stopDaemonByPID reads the state file and sends a graceful stop to the daemon PID.
|
// stopDaemonByPID reads the state file and sends a graceful stop to the daemon PID.
|
||||||
// Used as fallback on platforms without a service manager (and as Windows implementation).
|
// Used as fallback on platforms without a service manager (and as Windows implementation).
|
||||||
func stopDaemonByPID() error {
|
func stopDaemonByPID() error {
|
||||||
state, err := agent.LoadState()
|
state := agent.ReadState()
|
||||||
if err != nil {
|
if state == nil {
|
||||||
if errors.Is(err, agent.ErrDaemonNotRunning) {
|
return fmt.Errorf("daemon does not appear to be running (state file not found)")
|
||||||
return err
|
|
||||||
}
|
|
||||||
return fmt.Errorf("read daemon state: %w", err)
|
|
||||||
}
|
}
|
||||||
return killPID(state.PID)
|
return killPID(state.PID)
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -3,7 +3,6 @@
|
||||||
package cmd
|
package cmd
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"errors"
|
|
||||||
"fmt"
|
"fmt"
|
||||||
"log"
|
"log"
|
||||||
"os"
|
"os"
|
||||||
|
|
@ -44,12 +43,9 @@ func startReloadWatcher(rc *ReloadableConfig) {
|
||||||
|
|
||||||
// sendReloadSignal sends SIGUSR1 to the running daemon process.
|
// sendReloadSignal sends SIGUSR1 to the running daemon process.
|
||||||
func sendReloadSignal() error {
|
func sendReloadSignal() error {
|
||||||
state, err := agent.LoadState()
|
state := agent.ReadState()
|
||||||
if err != nil {
|
if state == nil {
|
||||||
if errors.Is(err, agent.ErrDaemonNotRunning) {
|
return fmt.Errorf("daemon does not appear to be running (state file not found)")
|
||||||
return err
|
|
||||||
}
|
|
||||||
return fmt.Errorf("read daemon state: %w", err)
|
|
||||||
}
|
}
|
||||||
p, err := os.FindProcess(state.PID)
|
p, err := os.FindProcess(state.PID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|
|
||||||
|
|
@ -25,20 +25,16 @@ var (
|
||||||
|
|
||||||
func init() {
|
func init() {
|
||||||
rootCmd = &cobra.Command{
|
rootCmd = &cobra.Command{
|
||||||
Use: "unarr",
|
Use: "unarr",
|
||||||
Version: Version,
|
Short: "unarr — torrent search and management",
|
||||||
Short: "Terminal torrent + debrid + usenet client — download, stream, transcode",
|
Long: `unarr is a powerful terminal tool for torrent search and management.
|
||||||
Long: `unarr is a terminal-native client that downloads torrents, debrid links,
|
|
||||||
and usenet (NZB) — all from the same binary. It streams content straight
|
Search 30+ torrent sources, inspect torrent quality, discover popular content,
|
||||||
to mpv/vlc with sequential piece prioritization, transcodes on the fly via
|
find streaming providers, and manage your media collection — all from your terminal.
|
||||||
ffmpeg with hardware acceleration (NVENC, QSV, VA-API, VideoToolbox), and
|
|
||||||
organizes your library into Movies/TV folders. Run it one-shot or as a
|
|
||||||
long-running daemon with a built-in WireGuard split-tunnel and remote
|
|
||||||
playback over Cloudflare Funnel.
|
|
||||||
|
|
||||||
Get started:
|
Get started:
|
||||||
unarr init First-time configuration wizard
|
unarr init First-time configuration wizard
|
||||||
unarr download <magnet|hash> Grab a torrent one-shot
|
unarr search "breaking bad" Search for content
|
||||||
unarr start Start the download daemon
|
unarr start Start the download daemon
|
||||||
|
|
||||||
Documentation: https://torrentclaw.com/cli
|
Documentation: https://torrentclaw.com/cli
|
||||||
|
|
@ -59,7 +55,7 @@ Source: https://github.com/torrentclaw/unarr`,
|
||||||
// Command groups for organized help output
|
// Command groups for organized help output
|
||||||
rootCmd.AddGroup(
|
rootCmd.AddGroup(
|
||||||
&cobra.Group{ID: "start", Title: "Getting Started:"},
|
&cobra.Group{ID: "start", Title: "Getting Started:"},
|
||||||
&cobra.Group{ID: "search", Title: "Catalog & Discovery:"},
|
&cobra.Group{ID: "search", Title: "Search & Discovery:"},
|
||||||
&cobra.Group{ID: "download", Title: "Downloads & Streaming:"},
|
&cobra.Group{ID: "download", Title: "Downloads & Streaming:"},
|
||||||
&cobra.Group{ID: "daemon", Title: "Daemon Management:"},
|
&cobra.Group{ID: "daemon", Title: "Daemon Management:"},
|
||||||
&cobra.Group{ID: "system", Title: "System & Diagnostics:"},
|
&cobra.Group{ID: "system", Title: "System & Diagnostics:"},
|
||||||
|
|
|
||||||
|
|
@ -1,4 +1,4 @@
|
||||||
package cmd
|
package cmd
|
||||||
|
|
||||||
// Version is the CLI version. Overridden by goreleaser ldflags at release time.
|
// Version is the CLI version. Overridden by goreleaser ldflags at release time.
|
||||||
var Version = "0.9.15"
|
var Version = "0.9.14"
|
||||||
|
|
|
||||||
|
|
@ -67,31 +67,3 @@ func TestBuildHLSFFmpegArgsLibx264NoRegression(t *testing.T) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// TestBuildHLSFFmpegArgsVAAPIDump prints the full argv buildHLSFFmpegArgsAt
|
|
||||||
// emits for a typical VAAPI session. Mimics the daemon spawn step so the
|
|
||||||
// operator can verify the ffmpeg command-line shape without booting the
|
|
||||||
// stack — equivalent to `journalctl --user -u unarr-dev | grep ffmpeg`
|
|
||||||
// but without waiting for a real player session.
|
|
||||||
func TestBuildHLSFFmpegArgsVAAPIDump(t *testing.T) {
|
|
||||||
cfg := HLSSessionConfig{
|
|
||||||
SessionID: "vaapi-smoke",
|
|
||||||
SourcePath: "/mnt/nas/peliculas/sample.mkv",
|
|
||||||
Quality: "720p",
|
|
||||||
AudioIndex: -1,
|
|
||||||
Transcode: TranscodeRuntime{
|
|
||||||
FFmpegPath: "/usr/bin/ffmpeg",
|
|
||||||
FFprobePath: "/usr/bin/ffprobe",
|
|
||||||
HWAccel: HWAccelVAAPI,
|
|
||||||
},
|
|
||||||
}
|
|
||||||
probe := &StreamProbe{
|
|
||||||
VideoCodec: "hevc",
|
|
||||||
Width: 3840,
|
|
||||||
Height: 2160,
|
|
||||||
DurationSec: 5400,
|
|
||||||
AudioTracks: []ProbeAudioTrack{{Index: 0, Lang: "en", Codec: "ac3"}},
|
|
||||||
}
|
|
||||||
args := buildHLSFFmpegArgsAt(cfg, probe, "/tmp/smoke-tmpdir", 0, 0)
|
|
||||||
t.Logf("ffmpeg %s", strings.Join(args, " "))
|
|
||||||
}
|
|
||||||
|
|
|
||||||
|
|
@ -1,14 +1,12 @@
|
||||||
package sentry
|
package sentry
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"errors"
|
|
||||||
"os"
|
"os"
|
||||||
"runtime"
|
"runtime"
|
||||||
"strings"
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
gosentry "github.com/getsentry/sentry-go"
|
gosentry "github.com/getsentry/sentry-go"
|
||||||
"github.com/spf13/pflag"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
// dsn is injected at build time via ldflags. If empty, Sentry is disabled.
|
// dsn is injected at build time via ldflags. If empty, Sentry is disabled.
|
||||||
|
|
@ -46,16 +44,9 @@ func Close() {
|
||||||
gosentry.Flush(flushTimeout)
|
gosentry.Flush(flushTimeout)
|
||||||
}
|
}
|
||||||
|
|
||||||
// daemonNotRunningMarker matches the message of agent.ErrDaemonNotRunning
|
|
||||||
// without importing the agent package — avoids a sentry → agent dependency
|
|
||||||
// that would risk a cycle if agent ever needed to report errors itself.
|
|
||||||
const daemonNotRunningMarker = "daemon does not appear to be running"
|
|
||||||
|
|
||||||
// CaptureError sends a non-fatal error to Sentry with optional command context.
|
// CaptureError sends a non-fatal error to Sentry with optional command context.
|
||||||
// Expected non-bug errors (bad CLI input, daemon not running) are skipped to
|
|
||||||
// keep the issue feed signal-heavy.
|
|
||||||
func CaptureError(err error, command string) {
|
func CaptureError(err error, command string) {
|
||||||
if err == nil || shouldSkipSentry(err) {
|
if err == nil {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -67,21 +58,6 @@ func CaptureError(err error, command string) {
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
func shouldSkipSentry(err error) bool {
|
|
||||||
var notExist *pflag.NotExistError
|
|
||||||
var valueReq *pflag.ValueRequiredError
|
|
||||||
var invalidVal *pflag.InvalidValueError
|
|
||||||
var invalidSyn *pflag.InvalidSyntaxError
|
|
||||||
if errors.As(err, ¬Exist) || errors.As(err, &valueReq) ||
|
|
||||||
errors.As(err, &invalidVal) || errors.As(err, &invalidSyn) {
|
|
||||||
return true
|
|
||||||
}
|
|
||||||
msg := err.Error()
|
|
||||||
return strings.HasPrefix(msg, "unknown command ") ||
|
|
||||||
strings.HasPrefix(msg, "required flag(s)") ||
|
|
||||||
strings.Contains(msg, daemonNotRunningMarker)
|
|
||||||
}
|
|
||||||
|
|
||||||
// RecoverPanic captures a panic and re-panics after reporting.
|
// RecoverPanic captures a panic and re-panics after reporting.
|
||||||
// Usage: defer sentry.RecoverPanic()
|
// Usage: defer sentry.RecoverPanic()
|
||||||
func RecoverPanic() {
|
func RecoverPanic() {
|
||||||
|
|
|
||||||
|
|
@ -1,10 +1,6 @@
|
||||||
package sentry
|
package sentry
|
||||||
|
|
||||||
import (
|
import "testing"
|
||||||
"errors"
|
|
||||||
"fmt"
|
|
||||||
"testing"
|
|
||||||
)
|
|
||||||
|
|
||||||
func TestEnvironment(t *testing.T) {
|
func TestEnvironment(t *testing.T) {
|
||||||
tests := []struct {
|
tests := []struct {
|
||||||
|
|
@ -49,16 +45,3 @@ func TestSetUser(t *testing.T) {
|
||||||
// Should not panic without initialization
|
// Should not panic without initialization
|
||||||
SetUser("agent-123")
|
SetUser("agent-123")
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestShouldSkipSentryDaemonNotRunning(t *testing.T) {
|
|
||||||
// String must stay in sync with agent.ErrDaemonNotRunning. If that sentinel
|
|
||||||
// is reworded, this test fails loudly so the marker can be updated.
|
|
||||||
err := errors.New("daemon does not appear to be running (state file not found)")
|
|
||||||
if !shouldSkipSentry(err) {
|
|
||||||
t.Error("ErrDaemonNotRunning message should be skipped")
|
|
||||||
}
|
|
||||||
wrapped := fmt.Errorf("read daemon state: %w", err)
|
|
||||||
if !shouldSkipSentry(wrapped) {
|
|
||||||
t.Error("wrapped ErrDaemonNotRunning message should be skipped")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
|
||||||
|
|
@ -55,17 +55,6 @@ fi
|
||||||
CURRENT_BRANCH=$(git branch --show-current)
|
CURRENT_BRANCH=$(git branch --show-current)
|
||||||
[ "$CURRENT_BRANCH" = "main" ] || warn "Not on main branch (current: $CURRENT_BRANCH)"
|
[ "$CURRENT_BRANCH" = "main" ] || warn "Not on main branch (current: $CURRENT_BRANCH)"
|
||||||
|
|
||||||
HEAD_SUBJECT=$(git log -1 --pretty=%s)
|
|
||||||
if [[ "$HEAD_SUBJECT" =~ \(([0-9]+\.[0-9]+\.[0-9]+)\) ]]; then
|
|
||||||
die "HEAD commit subject contains inline version bump: \"$HEAD_SUBJECT\"
|
|
||||||
Release contract: version bumps MUST live in a dedicated 'chore(release): X.Y.Z' commit.
|
|
||||||
Revert the inline bump and re-run this script — it will create the proper commit."
|
|
||||||
fi
|
|
||||||
if [[ "$HEAD_SUBJECT" =~ ^chore\(release\): ]]; then
|
|
||||||
die "HEAD is already a chore(release) commit: \"$HEAD_SUBJECT\"
|
|
||||||
Nothing new to release. Add commits since the last release or amend intentionally outside this script."
|
|
||||||
fi
|
|
||||||
|
|
||||||
# ── Resolve version ────────────────────────────────────────────────
|
# ── Resolve version ────────────────────────────────────────────────
|
||||||
LATEST_TAG=$(git describe --tags --abbrev=0 2>/dev/null || echo "v0.0.0")
|
LATEST_TAG=$(git describe --tags --abbrev=0 2>/dev/null || echo "v0.0.0")
|
||||||
LATEST_VERSION="${LATEST_TAG#v}"
|
LATEST_VERSION="${LATEST_TAG#v}"
|
||||||
|
|
|
||||||
|
|
@ -17,8 +17,7 @@
|
||||||
# 3. Rsync to Hetzner via web/scripts/publish-cli-release.sh
|
# 3. Rsync to Hetzner via web/scripts/publish-cli-release.sh
|
||||||
# 4. Multi-arch Docker build + push (amd64 + arm64) to Docker Hub
|
# 4. Multi-arch Docker build + push (amd64 + arm64) to Docker Hub
|
||||||
# 5. Smoke checks (torrentclaw.com/version + docker run image version)
|
# 5. Smoke checks (torrentclaw.com/version + docker run image version)
|
||||||
# 6. Prune Forgejo releases older than FORGEJO_PRUNE_DAYS (default 90)
|
# 6. Optional `git push --follow-tags`
|
||||||
# 7. Optional `git push --follow-tags`
|
|
||||||
#
|
#
|
||||||
# Usage:
|
# Usage:
|
||||||
# scripts/ship.sh Detect version from internal/cmd/version.go
|
# scripts/ship.sh Detect version from internal/cmd/version.go
|
||||||
|
|
@ -34,10 +33,6 @@
|
||||||
# SKIP_DOCKER=1 skip Docker build/push
|
# SKIP_DOCKER=1 skip Docker build/push
|
||||||
# SKIP_HETZNER=1 skip Hetzner publish
|
# SKIP_HETZNER=1 skip Hetzner publish
|
||||||
# SKIP_SMOKE=1 skip smoke checks
|
# SKIP_SMOKE=1 skip smoke checks
|
||||||
# SKIP_FORGEJO_PRUNE=1 skip Forgejo retention prune
|
|
||||||
# FORGEJO_TOKEN PAT with write:repository for prune (no token = skip + warn)
|
|
||||||
# FORGEJO_PRUNE_DAYS retention window, default 90 days
|
|
||||||
# FORGEJO_REPO default torrentclaw/unarr
|
|
||||||
#
|
#
|
||||||
set -euo pipefail
|
set -euo pipefail
|
||||||
|
|
||||||
|
|
@ -49,10 +44,6 @@ PUBLISH_SCRIPT="${PUBLISH_SCRIPT:-$REPO_DIR/../torrentclaw-web/scripts/publish-c
|
||||||
SKIP_DOCKER="${SKIP_DOCKER:-0}"
|
SKIP_DOCKER="${SKIP_DOCKER:-0}"
|
||||||
SKIP_HETZNER="${SKIP_HETZNER:-0}"
|
SKIP_HETZNER="${SKIP_HETZNER:-0}"
|
||||||
SKIP_SMOKE="${SKIP_SMOKE:-0}"
|
SKIP_SMOKE="${SKIP_SMOKE:-0}"
|
||||||
SKIP_FORGEJO_PRUNE="${SKIP_FORGEJO_PRUNE:-0}"
|
|
||||||
FORGEJO_PRUNE_DAYS="${FORGEJO_PRUNE_DAYS:-90}"
|
|
||||||
FORGEJO_REPO="${FORGEJO_REPO:-torrentclaw/unarr}"
|
|
||||||
FORGEJO_BASE="${FORGEJO_BASE:-https://git.torrentclaw.com}"
|
|
||||||
|
|
||||||
DRY_RUN=false
|
DRY_RUN=false
|
||||||
PUSH_TAG=false
|
PUSH_TAG=false
|
||||||
|
|
@ -170,48 +161,7 @@ if [ "$SKIP_SMOKE" != "1" ]; then
|
||||||
fi
|
fi
|
||||||
fi
|
fi
|
||||||
|
|
||||||
# 6. Forgejo retention prune
|
# 5. Optional push
|
||||||
if [ "$SKIP_FORGEJO_PRUNE" != "1" ]; then
|
|
||||||
if [ -z "${FORGEJO_TOKEN:-}" ]; then
|
|
||||||
warn "FORGEJO_TOKEN not set — skipping Forgejo prune (set it to enable >${FORGEJO_PRUNE_DAYS}-day cleanup)"
|
|
||||||
else
|
|
||||||
info "pruning Forgejo releases older than $FORGEJO_PRUNE_DAYS days"
|
|
||||||
FORGEJO_API="$FORGEJO_BASE/api/v1/repos/$FORGEJO_REPO/releases"
|
|
||||||
RELEASES_JSON="$(curl -fsSL -H "Authorization: token $FORGEJO_TOKEN" "$FORGEJO_API?limit=50" || echo '[]')"
|
|
||||||
PRUNE_IDS="$(echo "$RELEASES_JSON" | python3 -c "
|
|
||||||
import json, sys
|
|
||||||
from datetime import datetime, timedelta, timezone
|
|
||||||
days = int('${FORGEJO_PRUNE_DAYS}')
|
|
||||||
cutoff = datetime.now(timezone.utc) - timedelta(days=days)
|
|
||||||
for r in json.load(sys.stdin):
|
|
||||||
created = datetime.fromisoformat(r['created_at'].replace('Z', '+00:00'))
|
|
||||||
if created < cutoff:
|
|
||||||
print(f\"{r['id']}\t{r['tag_name']}\t{r['created_at']}\")
|
|
||||||
" 2>/dev/null || true)"
|
|
||||||
DELETED=0
|
|
||||||
FAILED=0
|
|
||||||
if [ -n "$PRUNE_IDS" ]; then
|
|
||||||
while IFS=$'\t' read -r REL_ID REL_TAG REL_CREATED; do
|
|
||||||
[ -z "$REL_ID" ] && continue
|
|
||||||
CODE="$(curl -s -o /dev/null -w '%{http_code}' -X DELETE -H "Authorization: token $FORGEJO_TOKEN" "$FORGEJO_API/$REL_ID")"
|
|
||||||
if [ "$CODE" = "204" ]; then
|
|
||||||
echo " deleted $REL_TAG (created $REL_CREATED)"
|
|
||||||
DELETED=$((DELETED + 1))
|
|
||||||
else
|
|
||||||
warn " failed to delete $REL_TAG (id=$REL_ID, http=$CODE)"
|
|
||||||
FAILED=$((FAILED + 1))
|
|
||||||
fi
|
|
||||||
done <<< "$PRUNE_IDS"
|
|
||||||
fi
|
|
||||||
if [ "$FAILED" -gt 0 ]; then
|
|
||||||
warn "Forgejo prune: $DELETED removed, $FAILED failed"
|
|
||||||
else
|
|
||||||
ok "Forgejo prune: $DELETED release(s) removed (>${FORGEJO_PRUNE_DAYS} days old)"
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
|
|
||||||
# 7. Optional push
|
|
||||||
if [ "$PUSH_TAG" = true ]; then
|
if [ "$PUSH_TAG" = true ]; then
|
||||||
info "git push origin main --follow-tags"
|
info "git push origin main --follow-tags"
|
||||||
git push origin main --follow-tags
|
git push origin main --follow-tags
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue