Release/0.8.0 (#9)

* v0.8.0 - see CHANGELOG for details

Author: Thesephi

CHANGELOG.md

@@ -1,3 +1,10 @@
+## [0.8.0] - 2025-03-31
+
+### Changed
+
+- `get_profile_info()` argument changed
+- `get_conversations()` argument changed
+
 ## [0.7.0] - 2025-03-28
 
 ### Added

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "rusty_meta_threads"
-version = "0.7.0"
+version = "0.8.0"
 edition = "2024"
 description = "Community Rust SDK for integrating with Meta Threads API"
 repository = "https://github.com/Thesephi/rusty_meta_threads.git"

src/create_reply.rs

@@ -11,8 +11,7 @@ pub async fn create_reply(
 ) -> Result<SimpleMediaObject, reqwest::Error> {
     let mut url = format!(
         "https://graph.threads.net/v1.0/me/threads\
-        ?reply_to_id={reply_to_id}\
-        &access_token={token}"
+        ?reply_to_id={reply_to_id}"
     );
 
     let mut publish_wait_time_ms = 300;
@@ -34,6 +33,7 @@ pub async fn create_reply(
 
     let media_container = reqwest::Client::new()
         .post(&url)
+        .bearer_auth(token)
         .send()
         .await?
         .json::<SimpleMediaObject>()

src/mentions.rs

@@ -6,11 +6,7 @@ pub async fn get_mentions(
     fields: Option<&str>,
     token: &str,
 ) -> Result<MetaMediaResponse<MetaMedia>, reqwest::Error> {
-    let the_fields = if let Some(f) = fields {
-        f
-    } else {
-        "id,username,text,media_url,root_post,replied_to"
-    };
+    let the_fields = fields.unwrap_or_else(|| "id,username,text,media_url,root_post,replied_to");
 
     let url = format!(
         "https://graph.threads.net/{user_id}/mentions\
@@ -33,6 +29,11 @@ mod tests {
     use super::*;
     use crate::utils::read_dot_env;
     use log::debug;
+    use std::any::{Any, TypeId};
+
+    fn is_meta_media_vec<T: Any>(_val: &T) -> bool {
+        TypeId::of::<T>() == TypeId::of::<Vec<MetaMedia>>()
+    }
 
     #[tokio::test]
     async fn test_get_mentions() {
@@ -49,7 +50,7 @@ mod tests {
             Ok(val) => match val.data {
                 Some(dat) => {
                     debug!("mentions fetched: {:?}", dat);
-                    assert_eq!(dat[0].id, "foo")
+                    assert_eq!(is_meta_media_vec(&dat), true);
                 }
                 None => panic!("unexpected result"),
             },

src/oembed.rs

@@ -16,15 +16,13 @@ pub async fn get_oembed_html(
     token: &str,
 ) -> Result<OembedResponse, reqwest::Error> {
     let the_post_url = encode(post_url);
-    let url = format!(
-        "https://graph.threads.net/v1.0/oembed?url={the_post_url}\
-        &access_token={token}"
-    );
+    let url = format!("https://graph.threads.net/v1.0/oembed?url={the_post_url}");
 
     debug!("requesting oembed for: {:?}", &url);
 
     let res = reqwest::Client::new()
         .get(&url)
+        .bearer_auth(token)
         .send()
         .await?
         .json::<OembedResponse>()
@@ -49,12 +47,11 @@ mod tests {
         let env = read_dot_env();
         let token = env.get("ACCESS_TOKEN").unwrap();
 
-        let res =
-            get_oembed_html("https://www.threads.net/@dkode___/post/DHwBylVNThs", token).await;
+        let res = get_oembed_html("https://www.threads.net/@threads/post/DHvtwr8g63f", token).await;
 
         debug!("oembed response fetched: {:?}", res);
 
         assert_eq!(true, res.is_ok());
-        assert_eq!(res.unwrap().html, "");
+        assert_eq!(res.unwrap().provider_url, "https://www.threads.net/");
     }
 }

src/posts.rs

@@ -6,12 +6,12 @@ pub async fn publish_media_container(
 ) -> Result<SimpleMediaObject, reqwest::Error> {
     let url = format!(
         "https://graph.threads.net/v1.0/me/threads_publish\
-        ?creation_id={media_container_id}\
-        &access_token={token}"
+        ?creation_id={media_container_id}"
     );
 
     let res = reqwest::Client::new()
         .post(&url)
+        .bearer_auth(token)
         .send()
         .await?
         .json::<SimpleMediaObject>()

src/profiles.rs

@@ -12,11 +12,16 @@ pub struct ThreadsUserProfile {
     pub error: Option<ThreadsApiRespErrorPayload>,
 }
 
-// @TODO have fields as fn arguments instead of hardcoding
-pub async fn get_profile_info(bearer_token: &str) -> Result<ThreadsUserProfile, reqwest::Error> {
-    let url = "https://graph.threads.net/me\
-        ?fields=id%2Cusername%2Cname%2C\
-        threads_profile_picture_url%2Cthreads_biography";
+pub async fn get_profile_info(
+    fields: Option<&str>,
+    bearer_token: &str,
+) -> Result<ThreadsUserProfile, reqwest::Error> {
+    let the_fields =
+        fields.unwrap_or_else(|| "id,username,name,threads_profile_picture_url,threads_biography");
+    let url = format!(
+        "https://graph.threads.net/me\
+        ?fields={the_fields}"
+    );
 
     let res = reqwest::Client::new()
         .get(url)
@@ -57,7 +62,7 @@ mod tests {
         let env = read_dot_env();
         let token = env.get("ACCESS_TOKEN").unwrap();
 
-        let res = get_profile_info(token).await;
+        let res = get_profile_info(None, token).await;
 
         debug!("profile fetched {:?}", res);
 

src/reply_management.rs

@@ -3,21 +3,25 @@ use crate::shared::MetaMediaResponse;
 
 pub async fn get_conversations(
     media_id: &str,
+    fields: Option<&str>,
+    reverse: Option<bool>,
     token: &str,
 ) -> Result<MetaMediaResponse<MetaMedia>, reqwest::Error> {
-    // @TODO get fields from method arguments
-    let reverse = false;
+    let the_fields = fields.unwrap_or_else(|| {
+        "id,is_reply_owned_by_me,username,text,timestamp,\
+        media_product_type,media_type,media_url,shortcode,thumbnail_url,\
+        children,has_replies,root_post,replied_to,is_reply,hide_status"
+    });
+    let the_reverse = reverse.unwrap_or(false);
     let url = format!(
         "https://graph.threads.net/v1.0/{media_id}/conversation\
-        ?fields=id,is_reply_owned_by_me,username,text,timestamp,\
-        media_product_type,media_type,media_url,shortcode,thumbnail_url,\
-        children,has_replies,root_post,replied_to,is_reply,hide_status\
-        &reverse={reverse}\
-        &access_token={token}"
+        ?fields={the_fields}\
+        &reverse={the_reverse}"
     );
 
     let res = reqwest::Client::new()
         .get(&url)
+        .bearer_auth(token)
         .send()
         .await?
         .json::<MetaMediaResponse<MetaMedia>>()

src/retrieve_media.rs

@@ -69,18 +69,13 @@ pub async fn get_thread(
     fields: Option<&str>,
     token: &str,
 ) -> Result<MetaMedia, reqwest::Error> {
-    let the_fields = if let Some(f) = fields {
-        f
-    } else {
-        "id,root_post,replied_to,media_product_type,media_type,media_url,permalink,owner,username,text,timestamp,shortcode,thumbnail_url,children,is_quote_post"
-    };
+    let the_fields = fields.unwrap_or_else(|| "id,root_post,replied_to,media_product_type,media_type,media_url,permalink,owner,username,text,timestamp,shortcode,thumbnail_url,children,is_quote_post");
 
-    let url = format!(
-        "https://graph.threads.net/v1.0/{thread_id}?fields={the_fields}&access_token={token}"
-    );
+    let url = format!("https://graph.threads.net/v1.0/{thread_id}?fields={the_fields}");
 
     let res = reqwest::Client::new()
         .get(&url)
+        .bearer_auth(token)
         .send()
         .await?
         .json::<MetaMedia>()