tqcq/crpc
1
0
Fork 0
Code Issues Pull Requests Actions Projects Releases 1 Wiki Activity

Compare commits

base: tqcq:master
Branches Tags
tqcq:master
tqcq:v0.1.0
..
compare: tqcq:v0.1.0
Branches Tags
tqcq:master
tqcq:v0.1.0

No commits in common. "master" and "v0.1.0" have entirely different histories.
master ... v0.1.0

17 changed files with 16 additions and 287 deletions
Show Stats Expand all files Collapse all files

2
CMakeLists.txt
View File

@ -34,8 +34,6 @@ add_executable(crpc
src/plugins/c/rpcs/crpc.cpp
src/plugins/c/c_service_plugin.cpp
${antlr4cpp_src_files_tqcq}
src/plugins/c/items/c_item_message.cpp
src/plugins/c/items/c_item_uint_32.cpp
)
target_include_directories(crpc PRIVATE src/grammar/ src/)
target_include_directories(crpc PRIVATE

25
main.cpp
View File

@ -35,30 +35,17 @@ public:
message_stack.pop();
}
void exitMessageBaseItemStatement(ProtoParser::MessageBaseItemStatementContext *context) override
void exitItemStatement(ProtoParser::ItemStatementContext *context) override
{
int idx = std::stoi(context->NUMBER()->getText());
tqcq::Item::Ptr item = nullptr;
tqcq::Item::Type item_type = tqcq::Item::Type::kInt32;
if (context->INT32()) {
item_type = tqcq::Item::Type::kInt32;
item = std::make_shared<tqcq::Item>(tqcq::Item::Type::kInt32, context->ID()->getText(), idx);
} else if (context->STRING()){
item_type = tqcq::Item::Type::kString;
} else if (context->UINT32()) {
item_type = tqcq::Item::Type::kUInt32;
item = std::make_shared<tqcq::Item>(tqcq::Item::Type::kString, context->ID()->getText(), idx);
} else {
assert(false);
}
item = std::make_shared<tqcq::Item>(item_type, context->ID()->getText(), idx);
items.push_back(std::move(item));
}
void exitMessageMessageItemStatement(ProtoParser::MessageMessageItemStatementContext *context) override
{
int idx = std::stoi(context->NUMBER()->getText());
auto message_type = context->ID(0)->getText();
auto message_name = context->ID(1)->getText();
auto item = std::make_shared<tqcq::Item>(tqcq::Item::Type::kMessage, message_name, idx);
items.push_back(std::move(item));
}
@ -119,9 +106,9 @@ main(int argc, char *argv[])
Listener listener;
Listener listener2;
antlr4::tree::ParseTreeWalker::DEFAULT.walk(&listener, parser.program());
for (const auto& item : listener.message_map) {
std::cout << item.second->ToString() << std::endl;
}
// for (const auto& item : listener.message_map) {
// std::cout << item.second->ToString() << std::endl;
// }
// for (const auto& service : listener.services) {
// std::cout << service->ToString() << std::endl;

1
src/grammar/ProtoLexer.g4
View File

@ -1,7 +1,6 @@
lexer grammar ProtoLexer;
INT32: 'int32';
UINT32: 'uint32';
STRING: 'string';
VERSION2: 'proto2';

10
src/grammar/ProtoParser.g4
View File

@ -6,15 +6,9 @@ program: syntaxStatement baseStatement* EOF;
syntaxStatement: SYNTAX_TYPE '=' '"' (VERSION2 | VERSION3) '"' ';';
baseStatement: messageStatement | serviceStatement | ';' ;
messageStatement:
MESSAGE_TYPE ID '{' (
messageBaseItemStatement
| ';'
| messageMessageItemStatement
)* '}';
messageStatement: MESSAGE_TYPE ID '{' (itemStatement | ';')* '}';
serviceStatement: SERVICE_TYPE ID '{' (rpcStatement | ';')* '}';
messageBaseItemStatement: (INT32 | UINT32 | STRING) ID '=' NUMBER ';';
messageMessageItemStatement: ID ID '=' NUMBER ';';
itemStatement: (INT32 | STRING) ID '=' NUMBER ';';
rpcStatement: RPC_TYPE ID '(' ID ')' 'returns' '(' ID ')' '{' '}';

1
src/item.h
View File

@ -15,7 +15,6 @@ public:
enum class Type {
kMessage,
kInt32,
kUInt32,
kString
};
static std::string ToString(Type type);

12
src/plugins/c/c_service_client_plugin.cpp
View File

@ -430,16 +430,4 @@ CServiceClientPlugin::GenerateHeaderGuardStart(Service::Ptr service)
return ss.str();
}
std::string
CServiceClientPlugin::GenerateHeaderExamples(Service::Ptr service)
{
return "";
}
std::string
CServiceClientPlugin::GenerateSourceExamples(Service::Ptr service)
{
return "";
}
}// namespace tqcq

3
src/plugins/c/c_service_client_plugin.h
View File

@ -39,9 +39,6 @@ protected:
std::string GenerateSourceSendFunctionDefinition(Service::Ptr service);
std::string GenerateSourceDispatchFunctionDefinition(Service::Ptr service);
std::string GenerateHeaderExamples(Service::Ptr service);
std::string GenerateSourceExamples(Service::Ptr service);
};
}// namespace tqcq

9
src/plugins/c/c_service_server_plugin.cpp
View File

@ -38,15 +38,6 @@ std::string
CServiceServerPlugin::GenerateHeaderStructAPIStart(Service::Ptr service)
{
std::stringstream ss;
ss << "/** api examples" << std::endl;
for (const auto& rpc : service->rpcs()) {
auto crpc = CRPCServer::Create(rpc);
ss << crpc->GenerateAPITypedef(service->id());
}
ss << " * api examples" << std::endl;
ss << " */ " << std::endl;
ss << std::endl;
ss << "typedef struct "
<< "{" << std::endl;
return ss.str();

3
src/plugins/c/items/c_item.cpp
View File

@ -5,7 +5,6 @@
#include "c_item.h"
#include "assert.h"
#include "c_item_int_32.h"
#include "c_item_uint_32.h"
#include "c_item_string.h"
namespace tqcq {
@ -16,8 +15,6 @@ CItem::Create(Item::Ptr item)
switch (item->type()) {
case Item::Type::kInt32:
return std::make_shared<CItemInt32>(item);
case Item::Type::kUInt32:
return std::make_shared<CItemUInt32>(item);
case Item::Type::kString:
return std::make_shared<CItemString>(item);
default:

7
src/plugins/c/items/c_item_message.cpp
View File

@ -1,7 +0,0 @@
//
// Created by tqcq on 2023/12/4.
//
#include "c_item_message.h"
namespace tqcq {}// namespace tqcq

14
src/plugins/c/items/c_item_message.h
View File

@ -1,14 +0,0 @@
//
// Created by tqcq on 2023/12/4.
//
#ifndef CRPC_SRC_PLUGINS_C_ITEMS_C_ITEM_MESSAGE_H_
#define CRPC_SRC_PLUGINS_C_ITEMS_C_ITEM_MESSAGE_H_
namespace tqcq {
class CItemMessage {};
}// namespace tqcq
#endif//CRPC_SRC_PLUGINS_C_ITEMS_C_ITEM_MESSAGE_H_

29
src/plugins/c/items/c_item_string.cpp
View File

@ -41,9 +41,9 @@ std::string
CItemString::GenerateSetterDeclaration(std::string message_id) const
{
std::stringstream ss;
ss << "void " << message_id << "_set_" << id() << "_string(" << message_id << "* message, const void* " << id() << ");";
ss << "void " << message_id << "_set_" << id() << "_string(" << message_id << "* message, const char* " << id() << ");";
ss << std::endl;
ss << "void " << message_id << "_set_" << id() << "_data(" << message_id << "* message, const void* " << id() << ", int32_t " << id() << "_len);";
ss << "void " << message_id << "_set_" << id() << "_data(" << message_id << "* message, const char* " << id() << ", int32_t " << id() << "_len);";
ss << std::endl;
return ss.str();
}
@ -53,8 +53,7 @@ CItemString::GenerateSetterDefinition(std::string message_id) const
{
std::stringstream ss;
// set_xxx_data
ss << "void " << message_id << "_set_" << id() << "_data(" << message_id << "* message, const void* " << id() << ", int32_t " << id() << "_len) {" << std::endl;
ss << " assert(" << id() << " || " << id() << "_len == 0);" << std::endl;
ss << "void " << message_id << "_set_" << id() << "_data(" << message_id << "* message, const char* " << id() << ", int32_t " << id() << "_len) {" << std::endl;
ss << " char* new_" << id() << " = (char*)malloc(" << id() << "_len + 1);" << std::endl;
ss << " if (new_" << id() << " == NULL) { return; }" << std::endl;
ss << " memcpy(new_" << id() << ", " << id() << ", " << id() << "_len);" << std::endl;
@ -68,7 +67,7 @@ CItemString::GenerateSetterDefinition(std::string message_id) const
ss << std::endl;
// set_xxx_string
ss << "void " << message_id << "_set_" << id() << "_string(" << message_id << "* message, const void* " << id() << ") {" << std::endl;
ss << "void " << message_id << "_set_" << id() << "_string(" << message_id << "* message, const char* " << id() << ") {" << std::endl;
ss << " int32_t " << id() << "_len = strlen(" << id() << ");" << std::endl;
ss << " " << message_id << "_set_" << id() << "_data(message, " << id() << ", " << id() << "_len);" << std::endl;
ss << "}" << std::endl;
@ -81,18 +80,8 @@ std::string
CItemString::GenerateGetterDefinition(std::string message_id) const
{
std::stringstream ss;
ss << "void* " << message_id << "_get_" << id() << "_data(const " << message_id << "* message) {" << std::endl;
ss << " return (void*)message->" << id() << ";" << std::endl;
ss << "}" << std::endl;
ss << std::endl;
ss << "const char* " << message_id << "_get_" << id() << "_string(const " << message_id << "* message) {" << std::endl;
ss << " return (const char*)message->" << id() << ";" << std::endl;
ss << "}" << std::endl;
ss << std::endl;
ss << "int32_t " << message_id << "_get_" << id() << "_len(const " << message_id << "* message) {" << std::endl;
ss << " return message->" << id() << "_len;" << std::endl;
ss << "const char* " << message_id << "_get_" << id() << "_data(const " << message_id << "* message) {" << std::endl;
ss << " return message->" << id() << ";" << std::endl;
ss << "}" << std::endl;
return ss.str();
@ -102,11 +91,9 @@ std::string
CItemString::GenerateGetterDeclaration(std::string message_id) const
{
std::stringstream ss;
ss << "void* " << message_id << "_get_" << id() << "_data(const " << message_id << "* message);";
ss << "const char* " << message_id << "_get_" << id() << "_data(const " << message_id << "* message);";
ss << std::endl;
ss << "const char* " << message_id << "_get_" << id() << "_string(const " << message_id << "* message);";
ss << std::endl;
ss << "int32_t " << message_id << "_get_" << id() << "_len(const " << message_id << "* message);";
ss << "const char* " << message_id << "_get_" << id() << "_len(const " << message_id << "* message);";
return ss.str();
}

78
src/plugins/c/items/c_item_uint_32.cpp
View File

@ -1,78 +0,0 @@
//
// Created by tqcq on 2023/12/2.
//
#include "c_item_uint_32.h"
#include <sstream>
namespace tqcq {
CItemUInt32::CItemUInt32(Item::Ptr item) : CItem(item) {}
std::string
CItemUInt32::GenerateStructDeclareCodeBlock(std::string message_id) const
{
return " uint32_t " + id() + ";";
}
std::string
CItemUInt32::GenerateInitCodeBlock(std::string message_id) const
{
std::stringstream ss;
ss << " " << "message->" << id() << " = 0;";
return ss.str();
}
std::string
CItemUInt32::GenerateDestroyCodeBlock(std::string message_id) const
{
return " // do nothing for " + id() + " destroy";
}
std::string
CItemUInt32::GenerateSetterDeclaration(std::string message_id) const
{
return "void " + message_id + "_set_" + id() + "(" + message_id + "* message, uint32_t " + id() + ");";
}
std::string
CItemUInt32::GenerateSetterDefinition(std::string message_id) const
{
std::stringstream ss;
ss << "void " << message_id << "_set_" << id() << "(" << message_id << "* message, uint32_t " << id() << ") {" << std::endl;
ss << " message->" << id() << " = " << id() << ";" << std::endl;
ss << "}" << std::endl;
ss << std::endl;
return ss.str();
}
std::string
CItemUInt32::GenerateGetterDefinition(std::string message_id) const
{
std::stringstream ss;
ss << "uint32_t " << message_id << "_get_" << id() << "(const " << message_id << "* message) {" << std::endl;
ss << " return message->" << id() << ";" << std::endl;
ss << "}" << std::endl;
ss << std::endl;
return ss.str();
}
std::string
CItemUInt32::GenerateGetterDeclaration(std::string message_id) const
{
std::stringstream ss;
ss << "uint32_t " << message_id << "_get_" << id() << "(const " << message_id << "* message);";
return ss.str();
}
std::string
CItemUInt32::GenerateSerializeCodeBlock(std::string message_id) const
{
return " // implement me for " + message_id + "_" + id() + " serialize";
}
std::string
CItemUInt32::GenerateDeserializeCodeBlock(std::string message_id) const
{
return " // implement me for " + id() + " deserialize";
}
}// namespace tqcq

35
src/plugins/c/items/c_item_uint_32.h
View File

@ -1,35 +0,0 @@
//
// Created by tqcq on 2023/12/2.
//
#ifndef CRPC_SRC_PLUGINS_C_GENERATORS_C_ITEM_UINT_32_H_
#define CRPC_SRC_PLUGINS_C_GENERATORS_C_ITEM_UINT_32_H_
#include "c_item.h"
namespace tqcq {
class CItemUInt32 : public CItem {
public:
using Ptr = std::shared_ptr<CItemUInt32>;
CItemUInt32(Item::Ptr item);
~CItemUInt32() override = default;
std::string GenerateStructDeclareCodeBlock(std::string message_id) const override;
std::string GenerateInitCodeBlock(std::string message_id) const override;
std::string GenerateDestroyCodeBlock(std::string message_id) const override;
std::string GenerateSetterDeclaration(std::string message_id) const override;
std::string GenerateSetterDefinition(std::string message_id) const override;
std::string GenerateGetterDefinition(std::string message_id) const override;
std::string GenerateGetterDeclaration(std::string message_id) const override;
std::string GenerateSerializeCodeBlock(std::string message_id) const override;
std::string GenerateDeserializeCodeBlock(std::string message_id) const override;
};
}// namespace tqcq
#endif//CRPC_SRC_PLUGINS_C_GENERATORS_C_ITEM_UINT_32_H_

9
src/plugins/c/rpcs/crpc_server.cpp
View File

@ -110,13 +110,4 @@ CRPCServer::GenerateStructAPIWrapper(std::string service_id) const
return ss.str();
}
std::string
CRPCServer::GenerateAPITypedef(std::string service_id) const
{
std::stringstream ss;
// ss << "typedef int32_t (*" << service_id << "_API_"<< id() << "_Type)(const " << request_id() << " *request, " << response_id() << " *response);\n";
ss << "int32_t YOUR_PREFIX_" << id() << "_API_Impl" << "(const " << request_id() << " *request, " << response_id() << " *response);\n";;
return ss.str();
}
}// namespace tqcq

1
src/plugins/c/rpcs/crpc_server.h
View File

@ -20,7 +20,6 @@ public:
std::string GenerateStructAPIWrapper(std::string service_id) const override;
std::string GenerateStructDeclareCodeBlock(std::string service_id) const override;
std::string GenerateStructAPIDeclareCodeBlock(std::string service_id) const override;
std::string GenerateAPITypedef(std::string service_id) const;
};
}// namespace tqcq

64
src/test.proto
View File

@ -2,7 +2,6 @@ syntax = "proto3";
message EmptyRequest {
}
message EmptyResponse {
int32 code = 1;
string msg = 2;
@ -81,63 +80,13 @@ message SMSymmetricResponse {
string out_data = 3;
}
message SM2_3_Request {
string ecc_pubkey = 1;
string ecc_prikey = 2;
string in_data = 3;
}
message SM2_3_Response {
int32 code = 1;
string msg = 2;
string out_data = 3;
}
message ExportPublicKeyRequest {
int32 key_pair_type = 1;
}
message ImportECCKeyPairRequest {
int32 key_pair_type = 1;
string private_key = 2;
string public_key = 3;
}
message ImportCertificateRequest {
int32 cer_type = 1;
string in_data = 2;
}
message ExportCertificateRequest {
int32 cer_type = 1;
}
message ImportFileRequest {
string filename = 1;
string in_data = 2;
}
message ExportFileRequest {
string filename = 1;
}
message ExportResponse {
int32 code = 1;
string msg = 2;
string out_data = 3;
}
service DeviceService {
rpc GetUseCount(EmptyRequest) returns (StatusResponse) {}
rpc Init(EmptyRequest) returns (StatusResponse) {}
rpc Status(EmptyRequest) returns (StatusResponse) {}
rpc GetHWCode(EmptyRequest) returns (SingleDataResponse) {}
rpc Close(EmptyRequest) returns (StatusResponse) {}
rpc ClearApp(EmptyRequest) returns (EmptyResponse) {}
rpc GenerateECCKeyPair(EmptyRequest) returns (StatusResponse) {}
rpc UnlockApplicationPIN(ApplicationPINRequest) returns (StatusResponse) {}
rpc ChangeApplicationPIN(ApplicationPINRequest) returns (StatusResponse) {}
@ -150,21 +99,8 @@ service DeviceService {
rpc GenerateSignatureByExternalPrivateKey(GenerateSignatureByExternalPrivateKeyRequest) returns (SingleDataResponse) {}
rpc VerifySignature(VerifySignatureRequest) returns (StatusResponse) {}
rpc SM2_3_Encrypt_ExternalPubkey(SM2_3_Request) returns (SM2_3_Response) {}
rpc SM2_3_Decrypt_ExternalPrikey(SM2_3_Request) returns (SM2_3_Response) {}
rpc SM2_3_Decrypt_InternalPrikey(SM2_3_Request) returns (SM2_3_Response) {}
rpc SM2_3_Decrypt_InternalCryptPrikey(SM2_3_Request) returns (SM2_3_Response) {}
rpc SM1Encrypt(SMSymmetricRequest) returns (SMSymmetricResponse) {}
rpc SM1Decrypt(SMSymmetricRequest) returns (SMSymmetricResponse) {}
rpc SM4Encrypt(SMSymmetricRequest) returns (SMSymmetricResponse) {}
rpc SM4Decrypt(SMSymmetricRequest) returns (SMSymmetricResponse) {}
rpc ExportPublicKey(ExportPublicKeyRequest) returns (ExportResponse) {}
rpc ImportEccKeyPair(ImportECCKeyPairRequest) returns (StatusResponse) {}
rpc ImportCertificate(ImportCertificateRequest) returns (StatusResponse) {}
rpc ExportCertificate(ExportCertificateRequest) returns (ExportResponse) {}
rpc ImportFile(ImportFileRequest) returns (StatusResponse) {}
rpc ExportFile(ExportFileRequest) returns (ExportResponse) {}
}