Add local and OGAD remote video generation to Mobile

.gitignore

@@ -98,3 +98,7 @@ docs/wire-captures/
 
 # Scratch renders derived from scripts/e2e/fixtures (regenerable, not versioned)
 /tmp/
+
+# Generated native video runtime
+.video-build/
+native/video/*.xcframework/

App.tsx

@@ -1,3 +1,5 @@
+import { videoGenerationService } from './src/services/videoGenerationService';
+import { videoProvider } from './src/services/modelDownloadService/providers/videoProvider';
 /**
  * Off Grid - On-Device AI Chat Application
  * Private AI assistant that runs entirely on your device
@@ -121,7 +123,7 @@
   );
 }
 
 function App() {
   useEffect(() => () => {
     stopStartupProbe?.();
     stopStartupProbe = null;
@@ -136,6 +138,7 @@
   const applyPendingProRedirect = useProExpiryRedirect();
   const [isInitializing, setIsInitializing] = useState(true);
   const startupGeneration = useRef(0);
+  const showSyncStatusBar = useAppStore(s => s.showSyncStatusBar);
   const setDeviceInfo = useAppStore((s) => s.setDeviceInfo);
   const setModelRecommendation = useAppStore((s) => s.setModelRecommendation);
   const setDownloadedModels = useAppStore((s) => s.setDownloadedModels);
@@ -234,6 +237,8 @@
       // becomes the SINGLE owner only once the Download Manager consumes the service
       // and the old recovery paths are folded into the providers.
       registerCoreDownloadProviders();
+      await videoProvider.reconcile?.().catch(error => logger.error('[Video] Download recovery failed:', error));
+      await videoGenerationService.restore().catch(error => logger.error('[Video] Job recovery failed:', error));
 
       // Re-surface QUEUED downloads that never started before an app kill. A queued item (waiting for
       // one of the 3 concurrency slots) has no native row, so hydrateDownloadStore can't recover it —
@@ -406,7 +411,7 @@
             <SystemBars style={isDark ? 'light' : 'dark'} />
             <LoadingDots size={8} testID="startup-loading-dots" />
           </View>
-          {__DEV__ ? <DevSyncStrip /> : null}
+          {__DEV__ && showSyncStatusBar ? <DevSyncStrip /> : null}
         </SafeAreaProvider>
       </GestureHandlerRootView>
     );
@@ -419,7 +424,7 @@
         <SafeAreaProvider>
           <SystemBars style={isDark ? 'light' : 'dark'} />
           <LockScreen onUnlock={handleUnlock} />
-          {__DEV__ ? <DevSyncStrip /> : null}
+          {__DEV__ && showSyncStatusBar ? <DevSyncStrip /> : null}
         </SafeAreaProvider>
       </GestureHandlerRootView>
     );
@@ -465,7 +470,7 @@
         >
           <AppNavigator />
         </NavigationContainer>
-        {__DEV__ ? <DevSyncStrip /> : null}
+        {__DEV__ && showSyncStatusBar ? <DevSyncStrip /> : null}
       </SafeAreaProvider>
     </GestureHandlerRootView>
   );

__tests__/integration/settings/modelSettingsSurfaceParity.test.tsx

@@ -40,6 +40,40 @@ describe('model settings surface parity', () => {
     _clearSlotsForTesting();
   });
 
+  it('keeps shared controls in General on both surfaces and preserves saved values', () => {
+    useAppStore.getState().updateSettings({
+      modelLoadingMode: 'aggressive',
+      showGenerationDetails: true,
+    });
+    const chatSettings = render(<GenerationSettingsModal visible onClose={() => {}} />);
+    fireEvent.press(chatSettings.getByText('TEXT GENERATION'));
+    expect(chatSettings.queryByText('Model Loading')).toBeNull();
+    expect(chatSettings.queryByText('Show Generation Details')).toBeNull();
+    fireEvent.press(chatSettings.getByTestId('modal-general-accordion'));
+    expect(chatSettings.getByText('Inference Backend')).toBeTruthy();
+    expect(chatSettings.getByTestId('model-loading-mode-aggressive-button')).toBeTruthy();
+    expect(chatSettings.getByTestId('show-gen-details-on-button')).toBeTruthy();
+    chatSettings.unmount();
+
+    const modelSettings = renderModelSettings();
+    fireEvent.press(modelSettings.getByTestId('text-generation-accordion'));
+    expect(modelSettings.queryByText('Model Loading')).toBeNull();
+    fireEvent.press(modelSettings.getByTestId('general-generation-accordion'));
+    expect(modelSettings.getByText('Inference Backend')).toBeTruthy();
+    expect(modelSettings.getByTestId('model-loading-mode-aggressive-button')).toBeTruthy();
+    expect(modelSettings.getByTestId('show-gen-details-on-button')).toBeTruthy();
+  });
+
+  it('shows and edits the saved default system prompt in chat Text settings', () => {
+    useAppStore.getState().updateSettings({ systemPrompt: 'Saved instructions' });
+    const chatSettings = render(<GenerationSettingsModal visible onClose={() => {}} />);
+    fireEvent.press(chatSettings.getByText('TEXT GENERATION'));
+    const input = chatSettings.getByTestId('default-system-prompt-input');
+    expect(input.props.value).toBe('Saved instructions');
+    fireEvent.changeText(input, 'New instructions');
+    expect(useAppStore.getState().settings.systemPrompt).toBe('New instructions');
+  });
+
   it('caps output by context on both surfaces and writes one shared setting state', () => {
     useAppStore.getState().setModelMaxContext(262144);
     // A context wide enough for the output this test chooses. Max tokens is capped BY the context,

__tests__/rntl/screens/ModelSettingsScreen.test.tsx

@@ -59,6 +59,9 @@
     text: 'text-advanced-toggle',
   };
   for (const section of sections) {
+    if (section === 'text') {
+      fireEvent.press(result.getByTestId('general-generation-accordion'));
+    }
     fireEvent.press(result.getByTestId(testIDMap[section]));
     if (advancedMap[section]) {
       fireEvent.press(result.getByTestId(advancedMap[section]));
@@ -903,7 +906,7 @@
     it('uses fallback values when settings fields are undefined', () => {
       // Set settings to have minimal/undefined values to test || fallback branches
       useAppStore.setState({
         settings: {
           systemPrompt: undefined as any,
           temperature: undefined as any,
           maxTokens: undefined as any,

__tests__/unit/sync/sharedFileMaterializer.test.ts

@@ -65,10 +65,36 @@ describe('making a transferred file appear in the app', () => {
       ?.messages.find(({ uuid }) => uuid === messageUuid)?.attachments ?? [];
 
   beforeEach(() => {
-    useAppStore.setState({ generatedImages: [] });
+    useAppStore.setState({ generatedImages: [], generatedVideos: [] });
     useChatStore.setState({ conversations: [] });
   });
 
+  describe('a video generated on another device', () => {
+    const video = () => record({
+      mimeType: 'video/mp4', name: 'lake.mp4', localPath: '/docs/shared_files/lake.mp4',
+      conversationId: 'chat-7', messageId: 'message-1', width: 320, height: 192,
+      durationSeconds: 2.125,
+      metadataJson: JSON.stringify({ prompt: 'A moving lake', steps: 20, guidance: 6, seed: 42, modelId: 'wan', fps: 8, frames: 17 }),
+    });
+    it('appears once in the video gallery and on its message after repeated delivery', () => {
+      useChatStore.setState({ conversations: [conversation()] });
+      materializeSharedFile(video());
+      materializeSharedFile(video());
+      expect(gallery()).toEqual([]);
+      expect(useAppStore.getState().generatedVideos).toHaveLength(1);
+      expect(useAppStore.getState().generatedVideos[0]).toMatchObject({ prompt: 'A moving lake', durationSeconds: 2.125, fps: 8, seed: 42 });
+      expect(attachmentsOn('chat-7', 'message-1')).toHaveLength(1);
+      expect(attachmentsOn('chat-7', 'message-1')[0]).toMatchObject({ type: 'video', mimeType: 'video/mp4' });
+    });
+    it('removes the gallery entry and chat attachment when the shared video is deleted', () => {
+      useChatStore.setState({ conversations: [conversation()] });
+      materializeSharedFile(video());
+      removeMaterializedSharedFile(video());
+      expect(useAppStore.getState().generatedVideos).toEqual([]);
+      expect(attachmentsOn('chat-7', 'message-1')).toEqual([]);
+    });
+  });
+
   describe('a picture generated on another device', () => {
     it('appears in the gallery, with the prompt that made it', () => {
       materializeSharedFile(

__tests__/unit/utils/proPricing.test.ts

@@ -3,14 +3,13 @@ import { getPricingCopy } from '../../../src/utils/proPricing';
 describe('getPricingCopy', () => {
   const copy = getPricingCopy();
 
-  it('offers the two current plans - $49/yr and $69 lifetime - and no monthly', () => {
-    expect(copy.title).toBe('$49/yr or $69 lifetime');
-    expect(copy.sheetSubheadline).toMatch(/\$49 a year/);
+  it('offers the two current plans - $4.99/month and $69 lifetime - and no yearly', () => {
+    expect(copy.title).toBe('$4.99/month or $69 lifetime');
+    expect(copy.sheetSubheadline).toMatch(/\$4\.99 a month/);
     expect(copy.sheetSubheadline).toMatch(/\$69 once/);
-    // The retired monthly plan must not resurface anywhere in the copy.
+    // The retired yearly plan must not resurface anywhere in the copy.
     const all = Object.values(copy).join(' ');
-    expect(all).not.toMatch(/month/i);
-    expect(all).not.toMatch(/\$39/);
+    expect(all).not.toMatch(/year|annual|\$49/i);
   });
 
   it('keeps the Get Pro CTA (the web pay-page trigger the Pro surfaces assert)', () => {

android/app/build.gradle

@@ -89,6 +89,8 @@ android {
         coreLibraryDesugaringEnabled true
     }
 
+    externalNativeBuild { cmake { path "src/main/cpp/CMakeLists.txt"; version "3.22.1" } }
+    sourceSets.main.assets.srcDir("../../.video-build/hexagon-assets")
     defaultConfig {
         applicationId "ai.offgridmobile"
         minSdkVersion rootProject.ext.minSdkVersion
@@ -195,3 +197,18 @@ dependencies {
     testImplementation("org.mockito.kotlin:mockito-kotlin:5.4.0")
     testImplementation("androidx.test:core:1.6.1")
 }
+
+// Native video setup is shared by command-line, IDE, and CI builds.
+// Configure tasks need the source tree before CMake evaluates it.
+def videoRoot = rootProject.projectDir.parentFile
+def prepareVideoRuntime = tasks.register("prepareVideoRuntime", Exec) {
+    workingDir videoRoot
+    commandLine "bash", new File(videoRoot, "scripts/prepare-video-runtime.sh").absolutePath, "--android"
+    inputs.files(fileTree(new File(videoRoot, "scripts/video")), new File(videoRoot, "scripts/prepare-video-runtime.sh"))
+    outputs.files(new File(videoRoot, ".video-build/runtime-ready"), new File(videoRoot, ".video-build/shaderc/bin/glslc"),
+        new File(videoRoot, ".video-build/hexagon-runtime/htp_iface_stub.c"), new File(videoRoot, ".video-build/hexagon-runtime/htp_iface.h"))
+    outputs.dir(new File(videoRoot, ".video-build/hexagon-assets/video-hexagon"))
+}
+tasks.configureEach { task ->
+    if (task.name.startsWith("configureCMake") || (task.name.startsWith("merge") && task.name.endsWith("Assets"))) task.dependsOn(prepareVideoRuntime)
+}

android/app/src/main/AndroidManifest.xml

@@ -47,6 +47,8 @@
     <!-- Run large model downloads as a foreground service so they keep progressing when
          the app is backgrounded / the screen is off (WorkManager foreground worker). -->
     <uses-permission android:name="android.permission.FOREGROUND_SERVICE" />
+    <uses-permission android:name="android.permission.FOREGROUND_SERVICE_MEDIA_PROCESSING" />
+    <uses-permission android:name="android.permission.FOREGROUND_SERVICE_SPECIAL_USE" />
     <uses-permission android:name="android.permission.FOREGROUND_SERVICE_DATA_SYNC" />
     <!-- Personal Mesh keeps a live local-network connection to paired devices. -->
     <uses-permission android:name="android.permission.FOREGROUND_SERVICE_CONNECTED_DEVICE" />
@@ -78,6 +80,7 @@
       <uses-native-library android:name="libcdsprpc.so" android:required="false" />
       <activity
         android:name=".MainActivity"
+        android:supportsPictureInPicture="true"
         android:label="@string/app_name"
         android:configChanges="keyboard|keyboardHidden|orientation|screenLayout|screenSize|smallestScreenSize|uiMode"
         android:launchMode="singleTask"
@@ -140,5 +143,8 @@
           android:exported="false"
           android:foregroundServiceType="connectedDevice" />
 
+      <service android:name=".video.VideoGenerationService" android:exported="false" android:foregroundServiceType="mediaProcessing|specialUse">
+        <property android:name="android.app.PROPERTY_SPECIAL_USE_FGS_SUBTYPE" android:value="User-started local video generation" />
+      </service>
     </application>
 </manifest>

android/app/src/main/cpp/CMakeLists.txt

@@ -0,0 +1,54 @@
+cmake_minimum_required(VERSION 3.22)
+project(appmodules LANGUAGES C CXX)
+include(${REACT_ANDROID_DIR}/cmake-utils/ReactNative-application.cmake)
+set(CMAKE_CXX_STANDARD 17)
+set(CMAKE_C_VISIBILITY_PRESET hidden)
+set(CMAKE_CXX_VISIBILITY_PRESET hidden)
+set(SD_BUILD_EXAMPLES OFF CACHE BOOL "" FORCE)
+set(SD_BUILD_SHARED_LIBS OFF CACHE BOOL "" FORCE)
+set(SD_BUILD_SHARED_GGML_LIB OFF CACHE BOOL "" FORCE)
+set(GGML_NATIVE OFF CACHE BOOL "" FORCE)
+set(SD_WEBP OFF CACHE BOOL "" FORCE)
+set(SD_WEBM OFF CACHE BOOL "" FORCE)
+set(SD_METAL OFF CACHE BOOL "" FORCE)
+set(SD_VULKAN ON CACHE BOOL "" FORCE)
+set(SD_SOURCE "${CMAKE_CURRENT_SOURCE_DIR}/../../../../../.video-build/source")
+set(GGML_HEXAGON ON CACHE BOOL "" FORCE)
+set(OFFGRID_VIDEO_HEXAGON_CMAKE "${CMAKE_CURRENT_SOURCE_DIR}/../../../../../scripts/video/hexagon-prebuilt.cmake")
+if(NOT EXISTS "${SD_SOURCE}/CMakeLists.txt")
+  message(FATAL_ERROR "Run scripts/prepare-video-runtime.sh before building Android.")
+endif()
+set(SPIRV-Headers_DIR "${SD_SOURCE}/../vulkan-header-prefix/share/cmake/SPIRV-Headers")
+set(Vulkan_INCLUDE_DIR "${SD_SOURCE}/../vulkan-header-prefix/include" CACHE PATH "Pinned Vulkan headers" FORCE)
+string(TOLOWER "${CMAKE_HOST_SYSTEM_NAME}" VIDEO_HOST_OS)
+# The NDK shader compiler can be too old for the pinned runtime. Use the host
+# shaderc installation, or an explicit -DVulkan_GLSLC_EXECUTABLE path.
+find_program(Vulkan_GLSLC_EXECUTABLE NAMES glslc glslc.exe
+  HINTS "${SD_SOURCE}/../shaderc/bin" NO_CMAKE_FIND_ROOT_PATH REQUIRED)
+if(CMAKE_HOST_SYSTEM_NAME STREQUAL "Darwin")
+  # The NDK prepends its compiler directory even for host-program discovery.
+  # Its clang cannot compile against the current macOS SDK. Use Xcode's host
+  # toolchain for the shader generator; model libraries still use the NDK.
+  execute_process(COMMAND xcrun --sdk macosx --find clang
+    OUTPUT_VARIABLE VIDEO_HOST_CC OUTPUT_STRIP_TRAILING_WHITESPACE COMMAND_ERROR_IS_FATAL ANY)
+  execute_process(COMMAND xcrun --sdk macosx --find clang++
+    OUTPUT_VARIABLE VIDEO_HOST_CXX OUTPUT_STRIP_TRAILING_WHITESPACE COMMAND_ERROR_IS_FATAL ANY)
+else()
+  find_program(VIDEO_HOST_CC NAMES clang gcc cl NO_CMAKE_FIND_ROOT_PATH REQUIRED)
+  find_program(VIDEO_HOST_CXX NAMES clang++ g++ cl NO_CMAKE_FIND_ROOT_PATH REQUIRED)
+endif()
+set(GGML_VULKAN_SHADERS_GEN_TOOLCHAIN "${CMAKE_BINARY_DIR}/video-host-toolchain.cmake")
+file(WRITE "${GGML_VULKAN_SHADERS_GEN_TOOLCHAIN}"
+  "set(CMAKE_C_COMPILER \"${VIDEO_HOST_CC}\")\nset(CMAKE_CXX_COMPILER \"${VIDEO_HOST_CXX}\")\nset(CMAKE_MAKE_PROGRAM \"${CMAKE_MAKE_PROGRAM}\" CACHE FILEPATH \"Host build tool\" FORCE)\n")
+add_subdirectory("${SD_SOURCE}" runtime)
+# Keep model execution representative in debug apps. Unoptimized tensor kernels
+# make CPU conditioning take minutes even though the app remains responsive.
+foreach(VIDEO_RUNTIME_TARGET stable-diffusion ggml-base ggml-cpu ggml-vulkan ggml-hexagon)
+  if(TARGET ${VIDEO_RUNTIME_TARGET})
+    target_compile_options(${VIDEO_RUNTIME_TARGET} PRIVATE $<$<CONFIG:Debug>:-O3>)
+  endif()
+endforeach()
+add_library(offgrid_video SHARED video/video-jni.cpp)
+target_include_directories(offgrid_video PRIVATE "${SD_SOURCE}/include" "${CMAKE_CURRENT_SOURCE_DIR}/../../../../../native/video/common")
+target_link_libraries(offgrid_video PRIVATE stable-diffusion android log)
+target_link_options(offgrid_video PRIVATE "-Wl,--exclude-libs,ALL" "-Wl,-z,max-page-size=16384")