add furnace canister

Cargo.toml

@@ -1,5 +1,9 @@
 [workspace]
-members = ["backend/src/can_burner", "backend/src/shared"]
+members = [
+    "backend/src/can_burner",
+    "backend/src/can_furnace",
+    "backend/src/shared",
+]
 resolver = "2"
 
 [profile.release]

backend/src/can_furnace/Cargo.toml

@@ -0,0 +1,22 @@
+[package]
+name = "furnace"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[lib]
+crate-type = ["cdylib"]
+
+[dependencies]
+serde = { workspace = true }
+shared = { path = "../shared" }
+candid = { workspace = true }
+ic-cdk = { workspace = true }
+ic-cdk-timers = { workspace = true }
+ic-stable-structures = { workspace = true }
+garde = { workspace = true }
+ic-e8s = { workspace = true }
+icrc-ledger-types = { workspace = true }
+ic-ledger-types = { workspace = true }
+futures = { workspace = true }

backend/src/can_furnace/can.did

@@ -0,0 +1,48 @@
+type ClaimRewardRequest = record { to : principal };
+type ClaimRewardResponse = record { result : Result };
+type GetBurnersRequest = record { take : nat32; start : opt principal };
+type GetBurnersResponse = record {
+  entries : vec record { principal; nat; nat; bool; nat64 };
+};
+type GetTotalsResponse = record {
+  total_lottery_participants : nat64;
+  your_lottery_eligibility_status : bool;
+  total_share_supply : nat;
+  your_decide_id_verification_status : bool;
+  total_burners : nat64;
+  total_tcycles_burned : nat;
+  pos_start_key : opt principal;
+  your_share_tcycles : nat;
+  pos_round_delay_ns : nat64;
+  total_burn_token_minted : nat;
+  total_verified_accounts : nat64;
+  current_burn_token_reward : nat;
+  your_unclaimed_reward_e8s : nat;
+  is_lottery_enabled : bool;
+  current_pos_round : nat64;
+  current_share_fee : nat;
+};
+type RefundLostTokensRequest = record { kind : RefundTokenKind };
+type RefundLostTokensResponse = record { results : vec Result };
+type RefundTokenKind = variant { ICP : vec record { blob; nat64 } };
+type Result = variant { Ok : nat; Err : text };
+type StakeRequest = record { qty_e8s_u64 : nat64 };
+type VerifyDecideIdRequest = record { jwt : text };
+type WithdrawRequest = record { to : principal; qty_e8s : nat };
+service : () -> {
+  can_migrate_msq_account : () -> (bool) query;
+  claim_reward : (ClaimRewardRequest) -> (ClaimRewardResponse);
+  decide_id_verified_accounts_count : () -> (nat32) query;
+  disable_lottery : () -> ();
+  enable_lottery : () -> ();
+  get_burners : (GetBurnersRequest) -> (GetBurnersResponse) query;
+  get_totals : () -> (GetTotalsResponse) query;
+  migrate_msq_account : (ClaimRewardRequest) -> (record {});
+  refund_lost_tokens : (RefundLostTokensRequest) -> (RefundLostTokensResponse);
+  resume : () -> ();
+  stake : (StakeRequest) -> (record {});
+  stop : () -> ();
+  subaccount_of : (principal) -> (blob) query;
+  verify_decide_id : (VerifyDecideIdRequest) -> (record {});
+  withdraw : (WithdrawRequest) -> (record {});
+}

backend/src/can_furnace/src/lib.rs

@@ -0,0 +1 @@
+pub mod utils;

backend/src/can_furnace/src/utils.rs

@@ -0,0 +1,45 @@
+use std::{cell::RefCell, time::Duration};
+
+use ic_cdk::{
+    api::{management_canister::main::raw_rand, time},
+    spawn,
+};
+use ic_cdk_timers::set_timer;
+use ic_stable_structures::{
+    memory_manager::{MemoryId, MemoryManager},
+    Cell, DefaultMemoryImpl, StableBTreeMap,
+};
+use shared::furnace::{state::FurnaceState, types::FurnaceInfo};
+
+thread_local! {
+    pub static MEMORY_MANAGER: RefCell<MemoryManager<DefaultMemoryImpl>> =
+        RefCell::new(MemoryManager::init(DefaultMemoryImpl::default()));
+
+    pub static STATE: RefCell<FurnaceState> = RefCell::new(
+        FurnaceState {
+            cur_round_entries: StableBTreeMap::init(
+                MEMORY_MANAGER.with_borrow(|m| m.get(MemoryId::new(0))),
+            ),
+            positions: StableBTreeMap::init(
+                MEMORY_MANAGER.with_borrow(|m| m.get(MemoryId::new(1))),
+            ),
+            winners: StableBTreeMap::init(
+                MEMORY_MANAGER.with_borrow(|m| m.get(MemoryId::new(2))),
+            ),
+            furnace_info: Cell::init(MEMORY_MANAGER.with_borrow(|m| m.get(MemoryId::new(3))), FurnaceInfo::default()).expect("Unable to create furnace info cell"),
+            raffle_round_info: Cell::init(MEMORY_MANAGER.with_borrow(|m| m.get(MemoryId::new(3))), None).expect("Unable to create raffle round info cell")
+        }
+    )
+}
+
+pub fn set_init_seed_one_timer() {
+    set_timer(Duration::from_nanos(0), init_seed);
+}
+
+fn init_seed() {
+    spawn(async {
+        let (rand,) = raw_rand().await.expect("Unable to fetch rand");
+
+        STATE.with_borrow_mut(|s| s.init(rand, time()));
+    });
+}

backend/src/shared/src/furnace/api.rs

@@ -43,7 +43,7 @@ impl Guard<FurnaceState> for CreatePositionRequest {
             self.title = Some(trimmed_title);
         }
 
-        let info = state.get_info_ref();
+        let info = state.get_furnace_info_ref();
         let usd_value = info
             .get_whitelisted_token_usd_value(&self.token_can_id, self.qty.clone())
             .ok_or(String::from("The token is not whitelisted"))?;
@@ -83,7 +83,7 @@ impl Guard<FurnaceState> for AffectPositionRequest {
     ) -> Result<(), String> {
         self.validate(&()).map_err(|e| e.to_string())?;
 
-        let info = state.get_info_ref();
+        let info = state.get_furnace_info_ref();
         let usd_value = info
             .get_whitelisted_token_usd_value(&self.token_can_id, self.qty.clone())
             .ok_or(String::from("The token is not whitelisted"))?;