11use crate :: * ;
22
3- pub async fn json ( controller_data : ControllerData ) {
3+ pub async fn json ( ctx : Context ) {
44 let json: Value = json ! ( {
55 "message" : RESPONSEDATA_STR
66 } ) ;
7- let _ = controller_data
7+ let _ = ctx
88 . set_response_body ( serde_json:: to_string ( & json) . unwrap_or_default ( ) )
99 . await ;
1010}
1111
12- pub async fn plaintext ( controller_data : ControllerData ) {
13- let _ = controller_data
12+ pub async fn plaintext ( ctx : Context ) {
13+ let _ = ctx
1414 . set_response_header ( CONTENT_TYPE , TEXT_PLAIN )
1515 . await
1616 . set_response_body ( RESPONSEDATA_BIN )
1717 . await ;
1818}
1919
20- pub async fn db ( controller_data : ControllerData ) {
20+ pub async fn db ( ctx : Context ) {
2121 let db_connection: DbPoolConnection = get_db_connection ( ) . await ;
2222 let query_row: QueryRow = random_world_row ( & db_connection) . await ;
23- let _ = controller_data
23+ let _ = ctx
2424 . set_response_body ( serde_json:: to_string ( & query_row) . unwrap_or_default ( ) )
2525 . await ;
2626}
2727
28- pub async fn queries ( controller_data : ControllerData ) {
29- let queries: Queries = controller_data
28+ pub async fn queries ( ctx : Context ) {
29+ let queries: Queries = ctx
3030 . get_request_query ( "q" )
3131 . await
3232 . and_then ( |queries| queries. parse :: < Queries > ( ) . ok ( ) )
@@ -35,12 +35,12 @@ pub async fn queries(controller_data: ControllerData) {
3535 . max ( 1 ) ;
3636 let db_pool: DbPoolConnection = get_db_connection ( ) . await ;
3737 let data: Vec < QueryRow > = get_some_row_id ( queries, & db_pool) . await ;
38- let _ = controller_data
38+ let _ = ctx
3939 . set_response_body ( serde_json:: to_string ( & data) . unwrap_or_default ( ) )
4040 . await ;
4141}
4242
43- pub async fn fortunes ( controller_data : ControllerData ) {
43+ pub async fn fortunes ( ctx : Context ) {
4444 let all_rows: Vec < PgRow > = all_world_row ( ) . await ;
4545 let mut fortunes_list: Vec < Fortunes > = all_rows
4646 . iter ( )
@@ -56,29 +56,28 @@ pub async fn fortunes(controller_data: ControllerData) {
5656 ) ) ;
5757 fortunes_list. sort_by ( |it, next| it. message . cmp ( & next. message ) ) ;
5858 let res: String = FortunesTemplate :: new ( fortunes_list) . to_string ( ) ;
59- controller_data
60- . set_response_header ( CONTENT_TYPE , content_type_charset ( TEXT_HTML , UTF8 ) )
59+ ctx. set_response_header ( CONTENT_TYPE , content_type_charset ( TEXT_HTML , UTF8 ) )
6160 . await
6261 . set_response_body ( res)
6362 . await ;
6463}
6564
66- pub async fn updates ( controller_data : ControllerData ) {
67- let queries: Queries = controller_data
65+ pub async fn updates ( ctx : Context ) {
66+ let queries: Queries = ctx
6867 . get_request_query ( "q" )
6968 . await
7069 . and_then ( |queries| queries. parse :: < Queries > ( ) . ok ( ) )
7170 . unwrap_or_default ( )
7271 . min ( ROW_LIMIT as Queries )
7372 . max ( 1 ) ;
7473 let res: Vec < QueryRow > = update_world_rows ( queries) . await ;
75- let _ = controller_data
74+ let _ = ctx
7675 . set_response_body ( serde_json:: to_string ( & res) . unwrap_or_default ( ) )
7776 . await ;
7877}
7978
80- pub async fn cached_queries ( controller_data : ControllerData ) {
81- let count: Queries = controller_data
79+ pub async fn cached_queries ( ctx : Context ) {
80+ let count: Queries = ctx
8281 . get_request_query ( "c" )
8382 . await
8483 . and_then ( |queries| queries. parse :: < Queries > ( ) . ok ( ) )
@@ -92,7 +91,7 @@ pub async fn cached_queries(controller_data: ControllerData) {
9291 . take ( count as usize )
9392 . cloned ( )
9493 . collect ( ) ;
95- let _ = controller_data
94+ let _ = ctx
9695 . set_response_body ( serde_json:: to_string ( & res) . unwrap_or_default ( ) )
9796 . await ;
9897}
0 commit comments