pyo3/conversions/std/
osstr.rsuse crate::instance::Bound;
use crate::types::any::PyAnyMethods;
use crate::types::PyString;
use crate::{ffi, FromPyObject, IntoPy, PyAny, PyObject, PyResult, Python, ToPyObject};
use std::borrow::Cow;
use std::ffi::{OsStr, OsString};
impl ToPyObject for OsStr {
fn to_object(&self, py: Python<'_>) -> PyObject {
if let Some(valid_utf8_path) = self.to_str() {
return valid_utf8_path.to_object(py);
}
#[cfg(not(windows))]
{
#[cfg(target_os = "wasi")]
let bytes = std::os::wasi::ffi::OsStrExt::as_bytes(self);
#[cfg(not(target_os = "wasi"))]
let bytes = std::os::unix::ffi::OsStrExt::as_bytes(self);
let ptr = bytes.as_ptr().cast();
let len = bytes.len() as ffi::Py_ssize_t;
unsafe {
let pystring = ffi::PyUnicode_DecodeFSDefaultAndSize(ptr, len);
PyObject::from_owned_ptr(py, pystring)
}
}
#[cfg(windows)]
{
let wstr: Vec<u16> = std::os::windows::ffi::OsStrExt::encode_wide(self).collect();
unsafe {
PyObject::from_owned_ptr(
py,
ffi::PyUnicode_FromWideChar(wstr.as_ptr(), wstr.len() as ffi::Py_ssize_t),
)
}
}
}
}
impl FromPyObject<'_> for OsString {
fn extract_bound(ob: &Bound<'_, PyAny>) -> PyResult<Self> {
let pystring = ob.downcast::<PyString>()?;
#[cfg(not(windows))]
{
let fs_encoded_bytes = unsafe {
crate::Py::<crate::types::PyBytes>::from_owned_ptr(
ob.py(),
ffi::PyUnicode_EncodeFSDefault(pystring.as_ptr()),
)
};
#[cfg(target_os = "wasi")]
let os_str: &OsStr =
std::os::wasi::ffi::OsStrExt::from_bytes(fs_encoded_bytes.as_bytes(ob.py()));
#[cfg(not(target_os = "wasi"))]
let os_str: &OsStr =
std::os::unix::ffi::OsStrExt::from_bytes(fs_encoded_bytes.as_bytes(ob.py()));
Ok(os_str.to_os_string())
}
#[cfg(windows)]
{
use crate::types::string::PyStringMethods;
if let Ok(utf8_string) = pystring.to_cow() {
return Ok(utf8_string.into_owned().into());
}
let size =
unsafe { ffi::PyUnicode_AsWideChar(pystring.as_ptr(), std::ptr::null_mut(), 0) };
crate::err::error_on_minusone(ob.py(), size)?;
let mut buffer = vec![0; size as usize];
let bytes_read =
unsafe { ffi::PyUnicode_AsWideChar(pystring.as_ptr(), buffer.as_mut_ptr(), size) };
assert_eq!(bytes_read, size);
let os_string = std::os::windows::ffi::OsStringExt::from_wide(&buffer);
Ok(os_string)
}
}
}
impl IntoPy<PyObject> for &'_ OsStr {
#[inline]
fn into_py(self, py: Python<'_>) -> PyObject {
self.to_object(py)
}
}
impl ToPyObject for Cow<'_, OsStr> {
#[inline]
fn to_object(&self, py: Python<'_>) -> PyObject {
(self as &OsStr).to_object(py)
}
}
impl IntoPy<PyObject> for Cow<'_, OsStr> {
#[inline]
fn into_py(self, py: Python<'_>) -> PyObject {
self.to_object(py)
}
}
impl ToPyObject for OsString {
#[inline]
fn to_object(&self, py: Python<'_>) -> PyObject {
(self as &OsStr).to_object(py)
}
}
impl IntoPy<PyObject> for OsString {
fn into_py(self, py: Python<'_>) -> PyObject {
self.to_object(py)
}
}
impl<'a> IntoPy<PyObject> for &'a OsString {
fn into_py(self, py: Python<'_>) -> PyObject {
self.to_object(py)
}
}
#[cfg(test)]
mod tests {
use crate::types::{PyAnyMethods, PyStringMethods};
use crate::{types::PyString, IntoPy, PyObject, Python, ToPyObject};
use std::fmt::Debug;
use std::{
borrow::Cow,
ffi::{OsStr, OsString},
};
#[test]
#[cfg(not(windows))]
fn test_non_utf8_conversion() {
Python::with_gil(|py| {
#[cfg(not(target_os = "wasi"))]
use std::os::unix::ffi::OsStrExt;
#[cfg(target_os = "wasi")]
use std::os::wasi::ffi::OsStrExt;
let payload = &[250, 251, 252, 253, 254, 255, 0, 255];
let os_str = OsStr::from_bytes(payload);
let py_str: PyObject = os_str.into_py(py);
let os_str_2: OsString = py_str.extract(py).unwrap();
assert_eq!(os_str, os_str_2);
});
}
#[test]
fn test_topyobject_roundtrip() {
Python::with_gil(|py| {
fn test_roundtrip<T: ToPyObject + AsRef<OsStr> + Debug>(py: Python<'_>, obj: T) {
let pyobject = obj.to_object(py);
let pystring = pyobject.downcast_bound::<PyString>(py).unwrap();
assert_eq!(pystring.to_string_lossy(), obj.as_ref().to_string_lossy());
let roundtripped_obj: OsString = pystring.extract().unwrap();
assert_eq!(obj.as_ref(), roundtripped_obj.as_os_str());
}
let os_str = OsStr::new("Hello\0\nš");
test_roundtrip::<&OsStr>(py, os_str);
test_roundtrip::<Cow<'_, OsStr>>(py, Cow::Borrowed(os_str));
test_roundtrip::<Cow<'_, OsStr>>(py, Cow::Owned(os_str.to_os_string()));
test_roundtrip::<OsString>(py, os_str.to_os_string());
});
}
#[test]
fn test_intopy_roundtrip() {
Python::with_gil(|py| {
fn test_roundtrip<T: IntoPy<PyObject> + AsRef<OsStr> + Debug + Clone>(
py: Python<'_>,
obj: T,
) {
let pyobject = obj.clone().into_py(py);
let pystring = pyobject.downcast_bound::<PyString>(py).unwrap();
assert_eq!(pystring.to_string_lossy(), obj.as_ref().to_string_lossy());
let roundtripped_obj: OsString = pystring.extract().unwrap();
assert!(obj.as_ref() == roundtripped_obj.as_os_str());
}
let os_str = OsStr::new("Hello\0\nš");
test_roundtrip::<&OsStr>(py, os_str);
test_roundtrip::<OsString>(py, os_str.to_os_string());
test_roundtrip::<&OsString>(py, &os_str.to_os_string());
})
}
}