db/cloudflare.py

import requests, os

class Cloudflare():
    def __init__(self):
        self.CF_ACCOOUNT_ID=os.getenv("CF_ACCOOUNT_ID")
        self.DATABASE_ID=os.getenv("DATABASE_ID")
        self.X_Auth_Key=os.getenv("X_Auth_Key")
        self.X_Auth_Email=os.getenv("X_Auth_Email")

        # print('Cloudflare init')
        # print('self.CF_ACCOOUNT_ID',self.CF_ACCOOUNT_ID)
        # print('self.DATABASE_ID',self.DATABASE_ID)
        # print('self.X_Auth_Key',self.X_Auth_Key)
        # print('self.X_Auth_Email',self.X_Auth_Email)
   
    def execute_query(self, query):
        url = f"https://api.cloudflare.com/client/v4/accounts/{self.CF_ACCOOUNT_ID}/d1/database/{self.DATABASE_ID}/query"
        headers = {
            "X-Auth-Key": f"{self.X_Auth_Key}",
            "X-Auth-Email": f"{self.X_Auth_Email}"
        }
        input = {
            "params": [],
            "sql": query
        }
        response = requests.post(url, headers=headers, json=input)
        resp_json = response.json()
        return resp_json