cql using access token

[Bhuvan Annamalai]

im trying to create a chatbot where multiple users can query thier spaces,for that i haved oauth to get access token for each user though which i can query using cql

but im getting this error while searching

{
  "detail": {
    "code": 403,
    "message": "The app is not installed on this instance"
  }
}

this is my code

from fastapi import FastAPI, HTTPException

import requests

app = FastAPI()

# OAuth credentials

CLIENT_ID = "XWoOJPPwkFsdvXLp5ZA"

CLIENT_SECRET = "ATOACRoruoGA2E_S9FSKmLbuHrLp2EcT640EE26CA"

REDIRECT_URI = 'http://localhost:8000/callback'

STATIC_SPACE_KEY = "REDESIGN"

def get_access_token(code: str):

    """

    Exchange the authorization code for an access token.

    """

    token_url = "https://auth.atlassian.com/oauth/token"

    payload = {

        "grant_type": "authorization_code",

        "client_id": CLIENT_ID,

        "client_secret": CLIENT_SECRET,

        "code": code,

        "redirect_uri": REDIRECT_URI,

    }

    response = requests.post(token_url, json=payload)

    if response.status_code != 200:

        raise HTTPException(status_code=response.status_code, detail=response.json())

    return response.json()["access_token"]

def get_cloud_id(access_token: str):

    """

    Retrieve the cloud ID for the user.

    """

    url = "https://api.atlassian.com/oauth/token/accessible-resources"

    headers = {"Authorization": f"Bearer {access_token}"}

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

    if response.status_code != 200 or not response.json():

        raise HTTPException(status_code=404, detail="Unable to retrieve cloud ID.")

    return response.json()[0]["id"]

def query_pages(access_token: str, cloud_id: str):

    """

    Query all pages under the static space 'REDESIGN'.

    """

    cql = f"type=page AND space='{STATIC_SPACE_KEY}'"

    url = f"https://api.atlassian.com/ex/confluence/{cloud_id}/wiki/rest/api/content/search"

    headers = {

        "Authorization": f"Bearer {access_token}",

        "Accept": "application/json",

    }

    params = {"cql": cql, "expand": "body.storage"}

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

    if response.status_code != 200:

        raise HTTPException(status_code=response.status_code, detail=response.json())

    return [

        {

            "title": result["title"],

            "id": result["id"],

            "url": f"https://your-confluence-site.com{result['_links']['webui']}",

            "content": result.get("body", {}).get("storage", {}).get("value", "No Content"),

        }

        for result in response.json().get("results", [])

    ]

@app.get("/callback")

def callback(code: str):

    """

    Callback endpoint to handle OAuth redirect, fetch access token, and query pages.

    """

    # Step 1: Exchange the authorization code for an access token

    access_token = get_access_token(code)

    print("access token = ",access_token)

    # Step 2: Retrieve the cloud ID

    cloud_id = get_cloud_id(access_token)

    print("cloud id = ",cloud_id)

    # Step 3: Query pages under the static space 'REDESIGN'

    pages = query_pages(access_token, cloud_id)

    # Step 4: Return the queried pages

    return {"space": STATIC_SPACE_KEY, "pages": pages}

if __name__ == "__main__":

    import uvicorn

    uvicorn.run(app, host="0.0.0.0", port=8000)

this is my code

[Humashankar VJ]

Hi @Bhuvan Annamalai 

Ensure that the OAuth app is installed correctly and completely, and double-check that the client ID, client secret, and redirect URI are accurate.

As well, confirm that all necessary scopes are enabled and validate the app permissions in the Confluence admin settings to ensure that they are correctly configured.

Hope this helps - Happy to help further!!
Thank you very much and have a great one!
Warm regards