From 04402a8bdf61e1197b4afcfe80b1c5f36139c01e Mon Sep 17 00:00:00 2001 From: gjs Date: Thu, 3 Sep 2026 20:40:08 +0800 Subject: [PATCH] lonelog to record --- .gitea/workflows/cd-test.yml | 2 +- .../lonelog.pb.go => record/pb/record.pb.go} | 128 ++++++++---------- .../pb/record_grpc.pb.go} | 126 ++++++++--------- rpc/{lonelog/lonelog.pb => record/record.pb} | Bin 14638 -> 14594 bytes .../lonelog.proto => record/record.proto} | 6 +- .../record/internal/logic/actionaddlogic.go | 6 +- services/record/internal/logic/base.go | 18 +-- services/record/internal/logic/itemslogic.go | 4 +- .../record/internal/logic/loginItemsLogic.go | 4 +- .../record/internal/logic/loginaddlogic.go | 6 +- .../record/internal/server/lonelogServer.go | 44 ------ .../record/internal/server/recordServer.go | 44 ++++++ services/record/lonelogClient/lonelog.go | 59 -------- services/record/{lonelog.go => record.go} | 13 +- services/record/recordClient/record.go | 59 ++++++++ 15 files changed, 255 insertions(+), 264 deletions(-) rename rpc/{lonelog/pb/lonelog.pb.go => record/pb/record.pb.go} (78%) rename rpc/{lonelog/pb/lonelog_grpc.pb.go => record/pb/record_grpc.pb.go} (53%) rename rpc/{lonelog/lonelog.pb => record/record.pb} (96%) rename rpc/{lonelog/lonelog.proto => record/record.proto} (93%) delete mode 100644 services/record/internal/server/lonelogServer.go create mode 100644 services/record/internal/server/recordServer.go delete mode 100644 services/record/lonelogClient/lonelog.go rename services/record/{lonelog.go => record.go} (95%) create mode 100644 services/record/recordClient/record.go diff --git a/.gitea/workflows/cd-test.yml b/.gitea/workflows/cd-test.yml index eafffc5..74497e1 100644 --- a/.gitea/workflows/cd-test.yml +++ b/.gitea/workflows/cd-test.yml @@ -44,5 +44,5 @@ jobs: docker pull ${{ vars.REGISTRY }}/lone/express:latest docker pull ${{ vars.REGISTRY }}/lone/sale:latest docker pull ${{ vars.REGISTRY }}/lone/equipment:latest - docker pull ${{ vars.REGISTRY }}/lone/lonelog:latest + docker pull ${{ vars.REGISTRY }}/lone/record:latest docker compose up -d diff --git a/rpc/lonelog/pb/lonelog.pb.go b/rpc/record/pb/record.pb.go similarity index 78% rename from rpc/lonelog/pb/lonelog.pb.go rename to rpc/record/pb/record.pb.go index e882355..52d3ea1 100644 --- a/rpc/lonelog/pb/lonelog.pb.go +++ b/rpc/record/pb/record.pb.go @@ -2,9 +2,9 @@ // versions: // protoc-gen-go v1.36.11 // protoc v4.25.8 -// source: lonelog/lonelog.proto +// source: record/record.proto -package lonelog +package record import ( _ "google.golang.org/genproto/googleapis/api/annotations" @@ -29,7 +29,6 @@ type ItemsRequest struct { Type int32 `protobuf:"varint,3,opt,name=type,proto3" json:"type,omitempty"` Ip string `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,omitempty"` AdminId int64 `protobuf:"varint,5,opt,name=admin_id,json=adminId,proto3" json:"admin_id,omitempty"` - ServiceId int64 `protobuf:"varint,6,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"` Time []string `protobuf:"bytes,7,rep,name=time,proto3" json:"time,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache @@ -37,7 +36,7 @@ type ItemsRequest struct { func (x *ItemsRequest) Reset() { *x = ItemsRequest{} - mi := &file_lonelog_lonelog_proto_msgTypes[0] + mi := &file_record_record_proto_msgTypes[0] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -49,7 +48,7 @@ func (x *ItemsRequest) String() string { func (*ItemsRequest) ProtoMessage() {} func (x *ItemsRequest) ProtoReflect() protoreflect.Message { - mi := &file_lonelog_lonelog_proto_msgTypes[0] + mi := &file_record_record_proto_msgTypes[0] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -62,7 +61,7 @@ func (x *ItemsRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ItemsRequest.ProtoReflect.Descriptor instead. func (*ItemsRequest) Descriptor() ([]byte, []int) { - return file_lonelog_lonelog_proto_rawDescGZIP(), []int{0} + return file_record_record_proto_rawDescGZIP(), []int{0} } func (x *ItemsRequest) GetPage() int32 { @@ -100,13 +99,6 @@ func (x *ItemsRequest) GetAdminId() int64 { return 0 } -func (x *ItemsRequest) GetServiceId() int64 { - if x != nil { - return x.ServiceId - } - return 0 -} - func (x *ItemsRequest) GetTime() []string { if x != nil { return x.Time @@ -125,7 +117,7 @@ type Response struct { func (x *Response) Reset() { *x = Response{} - mi := &file_lonelog_lonelog_proto_msgTypes[1] + mi := &file_record_record_proto_msgTypes[1] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -137,7 +129,7 @@ func (x *Response) String() string { func (*Response) ProtoMessage() {} func (x *Response) ProtoReflect() protoreflect.Message { - mi := &file_lonelog_lonelog_proto_msgTypes[1] + mi := &file_record_record_proto_msgTypes[1] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -150,7 +142,7 @@ func (x *Response) ProtoReflect() protoreflect.Message { // Deprecated: Use Response.ProtoReflect.Descriptor instead. func (*Response) Descriptor() ([]byte, []int) { - return file_lonelog_lonelog_proto_rawDescGZIP(), []int{1} + return file_record_record_proto_rawDescGZIP(), []int{1} } func (x *Response) GetCode() int32 { @@ -193,7 +185,7 @@ type ActionLog struct { func (x *ActionLog) Reset() { *x = ActionLog{} - mi := &file_lonelog_lonelog_proto_msgTypes[2] + mi := &file_record_record_proto_msgTypes[2] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -205,7 +197,7 @@ func (x *ActionLog) String() string { func (*ActionLog) ProtoMessage() {} func (x *ActionLog) ProtoReflect() protoreflect.Message { - mi := &file_lonelog_lonelog_proto_msgTypes[2] + mi := &file_record_record_proto_msgTypes[2] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -218,7 +210,7 @@ func (x *ActionLog) ProtoReflect() protoreflect.Message { // Deprecated: Use ActionLog.ProtoReflect.Descriptor instead. func (*ActionLog) Descriptor() ([]byte, []int) { - return file_lonelog_lonelog_proto_rawDescGZIP(), []int{2} + return file_record_record_proto_rawDescGZIP(), []int{2} } func (x *ActionLog) GetContent() string { @@ -315,7 +307,7 @@ type LoginLog struct { func (x *LoginLog) Reset() { *x = LoginLog{} - mi := &file_lonelog_lonelog_proto_msgTypes[3] + mi := &file_record_record_proto_msgTypes[3] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -327,7 +319,7 @@ func (x *LoginLog) String() string { func (*LoginLog) ProtoMessage() {} func (x *LoginLog) ProtoReflect() protoreflect.Message { - mi := &file_lonelog_lonelog_proto_msgTypes[3] + mi := &file_record_record_proto_msgTypes[3] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -340,7 +332,7 @@ func (x *LoginLog) ProtoReflect() protoreflect.Message { // Deprecated: Use LoginLog.ProtoReflect.Descriptor instead. func (*LoginLog) Descriptor() ([]byte, []int) { - return file_lonelog_lonelog_proto_rawDescGZIP(), []int{3} + return file_record_record_proto_rawDescGZIP(), []int{3} } func (x *LoginLog) GetAdminId() int64 { @@ -419,7 +411,7 @@ type ItemsLoginRequest struct { func (x *ItemsLoginRequest) Reset() { *x = ItemsLoginRequest{} - mi := &file_lonelog_lonelog_proto_msgTypes[4] + mi := &file_record_record_proto_msgTypes[4] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -431,7 +423,7 @@ func (x *ItemsLoginRequest) String() string { func (*ItemsLoginRequest) ProtoMessage() {} func (x *ItemsLoginRequest) ProtoReflect() protoreflect.Message { - mi := &file_lonelog_lonelog_proto_msgTypes[4] + mi := &file_record_record_proto_msgTypes[4] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -444,7 +436,7 @@ func (x *ItemsLoginRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ItemsLoginRequest.ProtoReflect.Descriptor instead. func (*ItemsLoginRequest) Descriptor() ([]byte, []int) { - return file_lonelog_lonelog_proto_rawDescGZIP(), []int{4} + return file_record_record_proto_rawDescGZIP(), []int{4} } func (x *ItemsLoginRequest) GetPage() int32 { @@ -482,19 +474,17 @@ func (x *ItemsLoginRequest) GetTime() []string { return nil } -var File_lonelog_lonelog_proto protoreflect.FileDescriptor +var File_record_record_proto protoreflect.FileDescriptor -const file_lonelog_lonelog_proto_rawDesc = "" + +const file_record_record_proto_rawDesc = "" + "\n" + - "\x15lonelog/lonelog.proto\x12\alonelog\x1a\x1cgoogle/api/annotations.proto\"\xa8\x01\n" + + "\x13record/record.proto\x12\x06record\x1a\x1cgoogle/api/annotations.proto\"\x89\x01\n" + "\fItemsRequest\x12\x12\n" + "\x04page\x18\x01 \x01(\x05R\x04page\x12\x12\n" + "\x04size\x18\x02 \x01(\x05R\x04size\x12\x12\n" + "\x04type\x18\x03 \x01(\x05R\x04type\x12\x0e\n" + "\x02ip\x18\x04 \x01(\tR\x02ip\x12\x19\n" + - "\badmin_id\x18\x05 \x01(\x03R\aadminId\x12\x1d\n" + - "\n" + - "service_id\x18\x06 \x01(\x03R\tserviceId\x12\x12\n" + + "\badmin_id\x18\x05 \x01(\x03R\aadminId\x12\x12\n" + "\x04time\x18\a \x03(\tR\x04time\"D\n" + "\bResponse\x12\x12\n" + "\x04code\x18\x01 \x01(\x05R\x04code\x12\x10\n" + @@ -532,43 +522,43 @@ const file_lonelog_lonelog_proto_rawDesc = "" + "\x04size\x18\x02 \x01(\x05R\x04size\x12\x0e\n" + "\x02ip\x18\x03 \x01(\tR\x02ip\x12\x19\n" + "\badmin_id\x18\x04 \x01(\x03R\aadminId\x12\x12\n" + - "\x04time\x18\x05 \x03(\tR\x04time2\x9b\x02\n" + - "\aLonelog\x12R\n" + - "\x05Items\x12\x15.lonelog.ItemsRequest\x1a\x11.lonelog.Response\"\x1f\x82\xd3\xe4\x93\x02\x19:\x01*\x12\x14/admin/v3/log/action\x12V\n" + + "\x04time\x18\x05 \x03(\tR\x04time2\x92\x02\n" + + "\x06Record\x12P\n" + + "\x05Items\x12\x14.record.ItemsRequest\x1a\x10.record.Response\"\x1f\x82\xd3\xe4\x93\x02\x19:\x01*\x12\x14/admin/v3/log/action\x12T\n" + "\n" + - "LoginItems\x12\x15.lonelog.ItemsRequest\x1a\x11.lonelog.Response\"\x1e\x82\xd3\xe4\x93\x02\x18:\x01*\x12\x13/admin/v3/log/login\x122\n" + - "\tActionAdd\x12\x12.lonelog.ActionLog\x1a\x11.lonelog.Response\x120\n" + - "\bLoginAdd\x12\x11.lonelog.LoginLog\x1a\x11.lonelog.ResponseB\x1bZ\x19lone-services/rpc/lonelogb\x06proto3" + "LoginItems\x12\x14.record.ItemsRequest\x1a\x10.record.Response\"\x1e\x82\xd3\xe4\x93\x02\x18:\x01*\x12\x13/admin/v3/log/login\x120\n" + + "\tActionAdd\x12\x11.record.ActionLog\x1a\x10.record.Response\x12.\n" + + "\bLoginAdd\x12\x10.record.LoginLog\x1a\x10.record.ResponseB\x1aZ\x18lone-services/rpc/recordb\x06proto3" var ( - file_lonelog_lonelog_proto_rawDescOnce sync.Once - file_lonelog_lonelog_proto_rawDescData []byte + file_record_record_proto_rawDescOnce sync.Once + file_record_record_proto_rawDescData []byte ) -func file_lonelog_lonelog_proto_rawDescGZIP() []byte { - file_lonelog_lonelog_proto_rawDescOnce.Do(func() { - file_lonelog_lonelog_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_lonelog_lonelog_proto_rawDesc), len(file_lonelog_lonelog_proto_rawDesc))) +func file_record_record_proto_rawDescGZIP() []byte { + file_record_record_proto_rawDescOnce.Do(func() { + file_record_record_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_record_record_proto_rawDesc), len(file_record_record_proto_rawDesc))) }) - return file_lonelog_lonelog_proto_rawDescData + return file_record_record_proto_rawDescData } -var file_lonelog_lonelog_proto_msgTypes = make([]protoimpl.MessageInfo, 5) -var file_lonelog_lonelog_proto_goTypes = []any{ - (*ItemsRequest)(nil), // 0: lonelog.ItemsRequest - (*Response)(nil), // 1: lonelog.Response - (*ActionLog)(nil), // 2: lonelog.ActionLog - (*LoginLog)(nil), // 3: lonelog.LoginLog - (*ItemsLoginRequest)(nil), // 4: lonelog.ItemsLoginRequest +var file_record_record_proto_msgTypes = make([]protoimpl.MessageInfo, 5) +var file_record_record_proto_goTypes = []any{ + (*ItemsRequest)(nil), // 0: record.ItemsRequest + (*Response)(nil), // 1: record.Response + (*ActionLog)(nil), // 2: record.ActionLog + (*LoginLog)(nil), // 3: record.LoginLog + (*ItemsLoginRequest)(nil), // 4: record.ItemsLoginRequest } -var file_lonelog_lonelog_proto_depIdxs = []int32{ - 0, // 0: lonelog.Lonelog.Items:input_type -> lonelog.ItemsRequest - 0, // 1: lonelog.Lonelog.LoginItems:input_type -> lonelog.ItemsRequest - 2, // 2: lonelog.Lonelog.ActionAdd:input_type -> lonelog.ActionLog - 3, // 3: lonelog.Lonelog.LoginAdd:input_type -> lonelog.LoginLog - 1, // 4: lonelog.Lonelog.Items:output_type -> lonelog.Response - 1, // 5: lonelog.Lonelog.LoginItems:output_type -> lonelog.Response - 1, // 6: lonelog.Lonelog.ActionAdd:output_type -> lonelog.Response - 1, // 7: lonelog.Lonelog.LoginAdd:output_type -> lonelog.Response +var file_record_record_proto_depIdxs = []int32{ + 0, // 0: record.Record.Items:input_type -> record.ItemsRequest + 0, // 1: record.Record.LoginItems:input_type -> record.ItemsRequest + 2, // 2: record.Record.ActionAdd:input_type -> record.ActionLog + 3, // 3: record.Record.LoginAdd:input_type -> record.LoginLog + 1, // 4: record.Record.Items:output_type -> record.Response + 1, // 5: record.Record.LoginItems:output_type -> record.Response + 1, // 6: record.Record.ActionAdd:output_type -> record.Response + 1, // 7: record.Record.LoginAdd:output_type -> record.Response 4, // [4:8] is the sub-list for method output_type 0, // [0:4] is the sub-list for method input_type 0, // [0:0] is the sub-list for extension type_name @@ -576,26 +566,26 @@ var file_lonelog_lonelog_proto_depIdxs = []int32{ 0, // [0:0] is the sub-list for field type_name } -func init() { file_lonelog_lonelog_proto_init() } -func file_lonelog_lonelog_proto_init() { - if File_lonelog_lonelog_proto != nil { +func init() { file_record_record_proto_init() } +func file_record_record_proto_init() { + if File_record_record_proto != nil { return } type x struct{} out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), - RawDescriptor: unsafe.Slice(unsafe.StringData(file_lonelog_lonelog_proto_rawDesc), len(file_lonelog_lonelog_proto_rawDesc)), + RawDescriptor: unsafe.Slice(unsafe.StringData(file_record_record_proto_rawDesc), len(file_record_record_proto_rawDesc)), NumEnums: 0, NumMessages: 5, NumExtensions: 0, NumServices: 1, }, - GoTypes: file_lonelog_lonelog_proto_goTypes, - DependencyIndexes: file_lonelog_lonelog_proto_depIdxs, - MessageInfos: file_lonelog_lonelog_proto_msgTypes, + GoTypes: file_record_record_proto_goTypes, + DependencyIndexes: file_record_record_proto_depIdxs, + MessageInfos: file_record_record_proto_msgTypes, }.Build() - File_lonelog_lonelog_proto = out.File - file_lonelog_lonelog_proto_goTypes = nil - file_lonelog_lonelog_proto_depIdxs = nil + File_record_record_proto = out.File + file_record_record_proto_goTypes = nil + file_record_record_proto_depIdxs = nil } diff --git a/rpc/lonelog/pb/lonelog_grpc.pb.go b/rpc/record/pb/record_grpc.pb.go similarity index 53% rename from rpc/lonelog/pb/lonelog_grpc.pb.go rename to rpc/record/pb/record_grpc.pb.go index a990a77..de205f6 100644 --- a/rpc/lonelog/pb/lonelog_grpc.pb.go +++ b/rpc/record/pb/record_grpc.pb.go @@ -2,9 +2,9 @@ // versions: // - protoc-gen-go-grpc v1.6.2 // - protoc v4.25.8 -// source: lonelog/lonelog.proto +// source: record/record.proto -package lonelog +package record import ( context "context" @@ -19,217 +19,217 @@ import ( const _ = grpc.SupportPackageIsVersion9 const ( - Lonelog_Items_FullMethodName = "/lonelog.Lonelog/Items" - Lonelog_LoginItems_FullMethodName = "/lonelog.Lonelog/LoginItems" - Lonelog_ActionAdd_FullMethodName = "/lonelog.Lonelog/ActionAdd" - Lonelog_LoginAdd_FullMethodName = "/lonelog.Lonelog/LoginAdd" + Record_Items_FullMethodName = "/record.Record/Items" + Record_LoginItems_FullMethodName = "/record.Record/LoginItems" + Record_ActionAdd_FullMethodName = "/record.Record/ActionAdd" + Record_LoginAdd_FullMethodName = "/record.Record/LoginAdd" ) -// LonelogClient is the client API for Lonelog service. +// RecordClient is the client API for Record 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 LonelogClient interface { +type RecordClient interface { Items(ctx context.Context, in *ItemsRequest, opts ...grpc.CallOption) (*Response, error) LoginItems(ctx context.Context, in *ItemsRequest, opts ...grpc.CallOption) (*Response, error) ActionAdd(ctx context.Context, in *ActionLog, opts ...grpc.CallOption) (*Response, error) LoginAdd(ctx context.Context, in *LoginLog, opts ...grpc.CallOption) (*Response, error) } -type lonelogClient struct { +type recordClient struct { cc grpc.ClientConnInterface } -func NewLonelogClient(cc grpc.ClientConnInterface) LonelogClient { - return &lonelogClient{cc} +func NewRecordClient(cc grpc.ClientConnInterface) RecordClient { + return &recordClient{cc} } -func (c *lonelogClient) Items(ctx context.Context, in *ItemsRequest, opts ...grpc.CallOption) (*Response, error) { +func (c *recordClient) Items(ctx context.Context, in *ItemsRequest, opts ...grpc.CallOption) (*Response, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, Lonelog_Items_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, Record_Items_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } -func (c *lonelogClient) LoginItems(ctx context.Context, in *ItemsRequest, opts ...grpc.CallOption) (*Response, error) { +func (c *recordClient) LoginItems(ctx context.Context, in *ItemsRequest, opts ...grpc.CallOption) (*Response, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, Lonelog_LoginItems_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, Record_LoginItems_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } -func (c *lonelogClient) ActionAdd(ctx context.Context, in *ActionLog, opts ...grpc.CallOption) (*Response, error) { +func (c *recordClient) ActionAdd(ctx context.Context, in *ActionLog, opts ...grpc.CallOption) (*Response, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, Lonelog_ActionAdd_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, Record_ActionAdd_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } -func (c *lonelogClient) LoginAdd(ctx context.Context, in *LoginLog, opts ...grpc.CallOption) (*Response, error) { +func (c *recordClient) LoginAdd(ctx context.Context, in *LoginLog, opts ...grpc.CallOption) (*Response, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) - err := c.cc.Invoke(ctx, Lonelog_LoginAdd_FullMethodName, in, out, cOpts...) + err := c.cc.Invoke(ctx, Record_LoginAdd_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } -// LonelogServer is the server API for Lonelog service. -// All implementations must embed UnimplementedLonelogServer +// RecordServer is the server API for Record service. +// All implementations must embed UnimplementedRecordServer // for forward compatibility. -type LonelogServer interface { +type RecordServer interface { Items(context.Context, *ItemsRequest) (*Response, error) LoginItems(context.Context, *ItemsRequest) (*Response, error) ActionAdd(context.Context, *ActionLog) (*Response, error) LoginAdd(context.Context, *LoginLog) (*Response, error) - mustEmbedUnimplementedLonelogServer() + mustEmbedUnimplementedRecordServer() } -// UnimplementedLonelogServer must be embedded to have +// UnimplementedRecordServer 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 UnimplementedLonelogServer struct{} +type UnimplementedRecordServer struct{} -func (UnimplementedLonelogServer) Items(context.Context, *ItemsRequest) (*Response, error) { +func (UnimplementedRecordServer) Items(context.Context, *ItemsRequest) (*Response, error) { return nil, status.Error(codes.Unimplemented, "method Items not implemented") } -func (UnimplementedLonelogServer) LoginItems(context.Context, *ItemsRequest) (*Response, error) { +func (UnimplementedRecordServer) LoginItems(context.Context, *ItemsRequest) (*Response, error) { return nil, status.Error(codes.Unimplemented, "method LoginItems not implemented") } -func (UnimplementedLonelogServer) ActionAdd(context.Context, *ActionLog) (*Response, error) { +func (UnimplementedRecordServer) ActionAdd(context.Context, *ActionLog) (*Response, error) { return nil, status.Error(codes.Unimplemented, "method ActionAdd not implemented") } -func (UnimplementedLonelogServer) LoginAdd(context.Context, *LoginLog) (*Response, error) { +func (UnimplementedRecordServer) LoginAdd(context.Context, *LoginLog) (*Response, error) { return nil, status.Error(codes.Unimplemented, "method LoginAdd not implemented") } -func (UnimplementedLonelogServer) mustEmbedUnimplementedLonelogServer() {} -func (UnimplementedLonelogServer) testEmbeddedByValue() {} +func (UnimplementedRecordServer) mustEmbedUnimplementedRecordServer() {} +func (UnimplementedRecordServer) testEmbeddedByValue() {} -// UnsafeLonelogServer may be embedded to opt out of forward compatibility for this service. -// Use of this interface is not recommended, as added methods to LonelogServer will +// UnsafeRecordServer may be embedded to opt out of forward compatibility for this service. +// Use of this interface is not recommended, as added methods to RecordServer will // result in compilation errors. -type UnsafeLonelogServer interface { - mustEmbedUnimplementedLonelogServer() +type UnsafeRecordServer interface { + mustEmbedUnimplementedRecordServer() } -func RegisterLonelogServer(s grpc.ServiceRegistrar, srv LonelogServer) { - // If the following call panics, it indicates UnimplementedLonelogServer was +func RegisterRecordServer(s grpc.ServiceRegistrar, srv RecordServer) { + // If the following call panics, it indicates UnimplementedRecordServer 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(&Lonelog_ServiceDesc, srv) + s.RegisterService(&Record_ServiceDesc, srv) } -func _Lonelog_Items_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { +func _Record_Items_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ItemsRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { - return srv.(LonelogServer).Items(ctx, in) + return srv.(RecordServer).Items(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: Lonelog_Items_FullMethodName, + FullMethod: Record_Items_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(LonelogServer).Items(ctx, req.(*ItemsRequest)) + return srv.(RecordServer).Items(ctx, req.(*ItemsRequest)) } return interceptor(ctx, in, info, handler) } -func _Lonelog_LoginItems_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { +func _Record_LoginItems_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ItemsRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { - return srv.(LonelogServer).LoginItems(ctx, in) + return srv.(RecordServer).LoginItems(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: Lonelog_LoginItems_FullMethodName, + FullMethod: Record_LoginItems_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(LonelogServer).LoginItems(ctx, req.(*ItemsRequest)) + return srv.(RecordServer).LoginItems(ctx, req.(*ItemsRequest)) } return interceptor(ctx, in, info, handler) } -func _Lonelog_ActionAdd_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { +func _Record_ActionAdd_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ActionLog) if err := dec(in); err != nil { return nil, err } if interceptor == nil { - return srv.(LonelogServer).ActionAdd(ctx, in) + return srv.(RecordServer).ActionAdd(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: Lonelog_ActionAdd_FullMethodName, + FullMethod: Record_ActionAdd_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(LonelogServer).ActionAdd(ctx, req.(*ActionLog)) + return srv.(RecordServer).ActionAdd(ctx, req.(*ActionLog)) } return interceptor(ctx, in, info, handler) } -func _Lonelog_LoginAdd_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { +func _Record_LoginAdd_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(LoginLog) if err := dec(in); err != nil { return nil, err } if interceptor == nil { - return srv.(LonelogServer).LoginAdd(ctx, in) + return srv.(RecordServer).LoginAdd(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: Lonelog_LoginAdd_FullMethodName, + FullMethod: Record_LoginAdd_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(LonelogServer).LoginAdd(ctx, req.(*LoginLog)) + return srv.(RecordServer).LoginAdd(ctx, req.(*LoginLog)) } return interceptor(ctx, in, info, handler) } -// Lonelog_ServiceDesc is the grpc.ServiceDesc for Lonelog service. +// Record_ServiceDesc is the grpc.ServiceDesc for Record service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) -var Lonelog_ServiceDesc = grpc.ServiceDesc{ - ServiceName: "lonelog.Lonelog", - HandlerType: (*LonelogServer)(nil), +var Record_ServiceDesc = grpc.ServiceDesc{ + ServiceName: "record.Record", + HandlerType: (*RecordServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Items", - Handler: _Lonelog_Items_Handler, + Handler: _Record_Items_Handler, }, { MethodName: "LoginItems", - Handler: _Lonelog_LoginItems_Handler, + Handler: _Record_LoginItems_Handler, }, { MethodName: "ActionAdd", - Handler: _Lonelog_ActionAdd_Handler, + Handler: _Record_ActionAdd_Handler, }, { MethodName: "LoginAdd", - Handler: _Lonelog_LoginAdd_Handler, + Handler: _Record_LoginAdd_Handler, }, }, Streams: []grpc.StreamDesc{}, - Metadata: "lonelog/lonelog.proto", + Metadata: "record/record.proto", } diff --git a/rpc/lonelog/lonelog.pb b/rpc/record/record.pb similarity index 96% rename from rpc/lonelog/lonelog.pb rename to rpc/record/record.pb index 8a9b6bda3251c42fc93db5f6a830a7ab746242f8..1876ac79ec57359dcf5170ebf1cac69f2f058fae 100644 GIT binary patch delta 295 zcmZ2i)Ks+Lv9ZEjE-vAs)a3l46nzM#S5TB+k}t#t;Ym&2Z6wR2)HzwzqJ7L!9g|Bk^Ya{2QiKFy7C?l6Cc#bD3ra06$j>WI71HD409ygl0JB>UEP_?NlT?&M ePJUjhZgFZ+S!Qx-v3^lOGBgm9*x10qUP)S|M?M{X(lGjrn8y2*nJ>|3k7kpg0%~Y z>cQ**^Mg_gOH+$Wqy%BYlmD1&>xFS~`Q)c(<`JnS*g~t`h>O!Pxg;|`&oL!MNC;+{ z9z+ai7{Ugzl8%xDIbRp*&tm