random-mirrors/cosmos-explorer
1
0
Fork 0
mirror of https://github.com/Azure/cosmos-explorer.git synced 2026-01-29 22:54:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixing test case

Browse Source
This commit is contained in:
Bala Lakshmi Narayanasami
2022-07-20 02:02:14 +05:30
parent 3e0694b8d2
commit e3e05e832a
1 changed files with 26 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
src/Explorer/Explorer.tsx
View File

@@ -21,7 +21,7 @@ import {
ContainerConnectionInfo, ContainerConnectionInfo,
IPhoenixConnectionInfoResult, IPhoenixConnectionInfoResult,
IProvisionData, IProvisionData,
IResponse, IResponse
} from "../Contracts/DataModels"; } from "../Contracts/DataModels";
import * as ViewModels from "../Contracts/ViewModels"; import * as ViewModels from "../Contracts/ViewModels";
import { GitHubOAuthService } from "../GitHub/GitHubOAuthService"; import { GitHubOAuthService } from "../GitHub/GitHubOAuthService";
@@ -468,26 +468,35 @@ export default class Explorer {
} }
private async generateConversationToken() { private async generateConversationToken() {
if (!userContext.databaseAccount || !userContext.databaseAccount.id) {
console.error("Database account undefined");
return;
}
const url = `${configContext.JUNO_ENDPOINT}/api/chatbot/bot${userContext.databaseAccount.id}/conversationToken`; const url = `${configContext.JUNO_ENDPOINT}/api/chatbot/bot${userContext.databaseAccount.id}/conversationToken`;
const authorizationHeader = getAuthorizationHeader(); const authorizationHeader = getAuthorizationHeader();
try {
const response = await fetch(url, {
method: "GET",
headers: {
[Constants.HttpHeaders.authorization]: authorizationHeader.token,
Accept: "application/json",
[Constants.HttpHeaders.contentType]: "application/json",
},
});
const response = await fetch(url, { if (!response.ok) {
method: "GET", throw new Error(await response.json());
headers: { }
[Constants.HttpHeaders.authorization]: authorizationHeader.token,
Accept: "application/json",
[Constants.HttpHeaders.contentType]: "application/json",
},
});
if (!response.ok) { const tokenResponse: { conversationId: string; token: string; expires_in: number } = await response.json();
throw new Error(await response.json()); this.conversationToken(tokenResponse?.token);
} if (tokenResponse?.expires_in) {
setTimeout(() => this.generateConversationToken(), (tokenResponse?.expires_in - 1000) * 1000);
const tokenResponse: { conversationId: string; token: string; expires_in: number } = await response.json(); }
this.conversationToken(tokenResponse?.token); } catch (error) {
if (tokenResponse?.expires_in) { console.error("Error fetching conversation token");
setTimeout(() => this.generateConversationToken(), (tokenResponse?.expires_in - 1000) * 1000); console.error(error);
} }
} }