This topic was automatically generated from Slack. You can find the original thread here.
Needed help to check if this issue is fixed
cc @U095BDJKWBB @U094SC3LJR1
Did you see ’s response?
checked but not helping us in getting answer as we are facing the same issue.
@U095BDJKWBB from my team is working on it and is not able to resolve it
Can you please elaborate on the issue?
Hi We are using Vue.js and Python for creating an like chat.pipedream.com for the instance we are able to connect with the MCP server, and proper tool calling (e.g Slack). We are also able to authorize the user for the slack. but we are stuck of re-confirming the Token. We are using stream and while fetching back the connected app for the user it respond back empty.
I’m not sure I’m following. What do you mean reconfirming the token?
Can you show the error? What are you calling and what is the error?
Let me share the code, api calls and response I am getting.
Request: http://localhost:3000/api/v1/chat/d1f6b633-28e6-44ea-80a9-0beaff08d45c?sync_with_pipedream=true
Method: GET
{
“id”: “d1f6b633-28e6-44ea-80a9-0beaff08d45c”,
“title”: “New Chat”,
“visibility”: “private”,
“pipedream_chat_id”: null,
“pipedream_synced”: false,
“created_at”: “2025-07-16T06:17:04.249943”,
“updated_at”: “2025-07-16T06:17:04.249947”,
“messages”: [
{
“id”: “a4376fae-131b-4d28-a4c0-c21345394fba”,
“role”: “user”,
“content”: “Send a slack notification to channel mailgun-notifications”,
“pipedream_message_id”: null,
“tool_calls”: null,
“created_at”: “2025-07-16T06:17:31.995291”
},
{
“id”: “c13c1419-f642-44b0-8965-48d0275d2b88”,
“role”: “assistant”,
“content”: “To send a Slack notification, you’ll first need to connect your Slack account. Please click the link below to authorize Slack:\n\nConnect your Slack account\n\nOnce you’ve connected your account, let me know, and I can help you send the notification to the mailgun-notifications channel!”,
“pipedream_message_id”: null,
“tool_calls”: null,
“created_at”: “2025-07-16T06:19:06.889659”
}
]
}
and in the status API we are always getting following
URL: http://localhost:3000/api/v1/auth-flow/accounts/slack/status
{
“app”: “slack”,
“connected”: false,
“account_id”: null,
“details”: {
“connected”: false,
“message”: “No connected slack account found”
}
}
And what’s the error? I see that Connect Link URL is incomplete, it isn’t coming from our server like that, so somewhere downstream it’s becoming malformed.
But what’s the actual error?
And what’s the error? I see that Connect Link URL is incomplete, it isn’t coming from our server like that, so somewhere downstream it’s becoming malformed.
no error slack or any other tool not functional due to connection issue.
Can you please explain Connect Link URL is incomplete .
so somewhere downstream it’s becoming malformed. not sure about this. pasting my code here below.
async def stream_chat_response(
self,
chat_id: str,
message: str,
model: str = "gpt-4o-mini",
tools: Optional[List[Dict[str, Any]]] = None
) -> AsyncGenerator[Dict[str, Any], None]:
"""Stream chat response directly from Pipedream's chat API"""
try:
headers = await self.get_headers()
headers["Accept"] = "text/event-stream"
payload = {
"message": message,
"model": model,
"chatId": chat_id,
"userId": self.pipedream_user_id,
"externalUserId": self.user_id,
"stream": True
}
if tools:
payload["tools"] = tools
async with httpx.AsyncClient(timeout=120.0) as client:
async with client.stream(
"POST",
f"{self.chat_base_url}/chat/stream",
headers=headers,
json=payload
) as response:
if response.status_code == 200:
buffer = ""
async for chunk in response.aiter_text():
buffer += chunk
# Process complete lines
while '\n' in buffer:
line, buffer = buffer.split('\n', 1)
line = line.strip()
if line.startswith('data: '):
try:
data = json.loads(line[6:])
yield data
except json.JSONDecodeError:
# Handle non-JSON data
content = line[6:]
if content and content != '[DONE]':
yield {"content": content}
elif line.startswith('f:'):
# Handle messageId format from Pipedream
try:
data = json.loads(line[2:])
yield {"messageId": data.get("messageId")}
except json.JSONDecodeError:
pass
elif line.startswith('0:'):
# Handle content chunks
content = line[2:].strip('"')
if content:
yield {"content": content}
elif line.startswith('9:'):
# Handle tool calls
try:
tool_data = json.loads(line[2:])
yield {"tool_call": tool_data}
except json.JSONDecodeError:
pass
elif line.startswith('a:'):
# Handle assistant responses
try:
assistant_data = json.loads(line[2:])
yield {"assistant": assistant_data}
except json.JSONDecodeError:
pass
elif line == 'event: done':
yield {"done": True}
return
else:
print(f":x: Streaming failed: {response.status_code} - {response.text}")
yield {"error": f"Streaming failed: {response.status_code}"}
except Exception as e:
print(f":x: Error streaming from Pipedream: {e}")
yield {"error": f"Streaming error: {str(e)}"}
I can’t help you debug the code in your app, I can just help with the Connect API and Pipedream MCP.
I get your point and totally agree but, after authorization is complete, the app should be connected, as the things are happening on the stream. no?
its showing connected on Pipedream but unable to get it
Maybe there’s something up with how you’re defining and passing your Pipedream credentials. That might be a place to dig in.
hmm, okay thank you . appreciated.