From 4c98db2dfcf603839e8eb93825e4b38272276af7 Mon Sep 17 00:00:00 2001 From: "github-actions[bot]" Date: Mon, 30 Mar 2026 15:31:20 +0000 Subject: [PATCH] chore: auto-generate protobuf files [skip ci] --- gen/go/identity.pb.go | 1622 ++++++++++++++++++++++++++++++++++++ gen/go/identity_grpc.pb.go | 641 ++++++++++++++ gen/go/ldap.pb.go | 277 ++++++ gen/go/ldap_grpc.pb.go | 121 +++ gen/identity.ts | 4 +- gen/ldap.ts | 56 ++ 6 files changed, 2718 insertions(+), 3 deletions(-) create mode 100644 gen/go/identity.pb.go create mode 100644 gen/go/identity_grpc.pb.go create mode 100644 gen/go/ldap.pb.go create mode 100644 gen/go/ldap_grpc.pb.go create mode 100644 gen/ldap.ts diff --git a/gen/go/identity.pb.go b/gen/go/identity.pb.go new file mode 100644 index 0000000..4ef1bf7 --- /dev/null +++ b/gen/go/identity.pb.go @@ -0,0 +1,1622 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.36.11 +// protoc v3.21.12 +// source: identity.proto + +package gen + +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 LoginRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` + Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *LoginRequest) Reset() { + *x = LoginRequest{} + mi := &file_identity_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *LoginRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LoginRequest) ProtoMessage() {} + +func (x *LoginRequest) ProtoReflect() protoreflect.Message { + mi := &file_identity_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 LoginRequest.ProtoReflect.Descriptor instead. +func (*LoginRequest) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{0} +} + +func (x *LoginRequest) GetUsername() string { + if x != nil { + return x.Username + } + return "" +} + +func (x *LoginRequest) GetPassword() string { + if x != nil { + return x.Password + } + return "" +} + +type LoginResponse struct { + state protoimpl.MessageState `protogen:"open.v1"` + AccessToken string `protobuf:"bytes,1,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"` + RefreshToken string `protobuf:"bytes,2,opt,name=refresh_token,json=refreshToken,proto3" json:"refresh_token,omitempty"` + Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"` + Need2Fa bool `protobuf:"varint,4,opt,name=need2fa,proto3" json:"need2fa,omitempty"` + TempToken *string `protobuf:"bytes,5,opt,name=temp_token,json=tempToken,proto3,oneof" json:"temp_token,omitempty"` + Message *string `protobuf:"bytes,6,opt,name=message,proto3,oneof" json:"message,omitempty"` + ErrorCode *string `protobuf:"bytes,7,opt,name=error_code,json=errorCode,proto3,oneof" json:"error_code,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *LoginResponse) Reset() { + *x = LoginResponse{} + mi := &file_identity_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *LoginResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LoginResponse) ProtoMessage() {} + +func (x *LoginResponse) ProtoReflect() protoreflect.Message { + mi := &file_identity_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 LoginResponse.ProtoReflect.Descriptor instead. +func (*LoginResponse) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{1} +} + +func (x *LoginResponse) GetAccessToken() string { + if x != nil { + return x.AccessToken + } + return "" +} + +func (x *LoginResponse) GetRefreshToken() string { + if x != nil { + return x.RefreshToken + } + return "" +} + +func (x *LoginResponse) GetStatus() string { + if x != nil { + return x.Status + } + return "" +} + +func (x *LoginResponse) GetNeed2Fa() bool { + if x != nil { + return x.Need2Fa + } + return false +} + +func (x *LoginResponse) GetTempToken() string { + if x != nil && x.TempToken != nil { + return *x.TempToken + } + return "" +} + +func (x *LoginResponse) GetMessage() string { + if x != nil && x.Message != nil { + return *x.Message + } + return "" +} + +func (x *LoginResponse) GetErrorCode() string { + if x != nil && x.ErrorCode != nil { + return *x.ErrorCode + } + return "" +} + +type RefreshRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + RefreshToken string `protobuf:"bytes,1,opt,name=refresh_token,json=refreshToken,proto3" json:"refresh_token,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *RefreshRequest) Reset() { + *x = RefreshRequest{} + mi := &file_identity_proto_msgTypes[2] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *RefreshRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*RefreshRequest) ProtoMessage() {} + +func (x *RefreshRequest) ProtoReflect() protoreflect.Message { + mi := &file_identity_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 RefreshRequest.ProtoReflect.Descriptor instead. +func (*RefreshRequest) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{2} +} + +func (x *RefreshRequest) GetRefreshToken() string { + if x != nil { + return x.RefreshToken + } + return "" +} + +type RefreshResponse struct { + state protoimpl.MessageState `protogen:"open.v1"` + AccessToken string `protobuf:"bytes,1,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"` + RefreshToken string `protobuf:"bytes,2,opt,name=refresh_token,json=refreshToken,proto3" json:"refresh_token,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *RefreshResponse) Reset() { + *x = RefreshResponse{} + mi := &file_identity_proto_msgTypes[3] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *RefreshResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*RefreshResponse) ProtoMessage() {} + +func (x *RefreshResponse) ProtoReflect() protoreflect.Message { + mi := &file_identity_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 RefreshResponse.ProtoReflect.Descriptor instead. +func (*RefreshResponse) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{3} +} + +func (x *RefreshResponse) GetAccessToken() string { + if x != nil { + return x.AccessToken + } + return "" +} + +func (x *RefreshResponse) GetRefreshToken() string { + if x != nil { + return x.RefreshToken + } + return "" +} + +type LogoutRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + AccessToken string `protobuf:"bytes,1,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *LogoutRequest) Reset() { + *x = LogoutRequest{} + mi := &file_identity_proto_msgTypes[4] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *LogoutRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LogoutRequest) ProtoMessage() {} + +func (x *LogoutRequest) ProtoReflect() protoreflect.Message { + mi := &file_identity_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 LogoutRequest.ProtoReflect.Descriptor instead. +func (*LogoutRequest) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{4} +} + +func (x *LogoutRequest) GetAccessToken() string { + if x != nil { + return x.AccessToken + } + return "" +} + +type LogoutResponse struct { + state protoimpl.MessageState `protogen:"open.v1"` + Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` + Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *LogoutResponse) Reset() { + *x = LogoutResponse{} + mi := &file_identity_proto_msgTypes[5] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *LogoutResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*LogoutResponse) ProtoMessage() {} + +func (x *LogoutResponse) ProtoReflect() protoreflect.Message { + mi := &file_identity_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 LogoutResponse.ProtoReflect.Descriptor instead. +func (*LogoutResponse) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{5} +} + +func (x *LogoutResponse) GetSuccess() bool { + if x != nil { + return x.Success + } + return false +} + +func (x *LogoutResponse) GetMessage() string { + if x != nil { + return x.Message + } + return "" +} + +type UnlockPinRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + AccessToken string `protobuf:"bytes,1,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"` + PinCode string `protobuf:"bytes,2,opt,name=pin_code,json=pinCode,proto3" json:"pin_code,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *UnlockPinRequest) Reset() { + *x = UnlockPinRequest{} + mi := &file_identity_proto_msgTypes[6] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *UnlockPinRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*UnlockPinRequest) ProtoMessage() {} + +func (x *UnlockPinRequest) ProtoReflect() protoreflect.Message { + mi := &file_identity_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 UnlockPinRequest.ProtoReflect.Descriptor instead. +func (*UnlockPinRequest) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{6} +} + +func (x *UnlockPinRequest) GetAccessToken() string { + if x != nil { + return x.AccessToken + } + return "" +} + +func (x *UnlockPinRequest) GetPinCode() string { + if x != nil { + return x.PinCode + } + return "" +} + +type UnlockPinResponse struct { + state protoimpl.MessageState `protogen:"open.v1"` + Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` + Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *UnlockPinResponse) Reset() { + *x = UnlockPinResponse{} + mi := &file_identity_proto_msgTypes[7] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *UnlockPinResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*UnlockPinResponse) ProtoMessage() {} + +func (x *UnlockPinResponse) ProtoReflect() protoreflect.Message { + mi := &file_identity_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 UnlockPinResponse.ProtoReflect.Descriptor instead. +func (*UnlockPinResponse) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{7} +} + +func (x *UnlockPinResponse) GetSuccess() bool { + if x != nil { + return x.Success + } + return false +} + +func (x *UnlockPinResponse) GetMessage() string { + if x != nil { + return x.Message + } + return "" +} + +type Verify2FaRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + TempToken string `protobuf:"bytes,1,opt,name=temp_token,json=tempToken,proto3" json:"temp_token,omitempty"` + TotpCode *string `protobuf:"bytes,2,opt,name=totp_code,json=totpCode,proto3,oneof" json:"totp_code,omitempty"` + TelegramCode *string `protobuf:"bytes,3,opt,name=telegram_code,json=telegramCode,proto3,oneof" json:"telegram_code,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *Verify2FaRequest) Reset() { + *x = Verify2FaRequest{} + mi := &file_identity_proto_msgTypes[8] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *Verify2FaRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*Verify2FaRequest) ProtoMessage() {} + +func (x *Verify2FaRequest) ProtoReflect() protoreflect.Message { + mi := &file_identity_proto_msgTypes[8] + 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 Verify2FaRequest.ProtoReflect.Descriptor instead. +func (*Verify2FaRequest) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{8} +} + +func (x *Verify2FaRequest) GetTempToken() string { + if x != nil { + return x.TempToken + } + return "" +} + +func (x *Verify2FaRequest) GetTotpCode() string { + if x != nil && x.TotpCode != nil { + return *x.TotpCode + } + return "" +} + +func (x *Verify2FaRequest) GetTelegramCode() string { + if x != nil && x.TelegramCode != nil { + return *x.TelegramCode + } + return "" +} + +type Verify2FaResponse struct { + state protoimpl.MessageState `protogen:"open.v1"` + AccessToken string `protobuf:"bytes,1,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"` + RefreshToken string `protobuf:"bytes,2,opt,name=refresh_token,json=refreshToken,proto3" json:"refresh_token,omitempty"` + Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"` + Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"` + ReserveCodes []string `protobuf:"bytes,5,rep,name=reserve_codes,json=reserveCodes,proto3" json:"reserve_codes,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *Verify2FaResponse) Reset() { + *x = Verify2FaResponse{} + mi := &file_identity_proto_msgTypes[9] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *Verify2FaResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*Verify2FaResponse) ProtoMessage() {} + +func (x *Verify2FaResponse) ProtoReflect() protoreflect.Message { + mi := &file_identity_proto_msgTypes[9] + 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 Verify2FaResponse.ProtoReflect.Descriptor instead. +func (*Verify2FaResponse) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{9} +} + +func (x *Verify2FaResponse) GetAccessToken() string { + if x != nil { + return x.AccessToken + } + return "" +} + +func (x *Verify2FaResponse) GetRefreshToken() string { + if x != nil { + return x.RefreshToken + } + return "" +} + +func (x *Verify2FaResponse) GetStatus() string { + if x != nil { + return x.Status + } + return "" +} + +func (x *Verify2FaResponse) GetMessage() string { + if x != nil { + return x.Message + } + return "" +} + +func (x *Verify2FaResponse) GetReserveCodes() []string { + if x != nil { + return x.ReserveCodes + } + return nil +} + +type AuthenticatedAccessRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + AccessToken string `protobuf:"bytes,1,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *AuthenticatedAccessRequest) Reset() { + *x = AuthenticatedAccessRequest{} + mi := &file_identity_proto_msgTypes[10] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *AuthenticatedAccessRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*AuthenticatedAccessRequest) ProtoMessage() {} + +func (x *AuthenticatedAccessRequest) ProtoReflect() protoreflect.Message { + mi := &file_identity_proto_msgTypes[10] + 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 AuthenticatedAccessRequest.ProtoReflect.Descriptor instead. +func (*AuthenticatedAccessRequest) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{10} +} + +func (x *AuthenticatedAccessRequest) GetAccessToken() string { + if x != nil { + return x.AccessToken + } + return "" +} + +type GetTwoFaStatusRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + AccessToken string `protobuf:"bytes,1,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *GetTwoFaStatusRequest) Reset() { + *x = GetTwoFaStatusRequest{} + mi := &file_identity_proto_msgTypes[11] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *GetTwoFaStatusRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*GetTwoFaStatusRequest) ProtoMessage() {} + +func (x *GetTwoFaStatusRequest) ProtoReflect() protoreflect.Message { + mi := &file_identity_proto_msgTypes[11] + 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 GetTwoFaStatusRequest.ProtoReflect.Descriptor instead. +func (*GetTwoFaStatusRequest) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{11} +} + +func (x *GetTwoFaStatusRequest) GetAccessToken() string { + if x != nil { + return x.AccessToken + } + return "" +} + +type GetTwoFaStatusResponse struct { + state protoimpl.MessageState `protogen:"open.v1"` + TotpEnabled bool `protobuf:"varint,1,opt,name=totp_enabled,json=totpEnabled,proto3" json:"totp_enabled,omitempty"` + TelegramEnabled bool `protobuf:"varint,2,opt,name=telegram_enabled,json=telegramEnabled,proto3" json:"telegram_enabled,omitempty"` + TotpEnrollmentPending bool `protobuf:"varint,3,opt,name=totp_enrollment_pending,json=totpEnrollmentPending,proto3" json:"totp_enrollment_pending,omitempty"` + TelegramEnrollmentPending bool `protobuf:"varint,4,opt,name=telegram_enrollment_pending,json=telegramEnrollmentPending,proto3" json:"telegram_enrollment_pending,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *GetTwoFaStatusResponse) Reset() { + *x = GetTwoFaStatusResponse{} + mi := &file_identity_proto_msgTypes[12] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *GetTwoFaStatusResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*GetTwoFaStatusResponse) ProtoMessage() {} + +func (x *GetTwoFaStatusResponse) ProtoReflect() protoreflect.Message { + mi := &file_identity_proto_msgTypes[12] + 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 GetTwoFaStatusResponse.ProtoReflect.Descriptor instead. +func (*GetTwoFaStatusResponse) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{12} +} + +func (x *GetTwoFaStatusResponse) GetTotpEnabled() bool { + if x != nil { + return x.TotpEnabled + } + return false +} + +func (x *GetTwoFaStatusResponse) GetTelegramEnabled() bool { + if x != nil { + return x.TelegramEnabled + } + return false +} + +func (x *GetTwoFaStatusResponse) GetTotpEnrollmentPending() bool { + if x != nil { + return x.TotpEnrollmentPending + } + return false +} + +func (x *GetTwoFaStatusResponse) GetTelegramEnrollmentPending() bool { + if x != nil { + return x.TelegramEnrollmentPending + } + return false +} + +type StartTotpEnrollmentResponse struct { + state protoimpl.MessageState `protogen:"open.v1"` + SecretBase32 string `protobuf:"bytes,1,opt,name=secret_base32,json=secretBase32,proto3" json:"secret_base32,omitempty"` + OtpauthUri string `protobuf:"bytes,2,opt,name=otpauth_uri,json=otpauthUri,proto3" json:"otpauth_uri,omitempty"` + Issuer string `protobuf:"bytes,3,opt,name=issuer,proto3" json:"issuer,omitempty"` + AccountLabel string `protobuf:"bytes,4,opt,name=account_label,json=accountLabel,proto3" json:"account_label,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *StartTotpEnrollmentResponse) Reset() { + *x = StartTotpEnrollmentResponse{} + mi := &file_identity_proto_msgTypes[13] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *StartTotpEnrollmentResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*StartTotpEnrollmentResponse) ProtoMessage() {} + +func (x *StartTotpEnrollmentResponse) ProtoReflect() protoreflect.Message { + mi := &file_identity_proto_msgTypes[13] + 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 StartTotpEnrollmentResponse.ProtoReflect.Descriptor instead. +func (*StartTotpEnrollmentResponse) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{13} +} + +func (x *StartTotpEnrollmentResponse) GetSecretBase32() string { + if x != nil { + return x.SecretBase32 + } + return "" +} + +func (x *StartTotpEnrollmentResponse) GetOtpauthUri() string { + if x != nil { + return x.OtpauthUri + } + return "" +} + +func (x *StartTotpEnrollmentResponse) GetIssuer() string { + if x != nil { + return x.Issuer + } + return "" +} + +func (x *StartTotpEnrollmentResponse) GetAccountLabel() string { + if x != nil { + return x.AccountLabel + } + return "" +} + +type ConfirmTotpEnrollmentRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + AccessToken string `protobuf:"bytes,1,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"` + TotpCode string `protobuf:"bytes,2,opt,name=totp_code,json=totpCode,proto3" json:"totp_code,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *ConfirmTotpEnrollmentRequest) Reset() { + *x = ConfirmTotpEnrollmentRequest{} + mi := &file_identity_proto_msgTypes[14] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *ConfirmTotpEnrollmentRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*ConfirmTotpEnrollmentRequest) ProtoMessage() {} + +func (x *ConfirmTotpEnrollmentRequest) ProtoReflect() protoreflect.Message { + mi := &file_identity_proto_msgTypes[14] + 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 ConfirmTotpEnrollmentRequest.ProtoReflect.Descriptor instead. +func (*ConfirmTotpEnrollmentRequest) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{14} +} + +func (x *ConfirmTotpEnrollmentRequest) GetAccessToken() string { + if x != nil { + return x.AccessToken + } + return "" +} + +func (x *ConfirmTotpEnrollmentRequest) GetTotpCode() string { + if x != nil { + return x.TotpCode + } + return "" +} + +type ConfirmTotpEnrollmentResponse struct { + state protoimpl.MessageState `protogen:"open.v1"` + Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` + Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` + ReserveCodes []string `protobuf:"bytes,3,rep,name=reserve_codes,json=reserveCodes,proto3" json:"reserve_codes,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *ConfirmTotpEnrollmentResponse) Reset() { + *x = ConfirmTotpEnrollmentResponse{} + mi := &file_identity_proto_msgTypes[15] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *ConfirmTotpEnrollmentResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*ConfirmTotpEnrollmentResponse) ProtoMessage() {} + +func (x *ConfirmTotpEnrollmentResponse) ProtoReflect() protoreflect.Message { + mi := &file_identity_proto_msgTypes[15] + 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 ConfirmTotpEnrollmentResponse.ProtoReflect.Descriptor instead. +func (*ConfirmTotpEnrollmentResponse) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{15} +} + +func (x *ConfirmTotpEnrollmentResponse) GetStatus() string { + if x != nil { + return x.Status + } + return "" +} + +func (x *ConfirmTotpEnrollmentResponse) GetMessage() string { + if x != nil { + return x.Message + } + return "" +} + +func (x *ConfirmTotpEnrollmentResponse) GetReserveCodes() []string { + if x != nil { + return x.ReserveCodes + } + return nil +} + +type CancelTotpEnrollmentResponse struct { + state protoimpl.MessageState `protogen:"open.v1"` + Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` + Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *CancelTotpEnrollmentResponse) Reset() { + *x = CancelTotpEnrollmentResponse{} + mi := &file_identity_proto_msgTypes[16] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *CancelTotpEnrollmentResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*CancelTotpEnrollmentResponse) ProtoMessage() {} + +func (x *CancelTotpEnrollmentResponse) ProtoReflect() protoreflect.Message { + mi := &file_identity_proto_msgTypes[16] + 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 CancelTotpEnrollmentResponse.ProtoReflect.Descriptor instead. +func (*CancelTotpEnrollmentResponse) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{16} +} + +func (x *CancelTotpEnrollmentResponse) GetStatus() string { + if x != nil { + return x.Status + } + return "" +} + +func (x *CancelTotpEnrollmentResponse) GetMessage() string { + if x != nil { + return x.Message + } + return "" +} + +type DisableTotpRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + AccessToken string `protobuf:"bytes,1,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"` + Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"` + TotpCode *string `protobuf:"bytes,3,opt,name=totp_code,json=totpCode,proto3,oneof" json:"totp_code,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *DisableTotpRequest) Reset() { + *x = DisableTotpRequest{} + mi := &file_identity_proto_msgTypes[17] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *DisableTotpRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*DisableTotpRequest) ProtoMessage() {} + +func (x *DisableTotpRequest) ProtoReflect() protoreflect.Message { + mi := &file_identity_proto_msgTypes[17] + 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 DisableTotpRequest.ProtoReflect.Descriptor instead. +func (*DisableTotpRequest) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{17} +} + +func (x *DisableTotpRequest) GetAccessToken() string { + if x != nil { + return x.AccessToken + } + return "" +} + +func (x *DisableTotpRequest) GetPassword() string { + if x != nil { + return x.Password + } + return "" +} + +func (x *DisableTotpRequest) GetTotpCode() string { + if x != nil && x.TotpCode != nil { + return *x.TotpCode + } + return "" +} + +type DisableTotpResponse struct { + state protoimpl.MessageState `protogen:"open.v1"` + Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` + Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *DisableTotpResponse) Reset() { + *x = DisableTotpResponse{} + mi := &file_identity_proto_msgTypes[18] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *DisableTotpResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*DisableTotpResponse) ProtoMessage() {} + +func (x *DisableTotpResponse) ProtoReflect() protoreflect.Message { + mi := &file_identity_proto_msgTypes[18] + 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 DisableTotpResponse.ProtoReflect.Descriptor instead. +func (*DisableTotpResponse) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{18} +} + +func (x *DisableTotpResponse) GetStatus() string { + if x != nil { + return x.Status + } + return "" +} + +func (x *DisableTotpResponse) GetMessage() string { + if x != nil { + return x.Message + } + return "" +} + +type StartTelegramEnrollmentResponse struct { + state protoimpl.MessageState `protogen:"open.v1"` + EnrollmentToken string `protobuf:"bytes,1,opt,name=enrollment_token,json=enrollmentToken,proto3" json:"enrollment_token,omitempty"` + DeepLink string `protobuf:"bytes,2,opt,name=deep_link,json=deepLink,proto3" json:"deep_link,omitempty"` + BotUsername string `protobuf:"bytes,3,opt,name=bot_username,json=botUsername,proto3" json:"bot_username,omitempty"` + ExpiresAtIso string `protobuf:"bytes,4,opt,name=expires_at_iso,json=expiresAtIso,proto3" json:"expires_at_iso,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *StartTelegramEnrollmentResponse) Reset() { + *x = StartTelegramEnrollmentResponse{} + mi := &file_identity_proto_msgTypes[19] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *StartTelegramEnrollmentResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*StartTelegramEnrollmentResponse) ProtoMessage() {} + +func (x *StartTelegramEnrollmentResponse) ProtoReflect() protoreflect.Message { + mi := &file_identity_proto_msgTypes[19] + 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 StartTelegramEnrollmentResponse.ProtoReflect.Descriptor instead. +func (*StartTelegramEnrollmentResponse) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{19} +} + +func (x *StartTelegramEnrollmentResponse) GetEnrollmentToken() string { + if x != nil { + return x.EnrollmentToken + } + return "" +} + +func (x *StartTelegramEnrollmentResponse) GetDeepLink() string { + if x != nil { + return x.DeepLink + } + return "" +} + +func (x *StartTelegramEnrollmentResponse) GetBotUsername() string { + if x != nil { + return x.BotUsername + } + return "" +} + +func (x *StartTelegramEnrollmentResponse) GetExpiresAtIso() string { + if x != nil { + return x.ExpiresAtIso + } + return "" +} + +type ConfirmTelegramEnrollmentRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + AccessToken string `protobuf:"bytes,1,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"` + EnrollmentToken string `protobuf:"bytes,2,opt,name=enrollment_token,json=enrollmentToken,proto3" json:"enrollment_token,omitempty"` + OtpCode string `protobuf:"bytes,3,opt,name=otp_code,json=otpCode,proto3" json:"otp_code,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *ConfirmTelegramEnrollmentRequest) Reset() { + *x = ConfirmTelegramEnrollmentRequest{} + mi := &file_identity_proto_msgTypes[20] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *ConfirmTelegramEnrollmentRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*ConfirmTelegramEnrollmentRequest) ProtoMessage() {} + +func (x *ConfirmTelegramEnrollmentRequest) ProtoReflect() protoreflect.Message { + mi := &file_identity_proto_msgTypes[20] + 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 ConfirmTelegramEnrollmentRequest.ProtoReflect.Descriptor instead. +func (*ConfirmTelegramEnrollmentRequest) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{20} +} + +func (x *ConfirmTelegramEnrollmentRequest) GetAccessToken() string { + if x != nil { + return x.AccessToken + } + return "" +} + +func (x *ConfirmTelegramEnrollmentRequest) GetEnrollmentToken() string { + if x != nil { + return x.EnrollmentToken + } + return "" +} + +func (x *ConfirmTelegramEnrollmentRequest) GetOtpCode() string { + if x != nil { + return x.OtpCode + } + return "" +} + +type ConfirmTelegramEnrollmentResponse struct { + state protoimpl.MessageState `protogen:"open.v1"` + Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` + Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` + ReserveCodes []string `protobuf:"bytes,3,rep,name=reserve_codes,json=reserveCodes,proto3" json:"reserve_codes,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *ConfirmTelegramEnrollmentResponse) Reset() { + *x = ConfirmTelegramEnrollmentResponse{} + mi := &file_identity_proto_msgTypes[21] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *ConfirmTelegramEnrollmentResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*ConfirmTelegramEnrollmentResponse) ProtoMessage() {} + +func (x *ConfirmTelegramEnrollmentResponse) ProtoReflect() protoreflect.Message { + mi := &file_identity_proto_msgTypes[21] + 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 ConfirmTelegramEnrollmentResponse.ProtoReflect.Descriptor instead. +func (*ConfirmTelegramEnrollmentResponse) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{21} +} + +func (x *ConfirmTelegramEnrollmentResponse) GetStatus() string { + if x != nil { + return x.Status + } + return "" +} + +func (x *ConfirmTelegramEnrollmentResponse) GetMessage() string { + if x != nil { + return x.Message + } + return "" +} + +func (x *ConfirmTelegramEnrollmentResponse) GetReserveCodes() []string { + if x != nil { + return x.ReserveCodes + } + return nil +} + +type DisableTelegramRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + AccessToken string `protobuf:"bytes,1,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"` + Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"` + TelegramOtpCode *string `protobuf:"bytes,3,opt,name=telegram_otp_code,json=telegramOtpCode,proto3,oneof" json:"telegram_otp_code,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *DisableTelegramRequest) Reset() { + *x = DisableTelegramRequest{} + mi := &file_identity_proto_msgTypes[22] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *DisableTelegramRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*DisableTelegramRequest) ProtoMessage() {} + +func (x *DisableTelegramRequest) ProtoReflect() protoreflect.Message { + mi := &file_identity_proto_msgTypes[22] + 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 DisableTelegramRequest.ProtoReflect.Descriptor instead. +func (*DisableTelegramRequest) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{22} +} + +func (x *DisableTelegramRequest) GetAccessToken() string { + if x != nil { + return x.AccessToken + } + return "" +} + +func (x *DisableTelegramRequest) GetPassword() string { + if x != nil { + return x.Password + } + return "" +} + +func (x *DisableTelegramRequest) GetTelegramOtpCode() string { + if x != nil && x.TelegramOtpCode != nil { + return *x.TelegramOtpCode + } + return "" +} + +type DisableTelegramResponse struct { + state protoimpl.MessageState `protogen:"open.v1"` + Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` + Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *DisableTelegramResponse) Reset() { + *x = DisableTelegramResponse{} + mi := &file_identity_proto_msgTypes[23] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *DisableTelegramResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*DisableTelegramResponse) ProtoMessage() {} + +func (x *DisableTelegramResponse) ProtoReflect() protoreflect.Message { + mi := &file_identity_proto_msgTypes[23] + 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 DisableTelegramResponse.ProtoReflect.Descriptor instead. +func (*DisableTelegramResponse) Descriptor() ([]byte, []int) { + return file_identity_proto_rawDescGZIP(), []int{23} +} + +func (x *DisableTelegramResponse) GetStatus() string { + if x != nil { + return x.Status + } + return "" +} + +func (x *DisableTelegramResponse) GetMessage() string { + if x != nil { + return x.Message + } + return "" +} + +var File_identity_proto protoreflect.FileDescriptor + +const file_identity_proto_rawDesc = "" + + "\n" + + "\x0eidentity.proto\x12\bidentity\"F\n" + + "\fLoginRequest\x12\x1a\n" + + "\busername\x18\x01 \x01(\tR\busername\x12\x1a\n" + + "\bpassword\x18\x02 \x01(\tR\bpassword\"\x9a\x02\n" + + "\rLoginResponse\x12!\n" + + "\faccess_token\x18\x01 \x01(\tR\vaccessToken\x12#\n" + + "\rrefresh_token\x18\x02 \x01(\tR\frefreshToken\x12\x16\n" + + "\x06status\x18\x03 \x01(\tR\x06status\x12\x18\n" + + "\aneed2fa\x18\x04 \x01(\bR\aneed2fa\x12\"\n" + + "\n" + + "temp_token\x18\x05 \x01(\tH\x00R\ttempToken\x88\x01\x01\x12\x1d\n" + + "\amessage\x18\x06 \x01(\tH\x01R\amessage\x88\x01\x01\x12\"\n" + + "\n" + + "error_code\x18\a \x01(\tH\x02R\terrorCode\x88\x01\x01B\r\n" + + "\v_temp_tokenB\n" + + "\n" + + "\b_messageB\r\n" + + "\v_error_code\"5\n" + + "\x0eRefreshRequest\x12#\n" + + "\rrefresh_token\x18\x01 \x01(\tR\frefreshToken\"Y\n" + + "\x0fRefreshResponse\x12!\n" + + "\faccess_token\x18\x01 \x01(\tR\vaccessToken\x12#\n" + + "\rrefresh_token\x18\x02 \x01(\tR\frefreshToken\"2\n" + + "\rLogoutRequest\x12!\n" + + "\faccess_token\x18\x01 \x01(\tR\vaccessToken\"D\n" + + "\x0eLogoutResponse\x12\x18\n" + + "\asuccess\x18\x01 \x01(\bR\asuccess\x12\x18\n" + + "\amessage\x18\x02 \x01(\tR\amessage\"P\n" + + "\x10UnlockPinRequest\x12!\n" + + "\faccess_token\x18\x01 \x01(\tR\vaccessToken\x12\x19\n" + + "\bpin_code\x18\x02 \x01(\tR\apinCode\"G\n" + + "\x11UnlockPinResponse\x12\x18\n" + + "\asuccess\x18\x01 \x01(\bR\asuccess\x12\x18\n" + + "\amessage\x18\x02 \x01(\tR\amessage\"\x9d\x01\n" + + "\x10Verify2FaRequest\x12\x1d\n" + + "\n" + + "temp_token\x18\x01 \x01(\tR\ttempToken\x12 \n" + + "\ttotp_code\x18\x02 \x01(\tH\x00R\btotpCode\x88\x01\x01\x12(\n" + + "\rtelegram_code\x18\x03 \x01(\tH\x01R\ftelegramCode\x88\x01\x01B\f\n" + + "\n" + + "_totp_codeB\x10\n" + + "\x0e_telegram_code\"\xb2\x01\n" + + "\x11Verify2FaResponse\x12!\n" + + "\faccess_token\x18\x01 \x01(\tR\vaccessToken\x12#\n" + + "\rrefresh_token\x18\x02 \x01(\tR\frefreshToken\x12\x16\n" + + "\x06status\x18\x03 \x01(\tR\x06status\x12\x18\n" + + "\amessage\x18\x04 \x01(\tR\amessage\x12#\n" + + "\rreserve_codes\x18\x05 \x03(\tR\freserveCodes\"?\n" + + "\x1aAuthenticatedAccessRequest\x12!\n" + + "\faccess_token\x18\x01 \x01(\tR\vaccessToken\":\n" + + "\x15GetTwoFaStatusRequest\x12!\n" + + "\faccess_token\x18\x01 \x01(\tR\vaccessToken\"\xde\x01\n" + + "\x16GetTwoFaStatusResponse\x12!\n" + + "\ftotp_enabled\x18\x01 \x01(\bR\vtotpEnabled\x12)\n" + + "\x10telegram_enabled\x18\x02 \x01(\bR\x0ftelegramEnabled\x126\n" + + "\x17totp_enrollment_pending\x18\x03 \x01(\bR\x15totpEnrollmentPending\x12>\n" + + "\x1btelegram_enrollment_pending\x18\x04 \x01(\bR\x19telegramEnrollmentPending\"\xa0\x01\n" + + "\x1bStartTotpEnrollmentResponse\x12#\n" + + "\rsecret_base32\x18\x01 \x01(\tR\fsecretBase32\x12\x1f\n" + + "\votpauth_uri\x18\x02 \x01(\tR\n" + + "otpauthUri\x12\x16\n" + + "\x06issuer\x18\x03 \x01(\tR\x06issuer\x12#\n" + + "\raccount_label\x18\x04 \x01(\tR\faccountLabel\"^\n" + + "\x1cConfirmTotpEnrollmentRequest\x12!\n" + + "\faccess_token\x18\x01 \x01(\tR\vaccessToken\x12\x1b\n" + + "\ttotp_code\x18\x02 \x01(\tR\btotpCode\"v\n" + + "\x1dConfirmTotpEnrollmentResponse\x12\x16\n" + + "\x06status\x18\x01 \x01(\tR\x06status\x12\x18\n" + + "\amessage\x18\x02 \x01(\tR\amessage\x12#\n" + + "\rreserve_codes\x18\x03 \x03(\tR\freserveCodes\"P\n" + + "\x1cCancelTotpEnrollmentResponse\x12\x16\n" + + "\x06status\x18\x01 \x01(\tR\x06status\x12\x18\n" + + "\amessage\x18\x02 \x01(\tR\amessage\"\x83\x01\n" + + "\x12DisableTotpRequest\x12!\n" + + "\faccess_token\x18\x01 \x01(\tR\vaccessToken\x12\x1a\n" + + "\bpassword\x18\x02 \x01(\tR\bpassword\x12 \n" + + "\ttotp_code\x18\x03 \x01(\tH\x00R\btotpCode\x88\x01\x01B\f\n" + + "\n" + + "_totp_code\"G\n" + + "\x13DisableTotpResponse\x12\x16\n" + + "\x06status\x18\x01 \x01(\tR\x06status\x12\x18\n" + + "\amessage\x18\x02 \x01(\tR\amessage\"\xb2\x01\n" + + "\x1fStartTelegramEnrollmentResponse\x12)\n" + + "\x10enrollment_token\x18\x01 \x01(\tR\x0fenrollmentToken\x12\x1b\n" + + "\tdeep_link\x18\x02 \x01(\tR\bdeepLink\x12!\n" + + "\fbot_username\x18\x03 \x01(\tR\vbotUsername\x12$\n" + + "\x0eexpires_at_iso\x18\x04 \x01(\tR\fexpiresAtIso\"\x8b\x01\n" + + " ConfirmTelegramEnrollmentRequest\x12!\n" + + "\faccess_token\x18\x01 \x01(\tR\vaccessToken\x12)\n" + + "\x10enrollment_token\x18\x02 \x01(\tR\x0fenrollmentToken\x12\x19\n" + + "\botp_code\x18\x03 \x01(\tR\aotpCode\"z\n" + + "!ConfirmTelegramEnrollmentResponse\x12\x16\n" + + "\x06status\x18\x01 \x01(\tR\x06status\x12\x18\n" + + "\amessage\x18\x02 \x01(\tR\amessage\x12#\n" + + "\rreserve_codes\x18\x03 \x03(\tR\freserveCodes\"\x9e\x01\n" + + "\x16DisableTelegramRequest\x12!\n" + + "\faccess_token\x18\x01 \x01(\tR\vaccessToken\x12\x1a\n" + + "\bpassword\x18\x02 \x01(\tR\bpassword\x12/\n" + + "\x11telegram_otp_code\x18\x03 \x01(\tH\x00R\x0ftelegramOtpCode\x88\x01\x01B\x14\n" + + "\x12_telegram_otp_code\"K\n" + + "\x17DisableTelegramResponse\x12\x16\n" + + "\x06status\x18\x01 \x01(\tR\x06status\x12\x18\n" + + "\amessage\x18\x02 \x01(\tR\amessage2\xd0\x02\n" + + "\vAuthService\x128\n" + + "\x05Login\x12\x16.identity.LoginRequest\x1a\x17.identity.LoginResponse\x12>\n" + + "\aRefresh\x12\x18.identity.RefreshRequest\x1a\x19.identity.RefreshResponse\x12;\n" + + "\x06Logout\x12\x17.identity.LogoutRequest\x1a\x18.identity.LogoutResponse\x12D\n" + + "\tUnlockPin\x12\x1a.identity.UnlockPinRequest\x1a\x1b.identity.UnlockPinResponse\x12D\n" + + "\tVerify2Fa\x12\x1a.identity.Verify2FaRequest\x1a\x1b.identity.Verify2FaResponse2\x9c\x06\n" + + "\fTwoFaService\x12S\n" + + "\x0eGetTwoFaStatus\x12\x1f.identity.GetTwoFaStatusRequest\x1a .identity.GetTwoFaStatusResponse\x12b\n" + + "\x13StartTotpEnrollment\x12$.identity.AuthenticatedAccessRequest\x1a%.identity.StartTotpEnrollmentResponse\x12g\n" + + "\x14ConfirmTotpErollment\x12&.identity.ConfirmTotpEnrollmentRequest\x1a'.identity.ConfirmTotpEnrollmentResponse\x12d\n" + + "\x14CancelTotpEnrollment\x12$.identity.AuthenticatedAccessRequest\x1a&.identity.CancelTotpEnrollmentResponse\x12J\n" + + "\vDisableTotp\x12\x1c.identity.DisableTotpRequest\x1a\x1d.identity.DisableTotpResponse\x12j\n" + + "\x17StartTelegramEnrollment\x12$.identity.AuthenticatedAccessRequest\x1a).identity.StartTelegramEnrollmentResponse\x12t\n" + + "\x19ConfirmTelegramEnrollment\x12*.identity.ConfirmTelegramEnrollmentRequest\x1a+.identity.ConfirmTelegramEnrollmentResponse\x12V\n" + + "\x0fDisableTelegram\x12 .identity.DisableTelegramRequest\x1a!.identity.DisableTelegramResponseB\aZ\x05./genb\x06proto3" + +var ( + file_identity_proto_rawDescOnce sync.Once + file_identity_proto_rawDescData []byte +) + +func file_identity_proto_rawDescGZIP() []byte { + file_identity_proto_rawDescOnce.Do(func() { + file_identity_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_identity_proto_rawDesc), len(file_identity_proto_rawDesc))) + }) + return file_identity_proto_rawDescData +} + +var file_identity_proto_msgTypes = make([]protoimpl.MessageInfo, 24) +var file_identity_proto_goTypes = []any{ + (*LoginRequest)(nil), // 0: identity.LoginRequest + (*LoginResponse)(nil), // 1: identity.LoginResponse + (*RefreshRequest)(nil), // 2: identity.RefreshRequest + (*RefreshResponse)(nil), // 3: identity.RefreshResponse + (*LogoutRequest)(nil), // 4: identity.LogoutRequest + (*LogoutResponse)(nil), // 5: identity.LogoutResponse + (*UnlockPinRequest)(nil), // 6: identity.UnlockPinRequest + (*UnlockPinResponse)(nil), // 7: identity.UnlockPinResponse + (*Verify2FaRequest)(nil), // 8: identity.Verify2FaRequest + (*Verify2FaResponse)(nil), // 9: identity.Verify2FaResponse + (*AuthenticatedAccessRequest)(nil), // 10: identity.AuthenticatedAccessRequest + (*GetTwoFaStatusRequest)(nil), // 11: identity.GetTwoFaStatusRequest + (*GetTwoFaStatusResponse)(nil), // 12: identity.GetTwoFaStatusResponse + (*StartTotpEnrollmentResponse)(nil), // 13: identity.StartTotpEnrollmentResponse + (*ConfirmTotpEnrollmentRequest)(nil), // 14: identity.ConfirmTotpEnrollmentRequest + (*ConfirmTotpEnrollmentResponse)(nil), // 15: identity.ConfirmTotpEnrollmentResponse + (*CancelTotpEnrollmentResponse)(nil), // 16: identity.CancelTotpEnrollmentResponse + (*DisableTotpRequest)(nil), // 17: identity.DisableTotpRequest + (*DisableTotpResponse)(nil), // 18: identity.DisableTotpResponse + (*StartTelegramEnrollmentResponse)(nil), // 19: identity.StartTelegramEnrollmentResponse + (*ConfirmTelegramEnrollmentRequest)(nil), // 20: identity.ConfirmTelegramEnrollmentRequest + (*ConfirmTelegramEnrollmentResponse)(nil), // 21: identity.ConfirmTelegramEnrollmentResponse + (*DisableTelegramRequest)(nil), // 22: identity.DisableTelegramRequest + (*DisableTelegramResponse)(nil), // 23: identity.DisableTelegramResponse +} +var file_identity_proto_depIdxs = []int32{ + 0, // 0: identity.AuthService.Login:input_type -> identity.LoginRequest + 2, // 1: identity.AuthService.Refresh:input_type -> identity.RefreshRequest + 4, // 2: identity.AuthService.Logout:input_type -> identity.LogoutRequest + 6, // 3: identity.AuthService.UnlockPin:input_type -> identity.UnlockPinRequest + 8, // 4: identity.AuthService.Verify2Fa:input_type -> identity.Verify2FaRequest + 11, // 5: identity.TwoFaService.GetTwoFaStatus:input_type -> identity.GetTwoFaStatusRequest + 10, // 6: identity.TwoFaService.StartTotpEnrollment:input_type -> identity.AuthenticatedAccessRequest + 14, // 7: identity.TwoFaService.ConfirmTotpErollment:input_type -> identity.ConfirmTotpEnrollmentRequest + 10, // 8: identity.TwoFaService.CancelTotpEnrollment:input_type -> identity.AuthenticatedAccessRequest + 17, // 9: identity.TwoFaService.DisableTotp:input_type -> identity.DisableTotpRequest + 10, // 10: identity.TwoFaService.StartTelegramEnrollment:input_type -> identity.AuthenticatedAccessRequest + 20, // 11: identity.TwoFaService.ConfirmTelegramEnrollment:input_type -> identity.ConfirmTelegramEnrollmentRequest + 22, // 12: identity.TwoFaService.DisableTelegram:input_type -> identity.DisableTelegramRequest + 1, // 13: identity.AuthService.Login:output_type -> identity.LoginResponse + 3, // 14: identity.AuthService.Refresh:output_type -> identity.RefreshResponse + 5, // 15: identity.AuthService.Logout:output_type -> identity.LogoutResponse + 7, // 16: identity.AuthService.UnlockPin:output_type -> identity.UnlockPinResponse + 9, // 17: identity.AuthService.Verify2Fa:output_type -> identity.Verify2FaResponse + 12, // 18: identity.TwoFaService.GetTwoFaStatus:output_type -> identity.GetTwoFaStatusResponse + 13, // 19: identity.TwoFaService.StartTotpEnrollment:output_type -> identity.StartTotpEnrollmentResponse + 15, // 20: identity.TwoFaService.ConfirmTotpErollment:output_type -> identity.ConfirmTotpEnrollmentResponse + 16, // 21: identity.TwoFaService.CancelTotpEnrollment:output_type -> identity.CancelTotpEnrollmentResponse + 18, // 22: identity.TwoFaService.DisableTotp:output_type -> identity.DisableTotpResponse + 19, // 23: identity.TwoFaService.StartTelegramEnrollment:output_type -> identity.StartTelegramEnrollmentResponse + 21, // 24: identity.TwoFaService.ConfirmTelegramEnrollment:output_type -> identity.ConfirmTelegramEnrollmentResponse + 23, // 25: identity.TwoFaService.DisableTelegram:output_type -> identity.DisableTelegramResponse + 13, // [13:26] is the sub-list for method output_type + 0, // [0:13] 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_identity_proto_init() } +func file_identity_proto_init() { + if File_identity_proto != nil { + return + } + file_identity_proto_msgTypes[1].OneofWrappers = []any{} + file_identity_proto_msgTypes[8].OneofWrappers = []any{} + file_identity_proto_msgTypes[17].OneofWrappers = []any{} + file_identity_proto_msgTypes[22].OneofWrappers = []any{} + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: unsafe.Slice(unsafe.StringData(file_identity_proto_rawDesc), len(file_identity_proto_rawDesc)), + NumEnums: 0, + NumMessages: 24, + NumExtensions: 0, + NumServices: 2, + }, + GoTypes: file_identity_proto_goTypes, + DependencyIndexes: file_identity_proto_depIdxs, + MessageInfos: file_identity_proto_msgTypes, + }.Build() + File_identity_proto = out.File + file_identity_proto_goTypes = nil + file_identity_proto_depIdxs = nil +} diff --git a/gen/go/identity_grpc.pb.go b/gen/go/identity_grpc.pb.go new file mode 100644 index 0000000..da94db5 --- /dev/null +++ b/gen/go/identity_grpc.pb.go @@ -0,0 +1,641 @@ +// Code generated by protoc-gen-go-grpc. DO NOT EDIT. +// versions: +// - protoc-gen-go-grpc v1.6.1 +// - protoc v3.21.12 +// source: identity.proto + +package gen + +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 ( + AuthService_Login_FullMethodName = "/identity.AuthService/Login" + AuthService_Refresh_FullMethodName = "/identity.AuthService/Refresh" + AuthService_Logout_FullMethodName = "/identity.AuthService/Logout" + AuthService_UnlockPin_FullMethodName = "/identity.AuthService/UnlockPin" + AuthService_Verify2Fa_FullMethodName = "/identity.AuthService/Verify2Fa" +) + +// AuthServiceClient is the client API for AuthService 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 AuthServiceClient interface { + Login(ctx context.Context, in *LoginRequest, opts ...grpc.CallOption) (*LoginResponse, error) + Refresh(ctx context.Context, in *RefreshRequest, opts ...grpc.CallOption) (*RefreshResponse, error) + Logout(ctx context.Context, in *LogoutRequest, opts ...grpc.CallOption) (*LogoutResponse, error) + UnlockPin(ctx context.Context, in *UnlockPinRequest, opts ...grpc.CallOption) (*UnlockPinResponse, error) + Verify2Fa(ctx context.Context, in *Verify2FaRequest, opts ...grpc.CallOption) (*Verify2FaResponse, error) +} + +type authServiceClient struct { + cc grpc.ClientConnInterface +} + +func NewAuthServiceClient(cc grpc.ClientConnInterface) AuthServiceClient { + return &authServiceClient{cc} +} + +func (c *authServiceClient) Login(ctx context.Context, in *LoginRequest, opts ...grpc.CallOption) (*LoginResponse, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(LoginResponse) + err := c.cc.Invoke(ctx, AuthService_Login_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *authServiceClient) Refresh(ctx context.Context, in *RefreshRequest, opts ...grpc.CallOption) (*RefreshResponse, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(RefreshResponse) + err := c.cc.Invoke(ctx, AuthService_Refresh_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *authServiceClient) Logout(ctx context.Context, in *LogoutRequest, opts ...grpc.CallOption) (*LogoutResponse, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(LogoutResponse) + err := c.cc.Invoke(ctx, AuthService_Logout_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *authServiceClient) UnlockPin(ctx context.Context, in *UnlockPinRequest, opts ...grpc.CallOption) (*UnlockPinResponse, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(UnlockPinResponse) + err := c.cc.Invoke(ctx, AuthService_UnlockPin_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *authServiceClient) Verify2Fa(ctx context.Context, in *Verify2FaRequest, opts ...grpc.CallOption) (*Verify2FaResponse, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(Verify2FaResponse) + err := c.cc.Invoke(ctx, AuthService_Verify2Fa_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +// AuthServiceServer is the server API for AuthService service. +// All implementations must embed UnimplementedAuthServiceServer +// for forward compatibility. +type AuthServiceServer interface { + Login(context.Context, *LoginRequest) (*LoginResponse, error) + Refresh(context.Context, *RefreshRequest) (*RefreshResponse, error) + Logout(context.Context, *LogoutRequest) (*LogoutResponse, error) + UnlockPin(context.Context, *UnlockPinRequest) (*UnlockPinResponse, error) + Verify2Fa(context.Context, *Verify2FaRequest) (*Verify2FaResponse, error) + mustEmbedUnimplementedAuthServiceServer() +} + +// UnimplementedAuthServiceServer 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 UnimplementedAuthServiceServer struct{} + +func (UnimplementedAuthServiceServer) Login(context.Context, *LoginRequest) (*LoginResponse, error) { + return nil, status.Error(codes.Unimplemented, "method Login not implemented") +} +func (UnimplementedAuthServiceServer) Refresh(context.Context, *RefreshRequest) (*RefreshResponse, error) { + return nil, status.Error(codes.Unimplemented, "method Refresh not implemented") +} +func (UnimplementedAuthServiceServer) Logout(context.Context, *LogoutRequest) (*LogoutResponse, error) { + return nil, status.Error(codes.Unimplemented, "method Logout not implemented") +} +func (UnimplementedAuthServiceServer) UnlockPin(context.Context, *UnlockPinRequest) (*UnlockPinResponse, error) { + return nil, status.Error(codes.Unimplemented, "method UnlockPin not implemented") +} +func (UnimplementedAuthServiceServer) Verify2Fa(context.Context, *Verify2FaRequest) (*Verify2FaResponse, error) { + return nil, status.Error(codes.Unimplemented, "method Verify2Fa not implemented") +} +func (UnimplementedAuthServiceServer) mustEmbedUnimplementedAuthServiceServer() {} +func (UnimplementedAuthServiceServer) testEmbeddedByValue() {} + +// UnsafeAuthServiceServer may be embedded to opt out of forward compatibility for this service. +// Use of this interface is not recommended, as added methods to AuthServiceServer will +// result in compilation errors. +type UnsafeAuthServiceServer interface { + mustEmbedUnimplementedAuthServiceServer() +} + +func RegisterAuthServiceServer(s grpc.ServiceRegistrar, srv AuthServiceServer) { + // If the following call panics, it indicates UnimplementedAuthServiceServer 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(&AuthService_ServiceDesc, srv) +} + +func _AuthService_Login_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(LoginRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(AuthServiceServer).Login(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: AuthService_Login_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(AuthServiceServer).Login(ctx, req.(*LoginRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _AuthService_Refresh_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(RefreshRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(AuthServiceServer).Refresh(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: AuthService_Refresh_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(AuthServiceServer).Refresh(ctx, req.(*RefreshRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _AuthService_Logout_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(LogoutRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(AuthServiceServer).Logout(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: AuthService_Logout_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(AuthServiceServer).Logout(ctx, req.(*LogoutRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _AuthService_UnlockPin_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(UnlockPinRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(AuthServiceServer).UnlockPin(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: AuthService_UnlockPin_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(AuthServiceServer).UnlockPin(ctx, req.(*UnlockPinRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _AuthService_Verify2Fa_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(Verify2FaRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(AuthServiceServer).Verify2Fa(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: AuthService_Verify2Fa_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(AuthServiceServer).Verify2Fa(ctx, req.(*Verify2FaRequest)) + } + return interceptor(ctx, in, info, handler) +} + +// AuthService_ServiceDesc is the grpc.ServiceDesc for AuthService service. +// It's only intended for direct use with grpc.RegisterService, +// and not to be introspected or modified (even as a copy) +var AuthService_ServiceDesc = grpc.ServiceDesc{ + ServiceName: "identity.AuthService", + HandlerType: (*AuthServiceServer)(nil), + Methods: []grpc.MethodDesc{ + { + MethodName: "Login", + Handler: _AuthService_Login_Handler, + }, + { + MethodName: "Refresh", + Handler: _AuthService_Refresh_Handler, + }, + { + MethodName: "Logout", + Handler: _AuthService_Logout_Handler, + }, + { + MethodName: "UnlockPin", + Handler: _AuthService_UnlockPin_Handler, + }, + { + MethodName: "Verify2Fa", + Handler: _AuthService_Verify2Fa_Handler, + }, + }, + Streams: []grpc.StreamDesc{}, + Metadata: "identity.proto", +} + +const ( + TwoFaService_GetTwoFaStatus_FullMethodName = "/identity.TwoFaService/GetTwoFaStatus" + TwoFaService_StartTotpEnrollment_FullMethodName = "/identity.TwoFaService/StartTotpEnrollment" + TwoFaService_ConfirmTotpErollment_FullMethodName = "/identity.TwoFaService/ConfirmTotpErollment" + TwoFaService_CancelTotpEnrollment_FullMethodName = "/identity.TwoFaService/CancelTotpEnrollment" + TwoFaService_DisableTotp_FullMethodName = "/identity.TwoFaService/DisableTotp" + TwoFaService_StartTelegramEnrollment_FullMethodName = "/identity.TwoFaService/StartTelegramEnrollment" + TwoFaService_ConfirmTelegramEnrollment_FullMethodName = "/identity.TwoFaService/ConfirmTelegramEnrollment" + TwoFaService_DisableTelegram_FullMethodName = "/identity.TwoFaService/DisableTelegram" +) + +// TwoFaServiceClient is the client API for TwoFaService 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 TwoFaServiceClient interface { + GetTwoFaStatus(ctx context.Context, in *GetTwoFaStatusRequest, opts ...grpc.CallOption) (*GetTwoFaStatusResponse, error) + StartTotpEnrollment(ctx context.Context, in *AuthenticatedAccessRequest, opts ...grpc.CallOption) (*StartTotpEnrollmentResponse, error) + ConfirmTotpErollment(ctx context.Context, in *ConfirmTotpEnrollmentRequest, opts ...grpc.CallOption) (*ConfirmTotpEnrollmentResponse, error) + CancelTotpEnrollment(ctx context.Context, in *AuthenticatedAccessRequest, opts ...grpc.CallOption) (*CancelTotpEnrollmentResponse, error) + DisableTotp(ctx context.Context, in *DisableTotpRequest, opts ...grpc.CallOption) (*DisableTotpResponse, error) + StartTelegramEnrollment(ctx context.Context, in *AuthenticatedAccessRequest, opts ...grpc.CallOption) (*StartTelegramEnrollmentResponse, error) + ConfirmTelegramEnrollment(ctx context.Context, in *ConfirmTelegramEnrollmentRequest, opts ...grpc.CallOption) (*ConfirmTelegramEnrollmentResponse, error) + DisableTelegram(ctx context.Context, in *DisableTelegramRequest, opts ...grpc.CallOption) (*DisableTelegramResponse, error) +} + +type twoFaServiceClient struct { + cc grpc.ClientConnInterface +} + +func NewTwoFaServiceClient(cc grpc.ClientConnInterface) TwoFaServiceClient { + return &twoFaServiceClient{cc} +} + +func (c *twoFaServiceClient) GetTwoFaStatus(ctx context.Context, in *GetTwoFaStatusRequest, opts ...grpc.CallOption) (*GetTwoFaStatusResponse, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(GetTwoFaStatusResponse) + err := c.cc.Invoke(ctx, TwoFaService_GetTwoFaStatus_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *twoFaServiceClient) StartTotpEnrollment(ctx context.Context, in *AuthenticatedAccessRequest, opts ...grpc.CallOption) (*StartTotpEnrollmentResponse, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(StartTotpEnrollmentResponse) + err := c.cc.Invoke(ctx, TwoFaService_StartTotpEnrollment_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *twoFaServiceClient) ConfirmTotpErollment(ctx context.Context, in *ConfirmTotpEnrollmentRequest, opts ...grpc.CallOption) (*ConfirmTotpEnrollmentResponse, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(ConfirmTotpEnrollmentResponse) + err := c.cc.Invoke(ctx, TwoFaService_ConfirmTotpErollment_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *twoFaServiceClient) CancelTotpEnrollment(ctx context.Context, in *AuthenticatedAccessRequest, opts ...grpc.CallOption) (*CancelTotpEnrollmentResponse, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(CancelTotpEnrollmentResponse) + err := c.cc.Invoke(ctx, TwoFaService_CancelTotpEnrollment_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *twoFaServiceClient) DisableTotp(ctx context.Context, in *DisableTotpRequest, opts ...grpc.CallOption) (*DisableTotpResponse, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(DisableTotpResponse) + err := c.cc.Invoke(ctx, TwoFaService_DisableTotp_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *twoFaServiceClient) StartTelegramEnrollment(ctx context.Context, in *AuthenticatedAccessRequest, opts ...grpc.CallOption) (*StartTelegramEnrollmentResponse, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(StartTelegramEnrollmentResponse) + err := c.cc.Invoke(ctx, TwoFaService_StartTelegramEnrollment_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *twoFaServiceClient) ConfirmTelegramEnrollment(ctx context.Context, in *ConfirmTelegramEnrollmentRequest, opts ...grpc.CallOption) (*ConfirmTelegramEnrollmentResponse, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(ConfirmTelegramEnrollmentResponse) + err := c.cc.Invoke(ctx, TwoFaService_ConfirmTelegramEnrollment_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *twoFaServiceClient) DisableTelegram(ctx context.Context, in *DisableTelegramRequest, opts ...grpc.CallOption) (*DisableTelegramResponse, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(DisableTelegramResponse) + err := c.cc.Invoke(ctx, TwoFaService_DisableTelegram_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +// TwoFaServiceServer is the server API for TwoFaService service. +// All implementations must embed UnimplementedTwoFaServiceServer +// for forward compatibility. +type TwoFaServiceServer interface { + GetTwoFaStatus(context.Context, *GetTwoFaStatusRequest) (*GetTwoFaStatusResponse, error) + StartTotpEnrollment(context.Context, *AuthenticatedAccessRequest) (*StartTotpEnrollmentResponse, error) + ConfirmTotpErollment(context.Context, *ConfirmTotpEnrollmentRequest) (*ConfirmTotpEnrollmentResponse, error) + CancelTotpEnrollment(context.Context, *AuthenticatedAccessRequest) (*CancelTotpEnrollmentResponse, error) + DisableTotp(context.Context, *DisableTotpRequest) (*DisableTotpResponse, error) + StartTelegramEnrollment(context.Context, *AuthenticatedAccessRequest) (*StartTelegramEnrollmentResponse, error) + ConfirmTelegramEnrollment(context.Context, *ConfirmTelegramEnrollmentRequest) (*ConfirmTelegramEnrollmentResponse, error) + DisableTelegram(context.Context, *DisableTelegramRequest) (*DisableTelegramResponse, error) + mustEmbedUnimplementedTwoFaServiceServer() +} + +// UnimplementedTwoFaServiceServer 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 UnimplementedTwoFaServiceServer struct{} + +func (UnimplementedTwoFaServiceServer) GetTwoFaStatus(context.Context, *GetTwoFaStatusRequest) (*GetTwoFaStatusResponse, error) { + return nil, status.Error(codes.Unimplemented, "method GetTwoFaStatus not implemented") +} +func (UnimplementedTwoFaServiceServer) StartTotpEnrollment(context.Context, *AuthenticatedAccessRequest) (*StartTotpEnrollmentResponse, error) { + return nil, status.Error(codes.Unimplemented, "method StartTotpEnrollment not implemented") +} +func (UnimplementedTwoFaServiceServer) ConfirmTotpErollment(context.Context, *ConfirmTotpEnrollmentRequest) (*ConfirmTotpEnrollmentResponse, error) { + return nil, status.Error(codes.Unimplemented, "method ConfirmTotpErollment not implemented") +} +func (UnimplementedTwoFaServiceServer) CancelTotpEnrollment(context.Context, *AuthenticatedAccessRequest) (*CancelTotpEnrollmentResponse, error) { + return nil, status.Error(codes.Unimplemented, "method CancelTotpEnrollment not implemented") +} +func (UnimplementedTwoFaServiceServer) DisableTotp(context.Context, *DisableTotpRequest) (*DisableTotpResponse, error) { + return nil, status.Error(codes.Unimplemented, "method DisableTotp not implemented") +} +func (UnimplementedTwoFaServiceServer) StartTelegramEnrollment(context.Context, *AuthenticatedAccessRequest) (*StartTelegramEnrollmentResponse, error) { + return nil, status.Error(codes.Unimplemented, "method StartTelegramEnrollment not implemented") +} +func (UnimplementedTwoFaServiceServer) ConfirmTelegramEnrollment(context.Context, *ConfirmTelegramEnrollmentRequest) (*ConfirmTelegramEnrollmentResponse, error) { + return nil, status.Error(codes.Unimplemented, "method ConfirmTelegramEnrollment not implemented") +} +func (UnimplementedTwoFaServiceServer) DisableTelegram(context.Context, *DisableTelegramRequest) (*DisableTelegramResponse, error) { + return nil, status.Error(codes.Unimplemented, "method DisableTelegram not implemented") +} +func (UnimplementedTwoFaServiceServer) mustEmbedUnimplementedTwoFaServiceServer() {} +func (UnimplementedTwoFaServiceServer) testEmbeddedByValue() {} + +// UnsafeTwoFaServiceServer may be embedded to opt out of forward compatibility for this service. +// Use of this interface is not recommended, as added methods to TwoFaServiceServer will +// result in compilation errors. +type UnsafeTwoFaServiceServer interface { + mustEmbedUnimplementedTwoFaServiceServer() +} + +func RegisterTwoFaServiceServer(s grpc.ServiceRegistrar, srv TwoFaServiceServer) { + // If the following call panics, it indicates UnimplementedTwoFaServiceServer 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(&TwoFaService_ServiceDesc, srv) +} + +func _TwoFaService_GetTwoFaStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(GetTwoFaStatusRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(TwoFaServiceServer).GetTwoFaStatus(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: TwoFaService_GetTwoFaStatus_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(TwoFaServiceServer).GetTwoFaStatus(ctx, req.(*GetTwoFaStatusRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _TwoFaService_StartTotpEnrollment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(AuthenticatedAccessRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(TwoFaServiceServer).StartTotpEnrollment(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: TwoFaService_StartTotpEnrollment_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(TwoFaServiceServer).StartTotpEnrollment(ctx, req.(*AuthenticatedAccessRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _TwoFaService_ConfirmTotpErollment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(ConfirmTotpEnrollmentRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(TwoFaServiceServer).ConfirmTotpErollment(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: TwoFaService_ConfirmTotpErollment_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(TwoFaServiceServer).ConfirmTotpErollment(ctx, req.(*ConfirmTotpEnrollmentRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _TwoFaService_CancelTotpEnrollment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(AuthenticatedAccessRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(TwoFaServiceServer).CancelTotpEnrollment(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: TwoFaService_CancelTotpEnrollment_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(TwoFaServiceServer).CancelTotpEnrollment(ctx, req.(*AuthenticatedAccessRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _TwoFaService_DisableTotp_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(DisableTotpRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(TwoFaServiceServer).DisableTotp(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: TwoFaService_DisableTotp_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(TwoFaServiceServer).DisableTotp(ctx, req.(*DisableTotpRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _TwoFaService_StartTelegramEnrollment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(AuthenticatedAccessRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(TwoFaServiceServer).StartTelegramEnrollment(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: TwoFaService_StartTelegramEnrollment_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(TwoFaServiceServer).StartTelegramEnrollment(ctx, req.(*AuthenticatedAccessRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _TwoFaService_ConfirmTelegramEnrollment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(ConfirmTelegramEnrollmentRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(TwoFaServiceServer).ConfirmTelegramEnrollment(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: TwoFaService_ConfirmTelegramEnrollment_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(TwoFaServiceServer).ConfirmTelegramEnrollment(ctx, req.(*ConfirmTelegramEnrollmentRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _TwoFaService_DisableTelegram_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(DisableTelegramRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(TwoFaServiceServer).DisableTelegram(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: TwoFaService_DisableTelegram_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(TwoFaServiceServer).DisableTelegram(ctx, req.(*DisableTelegramRequest)) + } + return interceptor(ctx, in, info, handler) +} + +// TwoFaService_ServiceDesc is the grpc.ServiceDesc for TwoFaService service. +// It's only intended for direct use with grpc.RegisterService, +// and not to be introspected or modified (even as a copy) +var TwoFaService_ServiceDesc = grpc.ServiceDesc{ + ServiceName: "identity.TwoFaService", + HandlerType: (*TwoFaServiceServer)(nil), + Methods: []grpc.MethodDesc{ + { + MethodName: "GetTwoFaStatus", + Handler: _TwoFaService_GetTwoFaStatus_Handler, + }, + { + MethodName: "StartTotpEnrollment", + Handler: _TwoFaService_StartTotpEnrollment_Handler, + }, + { + MethodName: "ConfirmTotpErollment", + Handler: _TwoFaService_ConfirmTotpErollment_Handler, + }, + { + MethodName: "CancelTotpEnrollment", + Handler: _TwoFaService_CancelTotpEnrollment_Handler, + }, + { + MethodName: "DisableTotp", + Handler: _TwoFaService_DisableTotp_Handler, + }, + { + MethodName: "StartTelegramEnrollment", + Handler: _TwoFaService_StartTelegramEnrollment_Handler, + }, + { + MethodName: "ConfirmTelegramEnrollment", + Handler: _TwoFaService_ConfirmTelegramEnrollment_Handler, + }, + { + MethodName: "DisableTelegram", + Handler: _TwoFaService_DisableTelegram_Handler, + }, + }, + Streams: []grpc.StreamDesc{}, + Metadata: "identity.proto", +} diff --git a/gen/go/ldap.pb.go b/gen/go/ldap.pb.go new file mode 100644 index 0000000..7b8b2e5 --- /dev/null +++ b/gen/go/ldap.pb.go @@ -0,0 +1,277 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.36.11 +// protoc v3.21.12 +// source: ldap.proto + +package ldap_service + +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 VerifyRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` + Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *VerifyRequest) Reset() { + *x = VerifyRequest{} + mi := &file_ldap_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *VerifyRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*VerifyRequest) ProtoMessage() {} + +func (x *VerifyRequest) ProtoReflect() protoreflect.Message { + mi := &file_ldap_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 VerifyRequest.ProtoReflect.Descriptor instead. +func (*VerifyRequest) Descriptor() ([]byte, []int) { + return file_ldap_proto_rawDescGZIP(), []int{0} +} + +func (x *VerifyRequest) GetUsername() string { + if x != nil { + return x.Username + } + return "" +} + +func (x *VerifyRequest) GetPassword() string { + if x != nil { + return x.Password + } + return "" +} + +type VerifyResponse struct { + state protoimpl.MessageState `protogen:"open.v1"` + Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` + ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"` + User *UserData `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *VerifyResponse) Reset() { + *x = VerifyResponse{} + mi := &file_ldap_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *VerifyResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*VerifyResponse) ProtoMessage() {} + +func (x *VerifyResponse) ProtoReflect() protoreflect.Message { + mi := &file_ldap_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 VerifyResponse.ProtoReflect.Descriptor instead. +func (*VerifyResponse) Descriptor() ([]byte, []int) { + return file_ldap_proto_rawDescGZIP(), []int{1} +} + +func (x *VerifyResponse) GetSuccess() bool { + if x != nil { + return x.Success + } + return false +} + +func (x *VerifyResponse) GetErrorMessage() string { + if x != nil { + return x.ErrorMessage + } + return "" +} + +func (x *VerifyResponse) GetUser() *UserData { + if x != nil { + return x.User + } + return nil +} + +type UserData struct { + state protoimpl.MessageState `protogen:"open.v1"` + Dn string `protobuf:"bytes,1,opt,name=dn,proto3" json:"dn,omitempty"` + DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"` + Groups []string `protobuf:"bytes,3,rep,name=groups,proto3" json:"groups,omitempty"` + IsActive bool `protobuf:"varint,4,opt,name=is_active,json=isActive,proto3" json:"is_active,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *UserData) Reset() { + *x = UserData{} + mi := &file_ldap_proto_msgTypes[2] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *UserData) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*UserData) ProtoMessage() {} + +func (x *UserData) ProtoReflect() protoreflect.Message { + mi := &file_ldap_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 UserData.ProtoReflect.Descriptor instead. +func (*UserData) Descriptor() ([]byte, []int) { + return file_ldap_proto_rawDescGZIP(), []int{2} +} + +func (x *UserData) GetDn() string { + if x != nil { + return x.Dn + } + return "" +} + +func (x *UserData) GetDisplayName() string { + if x != nil { + return x.DisplayName + } + return "" +} + +func (x *UserData) GetGroups() []string { + if x != nil { + return x.Groups + } + return nil +} + +func (x *UserData) GetIsActive() bool { + if x != nil { + return x.IsActive + } + return false +} + +var File_ldap_proto protoreflect.FileDescriptor + +const file_ldap_proto_rawDesc = "" + + "\n" + + "\n" + + "ldap.proto\x12\fldap_service\"G\n" + + "\rVerifyRequest\x12\x1a\n" + + "\busername\x18\x01 \x01(\tR\busername\x12\x1a\n" + + "\bpassword\x18\x02 \x01(\tR\bpassword\"{\n" + + "\x0eVerifyResponse\x12\x18\n" + + "\asuccess\x18\x01 \x01(\bR\asuccess\x12#\n" + + "\rerror_message\x18\x02 \x01(\tR\ferrorMessage\x12*\n" + + "\x04user\x18\x03 \x01(\v2\x16.ldap_service.UserDataR\x04user\"r\n" + + "\bUserData\x12\x0e\n" + + "\x02dn\x18\x01 \x01(\tR\x02dn\x12!\n" + + "\fdisplay_name\x18\x02 \x01(\tR\vdisplayName\x12\x16\n" + + "\x06groups\x18\x03 \x03(\tR\x06groups\x12\x1b\n" + + "\tis_active\x18\x04 \x01(\bR\bisActive2S\n" + + "\bLdapAuth\x12G\n" + + "\n" + + "VerifyUser\x12\x1b.ldap_service.VerifyRequest\x1a\x1c.ldap_service.VerifyResponseB+Z)git.lendry.ru/lendry-erp/gen;ldap_serviceb\x06proto3" + +var ( + file_ldap_proto_rawDescOnce sync.Once + file_ldap_proto_rawDescData []byte +) + +func file_ldap_proto_rawDescGZIP() []byte { + file_ldap_proto_rawDescOnce.Do(func() { + file_ldap_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_ldap_proto_rawDesc), len(file_ldap_proto_rawDesc))) + }) + return file_ldap_proto_rawDescData +} + +var file_ldap_proto_msgTypes = make([]protoimpl.MessageInfo, 3) +var file_ldap_proto_goTypes = []any{ + (*VerifyRequest)(nil), // 0: ldap_service.VerifyRequest + (*VerifyResponse)(nil), // 1: ldap_service.VerifyResponse + (*UserData)(nil), // 2: ldap_service.UserData +} +var file_ldap_proto_depIdxs = []int32{ + 2, // 0: ldap_service.VerifyResponse.user:type_name -> ldap_service.UserData + 0, // 1: ldap_service.LdapAuth.VerifyUser:input_type -> ldap_service.VerifyRequest + 1, // 2: ldap_service.LdapAuth.VerifyUser:output_type -> ldap_service.VerifyResponse + 2, // [2:3] is the sub-list for method output_type + 1, // [1:2] is the sub-list for method input_type + 1, // [1:1] is the sub-list for extension type_name + 1, // [1:1] is the sub-list for extension extendee + 0, // [0:1] is the sub-list for field type_name +} + +func init() { file_ldap_proto_init() } +func file_ldap_proto_init() { + if File_ldap_proto != nil { + return + } + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: unsafe.Slice(unsafe.StringData(file_ldap_proto_rawDesc), len(file_ldap_proto_rawDesc)), + NumEnums: 0, + NumMessages: 3, + NumExtensions: 0, + NumServices: 1, + }, + GoTypes: file_ldap_proto_goTypes, + DependencyIndexes: file_ldap_proto_depIdxs, + MessageInfos: file_ldap_proto_msgTypes, + }.Build() + File_ldap_proto = out.File + file_ldap_proto_goTypes = nil + file_ldap_proto_depIdxs = nil +} diff --git a/gen/go/ldap_grpc.pb.go b/gen/go/ldap_grpc.pb.go new file mode 100644 index 0000000..808c13e --- /dev/null +++ b/gen/go/ldap_grpc.pb.go @@ -0,0 +1,121 @@ +// Code generated by protoc-gen-go-grpc. DO NOT EDIT. +// versions: +// - protoc-gen-go-grpc v1.6.1 +// - protoc v3.21.12 +// source: ldap.proto + +package ldap_service + +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 ( + LdapAuth_VerifyUser_FullMethodName = "/ldap_service.LdapAuth/VerifyUser" +) + +// LdapAuthClient is the client API for LdapAuth 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 LdapAuthClient interface { + VerifyUser(ctx context.Context, in *VerifyRequest, opts ...grpc.CallOption) (*VerifyResponse, error) +} + +type ldapAuthClient struct { + cc grpc.ClientConnInterface +} + +func NewLdapAuthClient(cc grpc.ClientConnInterface) LdapAuthClient { + return &ldapAuthClient{cc} +} + +func (c *ldapAuthClient) VerifyUser(ctx context.Context, in *VerifyRequest, opts ...grpc.CallOption) (*VerifyResponse, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(VerifyResponse) + err := c.cc.Invoke(ctx, LdapAuth_VerifyUser_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +// LdapAuthServer is the server API for LdapAuth service. +// All implementations must embed UnimplementedLdapAuthServer +// for forward compatibility. +type LdapAuthServer interface { + VerifyUser(context.Context, *VerifyRequest) (*VerifyResponse, error) + mustEmbedUnimplementedLdapAuthServer() +} + +// UnimplementedLdapAuthServer 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 UnimplementedLdapAuthServer struct{} + +func (UnimplementedLdapAuthServer) VerifyUser(context.Context, *VerifyRequest) (*VerifyResponse, error) { + return nil, status.Error(codes.Unimplemented, "method VerifyUser not implemented") +} +func (UnimplementedLdapAuthServer) mustEmbedUnimplementedLdapAuthServer() {} +func (UnimplementedLdapAuthServer) testEmbeddedByValue() {} + +// UnsafeLdapAuthServer may be embedded to opt out of forward compatibility for this service. +// Use of this interface is not recommended, as added methods to LdapAuthServer will +// result in compilation errors. +type UnsafeLdapAuthServer interface { + mustEmbedUnimplementedLdapAuthServer() +} + +func RegisterLdapAuthServer(s grpc.ServiceRegistrar, srv LdapAuthServer) { + // If the following call panics, it indicates UnimplementedLdapAuthServer 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(&LdapAuth_ServiceDesc, srv) +} + +func _LdapAuth_VerifyUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(VerifyRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(LdapAuthServer).VerifyUser(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: LdapAuth_VerifyUser_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(LdapAuthServer).VerifyUser(ctx, req.(*VerifyRequest)) + } + return interceptor(ctx, in, info, handler) +} + +// LdapAuth_ServiceDesc is the grpc.ServiceDesc for LdapAuth service. +// It's only intended for direct use with grpc.RegisterService, +// and not to be introspected or modified (even as a copy) +var LdapAuth_ServiceDesc = grpc.ServiceDesc{ + ServiceName: "ldap_service.LdapAuth", + HandlerType: (*LdapAuthServer)(nil), + Methods: []grpc.MethodDesc{ + { + MethodName: "VerifyUser", + Handler: _LdapAuth_VerifyUser_Handler, + }, + }, + Streams: []grpc.StreamDesc{}, + Metadata: "ldap.proto", +} diff --git a/gen/identity.ts b/gen/identity.ts index 2d0a12c..2e6994d 100644 --- a/gen/identity.ts +++ b/gen/identity.ts @@ -1,13 +1,12 @@ // Code generated by protoc-gen-ts_proto. DO NOT EDIT. // versions: // protoc-gen-ts_proto v2.11.6 -// protoc v7.34.1 +// protoc v3.21.12 // source: identity.proto /* eslint-disable */ import { GrpcMethod, GrpcStreamMethod } from "@nestjs/microservices"; import { Observable } from "rxjs"; -import { Status } from "./google/rpc/status"; export const protobufPackage = "identity"; @@ -24,7 +23,6 @@ export interface LoginResponse { tempToken?: string | undefined; message?: string | undefined; errorCode?: string | undefined; - error?: Status | undefined; } export interface RefreshRequest { diff --git a/gen/ldap.ts b/gen/ldap.ts new file mode 100644 index 0000000..18e73c2 --- /dev/null +++ b/gen/ldap.ts @@ -0,0 +1,56 @@ +// Code generated by protoc-gen-ts_proto. DO NOT EDIT. +// versions: +// protoc-gen-ts_proto v2.11.6 +// protoc v3.21.12 +// source: ldap.proto + +/* eslint-disable */ +import { GrpcMethod, GrpcStreamMethod } from "@nestjs/microservices"; +import { Observable } from "rxjs"; + +export const protobufPackage = "ldap_service"; + +export interface VerifyRequest { + username: string; + password: string; +} + +export interface VerifyResponse { + success: boolean; + errorMessage: string; + user: UserData | undefined; +} + +export interface UserData { + dn: string; + displayName: string; + groups: string[]; + isActive: boolean; +} + +export const LDAP_SERVICE_PACKAGE_NAME = "ldap_service"; + +export interface LdapAuthClient { + verifyUser(request: VerifyRequest): Observable; +} + +export interface LdapAuthController { + verifyUser(request: VerifyRequest): Promise | Observable | VerifyResponse; +} + +export function LdapAuthControllerMethods() { + return function (constructor: Function) { + const grpcMethods: string[] = ["verifyUser"]; + for (const method of grpcMethods) { + const descriptor: any = Reflect.getOwnPropertyDescriptor(constructor.prototype, method); + GrpcMethod("LdapAuth", method)(constructor.prototype[method], method, descriptor); + } + const grpcStreamMethods: string[] = []; + for (const method of grpcStreamMethods) { + const descriptor: any = Reflect.getOwnPropertyDescriptor(constructor.prototype, method); + GrpcStreamMethod("LdapAuth", method)(constructor.prototype[method], method, descriptor); + } + }; +} + +export const LDAP_AUTH_SERVICE_NAME = "LdapAuth";