Method append

nodedb/src/control/array_sync/op_log.rs:132–168

(&self, op: &ArrayOp)

impl OpLog for OriginOpLog {
    fn append(&self, op: &ArrayOp) -> ArrayResult<()> {
        let key = op_key(&op.header.array, op.header.hlc).ok_or_else(|| ArrayError::InvalidOp {
            detail: format!("array name too long (>255 bytes): '{}'", op.header.array),
        })?;
        let encoded = op_codec::encode_op(op).map_err(|e| ArrayError::InvalidOp {
            detail: format!("op_log append encode: {e}"),
        })?;

        let txn = self.db.begin_write().map_err(|e| ArrayError::InvalidOp {
            detail: format!("op_log append begin_write: {e}"),
        })?;
        {
            let mut table = txn
                .open_table(ARRAY_OP_LOG)
                .map_err(|e| ArrayError::InvalidOp {
                    detail: format!("op_log append open_table: {e}"),
                })?;
            // Idempotent: insert only if the key is absent.
            if table
                .get(key.as_slice())
                .map_err(|e| ArrayError::InvalidOp {
                    detail: format!("op_log append get: {e}"),
                })?
                .is_none()
            {
                table
                    .insert(key.as_slice(), encoded.as_slice())
                    .map_err(|e| ArrayError::InvalidOp {
                        detail: format!("op_log append insert: {e}"),
                    })?;
            }
        }
        txn.commit().map_err(|e| ArrayError::InvalidOp {
            detail: format!("op_log append commit: {e}"),
        })?;
        Ok(())
    }

    fn scan_from<'a>(&'a self, from: Hlc) -> ArrayResult<OpIter<'a>> {
        let txn = self.db.begin_read().map_err(|e| ArrayError::InvalidOp {