chk
/
AppFlowy-Cloud
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

chore: fix clippy linting errors and warnings (#639)

This commit is contained in:
Khor Shu Heng 2024-06-23 23:18:38 +08:00 committed by GitHub
parent d61524d636
commit 537824e82b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
4 changed files with 1 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
libs/client-api/src/http_billing.rs
View File

@ -39,7 +39,7 @@ impl Client {
("recurring_interval", recurring_interval.as_str()), ("recurring_interval", recurring_interval.as_str()),
( (
"workspace_subscription_plan", "workspace_subscription_plan",
&workspace_subscription_plan.as_str(), workspace_subscription_plan.as_str(),
), ),
("success_url", success_url), ("success_url", success_url),
]) ])

3
services/appflowy-collaborate/src/group/broadcast.rs
View File

@ -189,7 +189,6 @@ impl CollabBroadcast {
Stream: StreamExt<Item = MessageByObjectId> + Send + Sync + Unpin + 'static, Stream: StreamExt<Item = MessageByObjectId> + Send + Sync + Unpin + 'static,
<Sink as futures_util::Sink<CollabMessage>>::Error: std::error::Error + Send + Sync, <Sink as futures_util::Sink<CollabMessage>>::Error: std::error::Error + Send + Sync,
{ {
let cloned_origin = subscriber_origin.clone();
let sink_stop_tx = { let sink_stop_tx = {
let mut sink = sink.clone(); let mut sink = sink.clone();
let (stop_tx, mut stop_rx) = tokio::sync::mpsc::channel::<()>(1); let (stop_tx, mut stop_rx) = tokio::sync::mpsc::channel::<()>(1);
@ -266,7 +265,6 @@ impl CollabBroadcast {
}; };
Subscription { Subscription {
origin: cloned_origin,
sink_stop_tx: Some(sink_stop_tx), sink_stop_tx: Some(sink_stop_tx),
stream_stop_tx: Some(stream_stop_tx), stream_stop_tx: Some(stream_stop_tx),
} }
@ -540,7 +538,6 @@ fn ack_code_from_error(error: &RTProtocolError) -> AckCode {
/// connection error or closed connection). /// connection error or closed connection).
#[derive(Debug)] #[derive(Debug)]
pub struct Subscription { pub struct Subscription {
pub origin: CollabOrigin,
sink_stop_tx: Option<tokio::sync::mpsc::Sender<()>>, sink_stop_tx: Option<tokio::sync::mpsc::Sender<()>>,
stream_stop_tx: Option<tokio::sync::mpsc::Sender<()>>, stream_stop_tx: Option<tokio::sync::mpsc::Sender<()>>,
} }

1
services/appflowy-collaborate/src/group/cmd.rs
View File

@ -46,7 +46,6 @@ where
{ {
pub group_manager: Arc<GroupManager<S, AC>>, pub group_manager: Arc<GroupManager<S, AC>>,
pub msg_router_by_user: Arc<DashMap<RealtimeUser, ClientMessageRouter>>, pub msg_router_by_user: Arc<DashMap<RealtimeUser, ClientMessageRouter>>,
pub access_control: Arc<AC>,
pub recv: Option<GroupCommandReceiver>, pub recv: Option<GroupCommandReceiver>,
} }

4
services/appflowy-collaborate/src/rt_server.rs
View File

@ -32,7 +32,6 @@ pub struct CollaborationServer<S, AC> {
group_manager: Arc<GroupManager<S, AC>>, group_manager: Arc<GroupManager<S, AC>>,
connect_state: ConnectState, connect_state: ConnectState,
group_sender_by_object_id: Arc<DashMap<String, GroupCommandSender>>, group_sender_by_object_id: Arc<DashMap<String, GroupCommandSender>>,
access_control: Arc<AC>,
storage: Arc<S>, storage: Arc<S>,
#[allow(dead_code)] #[allow(dead_code)]
metrics: Arc<CollabRealtimeMetrics>, metrics: Arc<CollabRealtimeMetrics>,
@ -82,7 +81,6 @@ where
group_manager, group_manager,
connect_state, connect_state,
group_sender_by_object_id, group_sender_by_object_id,
access_control,
metrics, metrics,
metrics_calculate, metrics_calculate,
}) })
@ -168,7 +166,6 @@ where
let group_sender_by_object_id = self.group_sender_by_object_id.clone(); let group_sender_by_object_id = self.group_sender_by_object_id.clone();
let client_msg_router_by_user = self.connect_state.client_message_routers.clone(); let client_msg_router_by_user = self.connect_state.client_message_routers.clone();
let group_manager = self.group_manager.clone(); let group_manager = self.group_manager.clone();
let access_control = self.access_control.clone();
Box::pin(async move { Box::pin(async move {
for (object_id, collab_messages) in message_by_oid { for (object_id, collab_messages) in message_by_oid {
@ -186,7 +183,6 @@ where
let runner = GroupCommandRunner { let runner = GroupCommandRunner {
group_manager: group_manager.clone(), group_manager: group_manager.clone(),
msg_router_by_user: client_msg_router_by_user.clone(), msg_router_by_user: client_msg_router_by_user.clone(),
access_control: access_control.clone(),
recv: Some(recv), recv: Some(recv),
}; };