Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 8 additions & 3 deletions packages/pas/sources/requests/request.move
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,11 @@ use sui::vec_set::{Self, VecSet};

#[error(code = 0)]
const EInsufficientApprovals: vector<u8> =
b"Cannot resolve request: insufficient approvals received.";
b"Cannot resolve request: insufficient or invalid approvals received.";

#[error(code = 1)]
const EInvalidNumberOfApprovals: vector<u8> =
b"Cannot resolve request: Invalid number of approvals received.";

/// A base request type.
/// Examples:
Expand Down Expand Up @@ -39,8 +43,9 @@ public(package) fun new<K>(data: K): Request<K> {

/// An internal function to resolve a request.
public(package) fun resolve<K>(request: Request<K>, required_approvals: VecSet<TypeName>): K {
required_approvals.keys().do_ref!(|approval| {
assert!(request.approvals.contains(approval), EInsufficientApprovals);
assert!(request.approvals.length() == required_approvals.length(), EInvalidNumberOfApprovals);
request.approvals.into_keys().zip_do_ref!(&required_approvals.into_keys(), |a, b| {
assert!(a == b, EInsufficientApprovals);
});
let Request { data, .. } = request;
data
Expand Down
136 changes: 133 additions & 3 deletions packages/pas/tests/e2e.move
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
#[test_only, allow(unused_variable, unused_mut_ref, dead_code)]
module pas::e2e;

use pas::{rule, transfer_funds, unlock_funds, vault::{Self, Vault}};
use std::unit_test::{assert_eq, destroy};
use sui::{balance::{Self, send_funds}, sui::SUI, test_scenario::return_shared};
use pas::{rule::{Self, RuleCap}, transfer_funds, unlock_funds, vault::{Self, Vault}};
use std::{type_name, unit_test::{assert_eq, destroy}};
use sui::{balance::{Self, send_funds}, sui::SUI, test_scenario::return_shared, vec_set};

public struct A has drop {}
public struct B has drop {}
Expand Down Expand Up @@ -302,6 +302,136 @@ fun try_to_create_duplicate_rule() {
});
}

#[test]
fun multiple_approvals_required() {
test_tx!(@0x1, |namespace, managed_rule, unmanaged_rule, scenario| {
scenario.next_tx(@0x1);

let namespace_id = object::id(namespace);
let rule_cap = scenario.take_from_sender<RuleCap<A>>();

let mut approvals = vec_set::empty();
approvals.insert(type_name::with_defining_ids<AWitness>());
approvals.insert(type_name::with_defining_ids<BWitness>());

managed_rule.set_required_approvals(&rule_cap, "transfer_funds", approvals);

scenario.return_to_sender(rule_cap);

// create vaults of 0x1 and 0x2
let vault = vault::create(namespace, @0x1);

// transfer some funds to both 0x1 and 0x2
vault.deposit_funds(balance::create_for_testing<A>(100));
vault.share();

scenario.next_tx(@0x1);

let mut vault = scenario.take_shared_by_id<Vault>(namespace
.vault_address(
@0x1,
)
.to_id());

let auth = vault::new_auth(scenario.ctx());
let mut transfer_request = vault.unsafe_transfer_funds<A>(
&auth,
@0x2,
50,
scenario.ctx(),
);

transfer_request.approve(AWitness());
transfer_request.approve(BWitness());
transfer_funds::resolve(transfer_request, managed_rule);

return_shared(vault);
});
}

#[test, expected_failure(abort_code = ::pas::request::EInsufficientApprovals)]
fun multiple_approvals_invalid_order_failure() {
test_tx!(@0x1, |namespace, managed_rule, unmanaged_rule, scenario| {
scenario.next_tx(@0x1);

let namespace_id = object::id(namespace);
let rule_cap = scenario.take_from_sender<RuleCap<A>>();

let mut approvals = vec_set::empty();
approvals.insert(type_name::with_defining_ids<AWitness>());
approvals.insert(type_name::with_defining_ids<BWitness>());

managed_rule.set_required_approvals(&rule_cap, "transfer_funds", approvals);

scenario.return_to_sender(rule_cap);

// create vaults of 0x1 and 0x2
let vault = vault::create(namespace, @0x1);

// transfer some funds to both 0x1 and 0x2
vault.deposit_funds(balance::create_for_testing<A>(100));
vault.share();

scenario.next_tx(@0x1);

let mut vault = scenario.take_shared_by_id<Vault>(namespace
.vault_address(
@0x1,
)
.to_id());

let auth = vault::new_auth(scenario.ctx());
let mut transfer_request = vault.unsafe_transfer_funds<A>(
&auth,
@0x2,
50,
scenario.ctx(),
);
transfer_request.approve(BWitness());
transfer_request.approve(AWitness());

transfer_funds::resolve(transfer_request, managed_rule);
abort
});
}

#[test, expected_failure(abort_code = ::pas::request::EInvalidNumberOfApprovals)]
fun cannot_have_extra_approvals() {
test_tx!(@0x1, |namespace, managed_rule, unmanaged_rule, scenario| {
scenario.next_tx(@0x1);

let namespace_id = object::id(namespace);

// create vaults of 0x1 and 0x2
let vault = vault::create(namespace, @0x1);

// transfer some funds to both 0x1 and 0x2
vault.deposit_funds(balance::create_for_testing<A>(100));
vault.share();

scenario.next_tx(@0x1);

let mut vault = scenario.take_shared_by_id<Vault>(namespace
.vault_address(
@0x1,
)
.to_id());

let auth = vault::new_auth(scenario.ctx());
let mut transfer_request = vault.unsafe_transfer_funds<A>(
&auth,
@0x2,
50,
scenario.ctx(),
);
transfer_request.approve(BWitness());
transfer_request.approve(AWitness());

transfer_funds::resolve(transfer_request, managed_rule);
abort
});
}

public fun package_id<T>(): ID {
sui::address::from_ascii_bytes(std::type_name::with_defining_ids<T>()
.address_string()
Expand Down