jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

ui: change endpoints to prod

Browse source
This commit is contained in:
nick-delirium 2025-05-12 17:36:31 +02:00
parent b524af2b70
commit c4236cae6e
No known key found for this signature in database
GPG key ID: 93ABD695DF5FDBA0
2 changed files with 11 additions and 58 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

61
frontend/app/components/Kai/KaiService.ts
View file

@ -2,15 +2,7 @@ import AiService from "@/services/AiService";
export default class KaiService extends AiService {
getKaiChats = async (projectId: string): Promise<{ title: string, threadId: string }[]> => {
// const r = await this.client.get('/kai/PROJECT_ID/chats');
const jwt = this.client.getJwt()
const r = await fetch(`http://localhost:8700/kai/${projectId}/chats`, {
headers: new Headers({
Accept: 'application/json',
'Content-Type': 'application/json',
'Authorization': `Bearer ${jwt}`
}),
});
const r = await this.client.get(`/kai/${projectId}/chats`);
if (!r.ok) {
throw new Error('Failed to fetch chats');
}
@ -19,15 +11,7 @@ export default class KaiService extends AiService {
}
deleteKaiChat = async (projectId: string, threadId: string): Promise<boolean> => {
const jwt = this.client.getJwt()
const r = await fetch(`http://localhost:8700/kai/${projectId}/chats/${threadId}`, {
method: 'DELETE',
headers: new Headers({
Accept: 'application/json',
'Content-Type': 'application/json',
'Authorization': `Bearer ${jwt}`
}),
});
const r = await this.client.delete(`/kai/${projectId}/chats/${threadId}`);
if (!r.ok) {
throw new Error('Failed to delete chat');
}
@ -35,15 +19,7 @@ export default class KaiService extends AiService {
}
getKaiChat = async (projectId: string, threadId: string): Promise<{ role: string, content: string, message_id: any, duration?: number }[]> => {
const jwt = this.client.getJwt()
const r = await fetch(`http://localhost:8700/kai/${projectId}/chats/${threadId}`, {
method: 'GET',
headers: new Headers({
Accept: 'application/json',
'Content-Type': 'application/json',
'Authorization': `Bearer ${jwt}`
}),
});
const r = await this.client.get(`/kai/${projectId}/chats/${threadId}`);
if (!r.ok) {
throw new Error('Failed to fetch chat');
}
@ -52,15 +28,7 @@ export default class KaiService extends AiService {
}
createKaiChat = async (projectId: string): Promise<number> => {
const jwt = this.client.getJwt()
const r = await fetch(`http://localhost:8700/kai/${projectId}/chat/new`, {
method: 'GET',
headers: new Headers({
Accept: 'application/json',
'Content-Type': 'application/json',
'Authorization': `Bearer ${jwt}`
}),
})
const r = await this.client.get(`/kai/${projectId}/chat/new`)
if (!r.ok) {
throw new Error('Failed to create chat');
}
@ -69,19 +37,10 @@ export default class KaiService extends AiService {
}
feedback = async (positive: boolean | null, messageId: string, projectId: string) => {
const jwt = this.client.getJwt()
const r = await fetch(`http://localhost:8700/kai/${projectId}/messages/feedback`, {
method: 'POST',
headers: new Headers({
Accept: 'application/json',
'Content-Type': 'application/json',
'Authorization': `Bearer ${jwt}`
}),
body: JSON.stringify({
const r = await this.client.post(`/kai/${projectId}/messages/feedback`, {
message_id: messageId,
value: positive,
user_id: userId,
}),
});
if (!r.ok) {
throw new Error('Failed to send feedback');
@ -91,15 +50,7 @@ export default class KaiService extends AiService {
}
cancelGeneration = async (projectId: string, threadId: string) => {
const jwt = this.client.getJwt()
const r = await fetch(`http://localhost:8700/kai/${projectId}/cancel/${threadId}`, {
method: 'POST',
headers: new Headers({
Accept: 'application/json',
'Content-Type': 'application/json',
'Authorization': `Bearer ${jwt}`
}),
});
const r = await this.client.post(`/kai/${projectId}/cancel/${threadId}`);
if (!r.ok) {
throw new Error('Failed to cancel generation');
}

8
frontend/app/components/Kai/SocketManager.ts
View file

@ -6,9 +6,11 @@ export class ChatManager {
constructor({ projectId, threadId, token }: { projectId: string; threadId: string, token: string }) {
this.threadId = threadId;
console.log('Kai socket', projectId, threadId, token);
const socket = io(`localhost:8700/kai/chat`, {
const urlObject = new URL(window.env.API_EDP || window.location.origin);
console.log(token, projectId, threadId)
const socket = io(urlObject.origin, {
transports: ['websocket'],
path: '/kai/chat',
autoConnect: true,
reconnection: true,
reconnectionAttempts: 5,
@ -21,7 +23,7 @@ export class ChatManager {
thread_id: threadId,
},
auth: {
token: `Bearer ${token}`,
token,
}
});
socket.on('connect', () => {