simplicity/bit_machine/

mod.rs

// SPDX-License-Identifier: CC0-1.0

//! Simplicity Execution
//!
//! Implementation of the Bit Machine, without TCO, as TCO precludes some
//! frame management optimizations which can be used to great benefit.
//!

mod frame;
mod limits;
mod tracker;

use std::error;
use std::fmt;
use std::sync::Arc;

use crate::analysis;
use crate::jet::JetEnvironment;
use crate::jet::{Jet, JetFailed};
use crate::node::{self, RedeemNode};
use crate::types::Final;
use crate::{Cmr, FailEntropy, Value};
use frame::Frame;

pub use self::limits::LimitError;
pub use self::tracker::{
    ExecTracker, NoTracker, NodeOutput, PruneTracker, SetTracker, StderrTracker,
};

/// An iterator over the contents of a read or write frame which yields bits.
pub type FrameIter<'a> = crate::BitIter<core::iter::Copied<core::slice::Iter<'a, u8>>>;

/// An execution context for a Simplicity program
pub struct BitMachine {
    /// Space for bytes that read and write frames point to.
    /// (De)allocation happens LIFO from left to right
    data: Vec<u8>,
    /// Top of data stack; index of first unused bit
    next_frame_start: usize,
    /// Read frame stack
    read: Vec<Frame>,
    /// Write frame stack
    write: Vec<Frame>,
    /// Acceptable source type
    source_ty: Arc<Final>,
}

impl BitMachine {
    /// Construct a Bit Machine with enough space to execute the given program.
    pub fn for_program(program: &RedeemNode) -> Result<Self, LimitError> {
        LimitError::check_program(program)?;
        let io_width = program.arrow().source.bit_width() + program.arrow().target.bit_width();

        Ok(Self {
            data: vec![0; (io_width + program.bounds().extra_cells).div_ceil(8)],
            next_frame_start: 0,
            read: Vec::with_capacity(program.bounds().extra_frames + analysis::IO_EXTRA_FRAMES),
            write: Vec::with_capacity(program.bounds().extra_frames + analysis::IO_EXTRA_FRAMES),
            source_ty: program.arrow().source.clone(),
        })
    }

    #[cfg(test)]
    pub fn test_exec<JE: JetEnvironment>(
        program: Arc<crate::node::ConstructNode>,
        env: &JE,
    ) -> Result<Value, ExecutionError> {
        use crate::node::SimpleFinalizer;

        let prog = program
            .finalize_types_non_program()
            .expect("finalizing types")
            .finalize(&mut SimpleFinalizer::new(None.into_iter()))
            .expect("finalizing");
        let mut mac = BitMachine::for_program(&prog).expect("program has reasonable bounds");
        mac.exec(&prog, env)
    }

    /// Push a new frame of given size onto the write frame stack
    fn new_write_frame(&mut self, len: usize) {
        debug_assert!(
            self.next_frame_start + len <= self.data.len() * 8,
            "Data out of bounds: number of cells"
        );
        debug_assert!(
            self.write.len() + self.read.len() < self.read.capacity(),
            "Stacks out of bounds: number of frames"
        );

        self.write.push(Frame::new(self.next_frame_start, len));
        self.next_frame_start += len;
    }

    /// Move the active write frame to the read frame stack
    fn move_write_frame_to_read(&mut self) {
        let mut _active_write_frame = self.write.pop().unwrap();
        _active_write_frame.reset_cursor();
        self.read.push(_active_write_frame);
    }

    /// Drop the active read frame
    fn drop_read_frame(&mut self) {
        let active_read_frame = self.read.pop().unwrap();
        self.next_frame_start -= active_read_frame.bit_width();
        assert_eq!(self.next_frame_start, active_read_frame.start());
    }

    /// Write a single bit to the active write frame
    fn write_bit(&mut self, bit: bool) {
        self.write
            .last_mut()
            .expect("Empty write frame stack")
            .write_bit(bit, &mut self.data);
    }

    /// Move the cursor of the active write frame forward by
    /// a specified number of bits
    fn skip(&mut self, n: usize) {
        // short circuit n = 0
        if n == 0 {
            return;
        }
        let idx = self.write.len() - 1;
        self.write[idx].move_cursor_forward(n);
    }

    /// Copy the given number of bits from the active read frame
    /// to the active write frame
    fn copy(&mut self, n: usize) {
        // short circuit n = 0
        if n == 0 {
            return;
        }
        let widx = self.write.len() - 1;
        let ridx = self.read.len() - 1;
        self.write[widx].copy_from(&self.read[ridx], n, &mut self.data);
    }

    /// Move the cursor of the active read frame forward
    /// by the given number of bits
    fn fwd(&mut self, n: usize) {
        // short circuit n = 0
        if n == 0 {
            return;
        }
        let idx = self.read.len() - 1;
        self.read[idx].move_cursor_forward(n);
    }

    /// Move the cursor of the active read frame back
    /// by the given number of bits
    fn back(&mut self, n: usize) {
        // short circuit n = 0
        if n == 0 {
            return;
        }
        let idx = self.read.len() - 1;
        self.read[idx].move_cursor_backward(n);
    }

    /// Write a big-endian u8 value to the active write frame
    fn write_u8(&mut self, value: u8) {
        self.write
            .last_mut()
            .expect("Empty write frame stack")
            .write_u8(value, &mut self.data);
    }

    /// Read a bit from the active read frame
    fn read_bit(&mut self) -> bool {
        self.read
            .last_mut()
            .expect("Empty read frame stack")
            .read_bit(&self.data)
    }

    /// Write a bit string to the active write frame
    fn write_bytes(&mut self, bytes: &[u8]) {
        for bit in bytes {
            self.write_u8(*bit);
        }
    }

    /// Write a value to the current write frame
    fn write_value(&mut self, val: &Value) {
        for bit in val.iter_padded() {
            self.write_bit(bit);
        }
    }

    /// Return the bit width of the active read frame.
    fn active_read_bit_width(&self) -> usize {
        self.read.last().map(|frame| frame.bit_width()).unwrap_or(0)
    }

    /// Return the bit width of the active write frame.
    fn active_write_bit_width(&self) -> usize {
        self.write
            .last()
            .map(|frame| frame.bit_width())
            .unwrap_or(0)
    }

    /// Add a read frame with some given value in it, as input to the
    /// program
    pub fn input(&mut self, input: &Value) -> Result<(), ExecutionError> {
        if !input.is_of_type(&self.source_ty) {
            return Err(ExecutionError::InputWrongType(self.source_ty.clone()));
        }
        // Unit value doesn't need extra frame
        if !input.is_empty() {
            self.new_write_frame(input.padded_len());
            self.write_value(input);
            self.move_write_frame_to_read();
        }
        Ok(())
    }

    /// Execute the given `program` on the Bit Machine, using the given environment.
    ///
    ///  ## Precondition
    ///
    /// The Bit Machine is constructed via [`Self::for_program()`] to ensure enough space.
    pub fn exec<JE: JetEnvironment>(
        &mut self,
        program: &RedeemNode,
        env: &JE,
    ) -> Result<Value, ExecutionError> {
        self.exec_with_tracker(program, env, &mut NoTracker)
    }

    /// Execute the given `program` on the Bit Machine, using the given environment and tracker.
    ///
    /// See [`crate::bit_machine::StderrTracker`] as an example which outputs various debug
    /// data for each node, providing a track of the bit machine's operation.
    ///
    ///  ## Precondition
    ///
    /// The Bit Machine is constructed via [`Self::for_program()`] to ensure enough space.
    pub fn exec_with_tracker<JE: JetEnvironment, T: ExecTracker>(
        &mut self,
        program: &RedeemNode,
        env: &JE,
        tracker: &mut T,
    ) -> Result<Value, ExecutionError> {
        enum CallStack<'a> {
            Goto(&'a RedeemNode),
            MoveWriteFrameToRead,
            DropReadFrame,
            CopyFwd(usize),
            Back(usize),
        }

        // Not used, but useful for debugging, so keep it around
        impl fmt::Debug for CallStack<'_> {
            fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
                match self {
                    CallStack::Goto(ins) => write!(f, "goto {}", ins.inner()),
                    CallStack::MoveWriteFrameToRead => f.write_str("move frame"),
                    CallStack::DropReadFrame => f.write_str("drop frame"),
                    CallStack::CopyFwd(n) => write!(f, "copy/fwd {}", n),
                    CallStack::Back(n) => write!(f, "back {}", n),
                }
            }
        }

        if self.read.is_empty() != self.source_ty.is_empty() {
            return Err(ExecutionError::InputWrongType(self.source_ty.clone()));
        }

        let mut ip = program;
        let mut call_stack: Vec<CallStack<'_>> = vec![];

        let output_width = ip.arrow().target.bit_width();
        if output_width > 0 {
            self.new_write_frame(output_width);
        }

        'main_loop: loop {
            // Capture read and write frames before the node action, to give to the tracker.
            // The read frame cursor is where the node's input begins.
            // The write frame cursor is where the node's output begins.
            let input_frame = self.read.last().map(Frame::shallow_copy);
            let output_frame = self.write.last().map(Frame::shallow_copy);
            let mut jet_result = Ok(());

            match ip.inner() {
                node::Inner::Unit => {}
                node::Inner::Iden => {
                    let size_a = ip.arrow().source.bit_width();
                    self.copy(size_a);
                }
                node::Inner::InjL(left) => {
                    let (b, c) = ip.arrow().target.as_sum().unwrap();
                    self.write_bit(false);
                    self.skip(b.pad_left(c));
                    call_stack.push(CallStack::Goto(left));
                }
                node::Inner::InjR(left) => {
                    let (b, c) = ip.arrow().target.as_sum().unwrap();
                    self.write_bit(true);
                    self.skip(b.pad_right(c));
                    call_stack.push(CallStack::Goto(left));
                }
                node::Inner::Pair(left, right) => {
                    call_stack.push(CallStack::Goto(right));
                    call_stack.push(CallStack::Goto(left));
                }
                node::Inner::Comp(left, right) => {
                    let size_b = left.arrow().target.bit_width();

                    self.new_write_frame(size_b);
                    call_stack.push(CallStack::DropReadFrame);
                    call_stack.push(CallStack::Goto(right));
                    call_stack.push(CallStack::MoveWriteFrameToRead);
                    call_stack.push(CallStack::Goto(left));
                }
                node::Inner::Disconnect(left, right) => {
                    let size_prod_256_a = left.arrow().source.bit_width();
                    let size_a = size_prod_256_a - 256;
                    let size_prod_b_c = left.arrow().target.bit_width();
                    let size_b = size_prod_b_c - right.arrow().source.bit_width();

                    self.new_write_frame(size_prod_256_a);
                    self.write_bytes(right.cmr().as_ref());
                    self.copy(size_a);
                    self.move_write_frame_to_read();
                    self.new_write_frame(size_prod_b_c);

                    // Remember that call stack pushes are executed in reverse order
                    call_stack.push(CallStack::DropReadFrame);
                    call_stack.push(CallStack::DropReadFrame);
                    call_stack.push(CallStack::Goto(right));
                    call_stack.push(CallStack::CopyFwd(size_b));
                    call_stack.push(CallStack::MoveWriteFrameToRead);
                    call_stack.push(CallStack::Goto(left));
                }
                node::Inner::Take(left) => call_stack.push(CallStack::Goto(left)),
                node::Inner::Drop(left) => {
                    let size_a = ip.arrow().source.as_product().unwrap().0.bit_width();
                    self.fwd(size_a);
                    call_stack.push(CallStack::Back(size_a));
                    call_stack.push(CallStack::Goto(left));
                }
                node::Inner::Case(..) | node::Inner::AssertL(..) | node::Inner::AssertR(..) => {
                    let in_frame = &self.read[self.read.len() - 1];
                    let choice_bit: bool = in_frame.peek_bit(&self.data);

                    let (sum_a_b, _c) = ip.arrow().source.as_product().unwrap();
                    let (a, b) = sum_a_b.as_sum().unwrap();

                    match (ip.inner(), choice_bit) {
                        (node::Inner::Case(_, right), true)
                        | (node::Inner::AssertR(_, right), true) => {
                            self.fwd(1 + a.pad_right(b));
                            call_stack.push(CallStack::Back(1 + a.pad_right(b)));
                            call_stack.push(CallStack::Goto(right));
                        }
                        (node::Inner::Case(left, _), false)
                        | (node::Inner::AssertL(left, _), false) => {
                            self.fwd(1 + a.pad_left(b));
                            call_stack.push(CallStack::Back(1 + a.pad_left(b)));
                            call_stack.push(CallStack::Goto(left));
                        }
                        (node::Inner::AssertL(_, r_cmr), true) => {
                            return Err(ExecutionError::ReachedPrunedBranch(*r_cmr))
                        }
                        (node::Inner::AssertR(l_cmr, _), false) => {
                            return Err(ExecutionError::ReachedPrunedBranch(*l_cmr))
                        }
                        _ => unreachable!(),
                    }
                }
                node::Inner::Witness(value) => self.write_value(value),
                node::Inner::Jet(jet) => {
                    let typed_jet = jet
                        .as_ref()
                        .as_any()
                        .downcast_ref::<JE::Jet>()
                        .ok_or(ExecutionError::JetTypeMismatch)?;
                    jet_result = self.exec_jet(typed_jet, env);
                }
                node::Inner::Word(value) => self.write_value(value.as_value()),
                node::Inner::Fail(entropy) => {
                    return Err(ExecutionError::ReachedFailNode(*entropy))
                }
            }

            // Notify the tracker.
            {
                // Notice that, because the read frame stack is only ever
                // shortened by `drop_read_frame`, and that method was not
                // called above, this frame is still valid and correctly
                // describes the Bit Machine "input" to the current node,
                // no matter the node.
                let read_iter = input_frame
                    .map(|frame| frame.as_bit_iter_from_cursor(&self.data))
                    .unwrap_or(crate::BitIter::from([].iter().copied()));
                // See the docs on `tracker::NodeOutput` for more information about
                // this match.
                let output = match (ip.inner(), &jet_result) {
                    (node::Inner::Unit | node::Inner::Iden | node::Inner::Witness(_), _)
                    | (node::Inner::Jet(_), Ok(_)) => NodeOutput::Success(
                        output_frame
                            .map(|frame| frame.as_bit_iter_from_cursor(&self.data))
                            .unwrap_or(crate::BitIter::from([].iter().copied())),
                    ),
                    (node::Inner::Jet(_), Err(_)) => NodeOutput::JetFailed,
                    _ => NodeOutput::NonTerminal,
                };
                tracker.visit_node(ip, read_iter, output);
            }
            // Fail if the jet failed.
            jet_result?;

            ip = loop {
                match call_stack.pop() {
                    Some(CallStack::Goto(next)) => break next,
                    Some(CallStack::MoveWriteFrameToRead) => self.move_write_frame_to_read(),
                    Some(CallStack::DropReadFrame) => self.drop_read_frame(),
                    Some(CallStack::CopyFwd(n)) => {
                        self.copy(n);
                        self.fwd(n);
                    }
                    Some(CallStack::Back(n)) => self.back(n),
                    None => break 'main_loop,
                };
            };
        }

        if output_width > 0 {
            let out_frame = self.write.last_mut().unwrap();
            out_frame.reset_cursor();
            let value = Value::from_padded_bits(
                &mut out_frame.as_bit_iter_from_cursor(&self.data),
                &program.arrow().target,
            )
            .expect("Decode value of output frame");

            Ok(value)
        } else {
            Ok(Value::unit())
        }
    }

    fn exec_jet<JE: JetEnvironment>(&mut self, jet: &JE::Jet, env: &JE) -> Result<(), JetFailed> {
        use crate::ffi::c_jets::frame_ffi::{c_readBit, c_writeBit, CFrameItem};
        use crate::ffi::c_jets::uword_width;
        use crate::ffi::ffi::UWORD;

        /// Create new C read frame that contains `bit_width` many bits from active read frame.
        ///
        /// Return C read frame together with underlying buffer.
        ///
        /// ## Safety
        ///
        /// The returned frame must outlive its buffer or there is a dangling pointer.
        ///
        /// ## Panics
        ///
        /// Active read frame has fewer bits than `bit_width`.
        unsafe fn get_input_frame(
            mac: &mut BitMachine,
            bit_width: usize,
        ) -> (CFrameItem, Vec<UWORD>) {
            assert!(bit_width <= mac.active_read_bit_width());
            let uword_width = uword_width(bit_width);
            let mut buffer = vec![0; uword_width];

            // Copy bits from active read frame into input frame
            let buffer_end = buffer.as_mut_ptr().add(uword_width);
            let mut write_frame = CFrameItem::new_write(bit_width, buffer_end);
            for _ in 0..bit_width {
                let bit = mac.read_bit();
                c_writeBit(&mut write_frame, bit);
            }
            mac.back(bit_width);

            // Convert input frame into read frame
            let buffer_ptr = buffer.as_mut_ptr();
            let read_frame = CFrameItem::new_read(bit_width, buffer_ptr);

            (read_frame, buffer)
        }

        /// Create C write frame that is as wide as `bit_width`.
        ///
        /// Return C write frame together with underlying buffer.
        ///
        /// ## Safety
        ///
        /// The returned frame must outlive its buffer or there is a dangling pointer.
        unsafe fn get_output_frame(bit_width: usize) -> (CFrameItem, Vec<UWORD>) {
            let uword_width = uword_width(bit_width);
            let mut buffer = vec![0; uword_width];

            // Return output frame as write frame
            let buffer_end = buffer.as_mut_ptr().add(uword_width);
            let write_frame = CFrameItem::new_write(bit_width, buffer_end);

            (write_frame, buffer)
        }

        /// Write `bit_width` many bits from `buffer` into active write frame.
        ///
        /// ## Panics
        ///
        /// Active write frame has fewer bits than `bit_width`.
        ///
        /// Buffer has fewer than bits than `bit_width` (converted to UWORDs).
        fn update_active_write_frame(mac: &mut BitMachine, bit_width: usize, buffer: &[UWORD]) {
            assert!(bit_width <= mac.active_write_bit_width());
            assert!(uword_width(bit_width) <= buffer.len());
            let buffer_ptr = buffer.as_ptr();
            let mut read_frame = unsafe { CFrameItem::new_read(bit_width, buffer_ptr) };

            for _ in 0..bit_width {
                let bit = unsafe { c_readBit(&mut read_frame) };
                mac.write_bit(bit);
            }
        }

        // Sanity Check: This should never really fail, but still good to do
        if !simplicity_sys::c_jets::sanity_checks() {
            return Err(JetFailed);
        }

        let input_width = jet.source_ty().to_bit_width();
        let output_width = jet.target_ty().to_bit_width();
        // Input buffer is implicitly referenced by input read frame!
        // Same goes for output buffer
        let (input_read_frame, _input_buffer) = unsafe { get_input_frame(self, input_width) };
        let (mut output_write_frame, output_buffer) = unsafe { get_output_frame(output_width) };

        let jet_fn = JE::c_jet_ptr(jet);
        let c_env = env.c_jet_env();
        let success = jet_fn(&mut output_write_frame, input_read_frame, c_env);

        if !success {
            Err(JetFailed)
        } else {
            update_active_write_frame(self, output_width, &output_buffer);
            Ok(())
        }
    }
}

/// Errors related to simplicity Execution
#[derive(Debug)]
pub enum ExecutionError {
    /// Provided input is of wrong type
    InputWrongType(Arc<Final>),
    /// Reached a fail node
    ReachedFailNode(FailEntropy),
    /// Reached a pruned branch
    ReachedPrunedBranch(Cmr),
    /// Exceeded some program limit
    LimitExceeded(LimitError),
    /// Jet failed during execution
    JetFailed(JetFailed),
    /// Jet type mismatch between program and execution environment
    JetTypeMismatch,
}

impl fmt::Display for ExecutionError {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        match self {
            ExecutionError::InputWrongType(expected_ty) => {
                write!(f, "Expected input of type: {expected_ty}")
            }
            ExecutionError::ReachedFailNode(entropy) => {
                write!(f, "Execution reached a fail node: {}", entropy)
            }
            ExecutionError::ReachedPrunedBranch(hash) => {
                write!(f, "Execution reached a pruned branch: {}", hash)
            }
            ExecutionError::LimitExceeded(e) => e.fmt(f),
            ExecutionError::JetFailed(jet_failed) => jet_failed.fmt(f),
            ExecutionError::JetTypeMismatch => {
                f.write_str("Jet type mismatch between program and execution environment")
            }
        }
    }
}

impl error::Error for ExecutionError {
    fn source(&self) -> Option<&(dyn error::Error + 'static)> {
        match self {
            Self::InputWrongType(..)
            | Self::ReachedFailNode(..)
            | Self::ReachedPrunedBranch(..)
            | Self::JetTypeMismatch => None,
            Self::LimitExceeded(ref e) => Some(e),
            Self::JetFailed(ref e) => Some(e),
        }
    }
}

impl From<LimitError> for ExecutionError {
    fn from(e: LimitError) -> Self {
        ExecutionError::LimitExceeded(e)
    }
}

impl From<JetFailed> for ExecutionError {
    fn from(jet_failed: JetFailed) -> Self {
        ExecutionError::JetFailed(jet_failed)
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[cfg(feature = "elements")]
    use crate::jet::elements::ElementsEnv;
    use crate::jet::CoreEnv;
    #[cfg(feature = "elements")]
    use crate::{node::RedeemNode, BitIter};
    #[cfg(feature = "elements")]
    use hex::DisplayHex;

    #[cfg(feature = "elements")]
    fn run_program_elements(
        prog_bytes: &[u8],
        witness_bytes: &[u8],
        cmr_str: &str,
        amr_str: &str,
        ihr_str: &str,
    ) -> Result<Value, ExecutionError> {
        let prog_hex = prog_bytes.as_hex();

        let prog = BitIter::from(prog_bytes);
        let witness = BitIter::from(witness_bytes);
        let prog = match RedeemNode::decode::<_, _, crate::jet::Elements>(prog, witness) {
            Ok(prog) => prog,
            Err(e) => panic!("program {} failed: {}", prog_hex, e),
        };

        // Check Merkle roots; check AMR last because the AMR is a more complicated
        // calculation and historically has been much more likely to be wrong.
        assert_eq!(
            prog.cmr().to_string(),
            cmr_str,
            "CMR mismatch (got {} expected {}) for program {}",
            prog.cmr(),
            cmr_str,
            prog_hex,
        );
        assert_eq!(
            prog.amr().to_string(),
            amr_str,
            "AMR mismatch (got {} expected {}) for program {}",
            prog.amr(),
            amr_str,
            prog_hex,
        );
        assert_eq!(
            prog.ihr().to_string(),
            ihr_str,
            "IHR mismatch (got {} expected {}) for program {}",
            prog.ihr(),
            ihr_str,
            prog_hex,
        );

        // Try to run it on the bit machine and return the result
        let env = ElementsEnv::dummy();
        BitMachine::for_program(&prog)
            .expect("program has reasonable bounds")
            .exec(&prog, &env)
    }

    #[test]
    #[cfg(feature = "human_encoding")]
    fn set_tracker_cursor_regression() {
        // When a `case` node executes inside another `case` or `drop`, the read frame cursor
        // is no longer at the frame's start. Before this fix, `exec_with_tracker` passed an
        // iterator starting at frame.start to the tracker, so `SetTracker` read the wrong bit
        // and recorded the wrong branch, leading to an assertl/assertr mismatch after pruning.
        //
        // Program: comp (pair (injl (injr unit)) unit) (case (case unit unit) unit)
        // Intermediate frame bits: [0=L-tag of outer, 1=R-tag of inner]
        // Outer case: peek bit 0 = 0 (LEFT), fwd(1), cursor moves to bit 1.
        // Inner case: should read bit 1 = 1 (RIGHT).
        // Bug: tracker received iterator from bit 0, read 0 (LEFT) → pruned wrong branch.
        use crate::human_encoding::Forest;
        use crate::types;
        use std::collections::HashMap;

        types::Context::with_context(|ctx| {
            let s = "main := comp (pair (injl (injr unit)) unit) (case (case unit unit) unit)";
            let program = Forest::parse::<crate::jet::Core>(s)
                .expect("parse")
                .to_witness_node(&ctx, &HashMap::new())
                .expect("main root")
                .finalize_pruned(&CoreEnv::new())
                .expect("finalize and prune");
            let mut mac = BitMachine::for_program(&program).expect("for_program");
            mac.exec(&program, &CoreEnv::new())
                .expect("pruned execution should succeed");
        });
    }

    #[test]
    #[cfg(feature = "elements")]
    fn crash_regression1() {
        // cfe18fb44028870400
        // This program caused an array OOB.
        // # Witnesses
        // wit1 = witness :: (((1 + (1 + 2^256)) * (1 + (1 + 2^256))) + 1) -> 1
        //
        // # Program code
        // jt1 = jet_num_outputs    :: 1 -> 2^32                                          # cmr 447165a3...
        // jt2 = jet_issuance_token :: 2^32 -> (1 + (1 + 2^256))                          # cmr 85e9591c...
        // pr3 = pair jt2 jt2       :: 2^32 -> ((1 + (1 + 2^256)) * (1 + (1 + 2^256)))    # cmr 45d40848...
        // cp4 = comp jt1 pr3       :: 1 -> ((1 + (1 + 2^256)) * (1 + (1 + 2^256)))       # cmr 7bb1824f...
        // jl5 = injl cp4           :: 1 -> (((1 + (1 + 2^256)) * (1 + (1 + 2^256))) + 1) # cmr 277ee32c...
        //
        // main = comp jl5 wit1     :: 1 -> 1                                             # cmr 7050c4a6...

        let res = run_program_elements(
            &[0xcf, 0xe1, 0x8f, 0xb4, 0x40, 0x28, 0x87, 0x04, 0x00],
            &[],
            "0075f5368af7b453c2f7318493df12567bc6d733cf1ebb69a08ce93e1e529956",
            "0ac9baaee94e416c6598a271dfc18d6014f751ac300cfe69eb758c20f26c624b",
            "61f2cf59bfec55bb6e44cbae71c3ba225f1059f9a5679c0b42a7177daff52b5a",
        );
        assert_eq!(res.unwrap(), Value::unit());
    }

    #[test]
    fn crash_regression2() {
        use crate::node::{CoreConstructible as _, JetConstructible as _};

        type Node<'brand> = Arc<crate::ConstructNode<'brand>>;

        crate::types::Context::with_context(|ctx| {
            let mut bomb = Node::jet(
                &ctx,
                &crate::jet::Core::Ch8, // arbitrary jet with nonzero output size
            );
            for _ in 0..100 {
                bomb = Node::pair(&bomb, &bomb).unwrap();
            }
            let _ = bomb.finalize_pruned(&CoreEnv::new());
        });
    }
}