Export events in readonly endpoints

CHANGELOG.md

@@ -10,6 +10,7 @@ and this project adheres to the versioning scheme outlined in the [README.md](RE
 ### Added
 
 - In the `/v3/transaction/{txid}` RPC endpoint, added `block_height` and `is_canonical` to the response.
+- Added the `events` array to readonly endpoints output.
 
 ## [3.3.0.0.2]
 

clarity/src/vm/contexts.rs

@@ -1124,6 +1124,16 @@
         &self.global_context.epoch_id
     }
 
+    pub fn execute_contract_with_events(
+        &mut self,
+        contract: &QualifiedContractIdentifier,
+        tx_name: &str,
+        args: &[SymbolicExpression],
+        read_only: bool,
+    ) -> Result<(Value, Vec<StacksTransactionEvent>), VmExecutionError> {
+        self.inner_execute_contract(contract, tx_name, args, read_only, false)
+    }
+
     pub fn execute_contract(
         &mut self,
         contract: &QualifiedContractIdentifier,
@@ -1132,6 +1142,7 @@
         read_only: bool,
     ) -> Result<Value, VmExecutionError> {
         self.inner_execute_contract(contract, tx_name, args, read_only, false)
+            .map(|(value, _)| value)
     }
 
     /// This method is exposed for callers that need to invoke a private method directly.
@@ -1145,6 +1156,7 @@
         read_only: bool,
     ) -> Result<Value, VmExecutionError> {
         self.inner_execute_contract(contract, tx_name, args, read_only, true)
+            .map(|(value, _)| value)
     }
 
     /// This method handles actual execution of contract-calls on a contract.
@@ -1160,7 +1172,7 @@
         args: &[SymbolicExpression],
         read_only: bool,
         allow_private: bool,
-    ) -> Result<Value, VmExecutionError> {
+    ) -> Result<(Value, Vec<StacksTransactionEvent>), VmExecutionError> {
         let contract_size = self
             .global_context
             .database
@@ -1208,11 +1220,11 @@
                 return Err(CheckErrorKind::CircularReference(vec![func_identifier.to_string()]).into())
             }
             self.call_stack.insert(&func_identifier, true);
-            let res = self.execute_function_as_transaction(&func, &args, Some(&contract.contract_context), allow_private);
+            let res = self.execute_function_as_transaction_and_events(&func, &args, Some(&contract.contract_context), allow_private);
             self.call_stack.remove(&func_identifier, true)?;
 
             match res {
-                Ok(value) => {
+                Ok((value, events)) => {
                     if let Some(handler) = self.global_context.database.get_cc_special_cases_handler() {
                         handler(
                             self.global_context,
@@ -1224,7 +1236,7 @@
                             &value
                         )?;
                     }
-                    Ok(value)
+                    Ok((value, events))
                 },
                 Err(e) => Err(e)
             }
@@ -1238,6 +1250,23 @@
         next_contract_context: Option<&ContractContext>,
         allow_private: bool,
     ) -> Result<Value, VmExecutionError> {
+        let (value, _events) = self.execute_function_as_transaction_and_events(
+            function,
+            args,
+            next_contract_context,
+            allow_private,
+        )?;
+
+        Ok(value)
+    }
+
+    pub fn execute_function_as_transaction_and_events(
+        &mut self,
+        function: &DefinedFunction,
+        args: &[Value],
+        next_contract_context: Option<&ContractContext>,
+        allow_private: bool,
+    ) -> Result<(Value, Vec<StacksTransactionEvent>), VmExecutionError> {
         let make_read_only = function.is_read_only();
 
         if make_read_only {
@@ -1261,11 +1290,25 @@
             function.execute_apply(args, &mut nested_env)
         };
 
-        if make_read_only {
+        // retrieve all the events
+        let mut events = vec![];
+        self.global_context
+            .event_batches
+            .iter()
+            .for_each(|event_batch| {
+                events.extend(event_batch.events.clone());
+            });
+
+        let result = if make_read_only {
             self.global_context.roll_back()?;
             result
         } else {
             self.global_context.handle_tx_result(result, allow_private)
+        };
+
+        match result {
+            Ok(result) => Ok((result, events)),
+            Err(e) => Err(e),
         }
     }
 

docs/rpc/components/schemas/read-only-function-result.schema.yaml

@@ -24,3 +24,18 @@ oneOf:
       cause:
         type: string
         description: A string representing the cause of the error.
+      events:
+        type: array
+        description: Contract events generated by the call
+        items:
+          type: object
+          properties:
+            sender:
+              type: string
+              description: The contract address generating the event.
+            key:
+              type: string
+              description: Who generated the event (generally "print").
+            value:
+              type: string
+              description: Hex-encoded Clarity value of the event.