-
stalkarr
+
sleeparr
{version &&
{version.current}}
{version?.hasUpdate && (
diff --git a/frontend/src/components/Layout.tsx b/frontend/src/components/Layout.tsx
index 33efe25..9760beb 100644
--- a/frontend/src/components/Layout.tsx
+++ b/frontend/src/components/Layout.tsx
@@ -42,7 +42,7 @@ export default function Layout() {
- stalkarr
+ sleeparr
diff --git a/frontend/src/pages/DashboardPage.tsx b/frontend/src/pages/DashboardPage.tsx
index 6510198..eee132c 100644
--- a/frontend/src/pages/DashboardPage.tsx
+++ b/frontend/src/pages/DashboardPage.tsx
@@ -10,17 +10,17 @@ import type { InstanceSummary } from "@/types";
export default function DashboardPage() {
const [sonarr, setSonarr] = useState
([]);
const [loading, setLoading] = useState(true);
- const [stalksToday, setStalksToday] = useState(0);
+ const [runsToday, setRunsToday] = useState(0);
useEffect(() => {
api
.get("/api/dashboard")
.then((res) => {
setSonarr(res.data.sonarr);
- setStalksToday(res.data.stalksToday);
+ setRunsToday(res.data.runsToday);
})
.finally(() => setLoading(false));
- }, [setStalksToday]);
+ }, [setRunsToday]);
const totalMissing = sonarr.reduce(
(acc, s) => acc + (s.missingCount ?? 0),
@@ -44,8 +44,8 @@ export default function DashboardPage() {
},
{ label: "Missing Movies", value: "—" },
{
- label: "Stalks Today",
- value: loading ? "—" : stalksToday.toString(),
+ label: "Runs Today",
+ value: loading ? "—" : runsToday.toString(),
},
{ label: "Found Today", value: "0" },
].map(({ label, value }) => (
@@ -117,11 +117,11 @@ export default function DashboardPage() {
- Last stalk
+ Last run
- {inst.lastStalk
- ? new Date(inst.lastStalk).toLocaleTimeString([], {
+ {inst.lastRun
+ ? new Date(inst.lastRun).toLocaleTimeString([], {
hour: "2-digit",
minute: "2-digit",
})
diff --git a/frontend/src/pages/LoginPage.tsx b/frontend/src/pages/LoginPage.tsx
index ea14802..efff277 100644
--- a/frontend/src/pages/LoginPage.tsx
+++ b/frontend/src/pages/LoginPage.tsx
@@ -41,7 +41,7 @@ export default function LoginPage() {
- stalkarr
+ sleeparr
Sign in to your instance
diff --git a/frontend/src/pages/SettingsPage.tsx b/frontend/src/pages/SettingsPage.tsx
index 86e9aff..31d38d1 100644
--- a/frontend/src/pages/SettingsPage.tsx
+++ b/frontend/src/pages/SettingsPage.tsx
@@ -204,14 +204,14 @@ export default function SettingsPage() {
const [confirmPassword, setConfirmPassword] = useState("");
const [passwordSaving, setPasswordSaving] = useState(false);
const [passwordError, setPasswordError] = useState(null);
- const [stalk, setStalk] = useState({
+ const [agent, setAgent] = useState({
enabled: false,
intervalMinutes: 60,
episodesPerRun: 10,
cooldownHours: 24,
});
- const [stalkSaving, setStalkSaving] = useState(false);
- const [stalkSaved, setStalkSaved] = useState(false);
+ const [runSaving, setRunSaving] = useState(false);
+ const [runSaved, setRunSaved] = useState(false);
const navigate = useNavigate();
@@ -248,7 +248,7 @@ export default function SettingsPage() {
useEffect(() => {
api.get("/api/settings").then((res) => setInstances(res.data.sonarr));
- api.get("/api/settings/stalk").then((res) => setStalk(res.data));
+ api.get("/api/settings/agent").then((res) => setAgent(res.data));
}, []);
async function addInstance(data: {
@@ -275,16 +275,16 @@ export default function SettingsPage() {
setInstances((prev) => prev.filter((i) => i.id !== id));
}
- async function saveStalkSettings() {
- setStalkSaving(true);
- setStalkSaved(false);
+ async function saveRunSettings() {
+ setRunSaving(true);
+ setRunSaved(false);
try {
- const res = await api.post("/api/settings/stalk", stalk);
- setStalk(res.data);
- setStalkSaved(true);
- setTimeout(() => setStalkSaved(false), 3000);
+ const res = await api.post("/api/settings/agent", agent);
+ setAgent(res.data);
+ setRunSaved(true);
+ setTimeout(() => setRunSaved(false), 3000);
} finally {
- setStalkSaving(false);
+ setRunSaving(false);
}
}
@@ -365,17 +365,17 @@ export default function SettingsPage() {
- Auto Stalker
+ Auto Agent
- setStalk((prev) => ({ ...prev, enabled: checked }))
+ setAgent((prev) => ({ ...prev, enabled: checked }))
}
/>
- Automatically stalk missing episodes on a schedule
+ Automatically hunt missing episodes on a schedule
@@ -385,14 +385,14 @@ export default function SettingsPage() {
- setStalk((prev) => ({
+ setAgent((prev) => ({
...prev,
intervalMinutes: Number(e.target.value),
}))
}
- disabled={!stalk.enabled}
+ disabled={!agent.enabled}
/>
@@ -400,14 +400,14 @@ export default function SettingsPage() {
- setStalk((prev) => ({
+ setAgent((prev) => ({
...prev,
episodesPerRun: Number(e.target.value),
}))
}
- disabled={!stalk.enabled}
+ disabled={!agent.enabled}
/>
@@ -415,31 +415,27 @@ export default function SettingsPage() {
- setStalk((prev) => ({
+ setAgent((prev) => ({
...prev,
cooldownHours: Number(e.target.value),
}))
}
- disabled={!stalk.enabled}
+ disabled={!agent.enabled}
/>
{[
- { label: "Total Stalks", value: "0", icon: BarChart2 },
+ { label: "Total Runs", value: "0", icon: BarChart2 },
{ label: "Episodes Found", value: "0", icon: CheckCircle2 },
{ label: "Success Rate", value: "—", icon: TrendingUp },
- { label: "Avg Stalk Time", value: "—", icon: Clock },
+ { label: "Avg Run Time", value: "—", icon: Clock },
].map(({ label, value, icon: Icon }) => (
@@ -30,14 +30,14 @@ export default function StatsPage() {
- Stalk History
+ Run History
-
No stalk history yet
+
No run history yet
- Stats will appear here once stalking begins
+ Stats will appear here once running job begins
diff --git a/frontend/src/types.ts b/frontend/src/types.ts
index 8e17d03..7ba53ad 100644
--- a/frontend/src/types.ts
+++ b/frontend/src/types.ts
@@ -26,8 +26,8 @@ export interface InstanceSummary {
id: string;
name: string;
missingCount: number;
- lastStalk: string | null;
- lastStalkCount: number;
+ lastRun: string | null;
+ lastRunCount: number;
state: string;
error?: string;
}
diff --git a/go.mod b/go.mod
index 851e289..bfd915f 100644
--- a/go.mod
+++ b/go.mod
@@ -1,4 +1,4 @@
-module stalkarr
+module sleeparr
go 1.26.1
diff --git a/internal/api/api_test.go b/internal/api/api_test.go
index cb35141..172ddb3 100644
--- a/internal/api/api_test.go
+++ b/internal/api/api_test.go
@@ -7,7 +7,7 @@ import (
"net/http/httptest"
"testing"
- "stalkarr/internal/config"
+ "sleeparr/internal/config"
"github.com/gin-gonic/gin"
)
diff --git a/internal/api/auth.go b/internal/api/auth.go
index 7c0381a..6d03419 100644
--- a/internal/api/auth.go
+++ b/internal/api/auth.go
@@ -9,7 +9,7 @@ import (
"os"
"time"
- "stalkarr/internal/config"
+ "sleeparr/internal/config"
"github.com/gin-gonic/gin"
"github.com/golang-jwt/jwt/v5"
@@ -30,7 +30,7 @@ func mustGetJWTSecret() string {
const (
accessTokenDuration = 15 * time.Minute
refreshTokenDuration = 7 * 24 * time.Hour
- refreshCookieName = "stalkarr_refresh"
+ refreshCookieName = "sleeparr_refresh"
)
func generateAccessToken(username string) (string, error) {
diff --git a/internal/api/router.go b/internal/api/router.go
index ff319f4..3975ed4 100644
--- a/internal/api/router.go
+++ b/internal/api/router.go
@@ -4,11 +4,11 @@ import (
"fmt"
"io/fs"
"net/http"
- "stalkarr/internal/arr"
- "stalkarr/internal/config"
- "stalkarr/internal/jobs"
- "stalkarr/internal/static"
- "stalkarr/internal/version"
+ "sleeparr/internal/arr"
+ "sleeparr/internal/config"
+ "sleeparr/internal/jobs"
+ "sleeparr/internal/static"
+ "sleeparr/internal/version"
"time"
"github.com/gin-contrib/cors"
@@ -16,11 +16,11 @@ import (
)
type Handler struct {
- stalker *jobs.StalkerJob
+ agent *jobs.AgentJob
}
-func NewRouter(stalker *jobs.StalkerJob) *gin.Engine {
- h := &Handler{stalker: stalker}
+func NewRouter(agent *jobs.AgentJob) *gin.Engine {
+ h := &Handler{agent: agent}
r := gin.Default()
r.RedirectTrailingSlash = false
@@ -50,8 +50,8 @@ func NewRouter(stalker *jobs.StalkerJob) *gin.Engine {
protected.PUT("/settings/sonarr/:id", updateSonarrInstance)
protected.DELETE("/settings/sonarr/:id", deleteSonarrInstance)
protected.POST("/settings/sonarr/:id/test", testSonarrInstance)
- protected.GET("/settings/stalk", getStalkSettings)
- protected.POST("/settings/stalk", saveStalkSettings)
+ protected.GET("/settings/agent", getAgentSettings)
+ protected.POST("/settings/agent", saveAgentSettings)
protected.GET("/dashboard", h.getDashboard)
protected.GET("/version", getVersion)
protected.POST("/auth/logout", handleLogout)
@@ -61,8 +61,8 @@ func NewRouter(stalker *jobs.StalkerJob) *gin.Engine {
sonarr := protected.Group("/sonarr/:id")
{
sonarr.GET("/missing", getMissing)
- sonarr.POST("/stalk", h.stalkEpisodes)
- sonarr.POST("/stalk/all", h.stalkAll)
+ sonarr.POST("/run", h.runEpisodes)
+ sonarr.POST("/run/all", h.runAll)
}
}
@@ -125,7 +125,7 @@ func getMissing(c *gin.Context) {
c.JSON(http.StatusOK, result)
}
-func (h *Handler) stalkEpisodes(c *gin.Context) {
+func (h *Handler) runEpisodes(c *gin.Context) {
client, ok := getSonarrClient(c)
if !ok {
return
@@ -145,7 +145,7 @@ func (h *Handler) stalkEpisodes(c *gin.Context) {
return
}
- h.stalker.RecordManualStalk(c.Param("id"), len(req.EpisodeIDs))
+ h.agent.RecordManualRun(c.Param("id"), len(req.EpisodeIDs))
c.JSON(http.StatusOK, gin.H{
"message": result.Message,
@@ -155,31 +155,31 @@ func (h *Handler) stalkEpisodes(c *gin.Context) {
}
func (h *Handler) getJobStatus(c *gin.Context) {
- c.JSON(http.StatusOK, h.stalker.Status())
+ c.JSON(http.StatusOK, h.agent.Status())
}
func (h *Handler) getDashboard(c *gin.Context) {
cfg := config.Get()
- jobStatus := h.stalker.Status()
+ jobStatus := h.agent.Status()
type instanceSummary struct {
ID string `json:"id"`
Name string `json:"name"`
MissingCount int `json:"missingCount"`
- LastStalk *time.Time `json:"lastStalk"`
- LastCount int `json:"lastStalkCount"`
+ LastRun *time.Time `json:"lastRun"`
+ LastCount int `json:"lastRunCount"`
State string `json:"state"`
Error string `json:"error,omitempty"`
}
- stalksToday := 0
+ runsToday := 0
summaries := make([]instanceSummary, 0, len(cfg.Sonarr))
for _, inst := range cfg.Sonarr {
client := arr.NewSonarrClient(inst.URL, inst.APIKey)
result, err := client.GetMissingEpisodes(1, 1, "")
status := jobStatus.Instances[inst.ID]
- stalksToday += status.LastCount
+ runsToday += status.LastCount
if err != nil {
summaries = append(summaries, instanceSummary{
@@ -191,15 +191,15 @@ func (h *Handler) getDashboard(c *gin.Context) {
ID: inst.ID,
Name: inst.Name,
MissingCount: result.TotalCount,
- LastStalk: status.LastRun,
+ LastRun: status.LastRun,
LastCount: status.LastCount,
State: status.State,
})
}
c.JSON(http.StatusOK, gin.H{
- "sonarr": summaries,
- "stalksToday": stalksToday,
+ "sonarr": summaries,
+ "runsToday": runsToday,
})
}
@@ -212,7 +212,7 @@ func getVersion(c *gin.Context) {
})
}
-func (h *Handler) stalkAll(c *gin.Context) {
+func (h *Handler) runAll(c *gin.Context) {
client, ok := getSonarrClient(c)
if !ok {
return
@@ -225,7 +225,7 @@ func (h *Handler) stalkAll(c *gin.Context) {
}
if len(result.Episodes) == 0 {
- c.JSON(http.StatusOK, gin.H{"message": "No missing episodes to stalk", "count": 0})
+ c.JSON(http.StatusOK, gin.H{"message": "No missing episodes to find", "count": 0})
return
}
@@ -234,15 +234,15 @@ func (h *Handler) stalkAll(c *gin.Context) {
ids[i] = ep.ID
}
- stalkResult, err := client.TriggerEpisodeSearch(ids)
+ runResult, err := client.TriggerEpisodeSearch(ids)
if err != nil {
c.JSON(http.StatusBadGateway, gin.H{"error": err.Error()})
return
}
c.JSON(http.StatusOK, gin.H{
- "message": stalkResult.Message,
- "commandId": stalkResult.CommandID,
+ "message": runResult.Message,
+ "commandId": runResult.CommandID,
"count": len(ids),
})
}
diff --git a/internal/api/settings.go b/internal/api/settings.go
index 7e4bdab..53005d2 100644
--- a/internal/api/settings.go
+++ b/internal/api/settings.go
@@ -7,7 +7,7 @@ import (
"strings"
"time"
- "stalkarr/internal/config"
+ "sleeparr/internal/config"
"github.com/gin-gonic/gin"
)
@@ -207,13 +207,13 @@ func testSonarrInstance(c *gin.Context) {
})
}
-func getStalkSettings(c *gin.Context) {
+func getAgentSettings(c *gin.Context) {
cfg := config.Get()
- c.JSON(http.StatusOK, cfg.Stalk)
+ c.JSON(http.StatusOK, cfg.Agent)
}
-func saveStalkSettings(c *gin.Context) {
- var req config.StalkConfig
+func saveAgentSettings(c *gin.Context) {
+ var req config.AgentConfig
if err := c.ShouldBindJSON(&req); err != nil {
c.JSON(http.StatusBadRequest, gin.H{"error": "invalid request"})
return
@@ -228,10 +228,10 @@ func saveStalkSettings(c *gin.Context) {
req.CooldownHours = 1
}
cfg := config.Get()
- cfg.Stalk = req
+ cfg.Agent = req
if err := config.Save(cfg); err != nil {
c.JSON(http.StatusInternalServerError, gin.H{"error": "could not save"})
return
}
- c.JSON(http.StatusOK, cfg.Stalk)
+ c.JSON(http.StatusOK, cfg.Agent)
}
diff --git a/internal/arr/sonarr_stalk.go b/internal/arr/sonarr_agent.go
similarity index 64%
rename from internal/arr/sonarr_stalk.go
rename to internal/arr/sonarr_agent.go
index 8682531..4e42fc7 100644
--- a/internal/arr/sonarr_stalk.go
+++ b/internal/arr/sonarr_agent.go
@@ -9,14 +9,14 @@ import (
"time"
)
-type StalkResult struct {
+type RunResult struct {
CommandID int `json:"commandId"`
Message string `json:"message"`
}
-func (c *SonarrClient) TriggerEpisodeSearch(episodeIDs []int) (StalkResult, error) {
+func (c *SonarrClient) TriggerEpisodeSearch(episodeIDs []int) (RunResult, error) {
if len(episodeIDs) == 0 {
- return StalkResult{}, fmt.Errorf("no episode IDs provided")
+ return RunResult{}, fmt.Errorf("no episode IDs provided")
}
payload := map[string]any{
@@ -25,36 +25,36 @@ func (c *SonarrClient) TriggerEpisodeSearch(episodeIDs []int) (StalkResult, erro
}
body, err := json.Marshal(payload)
if err != nil {
- return StalkResult{}, fmt.Errorf("marshal command: %w", err)
+ return RunResult{}, fmt.Errorf("marshal command: %w", err)
}
url := fmt.Sprintf("%s/api/v3/command?apikey=%s", c.BaseURL, c.APIKey)
req, err := http.NewRequest(http.MethodPost, url, bytes.NewReader(body))
if err != nil {
- return StalkResult{}, fmt.Errorf("build request: %w", err)
+ return RunResult{}, fmt.Errorf("build request: %w", err)
}
req.Header.Set("Content-Type", "application/json")
client := &http.Client{Timeout: 15 * time.Second}
resp, err := client.Do(req)
if err != nil {
- return StalkResult{}, fmt.Errorf("sonarr unreachable: %w", err)
+ return RunResult{}, fmt.Errorf("sonarr unreachable: %w", err)
}
defer resp.Body.Close()
if resp.StatusCode != http.StatusCreated && resp.StatusCode != http.StatusOK {
b, _ := io.ReadAll(resp.Body)
- return StalkResult{}, fmt.Errorf("sonarr returned %d: %s", resp.StatusCode, string(b))
+ return RunResult{}, fmt.Errorf("sonarr returned %d: %s", resp.StatusCode, string(b))
}
var raw struct {
ID int `json:"id"`
}
if err := json.NewDecoder(resp.Body).Decode(&raw); err != nil {
- return StalkResult{Message: fmt.Sprintf("Searching for %d episode(s)", len(episodeIDs))}, nil
+ return RunResult{Message: fmt.Sprintf("Searching for %d episode(s)", len(episodeIDs))}, nil
}
- return StalkResult{
+ return RunResult{
CommandID: raw.ID,
Message: fmt.Sprintf("Searching for %d episode(s)", len(episodeIDs)),
}, nil
diff --git a/internal/config/config.go b/internal/config/config.go
index 3a9229a..43723ac 100644
--- a/internal/config/config.go
+++ b/internal/config/config.go
@@ -23,10 +23,10 @@ type AuthConfig struct {
type Config struct {
Auth AuthConfig `json:"auth"`
Sonarr []SonarrInstance `json:"sonarr"`
- Stalk StalkConfig `json:"stalk"`
+ Agent AgentConfig `json:"agent"`
}
-type StalkConfig struct {
+type AgentConfig struct {
Enabled bool `json:"enabled"`
IntervalMinutes int `json:"intervalMinutes"`
EpisodesPerRun int `json:"episodesPerRun"`
@@ -60,7 +60,7 @@ func load() error {
defer f.Close()
current = Config{
- Stalk: StalkConfig{
+ Agent: AgentConfig{
Enabled: false,
IntervalMinutes: 60,
EpisodesPerRun: 10,
diff --git a/internal/jobs/cooldown.go b/internal/jobs/cooldown.go
index 329011b..b9af26c 100644
--- a/internal/jobs/cooldown.go
+++ b/internal/jobs/cooldown.go
@@ -7,15 +7,15 @@ import (
)
type CooldownTracker struct {
- mu sync.RWMutex
- lastStalk map[string]time.Time
- duration time.Duration
+ mu sync.RWMutex
+ lastRun map[string]time.Time
+ duration time.Duration
}
func NewCooldownTracker(cooldown time.Duration) *CooldownTracker {
return &CooldownTracker{
- lastStalk: make(map[string]time.Time),
- duration: cooldown,
+ lastRun: make(map[string]time.Time),
+ duration: cooldown,
}
}
@@ -23,27 +23,27 @@ func (c *CooldownTracker) IsReady(instanceID string, episodeID int) bool {
c.mu.RLock()
defer c.mu.RUnlock()
key := fmt.Sprintf("%s:%d", instanceID, episodeID)
- last, ok := c.lastStalk[key]
+ last, ok := c.lastRun[key]
if !ok {
return true
}
return time.Since(last) >= c.duration
}
-func (c *CooldownTracker) MarkStalked(instanceID string, episodeID int) {
+func (c *CooldownTracker) MarkRun(instanceID string, episodeID int) {
c.mu.Lock()
defer c.mu.Unlock()
key := fmt.Sprintf("%s:%d", instanceID, episodeID)
- c.lastStalk[key] = time.Now()
+ c.lastRun[key] = time.Now()
}
func (c *CooldownTracker) Prune() {
c.mu.Lock()
defer c.mu.Unlock()
cutoff := time.Now().Add(-2 * c.duration)
- for k, t := range c.lastStalk {
+ for k, t := range c.lastRun {
if t.Before(cutoff) {
- delete(c.lastStalk, k)
+ delete(c.lastRun, k)
}
}
}
diff --git a/internal/jobs/stalker.go b/internal/jobs/sleeparr.go
similarity index 58%
rename from internal/jobs/stalker.go
rename to internal/jobs/sleeparr.go
index 5d9c8e6..eb039f4 100644
--- a/internal/jobs/stalker.go
+++ b/internal/jobs/sleeparr.go
@@ -7,45 +7,45 @@ import (
"math/rand"
"time"
- "stalkarr/internal/arr"
- "stalkarr/internal/config"
+ "sleeparr/internal/arr"
+ "sleeparr/internal/config"
)
-type StalkerJob struct {
+type AgentJob struct {
cfg func() config.Config
cooldown *CooldownTracker
status *StatusTracker
}
-func NewStalkerJob(cfg func() config.Config) *StalkerJob {
- cooldownDur := time.Duration(cfg().Stalk.CooldownHours) * time.Hour
+func NewAgentJob(cfg func() config.Config) *AgentJob {
+ cooldownDur := time.Duration(cfg().Agent.CooldownHours) * time.Hour
if cooldownDur == 0 {
cooldownDur = 24 * time.Hour
}
- return &StalkerJob{
+ return &AgentJob{
cfg: cfg,
cooldown: NewCooldownTracker(cooldownDur),
status: NewStatusTracker(),
}
}
-func (h *StalkerJob) Status() JobStatus {
+func (h *AgentJob) Status() JobStatus {
return h.status.Get()
}
-func (h *StalkerJob) Start(ctx context.Context) {
+func (h *AgentJob) Start(ctx context.Context) {
cfg := h.cfg()
- if !cfg.Stalk.Enabled {
- log.Println("[stalkarr] disabled — set stalk.enabled=true in config to activate")
+ if !cfg.Agent.Enabled {
+ log.Println("[sleeparr] disabled — set agent.enabled=true in config to activate")
return
}
- log.Printf("[stalkarr] starting — interval=%dm, count=%d, cooldown=%dh",
- h.cfg().Stalk.IntervalMinutes, h.cfg().Stalk.EpisodesPerRun, h.cfg().Stalk.CooldownHours)
+ log.Printf("[sleeparr] starting — interval=%dm, count=%d, cooldown=%dh",
+ h.cfg().Agent.IntervalMinutes, h.cfg().Agent.EpisodesPerRun, h.cfg().Agent.CooldownHours)
// Run immediately on startup, then on the ticker.
h.runAll(ctx)
- interval := time.Duration(h.cfg().Stalk.IntervalMinutes) * time.Minute
+ interval := time.Duration(h.cfg().Agent.IntervalMinutes) * time.Minute
if interval == 0 {
interval = 60 * time.Minute
}
@@ -57,7 +57,7 @@ func (h *StalkerJob) Start(ctx context.Context) {
for {
select {
case <-ctx.Done():
- log.Println("[stalkarr] shutting down")
+ log.Println("[sleeparr] shutting down")
return
case <-ticker.C:
h.runAll(ctx)
@@ -67,19 +67,19 @@ func (h *StalkerJob) Start(ctx context.Context) {
}
}
-func (h *StalkerJob) runAll(ctx context.Context) {
+func (h *AgentJob) runAll(ctx context.Context) {
for _, instance := range h.cfg().Sonarr {
if ctx.Err() != nil {
return
}
if err := h.runInstance(ctx, instance); err != nil {
- log.Printf("[stalkarr] sonarr/%s error: %v", instance.ID, err)
+ log.Printf("[sleeparr] sonarr/%s error: %v", instance.ID, err)
h.status.SetError(instance.ID, err)
}
}
}
-func (h *StalkerJob) runInstance(ctx context.Context, instance config.SonarrInstance) error {
+func (h *AgentJob) runInstance(ctx context.Context, instance config.SonarrInstance) error {
client := arr.NewSonarrClient(instance.URL, instance.APIKey)
result, err := client.GetMissingEpisodes(1, 500, "")
@@ -88,7 +88,7 @@ func (h *StalkerJob) runInstance(ctx context.Context, instance config.SonarrInst
}
if len(result.Episodes) == 0 {
- log.Printf("[stalkarr] sonarr/%s — no missing episodes, nothing to do", instance.ID)
+ log.Printf("[sleeparr] sonarr/%s — no missing episodes, nothing to do", instance.ID)
h.status.SetIdle(instance.ID, 0)
return nil
}
@@ -101,13 +101,13 @@ func (h *StalkerJob) runInstance(ctx context.Context, instance config.SonarrInst
}
if len(eligible) == 0 {
- log.Printf("[stalkarr] sonarr/%s — %d missing but all on cooldown", instance.ID, len(result.Episodes))
+ log.Printf("[sleeparr] sonarr/%s — %d missing but all on cooldown", instance.ID, len(result.Episodes))
h.status.SetIdle(instance.ID, 0)
return nil
}
rand.Shuffle(len(eligible), func(i, j int) { eligible[i], eligible[j] = eligible[j], eligible[i] })
- count := h.cfg().Stalk.EpisodesPerRun
+ count := h.cfg().Agent.EpisodesPerRun
if count <= 0 {
count = 10
}
@@ -121,23 +121,23 @@ func (h *StalkerJob) runInstance(ctx context.Context, instance config.SonarrInst
ids[i] = ep.ID
}
- log.Printf("[stalkarr] sonarr/%s — stalking %d episode(s) (%d eligible, %d total missing)",
+ log.Printf("[sleeparr] sonarr/%s — finding %d episode(s) (%d eligible, %d total missing)",
instance.ID, len(ids), len(eligible), len(result.Episodes))
- stalkResult, err := client.TriggerEpisodeSearch(ids)
+ runResult, err := client.TriggerEpisodeSearch(ids)
if err != nil {
return fmt.Errorf("trigger search: %w", err)
}
for _, ep := range chosen {
- h.cooldown.MarkStalked(instance.ID, ep.ID)
+ h.cooldown.MarkRun(instance.ID, ep.ID)
}
- log.Printf("[stalkarr] sonarr/%s — %s (command ID: %d)", instance.ID, stalkResult.Message, stalkResult.CommandID)
+ log.Printf("[sleeparr] sonarr/%s — %s (command ID: %d)", instance.ID, runResult.Message, runResult.CommandID)
h.status.SetLastRun(instance.ID, len(ids), time.Now())
return nil
}
-func (h *StalkerJob) RecordManualStalk(instanceID string, count int) {
- h.status.RecordManualStalk(instanceID, count)
+func (h *AgentJob) RecordManualRun(instanceID string, count int) {
+ h.status.RecordManualRun(instanceID, count)
}
diff --git a/internal/jobs/status.go b/internal/jobs/status.go
index d0d1061..24e2713 100644
--- a/internal/jobs/status.go
+++ b/internal/jobs/status.go
@@ -66,7 +66,7 @@ func (s *StatusTracker) SetError(instanceID string, err error) {
s.instances[instanceID] = existing
}
-func (s *StatusTracker) RecordManualStalk(instanceID string, count int) {
+func (s *StatusTracker) RecordManualRun(instanceID string, count int) {
s.mu.Lock()
defer s.mu.Unlock()
now := time.Now()
diff --git a/internal/version/version.go b/internal/version/version.go
index f807161..1b51a74 100644
--- a/internal/version/version.go
+++ b/internal/version/version.go
@@ -10,7 +10,7 @@ import (
var Version = "dev"
const repoOwner = "codevski"
-const repoName = "stalkarr"
+const repoName = "sleeparr"
type updateCache struct {
latest string
- 
+