MSP Serverless平台链上交互框架 #

框架方案 #

架构 #

MSP Serverless编程框架支持用户自定义provider，应用程序编译成的wasm也就是actor可以通过abi，以类似于本地函数调用的方式与provider进行交互。在本例中，我们实现了weelink的provider，使得wasm程序可以非常方便的与区块链进行交互。

Untitled

abi接口 #

定义weelink交互的abi接口，可以执行/查询任意的链上合约。abi具体定义如下：

invoke(method, args string)

发送交易接口，调用的链码函数名称以及对应的参数数组json marshal后的字符串

query(method, …args string)

发送交易接口，查询的链码函数名称以及对应的参数数组json marshal后的字符串

interface #

使用smithy定义上述abi，定义Invoke 和 Query的operation。然后使用wash工具生成rust的SDK库，这样provider和actor可以利用这个库来极大的简化代码。

/// The Weelink service has a single method, calculate, which
/// calculates the factorial of its whole number parameter.
@wasmbus(
    contractId: "wasmcloud:oneitfarm:weelink",
    actorReceive: true,
    providerReceive: true )
service Weelink {
  version: "0.1",
  operations: [ Invoke, Query ]
}

/// Invoke - Execute transaction
operation Invoke {
    input: InvokeRequest,
    output: InvokeResponse,
}

/// Query - Get info from contract.
operation Query {
    input: QueryRequest,
    output: QueryResponse,
}

provider #

对于provider，实现invoke和query的方法，向链上进行数据交互。其主要逻辑如下所示：

/// Handle Weelink methods
#[async_trait]
impl Weelink for FakePayProvider {
    async fn invoke(&self, ctx: &Context, arg: &InvokeRequest) -> RpcResult<InvokeResponse>{
        // ...
        let res = dyncallgo::call_invoke(method_ref, addr_ref, amount);
        match res {
            Ok(message) =>  Ok(InvokeResponse{success: true, message: Some(message.to_string()) }),
            Err(e) =>  Ok(InvokeResponse{success: false, message: Some(format!("{:?}", e)) }),
        }
    }
    /// Query - Get info from contract.
    async fn query(&self, ctx: &Context, arg: &QueryRequest) -> RpcResult<QueryResponse>{
        // ...
        let res = dyncallgo::call_query(method_ref, addr_ref);
        match res {
            Ok(message) =>  Ok(QueryResponse{success: true, message: Some(message.to_string()) }),
            Err(e) =>  Ok(QueryResponse{success: false, message: Some(format!("{:?}", e)) }),
        }
    }
}

actor #

actor可以实现任意的业务逻辑，这里我们实现一个测试的actor，当actor的invoke接口被调用时，actor就调用provider进行token transfer。当actor的query接口被调用时，actor查询参数指定的address的token余额。

其核心逻辑如下，判断接口是否是invoke，然后执行对应的逻辑：

/// Implementation of HttpServer trait methods
#[async_trait]
impl HttpServer for WeelinkActor {

    /// Returns a greeting, "Hello World", in the response body.
    /// If the request contains a query parameter 'name=NAME', the
    /// response is changed to "Hello NAME"
    async fn handle_request(
        &self,
        _ctx: &Context,
        req: &HttpRequest,
    ) -> std::result::Result<HttpResponse, RpcError> {
        info!("request arrived");
        let provider = WeelinkSender::new();
        if req.path.contains("invoke") {
            let invoke_request = &InvokeRequest{address, amount:count, method:"".to_string()};
            let res = provider.invoke(_ctx, invoke_request).await?;
            if  !res.success {
                /* handle not authorized */
                return Result::Err(RpcError::from(format!("invoke failed {}", res.message.unwrap()).to_string()));
            }
            message = res.message.unwrap().clone(); // todo change unwrap to match
        } else {
            let res = provider.query(_ctx, query_request).await?;
            if  !res.success {
                /* handle not authorized */
                return Result::Err(RpcError::from(format!("query failed {}", res.message.unwrap()).to_string()));
            }
            message = res.message.unwrap().clone(); // todo change unwrap to match
        }
        Ok(HttpResponse {
            body: message.as_bytes().to_vec(),
            ..Default::default()
        })
    }
}