aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2026-01-04 08:54:20 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix clippy and remove old action yaml

Browse Source
This commit is contained in:
Nikita Sivukhin
2025-09-11 00:03:01 +04:00
parent fde376f36c
commit 1a4d334e47
5 changed files with 8 additions and 199 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
sync/engine/src/database_sync_engine.rs
View File

@@ -577,7 +577,7 @@ impl<P: ProtocolIO> DatabaseSyncEngine<P> {
let mut transformed = if self.opts.use_transform {
Some(
apply_transformation(
&coro,
coro,
self.protocol.as_ref(),
&local_changes,
&replay.generator,

12
sync/engine/src/database_sync_operations.rs
View File

@@ -752,7 +752,7 @@ pub async fn push_logical_changes<C: ProtocolIO, Ctx>(
}
let mut transformed = if opts.use_transform {
Some(apply_transformation(&coro, client, &local_changes, &generator).await?)
Some(apply_transformation(coro, client, &local_changes, &generator).await?)
} else {
None
};
@@ -779,9 +779,7 @@ pub async fn push_logical_changes<C: ProtocolIO, Ctx>(
);
assert!(
last_change_id.is_none() || last_change_id.unwrap() < change_id,
"change id must be strictly increasing: last_change_id={:?}, change.change_id={}",
last_change_id,
change_id
"change id must be strictly increasing: last_change_id={last_change_id:?}, change.change_id={change_id}"
);
rows_changed += 1;
// we give user full control over CDC table - so let's not emit assert here for now
@@ -945,11 +943,11 @@ pub async fn apply_transformation<Ctx, P: ProtocolIO>(
) -> Result<Vec<DatabaseRowTransformResult>> {
let mut mutations = Vec::new();
for change in changes {
let replay_info = generator.replay_info(&coro, &change).await?;
mutations.push(generator.create_mutation(&replay_info, &change)?);
let replay_info = generator.replay_info(coro, change).await?;
mutations.push(generator.create_mutation(&replay_info, change)?);
}
let completion = client.transform(mutations)?;
let transformed = wait_all_results(&coro, &completion).await?;
let transformed = wait_all_results(coro, &completion).await?;
if transformed.len() != changes.len() {
return Err(Error::DatabaseSyncEngineError(format!(
"unexpected result from custom transformation: mismatch in shapes: {} != {}",