Compare commits
	
		
			1 Commits
		
	
	
		
			f0b904f17e
			...
			a65a0469c1
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| a65a0469c1 | 
| @ -1,2 +0,0 @@ | ||||
| target/ | ||||
| .idea/ | ||||
| @ -10,4 +10,4 @@ teloxide = { version = "0.5", features = ["auto-send", "macros"] } | ||||
| log = "0.4" | ||||
| pretty_env_logger = "0.4.0" | ||||
| tokio = { version =  "1.8", features = ["rt-multi-thread", "macros"] } | ||||
| aspotify = "0.7.0" | ||||
| rspotify = { version = "0.10.0", features = ["blocking"] } | ||||
							
								
								
									
										18
									
								
								Dockerfile
									
									
									
									
									
								
							
							
						
						
									
										18
									
								
								Dockerfile
									
									
									
									
									
								
							| @ -1,18 +0,0 @@ | ||||
| FROM rust:1.55.0-bullseye as builder | ||||
| 
 | ||||
| # ENV RUSTFLAGS="-C target-feature=+crt-static" | ||||
| WORKDIR /build | ||||
| 
 | ||||
| RUN apt-get update && apt-get install -y \ | ||||
|     libssl-dev | ||||
| 
 | ||||
| COPY ./ /build | ||||
| RUN cargo build --release | ||||
| 
 | ||||
| FROM gcr.io/distroless/base | ||||
| 
 | ||||
| COPY --from=builder /build/target/release/songlify /usr/bin/songlify | ||||
| COPY --from=builder /lib/x86_64-linux-gnu/libgcc_s.so.1 /lib/x86_64-linux-gnu/ | ||||
| COPY --from=builder /usr/lib/x86_64-linux-gnu/libstdc++.so.6 /usr/lib/x86_64-linux-gnu/ | ||||
| 
 | ||||
| ENTRYPOINT /usr/bin/songlify | ||||
							
								
								
									
										32
									
								
								src/main.rs
									
									
									
									
									
								
							
							
						
						
									
										32
									
								
								src/main.rs
									
									
									
									
									
								
							| @ -1,5 +1,6 @@ | ||||
| use crate::SpotifyURL::Track; | ||||
| use aspotify::{Client, ClientCredentials}; | ||||
| use rspotify::blocking::client::Spotify; | ||||
| use rspotify::blocking::oauth2::SpotifyClientCredentials; | ||||
| use teloxide::prelude::*; | ||||
| 
 | ||||
| enum SpotifyURL { | ||||
| @ -17,16 +18,24 @@ fn get_spotify_entry(url: &str) -> Option<SpotifyURL> { | ||||
|     return None; | ||||
| } | ||||
| 
 | ||||
| fn is_spotify_url(url: &str) -> Option<&str> { | ||||
|     // https://open.spotify.com/track/0VffaI2jwQknRrxpECYHsF?si=1e16c64779744375
 | ||||
|     if url.contains("https://open.spotify.com/") { | ||||
|         return Some(url); | ||||
|     } | ||||
|     return None; | ||||
| } | ||||
| 
 | ||||
| struct TrackInfo { | ||||
|     name: String, | ||||
|     artist: Vec<String>, | ||||
| } | ||||
| 
 | ||||
| async fn get_spotify_track(spotify: Box<Client>, id: &String) -> Option<TrackInfo> { | ||||
|     match spotify.tracks().get_track(id.as_str(), None).await { | ||||
| fn get_spotify_track(spotify: Box<Spotify>, id: &String) -> Option<TrackInfo> { | ||||
|     match spotify.track(id.as_str()) { | ||||
|         Ok(track) => Some(TrackInfo { | ||||
|             name: track.data.name, | ||||
|             artist: track.data.artists.iter().map(|x| x.name.clone()).collect(), | ||||
|             name: track.name, | ||||
|             artist: track.artists.iter().map(|x| x.name.clone()).collect(), | ||||
|         }), | ||||
|         Err(_e) => None, | ||||
|     } | ||||
| @ -39,16 +48,19 @@ async fn main() { | ||||
| 
 | ||||
|     let bot = Bot::from_env().auto_send(); | ||||
|     teloxide::repl(bot, |message| async move { | ||||
|         let spotify_creds = | ||||
|             ClientCredentials::from_env().expect("CLIENT_ID and CLIENT_SECRET not found."); | ||||
|         let spotify_client = Box::new(Client::new(spotify_creds)); | ||||
|         let spotify_creds = SpotifyClientCredentials::default().build(); | ||||
|         let spotify_client = Box::new( | ||||
|             Spotify::default() | ||||
|                 .client_credentials_manager(spotify_creds) | ||||
|                 .build(), | ||||
|         ); | ||||
| 
 | ||||
|         log::info!("Connected to Spotify"); | ||||
|         let text = message.update.text().and_then(get_spotify_entry); | ||||
|         match text { | ||||
|             Some(spotify) => match spotify { | ||||
|                 Track(id) => { | ||||
|                     let track_info = get_spotify_track(spotify_client, &id).await; | ||||
|                     let track_info = get_spotify_track(spotify_client, &id); | ||||
|                     match track_info { | ||||
|                         Some(info) => { | ||||
|                             let reply = format!( | ||||
| @ -69,6 +81,4 @@ async fn main() { | ||||
|         respond(()) | ||||
|     }) | ||||
|     .await; | ||||
| 
 | ||||
|     log::info!("Exiting..."); | ||||
| } | ||||
|  | ||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user