使用一个字段作为任意消息的代理

Question

Hello Nano开发人员，

我想意识到以下原始原型：

message container {
    enum MessageType {
        TYPE_UNKNOWN =  0;
        evt_resultStatus  =  1;
    }
    required MessageType mt = 1;
    optional bytes cmd_evt_transfer = 2;
}

message evt_resultStatus {
    required int32 operationMode = 1;
}

...

点表示，还有更多消息，其中包含数据类型的（多个）原始词。枚举也会同样增长，只是想简短。

容器的生成为：

typedef struct _container { 
    container_MessageType mt; 
    pb_callback_t cmd_evt_transfer; 
} container;

evt_resultStatus是：

typedef struct _evt_resultStatus { 
    int32_t operationMode; 
} evt_resultStatus;

字段cmd_evt_transfer应充当后续消息的代理，例如evt_resultStatus持有原始数据类型。 evt_resultstatus应编码为字节，并将其放置在cmd_evt_transfer字段中。 然后，容器应进行编码，并且编码结果将用于后续转移。

为什么这样做的背景是缩短原始定义并避免使用单一事物。不幸的是，语法版本3不完全支持，因此我们无法使用任何字段。

第一个问题是：这种方法可能有可能吗？

到目前为止，我所拥有的是编码，包括回调似乎表现不错。但另一方面，解码以某种方式跳过了回调。我已经阅读了问题在这里，这在使用oneof 和字节字段。

有人可以澄清如何继续这样做吗？

到目前为止，我得到的示例代码：

bool encode_msg_test(pb_byte_t* buffer, int32_t sval, size_t* sz, char* err) {
    evt_resultStatus rs = evt_resultStatus_init_zero;
    rs.operationMode = sval;
    pb_ostream_t stream = pb_ostream_from_buffer(buffer, sizeof(buffer));

    /*encode container*/
    container msg = container_init_zero;
    msg.mt = container_MessageType_evt_resultStatus;
    msg.cmd_evt_transfer.arg = &rs;
    msg.cmd_evt_transfer.funcs.encode = encode_cb;
    if(! pb_encode(&stream, container_fields, &msg)) {
        const char* local_err = PB_GET_ERROR(&stream);
        sprintf(err, "pb_encode error: %s", local_err);
        return false;
    }

    *sz = stream.bytes_written;
    return true;
}

bool encode_cb(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) {
    evt_resultStatus* rs = (evt_resultStatus*)(*arg);

//with the below in place a stream full error rises
//    if (! pb_encode_tag_for_field(stream, field)) {
//        return false;
//    }

    if(! pb_encode(stream, evt_resultStatus_fields, rs)) {
        return false;
    }

    return true;
}

//buffer holds previously encoded data
bool decode_msg_test(pb_byte_t* buffer, int32_t* sval, size_t msg_len, char* err) {
    container msg = container_init_zero;
    evt_resultStatus res = evt_resultStatus_init_zero;

    msg.cmd_evt_transfer.arg = &res;
    msg.cmd_evt_transfer.funcs.decode = decode_cb;
    pb_istream_t stream = pb_istream_from_buffer(buffer, msg_len);
    if(! pb_decode(&stream, container_fields, &msg)) {
        const char* local_err = PB_GET_ERROR(&stream);
        sprintf(err, "pb_encode error: %s", local_err);
        return false;
    }
    *sval = res.operationMode;
    return true;
}

bool decode_cb(pb_istream_t *istream, const pb_field_t *field, void **arg) {
    evt_resultStatus * rs = (evt_resultStatus*)(*arg);

    if(! pb_decode(istream, evt_resultStatus_fields, rs)) {
        return false;
    }

    return true;
}

我觉得，我对编码 /解码过程没有正确的理解。

假设是否正确：

• pb_encode的第一个呼叫（在encode_msg_test中）负责mt字段mt字段
• pb_encode的第二个呼叫（在encode_cb中）处理cmd_evt_transfer字段

如果我这样做：

bool encode_cb(pb_ostream_t *stream, const pb_field_t *field, void * const *arg) {
    evt_resultStatus* rs = (evt_resultStatus*)(*arg);

    if (! pb_encode_tag_for_field(stream, field)) {
         return false;
    }

    if(! pb_encode(stream, evt_resultStatus_fields, rs)) {
        return false;
    }

    return true;
}

然后，我会在pb_encode的呼叫上获得流的完整错误。

这是为什么？

Answer 1

是的，方法是合理的。 NanOPB回调不在乎回调的实际数据是什么。

至于为什么您的解码回调不起作用，您需要发布用于解码的代码。

（顺便说一句，任何类型都可以在NanOPB中起作用，并由此测试案例。但是type_url在所有中包含的任何消息都使它们具有很大的开销。）