run cargo fmt · tsiry-sandratraina.com/tunein-cli@40c0008

+14

.tangled/workflows/fmt.yml

··· 1 + when: 2 + - event: ["push", "pull_request"] 3 + branch: ["main"] 4 + 5 + dependencies: 6 + nixpkgs: 7 + - cargo 8 + - rustc 9 + - rustfmt 10 + 11 + steps: 12 + - name: "cargo fmt" 13 + command: | 14 + cargo fmt --all --check

+125 -235

src/api/tunein.v1alpha1.rs

··· 39 39 #[derive(Clone, PartialEq, ::prost::Message)] 40 40 pub struct GetStationDetailsResponse { 41 41 #[prost(message, optional, tag = "1")] 42 - pub station_link_details: ::core::option::Option< 43 - super::super::objects::v1alpha1::StationLinkDetails, 44 - >, 42 + pub station_link_details: 43 + ::core::option::Option<super::super::objects::v1alpha1::StationLinkDetails>, 45 44 } 46 45 #[derive(Clone, PartialEq, ::prost::Message)] 47 46 pub struct SearchRequest { ··· 62 61 dead_code, 63 62 missing_docs, 64 63 clippy::wildcard_imports, 65 - clippy::let_unit_value, 64 + clippy::let_unit_value 66 65 )] 67 - use tonic::codegen::*; 68 66 use tonic::codegen::http::Uri; 67 + use tonic::codegen::*; 69 68 #[derive(Debug, Clone)] 70 69 pub struct BrowseServiceClient<T> { 71 70 inner: tonic::client::Grpc<T>, ··· 109 108 <T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody, 110 109 >, 111 110 >, 112 - <T as tonic::codegen::Service< 113 - http::Request<tonic::body::BoxBody>, 114 - >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync, 111 + <T as tonic::codegen::Service<http::Request<tonic::body::BoxBody>>>::Error: 112 + Into<StdError> + std::marker::Send + std::marker::Sync, 115 113 { 116 114 BrowseServiceClient::new(InterceptedService::new(inner, interceptor)) 117 115 } ··· 149 147 pub async fn get_categories( 150 148 &mut self, 151 149 request: impl tonic::IntoRequest<super::GetCategoriesRequest>, 152 - ) -> std::result::Result< 153 - tonic::Response<super::GetCategoriesResponse>, 154 - tonic::Status, 155 - > { 156 - self.inner 157 - .ready() 158 - .await 159 - .map_err(|e| { 160 - tonic::Status::unknown( 161 - format!("Service was not ready: {}", e.into()), 162 - ) 163 - })?; 150 + ) -> std::result::Result<tonic::Response<super::GetCategoriesResponse>, tonic::Status> 151 + { 152 + self.inner.ready().await.map_err(|e| { 153 + tonic::Status::unknown(format!("Service was not ready: {}", e.into())) 154 + })?; 164 155 let codec = tonic::codec::ProstCodec::default(); 165 156 let path = http::uri::PathAndQuery::from_static( 166 157 "/tunein.v1alpha1.BrowseService/GetCategories", 167 158 ); 168 159 let mut req = request.into_request(); 169 - req.extensions_mut() 170 - .insert( 171 - GrpcMethod::new("tunein.v1alpha1.BrowseService", "GetCategories"), 172 - ); 160 + req.extensions_mut().insert(GrpcMethod::new( 161 + "tunein.v1alpha1.BrowseService", 162 + "GetCategories", 163 + )); 173 164 self.inner.unary(req, path, codec).await 174 165 } 175 166 pub async fn browse_category( 176 167 &mut self, 177 168 request: impl tonic::IntoRequest<super::BrowseCategoryRequest>, 178 - ) -> std::result::Result< 179 - tonic::Response<super::BrowseCategoryResponse>, 180 - tonic::Status, 181 - > { 182 - self.inner 183 - .ready() 184 - .await 185 - .map_err(|e| { 186 - tonic::Status::unknown( 187 - format!("Service was not ready: {}", e.into()), 188 - ) 189 - })?; 169 + ) -> std::result::Result<tonic::Response<super::BrowseCategoryResponse>, tonic::Status> 170 + { 171 + self.inner.ready().await.map_err(|e| { 172 + tonic::Status::unknown(format!("Service was not ready: {}", e.into())) 173 + })?; 190 174 let codec = tonic::codec::ProstCodec::default(); 191 175 let path = http::uri::PathAndQuery::from_static( 192 176 "/tunein.v1alpha1.BrowseService/BrowseCategory", 193 177 ); 194 178 let mut req = request.into_request(); 195 - req.extensions_mut() 196 - .insert( 197 - GrpcMethod::new("tunein.v1alpha1.BrowseService", "BrowseCategory"), 198 - ); 179 + req.extensions_mut().insert(GrpcMethod::new( 180 + "tunein.v1alpha1.BrowseService", 181 + "BrowseCategory", 182 + )); 199 183 self.inner.unary(req, path, codec).await 200 184 } 201 185 pub async fn get_station_details( 202 186 &mut self, 203 187 request: impl tonic::IntoRequest<super::GetStationDetailsRequest>, 204 - ) -> std::result::Result< 205 - tonic::Response<super::GetStationDetailsResponse>, 206 - tonic::Status, 207 - > { 208 - self.inner 209 - .ready() 210 - .await 211 - .map_err(|e| { 212 - tonic::Status::unknown( 213 - format!("Service was not ready: {}", e.into()), 214 - ) 215 - })?; 188 + ) -> std::result::Result<tonic::Response<super::GetStationDetailsResponse>, tonic::Status> 189 + { 190 + self.inner.ready().await.map_err(|e| { 191 + tonic::Status::unknown(format!("Service was not ready: {}", e.into())) 192 + })?; 216 193 let codec = tonic::codec::ProstCodec::default(); 217 194 let path = http::uri::PathAndQuery::from_static( 218 195 "/tunein.v1alpha1.BrowseService/GetStationDetails", 219 196 ); 220 197 let mut req = request.into_request(); 221 - req.extensions_mut() 222 - .insert( 223 - GrpcMethod::new("tunein.v1alpha1.BrowseService", "GetStationDetails"), 224 - ); 198 + req.extensions_mut().insert(GrpcMethod::new( 199 + "tunein.v1alpha1.BrowseService", 200 + "GetStationDetails", 201 + )); 225 202 self.inner.unary(req, path, codec).await 226 203 } 227 204 pub async fn search( 228 205 &mut self, 229 206 request: impl tonic::IntoRequest<super::SearchRequest>, 230 207 ) -> std::result::Result<tonic::Response<super::SearchResponse>, tonic::Status> { 231 - self.inner 232 - .ready() 233 - .await 234 - .map_err(|e| { 235 - tonic::Status::unknown( 236 - format!("Service was not ready: {}", e.into()), 237 - ) 238 - })?; 208 + self.inner.ready().await.map_err(|e| { 209 + tonic::Status::unknown(format!("Service was not ready: {}", e.into())) 210 + })?; 239 211 let codec = tonic::codec::ProstCodec::default(); 240 - let path = http::uri::PathAndQuery::from_static( 241 - "/tunein.v1alpha1.BrowseService/Search", 242 - ); 212 + let path = 213 + http::uri::PathAndQuery::from_static("/tunein.v1alpha1.BrowseService/Search"); 243 214 let mut req = request.into_request(); 244 215 req.extensions_mut() 245 216 .insert(GrpcMethod::new("tunein.v1alpha1.BrowseService", "Search")); ··· 254 225 dead_code, 255 226 missing_docs, 256 227 clippy::wildcard_imports, 257 - clippy::let_unit_value, 228 + clippy::let_unit_value 258 229 )] 259 230 use tonic::codegen::*; 260 231 /// Generated trait containing gRPC methods that should be implemented for use with BrowseServiceServer. ··· 263 234 async fn get_categories( 264 235 &self, 265 236 request: tonic::Request<super::GetCategoriesRequest>, 266 - ) -> std::result::Result< 267 - tonic::Response<super::GetCategoriesResponse>, 268 - tonic::Status, 269 - >; 237 + ) -> std::result::Result<tonic::Response<super::GetCategoriesResponse>, tonic::Status>; 270 238 async fn browse_category( 271 239 &self, 272 240 request: tonic::Request<super::BrowseCategoryRequest>, 273 - ) -> std::result::Result< 274 - tonic::Response<super::BrowseCategoryResponse>, 275 - tonic::Status, 276 - >; 241 + ) -> std::result::Result<tonic::Response<super::BrowseCategoryResponse>, tonic::Status>; 277 242 async fn get_station_details( 278 243 &self, 279 244 request: tonic::Request<super::GetStationDetailsRequest>, 280 - ) -> std::result::Result< 281 - tonic::Response<super::GetStationDetailsResponse>, 282 - tonic::Status, 283 - >; 245 + ) -> std::result::Result<tonic::Response<super::GetStationDetailsResponse>, tonic::Status>; 284 246 async fn search( 285 247 &self, 286 248 request: tonic::Request<super::SearchRequest>, ··· 307 269 max_encoding_message_size: None, 308 270 } 309 271 } 310 - pub fn with_interceptor<F>( 311 - inner: T, 312 - interceptor: F, 313 - ) -> InterceptedService<Self, F> 272 + pub fn with_interceptor<F>(inner: T, interceptor: F) -> InterceptedService<Self, F> 314 273 where 315 274 F: tonic::service::Interceptor, 316 275 { ··· 365 324 "/tunein.v1alpha1.BrowseService/GetCategories" => { 366 325 #[allow(non_camel_case_types)] 367 326 struct GetCategoriesSvc<T: BrowseService>(pub Arc<T>); 368 - impl< 369 - T: BrowseService, 370 - > tonic::server::UnaryService<super::GetCategoriesRequest> 371 - for GetCategoriesSvc<T> { 327 + impl<T: BrowseService> tonic::server::UnaryService<super::GetCategoriesRequest> 328 + for GetCategoriesSvc<T> 329 + { 372 330 type Response = super::GetCategoriesResponse; 373 - type Future = BoxFuture< 374 - tonic::Response<Self::Response>, 375 - tonic::Status, 376 - >; 331 + type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>; 377 332 fn call( 378 333 &mut self, 379 334 request: tonic::Request<super::GetCategoriesRequest>, ··· 410 365 "/tunein.v1alpha1.BrowseService/BrowseCategory" => { 411 366 #[allow(non_camel_case_types)] 412 367 struct BrowseCategorySvc<T: BrowseService>(pub Arc<T>); 413 - impl< 414 - T: BrowseService, 415 - > tonic::server::UnaryService<super::BrowseCategoryRequest> 416 - for BrowseCategorySvc<T> { 368 + impl<T: BrowseService> tonic::server::UnaryService<super::BrowseCategoryRequest> 369 + for BrowseCategorySvc<T> 370 + { 417 371 type Response = super::BrowseCategoryResponse; 418 - type Future = BoxFuture< 419 - tonic::Response<Self::Response>, 420 - tonic::Status, 421 - >; 372 + type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>; 422 373 fn call( 423 374 &mut self, 424 375 request: tonic::Request<super::BrowseCategoryRequest>, ··· 455 406 "/tunein.v1alpha1.BrowseService/GetStationDetails" => { 456 407 #[allow(non_camel_case_types)] 457 408 struct GetStationDetailsSvc<T: BrowseService>(pub Arc<T>); 458 - impl< 459 - T: BrowseService, 460 - > tonic::server::UnaryService<super::GetStationDetailsRequest> 461 - for GetStationDetailsSvc<T> { 409 + impl<T: BrowseService> 410 + tonic::server::UnaryService<super::GetStationDetailsRequest> 411 + for GetStationDetailsSvc<T> 412 + { 462 413 type Response = super::GetStationDetailsResponse; 463 - type Future = BoxFuture< 464 - tonic::Response<Self::Response>, 465 - tonic::Status, 466 - >; 414 + type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>; 467 415 fn call( 468 416 &mut self, 469 417 request: tonic::Request<super::GetStationDetailsRequest>, 470 418 ) -> Self::Future { 471 419 let inner = Arc::clone(&self.0); 472 420 let fut = async move { 473 - <T as BrowseService>::get_station_details(&inner, request) 474 - .await 421 + <T as BrowseService>::get_station_details(&inner, request).await 475 422 }; 476 423 Box::pin(fut) 477 424 } ··· 501 448 "/tunein.v1alpha1.BrowseService/Search" => { 502 449 #[allow(non_camel_case_types)] 503 450 struct SearchSvc<T: BrowseService>(pub Arc<T>); 504 - impl< 505 - T: BrowseService, 506 - > tonic::server::UnaryService<super::SearchRequest> 507 - for SearchSvc<T> { 451 + impl<T: BrowseService> tonic::server::UnaryService<super::SearchRequest> for SearchSvc<T> { 508 452 type Response = super::SearchResponse; 509 - type Future = BoxFuture< 510 - tonic::Response<Self::Response>, 511 - tonic::Status, 512 - >; 453 + type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>; 513 454 fn call( 514 455 &mut self, 515 456 request: tonic::Request<super::SearchRequest>, 516 457 ) -> Self::Future { 517 458 let inner = Arc::clone(&self.0); 518 - let fut = async move { 519 - <T as BrowseService>::search(&inner, request).await 520 - }; 459 + let fut = 460 + async move { <T as BrowseService>::search(&inner, request).await }; 521 461 Box::pin(fut) 522 462 } 523 463 } ··· 543 483 }; 544 484 Box::pin(fut) 545 485 } 546 - _ => { 547 - Box::pin(async move { 548 - let mut response = http::Response::new(empty_body()); 549 - let headers = response.headers_mut(); 550 - headers 551 - .insert( 552 - tonic::Status::GRPC_STATUS, 553 - (tonic::Code::Unimplemented as i32).into(), 554 - ); 555 - headers 556 - .insert( 557 - http::header::CONTENT_TYPE, 558 - tonic::metadata::GRPC_CONTENT_TYPE, 559 - ); 560 - Ok(response) 561 - }) 562 - } 486 + _ => Box::pin(async move { 487 + let mut response = http::Response::new(empty_body()); 488 + let headers = response.headers_mut(); 489 + headers.insert( 490 + tonic::Status::GRPC_STATUS, 491 + (tonic::Code::Unimplemented as i32).into(), 492 + ); 493 + headers.insert( 494 + http::header::CONTENT_TYPE, 495 + tonic::metadata::GRPC_CONTENT_TYPE, 496 + ); 497 + Ok(response) 498 + }), 563 499 } 564 500 } 565 501 } ··· 605 541 dead_code, 606 542 missing_docs, 607 543 clippy::wildcard_imports, 608 - clippy::let_unit_value, 544 + clippy::let_unit_value 609 545 )] 610 - use tonic::codegen::*; 611 546 use tonic::codegen::http::Uri; 547 + use tonic::codegen::*; 612 548 #[derive(Debug, Clone)] 613 549 pub struct PlaybackServiceClient<T> { 614 550 inner: tonic::client::Grpc<T>, ··· 652 588 <T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody, 653 589 >, 654 590 >, 655 - <T as tonic::codegen::Service< 656 - http::Request<tonic::body::BoxBody>, 657 - >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync, 591 + <T as tonic::codegen::Service<http::Request<tonic::body::BoxBody>>>::Error: 592 + Into<StdError> + std::marker::Send + std::marker::Sync, 658 593 { 659 594 PlaybackServiceClient::new(InterceptedService::new(inner, interceptor)) 660 595 } ··· 693 628 &mut self, 694 629 request: impl tonic::IntoRequest<super::PlayRequest>, 695 630 ) -> std::result::Result<tonic::Response<super::PlayResponse>, tonic::Status> { 696 - self.inner 697 - .ready() 698 - .await 699 - .map_err(|e| { 700 - tonic::Status::unknown( 701 - format!("Service was not ready: {}", e.into()), 702 - ) 703 - })?; 631 + self.inner.ready().await.map_err(|e| { 632 + tonic::Status::unknown(format!("Service was not ready: {}", e.into())) 633 + })?; 704 634 let codec = tonic::codec::ProstCodec::default(); 705 - let path = http::uri::PathAndQuery::from_static( 706 - "/tunein.v1alpha1.PlaybackService/Play", 707 - ); 635 + let path = 636 + http::uri::PathAndQuery::from_static("/tunein.v1alpha1.PlaybackService/Play"); 708 637 let mut req = request.into_request(); 709 638 req.extensions_mut() 710 639 .insert(GrpcMethod::new("tunein.v1alpha1.PlaybackService", "Play")); ··· 714 643 &mut self, 715 644 request: impl tonic::IntoRequest<super::StopRequest>, 716 645 ) -> std::result::Result<tonic::Response<super::StopResponse>, tonic::Status> { 717 - self.inner 718 - .ready() 719 - .await 720 - .map_err(|e| { 721 - tonic::Status::unknown( 722 - format!("Service was not ready: {}", e.into()), 723 - ) 724 - })?; 646 + self.inner.ready().await.map_err(|e| { 647 + tonic::Status::unknown(format!("Service was not ready: {}", e.into())) 648 + })?; 725 649 let codec = tonic::codec::ProstCodec::default(); 726 - let path = http::uri::PathAndQuery::from_static( 727 - "/tunein.v1alpha1.PlaybackService/Stop", 728 - ); 650 + let path = 651 + http::uri::PathAndQuery::from_static("/tunein.v1alpha1.PlaybackService/Stop"); 729 652 let mut req = request.into_request(); 730 653 req.extensions_mut() 731 654 .insert(GrpcMethod::new("tunein.v1alpha1.PlaybackService", "Stop")); ··· 734 657 pub async fn play_or_pause( 735 658 &mut self, 736 659 request: impl tonic::IntoRequest<super::PlayOrPauseRequest>, 737 - ) -> std::result::Result< 738 - tonic::Response<super::PlayOrPauseResponse>, 739 - tonic::Status, 740 - > { 741 - self.inner 742 - .ready() 743 - .await 744 - .map_err(|e| { 745 - tonic::Status::unknown( 746 - format!("Service was not ready: {}", e.into()), 747 - ) 748 - })?; 660 + ) -> std::result::Result<tonic::Response<super::PlayOrPauseResponse>, tonic::Status> 661 + { 662 + self.inner.ready().await.map_err(|e| { 663 + tonic::Status::unknown(format!("Service was not ready: {}", e.into())) 664 + })?; 749 665 let codec = tonic::codec::ProstCodec::default(); 750 666 let path = http::uri::PathAndQuery::from_static( 751 667 "/tunein.v1alpha1.PlaybackService/PlayOrPause", 752 668 ); 753 669 let mut req = request.into_request(); 754 - req.extensions_mut() 755 - .insert( 756 - GrpcMethod::new("tunein.v1alpha1.PlaybackService", "PlayOrPause"), 757 - ); 670 + req.extensions_mut().insert(GrpcMethod::new( 671 + "tunein.v1alpha1.PlaybackService", 672 + "PlayOrPause", 673 + )); 758 674 self.inner.unary(req, path, codec).await 759 675 } 760 676 } ··· 766 682 dead_code, 767 683 missing_docs, 768 684 clippy::wildcard_imports, 769 - clippy::let_unit_value, 685 + clippy::let_unit_value 770 686 )] 771 687 use tonic::codegen::*; 772 688 /// Generated trait containing gRPC methods that should be implemented for use with PlaybackServiceServer. ··· 783 699 async fn play_or_pause( 784 700 &self, 785 701 request: tonic::Request<super::PlayOrPauseRequest>, 786 - ) -> std::result::Result< 787 - tonic::Response<super::PlayOrPauseResponse>, 788 - tonic::Status, 789 - >; 702 + ) -> std::result::Result<tonic::Response<super::PlayOrPauseResponse>, tonic::Status>; 790 703 } 791 704 #[derive(Debug)] 792 705 pub struct PlaybackServiceServer<T> { ··· 809 722 max_encoding_message_size: None, 810 723 } 811 724 } 812 - pub fn with_interceptor<F>( 813 - inner: T, 814 - interceptor: F, 815 - ) -> InterceptedService<Self, F> 725 + pub fn with_interceptor<F>(inner: T, interceptor: F) -> InterceptedService<Self, F> 816 726 where 817 727 F: tonic::service::Interceptor, 818 728 { ··· 867 777 "/tunein.v1alpha1.PlaybackService/Play" => { 868 778 #[allow(non_camel_case_types)] 869 779 struct PlaySvc<T: PlaybackService>(pub Arc<T>); 870 - impl< 871 - T: PlaybackService, 872 - > tonic::server::UnaryService<super::PlayRequest> for PlaySvc<T> { 780 + impl<T: PlaybackService> tonic::server::UnaryService<super::PlayRequest> for PlaySvc<T> { 873 781 type Response = super::PlayResponse; 874 - type Future = BoxFuture< 875 - tonic::Response<Self::Response>, 876 - tonic::Status, 877 - >; 782 + type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>; 878 783 fn call( 879 784 &mut self, 880 785 request: tonic::Request<super::PlayRequest>, 881 786 ) -> Self::Future { 882 787 let inner = Arc::clone(&self.0); 883 - let fut = async move { 884 - <T as PlaybackService>::play(&inner, request).await 885 - }; 788 + let fut = 789 + async move { <T as PlaybackService>::play(&inner, request).await }; 886 790 Box::pin(fut) 887 791 } 888 792 } ··· 911 815 "/tunein.v1alpha1.PlaybackService/Stop" => { 912 816 #[allow(non_camel_case_types)] 913 817 struct StopSvc<T: PlaybackService>(pub Arc<T>); 914 - impl< 915 - T: PlaybackService, 916 - > tonic::server::UnaryService<super::StopRequest> for StopSvc<T> { 818 + impl<T: PlaybackService> tonic::server::UnaryService<super::StopRequest> for StopSvc<T> { 917 819 type Response = super::StopResponse; 918 - type Future = BoxFuture< 919 - tonic::Response<Self::Response>, 920 - tonic::Status, 921 - >; 820 + type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>; 922 821 fn call( 923 822 &mut self, 924 823 request: tonic::Request<super::StopRequest>, 925 824 ) -> Self::Future { 926 825 let inner = Arc::clone(&self.0); 927 - let fut = async move { 928 - <T as PlaybackService>::stop(&inner, request).await 929 - }; 826 + let fut = 827 + async move { <T as PlaybackService>::stop(&inner, request).await }; 930 828 Box::pin(fut) 931 829 } 932 830 } ··· 955 853 "/tunein.v1alpha1.PlaybackService/PlayOrPause" => { 956 854 #[allow(non_camel_case_types)] 957 855 struct PlayOrPauseSvc<T: PlaybackService>(pub Arc<T>); 958 - impl< 959 - T: PlaybackService, 960 - > tonic::server::UnaryService<super::PlayOrPauseRequest> 961 - for PlayOrPauseSvc<T> { 856 + impl<T: PlaybackService> tonic::server::UnaryService<super::PlayOrPauseRequest> 857 + for PlayOrPauseSvc<T> 858 + { 962 859 type Response = super::PlayOrPauseResponse; 963 - type Future = BoxFuture< 964 - tonic::Response<Self::Response>, 965 - tonic::Status, 966 - >; 860 + type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>; 967 861 fn call( 968 862 &mut self, 969 863 request: tonic::Request<super::PlayOrPauseRequest>, ··· 997 891 }; 998 892 Box::pin(fut) 999 893 } 1000 - _ => { 1001 - Box::pin(async move { 1002 - let mut response = http::Response::new(empty_body()); 1003 - let headers = response.headers_mut(); 1004 - headers 1005 - .insert( 1006 - tonic::Status::GRPC_STATUS, 1007 - (tonic::Code::Unimplemented as i32).into(), 1008 - ); 1009 - headers 1010 - .insert( 1011 - http::header::CONTENT_TYPE, 1012 - tonic::metadata::GRPC_CONTENT_TYPE, 1013 - ); 1014 - Ok(response) 1015 - }) 1016 - } 894 + _ => Box::pin(async move { 895 + let mut response = http::Response::new(empty_body()); 896 + let headers = response.headers_mut(); 897 + headers.insert( 898 + tonic::Status::GRPC_STATUS, 899 + (tonic::Code::Unimplemented as i32).into(), 900 + ); 901 + headers.insert( 902 + http::header::CONTENT_TYPE, 903 + tonic::metadata::GRPC_CONTENT_TYPE, 904 + ); 905 + Ok(response) 906 + }), 1017 907 } 1018 908 } 1019 909 }

+4 -1

src/extract.rs

··· 55 55 56 56 pub async fn get_currently_playing(station: &str) -> Result<String, Error> { 57 57 let client = Client::new(); 58 - let url = format!("https://feed.tunein.com/profiles/{}/nowPlaying?partnerId=RadioTime", station); 58 + let url = format!( 59 + "https://feed.tunein.com/profiles/{}/nowPlaying?partnerId=RadioTime", 60 + station 61 + ); 59 62 let response: NowPlaying = client 60 63 .get(Url::parse(&url)?) 61 64 .recv_json()

Configure Feed

Configure Feed