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: bump client api that deduplicate sync message (#4972)

Browse Source 
* chore: bump client api

* chore: update log

* chore: bump client api
This commit is contained in:
Nathan.fooo
2024-03-24 07:31:41 +08:00
committed by GitHub
parent b307312a71
commit 3f0b3478c1
12 changed files with 195 additions and 179 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
frontend/rust-lib/lib-dispatch/src/dispatcher.rs
View File

@ -164,7 +164,7 @@ impl AFPluginDispatcher {
let request: AFPluginRequest = request.into();
let plugins = dispatch.plugins.clone();
let service = Box::new(DispatchService { plugins });
tracing::trace!("Async event: {:?}", &request.event);
tracing::trace!("[dispatch]: Async event: {:?}", &request.event);
let service_ctx = DispatchContext {
request,
callback: Some(Box::new(callback)),
@ -172,7 +172,7 @@ impl AFPluginDispatcher {
let handle = dispatch.runtime.spawn(async move {
service.call(service_ctx).await.unwrap_or_else(|e| {
tracing::error!("Dispatch runtime error: {:?}", e);
tracing::error!("[dispatch]: runtime error: {:?}", e);
InternalError::Other(format!("{:?}", e)).as_response()
})
});
@ -292,18 +292,27 @@ impl Service<DispatchContext> for DispatchService {
let result = {
match module_map.get(&request.event) {
Some(module) => {
let event = format!("{:?}", request.event);
event!(
tracing::Level::TRACE,
"Handle event: {:?} by {:?}",
&request.event,
module.name
"[dispatch]: {:?} exec event:{}",
&module.name,
&event,
);
let fut = module.new_service(());
let service_fut = fut.await?.call(request);
service_fut.await
let result = service_fut.await;
event!(
tracing::Level::TRACE,
"[dispatch]: {:?} exec event:{} with result: {}",
&module.name,
&event,
result.is_ok()
);
result
},
None => {
let msg = format!("Can not find the event handler. {:?}", request);
let msg = format!("[dispatch]: can not find the event handler. {:?}", request);
event!(tracing::Level::ERROR, "{}", msg);
Err(InternalError::HandleNotFound(msg).into())
},