from astrapy import DataAPIClient
import base64
import zlib

# Initialize the client
client1 = DataAPIClient("AstraCS:vUPtWJNjuqSJzFwpjwGaIMCG:a763d288a24184d3d8f87e78d8f3a9bdb4e687002ea80fb3e21949b969715b7f")
db1 = client1.get_database_by_api_endpoint(
  "https://ab618096-30bc-47c4-85ac-1a97c75e746c-us-east-2.apps.astra.datastax.com"
)
coll1="kk"



client2= DataAPIClient("AstraCS:ZZUTCqocrzQiBhtvlEPfKqRq:b556beac8fc27ab35a3075db0d1fb34fde88872313673836f14ab3f5a1fb8438")
db2= client2.get_database_by_api_endpoint(
  "https://b4031b92-c3c2-46af-a2ff-bf39cd832d0a-us-east-2.apps.astra.datastax.com"
)
coll2="uq"


class DatabaseEngine():
    def __init__(self):
        pass

    
    def Update(self,data):
        
        collection=db1.get_collection(coll1)
        collection.update_one(
         {"version": data["promptversion"]},
            
         {"$set": {
             "biological_context_alignment":data["biological_context_alignment"],
             "contextual_relevance_alignment":data["contextual_relevance_alignment"],
             "unit_coherence":data["unit_coherence"],
             "response_specificity":data["response_specificity"]
         }
         },
        )

    
    def GetData(self,promptversion):
        
        collection1=db1.get_collection(coll1)
        collection2=db2.get_collection(coll2)
        
        promptdocument = collection1.find_one({"version":promptversion})
        

        contextdocument=collection2.find_one({"version":promptversion,"type":"context"})
        responsedocument=collection2.find_one({"version":promptversion,"type":"response"})

        
        actual_saved_response=responsedocument["response"]
        actual_saved_context=contextdocument["context"]
        actual_saved_prompt=promptdocument["prompt"]

        
        compressed_response_data = base64.b64decode(actual_saved_response)
        decompressed_data = zlib.decompress(compressed_response_data)
        actual_original_response=decompressed_data.decode("utf-8")


        compressed_context_data = base64.b64decode(actual_saved_context)
        decompressed_context_data = zlib.decompress(compressed_context_data)
        actual_original_context=decompressed_context_data.decode("utf-8")

        
        return {
            "prompt":actual_saved_prompt,
            "context":actual_original_context,
            "response":actual_original_response
        }