forked from coreos/rpm-ostree
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request coreos#3526 from lucab/ups/daemon-dbus-deployment-…
…lookup-rust
- Loading branch information
Showing
6 changed files
with
129 additions
and
62 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,98 @@ | ||
| //! Helper logic for handling deployments. | ||
| // SPDX-License-Identifier: Apache-2.0 OR MIT | ||
|
|
||
| use crate::cxxrsutil::*; | ||
| use anyhow::{anyhow, format_err, Result}; | ||
| use ostree_ext::glib::translate::*; | ||
| use ostree_ext::ostree; | ||
| use std::pin::Pin; | ||
|
|
||
| /// Get a currently unique (for this host) identifier for the deployment. | ||
| // TODO - adding the deployment timestamp would make it | ||
| // persistently unique, needs API in libostree. | ||
| pub fn deployment_generate_id(mut deployment: Pin<&mut crate::FFIOstreeDeployment>) -> String { | ||
| let deployment = deployment.gobj_wrap(); | ||
| deployment_generate_id_impl(&deployment) | ||
| } | ||
|
|
||
| pub(crate) fn deployment_generate_id_impl(deployment: &ostree::Deployment) -> String { | ||
| // SAFETY: the results of these are not-nullable in the C API. | ||
| format!( | ||
| "{}-{}.{}", | ||
| deployment.osname().unwrap(), | ||
| deployment.csum().unwrap(), | ||
| deployment.deployserial() | ||
| ) | ||
| } | ||
|
|
||
| pub fn deployment_for_id( | ||
| mut ffi_sysroot: Pin<&mut crate::ffi::OstreeSysroot>, | ||
| deploy_id: &str, | ||
| ) -> CxxResult<*mut crate::FFIOstreeDeployment> { | ||
| let sysroot = &ffi_sysroot.gobj_wrap(); | ||
|
|
||
| let deployment = deployment_for_id_impl(sysroot, deploy_id)?; | ||
|
|
||
| let depl_ptr: *mut ostree::ffi::OstreeDeployment = deployment.to_glib_full(); | ||
| Ok(depl_ptr as *mut _) | ||
| } | ||
|
|
||
| fn deployment_for_id_impl( | ||
| sysroot: &ostree::Sysroot, | ||
| deploy_id: &str, | ||
| ) -> Result<ostree::Deployment> { | ||
| if deploy_id.is_empty() { | ||
| return Err(anyhow!("empty deployment ID")); | ||
| } | ||
|
|
||
| for depl_entry in sysroot.deployments() { | ||
| let id = deployment_generate_id_impl(&depl_entry); | ||
| if deploy_id == id { | ||
| return Ok(depl_entry); | ||
| } | ||
| } | ||
|
|
||
| Err(anyhow!("Deployment with id '{}' not found", deploy_id)) | ||
| } | ||
|
|
||
| pub fn deployment_checksum_for_id( | ||
| mut ffi_sysroot: Pin<&mut crate::ffi::OstreeSysroot>, | ||
| deploy_id: &str, | ||
| ) -> CxxResult<String> { | ||
| let sysroot = &ffi_sysroot.gobj_wrap(); | ||
|
|
||
| let deployment = deployment_for_id_impl(&sysroot, deploy_id)?; | ||
| // SAFETY: result is not-nullable in the C API. | ||
| let csum = deployment.csum().unwrap(); | ||
| Ok(csum.to_string()) | ||
| } | ||
|
|
||
| pub fn deployment_get_base( | ||
| mut ffi_sysroot: Pin<&mut crate::ffi::OstreeSysroot>, | ||
| opt_deploy_id: &str, | ||
| opt_os_name: &str, | ||
| ) -> CxxResult<*mut crate::FFIOstreeDeployment> { | ||
| let sysroot = &ffi_sysroot.gobj_wrap(); | ||
| let deploy_id = opt_string(opt_deploy_id); | ||
| let os_name = opt_string(opt_os_name); | ||
|
|
||
| let deployment = deployment_get_base_impl(&sysroot, deploy_id, os_name)?; | ||
|
|
||
| let depl_ptr: *mut ostree::ffi::OstreeDeployment = deployment.to_glib_full(); | ||
| Ok(depl_ptr as *mut _) | ||
| } | ||
|
|
||
| fn deployment_get_base_impl( | ||
| sysroot: &ostree::Sysroot, | ||
| deploy_id: Option<&str>, | ||
| os_name: Option<&str>, | ||
| ) -> Result<ostree::Deployment> { | ||
| match deploy_id { | ||
| Some(id) => deployment_for_id_impl(sysroot, id), | ||
| None => sysroot.merge_deployment(os_name).ok_or_else(|| { | ||
| let name = os_name.unwrap_or_default(); | ||
| format_err!("No deployments found for os '{}'", name) | ||
| }), | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters