Update app.py

app.py

@@ -36,119 +36,55 @@ ASANA_HEADERS = {
 
 DEFAULT_PROJECT_GID = "1209104858113361"
 
-''''
-
 def create_asana_task(name, due_date=None):
     """Create a task in Asana."""
-    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
-
-        # Create the task using the requests library
-        headers = {
-            'Authorization': f'Bearer {access_token}',
-            'Content-Type': 'application/json',
+    url = f"{ASANA_BASE_URL}/tasks"
+    data = {
+        "data": {
+            "name": name,
+            "projects": [DEFAULT_PROJECT_GID]
         }
-        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()
+    }
+    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}
 
 def list_asana_tasks(only_open=True):
     """List tasks in the default project, optionally filtering for only open tasks."""
-    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()
+    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}
 
 def complete_asana_task(task_gid):
     """Mark a task as complete."""
-    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
-            }
-        }
-
-        headers = {
-            'Authorization': f'Bearer {access_token}',
-            'Content-Type': 'application/json',
+    url = f"{ASANA_BASE_URL}/tasks/{task_gid}"
+    data = {
+        "data": {
+            "completed": True
         }
-
-        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()
-
-'''            
+    }
+    resp = requests.put(url, json=data, headers=ASANA_HEADERS)
+    if resp.status_code == 200:
+        return resp.json()["data"]
+    else:
+        return {"error": resp.text}         
 
 def call_llm(user_message, conversation_history=None):
     today_date = datetime.date.today().strftime("%Y-%m-%d")