backend: Add basic support

.github/workflows/CI.yml

@@ -23,7 +23,7 @@ jobs:
       - uses: actions-rs/cargo@v1
         with:
           command: check
-          args: --features "gtk4,pipewire,wayland,raw_handle,tracing"
+          args: --features "gtk4,pipewire,wayland,raw_handle,tracing,backend"
 
   test:
     name: Test Suite
@@ -42,7 +42,7 @@ jobs:
       - uses: actions-rs/cargo@v1
         with:
           command: test
-          args: --features "gtk4,pipewire,wayland,raw_handle,tracing"
+          args: --features "gtk4,pipewire,wayland,raw_handle,tracing,backend"
 
   fmt:
     name: Rustfmt
@@ -82,4 +82,4 @@ jobs:
       - uses: actions-rs/cargo@v1
         with:
           command: clippy
-          args: --features "gtk4,pipewire,wayland,raw_handle,tracing" -- -D warnings
+          args: --features "gtk4,pipewire,wayland,raw_handle,tracing,backend" -- -D warnings

.github/workflows/backend-demo-ci.yml

@@ -0,0 +1,69 @@
+on:
+  push:
+    branches: [master]
+  pull_request:
+
+name: Backend Demo CI
+
+jobs:
+  check:
+    name: Check
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: actions-rs/toolchain@v1
+        with:
+          profile: minimal
+          toolchain: stable
+          override: true
+      - uses: actions-rs/cargo@v1
+        with:
+          command: check
+          args: --manifest-path=backend-demo/Cargo.toml
+
+  test:
+    name: Test Suite
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: actions-rs/toolchain@v1
+        with:
+          profile: minimal
+          toolchain: stable
+          override: true
+      - uses: actions-rs/cargo@v1
+        with:
+          command: test
+          args: --manifest-path=backend-demo/Cargo.toml
+
+  fmt:
+    name: Rustfmt
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: actions-rs/toolchain@v1
+        with:
+          profile: minimal
+          toolchain: stable
+          override: true
+      - run: rustup component add rustfmt
+      - uses: actions-rs/cargo@v1
+        with:
+          command: fmt
+          args: --manifest-path=backend-demo/Cargo.toml --all -- --check
+
+  clippy:
+    name: Clippy
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: actions-rs/toolchain@v1
+        with:
+          profile: minimal
+          toolchain: stable
+          override: true
+      - run: rustup component add clippy
+      - uses: actions-rs/cargo@v1
+        with:
+          command: clippy
+          args: --manifest-path=backend-demo/Cargo.toml -- -D warnings

.gitignore

@@ -15,9 +15,11 @@ ashpd-demo/_build/
 ashpd-demo/builddir/
 ashpd-demo/src/config.rs
 ashpd-demo/target/
+backend-demo/target
 
 .flatpak
 .vscode
 _build/
 builddir/
 session-test
+.fenv

Cargo.toml

@@ -14,6 +14,9 @@ rust-version = "1.75"
 [features]
 async-std = ["zbus/async-io", "dep:async-fs", "dep:async-net"]
 default = ["async-std"]
+
+backend = ["async-trait", "nix", "futures-channel/sink", "dep:async-lock"]
+
 gtk4 = ["gtk4_x11", "gtk4_wayland"]
 gtk4_wayland = ["gdk4wayland", "glib", "dep:gtk4"]
 gtk4_x11 = ["gdk4x11", "glib", "dep:gtk4"]
@@ -24,14 +27,17 @@ wayland = ["wayland-client", "wayland-protocols", "wayland-backend"]
 
 [dependencies]
 async-fs = { version = "2.1.0", optional = true }
+async-lock = { version = "3.3.0", optional = true }
 async-net = { version = "2.0.0", optional = true }
+async-trait = {version = "0.1.60", optional = true}
 enumflags2 = "0.7"
 futures-channel = "0.3"
 futures-util = "0.3"
 gdk4wayland = { package = "gdk4-wayland", version = "0.9", optional = true }
 gdk4x11 = { package = "gdk4-x11", version = "0.9", optional = true }
 glib = { version = "0.20", optional = true }
 gtk4 = { version = "0.9", optional = true }
+nix = { version = "0.28", optional = true, features = ["user"], default-features = false}
 pipewire = { version = "0.8", optional = true }
 rand = { version = "0.8", default-features = false }
 raw-window-handle = { version = "0.6", optional = true }

README.md

@@ -44,6 +44,7 @@ pub async fn run() -> ashpd::Result<()> {
 | tracing | Record various debug information using the `tracing` library | No |
 | tokio | Enable tokio runtime on zbus dependency | No |
 | async-std | Enable the use of the async-std runtime | Yes |
+| backend | *unstable* Enables APIs useful for writing portals implementations | No |
 | glib | Make all the enums derive `glib::Enum`. Flags are not supported yet | No |
 | gtk4 | Implement `From<Color>` for [`gdk4::RGBA`](https://gtk-rs.org/gtk4-rs/stable/latest/docs/gdk4/struct.RGBA.html) Provides `WindowIdentifier::from_native` that takes a [`IsA<gtk4::Native>`](https://gtk-rs.org/gtk4-rs/stable/latest/docs/gtk4/struct.Native.html) | No |
 | gtk4_wayland |Provides `WindowIdentifier::from_native` that takes a [`IsA<gtk4::Native>`](https://gtk-rs.org/gtk4-rs/stable/latest/docs/gtk4/struct.Native.html) with Wayland backend support only | No |

backend-demo/Cargo.toml

@@ -0,0 +1,20 @@
+[package]
+name = "ashpd-backend-demo"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+anyhow = "1.0"
+async-trait = "0.1.60"
+tokio = { version = "1.0", features = ["io-util", "net", "time", "macros", "rt-multi-thread"] }
+byteorder = "1.4.3"
+futures-channel = "0.3.25"
+futures-util = "0.3.25"
+tracing = "0.1"
+tracing-subscriber = "0.3.16"
+url = "2.3.1"
+zbus = "4.2"
+
+[dependencies.ashpd]
+path = "../"
+features = ["backend", "tracing"]

backend-demo/data/ashpd-backend-demo.portal

@@ -0,0 +1,3 @@
+[portal]
+DBusName=org.freedesktop.impl.portal.desktop.ashpd-backend-demo
+Interfaces=org.freedesktop.impl.portal.Account;org.freedesktop.impl.portal.Screenshot;org.freedesktop.impl.portal.Wallpaper;

backend-demo/src/account.rs

@@ -0,0 +1,41 @@
+use std::num::NonZeroU32;
+
+use ashpd::{
+    backend::{
+        account::{AccountImpl, UserInformationOptions},
+        request::RequestImpl,
+    },
+    desktop::{account::UserInformation, Response},
+    AppID, WindowIdentifierType,
+};
+use async_trait::async_trait;
+
+#[derive(Default)]
+pub struct Account;
+
+#[async_trait]
+impl RequestImpl for Account {
+    async fn close(&self) {
+        tracing::debug!("IN Close()");
+    }
+}
+
+#[async_trait]
+impl AccountImpl for Account {
+    const VERSION: NonZeroU32 = NonZeroU32::MIN;
+
+    async fn get_information(
+        &self,
+        _app_id: AppID,
+        _window_identifier: Option<WindowIdentifierType>,
+        _options: UserInformationOptions,
+    ) -> Response<UserInformation> {
+        match UserInformation::current_user().await {
+            Ok(info) => Response::ok(info),
+            Err(err) => {
+                tracing::error!("Failed to get user info: {err}");
+                Response::other()
+            }
+        }
+    }
+}

backend-demo/src/main.rs

@@ -0,0 +1,45 @@
+use futures_util::future::pending;
+mod account;
+mod screenshot;
+mod wallpaper;
+
+use account::Account;
+use screenshot::Screenshot;
+use wallpaper::Wallpaper;
+
+// NOTE Uncomment if you have ashpd-backend-demo.portal installed.
+// const NAME: &str = "org.freedesktop.impl.portal.desktop.ashpd-backend-demo";
+const NAME: &str = "org.freedesktop.impl.portal.desktop.gnome";
+// Run with
+// RUST_LOG=ashpd_backend_demo=debug,ashpd=debug cargo run --manifest-path ./backend-demo/Cargo.toml
+
+#[tokio::main]
+async fn main() -> ashpd::Result<()> {
+    // Enable debug with `RUST_LOG=ashpd_backend_demo=debug COMMAND`.
+    tracing_subscriber::fmt::init();
+
+    tracing::debug!("Serving interfaces at {NAME}");
+    let backend = ashpd::backend::Backend::new(NAME).await?;
+    let account = ashpd::backend::account::Account::new(Account, &backend).await?;
+    tokio::task::spawn(async move {
+        loop {
+            account.try_next().await.unwrap();
+        }
+    });
+    let wallpaper = ashpd::backend::wallpaper::Wallpaper::new(Wallpaper, &backend).await?;
+    tokio::task::spawn(async move {
+        loop {
+            wallpaper.try_next().await.unwrap();
+        }
+    });
+    let screenshot = ashpd::backend::screenshot::Screenshot::new(Screenshot, &backend).await?;
+    tokio::task::spawn(async move {
+        loop {
+            screenshot.try_next().await.unwrap();
+        }
+    });
+
+    loop {
+        pending::<()>().await;
+    }
+}

backend-demo/src/screenshot.rs

@@ -0,0 +1,46 @@
+use std::num::NonZeroU32;
+
+use ashpd::{
+    backend::{
+        request::RequestImpl,
+        screenshot::{ColorOptions, ScreenshotImpl, ScreenshotOptions},
+    },
+    desktop::{screenshot::Screenshot as ScreenshotResponse, Color, Response},
+    AppID, WindowIdentifierType,
+};
+use async_trait::async_trait;
+
+#[derive(Default)]
+pub struct Screenshot;
+
+#[async_trait]
+impl RequestImpl for Screenshot {
+    async fn close(&self) {
+        tracing::debug!("IN Close()");
+    }
+}
+
+#[async_trait]
+impl ScreenshotImpl for Screenshot {
+    const VERSION: NonZeroU32 = NonZeroU32::MIN;
+
+    async fn screenshot(
+        &self,
+        _app_id: AppID,
+        _window_identifier: Option<WindowIdentifierType>,
+        _options: ScreenshotOptions,
+    ) -> Response<ScreenshotResponse> {
+        Response::ok(ScreenshotResponse::new(
+            url::Url::parse("file:///some/sreenshot").unwrap(),
+        ))
+    }
+
+    async fn pick_color(
+        &self,
+        _app_id: AppID,
+        _window_identifier: Option<WindowIdentifierType>,
+        _options: ColorOptions,
+    ) -> Response<Color> {
+        Response::ok(Color::new(1.0, 1.0, 1.0))
+    }
+}

backend-demo/src/wallpaper.rs

@@ -0,0 +1,42 @@
+use std::num::NonZeroU32;
+
+use ashpd::{
+    backend::{
+        request::RequestImpl,
+        wallpaper::{WallpaperImpl, WallpaperOptions},
+    },
+    desktop::Response,
+    AppID, WindowIdentifierType,
+};
+use async_trait::async_trait;
+
+#[derive(Default)]
+pub struct Wallpaper;
+
+#[async_trait]
+impl RequestImpl for Wallpaper {
+    async fn close(&self) {
+        tracing::debug!("IN Close()");
+    }
+}
+
+#[async_trait]
+impl WallpaperImpl for Wallpaper {
+    const VERSION: NonZeroU32 = NonZeroU32::MIN;
+
+    async fn with_uri(
+        &self,
+        app_id: AppID,
+        window_identifier: Option<WindowIdentifierType>,
+        uri: url::Url,
+        options: WallpaperOptions,
+    ) -> Response<()> {
+        tracing::debug!(
+            "IN SetWallpaperURI({app_id}, {window_identifier:?}, {}, {options:?})",
+            uri.as_str()
+        );
+
+        tracing::debug!("OUT SetWallpaperURI",);
+        Response::ok(())
+    }
+}

src/app_id.rs

@@ -9,6 +9,18 @@ use zbus::zvariant::Type;
 #[derive(Debug, Serialize, Type, PartialEq, Eq, Hash, Clone)]
 pub struct AppID(String);
 
+impl AppID {
+    #[cfg(all(
+        feature = "backend",
+        any(feature = "gtk4_x11", feature = "gtk4_wayland")
+    ))]
+    /// Retrieves the associated `gio::DesktopAppInfo` if found
+    pub fn app_info(&self) -> Option<gtk4::gio::DesktopAppInfo> {
+        let desktop_file = format!("{}.desktop", self.0);
+        gtk4::gio::DesktopAppInfo::new(&desktop_file)
+    }
+}
+
 impl FromStr for AppID {
     type Err = crate::Error;
     fn from_str(value: &str) -> Result<Self, Self::Err> {

src/backend/access.rs

@@ -0,0 +1,33 @@
+use std::collections::HashMap;
+
+use zbus::zvariant::{OwnedValue, Value};
+
+use crate::{
+    desktop::{request::Response, HandleToken, ResponseError},
+    AppID, WindowIdentifierType,
+};
+
+pub struct Access {}
+
+#[zbus::interface(name = "org.freedesktop.impl.portal.Access")]
+impl Access {
+    fn access_dialog(
+        &self,
+        _handle: HandleToken,
+        _app_id: AppID,
+        window_identifier: &str,
+        _title: &str,
+        _subtitle: &str,
+        _body: &str,
+        _options: HashMap<&str, Value<'_>>,
+    ) -> Response<HashMap<String, OwnedValue>> {
+        #[cfg(feature = "tracing")]
+        tracing::debug!("Access::AccessDialog");
+        let _window_identifier = if window_identifier.is_empty() {
+            None
+        } else {
+            window_identifier.parse::<WindowIdentifierType>().ok()
+        };
+        Response::Err(ResponseError::Cancelled)
+    }
+}