Mirrored_Repos/AppFlowy
1
0
Fork 0
mirror of https://github.com/AppFlowy-IO/AppFlowy.git synced 2024-08-30 18:12:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: fix message id (#5943)

Browse Source
This commit is contained in:
Nathan.fooo 2024-08-12 22:24:06 +08:00 committed by GitHub
parent d3d9ab2fb0
commit 6e26dc128c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
frontend/appflowy_flutter/lib/plugins/ai_chat/application/chat_bloc.dart
View File

@ -88,7 +88,13 @@ class ChatBloc extends Bloc<ChatEvent, ChatState> {
Int64? beforeMessageId; Int64? beforeMessageId;
final oldestMessage = _getOlderstMessage(); final oldestMessage = _getOlderstMessage();
if (oldestMessage != null) { if (oldestMessage != null) {
beforeMessageId = Int64.parseInt(oldestMessage.id); try {
beforeMessageId = Int64.parseInt(oldestMessage.id);
} catch (e) {
Log.error(
"Failed to parse message id: $e, messaeg_id: ${oldestMessage.id}",
);
}
} }
_loadPrevMessage(beforeMessageId); _loadPrevMessage(beforeMessageId);
emit( emit(
@ -439,7 +445,9 @@ class ChatBloc extends Bloc<ChatEvent, ChatState> {
QuestionStream stream, QuestionStream stream,
Map<String, dynamic>? sentMetadata, Map<String, dynamic>? sentMetadata,
) { ) {
questionStreamMessageId = nanoid(); final now = DateTime.now();
final timestamp = now.millisecondsSinceEpoch;
questionStreamMessageId = timestamp.toString();
final Map<String, dynamic> metadata = {}; final Map<String, dynamic> metadata = {};
// if (sentMetadata != null) { // if (sentMetadata != null) {

2
frontend/appflowy_flutter/lib/plugins/ai_chat/application/chat_user_message_bloc.dart
View File

@ -15,7 +15,7 @@ class ChatUserMessageBloc
), ),
) { ) {
on<ChatUserMessageEvent>( on<ChatUserMessageEvent>(
(event, emit) async { (event, emit) {
event.when( event.when(
initial: () { initial: () {
if (state.stream != null) { if (state.stream != null) {

2
frontend/rust-lib/flowy-folder/src/manager.rs
View File

@ -337,7 +337,7 @@ impl FolderManager {
pub async fn get_workspace_pb(&self) -> FlowyResult<WorkspacePB> { pub async fn get_workspace_pb(&self) -> FlowyResult<WorkspacePB> {
let workspace_id = self.user.workspace_id()?; let workspace_id = self.user.workspace_id()?;
let guard = self.mutex_folder.read(); let guard = self.mutex_folder.write();
let folder = guard let folder = guard
.as_ref() .as_ref()
.ok_or(FlowyError::internal().with_context("folder is not initialized"))?; .ok_or(FlowyError::internal().with_context("folder is not initialized"))?;