From 354d60eaecebeba0dc940ffbaaca96492de5d4de Mon Sep 17 00:00:00 2001 From: Lorenzo Venerandi <68255980+Lore09@users.noreply.github.com> Date: Tue, 12 Nov 2024 18:56:22 +0100 Subject: [PATCH] project refactor --- src/rpc_go/pb/test.pb.go | 180 ---------------------------------- src/rpc_go/pb/test_grpc.pb.go | 121 ----------------------- src/rpc_go/proto/test.proto | 17 ---- src/rpc_go/server/main.go | 47 --------- 4 files changed, 365 deletions(-) delete mode 100644 src/rpc_go/pb/test.pb.go delete mode 100644 src/rpc_go/pb/test_grpc.pb.go delete mode 100644 src/rpc_go/proto/test.proto delete mode 100644 src/rpc_go/server/main.go diff --git a/src/rpc_go/pb/test.pb.go b/src/rpc_go/pb/test.pb.go deleted file mode 100644 index 30e5a49..0000000 --- a/src/rpc_go/pb/test.pb.go +++ /dev/null @@ -1,180 +0,0 @@ -// Code generated by protoc-gen-go. DO NOT EDIT. -// versions: -// protoc-gen-go v1.35.1 -// protoc v3.12.4 -// source: test.proto - -package pb - -import ( - protoreflect "google.golang.org/protobuf/reflect/protoreflect" - protoimpl "google.golang.org/protobuf/runtime/protoimpl" - reflect "reflect" - sync "sync" -) - -const ( - // Verify that this generated code is sufficiently up-to-date. - _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) - // Verify that runtime/protoimpl is sufficiently up-to-date. - _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) -) - -type TestRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` -} - -func (x *TestRequest) Reset() { - *x = TestRequest{} - mi := &file_test_proto_msgTypes[0] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *TestRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*TestRequest) ProtoMessage() {} - -func (x *TestRequest) ProtoReflect() protoreflect.Message { - mi := &file_test_proto_msgTypes[0] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use TestRequest.ProtoReflect.Descriptor instead. -func (*TestRequest) Descriptor() ([]byte, []int) { - return file_test_proto_rawDescGZIP(), []int{0} -} - -func (x *TestRequest) GetName() string { - if x != nil { - return x.Name - } - return "" -} - -type TestResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` -} - -func (x *TestResponse) Reset() { - *x = TestResponse{} - mi := &file_test_proto_msgTypes[1] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *TestResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*TestResponse) ProtoMessage() {} - -func (x *TestResponse) ProtoReflect() protoreflect.Message { - mi := &file_test_proto_msgTypes[1] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use TestResponse.ProtoReflect.Descriptor instead. -func (*TestResponse) Descriptor() ([]byte, []int) { - return file_test_proto_rawDescGZIP(), []int{1} -} - -func (x *TestResponse) GetMessage() string { - if x != nil { - return x.Message - } - return "" -} - -var File_test_proto protoreflect.FileDescriptor - -var file_test_proto_rawDesc = []byte{ - 0x0a, 0x0a, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x04, 0x74, 0x65, - 0x73, 0x74, 0x22, 0x21, 0x0a, 0x0b, 0x54, 0x65, 0x73, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, - 0x74, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, - 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x28, 0x0a, 0x0c, 0x54, 0x65, 0x73, 0x74, 0x52, 0x65, 0x73, - 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, - 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x32, - 0x44, 0x0a, 0x0b, 0x54, 0x65, 0x73, 0x74, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x35, - 0x0a, 0x0a, 0x54, 0x65, 0x73, 0x74, 0x4d, 0x65, 0x74, 0x68, 0x6f, 0x64, 0x12, 0x11, 0x2e, 0x74, - 0x65, 0x73, 0x74, 0x2e, 0x54, 0x65, 0x73, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, - 0x12, 0x2e, 0x74, 0x65, 0x73, 0x74, 0x2e, 0x54, 0x65, 0x73, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, - 0x6e, 0x73, 0x65, 0x22, 0x00, 0x42, 0x06, 0x5a, 0x04, 0x2e, 0x2f, 0x70, 0x62, 0x62, 0x06, 0x70, - 0x72, 0x6f, 0x74, 0x6f, 0x33, -} - -var ( - file_test_proto_rawDescOnce sync.Once - file_test_proto_rawDescData = file_test_proto_rawDesc -) - -func file_test_proto_rawDescGZIP() []byte { - file_test_proto_rawDescOnce.Do(func() { - file_test_proto_rawDescData = protoimpl.X.CompressGZIP(file_test_proto_rawDescData) - }) - return file_test_proto_rawDescData -} - -var file_test_proto_msgTypes = make([]protoimpl.MessageInfo, 2) -var file_test_proto_goTypes = []any{ - (*TestRequest)(nil), // 0: test.TestRequest - (*TestResponse)(nil), // 1: test.TestResponse -} -var file_test_proto_depIdxs = []int32{ - 0, // 0: test.TestService.TestMethod:input_type -> test.TestRequest - 1, // 1: test.TestService.TestMethod:output_type -> test.TestResponse - 1, // [1:2] is the sub-list for method output_type - 0, // [0:1] is the sub-list for method input_type - 0, // [0:0] is the sub-list for extension type_name - 0, // [0:0] is the sub-list for extension extendee - 0, // [0:0] is the sub-list for field type_name -} - -func init() { file_test_proto_init() } -func file_test_proto_init() { - if File_test_proto != nil { - return - } - type x struct{} - out := protoimpl.TypeBuilder{ - File: protoimpl.DescBuilder{ - GoPackagePath: reflect.TypeOf(x{}).PkgPath(), - RawDescriptor: file_test_proto_rawDesc, - NumEnums: 0, - NumMessages: 2, - NumExtensions: 0, - NumServices: 1, - }, - GoTypes: file_test_proto_goTypes, - DependencyIndexes: file_test_proto_depIdxs, - MessageInfos: file_test_proto_msgTypes, - }.Build() - File_test_proto = out.File - file_test_proto_rawDesc = nil - file_test_proto_goTypes = nil - file_test_proto_depIdxs = nil -} diff --git a/src/rpc_go/pb/test_grpc.pb.go b/src/rpc_go/pb/test_grpc.pb.go deleted file mode 100644 index 0077bbe..0000000 --- a/src/rpc_go/pb/test_grpc.pb.go +++ /dev/null @@ -1,121 +0,0 @@ -// Code generated by protoc-gen-go-grpc. DO NOT EDIT. -// versions: -// - protoc-gen-go-grpc v1.5.1 -// - protoc v3.12.4 -// source: test.proto - -package pb - -import ( - context "context" - grpc "google.golang.org/grpc" - codes "google.golang.org/grpc/codes" - status "google.golang.org/grpc/status" -) - -// This is a compile-time assertion to ensure that this generated file -// is compatible with the grpc package it is being compiled against. -// Requires gRPC-Go v1.64.0 or later. -const _ = grpc.SupportPackageIsVersion9 - -const ( - TestService_TestMethod_FullMethodName = "/test.TestService/TestMethod" -) - -// TestServiceClient is the client API for TestService service. -// -// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. -type TestServiceClient interface { - TestMethod(ctx context.Context, in *TestRequest, opts ...grpc.CallOption) (*TestResponse, error) -} - -type testServiceClient struct { - cc grpc.ClientConnInterface -} - -func NewTestServiceClient(cc grpc.ClientConnInterface) TestServiceClient { - return &testServiceClient{cc} -} - -func (c *testServiceClient) TestMethod(ctx context.Context, in *TestRequest, opts ...grpc.CallOption) (*TestResponse, error) { - cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) - out := new(TestResponse) - err := c.cc.Invoke(ctx, TestService_TestMethod_FullMethodName, in, out, cOpts...) - if err != nil { - return nil, err - } - return out, nil -} - -// TestServiceServer is the server API for TestService service. -// All implementations must embed UnimplementedTestServiceServer -// for forward compatibility. -type TestServiceServer interface { - TestMethod(context.Context, *TestRequest) (*TestResponse, error) - mustEmbedUnimplementedTestServiceServer() -} - -// UnimplementedTestServiceServer must be embedded to have -// forward compatible implementations. -// -// NOTE: this should be embedded by value instead of pointer to avoid a nil -// pointer dereference when methods are called. -type UnimplementedTestServiceServer struct{} - -func (UnimplementedTestServiceServer) TestMethod(context.Context, *TestRequest) (*TestResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method TestMethod not implemented") -} -func (UnimplementedTestServiceServer) mustEmbedUnimplementedTestServiceServer() {} -func (UnimplementedTestServiceServer) testEmbeddedByValue() {} - -// UnsafeTestServiceServer may be embedded to opt out of forward compatibility for this service. -// Use of this interface is not recommended, as added methods to TestServiceServer will -// result in compilation errors. -type UnsafeTestServiceServer interface { - mustEmbedUnimplementedTestServiceServer() -} - -func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer) { - // If the following call pancis, it indicates UnimplementedTestServiceServer was - // embedded by pointer and is nil. This will cause panics if an - // unimplemented method is ever invoked, so we test this at initialization - // time to prevent it from happening at runtime later due to I/O. - if t, ok := srv.(interface{ testEmbeddedByValue() }); ok { - t.testEmbeddedByValue() - } - s.RegisterService(&TestService_ServiceDesc, srv) -} - -func _TestService_TestMethod_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(TestRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(TestServiceServer).TestMethod(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: TestService_TestMethod_FullMethodName, - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(TestServiceServer).TestMethod(ctx, req.(*TestRequest)) - } - return interceptor(ctx, in, info, handler) -} - -// TestService_ServiceDesc is the grpc.ServiceDesc for TestService service. -// It's only intended for direct use with grpc.RegisterService, -// and not to be introspected or modified (even as a copy) -var TestService_ServiceDesc = grpc.ServiceDesc{ - ServiceName: "test.TestService", - HandlerType: (*TestServiceServer)(nil), - Methods: []grpc.MethodDesc{ - { - MethodName: "TestMethod", - Handler: _TestService_TestMethod_Handler, - }, - }, - Streams: []grpc.StreamDesc{}, - Metadata: "test.proto", -} diff --git a/src/rpc_go/proto/test.proto b/src/rpc_go/proto/test.proto deleted file mode 100644 index cd26b1c..0000000 --- a/src/rpc_go/proto/test.proto +++ /dev/null @@ -1,17 +0,0 @@ -syntax = "proto3"; - -package test; - -option go_package = "./pb"; - -service TestService { - rpc TestMethod (TestRequest) returns (TestResponse) {} -} - -message TestRequest { - string name = 1; -} - -message TestResponse { - string message = 1; -} \ No newline at end of file diff --git a/src/rpc_go/server/main.go b/src/rpc_go/server/main.go deleted file mode 100644 index 6c07a48..0000000 --- a/src/rpc_go/server/main.go +++ /dev/null @@ -1,47 +0,0 @@ -package main - -import ( - "context" - "log" - "net" - "thesis/rpc_go/pb" - - "google.golang.org/grpc" - "google.golang.org/grpc/reflection" -) - -type server struct { - pb.UnimplementedTestServiceServer -} - -func (s *server) TestMethod( - ctx context.Context, in *pb.TestRequest, - )( - *pb.TestResponse, error, - ){ - - return &pb.TestResponse{ - Message: "Hello " + in.Name, - }, nil - -} - - -func main() { - - listener, err := net.Listen("tcp", ":8080") - - if err != nil { - log.Fatalln("Failed to create listener: ", err) - } - - s := grpc.NewServer() - reflection.Register(s) - - pb.RegisterTestServiceServer(s, &server{}) - - if err := s.Serve(listener); err != nil { - log.Fatalln("Failed to serve: ", err) - } - -}