Movatterモバイル変換


[0]ホーム

URL:


Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

[Feat] AI Chat Component#1850

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to ourterms of service andprivacy statement. We’ll occasionally send you account related emails.

Already on GitHub?Sign in to your account

Merged
Show file tree
Hide file tree
Changes fromall commits
Commits
Show all changes
17 commits
Select commitHold shift + click to select a range
4585d15
[feat] replace mock data with query
iamfaranJul 7, 2025
75e635a
[Feat]: make chat component flexible
iamfaranJul 7, 2025
56e5247
setup sse http query
iamfaranJul 8, 2025
4664b5b
fix linter errors
iamfaranJul 8, 2025
188f9cb
setup http streaming with dummy data
iamfaranJul 8, 2025
7b68581
setup frontend for ssehttpquery
iamfaranJul 9, 2025
cf0b99c
chat component refactor
iamfaranJul 10, 2025
a349af4
add unique storage / expose convo history
iamfaranJul 11, 2025
5d88dbe
add event listeners for the chat component
iamfaranJul 14, 2025
ac38c66
add system prompt and improve edit UI
iamfaranJul 15, 2025
b2dcf3f
add docs button in chat component
iamfaranJul 15, 2025
35b0614
fix no threads infinite re render
iamfaranJul 16, 2025
b2d9d11
fix table name for better queries
iamfaranJul 16, 2025
aa40585
add custom loader
iamfaranJul 16, 2025
b1bc01a
add translations for the chat component
iamfaranJul 18, 2025
68b2802
remove console logs
iamfaranJul 18, 2025
4f9fbba
add file attachments components
iamfaranJul 22, 2025
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletionsclient/packages/lowcoder/package.json
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -33,6 +33,8 @@
"@jsonforms/core": "^3.5.1",
"@lottiefiles/dotlottie-react": "^0.13.0",
"@manaflair/redux-batch": "^1.0.0",
"@radix-ui/react-avatar": "^1.1.10",
"@radix-ui/react-dialog": "^1.1.14",
"@radix-ui/react-slot": "^1.2.3",
"@radix-ui/react-tooltip": "^1.2.7",
"@rjsf/antd": "^5.24.9",
Expand Down
12 changes: 11 additions & 1 deletionclient/packages/lowcoder/src/components/ResCreatePanel.tsx
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -13,7 +13,7 @@ import { BottomResTypeEnum } from "types/bottomRes";
import { LargeBottomResIconWrapper } from "util/bottomResUtils";
import type { PageType } from "../constants/pageConstants";
import type { SizeType } from "antd/es/config-provider/SizeContext";
import { Datasource } from "constants/datasourceConstants";
import { Datasource, QUICK_SSE_HTTP_API_ID } from "constants/datasourceConstants";
import {
QUICK_GRAPHQL_ID,
QUICK_REST_API_ID,
Expand DownExpand Up@@ -172,13 +172,22 @@ const ResButton = (props: {
compType: "streamApi",
},
},

alasql: {
label: trans("query.quickAlasql"),
type: BottomResTypeEnum.Query,
extra: {
compType: "alasql",
},
},
sseHttpApi: {
label: trans("query.quickSseHttpAPI"),
type: BottomResTypeEnum.Query,
extra: {
compType: "sseHttpApi",
dataSourceId: QUICK_SSE_HTTP_API_ID,
},
},
graphql: {
label: trans("query.quickGraphql"),
type: BottomResTypeEnum.Query,
Expand DownExpand Up@@ -339,6 +348,7 @@ export function ResCreatePanel(props: ResCreateModalProps) {
<DataSourceListWrapper $placement={placement}>
<ResButton size={buttonSize} identifier={"restApi"} onSelect={onSelect} />
<ResButton size={buttonSize} identifier={"streamApi"} onSelect={onSelect} />
<ResButton size={buttonSize} identifier={"sseHttpApi"} onSelect={onSelect} />
<ResButton size={buttonSize} identifier={"alasql"} onSelect={onSelect} />
<ResButton size={buttonSize} identifier={"graphql"} onSelect={onSelect} />
<DataSourceButton size={buttonSize} onClick={() => setCurlModalVisible(true)}>
Expand Down
302 changes: 257 additions & 45 deletionsclient/packages/lowcoder/src/comps/comps/chatComp/chatComp.tsx
View file
Open in desktop
Original file line numberDiff line numberDiff line change
@@ -1,46 +1,258 @@
// client/packages/lowcoder/src/comps/comps/chatComp/chatComp.tsx
import { UICompBuilder } from "comps/generators";
import { NameConfig, withExposingConfigs } from "comps/generators/withExposing";
import { chatChildrenMap } from "./chatCompTypes";
import { ChatView } from "./chatView";
import { ChatPropertyView } from "./chatPropertyView";
import { useEffect, useState } from "react";
import { changeChildAction } from "lowcoder-core";

// Build the component
let ChatTmpComp = new UICompBuilder(
chatChildrenMap,
(props, dispatch) => {
useEffect(() => {
if (Boolean(props.tableName)) return;

// Generate a unique database name for this ChatApp instance
const generateUniqueTableName = () => {
const timestamp = Date.now();
const randomId = Math.random().toString(36).substring(2, 15);
return `TABLE_${timestamp}`;
};

const tableName = generateUniqueTableName();
dispatch(changeChildAction('tableName', tableName, true));
}, [props.tableName]);

if (!props.tableName) {
return null; // Don't render until we have a unique DB name
}
return <ChatView {...props} chatQuery={props.chatQuery.value} />;
}
)
.setPropertyViewFn((children) => <ChatPropertyView children={children} />)
.build();

ChatTmpComp = class extends ChatTmpComp {
override autoHeight(): boolean {
return this.children.autoHeight.getView();
}
};

// Export the component
export const ChatComp = withExposingConfigs(ChatTmpComp, [
new NameConfig("text", "Chat component text"),
// client/packages/lowcoder/src/comps/comps/chatComp/chatComp.tsx

import { UICompBuilder } from "comps/generators";
import { NameConfig, withExposingConfigs } from "comps/generators/withExposing";
import { StringControl } from "comps/controls/codeControl";
import { arrayObjectExposingStateControl, stringExposingStateControl } from "comps/controls/codeStateControl";
import { withDefault } from "comps/generators";
import { BoolControl } from "comps/controls/boolControl";
import { dropdownControl } from "comps/controls/dropdownControl";
import QuerySelectControl from "comps/controls/querySelectControl";
import { eventHandlerControl, EventConfigType } from "comps/controls/eventHandlerControl";
import { ChatCore } from "./components/ChatCore";
import { ChatPropertyView } from "./chatPropertyView";
import { createChatStorage } from "./utils/storageFactory";
import { QueryHandler, createMessageHandler } from "./handlers/messageHandlers";
import { useMemo, useRef, useEffect } from "react";
import { changeChildAction } from "lowcoder-core";
import { ChatMessage } from "./types/chatTypes";
import { trans } from "i18n";

import "@assistant-ui/styles/index.css";
import "@assistant-ui/styles/markdown.css";

// ============================================================================
// CHAT-SPECIFIC EVENTS
// ============================================================================

export const componentLoadEvent: EventConfigType = {
label: trans("chat.componentLoad"),
value: "componentLoad",
description: trans("chat.componentLoadDesc"),
};

export const messageSentEvent: EventConfigType = {
label: trans("chat.messageSent"),
value: "messageSent",
description: trans("chat.messageSentDesc"),
};

export const messageReceivedEvent: EventConfigType = {
label: trans("chat.messageReceived"),
value: "messageReceived",
description: trans("chat.messageReceivedDesc"),
};

export const threadCreatedEvent: EventConfigType = {
label: trans("chat.threadCreated"),
value: "threadCreated",
description: trans("chat.threadCreatedDesc"),
};

export const threadUpdatedEvent: EventConfigType = {
label: trans("chat.threadUpdated"),
value: "threadUpdated",
description: trans("chat.threadUpdatedDesc"),
};

export const threadDeletedEvent: EventConfigType = {
label: trans("chat.threadDeleted"),
value: "threadDeleted",
description: trans("chat.threadDeletedDesc"),
};

const ChatEventOptions = [
componentLoadEvent,
messageSentEvent,
messageReceivedEvent,
threadCreatedEvent,
threadUpdatedEvent,
threadDeletedEvent,
] as const;

export const ChatEventHandlerControl = eventHandlerControl(ChatEventOptions);

// ============================================================================
// SIMPLIFIED CHILDREN MAP - WITH EVENT HANDLERS
// ============================================================================


export function addSystemPromptToHistory(
conversationHistory: ChatMessage[],
systemPrompt: string
): Array<{ role: string; content: string; timestamp: number }> {
// Format conversation history for use in queries
const formattedHistory = conversationHistory.map(msg => ({
role: msg.role,
content: msg.text,
timestamp: msg.timestamp
}));

// Create system message (always exists since we have default)
const systemMessage = [{
role: "system" as const,
content: systemPrompt,
timestamp: Date.now() - 1000000 // Ensure it's always first chronologically
}];

// Return complete history with system prompt prepended
return [...systemMessage, ...formattedHistory];
}


function generateUniqueTableName(): string {
return `chat${Math.floor(1000 + Math.random() * 9000)}`;
}

const ModelTypeOptions = [
{ label: trans("chat.handlerTypeQuery"), value: "query" },
{ label: trans("chat.handlerTypeN8N"), value: "n8n" },
] as const;

export const chatChildrenMap = {
// Storage
// Storage (add the hidden property here)
_internalDbName: withDefault(StringControl, ""),
// Message Handler Configuration
handlerType: dropdownControl(ModelTypeOptions, "query"),
chatQuery: QuerySelectControl, // Only used for "query" type
modelHost: withDefault(StringControl, ""), // Only used for "n8n" type
systemPrompt: withDefault(StringControl, trans("chat.defaultSystemPrompt")),
streaming: BoolControl.DEFAULT_TRUE,

// UI Configuration
placeholder: withDefault(StringControl, trans("chat.defaultPlaceholder")),

// Database Information (read-only)
databaseName: withDefault(StringControl, ""),

// Event Handlers
onEvent: ChatEventHandlerControl,

// Exposed Variables (not shown in Property View)
currentMessage: stringExposingStateControl("currentMessage", ""),
conversationHistory: stringExposingStateControl("conversationHistory", "[]"),
};

// ============================================================================
// CLEAN CHATCOMP - USES NEW ARCHITECTURE
// ============================================================================

const ChatTmpComp = new UICompBuilder(
chatChildrenMap,
(props, dispatch) => {

const uniqueTableName = useRef<string>();
// Generate unique table name once (with persistence)
if (!uniqueTableName.current) {
// Use persisted name if exists, otherwise generate new one
uniqueTableName.current = props._internalDbName || generateUniqueTableName();

// Save the name for future refreshes
if (!props._internalDbName) {
dispatch(changeChildAction("_internalDbName", uniqueTableName.current, false));
}

// Update the database name in the props for display
const dbName = `ChatDB_${uniqueTableName.current}`;
dispatch(changeChildAction("databaseName", dbName, false));
}
// Create storage with unique table name
const storage = useMemo(() =>
createChatStorage(uniqueTableName.current!),
[]
);

// Create message handler based on type
const messageHandler = useMemo(() => {
const handlerType = props.handlerType;

if (handlerType === "query") {
return new QueryHandler({
chatQuery: props.chatQuery.value,
dispatch,
streaming: props.streaming,
});
} else if (handlerType === "n8n") {
return createMessageHandler("n8n", {
modelHost: props.modelHost,
systemPrompt: props.systemPrompt,
streaming: props.streaming
});
} else {
// Fallback to mock handler
return createMessageHandler("mock", {
chatQuery: props.chatQuery.value,
dispatch,
streaming: props.streaming
});
}
}, [
props.handlerType,
props.chatQuery,
props.modelHost,
props.systemPrompt,
props.streaming,
dispatch,
]);

// Handle message updates for exposed variable
const handleMessageUpdate = (message: string) => {
dispatch(changeChildAction("currentMessage", message, false));
// Trigger messageSent event
props.onEvent("messageSent");
};

// Handle conversation history updates for exposed variable
// Handle conversation history updates for exposed variable
const handleConversationUpdate = (conversationHistory: any[]) => {
// Use utility function to create complete history with system prompt
const historyWithSystemPrompt = addSystemPromptToHistory(
conversationHistory,
props.systemPrompt
);

// Expose the complete history (with system prompt) for use in queries
dispatch(changeChildAction("conversationHistory", JSON.stringify(historyWithSystemPrompt), false));

// Trigger messageReceived event when bot responds
const lastMessage = conversationHistory[conversationHistory.length - 1];
if (lastMessage && lastMessage.role === 'assistant') {
props.onEvent("messageReceived");
}
};

// Cleanup on unmount
useEffect(() => {
return () => {
const tableName = uniqueTableName.current;
if (tableName) {
storage.cleanup();
}
};
}, []);

return (
<ChatCore
storage={storage}
messageHandler={messageHandler}
placeholder={props.placeholder}
onMessageUpdate={handleMessageUpdate}
onConversationUpdate={handleConversationUpdate}
onEvent={props.onEvent}
/>
);
}
)
.setPropertyViewFn((children) => <ChatPropertyView children={children} />)
.build();

// ============================================================================
// EXPORT WITH EXPOSED VARIABLES
// ============================================================================

export const ChatComp = withExposingConfigs(ChatTmpComp, [
new NameConfig("currentMessage", "Current user message"),
new NameConfig("conversationHistory", "Full conversation history as JSON array (includes system prompt for API calls)"),
new NameConfig("databaseName", "Database name for SQL queries (ChatDB_<componentName>)"),
]);
Loading
Loading

[8]ページ先頭

©2009-2025 Movatter.jp