initial commit

zhangzengfei

2023-01-11 c4d21b97b8a9eedd485efd026395a1007342c3da

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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
#include <string.h>
 
#include "google/protobuf/descriptor.h"
#include "google/protobuf/util/json_util.h"
#include "google/protobuf/util/type_resolver.h"
#include "google/protobuf/util/type_resolver_util.h"
 
#include "google/protobuf/message.h"
#include "google/protobuf/descriptor.h"
#include "google/protobuf/descriptor.pb.h"
#include "google/protobuf/dynamic_message.h"
#include "google/protobuf/compiler/importer.h"
 
#include "3rdparty/yyjson/yyjson.h"
#include "3rdparty/bus_client/cbhomeclient.h"
#include "3rdparty/bus_client/message.h"
#include "proto/x86_64/sysset.pb.h"
 
using namespace protomsg;
using namespace std;
using google::protobuf::util::JsonStringToMessage;
 
const char *CONTENT_TYPE_JSON = "application/json";
 
bool json_to_proto(const std::string &json, google::protobuf::Message& message) {
    google::protobuf::util::JsonParseOptions options;
    options.ignore_unknown_fields = true;
    return JsonStringToMessage(json, &message,options).ok();
}
 
bool proto_to_json(const google::protobuf::Message& message, std::string& json) {
    google::protobuf::util::JsonPrintOptions options;
    options.add_whitespace = true;
    options.always_print_primitive_fields = true;
    options.preserve_proto_field_names = true;
    return MessageToJsonString(message, &json, options).ok();
}
 
char *make_get_request(const char *topic) {
    auto doc = yyjson_mut_doc_new(NULL);
    auto root = yyjson_mut_obj(doc);
    yyjson_mut_obj_add_strn(doc, root, "path", topic, strlen(topic));
    yyjson_mut_obj_add_strn(doc, root, "method", "GET", 3);
    yyjson_mut_obj_add_strn(doc, root, "contentType", CONTENT_TYPE_JSON, strlen(CONTENT_TYPE_JSON));
 
    size_t jsonl = 0;
    char *json = yyjson_mut_val_write(root, 0, &jsonl);
 
    yyjson_mut_doc_free(doc);
 
    return json;
}
 
bool bus_dbapi_get(void *handle, const char* topic, google::protobuf::Message& message) {
    const auto topicl = strlen(topic);
 
    auto reqData = make_get_request(topic);
 
    auto reqmsg = make_req_msg(topic, topicl, reqData, strlen(reqData));
    
    crepmsg *repmsg = NULL;
    if (bus_client_request(handle, reqmsg, &repmsg)) {
        printf("======>> bus_client_reqest [%s] get [%s]\n", topic, repmsg->data);
    } else {
        return false;
    }
 
    char* msgdata = repmsg->data + 32;
    msgdata[strlen(msgdata) -1] = '\0';
    printf("======>> protomsg: %s\n", msgdata);
    
    std::string jsonString = msgdata;
    if (json_to_proto(jsonString, message)) {
        printf("======>> json_to_proto done\n");
        
    } else {
        printf("======>> json_to_proto fail\n");
        return false;
    }
 
    free_reqmsg(reqmsg);
 
    free(reqData);
 
    return true;
}