Handle a Register request.
(&mut self, req: Register)
| 404 | |
| 405 | /// Handle a Register request. |
| 406 | pub fn register(&mut self, req: Register) -> Result<(), Error> { |
| 407 | let Register { rules, .. } = req; |
| 408 | |
| 409 | for rule in rules.into_iter() { |
| 410 | if self.context.rules.contains_key(&rule.name) { |
| 411 | // @TODO panic if hashes don't match |
| 412 | // panic!("Attempted to re-register a named relation"); |
| 413 | continue; |
| 414 | } else { |
| 415 | // if self.config.enable_meta { |
| 416 | // let mut data = rule.plan.datafy(); |
| 417 | // let tx_data: Vec<TxData> = data |
| 418 | // .drain(..) |
| 419 | // .map(|(e, a, v)| TxData(1, Value::Eid(e), a, v, None)) |
| 420 | // .collect(); |
| 421 | |
| 422 | // self.transact(tx_data, 0, 0)?; |
| 423 | // } |
| 424 | |
| 425 | self.context.rules.insert(rule.name.to_string(), rule); |
| 426 | } |
| 427 | } |
| 428 | |
| 429 | Ok(()) |
| 430 | } |
| 431 | |
| 432 | /// Handle a RegisterSource request. |
| 433 | pub fn register_source<S: Scope<Timestamp = T>>( |
no outgoing calls