Release 107 feedback: mobile sync, previews, and Pro cleanup

.github/workflows/ci.yml

@@ -1,6 +1,7 @@
 name: CI
 
 on:
+  workflow_dispatch:
   push:
     branches:
       - main
@@ -130,14 +131,12 @@ jobs:
           # against dependencies nobody committed. The drift it papered over was real (five packages committed to
           # shared without regenerating its lock) and is fixed at the source; if it recurs, this should stop.
           npm --prefix ../shared ci
-          # Both packages this app consumes, because npm resolves each file: dep to its dist/ (jest
-          # reads src/, but tsc and metro read dist/). rag was never built at all before.
+          # Build every shared package this app consumes, because npm resolves each file: dependency
+          # to its dist/ (Jest reads src/, but TypeScript and Metro read dist/).
           npm --prefix ../shared/packages/sync run build
           npm --prefix ../shared/packages/rag run build
-          # speech too. It is a file: dep like the other two and six src files import it, but it was
-          # never built here - so every gate failed on "Cannot find module '@offgrid/speech'" (1966
-          # errors in one run) long before it reached anything real.
           npm --prefix ../shared/packages/speech run build
+          npm --prefix ../shared/packages/ui run build
 
       - name: Install dependencies
         id: install
@@ -183,6 +182,11 @@ jobs:
 
       - name: Run Jest tests
         if: ${{ !cancelled() && steps.install.outcome == 'success' }}
+        env:
+          # The serial RN + jsdom suite retains more than Node's default 2 GB heap before
+          # coverage is written. The macOS runner has 14 GB; keep enough headroom for native
+          # tooling while allowing the complete suite to finish without weakening the gate.
+          NODE_OPTIONS: --max-old-space-size=8192
         run: npx jest --coverage --forceExit --runInBand
 
       - name: Install Android NDK

.husky/pre-push

@@ -54,7 +54,13 @@ if [ -n "$PUSHED_JS" ]; then
   npx tsc --noEmit
 
   echo "▶ JS/TS tests (related to changed files)..."
-  echo "$PUSHED_JS" | tr '\n' '\0' | xargs -0 npx jest --findRelatedTests --passWithNoTests
+  # Rendered RN journeys share native-boundary state and are memory-heavy. Parallel workers
+  # starve one another and turn normal 10-second journeys into false multi-minute timeouts.
+  # CI runs this same graph serially; keep the local merge gate deterministic too.
+  # Some React Native boundary shims keep native-style handles alive after Jest has completed every
+  # assertion. The repository's full test command already force-closes those handles. Apply the same
+  # completion policy here so a fully passing related suite does not return a false non-zero status.
+  echo "$PUSHED_JS" | tr '\n' '\0' | xargs -0 npx jest --findRelatedTests --passWithNoTests --runInBand --forceExit
 
   echo "▶ Architecture gate (dependency-cruiser)..."
   npm run depcruise

App.tsx

@@ -11,12 +11,16 @@ import { GestureHandlerRootView } from 'react-native-gesture-handler';
 import { SafeAreaProvider } from 'react-native-safe-area-context';
 import { NavigationContainer } from '@react-navigation/native';
 import { AppNavigator } from './src/navigation';
+import {
+  appNavigationRef,
+  useProExpiryRedirect,
+} from './src/navigation/useProExpiryRedirect';
 import { useTheme } from './src/theme';
 import { hardwareService, modelManager, authService, ragService, remoteServerManager } from './src/services';
 import logger from './src/utils/logger';
 import { useAppStore, useAuthStore, useRemoteServerStore, useWhisperStore } from './src/stores';
 import { useDebugLogsStore } from './src/stores/debugLogsStore';
-import { initDebugLogFile, appendDebugLine } from './src/utils/debugLogFile';
+import { initDebugLogFile, appendDebugLine, stopDebugLogFile } from './src/utils/debugLogFile';
 import { startStartupMemoryProbe } from './src/services/startupMemoryProbe';
 import { loadProFeatures } from './src/bootstrap/loadProFeatures';
 import { hydrateDownloadStore } from './src/services/downloadHydration';
@@ -34,6 +38,7 @@ import { ErrorBoundary } from './src/components/ErrorBoundary';
 
 LogBox.ignoreAllLogs(); // Suppress all logs
 
+let stopStartupProbe: (() => void) | null = null;
 // Dev-only: mirror logger output into the in-app Debug Logs viewer. The whole block
 // is behind __DEV__, so release builds keep main's no-op logger (zero logging cost).
 if (__DEV__) {
@@ -60,7 +65,7 @@ if (__DEV__) {
   // Immediately after the sink exists, so the first sample lands before anything heavy runs. The app
   // was being killed by iOS at launch with the log going silent half a second in; this says where it
   // stops and what memory was doing when it did.
-  startStartupMemoryProbe();
+  stopStartupProbe = startStartupMemoryProbe();
 }
 
 const ensureRemoteServerStoreHydrated = async () => {
@@ -72,11 +77,18 @@ const ensureRemoteServerStoreHydrated = async () => {
 };
 
 function App() {
+  useEffect(() => () => {
+    stopStartupProbe?.();
+    stopStartupProbe = null;
+    stopDebugLogFile();
+  }, []);
+
   useDownloadListeners();
   // Reactive: when Pro is activated at runtime (license key → loadProFeatures),
   // the appRoot slot (TTS engine bridge) registers and this re-renders to mount
   // it live — no restart needed.
   const AppRoot = useSlot(SLOTS.appRoot);
+  const applyPendingProRedirect = useProExpiryRedirect();
   const [isInitializing, setIsInitializing] = useState(true);
   const setDeviceInfo = useAppStore((s) => s.setDeviceInfo);
   const setModelRecommendation = useAppStore((s) => s.setModelRecommendation);
@@ -205,7 +217,11 @@ function App() {
     })().catch((error) => {
       logger.error('[App] Download-state recovery failed:', error);
     });
-  }, [setDownloadedModels, setDownloadedImageModels]);
+  }, [
+    reattachTextDownloadRecovery,
+    setDownloadedModels,
+    setDownloadedImageModels,
+  ]);
 
   const initializeApp = useCallback(async () => {
     try {
@@ -353,6 +369,8 @@ function App() {
         <SystemBars style={isDark ? 'light' : 'dark'} />
         {AppRoot ? <AppRoot /> : null}
         <NavigationContainer
+          ref={appNavigationRef}
+          onReady={applyPendingProRedirect}
           theme={{
             dark: isDark,
             colors: {

README.md

@@ -50,7 +50,7 @@ Pro is an optional, additive tier. It gives the assistant a voice that talks bac
 - **Voice mode** - the free app transcribes your speech; Pro adds on-device Kokoro text-to-speech, so it talks back and you run the whole thing hands-free. The voice runs in your phone's RAM.
 - **Custom personas** - give each assistant its own system prompt, voice, and persistent memory, so it stays in character across conversations.
 - **Draft, then approve** - connect Calendar, email, and MCP servers like Linear, Notion, and GitHub. It drafts the reply or files the ticket and waits. Nothing sends without your tap.
-- **Sync, landing through July** - your phone and your Mac merge into one picture over your own network, never a relay. Your license includes it the day it ships.
+- **Personal Mesh sync** - your phone and your Mac share chats, files, and settings over your own network. There is no relay. See the [Personal Mesh guide](docs/PERSONAL_MESH.md).
 
 **[→ Get Pro access](https://offgridmobileai.co/pay/)** - $69 once and it is yours forever (the price climbs as more people join, never down), or $49/year.
 
@@ -95,7 +95,7 @@ Most "local LLM" apps give you a text chatbot and call it a day. Off Grid AI is
 
 **Vision AI** — Point your camera at anything and ask questions. SmolVLM, Qwen3-VL, Gemma 3n — analyze documents, describe scenes, read receipts. ~7s on flagship devices.
 
-**Voice Input** — On-device Whisper speech-to-text. Hold to record, auto-transcribe. No audio ever leaves your phone.
+**Voice Input** - On-device Whisper speech-to-text. Tap the microphone to start and stop, or use Auto and Hands-free modes. No audio ever leaves your phone.
 
 **Document Analysis** — Attach PDFs, code files, CSVs, and more to your conversations. Native PDF text extraction on both platforms.
 

__tests__/hardening/batch5-kokoroDownloadError.test.ts

@@ -16,16 +16,35 @@
  * is exercised nowhere — the ttsStore setVoice tests mock engine.setVoice entirely.
  */
 import { BareResourceFetcher } from 'react-native-executorch-bare-resource-fetcher';
-import { KokoroEngine } from '../../pro/audio/engine/tts/engines/kokoro/KokoroEngine';
+import {
+  KokoroEngine,
+  type KokoroBridgeHandle,
+} from '../../pro/audio/engine/tts/engines/kokoro/KokoroEngine';
+import type { KokoroVoiceId } from '../../pro/audio/engine/tts/engines/kokoro/voices';
 
 const fetchResources = (BareResourceFetcher as any).fetch as jest.Mock;
-const listDownloadedFiles = BareResourceFetcher.listDownloadedFiles as jest.Mock;
+const listDownloadedFiles =
+  BareResourceFetcher.listDownloadedFiles as jest.Mock;
 
 beforeEach(() => {
   fetchResources?.mockReset().mockResolvedValue(undefined);
   listDownloadedFiles?.mockReset().mockResolvedValue([]);
 });
 
+function attachSelectedVoiceBridge(engine: KokoroEngine): void {
+  const bridge: KokoroBridgeHandle = {
+    speak: async () => undefined,
+    stop: () => undefined,
+    pause: () => undefined,
+    resume: () => undefined,
+    setSpeed: () => undefined,
+    setKeepAlive: () => undefined,
+  };
+  engine._setMountRequester(() => {
+    engine._setBridge(bridge, engine.getActiveVoice()!.id as KokoroVoiceId);
+  });
+}
+
 describe('KokoroEngine — download failure (offline / interrupted fetch)', () => {
   it('a REAL fetch rejection lands the engine in the error phase, records the message, and rethrows', async () => {
     // The offline case: BareResourceFetcher.fetch rejects with a genuine error (NOT the
@@ -35,7 +54,9 @@ describe('KokoroEngine — download failure (offline / interrupted fetch)', () =
     const engine = new KokoroEngine();
     fetchResources.mockRejectedValueOnce(new Error('Network is unreachable'));
 
-    await expect(engine.downloadAssets()).rejects.toThrow(/network is unreachable/i);
+    await expect(engine.downloadAssets()).rejects.toThrow(
+      /network is unreachable/i,
+    );
 
     expect(engine.getPhase()).toBe('error');
     expect(engine.getLastDownloadError()).toMatch(/network is unreachable/i);
@@ -54,7 +75,11 @@ describe('KokoroEngine — download failure (offline / interrupted fetch)', () =
 
     expect(onError).toHaveBeenCalledTimes(1);
     expect(onError).toHaveBeenCalledWith(
-      expect.objectContaining({ code: 'KOKORO_DOWNLOAD', recoverable: true, message: expect.stringMatching(/interrupted/i) }),
+      expect.objectContaining({
+        code: 'KOKORO_DOWNLOAD',
+        recoverable: true,
+        message: expect.stringMatching(/interrupted/i),
+      }),
     );
   });
 
@@ -88,8 +113,38 @@ describe('KokoroEngine — download failure (offline / interrupted fetch)', () =
 });
 
 describe('KokoroEngine.setVoice — active voice + completeness + events', () => {
+  it('serializes a voice-pack fetch behind an active base-model download', async () => {
+    const engine = new KokoroEngine();
+    attachSelectedVoiceBridge(engine);
+    let finishBase!: () => void;
+    fetchResources
+      .mockImplementationOnce(
+        () =>
+          new Promise<void>(resolve => {
+            finishBase = resolve;
+          }),
+      )
+      .mockResolvedValueOnce(undefined);
+
+    const baseDownload = engine.downloadAssets();
+    const voiceSwitch = engine.setVoice('hf_alpha');
+
+    await Promise.resolve();
+    await Promise.resolve();
+    expect(fetchResources).toHaveBeenCalledTimes(1);
+
+    finishBase();
+    await baseDownload;
+    await voiceSwitch;
+
+    expect(fetchResources).toHaveBeenCalledTimes(2);
+    expect(engine.getActiveVoice()?.id).toBe('hf_alpha');
+    expect(engine.isFullyDownloaded()).toBe(true);
+  });
+
   it('updates the active voice and reflects it via getActiveVoice()', async () => {
     const engine = new KokoroEngine();
+    attachSelectedVoiceBridge(engine);
     // Default active voice is af_heart.
     expect(engine.getActiveVoice()?.id).toBe('af_heart');
 
@@ -101,6 +156,7 @@ describe('KokoroEngine.setVoice — active voice + completeness + events', () =>
 
   it('emits voiceChanged with the new voice id', async () => {
     const engine = new KokoroEngine();
+    attachSelectedVoiceBridge(engine);
     const onVoiceChanged = jest.fn();
     engine.on('voiceChanged', onVoiceChanged);
     fetchResources.mockResolvedValueOnce(undefined);
@@ -112,6 +168,7 @@ describe('KokoroEngine.setVoice — active voice + completeness + events', () =>
 
   it('records genuine completion once the new voice fetch resolves (reads downloaded)', async () => {
     const engine = new KokoroEngine();
+    attachSelectedVoiceBridge(engine);
     fetchResources.mockResolvedValueOnce(undefined);
 
     await engine.setVoice('am_michael');
@@ -122,23 +179,24 @@ describe('KokoroEngine.setVoice — active voice + completeness + events', () =>
 
   it('rejects an unknown voice id without touching the active voice', async () => {
     const engine = new KokoroEngine();
-    await expect(engine.setVoice('not_a_real_voice')).rejects.toThrow(/unknown kokoro voice/i);
+    await expect(engine.setVoice('not_a_real_voice')).rejects.toThrow(
+      /unknown kokoro voice/i,
+    );
     expect(engine.getActiveVoice()?.id).toBe('af_heart'); // unchanged
     expect(fetchResources).not.toHaveBeenCalled();
   });
 
-  it('a failed voice-asset fetch is tolerated: active voice still switches, voiceChanged still emits', async () => {
-    // setVoice reflects the new voice immediately (the picker reads active voice) and the
-    // asset prefetch is best-effort — a fetch failure is logged, not thrown, so the picker
-    // never wedges. The store layer owns the switching-flag/spinner lifecycle.
+  it('a failed voice-asset fetch rejects and keeps the last usable voice active', async () => {
     const engine = new KokoroEngine();
     const onVoiceChanged = jest.fn();
     engine.on('voiceChanged', onVoiceChanged);
     fetchResources.mockRejectedValueOnce(new Error('voice fetch offline'));
 
-    await expect(engine.setVoice('am_santa')).resolves.toBeUndefined();
+    await expect(engine.setVoice('am_santa')).rejects.toThrow(
+      'voice fetch offline',
+    );
 
-    expect(engine.getActiveVoice()?.id).toBe('am_santa');
-    expect(onVoiceChanged).toHaveBeenCalledWith('am_santa');
+    expect(engine.getActiveVoice()?.id).toBe('af_heart');
+    expect(onVoiceChanged).not.toHaveBeenCalled();
   });
 });