feat: move authenticator

Author: miker83z

Cargo.lock

@@ -11,7 +11,7 @@ use iota_types::{
     base_types::ObjectID,
     effects::{TransactionEffects, TransactionEffectsAPI},
     object::{Object, Owner, bounded_visitor::BoundedVisitor},
-    transaction::{TransactionData, TransactionDataAPI},
+    transaction::{SenderSignedData, TransactionDataAPI},
 };
 use move_core_types::{
     annotated_value::{MoveStruct, MoveTypeLayout, MoveValue},
@@ -90,17 +90,20 @@ struct InputObjectTracker {
 }
 
 impl InputObjectTracker {
-    fn new(txn_data: &TransactionData) -> Self {
-        let shared: BTreeSet<ObjectID> = txn_data
+    fn new(txn: &SenderSignedData) -> Self {
+        let shared: BTreeSet<ObjectID> = txn
             .shared_input_objects()
-            .iter()
+            .into_iter()
             .map(|shared_io| shared_io.id())
             .collect();
-        let coins: BTreeSet<ObjectID> = txn_data.gas().iter().map(|obj_ref| obj_ref.0).collect();
-        let input: BTreeSet<ObjectID> = txn_data
+        let tx_data = txn.transaction_data();
+        let coins: BTreeSet<ObjectID> = tx_data.gas().iter().map(|obj_ref| obj_ref.0).collect();
+        // All input objects (transaction + authenticators) are collected here, just
+        // like the shared objects previously.
+        let input: BTreeSet<ObjectID> = txn
             .input_objects()
             .expect("input objects must be valid")
-            .iter()
+            .into_iter()
             .map(|io_kind| io_kind.object_id())
             .collect();
         Self {

crates/iota-analytics-indexer/src/handlers/mod.rs

@@ -154,11 +154,12 @@ impl TransactionHandler {
             is_sponsored_tx,
             transaction_count: txn_data.kind().num_commands() as u64,
             execution_success: effects.status().is_ok(),
-            input: txn_data
+            // Calculate all objects(transaction + authenticators) amount.
+            input: transaction
                 .input_objects()
                 .expect("input objects must be valid")
                 .len() as u64,
-            shared_input: txn_data.shared_input_objects().len() as u64,
+            shared_input: transaction.shared_input_objects().len() as u64,
             gas_coins: txn_data.gas().len() as u64,
             created: effects.created().len() as u64,
             mutated: (effects.mutated().len() + effects.unwrapped().len()) as u64,

crates/iota-analytics-indexer/src/handlers/transaction_handler.rs

@@ -10,7 +10,6 @@ use iota_types::{
     base_types::ObjectID,
     effects::TransactionEffects,
     full_checkpoint_content::{CheckpointData, CheckpointTransaction},
-    transaction::TransactionDataAPI,
 };
 use tokio::sync::Mutex;
 
@@ -93,15 +92,19 @@ impl TransactionObjectsHandler {
         state: &mut State,
     ) {
         let transaction = &checkpoint_transaction.transaction;
-        let transaction_digest = transaction.digest().base58_encode();
-        let txn_data = transaction.transaction_data();
-        let input_object_tracker = InputObjectTracker::new(txn_data);
+        let input_object_tracker = InputObjectTracker::new(transaction.data());
         let object_status_tracker = ObjectStatusTracker::new(effects);
+
+        let transaction_digest = transaction.digest().base58_encode();
+
         // input
-        txn_data
+        //
+        // Process all objects associated with the transaction, including authenticator
+        // inputs.
+        transaction
             .input_objects()
             .expect("input objects must be valid")
-            .iter()
+            .into_iter()
             .map(|object| (object.object_id(), object.version().map(|v| v.value())))
             .for_each(|(object_id, version)| {
                 self.process_transaction_object(