Skip to content

Commit 7461632

Browse files
committed
refactor(dmq): adapt publisher server with new 'DmqMsg' structure
1 parent ff84253 commit 7461632

File tree

1 file changed

+13
-7
lines changed
  • internal/mithril-dmq/src/publisher/server

1 file changed

+13
-7
lines changed

internal/mithril-dmq/src/publisher/server/pallas.rs

Lines changed: 13 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -242,7 +242,10 @@ mod tests {
242242

243243
use pallas_network::{
244244
facades::DmqClient,
245-
miniprotocols::{localmsgsubmission::DmqMsg, localtxsubmission},
245+
miniprotocols::{
246+
localmsgsubmission::{DmqMsg, DmqMsgPayload},
247+
localtxsubmission,
248+
},
246249
};
247250
use tokio::sync::{mpsc::unbounded_channel, watch};
248251

@@ -258,13 +261,16 @@ mod tests {
258261

259262
async fn fake_msg() -> DmqMsg {
260263
DmqMsg {
261-
msg_id: vec![0, 1],
262-
msg_body: vec![0, 1, 2],
264+
msg_payload: DmqMsgPayload {
265+
msg_id: vec![0, 1],
266+
msg_body: vec![0, 1, 2],
267+
268+
kes_period: 10,
269+
operational_certificate: vec![0, 1, 2, 3, 4],
270+
cold_verification_key: vec![0, 1, 2, 3, 4, 5],
271+
expires_at: 100,
272+
},
263273
kes_signature: vec![0, 1, 2, 3],
264-
kes_period: 10,
265-
operational_certificate: vec![0, 1, 2, 3, 4],
266-
cold_verification_key: vec![0, 1, 2, 3, 4, 5],
267-
expires_at: 100,
268274
}
269275
}
270276

0 commit comments

Comments
 (0)