Skip to content

Commit 5cff949

Browse files
authored
improve-updates (#155)
1 parent 6a7eb4b commit 5cff949

File tree

1 file changed

+6
-8
lines changed
  • woori-db/src/controllers

1 file changed

+6
-8
lines changed

woori-db/src/controllers/tx.rs

Lines changed: 6 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -420,8 +420,7 @@ pub async fn update_set_controller(
420420
previous_entry.clone()
421421
};
422422

423-
let previous_state_str = actor.send(previous_entry.0.to_owned()).await??;
424-
let mut previous_state = actor.send(State(previous_state_str)).await??;
423+
let mut previous_state = previous_entry.1.clone();
425424
let encrypted_content_clone = encrypted_content.clone();
426425
encrypted_content.into_iter().for_each(|(k, v)| {
427426
let local_state = previous_state.entry(k).or_insert_with(|| v.clone());
@@ -438,7 +437,7 @@ pub async fn update_set_controller(
438437
&content_log,
439438
args.id,
440439
datetime,
441-
&to_string_pretty(&previous_entry.clone(), pretty_config_inner())
440+
&to_string_pretty(&previous_entry, pretty_config_inner())
442441
.map_err(Error::Serialization)?,
443442
))
444443
.await??;
@@ -542,8 +541,7 @@ pub async fn update_content_controller(
542541
previous_entry.clone()
543542
};
544543

545-
let previous_state_str = actor.send(previous_entry.0.to_owned()).await??;
546-
let mut previous_state = actor.send(State(previous_state_str)).await??;
544+
let mut previous_state = previous_entry.1.clone();
547545

548546
content
549547
.into_iter()
@@ -724,13 +722,13 @@ pub async fn match_update_set_controller(
724722
let previous_entry = local_data.get(&args.entity).unwrap().get(&args.id).unwrap();
725723
previous_entry.clone()
726724
};
727-
let previous_state_str = actor.send(previous_entry.0.to_owned()).await??;
728-
let mut previous_state = actor.send(State(previous_state_str)).await??;
725+
726+
let mut previous_state = previous_entry.1.clone();
729727

730728
actor
731729
.send(MatchUpdate {
732730
conditions: args.conditions,
733-
previous_state: previous_state.clone(),
731+
previous_state: previous_entry.1.clone(),
734732
})
735733
.await??;
736734

0 commit comments

Comments
 (0)