Update linkedin_follower_stats.py

linkedin_follower_stats.py

@@ -196,26 +196,38 @@ def fetch_monthly_follower_gains(session, org_urn, api_rest_base):
     # )
     # logging.info(f"Fetching monthly follower gains from URL: {url}")
 
-    session.headers.setdefault('LinkedIn-Version', '202502')
+    now_utc = datetime.now(timezone.utc)
+    start_of_reporting_period = (now_utc - timedelta(days=365)).replace(day=1, hour=0, minute=0, second=0, microsecond=0)
+    start_ms = int(start_of_reporting_period.timestamp() * 1000)
 
-    now = datetime.now(timezone.utc)
-    twelve_months_ago = (now - timedelta(days=365)).replace(day=1)
-    start_ms = int(twelve_months_ago.timestamp() * 1000)
+    base_url = f"{api_rest_base_url}/organizationalEntityFollowerStatistics"
+    time_intervals_value = f"(timeRange:(start:{start_ms}),timeGranularityType:MONTH)"
 
-    # only pass start + granularity
-    url = (
-        f"{api_rest_base}/organizationalEntityFollowerStatistics"
-        f"?q=organizationalEntity"
-        f"&organizationalEntity={org_urn}"
-        f"&timeIntervals.timeRange.start={start_ms}"
-        f"&timeIntervals.timeGranularityType=MONTH"
-    )
+    api_params = {
+        "q": "organizationalEntity",
+        "organizationalEntity": org_urn,
+        "timeIntervals": time_intervals_value
+    }
+    
+    logging.info(f"Preparing to fetch monthly follower gains for {org_urn}.")
+    logging.debug(f"API Parameters for monthly gains: {json.dumps(api_params)}")
 
     results = []
+    request_url_for_logging = "Not constructed" 
+    response_obj = None # To store response for logging in broader exception blocks
+
     try:
-        response = session.get(url)
-        response.raise_for_status()  # Raises an HTTPError for bad responses (4XX or 5XX)
-        data = response.json()
+        req = requests.Request('GET', base_url, params=api_params)
+        prepared_req = session.prepare_request(req)
+        request_url_for_logging = prepared_req.url
+        
+        logging.info(f"Requesting monthly follower gains from URL: {request_url_for_logging}")
+        logging.debug(f"Request Headers for monthly gains: {json.dumps(dict(prepared_req.headers), indent=2)}")
+
+        response_obj = session.send(prepared_req, timeout=30) # Added timeout
+        response_obj.raise_for_status() 
+        data = response_obj.json()
+        
         
         elements = data.get('elements', [])
         if not elements: