surrealpatch/lib/src/doc/lives.rs

use crate::ctx::Context;
use crate::dbs::Options;
use crate::dbs::Statement;
use crate::doc::Document;
use crate::err::Error;

impl<'a> Document<'a> {
	pub async fn lives(
		&self,
		ctx: &Context<'_>,
		opt: &Options,
		_stm: &Statement<'_>,
	) -> Result<(), Error> {
		// Check if forced
		if !opt.force && !self.changed() {
			return Ok(());
		}
		// Clone transaction
		let txn = ctx.clone_transaction()?;
		// Get the record id
		let _ = self.id.as_ref().unwrap();
		// Loop through all index statements
		for lv in self.lv(opt, &txn).await?.iter() {
			// Create a new statement
			let stm = Statement::from(lv);
			// Check LIVE SELECT where condition
			if self.check(ctx, opt, &stm).await.is_err() {
				continue;
			}
			// Check what type of data change this is
			if stm.is_delete() {
				// Send a DELETE notification to the WebSocket
			} else if self.is_new() {
				// Process the CREATE notification to send
				let _ = self.pluck(ctx, opt, &stm).await?;
			} else {
				// Process the CREATE notification to send
				let _ = self.pluck(ctx, opt, &stm).await?;
			};
		}
		// Carry on
		Ok(())
	}
}