Update linkedin_follower_stats.py

linkedin_follower_stats.py

@@ -1,3 +1,4 @@
+# -- coding: utf-8 --
 import json
 import requests
 import logging
@@ -26,7 +27,7 @@ def _fetch_linkedin_names(session, url, params, result_key_path, name_key_path,
     request_url_for_logging = url 
     response_obj = None 
     try:
-        logging.debug(f"_fetch_linkedin_names: About to prepare request. Session token: {session.token}")
+        logging.debug(f"_fetch_linkedin_names: About to prepare request. Session token: {session.token}, Session authorized: {session.authorized}")
         req = requests.Request('GET', url, params=params)
         prepared_req = session.prepare_request(req) 
         request_url_for_logging = prepared_req.url
@@ -132,7 +133,7 @@ def get_industries_map(session, industry_urns, version="DEFAULT"):
     response_obj = None
     logging.info(f"Fetching all industries (to filter {len(unique_ids)} IDs)")
     try:
-        logging.debug(f"get_industries_map: About to prepare request. Session token: {session.token}")
+        logging.debug(f"get_industries_map: About to prepare request. Session token: {session.token}, Session authorized: {session.authorized}")
         req = requests.Request('GET', url, params=params)
         prepared_req = session.prepare_request(req)
         request_url_for_logging = prepared_req.url
@@ -145,7 +146,6 @@ def get_industries_map(session, industry_urns, version="DEFAULT"):
         elements = data.get('elements', [])
 
         mapping = {}
-        # ... (rest of the function)
         for el in elements:
             el_id = el.get('id')
             if el_id and str(el_id) in unique_ids:
@@ -200,7 +200,6 @@ def get_geo_map(session, geo_urns):
         geo_params = { 'ids': ids_param_value, 'locale': locale_param_value }
         
         logging.info(f"Fetching names for {len(chunk_ids)} geo IDs (chunk {i//MAX_GEO_IDS_PER_CALL + 1})")
-        # _fetch_linkedin_names will log its own session.token
         chunk_mapping = _fetch_linkedin_names(session, url, geo_params, ["results"], ["defaultLocalizedName", "value"])
         all_geo_mappings.update(chunk_mapping)
         
@@ -244,8 +243,7 @@ def fetch_monthly_follower_gains(session, org_urn, api_rest_base_url):
     response_obj = None 
 
     try:
-        # ***** ADDED LOGGING HERE *****
-        logging.debug(f"fetch_monthly_follower_gains: About to prepare request. Session token: {session.token}")
+        logging.debug(f"fetch_monthly_follower_gains: About to prepare request. Session token: {session.token}, Session authorized: {session.authorized}")
         if session.token and 'access_token' in session.token:
             logging.debug(f"fetch_monthly_follower_gains: Access token (partial): {str(session.token['access_token'])[:20]}...")
         else:
@@ -263,7 +261,6 @@ def fetch_monthly_follower_gains(session, org_urn, api_rest_base_url):
         data = response_obj.json()
         
         elements = data.get('elements', [])
-        # ... (rest of the function)
         if not elements:
             logging.info(f"No 'elements' found in monthly follower gains API response for {org_urn} (start_ms {start_ms}). Response data: {json.dumps(data, indent=2)}")
 
@@ -334,8 +331,7 @@ def fetch_follower_demographics(session, org_urn, functions_map, seniorities_map
     response_obj = None
 
     try:
-        # ***** ADDED LOGGING HERE *****
-        logging.debug(f"fetch_follower_demographics: About to prepare request. Session token: {session.token}")
+        logging.debug(f"fetch_follower_demographics: About to prepare request. Session token: {session.token}, Session authorized: {session.authorized}")
         if session.token and 'access_token' in session.token:
             logging.debug(f"fetch_follower_demographics: Access token (partial): {str(session.token['access_token'])[:20]}...")
         else:
@@ -353,7 +349,6 @@ def fetch_follower_demographics(session, org_urn, functions_map, seniorities_map
         data = response_obj.json()
         
         elements = data.get("elements", [])
-        # ... (rest of the function)
         if not elements:
             logging.warning(f"No elements found in follower demographics response for {org_urn}. Response data: {json.dumps(data, indent=2)}")
             return []
@@ -486,8 +481,7 @@ def get_linkedin_follower_stats(comm_client_id, community_token, org_urn):
             "Accept-Language": "en_US" 
         })
         logging.info(f"Session created and headers updated for org {org_urn}.")
-        # ***** ADDED LOGGING HERE *****
-        logging.debug(f"get_linkedin_follower_stats: Session token after creation and header update: {session.token}")
+        logging.debug(f"get_linkedin_follower_stats: Session token after creation and header update: {session.token}, Session authorized: {session.authorized}")
         if session.token and 'access_token' in session.token:
              logging.debug(f"get_linkedin_follower_stats: Access token in session (partial): {str(session.token['access_token'])[:20]}...")
         else:
@@ -519,4 +513,4 @@ def get_linkedin_follower_stats(comm_client_id, community_token, org_urn):
     else:
         logging.info(f"Successfully compiled {len(all_follower_data)} total follower stat entries for {org_urn}.")
     
-    return all_follower_data
+    return all_follower_data