feat(spatial): basic interface
This commit is contained in:
@@ -1,4 +1,5 @@
|
|||||||
use super::scenegraph::Scenegraph;
|
use super::scenegraph::Scenegraph;
|
||||||
|
use crate::nodes::spatial;
|
||||||
use libstardustxr::messenger::Messenger;
|
use libstardustxr::messenger::Messenger;
|
||||||
use mio::net::UnixStream;
|
use mio::net::UnixStream;
|
||||||
use rccell::{RcCell, WeakCell};
|
use rccell::{RcCell, WeakCell};
|
||||||
@@ -6,7 +7,7 @@ use rccell::{RcCell, WeakCell};
|
|||||||
pub struct Client<'a> {
|
pub struct Client<'a> {
|
||||||
weak_ref: WeakCell<Client<'a>>,
|
weak_ref: WeakCell<Client<'a>>,
|
||||||
messenger: Messenger<'a>,
|
messenger: Messenger<'a>,
|
||||||
scenegraph: Option<Scenegraph<'a>>,
|
scenegraph: Scenegraph<'a>,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl<'a> Client<'a> {
|
impl<'a> Client<'a> {
|
||||||
@@ -16,20 +17,22 @@ impl<'a> Client<'a> {
|
|||||||
scenegraph: Default::default(),
|
scenegraph: Default::default(),
|
||||||
messenger: Messenger::new(connection),
|
messenger: Messenger::new(connection),
|
||||||
});
|
});
|
||||||
|
client.borrow_mut().scenegraph.set_client(client.clone());
|
||||||
client.borrow_mut().weak_ref = client.downgrade();
|
client.borrow_mut().weak_ref = client.downgrade();
|
||||||
|
spatial::create_interface(client.clone());
|
||||||
client
|
client
|
||||||
}
|
}
|
||||||
pub fn dispatch(&self) -> Result<(), std::io::Error> {
|
pub fn dispatch(&self) -> Result<(), std::io::Error> {
|
||||||
self.messenger.dispatch(self.scenegraph.as_ref().unwrap())
|
self.messenger.dispatch(&self.scenegraph)
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn get_messenger(&self) -> &Messenger<'a> {
|
pub fn get_messenger(&self) -> &Messenger<'a> {
|
||||||
&self.messenger
|
&self.messenger
|
||||||
}
|
}
|
||||||
pub fn get_scenegraph(&self) -> &Scenegraph<'a> {
|
pub fn get_scenegraph(&self) -> &Scenegraph<'a> {
|
||||||
self.scenegraph.as_ref().unwrap()
|
&self.scenegraph
|
||||||
}
|
}
|
||||||
pub fn get_scenegraph_mut(&mut self) -> &mut Scenegraph<'a> {
|
pub fn get_scenegraph_mut(&mut self) -> &mut Scenegraph<'a> {
|
||||||
self.scenegraph.as_mut().unwrap()
|
&mut self.scenegraph
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -11,6 +11,19 @@ pub struct Scenegraph<'a> {
|
|||||||
pub nodes: HashMap<String, RcCell<Node<'a>>>,
|
pub nodes: HashMap<String, RcCell<Node<'a>>>,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
impl<'a> Scenegraph<'a> {
|
||||||
|
pub fn set_client(&mut self, client: RcCell<Client<'a>>) {
|
||||||
|
self.client = client.downgrade();
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn add_node(&mut self, node: Node<'a>) -> RcCell<Node<'a>> {
|
||||||
|
let path = node.get_path().to_string();
|
||||||
|
let node_rc = RcCell::new(node);
|
||||||
|
self.nodes.insert(path, node_rc.clone());
|
||||||
|
node_rc
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
impl<'a> Default for Scenegraph<'a> {
|
impl<'a> Default for Scenegraph<'a> {
|
||||||
fn default() -> Self {
|
fn default() -> Self {
|
||||||
Scenegraph {
|
Scenegraph {
|
||||||
|
|||||||
@@ -29,23 +29,24 @@ impl<'a> Node<'a> {
|
|||||||
self.path.as_str()
|
self.path.as_str()
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn from_path(
|
pub fn create(
|
||||||
client: WeakCell<Client<'a>>,
|
client: WeakCell<Client<'a>>,
|
||||||
path: &str,
|
parent: &str,
|
||||||
|
name: &str,
|
||||||
destroyable: bool,
|
destroyable: bool,
|
||||||
) -> Result<Node<'a>> {
|
) -> Self {
|
||||||
ensure!(path.starts_with('/'), "Invalid path {}", path);
|
let mut path = parent.to_string();
|
||||||
Ok(Node {
|
path.push('/');
|
||||||
|
path.push_str(name);
|
||||||
|
Node {
|
||||||
client,
|
client,
|
||||||
path: path.to_string(),
|
path: path,
|
||||||
trailing_slash_pos: path
|
trailing_slash_pos: parent.len(),
|
||||||
.rfind('/')
|
|
||||||
.ok_or_else(|| anyhow!("Invalid path {}", path))?,
|
|
||||||
local_signals: HashMap::new(),
|
local_signals: HashMap::new(),
|
||||||
local_methods: HashMap::new(),
|
local_methods: HashMap::new(),
|
||||||
destroyable,
|
destroyable,
|
||||||
spatial: None,
|
spatial: None,
|
||||||
})
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn add_local_signal(&mut self, method: &str, signal: Signal<'a>) {
|
pub fn add_local_signal(&mut self, method: &str, signal: Signal<'a>) {
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
use super::core::Node;
|
use super::core::Node;
|
||||||
use crate::core::client::Client;
|
use crate::core::client::Client;
|
||||||
use anyhow::{anyhow, ensure, Result};
|
use anyhow::{anyhow, bail, ensure, Result};
|
||||||
use glam::{Mat4, Quat, Vec3};
|
use glam::{Mat4, Quat, Vec3};
|
||||||
use libstardustxr::{flex_to_quat, flex_to_vec3};
|
use libstardustxr::{flex_to_quat, flex_to_vec3};
|
||||||
use rccell::{RcCell, WeakCell};
|
use rccell::{RcCell, WeakCell};
|
||||||
@@ -12,10 +12,17 @@ pub struct Spatial<'a> {
|
|||||||
}
|
}
|
||||||
|
|
||||||
impl<'a> Spatial<'a> {
|
impl<'a> Spatial<'a> {
|
||||||
pub fn new(node: RcCell<Node<'a>>, transform: Mat4) -> Self {
|
pub fn add_to(
|
||||||
|
node: RcCell<Node<'a>>,
|
||||||
|
parent: WeakCell<Node<'a>>,
|
||||||
|
transform: Mat4,
|
||||||
|
) -> Result<()> {
|
||||||
|
if node.borrow_mut().spatial.is_none() {
|
||||||
|
bail!("Node already has a Spatial aspect!");
|
||||||
|
}
|
||||||
let spatial = Spatial {
|
let spatial = Spatial {
|
||||||
node: node.downgrade(),
|
node: node.downgrade(),
|
||||||
parent: WeakCell::new(),
|
parent,
|
||||||
transform,
|
transform,
|
||||||
};
|
};
|
||||||
let node_captured = node.clone();
|
let node_captured = node.clone();
|
||||||
@@ -24,7 +31,6 @@ impl<'a> Spatial<'a> {
|
|||||||
Box::new(move |calling_client, data| {
|
Box::new(move |calling_client, data| {
|
||||||
let root = flexbuffers::Reader::get_root(data)?;
|
let root = flexbuffers::Reader::get_root(data)?;
|
||||||
let flex_vec = root.get_vector()?;
|
let flex_vec = root.get_vector()?;
|
||||||
// let node = node.
|
|
||||||
let client = node_captured
|
let client = node_captured
|
||||||
.borrow()
|
.borrow()
|
||||||
.get_client()
|
.get_client()
|
||||||
@@ -52,7 +58,8 @@ impl<'a> Spatial<'a> {
|
|||||||
Ok(())
|
Ok(())
|
||||||
}),
|
}),
|
||||||
);
|
);
|
||||||
spatial
|
node.borrow_mut().spatial = Some(spatial);
|
||||||
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn local_transform(&self) -> Mat4 {
|
pub fn local_transform(&self) -> Mat4 {
|
||||||
@@ -80,3 +87,34 @@ impl<'a> Spatial<'a> {
|
|||||||
|
|
||||||
// pub fn relative_transform(&self, space: WeakCell<Spatial>) {}
|
// pub fn relative_transform(&self, space: WeakCell<Spatial>) {}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub fn create_interface(client: RcCell<Client>) {
|
||||||
|
let mut node = Node::create(client.downgrade(), "", "spatial", false);
|
||||||
|
node.add_local_signal(
|
||||||
|
"createSpatial",
|
||||||
|
Box::new(move |calling_client, data| {
|
||||||
|
let root = flexbuffers::Reader::get_root(data)?;
|
||||||
|
let flex_vec = root.get_vector()?;
|
||||||
|
let node = Node::create(
|
||||||
|
calling_client.downgrade(),
|
||||||
|
"/spatial",
|
||||||
|
flex_vec.idx(0).get_str()?,
|
||||||
|
true,
|
||||||
|
);
|
||||||
|
let pos = flex_to_vec3!(flex_vec.idx(2)).ok_or(anyhow!("Position not found"))?;
|
||||||
|
let rot = flex_to_quat!(flex_vec.idx(3)).ok_or(anyhow!("Rotation not found"))?;
|
||||||
|
let scl = flex_to_vec3!(flex_vec.idx(4)).ok_or(anyhow!("Scale not found"))?;
|
||||||
|
let node_rc = calling_client
|
||||||
|
.borrow_mut()
|
||||||
|
.get_scenegraph_mut()
|
||||||
|
.add_node(node);
|
||||||
|
Spatial::add_to(
|
||||||
|
node_rc,
|
||||||
|
WeakCell::new(),
|
||||||
|
Mat4::from_scale_rotation_translation(scl.into(), rot.into(), pos.into()),
|
||||||
|
)?;
|
||||||
|
Ok(())
|
||||||
|
}),
|
||||||
|
);
|
||||||
|
client.borrow_mut().get_scenegraph_mut().add_node(node);
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user