use bumpalo::Bump;
use fxhash::{FxHashMap, FxHashSet};
use generational_arena::Index;
use crate::{
changelist::{CbIdx, Edit, EditList, EditMachine},
innerlude::{Attribute, Listener, Scope, VElement, VNode, VText},
virtual_dom::LifecycleEvent,
};
use std::cmp::Ordering;
pub struct DiffMachine<'a> {
pub change_list: EditMachine<'a>,
immediate_queue: Vec<Index>,
diffed: FxHashSet<Index>,
need_to_diff: FxHashSet<Index>,
current_idx: Option<generational_arena::Index>,
}
impl<'a> DiffMachine<'a> {
pub fn new(bump: &'a Bump) -> Self {
Self {
change_list: EditMachine::new(bump),
immediate_queue: Vec::new(),
diffed: FxHashSet::default(),
need_to_diff: FxHashSet::default(),
current_idx: None,
}
}
pub fn consume(self) -> EditList<'a> {
self.change_list.emitter
}
pub fn diff_node(
&mut self,
old: &VNode<'a>,
new: &VNode<'a>,
scope: Option<generational_arena::Index>,
) {
log::debug!("old {:#?}", old);
log::debug!("new {:#?}", new);
self.current_idx = scope;
match (old, new) {
(VNode::Text(VText { text: old_text }), VNode::Text(VText { text: new_text })) => {
if old_text != new_text {
self.change_list.commit_traversal();
self.change_list.set_text(new_text);
}
}
(VNode::Text(_), VNode::Element(_)) => {
self.change_list.commit_traversal();
self.create(new);
self.change_list.replace_with();
}
(VNode::Element(_), VNode::Text(_)) => {
self.change_list.commit_traversal();
self.create(new);
self.change_list.replace_with();
}
(VNode::Element(eold), VNode::Element(enew)) => {
if enew.tag_name != eold.tag_name || enew.namespace != eold.namespace {
self.change_list.commit_traversal();
self.change_list.replace_with();
return;
}
self.diff_listeners(eold.listeners, enew.listeners);
self.diff_attr(eold.attributes, enew.attributes, enew.namespace.is_some());
self.diff_children(eold.children, enew.children);
}
(VNode::Component(_), VNode::Component(_)) => {
todo!("Usage of component VNode not currently supported");
}
(_, VNode::Component(_)) => {
todo!("Usage of component VNode not currently supported");
}
(VNode::Component(_), _) => {
todo!("Usage of component VNode not currently supported");
}
(VNode::Suspended, _) | (_, VNode::Suspended) => {
todo!("Suspended components not currently available")
}
}
self.current_idx = None;
}
fn diff_listeners(&mut self, old: &[Listener<'a>], new: &[Listener<'a>]) {
if !old.is_empty() || !new.is_empty() {
self.change_list.commit_traversal();
}
'outer1: for (l_idx, new_l) in new.iter().enumerate() {
let event_type = new_l.event;
for old_l in old {
if new_l.event == old_l.event {
if let Some(scope) = self.current_idx {
let cb = CbIdx::from_gi_index(scope, l_idx);
self.change_list.update_event_listener(event_type, cb);
}
continue 'outer1;
}
}
if let Some(scope) = self.current_idx {
let cb = CbIdx::from_gi_index(scope, l_idx);
self.change_list.new_event_listener(event_type, cb);
}
}
'outer2: for old_l in old {
for new_l in new {
if new_l.event == old_l.event {
continue 'outer2;
}
}
self.change_list.remove_event_listener(old_l.event);
}
}
fn diff_attr(
&mut self,
old: &'a [Attribute<'a>],
new: &'a [Attribute<'a>],
is_namespaced: bool,
) {
'outer: for new_attr in new {
if new_attr.is_volatile() {
self.change_list.commit_traversal();
self.change_list
.set_attribute(new_attr.name, new_attr.value, is_namespaced);
} else {
for old_attr in old {
if old_attr.name == new_attr.name {
if old_attr.value != new_attr.value {
self.change_list.commit_traversal();
self.change_list.set_attribute(
new_attr.name,
new_attr.value,
is_namespaced,
);
}
continue 'outer;
}
}
self.change_list.commit_traversal();
self.change_list
.set_attribute(new_attr.name, new_attr.value, is_namespaced);
}
}
'outer2: for old_attr in old {
for new_attr in new {
if old_attr.name == new_attr.name {
continue 'outer2;
}
}
self.change_list.commit_traversal();
self.change_list.remove_attribute(old_attr.name);
}
}
fn diff_children(&mut self, old: &'a [VNode<'a>], new: &'a [VNode<'a>]) {
if new.is_empty() {
if !old.is_empty() {
self.change_list.commit_traversal();
self.remove_all_children(old);
}
return;
}
if new.len() == 1 {
match (old.first(), &new[0]) {
(
Some(&VNode::Text(VText { text: old_text })),
&VNode::Text(VText { text: new_text }),
) if old_text == new_text => {
}
(_, &VNode::Text(VText { text })) => {
self.change_list.commit_traversal();
self.change_list.set_text(text);
return;
}
(_, _) => {}
}
}
if old.is_empty() {
if !new.is_empty() {
self.change_list.commit_traversal();
self.create_and_append_children(new);
}
return;
}
let new_is_keyed = new[0].key().is_some();
let old_is_keyed = old[0].key().is_some();
debug_assert!(
new.iter().all(|n| n.key().is_some() == new_is_keyed),
"all siblings must be keyed or all siblings must be non-keyed"
);
debug_assert!(
old.iter().all(|o| o.key().is_some() == old_is_keyed),
"all siblings must be keyed or all siblings must be non-keyed"
);
if new_is_keyed && old_is_keyed {
let t = self.change_list.next_temporary();
self.change_list.set_next_temporary(t);
} else {
self.diff_non_keyed_children(old, new);
}
}
fn diff_keyed_children(&mut self, old: &[VNode<'a>], new: &[VNode<'a>]) {
if cfg!(debug_assertions) {
let mut keys = fxhash::FxHashSet::default();
let mut assert_unique_keys = |children: &[VNode]| {
keys.clear();
for child in children {
let key = child.key();
debug_assert!(
key.is_some(),
"if any sibling is keyed, all siblings must be keyed"
);
keys.insert(key);
}
debug_assert_eq!(
children.len(),
keys.len(),
"keyed siblings must each have a unique key"
);
};
assert_unique_keys(old);
assert_unique_keys(new);
}
let shared_prefix_count = match self.diff_keyed_prefix(old, new) {
KeyedPrefixResult::Finished => return,
KeyedPrefixResult::MoreWorkToDo(count) => count,
};
match self.diff_keyed_prefix(old, new) {
KeyedPrefixResult::Finished => return,
KeyedPrefixResult::MoreWorkToDo(count) => count,
};
let shared_suffix_count = old[shared_prefix_count..]
.iter()
.rev()
.zip(new[shared_prefix_count..].iter().rev())
.take_while(|&(old, new)| old.key() == new.key())
.count();
let old_shared_suffix_start = old.len() - shared_suffix_count;
let new_shared_suffix_start = new.len() - shared_suffix_count;
self.diff_keyed_middle(
&old[shared_prefix_count..old_shared_suffix_start],
&new[shared_prefix_count..new_shared_suffix_start],
shared_prefix_count,
shared_suffix_count,
old_shared_suffix_start,
);
let old_suffix = &old[old_shared_suffix_start..];
let new_suffix = &new[new_shared_suffix_start..];
debug_assert_eq!(old_suffix.len(), new_suffix.len());
if !old_suffix.is_empty() {
self.diff_keyed_suffix(old_suffix, new_suffix, new_shared_suffix_start)
}
}
fn diff_keyed_prefix(&mut self, old: &[VNode<'a>], new: &[VNode<'a>]) -> KeyedPrefixResult {
self.change_list.go_down();
let mut shared_prefix_count = 0;
for (i, (old, new)) in old.iter().zip(new.iter()).enumerate() {
if old.key() != new.key() {
break;
}
self.change_list.go_to_sibling(i);
self.diff_node(old, new, self.current_idx);
shared_prefix_count += 1;
}
if shared_prefix_count == old.len() {
self.change_list.go_up();
self.change_list.commit_traversal();
self.create_and_append_children(&new[shared_prefix_count..]);
return KeyedPrefixResult::Finished;
}
if shared_prefix_count == new.len() {
self.change_list.go_to_sibling(shared_prefix_count);
self.change_list.commit_traversal();
self.remove_self_and_next_siblings(&old[shared_prefix_count..]);
return KeyedPrefixResult::Finished;
}
self.change_list.go_up();
KeyedPrefixResult::MoreWorkToDo(shared_prefix_count)
}
fn diff_keyed_middle(
&mut self,
old: &[VNode<'a>],
mut new: &[VNode<'a>],
shared_prefix_count: usize,
shared_suffix_count: usize,
old_shared_suffix_start: usize,
) {
debug_assert_ne!(new.first().map(|n| n.key()), old.first().map(|o| o.key()));
debug_assert_ne!(new.last().map(|n| n.key()), old.last().map(|o| o.key()));
debug_assert!(new.len() < u32::MAX as usize);
let mut old_key_to_old_index = FxHashMap::default();
old_key_to_old_index.reserve(old.len());
old_key_to_old_index.extend(old.iter().enumerate().map(|(i, o)| (o.key(), i)));
let mut shared_keys = FxHashSet::default();
let mut new_index_to_old_index = Vec::with_capacity(new.len());
new_index_to_old_index.extend(new.iter().map(|n| {
let key = n.key();
if let Some(&i) = old_key_to_old_index.get(&key) {
shared_keys.insert(key);
i
} else {
u32::MAX as usize
}
}));
if shared_suffix_count == 0 && shared_keys.is_empty() {
if shared_prefix_count == 0 {
self.change_list.commit_traversal();
self.remove_all_children(old);
} else {
self.change_list.go_down_to_child(shared_prefix_count);
self.change_list.commit_traversal();
self.remove_self_and_next_siblings(&old[shared_prefix_count..]);
}
self.create_and_append_children(new);
return;
}
let mut old_index_to_temp = vec![u32::MAX; old.len()];
let mut start = 0;
loop {
let end = (start..old.len())
.find(|&i| {
let key = old[i].key();
!shared_keys.contains(&key)
})
.unwrap_or(old.len());
if end - start > 0 {
self.change_list.commit_traversal();
let mut t = self.change_list.save_children_to_temporaries(
shared_prefix_count + start,
shared_prefix_count + end,
);
for i in start..end {
old_index_to_temp[i] = t;
t += 1;
}
}
debug_assert!(end <= old.len());
if end == old.len() {
break;
} else {
start = end + 1;
}
}
let mut removed_count = 0;
for (i, old_child) in old.iter().enumerate().rev() {
if !shared_keys.contains(&old_child.key()) {
self.change_list.commit_traversal();
self.change_list.remove_child(i + shared_prefix_count);
removed_count += 1;
}
}
if new.is_empty() {
return;
}
let mut new_index_is_in_lis = FxHashSet::default();
new_index_is_in_lis.reserve(new_index_to_old_index.len());
let mut predecessors = vec![0; new_index_to_old_index.len()];
let mut starts = vec![0; new_index_to_old_index.len()];
longest_increasing_subsequence::lis_with(
&new_index_to_old_index,
&mut new_index_is_in_lis,
|a, b| a < b,
&mut predecessors,
&mut starts,
);
if shared_suffix_count > 0 {
self.change_list
.go_down_to_child(old_shared_suffix_start - removed_count);
} else {
let last_index = new.len() - 1;
let last = new.last().unwrap();
new = &new[..new.len() - 1];
if shared_keys.contains(&last.key()) {
let old_index = new_index_to_old_index[last_index];
let temp = old_index_to_temp[old_index];
self.change_list.go_down_to_temp_child(temp);
self.diff_node(&old[old_index], last, self.current_idx);
if new_index_is_in_lis.contains(&last_index) {
} else {
self.change_list.commit_traversal();
self.change_list.append_child();
self.change_list.go_down_to_temp_child(temp);
}
} else {
self.change_list.commit_traversal();
self.create(last);
self.change_list.append_child();
self.change_list.go_down_to_reverse_child(0);
}
}
for (new_index, new_child) in new.iter().enumerate().rev() {
let old_index = new_index_to_old_index[new_index];
if old_index == u32::MAX as usize {
debug_assert!(!shared_keys.contains(&new_child.key()));
self.change_list.commit_traversal();
self.create(new_child);
self.change_list.insert_before();
} else {
debug_assert!(shared_keys.contains(&new_child.key()));
let temp = old_index_to_temp[old_index];
debug_assert_ne!(temp, u32::MAX);
if new_index_is_in_lis.contains(&new_index) {
self.change_list.go_to_temp_sibling(temp);
} else {
self.change_list.commit_traversal();
self.change_list.push_temporary(temp);
self.change_list.insert_before();
}
self.diff_node(&old[old_index], new_child, self.current_idx);
}
}
self.change_list.go_up();
}
fn diff_keyed_suffix(
&mut self,
old: &[VNode<'a>],
new: &[VNode<'a>],
new_shared_suffix_start: usize,
) {
debug_assert_eq!(old.len(), new.len());
debug_assert!(!old.is_empty());
self.change_list.go_down();
for (i, (old_child, new_child)) in old.iter().zip(new.iter()).enumerate() {
self.change_list.go_to_sibling(new_shared_suffix_start + i);
self.diff_node(old_child, new_child, self.current_idx);
}
self.change_list.go_up();
}
fn diff_non_keyed_children(&mut self, old: &'a [VNode<'a>], new: &'a [VNode<'a>]) {
debug_assert!(!new.is_empty());
debug_assert!(!old.is_empty());
self.change_list.go_down();
for (i, (new_child, old_child)) in new.iter().zip(old.iter()).enumerate() {
self.change_list.go_to_sibling(i);
self.diff_node(old_child, new_child, self.current_idx);
}
match old.len().cmp(&new.len()) {
Ordering::Greater => {
self.change_list.go_to_sibling(new.len());
self.change_list.commit_traversal();
self.remove_self_and_next_siblings(&old[new.len()..]);
}
Ordering::Less => {
self.change_list.go_up();
self.change_list.commit_traversal();
self.create_and_append_children(&new[old.len()..]);
}
Ordering::Equal => {
self.change_list.go_up();
}
}
}
fn create(&mut self, node: &VNode<'a>) {
debug_assert!(self.change_list.traversal_is_committed());
match node {
VNode::Text(VText { text }) => {
self.change_list.create_text_node(text);
}
VNode::Element(&VElement {
key: _,
tag_name,
listeners,
attributes,
children,
namespace,
}) => {
if let Some(namespace) = namespace {
self.change_list.create_element_ns(tag_name, namespace);
} else {
self.change_list.create_element(tag_name);
}
listeners.iter().enumerate().for_each(|(id, listener)| {
if let Some(index) = self.current_idx {
self.change_list
.new_event_listener(listener.event, CbIdx::from_gi_index(index, id));
} else {
log::trace!("Failed to set listener, create was not called in the context of the virtual dom");
}
});
for attr in attributes {
self.change_list
.set_attribute(&attr.name, &attr.value, namespace.is_some());
}
if children.len() == 1 {
if let VNode::Text(VText { text }) = children[0] {
self.change_list.set_text(text);
return;
}
}
for child in children {
self.create(child);
self.change_list.append_child();
}
}
VNode::Suspended => {
todo!("Creation of VNode::Suspended not yet supported")
}
VNode::Component(_) => {
todo!("Creation of VNode::Component not yet supported")
}
}
}
pub fn remove_all_children(&mut self, old: &[VNode<'a>]) {
debug_assert!(self.change_list.traversal_is_committed());
for _child in old {
}
self.change_list.set_text("");
}
pub fn create_and_append_children(&mut self, new: &[VNode<'a>]) {
debug_assert!(self.change_list.traversal_is_committed());
for child in new {
self.create(child);
self.change_list.append_child();
}
}
pub fn remove_self_and_next_siblings(&mut self, old: &[VNode<'a>]) {
debug_assert!(self.change_list.traversal_is_committed());
for _child in old {
}
self.change_list.remove_self_and_next_siblings();
}
}
enum KeyedPrefixResult {
Finished,
MoreWorkToDo(usize),
}
mod support {
}