Merge pull request opentensor#2266 from opentensor/mevshield-transaction-extension

MevShield / Transaction Extension

Author: sam0x17

pallets/shield/src/lib.rs

@@ -16,20 +16,22 @@ pub mod pallet {
     use super::*;
     use codec::Encode;
     use frame_support::{
-        dispatch::{GetDispatchInfo, PostDispatchInfo},
+        dispatch::{DispatchInfo, GetDispatchInfo, PostDispatchInfo},
         pallet_prelude::*,
         traits::ConstU32,
+        traits::IsSubType,
         weights::Weight,
     };
     use frame_system::pallet_prelude::*;
     use sp_consensus_aura::sr25519::AuthorityId as AuraAuthorityId;
     use sp_core::ByteArray;
-    use sp_runtime::transaction_validity::{
-        InvalidTransaction, TransactionSource, ValidTransaction,
-    };
     use sp_runtime::{
         AccountId32, DispatchErrorWithPostInfo, RuntimeDebug, Saturating,
-        traits::{BadOrigin, Hash},
+        traits::{
+            BadOrigin, DispatchInfoOf, DispatchOriginOf, Dispatchable, Hash, Implication,
+            TransactionExtension,
+        },
+        transaction_validity::{InvalidTransaction, TransactionSource, ValidTransaction},
     };
     use sp_std::{marker::PhantomData, prelude::*};
     use subtensor_macros::freeze_struct;
@@ -382,4 +384,93 @@ pub mod pallet {
             }
         }
     }
+
+    #[freeze_struct("51f74eb54f5ab1fe")]
+    #[derive(Default, Encode, Decode, DecodeWithMemTracking, Clone, Eq, PartialEq, TypeInfo)]
+    pub struct MevShieldDecryptionFilter<T: Config + Send + Sync + TypeInfo>(pub PhantomData<T>);
+
+    impl<T: Config + Send + Sync + TypeInfo> sp_std::fmt::Debug for MevShieldDecryptionFilter<T> {
+        fn fmt(&self, f: &mut sp_std::fmt::Formatter) -> sp_std::fmt::Result {
+            write!(f, "MevShieldDecryptionFilter")
+        }
+    }
+
+    impl<T: Config + Send + Sync + TypeInfo> MevShieldDecryptionFilter<T> {
+        pub fn new() -> Self {
+            Self(PhantomData)
+        }
+
+        #[inline]
+        fn mev_failed_priority() -> TransactionPriority {
+            1u64
+        }
+    }
+
+    impl<T: Config + Send + Sync + TypeInfo> TransactionExtension<RuntimeCallFor<T>>
+        for MevShieldDecryptionFilter<T>
+    where
+        <T as frame_system::Config>::RuntimeCall:
+            Dispatchable<Info = DispatchInfo, PostInfo = PostDispatchInfo>,
+        <T as frame_system::Config>::RuntimeCall: IsSubType<Call<T>>,
+    {
+        const IDENTIFIER: &'static str = "MevShieldDecryptionFilter";
+
+        type Implicit = ();
+        type Val = ();
+        type Pre = ();
+
+        fn weight(&self, _call: &RuntimeCallFor<T>) -> Weight {
+            // Only does light pattern matching; treat as free.
+            Weight::zero()
+        }
+
+        fn validate(
+            &self,
+            origin: DispatchOriginOf<RuntimeCallFor<T>>,
+            call: &RuntimeCallFor<T>,
+            _info: &DispatchInfoOf<RuntimeCallFor<T>>,
+            _len: usize,
+            _self_implicit: Self::Implicit,
+            _inherited_implication: &impl Implication,
+            source: TransactionSource,
+        ) -> ValidateResult<Self::Val, RuntimeCallFor<T>> {
+            match call.is_sub_type() {
+                Some(Call::mark_decryption_failed { id, .. }) => {
+                    match source {
+                        TransactionSource::Local | TransactionSource::InBlock => {
+                            let validity_res =
+                                ValidTransaction::with_tag_prefix("mev-shield-failed")
+                                    .priority(Self::mev_failed_priority())
+                                    .longevity(64)
+                                    .and_provides(id)
+                                    .propagate(false)
+                                    .build();
+
+                            match validity_res {
+                                Ok(validity) => Ok((validity, (), origin)),
+                                Err(e) => Err(e),
+                            }
+                        }
+
+                        // Anything coming from the outside world (including *signed*
+                        // transactions) is rejected at the pool boundary.
+                        _ => Err(InvalidTransaction::Call.into()),
+                    }
+                }
+
+                _ => Ok((Default::default(), (), origin)),
+            }
+        }
+
+        fn prepare(
+            self,
+            _val: Self::Val,
+            _origin: &DispatchOriginOf<RuntimeCallFor<T>>,
+            _call: &RuntimeCallFor<T>,
+            _info: &DispatchInfoOf<RuntimeCallFor<T>>,
+            _len: usize,
+        ) -> Result<Self::Pre, TransactionValidityError> {
+            Ok(())
+        }
+    }
 }