refactor: rename upsertSourceConfig to saveSourceConfig

Co-authored-by: Ona <no-reply@ona.com>

.agents/skills/upgrading-expo/SKILL.md

@@ -1,134 +0,0 @@
----
-name: upgrading-expo
-description: Guidelines for upgrading Expo SDK versions and fixing dependency issues
-version: 1.0.0
-license: MIT
----
-
-## References
-
-- ./references/react-19.md -- SDK +54: React 19 changes (useContext → use, Context.Provider → Context, forwardRef removal)
-- ./references/new-architecture.md -- SDK +53: New Architecture migration guide
-- ./references/react-compiler.md -- SDK +54: React Compiler setup and migration guide
-- ./references/native-tabs.md -- SDK +55: Native tabs changes (Icon/Label/Badge now accessed via NativeTabs.Trigger.\*)
-- ./references/expo-av-to-audio.md -- SDK +55: Migrate audio playback and recording from expo-av to expo-audio
-- ./references/expo-av-to-video.md -- SDK +55: Migrate video playback from expo-av to expo-video
-- ./references/react-navigation-to-expo-router.md -- SDK +56: Migrate `@react-navigation/*` imports to `expo-router` entry points (codemod + manual mapping)
-
-## Beta/Preview Releases
-
-Beta versions use `.preview` suffix (e.g., `55.0.0-preview.2`), published under `@next` tag.
-
-Check if latest is beta: https://exp.host/--/api/v2/versions (look for `-preview` in `expoVersion`)
-
-```bash
-npx expo install expo@next --fix  # install beta
-```
-
-## Step-by-Step Upgrade Process
-
-1. Upgrade Expo and dependencies
-
-```bash
-npx expo install expo@latest
-npx expo install --fix
-```
-
-2. Run diagnostics: `npx expo-doctor`
-
-3. Clear caches and reinstall
-
-```bash
-npx expo export -p ios --clear
-rm -rf node_modules .expo
-watchman watch-del-all
-```
-
-## Breaking Changes Checklist
-
-- Check for removed APIs in release notes
-- Update import paths for moved modules
-- Review native module changes requiring prebuild
-- Test all camera, audio, and video features
-- Verify navigation still works correctly
-
-## Prebuild for Native Changes
-
-**First check if `ios/` and `android/` directories exist in the project.** If neither directory exists, the project uses Continuous Native Generation (CNG) and native projects are regenerated at build time — skip this section and "Clear caches for bare workflow" entirely.
-
-If upgrading requires native changes:
-
-```bash
-npx expo prebuild --clean
-```
-
-This regenerates the `ios` and `android` directories. Ensure the project is not a bare workflow app before running this command.
-
-## Clear caches for bare workflow
-
-These steps only apply when `ios/` and/or `android/` directories exist in the project:
-
-- Clear the cocoapods cache for iOS: `cd ios && pod install --repo-update`
-- Clear derived data for Xcode: `npx expo run:ios --no-build-cache`
-- Clear the Gradle cache for Android: `cd android && ./gradlew clean`
-
-## Housekeeping
-
-- Review release notes for the target SDK version at https://expo.dev/changelog
-- If using Expo SDK 54 or later, ensure react-native-worklets is installed — this is required for react-native-reanimated to work.
-- Enable React Compiler in SDK 54+ by adding `"experiments": { "reactCompiler": true }` to app.json — it's stable and recommended
-- Delete sdkVersion from `app.json` to let Expo manage it automatically
-- Remove implicit packages from `package.json`: `@babel/core`, `babel-preset-expo`, `expo-constants`.
-- If the babel.config.js only contains 'babel-preset-expo', delete the file
-- If the metro.config.js only contains expo defaults, delete the file
-
-## Deprecated Packages
-
-| Old Package          | Replacement                                          |
-| -------------------- | ---------------------------------------------------- |
-| `expo-av`            | `expo-audio` and `expo-video`                        |
-| `expo-permissions`   | Individual package permission APIs                   |
-| `@expo/vector-icons` | `expo-symbols` (for SF Symbols)                      |
-| `AsyncStorage`       | `expo-sqlite/localStorage/install`                   |
-| `expo-app-loading`   | `expo-splash-screen`                                 |
-| expo-linear-gradient | experimental_backgroundImage + CSS gradients in View |
-
-When migrating deprecated packages, update all code usage before removing the old package. For expo-av, consult the migration references to convert Audio.Sound to useAudioPlayer, Audio.Recording to useAudioRecorder, and Video components to VideoView with useVideoPlayer.
-
-## expo.install.exclude
-
-Check if package.json has excluded packages:
-
-```json
-{
-  "expo": { "install": { "exclude": ["react-native-reanimated"] } }
-}
-```
-
-Exclusions are often workarounds that may no longer be needed after upgrading. Review each one.
-## Removing patches
-
-Check if there are any outdated patches in the `patches/` directory. Remove them if they are no longer needed.
-
-## Postcss
-
-- `autoprefixer` isn't needed in SDK +53. Remove it from dependencies and check `postcss.config.js` or `postcss.config.mjs` to remove it from the plugins list.
-- Use `postcss.config.mjs` in SDK +53.
-
-## Metro
-
-Remove redundant metro config options:
-
-- resolver.unstable_enablePackageExports is enabled by default in SDK +53.
-- `experimentalImportSupport` is enabled by default in SDK +54.
-- `EXPO_USE_FAST_RESOLVER=1` is removed in SDK +54.
-- cjs and mjs extensions are supported by default in SDK +50.
-- Expo webpack is deprecated, migrate to [Expo Router and Metro web](https://docs.expo.dev/router/migrate/from-expo-webpack/).
-
-## Hermes engine v1
-
-Since SDK 55, users can opt-in to use Hermes engine v1 for improved runtime performance. This requires setting `useHermesV1: true` in the `expo-build-properties` config plugin, and may require a specific version of the `hermes-compiler` npm package. Hermes v1 will become a default in some future SDK release.
-
-## New Architecture
-
-The new architecture is enabled by default, the app.json field `"newArchEnabled": true` is no longer needed as it's the default. Expo Go only supports the new architecture as of SDK +53.

.agents/skills/upgrading-expo/agents/openai.yaml

@@ -1,4 +0,0 @@
-interface:
-  display_name: "Upgrading Expo"
-  short_description: "Upgrade Expo SDKs, fix dependencies, adopt React 19 / React Compiler, and migrate deprecated Expo packages"
-  default_prompt: "Use $upgrading-expo to upgrade an Expo SDK, run diagnostics, fix dependency conflicts, decide whether prebuild/cache clearing applies, and migrate away from deprecated Expo packages."

.agents/skills/upgrading-expo/references/expo-av-to-audio.md

@@ -1,132 +0,0 @@
-# Migrating from expo-av to expo-audio
-
-## Imports
-
-```tsx
-// Before
-import { Audio } from 'expo-av';
-
-// After
-import { useAudioPlayer, useAudioRecorder, RecordingPresets, AudioModule, setAudioModeAsync } from 'expo-audio';
-```
-
-## Audio Playback
-
-### Before (expo-av)
-
-```tsx
-const [sound, setSound] = useState<Audio.Sound>();
-
-async function playSound() {
-  const { sound } = await Audio.Sound.createAsync(require('./audio.mp3'));
-  setSound(sound);
-  await sound.playAsync();
-}
-
-useEffect(() => {
-  return sound ? () => { sound.unloadAsync(); } : undefined;
-}, [sound]);
-```
-
-### After (expo-audio)
-
-```tsx
-const player = useAudioPlayer(require('./audio.mp3'));
-
-// Play
-player.play();
-```
-
-## Audio Recording
-
-### Before (expo-av)
-
-```tsx
-const [recording, setRecording] = useState<Audio.Recording>();
-
-async function startRecording() {
-  await Audio.requestPermissionsAsync();
-  await Audio.setAudioModeAsync({ allowsRecordingIOS: true, playsInSilentModeIOS: true });
-  const { recording } = await Audio.Recording.createAsync(Audio.RecordingOptionsPresets.HIGH_QUALITY);
-  setRecording(recording);
-}
-
-async function stopRecording() {
-  await recording?.stopAndUnloadAsync();
-  const uri = recording?.getURI();
-}
-```
-
-### After (expo-audio)
-
-```tsx
-const recorder = useAudioRecorder(RecordingPresets.HIGH_QUALITY);
-
-async function startRecording() {
-  await AudioModule.requestRecordingPermissionsAsync();
-  await recorder.prepareToRecordAsync();
-  recorder.record();
-}
-
-async function stopRecording() {
-  await recorder.stop();
-  const uri = recorder.uri;
-}
-```
-
-## Audio Mode
-
-### Before (expo-av)
-
-```tsx
-await Audio.setAudioModeAsync({
-  allowsRecordingIOS: true,
-  playsInSilentModeIOS: true,
-  staysActiveInBackground: true,
-  interruptionModeIOS: InterruptionModeIOS.DoNotMix,
-});
-```
-
-### After (expo-audio)
-
-```tsx
-await setAudioModeAsync({
-  playsInSilentMode: true,
-  shouldPlayInBackground: true,
-  interruptionMode: 'doNotMix',
-});
-```
-
-## API Mapping
-
-| expo-av | expo-audio |
-|---------|------------|
-| `Audio.Sound.createAsync()` | `useAudioPlayer(source)` |
-| `sound.playAsync()` | `player.play()` |
-| `sound.pauseAsync()` | `player.pause()` |
-| `sound.setPositionAsync(ms)` | `player.seekTo(seconds)` |
-| `sound.setVolumeAsync(vol)` | `player.volume = vol` |
-| `sound.setRateAsync(rate)` | `player.playbackRate = rate` |
-| `sound.setIsLoopingAsync(loop)` | `player.loop = loop` |
-| `sound.unloadAsync()` | Automatic via hook |
-| `playbackStatus.positionMillis` | `player.currentTime` (seconds) |
-| `playbackStatus.durationMillis` | `player.duration` (seconds) |
-| `playbackStatus.isPlaying` | `player.playing` |
-| `Audio.Recording.createAsync()` | `useAudioRecorder(preset)` |
-| `Audio.RecordingOptionsPresets.*` | `RecordingPresets.*` |
-| `recording.stopAndUnloadAsync()` | `recorder.stop()` |
-| `recording.getURI()` | `recorder.uri` |
-| `Audio.requestPermissionsAsync()` | `AudioModule.requestRecordingPermissionsAsync()` |
-
-## Key Differences
-
-- **No auto-reset on finish**: After `play()` completes, the player stays paused at the end. To replay, call `player.seekTo(0)` then `play()`
-- **Time in seconds**: expo-audio uses seconds, not milliseconds (matching web standards)
-- **Immediate loading**: Audio loads immediately when the hook mounts—no explicit preloading needed
-- **Automatic cleanup**: No need to call `unloadAsync()`, hooks handle resource cleanup on unmount
-- **Multiple players**: Create multiple `useAudioPlayer` instances and store them—all load immediately
-- **Direct property access**: Set volume, rate, loop directly on the player object (`player.volume = 0.5`)
-
-## API Reference
-
-https://docs.expo.dev/versions/latest/sdk/audio/

.agents/skills/upgrading-expo/references/expo-av-to-video.md

@@ -1,160 +0,0 @@
-# Migrating from expo-av to expo-video
-
-## Imports
-
-```tsx
-// Before
-import { Video, ResizeMode } from 'expo-av';
-
-// After
-import { useVideoPlayer, VideoView, VideoSource } from 'expo-video';
-import { useEvent, useEventListener } from 'expo';
-```
-
-## Video Playback
-
-### Before (expo-av)
-
-```tsx
-const videoRef = useRef<Video>(null);
-const [status, setStatus] = useState({});
-
-<Video
-  ref={videoRef}
-  source={{ uri: 'https://example.com/video.mp4' }}
-  style={{ width: 350, height: 200 }}
-  resizeMode={ResizeMode.CONTAIN}
-  isLooping
-  onPlaybackStatusUpdate={setStatus}
-/>
-
-// Control
-videoRef.current?.playAsync();
-videoRef.current?.pauseAsync();
-```
-
-### After (expo-video)
-
-```tsx
-const player = useVideoPlayer('https://example.com/video.mp4', player => {
-  player.loop = true;
-});
-
-const { isPlaying } = useEvent(player, 'playingChange', { isPlaying: player.playing });
-
-<VideoView
-  player={player}
-  style={{ width: 350, height: 200 }}
-  contentFit="contain"
-/>
-
-// Control
-player.play();
-player.pause();
-```
-
-## Status Updates
-
-### Before (expo-av)
-
-```tsx
-<Video
-  onPlaybackStatusUpdate={status => {
-    if (status.isLoaded) {
-      console.log(status.positionMillis, status.durationMillis, status.isPlaying);
-      if (status.didJustFinish) console.log('finished');
-    }
-  }}
-/>
-```
-
-### After (expo-video)
-
-```tsx
-// Reactive state
-const { isPlaying } = useEvent(player, 'playingChange', { isPlaying: player.playing });
-
-// Side effects
-useEventListener(player, 'playToEnd', () => console.log('finished'));
-
-// Direct access
-console.log(player.currentTime, player.duration, player.playing);
-```
-
-## Local Files
-
-### Before (expo-av)
-
-```tsx
-<Video source={require('./video.mp4')} />
-```
-
-### After (expo-video)
-
-```tsx
-const player = useVideoPlayer({ assetId: require('./video.mp4') });
-```
-
-## Fullscreen and PiP
-
-```tsx
-<VideoView
-  player={player}
-  allowsFullscreen
-  allowsPictureInPicture
-  onFullscreenEnter={() => {}}
-  onFullscreenExit={() => {}}
-/>
-```
-
-For PiP and background playback, add to app.json:
-
-```json
-{
-  "expo": {
-    "plugins": [
-      ["expo-video", { "supportsBackgroundPlayback": true, "supportsPictureInPicture": true }]
-    ]
-  }
-}
-```
-
-## API Mapping
-
-| expo-av | expo-video |
-|---------|------------|
-| `<Video>` | `<VideoView>` |
-| `ref={videoRef}` | `player={useVideoPlayer()}` |
-| `source={{ uri }}` | Pass to `useVideoPlayer(uri)` |
-| `resizeMode={ResizeMode.CONTAIN}` | `contentFit="contain"` |
-| `isLooping` | `player.loop = true` |
-| `shouldPlay` | `player.play()` in setup |
-| `isMuted` | `player.muted = true` |
-| `useNativeControls` | `nativeControls={true}` |
-| `onPlaybackStatusUpdate` | `useEvent` / `useEventListener` |
-| `videoRef.current.playAsync()` | `player.play()` |
-| `videoRef.current.pauseAsync()` | `player.pause()` |
-| `videoRef.current.replayAsync()` | `player.replay()` |
-| `videoRef.current.setPositionAsync(ms)` | `player.currentTime = seconds` |
-| `status.positionMillis` | `player.currentTime` (seconds) |
-| `status.durationMillis` | `player.duration` (seconds) |
-| `status.didJustFinish` | `useEventListener(player, 'playToEnd')` |
-
-## Key Differences
-
-- **Separate player and view**: Player logic decoupled from the view—one player can be used across multiple views
-- **Time in seconds**: Uses seconds, not milliseconds
-- **Event system**: Uses `useEvent`/`useEventListener` from `expo` instead of callback props
-- **Video preloading**: Create a player without mounting a VideoView to preload for faster transitions
-- **Built-in caching**: Set `useCaching: true` in VideoSource for persistent offline caching
-
-## Known Issues
-
-- **Uninstall expo-av first**: On Android, having both expo-av and expo-video installed can cause VideoView to show a black screen. Uninstall expo-av before installing expo-video
-- **Android: Reusing players**: Mounting the same player in multiple VideoViews simultaneously can cause black screens on Android (works on iOS)
-- **Android: currentTime in setup**: Setting `player.currentTime` in the `useVideoPlayer` setup callback may not work on Android—set it after mount instead
-- **Changing source**: Use `player.replace(newSource)` to change videos without recreating the player
-
-## API Reference
-
-https://docs.expo.dev/versions/latest/sdk/video/

.agents/skills/upgrading-expo/references/native-tabs.md

@@ -1,124 +0,0 @@
-# Native Tabs Migration (SDK 55)
-
-In SDK 55, `Label`, `Icon`, `Badge`, and `VectorIcon` are now accessed as static properties on `NativeTabs.Trigger` rather than separate imports.
-
-## Import Changes
-
-```tsx
-// SDK 53/54
-import {
-  NativeTabs,
-  Icon,
-  Label,
-  Badge,
-  VectorIcon,
-} from "expo-router/unstable-native-tabs";
-
-// SDK 55+
-import { NativeTabs } from "expo-router/unstable-native-tabs";
-```
-
-## Component Changes
-
-| SDK 53/54        | SDK 55+                             |
-| ---------------- | ----------------------------------- |
-| `<Icon />`       | `<NativeTabs.Trigger.Icon />`       |
-| `<Label />`      | `<NativeTabs.Trigger.Label />`      |
-| `<Badge />`      | `<NativeTabs.Trigger.Badge />`      |
-| `<VectorIcon />` | `<NativeTabs.Trigger.VectorIcon />` |
-| (n/a)            | `<NativeTabs.BottomAccessory />`    |
-
-## New in SDK 55
-
-### BottomAccessory
-
-New component for Apple Music-style mini players on iOS +26 that float above the tab bar:
-
-```tsx
-<NativeTabs>
-  <NativeTabs.BottomAccessory>
-    {/* Content above tabs */}
-  </NativeTabs.BottomAccessory>
-  <NativeTabs.Trigger name="(index)">
-    <NativeTabs.Trigger.Label>Home</NativeTabs.Trigger.Label>
-  </NativeTabs.Trigger>
-</NativeTabs>
-```
-
-On Android and web, this component will render as a no-op. Position a view absolutely above the tab bar instead.
-
-### Icon `md` Prop
-
-New `md` prop for Material icon glyphs on Android (alongside existing `drawable`):
-
-```tsx
-<NativeTabs.Trigger.Icon sf="house" md="home" />
-```
-
-## Full Migration Example
-
-### Before (SDK 53/54)
-
-```tsx
-import {
-  NativeTabs,
-  Icon,
-  Label,
-  Badge,
-} from "expo-router/unstable-native-tabs";
-
-export default function TabLayout() {
-  return (
-    <NativeTabs minimizeBehavior="onScrollDown">
-      <NativeTabs.Trigger name="(index)">
-        <Label>Home</Label>
-        <Icon sf="house.fill" />
-        <Badge>3</Badge>
-      </NativeTabs.Trigger>
-      <NativeTabs.Trigger name="(settings)">
-        <Label>Settings</Label>
-        <Icon sf="gear" />
-      </NativeTabs.Trigger>
-      <NativeTabs.Trigger name="(search)" role="search">
-        <Label>Search</Label>
-      </NativeTabs.Trigger>
-    </NativeTabs>
-  );
-}
-```
-
-### After (SDK 55+)
-
-```tsx
-import { NativeTabs } from "expo-router/unstable-native-tabs";
-
-export default function TabLayout() {
-  return (
-    <NativeTabs minimizeBehavior="onScrollDown">
-      <NativeTabs.Trigger name="(index)">
-        <NativeTabs.Trigger.Label>Home</NativeTabs.Trigger.Label>
-        <NativeTabs.Trigger.Icon sf="house.fill" md="home" />
-        <NativeTabs.Trigger.Badge>3</NativeTabs.Trigger.Badge>
-      </NativeTabs.Trigger>
-      <NativeTabs.Trigger name="(settings)">
-        <NativeTabs.Trigger.Label>Settings</NativeTabs.Trigger.Label>
-        <NativeTabs.Trigger.Icon sf="gear" md="settings" />
-      </NativeTabs.Trigger>
-      <NativeTabs.Trigger name="(search)" role="search">
-        <NativeTabs.Trigger.Label>Search</NativeTabs.Trigger.Label>
-      </NativeTabs.Trigger>
-    </NativeTabs>
-  );
-}
-```
-
-## Migration Checklist
-
-1. Remove `Icon`, `Label`, `Badge`, `VectorIcon` from imports
-2. Keep only `NativeTabs` import from `expo-router/unstable-native-tabs`
-3. Replace `<Icon />` with `<NativeTabs.Trigger.Icon />`
-4. Replace `<Label />` with `<NativeTabs.Trigger.Label />`
-5. Replace `<Badge />` with `<NativeTabs.Trigger.Badge />`
-6. Replace `<VectorIcon />` with `<NativeTabs.Trigger.VectorIcon />`
-
-- Read docs for more info https://docs.expo.dev/versions/v55.0.0/sdk/router-native-tabs/

.agents/skills/upgrading-expo/references/new-architecture.md

@@ -1,79 +0,0 @@
-# New Architecture
-
-The New Architecture is enabled by default in Expo SDK 53+. It replaces the legacy bridge with a faster, synchronous communication layer between JavaScript and native code.
-
-## Documentation
-
-Full guide: https://docs.expo.dev/guides/new-architecture/
-
-## What Changed
-
-- **JSI (JavaScript Interface)** — Direct synchronous calls between JS and native
-- **Fabric** — New rendering system with concurrent features
-- **TurboModules** — Lazy-loaded native modules with type safety
-
-## SDK Compatibility
-
-| SDK Version | New Architecture Status |
-| ----------- | ----------------------- |
-| SDK 53+     | Enabled by default      |
-| SDK 52      | Opt-in via app.json     |
-| SDK 51-     | Experimental            |
-
-## Configuration
-
-New Architecture is enabled by default. To explicitly disable (not recommended):
-
-```json
-{
-  "expo": {
-    "newArchEnabled": false
-  }
-}
-```
-
-## Expo Go
-
-Expo Go only supports the New Architecture as of SDK 53. Apps using the old architecture must use development builds.
-
-## Common Migration Issues
-
-### Native Module Compatibility
-
-Some older native modules may not support the New Architecture. Check:
-
-1. Module documentation for New Architecture support
-2. GitHub issues for compatibility discussions
-3. Consider alternatives if module is unmaintained
-
-### Reanimated
-
-React Native Reanimated requires `react-native-worklets` in SDK 54+:
-
-```bash
-npx expo install react-native-worklets
-```
-
-### Layout Animations
-
-Some layout animations behave differently. Test thoroughly after upgrading.
-
-## Verifying New Architecture
-
-Check if New Architecture is active:
-
-```tsx
-import { Platform } from "react-native";
-
-// Returns true if Fabric is enabled
-const isNewArch = global._IS_FABRIC !== undefined;
-```
-
-Verify from the command line if the currently running app uses the New Architecture: `bunx xcobra expo eval "_IS_FABRIC"` -> `true`
-
-## Troubleshooting
-
-1. **Clear caches** — `npx expo start --clear`
-2. **Clean prebuild** — `npx expo prebuild --clean`
-3. **Check native modules** — Ensure all dependencies support New Architecture
-4. **Review console warnings** — Legacy modules log compatibility warnings

.agents/skills/upgrading-expo/references/react-19.md

@@ -1,79 +0,0 @@
-# React 19
-
-React 19 is included in Expo SDK 54. This release simplifies several common patterns.
-
-## Context Changes
-
-### useContext → use
-
-The `use` hook replaces `useContext`:
-
-```tsx
-// Before (React 18)
-import { useContext } from "react";
-const value = useContext(MyContext);
-
-// After (React 19)
-import { use } from "react";
-const value = use(MyContext);
-```
-
-- The `use` hook can also read promises, enabling Suspense-based data fetching.
-- `use` can be called conditionally, this simplifies components that consume multiple contexts.
-
-### Context.Provider → Context
-
-Context providers no longer need the `.Provider` suffix:
-
-```tsx
-// Before (React 18)
-<ThemeContext.Provider value={theme}>
-  {children}
-</ThemeContext.Provider>
-
-// After (React 19)
-<ThemeContext value={theme}>
-  {children}
-</ThemeContext>
-```
-
-## ref as a Prop
-
-### Removing forwardRef
-
-Components can now receive `ref` as a regular prop. `forwardRef` is no longer needed:
-
-```tsx
-// Before (React 18)
-import { forwardRef } from "react";
-
-const Input = forwardRef<TextInput, Props>((props, ref) => {
-  return <TextInput ref={ref} {...props} />;
-});
-
-// After (React 19)
-function Input({ ref, ...props }: Props & { ref?: React.Ref<TextInput> }) {
-  return <TextInput ref={ref} {...props} />;
-}
-```
-
-### Migration Steps
-
-1. Remove `forwardRef` wrapper
-2. Add `ref` to the props destructuring
-3. Update the type to include `ref?: React.Ref<T>`
-
-## Other React 19 Features
-
-- **Actions** — Functions that handle async transitions
-- **useOptimistic** — Optimistic UI updates
-- **useFormStatus** — Form submission state (web)
-- **Document Metadata** — Native `<title>` and `<meta>` support (web)
-
-## Cleanup Checklist
-
-When upgrading to SDK 54:
-
-- [ ] Replace `useContext` with `use`
-- [ ] Remove `.Provider` from Context components
-- [ ] Remove `forwardRef` wrappers, use `ref` prop instead

.agents/skills/upgrading-expo/references/react-compiler.md

@@ -1,59 +0,0 @@
-# React Compiler
-
-React Compiler is stable in Expo SDK 54 and later. It automatically memoizes components and hooks, eliminating the need for manual `useMemo`, `useCallback`, and `React.memo`.
-
-## Enabling React Compiler
-
-Add to `app.json`:
-
-```json
-{
-  "expo": {
-    "experiments": {
-      "reactCompiler": true
-    }
-  }
-}
-```
-
-## What React Compiler Does
-
-- Automatically memoizes components and values
-- Eliminates unnecessary re-renders
-- Removes the need for manual `useMemo` and `useCallback`
-- Works with existing code without modifications
-
-## Cleanup After Enabling
-
-Once React Compiler is enabled, you can remove manual memoization:
-
-```tsx
-// Before (manual memoization)
-const memoizedValue = useMemo(() => computeExpensive(a, b), [a, b]);
-const memoizedCallback = useCallback(() => doSomething(a), [a]);
-const MemoizedComponent = React.memo(MyComponent);
-
-// After (React Compiler handles it)
-const value = computeExpensive(a, b);
-const callback = () => doSomething(a);
-// Just use MyComponent directly
-```
-
-## Requirements
-
-- Expo SDK 54 or later
-- New Architecture enabled (default in SDK 54+)
-
-## Verifying It's Working
-
-React Compiler runs at build time. Check the Metro bundler output for compilation messages. You can also use React DevTools to verify components are being optimized.
-
-## Troubleshooting
-
-If you encounter issues:
-
-1. Ensure New Architecture is enabled
-2. Clear Metro cache: `npx expo start --clear`
-3. Check for incompatible patterns in your code (rare)
-
-React Compiler is designed to work with idiomatic React code. If it can't safely optimize a component, it skips that component without breaking your app.

.agents/skills/upgrading-expo/references/react-navigation-to-expo-router.md

@@ -1,61 +0,0 @@
-# Migrating from react-navigation to expo-router
-
-In SDK 56+, application code must not import from `@react-navigation/*` directly. Repoint those imports to the matching `expo-router` entry points. Runtime API is unchanged — only the module specifiers move.
-
-## Steps
-
-1. Prefer the automated codemod (see below). If it is not viable, fall back to the manual mapping.
-2. Replace imports using the table. Use the entry point that matches the `@react-navigation/*` source.
-3. After rewriting, check whether any of the rewritten imports are deprecated in `expo-router` (see [Check for deprecated imports](#check-for-deprecated-imports)). If so, surface the deprecation reason and the suggested replacement to the user before continuing.
-4. Validate: search for remaining `@react-navigation/` references in source files, then run typecheck/build/start.
-5. Remove `@react-navigation/*` packages that are no longer imported from `package.json` and reinstall (delete `node_modules` if needed).
-
-## Automated migration (preferred)
-
-Run from the project root over your application code (replace `src` with the actual directory or glob):
-
-```sh
-npx expo-codemod sdk-56-expo-router-react-navigation-replace src
-```
-
-```sh
-npx expo-codemod sdk-56-expo-router-react-navigation-replace '**/*.{ts,tsx,js,jsx}'
-```
-
-## Manual API mapping
-
-| React Navigation source               | Expo Router target                                                       |
-| ------------------------------------- | ------------------------------------------------------------------------ |
-| `@react-navigation/native`            | `expo-router/react-navigation`                                           |
-| `@react-navigation/core`              | `expo-router/react-navigation`                                           |
-| `@react-navigation/elements`          | `expo-router/react-navigation`                                           |
-| `@react-navigation/routers`           | `expo-router/react-navigation`                                           |
-| `@react-navigation/stack`             | `expo-router/js-stack`                                                   |
-| `@react-navigation/bottom-tabs`       | `expo-router/js-tabs`                                                    |
-| `@react-navigation/material-top-tabs` | `expo-router/js-top-tabs`                                                |
-| `@react-navigation/native-stack`      | No direct equivalent. Use the `Stack` layout from `expo-router` instead. |
-
-**Stack caveat:** Do NOT rewrite `import { Stack } from "expo-router"` to `expo-router/js-stack`. The root `Stack` is the Expo Router layout component used in route files; only use `expo-router/js-stack` when replacing a `@react-navigation/stack` JS stack navigator.
-
-If you encounter a symbol that has no replacement, ask the user to file an issue in the `expo/expo` repository describing what is needed and why.
-
-## Check for deprecated imports
-
-A successful rewrite to `expo-router/*` does not guarantee the new import is the recommended one. Some symbols are re-exported as deprecated shims and the project may need to migrate further (for example, to a different `expo-router` API or to a first-party Expo package).
-
-For each symbol rewritten in step 2:
-
-1. Resolve the rewritten module to its source in `node_modules` (e.g., `node_modules/expo-router/build/react-navigation.d.ts`, `js-stack`, `js-tabs`, `js-top-tabs`).
-2. Look for a `@deprecated` JSDoc tag on the named export, or a runtime deprecation warning in the implementation file.
-3. If deprecated, capture both the reason and the recommended replacement from the JSDoc/comment.
-4. Report each deprecated symbol to the user with: the import path, the symbol, the deprecation reason, and the suggested replacement. Wait for the user to confirm before mass-applying further changes.
-
-## Done when
-
-1. No `@react-navigation/*` imports remain in source files.
-2. No unused `@react-navigation/*` entries remain in `package.json`.
-3. Typecheck and bundler start without `@react-navigation/*` errors.
-
-## Reference
-
-- Official Expo Router SDK 55 → 56 migration guide: https://docs.expo.dev/router/migrate/sdk-55-to-56

.claude/skills/gpg-commit-signing/SKILL.md

@@ -0,0 +1,43 @@
+---
+name: gpg-commit-signing
+description: Sign git commits with GPG in non-interactive environments. Use when committing code and the `GPG_PRIVATE_KEY_PASSPHRASE` environment variable is available. Triggers on "commit", "sign commit", "GPG", "git commit -S", or any git operation requiring signed commits.
+---
+
+# GPG Commit Signing
+
+Sign commits in headless/non-interactive environments where `/dev/tty` is unavailable.
+
+## Workflow
+
+1. Check whether `GPG_PRIVATE_KEY_PASSPHRASE` is set:
+
+   ```bash
+   test -n "$GPG_PRIVATE_KEY_PASSPHRASE" && echo "available" || echo "not set"
+   ```
+
+   If not set, skip signing — commit without `-S`.
+
+2. Try a direct signed commit first — the environment may already have loopback pinentry configured:
+
+   ```bash
+   git commit -S -m "message"
+   ```
+
+   If this succeeds, no further steps are needed.
+
+3. If step 2 fails with a `/dev/tty` error, use `--pinentry-mode loopback` via a wrapper script:
+
+   ```bash
+   printf '#!/bin/sh\ngpg --batch --pinentry-mode loopback --passphrase "$GPG_PRIVATE_KEY_PASSPHRASE" "$@"\n' > /tmp/gpg-sign.sh
+   chmod +x /tmp/gpg-sign.sh
+   git -c gpg.program=/tmp/gpg-sign.sh commit -S -m "message"
+   rm /tmp/gpg-sign.sh
+   ```
+
+   This passes the passphrase directly to gpg on each signing invocation, bypassing the need for a configured gpg-agent.
+
+## Anti-patterns
+
+- Do not echo or log `GPG_PRIVATE_KEY_PASSPHRASE`.
+- Do not commit without `-S` when the passphrase is available — the project expects signed commits.
+- Do not leave wrapper scripts on disk after committing.

.github/workflows/build-waitlist-website.yml

@@ -11,7 +11,7 @@ on:
 
 env:
   REGISTRY: cr.nym.sh
-  IMAGE_NAME: freya-waitlist-website
+  IMAGE_NAME: aelis-waitlist-website
 
 jobs:
   build:

.ona/automations.yaml

@@ -0,0 +1,45 @@
+services:
+  expo:
+    name: Expo Dev Server
+    description: Expo development server for aelis-client
+    triggeredBy:
+      - postDevcontainerStart
+    commands:
+      start: cd apps/aelis-client && ./scripts/run-dev-server.sh
+
+  drizzle-studio:
+    name: Drizzle Studio
+    description: Drizzle Studio database browser for aelis-backend
+    triggeredBy:
+      - manual
+    commands:
+      start: |
+        FORWARD_URL=$(gitpod environment port open 4983 --name drizzle-studio-server | sed 's|https://||')
+        echo "Drizzle Studio: https://local.drizzle.studio/?host=${FORWARD_URL}&port=443"
+        cd apps/aelis-backend && bunx drizzle-kit studio --host 0.0.0.0 --port 4983
+
+  aelis-backend:
+    name: Aelis Backend
+    description: Hono API server for aelis-backend (port 3000)
+    triggeredBy:
+      - manual
+    commands:
+      start: |
+        gitpod --context environment environment port open 3000 --name "Aelis Backend" --protocol http
+        TS_IP=$(tailscale ip -4)
+        echo ""
+        echo "------------------ Bun Debugger ------------------"
+        echo "https://debug.bun.sh/#${TS_IP}:6499"
+        echo "------------------ Bun Debugger ------------------"
+        echo ""
+        cd apps/aelis-backend && bun run dev
+
+  admin-dashboard:
+    name: Admin Dashboard
+    description: Vite dev server for admin-dashboard (port 5174)
+    triggeredBy:
+      - manual
+    commands:
+      start: |
+        gitpod --context environment environment port open 5174 --name "Admin Dashboard" --protocol http
+        cd apps/admin-dashboard && bun run dev --host

.oxfmtrc.json

@@ -1,12 +1,12 @@
 {
-  "$schema": "./node_modules/oxfmt/configuration_schema.json",
+	"$schema": "./node_modules/oxfmt/configuration_schema.json",
-  "useTabs": true,
+	"useTabs": true,
-  "semi": false,
+	"semi": false,
-  "trailingComma": "all",
+	"trailingComma": "all",
-  "experimentalSortImports": {
+	"experimentalSortImports": {
-    "order": "asc",
+		"order": "asc",
-    "ignoreCase": true,
+		"ignoreCase": true,
-    "newlinesBetween": true
+		"newlinesBetween": true
-  },
+	},
-  "ignorePatterns": [".claude", ".ona", "drizzle", "fixtures"]
+	"ignorePatterns": [".claude", "fixtures"]
 }

.zed/settings.json

@@ -1,20 +0,0 @@
-// Folder-specific settings
-//
-// For a full list of overridable settings, and general information on folder-specific settings,
-// see the documentation: https://zed.dev/docs/configuring-zed#settings-files
-{
-  "languages": {
-    "TypeScript": {
-      "formatter": { "language_server": { "name": "oxfmt" } }
-    },
-    "TSX": {
-      "formatter": { "language_server": { "name": "oxfmt" } }
-    },
-    "JavaScript": {
-      "formatter": { "language_server": { "name": "oxfmt" } }
-    },
-    "JSX": {
-      "formatter": { "language_server": { "name": "oxfmt" } }
-    }
-  }
-}

AGENTS.md

@@ -2,7 +2,7 @@
 
 ## Project
 
-FREYA is an AI-powered personal assistant that aggregates data from various sources into a contextual feed. Monorepo with `packages/` (shared libraries) and `apps/` (applications).
+AELIS is an AI-powered personal assistant that aggregates data from various sources into a contextual feed. Monorepo with `packages/` (shared libraries) and `apps/` (applications).
 
 ## Commands
 
@@ -39,13 +39,4 @@ Use Bun exclusively. Do not use npm or yarn.
 
 - Branch: `feat/<task>`, `fix/<task>`, `ci/<task>`, etc.
 - Commits: conventional commit format, title <= 50 chars
-
+- Signing: If `GPG_PRIVATE_KEY_PASSPHRASE` env var is available, use it to sign commits with `git commit -S`
-## Nix
-
-Use the Nix dev shell for project commands by default.
-
-- Run repo tooling through `nix develop -c`, e.g. `nix develop -c bun test`.
-- Use Bun exclusively inside the Nix shell.
-- Do not use host `bun`, `node`, `tsc`, or package binaries for project tasks unless explicitly checking host behavior.
-- Simple inspection commands like `rg`, `sed`, `ls`, and `git status` may run outside Nix.
-- While `flake.nix` is untracked, use `nix develop path:. -c <command>`.

README.md

@@ -1,4 +1,4 @@
-# freya
+# aelis
 
 To install dependencies:
 
@@ -8,14 +8,14 @@ bun install
 
 ## Packages
 
-### @freya/source-tfl
+### @aelis/source-tfl
 
 TfL (Transport for London) feed source for tube, overground, and Elizabeth line alerts.
 
 #### Testing
 
 ```bash
-cd packages/freya-source-tfl
+cd packages/aelis-source-tfl
 bun run test
 ```
 

apps/admin-dashboard/package.json

@@ -21,8 +21,8 @@
 		"lucide-react": "^0.577.0",
 		"next-themes": "^0.4.6",
 		"radix-ui": "^1.4.3",
-		"react": "19.2.3",
+		"react": "^19.2.0",
-		"react-dom": "19.2.3",
+		"react-dom": "^19.2.0",
 		"shadcn": "^4.0.8",
 		"sonner": "^2.0.7",
 		"tailwind-merge": "^3.5.0",

apps/admin-dashboard/src/components/login-page.tsx

@@ -71,7 +71,7 @@ export function LoginPage({ onLogin }: LoginPageProps) {
 								type="email"
 								value={email}
 								onChange={(e) => setEmail(e.target.value)}
-								placeholder="admin@freya.local"
+								placeholder="admin@aelis.local"
 								required
 							/>
 						</div>

apps/admin-dashboard/src/components/reminder-crud-panel.tsx

@@ -1,639 +0,0 @@
-import type { Dispatch, FormEvent, SetStateAction } from "react"
-
-import { useMutation, useQuery, useQueryClient } from "@tanstack/react-query"
-import { Check, Loader2, Pencil, Plus, RefreshCw, RotateCcw, Save, Trash2, X } from "lucide-react"
-import { useMemo, useState } from "react"
-import { toast } from "sonner"
-
-import type { FeedItem } from "@/lib/api"
-
-import { Badge } from "@/components/ui/badge"
-import { Button } from "@/components/ui/button"
-import { Card, CardContent, CardHeader, CardTitle } from "@/components/ui/card"
-import { Input } from "@/components/ui/input"
-import { Label } from "@/components/ui/label"
-import {
-	Select,
-	SelectContent,
-	SelectItem,
-	SelectTrigger,
-	SelectValue,
-} from "@/components/ui/select"
-import { Switch } from "@/components/ui/switch"
-import { executeSourceAction, fetchFeed } from "@/lib/api"
-
-const REMINDER_SOURCE_ID = "freya.reminders"
-
-type ReminderPriority = "low" | "normal" | "high"
-type ReminderFrequency = "daily" | "weekly" | "monthly" | "yearly"
-type ReminderEditScope = "this-occurrence" | "this-and-future" | "entire-series"
-
-interface ReminderRecurrence {
-	frequency: ReminderFrequency
-	interval: number
-	count?: number
-	until?: string
-}
-
-interface ReminderFeedData extends Record<string, unknown> {
-	reminderId: string
-	occurrenceId: string
-	title: string
-	notes: string | null
-	originalDueAt: string
-	dueAt: string
-	timeZone: string
-	recurrence: ReminderRecurrence | null
-	priority: ReminderPriority
-	completedAt: string | null
-}
-
-interface ReminderFormState {
-	title: string
-	notes: string
-	dueAt: string
-	priority: ReminderPriority
-	scope: ReminderEditScope
-	recurs: boolean
-	frequency: ReminderFrequency
-	interval: string
-	count: string
-	until: string
-}
-
-const emptyForm: ReminderFormState = {
-	title: "",
-	notes: "",
-	dueAt: toLocalInput(new Date()),
-	priority: "normal",
-	scope: "entire-series",
-	recurs: false,
-	frequency: "daily",
-	interval: "1",
-	count: "",
-	until: "",
-}
-
-export function ReminderCrudPanel() {
-	const queryClient = useQueryClient()
-	const [form, setForm] = useState<ReminderFormState>(emptyForm)
-	const [editing, setEditing] = useState<ReminderFeedData | null>(null)
-	const [deleteScopes, setDeleteScopes] = useState<Record<string, ReminderEditScope>>({})
-
-	const {
-		data: feed,
-		isFetching,
-		refetch,
-	} = useQuery({
-		queryKey: ["feed"],
-		queryFn: fetchFeed,
-	})
-
-	const reminders = useMemo(
-		() => (feed?.items ?? []).filter(isReminderItem).map((item) => item.data),
-		[feed],
-	)
-
-	const actionMutation = useMutation({
-		mutationFn: (input: { actionId: string; params: unknown }) =>
-			executeSourceAction(REMINDER_SOURCE_ID, input.actionId, input.params),
-	})
-
-	const busy = actionMutation.isPending
-	const canConfigureRecurrence = !editing || form.scope !== "this-occurrence"
-
-	async function runAction(actionId: string, params: unknown, success: string): Promise<boolean> {
-		try {
-			await actionMutation.mutateAsync({ actionId, params })
-			await queryClient.invalidateQueries({ queryKey: ["feed"] })
-			toast.success(success)
-			return true
-		} catch (err) {
-			toast.error(err instanceof Error ? err.message : String(err))
-			return false
-		}
-	}
-
-	async function handleSubmit(event: FormEvent<HTMLFormElement>) {
-		event.preventDefault()
-
-		if (editing) {
-			const patch = formToPatch(formFromReminder(editing), form)
-			if (Object.keys(patch).length === 0) {
-				toast.info("No changes to save")
-				return
-			}
-
-			const saved = await runAction(
-				"update-reminder",
-				{
-					reminderId: editing.reminderId,
-					scope: form.scope,
-					occurrenceDueAt: editing.originalDueAt,
-					patch,
-				},
-				"Reminder updated",
-			)
-			if (saved) resetForm()
-			return
-		} else {
-			const created = await runAction(
-				"create-reminder",
-				formToCreatePayload(form),
-				"Reminder created",
-			)
-			if (created) resetForm()
-		}
-	}
-
-	function startEdit(reminder: ReminderFeedData) {
-		setEditing(reminder)
-		setForm(formFromReminder(reminder))
-	}
-
-	function resetForm() {
-		setEditing(null)
-		setForm({ ...emptyForm, dueAt: toLocalInput(new Date()) })
-	}
-
-	function getDeleteScope(reminder: ReminderFeedData): ReminderEditScope {
-		return (
-			deleteScopes[reminderKey(reminder)] ??
-			(reminder.recurrence ? "this-occurrence" : "entire-series")
-		)
-	}
-
-	function setDeleteScope(reminder: ReminderFeedData, scope: ReminderEditScope) {
-		setDeleteScopes((prev) => ({ ...prev, [reminderKey(reminder)]: scope }))
-	}
-
-	return (
-		<Card className="-mx-4">
-			<CardHeader className="pb-4">
-				<div className="flex items-center justify-between gap-3">
-					<CardTitle className="text-sm">Reminders</CardTitle>
-					<Button size="sm" variant="outline" onClick={() => refetch()} disabled={isFetching}>
-						{isFetching ? (
-							<Loader2 className="size-3.5 animate-spin" />
-						) : (
-							<RefreshCw className="size-3.5" />
-						)}
-						Refresh
-					</Button>
-				</div>
-			</CardHeader>
-			<CardContent className="space-y-5">
-				<form className="grid gap-4" onSubmit={handleSubmit}>
-					<div className="grid gap-3 sm:grid-cols-2">
-						<div className="space-y-2 sm:col-span-2">
-							<Label htmlFor="reminder-title" className="text-xs font-medium">
-								Title
-							</Label>
-							<Input
-								id="reminder-title"
-								value={form.title}
-								onChange={(event) => setFormField(setForm, "title", event.target.value)}
-								disabled={busy}
-								required
-							/>
-						</div>
-
-						<div className="space-y-2 sm:col-span-2">
-							<Label htmlFor="reminder-notes" className="text-xs font-medium">
-								Notes
-							</Label>
-							<Input
-								id="reminder-notes"
-								value={form.notes}
-								onChange={(event) => setFormField(setForm, "notes", event.target.value)}
-								disabled={busy}
-							/>
-						</div>
-
-						<div className="space-y-2">
-							<Label htmlFor="reminder-due-at" className="text-xs font-medium">
-								Due
-							</Label>
-							<Input
-								id="reminder-due-at"
-								type="datetime-local"
-								value={form.dueAt}
-								onChange={(event) => setFormField(setForm, "dueAt", event.target.value)}
-								disabled={busy}
-								required
-							/>
-						</div>
-
-						<div className="space-y-2">
-							<Label htmlFor="reminder-priority" className="text-xs font-medium">
-								Priority
-							</Label>
-							<Select
-								value={form.priority}
-								onValueChange={(value) =>
-									setFormField(setForm, "priority", value as ReminderPriority)
-								}
-								disabled={busy}
-							>
-								<SelectTrigger id="reminder-priority">
-									<SelectValue />
-								</SelectTrigger>
-								<SelectContent>
-									<SelectItem value="low">Low</SelectItem>
-									<SelectItem value="normal">Normal</SelectItem>
-									<SelectItem value="high">High</SelectItem>
-								</SelectContent>
-							</Select>
-						</div>
-
-						{editing?.recurrence && (
-							<div className="space-y-2 sm:col-span-2">
-								<Label htmlFor="reminder-edit-scope" className="text-xs font-medium">
-									Edit scope
-								</Label>
-								<Select
-									value={form.scope}
-									onValueChange={(value) =>
-										setFormField(setForm, "scope", value as ReminderEditScope)
-									}
-									disabled={busy}
-								>
-									<SelectTrigger id="reminder-edit-scope">
-										<SelectValue />
-									</SelectTrigger>
-									<SelectContent>
-										<SelectItem value="this-occurrence">This occurrence</SelectItem>
-										<SelectItem value="this-and-future">This and future</SelectItem>
-										<SelectItem value="entire-series">Entire series</SelectItem>
-									</SelectContent>
-								</Select>
-							</div>
-						)}
-					</div>
-
-					{canConfigureRecurrence && (
-						<div className="grid gap-3 rounded-md border p-3 sm:grid-cols-4">
-							<div className="flex items-center justify-between gap-3 sm:col-span-4">
-								<Label htmlFor="reminder-recurs" className="text-xs font-medium">
-									Recurring
-								</Label>
-								<Switch
-									id="reminder-recurs"
-									checked={form.recurs}
-									onCheckedChange={(checked) => setFormField(setForm, "recurs", checked)}
-									disabled={busy}
-								/>
-							</div>
-
-							{form.recurs && (
-								<>
-									<div className="space-y-2 sm:col-span-2">
-										<Label htmlFor="reminder-frequency" className="text-xs font-medium">
-											Frequency
-										</Label>
-										<Select
-											value={form.frequency}
-											onValueChange={(value) =>
-												setFormField(setForm, "frequency", value as ReminderFrequency)
-											}
-											disabled={busy}
-										>
-											<SelectTrigger id="reminder-frequency">
-												<SelectValue />
-											</SelectTrigger>
-											<SelectContent>
-												<SelectItem value="daily">Daily</SelectItem>
-												<SelectItem value="weekly">Weekly</SelectItem>
-												<SelectItem value="monthly">Monthly</SelectItem>
-												<SelectItem value="yearly">Yearly</SelectItem>
-											</SelectContent>
-										</Select>
-									</div>
-
-									<div className="space-y-2">
-										<Label htmlFor="reminder-interval" className="text-xs font-medium">
-											Interval
-										</Label>
-										<Input
-											id="reminder-interval"
-											type="number"
-											min={1}
-											value={form.interval}
-											onChange={(event) => setFormField(setForm, "interval", event.target.value)}
-											disabled={busy}
-										/>
-									</div>
-
-									<div className="space-y-2">
-										<Label htmlFor="reminder-count" className="text-xs font-medium">
-											Count
-										</Label>
-										<Input
-											id="reminder-count"
-											type="number"
-											min={1}
-											value={form.count}
-											onChange={(event) => setFormField(setForm, "count", event.target.value)}
-											disabled={busy}
-										/>
-									</div>
-
-									<div className="space-y-2 sm:col-span-4">
-										<Label htmlFor="reminder-until" className="text-xs font-medium">
-											Until
-										</Label>
-										<Input
-											id="reminder-until"
-											type="datetime-local"
-											value={form.until}
-											onChange={(event) => setFormField(setForm, "until", event.target.value)}
-											disabled={busy}
-										/>
-									</div>
-								</>
-							)}
-						</div>
-					)}
-
-					<div className="flex justify-end gap-2">
-						{editing && (
-							<Button type="button" variant="outline" onClick={resetForm} disabled={busy}>
-								<X className="size-3.5" />
-								Cancel
-							</Button>
-						)}
-						<Button type="submit" disabled={busy || !form.title || !form.dueAt}>
-							{busy ? <Loader2 className="size-3.5 animate-spin" /> : <Save className="size-3.5" />}
-							{editing ? "Update" : "Create"}
-						</Button>
-					</div>
-				</form>
-
-				<div className="space-y-2">
-					<div className="flex items-center justify-between text-xs text-muted-foreground">
-						<span>
-							{reminders.length} {reminders.length === 1 ? "occurrence" : "occurrences"}
-						</span>
-						{!editing && (
-							<Button size="sm" variant="ghost" onClick={resetForm} disabled={busy}>
-								<Plus className="size-3.5" />
-								New
-							</Button>
-						)}
-					</div>
-
-					{reminders.length === 0 && (
-						<div className="rounded-md border border-dashed px-3 py-6 text-center text-sm text-muted-foreground">
-							No reminders in the current feed.
-						</div>
-					)}
-
-					{reminders.map((reminder) => {
-						const deleteScope = getDeleteScope(reminder)
-						return (
-							<ReminderRow
-								key={reminderKey(reminder)}
-								reminder={reminder}
-								busy={busy}
-								deleteScope={deleteScope}
-								onDeleteScopeChange={(scope) => setDeleteScope(reminder, scope)}
-								onEdit={() => startEdit(reminder)}
-								onComplete={() =>
-									runAction(
-										reminder.completedAt ? "uncomplete-reminder" : "complete-reminder",
-										{
-											reminderId: reminder.reminderId,
-											occurrenceDueAt: reminder.originalDueAt,
-										},
-										reminder.completedAt ? "Reminder reopened" : "Reminder completed",
-									)
-								}
-								onDelete={() => {
-									if (
-										!confirm(
-											`Delete ${formatScope(deleteScope).toLowerCase()} for "${reminder.title}"?`,
-										)
-									) {
-										return
-									}
-									void runAction(
-										"delete-reminder",
-										{
-											reminderId: reminder.reminderId,
-											scope: deleteScope,
-											occurrenceDueAt: reminder.originalDueAt,
-										},
-										"Reminder deleted",
-									).then((deleted) => {
-										if (deleted && editing?.reminderId === reminder.reminderId) resetForm()
-									})
-								}}
-							/>
-						)
-					})}
-				</div>
-			</CardContent>
-		</Card>
-	)
-}
-
-function ReminderRow({
-	reminder,
-	busy,
-	deleteScope,
-	onDeleteScopeChange,
-	onEdit,
-	onComplete,
-	onDelete,
-}: {
-	reminder: ReminderFeedData
-	busy: boolean
-	deleteScope: ReminderEditScope
-	onDeleteScopeChange: (scope: ReminderEditScope) => void
-	onEdit: () => void
-	onComplete: () => void
-	onDelete: () => void
-}) {
-	return (
-		<div className="flex items-start justify-between gap-3 rounded-md border px-3 py-2">
-			<div className="min-w-0 space-y-1">
-				<div className="flex flex-wrap items-center gap-2">
-					<span className="truncate text-sm font-medium">{reminder.title}</span>
-					<Badge variant={reminder.completedAt ? "secondary" : "outline"} className="text-xs">
-						{reminder.completedAt ? "Done" : reminder.priority}
-					</Badge>
-					{reminder.recurrence && (
-						<Badge variant="secondary" className="text-xs">
-							{formatRecurrence(reminder.recurrence)}
-						</Badge>
-					)}
-				</div>
-				<div className="text-xs text-muted-foreground">{formatDate(reminder.dueAt)}</div>
-				{reminder.notes && <div className="text-xs text-muted-foreground">{reminder.notes}</div>}
-			</div>
-			<div className="flex shrink-0 flex-wrap items-center justify-end gap-1">
-				{reminder.recurrence && (
-					<Select
-						value={deleteScope}
-						onValueChange={(value) => onDeleteScopeChange(value as ReminderEditScope)}
-						disabled={busy}
-					>
-						<SelectTrigger className="h-8 w-[86px] text-xs">
-							<SelectValue />
-						</SelectTrigger>
-						<SelectContent>
-							<SelectItem value="this-occurrence">This</SelectItem>
-							<SelectItem value="this-and-future">Future</SelectItem>
-							<SelectItem value="entire-series">All</SelectItem>
-						</SelectContent>
-					</Select>
-				)}
-				<Button size="sm" variant="ghost" onClick={onComplete} disabled={busy}>
-					{reminder.completedAt ? (
-						<RotateCcw className="size-3.5" />
-					) : (
-						<Check className="size-3.5" />
-					)}
-				</Button>
-				<Button size="sm" variant="ghost" onClick={onEdit} disabled={busy}>
-					<Pencil className="size-3.5" />
-				</Button>
-				<Button size="sm" variant="ghost" onClick={onDelete} disabled={busy}>
-					<Trash2 className="size-3.5 text-destructive" />
-				</Button>
-			</div>
-		</div>
-	)
-}
-
-function formToCreatePayload(form: ReminderFormState): Record<string, unknown> {
-	return {
-		title: form.title.trim(),
-		notes: form.notes.trim() || null,
-		dueAt: toIsoString(form.dueAt),
-		timeZone: localTimeZone(),
-		priority: form.priority,
-		recurrence: recurrenceValueFromForm(form),
-	}
-}
-
-function formToPatch(initial: ReminderFormState, form: ReminderFormState): Record<string, unknown> {
-	const patch: Record<string, unknown> = {}
-	const title = form.title.trim()
-	const notes = form.notes.trim() || null
-	const initialNotes = initial.notes.trim() || null
-
-	if (title !== initial.title.trim()) patch.title = title
-	if (notes !== initialNotes) patch.notes = notes
-	if (form.dueAt !== initial.dueAt) {
-		patch.dueAt = toIsoString(form.dueAt)
-		patch.timeZone = localTimeZone()
-	}
-	if (form.priority !== initial.priority) patch.priority = form.priority
-	if (form.scope !== "this-occurrence" && recurrenceChanged(initial, form)) {
-		patch.recurrence = recurrenceValueFromForm(form)
-	}
-
-	return patch
-}
-
-function recurrenceValueFromForm(form: ReminderFormState): ReminderRecurrence | null {
-	return form.recurs ? recurrenceFromForm(form) : null
-}
-
-function recurrenceFromForm(form: ReminderFormState): ReminderRecurrence {
-	const recurrence: ReminderRecurrence = {
-		frequency: form.frequency,
-		interval: Math.max(1, Number(form.interval) || 1),
-	}
-
-	const count = Number(form.count)
-	if (Number.isInteger(count) && count > 0) recurrence.count = count
-	if (form.until) recurrence.until = toIsoString(form.until)
-
-	return recurrence
-}
-
-function formFromReminder(reminder: ReminderFeedData): ReminderFormState {
-	return {
-		title: reminder.title,
-		notes: reminder.notes ?? "",
-		dueAt: toLocalInput(new Date(reminder.dueAt)),
-		priority: reminder.priority,
-		scope: reminder.recurrence ? "this-occurrence" : "entire-series",
-		recurs: reminder.recurrence !== null,
-		frequency: reminder.recurrence?.frequency ?? "daily",
-		interval: String(reminder.recurrence?.interval ?? 1),
-		count: reminder.recurrence?.count ? String(reminder.recurrence.count) : "",
-		until: reminder.recurrence?.until ? toLocalInput(new Date(reminder.recurrence.until)) : "",
-	}
-}
-
-function setFormField<TKey extends keyof ReminderFormState>(
-	setForm: Dispatch<SetStateAction<ReminderFormState>>,
-	key: TKey,
-	value: ReminderFormState[TKey],
-) {
-	setForm((prev) => ({ ...prev, [key]: value }))
-}
-
-function recurrenceChanged(initial: ReminderFormState, form: ReminderFormState): boolean {
-	return (
-		JSON.stringify(recurrenceValueFromForm(initial)) !==
-		JSON.stringify(recurrenceValueFromForm(form))
-	)
-}
-
-function reminderKey(reminder: ReminderFeedData): string {
-	return `${reminder.reminderId}:${reminder.occurrenceId}`
-}
-
-function isReminderItem(item: FeedItem): item is FeedItem & { data: ReminderFeedData } {
-	return (
-		item.sourceId === REMINDER_SOURCE_ID &&
-		typeof item.data.reminderId === "string" &&
-		typeof item.data.occurrenceId === "string" &&
-		typeof item.data.title === "string" &&
-		typeof item.data.originalDueAt === "string" &&
-		typeof item.data.dueAt === "string"
-	)
-}
-
-function toLocalInput(date: Date): string {
-	const offsetMs = date.getTimezoneOffset() * 60 * 1000
-	return new Date(date.getTime() - offsetMs).toISOString().slice(0, 16)
-}
-
-function toIsoString(value: string): string {
-	return new Date(value).toISOString()
-}
-
-function localTimeZone(): string {
-	return Intl.DateTimeFormat().resolvedOptions().timeZone
-}
-
-function formatDate(value: string): string {
-	return new Date(value).toLocaleString(undefined, {
-		month: "short",
-		day: "numeric",
-		hour: "numeric",
-		minute: "2-digit",
-	})
-}
-
-function formatRecurrence(recurrence: ReminderRecurrence): string {
-	return recurrence.interval === 1
-		? recurrence.frequency
-		: `${recurrence.frequency} / ${recurrence.interval}`
-}
-
-function formatScope(scope: ReminderEditScope): string {
-	switch (scope) {
-		case "this-occurrence":
-			return "this occurrence"
-		case "this-and-future":
-			return "this and future"
-		case "entire-series":
-			return "entire series"
-	}
-}

apps/admin-dashboard/src/components/source-config-panel.tsx

@@ -5,7 +5,6 @@ import { toast } from "sonner"
 
 import type { ConfigFieldDef, SourceDefinition } from "@/lib/api"
 
-import { ReminderCrudPanel } from "@/components/reminder-crud-panel"
 import { Badge } from "@/components/ui/badge"
 import { Button } from "@/components/ui/button"
 import { Card, CardContent, CardDescription, CardHeader, CardTitle } from "@/components/ui/card"
@@ -67,20 +66,6 @@ export function SourceConfigPanel({ source, onUpdate }: SourceConfigPanelProps)
 		return creds
 	}
 
-	function hasUserConfigFields(): boolean {
-		return Object.values(source.fields).some((field) => !isCredentialField(field))
-	}
-
-	function buildReplaceBody(enabledValue: boolean): Parameters<typeof replaceSource>[1] {
-		const body: Parameters<typeof replaceSource>[1] = { enabled: enabledValue }
-
-		if (hasUserConfigFields()) {
-			body.config = getUserConfig()
-		}
-
-		return body
-	}
-
 	function invalidate() {
 		queryClient.invalidateQueries({ queryKey: ["sourceConfig", source.id] })
 		queryClient.invalidateQueries({ queryKey: ["configs"] })
@@ -94,7 +79,10 @@ export function SourceConfigPanel({ source, onUpdate }: SourceConfigPanelProps)
 				(v) => typeof v === "string" && v.length > 0,
 			)
 
-			const body = buildReplaceBody(enabled)
+			const body: Parameters<typeof replaceSource>[1] = {
+				enabled,
+				config: getUserConfig(),
+			}
 			if (hasCredentials && source.perUserCredentials) {
 				body.credentials = credentialFields
 			}
@@ -116,7 +104,8 @@ export function SourceConfigPanel({ source, onUpdate }: SourceConfigPanelProps)
 	})
 
 	const toggleMutation = useMutation({
-		mutationFn: (checked: boolean) => replaceSource(source.id, buildReplaceBody(checked)),
+		mutationFn: (checked: boolean) =>
+			replaceSource(source.id, { enabled: checked, config: getUserConfig() }),
 		onSuccess(_data, checked) {
 			invalidate()
 			toast.success(`Source ${checked ? "enabled" : "disabled"}`)
@@ -127,7 +116,7 @@ export function SourceConfigPanel({ source, onUpdate }: SourceConfigPanelProps)
 	})
 
 	const deleteMutation = useMutation({
-		mutationFn: () => replaceSource(source.id, buildReplaceBody(false)),
+		mutationFn: () => replaceSource(source.id, { enabled: false, config: {} }),
 		onSuccess() {
 			setDirty({})
 			invalidate()
@@ -258,7 +247,7 @@ export function SourceConfigPanel({ source, onUpdate }: SourceConfigPanelProps)
 			)}
 
 			{/* Always-on sources */}
-			{source.alwaysEnabled && source.id !== "freya.location" && (
+			{source.alwaysEnabled && source.id !== "aelis.location" && (
 				<>
 					<Separator />
 					<p className="text-sm text-muted-foreground">
@@ -267,9 +256,7 @@ export function SourceConfigPanel({ source, onUpdate }: SourceConfigPanelProps)
 				</>
 			)}
 
-			{source.id === "freya.location" && <LocationCard />}
+			{source.id === "aelis.location" && <LocationCard />}
-
-			{source.id === "freya.reminders" && enabled && <ReminderCrudPanel />}
 		</div>
 	)
 }
@@ -480,17 +467,6 @@ function FieldInput({
 		)
 	}
 
-	if (field.type === "boolean") {
-		return (
-			<div className="flex items-center justify-between gap-3 rounded-md border px-3 py-2">
-				<Label htmlFor={name} className="text-xs font-medium">
-					{labelContent}
-				</Label>
-				<Switch id={name} checked={value === true} onCheckedChange={onChange} disabled={disabled} />
-			</div>
-		)
-	}
-
 	return (
 		<div className="space-y-2">
 			<Label htmlFor={name} className="text-xs font-medium">
@@ -518,8 +494,6 @@ function buildInitialValues(
 			values[name] = saved[name]
 		} else if (field.defaultValue !== undefined) {
 			values[name] = field.defaultValue
-		} else if (field.type === "boolean") {
-			values[name] = false
 		} else if (field.type === "multiselect") {
 			values[name] = []
 		} else {

apps/admin-dashboard/src/lib/api.ts

@@ -9,12 +9,12 @@ function serverBase() {
 }
 
 export interface ConfigFieldDef {
-	type: "string" | "number" | "select" | "multiselect" | "boolean"
+	type: "string" | "number" | "select" | "multiselect"
 	label: string
 	required?: boolean
 	description?: string
 	secret?: boolean
-	defaultValue?: string | number | string[] | boolean
+	defaultValue?: string | number | string[]
 	options?: { label: string; value: string }[]
 }
 
@@ -36,14 +36,14 @@ export interface SourceConfig {
 
 const sourceDefinitions: SourceDefinition[] = [
 	{
-		id: "freya.location",
+		id: "aelis.location",
 		name: "Location",
 		description: "Device location provider. Always enabled as a dependency for other sources.",
 		alwaysEnabled: true,
 		fields: {},
 	},
 	{
-		id: "freya.weather",
+		id: "aelis.weather",
 		name: "WeatherKit",
 		description: "Apple WeatherKit weather data. Requires Apple Developer credentials.",
 		fields: {
@@ -81,7 +81,7 @@ const sourceDefinitions: SourceDefinition[] = [
 		},
 	},
 	{
-		id: "freya.caldav",
+		id: "aelis.caldav",
 		name: "CalDAV",
 		description: "Calendar events from any CalDAV server (Nextcloud, Radicale, Baikal, etc.).",
 		perUserCredentials: true,
@@ -119,7 +119,7 @@ const sourceDefinitions: SourceDefinition[] = [
 		},
 	},
 	{
-		id: "freya.tfl",
+		id: "aelis.tfl",
 		name: "TfL",
 		description: "Transport for London tube line status alerts.",
 		fields: {
@@ -151,49 +151,6 @@ const sourceDefinitions: SourceDefinition[] = [
 			},
 		},
 	},
-	{
-		id: "freya.reminders",
-		name: "Reminders",
-		description: "One-off and recurring reminders in the contextual feed.",
-		fields: {
-			lookAheadMs: {
-				type: "number",
-				label: "Look-ahead Milliseconds",
-				defaultValue: 24 * 60 * 60 * 1000,
-				description: "How far into the future reminders should appear in the feed.",
-			},
-			lookBackMs: {
-				type: "number",
-				label: "Look-back Milliseconds",
-				defaultValue: 24 * 60 * 60 * 1000,
-				description: "How far into the past due reminders should remain visible.",
-			},
-			includeCompleted: {
-				type: "boolean",
-				label: "Include Completed",
-				defaultValue: false,
-				description: "Show completed reminder occurrences in the feed.",
-			},
-			defaultTimeZone: {
-				type: "string",
-				label: "Default Timezone",
-				defaultValue: "UTC",
-				description: "IANA timezone used when new reminders omit a timezone.",
-			},
-		},
-	},
-	{
-		id: "freya.web-search",
-		name: "Web Search",
-		description: "Exa web search action. Requires EXA_API_KEY on the backend.",
-		fields: {},
-	},
-	{
-		id: "freya.google-maps",
-		name: "Google Maps",
-		description: "Google Maps Grounding Lite MCP tools for places, weather, routes, and Place IDs.",
-		fields: {},
-	},
 ]
 
 export function fetchSources(): Promise<SourceDefinition[]> {
@@ -217,7 +174,7 @@ export async function fetchConfigs(): Promise<SourceConfig[]> {
 
 export async function replaceSource(
 	sourceId: string,
-	body: { enabled: boolean; config?: unknown; credentials?: Record<string, unknown> },
+	body: { enabled: boolean; config: unknown; credentials?: Record<string, unknown> },
 ): Promise<void> {
 	const res = await fetch(`${serverBase()}/sources/${sourceId}`, {
 		method: "PUT",
@@ -263,25 +220,6 @@ export async function updateSourceCredentials(
 	}
 }
 
-export async function executeSourceAction(
-	sourceId: string,
-	actionId: string,
-	params: unknown,
-): Promise<unknown> {
-	const res = await fetch(`${serverBase()}/sources/${sourceId}/actions/${actionId}`, {
-		method: "POST",
-		headers: { "Content-Type": "application/json" },
-		credentials: "include",
-		body: JSON.stringify(params),
-	})
-	if (!res.ok) {
-		const data = (await res.json()) as { error?: string }
-		throw new Error(data.error ?? `Failed to execute source action: ${res.status}`)
-	}
-	const data = (await res.json()) as { result: unknown }
-	return data.result
-}
-
 export interface LocationInput {
 	lat: number
 	lng: number

apps/admin-dashboard/src/lib/server-url.ts

@@ -1,4 +1,4 @@
-const STORAGE_KEY = "freya-server-url"
+const STORAGE_KEY = "aelis-server-url"
 const DEFAULT_URL = "https://3000--019cf276-6ed6-7529-a425-210182693908.eu-runner.flex.doptig.cloud"
 
 export function getServerUrl(): string {

apps/admin-dashboard/src/routes/_dashboard.tsx

@@ -8,7 +8,6 @@ import {
 	Link,
 } from "@tanstack/react-router"
 import {
-	Bell,
 	Calendar,
 	CalendarDays,
 	CircleDot,
@@ -16,7 +15,6 @@ import {
 	Loader2,
 	TrainFront,
 	LogOut,
-	Map as MapIcon,
 	MapPin,
 	Rss,
 	Server,
@@ -47,13 +45,11 @@ import { getSession, signOut } from "@/lib/auth"
 import { Route as rootRoute } from "./__root"
 
 const SOURCE_ICONS: Record<string, React.ComponentType<{ className?: string }>> = {
-	"freya.location": MapPin,
+	"aelis.location": MapPin,
-	"freya.weather": CloudSun,
+	"aelis.weather": CloudSun,
-	"freya.caldav": CalendarDays,
+	"aelis.caldav": CalendarDays,
-	"freya.google-calendar": Calendar,
+	"aelis.google-calendar": Calendar,
-	"freya.google-maps": MapIcon,
+	"aelis.tfl": TrainFront,
-	"freya.reminders": Bell,
-	"freya.tfl": TrainFront,
 }
 
 export const Route = createRoute({

apps/admin-dashboard/vite.config.ts

@@ -12,7 +12,6 @@ export default defineConfig({
 		},
 	},
 	server: {
-		host: "0.0.0.0",
 		port: 5174,
 		allowedHosts: true,
 	},

apps/aelis-backend/.env.example

@@ -12,6 +12,8 @@ BETTER_AUTH_URL=http://localhost:3000
 
 # OpenRouter (LLM feed enhancement)
 OPENROUTER_API_KEY=
+# Optional: override the default model (default: openai/gpt-4.1-mini)
+# OPENROUTER_MODEL=openai/gpt-4.1-mini
 
 # Apple WeatherKit credentials
 WEATHERKIT_PRIVATE_KEY=

apps/aelis-backend/drizzle/0000_wakeful_scorpion.sql

@@ -49,33 +49,6 @@ CREATE TABLE "user_sources" (
 	CONSTRAINT "user_sources_user_id_source_id_unique" UNIQUE("user_id","source_id")
 );
 --> statement-breakpoint
-CREATE TABLE "reminders" (
-	"id" uuid PRIMARY KEY DEFAULT gen_random_uuid() NOT NULL,
-	"user_id" text NOT NULL,
-	"title" text NOT NULL,
-	"notes" text,
-	"due_at" timestamp NOT NULL,
-	"time_zone" text DEFAULT 'UTC' NOT NULL,
-	"recurrence" jsonb,
-	"priority" text DEFAULT 'normal' NOT NULL,
-	"created_at" timestamp DEFAULT now() NOT NULL,
-	"updated_at" timestamp DEFAULT now() NOT NULL
-);
---> statement-breakpoint
-CREATE TABLE "reminder_occurrence_overrides" (
-	"id" uuid PRIMARY KEY DEFAULT gen_random_uuid() NOT NULL,
-	"user_id" text NOT NULL,
-	"reminder_id" uuid NOT NULL,
-	"occurrence_id" text NOT NULL,
-	"original_due_at" timestamp NOT NULL,
-	"patch" jsonb,
-	"completed_at" timestamp,
-	"deleted_at" timestamp,
-	"created_at" timestamp DEFAULT now() NOT NULL,
-	"updated_at" timestamp DEFAULT now() NOT NULL,
-	CONSTRAINT "reminder_occurrence_overrides_reminder_id_occurrence_id_unique" UNIQUE("reminder_id","occurrence_id")
-);
---> statement-breakpoint
 CREATE TABLE "verification" (
 	"id" text PRIMARY KEY NOT NULL,
 	"identifier" text NOT NULL,
@@ -88,13 +61,6 @@ CREATE TABLE "verification" (
 ALTER TABLE "account" ADD CONSTRAINT "account_user_id_user_id_fk" FOREIGN KEY ("user_id") REFERENCES "public"."user"("id") ON DELETE cascade ON UPDATE no action;--> statement-breakpoint
 ALTER TABLE "session" ADD CONSTRAINT "session_user_id_user_id_fk" FOREIGN KEY ("user_id") REFERENCES "public"."user"("id") ON DELETE cascade ON UPDATE no action;--> statement-breakpoint
 ALTER TABLE "user_sources" ADD CONSTRAINT "user_sources_user_id_user_id_fk" FOREIGN KEY ("user_id") REFERENCES "public"."user"("id") ON DELETE cascade ON UPDATE no action;--> statement-breakpoint
-ALTER TABLE "reminders" ADD CONSTRAINT "reminders_user_id_user_id_fk" FOREIGN KEY ("user_id") REFERENCES "public"."user"("id") ON DELETE cascade ON UPDATE no action;--> statement-breakpoint
-ALTER TABLE "reminder_occurrence_overrides" ADD CONSTRAINT "reminder_occurrence_overrides_user_id_user_id_fk" FOREIGN KEY ("user_id") REFERENCES "public"."user"("id") ON DELETE cascade ON UPDATE no action;--> statement-breakpoint
-ALTER TABLE "reminder_occurrence_overrides" ADD CONSTRAINT "reminder_occurrence_overrides_reminder_id_reminders_id_fk" FOREIGN KEY ("reminder_id") REFERENCES "public"."reminders"("id") ON DELETE cascade ON UPDATE no action;--> statement-breakpoint
 CREATE INDEX "account_userId_idx" ON "account" USING btree ("user_id");--> statement-breakpoint
 CREATE INDEX "session_userId_idx" ON "session" USING btree ("user_id");--> statement-breakpoint
-CREATE INDEX "reminders_user_id_due_at_idx" ON "reminders" USING btree ("user_id","due_at");--> statement-breakpoint
-CREATE INDEX "reminders_user_id_updated_at_idx" ON "reminders" USING btree ("user_id","updated_at");--> statement-breakpoint
-CREATE INDEX "reminder_occurrence_overrides_user_id_reminder_id_idx" ON "reminder_occurrence_overrides" USING btree ("user_id","reminder_id");--> statement-breakpoint
-CREATE INDEX "reminder_occurrence_overrides_user_id_original_due_at_idx" ON "reminder_occurrence_overrides" USING btree ("user_id","original_due_at");--> statement-breakpoint
 CREATE INDEX "verification_identifier_idx" ON "verification" USING btree ("identifier");

apps/aelis-backend/drizzle/0001_misty_white_tiger.sql

@@ -0,0 +1 @@
+CREATE INDEX "user_sources_user_id_enabled_idx" ON "user_sources" USING btree ("user_id","enabled");

apps/aelis-backend/drizzle/meta/0000_snapshot.json

@@ -0,0 +1,457 @@
+{
+  "id": "d8c59ec7-b686-41a7-a472-da29f3ab6727",
+  "prevId": "00000000-0000-0000-0000-000000000000",
+  "version": "7",
+  "dialect": "postgresql",
+  "tables": {
+    "public.account": {
+      "name": "account",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "account_id": {
+          "name": "account_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "provider_id": {
+          "name": "provider_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "user_id": {
+          "name": "user_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "access_token": {
+          "name": "access_token",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "refresh_token": {
+          "name": "refresh_token",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "id_token": {
+          "name": "id_token",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "access_token_expires_at": {
+          "name": "access_token_expires_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "refresh_token_expires_at": {
+          "name": "refresh_token_expires_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "scope": {
+          "name": "scope",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "password": {
+          "name": "password",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "updated_at": {
+          "name": "updated_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": true
+        }
+      },
+      "indexes": {
+        "account_userId_idx": {
+          "name": "account_userId_idx",
+          "columns": [
+            {
+              "expression": "user_id",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        }
+      },
+      "foreignKeys": {
+        "account_user_id_user_id_fk": {
+          "name": "account_user_id_user_id_fk",
+          "tableFrom": "account",
+          "tableTo": "user",
+          "columnsFrom": [
+            "user_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.session": {
+      "name": "session",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "expires_at": {
+          "name": "expires_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "token": {
+          "name": "token",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "updated_at": {
+          "name": "updated_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "ip_address": {
+          "name": "ip_address",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "user_agent": {
+          "name": "user_agent",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "user_id": {
+          "name": "user_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        }
+      },
+      "indexes": {
+        "session_userId_idx": {
+          "name": "session_userId_idx",
+          "columns": [
+            {
+              "expression": "user_id",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        }
+      },
+      "foreignKeys": {
+        "session_user_id_user_id_fk": {
+          "name": "session_user_id_user_id_fk",
+          "tableFrom": "session",
+          "tableTo": "user",
+          "columnsFrom": [
+            "user_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {
+        "session_token_unique": {
+          "name": "session_token_unique",
+          "nullsNotDistinct": false,
+          "columns": [
+            "token"
+          ]
+        }
+      },
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.user": {
+      "name": "user",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "name": {
+          "name": "name",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "email": {
+          "name": "email",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "email_verified": {
+          "name": "email_verified",
+          "type": "boolean",
+          "primaryKey": false,
+          "notNull": true,
+          "default": false
+        },
+        "image": {
+          "name": "image",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "updated_at": {
+          "name": "updated_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": true
+        }
+      },
+      "indexes": {},
+      "foreignKeys": {},
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {
+        "user_email_unique": {
+          "name": "user_email_unique",
+          "nullsNotDistinct": false,
+          "columns": [
+            "email"
+          ]
+        }
+      },
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.user_sources": {
+      "name": "user_sources",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "uuid",
+          "primaryKey": true,
+          "notNull": true,
+          "default": "gen_random_uuid()"
+        },
+        "user_id": {
+          "name": "user_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "source_id": {
+          "name": "source_id",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "enabled": {
+          "name": "enabled",
+          "type": "boolean",
+          "primaryKey": false,
+          "notNull": true,
+          "default": true
+        },
+        "config": {
+          "name": "config",
+          "type": "jsonb",
+          "primaryKey": false,
+          "notNull": false,
+          "default": "'{}'::jsonb"
+        },
+        "credentials": {
+          "name": "credentials",
+          "type": "bytea",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "updated_at": {
+          "name": "updated_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        }
+      },
+      "indexes": {},
+      "foreignKeys": {
+        "user_sources_user_id_user_id_fk": {
+          "name": "user_sources_user_id_user_id_fk",
+          "tableFrom": "user_sources",
+          "tableTo": "user",
+          "columnsFrom": [
+            "user_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {
+        "user_sources_user_id_source_id_unique": {
+          "name": "user_sources_user_id_source_id_unique",
+          "nullsNotDistinct": false,
+          "columns": [
+            "user_id",
+            "source_id"
+          ]
+        }
+      },
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.verification": {
+      "name": "verification",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "text",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "identifier": {
+          "name": "identifier",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "value": {
+          "name": "value",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "expires_at": {
+          "name": "expires_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "created_at": {
+          "name": "created_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "updated_at": {
+          "name": "updated_at",
+          "type": "timestamp",
+          "primaryKey": false,
+          "notNull": true
+        }
+      },
+      "indexes": {
+        "verification_identifier_idx": {
+          "name": "verification_identifier_idx",
+          "columns": [
+            {
+              "expression": "identifier",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        }
+      },
+      "foreignKeys": {},
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    }
+  },
+  "enums": {},
+  "schemas": {},
+  "sequences": {},
+  "roles": {},
+  "policies": {},
+  "views": {},
+  "_meta": {
+    "columns": {},
+    "schemas": {},
+    "tables": {}
+  }
+}

apps/aelis-backend/drizzle/meta/0001_snapshot.json

@@ -1,6 +1,6 @@
 {
-  "id": "d8c59ec7-b686-41a7-a472-da29f3ab6727",
+  "id": "d963322c-77e2-4ac9-bd3c-ca544c85ae35",
-  "prevId": "00000000-0000-0000-0000-000000000000",
+  "prevId": "d8c59ec7-b686-41a7-a472-da29f3ab6727",
   "version": "7",
   "dialect": "postgresql",
   "tables": {
@@ -346,7 +346,29 @@
           "default": "now()"
         }
       },
-      "indexes": {},
+      "indexes": {
+        "user_sources_user_id_enabled_idx": {
+          "name": "user_sources_user_id_enabled_idx",
+          "columns": [
+            {
+              "expression": "user_id",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            },
+            {
+              "expression": "enabled",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        }
+      },
       "foreignKeys": {
         "user_sources_user_id_user_id_fk": {
           "name": "user_sources_user_id_user_id_fk",
@@ -441,296 +463,6 @@
       "policies": {},
       "checkConstraints": {},
       "isRLSEnabled": false
-    },
-    "public.reminders": {
-      "name": "reminders",
-      "schema": "",
-      "columns": {
-        "id": {
-          "name": "id",
-          "type": "uuid",
-          "primaryKey": true,
-          "notNull": true,
-          "default": "gen_random_uuid()"
-        },
-        "user_id": {
-          "name": "user_id",
-          "type": "text",
-          "primaryKey": false,
-          "notNull": true
-        },
-        "title": {
-          "name": "title",
-          "type": "text",
-          "primaryKey": false,
-          "notNull": true
-        },
-        "notes": {
-          "name": "notes",
-          "type": "text",
-          "primaryKey": false,
-          "notNull": false
-        },
-        "due_at": {
-          "name": "due_at",
-          "type": "timestamp",
-          "primaryKey": false,
-          "notNull": true
-        },
-        "time_zone": {
-          "name": "time_zone",
-          "type": "text",
-          "primaryKey": false,
-          "notNull": true,
-          "default": "'UTC'"
-        },
-        "recurrence": {
-          "name": "recurrence",
-          "type": "jsonb",
-          "primaryKey": false,
-          "notNull": false
-        },
-        "priority": {
-          "name": "priority",
-          "type": "text",
-          "primaryKey": false,
-          "notNull": true,
-          "default": "'normal'"
-        },
-        "created_at": {
-          "name": "created_at",
-          "type": "timestamp",
-          "primaryKey": false,
-          "notNull": true,
-          "default": "now()"
-        },
-        "updated_at": {
-          "name": "updated_at",
-          "type": "timestamp",
-          "primaryKey": false,
-          "notNull": true,
-          "default": "now()"
-        }
-      },
-      "indexes": {
-        "reminders_user_id_due_at_idx": {
-          "name": "reminders_user_id_due_at_idx",
-          "columns": [
-            {
-              "expression": "user_id",
-              "isExpression": false,
-              "asc": true,
-              "nulls": "last"
-            },
-            {
-              "expression": "due_at",
-              "isExpression": false,
-              "asc": true,
-              "nulls": "last"
-            }
-          ],
-          "isUnique": false,
-          "concurrently": false,
-          "method": "btree",
-          "with": {}
-        },
-        "reminders_user_id_updated_at_idx": {
-          "name": "reminders_user_id_updated_at_idx",
-          "columns": [
-            {
-              "expression": "user_id",
-              "isExpression": false,
-              "asc": true,
-              "nulls": "last"
-            },
-            {
-              "expression": "updated_at",
-              "isExpression": false,
-              "asc": true,
-              "nulls": "last"
-            }
-          ],
-          "isUnique": false,
-          "concurrently": false,
-          "method": "btree",
-          "with": {}
-        }
-      },
-      "foreignKeys": {
-        "reminders_user_id_user_id_fk": {
-          "name": "reminders_user_id_user_id_fk",
-          "tableFrom": "reminders",
-          "tableTo": "user",
-          "columnsFrom": [
-            "user_id"
-          ],
-          "columnsTo": [
-            "id"
-          ],
-          "onDelete": "cascade",
-          "onUpdate": "no action"
-        }
-      },
-      "compositePrimaryKeys": {},
-      "uniqueConstraints": {},
-      "policies": {},
-      "checkConstraints": {},
-      "isRLSEnabled": false
-    },
-    "public.reminder_occurrence_overrides": {
-      "name": "reminder_occurrence_overrides",
-      "schema": "",
-      "columns": {
-        "id": {
-          "name": "id",
-          "type": "uuid",
-          "primaryKey": true,
-          "notNull": true,
-          "default": "gen_random_uuid()"
-        },
-        "user_id": {
-          "name": "user_id",
-          "type": "text",
-          "primaryKey": false,
-          "notNull": true
-        },
-        "reminder_id": {
-          "name": "reminder_id",
-          "type": "uuid",
-          "primaryKey": false,
-          "notNull": true
-        },
-        "occurrence_id": {
-          "name": "occurrence_id",
-          "type": "text",
-          "primaryKey": false,
-          "notNull": true
-        },
-        "original_due_at": {
-          "name": "original_due_at",
-          "type": "timestamp",
-          "primaryKey": false,
-          "notNull": true
-        },
-        "patch": {
-          "name": "patch",
-          "type": "jsonb",
-          "primaryKey": false,
-          "notNull": false
-        },
-        "completed_at": {
-          "name": "completed_at",
-          "type": "timestamp",
-          "primaryKey": false,
-          "notNull": false
-        },
-        "deleted_at": {
-          "name": "deleted_at",
-          "type": "timestamp",
-          "primaryKey": false,
-          "notNull": false
-        },
-        "created_at": {
-          "name": "created_at",
-          "type": "timestamp",
-          "primaryKey": false,
-          "notNull": true,
-          "default": "now()"
-        },
-        "updated_at": {
-          "name": "updated_at",
-          "type": "timestamp",
-          "primaryKey": false,
-          "notNull": true,
-          "default": "now()"
-        }
-      },
-      "indexes": {
-        "reminder_occurrence_overrides_user_id_reminder_id_idx": {
-          "name": "reminder_occurrence_overrides_user_id_reminder_id_idx",
-          "columns": [
-            {
-              "expression": "user_id",
-              "isExpression": false,
-              "asc": true,
-              "nulls": "last"
-            },
-            {
-              "expression": "reminder_id",
-              "isExpression": false,
-              "asc": true,
-              "nulls": "last"
-            }
-          ],
-          "isUnique": false,
-          "concurrently": false,
-          "method": "btree",
-          "with": {}
-        },
-        "reminder_occurrence_overrides_user_id_original_due_at_idx": {
-          "name": "reminder_occurrence_overrides_user_id_original_due_at_idx",
-          "columns": [
-            {
-              "expression": "user_id",
-              "isExpression": false,
-              "asc": true,
-              "nulls": "last"
-            },
-            {
-              "expression": "original_due_at",
-              "isExpression": false,
-              "asc": true,
-              "nulls": "last"
-            }
-          ],
-          "isUnique": false,
-          "concurrently": false,
-          "method": "btree",
-          "with": {}
-        }
-      },
-      "foreignKeys": {
-        "reminder_occurrence_overrides_user_id_user_id_fk": {
-          "name": "reminder_occurrence_overrides_user_id_user_id_fk",
-          "tableFrom": "reminder_occurrence_overrides",
-          "tableTo": "user",
-          "columnsFrom": [
-            "user_id"
-          ],
-          "columnsTo": [
-            "id"
-          ],
-          "onDelete": "cascade",
-          "onUpdate": "no action"
-        },
-        "reminder_occurrence_overrides_reminder_id_reminders_id_fk": {
-          "name": "reminder_occurrence_overrides_reminder_id_reminders_id_fk",
-          "tableFrom": "reminder_occurrence_overrides",
-          "tableTo": "reminders",
-          "columnsFrom": [
-            "reminder_id"
-          ],
-          "columnsTo": [
-            "id"
-          ],
-          "onDelete": "cascade",
-          "onUpdate": "no action"
-        }
-      },
-      "compositePrimaryKeys": {},
-      "uniqueConstraints": {
-        "reminder_occurrence_overrides_reminder_id_occurrence_id_unique": {
-          "name": "reminder_occurrence_overrides_reminder_id_occurrence_id_unique",
-          "nullsNotDistinct": false,
-          "columns": [
-            "reminder_id",
-            "occurrence_id"
-          ]
-        }
-      },
-      "policies": {},
-      "checkConstraints": {},
-      "isRLSEnabled": false
     }
   },
   "enums": {},

apps/aelis-backend/package.json

@@ -1,5 +1,5 @@
 {
-	"name": "@freya/backend",
+	"name": "@aelis/backend",
 	"version": "0.0.0",
 	"type": "module",
 	"main": "src/server.ts",
@@ -15,25 +15,18 @@
 		"create-admin": "bun run src/scripts/create-admin.ts"
 	},
 	"dependencies": {
-		"@earendil-works/pi-coding-agent": "^0.79.1",
+		"@aelis/core": "workspace:*",
-		"@freya/agent-protocol": "workspace:*",
+		"@aelis/source-caldav": "workspace:*",
-		"@freya/core": "workspace:*",
+		"@aelis/source-google-calendar": "workspace:*",
-		"@freya/source-caldav": "workspace:*",
+		"@aelis/source-location": "workspace:*",
-		"@freya/source-google-calendar": "workspace:*",
+		"@aelis/source-tfl": "workspace:*",
-		"@freya/source-google-maps": "workspace:*",
+		"@aelis/source-weatherkit": "workspace:*",
-		"@freya/source-location": "workspace:*",
-		"@freya/source-reminders": "workspace:*",
-		"@freya/source-tfl": "workspace:*",
-		"@freya/source-weatherkit": "workspace:*",
-		"@freya/source-web-search": "workspace:*",
-		"@nym.sh/jrpc": "^0.1.0",
 		"@openrouter/sdk": "^0.9.11",
 		"arktype": "^2.1.29",
 		"better-auth": "^1",
 		"drizzle-orm": "^0.45.1",
 		"hono": "^4",
-		"lodash.merge": "^4.6.2",
+		"lodash.merge": "^4.6.2"
-		"typebox": "^1.1.38"
 	},
 	"devDependencies": {
 		"@types/lodash.merge": "^4.6.9",

apps/aelis-backend/src/admin/http.test.ts

@@ -1,4 +1,4 @@
-import type { ActionDefinition, ContextEntry, FeedItem, FeedSource } from "@freya/core"
+import type { ActionDefinition, ContextEntry, FeedItem, FeedSource } from "@aelis/core"
 
 import { describe, expect, mock, test } from "bun:test"
 import { Hono } from "hono"
@@ -44,20 +44,6 @@ mock.module("../sources/user-sources.ts", () => ({
 	}),
 }))
 
-mock.module("../conversations/storage.ts", () => ({
-	conversations: (_db: Database, userId: string) => ({
-		async getOrCreateConversation() {
-			return { id: `conversation-${userId}` }
-		},
-		async listEntries() {
-			return []
-		},
-		async appendEntry() {
-			return { id: "entry-1", sequence: 1 }
-		},
-	}),
-}))
-
 function createStubSource(id: string): FeedSource {
 	return {
 		id,
@@ -132,9 +118,9 @@ const validWeatherConfig = {
 
 describe("PUT /api/admin/:sourceId/config", () => {
 	test("returns 404 for unknown provider", async () => {
-		const { app } = createApp([createStubProvider("freya.location")])
+		const { app } = createApp([createStubProvider("aelis.location")])
 
-		const res = await app.request("/api/admin/freya.nonexistent/config", {
+		const res = await app.request("/api/admin/aelis.nonexistent/config", {
 			method: "PUT",
 			headers: { "Content-Type": "application/json" },
 			body: JSON.stringify({ key: "value" }),
@@ -146,9 +132,9 @@ describe("PUT /api/admin/:sourceId/config", () => {
 	})
 
 	test("returns 404 for provider without runtime config support", async () => {
-		const { app } = createApp([createStubProvider("freya.location")])
+		const { app } = createApp([createStubProvider("aelis.location")])
 
-		const res = await app.request("/api/admin/freya.location/config", {
+		const res = await app.request("/api/admin/aelis.location/config", {
 			method: "PUT",
 			headers: { "Content-Type": "application/json" },
 			body: JSON.stringify({ key: "value" }),
@@ -160,9 +146,9 @@ describe("PUT /api/admin/:sourceId/config", () => {
 	})
 
 	test("returns 400 for invalid JSON body", async () => {
-		const { app } = createApp([createStubProvider("freya.weather")])
+		const { app } = createApp([createStubProvider("aelis.weather")])
 
-		const res = await app.request("/api/admin/freya.weather/config", {
+		const res = await app.request("/api/admin/aelis.weather/config", {
 			method: "PUT",
 			headers: { "Content-Type": "application/json" },
 			body: "not json",
@@ -174,9 +160,9 @@ describe("PUT /api/admin/:sourceId/config", () => {
 	})
 
 	test("returns 400 when weather config fails validation", async () => {
-		const { app } = createApp([createStubProvider("freya.weather")])
+		const { app } = createApp([createStubProvider("aelis.weather")])
 
-		const res = await app.request("/api/admin/freya.weather/config", {
+		const res = await app.request("/api/admin/aelis.weather/config", {
 			method: "PUT",
 			headers: { "Content-Type": "application/json" },
 			body: JSON.stringify({ credentials: { privateKey: 123 } }),
@@ -188,11 +174,11 @@ describe("PUT /api/admin/:sourceId/config", () => {
 	})
 
 	test("returns 204 and applies valid weather config", async () => {
-		const { app, sessionManager } = createApp([createStubProvider("freya.weather")])
+		const { app, sessionManager } = createApp([createStubProvider("aelis.weather")])
 
-		const originalProvider = sessionManager.getProvider("freya.weather")
+		const originalProvider = sessionManager.getProvider("aelis.weather")
 
-		const res = await app.request("/api/admin/freya.weather/config", {
+		const res = await app.request("/api/admin/aelis.weather/config", {
 			method: "PUT",
 			headers: { "Content-Type": "application/json" },
 			body: JSON.stringify(validWeatherConfig),
@@ -201,9 +187,9 @@ describe("PUT /api/admin/:sourceId/config", () => {
 		expect(res.status).toBe(204)
 
 		// Provider was replaced with a new instance
-		const provider = sessionManager.getProvider("freya.weather")
+		const provider = sessionManager.getProvider("aelis.weather")
 		expect(provider).toBeDefined()
-		expect(provider!.sourceId).toBe("freya.weather")
+		expect(provider!.sourceId).toBe("aelis.weather")
 		expect(provider).not.toBe(originalProvider)
 	})
 })

apps/aelis-backend/src/admin/http.ts

@@ -60,7 +60,7 @@ async function handleUpdateProviderConfig(c: Context<Env>) {
 	}
 
 	switch (sourceId) {
-		case "freya.weather": {
+		case "aelis.weather": {
 			const parsed = WeatherKitSourceProviderConfig(body)
 			if (parsed instanceof type.errors) {
 				return c.json({ error: parsed.summary }, 400)

apps/aelis-backend/src/auth/admin-middleware.test.ts

@@ -1,5 +1,5 @@
-import { describe, expect, test } from "bun:test"
 import { Hono } from "hono"
+import { describe, expect, test } from "bun:test"
 
 import type { Auth } from "./index.ts"
 import type { AuthSession, AuthUser } from "./session.ts"

apps/aelis-backend/src/auth/index.ts

@@ -5,7 +5,6 @@ import { admin } from "better-auth/plugins"
 import type { Database } from "../db/index.ts"
 
 import * as schema from "../db/schema.ts"
-import { insertDefaultUserSources } from "../sources/default-sources.ts"
 
 export function createAuth(db: Database) {
 	if (!process.env.BETTER_AUTH_SECRET) {
@@ -23,15 +22,6 @@ export function createAuth(db: Database) {
 		emailAndPassword: {
 			enabled: true,
 		},
-		databaseHooks: {
-			user: {
-				create: {
-					async after(user, _context) {
-						await insertDefaultUserSources(db, user.id)
-					},
-				},
-			},
-		},
 		plugins: [admin()],
 	})
 }

apps/aelis-backend/src/auth/session-middleware.ts

@@ -53,6 +53,16 @@ export function createRequireSession(auth: Auth): AuthSessionMiddleware {
 	}
 }
 
+/**
+ * Creates a function to get session from headers. Useful for WebSocket upgrade validation.
+ */
+export function createGetSessionFromHeaders(auth: Auth) {
+	return async (headers: Headers): Promise<{ user: AuthUser; session: AuthSession } | null> => {
+		const session = await auth.api.getSession({ headers })
+		return session
+	}
+}
+
 /**
  * Dev/test middleware that injects a fake user and session.
  * Pass userId to simulate an authenticated request, or omit to get 401.
@@ -69,7 +79,7 @@ export function mockAuthSessionMiddleware(userId?: string): AuthSessionMiddlewar
 		const user: AuthUser = {
 			id: "k7Gx2mPqRvNwYs9TdLfA4bHcJeUo1iZn",
 			name: "Dev User",
-			email: "dev@freya.local",
+			email: "dev@aelis.local",
 			emailVerified: true,
 			image: null,
 			createdAt: now,
@@ -86,7 +96,7 @@ export function mockAuthSessionMiddleware(userId?: string): AuthSessionMiddlewar
 			token: "Vb9CxNfRm2KwQs7TjPeA5dLhYg0UoZi4",
 			expiresAt,
 			ipAddress: "127.0.0.1",
-			userAgent: "freya-dev",
+			userAgent: "aelis-dev",
 			createdAt: now,
 			updatedAt: now,
 		}

apps/aelis-backend/src/caldav/provider.test.ts

@@ -5,8 +5,8 @@ import { CalDavSourceProvider } from "./provider.ts"
 describe("CalDavSourceProvider", () => {
 	const provider = new CalDavSourceProvider()
 
-	test("sourceId is freya.caldav", () => {
+	test("sourceId is aelis.caldav", () => {
-		expect(provider.sourceId).toBe("freya.caldav")
+		expect(provider.sourceId).toBe("aelis.caldav")
 	})
 
 	test("throws when credentials are null", async () => {
@@ -68,7 +68,7 @@ describe("CalDavSourceProvider", () => {
 
 		const source = await provider.feedSourceForUser("user-1", config, credentials)
 		expect(source).toBeDefined()
-		expect(source.id).toBe("freya.caldav")
+		expect(source.id).toBe("aelis.caldav")
 	})
 
 	test("returns CalDavSource with minimal config", async () => {
@@ -80,6 +80,6 @@ describe("CalDavSourceProvider", () => {
 
 		const source = await provider.feedSourceForUser("user-1", config, credentials)
 		expect(source).toBeDefined()
-		expect(source.id).toBe("freya.caldav")
+		expect(source.id).toBe("aelis.caldav")
 	})
 })

apps/aelis-backend/src/caldav/provider.ts

@@ -1,4 +1,4 @@
-import { CalDavSource } from "@freya/source-caldav"
+import { CalDavSource } from "@aelis/source-caldav"
 import { type } from "arktype"
 
 import type { FeedSourceProvider } from "../session/feed-source-provider.ts"
@@ -19,7 +19,7 @@ const caldavCredentials = type({
 })
 
 export class CalDavSourceProvider implements FeedSourceProvider {
-	readonly sourceId = "freya.caldav"
+	readonly sourceId = "aelis.caldav"
 	readonly configSchema = caldavConfig
 
 	async feedSourceForUser(
@@ -33,12 +33,12 @@ export class CalDavSourceProvider implements FeedSourceProvider {
 		}
 
 		if (!credentials) {
-			throw new InvalidSourceCredentialsError("freya.caldav", "No CalDAV credentials configured")
+			throw new InvalidSourceCredentialsError("aelis.caldav", "No CalDAV credentials configured")
 		}
 
 		const creds = caldavCredentials(credentials)
 		if (creds instanceof type.errors) {
-			throw new InvalidSourceCredentialsError("freya.caldav", creds.summary)
+			throw new InvalidSourceCredentialsError("aelis.caldav", creds.summary)
 		}
 
 		return new CalDavSource({

apps/aelis-backend/src/db/index.ts

@@ -1,12 +1,9 @@
-import type { PgDatabase } from "drizzle-orm/pg-core"
-
 import { SQL } from "bun"
-import { drizzle, type BunSQLQueryResultHKT } from "drizzle-orm/bun-sql"
+import { drizzle, type BunSQLDatabase } from "drizzle-orm/bun-sql"
 
 import * as schema from "./schema.ts"
 
-/** Covers both the top-level drizzle instance and transaction handles. */
+export type Database = BunSQLDatabase<typeof schema>
-export type Database = PgDatabase<BunSQLQueryResultHKT, typeof schema>
 
 export interface DatabaseConnection {
 	db: Database

apps/aelis-backend/src/db/schema.ts

@@ -0,0 +1,62 @@
+import {
+	boolean,
+	customType,
+	index,
+	jsonb,
+	pgTable,
+	text,
+	timestamp,
+	unique,
+	uuid,
+} from "drizzle-orm/pg-core"
+
+// ---------------------------------------------------------------------------
+// Better Auth core tables
+// Re-exported from CLI-generated schema.
+// Regenerate with: bunx --bun auth@latest generate --config auth.ts --output src/db/auth-schema.ts
+// ---------------------------------------------------------------------------
+
+export {
+	user,
+	session,
+	account,
+	verification,
+	userRelations,
+	sessionRelations,
+	accountRelations,
+} from "./auth-schema.ts"
+
+import { user } from "./auth-schema.ts"
+
+// ---------------------------------------------------------------------------
+// AELIS — per-user source configuration
+// ---------------------------------------------------------------------------
+
+const bytea = customType<{ data: Buffer }>({
+	dataType() {
+		return "bytea"
+	},
+})
+
+export const userSources = pgTable(
+	"user_sources",
+	{
+		id: uuid("id").primaryKey().defaultRandom(),
+		userId: text("user_id")
+			.notNull()
+			.references(() => user.id, { onDelete: "cascade" }),
+		sourceId: text("source_id").notNull(),
+		enabled: boolean("enabled").notNull().default(true),
+		config: jsonb("config").default({}),
+		credentials: bytea("credentials"),
+		createdAt: timestamp("created_at").notNull().defaultNow(),
+		updatedAt: timestamp("updated_at")
+			.notNull()
+			.defaultNow()
+			.$onUpdate(() => new Date()),
+	},
+	(t) => [
+		unique("user_sources_user_id_source_id_unique").on(t.userId, t.sourceId),
+		index("user_sources_user_id_enabled_idx").on(t.userId, t.enabled),
+	],
+)

apps/aelis-backend/src/engine/http.test.ts

@@ -1,6 +1,6 @@
-import type { ActionDefinition, ContextEntry, FeedItem, FeedSource } from "@freya/core"
+import type { ActionDefinition, ContextEntry, FeedItem, FeedSource } from "@aelis/core"
 
-import { contextKey } from "@freya/core"
+import { contextKey } from "@aelis/core"
 import { describe, expect, mock, spyOn, test } from "bun:test"
 import { Hono } from "hono"
 
@@ -85,20 +85,6 @@ mock.module("../sources/user-sources.ts", () => ({
 	}),
 }))
 
-mock.module("../conversations/storage.ts", () => ({
-	conversations: (_db: Database, userId: string) => ({
-		async getOrCreateConversation() {
-			return { id: `conversation-${userId}` }
-		},
-		async listEntries() {
-			return []
-		},
-		async appendEntry() {
-			return { id: "entry-1", sequence: 1 }
-		},
-	}),
-}))
-
 const fakeDb = {} as Database
 
 describe("GET /api/feed", () => {
@@ -258,7 +244,7 @@ describe("GET /api/feed", () => {
 })
 
 describe("GET /api/context", () => {
-	const weatherKey = contextKey("freya.weather", "weather")
+	const weatherKey = contextKey("aelis.weather", "weather")
 	const weatherData = { temperature: 20, condition: "Clear" }
 	const contextEntries: readonly ContextEntry[] = [[weatherKey, weatherData]]
 
@@ -288,7 +274,7 @@ describe("GET /api/context", () => {
 		const manager = new UserSessionManager({ db: fakeDb, providers: [] })
 		const app = buildTestApp(manager)
 
-		const res = await app.request('/api/context?key=["freya.weather","weather"]')
+		const res = await app.request('/api/context?key=["aelis.weather","weather"]')
 
 		expect(res.status).toBe(401)
 	})
@@ -346,7 +332,7 @@ describe("GET /api/context", () => {
 	test("returns 400 when match param is invalid", async () => {
 		const { app } = await buildContextApp("user-1")
 
-		const res = await app.request('/api/context?key=["freya.weather"]&match=invalid')
+		const res = await app.request('/api/context?key=["aelis.weather"]&match=invalid')
 
 		expect(res.status).toBe(400)
 		const body = (await res.json()) as { error: string }
@@ -357,7 +343,7 @@ describe("GET /api/context", () => {
 		const { app, session } = await buildContextApp("user-1")
 		await session.engine.refresh()
 
-		const res = await app.request('/api/context?key=["freya.weather","weather"]&match=exact')
+		const res = await app.request('/api/context?key=["aelis.weather","weather"]&match=exact')
 
 		expect(res.status).toBe(200)
 		const body = (await res.json()) as { match: string; value: unknown }
@@ -369,7 +355,7 @@ describe("GET /api/context", () => {
 		const { app, session } = await buildContextApp("user-1")
 		await session.engine.refresh()
 
-		const res = await app.request('/api/context?key=["freya.weather"]&match=exact')
+		const res = await app.request('/api/context?key=["aelis.weather"]&match=exact')
 
 		expect(res.status).toBe(404)
 	})
@@ -378,7 +364,7 @@ describe("GET /api/context", () => {
 		const { app, session } = await buildContextApp("user-1")
 		await session.engine.refresh()
 
-		const res = await app.request('/api/context?key=["freya.weather"]&match=prefix')
+		const res = await app.request('/api/context?key=["aelis.weather"]&match=prefix')
 
 		expect(res.status).toBe(200)
 		const body = (await res.json()) as {
@@ -387,7 +373,7 @@ describe("GET /api/context", () => {
 		}
 		expect(body.match).toBe("prefix")
 		expect(body.entries).toHaveLength(1)
-		expect(body.entries[0]!.key).toEqual(["freya.weather", "weather"])
+		expect(body.entries[0]!.key).toEqual(["aelis.weather", "weather"])
 		expect(body.entries[0]!.value).toEqual(weatherData)
 	})
 
@@ -395,7 +381,7 @@ describe("GET /api/context", () => {
 		const { app, session } = await buildContextApp("user-1")
 		await session.engine.refresh()
 
-		const res = await app.request('/api/context?key=["freya.weather","weather"]')
+		const res = await app.request('/api/context?key=["aelis.weather","weather"]')
 
 		expect(res.status).toBe(200)
 		const body = (await res.json()) as { match: string; value: unknown }
@@ -407,7 +393,7 @@ describe("GET /api/context", () => {
 		const { app, session } = await buildContextApp("user-1")
 		await session.engine.refresh()
 
-		const res = await app.request('/api/context?key=["freya.weather"]')
+		const res = await app.request('/api/context?key=["aelis.weather"]')
 
 		expect(res.status).toBe(200)
 		const body = (await res.json()) as {

apps/aelis-backend/src/engine/http.ts

@@ -1,6 +1,6 @@
 import type { Context, Hono } from "hono"
 
-import { contextKey } from "@freya/core"
+import { contextKey } from "@aelis/core"
 import { createMiddleware } from "hono/factory"
 
 import type { AuthSessionMiddleware } from "../auth/session-middleware.ts"

apps/aelis-backend/src/enhancement/enhance-feed.ts

@@ -1,4 +1,4 @@
-import type { FeedItem } from "@freya/core"
+import type { FeedItem } from "@aelis/core"
 
 import type { LlmClient } from "./llm-client.ts"
 
@@ -47,3 +47,5 @@ export function createFeedEnhancer(config: FeedEnhancerConfig): FeedEnhancer {
 		return mergeEnhancement(items, result, currentTime)
 	}
 }
+
+

apps/aelis-backend/src/enhancement/merge.test.ts

@@ -1,4 +1,4 @@
-import type { FeedItem } from "@freya/core"
+import type { FeedItem } from "@aelis/core"
 
 import { describe, expect, test } from "bun:test"
 

apps/aelis-backend/src/enhancement/merge.ts

@@ -1,8 +1,8 @@
-import type { FeedItem } from "@freya/core"
+import type { FeedItem } from "@aelis/core"
 
 import type { EnhancementResult } from "./schema.ts"
 
-const ENHANCEMENT_SOURCE_ID = "freya.enhancement"
+const ENHANCEMENT_SOURCE_ID = "aelis.enhancement"
 
 /**
  * Merges an EnhancementResult into feed items.

apps/aelis-backend/src/enhancement/prompt-builder.test.ts

@@ -1,4 +1,4 @@
-import type { FeedItem } from "@freya/core"
+import type { FeedItem } from "@aelis/core"
 
 import { describe, expect, test } from "bun:test"
 

apps/aelis-backend/src/enhancement/prompt-builder.ts

@@ -1,7 +1,7 @@
-import type { FeedItem } from "@freya/core"
+import type { FeedItem } from "@aelis/core"
 
-import { CalDavFeedItemType } from "@freya/source-caldav"
+import { CalDavFeedItemType } from "@aelis/source-caldav"
-import { CalendarFeedItemType } from "@freya/source-google-calendar"
+import { CalendarFeedItemType } from "@aelis/source-google-calendar"
 
 import systemPromptBase from "./prompts/system.txt"
 
@@ -36,7 +36,8 @@ export function buildPrompt(
 
 	for (const item of items) {
 		const hasUnfilledSlots =
-			item.slots && Object.values(item.slots).some((slot) => slot.content === null)
+			item.slots &&
+			Object.values(item.slots).some((slot) => slot.content === null)
 
 		if (hasUnfilledSlots) {
 			enhanceItems.push({
@@ -78,7 +79,9 @@ export function buildPrompt(
  */
 export function hasUnfilledSlots(items: FeedItem[]): boolean {
 	return items.some(
-		(item) => item.slots && Object.values(item.slots).some((slot) => slot.content === null),
+		(item) =>
+			item.slots &&
+			Object.values(item.slots).some((slot) => slot.content === null),
 	)
 }
 
@@ -126,20 +129,7 @@ function extractCalendarEntry(item: FeedItem): CalendarEntry | null {
 }
 
 const DAYS = ["Sun", "Mon", "Tue", "Wed", "Thu", "Fri", "Sat"] as const
-const MONTHS = [
+const MONTHS = ["Jan", "Feb", "Mar", "Apr", "May", "Jun", "Jul", "Aug", "Sep", "Oct", "Nov", "Dec"] as const
-	"Jan",
-	"Feb",
-	"Mar",
-	"Apr",
-	"May",
-	"Jun",
-	"Jul",
-	"Aug",
-	"Sep",
-	"Oct",
-	"Nov",
-	"Dec",
-] as const
 
 function pad2(n: number): string {
 	return n.toString().padStart(2, "0")
@@ -154,11 +144,7 @@ function formatDayShort(date: Date): string {
 }
 
 function formatDayLabel(date: Date, currentTime: Date): string {
-	const currentDay = Date.UTC(
+	const currentDay = Date.UTC(currentTime.getUTCFullYear(), currentTime.getUTCMonth(), currentTime.getUTCDate())
-		currentTime.getUTCFullYear(),
-		currentTime.getUTCMonth(),
-		currentTime.getUTCDate(),
-	)
 	const targetDay = Date.UTC(date.getUTCFullYear(), date.getUTCMonth(), date.getUTCDate())
 	const diffDays = Math.round((targetDay - currentDay) / (1000 * 60 * 60 * 24))
 

apps/aelis-backend/src/enhancement/prompts/system.txt

@@ -1,4 +1,4 @@
-You are FREYA, a personal assistant. You enhance a user's feed by filling slots and optionally generating synthetic items.
+You are AELIS, a personal assistant. You enhance a user's feed by filling slots and optionally generating synthetic items.
 
 The user message is a JSON object with:
 - "items": feed items with data and named slots to fill. Each slot has a description of what to write.

apps/aelis-backend/src/enhancement/schema.test.ts

@@ -135,7 +135,9 @@ describe("schema sync", () => {
 
 			// JSON Schema structure matches
 			const jsonSchema = enhancementResultJsonSchema
-			expect(Object.keys(jsonSchema.properties).sort()).toEqual(Object.keys(payload).sort())
+			expect(Object.keys(jsonSchema.properties).sort()).toEqual(
+				Object.keys(payload).sort(),
+			)
 			expect([...jsonSchema.required].sort()).toEqual(Object.keys(payload).sort())
 
 			// syntheticItems item schema has the right required fields
@@ -165,7 +167,11 @@ describe("schema sync", () => {
 
 		// JSON Schema only allows string or null for slot values
 		const slotValueSchema =
-			enhancementResultJsonSchema.properties.slotFills.additionalProperties.additionalProperties
+			enhancementResultJsonSchema.properties.slotFills.additionalProperties
-		expect(slotValueSchema.anyOf).toEqual([{ type: "string" }, { type: "null" }])
+				.additionalProperties
+		expect(slotValueSchema.anyOf).toEqual([
+			{ type: "string" },
+			{ type: "null" },
+		])
 	})
 })

apps/aelis-backend/src/lib/crypto.test.ts

@@ -1,5 +1,5 @@
-import { describe, expect, test } from "bun:test"
 import { randomBytes } from "node:crypto"
+import { describe, expect, test } from "bun:test"
 
 import { CredentialEncryptor } from "./crypto.ts"
 

apps/aelis-backend/src/location/http.ts

@@ -57,7 +57,7 @@ async function handleUpdateLocation(c: Context<Env>) {
 		return c.json({ error: "Service unavailable" }, 503)
 	}
 
-	await session.engine.executeAction("freya.location", "update-location", {
+	await session.engine.executeAction("aelis.location", "update-location", {
 		lat: result.lat,
 		lng: result.lng,
 		accuracy: result.accuracy,

apps/aelis-backend/src/location/provider.ts

@@ -1,9 +1,9 @@
-import { LocationSource } from "@freya/source-location"
+import { LocationSource } from "@aelis/source-location"
 
 import type { FeedSourceProvider } from "../session/feed-source-provider.ts"
 
 export class LocationSourceProvider implements FeedSourceProvider {
-	readonly sourceId = LocationSource.id
+	readonly sourceId = "aelis.location"
 
 	async feedSourceForUser(
 		_userId: string,

apps/aelis-backend/src/server.ts

@@ -1,82 +1,73 @@
 import { Hono } from "hono"
 import { cors } from "hono/cors"
-import { createMiddleware } from "hono/factory"
 
 import { registerAdminHttpHandlers } from "./admin/http.ts"
-import { createQueryDebugTools } from "./agent/debug-tools.ts"
-import { registerAgentHttpHandlers, registerDebugAgentHttpHandlers } from "./agent/http.ts"
-import { agentWebSocket, registerAgentWebSocketHandlers } from "./agent/ws.ts"
 import { createRequireAdmin } from "./auth/admin-middleware.ts"
 import { registerAuthHandlers } from "./auth/http.ts"
 import { createAuth } from "./auth/index.ts"
 import { createRequireSession } from "./auth/session-middleware.ts"
 import { CalDavSourceProvider } from "./caldav/provider.ts"
-import { registerConversationsHttpHandlers } from "./conversations/http.ts"
 import { createDatabase } from "./db/index.ts"
 import { registerFeedHttpHandlers } from "./engine/http.ts"
 import { createFeedEnhancer } from "./enhancement/enhance-feed.ts"
 import { createLlmClient } from "./enhancement/llm-client.ts"
-import { GoogleMapsSourceProvider } from "./google-maps/provider.ts"
 import { CredentialEncryptor } from "./lib/crypto.ts"
-import { ensureEnv } from "./lib/env.ts"
 import { registerLocationHttpHandlers } from "./location/http.ts"
 import { LocationSourceProvider } from "./location/provider.ts"
-import { ReminderSourceProvider } from "./reminders/provider.ts"
 import { UserSessionManager } from "./session/index.ts"
 import { registerSourcesHttpHandlers } from "./sources/http.ts"
 import { TflSourceProvider } from "./tfl/provider.ts"
 import { WeatherSourceProvider } from "./weather/provider.ts"
-import { WebSearchSourceProvider } from "./web-search/provider.ts"
 
 function main() {
-	const env = ensureEnv(process.env)
+	const { db, close: closeDb } = createDatabase(process.env.DATABASE_URL!)
-
-	const { db, close: closeDb } = createDatabase(env.databaseUrl)
 	const auth = createAuth(db)
 
-	const feedEnhancer = createFeedEnhancer({
+	const openrouterApiKey = process.env.OPENROUTER_API_KEY
-		client: createLlmClient({
+	const feedEnhancer = openrouterApiKey
-			apiKey: env.openrouterApiKey,
+		? createFeedEnhancer({
-		}),
+				client: createLlmClient({
-	})
+					apiKey: openrouterApiKey,
+					model: process.env.OPENROUTER_MODEL || undefined,
+				}),
+			})
+		: null
+	if (!feedEnhancer) {
+		console.warn("[enhancement] OPENROUTER_API_KEY not set — feed enhancement disabled")
+	}
 
-	const credentialEncryptor = new CredentialEncryptor(env.credentialEncryptionKey)
+	const credentialEncryptionKey = process.env.CREDENTIAL_ENCRYPTION_KEY
-	const piApiKey = process.env.PI_API_KEY ?? env.openrouterApiKey
+	const credentialEncryptor = credentialEncryptionKey
+		? new CredentialEncryptor(credentialEncryptionKey)
+		: null
+	if (!credentialEncryptor) {
+		console.warn(
+			"[credentials] CREDENTIAL_ENCRYPTION_KEY not set — per-user credential storage disabled",
+		)
+	}
 
 	const sessionManager = new UserSessionManager({
 		db,
 		providers: [
 			new CalDavSourceProvider(),
 			new LocationSourceProvider(),
-			new ReminderSourceProvider({ db }),
 			new WeatherSourceProvider({
 				credentials: {
-					privateKey: env.weatherkitPrivateKey,
+					privateKey: process.env.WEATHERKIT_PRIVATE_KEY!,
-					keyId: env.weatherkitKeyId,
+					keyId: process.env.WEATHERKIT_KEY_ID!,
-					teamId: env.weatherkitTeamId,
+					teamId: process.env.WEATHERKIT_TEAM_ID!,
-					serviceId: env.weatherkitServiceId,
+					serviceId: process.env.WEATHERKIT_SERVICE_ID!,
 				},
 			}),
-			new TflSourceProvider({ apiKey: env.tflApiKey }),
+			new TflSourceProvider({ apiKey: process.env.TFL_API_KEY! }),
-			new WebSearchSourceProvider({ apiKey: env.exaApiKey }),
-			new GoogleMapsSourceProvider({
-				apiKey: env.googleMapsApiKey,
-			}),
 		],
 		feedEnhancer,
 		credentialEncryptor,
-		queryAgent: {
-			apiKey: piApiKey,
-		},
 	})
-	if (!piApiKey) {
-		console.warn("[query] PI_API_KEY or OPENROUTER_API_KEY not set — query agent unavailable")
-	}
 
 	const app = new Hono()
 
 	const isDev = process.env.NODE_ENV !== "production"
-	const isDebugMode = isDev
 	const allowedOrigins = process.env.CORS_ORIGINS?.split(",").map((o) => o.trim()) ?? []
 
 	function resolveOrigin(origin: string): string | undefined {
@@ -84,15 +75,6 @@ function main() {
 		return allowedOrigins.includes(origin) ? origin : undefined
 	}
 
-	const agentWebSocketCorsMiddleware = createMiddleware(async (c, next) => {
-		const origin = c.req.header("origin")
-		if (origin && resolveOrigin(origin) === undefined) {
-			return c.text("Forbidden", 403)
-		}
-
-		await next()
-	})
-
 	app.use(
 		"/api/auth/*",
 		cors({
@@ -126,28 +108,9 @@ function main() {
 	})
 	registerLocationHttpHandlers(app, { sessionManager, authSessionMiddleware })
 	registerSourcesHttpHandlers(app, { sessionManager, authSessionMiddleware })
-	registerAgentHttpHandlers(app, {
-		sessionManager,
-		authSessionMiddleware,
-	})
-	registerConversationsHttpHandlers(app, { db, authSessionMiddleware })
-	if (isDebugMode) {
-		registerDebugAgentHttpHandlers(app, {
-			authSessionMiddleware,
-			debugTools: createQueryDebugTools(sessionManager),
-			debug: isDebugMode,
-		})
-	}
 	registerAdminHttpHandlers(app, { sessionManager, adminMiddleware, db })
 
-	registerAgentWebSocketHandlers(app, {
-		sessionManager,
-		authSessionMiddleware,
-		corsMiddleware: agentWebSocketCorsMiddleware,
-	})
-
 	process.on("SIGTERM", async () => {
-		sessionManager.dispose()
 		await closeDb()
 		process.exit(0)
 	})
@@ -159,7 +122,5 @@ const app = main()
 
 export default {
 	port: 3000,
-	hostname: "0.0.0.0",
 	fetch: app.fetch,
-	websocket: agentWebSocket,
 }

apps/aelis-backend/src/session/feed-source-provider.ts

@@ -1,9 +1,10 @@
-import type { FeedSource } from "@freya/core"
+import type { FeedSource } from "@aelis/core"
+import type { type } from "arktype"
 
-export type ConfigSchema = (value: unknown) => unknown
+export type ConfigSchema = ReturnType<typeof type>
 
 export interface FeedSourceProvider {
-	/** The source ID this provider is responsible for (e.g., "freya.location"). */
+	/** The source ID this provider is responsible for (e.g., "aelis.location"). */
 	readonly sourceId: string
 	/** Arktype schema for validating user-provided config. Omit if the source has no config. */
 	readonly configSchema?: ConfigSchema

apps/aelis-backend/src/session/user-session-manager.test.ts

@@ -1,12 +1,9 @@
-import type { ActionDefinition, ContextEntry, FeedItem, FeedSource } from "@freya/core"
+import type { ActionDefinition, ContextEntry, FeedItem, FeedSource } from "@aelis/core"
 
-import { ConversationEntryKind } from "@freya/core"
+import { LocationSource } from "@aelis/source-location"
-import { LocationSource } from "@freya/source-location"
+import { WeatherSource } from "@aelis/source-weatherkit"
-import { WeatherSource } from "@freya/source-weatherkit"
 import { beforeEach, describe, expect, mock, spyOn, test } from "bun:test"
 
-import type { ConversationStorageEntry } from "../agent/conversation-recording-query-agent.ts"
-import type { AppendConversationEntryInput } from "../conversations/storage.ts"
 import type { Database } from "../db/index.ts"
 import type { FeedSourceProvider } from "./feed-source-provider.ts"
 
@@ -24,8 +21,6 @@ import { UserSessionManager } from "./user-session-manager.ts"
  * Key = userId (or "*" for a default), value = array of enabled sourceIds.
  */
 const enabledByUser = new Map<string, string[]>()
-const conversationEntriesByUser = new Map<string, ConversationStorageEntry[]>()
-const mockConversationCalls: Array<{ type: "getOrCreate" | "listEntries"; userId: string }> = []
 
 /** Set which sourceIds are enabled for all users. */
 function setEnabledSources(sourceIds: string[]) {
@@ -42,10 +37,6 @@ function getEnabledSourceIds(userId: string): string[] {
 	return enabledByUser.get(userId) ?? enabledByUser.get("*") ?? []
 }
 
-function setConversationEntriesForUser(userId: string, entries: ConversationStorageEntry[]) {
-	conversationEntriesByUser.set(userId, entries)
-}
-
 /**
  * Controls what `find()` returns in the mock. When `undefined` (the default),
  * `find()` returns a standard enabled row. Set to a specific value (including
@@ -90,24 +81,6 @@ mock.module("../sources/user-sources.ts", () => ({
 				updatedAt: now,
 			}
 		},
-		async findForUpdate(sourceId: string) {
-			// Delegates to find — row locking is a no-op in tests.
-			if (mockFindResult !== undefined) return mockFindResult
-			const now = new Date()
-			return {
-				id: crypto.randomUUID(),
-				userId,
-				sourceId,
-				enabled: true,
-				config: {},
-				credentials: null,
-				createdAt: now,
-				updatedAt: now,
-			}
-		},
-		async updateConfig(_sourceId: string, _update: { enabled?: boolean; config?: unknown }) {
-			// no-op for tests
-		},
 		async upsertConfig(_sourceId: string, _data: { enabled: boolean; config: unknown }) {
 			// no-op for tests
 		},
@@ -120,38 +93,7 @@ mock.module("../sources/user-sources.ts", () => ({
 	}),
 }))
 
-mock.module("../conversations/storage.ts", () => ({
+const fakeDb = {} as Database
-	conversations: (_db: Database, userId: string) => ({
-		async getOrCreateConversation(): Promise<{ id: string }> {
-			mockConversationCalls.push({ type: "getOrCreate", userId })
-			return { id: `conversation-${userId}` }
-		},
-		async listEntries(_conversationId: string): Promise<ConversationStorageEntry[]> {
-			mockConversationCalls.push({ type: "listEntries", userId })
-			return conversationEntriesByUser.get(userId) ?? []
-		},
-		async appendEntry(
-			_conversationId: string,
-			input: AppendConversationEntryInput,
-		): Promise<ConversationStorageEntry> {
-			const entries = conversationEntriesByUser.get(userId) ?? []
-			const row: ConversationStorageEntry = {
-				id: `entry-${entries.length + 1}`,
-				sequence: entries.length + 1,
-				kind: input.kind,
-				payload: input.payload,
-				metadata: input.metadata ?? {},
-				createdAt: new Date("2026-06-15T00:00:00.000Z"),
-			}
-			conversationEntriesByUser.set(userId, [...entries, row])
-			return row
-		},
-	}),
-}))
-
-const fakeDb = {
-	transaction: <T>(fn: (tx: unknown) => Promise<T>) => fn(fakeDb),
-} as unknown as Database
 
 function createStubSource(id: string, items: FeedItem[] = []): FeedSource {
 	return {
@@ -183,14 +125,14 @@ function createStubProvider(
 }
 
 const locationProvider: FeedSourceProvider = {
-	sourceId: "freya.location",
+	sourceId: "aelis.location",
 	async feedSourceForUser() {
 		return new LocationSource()
 	},
 }
 
 const weatherProvider: FeedSourceProvider = {
-	sourceId: "freya.weather",
+	sourceId: "aelis.weather",
 	async feedSourceForUser() {
 		return new WeatherSource({ client: { fetch: async () => ({}) as never } })
 	},
@@ -198,8 +140,6 @@ const weatherProvider: FeedSourceProvider = {
 
 beforeEach(() => {
 	enabledByUser.clear()
-	conversationEntriesByUser.clear()
-	mockConversationCalls.length = 0
 	mockFindResult = undefined
 	mockUpdateCredentialsCalls.length = 0
 	mockUpdateCredentialsError = null
@@ -207,7 +147,7 @@ beforeEach(() => {
 
 describe("UserSessionManager", () => {
 	test("getOrCreate creates session on first call", async () => {
-		setEnabledSources(["freya.location"])
+		setEnabledSources(["aelis.location"])
 		const manager = new UserSessionManager({ db: fakeDb, providers: [locationProvider] })
 
 		const session = await manager.getOrCreate("user-1")
@@ -216,33 +156,8 @@ describe("UserSessionManager", () => {
 		expect(session.engine).toBeDefined()
 	})
 
-	test("getOrCreate eagerly loads conversation entries for the user session", async () => {
-		setEnabledSources([])
-		setConversationEntriesForUser("user-1", [
-			{
-				id: "entry-1",
-				sequence: 1,
-				kind: ConversationEntryKind.UserMessage,
-				payload: {
-					role: "user",
-					parts: [{ type: "text", text: "stored hello" }],
-				},
-				metadata: {},
-				createdAt: new Date("2026-06-15T00:00:00.000Z"),
-			},
-		])
-		const manager = new UserSessionManager({ db: fakeDb, providers: [] })
-
-		await manager.getOrCreate("user-1")
-
-		expect(mockConversationCalls).toEqual([
-			{ type: "getOrCreate", userId: "user-1" },
-			{ type: "listEntries", userId: "user-1" },
-		])
-	})
-
 	test("getOrCreate returns same session for same user", async () => {
-		setEnabledSources(["freya.location"])
+		setEnabledSources(["aelis.location"])
 		const manager = new UserSessionManager({ db: fakeDb, providers: [locationProvider] })
 
 		const session1 = await manager.getOrCreate("user-1")
@@ -252,7 +167,7 @@ describe("UserSessionManager", () => {
 	})
 
 	test("getOrCreate returns different sessions for different users", async () => {
-		setEnabledSources(["freya.location"])
+		setEnabledSources(["aelis.location"])
 		const manager = new UserSessionManager({ db: fakeDb, providers: [locationProvider] })
 
 		const session1 = await manager.getOrCreate("user-1")
@@ -262,20 +177,20 @@ describe("UserSessionManager", () => {
 	})
 
 	test("each user gets independent source instances", async () => {
-		setEnabledSources(["freya.location"])
+		setEnabledSources(["aelis.location"])
 		const manager = new UserSessionManager({ db: fakeDb, providers: [locationProvider] })
 
 		const session1 = await manager.getOrCreate("user-1")
 		const session2 = await manager.getOrCreate("user-2")
 
-		const source1 = session1.getSource<LocationSource>("freya.location")
+		const source1 = session1.getSource<LocationSource>("aelis.location")
-		const source2 = session2.getSource<LocationSource>("freya.location")
+		const source2 = session2.getSource<LocationSource>("aelis.location")
 
 		expect(source1).not.toBe(source2)
 	})
 
 	test("remove destroys session and allows re-creation", async () => {
-		setEnabledSources(["freya.location"])
+		setEnabledSources(["aelis.location"])
 		const manager = new UserSessionManager({ db: fakeDb, providers: [locationProvider] })
 
 		const session1 = await manager.getOrCreate("user-1")
@@ -286,14 +201,14 @@ describe("UserSessionManager", () => {
 	})
 
 	test("remove is no-op for unknown user", () => {
-		setEnabledSources(["freya.location"])
+		setEnabledSources(["aelis.location"])
 		const manager = new UserSessionManager({ db: fakeDb, providers: [locationProvider] })
 
 		expect(() => manager.remove("unknown")).not.toThrow()
 	})
 
 	test("registers multiple providers", async () => {
-		setEnabledSources(["freya.location", "freya.weather"])
+		setEnabledSources(["aelis.location", "aelis.weather"])
 		const manager = new UserSessionManager({
 			db: fakeDb,
 			providers: [locationProvider, weatherProvider],
@@ -301,12 +216,12 @@ describe("UserSessionManager", () => {
 
 		const session = await manager.getOrCreate("user-1")
 
-		expect(session.getSource("freya.location")).toBeDefined()
+		expect(session.getSource("aelis.location")).toBeDefined()
-		expect(session.getSource("freya.weather")).toBeDefined()
+		expect(session.getSource("aelis.weather")).toBeDefined()
 	})
 
 	test("refresh returns feed result through session", async () => {
-		setEnabledSources(["freya.location"])
+		setEnabledSources(["aelis.location"])
 		const manager = new UserSessionManager({ db: fakeDb, providers: [locationProvider] })
 
 		const session = await manager.getOrCreate("user-1")
@@ -319,30 +234,30 @@ describe("UserSessionManager", () => {
 	})
 
 	test("location update via executeAction works", async () => {
-		setEnabledSources(["freya.location"])
+		setEnabledSources(["aelis.location"])
 		const manager = new UserSessionManager({ db: fakeDb, providers: [locationProvider] })
 
 		const session = await manager.getOrCreate("user-1")
-		await session.engine.executeAction("freya.location", "update-location", {
+		await session.engine.executeAction("aelis.location", "update-location", {
 			lat: 51.5074,
 			lng: -0.1278,
 			accuracy: 10,
 			timestamp: new Date(),
 		})
 
-		const source = session.getSource<LocationSource>("freya.location")
+		const source = session.getSource<LocationSource>("aelis.location")
 		expect(source?.lastLocation?.lat).toBe(51.5074)
 	})
 
 	test("subscribe receives updates after location push", async () => {
-		setEnabledSources(["freya.location"])
+		setEnabledSources(["aelis.location"])
 		const manager = new UserSessionManager({ db: fakeDb, providers: [locationProvider] })
 		const callback = mock()
 
 		const session = await manager.getOrCreate("user-1")
 		session.engine.subscribe(callback)
 
-		await session.engine.executeAction("freya.location", "update-location", {
+		await session.engine.executeAction("aelis.location", "update-location", {
 			lat: 51.5074,
 			lng: -0.1278,
 			accuracy: 10,
@@ -356,7 +271,7 @@ describe("UserSessionManager", () => {
 	})
 
 	test("remove stops reactive updates", async () => {
-		setEnabledSources(["freya.location"])
+		setEnabledSources(["aelis.location"])
 		const manager = new UserSessionManager({ db: fakeDb, providers: [locationProvider] })
 		const callback = mock()
 
@@ -367,7 +282,7 @@ describe("UserSessionManager", () => {
 
 		// Create new session and push location — old callback should not fire
 		const session2 = await manager.getOrCreate("user-1")
-		await session2.engine.executeAction("freya.location", "update-location", {
+		await session2.engine.executeAction("aelis.location", "update-location", {
 			lat: 51.5074,
 			lng: -0.1278,
 			accuracy: 10,
@@ -380,9 +295,9 @@ describe("UserSessionManager", () => {
 	})
 
 	test("creates session with successful providers when some fail", async () => {
-		setEnabledSources(["freya.location", "freya.failing"])
+		setEnabledSources(["aelis.location", "aelis.failing"])
 		const failingProvider: FeedSourceProvider = {
-			sourceId: "freya.failing",
+			sourceId: "aelis.failing",
 			async feedSourceForUser() {
 				throw new Error("provider failed")
 			},
@@ -398,25 +313,25 @@ describe("UserSessionManager", () => {
 		const session = await manager.getOrCreate("user-1")
 
 		expect(session).toBeDefined()
-		expect(session.getSource("freya.location")).toBeDefined()
+		expect(session.getSource("aelis.location")).toBeDefined()
 		expect(spy).toHaveBeenCalled()
 
 		spy.mockRestore()
 	})
 
 	test("throws AggregateError when all providers fail", async () => {
-		setEnabledSources(["freya.fail-1", "freya.fail-2"])
+		setEnabledSources(["aelis.fail-1", "aelis.fail-2"])
 		const manager = new UserSessionManager({
 			db: fakeDb,
 			providers: [
 				{
-					sourceId: "freya.fail-1",
+					sourceId: "aelis.fail-1",
 					async feedSourceForUser() {
 						throw new Error("first failed")
 					},
 				},
 				{
-					sourceId: "freya.fail-2",
+					sourceId: "aelis.fail-2",
 					async feedSourceForUser() {
 						throw new Error("second failed")
 					},
@@ -428,13 +343,13 @@ describe("UserSessionManager", () => {
 	})
 
 	test("concurrent getOrCreate for same user returns same session", async () => {
-		setEnabledSources(["freya.location"])
+		setEnabledSources(["aelis.location"])
 		let callCount = 0
 		const manager = new UserSessionManager({
 			db: fakeDb,
 			providers: [
 				{
-					sourceId: "freya.location",
+					sourceId: "aelis.location",
 					async feedSourceForUser() {
 						callCount++
 						await new Promise((resolve) => setTimeout(resolve, 10))
@@ -454,7 +369,7 @@ describe("UserSessionManager", () => {
 	})
 
 	test("remove during in-flight getOrCreate prevents session from being stored", async () => {
-		setEnabledSources(["freya.location"])
+		setEnabledSources(["aelis.location"])
 		let resolveProvider: () => void
 		const providerGate = new Promise<void>((r) => {
 			resolveProvider = r
@@ -464,7 +379,7 @@ describe("UserSessionManager", () => {
 			db: fakeDb,
 			providers: [
 				{
-					sourceId: "freya.location",
+					sourceId: "aelis.location",
 					async feedSourceForUser() {
 						await providerGate
 						return new LocationSource()
@@ -490,15 +405,15 @@ describe("UserSessionManager", () => {
 	})
 
 	test("only invokes providers for sources enabled for the user", async () => {
-		setEnabledSources(["freya.location"])
+		setEnabledSources(["aelis.location"])
-		const locationFactory = mock(async () => createStubSource("freya.location"))
+		const locationFactory = mock(async () => createStubSource("aelis.location"))
-		const weatherFactory = mock(async () => createStubSource("freya.weather"))
+		const weatherFactory = mock(async () => createStubSource("aelis.weather"))
 
 		const manager = new UserSessionManager({
 			db: fakeDb,
 			providers: [
-				{ sourceId: "freya.location", feedSourceForUser: locationFactory },
+				{ sourceId: "aelis.location", feedSourceForUser: locationFactory },
-				{ sourceId: "freya.weather", feedSourceForUser: weatherFactory },
+				{ sourceId: "aelis.weather", feedSourceForUser: weatherFactory },
 			],
 		})
 
@@ -506,43 +421,43 @@ describe("UserSessionManager", () => {
 
 		expect(locationFactory).toHaveBeenCalledTimes(1)
 		expect(weatherFactory).not.toHaveBeenCalled()
-		expect(session.getSource("freya.location")).toBeDefined()
+		expect(session.getSource("aelis.location")).toBeDefined()
-		expect(session.getSource("freya.weather")).toBeUndefined()
+		expect(session.getSource("aelis.weather")).toBeUndefined()
 	})
 
 	test("creates empty session when no sources are enabled", async () => {
 		setEnabledSources([])
-		const factory = mock(async () => createStubSource("freya.location"))
+		const factory = mock(async () => createStubSource("aelis.location"))
 
 		const manager = new UserSessionManager({
 			db: fakeDb,
-			providers: [{ sourceId: "freya.location", feedSourceForUser: factory }],
+			providers: [{ sourceId: "aelis.location", feedSourceForUser: factory }],
 		})
 
 		const session = await manager.getOrCreate("user-1")
 
 		expect(factory).not.toHaveBeenCalled()
 		expect(session).toBeDefined()
-		expect(session.getSource("freya.location")).toBeUndefined()
+		expect(session.getSource("aelis.location")).toBeUndefined()
 	})
 
 	test("per-user enabled sources are respected", async () => {
 		enabledByUser.clear()
-		setEnabledSourcesForUser("user-1", ["freya.location"])
+		setEnabledSourcesForUser("user-1", ["aelis.location"])
-		setEnabledSourcesForUser("user-2", ["freya.weather"])
+		setEnabledSourcesForUser("user-2", ["aelis.weather"])
 
 		const manager = new UserSessionManager({
 			db: fakeDb,
-			providers: [createStubProvider("freya.location"), createStubProvider("freya.weather")],
+			providers: [createStubProvider("aelis.location"), createStubProvider("aelis.weather")],
 		})
 
 		const session1 = await manager.getOrCreate("user-1")
 		const session2 = await manager.getOrCreate("user-2")
 
-		expect(session1.getSource("freya.location")).toBeDefined()
+		expect(session1.getSource("aelis.location")).toBeDefined()
-		expect(session1.getSource("freya.weather")).toBeUndefined()
+		expect(session1.getSource("aelis.weather")).toBeUndefined()
-		expect(session2.getSource("freya.location")).toBeUndefined()
+		expect(session2.getSource("aelis.location")).toBeUndefined()
-		expect(session2.getSource("freya.weather")).toBeDefined()
+		expect(session2.getSource("aelis.weather")).toBeDefined()
 	})
 })
 
@@ -590,10 +505,10 @@ describe("UserSessionManager.replaceProvider", () => {
 	})
 
 	test("throws for unknown provider sourceId", async () => {
-		setEnabledSources(["freya.location"])
+		setEnabledSources(["aelis.location"])
 		const manager = new UserSessionManager({ db: fakeDb, providers: [locationProvider] })
 
-		const unknownProvider = createStubProvider("freya.unknown")
+		const unknownProvider = createStubProvider("aelis.unknown")
 
 		await expect(manager.replaceProvider(unknownProvider)).rejects.toThrow(
 			"no existing provider with that sourceId",

apps/aelis-backend/src/session/user-session-manager.ts

@@ -1,4 +1,4 @@
-import type { FeedSource } from "@freya/core"
+import type { FeedSource } from "@aelis/core"
 
 import { type } from "arktype"
 import merge from "lodash.merge"
@@ -8,21 +8,19 @@ import type { FeedEnhancer } from "../enhancement/enhance-feed.ts"
 import type { CredentialEncryptor } from "../lib/crypto.ts"
 import type { FeedSourceProvider } from "./feed-source-provider.ts"
 
-import { conversations } from "../conversations/storage.ts"
 import {
 	CredentialStorageUnavailableError,
 	InvalidSourceConfigError,
 	SourceNotFoundError,
 } from "../sources/errors.ts"
 import { sources } from "../sources/user-sources.ts"
-import { UserSession, type UserSessionAgentConfig } from "./user-session.ts"
+import { UserSession } from "./user-session.ts"
 
 export interface UserSessionManagerConfig {
 	db: Database
 	providers: FeedSourceProvider[]
 	feedEnhancer?: FeedEnhancer | null
 	credentialEncryptor?: CredentialEncryptor | null
-	queryAgent?: UserSessionAgentConfig
 }
 
 export class UserSessionManager {
@@ -32,7 +30,6 @@ export class UserSessionManager {
 	private readonly providers = new Map<string, FeedSourceProvider>()
 	private readonly feedEnhancer: FeedEnhancer | null
 	private readonly encryptor: CredentialEncryptor | null
-	private readonly queryAgentConfig: UserSessionAgentConfig | undefined
 
 	constructor(config: UserSessionManagerConfig) {
 		this.db = config.db
@@ -41,7 +38,6 @@ export class UserSessionManager {
 		}
 		this.feedEnhancer = config.feedEnhancer ?? null
 		this.encryptor = config.credentialEncryptor ?? null
-		this.queryAgentConfig = config.queryAgent
 	}
 
 	getProvider(sourceId: string): FeedSourceProvider | undefined {
@@ -103,14 +99,6 @@ export class UserSessionManager {
 		this.pending.delete(userId)
 	}
 
-	dispose(): void {
-		for (const session of this.sessions.values()) {
-			session.destroy()
-		}
-		this.sessions.clear()
-		this.pending.clear()
-	}
-
 	/**
 	 * Merges, validates, and persists a user's source config and/or enabled
 	 * state, then invalidates the cached session.
@@ -138,29 +126,27 @@ export class UserSessionManager {
 			return
 		}
 
-		// Use a transaction with SELECT FOR UPDATE to prevent lost updates
+		// Fetch the existing row for config merging and credential access.
-		// when concurrent PATCH requests merge config against the same base.
+		// NOTE: find + updateConfig is not atomic. A concurrent update could
-		const { existingRow, mergedConfig } = await this.db.transaction(async (tx) => {
+		// read stale config. Use SELECT FOR UPDATE or atomic jsonb merge if
-			const existingRow = await sources(tx, userId).findForUpdate(sourceId)
+		// this becomes a problem.
+		const existingRow = await sources(this.db, userId).find(sourceId)
 
-			let mergedConfig: Record<string, unknown> | undefined
+		let mergedConfig: Record<string, unknown> | undefined
-			if (update.config !== undefined && provider.configSchema) {
+		if (update.config !== undefined && provider.configSchema) {
-				const existingConfig = (existingRow?.config ?? {}) as Record<string, unknown>
+			const existingConfig = (existingRow?.config ?? {}) as Record<string, unknown>
-				mergedConfig = merge({}, existingConfig, update.config)
+			mergedConfig = merge({}, existingConfig, update.config)
 
-				const validated = provider.configSchema(mergedConfig)
+			const validated = provider.configSchema(mergedConfig)
-				if (validated instanceof type.errors) {
+			if (validated instanceof type.errors) {
-					throw new InvalidSourceConfigError(sourceId, validated.summary)
+				throw new InvalidSourceConfigError(sourceId, validated.summary)
-				}
 			}
+		}
 
-			// Throws SourceNotFoundError if the row doesn't exist
+		// Throws SourceNotFoundError if the row doesn't exist
-			await sources(tx, userId).updateConfig(sourceId, {
+		await sources(this.db, userId).updateConfig(sourceId, {
-				enabled: update.enabled,
+			enabled: update.enabled,
-				config: mergedConfig,
+			config: mergedConfig,
-			})
-
-			return { existingRow, mergedConfig }
 		})
 
 		// Refresh the specific source in the active session instead of
@@ -216,24 +202,21 @@ export class UserSessionManager {
 
 		const config = data.config ?? {}
 
-		// Run the upsert + credential update atomically so a failure in
+		// Fetch existing row before upsert to capture credentials for session refresh.
-		// either step doesn't leave the row in an inconsistent state.
+		// For new rows this will be undefined — credentials will be null.
-		const existingRow = await this.db.transaction(async (tx) => {
+		const existingRow = await sources(this.db, userId).find(sourceId)
-			const existing = await sources(tx, userId).find(sourceId)
 
-			await sources(tx, userId).upsertConfig(sourceId, {
+		await sources(this.db, userId).upsertConfig(sourceId, {
-				enabled: data.enabled,
+			enabled: data.enabled,
-				config,
+			config,
-			})
-
-			if (data.credentials !== undefined && this.encryptor) {
-				const encrypted = this.encryptor.encrypt(JSON.stringify(data.credentials))
-				await sources(tx, userId).updateCredentials(sourceId, encrypted)
-			}
-
-			return existing
 		})
 
+		// Persist credentials after the upsert so the row exists.
+		if (data.credentials !== undefined && this.encryptor) {
+			const encrypted = this.encryptor.encrypt(JSON.stringify(data.credentials))
+			await sources(this.db, userId).updateCredentials(sourceId, encrypted)
+		}
+
 		const session = this.sessions.get(userId)
 		if (session) {
 			if (!data.enabled) {
@@ -363,7 +346,6 @@ export class UserSessionManager {
 
 	private async createSession(userId: string): Promise<UserSession> {
 		const enabledRows = await sources(this.db, userId).enabled()
-		const agentConfig = this.queryAgentConfigForUser(userId)
 
 		const promises: Promise<FeedSource>[] = []
 		for (const row of enabledRows) {
@@ -375,7 +357,7 @@ export class UserSessionManager {
 		}
 
 		if (promises.length === 0) {
-			return this.initializedSession(userId, [], agentConfig)
+			return new UserSession(userId, [], this.feedEnhancer)
 		}
 
 		const results = await Promise.allSettled(promises)
@@ -399,29 +381,7 @@ export class UserSessionManager {
 			console.error("[UserSessionManager] Feed source provider failed:", error)
 		}
 
-		return this.initializedSession(userId, feedSources, agentConfig)
+		return new UserSession(userId, feedSources, this.feedEnhancer)
-	}
-
-	private queryAgentConfigForUser(userId: string): UserSessionAgentConfig {
-		return {
-			...(this.queryAgentConfig ?? {}),
-			conversationStorage: conversations(this.db, userId),
-		}
-	}
-
-	private async initializedSession(
-		userId: string,
-		sources: FeedSource[],
-		agentConfig: UserSessionAgentConfig,
-	): Promise<UserSession> {
-		const session = new UserSession(userId, sources, this.feedEnhancer, agentConfig)
-		try {
-			await session.initialize()
-			return session
-		} catch (err) {
-			session.destroy()
-			throw err
-		}
 	}
 
 	/**

apps/aelis-backend/src/session/user-session.test.ts

@@ -1,15 +1,8 @@
-import type { ActionDefinition, ContextEntry, FeedItem, FeedSource } from "@freya/core"
+import type { ActionDefinition, ContextEntry, FeedItem, FeedSource } from "@aelis/core"
 
-import { ConversationEntryKind } from "@freya/core"
+import { LocationSource } from "@aelis/source-location"
-import { LocationSource } from "@freya/source-location"
 import { describe, expect, spyOn, test } from "bun:test"
 
-import type {
-	ConversationStorage,
-	ConversationStorageEntry,
-} from "../agent/conversation-recording-query-agent.ts"
-import type { AppendConversationEntryInput } from "../conversations/storage.ts"
-
 import { UserSession } from "./user-session.ts"
 
 function createStubSource(id: string, items: FeedItem[] = []): FeedSource {
@@ -30,40 +23,6 @@ function createStubSource(id: string, items: FeedItem[] = []): FeedSource {
 	}
 }
 
-class FakeConversationStorage implements ConversationStorage {
-	readonly calls: string[] = []
-	private readonly entries: ConversationStorageEntry[]
-
-	constructor(entries: ConversationStorageEntry[] = []) {
-		this.entries = entries
-	}
-
-	async getOrCreateConversation(): Promise<{ id: string }> {
-		this.calls.push("getOrCreateConversation")
-		return { id: "conversation-1" }
-	}
-
-	async appendEntry(
-		_conversationId: string,
-		input: AppendConversationEntryInput,
-	): Promise<ConversationStorageEntry> {
-		this.calls.push("appendEntry")
-		return {
-			id: "entry-appended",
-			sequence: 1,
-			kind: input.kind,
-			payload: input.payload,
-			metadata: input.metadata ?? {},
-			createdAt: new Date("2026-06-15T00:00:00.000Z"),
-		}
-	}
-
-	async listEntries(_conversationId: string): Promise<ConversationStorageEntry[]> {
-		this.calls.push("listEntries")
-		return this.entries
-	}
-}
-
 describe("UserSession", () => {
 	test("registers sources and starts engine", async () => {
 		const session = new UserSession("test-user", [
@@ -80,7 +39,7 @@ describe("UserSession", () => {
 		const location = new LocationSource()
 		const session = new UserSession("test-user", [location])
 
-		const result = session.getSource<LocationSource>("freya.location")
+		const result = session.getSource<LocationSource>("aelis.location")
 
 		expect(result).toBe(location)
 	})
@@ -99,46 +58,11 @@ describe("UserSession", () => {
 		expect(session.getSource("test")).toBeUndefined()
 	})
 
-	test("destroy disposes query agent", () => {
-		const session = new UserSession("test-user", [createStubSource("test")])
-		const disposeSpy = spyOn(session.agent, "dispose")
-
-		session.destroy()
-
-		expect(disposeSpy).toHaveBeenCalled()
-	})
-
-	test("initialize loads conversation entries before exposing stored agent", async () => {
-		const storage = new FakeConversationStorage([
-			{
-				id: "entry-1",
-				sequence: 1,
-				kind: ConversationEntryKind.UserMessage,
-				payload: {
-					role: "user",
-					parts: [{ type: "text", text: "stored hello" }],
-				},
-				metadata: {},
-				createdAt: new Date("2026-06-15T00:00:00.000Z"),
-			},
-		])
-		const session = new UserSession("test-user", [createStubSource("test")], null, {
-			conversationStorage: storage,
-		})
-
-		expect(() => session.agent).toThrow("UserSession has not been initialized")
-
-		await session.initialize()
-
-		expect(storage.calls).toEqual(["getOrCreateConversation", "listEntries"])
-		expect(session.agent).toBeDefined()
-	})
-
 	test("engine.executeAction routes to correct source", async () => {
 		const location = new LocationSource()
 		const session = new UserSession("test-user", [location])
 
-		await session.engine.executeAction("freya.location", "update-location", {
+		await session.engine.executeAction("aelis.location", "update-location", {
 			lat: 51.5,
 			lng: -0.1,
 			accuracy: 10,

apps/aelis-backend/src/session/user-session.ts

@@ -1,55 +1,22 @@
-import {
+import { FeedEngine, type FeedItem, type FeedResult, type FeedSource } from "@aelis/core"
-	FeedEngine,
-	type ActionDefinition,
-	type FeedItem,
-	type FeedResult,
-	type FeedSource,
-} from "@freya/core"
 
-import type { QueryAgentToolbox } from "../agent/query-agent-toolbox.ts"
-import type { QueryAgent } from "../agent/query-agent.ts"
 import type { FeedEnhancer } from "../enhancement/enhance-feed.ts"
 
-import {
-	ConversationRecordingQueryAgent,
-	type ConversationStorage,
-} from "../agent/conversation-recording-query-agent.ts"
-import { PiQueryAgent, PI_MODEL_ID, PI_MODEL_PROVIDER } from "../agent/pi-query-agent.ts"
-import { UserSessionQueryAgentToolbox } from "../agent/user-session-query-agent-toolbox.ts"
-
-export interface UserSessionAgentConfig {
-	apiKey?: string
-	cwd?: string
-	systemPrompt?: string
-	conversationStorage?: ConversationStorage
-}
-
 export class UserSession {
 	readonly userId: string
 	readonly engine: FeedEngine
-	readonly toolbox: QueryAgentToolbox
 	private sources = new Map<string, FeedSource>()
 	private readonly enhancer: FeedEnhancer | null
-	private readonly agentConfig: UserSessionAgentConfig | undefined
-	private queryAgent: QueryAgent | null = null
-	private initializePromise: Promise<void> | null = null
-	private initialized = false
 	private enhancedItems: FeedItem[] | null = null
 	/** The FeedResult that enhancedItems was derived from. */
 	private enhancedSource: FeedResult | null = null
 	private enhancingPromise: Promise<void> | null = null
 	private unsubscribe: (() => void) | null = null
 
-	constructor(
+	constructor(userId: string, sources: FeedSource[], enhancer?: FeedEnhancer | null) {
-		userId: string,
-		sources: FeedSource[],
-		enhancer?: FeedEnhancer | null,
-		agentConfig?: UserSessionAgentConfig,
-	) {
 		this.userId = userId
 		this.engine = new FeedEngine()
 		this.enhancer = enhancer ?? null
-		this.agentConfig = agentConfig
 		for (const source of sources) {
 			this.sources.set(source.id, source)
 			this.engine.register(source)
@@ -62,44 +29,9 @@ export class UserSession {
 			})
 		}
 
-		this.toolbox = new UserSessionQueryAgentToolbox(this)
-		if (!agentConfig?.conversationStorage) {
-			this.queryAgent = new PiQueryAgent({
-				toolbox: this.toolbox,
-				apiKey: this.agentConfig?.apiKey,
-				cwd: this.agentConfig?.cwd,
-				systemPrompt: this.agentConfig?.systemPrompt,
-			})
-			this.initialized = true
-		}
-
 		this.engine.start()
 	}
 
-	get agent(): QueryAgent {
-		if (!this.queryAgent) {
-			throw new Error("UserSession has not been initialized")
-		}
-		return this.queryAgent
-	}
-
-	async initialize(): Promise<void> {
-		if (this.initialized) return
-		if (this.initializePromise) return this.initializePromise
-
-		const promise = this.initializeAgent()
-		this.initializePromise = promise
-
-		try {
-			await promise
-			this.initialized = true
-		} finally {
-			if (this.initializePromise === promise) {
-				this.initializePromise = null
-			}
-		}
-	}
-
 	/**
 	 * Returns the current feed, refreshing if the engine cache expired.
 	 * Enhancement runs eagerly on engine updates; this method awaits
@@ -141,21 +73,6 @@ export class UserSession {
 		return this.sources.has(sourceId)
 	}
 
-	async listActions(): Promise<
-		Array<{ sourceId: string; actions: Record<string, ActionDefinition> }>
-	> {
-		const result: Array<{ sourceId: string; actions: Record<string, ActionDefinition> }> = []
-
-		for (const [sourceId, source] of this.sources) {
-			result.push({
-				sourceId,
-				actions: await source.listActions(),
-			})
-		}
-
-		return result
-	}
-
 	/**
 	 * Registers a new source in the engine and invalidates all caches.
 	 * Stops and restarts the engine to establish reactive subscriptions.
@@ -236,8 +153,6 @@ export class UserSession {
 	}
 
 	destroy(): void {
-		this.queryAgent?.dispose()
-		this.queryAgent = null
 		this.unsubscribe?.()
 		this.unsubscribe = null
 		this.engine.stop()
@@ -246,38 +161,6 @@ export class UserSession {
 		this.enhancingPromise = null
 	}
 
-	private async initializeAgent(): Promise<void> {
-		if (this.queryAgent) return
-
-		const conversationStorage = this.agentConfig?.conversationStorage
-		if (!conversationStorage) {
-			this.queryAgent = new PiQueryAgent({
-				toolbox: this.toolbox,
-				apiKey: this.agentConfig?.apiKey,
-				cwd: this.agentConfig?.cwd,
-				systemPrompt: this.agentConfig?.systemPrompt,
-			})
-			return
-		}
-
-		const conversation = await conversationStorage.getOrCreateConversation()
-		const entries = await conversationStorage.listEntries(conversation.id)
-
-		this.queryAgent = new ConversationRecordingQueryAgent({
-			agent: new PiQueryAgent({
-				toolbox: this.toolbox,
-				apiKey: this.agentConfig?.apiKey,
-				cwd: this.agentConfig?.cwd,
-				systemPrompt: this.agentConfig?.systemPrompt,
-				initialEntries: entries,
-			}),
-			storage: conversationStorage,
-			defaultConversationId: conversation.id,
-			modelProvider: PI_MODEL_PROVIDER,
-			modelId: PI_MODEL_ID,
-		})
-	}
-
 	private invalidateEnhancement(): void {
 		this.enhancedItems = null
 		this.enhancedSource = null

apps/aelis-backend/src/sources/http.test.ts

@@ -1,4 +1,4 @@
-import type { ActionDefinition, ContextEntry, FeedItem, FeedSource } from "@freya/core"
+import type { ActionDefinition, ContextEntry, FeedItem, FeedSource } from "@aelis/core"
 
 import { describe, expect, mock, spyOn, test } from "bun:test"
 import { Hono } from "hono"
@@ -80,9 +80,6 @@ function createInMemoryStore() {
 				async find(sourceId: string) {
 					return rows.get(key(userId, sourceId))
 				},
-				async findForUpdate(sourceId: string) {
-					return rows.get(key(userId, sourceId))
-				},
 				async updateConfig(sourceId: string, update: { enabled?: boolean; config?: unknown }) {
 					const existing = rows.get(key(userId, sourceId))
 					if (!existing) {
@@ -128,23 +125,7 @@ mock.module("../sources/user-sources.ts", () => ({
 	},
 }))
 
-mock.module("../conversations/storage.ts", () => ({
+const fakeDb = {} as Database
-	conversations: (_db: Database, userId: string) => ({
-		async getOrCreateConversation() {
-			return { id: `conversation-${userId}` }
-		},
-		async listEntries() {
-			return []
-		},
-		async appendEntry() {
-			return { id: "entry-1", sequence: 1 }
-		},
-	}),
-}))
-
-const fakeDb = {
-	transaction: <T>(fn: (tx: unknown) => Promise<T>) => fn(fakeDb),
-} as unknown as Database
 
 function createApp(providers: FeedSourceProvider[], userId?: string) {
 	const sessionManager = new UserSessionManager({ providers, db: fakeDb })
@@ -200,18 +181,6 @@ function put(app: Hono, sourceId: string, body: unknown) {
 	})
 }
 
-function listActions(app: Hono, sourceId: string) {
-	return app.request(`/api/sources/${sourceId}/actions`, { method: "GET" })
-}
-
-function executeAction(app: Hono, sourceId: string, actionId: string, body: unknown) {
-	return app.request(`/api/sources/${sourceId}/actions/${actionId}`, {
-		method: "POST",
-		headers: { "Content-Type": "application/json" },
-		body: JSON.stringify(body),
-	})
-}
-
 // ---------------------------------------------------------------------------
 // Tests
 // ---------------------------------------------------------------------------
@@ -219,16 +188,16 @@ function executeAction(app: Hono, sourceId: string, actionId: string, body: unkn
 describe("GET /api/sources/:sourceId", () => {
 	test("returns 401 without auth", async () => {
 		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)])
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)])
 
-		const res = await get(app, "freya.weather")
+		const res = await get(app, "aelis.weather")
 
 		expect(res.status).toBe(401)
 	})
 
 	test("returns 404 for unknown source", async () => {
 		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
 		const res = await get(app, "unknown.source")
 
@@ -239,13 +208,13 @@ describe("GET /api/sources/:sourceId", () => {
 
 	test("returns enabled and config for existing source", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.weather", {
+		activeStore.seed(MOCK_USER_ID, "aelis.weather", {
 			enabled: true,
 			config: { units: "metric" },
 		})
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await get(app, "freya.weather")
+		const res = await get(app, "aelis.weather")
 
 		expect(res.status).toBe(200)
 		const body = (await res.json()) as { enabled: boolean; config: unknown }
@@ -255,9 +224,9 @@ describe("GET /api/sources/:sourceId", () => {
 
 	test("returns defaults when user has no row for source", async () => {
 		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await get(app, "freya.weather")
+		const res = await get(app, "aelis.weather")
 
 		expect(res.status).toBe(200)
 		const body = (await res.json()) as { enabled: boolean; config: unknown }
@@ -267,13 +236,13 @@ describe("GET /api/sources/:sourceId", () => {
 
 	test("returns disabled source", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.weather", {
+		activeStore.seed(MOCK_USER_ID, "aelis.weather", {
 			enabled: false,
 			config: { units: "imperial" },
 		})
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await get(app, "freya.weather")
+		const res = await get(app, "aelis.weather")
 
 		expect(res.status).toBe(200)
 		const body = (await res.json()) as { enabled: boolean; config: unknown }
@@ -285,16 +254,16 @@ describe("GET /api/sources/:sourceId", () => {
 describe("PATCH /api/sources/:sourceId", () => {
 	test("returns 401 without auth", async () => {
 		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)])
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)])
 
-		const res = await patch(app, "freya.weather", { enabled: true })
+		const res = await patch(app, "aelis.weather", { enabled: true })
 
 		expect(res.status).toBe(401)
 	})
 
 	test("returns 404 for unknown source", async () => {
 		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
 		const res = await patch(app, "unknown.source", { enabled: true })
 
@@ -305,9 +274,9 @@ describe("PATCH /api/sources/:sourceId", () => {
 
 	test("returns 404 when user has no existing row for source", async () => {
 		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await patch(app, "freya.weather", { enabled: true })
+		const res = await patch(app, "aelis.weather", { enabled: true })
 
 		expect(res.status).toBe(404)
 		const body = (await res.json()) as { error: string }
@@ -316,29 +285,29 @@ describe("PATCH /api/sources/:sourceId", () => {
 
 	test("returns 204 when body is empty object (no-op) on existing source", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.weather")
+		activeStore.seed(MOCK_USER_ID, "aelis.weather")
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await patch(app, "freya.weather", {})
+		const res = await patch(app, "aelis.weather", {})
 
 		expect(res.status).toBe(204)
 	})
 
 	test("returns 404 when body is empty object on nonexistent user source", async () => {
 		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await patch(app, "freya.weather", {})
+		const res = await patch(app, "aelis.weather", {})
 
 		expect(res.status).toBe(404)
 	})
 
 	test("returns 400 for invalid JSON body", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.weather")
+		activeStore.seed(MOCK_USER_ID, "aelis.weather")
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await app.request("/api/sources/freya.weather", {
+		const res = await app.request("/api/sources/aelis.weather", {
 			method: "PATCH",
 			headers: { "Content-Type": "application/json" },
 			body: "not json",
@@ -351,10 +320,10 @@ describe("PATCH /api/sources/:sourceId", () => {
 
 	test("returns 400 when request body contains unknown fields", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.weather")
+		activeStore.seed(MOCK_USER_ID, "aelis.weather")
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await patch(app, "freya.weather", {
+		const res = await patch(app, "aelis.weather", {
 			enabled: true,
 			unknownField: "hello",
 		})
@@ -364,10 +333,10 @@ describe("PATCH /api/sources/:sourceId", () => {
 
 	test("returns 400 when weather config contains unknown fields", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.weather")
+		activeStore.seed(MOCK_USER_ID, "aelis.weather")
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await patch(app, "freya.weather", {
+		const res = await patch(app, "aelis.weather", {
 			config: { units: "metric", unknownField: "hello" },
 		})
 
@@ -376,10 +345,10 @@ describe("PATCH /api/sources/:sourceId", () => {
 
 	test("returns 400 when weather config fails validation", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.weather")
+		activeStore.seed(MOCK_USER_ID, "aelis.weather")
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await patch(app, "freya.weather", {
+		const res = await patch(app, "aelis.weather", {
 			config: { units: "invalid" },
 		})
 
@@ -388,65 +357,65 @@ describe("PATCH /api/sources/:sourceId", () => {
 
 	test("returns 204 and updates enabled", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.weather", {
+		activeStore.seed(MOCK_USER_ID, "aelis.weather", {
 			enabled: true,
 			config: { units: "metric" },
 		})
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await patch(app, "freya.weather", { enabled: false })
+		const res = await patch(app, "aelis.weather", { enabled: false })
 
 		expect(res.status).toBe(204)
-		const row = activeStore.rows.get(`${MOCK_USER_ID}:freya.weather`)
+		const row = activeStore.rows.get(`${MOCK_USER_ID}:aelis.weather`)
 		expect(row!.enabled).toBe(false)
 		expect(row!.config).toEqual({ units: "metric" })
 	})
 
 	test("returns 204 and updates config", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.weather", {
+		activeStore.seed(MOCK_USER_ID, "aelis.weather", {
 			config: { units: "metric" },
 		})
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await patch(app, "freya.weather", {
+		const res = await patch(app, "aelis.weather", {
 			config: { units: "imperial" },
 		})
 
 		expect(res.status).toBe(204)
-		const row = activeStore.rows.get(`${MOCK_USER_ID}:freya.weather`)
+		const row = activeStore.rows.get(`${MOCK_USER_ID}:aelis.weather`)
 		expect(row!.config).toEqual({ units: "imperial" })
 	})
 
 	test("preserves config when only updating enabled", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.tfl", {
+		activeStore.seed(MOCK_USER_ID, "aelis.tfl", {
 			enabled: true,
 			config: { lines: ["bakerloo"] },
 		})
-		const { app } = createApp([createStubProvider("freya.tfl", tflConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.tfl", tflConfig)], MOCK_USER_ID)
 
-		const res = await patch(app, "freya.tfl", { enabled: false })
+		const res = await patch(app, "aelis.tfl", { enabled: false })
 
 		expect(res.status).toBe(204)
-		const row = activeStore.rows.get(`${MOCK_USER_ID}:freya.tfl`)
+		const row = activeStore.rows.get(`${MOCK_USER_ID}:aelis.tfl`)
 		expect(row!.enabled).toBe(false)
 		expect(row!.config).toEqual({ lines: ["bakerloo"] })
 	})
 
 	test("deep-merges config on update", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.weather", {
+		activeStore.seed(MOCK_USER_ID, "aelis.weather", {
 			config: { units: "metric", hourlyLimit: 12 },
 		})
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await patch(app, "freya.weather", {
+		const res = await patch(app, "aelis.weather", {
 			config: { dailyLimit: 5 },
 		})
 
 		expect(res.status).toBe(204)
-		const row = activeStore.rows.get(`${MOCK_USER_ID}:freya.weather`)
+		const row = activeStore.rows.get(`${MOCK_USER_ID}:aelis.weather`)
 		expect(row!.config).toEqual({
 			units: "metric",
 			hourlyLimit: 12,
@@ -456,18 +425,18 @@ describe("PATCH /api/sources/:sourceId", () => {
 
 	test("refreshes source in active session after config update", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.weather", {
+		activeStore.seed(MOCK_USER_ID, "aelis.weather", {
 			config: { units: "metric" },
 		})
 		const { app, sessionManager } = createApp(
-			[createStubProvider("freya.weather", weatherConfig)],
+			[createStubProvider("aelis.weather", weatherConfig)],
 			MOCK_USER_ID,
 		)
 
 		const session = await sessionManager.getOrCreate(MOCK_USER_ID)
 		const replaceSpy = spyOn(session, "replaceSource")
 
-		const res = await patch(app, "freya.weather", {
+		const res = await patch(app, "aelis.weather", {
 			config: { units: "imperial" },
 		})
 
@@ -478,31 +447,31 @@ describe("PATCH /api/sources/:sourceId", () => {
 
 	test("removes source from session when disabled", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.weather", {
+		activeStore.seed(MOCK_USER_ID, "aelis.weather", {
 			enabled: true,
 			config: { units: "metric" },
 		})
 		const { app, sessionManager } = createApp(
-			[createStubProvider("freya.weather", weatherConfig)],
+			[createStubProvider("aelis.weather", weatherConfig)],
 			MOCK_USER_ID,
 		)
 
 		const session = await sessionManager.getOrCreate(MOCK_USER_ID)
 		const removeSpy = spyOn(session, "removeSource")
 
-		const res = await patch(app, "freya.weather", { enabled: false })
+		const res = await patch(app, "aelis.weather", { enabled: false })
 
 		expect(res.status).toBe(204)
-		expect(removeSpy).toHaveBeenCalledWith("freya.weather")
+		expect(removeSpy).toHaveBeenCalledWith("aelis.weather")
 		removeSpy.mockRestore()
 	})
 
 	test("returns 400 when config is provided for source without schema", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.location")
+		activeStore.seed(MOCK_USER_ID, "aelis.location")
-		const { app } = createApp([createStubProvider("freya.location")], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.location")], MOCK_USER_ID)
 
-		const res = await patch(app, "freya.location", {
+		const res = await patch(app, "aelis.location", {
 			config: { something: "value" },
 		})
 
@@ -511,10 +480,10 @@ describe("PATCH /api/sources/:sourceId", () => {
 
 	test("returns 400 when empty config is provided for source without schema", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.location")
+		activeStore.seed(MOCK_USER_ID, "aelis.location")
-		const { app } = createApp([createStubProvider("freya.location")], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.location")], MOCK_USER_ID)
 
-		const res = await patch(app, "freya.location", {
+		const res = await patch(app, "aelis.location", {
 			config: {},
 		})
 
@@ -523,13 +492,13 @@ describe("PATCH /api/sources/:sourceId", () => {
 
 	test("updates enabled on location source", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.location", { enabled: true })
+		activeStore.seed(MOCK_USER_ID, "aelis.location", { enabled: true })
-		const { app } = createApp([createStubProvider("freya.location")], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.location")], MOCK_USER_ID)
 
-		const res = await patch(app, "freya.location", { enabled: false })
+		const res = await patch(app, "aelis.location", { enabled: false })
 
 		expect(res.status).toBe(204)
-		const row = activeStore.rows.get(`${MOCK_USER_ID}:freya.location`)
+		const row = activeStore.rows.get(`${MOCK_USER_ID}:aelis.location`)
 		expect(row!.enabled).toBe(false)
 	})
 })
@@ -541,16 +510,16 @@ describe("PATCH /api/sources/:sourceId", () => {
 describe("PUT /api/sources/:sourceId", () => {
 	test("returns 401 without auth", async () => {
 		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)])
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)])
 
-		const res = await put(app, "freya.weather", { enabled: true, config: {} })
+		const res = await put(app, "aelis.weather", { enabled: true, config: {} })
 
 		expect(res.status).toBe(401)
 	})
 
 	test("returns 404 for unknown source", async () => {
 		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
 		const res = await put(app, "unknown.source", { enabled: true, config: {} })
 
@@ -561,9 +530,9 @@ describe("PUT /api/sources/:sourceId", () => {
 
 	test("returns 400 for invalid JSON", async () => {
 		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await app.request("/api/sources/freya.weather", {
+		const res = await app.request("/api/sources/aelis.weather", {
 			method: "PUT",
 			headers: { "Content-Type": "application/json" },
 			body: "not json",
@@ -576,27 +545,27 @@ describe("PUT /api/sources/:sourceId", () => {
 
 	test("returns 400 when enabled is missing", async () => {
 		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await put(app, "freya.weather", { config: {} })
+		const res = await put(app, "aelis.weather", { config: {} })
 
 		expect(res.status).toBe(400)
 	})
 
 	test("returns 400 when config is missing", async () => {
 		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await put(app, "freya.weather", { enabled: true })
+		const res = await put(app, "aelis.weather", { enabled: true })
 
 		expect(res.status).toBe(400)
 	})
 
 	test("returns 400 when request body contains unknown fields", async () => {
 		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await put(app, "freya.weather", {
+		const res = await put(app, "aelis.weather", {
 			enabled: true,
 			config: { units: "metric" },
 			unknownField: "hello",
@@ -607,9 +576,9 @@ describe("PUT /api/sources/:sourceId", () => {
 
 	test("returns 400 when weather config contains unknown fields", async () => {
 		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await put(app, "freya.weather", {
+		const res = await put(app, "aelis.weather", {
 			enabled: true,
 			config: { units: "metric", unknownField: "hello" },
 		})
@@ -619,9 +588,9 @@ describe("PUT /api/sources/:sourceId", () => {
 
 	test("returns 400 when config fails schema validation", async () => {
 		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await put(app, "freya.weather", {
+		const res = await put(app, "aelis.weather", {
 			enabled: true,
 			config: { units: "invalid" },
 		})
@@ -631,15 +600,15 @@ describe("PUT /api/sources/:sourceId", () => {
 
 	test("returns 204 and inserts when row does not exist", async () => {
 		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await put(app, "freya.weather", {
+		const res = await put(app, "aelis.weather", {
 			enabled: true,
 			config: { units: "metric" },
 		})
 
 		expect(res.status).toBe(204)
-		const row = activeStore.rows.get(`${MOCK_USER_ID}:freya.weather`)
+		const row = activeStore.rows.get(`${MOCK_USER_ID}:aelis.weather`)
 		expect(row).toBeDefined()
 		expect(row!.enabled).toBe(true)
 		expect(row!.config).toEqual({ units: "metric" })
@@ -647,19 +616,19 @@ describe("PUT /api/sources/:sourceId", () => {
 
 	test("returns 204 and fully replaces existing row", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.weather", {
+		activeStore.seed(MOCK_USER_ID, "aelis.weather", {
 			enabled: true,
 			config: { units: "metric", hourlyLimit: 12 },
 		})
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await put(app, "freya.weather", {
+		const res = await put(app, "aelis.weather", {
 			enabled: false,
 			config: { units: "imperial" },
 		})
 
 		expect(res.status).toBe(204)
-		const row = activeStore.rows.get(`${MOCK_USER_ID}:freya.weather`)
+		const row = activeStore.rows.get(`${MOCK_USER_ID}:aelis.weather`)
 		expect(row!.enabled).toBe(false)
 		// hourlyLimit should be gone — full replace, not merge
 		expect(row!.config).toEqual({ units: "imperial" })
@@ -667,18 +636,18 @@ describe("PUT /api/sources/:sourceId", () => {
 
 	test("refreshes source in active session after upsert", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.weather", {
+		activeStore.seed(MOCK_USER_ID, "aelis.weather", {
 			config: { units: "metric" },
 		})
 		const { app, sessionManager } = createApp(
-			[createStubProvider("freya.weather", weatherConfig)],
+			[createStubProvider("aelis.weather", weatherConfig)],
 			MOCK_USER_ID,
 		)
 
 		const session = await sessionManager.getOrCreate(MOCK_USER_ID)
 		const replaceSpy = spyOn(session, "replaceSource")
 
-		const res = await put(app, "freya.weather", {
+		const res = await put(app, "aelis.weather", {
 			enabled: true,
 			config: { units: "imperial" },
 		})
@@ -690,56 +659,56 @@ describe("PUT /api/sources/:sourceId", () => {
 
 	test("removes source from session when disabled via upsert", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.weather", {
+		activeStore.seed(MOCK_USER_ID, "aelis.weather", {
 			enabled: true,
 			config: { units: "metric" },
 		})
 		const { app, sessionManager } = createApp(
-			[createStubProvider("freya.weather", weatherConfig)],
+			[createStubProvider("aelis.weather", weatherConfig)],
 			MOCK_USER_ID,
 		)
 
 		const session = await sessionManager.getOrCreate(MOCK_USER_ID)
 		const removeSpy = spyOn(session, "removeSource")
 
-		const res = await put(app, "freya.weather", {
+		const res = await put(app, "aelis.weather", {
 			enabled: false,
 			config: { units: "metric" },
 		})
 
 		expect(res.status).toBe(204)
-		expect(removeSpy).toHaveBeenCalledWith("freya.weather")
+		expect(removeSpy).toHaveBeenCalledWith("aelis.weather")
 		removeSpy.mockRestore()
 	})
 
 	test("adds source to active session when inserting a new source", async () => {
 		activeStore = createInMemoryStore()
 		// Seed a different source so the session can be created
-		activeStore.seed(MOCK_USER_ID, "freya.location", { enabled: true })
+		activeStore.seed(MOCK_USER_ID, "aelis.location", { enabled: true })
 		const { app, sessionManager } = createApp(
-			[createStubProvider("freya.location"), createStubProvider("freya.weather", weatherConfig)],
+			[createStubProvider("aelis.location"), createStubProvider("aelis.weather", weatherConfig)],
 			MOCK_USER_ID,
 		)
 
-		// Create session — only has freya.location
+		// Create session — only has aelis.location
 		const session = await sessionManager.getOrCreate(MOCK_USER_ID)
-		expect(session.hasSource("freya.weather")).toBe(false)
+		expect(session.hasSource("aelis.weather")).toBe(false)
 
 		// PUT a new source that didn't exist before
-		const res = await put(app, "freya.weather", {
+		const res = await put(app, "aelis.weather", {
 			enabled: true,
 			config: { units: "metric" },
 		})
 
 		expect(res.status).toBe(204)
-		expect(session.hasSource("freya.weather")).toBe(true)
+		expect(session.hasSource("aelis.weather")).toBe(true)
 	})
 
 	test("returns 400 when config is provided for source without schema", async () => {
 		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.location")], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.location")], MOCK_USER_ID)
 
-		const res = await put(app, "freya.location", {
+		const res = await put(app, "aelis.location", {
 			enabled: true,
 			config: { something: "value" },
 		})
@@ -749,9 +718,9 @@ describe("PUT /api/sources/:sourceId", () => {
 
 	test("returns 400 when empty config is provided for source without schema", async () => {
 		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.location")], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.location")], MOCK_USER_ID)
 
-		const res = await put(app, "freya.location", {
+		const res = await put(app, "aelis.location", {
 			enabled: true,
 			config: {},
 		})
@@ -761,9 +730,9 @@ describe("PUT /api/sources/:sourceId", () => {
 
 	test("returns 204 without config field for source without schema", async () => {
 		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.location")], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.location")], MOCK_USER_ID)
 
-		const res = await put(app, "freya.location", {
+		const res = await put(app, "aelis.location", {
 			enabled: true,
 		})
 
@@ -773,18 +742,18 @@ describe("PUT /api/sources/:sourceId", () => {
 	test("returns 204 when credentials are included alongside config", async () => {
 		activeStore = createInMemoryStore()
 		const { app } = createAppWithEncryptor(
-			[createStubProvider("freya.weather", weatherConfig)],
+			[createStubProvider("aelis.weather", weatherConfig)],
 			MOCK_USER_ID,
 		)
 
-		const res = await put(app, "freya.weather", {
+		const res = await put(app, "aelis.weather", {
 			enabled: true,
 			config: { units: "metric" },
 			credentials: { apiKey: "secret123" },
 		})
 
 		expect(res.status).toBe(204)
-		const row = activeStore.rows.get(`${MOCK_USER_ID}:freya.weather`)
+		const row = activeStore.rows.get(`${MOCK_USER_ID}:aelis.weather`)
 		expect(row).toBeDefined()
 		expect(row!.enabled).toBe(true)
 		expect(row!.config).toEqual({ units: "metric" })
@@ -793,9 +762,9 @@ describe("PUT /api/sources/:sourceId", () => {
 	test("returns 503 when credentials are provided but no encryptor is configured", async () => {
 		activeStore = createInMemoryStore()
 		// createApp does NOT configure an encryptor
-		const { app } = createApp([createStubProvider("freya.weather", weatherConfig)], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.weather", weatherConfig)], MOCK_USER_ID)
 
-		const res = await put(app, "freya.weather", {
+		const res = await put(app, "aelis.weather", {
 			enabled: true,
 			config: { units: "metric" },
 			credentials: { apiKey: "secret123" },
@@ -807,181 +776,19 @@ describe("PUT /api/sources/:sourceId", () => {
 	})
 })
 
-describe("GET /api/sources/:sourceId/actions", () => {
-	test("returns 401 without auth", async () => {
-		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.location")])
-
-		const res = await listActions(app, "freya.location")
-
-		expect(res.status).toBe(401)
-	})
-
-	test("returns 404 for source that is not enabled in the user session", async () => {
-		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.location")], MOCK_USER_ID)
-
-		const res = await listActions(app, "freya.location")
-
-		expect(res.status).toBe(404)
-	})
-
-	test("returns serializable action definitions", async () => {
-		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "test.actions")
-		const provider: FeedSourceProvider = {
-			sourceId: "test.actions",
-			async feedSourceForUser() {
-				return {
-					id: "test.actions",
-					async listActions() {
-						return {
-							search: {
-								id: "search",
-								description: "Search something",
-								input: tflConfig,
-							},
-						}
-					},
-					async executeAction() {
-						return undefined
-					},
-					async fetchContext() {
-						return null
-					},
-				}
-			},
-		}
-		const { app } = createApp([provider], MOCK_USER_ID)
-
-		const res = await listActions(app, "test.actions")
-
-		expect(res.status).toBe(200)
-		const body = (await res.json()) as {
-			actions: Record<string, { id: string; description?: string; input?: unknown }>
-		}
-		expect(body.actions.search).toEqual({
-			id: "search",
-			description: "Search something",
-		})
-	})
-})
-
-describe("POST /api/sources/:sourceId/actions/:actionId", () => {
-	test("returns 401 without auth", async () => {
-		activeStore = createInMemoryStore()
-		const { app } = createApp([createStubProvider("freya.location")])
-
-		const res = await executeAction(app, "freya.location", "update-location", {})
-
-		expect(res.status).toBe(401)
-	})
-
-	test("executes source action with request body as params", async () => {
-		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "test.actions")
-		let receivedParams: unknown
-		const provider: FeedSourceProvider = {
-			sourceId: "test.actions",
-			async feedSourceForUser() {
-				return {
-					id: "test.actions",
-					async listActions() {
-						return {
-							search: { id: "search", description: "Search something" },
-						}
-					},
-					async executeAction(_actionId: string, params: unknown) {
-						receivedParams = params
-						return { ok: true, count: 2 }
-					},
-					async fetchContext() {
-						return null
-					},
-				}
-			},
-		}
-		const { app } = createApp([provider], MOCK_USER_ID)
-
-		const res = await executeAction(app, "test.actions", "search", { query: "exa" })
-
-		expect(res.status).toBe(200)
-		expect(receivedParams).toEqual({ query: "exa" })
-		const body = (await res.json()) as { result: unknown }
-		expect(body.result).toEqual({ ok: true, count: 2 })
-	})
-
-	test("returns 404 for unknown action", async () => {
-		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.location")
-		const { app } = createApp([createStubProvider("freya.location")], MOCK_USER_ID)
-
-		const res = await executeAction(app, "freya.location", "missing", {})
-
-		expect(res.status).toBe(404)
-	})
-
-	test("returns 400 for invalid JSON", async () => {
-		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.location")
-		const { app } = createApp([createStubProvider("freya.location")], MOCK_USER_ID)
-
-		const res = await app.request("/api/sources/freya.location/actions/search", {
-			method: "POST",
-			headers: { "Content-Type": "application/json" },
-			body: "not-json",
-		})
-
-		expect(res.status).toBe(400)
-		const body = (await res.json()) as { error: string }
-		expect(body.error).toBe("Invalid JSON")
-	})
-
-	test("returns 400 when source rejects params", async () => {
-		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "test.actions")
-		const provider: FeedSourceProvider = {
-			sourceId: "test.actions",
-			async feedSourceForUser() {
-				return {
-					id: "test.actions",
-					async listActions() {
-						return {
-							search: { id: "search" },
-						}
-					},
-					async executeAction() {
-						throw new Error("query must not be empty")
-					},
-					async fetchContext() {
-						return null
-					},
-				}
-			},
-		}
-		const { app } = createApp([provider], MOCK_USER_ID)
-
-		const res = await executeAction(app, "test.actions", "search", { query: "" })
-
-		expect(res.status).toBe(400)
-		const body = (await res.json()) as { error: string }
-		expect(body.error).toBe("query must not be empty")
-	})
-})
-
 describe("PUT /api/sources/:sourceId/credentials", () => {
 	test("returns 401 without auth", async () => {
 		activeStore = createInMemoryStore()
-		const { app } = createAppWithEncryptor([createStubProvider("freya.location")])
+		const { app } = createAppWithEncryptor([createStubProvider("aelis.location")])
 
-		const res = await putCredentials(app, "freya.location", { token: "x" })
+		const res = await putCredentials(app, "aelis.location", { token: "x" })
 
 		expect(res.status).toBe(401)
 	})
 
 	test("returns 404 for unknown source", async () => {
 		activeStore = createInMemoryStore()
-		const { app } = createAppWithEncryptor([createStubProvider("freya.location")], MOCK_USER_ID)
+		const { app } = createAppWithEncryptor([createStubProvider("aelis.location")], MOCK_USER_ID)
 
 		const res = await putCredentials(app, "unknown.source", { token: "x" })
 
@@ -990,10 +797,10 @@ describe("PUT /api/sources/:sourceId/credentials", () => {
 
 	test("returns 400 for invalid JSON", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.location")
+		activeStore.seed(MOCK_USER_ID, "aelis.location")
-		const { app } = createAppWithEncryptor([createStubProvider("freya.location")], MOCK_USER_ID)
+		const { app } = createAppWithEncryptor([createStubProvider("aelis.location")], MOCK_USER_ID)
 
-		const res = await app.request("/api/sources/freya.location/credentials", {
+		const res = await app.request("/api/sources/aelis.location/credentials", {
 			method: "PUT",
 			headers: { "Content-Type": "application/json" },
 			body: "not-json",
@@ -1006,10 +813,10 @@ describe("PUT /api/sources/:sourceId/credentials", () => {
 
 	test("returns 204 and persists credentials", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.location")
+		activeStore.seed(MOCK_USER_ID, "aelis.location")
-		const { app } = createAppWithEncryptor([createStubProvider("freya.location")], MOCK_USER_ID)
+		const { app } = createAppWithEncryptor([createStubProvider("aelis.location")], MOCK_USER_ID)
 
-		const res = await putCredentials(app, "freya.location", { token: "secret" })
+		const res = await putCredentials(app, "aelis.location", { token: "secret" })
 
 		expect(res.status).toBe(204)
 	})
@@ -1041,10 +848,10 @@ describe("PUT /api/sources/:sourceId/credentials", () => {
 
 	test("returns 503 when credential encryption is not configured", async () => {
 		activeStore = createInMemoryStore()
-		activeStore.seed(MOCK_USER_ID, "freya.location")
+		activeStore.seed(MOCK_USER_ID, "aelis.location")
-		const { app } = createApp([createStubProvider("freya.location")], MOCK_USER_ID)
+		const { app } = createApp([createStubProvider("aelis.location")], MOCK_USER_ID)
 
-		const res = await putCredentials(app, "freya.location", { token: "x" })
+		const res = await putCredentials(app, "aelis.location", { token: "x" })
 
 		expect(res.status).toBe(503)
 		const body = (await res.json()) as { error: string }

apps/aelis-backend/src/sources/http.ts

@@ -1,4 +1,3 @@
-import type { ActionDefinition } from "@freya/core"
 import type { Context, Hono } from "hono"
 
 import { type } from "arktype"
@@ -56,13 +55,6 @@ export function registerSourcesHttpHandlers(
 	app.get("/api/sources/:sourceId", inject, authSessionMiddleware, handleGetSource)
 	app.patch("/api/sources/:sourceId", inject, authSessionMiddleware, handleUpdateSource)
 	app.put("/api/sources/:sourceId", inject, authSessionMiddleware, handleReplaceSource)
-	app.get("/api/sources/:sourceId/actions", inject, authSessionMiddleware, handleListActions)
-	app.post(
-		"/api/sources/:sourceId/actions/:actionId",
-		inject,
-		authSessionMiddleware,
-		handleExecuteAction,
-	)
 	app.put(
 		"/api/sources/:sourceId/credentials",
 		inject,
@@ -197,71 +189,6 @@ async function handleReplaceSource(c: Context<Env>) {
 	return c.body(null, 204)
 }
 
-async function handleListActions(c: Context<Env>) {
-	const sourceId = c.req.param("sourceId")
-	if (!sourceId) {
-		return c.body(null, 404)
-	}
-
-	const user = c.get("user")!
-	const sessionManager = c.get("sessionManager")
-
-	let session
-	try {
-		session = await sessionManager.getOrCreate(user.id)
-	} catch (err) {
-		console.error("[handleListActions] Failed to create session:", err)
-		return c.json({ error: "Service unavailable" }, 503)
-	}
-
-	try {
-		const actions = await session.engine.listActions(sourceId)
-		return c.json({ actions: serializeActions(actions) })
-	} catch (err) {
-		if (isActionNotFoundError(err)) {
-			return c.json({ error: err.message }, 404)
-		}
-		console.error(`[handleListActions] Failed to list actions for "${sourceId}":`, err)
-		return c.json({ error: "Failed to list actions" }, 500)
-	}
-}
-
-async function handleExecuteAction(c: Context<Env>) {
-	const sourceId = c.req.param("sourceId")
-	const actionId = c.req.param("actionId")
-	if (!sourceId || !actionId) {
-		return c.body(null, 404)
-	}
-
-	let params: unknown
-	try {
-		params = await c.req.json()
-	} catch {
-		return c.json({ error: "Invalid JSON" }, 400)
-	}
-
-	const user = c.get("user")!
-	const sessionManager = c.get("sessionManager")
-
-	let session
-	try {
-		session = await sessionManager.getOrCreate(user.id)
-	} catch (err) {
-		console.error("[handleExecuteAction] Failed to create session:", err)
-		return c.json({ error: "Service unavailable" }, 503)
-	}
-
-	try {
-		const result = await session.engine.executeAction(sourceId, actionId, params)
-		return c.json({ result })
-	} catch (err) {
-		if (isActionNotFoundError(err)) {
-			return c.json({ error: err.message }, 404)
-		}
-		return c.json({ error: err instanceof Error ? err.message : String(err) }, 400)
-	}
-}
-
 async function handleUpdateCredentials(c: Context<Env>) {
 	const sourceId = c.req.param("sourceId")
 	if (!sourceId) {
@@ -301,21 +228,3 @@ async function handleUpdateCredentials(c: Context<Env>) {
 
 	return c.body(null, 204)
 }
-
-function serializeActions(actions: Record<string, ActionDefinition>) {
-	const serialized: Record<string, { id: string; description?: string }> = {}
-	for (const [key, action] of Object.entries(actions)) {
-		serialized[key] = {
-			id: action.id,
-			...(action.description ? { description: action.description } : {}),
-		}
-	}
-	return serialized
-}
-
-function isActionNotFoundError(err: unknown): err is Error {
-	if (!(err instanceof Error)) {
-		return false
-	}
-	return err.message.startsWith("Source not found:") || err.message.startsWith("Action ")
-}

apps/aelis-backend/src/sources/user-sources.ts

@@ -26,18 +26,6 @@ export function sources(db: Database, userId: string) {
 			return rows[0]
 		},
 
-		/** Like find(), but acquires a row lock to prevent concurrent modifications. Must be called inside a transaction. */
-		async findForUpdate(sourceId: string) {
-			const rows = await db
-				.select()
-				.from(userSources)
-				.where(and(eq(userSources.userId, userId), eq(userSources.sourceId, sourceId)))
-				.limit(1)
-				.for("update")
-
-			return rows[0]
-		},
-
 		/** Enables a source for the user. Throws if the source row doesn't exist. */
 		async enableSource(sourceId: string) {
 			const rows = await db

apps/aelis-backend/src/tfl/provider.ts

@@ -1,4 +1,4 @@
-import { TflSource, type ITflApi, type TflLineId } from "@freya/source-tfl"
+import { TflSource, type ITflApi, type TflLineId } from "@aelis/source-tfl"
 import { type } from "arktype"
 
 import type { FeedSourceProvider } from "../session/feed-source-provider.ts"
@@ -13,7 +13,7 @@ export const tflConfig = type({
 })
 
 export class TflSourceProvider implements FeedSourceProvider {
-	readonly sourceId = "freya.tfl"
+	readonly sourceId = "aelis.tfl"
 	readonly configSchema = tflConfig
 	private readonly apiKey: string | undefined
 	private readonly client: ITflApi | undefined

apps/aelis-backend/src/weather/provider.ts

@@ -1,4 +1,4 @@
-import { WeatherSource, type WeatherSourceOptions } from "@freya/source-weatherkit"
+import { WeatherSource, type WeatherSourceOptions } from "@aelis/source-weatherkit"
 import { type } from "arktype"
 
 import type { FeedSourceProvider } from "../session/feed-source-provider.ts"
@@ -16,7 +16,7 @@ export const weatherConfig = type({
 })
 
 export class WeatherSourceProvider implements FeedSourceProvider {
-	readonly sourceId = "freya.weather"
+	readonly sourceId = "aelis.weather"
 	readonly configSchema = weatherConfig
 	private readonly credentials: WeatherSourceOptions["credentials"]
 	private readonly client: WeatherSourceOptions["client"]

apps/aelis-client/app.json

@@ -0,0 +1,152 @@
+{
+	"expo": {
+		"name": "Aelis",
+		"slug": "aelis-client",
+		"version": "1.0.0",
+		"orientation": "portrait",
+		"icon": "./assets/images/icon.png",
+		"scheme": "aelis",
+		"userInterfaceStyle": "automatic",
+		"newArchEnabled": true,
+		"ios": {
+			"infoPlist": {
+				"NSAppTransportSecurity": {
+					"NSAllowsArbitraryLoads": true
+				},
+				"ITSAppUsesNonExemptEncryption": false
+			},
+			"bundleIdentifier": "sh.nym.aelis"
+		},
+		"android": {
+			"adaptiveIcon": {
+				"backgroundColor": "#E6F4FE",
+				"foregroundImage": "./assets/images/android-icon-foreground.png",
+				"backgroundImage": "./assets/images/android-icon-background.png",
+				"monochromeImage": "./assets/images/android-icon-monochrome.png"
+			},
+			"edgeToEdgeEnabled": true,
+			"predictiveBackGestureEnabled": false,
+			"package": "sh.nym.aelis"
+		},
+		"web": {
+			"output": "static",
+			"favicon": "./assets/images/favicon.png"
+		},
+		"plugins": [
+			"expo-router",
+			[
+				"expo-splash-screen",
+				{
+					"image": "./assets/images/splash-icon.png",
+					"imageWidth": 200,
+					"resizeMode": "contain",
+					"backgroundColor": "#ffffff",
+					"dark": {
+						"backgroundColor": "#000000"
+					}
+				}
+			],
+			[
+				"expo-font",
+				{
+					"android": {
+						"fonts": [
+							{
+								"fontFamily": "Inter",
+								"fontDefinitions": [
+									{ "path": "./assets/fonts/Inter_100Thin.ttf", "weight": 100 },
+									{ "path": "./assets/fonts/Inter_100Thin_Italic.ttf", "weight": 100, "style": "italic" },
+									{ "path": "./assets/fonts/Inter_200ExtraLight.ttf", "weight": 200 },
+									{ "path": "./assets/fonts/Inter_200ExtraLight_Italic.ttf", "weight": 200, "style": "italic" },
+									{ "path": "./assets/fonts/Inter_300Light.ttf", "weight": 300 },
+									{ "path": "./assets/fonts/Inter_300Light_Italic.ttf", "weight": 300, "style": "italic" },
+									{ "path": "./assets/fonts/Inter_400Regular.ttf", "weight": 400 },
+									{ "path": "./assets/fonts/Inter_400Regular_Italic.ttf", "weight": 400, "style": "italic" },
+									{ "path": "./assets/fonts/Inter_500Medium.ttf", "weight": 500 },
+									{ "path": "./assets/fonts/Inter_500Medium_Italic.ttf", "weight": 500, "style": "italic" },
+									{ "path": "./assets/fonts/Inter_600SemiBold.ttf", "weight": 600 },
+									{ "path": "./assets/fonts/Inter_600SemiBold_Italic.ttf", "weight": 600, "style": "italic" },
+									{ "path": "./assets/fonts/Inter_700Bold.ttf", "weight": 700 },
+									{ "path": "./assets/fonts/Inter_700Bold_Italic.ttf", "weight": 700, "style": "italic" },
+									{ "path": "./assets/fonts/Inter_800ExtraBold.ttf", "weight": 800 },
+									{ "path": "./assets/fonts/Inter_800ExtraBold_Italic.ttf", "weight": 800, "style": "italic" },
+									{ "path": "./assets/fonts/Inter_900Black.ttf", "weight": 900 },
+									{ "path": "./assets/fonts/Inter_900Black_Italic.ttf", "weight": 900, "style": "italic" }
+								]
+							},
+							{
+								"fontFamily": "Source Serif 4",
+								"fontDefinitions": [
+									{ "path": "./assets/fonts/SourceSerif4_200ExtraLight.ttf", "weight": 200 },
+									{ "path": "./assets/fonts/SourceSerif4_200ExtraLight_Italic.ttf", "weight": 200, "style": "italic" },
+									{ "path": "./assets/fonts/SourceSerif4_300Light.ttf", "weight": 300 },
+									{ "path": "./assets/fonts/SourceSerif4_300Light_Italic.ttf", "weight": 300, "style": "italic" },
+									{ "path": "./assets/fonts/SourceSerif4_400Regular.ttf", "weight": 400 },
+									{ "path": "./assets/fonts/SourceSerif4_400Regular_Italic.ttf", "weight": 400, "style": "italic" },
+									{ "path": "./assets/fonts/SourceSerif4_500Medium.ttf", "weight": 500 },
+									{ "path": "./assets/fonts/SourceSerif4_500Medium_Italic.ttf", "weight": 500, "style": "italic" },
+									{ "path": "./assets/fonts/SourceSerif4_600SemiBold.ttf", "weight": 600 },
+									{ "path": "./assets/fonts/SourceSerif4_600SemiBold_Italic.ttf", "weight": 600, "style": "italic" },
+									{ "path": "./assets/fonts/SourceSerif4_700Bold.ttf", "weight": 700 },
+									{ "path": "./assets/fonts/SourceSerif4_700Bold_Italic.ttf", "weight": 700, "style": "italic" },
+									{ "path": "./assets/fonts/SourceSerif4_800ExtraBold.ttf", "weight": 800 },
+									{ "path": "./assets/fonts/SourceSerif4_800ExtraBold_Italic.ttf", "weight": 800, "style": "italic" },
+									{ "path": "./assets/fonts/SourceSerif4_900Black.ttf", "weight": 900 },
+									{ "path": "./assets/fonts/SourceSerif4_900Black_Italic.ttf", "weight": 900, "style": "italic" }
+								]
+							}
+						]
+					},
+					"ios": {
+						"fonts": [
+							"./assets/fonts/Inter_100Thin.ttf",
+							"./assets/fonts/Inter_100Thin_Italic.ttf",
+							"./assets/fonts/Inter_200ExtraLight.ttf",
+							"./assets/fonts/Inter_200ExtraLight_Italic.ttf",
+							"./assets/fonts/Inter_300Light.ttf",
+							"./assets/fonts/Inter_300Light_Italic.ttf",
+							"./assets/fonts/Inter_400Regular.ttf",
+							"./assets/fonts/Inter_400Regular_Italic.ttf",
+							"./assets/fonts/Inter_500Medium.ttf",
+							"./assets/fonts/Inter_500Medium_Italic.ttf",
+							"./assets/fonts/Inter_600SemiBold.ttf",
+							"./assets/fonts/Inter_600SemiBold_Italic.ttf",
+							"./assets/fonts/Inter_700Bold.ttf",
+							"./assets/fonts/Inter_700Bold_Italic.ttf",
+							"./assets/fonts/Inter_800ExtraBold.ttf",
+							"./assets/fonts/Inter_800ExtraBold_Italic.ttf",
+							"./assets/fonts/Inter_900Black.ttf",
+							"./assets/fonts/Inter_900Black_Italic.ttf",
+							"./assets/fonts/SourceSerif4_200ExtraLight.ttf",
+							"./assets/fonts/SourceSerif4_200ExtraLight_Italic.ttf",
+							"./assets/fonts/SourceSerif4_300Light.ttf",
+							"./assets/fonts/SourceSerif4_300Light_Italic.ttf",
+							"./assets/fonts/SourceSerif4_400Regular.ttf",
+							"./assets/fonts/SourceSerif4_400Regular_Italic.ttf",
+							"./assets/fonts/SourceSerif4_500Medium.ttf",
+							"./assets/fonts/SourceSerif4_500Medium_Italic.ttf",
+							"./assets/fonts/SourceSerif4_600SemiBold.ttf",
+							"./assets/fonts/SourceSerif4_600SemiBold_Italic.ttf",
+							"./assets/fonts/SourceSerif4_700Bold.ttf",
+							"./assets/fonts/SourceSerif4_700Bold_Italic.ttf",
+							"./assets/fonts/SourceSerif4_800ExtraBold.ttf",
+							"./assets/fonts/SourceSerif4_800ExtraBold_Italic.ttf",
+							"./assets/fonts/SourceSerif4_900Black.ttf",
+							"./assets/fonts/SourceSerif4_900Black_Italic.ttf"
+						]
+					}
+				}
+			]
+		],
+		"experiments": {
+			"typedRoutes": true,
+			"reactCompiler": true
+		},
+		"extra": {
+			"router": {},
+			"eas": {
+				"projectId": "61092d23-36aa-418e-929d-ea40dc912e8f"
+			}
+		}
+	}
+}