Skip to content

Commit a6c6e62

Browse files
committed
Remove "target" processing for MOVE operations.
This has been removed from the protocol, and has no active implementations.
1 parent 5704c7f commit a6c6e62

File tree

1 file changed

+0
-14
lines changed

1 file changed

+0
-14
lines changed

crates/core/src/operations.rs

Lines changed: 0 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -74,13 +74,6 @@ INSERT INTO ps_oplog(bucket, op_id, op, key, row_type, row_id, data, hash, super
7474
bucket_statement.bind_text(1, bucket, sqlite::Destructor::STATIC)?;
7575
bucket_statement.exec()?;
7676

77-
// language=SQLite
78-
let bucket_target_statement = db.prepare_v2("\
79-
UPDATE ps_buckets
80-
SET target_op = MAX(ifnull(cast(json_extract(?, '$.target') as integer), 0), ps_buckets.target_op)
81-
WHERE name = ?")?;
82-
bucket_target_statement.bind_text(2, bucket, sqlite::Destructor::STATIC)?;
83-
8477
let mut first_op: Option<i64> = None;
8578
let mut last_op: Option<i64> = None;
8679

@@ -134,13 +127,6 @@ UPDATE ps_buckets
134127
insert_statement.bind_int(8, checksum)?;
135128
insert_statement.bind_int(9, superseded)?;
136129
insert_statement.exec()?;
137-
138-
if op == "MOVE" {
139-
if let Ok(data) = op_data {
140-
bucket_target_statement.bind_text(1, data, sqlite::Destructor::STATIC)?;
141-
bucket_target_statement.exec()?;
142-
}
143-
}
144130
} else if op == "CLEAR" {
145131
// Any remaining PUT operations should get an implicit REMOVE
146132
// language=SQLite

0 commit comments

Comments
 (0)