tvl fix

service/scheduler.py

@@ -10,7 +10,7 @@ class Scheduler:
 
     def __init__(self):
         self.scheduler = BackgroundScheduler()
-        self.jobs = [self.update_filecoin_stat]
+        self.jobs = [self.update_filecoin_stat,self.update_filecoin_data_stat]
     
     def run(self):
         for job in self.jobs:
@@ -34,5 +34,11 @@ class Scheduler:
         # print(f"Update {text}")
         vector_store.upsert(text,"dataset_1",source='https://fvm.starboard.ventures/explorer/leaderboard?utm_source=Starboard-TLDR-HTS')
     
+    def update_filecoin_data_stat(sefl):
+        total_raw_bytes_power = api.get_fvm_storage()
+        text  = """The Data stored on the Filecoin Network is {} EiB. The Network Raw Byte Power of the Filecoin Network is {} EiB. 
+        """.format(total_raw_bytes_power,total_raw_bytes_power)
+        # print(f"Update {text}")
+        vector_store.upsert(text,"dataset_2",source='https://fvm.starboard.ventures/explorer/leaderboard?utm_source=Starboard-TLDR-HTS')
         
 

service/vector_store.py

@@ -188,7 +188,11 @@ class VectorStore(Pinecone):
 
     def upsert(self,text,id,source=''):
         embed = self.embeddings.embed_query(text)
-        vector_store._index.update(id=id,values=embed,set_metadata={"description":text,"text":text,source:source})
-        print(f"upsert text:{text} with id:{id}")
+        metadata = {"description":text,"text":text,"source":source}
+        vector_store._index.update(id=id,values=embed,set_metadata=metadata)
+        # vector_store._index.upsert(vectors=[
+        #     {'id':id,'values':embed,'metadata':metadata}]
+        # )
+        print(f"upsert text:{text} with meta:{metadata}")
 
 vector_store = VectorStore()