File tree 2 files changed +11
-2
lines changed
2 files changed +11
-2
lines changed Original file line number Diff line number Diff line change @@ -59,6 +59,7 @@ class GetDataType {
59
59
}
60
60
61
61
class GetQuery {
62
+ String ? topic;
62
63
bool ? cred;
63
64
bool ? tags;
64
65
String ? what;
@@ -68,6 +69,7 @@ class GetQuery {
68
69
GetDataType ? del;
69
70
70
71
GetQuery ({
72
+ this .topic,
71
73
this .desc,
72
74
this .sub,
73
75
this .data,
@@ -79,6 +81,7 @@ class GetQuery {
79
81
80
82
static GetQuery fromMessage (Map <String , dynamic > msg) {
81
83
return GetQuery (
84
+ topic: msg['topic' ],
82
85
cred: msg['cred' ],
83
86
what: msg['what' ],
84
87
data: msg['data' ] != null ? GetDataType .fromMessage (msg['data' ]) : null ,
@@ -91,6 +94,7 @@ class GetQuery {
91
94
92
95
Map <String , dynamic > toMap () {
93
96
var map = {
97
+ 'topic' : topic,
94
98
'cred' : cred,
95
99
'what' : what,
96
100
'data' : data != null ? data? .toMap () : null ,
Original file line number Diff line number Diff line change @@ -710,8 +710,13 @@ class Topic {
710
710
/// Process data message
711
711
void routeData (DataMessage data) {
712
712
if (data.content != null ) {
713
- if (touched! .isBefore (data.ts! )) {
714
- touched = data.ts;
713
+ if (touched == null ) {
714
+ touched= data.ts;
715
+ }
716
+ else {
717
+ if (touched! .isBefore (data.ts! )) {
718
+ touched = data.ts;
719
+ }
715
720
}
716
721
}
717
722
You can’t perform that action at this time.
0 commit comments