Update app.py

app.py

@@ -38,53 +38,113 @@ DEFAULT_PROJECT_GID = "1209104858113361"
 
 def create_asana_task(name, due_date=None):
     """Create a task in Asana."""
-    url = f"{ASANA_BASE_URL}/tasks"
-    data = {
-        "data": {
-            "name": name,
-            "projects": [DEFAULT_PROJECT_GID]
+    api_client = None  # Initialize to None
+    try:
+        configuration = asana.Configuration()
+        configuration.access_token = access_token
+        api_client = asana.ApiClient(configuration)
+        tasks_api = asana.TasksApi(api_client)
+
+        url = f"{ASANA_BASE_URL}/tasks"  # Construct the URL for creating tasks
+        data = {
+            "data": {
+                "name": name,
+                "projects": [DEFAULT_PROJECT_GID]
+            }
         }
-    }
-    if due_date:
-        data["data"]["due_on"] = due_date  # Asana uses 'due_on' in YYYY-MM-DD format
-    resp = requests.post(url, json=data, headers=ASANA_HEADERS)
-    if resp.status_code == 201:
-        return resp.json()["data"]  # returns the newly created task object
-    else:
-        return {"error": resp.text}
+        if due_date:
+            data["data"]["due_on"] = due_date  # Asana uses 'due_on' in YYYY-MM-DD format
+
+        # Create the task using the requests library
+        headers = {
+            'Authorization': f'Bearer {access_token}',
+            'Content-Type': 'application/json',
+        }
+        response = requests.post(url, headers=headers, json={"data": data["data"]})
+
+        if response.status_code == 201:
+            return response.json()["data"]  # returns the newly created task object
+        else:
+            return {"error": response.text}
+
+    except Exception as e:
+        print(f"Exception when creating task: {e}\n")
+        return {"error": str(e)}
+    finally:
+        if api_client:
+            api_client.close()
 
 def list_asana_tasks(only_open=True):
     """List tasks in the default project, optionally filtering for only open tasks."""
-    url = f"{ASANA_BASE_URL}/projects/{DEFAULT_PROJECT_GID}/tasks"
-    params = {
-        "opt_fields": "name,completed"  # Include the "completed" field to verify task status
-    }
-    if only_open:
-        params["completed_since"] = "now"  # Fetch only incomplete or recently updated tasks
-
-    resp = requests.get(url, headers=ASANA_HEADERS, params=params)
-    if resp.status_code == 200:
-        tasks = resp.json()["data"]
-        if only_open:
-            # Filter out completed tasks if only_open is True
-            tasks = [task for task in tasks if not task.get("completed", False)]
-        return tasks
-    else:
-        return {"error": resp.text}
+    api_client = None
+    try:
+        configuration = asana.Configuration()
+        configuration.access_token = access_token
+        api_client = asana.ApiClient(configuration)
+        tasks_api = asana.TasksApi(api_client)
+
+        url = f"{ASANA_BASE_URL}/projects/{DEFAULT_PROJECT_GID}/tasks"
+        params = {
+            "opt_fields": "name,completed",
+            "completed_since": "now" if only_open else None
+        }
+
+        headers = {
+            'Authorization': f'Bearer {access_token}',
+            'Accept': 'application/json',
+        }
+
+        response = requests.get(url, headers=headers, params=params)
+
+        if response.status_code == 200:
+            tasks = response.json()["data"]
+            if only_open:
+                tasks = [task for task in tasks if not task.get("completed", False)]
+            return tasks
+        else:
+            return {"error": response.text}
+
+    except Exception as e:
+        print(f"Exception when listing tasks: {e}\n")
+        return {"error": str(e)}
+    finally:
+        if api_client:
+            api_client.close()
 
 def complete_asana_task(task_gid):
     """Mark a task as complete."""
-    url = f"{ASANA_BASE_URL}/tasks/{task_gid}"
-    data = {
-        "data": {
-            "completed": True
+    api_client = None
+    try:
+        configuration = asana.Configuration()
+        configuration.access_token = access_token
+        api_client = asana.ApiClient(configuration)
+        tasks_api = asana.TasksApi(api_client)
+
+        url = f"{ASANA_BASE_URL}/tasks/{task_gid}"
+        data = {
+            "data": {
+                "completed": True
+            }
         }
-    }
-    resp = requests.put(url, json=data, headers=ASANA_HEADERS)
-    if resp.status_code == 200:
-        return resp.json()["data"]
-    else:
-        return {"error": resp.text}
+
+        headers = {
+            'Authorization': f'Bearer {access_token}',
+            'Content-Type': 'application/json',
+        }
+
+        response = requests.put(url, headers=headers, json=data)
+
+        if response.status_code == 200:
+            return response.json()["data"]
+        else:
+            return {"error": response.text}
+
+    except Exception as e:
+        print(f"Exception when completing task: {e}\n")
+        return {"error": str(e)}
+    finally:
+        if api_client:
+            api_client.close()
 
 def call_llm(user_message, conversation_history=None):
     today_date = datetime.date.today().strftime("%Y-%m-%d")