use glam::{DAffine2, DVec2}; use graph_craft::imaginate_input::{ImaginateMaskStartingFill, ImaginateSamplingMethod, ImaginateStatus}; use graphene_core::ops::{CloneNode, IdNode, TypeNode}; use once_cell::sync::Lazy; use std::collections::HashMap; use graphene_core::raster::color::Color; use graphene_core::raster::*; use graphene_core::structural::Then; use graphene_core::value::{ClonedNode, ForgetNode, ValueNode}; use graphene_core::{Node, NodeIO, NodeIOTypes}; use graphene_std::any::{ComposeTypeErased, DowncastBothNode, DowncastBothRefNode, DynAnyNode, IntoTypeErasedNode}; use graphene_core::{Cow, NodeIdentifier, Type, TypeDescriptor}; use graph_craft::proto::NodeConstructor; use graphene_core::{concrete, generic}; use graphene_std::memo::CacheNode; use crate::executor::NodeContainer; use dyn_any::StaticType; macro_rules! register_node { ($path:ty, input: $input:ty, params: [$($type:ty),*]) => { ( NodeIdentifier::new(stringify!($path)), |args| { let mut args = args.clone(); args.reverse(); let node = <$path>::new($( graphene_std::any::input_node::<$type>( args.pop().expect("not enough arguments provided to construct node") ) ),*); let any: DynAnyNode<$input, _, _> = graphene_std::any::DynAnyNode::new(graphene_core::value::ValueNode::new(node)); Box::pin(any) }, { let node = IdNode::new().into_type_erased(); let node = NodeContainer::new(node, vec![]); let _node = unsafe { node.erase_lifetime().static_ref() }; let node = <$path>::new($( graphene_std::any::input_node::<$type>(_node) ),*); let params = vec![$(concrete!($type)),*]; let mut node_io = <$path as NodeIO<'_, $input>>::to_node_io(&node, params); node_io.input = concrete!(<$input as StaticType>::Static); node_io }, ) }; } macro_rules! raster_node { ($path:ty, params: [$($type:ty),*]) => { ( NodeIdentifier::new(stringify!($path)), |args| { let mut args = args.clone(); args.reverse(); let node = <$path>::new($( graphene_core::value::ClonedNode::new( graphene_std::any::input_node::<$type>( args.pop().expect("Not enough arguments provided to construct node") ).eval(()) ) ),*); let map_node = graphene_std::raster::MapImageNode::new(graphene_core::value::ValueNode::new(node)); let any: DynAnyNode = graphene_std::any::DynAnyNode::new(graphene_core::value::ValueNode::new(map_node)); Box::pin(any) }, { let params = vec![$(concrete!($type)),*]; NodeIOTypes::new(concrete!(Image), concrete!(Image), params) }, ) }; } //TODO: turn into hashmap fn node_registry() -> HashMap> { let node_types: Vec<(NodeIdentifier, NodeConstructor, NodeIOTypes)> = vec![ //register_node!(graphene_core::ops::IdNode, input: Any<'_>, params: []), ( NodeIdentifier::new("graphene_core::ops::IdNode"), |_| IdNode::new().into_type_erased(), NodeIOTypes::new(generic!(I), generic!(I), vec![]), ), // TODO: create macro to impl for all types register_node!(graphene_core::structural::ConsNode<_, _>, input: u32, params: [u32]), register_node!(graphene_core::structural::ConsNode<_, _>, input: u32, params: [&u32]), register_node!(graphene_core::structural::ConsNode<_, _>, input: &u32, params: [u32]), register_node!(graphene_core::structural::ConsNode<_, _>, input: &u32, params: [&u32]), register_node!(graphene_core::ops::AddNode, input: (u32, u32), params: []), register_node!(graphene_core::ops::AddNode, input: (u32, &u32), params: []), register_node!(graphene_core::ops::AddParameterNode<_>, input: u32, params: [u32]), register_node!(graphene_core::ops::AddParameterNode<_>, input: &u32, params: [u32]), register_node!(graphene_core::ops::AddParameterNode<_>, input: u32, params: [&u32]), register_node!(graphene_core::ops::AddParameterNode<_>, input: &u32, params: [&u32]), register_node!(graphene_core::ops::AddParameterNode<_>, input: f64, params: [f64]), register_node!(graphene_core::ops::AddParameterNode<_>, input: &f64, params: [f64]), register_node!(graphene_core::ops::AddParameterNode<_>, input: f64, params: [&f64]), register_node!(graphene_core::ops::AddParameterNode<_>, input: &f64, params: [&f64]), ( NodeIdentifier::new("graphene_core::structural::ComposeNode<_, _, _>"), |args| { let node = ComposeTypeErased::new(args[0], args[1]); node.into_type_erased() }, NodeIOTypes::new(generic!(T), generic!(U), vec![generic!(V), generic!(U)]), ), // Filters raster_node!(graphene_core::raster::LuminanceNode<_>, params: [LuminanceCalculation]), raster_node!(graphene_core::raster::LevelsNode<_, _, _, _, _>, params: [f64, f64, f64, f64, f64]), raster_node!(graphene_core::raster::GrayscaleNode<_, _, _, _, _, _, _>, params: [Color, f64, f64, f64, f64, f64, f64]), raster_node!(graphene_core::raster::HueSaturationNode<_, _, _>, params: [f64, f64, f64]), raster_node!(graphene_core::raster::InvertRGBNode, params: []), raster_node!(graphene_core::raster::ThresholdNode<_, _>, params: [LuminanceCalculation, f64]), raster_node!(graphene_core::raster::VibranceNode<_>, params: [f64]), raster_node!(graphene_core::raster::BrightnessContrastNode< _, _>, params: [f64, f64]), raster_node!(graphene_core::raster::OpacityNode<_>, params: [f64]), raster_node!(graphene_core::raster::PosterizeNode<_>, params: [f64]), raster_node!(graphene_core::raster::ExposureNode<_, _, _>, params: [f64, f64, f64]), ( NodeIdentifier::new("graphene_core::structural::MapImageNode"), |args| { let map_fn: DowncastBothNode = DowncastBothNode::new(args[0]); let node = graphene_std::raster::MapImageNode::new(ValueNode::new(map_fn)); let any: DynAnyNode = graphene_std::any::DynAnyNode::new(graphene_core::value::ValueNode::new(node)); any.into_type_erased() }, NodeIOTypes::new(concrete!(Image), concrete!(Image), vec![]), ), ( NodeIdentifier::new("graphene_std::raster::ImaginateNode<_>"), |args| { let cached = graphene_std::any::input_node::>>(args[16]); let node = graphene_std::raster::ImaginateNode::new(cached); let any = DynAnyNode::new(ValueNode::new(node)); any.into_type_erased() }, NodeIOTypes::new( concrete!(Image), concrete!(Image), vec![ concrete!(DAffine2), concrete!(f64), concrete!(Option), concrete!(f64), concrete!(ImaginateSamplingMethod), concrete!(f64), concrete!(String), concrete!(String), concrete!(bool), concrete!(f64), concrete!(Option>), concrete!(bool), concrete!(f64), concrete!(ImaginateMaskStartingFill), concrete!(bool), concrete!(bool), concrete!(Option>), concrete!(f64), concrete!(ImaginateStatus), ], ), ), ( NodeIdentifier::new("graphene_core::raster::BlurNode"), |args| { let radius = DowncastBothNode::<(), u32>::new(args[0]); let sigma = DowncastBothNode::<(), f64>::new(args[1]); let image = DowncastBothRefNode::::new(args[2]); let empty_image: ValueNode = ValueNode::new(Image::empty()); let empty: TypeNode<_, (), Image> = TypeNode::new(empty_image.then(CloneNode::new())); use graphene_core::Node; let radius = ClonedNode::new(radius.eval(())); let sigma = ClonedNode::new(sigma.eval(())); //let image = &image as &dyn for<'a> Node<'a, (), Output = &'a Image>; // dirty hack: we abuse that the cache node will ignore the input if it is evaluated a second time let image = empty.then(image).then(ImageRefNode::new()); let window = WindowNode::new(radius, image.clone()); let map_gaussian = MapSndNode::new(ValueNode::new(DistanceNode.then(GaussianNode::new(sigma)))); let map_distances = MapNode::new(ValueNode::new(map_gaussian)); let gaussian_iter = window.then(map_distances); let avg = gaussian_iter.then(WeightedAvgNode::new()); let avg: TypeNode<_, u32, Color> = TypeNode::new(avg); let blur_iter = MapNode::new(ValueNode::new(avg)); let pixel_iter = image.clone().then(ImageIndexIterNode::new()); let blur = pixel_iter.then(blur_iter); let collect = CollectNode {}; let vec = blur.then(collect); let new_image = MapImageSliceNode::new(vec); let dimensions = image.then(ImageDimensionsNode::new()); let dimensions: TypeNode<_, (), (u32, u32)> = TypeNode::new(dimensions); let new_image = dimensions.then(new_image); let new_image = ForgetNode::new().then(new_image); let node: DynAnyNode<&Image, _, _> = DynAnyNode::new(ValueNode::new(new_image)); node.into_type_erased() }, NodeIOTypes::new(concrete!(Image), concrete!(Image), vec![concrete!(u32), concrete!(f64)]), ), //register_node!(graphene_std::memo::CacheNode<_>, input: Image, params: []), ( NodeIdentifier::new("graphene_std::memo::CacheNode"), |_| { let node: CacheNode = graphene_std::memo::CacheNode::new(); let any = graphene_std::any::DynAnyRefNode::new(node); any.into_type_erased() }, NodeIOTypes::new(concrete!(Image), concrete!(&Image), vec![]), ), register_node!(graphene_core::structural::ConsNode<_, _>, input: Image, params: [&str]), register_node!(graphene_std::raster::ImageFrameNode<_>, input: Image, params: [DAffine2]), /* (NodeIdentifier::new("graphene_std::raster::ImageNode", &[concrete!("&str")]), |_proto_node, stack| { stack.push_fn(|_nodes| { let image = FnNode::new(|s: &str| graphene_std::raster::image_node::<&str>().eval(s).unwrap()); let node: DynAnyNode<_, &str, _, _> = DynAnyNode::new(image); node.into_type_erased() }) }), (NodeIdentifier::new("graphene_std::raster::ExportImageNode", &[concrete!("&str")]), |proto_node, stack| { stack.push_fn(|nodes| { let pre_node = nodes.get(proto_node.input.unwrap_node() as usize).unwrap(); let image = FnNode::new(|input: (Image, &str)| graphene_std::raster::export_image_node().eval(input).unwrap()); let node: DynAnyNode<_, (Image, &str), _, _> = DynAnyNode::new(image); let node = (pre_node).then(node); node.into_type_erased() }) }), ( NodeIdentifier::new("graphene_core::structural::ConsNode", &[concrete!("Image"), concrete!("&str")]), |proto_node, stack| { let node_id = proto_node.input.unwrap_node() as usize; if let ConstructionArgs::Nodes(cons_node_arg) = proto_node.construction_args { stack.push_fn(move |nodes| { let pre_node = nodes.get(node_id).unwrap(); let cons_node_arg = nodes.get(cons_node_arg[0] as usize).unwrap(); let cons_node = ConsNode::new(DowncastNode::<_, &str>::new(cons_node_arg)); let node: DynAnyNode<_, Image, _, _> = DynAnyNode::new(cons_node); let node = (pre_node).then(node); node.into_type_erased() }) } else { unimplemented!() } }, ), (NodeIdentifier::new("graphene_std::vector::generator_nodes::UnitCircleGenerator", &[]), |_proto_node, stack| { stack.push_fn(|_nodes| DynAnyNode::new(graphene_std::vector::generator_nodes::UnitCircleGenerator).into_type_erased()) }), (NodeIdentifier::new("graphene_std::vector::generator_nodes::UnitSquareGenerator", &[]), |_proto_node, stack| { stack.push_fn(|_nodes| DynAnyNode::new(graphene_std::vector::generator_nodes::UnitSquareGenerator).into_type_erased()) }), (NodeIdentifier::new("graphene_std::vector::generator_nodes::BlitSubpath", &[]), |proto_node, stack| { stack.push_fn(move |nodes| { let ConstructionArgs::Nodes(construction_nodes) = proto_node.construction_args else { unreachable!("BlitSubpath without subpath input") }; let value_node = nodes.get(construction_nodes[0] as usize).unwrap(); let input_node: DowncastBothNode<_, (), Subpath> = DowncastBothNode::new(value_node); let node = DynAnyNode::new(graphene_std::vector::generator_nodes::BlitSubpath::new(input_node)); if let ProtoNodeInput::Node(node_id) = proto_node.input { let pre_node = nodes.get(node_id as usize).unwrap(); (pre_node).then(node).into_type_erased() } else { node.into_type_erased() } }) }), (NodeIdentifier::new("graphene_std::vector::generator_nodes::TransformSubpathNode", &[]), |proto_node, stack| { stack.push_fn(move |nodes| { let ConstructionArgs::Nodes(construction_nodes) = proto_node.construction_args else { unreachable!("TransformSubpathNode without subpath input") }; let translate_node: DowncastBothNode<_, (), DVec2> = DowncastBothNode::new(nodes.get(construction_nodes[0] as usize).unwrap()); let rotate_node: DowncastBothNode<_, (), f64> = DowncastBothNode::new(nodes.get(construction_nodes[1] as usize).unwrap()); let scale_node: DowncastBothNode<_, (), DVec2> = DowncastBothNode::new(nodes.get(construction_nodes[2] as usize).unwrap()); let shear_node: DowncastBothNode<_, (), DVec2> = DowncastBothNode::new(nodes.get(construction_nodes[3] as usize).unwrap()); let node = DynAnyNode::new(graphene_std::vector::generator_nodes::TransformSubpathNode::new(translate_node, rotate_node, scale_node, shear_node)); if let ProtoNodeInput::Node(node_id) = proto_node.input { let pre_node = nodes.get(node_id as usize).unwrap(); (pre_node).then(node).into_type_erased() } else { node.into_type_erased() } }) }), #[cfg(feature = "gpu")] ( NodeIdentifier::new("graphene_std::executor::MapGpuNode", &[concrete!("&TypeErasedNode"), concrete!("Color"), concrete!("Color")]), |proto_node, stack| { if let ConstructionArgs::Nodes(operation_node_id) = proto_node.construction_args { stack.push_fn(move |nodes| { info!("Map image Depending upon id {:?}", operation_node_id); let operation_node = nodes.get(operation_node_id[0] as usize).unwrap(); let input_node: DowncastBothNode<_, (), &graph_craft::document::NodeNetwork> = DowncastBothNode::new(operation_node); let map_node: graphene_std::executor::MapGpuNode<_, Vec, u32, u32> = graphene_std::executor::MapGpuNode::new(input_node); let map_node = DynAnyNode::new(map_node); if let ProtoNodeInput::Node(node_id) = proto_node.input { let pre_node = nodes.get(node_id as usize).unwrap(); (pre_node).then(map_node).into_type_erased() } else { map_node.into_type_erased() } }) } else { unimplemented!() } }, ), #[cfg(feature = "gpu")] ( NodeIdentifier::new("graphene_std::executor::MapGpuSingleImageNode", &[concrete!("&TypeErasedNode")]), |proto_node, stack| { if let ConstructionArgs::Nodes(operation_node_id) = proto_node.construction_args { stack.push_fn(move |nodes| { info!("Map image Depending upon id {:?}", operation_node_id); let operation_node = nodes.get(operation_node_id[0] as usize).unwrap(); let input_node: DowncastBothNode<_, (), String> = DowncastBothNode::new(operation_node); let map_node = graphene_std::executor::MapGpuSingleImageNode(input_node); let map_node = DynAnyNode::new(map_node); if let ProtoNodeInput::Node(node_id) = proto_node.input { let pre_node = nodes.get(node_id as usize).unwrap(); (pre_node).then(map_node).into_type_erased() } else { map_node.into_type_erased() } }) } else { unimplemented!() } }, ), #[cfg(feature = "quantization")] ( NodeIdentifier::new("graphene_std::quantization::GenerateQuantizationNode", &[concrete!("&TypeErasedNode")]), |proto_node, stack| { if let ConstructionArgs::Nodes(operation_node_id) = proto_node.construction_args { stack.push_fn(move |nodes| { info!("Quantization Depending upon id {:?}", operation_node_id); let samples_node = nodes.get(operation_node_id[0] as usize).unwrap(); let index_node = nodes.get(operation_node_id[1] as usize).unwrap(); let samples_node: DowncastBothNode<_, (), u32> = DowncastBothNode::new(samples_node); let index_node: DowncastBothNode<_, (), u32> = DowncastBothNode::new(index_node); let map_node = graphene_std::quantization::GenerateQuantizationNode::new(samples_node, index_node); let map_node = DynAnyNode::new(map_node); if let ProtoNodeInput::Node(node_id) = proto_node.input { let pre_node = nodes.get(node_id as usize).unwrap(); (pre_node).then(map_node).into_type_erased() } else { map_node.into_type_erased() } }) } else { unimplemented!() } }, ), <<<<<<< HEAD */ ]; let mut map: HashMap> = HashMap::new(); for (id, c, types) in node_types { map.entry(id).or_default().insert(types.clone(), c); } map } pub static NODE_REGISTRY: Lazy>> = Lazy::new(|| node_registry()); /* #[cfg(test)] mod protograph_testing { use borrow_stack::BorrowStack; use super::*; #[test] fn add_values() { let stack = FixedSizeStack::new(256); let val_1_protonode = ProtoNode::value(ConstructionArgs::Value(Box::new(2u32))); constrcut_node(val_1_protonode, &stack); let val_2_protonode = ProtoNode::value(ConstructionArgs::Value(Box::new(40u32))); constrcut_node(val_2_protonode, &stack); let cons_protonode = ProtoNode { construction_args: ConstructionArgs::Nodes(vec![1]), input: ProtoNodeInput::Node(0), identifier: NodeIdentifier::new("graphene_core::structural::ConsNode", &[concrete!("u32"), concrete!("u32")]), }; constrcut_node(cons_protonode, &stack); let add_protonode = ProtoNode { construction_args: ConstructionArgs::Nodes(vec![]), input: ProtoNodeInput::Node(2), identifier: NodeIdentifier::new("graphene_core::ops::AddNode", &[concrete!("u32"), concrete!("u32")]), }; constrcut_node(add_protonode, &stack); let result = unsafe { stack.get()[3].eval(Box::new(())) }; let val = *dyn_any::downcast::(result).unwrap(); assert_eq!(val, 42); } #[test] fn grayscale_color() { let stack = FixedSizeStack::new(256); let val_protonode = ProtoNode::value(ConstructionArgs::Value(Box::new(Color::from_rgb8(10, 20, 30)))); constrcut_node(val_protonode, &stack); let grayscale_protonode = ProtoNode { construction_args: ConstructionArgs::Nodes(vec![]), input: ProtoNodeInput::Node(0), identifier: NodeIdentifier::new("graphene_core::raster::GrayscaleColorNode", &[]), }; constrcut_node(grayscale_protonode, &stack); let result = unsafe { stack.get()[1].eval(Box::new(())) }; let val = *dyn_any::downcast::(result).unwrap(); assert_eq!(val, Color::from_rgb8(20, 20, 20)); } #[test] fn load_image() { let stack = FixedSizeStack::new(256); let image_protonode = ProtoNode { construction_args: ConstructionArgs::Nodes(vec![]), input: ProtoNodeInput::None, identifier: NodeIdentifier::new("graphene_std::raster::ImageNode", &[concrete!("&str")]), }; constrcut_node(image_protonode, &stack); let result = unsafe { stack.get()[0].eval(Box::new("../gstd/test-image-1.png")) }; let image = *dyn_any::downcast::(result).unwrap(); assert_eq!(image.height, 240); } #[test] fn grayscale_map_image() { let stack = FixedSizeStack::new(256); let image_protonode = ProtoNode { construction_args: ConstructionArgs::Nodes(vec![]), input: ProtoNodeInput::None, identifier: NodeIdentifier::new("graphene_std::raster::ImageNode", &[concrete!("&str")]), }; constrcut_node(image_protonode, &stack); let grayscale_protonode = ProtoNode { construction_args: ConstructionArgs::Nodes(vec![]), input: ProtoNodeInput::None, identifier: NodeIdentifier::new("graphene_core::raster::GrayscaleColorNode", &[]), }; constrcut_node(grayscale_protonode, &stack); let image_map_protonode = ProtoNode { construction_args: ConstructionArgs::Nodes(vec![1]), input: ProtoNodeInput::Node(0), identifier: NodeIdentifier::new("graphene_std::raster::MapImageNode", &[]), }; constrcut_node(image_map_protonode, &stack); let result = unsafe { stack.get()[2].eval(Box::new("../gstd/test-image-1.png")) }; let image = *dyn_any::downcast::(result).unwrap(); assert!(!image.data.iter().any(|c| c.r() != c.b() || c.b() != c.g())); } } */