@@ -57,10 +57,10 @@ void main() {
57
57
58
58
group ('RecentSenders.handleMessages' , () {
59
59
late RecentSenders model;
60
- final stream1 = eg.stream (streamId : 1 );
61
- final stream2 = eg.stream (streamId : 2 );
62
- final user10 = eg.user (userId : 10 );
63
- final user20 = eg.user (userId : 20 );
60
+ final streamA = eg.stream ();
61
+ final streamB = eg.stream ();
62
+ final userX = eg.user ();
63
+ final userY = eg.user ();
64
64
65
65
void setupModel (List <Message > messages) {
66
66
model = RecentSenders ();
@@ -81,10 +81,10 @@ void main() {
81
81
void checkHandleMessagesSingle (List <int > oldIds, List <int > newIds) {
82
82
checkHandleMessages ([
83
83
for (final id in oldIds)
84
- eg.streamMessage (stream: stream1 , topic: 'a' , sender: user10 , id: id),
84
+ eg.streamMessage (stream: streamA , topic: 'a' , sender: userX , id: id),
85
85
], [
86
86
for (final id in newIds)
87
- eg.streamMessage (stream: stream1 , topic: 'a' , sender: user10 , id: id),
87
+ eg.streamMessage (stream: streamA , topic: 'a' , sender: userX , id: id),
88
88
]);
89
89
}
90
90
@@ -107,51 +107,51 @@ void main() {
107
107
108
108
test ('batch with both DM and stream messages -> ignores DM, processes stream messages' , () {
109
109
checkHandleMessages ([], [
110
- eg.streamMessage (stream: stream1 , topic: 'a ' , sender: user10 ),
110
+ eg.streamMessage (stream: streamA , topic: 'thing ' , sender: userX ),
111
111
eg.dmMessage (from: eg.otherUser, to: [eg.selfUser]),
112
- eg.streamMessage (stream: stream1 , topic: 'a ' , sender: user10 ),
112
+ eg.streamMessage (stream: streamA , topic: 'thing ' , sender: userX ),
113
113
]);
114
114
});
115
115
116
116
test ('add new sender' , () {
117
117
checkHandleMessages (
118
- [eg.streamMessage (stream: stream1 , topic: 'a ' , sender: user10 )],
119
- [eg.streamMessage (stream: stream1 , topic: 'a ' , sender: user20 )]);
118
+ [eg.streamMessage (stream: streamA , topic: 'thing ' , sender: userX )],
119
+ [eg.streamMessage (stream: streamA , topic: 'thing ' , sender: userY )]);
120
120
});
121
121
122
122
test ('add new topic' , () {
123
123
checkHandleMessages (
124
- [eg.streamMessage (stream: stream1 , topic: 'a ' , sender: user10 )],
125
- [eg.streamMessage (stream: stream1 , topic: 'b ' , sender: user10 )]);
124
+ [eg.streamMessage (stream: streamA , topic: 'thing ' , sender: userX )],
125
+ [eg.streamMessage (stream: streamA , topic: 'other ' , sender: userX )]);
126
126
});
127
127
128
128
test ('add new stream' , () {
129
129
checkHandleMessages (
130
- [eg.streamMessage (stream: stream1 , topic: 'a ' , sender: user10 )],
131
- [eg.streamMessage (stream: stream2 , topic: 'a ' , sender: user10 )]);
130
+ [eg.streamMessage (stream: streamA , topic: 'thing ' , sender: userX )],
131
+ [eg.streamMessage (stream: streamB , topic: 'thing ' , sender: userX )]);
132
132
});
133
133
134
134
test ('multiple conversations and senders interspersed' , () {
135
135
checkHandleMessages ([], [
136
- eg.streamMessage (stream: stream1 , topic: 'a ' , sender: user10 ),
137
- eg.streamMessage (stream: stream1 , topic: 'b ' , sender: user10 ),
138
- eg.streamMessage (stream: stream2 , topic: 'a ' , sender: user10 ),
139
- eg.streamMessage (stream: stream1 , topic: 'a ' , sender: user20 ),
140
- eg.streamMessage (stream: stream1 , topic: 'a ' , sender: user10 ),
136
+ eg.streamMessage (stream: streamA , topic: 'thing ' , sender: userX ),
137
+ eg.streamMessage (stream: streamA , topic: 'other ' , sender: userX ),
138
+ eg.streamMessage (stream: streamB , topic: 'thing ' , sender: userX ),
139
+ eg.streamMessage (stream: streamA , topic: 'thing ' , sender: userY ),
140
+ eg.streamMessage (stream: streamA , topic: 'thing ' , sender: userX ),
141
141
]);
142
142
});
143
143
});
144
144
145
145
test ('RecentSenders.handleDeleteMessageEvent' , () {
146
146
final model = RecentSenders ();
147
- final stream1 = eg.stream (streamId : 1 );
148
- final user1 = eg.user (userId : 1 );
149
- final user2 = eg.user (userId : 2 );
147
+ final stream = eg.stream ();
148
+ final userX = eg.user ();
149
+ final userY = eg.user ();
150
150
151
151
final messages = [
152
- eg.streamMessage (stream: stream1 , topic: 'a ' , sender: user1, id : 100 ),
153
- eg.streamMessage (stream: stream1 , topic: 'b ' , sender: user1, id : 200 ),
154
- eg.streamMessage (stream: stream1 , topic: 'a ' , sender: user2, id : 300 ),
152
+ eg.streamMessage (stream: stream , topic: 'thing ' , sender: userX ),
153
+ eg.streamMessage (stream: stream , topic: 'other ' , sender: userX ),
154
+ eg.streamMessage (stream: stream , topic: 'thing ' , sender: userY ),
155
155
];
156
156
157
157
model.handleMessages (messages);
0 commit comments