Update linkedin_follower_stats.py

linkedin_follower_stats.py

@@ -195,24 +195,30 @@ def fetch_monthly_follower_gains(session, org_urn, api_rest_base):
     # )
     # logging.info(f"Fetching monthly follower gains from URL: {url}")
 
-    now = datetime.now(timezone.utc)
+    linkedin.headers.update({'LinkedIn-Version': "202502"})
+    # Replace with your LinkedIn organization URN
+    
+    now = datetime.now()
+
+    # Subtract 12 months
     twelve_months_ago = now - timedelta(days=365)
     twelve_months_ago = twelve_months_ago.replace(day=1)
-
-    start_date = int(twelve_months_ago.timestamp() * 1000)
-    end_date = int(now.timestamp() * 1000)  # You could omit this if letting LinkedIn default
-
-    time_intervals = f"(timeRange:(start:{start_date},end:{end_date}),timeGranularityType:MONTH)"
-
-    url = (
-        f"{api_rest_base}/organizationalEntityFollowerStatistics"
-        f"?q=organizationalEntity"
-        f"&organizationalEntity={org_urn}"
-        f"&timeIntervals={time_intervals}"
+    
+    start_date1 = int(twelve_months_ago.timestamp() * 1000)
+    
+    # Build the URL with time interval parameters
+    orgs_url = (
+    "https://api.linkedin.com/rest/organizationalEntityFollowerStatistics"
+    f"?q=organizationalEntity"
+    f"&organizationalEntity={org_urn}"
+    f"&timeIntervals.timeGranularityType=MONTH"
+    f"&timeIntervals.timeRange.start={start_date1}"
+    #f"&timeIntervals.timeRange.end={end_ms}"
     )
 
     results = []
     try:
+        
         response = session.get(url)
         response.raise_for_status()  # Raises an HTTPError for bad responses (4XX or 5XX)
         data = response.json()
@@ -396,11 +402,12 @@ def get_linkedin_follower_stats(comm_client_id, community_token, org_urn):
 
     all_follower_data = []
 
-    monthly_gains = fetch_monthly_follower_gains(session, org_urn, API_REST_BASE)
-    all_follower_data.extend(monthly_gains)
-
     demographics = fetch_follower_demographics(session, org_urn, functions_map, seniorities_map)
     all_follower_data.extend(demographics)
 
+    session = create_session(comm_client_id, token=token_dict) #try a new session with base header because follower gains is not working
+    monthly_gains = fetch_monthly_follower_gains(session, org_urn, API_REST_BASE)
+    all_follower_data.extend(monthly_gains)
+
     logging.info(f"Successfully compiled {len(all_follower_data)} total follower stat entries for {org_urn}.")
     return all_follower_data