nologies/cycles-quartz
4
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Use Item<Vec> for REQUESTS storage

Browse source
This commit is contained in:
hu55a1n1 2024-01-01 12:49:32 -08:00
parent de5314122a
commit 57c14e3ef9
2 changed files with 9 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
bisenzone-cw-mvp/contracts/cw-tee-mtcs/src/contract.rs
View file

@ -108,13 +108,12 @@ pub mod execute {
let _ = deps.api.addr_validate(&address)?; let _ = deps.api.addr_validate(&address)?;
let _ = hex::decode(&nonce); let _ = hex::decode(&nonce);
REQUESTS.push_back( let mut requests = REQUESTS.may_load(deps.storage)?.unwrap_or_default();
deps.storage, requests.push((
&( nonce,
nonce, Request::JoinComputeNode((io_exchange_key.clone(), address)),
Request::JoinComputeNode((io_exchange_key.clone(), address)), ));
), REQUESTS.save(deps.storage, &requests)?;
)?;
Ok(Response::new() Ok(Response::new()
.add_attribute("action", "enqueue_request") .add_attribute("action", "enqueue_request")
@ -150,7 +149,7 @@ pub mod query {
pub fn get_requests(deps: Deps) -> StdResult<GetRequestsResponse> { pub fn get_requests(deps: Deps) -> StdResult<GetRequestsResponse> {
Ok(GetRequestsResponse { Ok(GetRequestsResponse {
requests: REQUESTS.iter(deps.storage)?.flat_map(|r| r.ok()).collect(), requests: REQUESTS.load(deps.storage)?,
}) })
} }
} }

4
bisenzone-cw-mvp/contracts/cw-tee-mtcs/src/state.rs
View file

@ -1,5 +1,5 @@
use cosmwasm_schema::cw_serde; use cosmwasm_schema::cw_serde;
use cw_storage_plus::{Deque, Item}; use cw_storage_plus::Item;
pub type RawNonce = String; pub type RawNonce = String;
pub type RawPublicKey = String; pub type RawPublicKey = String;
@ -27,5 +27,5 @@ pub struct SgxState {
} }
pub const STATE: Item<State> = Item::new("state"); pub const STATE: Item<State> = Item::new("state");
pub const REQUESTS: Deque<(RawNonce, Request)> = Deque::new("requests"); pub const REQUESTS: Item<Vec<(RawNonce, Request)>> = Item::new("requests");
pub const SGX_STATE: Item<SgxState> = Item::new("sgxstate"); pub const SGX_STATE: Item<SgxState> = Item::new("sgxstate");