From b20847c99889e4a70af567acda328079e48e67ae Mon Sep 17 00:00:00 2001 From: admin Date: Sun, 13 Apr 2025 20:27:20 +0300 Subject: [PATCH] first commit --- api/generated/v1/test.pb.go | 486 ++++++++++++++++++++++ api/generated/v1/test_grpc.pb.go | 235 +++++++++++ api/proto/v1/test.proto | 44 ++ cmd/server/main.go | 102 +++++ generate_grpc.sh | 6 + go.mod | 50 +++ go.sum | 142 +++++++ internal/config/config.go | 17 + internal/db/conn.go | 17 + internal/db/schema.sql | 5 + internal/db/sqlc.yaml | 7 + internal/logger/logger.go | 1 + internal/test/adapters/http.go | 19 + internal/test/db/generated/db.go | 31 ++ internal/test/db/generated/models.go | 10 + internal/test/db/generated/queries.sql.go | 55 +++ internal/test/db/queries.sql | 11 + internal/test/repository.go | 42 ++ internal/test/service.go | 37 ++ pkg/utils/utils.go | 1 + pkgs | 9 + 21 files changed, 1327 insertions(+) create mode 100644 api/generated/v1/test.pb.go create mode 100644 api/generated/v1/test_grpc.pb.go create mode 100644 api/proto/v1/test.proto create mode 100644 cmd/server/main.go create mode 100755 generate_grpc.sh create mode 100644 go.mod create mode 100644 go.sum create mode 100644 internal/config/config.go create mode 100644 internal/db/conn.go create mode 100644 internal/db/schema.sql create mode 100644 internal/db/sqlc.yaml create mode 100644 internal/logger/logger.go create mode 100644 internal/test/adapters/http.go create mode 100644 internal/test/db/generated/db.go create mode 100644 internal/test/db/generated/models.go create mode 100644 internal/test/db/generated/queries.sql.go create mode 100644 internal/test/db/queries.sql create mode 100644 internal/test/repository.go create mode 100644 internal/test/service.go create mode 100644 pkg/utils/utils.go create mode 100644 pkgs diff --git a/api/generated/v1/test.pb.go b/api/generated/v1/test.pb.go new file mode 100644 index 0000000..1f92a47 --- /dev/null +++ b/api/generated/v1/test.pb.go @@ -0,0 +1,486 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.36.6 +// protoc v6.30.0 +// source: test.proto + +package v1 + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" + unsafe "unsafe" +) + +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 CreateTestRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *CreateTestRequest) Reset() { + *x = CreateTestRequest{} + mi := &file_test_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *CreateTestRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*CreateTestRequest) ProtoMessage() {} + +func (x *CreateTestRequest) 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 CreateTestRequest.ProtoReflect.Descriptor instead. +func (*CreateTestRequest) Descriptor() ([]byte, []int) { + return file_test_proto_rawDescGZIP(), []int{0} +} + +func (x *CreateTestRequest) GetData() string { + if x != nil { + return x.Data + } + return "" +} + +type CreateTestResponse struct { + state protoimpl.MessageState `protogen:"open.v1"` + Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *CreateTestResponse) Reset() { + *x = CreateTestResponse{} + mi := &file_test_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *CreateTestResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*CreateTestResponse) ProtoMessage() {} + +func (x *CreateTestResponse) 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 CreateTestResponse.ProtoReflect.Descriptor instead. +func (*CreateTestResponse) Descriptor() ([]byte, []int) { + return file_test_proto_rawDescGZIP(), []int{1} +} + +func (x *CreateTestResponse) GetId() int64 { + if x != nil { + return x.Id + } + return 0 +} + +type GetTestRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *GetTestRequest) Reset() { + *x = GetTestRequest{} + mi := &file_test_proto_msgTypes[2] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *GetTestRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*GetTestRequest) ProtoMessage() {} + +func (x *GetTestRequest) ProtoReflect() protoreflect.Message { + mi := &file_test_proto_msgTypes[2] + 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 GetTestRequest.ProtoReflect.Descriptor instead. +func (*GetTestRequest) Descriptor() ([]byte, []int) { + return file_test_proto_rawDescGZIP(), []int{2} +} + +func (x *GetTestRequest) GetId() int64 { + if x != nil { + return x.Id + } + return 0 +} + +type GetTestResponse struct { + state protoimpl.MessageState `protogen:"open.v1"` + Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` + Data string `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *GetTestResponse) Reset() { + *x = GetTestResponse{} + mi := &file_test_proto_msgTypes[3] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *GetTestResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*GetTestResponse) ProtoMessage() {} + +func (x *GetTestResponse) ProtoReflect() protoreflect.Message { + mi := &file_test_proto_msgTypes[3] + 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 GetTestResponse.ProtoReflect.Descriptor instead. +func (*GetTestResponse) Descriptor() ([]byte, []int) { + return file_test_proto_rawDescGZIP(), []int{3} +} + +func (x *GetTestResponse) GetId() int64 { + if x != nil { + return x.Id + } + return 0 +} + +func (x *GetTestResponse) GetData() string { + if x != nil { + return x.Data + } + return "" +} + +type UpdateTestRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` + Data string `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *UpdateTestRequest) Reset() { + *x = UpdateTestRequest{} + mi := &file_test_proto_msgTypes[4] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *UpdateTestRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*UpdateTestRequest) ProtoMessage() {} + +func (x *UpdateTestRequest) ProtoReflect() protoreflect.Message { + mi := &file_test_proto_msgTypes[4] + 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 UpdateTestRequest.ProtoReflect.Descriptor instead. +func (*UpdateTestRequest) Descriptor() ([]byte, []int) { + return file_test_proto_rawDescGZIP(), []int{4} +} + +func (x *UpdateTestRequest) GetId() int64 { + if x != nil { + return x.Id + } + return 0 +} + +func (x *UpdateTestRequest) GetData() string { + if x != nil { + return x.Data + } + return "" +} + +type UpdateTestResponse struct { + state protoimpl.MessageState `protogen:"open.v1"` + Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *UpdateTestResponse) Reset() { + *x = UpdateTestResponse{} + mi := &file_test_proto_msgTypes[5] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *UpdateTestResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*UpdateTestResponse) ProtoMessage() {} + +func (x *UpdateTestResponse) ProtoReflect() protoreflect.Message { + mi := &file_test_proto_msgTypes[5] + 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 UpdateTestResponse.ProtoReflect.Descriptor instead. +func (*UpdateTestResponse) Descriptor() ([]byte, []int) { + return file_test_proto_rawDescGZIP(), []int{5} +} + +func (x *UpdateTestResponse) GetId() int64 { + if x != nil { + return x.Id + } + return 0 +} + +type DeleteTestRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *DeleteTestRequest) Reset() { + *x = DeleteTestRequest{} + mi := &file_test_proto_msgTypes[6] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *DeleteTestRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*DeleteTestRequest) ProtoMessage() {} + +func (x *DeleteTestRequest) ProtoReflect() protoreflect.Message { + mi := &file_test_proto_msgTypes[6] + 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 DeleteTestRequest.ProtoReflect.Descriptor instead. +func (*DeleteTestRequest) Descriptor() ([]byte, []int) { + return file_test_proto_rawDescGZIP(), []int{6} +} + +func (x *DeleteTestRequest) GetId() int64 { + if x != nil { + return x.Id + } + return 0 +} + +type DeleteTestResponse struct { + state protoimpl.MessageState `protogen:"open.v1"` + Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *DeleteTestResponse) Reset() { + *x = DeleteTestResponse{} + mi := &file_test_proto_msgTypes[7] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *DeleteTestResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*DeleteTestResponse) ProtoMessage() {} + +func (x *DeleteTestResponse) ProtoReflect() protoreflect.Message { + mi := &file_test_proto_msgTypes[7] + 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 DeleteTestResponse.ProtoReflect.Descriptor instead. +func (*DeleteTestResponse) Descriptor() ([]byte, []int) { + return file_test_proto_rawDescGZIP(), []int{7} +} + +func (x *DeleteTestResponse) GetId() int64 { + if x != nil { + return x.Id + } + return 0 +} + +var File_test_proto protoreflect.FileDescriptor + +const file_test_proto_rawDesc = "" + + "\n" + + "\n" + + "test.proto\x12\x02v1\"'\n" + + "\x11CreateTestRequest\x12\x12\n" + + "\x04data\x18\x01 \x01(\tR\x04data\"$\n" + + "\x12CreateTestResponse\x12\x0e\n" + + "\x02id\x18\x01 \x01(\x03R\x02id\" \n" + + "\x0eGetTestRequest\x12\x0e\n" + + "\x02id\x18\x01 \x01(\x03R\x02id\"5\n" + + "\x0fGetTestResponse\x12\x0e\n" + + "\x02id\x18\x01 \x01(\x03R\x02id\x12\x12\n" + + "\x04data\x18\x02 \x01(\tR\x04data\"7\n" + + "\x11UpdateTestRequest\x12\x0e\n" + + "\x02id\x18\x01 \x01(\x03R\x02id\x12\x12\n" + + "\x04data\x18\x02 \x01(\tR\x04data\"$\n" + + "\x12UpdateTestResponse\x12\x0e\n" + + "\x02id\x18\x01 \x01(\x03R\x02id\"#\n" + + "\x11DeleteTestRequest\x12\x0e\n" + + "\x02id\x18\x01 \x01(\x03R\x02id\"$\n" + + "\x12DeleteTestResponse\x12\x0e\n" + + "\x02id\x18\x01 \x01(\x03R\x02id2\xf8\x01\n" + + "\vTestService\x12;\n" + + "\n" + + "CreateTest\x12\x15.v1.CreateTestRequest\x1a\x16.v1.CreateTestResponse\x122\n" + + "\aGetTest\x12\x12.v1.GetTestRequest\x1a\x13.v1.GetTestResponse\x12;\n" + + "\n" + + "UpdateTest\x12\x15.v1.UpdateTestRequest\x1a\x16.v1.UpdateTestResponse\x12;\n" + + "\n" + + "DeleteTest\x12\x15.v1.DeleteTestRequest\x1a\x16.v1.DeleteTestResponseB\x14Z\x12./api/generated/v1b\x06proto3" + +var ( + file_test_proto_rawDescOnce sync.Once + file_test_proto_rawDescData []byte +) + +func file_test_proto_rawDescGZIP() []byte { + file_test_proto_rawDescOnce.Do(func() { + file_test_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_test_proto_rawDesc), len(file_test_proto_rawDesc))) + }) + return file_test_proto_rawDescData +} + +var file_test_proto_msgTypes = make([]protoimpl.MessageInfo, 8) +var file_test_proto_goTypes = []any{ + (*CreateTestRequest)(nil), // 0: v1.CreateTestRequest + (*CreateTestResponse)(nil), // 1: v1.CreateTestResponse + (*GetTestRequest)(nil), // 2: v1.GetTestRequest + (*GetTestResponse)(nil), // 3: v1.GetTestResponse + (*UpdateTestRequest)(nil), // 4: v1.UpdateTestRequest + (*UpdateTestResponse)(nil), // 5: v1.UpdateTestResponse + (*DeleteTestRequest)(nil), // 6: v1.DeleteTestRequest + (*DeleteTestResponse)(nil), // 7: v1.DeleteTestResponse +} +var file_test_proto_depIdxs = []int32{ + 0, // 0: v1.TestService.CreateTest:input_type -> v1.CreateTestRequest + 2, // 1: v1.TestService.GetTest:input_type -> v1.GetTestRequest + 4, // 2: v1.TestService.UpdateTest:input_type -> v1.UpdateTestRequest + 6, // 3: v1.TestService.DeleteTest:input_type -> v1.DeleteTestRequest + 1, // 4: v1.TestService.CreateTest:output_type -> v1.CreateTestResponse + 3, // 5: v1.TestService.GetTest:output_type -> v1.GetTestResponse + 5, // 6: v1.TestService.UpdateTest:output_type -> v1.UpdateTestResponse + 7, // 7: v1.TestService.DeleteTest:output_type -> v1.DeleteTestResponse + 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 + 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: unsafe.Slice(unsafe.StringData(file_test_proto_rawDesc), len(file_test_proto_rawDesc)), + NumEnums: 0, + NumMessages: 8, + 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_goTypes = nil + file_test_proto_depIdxs = nil +} diff --git a/api/generated/v1/test_grpc.pb.go b/api/generated/v1/test_grpc.pb.go new file mode 100644 index 0000000..bc5ae5a --- /dev/null +++ b/api/generated/v1/test_grpc.pb.go @@ -0,0 +1,235 @@ +// Code generated by protoc-gen-go-grpc. DO NOT EDIT. +// versions: +// - protoc-gen-go-grpc v1.5.1 +// - protoc v6.30.0 +// source: test.proto + +package v1 + +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_CreateTest_FullMethodName = "/v1.TestService/CreateTest" + TestService_GetTest_FullMethodName = "/v1.TestService/GetTest" + TestService_UpdateTest_FullMethodName = "/v1.TestService/UpdateTest" + TestService_DeleteTest_FullMethodName = "/v1.TestService/DeleteTest" +) + +// 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 { + CreateTest(ctx context.Context, in *CreateTestRequest, opts ...grpc.CallOption) (*CreateTestResponse, error) + GetTest(ctx context.Context, in *GetTestRequest, opts ...grpc.CallOption) (*GetTestResponse, error) + UpdateTest(ctx context.Context, in *UpdateTestRequest, opts ...grpc.CallOption) (*UpdateTestResponse, error) + DeleteTest(ctx context.Context, in *DeleteTestRequest, opts ...grpc.CallOption) (*DeleteTestResponse, error) +} + +type testServiceClient struct { + cc grpc.ClientConnInterface +} + +func NewTestServiceClient(cc grpc.ClientConnInterface) TestServiceClient { + return &testServiceClient{cc} +} + +func (c *testServiceClient) CreateTest(ctx context.Context, in *CreateTestRequest, opts ...grpc.CallOption) (*CreateTestResponse, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(CreateTestResponse) + err := c.cc.Invoke(ctx, TestService_CreateTest_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *testServiceClient) GetTest(ctx context.Context, in *GetTestRequest, opts ...grpc.CallOption) (*GetTestResponse, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(GetTestResponse) + err := c.cc.Invoke(ctx, TestService_GetTest_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *testServiceClient) UpdateTest(ctx context.Context, in *UpdateTestRequest, opts ...grpc.CallOption) (*UpdateTestResponse, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(UpdateTestResponse) + err := c.cc.Invoke(ctx, TestService_UpdateTest_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *testServiceClient) DeleteTest(ctx context.Context, in *DeleteTestRequest, opts ...grpc.CallOption) (*DeleteTestResponse, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(DeleteTestResponse) + err := c.cc.Invoke(ctx, TestService_DeleteTest_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 { + CreateTest(context.Context, *CreateTestRequest) (*CreateTestResponse, error) + GetTest(context.Context, *GetTestRequest) (*GetTestResponse, error) + UpdateTest(context.Context, *UpdateTestRequest) (*UpdateTestResponse, error) + DeleteTest(context.Context, *DeleteTestRequest) (*DeleteTestResponse, 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) CreateTest(context.Context, *CreateTestRequest) (*CreateTestResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method CreateTest not implemented") +} +func (UnimplementedTestServiceServer) GetTest(context.Context, *GetTestRequest) (*GetTestResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetTest not implemented") +} +func (UnimplementedTestServiceServer) UpdateTest(context.Context, *UpdateTestRequest) (*UpdateTestResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method UpdateTest not implemented") +} +func (UnimplementedTestServiceServer) DeleteTest(context.Context, *DeleteTestRequest) (*DeleteTestResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method DeleteTest 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_CreateTest_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(CreateTestRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(TestServiceServer).CreateTest(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: TestService_CreateTest_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(TestServiceServer).CreateTest(ctx, req.(*CreateTestRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _TestService_GetTest_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(GetTestRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(TestServiceServer).GetTest(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: TestService_GetTest_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(TestServiceServer).GetTest(ctx, req.(*GetTestRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _TestService_UpdateTest_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(UpdateTestRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(TestServiceServer).UpdateTest(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: TestService_UpdateTest_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(TestServiceServer).UpdateTest(ctx, req.(*UpdateTestRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _TestService_DeleteTest_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(DeleteTestRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(TestServiceServer).DeleteTest(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: TestService_DeleteTest_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(TestServiceServer).DeleteTest(ctx, req.(*DeleteTestRequest)) + } + 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: "v1.TestService", + HandlerType: (*TestServiceServer)(nil), + Methods: []grpc.MethodDesc{ + { + MethodName: "CreateTest", + Handler: _TestService_CreateTest_Handler, + }, + { + MethodName: "GetTest", + Handler: _TestService_GetTest_Handler, + }, + { + MethodName: "UpdateTest", + Handler: _TestService_UpdateTest_Handler, + }, + { + MethodName: "DeleteTest", + Handler: _TestService_DeleteTest_Handler, + }, + }, + Streams: []grpc.StreamDesc{}, + Metadata: "test.proto", +} diff --git a/api/proto/v1/test.proto b/api/proto/v1/test.proto new file mode 100644 index 0000000..fef3856 --- /dev/null +++ b/api/proto/v1/test.proto @@ -0,0 +1,44 @@ +syntax = "proto3"; +package v1; +option go_package = "./api/generated/v1"; + +service TestService { + rpc CreateTest(CreateTestRequest) returns (CreateTestResponse); + rpc GetTest(GetTestRequest) returns (GetTestResponse); + rpc UpdateTest(UpdateTestRequest) returns (UpdateTestResponse); + rpc DeleteTest(DeleteTestRequest) returns (DeleteTestResponse); +} + +message CreateTestRequest { + string data = 1; +} + +message CreateTestResponse { + int64 id = 1; +} + +message GetTestRequest { + int64 id = 1; +} + +message GetTestResponse { + int64 id = 1; + string data = 2; +} + +message UpdateTestRequest { + int64 id = 1; + string data = 2; +} + +message UpdateTestResponse { + int64 id = 1; +} + +message DeleteTestRequest { + int64 id = 1; +} + +message DeleteTestResponse { + int64 id = 1; +} \ No newline at end of file diff --git a/cmd/server/main.go b/cmd/server/main.go new file mode 100644 index 0000000..6ba35b6 --- /dev/null +++ b/cmd/server/main.go @@ -0,0 +1,102 @@ +package main + +import ( + adapters2 "Sipro-Marketplaces/internal/test/adapters" + "context" + "database/sql" + "log" + "os" + "os/signal" + "sync" + "syscall" + + "Sipro-Marketplaces/internal/config" + "Sipro-Marketplaces/internal/db" + "github.com/gofiber/fiber/v2" + "google.golang.org/grpc" +) + +type Server struct { + httpApp *fiber.App + grpcServer *grpc.Server + db *sql.DB +} + +func NewServer(cfg config.Config) (*Server, error) { + dbConn, err := db.NewConnection(cfg.DB) + if err != nil { + return nil, err + } + + httpApp := fiber.New() + //adapters.RegisterHTTPRoutes(httpApp, testService) + kal := httpApp.Group("/test") + adapters2.RegisterRouter(&kal) + grpcServer := grpc.NewServer() + + return &Server{ + httpApp: httpApp, + grpcServer: grpcServer, + db: dbConn, + }, nil +} + +func (s *Server) Start(cfg config.Config) error { + var wg sync.WaitGroup + ctx, cancel := context.WithCancel(context.Background()) + defer cancel() + + wg.Add(1) + go func() { + defer wg.Done() + log.Printf("Starting HTTP server on %s", cfg.HTTP) + if err := s.httpApp.Listen(cfg.HTTP); err != nil { + log.Printf("HTTP server failed: %v", err) + cancel() + } + }() + + wg.Add(1) + go func() { + defer wg.Done() + log.Printf("Starting gRPC server on %s", cfg.GRPC) + }() + + wg.Add(1) + + quit := make(chan os.Signal, 1) + signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM) + select { + case <-quit: + log.Println("Shutting down...") + case <-ctx.Done(): + log.Println("Context cancelled, shutting down...") + } + + s.shutdown() + wg.Wait() + return nil +} + +func (s *Server) shutdown() { + log.Println("Initiating graceful shutdown...") + if err := s.httpApp.Shutdown(); err != nil { + log.Printf("Failed to stop HTTP: %v", err) + } + s.grpcServer.GracefulStop() + if err := s.db.Close(); err != nil { + log.Printf("Failed to close DB: %v", err) + } + log.Println("Shutdown complete") +} + +func main() { + cfg := config.Load() + server, err := NewServer(cfg) + if err != nil { + log.Fatalf("Failed to initialize server: %v", err) + } + if err := server.Start(cfg); err != nil { + log.Fatalf("Server failed: %v", err) + } +} diff --git a/generate_grpc.sh b/generate_grpc.sh new file mode 100755 index 0000000..1634d9e --- /dev/null +++ b/generate_grpc.sh @@ -0,0 +1,6 @@ +#!/bin/bash +protoc \ + --go_out=paths=source_relative:./api/generated/v1 \ + --go-grpc_out=paths=source_relative:./api/generated/v1 \ + -I./api/proto/v1 \ + ./api/proto/v1/*.proto diff --git a/go.mod b/go.mod new file mode 100644 index 0000000..0358945 --- /dev/null +++ b/go.mod @@ -0,0 +1,50 @@ +module Sipro-Marketplaces + +go 1.24 + +require ( + github.com/KyleBanks/depth v1.2.1 // indirect + github.com/PuerkitoBio/purell v1.1.1 // indirect + github.com/PuerkitoBio/urlesc v0.0.0-20170810143723-de5bf2ad4578 // indirect + github.com/andybalholm/brotli v1.1.0 // indirect + github.com/bytedance/sonic v1.13.2 // indirect + github.com/bytedance/sonic/loader v0.2.4 // indirect + github.com/cespare/xxhash/v2 v2.3.0 // indirect + github.com/cloudwego/base64x v0.1.5 // indirect + github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect + github.com/go-openapi/jsonpointer v0.19.5 // indirect + github.com/go-openapi/jsonreference v0.19.6 // indirect + github.com/go-openapi/spec v0.20.4 // indirect + github.com/go-openapi/swag v0.19.15 // indirect + github.com/gofiber/fiber/v2 v2.52.6 // indirect + github.com/gofiber/swagger v1.1.1 // indirect + github.com/golang-jwt/jwt/v5 v5.2.2 // indirect + github.com/google/uuid v1.6.0 // indirect + github.com/josharian/intern v1.0.0 // indirect + github.com/klauspost/compress v1.17.11 // indirect + github.com/klauspost/cpuid/v2 v2.0.9 // indirect + github.com/lib/pq v1.10.9 // indirect + github.com/mailru/easyjson v0.7.6 // indirect + github.com/mattn/go-colorable v0.1.13 // indirect + github.com/mattn/go-isatty v0.0.20 // indirect + github.com/mattn/go-runewidth v0.0.16 // indirect + github.com/redis/go-redis/v9 v9.7.3 // indirect + github.com/rivo/uniseg v0.2.0 // indirect + github.com/rs/zerolog v1.34.0 // indirect + github.com/swaggo/files/v2 v2.0.2 // indirect + github.com/swaggo/swag v1.16.4 // indirect + github.com/twitchyliquid64/golang-asm v0.15.1 // indirect + github.com/twmb/franz-go v1.18.1 // indirect + github.com/valyala/bytebufferpool v1.0.0 // indirect + github.com/valyala/fasthttp v1.51.0 // indirect + github.com/valyala/tcplisten v1.0.0 // indirect + golang.org/x/arch v0.0.0-20210923205945-b76863e36670 // indirect + golang.org/x/net v0.34.0 // indirect + golang.org/x/sys v0.29.0 // indirect + golang.org/x/text v0.21.0 // indirect + golang.org/x/tools v0.21.1-0.20240508182429-e35e4ccd0d2d // indirect + google.golang.org/genproto/googleapis/rpc v0.0.0-20250115164207-1a7da9e5054f // indirect + google.golang.org/grpc v1.71.1 // indirect + google.golang.org/protobuf v1.36.4 // indirect + gopkg.in/yaml.v2 v2.4.0 // indirect +) diff --git a/go.sum b/go.sum new file mode 100644 index 0000000..ef1b5c9 --- /dev/null +++ b/go.sum @@ -0,0 +1,142 @@ +github.com/KyleBanks/depth v1.2.1 h1:5h8fQADFrWtarTdtDudMmGsC7GPbOAu6RVB3ffsVFHc= +github.com/KyleBanks/depth v1.2.1/go.mod h1:jzSb9d0L43HxTQfT+oSA1EEp2q+ne2uh6XgeJcm8brE= +github.com/PuerkitoBio/purell v1.1.1 h1:WEQqlqaGbrPkxLJWfBwQmfEAE1Z7ONdDLqrN38tNFfI= +github.com/PuerkitoBio/purell v1.1.1/go.mod h1:c11w/QuzBsJSee3cPx9rAFu61PvFxuPbtSwDGJws/X0= +github.com/PuerkitoBio/urlesc v0.0.0-20170810143723-de5bf2ad4578 h1:d+Bc7a5rLufV/sSk/8dngufqelfh6jnri85riMAaF/M= +github.com/PuerkitoBio/urlesc v0.0.0-20170810143723-de5bf2ad4578/go.mod h1:uGdkoq3SwY9Y+13GIhn11/XLaGBb4BfwItxLd5jeuXE= +github.com/andybalholm/brotli v1.1.0 h1:eLKJA0d02Lf0mVpIDgYnqXcUn0GqVmEFny3VuID1U3M= +github.com/andybalholm/brotli v1.1.0/go.mod h1:sms7XGricyQI9K10gOSf56VKKWS4oLer58Q+mhRPtnY= +github.com/bytedance/sonic v1.13.2 h1:8/H1FempDZqC4VqjptGo14QQlJx8VdZJegxs6wwfqpQ= +github.com/bytedance/sonic v1.13.2/go.mod h1:o68xyaF9u2gvVBuGHPlUVCy+ZfmNNO5ETf1+KgkJhz4= +github.com/bytedance/sonic/loader v0.1.1/go.mod h1:ncP89zfokxS5LZrJxl5z0UJcsk4M4yY2JpfqGeCtNLU= +github.com/bytedance/sonic/loader v0.2.4 h1:ZWCw4stuXUsn1/+zQDqeE7JKP+QO47tz7QCNan80NzY= +github.com/bytedance/sonic/loader v0.2.4/go.mod h1:N8A3vUdtUebEY2/VQC0MyhYeKUFosQU6FxH2JmUe6VI= +github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44= +github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs= +github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs= +github.com/cloudwego/base64x v0.1.5 h1:XPciSp1xaq2VCSt6lF0phncD4koWyULpl5bUxbfCyP4= +github.com/cloudwego/base64x v0.1.5/go.mod h1:0zlkT4Wn5C6NdauXdJRhSKRlJvmclQ1hhJgA0rcu/8w= +github.com/cloudwego/iasm v0.2.0/go.mod h1:8rXZaNYT2n95jn+zTI1sDr+IgcD2GVs0nlbbQPiEFhY= +github.com/coreos/go-systemd/v22 v22.5.0/go.mod h1:Y58oyj3AT4RCenI/lSvhwexgC+NSVTIJ3seZv2GcEnc= +github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E= +github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78= +github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cuUVRXasLTGF7a8hSLbxyZXjz+1KgoB3wDUb6vlszIc= +github.com/go-openapi/jsonpointer v0.19.3/go.mod h1:Pl9vOtqEWErmShwVjC8pYs9cog34VGT37dQOVbmoatg= +github.com/go-openapi/jsonpointer v0.19.5 h1:gZr+CIYByUqjcgeLXnQu2gHYQC9o73G2XUeOFYEICuY= +github.com/go-openapi/jsonpointer v0.19.5/go.mod h1:Pl9vOtqEWErmShwVjC8pYs9cog34VGT37dQOVbmoatg= +github.com/go-openapi/jsonreference v0.19.6 h1:UBIxjkht+AWIgYzCDSv2GN+E/togfwXUJFRTWhl2Jjs= +github.com/go-openapi/jsonreference v0.19.6/go.mod h1:diGHMEHg2IqXZGKxqyvWdfWU/aim5Dprw5bqpKkTvns= +github.com/go-openapi/spec v0.20.4 h1:O8hJrt0UMnhHcluhIdUgCLRWyM2x7QkBXRvOs7m+O1M= +github.com/go-openapi/spec v0.20.4/go.mod h1:faYFR1CvsJZ0mNsmsphTMSoRrNV3TEDoAM7FOEWeq8I= +github.com/go-openapi/swag v0.19.5/go.mod h1:POnQmlKehdgb5mhVOsnJFsivZCEZ/vjK9gh66Z9tfKk= +github.com/go-openapi/swag v0.19.15 h1:D2NRCBzS9/pEY3gP9Nl8aDqGUcPFrwG2p+CNFrLyrCM= +github.com/go-openapi/swag v0.19.15/go.mod h1:QYRuS/SOXUCsnplDa677K7+DxSOj6IPNl/eQntq43wQ= +github.com/godbus/dbus/v5 v5.0.4/go.mod h1:xhWf0FNVPg57R7Z0UbKHbJfkEywrmjJnf7w5xrFpKfA= +github.com/gofiber/fiber/v2 v2.52.6 h1:Rfp+ILPiYSvvVuIPvxrBns+HJp8qGLDnLJawAu27XVI= +github.com/gofiber/fiber/v2 v2.52.6/go.mod h1:YEcBbO/FB+5M1IZNBP9FO3J9281zgPAreiI1oqg8nDw= +github.com/gofiber/swagger v1.1.1 h1:FZVhVQQ9s1ZKLHL/O0loLh49bYB5l1HEAgxDlcTtkRA= +github.com/gofiber/swagger v1.1.1/go.mod h1:vtvY/sQAMc/lGTUCg0lqmBL7Ht9O7uzChpbvJeJQINw= +github.com/golang-jwt/jwt/v5 v5.2.2 h1:Rl4B7itRWVtYIHFrSNd7vhTiz9UpLdi6gZhZ3wEeDy8= +github.com/golang-jwt/jwt/v5 v5.2.2/go.mod h1:pqrtFR0X4osieyHYxtmOUWsAWrfe1Q5UVIyoH402zdk= +github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0= +github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= +github.com/josharian/intern v1.0.0 h1:vlS4z54oSdjm0bgjRigI+G1HpF+tI+9rE5LLzOg8HmY= +github.com/josharian/intern v1.0.0/go.mod h1:5DoeVV0s6jJacbCEi61lwdGj/aVlrQvzHFFd8Hwg//Y= +github.com/klauspost/compress v1.17.9 h1:6KIumPrER1LHsvBVuDa0r5xaG0Es51mhhB9BQB2qeMA= +github.com/klauspost/compress v1.17.9/go.mod h1:Di0epgTjJY877eYKx5yC51cX2A2Vl2ibi7bDH9ttBbw= +github.com/klauspost/compress v1.17.11 h1:In6xLpyWOi1+C7tXUUWv2ot1QvBjxevKAaI6IXrJmUc= +github.com/klauspost/compress v1.17.11/go.mod h1:pMDklpSncoRMuLFrf1W9Ss9KT+0rH90U12bZKk7uwG0= +github.com/klauspost/cpuid/v2 v2.0.9 h1:lgaqFMSdTdQYdZ04uHyN2d/eKdOMyi2YLSvlQIBFYa4= +github.com/klauspost/cpuid/v2 v2.0.9/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg= +github.com/knz/go-libedit v1.10.1/go.mod h1:MZTVkCWyz0oBc7JOWP3wNAzd002ZbM/5hgShxwh4x8M= +github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo= +github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ= +github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI= +github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE= +github.com/lib/pq v1.10.9 h1:YXG7RB+JIjhP29X+OtkiDnYaXQwpS4JEWq7dtCCRUEw= +github.com/lib/pq v1.10.9/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o= +github.com/mailru/easyjson v0.0.0-20190614124828-94de47d64c63/go.mod h1:C1wdFJiN94OJF2b5HbByQZoLdCWB1Yqtg26g4irojpc= +github.com/mailru/easyjson v0.0.0-20190626092158-b2ccc519800e/go.mod h1:C1wdFJiN94OJF2b5HbByQZoLdCWB1Yqtg26g4irojpc= +github.com/mailru/easyjson v0.7.6 h1:8yTIVnZgCoiM1TgqoeTl+LfU5Jg6/xL3QhGQnimLYnA= +github.com/mailru/easyjson v0.7.6/go.mod h1:xzfreul335JAWq5oZzymOObrkdz5UnU4kGfJJLY9Nlc= +github.com/mattn/go-colorable v0.1.13 h1:fFA4WZxdEF4tXPZVKMLwD8oUnCTTo08duU7wxecdEvA= +github.com/mattn/go-colorable v0.1.13/go.mod h1:7S9/ev0klgBDR4GtXTXX8a3vIGJpMovkB8vQcUbaXHg= +github.com/mattn/go-isatty v0.0.16/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM= +github.com/mattn/go-isatty v0.0.19/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y= +github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY= +github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y= +github.com/mattn/go-runewidth v0.0.16 h1:E5ScNMtiwvlvB5paMFdw9p4kSQzbXFikJ5SQO6TULQc= +github.com/mattn/go-runewidth v0.0.16/go.mod h1:Jdepj2loyihRzMpdS35Xk/zdY8IAYHsh153qUoGf23w= +github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e/go.mod h1:zD1mROLANZcx1PVRCS0qkT7pwLkGfwJo4zjcN/Tysno= +github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0= +github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= +github.com/redis/go-redis/v9 v9.7.3 h1:YpPyAayJV+XErNsatSElgRZZVCwXX9QzkKYNvO7x0wM= +github.com/redis/go-redis/v9 v9.7.3/go.mod h1:bGUrSggJ9X9GUmZpZNEOQKaANxSGgOEBRltRTZHSvrA= +github.com/rivo/uniseg v0.2.0 h1:S1pD9weZBuJdFmowNwbpi7BJ8TNftyUImj/0WQi72jY= +github.com/rivo/uniseg v0.2.0/go.mod h1:J6wj4VEh+S6ZtnVlnTBMWIodfgj8LQOQFoIToxlJtxc= +github.com/rs/xid v1.6.0/go.mod h1:7XoLgs4eV+QndskICGsho+ADou8ySMSjJKDIan90Nz0= +github.com/rs/zerolog v1.34.0 h1:k43nTLIwcTVQAncfCw4KZ2VY6ukYoZaBPNOE8txlOeY= +github.com/rs/zerolog v1.34.0/go.mod h1:bJsvje4Z08ROH4Nhs5iH600c3IkWhwp44iRc54W6wYQ= +github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= +github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw= +github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo= +github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI= +github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= +github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= +github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= +github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU= +github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4= +github.com/swaggo/files/v2 v2.0.2 h1:Bq4tgS/yxLB/3nwOMcul5oLEUKa877Ykgz3CJMVbQKU= +github.com/swaggo/files/v2 v2.0.2/go.mod h1:TVqetIzZsO9OhHX1Am9sRf9LdrFZqoK49N37KON/jr0= +github.com/swaggo/swag v1.16.4 h1:clWJtd9LStiG3VeijiCfOVODP6VpHtKdQy9ELFG3s1A= +github.com/swaggo/swag v1.16.4/go.mod h1:VBsHJRsDvfYvqoiMKnsdwhNV9LEMHgEDZcyVYX0sxPg= +github.com/twitchyliquid64/golang-asm v0.15.1 h1:SU5vSMR7hnwNxj24w34ZyCi/FmDZTkS4MhqMhdFk5YI= +github.com/twitchyliquid64/golang-asm v0.15.1/go.mod h1:a1lVb/DtPvCB8fslRZhAngC2+aY1QWCk3Cedj/Gdt08= +github.com/twmb/franz-go v1.18.1 h1:D75xxCDyvTqBSiImFx2lkPduE39jz1vaD7+FNc+vMkc= +github.com/twmb/franz-go v1.18.1/go.mod h1:Uzo77TarcLTUZeLuGq+9lNpSkfZI+JErv7YJhlDjs9M= +github.com/valyala/bytebufferpool v1.0.0 h1:GqA5TC/0021Y/b9FG4Oi9Mr3q7XYx6KllzawFIhcdPw= +github.com/valyala/bytebufferpool v1.0.0/go.mod h1:6bBcMArwyJ5K/AmCkWv1jt77kVWyCJ6HpOuEn7z0Csc= +github.com/valyala/fasthttp v1.51.0 h1:8b30A5JlZ6C7AS81RsWjYMQmrZG6feChmgAolCl1SqA= +github.com/valyala/fasthttp v1.51.0/go.mod h1:oI2XroL+lI7vdXyYoQk03bXBThfFl2cVdIA3Xl7cH8g= +github.com/valyala/tcplisten v1.0.0 h1:rBHj/Xf+E1tRGZyWIWwJDiRY0zc1Js+CV5DqwacVSA8= +github.com/valyala/tcplisten v1.0.0/go.mod h1:T0xQ8SeCZGxckz9qRXTfG43PvQ/mcWh7FwZEA7Ioqkc= +golang.org/x/arch v0.0.0-20210923205945-b76863e36670 h1:18EFjUmQOcUvxNYSkA6jO9VAiXCnxFY6NyDX0bHDmkU= +golang.org/x/arch v0.0.0-20210923205945-b76863e36670/go.mod h1:5om86z9Hs0C8fWVUuoMHwpExlXzs5Tkyp9hOrfG7pp8= +golang.org/x/net v0.0.0-20210421230115-4e50805a0758/go.mod h1:72T/g9IO56b78aLF+1Kcs5dz7/ng1VjMUvfKvpfy+jM= +golang.org/x/net v0.34.0 h1:Mb7Mrk043xzHgnRM88suvJFwzVrRfHEHJEl5/71CKw0= +golang.org/x/net v0.34.0/go.mod h1:di0qlW3YNM5oh6GqDGQr92MyTozJPmybPK4Ev/Gm31k= +golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20210420072515-93ed5bcd2bfe/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.12.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.28.0 h1:Fksou7UEQUWlKvIdsqzJmUmCX3cZuD2+P3XyyzwMhlA= +golang.org/x/sys v0.28.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= +golang.org/x/sys v0.29.0 h1:TPYlXGxvx1MGTn2GiZDhnjPA9wZzZeGKHHmKhHYvgaU= +golang.org/x/sys v0.29.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= +golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= +golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= +golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ= +golang.org/x/text v0.21.0 h1:zyQAAkrwaneQ066sspRyJaG9VNi/YJ1NfzcGB3hZ/qo= +golang.org/x/text v0.21.0/go.mod h1:4IBbMaMmOPCJ8SecivzSH54+73PCFmPWxNTLm+vZkEQ= +golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= +golang.org/x/tools v0.21.1-0.20240508182429-e35e4ccd0d2d h1:vU5i/LfpvrRCpgM/VPfJLg5KjxD3E+hfT1SH+d9zLwg= +golang.org/x/tools v0.21.1-0.20240508182429-e35e4ccd0d2d/go.mod h1:aiJjzUbINMkxbQROHiO6hDPo2LHcIPhhQsa9DLh0yGk= +google.golang.org/genproto/googleapis/rpc v0.0.0-20250115164207-1a7da9e5054f h1:OxYkA3wjPsZyBylwymxSHa7ViiW1Sml4ToBrncvFehI= +google.golang.org/genproto/googleapis/rpc v0.0.0-20250115164207-1a7da9e5054f/go.mod h1:+2Yz8+CLJbIfL9z73EW45avw8Lmge3xVElCP9zEKi50= +google.golang.org/grpc v1.71.1 h1:ffsFWr7ygTUscGPI0KKK6TLrGz0476KUvvsbqWK0rPI= +google.golang.org/grpc v1.71.1/go.mod h1:H0GRtasmQOh9LkFoCPDu3ZrwUtD1YGE+b2vYBYd/8Ec= +google.golang.org/protobuf v1.36.4 h1:6A3ZDJHn/eNqc1i+IdefRzy/9PokBTPvcqMySR7NNIM= +google.golang.org/protobuf v1.36.4/go.mod h1:9fA7Ob0pmnwhb644+1+CVWFRbNajQ6iRojtC/QF5bRE= +gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= +gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= +gopkg.in/check.v1 v1.0.0-20200227125254-8fa46927fb4f/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= +gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= +gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY= +gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ= +gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= +gopkg.in/yaml.v3 v3.0.0-20200615113413-eeeca48fe776/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= +gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= +nullprogram.com/x/optparse v1.0.0/go.mod h1:KdyPE+Igbe0jQUrVfMqDMeJQIJZEuyV7pjYmp6pbG50= diff --git a/internal/config/config.go b/internal/config/config.go new file mode 100644 index 0000000..c5e0b68 --- /dev/null +++ b/internal/config/config.go @@ -0,0 +1,17 @@ +package config + +type Config struct { + DB string + HTTP string + GRPC string + Kafka string +} + +func Load() Config { + return Config{ + DB: "dbname=test password=GjitkYf[eq user=postgres sslmode=disable", + HTTP: ":8080", + GRPC: ":50051", + Kafka: "localhost:9092", + } +} diff --git a/internal/db/conn.go b/internal/db/conn.go new file mode 100644 index 0000000..6dc2112 --- /dev/null +++ b/internal/db/conn.go @@ -0,0 +1,17 @@ +package db + +import ( + "database/sql" + _ "github.com/lib/pq" +) + +func NewConnection(dsn string) (*sql.DB, error) { + db, err := sql.Open("postgres", dsn) + if err != nil { + return nil, err + } + if err := db.Ping(); err != nil { + return nil, err + } + return db, nil +} diff --git a/internal/db/schema.sql b/internal/db/schema.sql new file mode 100644 index 0000000..edb99cf --- /dev/null +++ b/internal/db/schema.sql @@ -0,0 +1,5 @@ +CREATE TABLE test +( + id SERIAL PRIMARY KEY, + data TEXT NOT NULL +); \ No newline at end of file diff --git a/internal/db/sqlc.yaml b/internal/db/sqlc.yaml new file mode 100644 index 0000000..f610c8b --- /dev/null +++ b/internal/db/sqlc.yaml @@ -0,0 +1,7 @@ +version: "1" +packages: + - name: "test" + path: "../test/db/generated" + queries: "../test/db/queries.sql" + schema: "./schema.sql" + engine: "postgresql" \ No newline at end of file diff --git a/internal/logger/logger.go b/internal/logger/logger.go new file mode 100644 index 0000000..90c66f6 --- /dev/null +++ b/internal/logger/logger.go @@ -0,0 +1 @@ +package logger diff --git a/internal/test/adapters/http.go b/internal/test/adapters/http.go new file mode 100644 index 0000000..5112623 --- /dev/null +++ b/internal/test/adapters/http.go @@ -0,0 +1,19 @@ +package adapters + +import "github.com/gofiber/fiber/v2" + +var ( + router *fiber.Router = nil +) + +func RegisterRouter(r *fiber.Router) { + router = r + if router == nil { + panic("router is nil") + } + (*router).Get("/test", test) +} + +func test(c *fiber.Ctx) error { + return c.SendString("test") +} diff --git a/internal/test/db/generated/db.go b/internal/test/db/generated/db.go new file mode 100644 index 0000000..4380e80 --- /dev/null +++ b/internal/test/db/generated/db.go @@ -0,0 +1,31 @@ +// Code generated by sqlc. DO NOT EDIT. +// versions: +// sqlc v1.28.0 + +package test + +import ( + "context" + "database/sql" +) + +type DBTX interface { + ExecContext(context.Context, string, ...interface{}) (sql.Result, error) + PrepareContext(context.Context, string) (*sql.Stmt, error) + QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error) + QueryRowContext(context.Context, string, ...interface{}) *sql.Row +} + +func New(db DBTX) *Queries { + return &Queries{db: db} +} + +type Queries struct { + db DBTX +} + +func (q *Queries) WithTx(tx *sql.Tx) *Queries { + return &Queries{ + db: tx, + } +} diff --git a/internal/test/db/generated/models.go b/internal/test/db/generated/models.go new file mode 100644 index 0000000..1273572 --- /dev/null +++ b/internal/test/db/generated/models.go @@ -0,0 +1,10 @@ +// Code generated by sqlc. DO NOT EDIT. +// versions: +// sqlc v1.28.0 + +package test + +type Test struct { + ID int32 + Data string +} diff --git a/internal/test/db/generated/queries.sql.go b/internal/test/db/generated/queries.sql.go new file mode 100644 index 0000000..5c9d38f --- /dev/null +++ b/internal/test/db/generated/queries.sql.go @@ -0,0 +1,55 @@ +// Code generated by sqlc. DO NOT EDIT. +// versions: +// sqlc v1.28.0 +// source: queries.sql + +package test + +import ( + "context" +) + +const createTest = `-- name: CreateTest :one +INSERT INTO test (data) VALUES ($1) RETURNING id +` + +func (q *Queries) CreateTest(ctx context.Context, data string) (int32, error) { + row := q.db.QueryRowContext(ctx, createTest, data) + var id int32 + err := row.Scan(&id) + return id, err +} + +const deleteTest = `-- name: DeleteTest :exec +DELETE FROM test WHERE id = $1 +` + +func (q *Queries) DeleteTest(ctx context.Context, id int32) error { + _, err := q.db.ExecContext(ctx, deleteTest, id) + return err +} + +const getTest = `-- name: GetTest :one +SELECT id, data FROM test WHERE id = $1 +` + +func (q *Queries) GetTest(ctx context.Context, id int32) (Test, error) { + row := q.db.QueryRowContext(ctx, getTest, id) + var i Test + err := row.Scan(&i.ID, &i.Data) + return i, err +} + +const updateTest = `-- name: UpdateTest :exec +UPDATE test SET data = $1 WHERE id = $2 +` + +type UpdateTestParams struct { + Data string + ID int32 +} + +func (q *Queries) UpdateTest(ctx context.Context, arg UpdateTestParams) error { + _, err := q.db.ExecContext(ctx, updateTest, arg.Data, arg.ID) + return err +} diff --git a/internal/test/db/queries.sql b/internal/test/db/queries.sql new file mode 100644 index 0000000..6897148 --- /dev/null +++ b/internal/test/db/queries.sql @@ -0,0 +1,11 @@ +-- name: CreateTest :one +INSERT INTO test (data) VALUES ($1) RETURNING id; + +-- name: GetTest :one +SELECT id, data FROM test WHERE id = $1; + +-- name: UpdateTest :exec +UPDATE test SET data = $1 WHERE id = $2; + +-- name: DeleteTest :exec +DELETE FROM test WHERE id = $1; \ No newline at end of file diff --git a/internal/test/repository.go b/internal/test/repository.go new file mode 100644 index 0000000..7dd791f --- /dev/null +++ b/internal/test/repository.go @@ -0,0 +1,42 @@ +package test + +import ( + generated "Sipro-Marketplaces/internal/test/db/generated" + "context" + "database/sql" +) + +type Repository interface { + Create(ctx context.Context, data string) (int32, error) + Get(ctx context.Context, id int32) (generated.Test, error) + Update(ctx context.Context, id int32, data string) error + Delete(ctx context.Context, id int32) error +} + +type repository struct { + db *sql.DB + queries *generated.Queries +} + +func NewRepository(db *sql.DB) Repository { + return &repository{ + db: db, + queries: generated.New(db), + } +} + +func (r *repository) Create(ctx context.Context, data string) (int32, error) { + return r.queries.CreateTest(ctx, data) +} + +func (r *repository) Get(ctx context.Context, id int32) (generated.Test, error) { + return r.queries.GetTest(ctx, id) +} + +func (r *repository) Update(ctx context.Context, id int32, data string) error { + return r.queries.UpdateTest(ctx, generated.UpdateTestParams{Data: data, ID: id}) +} + +func (r *repository) Delete(ctx context.Context, id int32) error { + return r.queries.DeleteTest(ctx, id) +} diff --git a/internal/test/service.go b/internal/test/service.go new file mode 100644 index 0000000..bd4a891 --- /dev/null +++ b/internal/test/service.go @@ -0,0 +1,37 @@ +package test + +import ( + generated "Sipro-Marketplaces/internal/test/db/generated" + "context" +) + +type Service interface { + Create(ctx context.Context, data string) (int32, error) + Get(ctx context.Context, id int32) (generated.Test, error) + Update(ctx context.Context, id int32, data string) error + Delete(ctx context.Context, id int32) error +} + +type service struct { + repo Repository +} + +func NewService(repo Repository) Service { + return &service{repo: repo} +} + +func (s *service) Create(ctx context.Context, data string) (int32, error) { + return s.repo.Create(ctx, data) +} + +func (s *service) Get(ctx context.Context, id int32) (generated.Test, error) { + return s.repo.Get(ctx, id) +} + +func (s *service) Update(ctx context.Context, id int32, data string) error { + return s.repo.Update(ctx, id, data) +} + +func (s *service) Delete(ctx context.Context, id int32) error { + return s.repo.Delete(ctx, id) +} diff --git a/pkg/utils/utils.go b/pkg/utils/utils.go new file mode 100644 index 0000000..d4b585b --- /dev/null +++ b/pkg/utils/utils.go @@ -0,0 +1 @@ +package utils diff --git a/pkgs b/pkgs new file mode 100644 index 0000000..446fbe7 --- /dev/null +++ b/pkgs @@ -0,0 +1,9 @@ +go get github.com/gofiber/fiber/v2 +go get github.com/twmb/franz-go +go get github.com/redis/go-redis/v9 +go get google.golang.org/grpc +go get github.com/lib/pq +go get github.com/rs/zerolog/log +go get github.com/bytedance/sonic +go get github.com/gofiber/swagger +go get github.com/golang-jwt/jwt/v5 \ No newline at end of file