fix(core): missing copilot param (#6602)
This commit is contained in:
@@ -88,10 +88,12 @@ export class CopilotClient {
|
|||||||
sessionId,
|
sessionId,
|
||||||
messageId,
|
messageId,
|
||||||
message,
|
message,
|
||||||
|
params,
|
||||||
}: {
|
}: {
|
||||||
sessionId: string;
|
sessionId: string;
|
||||||
messageId?: string;
|
messageId?: string;
|
||||||
message?: string;
|
message?: string;
|
||||||
|
params?: Record<string, string>;
|
||||||
}) {
|
}) {
|
||||||
if (messageId && message) {
|
if (messageId && message) {
|
||||||
throw new Error('Only one of messageId or message can be provided');
|
throw new Error('Only one of messageId or message can be provided');
|
||||||
@@ -105,6 +107,11 @@ export class CopilotClient {
|
|||||||
if (message) {
|
if (message) {
|
||||||
url.searchParams.set('message', message);
|
url.searchParams.set('message', message);
|
||||||
}
|
}
|
||||||
|
if (!messageId && params) {
|
||||||
|
Object.entries(params).forEach(([key, value]) => {
|
||||||
|
url.searchParams.set(key, value);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
return new Promise(resolve => {
|
return new Promise(resolve => {
|
||||||
fetch(url.toString())
|
fetch(url.toString())
|
||||||
@@ -120,10 +127,12 @@ export class CopilotClient {
|
|||||||
sessionId,
|
sessionId,
|
||||||
messageId,
|
messageId,
|
||||||
message,
|
message,
|
||||||
|
params,
|
||||||
}: {
|
}: {
|
||||||
sessionId: string;
|
sessionId: string;
|
||||||
messageId?: string;
|
messageId?: string;
|
||||||
message?: string;
|
message?: string;
|
||||||
|
params?: Record<string, string>;
|
||||||
}) {
|
}) {
|
||||||
if (messageId && message) {
|
if (messageId && message) {
|
||||||
throw new Error('Only one of messageId or message can be provided');
|
throw new Error('Only one of messageId or message can be provided');
|
||||||
@@ -139,6 +148,11 @@ export class CopilotClient {
|
|||||||
if (message) {
|
if (message) {
|
||||||
url.searchParams.set('message', message);
|
url.searchParams.set('message', message);
|
||||||
}
|
}
|
||||||
|
if (!messageId && params) {
|
||||||
|
Object.entries(params).forEach(([key, value]) => {
|
||||||
|
url.searchParams.set(key, value);
|
||||||
|
});
|
||||||
|
}
|
||||||
return new EventSource(url.toString());
|
return new EventSource(url.toString());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -136,6 +136,7 @@ export function textToText({
|
|||||||
sessionId: message.sessionId,
|
sessionId: message.sessionId,
|
||||||
messageId: message.messageId,
|
messageId: message.messageId,
|
||||||
message: message.message,
|
message: message.message,
|
||||||
|
params,
|
||||||
});
|
});
|
||||||
yield* toTextStream(eventSource, { timeout });
|
yield* toTextStream(eventSource, { timeout });
|
||||||
},
|
},
|
||||||
@@ -162,6 +163,7 @@ export function textToText({
|
|||||||
sessionId: message.sessionId,
|
sessionId: message.sessionId,
|
||||||
messageId: message.messageId,
|
messageId: message.messageId,
|
||||||
message: message.message,
|
message: message.message,
|
||||||
|
params,
|
||||||
});
|
});
|
||||||
}),
|
}),
|
||||||
]);
|
]);
|
||||||
|
|||||||
Reference in New Issue
Block a user