itemstore.update() now completely deletes the item. before adding a key, that already existed some time, would not work, also handle_mize_message() returns after one if-statement triggers

This commit is contained in:
Sebastian Moser
2023-01-25 12:27:34 +01:00
parent 188a7b2a7e
commit b5dd705f70
3 changed files with 11 additions and 4 deletions

View File

@@ -124,7 +124,10 @@ impl Itemstore {
if let Some(key_index) = old_keys.iter().position(|x| *x == key.clone()){
old_keys.remove(key_index);
}
tr.del(key).await?;
let mut store_key = update.id.clone().into_bytes();
store_key.push(':' as u8);
store_key.extend(key);
tr.del(store_key).await?;
} else {
tr.set(store_key.clone(), new_val).await?;
}

View File

@@ -611,6 +611,7 @@ pub async fn handle_mize_message(
let msg = Message::from_bytes(answer, message.origin.clone());
message.origin.send(msg).await;
return Ok(());
};
@@ -669,7 +670,6 @@ pub async fn handle_mize_message(
return Ok(());
};
@@ -685,6 +685,7 @@ pub async fn handle_mize_message(
for origin in subbed_origins {
message.clone().send(origin).await;
}
return Ok(());
};
@@ -721,6 +722,7 @@ pub async fn handle_mize_message(
};
return Err(err);
}
return Ok(());
}
@@ -786,11 +788,13 @@ pub async fn handle_mize_message(
let mut created_id_message = vec![VERSION, MSG_CREATED_ID];
created_id_message.extend(new_id.to_be_bytes());
message.origin.send(Message::from_bytes(created_id_message, message.origin.clone())).await;
return Ok(());
}
//###########################################################//
//for every other message
println!("Got a Message That did not Trigger any if Statement....");
println!("Got a Message That did not Trigger any if Statement....: {:?}", message.raw);
return Ok(());
}