modular session management daemon
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142mod session_management_v1 { #![allow(clippy::all, clippy::pedantic, clippy::nursery, clippy::unwrap_used)]
hyprwire::include_protocol!("session_management_v1"); pub use client::*;}
use hyprwire::client;use pamsm::{PamLibExt, PamServiceModule};use session_management_v1::session_manager;
struct Session { session_id: Option<u32>, seat: Option<String>,}
impl hyprwire::Dispatch<session_manager::SessionManager> for Session { fn event( &mut self, _: &session_manager::SessionManager, event: <session_manager::SessionManager as hyprwire::Object>::Event<'_>, ) { let session_manager::Event::SessionCreated { session_id, seat } = event; self.session_id = Some(session_id); self.seat = Some(seat); }}
struct Pam;
impl PamServiceModule for Pam { fn open_session(pamh: pamsm::Pam, _: pamsm::PamFlags, _: Vec<String>) -> pamsm::PamError { fn inner(pamh: &pamsm::Pam) -> Result<(), pamsm::PamError> { let mut session = Session { session_id: None, seat: None, };
let mut socket = client::Client::connect("/run/sessiond.sock") .map_err(|_| pamsm::PamError::SESSION_ERR)?; let event_queue = socket.new_event_queue();
socket.add_implementation::<session_management_v1::SessionManagementV1Impl>();
event_queue .wait_for_handshake(&mut session) .map_err(|_| pamsm::PamError::SESSION_ERR)?;
let manager = socket .bind::<session_manager::SessionManager, _>(&event_queue, &mut session, 1) .map_err(|_| pamsm::PamError::SESSION_ERR)?;
let username = pamh .get_user(None)? .ok_or(pamsm::PamError::USER_UNKNOWN)? .to_string_lossy() .to_string(); let uid = users::get_user_by_name(&username) .ok_or(pamsm::PamError::USER_UNKNOWN)? .uid(); let vt = pamh .get_tty()? .and_then(|tty| { tty.to_string_lossy() .rsplit('/') .next() .and_then(|name| name.strip_prefix("tty")) .and_then(|vt| vt.parse().ok()) }) .unwrap_or(0); manager.send_create_session(uid, username, vt);
while session.session_id.is_none() { event_queue .dispatch_events(&mut session, true) .map_err(|_| pamsm::PamError::SESSION_ERR)?; }
let session_id = session.session_id.ok_or(pamsm::PamError::SESSION_ERR)?; pamh.send_bytes("sessiond", session_id.to_le_bytes().to_vec(), None) .map_err(|_| pamsm::PamError::SESSION_ERR)?;
pamh.putenv(&format!("XDG_SESSION_ID={session_id}"))?; if let Some(seat) = session.seat { pamh.putenv(&format!("XDG_SEAT={seat}"))?; } pamh.putenv(&format!("XDG_RUNTIME_DIR=/run/user/{uid}"))?;
Ok(()) }
match inner(&pamh) { Ok(()) => pamsm::PamError::SUCCESS, Err(e) => e, } }
fn close_session(pamh: pamsm::Pam, _: pamsm::PamFlags, _: Vec<String>) -> pamsm::PamError { fn inner(pamh: &pamsm::Pam) -> Result<(), pamsm::PamError> { let session_id = pamh .retrieve_bytes("sessiond") .map_err(|_| pamsm::PamError::SESSION_ERR) .and_then(|bytes| { bytes .try_into() .map(u32::from_le_bytes) .map_err(|_| pamsm::PamError::SESSION_ERR) })?;
let mut session = Session { session_id: None, seat: None, };
let mut socket = client::Client::connect("/run/sessiond.sock") .map_err(|_| pamsm::PamError::SESSION_ERR)?; let event_queue = socket.new_event_queue();
socket.add_implementation::<session_management_v1::SessionManagementV1Impl>();
event_queue .wait_for_handshake(&mut session) .map_err(|_| pamsm::PamError::SESSION_ERR)?;
let manager = socket .bind::<session_manager::SessionManager, _>(&event_queue, &mut session, 1) .map_err(|_| pamsm::PamError::SESSION_ERR)?;
manager.send_destroy_session(session_id);
Ok(()) }
match inner(&pamh) { Ok(()) => pamsm::PamError::SUCCESS, Err(e) => e, } }}
pamsm::pam_module!(Pam);