Release Framely 0.5.1-preview.3

Cargo.lock

@@ -425,7 +425,7 @@ dependencies = [
 
 [[package]]
 name = "framely"
-version = "0.5.1-preview.1"
+version = "0.5.1-preview.3"
 dependencies = [
  "anyhow",
  "base64",

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "framely"
-version = "0.5.1-preview.1"
+version = "0.5.1-preview.3"
 edition = "2021"
 license = "AGPL-3.0-only"
 

native/gamepad.cpp

@@ -21,7 +21,7 @@ static void stop(int){stopped=1;}
 #include "gamepad_feedback.h"
 static const int axes[]={ABS_X,ABS_Y,ABS_RX,ABS_RY,ABS_Z,ABS_RZ,ABS_HAT0X,ABS_HAT0Y};
 static bool event(int fd,int type,int code,int value){input_event e{};e.type=type;e.code=code;e.value=value;return write(fd,&e,sizeof e)==sizeof e;}
-static bool send(int fd,const int* state){bool ok=true;for(int k=0;k<10;k++)ok=event(fd,EV_KEY,keys[k],state[k])&&ok;for(int k=0;k<8;k++)ok=event(fd,EV_ABS,axes[k],state[10+k])&&ok;return event(fd,EV_SYN,SYN_REPORT,0)&&ok;}
+static bool send(int fd,const int* state){static GamepadTriggers triggers;bool ok=true;for(int k=0;k<10;k++)ok=event(fd,EV_KEY,keys[k],state[k])&&ok;for(int k=0;k<2;k++)ok=event(fd,EV_KEY,trigger_keys[k],triggers.update(k,state[14+k]))&&ok;for(int k=0;k<8;k++)ok=event(fd,EV_ABS,axes[k],state[10+k])&&ok;return event(fd,EV_SYN,SYN_REPORT,0)&&ok;}
 int main(int argc,char**argv){
  if((argc!=2&&argc!=4)||geteuid()==0){fprintf(stderr,"Run gamepad bridge as the Steam session user with an action manifest.\n");return 1;}
  // A session request runs on a short-lived worker thread. PR_SET_PDEATHSIG
@@ -58,6 +58,7 @@ int main(int argc,char**argv){
  int fd=open("/dev/uinput",O_RDWR|O_NONBLOCK|O_CLOEXEC);if(fd<0){perror("Gamepad /dev/uinput");shutdown();return 1;}
  bool ok=ioctl(fd,UI_SET_EVBIT,EV_KEY)==0&&ioctl(fd,UI_SET_EVBIT,EV_ABS)==0&&ioctl(fd,UI_SET_EVBIT,EV_FF)==0&&ioctl(fd,UI_SET_FFBIT,FF_RUMBLE)==0;
  for(auto key:keys)ok=ioctl(fd,UI_SET_KEYBIT,key)==0&&ok;
+ for(auto key:trigger_keys)ok=ioctl(fd,UI_SET_KEYBIT,key)==0&&ok;
  for(int k=0;k<8;k++){ok=ioctl(fd,UI_SET_ABSBIT,axes[k])==0&&ok;uinput_abs_setup a{};a.code=axes[k];a.absinfo.minimum=k<4?-32768:(k<6?0:-1);a.absinfo.maximum=k<4?32767:(k<6?255:1);a.absinfo.flat=k<4?1024:0;ok=ioctl(fd,UI_ABS_SETUP,&a)==0&&ok;}
  uinput_setup device{};device.id={BUS_VIRTUAL,framely_pad_vendor,framely_pad_product,0x0001};device.ff_effects_max=GamepadFeedback::capacity;strcpy(device.name,"Framely Android gamepad");
  ok=ioctl(fd,UI_DEV_SETUP,&device)==0&&ioctl(fd,UI_DEV_CREATE)==0&&ok;

native/gamepad_mapping.h

@@ -4,3 +4,11 @@
 // Xbox/Android maps X to Linux 307 and Y to 308. The positional
 // aliases WEST/NORTH do not match these letter names.
 inline constexpr int keys[]={BTN_A,BTN_B,BTN_X,BTN_Y,BTN_TL,BTN_TR,BTN_SELECT,BTN_START,BTN_THUMBL,BTN_THUMBR};
+
+inline constexpr int trigger_keys[]={BTN_TL2,BTN_TR2};
+// Preserve analog travel while exposing Android's digital L2/R2 events.
+// Press at 30/255 and release at 20/255 to avoid noisy edges.
+struct GamepadTriggers {
+ bool down[2]{};
+ bool update(int side,int value){down[side]=down[side]?value>20:value>=30;return down[side];}
+};

native/host.cpp

@@ -123,7 +123,7 @@ template<class T> struct Handler {
  T* acquire(){api.base.add_ref(&api.base);return &api;}
 };
 struct View {
- std::string key,plugin,title;int width=600,height=840,render_scale=1;bool dashboard=false,shown=false,dirty=false,closing=false,closed=false;
+ std::string key,plugin,title;int width=600,height=840;float render_scale=1.f;bool dashboard=false,shown=false,dirty=false,closing=false,closed=false;
  OverlayPlacement placement;NotificationClick notification_click;LauncherPointer launcher_pointer;std::chrono::steady_clock::time_point haptic_at{},activation_at{};
  cef_mouse_event_t pointer{};bool pointer_valid=false,stick_scrolling=false;vr::TrackedDeviceIndex_t pointer_device=vr::k_unTrackedDeviceIndexInvalid;std::chrono::steady_clock::time_point pointer_at{};
  cef_file_dialog_callback_t* file_dialog=nullptr;std::string file_dialog_id;bool file_multiple=false,file_directory=false;
@@ -281,9 +281,9 @@ static void anchor_notification(View& v){
 }
 static View& create_view(const std::string& key,const std::string& title,const std::string& url,bool dock,int width,int height,const std::string& plugin="",float physical_width=0){
  if(views.count(key)){auto& v=*views.at(key);if(dock&&key!="launcher")overlays->ShowDashboard(key.c_str());else if(key!="notifications"&&key!="launcher")show(v,true);return v;}
- // Use 3x for launcher artwork and 2x for scrolling panels. CEF readback,
+ // Use 1.5x for launcher artwork and 2x for scrolling panels. CEF readback,
  // texture upload and launcher mipmap generation scale with the pixel count.
- if(views.size()>=34)throw std::runtime_error("Window limit exceeded");auto v=std::make_unique<View>();v->key=key;v->plugin=plugin;v->title=title;v->dashboard=dock;v->width=width;v->height=height;v->render_scale=key=="launcher"?3:(key=="framely.manager"||key=="menu"||key=="notifications")?2:1;
+ if(views.size()>=34)throw std::runtime_error("Window limit exceeded");auto v=std::make_unique<View>();v->key=key;v->plugin=plugin;v->title=title;v->dashboard=dock;v->width=width;v->height=height;v->render_scale=key=="launcher"?1.5f:(key=="framely.manager"||key=="menu"||key=="notifications")?2:1;
  auto error=dock?overlays->CreateDashboardOverlay(key.c_str(),title.c_str(),&v->overlay,&v->thumbnail):overlays->CreateOverlay(key.c_str(),title.c_str(),&v->overlay);if(error)throw std::runtime_error("Overlay creation failed: "+std::to_string(error));
  overlays->SetOverlayInputMethod(v->overlay,key=="notifications"?vr::VROverlayInputMethod_None:vr::VROverlayInputMethod_Mouse);vr::HmdVector2_t scale{{float(width),float(height)}};overlays->SetOverlayMouseScale(v->overlay,&scale);overlays->SetOverlayFlag(v->overlay,vr::VROverlayFlags_HideLaserIntersection,false);overlays->SetOverlayFlag(v->overlay,vr::VROverlayFlags_SendVRSmoothScrollEvents,true);overlays->SetOverlayFlag(v->overlay,vr::VROverlayFlags_VisibleInDashboard,true);overlays->SetOverlayFlag(v->overlay,vr::VROverlayFlags_MakeOverlaysInteractiveIfVisible,true);overlays->SetOverlayFlag(v->overlay,vr::VROverlayFlags_SortWithNonSceneOverlays,false);overlays->SetOverlaySortOrder(v->overlay,0);
 

native/input/gamepad/Vendor_0001_Product_f001.kl

@@ -5,6 +5,8 @@ key 307 BUTTON_X
 key 308 BUTTON_Y
 key 310 BUTTON_L1
 key 311 BUTTON_R1
+key 312 BUTTON_L2
+key 313 BUTTON_R2
 key 314 BUTTON_SELECT
 key 315 BUTTON_START
 key 317 BUTTON_THUMBL

native/render_resolution.h

@@ -1,6 +1,6 @@
 #pragma once
 // CEF view/input coordinates stay in DIP; only the paint buffer uses this scale.
-inline int render_screen_info(cef_screen_info_t* info,int width,int height,int scale){
+inline int render_screen_info(cef_screen_info_t* info,int width,int height,float scale){
  info->size=sizeof(*info);info->device_scale_factor=float(scale);info->depth=32;info->depth_per_component=8;info->is_monochrome=0;
  info->rect={0,0,width,height};info->available_rect=info->rect;return 1;
 }

src/apk.rs

@@ -545,6 +545,48 @@ fn restriction(c: &Container, package: &str) -> Option<(bool, bool, Vec<String>)
     }
     None
 }
+// Legacy installs may have reused a package-derived context for another app.
+// Allocate around that occupied context instead of touching its files or records.
+fn automatic_install_context(
+    home: &Path,
+    db: &Database,
+    cs: &[Container],
+    package: &str,
+) -> Result<String> {
+    let base = format!("framely-{}", hash(package));
+    for suffix in 0..1000 {
+        let id = if suffix == 0 {
+            base.clone()
+        } else {
+            format!("{base}-{}", suffix + 1)
+        };
+        let records: Vec<_> = db.records.values().filter(|r| r.context == id).collect();
+        if let Some(c) = cs.iter().find(|c| c.id == id) {
+            let packages = if c.baked.exists() {
+                installed(home, c)?
+            } else {
+                Vec::new()
+            };
+            if packages.iter().any(|(m, _)| m.package == package) {
+                return Ok(id); // Updating an existing app also remains valid in legacy shared containers.
+            }
+            if packages.iter().any(|(m, _)| m.package != package)
+                || records.iter().any(|r| r.metadata.package != package)
+            {
+                continue;
+            }
+            return Ok(id);
+        }
+        if !records.is_empty()
+            || fs::symlink_metadata(home.join(".local/share/lepton/contexts").join(&id)).is_ok()
+        {
+            continue; // Preserve retained records and unreadable/dangling paths.
+        }
+        return Ok(id);
+    }
+    anyhow::bail!("No free independent APK container name is available")
+}
+
 fn installed(home: &Path, c: &Container) -> Result<Vec<(Metadata, PathBuf)>> {
     let p = c.baked.join("data_overlay/system/packages.xml");
     let bytes = fs::read(&p)?;
@@ -2591,7 +2633,7 @@ fn operate_internal(
                 let requested = p["context"].as_str().unwrap_or("");
                 let cs = containers(home, &db);
                 let context = if requested.is_empty() {
-                    format!("framely-{}", hash(&metadata.package))
+                    automatic_install_context(home, &db, &cs, &metadata.package)?
                 } else {
                     requested.into()
                 };
@@ -5063,6 +5105,71 @@ setup_props
         assert!(f.save_file().exists());
         assert!(!load(&f.home).unwrap().records["test/com.example.app"].removed);
     }
+    #[test]
+    fn automatic_install_context_preserves_occupied_legacy_contexts() {
+        let dir = tempfile::tempdir().unwrap();
+        let home = dir.path();
+        let package = "com.example.new";
+        let base = format!("framely-{}", hash(package));
+        let baked = home
+            .join(".local/share/lepton/contexts")
+            .join(&base)
+            .join("baked");
+        fs::create_dir_all(baked.join("data_overlay/system")).unwrap();
+        let xml = b"<packages><package name=\"com.example.old\" codePath=\"/data/app/old\" version=\"1\"/></packages>";
+        fs::write(baked.join("data_overlay/system/packages.xml"), xml).unwrap();
+        let c = Container {
+            id: base.clone(),
+            name: base.clone(),
+            baked: baked.clone(),
+            running: false,
+            managed: true,
+            steam: false,
+        };
+        let mut db = Database::default();
+        assert_eq!(
+            automatic_install_context(home, &db, &[c.clone()], package).unwrap(),
+            format!("{base}-2")
+        );
+        assert_eq!(
+            fs::read(baked.join("data_overlay/system/packages.xml")).unwrap(),
+            xml
+        );
+        // An unreadable context must also be skipped, rather than overwritten.
+        fs::create_dir_all(
+            home.join(".local/share/lepton/contexts")
+                .join(format!("{base}-2")),
+        )
+        .unwrap();
+        assert_eq!(
+            automatic_install_context(home, &db, &[c.clone()], package).unwrap(),
+            format!("{base}-3")
+        );
+        // A retained foreign app reserves a name even if its directory is gone.
+        db.records.insert(
+            "retained".into(),
+            Record {
+                context: format!("{base}-3"),
+                metadata: Metadata {
+                    package: "com.example.retained".into(),
+                    ..Default::default()
+                },
+                removed: true,
+                ..Default::default()
+            },
+        );
+        assert_eq!(
+            automatic_install_context(home, &db, &[c.clone()], package).unwrap(),
+            format!("{base}-4")
+        );
+        // Same-package updates still reuse the existing legacy shared container.
+        fs::write(baked.join("data_overlay/system/packages.xml"), format!("<packages><package name=\"{package}\" codePath=\"/data/app/new\" version=\"1\"/><package name=\"com.example.old\" codePath=\"/data/app/old\" version=\"1\"/></packages>")).unwrap();
+        assert_eq!(
+            automatic_install_context(home, &db, &[c], package).unwrap(),
+            base
+        );
+    }
+
     #[test]
     fn shared_mount_loss_preserves_launcher_identity_until_confirmed_uninstall() {
         let f = Fixture::new();

src/apk/steam_shortcut_lookup.js

@@ -0,0 +1,32 @@
+async function(p) {
+    const executable = d => d.strShortcutExe?.replace(/^"|"$/g, '').replace('/./', '/');
+    const details = id => new Promise((resolve, reject) => {
+        let sub, settled = false;
+        const timer = setTimeout(() => { sub?.unregister(); reject(Error('Details timed out')); }, 3000);
+        sub = SteamClient.Apps.RegisterForAppDetails(id, d => { settled = true; clearTimeout(timer); sub?.unregister(); resolve(d); });
+        // Steam may invoke a cached callback synchronously.
+        if (settled) sub?.unregister();
+    });
+    let apps, app;
+    for (let n = 0; n < 10; n++) {
+        apps = Array.from(appStore.m_mapApps.values());
+        const matches = apps.filter(a => a.display_name === 'Devkit Game: ' + p.game);
+        app = matches.length === 1 ? matches[0] : apps.find(a => a.appid === p.previous);
+        if (app) break;
+        if (n < 9) await new Promise(r => setTimeout(r, 100));
+    }
+    if (app) {
+        if (app.appid < 2147483648) throw Error('Missing owned shortcut');
+        const d = await details(app.appid);
+        if (executable(d) !== p.exe) throw Error('Shortcut target does not match owned APK');
+        return { id: app.appid };
+    }
+    // A previous attempt may have renamed the entry before persisting its ID.
+    // Recover by exact executable ownership, never by a user-visible app name.
+    const shortcuts = apps.filter(a => a.appid >= 2147483648);
+    if (shortcuts.length > 256) throw Error('Too many shortcuts to recover owned entry');
+    const rows = await Promise.allSettled(shortcuts.map(async a => ({ id: a.appid, details: await details(a.appid) })));
+    const owned = rows.filter(r => r.status === 'fulfilled' && executable(r.value.details) === p.exe);
+    if (owned.length !== 1) throw Error('Missing or ambiguous owned shortcut');
+    return { id: owned[0].value.id };
+}

src/apk/steam_ui.rs

@@ -105,24 +105,8 @@ pub(super) fn configure(
     let expression = format!(
         r#"(async()=>{{
         const p={parameters};
-        let app;
-        for(let n=0;n<10;n++){{
-            const apps=Array.from(appStore.m_mapApps.values());
-            const matches=apps.filter(a=>a.display_name==='Devkit Game: '+p.game);
-            app=matches.length===1?matches[0]:apps.find(a=>a.appid===p.previous);
-            if(app) break;
-            await new Promise(r=>setTimeout(r,100));
-        }}
-        if(!app || app.appid<2147483648) throw Error('Missing owned shortcut');
-        const id=app.appid;
-        let sub;
-        const details=await new Promise((resolve,reject)=>{{
-            let timer=setTimeout(()=>{{sub?.unregister();reject(Error('Details timed out'))}},3000);
-            sub=SteamClient.Apps.RegisterForAppDetails(id,d=>{{clearTimeout(timer);sub?.unregister();resolve(d)}});
-        }});
-        sub?.unregister();
-        const exe=details.strShortcutExe?.replace(/^"|"$/g,'').replace('/./','/');
-        if(exe!==p.exe) throw Error('Shortcut target does not match owned APK');
+        const owned=await ({lookup})(p);
+        const id=owned.id;
         SteamClient.Apps.SetShortcutLaunchOptions(id,p.launch);
         SteamClient.Apps.SetShortcutName(id,p.name);
         if(p.icon) SteamClient.Apps.SetShortcutIcon(id,p.icon);
@@ -134,7 +118,8 @@ pub(super) fn configure(
             }}
         }}
         return id;
-    }})()"#
+    }})()"#,
+        lookup = include_str!("steam_shortcut_lookup.js")
     );
     let result = evaluate(&expression)?;
     result

src/service.rs

@@ -2636,6 +2636,13 @@ mod notification_tests {
     #[test]
     fn framely_notification_preferences_control_update_reminders_and_survive_reload() {
         let root = tempfile::tempdir().unwrap();
+        // Model an installed release independently of the build's package version.
+        fs::create_dir(root.path().join("current")).unwrap();
+        fs::write(
+            root.path().join("current/VERSION"),
+            "0.4.2-preview.12-012345abcdef\n",
+        )
+        .unwrap();
         let mut core = crate::tests::accepted_service(root.path(), 1000).unwrap();
         plugin(&mut core);
         send(&mut core, "saved", json!({"inbox":true}));
@@ -2823,6 +2830,13 @@ mod notification_tests {
     #[test]
     fn automatic_update_notifications_ignore_old_versions_and_deduplicate_after_reload() {
         let root = tempfile::tempdir().unwrap();
+        // Model an installed release independently of the build's package version.
+        fs::create_dir(root.path().join("current")).unwrap();
+        fs::write(
+            root.path().join("current/VERSION"),
+            "0.4.2-preview.12-012345abcdef\n",
+        )
+        .unwrap();
         let mut core = crate::tests::accepted_service(root.path(), 1000).unwrap();
         let source = UpdateSource {
             url: "https://example.org/framely-release.json".into(),
@@ -2876,6 +2890,13 @@ mod notification_tests {
     #[test]
     fn automatic_update_schedule_settings_and_stale_completions() {
         let root = tempfile::tempdir().unwrap();
+        // Model an installed release independently of the build's package version.
+        fs::create_dir(root.path().join("current")).unwrap();
+        fs::write(
+            root.path().join("current/VERSION"),
+            "0.4.2-preview.12-012345abcdef\n",
+        )
+        .unwrap();
         let mut core = crate::tests::accepted_service(root.path(), 1000).unwrap();
         let source = UpdateSource {
             url: "https://example.org/framely-release.json".into(),

tests/browser_probe.cpp

@@ -42,9 +42,9 @@ int main(int argc,char** argv){
  cef_main_args_t args{argc,argv};if(std::strcmp(cef_api_hash(CEF_API_VERSION,0),CEF_API_HASH_PLATFORM))return 2;int child=cef_execute_process(&args,nullptr,nullptr);if(child>=0)return child;if(url.empty()||runtime.empty()||cef.empty())return 2;
  cef_settings_t settings{};settings.size=sizeof(settings);settings.windowless_rendering_enabled=1;str(settings.root_cache_path,runtime+"/cache");str(settings.log_file,runtime+"/cef.log");str(settings.resources_dir_path,cef+"/Resources");str(settings.locales_dir_path,cef+"/Resources/locales");
  if(!cef_initialize(&args,&settings,nullptr,nullptr))return 3;
- render.api.get_view_rect=[](cef_render_handler_t*,cef_browser_t*,cef_rect_t* r){*r=launcher_mode?cef_rect_t{0,0,1440,800}:std::getenv("FRAMELY_STORE_TEST")?cef_rect_t{0,0,1440,810}:cef_rect_t{0,0,600,notification_mode?360:840};};render.api.get_screen_info=[](cef_render_handler_t*,cef_browser_t*,cef_screen_info_t* info){if(launcher_mode)return render_screen_info(info,1440,800,3);return render_screen_info(info,std::getenv("FRAMELY_STORE_TEST")?1440:600,std::getenv("FRAMELY_STORE_TEST")?810:(notification_mode?360:840),std::getenv("FRAMELY_STORE_TEST")?4:2);};render.api.on_paint=[](cef_render_handler_t*,cef_browser_t*,cef_paint_element_type_t type,size_t dirty_count,const cef_rect_t* dirty,const void* data,int w,int h){if(type!=PET_VIEW)return;++paints;if(w==(launcher_mode?4320:std::getenv("FRAMELY_STORE_TEST")?5760:1200)&&h==(launcher_mode?2400:std::getenv("FRAMELY_STORE_TEST")?3240:(notification_mode?720:1680)))scaled_paint=true;pixel_width=w;pixel_height=h;merge_paint(pixels,data,w,h,dirty_count,dirty);// Semi-transparent charcoal panels still need a readable surface and clear rounded corners.
+ render.api.get_view_rect=[](cef_render_handler_t*,cef_browser_t*,cef_rect_t* r){*r=launcher_mode?cef_rect_t{0,0,1440,800}:std::getenv("FRAMELY_STORE_TEST")?cef_rect_t{0,0,1440,810}:cef_rect_t{0,0,600,notification_mode?360:840};};render.api.get_screen_info=[](cef_render_handler_t*,cef_browser_t*,cef_screen_info_t* info){if(launcher_mode)return render_screen_info(info,1440,800,1.5f);return render_screen_info(info,std::getenv("FRAMELY_STORE_TEST")?1440:600,std::getenv("FRAMELY_STORE_TEST")?810:(notification_mode?360:840),std::getenv("FRAMELY_STORE_TEST")?4:2);};render.api.on_paint=[](cef_render_handler_t*,cef_browser_t*,cef_paint_element_type_t type,size_t dirty_count,const cef_rect_t* dirty,const void* data,int w,int h){if(type!=PET_VIEW)return;++paints;if(w==(launcher_mode?2160:std::getenv("FRAMELY_STORE_TEST")?5760:1200)&&h==(launcher_mode?1200:std::getenv("FRAMELY_STORE_TEST")?3240:(notification_mode?720:1680)))scaled_paint=true;pixel_width=w;pixel_height=h;merge_paint(pixels,data,w,h,dirty_count,dirty);// Semi-transparent charcoal panels still need a readable surface and clear rounded corners.
 if(!notification_mode&&w>0&&h>0){auto alpha=[&](int x,int y){return pixels[(y*w+x)*4+3];};if(alpha(0,0)==0&&alpha(w-1,0)==0&&alpha(0,h-1)==0&&alpha(w-1,h-1)==0&&alpha(w/2,40)>200)rounded_paint=true;}};
- display.api.on_console_message=[](cef_display_handler_t*,cef_browser_t* b,cef_log_severity_t,const cef_string_t* m,const cef_string_t*,int){auto s=text(m);std::cout<<s<<"\n";if(s.rfind("FRAMELY_PAGE_WHEEL_",0)==0){int x=0,y=0,dx=0,dy=0;if(std::sscanf(s.c_str(),"FRAMELY_PAGE_WHEEL_%d_%d_%d_%d",&x,&y,&dx,&dy)==4){auto* host=b->get_host(b);cef_mouse_event_t mouse{};mouse.x=x;mouse.y=y;host->send_mouse_move_event(host,&mouse,0);host->send_mouse_wheel_event(host,&mouse,dx,dy);host->base.release(&host->base);}}if(s.rfind("FRAMELY_NATIVE_KEYBOARD_",0)==0){auto* frame=b->get_focused_frame(b);auto command=s.substr(24);if(command=="TEXT")keyboard_edit(frame,"汉😃");else if(command=="BACKSPACE")keyboard_edit(frame,"\b");else if(command=="ENTER")keyboard_edit(frame,"\n");else if(command=="X")keyboard_edit(frame,"x");else if(command=="Y")keyboard_edit(frame,"y");else if(command=="LEFT")keyboard_edit(frame,"\x1b[D");else if(command=="RIGHT")keyboard_edit(frame,"\x1b[C");frame->base.release(&frame->base);}if(s=="FRAMELY_LAUNCHER_CANCEL_PRESS"){auto* pointer_host=b->get_host(b);cef_mouse_event_t outside{};outside.modifiers=EVENTFLAG_LEFT_MOUSE_BUTTON;pointer_host->send_mouse_move_event(pointer_host,&outside,0);outside.modifiers=0;pointer_host->send_mouse_click_event(pointer_host,&outside,MBT_LEFT,1,1);test_pointer.clear();press_pending=false;auto* frame=b->get_main_frame(b);cef_string_t code{},source{};str(code,"window.dispatchEvent(new Event('framely.launcher.cancelInput'))");frame->execute_java_script(frame,&code,&source,1);cef_string_utf16_clear(&code);frame->base.release(&frame->base);pointer_host->base.release(&pointer_host->base);}if(s.rfind("FRAMELY_LAUNCHER_DRAG_",0)==0){int x=0,y=0;if(press_pending&&std::sscanf(s.c_str(),"FRAMELY_LAUNCHER_DRAG_%d_%d",&x,&y)==2){press_dx=x-test_pointer.x;press_dy=y-test_pointer.y;}}if(s.rfind("FRAMELY_LAUNCHER_PRESS_",0)==0){int x=0,y=0;if(std::sscanf(s.c_str(),"FRAMELY_LAUNCHER_PRESS_%d_%d_%d_%d_%d",&x,&y,&press_dx,&press_dy,&press_duration)==5){auto* pointer_host=b->get_host(b);test_pointer.begin(x,y,std::chrono::steady_clock::now());press_pending=true;cef_mouse_event_t mouse{};mouse.x=x;mouse.y=y;pointer_host->set_focus(pointer_host,1);pointer_host->send_mouse_move_event(pointer_host,&mouse,0);mouse.modifiers=EVENTFLAG_LEFT_MOUSE_BUTTON;pointer_host->send_mouse_click_event(pointer_host,&mouse,MBT_LEFT,0,1);pointer_host->base.release(&pointer_host->base);}}if(s.rfind("FRAMELY_LAUNCHER_HOVER_",0)==0){int x=0,y=0;if(std::sscanf(s.c_str(),"FRAMELY_LAUNCHER_HOVER_%d_%d",&x,&y)==2){auto* hover_host=b->get_host(b);cef_mouse_event_t mouse{};mouse.x=x;mouse.y=y;hover_host->send_mouse_move_event(hover_host,&mouse,0);hover_host->base.release(&hover_host->base);}}if(s.rfind("FRAMELY_LAUNCHER_REGION_",0)==0){int x=0,y=0,w=0,h=0;if(std::sscanf(s.c_str(),"FRAMELY_LAUNCHER_REGION_%d_%d_%d_%d",&x,&y,&w,&h)==4){const int scale=launcher_mode?3:4;int ink=0;for(int py=std::max(0,y*scale);py<std::min(pixel_height,(y+h)*scale);py++)for(int px=std::max(0,x*scale);px<std::min(pixel_width,(x+w)*scale);px++)if(pixels[(size_t(py)*pixel_width+px)*4+3]>128)ink++;if(ink<30){failed=true;std::cerr<<"FRAMELY_BRIDGE_FAIL missing painted control "<<x<<","<<y<<"\n";}}}if(s.rfind("FRAMELY_LAUNCHER_INK_",0)==0){int x=0,y=0,w=0,h=0;if(std::sscanf(s.c_str(),"FRAMELY_LAUNCHER_INK_%d_%d_%d_%d",&x,&y,&w,&h)==4){const int scale=launcher_mode?3:4;int ink=0;for(int py=std::max(0,y*scale);py<std::min(pixel_height,(y+h)*scale);py++)for(int px=std::max(0,x*scale);px<std::min(pixel_width,(x+w)*scale);px++){size_t i=(size_t(py)*pixel_width+px)*4;if(pixels[i+3]>128&&pixels[i]>180&&pixels[i+1]>180&&pixels[i+2]>180)ink++;}if(ink<30){failed=true;std::cerr<<"FRAMELY_BRIDGE_FAIL missing painted label "<<x<<","<<y<<" ink="<<ink<<"\n";}}}
+ display.api.on_console_message=[](cef_display_handler_t*,cef_browser_t* b,cef_log_severity_t,const cef_string_t* m,const cef_string_t*,int){auto s=text(m);std::cout<<s<<"\n";if(s.rfind("FRAMELY_PAGE_WHEEL_",0)==0){int x=0,y=0,dx=0,dy=0;if(std::sscanf(s.c_str(),"FRAMELY_PAGE_WHEEL_%d_%d_%d_%d",&x,&y,&dx,&dy)==4){auto* host=b->get_host(b);cef_mouse_event_t mouse{};mouse.x=x;mouse.y=y;host->send_mouse_move_event(host,&mouse,0);host->send_mouse_wheel_event(host,&mouse,dx,dy);host->base.release(&host->base);}}if(s.rfind("FRAMELY_NATIVE_KEYBOARD_",0)==0){auto* frame=b->get_focused_frame(b);auto command=s.substr(24);if(command=="TEXT")keyboard_edit(frame,"汉😃");else if(command=="BACKSPACE")keyboard_edit(frame,"\b");else if(command=="ENTER")keyboard_edit(frame,"\n");else if(command=="X")keyboard_edit(frame,"x");else if(command=="Y")keyboard_edit(frame,"y");else if(command=="LEFT")keyboard_edit(frame,"\x1b[D");else if(command=="RIGHT")keyboard_edit(frame,"\x1b[C");frame->base.release(&frame->base);}if(s=="FRAMELY_LAUNCHER_CANCEL_PRESS"){auto* pointer_host=b->get_host(b);cef_mouse_event_t outside{};outside.modifiers=EVENTFLAG_LEFT_MOUSE_BUTTON;pointer_host->send_mouse_move_event(pointer_host,&outside,0);outside.modifiers=0;pointer_host->send_mouse_click_event(pointer_host,&outside,MBT_LEFT,1,1);test_pointer.clear();press_pending=false;auto* frame=b->get_main_frame(b);cef_string_t code{},source{};str(code,"window.dispatchEvent(new Event('framely.launcher.cancelInput'))");frame->execute_java_script(frame,&code,&source,1);cef_string_utf16_clear(&code);frame->base.release(&frame->base);pointer_host->base.release(&pointer_host->base);}if(s.rfind("FRAMELY_LAUNCHER_DRAG_",0)==0){int x=0,y=0;if(press_pending&&std::sscanf(s.c_str(),"FRAMELY_LAUNCHER_DRAG_%d_%d",&x,&y)==2){press_dx=x-test_pointer.x;press_dy=y-test_pointer.y;}}if(s.rfind("FRAMELY_LAUNCHER_PRESS_",0)==0){int x=0,y=0;if(std::sscanf(s.c_str(),"FRAMELY_LAUNCHER_PRESS_%d_%d_%d_%d_%d",&x,&y,&press_dx,&press_dy,&press_duration)==5){auto* pointer_host=b->get_host(b);test_pointer.begin(x,y,std::chrono::steady_clock::now());press_pending=true;cef_mouse_event_t mouse{};mouse.x=x;mouse.y=y;pointer_host->set_focus(pointer_host,1);pointer_host->send_mouse_move_event(pointer_host,&mouse,0);mouse.modifiers=EVENTFLAG_LEFT_MOUSE_BUTTON;pointer_host->send_mouse_click_event(pointer_host,&mouse,MBT_LEFT,0,1);pointer_host->base.release(&pointer_host->base);}}if(s.rfind("FRAMELY_LAUNCHER_HOVER_",0)==0){int x=0,y=0;if(std::sscanf(s.c_str(),"FRAMELY_LAUNCHER_HOVER_%d_%d",&x,&y)==2){auto* hover_host=b->get_host(b);cef_mouse_event_t mouse{};mouse.x=x;mouse.y=y;hover_host->send_mouse_move_event(hover_host,&mouse,0);hover_host->base.release(&hover_host->base);}}if(s.rfind("FRAMELY_LAUNCHER_REGION_",0)==0){int x=0,y=0,w=0,h=0;if(std::sscanf(s.c_str(),"FRAMELY_LAUNCHER_REGION_%d_%d_%d_%d",&x,&y,&w,&h)==4){const float scale=launcher_mode?1.5f:4.f;int ink=0;for(int py=std::max(0,int(y*scale));py<std::min(pixel_height,int((y+h)*scale));py++)for(int px=std::max(0,int(x*scale));px<std::min(pixel_width,int((x+w)*scale));px++)if(pixels[(size_t(py)*pixel_width+px)*4+3]>128)ink++;if(ink<30){failed=true;std::cerr<<"FRAMELY_BRIDGE_FAIL missing painted control "<<x<<","<<y<<"\n";}}}if(s.rfind("FRAMELY_LAUNCHER_INK_",0)==0){int x=0,y=0,w=0,h=0;if(std::sscanf(s.c_str(),"FRAMELY_LAUNCHER_INK_%d_%d_%d_%d",&x,&y,&w,&h)==4){const float scale=launcher_mode?1.5f:4.f;int ink=0;for(int py=std::max(0,int(y*scale));py<std::min(pixel_height,int((y+h)*scale));py++)for(int px=std::max(0,int(x*scale));px<std::min(pixel_width,int((x+w)*scale));px++){size_t i=(size_t(py)*pixel_width+px)*4;if(pixels[i+3]>128&&pixels[i]>180&&pixels[i+1]>180&&pixels[i+2]>180)ink++;}if(ink<30){failed=true;std::cerr<<"FRAMELY_BRIDGE_FAIL missing painted label "<<x<<","<<y<<" ink="<<ink<<"\n";}}}
 if(s=="FRAMELY_DPI_CLICK_REQUEST"){auto* host=b->get_host(b);cef_mouse_event_t mouse{};mouse.x=50;mouse.y=45;host->set_focus(host,1);host->send_mouse_move_event(host,&mouse,0);host->send_mouse_click_event(host,&mouse,MBT_LEFT,0,1);host->send_mouse_click_event(host,&mouse,MBT_LEFT,1,1);host->base.release(&host->base);}if(s=="FRAMELY_DPI_CLICK_PASS")dpi_click=true;if(s.rfind("FRAMELY_PREVIEW_INSTALL_",0)==0)snapshot(s.substr(16));if(s=="FRAMELY_PREVIEW_STORE")snapshot("store");if(s=="FRAMELY_PREVIEW_FAVORITES")snapshot("favorites");if(s=="FRAMELY_PREVIEW_INSTALLED")snapshot("installed");if(s=="FRAMELY_PREVIEW_SETTINGS")snapshot("settings");if(s=="FRAMELY_VIEW_READY")ready=true;if(s=="FRAMELY_BRIDGE_PASS")passed=true;if(s.rfind("FRAMELY_BRIDGE_FAIL",0)==0)failed=true;return 1;};life.api.on_before_close=[](cef_life_span_handler_t*,cef_browser_t*){closed=true;};
  client.api.get_render_handler=[](cef_client_t*){return render.acquire();};client.api.get_display_handler=[](cef_client_t*){return display.acquire();};client.api.get_life_span_handler=[](cef_client_t*){return life.acquire();};
  cef_window_info_t win{};win.size=sizeof(win);win.windowless_rendering_enabled=1;cef_browser_settings_t bs{};bs.size=sizeof(bs);bs.windowless_frame_rate=60;cef_string_t uri{};str(uri,url);auto* browser=cef_browser_host_create_browser_sync(&win,&client.api,&uri,&bs,nullptr,nullptr);cef_string_utf16_clear(&uri);if(!browser)return 4;auto* host=browser->get_host(browser);

tests/gamepad_mapping.cpp

@@ -14,4 +14,12 @@ int main(){
  while(std::getline(file,line)){std::istringstream row(line);std::string kind,name;int code;if(row>>kind>>code>>name&&kind=="key")entries[code]=name;}
  const char* names[]={"BUTTON_A","BUTTON_B","BUTTON_X","BUTTON_Y","BUTTON_L1","BUTTON_R1","BUTTON_SELECT","BUTTON_START","BUTTON_THUMBL","BUTTON_THUMBR"};
  for(int i=0;i<10;i++)assert(entries[keys[i]]==names[i]);
+ assert(trigger_keys[0]==312&&trigger_keys[1]==313);
+ assert(entries[trigger_keys[0]]=="BUTTON_L2"&&entries[trigger_keys[1]]=="BUTTON_R2");
+ GamepadTriggers triggers;
+ assert(!triggers.update(0,0));assert(!triggers.update(0,29));
+ assert(triggers.update(0,30));assert(triggers.update(0,25));
+ assert(!triggers.down[1]);assert(triggers.update(1,255));
+ assert(!triggers.update(0,20));assert(triggers.down[1]);
+ assert(!triggers.update(1,0));assert(!triggers.down[0]&&!triggers.down[1]);
 }

tests/test-steam-shortcut-lookup.mjs

@@ -0,0 +1,24 @@
+import assert from 'node:assert/strict';
+import {readFile} from 'node:fs/promises';
+const lookup=eval(`(${await readFile('src/apk/steam_shortcut_lookup.js','utf8')})`);
+const id=0xf1234567, exe='/home/steamos/devkit-game/owned/base.apk';
+let targets=new Map([[id,{strShortcutExe:`"${exe}"`}]]),unregistered=0;
+globalThis.appStore={m_mapApps:new Map([[id,{appid:id,display_name:'GamePad Tester'}]])};
+globalThis.SteamClient={Apps:{RegisterForAppDetails:(id,cb)=>{queueMicrotask(()=>cb(targets.get(id)??{}));return {unregister(){unregistered++}}}}};
+assert.deepEqual(await lookup({game:'owned',exe}),{id});
+assert.ok(unregistered>0);
+assert.deepEqual(await lookup({game:'owned',exe,previous:id}),{id});
+// Never accept an identically named entry belonging to a different executable.
+appStore.m_mapApps.set(id,{appid:id,display_name:'Devkit Game: owned'});
+targets.set(id,{strShortcutExe:'/another/app.apk'});
+await assert.rejects(lookup({game:'owned',exe}),/target does not match/);
+appStore.m_mapApps.set(id,{appid:id,display_name:'GamePad Tester'});
+await assert.rejects(lookup({game:'owned',exe}),/Missing or ambiguous/);
+targets.set(id,{strShortcutExe:exe});
+appStore.m_mapApps.set(id+1,{appid:id+1,display_name:'Another copy'});targets.set(id+1,{strShortcutExe:exe});
+await assert.rejects(lookup({game:'owned',exe}),/ambiguous/);
+// Cached details can call back before the subscription is returned.
+appStore.m_mapApps.delete(id+1);
+SteamClient.Apps.RegisterForAppDetails=(id,cb)=>{cb(targets.get(id));return {unregister(){unregistered++}}};
+assert.deepEqual(await lookup({game:'owned',exe,previous:id}),{id});
+console.log('Renamed registration recovery, executable ownership, ambiguity and cached callback checks passed.');