feat(plugins): Plugin workers and strider

Cargo.toml

@@ -34,6 +34,7 @@ members = [
     "default-plugins/status-bar",
     "default-plugins/strider",
     "default-plugins/tab-bar",
+    "default-plugins/fixture-plugin-for-tests",
     "zellij-client",
     "zellij-server",
     "zellij-utils",

default-plugins/fixture-plugin-for-tests/.cargo/config.toml

@@ -0,0 +1,2 @@
+[build]
+target = "wasm32-wasi"

default-plugins/fixture-plugin-for-tests/Cargo.toml

@@ -0,0 +1,11 @@
+[package]
+name = "fixture-plugin-for-tests"
+version = "0.1.0"
+authors = ["Aram Drevekenin <[email protected]>"]
+edition = "2021"
+license = "MIT"
+
+[dependencies]
+serde = { version = "1.0", features = ["derive"] }
+serde_json = "1.0"
+zellij-tile = { path = "../../zellij-tile" }

default-plugins/fixture-plugin-for-tests/LICENSE.md

@@ -0,0 +1 @@
+../../LICENSE.md

default-plugins/fixture-plugin-for-tests/src/main.rs

@@ -0,0 +1,78 @@
+use serde::{Deserialize, Serialize};
+use zellij_tile::prelude::*;
+
+// This is a fixture plugin used only for tests in Zellij
+// it is not (and should not!) be included in the mainline executable
+// it's included here for convenience so that it will be built by the CI
+
+#[derive(Default)]
+struct State {
+    received_events: Vec<Event>,
+    received_payload: Option<String>,
+}
+
+#[derive(Default, Serialize, Deserialize)]
+struct TestWorker {
+    number_of_messages_received: usize,
+}
+
+impl<'de> ZellijWorker<'de> for TestWorker {
+    fn on_message(&mut self, message: String, payload: String) {
+        if message == "ping" {
+            self.number_of_messages_received += 1;
+            post_message_to_plugin(
+                "pong".into(),
+                format!(
+                    "{}, received {} messages",
+                    payload, self.number_of_messages_received
+                ),
+            );
+        }
+    }
+}
+
+register_plugin!(State);
+register_worker!(TestWorker, test_worker);
+
+impl ZellijPlugin for State {
+    fn load(&mut self) {
+        subscribe(&[
+            EventType::InputReceived,
+            EventType::SystemClipboardFailure,
+            EventType::CustomMessage,
+        ]);
+    }
+
+    fn update(&mut self, event: Event) -> bool {
+        match &event {
+            Event::CustomMessage(message, payload) => {
+                if message == "pong" {
+                    self.received_payload = Some(payload.clone());
+                }
+            },
+            Event::SystemClipboardFailure => {
+                // this is just to trigger the worker message
+                post_message_to(
+                    "test",
+                    "ping".to_owned(),
+                    "gimme_back_my_payload".to_owned(),
+                );
+            },
+            _ => {},
+        }
+        let should_render = true;
+        self.received_events.push(event);
+        should_render
+    }
+
+    fn render(&mut self, rows: usize, cols: usize) {
+        if let Some(payload) = self.received_payload.as_ref() {
+            println!("Payload from worker: {:?}", payload);
+        } else {
+            println!(
+                "Rows: {:?}, Cols: {:?}, Received events: {:?}",
+                rows, cols, self.received_events
+            );
+        }
+    }
+}

default-plugins/strider/Cargo.toml

@@ -10,3 +10,9 @@ license = "MIT"
 colored = "2.0.0"
 zellij-tile = { path = "../../zellij-tile" }
 pretty-bytes = "0.2.2"
+walkdir = "2.3.3"
+fuzzy-matcher = "0.3.7"
+serde = { version = "1.0", features = ["derive"] }
+serde_json = "1.0"
+unicode-width = "0.1.8"
+ansi_term = "0.12.1"