-
{/if}
-
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/frontend/src/routes/template-configs/+page.svelte b/frontend/src/routes/template-configs/+page.svelte
new file mode 100644
index 0000000..0a11d84
--- /dev/null
+++ b/frontend/src/routes/template-configs/+page.svelte
@@ -0,0 +1,176 @@
+
+
+
+
+
+
+{#if !loaded}
{:else}
+
+{#if showForm}
+
+ {#if error}{error}
{/if}
+
+
+{/if}
+
+{#if configs.length === 0 && !showForm}
+
{t('templateConfig.noConfigs')}
+{:else}
+
+ {#each configs as config}
+
+
+
+
{config.name}
+
{config.message_assets_added?.slice(0, 120)}...
+ {#if previewResult && previewId === config.id}
+
+
{previewSlot}:
+
{previewResult}
+
+ {/if}
+
+
+
+
+
+
+
+ {/each}
+
+{/if}
+
+{/if}
diff --git a/frontend/src/routes/templates/+page.svelte b/frontend/src/routes/templates/+page.svelte
deleted file mode 100644
index f905660..0000000
--- a/frontend/src/routes/templates/+page.svelte
+++ /dev/null
@@ -1,117 +0,0 @@
-
-
-
-
-
-
-{#if !loaded}
{:else}
-
-{#if showForm}
-
- {#if error}{error}
{/if}
-
-
-{/if}
-
-{#if templates.length === 0 && !showForm}
-
{t('templates.noTemplates')}
-{:else}
-
- {#each templates as tmpl}
-
-
-
-
-
{tmpl.name}
- {#if tmpl.event_type}
-
{tmpl.event_type}
- {/if}
-
-
{tmpl.body.slice(0, 200)}{tmpl.body.length > 200 ? '...' : ''}
- {#if preview && previewId === tmpl.id && !showForm}
-
- {/if}
-
-
-
-
-
-
-
- {/each}
-
-{/if}
-
-{/if}
diff --git a/frontend/src/routes/trackers/+page.svelte b/frontend/src/routes/trackers/+page.svelte
index 7c62454..2902720 100644
--- a/frontend/src/routes/trackers/+page.svelte
+++ b/frontend/src/routes/trackers/+page.svelte
@@ -14,11 +14,8 @@
let showForm = $state(false);
let editing = $state
(null);
const defaultForm = () => ({
- name: '', server_id: 0, album_ids: [] as string[], event_types: ['assets_added'],
+ name: '', server_id: 0, album_ids: [] as string[],
target_ids: [] as number[], scan_interval: 60,
- track_images: true, track_videos: true, notify_favorites_only: false,
- include_people: true, include_asset_details: false,
- max_assets_to_show: 5, assets_order_by: 'none', assets_order: 'descending',
});
let form = $state(defaultForm());
let error = $state('');
@@ -33,11 +30,7 @@
async function edit(trk: any) {
form = {
name: trk.name, server_id: trk.server_id, album_ids: [...trk.album_ids],
- event_types: [...trk.event_types], target_ids: [...trk.target_ids], scan_interval: trk.scan_interval,
- track_images: trk.track_images ?? true, track_videos: trk.track_videos ?? true,
- notify_favorites_only: trk.notify_favorites_only ?? false, include_people: trk.include_people ?? true,
- include_asset_details: trk.include_asset_details ?? false, max_assets_to_show: trk.max_assets_to_show ?? 5,
- assets_order_by: trk.assets_order_by ?? 'none', assets_order: trk.assets_order ?? 'descending',
+ target_ids: [...trk.target_ids], scan_interval: trk.scan_interval,
};
editing = trk.id; showForm = true;
if (form.server_id) await loadAlbums();
@@ -103,57 +96,8 @@
{/if}
-
-
- {#each ['assets_added', 'assets_removed', 'album_renamed', 'album_sharing_changed', 'changed'] as evt}
-
- {/each}
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
{#if targets.length > 0}
@@ -191,10 +135,13 @@
{tracker.enabled ? t('trackers.active') : t('trackers.paused')}
- {tracker.album_ids.length} {t('trackers.albums_count')} · {t('trackers.every')} {tracker.scan_interval}s · {tracker.event_types.join(', ')}
+ {tracker.album_ids.length} {t('trackers.albums_count')} · {t('trackers.every')} {tracker.scan_interval}s · {tracker.target_ids.length} target(s)
+
+
+
diff --git a/frontend/src/routes/tracking-configs/+page.svelte b/frontend/src/routes/tracking-configs/+page.svelte
new file mode 100644
index 0000000..aeb6ff3
--- /dev/null
+++ b/frontend/src/routes/tracking-configs/+page.svelte
@@ -0,0 +1,204 @@
+
+
+
+
+
+
+{#if !loaded}
{:else}
+
+{#if showForm}
+
+ {#if error}{error}
{/if}
+
+
+{/if}
+
+{#if configs.length === 0 && !showForm}
+
{t('trackingConfig.noConfigs')}
+{:else}
+
+ {#each configs as config}
+
+
+
+
{config.name}
+
+ {[config.track_assets_added && 'added', config.track_assets_removed && 'removed', config.track_album_renamed && 'renamed', config.track_album_deleted && 'deleted'].filter(Boolean).join(', ')}
+ {config.periodic_enabled ? ' · periodic' : ''}
+ {config.scheduled_enabled ? ' · scheduled' : ''}
+ {config.memory_enabled ? ' · memory' : ''}
+
+
+
+
+
+
+
+ {/each}
+
+{/if}
+
+{/if}
diff --git a/packages/server/.gitignore b/packages/server/.gitignore
new file mode 100644
index 0000000..c18dd8d
--- /dev/null
+++ b/packages/server/.gitignore
@@ -0,0 +1 @@
+__pycache__/
diff --git a/packages/server/src/immich_watcher_server/api/trackers.py b/packages/server/src/immich_watcher_server/api/trackers.py
index dd8b349..5780c5c 100644
--- a/packages/server/src/immich_watcher_server/api/trackers.py
+++ b/packages/server/src/immich_watcher_server/api/trackers.py
@@ -109,6 +109,44 @@ async def trigger_tracker(
return {"triggered": True, "result": result}
+@router.post("/{tracker_id}/test-periodic")
+async def test_periodic(
+ tracker_id: int,
+ user: User = Depends(get_current_user),
+ session: AsyncSession = Depends(get_session),
+):
+ """Send a test periodic summary notification to all targets."""
+ tracker = await _get_user_tracker(session, tracker_id, user.id)
+ from ..services.notifier import send_test_notification
+ from ..database.models import NotificationTarget
+ results = []
+ for tid in list(tracker.target_ids):
+ target = await session.get(NotificationTarget, tid)
+ if target:
+ r = await send_test_notification(target)
+ results.append({"target": target.name, **r})
+ return {"test": "periodic_summary", "results": results}
+
+
+@router.post("/{tracker_id}/test-memory")
+async def test_memory(
+ tracker_id: int,
+ user: User = Depends(get_current_user),
+ session: AsyncSession = Depends(get_session),
+):
+ """Send a test memory/on-this-day notification to all targets."""
+ tracker = await _get_user_tracker(session, tracker_id, user.id)
+ from ..services.notifier import send_test_notification
+ from ..database.models import NotificationTarget
+ results = []
+ for tid in list(tracker.target_ids):
+ target = await session.get(NotificationTarget, tid)
+ if target:
+ r = await send_test_notification(target)
+ results.append({"target": target.name, **r})
+ return {"test": "memory_mode", "results": results}
+
+
@router.get("/{tracker_id}/history")
async def tracker_history(
tracker_id: int,