small revert

app.py

@@ -53,40 +53,37 @@ api = HfApi()
 """"""
 #csv_file = 'data.csv'
 global_df = pd.DataFrame()
-worksheet2_df = pd.DataFrame()
 print(type(global_df))
 community_global_df = pd.DataFrame() 
 data = pd.read_csv("https://docs.google.com/spreadsheets/d/1hQSsIg1Y9WdBF_CdNM1L1rUUREoxKqRTe3_ILo-WK8w/export?format=csv&gid=0")
-data2 = pd.read_csv("https://docs.google.com/spreadsheets/d/1T_twNONDSZ8zw7aDcYhw92DlawqPktti1xFw9ssJ13Y/edit#gid=0")
-
 
 @bot.event
 async def on_ready():
     try:
         global global_df
-        global worksheet2_df
         await asyncio.sleep(1.1)
         print(f'Logged in as {bot.user.name}')
         print(f"XP_PER_MESSAGE: {XP_PER_MESSAGE}")
+        # testing sheet -> read -> paste sheet
+    
+        """import data from google sheets -> HF Space .csv (doesn't make API call this way, as it's read-only)""" 
     
-        """import data from google sheets -> HF Space df (doesn't make API call this way, as it's read-only)""" 
         data['discord_user_id'] = data['discord_user_id'].astype(str)
         global_df = data
         print(f"csv successfully retrieved: \n {global_df}")
-        worksheet2_df = data2
+        #data.to_csv(csv_file, index=False)
 
-        # updates both leaderboards
         remove_huggingfolks.start()
-        await(periodic_api_test)
         print(f"------------------------------------------------------------------------")
     except Exception as e:
         print(f"on_message Error: {e}")
 
 
 def update_google_sheet():
-    """save data from HF Space -> google sheets (makes 2 API calls)"""
+    """save data from HF Space -> google sheets (makes 1 API call)"""
+    # run this in separate thread?
     try:
-        print("Updating google sheets...")
+        print("Updating...")
         name = "levelbot"
         #worksheet = gspread_bot.open(name).sheet1
         global_df['discord_user_id'] = global_df['discord_user_id'].astype(str)
@@ -107,8 +104,14 @@ def update_google_sheet():
 
 executor = ThreadPoolExecutor(max_workers=1)
 scheduler = BackgroundScheduler(executors={'default': executor})
-scheduler.add_job(update_google_sheet, trigger='interval', minutes=1, max_instances=1)
+scheduler.add_job(update_google_sheet, trigger='interval', minutes=2, max_instances=1)
 scheduler.start()
+"""
+scheduler = BackgroundScheduler()
+scheduler.add_job(update_google_sheet, "interval", seconds=60)
+scheduler.start()
+
+"""
 
 
 def calculate_level(xp):
@@ -119,7 +122,41 @@ def calculate_xp(level):
     return (int(level ** 3))
 
 
- 
+processed_users = set()
+
+async def periodic_api_test(): # needs rewrite, can do same thing and interact with csv -> push to google sheets
+    try:
+        await asyncio.sleep(0.1)
+        column_values_3 = worksheet2.col_values(3)
+        column_values_8 = worksheet2.col_values(8)
+    
+        for i, user in enumerate(column_values_3):
+            if user in processed_users:
+                continue
+    
+            url = f"https://huggingface.co/api/users/{user}/overview"
+            response = requests.get(url)
+    
+            if response.status_code == 200:
+                data = response.json()
+    
+                likes = data["numLikes"]
+                models = data["numModels"]
+                datasets = data["numDatasets"]
+                spaces = data["numSpaces"]
+                discussions = data["numDiscussions"]
+                papers = data["numPapers"]
+                upvotes = data["numUpvotes"]
+    
+                worksheet2.update(values=[[likes, models, datasets, spaces, discussions, papers, upvotes]],
+                                  range_name=f'G{i+1}:M{i+1}')
+    
+                processed_users.add(user)
+            else:
+                print(f"Failed to retrieve data for user {user}. Status code: {response.status_code}")
+            
+    except Exception as e:
+        print(f"periodic_api_test Error: {e}")    
 
     
 async def add_exp(member_id):
@@ -231,7 +268,7 @@ async def add_exp(member_id):
 
                             #lunar = bot.get_user(811235357663297546)
                             await member.send(embed=embed)                           
-                            print(f"Sent levelup embed to {member}")
+
                             #You can verify your account to earn 100 points! To verify, do A.                            
 
                             
@@ -274,7 +311,7 @@ async def on_message(message):
 async def on_reaction_add(reaction, user):
     try:
         if user.id not in bot_ids:
-            print(f"adding exp from react {user}")
+            print(f"adding exp from react {user.id}")
             await asyncio.sleep(0.1)            
             await add_exp(user.id)
             await asyncio.sleep(0.1)
@@ -298,25 +335,25 @@ async def remove_huggingfolks():
         for member_id in members_with_role:
             community_global_df = community_global_df[community_global_df.iloc[:, 0] != str(member_id)]
 
-        #print(community_global_df)
+        print(community_global_df)
 
         community_global_df.drop(community_global_df.columns[0], axis=1, inplace=True)
         community_global_df['discord_exp'] = pd.to_numeric(community_global_df['discord_exp'])
         community_global_df = community_global_df.nlargest(len(community_global_df), 'discord_exp')        
         
         top_30_exp = community_global_df.nlargest(30, 'discord_exp')
+        #community_global_df = top_30_exp.copy() # for gradio
         
         top_30_exp['D'] = ['🥇','🥈','🥉','','','','','','','','','','','','','','','','','','','','','','','','','','','']
         top_30_rows = top_30_exp.values.tolist()
 
-        #print(top_30_rows)
+        print(top_30_rows)
         channel = bot.get_channel(1197143964994773023)
         message = await channel.fetch_message(1197148293164187678)
 
         # put into message / leaderboard
         new_table = tabulate(top_30_rows, headers=["Name", "Experience", "Level", "Rank"], tablefmt="plain")
         await message.edit(content=f"Updated Leaderboard:\n```\n{new_table}\n```")
-        print(f"Updated discord leaderboard!")
         
     except Exception as e:
         print(f"remove_huggingfolks Error: {e}")
@@ -342,13 +379,24 @@ async def count_users_with_role(ctx, role_id):
 # embeds with user pfps? 
 # name, pfp, time in server....
 
+# discord_level column
+# pick 10 highest
+# update
+
 # weekly do different count
 # count number of messages per user for every channel (total messages)
 # fix sheet if necessary
+
+# might need cell location data to pull both level and username at same time
 # add emojis for some color
 # check if members are still in the server 
 
 
+
+
+    
+
+
 """"""
 DISCORD_TOKEN = os.environ.get("DISCORD_TOKEN", None)
 def run_bot():
@@ -365,7 +413,10 @@ def get_data():
         return community_global_df   
     except Exception as e:
         print(f"on_message Error: {e}")
-
+# csv
+# read into pandas dataframe1
+# read levels column and create pandas dataframe2 with first column containing levels from 2-max found in dataframe1
+# create second column in dataframe2 for number of each level found in dataframe1 levels column
 
 demo = gr.Blocks()
 with demo:
@@ -407,4 +458,3 @@ with demo:
         print(f"on_message Error: {e}")
 demo.queue().launch()       
 
-