retrival/judgments.py

import requests
import os
from dotenv import load_dotenv

load_dotenv()

from google import genai


class LegalQueryRewriter:

    def __init__(self, api_key):

        self.client = genai.Client(
            api_key=api_key
        )

    def rewrite(
        self,
        query: str
    ):

        prompt = f"""
You are an Indian legal search expert.

Convert the user question into a concise legal search query suitable for Indian Kanoon.

Rules:
- Include legal concepts.
- Include section names if obvious.
- Remove conversational words.
- Return ONLY the search query.

Question:
{query}
"""

        response = (
            self.client.models.generate_content(
                model="gemini-2.5-flash-lite",
                contents=prompt
            )
        )

        return response.text.strip()


class KanoonClient:

    def __init__(self):

        self.token = os.getenv(
            "kanoon_token"
        )

        self.headers = {
            "Authorization":
                f"Token {self.token}"
        }

        self.rewriter = LegalQueryRewriter(
            api_key=os.getenv("GEMINI_API_KEY")
        )  

    def search(
        self,
        query: str
    ):

        url = (
            "https://api.indiankanoon.org/search/"
        )

        response = requests.post(
            url,
            headers=self.headers,
            data={
                "formInput": query
            }
        )

        return response.json()

    def get_document(
        self,
        doc_id: str
    ):

        url = (
            f"https://api.indiankanoon.org/doc/{doc_id}/"
        )

        response = requests.get(
            url,
            headers=self.headers
        )

        return response.json()
    

    def retrieve(self, query: str, top_k: int = 5):

        kanoon_query = self.rewriter.rewrite(query) or query

        search_results = self.search(kanoon_query)

        judgments = []

        for doc in search_results.get("docs", [])[:top_k]:

            doc_id = doc.get("tid") or doc.get("id")

            if not doc_id:
                continue

            try:
                full_doc = self.get_document(doc_id)
                judgments.append(full_doc)

            except Exception as e:
                print(f"Failed to fetch {doc_id}: {e}")

        return judgments