mvarjon/plan9 - Change CAQK2LQ7RZDYNBXWVPB2OXN6WELWG7PXS5UY3GFYJSTCXK6RTS2QC

Revision 3 of the Mediator component interface.

Created by mvarjon on July 31, 2022

CAQK2LQ7RZDYNBXWVPB2OXN6WELWG7PXS5UY3GFYJSTCXK6RTS2QC

Dependencies

In channels

main

Change contents

Replacement in src/mediator/mod.rs at line 1 [3.53]

B:BD[3.53] → [2.0:745]

use std::collections::HashMap;
pub struct Message {
    pub kind: String,
    pub json: String,
}
pub trait MessageHandler {
    fn handle(&self, msg: &Message);
}
pub struct Mediator {
    storage: HashMap<String, &'static dyn MessageHandler>,
}
impl Mediator {
    pub fn new() -> Self {
        Self {
            storage: HashMap::with_capacity(100),
        }
    }
    pub fn add(&mut self, kind: String, handler: &'static dyn MessageHandler) {
        self.storage.insert(kind, handler);
    }
    pub fn invoke(&self, msg: &Message) {
        let kind = msg.kind.clone();
        if self.storage.contains_key(&kind) {
            let handler = self.storage.get(&kind).unwrap();
            handler.handle(msg);
        }
    }
}

[3.53]

use std::collections::HashMap;
pub struct Message {
    pub kind: String,
    pub json: String,
}
pub trait MessageHandler {
    fn handle(&self, msg: &Message);
}
pub struct Mediator {
    storage: HashMap<String, Vec<&'static dyn MessageHandler>>,
}
impl Mediator {
    pub fn new() -> Self {
        Self {
            storage: HashMap::with_capacity(100),
        }
    }
    pub fn add(&mut self, kind: String, handler: &'static dyn MessageHandler) {
        let key = kind.clone();
        if self.storage.contains_key(&key) {
            let handlers = self.storage.get_mut(&key).unwrap();
            handlers.push(handler);
        } else {
            let mut handlers: Vec<&'static dyn MessageHandler> = Vec::new();
            handlers.push(handler);
            self.storage.insert(key, handlers);
        }
    }
    pub fn invoke(&self, msg: &Message) {
        let kind = msg.kind.clone();
        if self.storage.contains_key(&kind) {
            let handlers = self.storage.get(&kind).unwrap();
            for handler in handlers {
                handler.handle(msg);
            }
        }
    }
}

Replacement in src/main.rs at line 7 [4.49]

B:BD[2.840] → [2.840:941]

    m.add(String::from("TEST"), &HandleThis {});
    m.add(String::from("TEST-2"), &HandleThis2 {});

[2.840]

[2.941]

    m.add(String::from("TEST-3"), &HandleThis {});
    m.add(String::from("TEST-3"), &HandleThis2 {});

Replacement in src/main.rs at line 11 [4.49]

B:BD[2.966] → [2.966:1004]

        kind: String::from("TEST-2"),

[2.966]

[2.1004]

        kind: String::from("TEST-3"),

Deletion in src/main.rs at line 16 [4.49]
B:BD[2.1079] → [2.1079:1080]
∅:D[2.1080] → [4.62:85]
B:BD[4.62] → [4.62:85]
```
    println!("SERVE");
```

Replacement in src/main.rs at line 22 [4.49]

B:BD[2.1181] → [2.1181:1212]

        println!("KABOOM : 1")

[2.1181]

[2.1212]

        println!("INVOKED : 1 = {}", msg.json);

Replacement in src/main.rs at line 30 [4.49]

B:BD[2.1319] → [2.1319:1362]

        println!("KABOOM : {}", msg.json);

[2.1319]

[2.1362]

        println!("INVOKED : 2 = {}", msg.json);