tendermint coin with-tokens-activation via task manager

Author: mariocynicys

mm2src/coins_activation/src/context.rs

@@ -4,6 +4,7 @@ use crate::init_erc20_token_activation::Erc20TokenTaskManagerShared;
 use crate::lightning_activation::LightningTaskManagerShared;
 #[cfg(feature = "enable-sia")]
 use crate::sia_coin_activation::SiaCoinTaskManagerShared;
+use crate::tendermint_with_assets_activation::TendermintCoinTaskManagerShared;
 use crate::utxo_activation::{BchTaskManagerShared, QtumTaskManagerShared, UtxoStandardTaskManagerShared};
 use crate::z_coin_activation::ZcoinTaskManagerShared;
 use mm2_core::mm_ctx::{from_ctx, MmArc};
@@ -19,6 +20,7 @@ pub struct CoinsActivationContext {
     pub(crate) init_z_coin_task_manager: ZcoinTaskManagerShared,
     pub(crate) init_eth_task_manager: EthTaskManagerShared,
     pub(crate) init_erc20_token_task_manager: Erc20TokenTaskManagerShared,
+    pub(crate) init_tendermint_coin_task_manager: TendermintCoinTaskManagerShared,
     #[cfg(not(target_arch = "wasm32"))]
     pub(crate) init_lightning_task_manager: LightningTaskManagerShared,
 }
@@ -36,6 +38,7 @@ impl CoinsActivationContext {
                 init_z_coin_task_manager: RpcTaskManager::new_shared(ctx.event_stream_manager.clone()),
                 init_eth_task_manager: RpcTaskManager::new_shared(ctx.event_stream_manager.clone()),
                 init_erc20_token_task_manager: RpcTaskManager::new_shared(ctx.event_stream_manager.clone()),
+                init_tendermint_coin_task_manager: RpcTaskManager::new_shared(ctx.event_stream_manager.clone()),
                 #[cfg(not(target_arch = "wasm32"))]
                 init_lightning_task_manager: RpcTaskManager::new_shared(ctx.event_stream_manager.clone()),
             })

mm2src/coins_activation/src/tendermint_with_assets_activation.rs

@@ -27,6 +27,8 @@ use serde::{Deserialize, Deserializer, Serialize};
 use serde_json::Value as Json;
 use std::collections::{HashMap, HashSet};
 
+pub type TendermintCoinTaskManagerShared = InitPlatformCoinWithTokensTaskManagerShared<TendermintCoin>;
+
 impl TokenOf for TendermintToken {
     type PlatformCoin = TendermintCoin;
 }
@@ -367,9 +369,7 @@ impl PlatformCoinWithTokensActivationOps for TendermintCoin {
         self.spawner().spawn_with_settings(fut, settings);
     }
 
-    fn rpc_task_manager(
-        _activation_ctx: &CoinsActivationContext,
-    ) -> &InitPlatformCoinWithTokensTaskManagerShared<TendermintCoin> {
-        unimplemented!()
+    fn rpc_task_manager(activation_ctx: &CoinsActivationContext) -> &TendermintCoinTaskManagerShared {
+        &activation_ctx.init_tendermint_coin_task_manager
     }
 }

mm2src/mm2_main/src/rpc/dispatcher/dispatcher.rs

@@ -280,22 +280,21 @@ async fn rpc_task_dispatcher(
         "enable_erc20::init" => handle_mmrpc(ctx, request, init_token::<EthCoin>).await,
         "enable_erc20::status" => handle_mmrpc(ctx, request, init_token_status::<EthCoin>).await,
         "enable_erc20::user_action" => handle_mmrpc(ctx, request, init_token_user_action::<EthCoin>).await,
-        // // FIXME: tendermint with tokens
-        // "enable_tendermint::cancel" => {
-        //     handle_mmrpc(ctx, request, cancel_init_platform_coin_with_tokens::<TendermintCoin>).await
-        // },
-        // "enable_tendermint::init" => handle_mmrpc(ctx, request, init_platform_coin_with_tokens::<TendermintCoin>).await,
-        // "enable_tendermint::status" => {
-        //     handle_mmrpc(ctx, request, init_platform_coin_with_tokens_status::<TendermintCoin>).await
-        // },
-        // "enable_tendermint::user_action" => {
-        //     handle_mmrpc(
-        //         ctx,
-        //         request,
-        //         init_platform_coin_with_tokens_user_action::<TendermintCoin>,
-        //     )
-        //     .await
-        // },
+        "enable_tendermint::cancel" => {
+            handle_mmrpc(ctx, request, cancel_init_platform_coin_with_tokens::<TendermintCoin>).await
+        },
+        "enable_tendermint::init" => handle_mmrpc(ctx, request, init_platform_coin_with_tokens::<TendermintCoin>).await,
+        "enable_tendermint::status" => {
+            handle_mmrpc(ctx, request, init_platform_coin_with_tokens_status::<TendermintCoin>).await
+        },
+        "enable_tendermint::user_action" => {
+            handle_mmrpc(
+                ctx,
+                request,
+                init_platform_coin_with_tokens_user_action::<TendermintCoin>,
+            )
+            .await
+        },
         // // FIXME: tendermint tokens
         // "enable_tendermint_token::cancel" => handle_mmrpc(ctx, request, cancel_init_token::<TendermintToken>).await,
         // "enable_tendermint_token::init" => handle_mmrpc(ctx, request, init_token::<TendermintToken>).await,