smokesignal.events
+2
-10
crates/atproto-jetstream/src/consumer.rs
+2
-10
crates/atproto-jetstream/src/consumer.rs
···
56
time_us: u64,
57
/// Event type identifier
58
kind: String,
59
-
60
-
#[serde(rename = "commit")]
61
/// Commit operation details
62
commit: JetstreamEventCommit,
63
},
···
70
time_us: u64,
71
/// Event type identifier
72
kind: String,
73
-
74
-
#[serde(rename = "commit")]
75
/// Delete operation details
76
commit: JetstreamEventDelete,
77
},
···
84
time_us: u64,
85
/// Event type identifier
86
kind: String,
87
-
88
-
#[serde(rename = "identity")]
89
/// Identity document data
90
identity: serde_json::Value,
91
},
···
98
time_us: u64,
99
/// Event type identifier
100
kind: String,
101
-
102
-
#[serde(rename = "account")]
103
/// Account data
104
-
identity: serde_json::Value,
105
},
106
}
107
···
469
.expect("Failed to parse account event JSON");
470
471
match event {
472
-
JetstreamEvent::Account { did, time_us, kind, identity } => {
473
assert_eq!(did, "did:plc:yn72uqr4ihkjfbz7us7buqsq");
474
assert_eq!(time_us, 1757517640675638);
475
assert_eq!(kind, "account");
···
56
time_us: u64,
57
/// Event type identifier
58
kind: String,
59
/// Commit operation details
60
commit: JetstreamEventCommit,
61
},
···
68
time_us: u64,
69
/// Event type identifier
70
kind: String,
71
/// Delete operation details
72
commit: JetstreamEventDelete,
73
},
···
80
time_us: u64,
81
/// Event type identifier
82
kind: String,
83
/// Identity document data
84
identity: serde_json::Value,
85
},
···
92
time_us: u64,
93
/// Event type identifier
94
kind: String,
95
/// Account data
96
+
account: serde_json::Value,
97
},
98
}
99
···
461
.expect("Failed to parse account event JSON");
462
463
match event {
464
+
JetstreamEvent::Account { did, time_us, kind, account: identity } => {
465
assert_eq!(did, "did:plc:yn72uqr4ihkjfbz7us7buqsq");
466
assert_eq!(time_us, 1757517640675638);
467
assert_eq!(kind, "account");