feat: add the activity insight

server/insight/router.py

@@ -1,10 +1,11 @@
 import json
-from typing import Optional
-from fastapi import APIRouter, Depends
+from fastapi import APIRouter
+from insight.service.activity import get_activity_data
 from insight.service.issue import get_issue_data
 from insight.service.pr import get_code_changes, get_pr_data
 
 
+# ref: https://open-digger.cn/en/docs/user_docs/metrics/metrics_usage_guide
 router = APIRouter(
     prefix="/api/insight",
     tags=["insight"],
@@ -49,3 +50,16 @@
 
     except Exception as e:
         return json.dumps({"success": False, "message": str(e)})
+
+
+@router.get("/activity")
+def get_activity_insight(repo_name: str):
+    try:
+        result = get_activity_data(repo_name)
+        return {
+            "success": True,
+            "data": result,
+        }
+
+    except Exception as e:
+        return json.dumps({"success": False, "message": str(e)})

server/insight/service/activity.py

@@ -0,0 +1,24 @@
+import datetime
+import requests
+from typing import List, Dict
+
+
+def get_activity_data(repo_name: str) -> List[Dict[str, int]]:
+    url = f"https://oss.open-digger.cn/github/{repo_name}/activity_details.json"
+
+    response = requests.get(url)
+    data = response.json()
+    if not data:
+        return []
+
+    # Filter out only the monthly data (excluding quarters)
+    monthly_data = {k: v for k, v in data.items() if "-" in k}
+
+    # Get the most recent month
+    most_recent_month_key = max(monthly_data.keys())
+
+    # Return the data for the most recent month
+    return [
+        {"user": user, "value": value}
+        for user, value in monthly_data[most_recent_month_key]
+    ]

server/insight/service/issue.py

@@ -1,8 +1,5 @@
-import requests
-from collections import defaultdict
-
 from utils.insight import get_data
 
 
 def get_issue_data(repo_name):
     metrics_mapping = {

server/insight/service/pr.py

@@ -1,8 +1,5 @@
-import requests
-from collections import defaultdict
-
 from utils.insight import get_data
 
 
 def get_pr_data(repo_name):
     metrics_mapping = {

server/tests/insight/test_activity.py

@@ -0,0 +1,45 @@
+import unittest
+from unittest.mock import patch, MagicMock
+from insight.service.activity import get_activity_data
+
+
+class TestGetActivityData(unittest.TestCase):
+
+    @patch("insight.service.activity.requests.get")
+    def test_get_activity_data(self, mock_get):
+        mock_response = MagicMock()
+        mock_response.json.return_value = {
+            "2023-12": [("user1", 10), ("user2", 5)],
+            "2024-01": [("user3", 20)],
+            "2024-02": [("user4", 25)],
+            "2024-03": [("user5", 30)],
+        }
+        mock_get.return_value = mock_response
+        repo_name = "petercat-ai/petercat"
+        expected_result = [{"user": "user5", "value": 30}]
+
+        result = get_activity_data(repo_name)
+
+        self.assertIsInstance(result, list)
+        self.assertEqual(result, expected_result)
+
+    @patch("insight.service.activity.requests.get")
+    def test_get_activity_data_empty(self, mock_get):
+        mock_response = MagicMock()
+        mock_response.json.return_value = {}
+        mock_get.return_value = mock_response
+        repo_name = "petercat-ai/petercat"
+        result = get_activity_data(repo_name)
+
+        self.assertEqual(result, [])
+
+    @patch("insight.service.activity.requests.get")
+    def test_get_activity_data_invalid_json(self, mock_get):
+
+        mock_response = MagicMock()
+        mock_response.json.side_effect = ValueError("Invalid JSON")
+        mock_get.return_value = mock_response
+
+        repo_name = "petercat-ai/petercat"
+        with self.assertRaises(ValueError):
+            get_activity_data(repo_name)