import os
import requests

ZOHO_BASE_URL = os.getenv("ZOHO_BASE_URL")
ZOHO_CLIENT_ID = os.getenv("ZOHO_CLIENT_ID")
ZOHO_CLIENT_SECRET = os.getenv("ZOHO_CLIENT_SECRET")
ZOHO_REFRESH_TOKEN = os.getenv("ZOHO_REFRESH_TOKEN")

def get_access_token():
    url = f"https://accounts.zoho.com/oauth/v2/token"
    params = {
        "refresh_token": ZOHO_REFRESH_TOKEN,
        "client_id": ZOHO_CLIENT_ID,
        "client_secret": ZOHO_CLIENT_SECRET,
        "grant_type": "refresh_token",
    }
    response = requests.post(url, params=params)
    data = response.json()
    return data.get("access_token")

def fetch_zoho_data(module_name):
    token = get_access_token()
    headers = {"Authorization": f"Zoho-oauthtoken {token}"}
    url = f"{ZOHO_BASE_URL}/crm/v2/{module_name}"
    response = requests.get(url, headers=headers)
    return response.json()