feat(instagram): upgrade SDK to 2.0.0, fix helpers import, add pytest unit + integration tests (#327)

* feat(instagram): upgrade SDK to 2.0.0, fix helpers import, add pytest unit + integration tests

- Fix ModuleNotFoundError: add sys.path.insert so actions/ subpackage can resolve helpers
- Use explicit config path in Integration.load() to avoid CWD-relative resolution
- Bump autohive-integrations-sdk to ~=2.0.0; update all response.data accesses
- Replace old context.py/test_instagram.py with conftest.py, 57 unit tests, and live integration tests

* fix(instagram): resolve ruff lint and formatting errors

* fix(instagram): fix ruff formatting, use inputs[] for required media_type fields, revert __init__.py to simple imports

* fix(instagram): apply ruff formatting to integration test file

* fix(instagram): guard against duplicate Integration instance when loaded by file path

* fix(instagram): add total_count to get_comments output_schema

---------

Co-authored-by: Shubhank <72601061+Sagsgit@users.noreply.github.com>

Author: Shubhank-Jonnada

instagram/actions/__init__.py

@@ -1,9 +1,3 @@
-"""
-Instagram integration actions.
-
-Importing this module registers all actions with the instagram integration instance.
-"""
-
 from . import account
 from . import media
 from . import comments

instagram/actions/account.py

@@ -1,7 +1,3 @@
-"""
-Instagram Account actions - Account information retrieval.
-"""
-
 from autohive_integrations_sdk import ActionHandler, ActionResult, ExecutionContext
 from typing import Dict, Any
 
@@ -11,14 +7,7 @@
 
 @instagram.action("get_account")
 class GetAccountAction(ActionHandler):
-    """
-    Retrieve Instagram Business/Creator account details.
-
-    Returns profile information including username, bio, follower counts,
-    and other account metadata.
-    """
-
-    async def execute(self, inputs: Dict[str, Any], context: ExecutionContext):
+    async def execute(self, inputs: Dict[str, Any], context: ExecutionContext) -> ActionResult:
         fields = ",".join(
             [
                 "id",
@@ -32,19 +21,18 @@ async def execute(self, inputs: Dict[str, Any], context: ExecutionContext):
                 "website",
             ]
         )
-
         response = await context.fetch(f"{INSTAGRAM_GRAPH_API_BASE}/me", method="GET", params={"fields": fields})
-
+        data = response.data
         return ActionResult(
             data={
-                "id": response.get("id", ""),
-                "username": response.get("username", ""),
-                "name": response.get("name", ""),
-                "biography": response.get("biography", ""),
-                "followers_count": response.get("followers_count", 0),
-                "following_count": response.get("follows_count", 0),
-                "media_count": response.get("media_count", 0),
-                "profile_picture_url": response.get("profile_picture_url", ""),
-                "website": response.get("website", ""),
+                "id": data.get("id", ""),
+                "username": data.get("username", ""),
+                "name": data.get("name", ""),
+                "biography": data.get("biography", ""),
+                "followers_count": data.get("followers_count", 0),
+                "following_count": data.get("follows_count", 0),
+                "media_count": data.get("media_count", 0),
+                "profile_picture_url": data.get("profile_picture_url", ""),
+                "website": data.get("website", ""),
             }
         )

instagram/actions/comments.py

@@ -1,7 +1,3 @@
-"""
-Instagram Comments actions - Read, reply, hide, and delete comments.
-"""
-
 from autohive_integrations_sdk import ActionHandler, ActionResult, ExecutionContext
 from typing import Dict, Any
 
@@ -10,12 +6,9 @@
 
 
 def _build_comment_response(comment: Dict[str, Any]) -> Dict[str, Any]:
-    """Normalize a comment object from the Graph API into a consistent response format."""
     replies_data = comment.get("replies", {}).get("data", [])
     from_data = comment.get("from", {})
-
     username = comment.get("username") or from_data.get("username", "")
-
     return {
         "id": comment.get("id", ""),
         "text": comment.get("text", ""),
@@ -38,14 +31,7 @@ def _build_comment_response(comment: Dict[str, Any]) -> Dict[str, Any]:
 
 @instagram.action("get_comments")
 class GetCommentsAction(ActionHandler):
-    """
-    Retrieve comments on an Instagram media object.
-
-    Returns comment text, author username, timestamps, and like counts.
-    Also includes nested replies.
-    """
-
-    async def execute(self, inputs: Dict[str, Any], context: ExecutionContext):
+    async def execute(self, inputs: Dict[str, Any], context: ExecutionContext) -> ActionResult:
         media_id = inputs["media_id"]
         limit = min(inputs.get("limit", 25), 100)
         after_cursor = inputs.get("after_cursor")
@@ -54,34 +40,33 @@ async def execute(self, inputs: Dict[str, Any], context: ExecutionContext):
             "id,text,timestamp,username,like_count,from{id,username},"
             "replies{id,text,timestamp,username,from{id,username}}"
         )
-
         params = {"fields": fields, "limit": limit}
         if after_cursor:
             params["after"] = after_cursor
 
-        response = await context.fetch(f"{INSTAGRAM_GRAPH_API_BASE}/{media_id}/comments", method="GET", params=params)
-
-        comments = [_build_comment_response(c) for c in response.get("data", [])]
-
-        paging = response.get("paging", {})
+        response = await context.fetch(
+            f"{INSTAGRAM_GRAPH_API_BASE}/{media_id}/comments",
+            method="GET",
+            params=params,
+        )
+        data = response.data
+        comments = [_build_comment_response(c) for c in data.get("data", [])]
+        paging = data.get("paging", {})
         cursors = paging.get("cursors", {})
         next_cursor = cursors.get("after") if paging.get("next") else None
 
-        return ActionResult(data={"comments": comments, "total_count": len(comments), "next_cursor": next_cursor})
+        return ActionResult(
+            data={
+                "comments": comments,
+                "total_count": len(comments),
+                "next_cursor": next_cursor,
+            }
+        )
 
 
 @instagram.action("manage_comment")
 class ManageCommentAction(ActionHandler):
-    """
-    Interact with comments on Instagram media.
-
-    Supported actions:
-    - reply: Post a reply to the comment
-    - hide: Hide the comment from public view
-    - unhide: Make a hidden comment visible again
-    """
-
-    async def execute(self, inputs: Dict[str, Any], context: ExecutionContext):
+    async def execute(self, inputs: Dict[str, Any], context: ExecutionContext) -> ActionResult:
         comment_id = inputs["comment_id"]
         action = inputs["action"]
         message = inputs.get("message")
@@ -91,14 +76,19 @@ async def execute(self, inputs: Dict[str, Any], context: ExecutionContext):
 
         if action == "reply":
             response = await context.fetch(
-                f"{INSTAGRAM_GRAPH_API_BASE}/{comment_id}/replies", method="POST", data={"message": message}
+                f"{INSTAGRAM_GRAPH_API_BASE}/{comment_id}/replies",
+                method="POST",
+                data={"message": message},
             )
-            return ActionResult(data={"success": True, "action_taken": "reply", "reply_id": response.get("id", "")})
+            reply_id = response.data.get("id", "")
+            return ActionResult(data={"success": True, "action_taken": "reply", "reply_id": reply_id})
 
         elif action in ("hide", "unhide"):
             hide_value = action == "hide"
             await context.fetch(
-                f"{INSTAGRAM_GRAPH_API_BASE}/{comment_id}", method="POST", data={"hide": str(hide_value).lower()}
+                f"{INSTAGRAM_GRAPH_API_BASE}/{comment_id}",
+                method="POST",
+                data={"hide": str(hide_value).lower()},
             )
             return ActionResult(data={"success": True, "action_taken": action, "is_hidden": hide_value})
 
@@ -107,16 +97,7 @@ async def execute(self, inputs: Dict[str, Any], context: ExecutionContext):
 
 @instagram.action("delete_comment")
 class DeleteCommentAction(ActionHandler):
-    """
-    Permanently delete a comment from Instagram media.
-
-    This action cannot be undone. You can only delete comments on
-    media you own or comments that others have left on your media.
-    """
-
-    async def execute(self, inputs: Dict[str, Any], context: ExecutionContext):
+    async def execute(self, inputs: Dict[str, Any], context: ExecutionContext) -> ActionResult:
         comment_id = inputs["comment_id"]
-
         await context.fetch(f"{INSTAGRAM_GRAPH_API_BASE}/{comment_id}", method="DELETE")
-
         return ActionResult(data={"success": True, "deleted_comment_id": comment_id})

instagram/actions/insights.py

@@ -1,7 +1,3 @@
-"""
-Instagram Insights actions - Analytics for accounts and media.
-"""
-
 from autohive_integrations_sdk import ActionHandler, ActionResult, ExecutionContext
 from typing import Dict, Any
 
@@ -11,27 +7,6 @@
 
 @instagram.action("get_insights")
 class GetInsightsAction(ActionHandler):
-    """
-    Retrieve advanced analytics for an Instagram account or specific media.
-
-    Use this for detailed performance metrics beyond basic like/comment
-    counts. For simple engagement counts, use Get Posts instead.
-
-    Account insights include:
-    - Reach and impressions
-    - Profile views
-    - Follower demographics
-    - Content interactions (likes, comments, shares, saves)
-
-    Media insights include:
-    - Reach and impressions
-    - Saves and shares
-    - Video views and watch time (for Reels)
-    - Story navigation and profile activity
-
-    Note: Story insights are only available for 24 hours after posting.
-    """
-
     DEFAULT_ACCOUNT_METRICS = [
         "reach",
         "profile_views",
@@ -43,9 +18,15 @@ class GetInsightsAction(ActionHandler):
         "saves",
         "follows_and_unfollows",
     ]
-
-    DEFAULT_MEDIA_METRICS_FEED = ["reach", "likes", "comments", "shares", "saved", "total_interactions", "views"]
-
+    DEFAULT_MEDIA_METRICS_FEED = [
+        "reach",
+        "likes",
+        "comments",
+        "shares",
+        "saved",
+        "total_interactions",
+        "views",
+    ]
     DEFAULT_MEDIA_METRICS_REELS = [
         "reach",
         "likes",
@@ -57,10 +38,16 @@ class GetInsightsAction(ActionHandler):
         "ig_reels_avg_watch_time",
         "ig_reels_video_view_total_time",
     ]
+    DEFAULT_MEDIA_METRICS_STORY = [
+        "reach",
+        "views",
+        "navigation",
+        "profile_activity",
+        "shares",
+        "follows",
+    ]
 
-    DEFAULT_MEDIA_METRICS_STORY = ["reach", "views", "navigation", "profile_activity", "shares", "follows"]
-
-    async def execute(self, inputs: Dict[str, Any], context: ExecutionContext):
+    async def execute(self, inputs: Dict[str, Any], context: ExecutionContext) -> ActionResult:
         target_type = inputs["target_type"]
         target_id = inputs.get("target_id")
         custom_metrics = inputs.get("metrics")
@@ -69,36 +56,34 @@ async def execute(self, inputs: Dict[str, Any], context: ExecutionContext):
         if target_type == "account":
             account_id = await get_instagram_account_id(context)
             metrics = custom_metrics or self.DEFAULT_ACCOUNT_METRICS
-
-            params = {"metric": ",".join(metrics), "period": period, "metric_type": "total_value"}
-
+            params = {
+                "metric": ",".join(metrics),
+                "period": period,
+                "metric_type": "total_value",
+            }
             endpoint = f"{INSTAGRAM_GRAPH_API_BASE}/{account_id}/insights"
-
         else:
             if not target_id:
                 raise Exception("target_id is required for media insights")
-
-            media_response = await context.fetch(
-                f"{INSTAGRAM_GRAPH_API_BASE}/{target_id}", method="GET", params={"fields": "media_product_type"}
+            type_r = await context.fetch(
+                f"{INSTAGRAM_GRAPH_API_BASE}/{target_id}",
+                method="GET",
+                params={"fields": "media_product_type"},
             )
-            media_product_type = media_response.get("media_product_type", "FEED")
-
+            media_product_type = type_r.data.get("media_product_type", "FEED")
             if media_product_type == "REELS":
                 metrics = custom_metrics or self.DEFAULT_MEDIA_METRICS_REELS
             elif media_product_type == "STORY":
                 metrics = custom_metrics or self.DEFAULT_MEDIA_METRICS_STORY
             else:
                 metrics = custom_metrics or self.DEFAULT_MEDIA_METRICS_FEED
-
             params = {"metric": ",".join(metrics)}
             endpoint = f"{INSTAGRAM_GRAPH_API_BASE}/{target_id}/insights"
 
         response = await context.fetch(endpoint, method="GET", params=params)
-
         metrics_data = {}
-        for item in response.get("data", []):
+        for item in response.data.get("data", []):
             metric_name = item.get("name", "")
-
             total_value = item.get("total_value", {})
             if total_value:
                 metrics_data[metric_name] = total_value.get("value", total_value)