test write changes

Author: simonwuelker

markup5ever/input_stream.rs

@@ -11,19 +11,43 @@ use crate::encoding::{Confidence, Decoder};
 /// Internally the `InputStream` keeps track of the current
 /// [insertion point](https://html.spec.whatwg.org/#insertion-point) by using
 /// two seperate buffers.
+///
+/// ### Insertion Points
+/// When `document.write` is called, the following things need to happen:
+/// * The provided string must be inserted at the beginning of the input stream
+/// * The parser must be invoked, but must not consume more than the provded string
+///
+/// Of course the second step may uncover more calls to `document.write`, which need
+/// to be executed immediately.
+///
+/// This can be realized with the [push_insertion_point] and [pop_insertion_point] methods.
 pub struct InputStream {
+    insertion_point_stack: RefCell<Vec<BufferQueue>>,
     input: BufferQueue,
     decoder: RefCell<Decoder>,
 }
 
 impl InputStream {
     fn new(encoding: &'static Encoding) -> Self {
         Self {
+            insertion_point_stack: Default::default(),
             input: Default::default(),
             decoder: RefCell::new(Decoder::new(encoding, Confidence::Tentative)),
         }
     }
 
+    pub fn push_insertion_point(&self) {
+        self.insertion_point_stack.borrow_mut().push(BufferQueue::default());
+    }
+
+    pub fn pop_insertion_point(&self) {
+        let previous_insertion_area = self.insertion_point_stack.borrow_mut().pop().unwrap();
+
+        if !previous_insertion_area.is_empty() {
+            // The parser for the input to document.write got suspended.
+        }
+    }
+
     pub fn append(&self, data: StrTendril) {
         self.input.push_back(data);
     }

markup5ever/util/buffer_queue.rs

@@ -18,7 +18,7 @@
 //!
 //! [`BufferQueue`]: struct.BufferQueue.html
 
-use std::{cell::RefCell, collections::VecDeque, fmt, mem};
+use std::{cell::{RefCell, RefMut}, collections::VecDeque, fmt, mem};
 
 use tendril::{
     fmt::{Bytes, SliceFormat, UTF8},
@@ -128,6 +128,14 @@ where
     pub fn clear(&self) {
         self.buffers.borrow_mut().clear();
     }
+
+    pub fn take(&self) -> Self {
+        let buffers = mem::take(self.buffers.borrow_mut());
+
+        Self {
+            buffers
+        }
+    }
 }
 
 impl BufferQueue {