@@ -75,13 +75,22 @@ pub async fn export_to_delimited(
7575
7676 if let ( Some ( st) , Some ( et) , Some ( interval) ) = ( start_opt, end_opt, interval_minutes) {
7777 StreamStatsRepository :: get_interpolated_stream_stats_for_export (
78- conn, None , Some ( channel_id) , st, et, interval,
78+ conn,
79+ None ,
80+ Some ( channel_id) ,
81+ st,
82+ et,
83+ interval,
7984 )
8085 . db_context ( "query interpolated stats for export" )
8186 . map_err ( |e| e. to_string ( ) )
8287 } else {
8388 StreamStatsRepository :: get_stream_stats_filtered (
84- conn, None , Some ( channel_id) , start_opt, end_opt,
89+ conn,
90+ None ,
91+ Some ( channel_id) ,
92+ start_opt,
93+ end_opt,
8594 true , // ORDER BY collected_at ASC for export
8695 )
8796 . db_context ( "query stats" )
@@ -177,13 +186,22 @@ pub async fn preview_export_data(
177186
178187 if let ( Some ( st) , Some ( et) , Some ( interval) ) = ( start_opt, end_opt, interval_minutes) {
179188 StreamStatsRepository :: get_interpolated_stream_stats_for_export (
180- conn, None , Some ( channel_id) , st, et, interval,
189+ conn,
190+ None ,
191+ Some ( channel_id) ,
192+ st,
193+ et,
194+ interval,
181195 )
182196 . db_context ( "query interpolated stats for preview" )
183197 . map_err ( |e| e. to_string ( ) )
184198 } else {
185199 StreamStatsRepository :: get_stream_stats_filtered (
186- conn, None , Some ( channel_id) , start_opt, end_opt,
200+ conn,
201+ None ,
202+ Some ( channel_id) ,
203+ start_opt,
204+ end_opt,
187205 true , // ORDER BY collected_at ASC
188206 )
189207 . db_context ( "query stats" )
0 commit comments