polywrap_plugin 0.1.11

Core package to build plugins in rust to interact with Polywrap Client
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

use std::{
    fmt::Debug,
    sync::{Arc, Mutex},
};

use polywrap_core::{
    error::Error,
    invoker::Invoker,
    wrapper::{GetFileOptions, Wrapper},
};
use polywrap_msgpack_serde::to_vec;

use crate::module::PluginModule;

#[derive(Debug)]
pub struct PluginWrapper<T: PluginModule> {
    instance: Arc<Mutex<T>>,
}

impl<T: PluginModule> PluginWrapper<T> {
    pub fn new(instance: Arc<Mutex<T>>) -> Self {
        Self { instance }
    }
}

impl<T: PluginModule + 'static> Wrapper for PluginWrapper<T> {
    fn invoke(
        &self,
        method: &str,
        args: Option<&[u8]>,
        env: Option<&[u8]>,
        invoker: Arc<dyn Invoker>,
    ) -> Result<Vec<u8>, Error> {
        let args = match args {
            Some(args) => args.to_vec(),
            None => to_vec(&{}).unwrap(),
        };

        let result = self
            .instance
            .lock()
            .unwrap()
            ._wrap_invoke(method, &args, env, invoker);

        match result {
            Ok(result) => Ok(result),
            Err(e) => Err(crate::error::PluginError::InvocationError {
                exception: e.to_string(),
            }
            .into()),
        }
    }
    fn get_file(&self, _: &GetFileOptions) -> Result<Vec<u8>, polywrap_core::error::Error> {
        unimplemented!("client.get_file(...) is not implemented for Plugins.")
    }
}

impl<T: PluginModule> PartialEq for PluginWrapper<T> {
    fn eq(&self, other: &Self) -> bool {
        self == other
    }
}