Cloud-Native RFID Zoho Integration for Modern Warehouses

import time
import requests

class ZohoInventoryRfidGateway:
    def __init__(self, client_id, client_secret, refresh_token, org_id, domain="zohoapis.in"):
        self.client_id = client_id
        self.client_secret = client_secret
        self.refresh_token = refresh_token
        self.org_id = org_id
        self.domain = domain
        self.access_token = None
        self.token_expiry = 0

    def get_access_token(self):
        if time.time() < self.token_expiry and self.access_token:
            return self.access_token

        auth_domain = "accounts.zoho.in" if "zohoapis.in" in self.domain else "accounts.zoho.com"
        url = f"https://{auth_domain}/oauth/v2/token"
        params = {
            "refresh_token": self.refresh_token,
            "client_id": self.client_id,
            "client_secret": self.client_secret,
            "grant_type": "refresh_token"
        }
        res = requests.post(url, data=params, timeout=10).json()
        self.access_token = res["access_token"]
        self.token_expiry = time.time() + res.get("expires_in", 3600) - 300
        return self.access_token

    def post_adjustment(self, line_items, reference_no):
        token = self.get_access_token()
        url = f"https://www.{self.domain}/inventory/v1/inventoryadjustments?organization_id={self.org_id}"
        headers = {
            "Authorization": f"Zoho-oauthtoken {token}",
            "Content-Type": "application/json"
        }
        payload = {
            "mode": "quantity",
            "reference_number": reference_no,
            "date": time.strftime("%Y-%m-%d"),
            "reason": "RFID Handheld Cycle Count",
            "line_items": line_items
        }
        res = requests.post(url, json=payload, headers=headers, timeout=15)
        return res.json()