Merge pull request #1 from Ringrev/main

update from stream

Author: osain-az

examples/seed/src/instagram.rs

@@ -75,7 +75,8 @@ enum Msg {
     ConfigFetched(fetch::Result<Config>),
     GetAccount,
     GetAccountSuccess(Data<Accounts>),
-
+    GetMeDetails,
+    GetMeDetailsSuccess(Me),
     AccessTokenInformation,
     AccessTokenInfoData(AccessTokenInformation),
 
@@ -95,6 +96,7 @@ fn update(msg: Msg, model: &mut Model, orders: &mut impl Orders<Msg>) {
         Msg::ConfigFetched(Err(fetch_error)) => error!("Config fetch failed! Be sure to have config.json at the root of your project with client_id and redirect_uri", fetch_error),
 
         Msg::GetAccount => {
+            orders.send_msg(Msg::GetMeDetails);
             if let Some(user_access_tokens) = model.user_tokens.clone() {
                 let user_tokens = user_access_tokens;
                 let client = Client::new(user_tokens, "".to_string());
@@ -111,6 +113,26 @@ fn update(msg: Msg, model: &mut Model, orders: &mut impl Orders<Msg>) {
             }
         }
 
+        Msg::GetMeDetails => {
+            if let Some(user_access_tokens) = model.user_tokens.clone() {
+                let user_tokens = user_access_tokens;
+                let user_token = user_tokens.long_lived_token.clone();
+                let client = Client::new(user_tokens, "".to_string());
+                orders.perform_cmd(async {
+                    // we are interested in the page long live token, therefore we called the long
+                    // live methed by passing "long_live_token" to the method
+                    client
+                        .me_by_short_or_long_live_token("short_live".to_string())
+                        .details()
+                        .await
+                        .map_or_else(Msg::ResponseFailed, Msg::GetMeDetailsSuccess)
+                });
+            }
+        }
+        Msg:: GetMeDetailsSuccess(resp) => {
+
+        }
+
         Msg:: GetAccountSuccess(accounts) => {
             model.accounts = Some(accounts.clone());
             model.facebook.accounts= Some(accounts.clone());

examples/seed/src/lib.rs

@@ -11,6 +11,7 @@ use crate::prelude::search::PagesSearchAPI;
 use crate::prelude::video::VideoApi;
 use seed::{prelude::*, *};
 use std::option::Option::Some;
+use crate::graph::instagram::media::InstagramMediaApi;
 
 /// Client Struct for making calls to Facebook Graph
 #[derive(Debug)]
@@ -30,6 +31,7 @@ pub struct Client {
 impl Default for Client {
     fn default() -> Self {
         let graph = "https://graph.facebook.com/v11.0/NODE/EDGE".to_string();
+      //  let insta_graph = "https://graph.instagram.com/v11.0/NODE/EDGE".to_string();
 
         Self {
             graph,
@@ -70,6 +72,10 @@ impl Client {
         self
     }
 
+    pub fn base_url (self) -> String{
+     self.graph
+}
+
     /// This method  is used to pass user data/crediteniatls to the ME method
     /// which will be used to reach the ME API.
     /// since facebbok allows two access token ( short and long live )  to used
@@ -126,12 +132,18 @@ impl Client {
         InstagramApi::new(self.page_access_token, base_url)
     }
 
-    pub fn instagram(self, instagarm_id: String) -> InstagramPostApi {
-        let base_url = self.graph.replace("NODE", &instagarm_id);
+    pub fn instagram_publish(self, instagram_id: String) -> InstagramPostApi {
+        let base_url = self.graph.replace("NODE", &instagram_id);
 
         InstagramPostApi::new(self.page_access_token, base_url)
     }
 
+    pub fn instagram_media_container(self, media_container_id: String) -> InstagramMediaApi{
+        let base_url = self.graph.replace("NODE", &media_container_id);
+
+        InstagramMediaApi::new(self.page_access_token, base_url)
+    }
+
     pub fn search_pages(self) -> PagesSearchAPI {
         let base_url = self.graph.replace("NODE/EDGE", "pages/search");
         PagesSearchAPI::new(base_url, self.page_access_token)

src/graph/client.rs

@@ -1,8 +1,12 @@
+//! This Api is used to get instagram business account for any given facebook page
+//! <https://developers.facebook.com/docs/instagram-api/reference/page>
+
 use seed::fetch::fetch;
 use seed::prelude::{Method, Request};
-
 use seed::{prelude::*, *};
 use serde::{Deserialize, Serialize};
+use seed::prelude::js_sys::encode_uri;
+use urlencoding::encode;
 
 #[derive(Deserialize, Clone, Debug, Serialize)]
 pub struct InstaAccount {
@@ -16,11 +20,13 @@ pub struct InstaAccountId {
     pub id: String,
 }
 
+#[derive( Clone)]
 pub struct InstagramApi {
     page_access_token: String,
     base_url: String,
 }
 
+
 impl InstagramApi {
     pub fn new(page_access_token: String, base_url: String) -> InstagramApi {
         InstagramApi {
@@ -29,7 +35,9 @@ impl InstagramApi {
         }
     }
 
-    pub async fn insta_account(self) -> seed::fetch::Result<InstaAccount> {
+    /// This method is use to get instagram business account id.
+    /// for reference check <https://developers.facebook.com/docs/instagram-api/reference/page>
+    pub async fn account_id(self) -> seed::fetch::Result<InstaAccount> {
         let base_url = self.base_url.replace("EDGE", "?");
         let url = base_url
             + "fields=instagram_business_account"
@@ -39,4 +47,96 @@ impl InstagramApi {
         let request = Request::new(url).method(Method::Get);
         fetch(request).await?.json::<InstaAccount>().await
     }
+
+    /// This method is used to get instagram business account with its details (name, user, id ,etc).
+    /// It accepts the instagram page id.
+    /// for reference check <https://developers.facebook.com/docs/instagram-api/reference/ig-user>
+    pub async fn account_details(self) -> seed::fetch::Result<InstagramAccount> {
+            let mut url = self.base_url.replace("EDGE", "?");
+            let  url_fields = Fields::default().build_url_with_fields(); // build urlenconded url withe regired fields
+
+             let mut request_url = url
+                 + "fields="
+                 +url_fields.as_str()
+                + "&access_token="
+                + &self.page_access_token;
+            let request = Request::new(request_url).method(Method::Get);
+           fetch(request).await?.json::<InstagramAccount>().await
+    }
 }
+
+
+#[derive(Deserialize, Clone, Debug, Serialize)]
+pub struct InstagramAccount {
+    //https://developers.facebook.com/docs/instagram-api/reference/ig-user/
+    //This is a public fields, which means it can be returned if available.
+  //  biography: String,
+
+    ///This is a public fields, which means it can be returned if available.
+  pub  id:  String,
+
+    ///This is not a public fields, which means it may be returned depending on the user setting.
+    pub  ig_id: u32,
+
+    ///This is a public fields, which means it can be returned if available.
+    pub  followers_count:  u32,
+
+    ///This is not a public fields, which means it may be returned depending on the user setting.
+    pub  follows_count : u32,
+
+    ///This is not a public fields, which means it may be returned depending on the user setting.
+    pub   media_count: u32,
+
+    ///This is not a public fields, which means it may be returned depending on the user setting.
+    pub   name: String,
+
+    //This is not a public fields, which means it may be returned depending on the user setting.
+  //  profile_picture_url:  String,
+
+    ///This is not a public fields, which means it may be returned depending on the user setting.
+    pub  username : String,
+
+    //This is not a public fields, which means it may be returned depending on the user setting.
+   // website :  String,
+}
+pub struct Fields {
+    pub(crate) fields: Vec<String>,
+}
+
+impl Default for Fields {
+    /// These parameters are used as fields which are passed in as a query
+    /// parameters to the get post request and feeds request
+    fn default() -> Self {
+        let field_list = vec![
+            "biography",
+            "id",
+            "ig_id",
+            "followers_count",
+            "follows_count",
+            "media_count",
+            "name",
+            "profile_picture_url",
+            "username",
+            "website",
+        ];
+
+        let fields = field_list.iter().map(|&field| field.into()).collect();
+        Self { fields }
+    }
+}
+
+impl Fields {
+    pub fn build_url_with_fields(self) -> String {
+        let mut url_fields= "".to_string();
+        let  fields_count = Fields::default().fields.len();
+        for (count, field) in Fields::default().fields.into_iter().enumerate() {
+            if count < fields_count - 1 {
+                url_fields = url_fields+ &field + ",";
+            } else {
+                url_fields= url_fields+ &field; // remove the comma in the last filed
+            }
+        }
+        url_fields = String::from(encode(url_fields.as_str())); // encode the url
+        url_fields
+    }
+}

src/graph/instagram/account/mod.rs

@@ -0,0 +1,137 @@
+//! This mode Represents Instagram api for  Photo, Video, Story, Album, or Instagram TV media. Reels are not supported.
+//! It allow´ you to get media details ( comments, like, etc).
+//! for details check <https://developers.facebook.com/docs/instagram-api/reference/ig-media>.
+
+use seed::fetch::fetch;
+use seed::prelude::{Method, Request};
+use seed::{prelude::*, *};
+use serde::{Deserialize, Serialize};
+use urlencoding::encode;
+use std::{thread, time};
+use crate::graph::client::Client;
+
+#[derive(Deserialize, Clone, Serialize)]
+pub struct InstagramMediaApi {
+    access_token: String,
+    base_url: String,
+}
+
+impl InstagramMediaApi {
+    pub fn new(access_token: String, base_url: String) -> InstagramMediaApi {
+        InstagramMediaApi {
+            access_token,
+            base_url,
+        }
+    }
+    /// this method allow´s you to post on a give media container.
+    // for details check <https://developers.facebook.com/docs/instagram-api/reference/ig-media/comments>
+    pub async fn post_comments(
+        self,
+        comment_message:String,
+    ) -> seed::fetch::Result<InstaMediaContainerId> {
+        let self_data = self.clone();
+         let  base_url = self.base_url.replace("EDGE", "comments");
+        let comment = comment_message ;
+        let message = encode(&comment);
+        let url = base_url.to_string()
+            + "?message="
+            + (&message).as_ref()
+            + "&access_token="
+            + &self_data.access_token;
+        let request = Request::new(url).method(Method::Post);
+        fetch(request).await?.json::<InstaMediaContainerId>().await
+    }
+
+    pub async fn data(self)  -> seed::fetch::Result<MediaContainerData>  {
+        let mut url = self.base_url.replace("EDGE", "?fields=");
+
+        let mut fields_count = Fields::default().fields.len();
+        for (count, field) in Fields::default().fields.into_iter().enumerate() {
+            if count < fields_count - 1 {
+                url = url+ &field + ",";
+            } else {
+                url= url+ &field; // remove the comma in the last filed
+            }
+        }
+        url = url
+            + "&access_token="
+            + &self.access_token;
+
+
+        let request = Request::new(url).method(Method::Get);
+        fetch(request).await?.json::<MediaContainerData>().await
+    }
+
+ /// This method allows you to check the status for a given media, this is important to check before
+ /// calling the publish_media method.
+ /// for details check <https://developers.facebook.com/docs/instagram-api/reference/ig-container#reading>
+    pub async fn status(self)
+                        -> seed::fetch::Result<MediaContainerStatus> {
+        let base_url = self.base_url.replace("EDGE", "?fields=status_code");
+        let url = base_url
+            + "&access_token="
+            + &self.access_token;
+
+        let request = Request::new(url).method(Method::Get);
+        fetch(request).await?.json::<MediaContainerStatus>().await
+    }
+}
+
+#[derive(Deserialize, Debug, Clone, Serialize)]
+pub struct  MediaContainerStatus {
+    pub      status_code:String
+}
+
+#[derive(Deserialize, Debug, Clone, Default, Serialize)]
+pub struct MediaContainerData {
+    media_type:String,
+    media_url: String,
+    owner:  Owner,
+    timestamp: String,
+    username: String,
+    permalink: String,
+    like_count: String,
+    comments_count: String,
+    caption : String
+}
+
+#[derive(Deserialize, Debug, Clone, Default, Serialize)]
+pub struct InstaMediaContainerId {
+    pub id: String,
+}
+
+#[derive(Deserialize, Debug, Clone, Default, Serialize)]
+pub struct Owner {
+    id: String
+}
+
+pub struct Fields {
+    pub(crate) fields: Vec<String>,
+}
+
+impl Default for Fields {
+    /// This parameters are used as fields which are passed in as a query
+    /// parameters to the get post request and feeds request
+    fn default() -> Self {
+        let field_list = vec![
+            "caption",
+            "id",
+            "ig_id",
+            "comments_count",
+            "follows_count",
+            "like_count",
+            "media_product_type",
+            "media_type",
+            "media_url",
+            "owner",
+            "permalink",
+            "thumbnail_url",
+            "timestamp " ,
+            "username",
+            "video_title",
+        ];
+
+        let fields = field_list.iter().map(|&field| field.into()).collect();
+        Self { fields }
+    }
+}

src/graph/instagram/media/mod.rs

@@ -1,2 +1,3 @@
 pub mod account;
 pub mod publish;
+pub mod media;