@@ -77,25 +77,21 @@ fn get_initial_data_from_db(
77
77
room_id : & str ,
78
78
max_state_group : Option < i64 > ,
79
79
) -> BTreeMap < i64 , StateGroupEntry > {
80
- let sql = format ! (
81
- r#"
80
+ let sql = r#"
82
81
SELECT m.id, prev_state_group, type, state_key, s.event_id
83
82
FROM state_groups AS m
84
83
LEFT JOIN state_groups_state AS s ON (m.id = s.state_group)
85
84
LEFT JOIN state_group_edges AS e ON (m.id = e.state_group)
86
- WHERE m.room_id = $1 {}
87
- "# ,
88
- if max_state_group. is_some( ) {
89
- "AND m.id <= $2"
90
- } else {
91
- ""
92
- }
93
- ) ;
85
+ WHERE m.room_id = $1
86
+ "# ;
94
87
95
88
let mut rows = if let Some ( s) = max_state_group {
96
- client. query_raw ( & sql[ ..] , vec ! [ & room_id as _, & s as _] )
89
+ client. query_raw (
90
+ format ! ( r"{} AND m.id <= $2" , sql) . as_str ( ) ,
91
+ vec ! [ & room_id as _, & s as _] ,
92
+ )
97
93
} else {
98
- client. query_raw ( & sql[ .. ] , iter:: once ( & room_id as _ ) )
94
+ client. query_raw ( sql, iter:: once ( & room_id as _ ) )
99
95
}
100
96
. unwrap ( ) ;
101
97
@@ -109,14 +105,11 @@ fn get_initial_data_from_db(
109
105
110
106
let mut num_rows = 0 ;
111
107
while let Some ( row) = rows. next ( ) . unwrap ( ) {
112
- let state_group = row. get ( 0 ) ;
113
-
114
- let entry = state_group_map. entry ( state_group) . or_default ( ) ;
108
+ let entry = state_group_map. entry ( row. get ( 0 ) ) . or_default ( ) ;
115
109
116
110
entry. prev_state_group = row. get ( 1 ) ;
117
- let etype: Option < String > = row. get ( 2 ) ;
118
111
119
- if let Some ( etype) = etype {
112
+ if let Some ( etype) = row . get :: < _ , Option < String > > ( 2 ) {
120
113
entry. state_map . insert (
121
114
& etype,
122
115
& row. get :: < _ , String > ( 3 ) ,
0 commit comments