pezstaging-xcm-builder 7.0.0

Tools & types for building with XCM and its executor.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95

// Copyright (C) Parity Technologies (UK) Ltd. and Dijital Kurdistan Tech Institute
// This file is part of Pezkuwi.

// Pezkuwi is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.

// Pezkuwi is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.

// You should have received a copy of the GNU General Public License
// along with Pezkuwi.  If not, see <http://www.gnu.org/licenses/>.

use super::*;
use pezframe_support::{assert_ok, traits::Everything};
use xcm_executor::traits::Properties;

fn props() -> Properties {
	Properties { weight_credit: Weight::zero(), message_id: None }
}

#[test]
fn trailing_set_topic_as_id_with_unique_topic_should_work() {
	type AllowSubscriptions = AllowSubscriptionsFrom<Everything>;

	// check the validity of XCM for the `AllowSubscriptions` barrier
	let valid_xcm = Xcm::<()>(vec![SubscribeVersion {
		query_id: 42,
		max_response_weight: Weight::from_parts(5000, 5000),
	}]);
	assert_eq!(
		AllowSubscriptions::should_execute(
			&Location::parent(),
			valid_xcm.clone().inner_mut(),
			Weight::from_parts(10, 10),
			&mut props(),
		),
		Ok(())
	);

	// simulate sending `valid_xcm` with the `WithUniqueTopic` router
	let mut sent_xcm = pezsp_io::TestExternalities::default().execute_with(|| {
		assert_ok!(send_xcm::<WithUniqueTopic<TestMessageSender>>(Location::parent(), valid_xcm,));
		sent_xcm()
	});
	assert_eq!(1, sent_xcm.len());

	// `sent_xcm` should contain `SubscribeVersion` and have `SetTopic` added
	let mut sent_xcm = sent_xcm.remove(0).1;
	let _ = sent_xcm
		.0
		.matcher()
		.assert_remaining_insts(2)
		.expect("two instructions")
		.match_next_inst(|instr| match instr {
			SubscribeVersion { .. } => Ok(()),
			_ => Err(ProcessMessageError::BadFormat),
		})
		.expect("expected instruction `SubscribeVersion`")
		.match_next_inst(|instr| match instr {
			SetTopic(..) => Ok(()),
			_ => Err(ProcessMessageError::BadFormat),
		})
		.expect("expected instruction `SetTopic`");

	// `sent_xcm` contains `SetTopic` and is now invalid for `AllowSubscriptions`
	assert_eq!(
		AllowSubscriptions::should_execute(
			&Location::parent(),
			sent_xcm.clone().inner_mut(),
			Weight::from_parts(10, 10),
			&mut props(),
		),
		Err(ProcessMessageError::BadFormat)
	);

	// let's apply `TrailingSetTopicAsId` before `AllowSubscriptions`
	let mut props = props();
	assert!(props.message_id.is_none());

	// should pass, and the `message_id` is set
	assert_eq!(
		TrailingSetTopicAsId::<AllowSubscriptions>::should_execute(
			&Location::parent(),
			sent_xcm.clone().inner_mut(),
			Weight::from_parts(10, 10),
			&mut props,
		),
		Ok(())
	);
	assert!(props.message_id.is_some());
}