Danie1
diff --git a/‎README.md
Copy file name to clipboardExpand all lines: README.md
+18-3 b/‎README.md
Copy file name to clipboardExpand all lines: README.md
+18-3
diff --git a/‎example.py
Copy file name to clipboardExpand all lines: example.py
+99 b/‎example.py
Copy file name to clipboardExpand all lines: example.py
+99
diff --git a/‎pyproject.toml
Copy file name to clipboardExpand all lines: pyproject.toml
+1-1 b/‎pyproject.toml
Copy file name to clipboardExpand all lines: pyproject.toml
+1-1
diff --git a/‎setup.py
Copy file name to clipboardExpand all lines: setup.py
+1-1 b/‎setup.py
Copy file name to clipboardExpand all lines: setup.py
+1-1
diff --git a/‎threads_api/src/threads_api.py
Copy file name to clipboardExpand all lines: threads_api/src/threads_api.py
+82-6 b/‎threads_api/src/threads_api.py
Copy file name to clipboardExpand all lines: threads_api/src/threads_api.py
+82-6
@@ -66,6 +66,17 @@ loop.run_until_complete(main())
 ```
 
 ## Usage Examples
+View [example.py](https://github.com/Danie1/threads-api/blob/main/example.py) for code examples. 
+At the end of the file you will be able to uncomment and run the individual examples with ease.
+
+Then simply run as:
+```
+# Pass the credentials as environment variables
+USERNAME=<Instagram Username> PASSWORD=<Instagram Password> python3 example.py
+```
+
+### Samples
+
 <details>
   <summary>"get_user_id_from_username" Function</summary>
 
@@ -327,25 +338,29 @@ Post has been successfully posted
 ## 📌 Roadmap
 
 - [x] ✅ Login functionality 🔒
-  - [x] ✅ Cache login token securely (reduce login requests)
+  - [x] ✅ Cache login token securely (reduce login requests / due to restrictive limits)
 - [x] ✅ Write Posts (Requires Login 🔒)
   - [x] ✅ Posts with just text
   - [x] ✅ Posts with text and an image
   - [x] ✅ Posts with text that share a url
+  - [x] ✅ Reply to Posts
   - [ ] 🚧 Post with text and share a video
-  - [ ] 🚧 Reply to Posts
 - [x] ✅ Perform Actions (Requires Login 🔒)
   - [x] ✅ Like Posts
   - [x] ✅ Unlike Posts
+  - [x] ✅ Delete post
   - [x] ✅ Follow User
   - [x] ✅ Unfollow User
-- [x] ✅ Read Data
+- [x] ✅ Read Public Data
   - [x] ✅ Read a user_id (eg. `314216`) via username(eg. `zuck`)
   - [x] ✅ Read a user's profile info
   - [x] ✅ Read list of a user's Threads
   - [x] ✅ Read list of a user's Replies
   - [x] ✅ Read Post and a list of its Replies
   - [x] ✅ View who liked a post
+- [x] ✅ Read Private Data (Requires Login 🔒)
+  - [x] ✅ Read a user's followers list
+  - [x] ✅ Read a user's following list
 - [x] ✅  CI/CD
   - [x] ✅  GitHub Actions Pipeline
   - [ ] 🚧  Pytest
 
@@ -195,6 +195,100 @@ async def login_with_cache():
     is_success = await api.login(username=os.environ.get('USERNAME'), password=os.environ.get('PASSWORD'), cached_token_path=".token")
     print(f"Login status: {'Success' if is_success else 'Failed'}")
 
+async def get_user_followers():
+    api = ThreadsAPI()
+
+    # Will login via REST to the Instagram API
+    is_success = await api.login(username=os.environ.get('USERNAME'), password=os.environ.get('PASSWORD'), cached_token_path=".token")
+    print(f"Login status: {'Success' if is_success else 'Failed'}")
+
+    if is_success:
+        username_to_search = "zuck"
+        number_of_likes_to_display = 10
+
+        user_id_to_search = await api.get_user_id_from_username(username_to_search)
+        data = await api.get_user_followers(user_id_to_search)
+        
+        for user in data['users'][0:number_of_likes_to_display]:
+            print(f"Username: {user['username']}")
+
+async def get_user_following():
+    api = ThreadsAPI()
+
+    # Will login via REST to the Instagram API
+    is_success = await api.login(username=os.environ.get('USERNAME'), password=os.environ.get('PASSWORD'), cached_token_path=".token")
+    print(f"Login status: {'Success' if is_success else 'Failed'}")
+
+    if is_success:
+        username_to_search = "zuck"
+        number_of_likes_to_display = 10
+
+        user_id_to_search = await api.get_user_id_from_username(username_to_search)
+        data = await api.get_user_following(user_id_to_search)
+        
+        for user in data['users'][0:number_of_likes_to_display]:
+            print(f"Username: {user['username']}")
+
+# Asynchronously likes a post
+async def like_post():
+    api = ThreadsAPI()
+
+    # Will login via REST to the Instagram API
+    is_success = await api.login(username=os.environ.get('USERNAME'), password=os.environ.get('PASSWORD'), cached_token_path=".token")
+    print(f"Login status: {'Success' if is_success else 'Failed'}")
+
+    if is_success:
+        post_url = "https://www.threads.net/t/CuZsgfWLyiI"
+        post_id = await api.get_post_id_from_url(post_url)
+
+        result = await api.like_post(post_id)
+        
+        print(f"Like status: {'Success' if result else 'Failed'}")
+
+# Asynchronously unlikes a post
+async def unlike_post():
+    api = ThreadsAPI()
+
+    # Will login via REST to the Instagram API
+    is_success = await api.login(username=os.environ.get('USERNAME'), password=os.environ.get('PASSWORD'), cached_token_path=".token")
+    print(f"Login status: {'Success' if is_success else 'Failed'}")
+
+    if is_success:
+        post_url = "https://www.threads.net/t/CuZsgfWLyiI"
+        post_id = await api.get_post_id_from_url(post_url)
+
+        result = await api.unlike_post(post_id)
+        
+        print(f"Unlike status: {'Success' if result else 'Failed'}")
+
+# Asynchronously creates then deletes the same post
+async def create_and_delete_post():
+    api = ThreadsAPI()
+
+    # Will login via REST to the Instagram API
+    is_success = await api.login(username=os.environ.get('USERNAME'), password=os.environ.get('PASSWORD'), cached_token_path=".token")
+    print(f"Login status: {'Success' if is_success else 'Failed'}")
+
+    if is_success:
+        post_id = await api.post("Hello World!")
+        await api.delete_post(post_id)
+
+        print(f"Created and deleted post {post_id} successfully")
+
+# Asynchronously creates then deletes the same post
+async def post_and_reply_to_post():
+    api = ThreadsAPI()
+
+    # Will login via REST to the Instagram API
+    is_success = await api.login(username=os.environ.get('USERNAME'), password=os.environ.get('PASSWORD'), cached_token_path=".token")
+    print(f"Login status: {'Success' if is_success else 'Failed'}")
+
+    if is_success:
+        first_post_id = await api.post("Hello World!")
+        second_post_id = await api.post("Hello World to you too!", parent_post_id=first_post_id)
+
+        print(f"Created parent post {first_post_id} and replied to it with post {second_post_id} successfully")
+
 '''
  Remove the # to run an individual example function wrapper.
 
@@ -218,3 +312,8 @@ async def login_with_cache():
 #asyncio.run(follow_user()) # Follows a user.
 #asyncio.run(unfollow_user()) # Unfollows a user.
 #asyncio.run(login_with_cache()) # Displays token cache capability
+#asyncio.run(get_user_followers()) # Displays users who follow a given user
+#asyncio.run(like_post()) # Likes a post
+#asyncio.run(unlike_post()) # Unlikes a post
+#asyncio.run(create_and_delete_post()) # Creates and deletes the same post
+#asyncio.run(post_and_reply_to_post()) # Post and then reply to the same post
@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "threads-api"
-version = "1.1.1"
+version = "1.1.2"
 description = "Unofficial Python client for Meta Threads.net API"
 authors = ["Danie1"]
 readme = "README.md"
 
@@ -5,7 +5,7 @@
 
 setup(
     name='threads-api',
-    version='1.1.1',
+    version='1.1.2',
     description='Unofficial Python client for Meta Threads.net API',
     long_description=long_description,
     long_description_content_type='text/markdown',
 
@@ -229,6 +229,10 @@ async def __auth_required_post_request(self, url: str):
             async with session.post(url, headers=self.auth_headers) as response:
                 return await response.json()
 
+    async def __auth_required_get_request(self, url: str):
+        async with aiohttp.ClientSession() as session:
+            async with session.get(url, headers=self.auth_headers) as response:
+                return await response.json()
 
 
     async def get_user_id_from_username(self, username: str) -> str:
@@ -401,7 +405,21 @@ async def get_user_replies(self, user_id: str):
 
         threads = data['data']['mediaData']['threads']
         return threads
-    
+
+    async def get_user_followers(self, user_id: str) -> bool:
+        if not self.is_logged_in:
+            raise Exception("The action 'get_user_followers' can only be perfomed while logged-in")
+        
+        res = await self.__auth_required_get_request(f"{BASE_URL}/friendships/{user_id}/followers")
+        return res
+
+    async def get_user_following(self, user_id: str) -> bool:
+        if not self.is_logged_in:
+            raise Exception("The action 'get_user_following' can only be perfomed while logged-in")
+        
+        res = await self.__auth_required_get_request(f"{BASE_URL}/friendships/{user_id}/following")
+        return res
+
     async def follow_user(self, user_id: str) -> bool:
         """
         Follows a user with the given user ID.
@@ -416,7 +434,7 @@ async def follow_user(self, user_id: str) -> bool:
             Exception: If an error occurs during the follow process.
         """
         if not self.is_logged_in:
-            raise Exception("The action 'follow' can only be perfomed while logged-in")
+            raise Exception("The action 'follow_user' can only be perfomed while logged-in")
 
         res = await self.__auth_required_post_request(f"{BASE_URL}/friendships/create/{user_id}/")
         return res["status"] == "ok"
@@ -435,12 +453,68 @@ async def unfollow_user(self, user_id: str) -> bool:
             Exception: If an error occurs during the unfollow process.
         """
         if not self.is_logged_in:
-            raise Exception("The action 'unfollow' can only be perfomed while logged-in")
+            raise Exception("The action 'unfollow_user' can only be perfomed while logged-in")
 
         res = await self.__auth_required_post_request(f"{BASE_URL}/friendships/destroy/{user_id}/")
         return res["status"] == "ok"
 
+    async def like_post(self, post_id: str) -> bool:
+        """
+        Likes a post with the given ID.
+
+        Args:
+            user_id (str): The ID of the post to like.
+
+        Returns:
+            bool: True if the post was liked successfully, False otherwise.
+
+        Raises:
+            Exception: If an error occurs during the like process.
+        """
+        if not self.is_logged_in:
+            raise Exception("The action 'like_post' can only be perfomed while logged-in")
+        
+        res = await self.__auth_required_post_request(f"{BASE_URL}/media/{post_id}_{self.user_id}/like/")
+        return res["status"] == "ok"
+    
+    async def unlike_post(self, post_id: str) -> bool:
+        """
+        Unlikes a post with the given ID.
+
+        Args:
+            user_id (str): The ID of the post to unlike.
+
+        Returns:
+            bool: True if the post was unliked successfully, False otherwise.
+
+        Raises:
+            Exception: If an error occurs during the like process.
+        """
+        if not self.is_logged_in:
+            raise Exception("The action 'unlike_post' can only be perfomed while logged-in")
+        
+        res = await self.__auth_required_post_request(f"{BASE_URL}/media/{post_id}_{self.user_id}/unlike/")
+        return res["status"] == "ok"
+    
+    async def delete_post(self, post_id: str) -> bool:
+        """
+        Deletes a post with the given ID.
+
+        Args:
+            user_id (str): The ID of the post to delete.
+
+        Returns:
+            bool: True if the post was deleted successfully, False otherwise.
 
+        Raises:
+            Exception: If an error occurs during the deletion process.
+        """
+        if not self.is_logged_in:
+            raise Exception("The action 'delete_post' can only be perfomed while logged-in")
+        
+        res = await self.__auth_required_post_request(f"{BASE_URL}/media/{post_id}_{self.user_id}/delete/?media_type=TEXT_POST")
+        return res["status"] == "ok"
+    
     async def get_post_id_from_url(self, post_url):
         """
         Retrieves the post ID from a given URL.
@@ -714,10 +788,12 @@ async def __upload_image(image_url: str, image_content: bytes) -> str:
         try:
             async with aiohttp.ClientSession() as session:
                 async with session.post(post_url, headers=headers, data=payload) as response:
-                    if response.status == 200:
-                        return True
+                    data = await response.json()
+
+                    if 'media' in data and 'pk' in data['media']:
+                        # Return the newly created post_id
+                        return data['media']['pk']
                     else:
-                        print(response)
                         raise Exception("Failed to post. Got response:\n" + str(response))
         except Exception as e:
             print("[ERROR] ", e)