feat: add support for openid

Closes #36

Author: imLinguin

proto

@@ -12,13 +12,16 @@ pub mod structs {
         pub refresh_token: String,
         #[serde(skip, default = "Utc::now")]
         pub obtain_time: DateTime<Utc>,
+        #[serde(default)]
+        pub scope: String
     }
     impl Token {
         pub fn new(access_token: String, refresh_token: String) -> Self {
             Self {
                 access_token,
                 refresh_token,
                 obtain_time: Utc::now(),
+                scope: String::new()
             }
         }
     }

src/api.rs

@@ -7,6 +7,7 @@ pub async fn get_token_for(
     client_secret: &str,
     refresh_token: &str,
     session: &Client,
+    openid: bool,
 ) -> Result<Token, Error> {
     let mut url = reqwest::Url::parse(
         "https://auth.gog.com/token?grant_type=refresh_token&without_new_session=1",
@@ -17,6 +18,10 @@ pub async fn get_token_for(
         .append_pair("client_secret", client_secret)
         .append_pair("refresh_token", refresh_token);
 
+    if openid {
+        url.query_pairs_mut().append_pair("scope", "openid");
+    }
+
     let result = session
         .get(url)
         .timeout(time::Duration::from_secs(10))

src/api/gog/users.rs

@@ -180,6 +180,7 @@ async fn sync_routine(
                 client_secret,
                 &token.refresh_token,
                 reqwest_client,
+                !token.scope.is_empty()
             )
             .await;
             match result {

src/api/handlers.rs

@@ -132,6 +132,8 @@ async fn auth_info_request(
 
     let client_id = request_data.client_id();
     let client_secret = request_data.client_secret();
+    let openid = request_data.openid();
+
     if !context.client_identified() {
         context.identify_client(client_id, client_secret);
         info!("Client identified as {} {}", client_id, client_secret);
@@ -153,6 +155,7 @@ async fn auth_info_request(
         client_secret,
         refresh_token.as_str(),
         reqwest_client,
+        openid,
     )
     .await;
 

src/api/handlers/communication_service.rs

@@ -70,6 +70,9 @@ impl HandlerContext {
         client_id: &str,
         user_id: &str,
     ) -> Result<(), sqlx::Error> {
+        if self.db_connected {
+            return Ok(());
+        }
         let connection = db::gameplay::setup_connection(client_id, user_id).await?;
         self.db_connection = Some(connection);
 

src/api/handlers/context.rs

@@ -280,6 +280,7 @@ impl NotificationPusherClient {
                         }
                     } else if msg_type == MessageType::MESSAGE_FROM_TOPIC.value() {
                         info!("Recieved message from topic");
+                        log::debug!("Topic message: {:#?}", String::from_utf8_lossy(&msg_data));
                         if let Err(error) = self.topic_sender.send(PusherEvent::Topic(msg_data)) {
                             error!(
                                 "There was an error when forwarding topic message: {}",

src/api/notification_pusher.rs

@@ -169,6 +169,7 @@ async fn main() {
                         &client_secret,
                         &refresh_token,
                         &reqwest_client,
+                        false
                     )
                     .await
                     .expect("Failed to obtain credentials");