@@ -22,18 +22,18 @@ pub struct FakeAggregatorData {
22
22
snapshots_list : FileContent ,
23
23
individual_snapshots : BTreeMap < ArtifactId , FileContent > ,
24
24
25
- msds_list : FileContent ,
26
- individual_msds : BTreeMap < ArtifactId , FileContent > ,
25
+ mithril_stake_distributions_list : FileContent ,
26
+ individual_mithril_stake_distributions : BTreeMap < ArtifactId , FileContent > ,
27
27
28
- ctx_snapshots_list : FileContent ,
29
- individual_ctx_snapshots : BTreeMap < ArtifactId , FileContent > ,
30
- ctx_proofs : BTreeMap < ArtifactId , FileContent > ,
28
+ cardano_transaction_snapshots_list : FileContent ,
29
+ individual_cardano_transaction_snapshots : BTreeMap < ArtifactId , FileContent > ,
30
+ cardano_transaction_proofs : BTreeMap < ArtifactId , FileContent > ,
31
31
32
- csds_list : FileContent ,
33
- individual_csds : BTreeMap < ArtifactId , FileContent > ,
32
+ cardano_stake_distributions_list : FileContent ,
33
+ individual_cardano_stake_distributions : BTreeMap < ArtifactId , FileContent > ,
34
34
35
- cdbs_list : FileContent ,
36
- individual_cdbs : BTreeMap < ArtifactId , FileContent > ,
35
+ cardano_database_snapshots_list : FileContent ,
36
+ individual_cardano_database_snapshots : BTreeMap < ArtifactId , FileContent > ,
37
37
}
38
38
39
39
impl FakeAggregatorData {
@@ -54,43 +54,47 @@ impl FakeAggregatorData {
54
54
data. epoch_settings = file_content;
55
55
}
56
56
"mithril-stake-distributions-list.json" => {
57
- data. msds_list = file_content;
57
+ data. mithril_stake_distributions_list = file_content;
58
58
}
59
59
"snapshots-list.json" => {
60
60
data. snapshots_list = file_content;
61
61
}
62
62
"cardano-stake-distributions-list.json" => {
63
- data. csds_list = file_content;
63
+ data. cardano_stake_distributions_list = file_content;
64
64
}
65
65
"cardano-databases-list.json" => {
66
- data. cdbs_list = file_content;
66
+ data. cardano_database_snapshots_list = file_content;
67
67
}
68
68
"certificates-list.json" => {
69
69
data. certificates_list = file_content;
70
70
}
71
71
"ctx-snapshots-list.json" => {
72
- data. ctx_snapshots_list = file_content;
72
+ data. cardano_transaction_snapshots_list = file_content;
73
73
}
74
74
"mithril-stake-distributions.json" => {
75
- data. individual_msds = Self :: read_artifacts_json_file ( & entry. path ( ) ) ;
75
+ data. individual_mithril_stake_distributions =
76
+ Self :: read_artifacts_json_file ( & entry. path ( ) ) ;
76
77
}
77
78
"snapshots.json" => {
78
79
data. individual_snapshots = Self :: read_artifacts_json_file ( & entry. path ( ) ) ;
79
80
}
80
81
"cardano-stake-distributions.json" => {
81
- data. individual_csds = Self :: read_artifacts_json_file ( & entry. path ( ) ) ;
82
+ data. individual_cardano_stake_distributions =
83
+ Self :: read_artifacts_json_file ( & entry. path ( ) ) ;
82
84
}
83
85
"cardano-databases.json" => {
84
- data. individual_cdbs = Self :: read_artifacts_json_file ( & entry. path ( ) ) ;
86
+ data. individual_cardano_database_snapshots =
87
+ Self :: read_artifacts_json_file ( & entry. path ( ) ) ;
85
88
}
86
89
"certificates.json" => {
87
90
data. individual_certificates = Self :: read_artifacts_json_file ( & entry. path ( ) ) ;
88
91
}
89
92
"ctx-snapshots.json" => {
90
- data. individual_ctx_snapshots = Self :: read_artifacts_json_file ( & entry. path ( ) ) ;
93
+ data. individual_cardano_transaction_snapshots =
94
+ Self :: read_artifacts_json_file ( & entry. path ( ) ) ;
91
95
}
92
96
"ctx-proofs.json" => {
93
- data. ctx_proofs = Self :: read_artifacts_json_file ( & entry. path ( ) ) ;
97
+ data. cardano_transaction_proofs = Self :: read_artifacts_json_file ( & entry. path ( ) ) ;
94
98
}
95
99
// unknown file
96
100
_ => { }
@@ -108,32 +112,42 @@ impl FakeAggregatorData {
108
112
BTreeSet :: from_iter ( self . individual_snapshots . keys ( ) . cloned ( ) ) ,
109
113
) ,
110
114
generate_ids_array (
111
- "msd_hashes" ,
112
- BTreeSet :: from_iter ( self . individual_msds . keys ( ) . cloned ( ) ) ,
115
+ "mithril_stake_distribution_hashes" ,
116
+ BTreeSet :: from_iter (
117
+ self . individual_mithril_stake_distributions . keys ( ) . cloned ( ) ,
118
+ ) ,
113
119
) ,
114
120
generate_ids_array (
115
- "csd_hashes" ,
116
- BTreeSet :: from_iter ( self . individual_csds . keys ( ) . cloned ( ) ) ,
121
+ "cardano_stake_distribution_hashes" ,
122
+ BTreeSet :: from_iter (
123
+ self . individual_cardano_stake_distributions . keys ( ) . cloned ( ) ,
124
+ ) ,
117
125
) ,
118
126
generate_ids_array (
119
- "csd_epochs" ,
120
- BTreeSet :: from_iter ( extract_csd_epochs ( & self . individual_csds ) ) ,
127
+ "cardano_stake_distribution_epochs" ,
128
+ BTreeSet :: from_iter ( extract_cardano_stake_distribution_epochs (
129
+ & self . individual_cardano_stake_distributions ,
130
+ ) ) ,
121
131
) ,
122
132
generate_ids_array (
123
- "cdb_hashes " ,
124
- BTreeSet :: from_iter ( self . individual_cdbs . keys ( ) . cloned ( ) ) ,
133
+ "cardano_database_snapshot_hashes " ,
134
+ BTreeSet :: from_iter ( self . individual_cardano_database_snapshots . keys ( ) . cloned ( ) ) ,
125
135
) ,
126
136
generate_ids_array (
127
137
"certificate_hashes" ,
128
138
BTreeSet :: from_iter ( self . individual_certificates . keys ( ) . cloned ( ) ) ,
129
139
) ,
130
140
generate_ids_array (
131
- "ctx_snapshot_hashes" ,
132
- BTreeSet :: from_iter ( self . individual_ctx_snapshots . keys ( ) . cloned ( ) ) ,
141
+ "cardano_transaction_snapshot_hashes" ,
142
+ BTreeSet :: from_iter (
143
+ self . individual_cardano_transaction_snapshots
144
+ . keys ( )
145
+ . cloned ( ) ,
146
+ ) ,
133
147
) ,
134
148
generate_ids_array (
135
149
"proof_transaction_hashes" ,
136
- BTreeSet :: from_iter ( self . ctx_proofs . keys ( ) . cloned ( ) ) ,
150
+ BTreeSet :: from_iter ( self . cardano_transaction_proofs . keys ( ) . cloned ( ) ) ,
137
151
) ,
138
152
] ,
139
153
false ,
@@ -151,44 +165,81 @@ impl FakeAggregatorData {
151
165
generate_artifact_getter ( "snapshots" , self . individual_snapshots ) ,
152
166
generate_list_getter ( "snapshot_list" , self . snapshots_list ) ,
153
167
generate_ids_array (
154
- "msd_hashes" ,
155
- BTreeSet :: from_iter ( self . individual_msds . keys ( ) . cloned ( ) ) ,
168
+ "mithril_stake_distribution_hashes" ,
169
+ BTreeSet :: from_iter (
170
+ self . individual_mithril_stake_distributions . keys ( ) . cloned ( ) ,
171
+ ) ,
172
+ ) ,
173
+ generate_artifact_getter (
174
+ "mithril_stake_distributions" ,
175
+ self . individual_mithril_stake_distributions ,
176
+ ) ,
177
+ generate_list_getter (
178
+ "mithril_stake_distribution_list" ,
179
+ self . mithril_stake_distributions_list ,
156
180
) ,
157
- generate_artifact_getter ( "msds" , self . individual_msds ) ,
158
- generate_list_getter ( "msd_list" , self . msds_list ) ,
159
181
generate_ids_array (
160
- "csd_hashes" ,
161
- BTreeSet :: from_iter ( self . individual_csds . keys ( ) . cloned ( ) ) ,
182
+ "cardano_stake_distribution_hashes" ,
183
+ BTreeSet :: from_iter (
184
+ self . individual_cardano_stake_distributions . keys ( ) . cloned ( ) ,
185
+ ) ,
162
186
) ,
163
187
generate_ids_array (
164
- "csd_epochs" ,
165
- BTreeSet :: from_iter ( extract_csd_epochs ( & self . individual_csds ) ) ,
188
+ "cardano_stake_distribution_epochs" ,
189
+ BTreeSet :: from_iter ( extract_cardano_stake_distribution_epochs (
190
+ & self . individual_cardano_stake_distributions ,
191
+ ) ) ,
192
+ ) ,
193
+ generate_artifact_getter (
194
+ "cardano_stake_distributions" ,
195
+ self . individual_cardano_stake_distributions ,
196
+ ) ,
197
+ generate_list_getter (
198
+ "cardano_stake_distribution_list" ,
199
+ self . cardano_stake_distributions_list ,
166
200
) ,
167
- generate_artifact_getter ( "csds" , self . individual_csds ) ,
168
- generate_list_getter ( "csd_list" , self . csds_list ) ,
169
201
generate_ids_array (
170
202
"certificate_hashes" ,
171
203
BTreeSet :: from_iter ( self . individual_certificates . keys ( ) . cloned ( ) ) ,
172
204
) ,
173
205
generate_ids_array (
174
- "cdb_hashes" ,
175
- BTreeSet :: from_iter ( self . individual_cdbs . keys ( ) . cloned ( ) ) ,
206
+ "cardano_database_snapshot_hashes" ,
207
+ BTreeSet :: from_iter ( self . individual_cardano_database_snapshots . keys ( ) . cloned ( ) ) ,
208
+ ) ,
209
+ generate_artifact_getter (
210
+ "cardano_database_snapshots" ,
211
+ self . individual_cardano_database_snapshots ,
212
+ ) ,
213
+ generate_list_getter (
214
+ "cardano_database_snapshot_list" ,
215
+ self . cardano_database_snapshots_list ,
176
216
) ,
177
- generate_artifact_getter ( "cdbs" , self . individual_cdbs ) ,
178
- generate_list_getter ( "cdb_list" , self . cdbs_list ) ,
179
217
generate_artifact_getter ( "certificates" , self . individual_certificates ) ,
180
218
generate_list_getter ( "certificate_list" , self . certificates_list ) ,
181
219
generate_ids_array (
182
- "ctx_snapshot_hashes" ,
183
- BTreeSet :: from_iter ( self . individual_ctx_snapshots . keys ( ) . cloned ( ) ) ,
220
+ "cardano_transaction_snapshot_hashes" ,
221
+ BTreeSet :: from_iter (
222
+ self . individual_cardano_transaction_snapshots
223
+ . keys ( )
224
+ . cloned ( ) ,
225
+ ) ,
226
+ ) ,
227
+ generate_artifact_getter (
228
+ "cardano_transaction_snapshots" ,
229
+ self . individual_cardano_transaction_snapshots ,
230
+ ) ,
231
+ generate_list_getter (
232
+ "cardano_transaction_snapshots_list" ,
233
+ self . cardano_transaction_snapshots_list ,
184
234
) ,
185
- generate_artifact_getter ( "ctx_snapshots" , self . individual_ctx_snapshots ) ,
186
- generate_list_getter ( "ctx_snapshots_list" , self . ctx_snapshots_list ) ,
187
235
generate_ids_array (
188
236
"proof_transaction_hashes" ,
189
- BTreeSet :: from_iter ( self . ctx_proofs . keys ( ) . cloned ( ) ) ,
237
+ BTreeSet :: from_iter ( self . cardano_transaction_proofs . keys ( ) . cloned ( ) ) ,
238
+ ) ,
239
+ generate_artifact_getter (
240
+ "cardano_transaction_proofs" ,
241
+ self . cardano_transaction_proofs ,
190
242
) ,
191
- generate_artifact_getter ( "ctx_proofs" , self . ctx_proofs ) ,
192
243
] ,
193
244
true ,
194
245
)
@@ -227,7 +278,9 @@ impl FakeAggregatorData {
227
278
}
228
279
}
229
280
230
- pub fn extract_csd_epochs ( individual_csds : & BTreeMap < ArtifactId , FileContent > ) -> Vec < String > {
281
+ pub fn extract_cardano_stake_distribution_epochs (
282
+ individual_csds : & BTreeMap < ArtifactId , FileContent > ,
283
+ ) -> Vec < String > {
231
284
individual_csds
232
285
. values ( )
233
286
. map ( |content| {
@@ -439,7 +492,7 @@ fn b() {}
439
492
r#"{"hash": "csd-456", "epoch": 456}"# . to_string ( ) ,
440
493
) ;
441
494
442
- let epochs = extract_csd_epochs ( & csds) ;
495
+ let epochs = extract_cardano_stake_distribution_epochs ( & csds) ;
443
496
444
497
assert_eq ! ( epochs, vec![ 123 . to_string( ) , 456 . to_string( ) ] ) ;
445
498
}
@@ -453,7 +506,7 @@ fn b() {}
453
506
r#""hash": "csd-123", "epoch": "123"# . to_string ( ) ,
454
507
) ;
455
508
456
- extract_csd_epochs ( & csds) ;
509
+ extract_cardano_stake_distribution_epochs ( & csds) ;
457
510
}
458
511
459
512
#[ test]
@@ -462,14 +515,14 @@ fn b() {}
462
515
let mut csds = BTreeMap :: new ( ) ;
463
516
csds. insert ( "csd-123" . to_string ( ) , r#"{"hash": "csd-123"}"# . to_string ( ) ) ;
464
517
465
- extract_csd_epochs ( & csds) ;
518
+ extract_cardano_stake_distribution_epochs ( & csds) ;
466
519
}
467
520
468
521
#[ test]
469
522
fn test_extract_csd_epochs_with_empty_map ( ) {
470
523
let csds = BTreeMap :: new ( ) ;
471
524
472
- let epochs = extract_csd_epochs ( & csds) ;
525
+ let epochs = extract_cardano_stake_distribution_epochs ( & csds) ;
473
526
474
527
assert ! ( epochs. is_empty( ) ) ;
475
528
}
0 commit comments