auth

Documentation

Index

• func GenerateTokens(userID string, role string) (accessToken string, refreshToken string, err error)
• func SessionMiddleware(sessionManager *SessionManager) func(next http.Handler) http.Handler
• type Repository
  • func NewRepository(db *pgxpool.Pool, redis *redis.Client, sessionManager *SessionManager) *Repository
  • func (r *Repository) ChangeEmail(ctx context.Context, req *pb.ChangeEmailRequest) (*pb.ChangeEmailResponse, error)
  • func (r *Repository) ChangePassword(ctx context.Context, req *pb.ChangePasswordRequest) (*pb.ChangePasswordResponse, error)
  • func (r *Repository) DeleteUser(ctx context.Context, req *pb.DeleteUserRequest) (*pb.DeleteUserResponse, error)
  • func (r *Repository) GetAllUsers(ctx context.Context) (*pb.GetAllUsersResponse, error)
  • func (r *Repository) GetUserByID(ctx context.Context, req *pb.GetUserByIDRequest) (*pb.GetUserByIDResponse, error)
  • func (r *Repository) InsertUser(ctx context.Context, req *pb.InsertUserRequest) (*pb.InsertUserResponse, error)
  • func (r *Repository) Login(ctx context.Context, req *pb.LoginRequest) (*pb.LoginResponse, error)
  • func (r *Repository) Logout(ctx context.Context, req *pb.NilReq) (*pb.NilRes, error)
  • func (r *Repository) RefreshToken(ctx context.Context, req *pb.RefreshTokenRequest) (*pb.TokenResponse, error)
  • func (r *Repository) Register(ctx context.Context, req *pb.RegisterRequest) (*pb.RegisterResponse, error)
  • func (r *Repository) UpdateUser(ctx context.Context, req *pb.UpdateUserRequest) (*pb.UpdateUserResponse, error)
• type Service
  • func NewService(ctx context.Context, repo domain.AuthRepository, db *pgxpool.Pool, ...) *Service
  • func (s *Service) ChangeEmail(ctx context.Context, req *pb.ChangeEmailRequest) (*pb.ChangeEmailResponse, error)
  • func (s *Service) ChangePassword(ctx context.Context, req *pb.ChangePasswordRequest) (*pb.ChangePasswordResponse, error)
  • func (s *Service) DeleteUser(ctx context.Context, req *pb.DeleteUserRequest) (*pb.DeleteUserResponse, error)
  • func (s *Service) GetAllUsers(ctx context.Context, _ *pb.GetAllUsersRequest) (*pb.GetAllUsersResponse, error)
  • func (s *Service) GetUserByID(ctx context.Context, req *pb.GetUserByIDRequest) (*pb.GetUserByIDResponse, error)
  • func (s *Service) InsertUser(ctx context.Context, req *pb.InsertUserRequest) (*pb.InsertUserResponse, error)
  • func (s *Service) Login(ctx context.Context, req *pb.LoginRequest) (*pb.LoginResponse, error)
  • func (s *Service) Logout(ctx context.Context, req *pb.NilReq) (*pb.NilRes, error)
  • func (s *Service) Register(ctx context.Context, req *pb.RegisterRequest) (*pb.RegisterResponse, error)
  • func (s *Service) UpdateUser(ctx context.Context, req *pb.UpdateUserRequest) (*pb.UpdateUserResponse, error)
• type SessionManager
  • func NewSessionManager(pgpool *pgxpool.Pool, redis *redis.Client) *SessionManager
  • func (s *SessionManager) GetSession(session string) (*UserSession, error)
  • func (s *SessionManager) SignIn(ctx context.Context, email, password string) (string, error)
  • func (s *SessionManager) SignOut(sessionId string) error
• type SessionManagerKey
• type User
• type UserSession

Functions

func GenerateTokens

func GenerateTokens(userID string, role string) (accessToken string, refreshToken string, err error)

func SessionMiddleware

func SessionMiddleware(sessionManager *SessionManager) func(next http.Handler) http.Handler

Types

type Repository

type Repository struct {
	pb.UnimplementedAuthServer
	// contains filtered or unexported fields
}

func NewRepository

func NewRepository(db *pgxpool.Pool, redis *redis.Client, sessionManager *SessionManager) *Repository

NewRepository creates a new AuthService

func (*Repository) ChangeEmail

func (r *Repository) ChangeEmail(ctx context.Context, req *pb.ChangeEmailRequest) (*pb.ChangeEmailResponse, error)

func (*Repository) ChangePassword

func (r *Repository) ChangePassword(ctx context.Context, req *pb.ChangePasswordRequest) (*pb.ChangePasswordResponse, error)

func (*Repository) DeleteUser

func (r *Repository) DeleteUser(ctx context.Context, req *pb.DeleteUserRequest) (*pb.DeleteUserResponse, error)

func (*Repository) GetAllUsers

func (r *Repository) GetAllUsers(ctx context.Context) (*pb.GetAllUsersResponse, error)

func (*Repository) GetUserByID

func (r *Repository) GetUserByID(ctx context.Context, req *pb.GetUserByIDRequest) (*pb.GetUserByIDResponse, error)

func (*Repository) InsertUser

func (r *Repository) InsertUser(ctx context.Context, req *pb.InsertUserRequest) (*pb.InsertUserResponse, error)

func (*Repository) Login

func (r *Repository) Login(ctx context.Context, req *pb.LoginRequest) (*pb.LoginResponse, error)

func (*Repository) Logout

func (r *Repository) Logout(ctx context.Context, req *pb.NilReq) (*pb.NilRes, error)

func (*Repository) RefreshToken

func (r *Repository) RefreshToken(ctx context.Context, req *pb.RefreshTokenRequest) (*pb.TokenResponse, error)

func (*Repository) Register

func (r *Repository) Register(ctx context.Context, req *pb.RegisterRequest) (*pb.RegisterResponse, error)

func (*Repository) UpdateUser

func (r *Repository) UpdateUser(ctx context.Context, req *pb.UpdateUserRequest) (*pb.UpdateUserResponse, error)

type Service

type Service struct {
	pb.UnimplementedAuthServer

	SessionManager *SessionManager
	// contains filtered or unexported fields
}

func NewService

func NewService(ctx context.Context, repo domain.AuthRepository,
	db *pgxpool.Pool,
	redis *redis.Client,
	sessionManager *SessionManager) *Service

func (*Service) ChangeEmail

func (s *Service) ChangeEmail(ctx context.Context, req *pb.ChangeEmailRequest) (*pb.ChangeEmailResponse, error)

func (*Service) ChangePassword

func (s *Service) ChangePassword(ctx context.Context, req *pb.ChangePasswordRequest) (*pb.ChangePasswordResponse, error)

func (*Service) DeleteUser

func (s *Service) DeleteUser(ctx context.Context, req *pb.DeleteUserRequest) (*pb.DeleteUserResponse, error)

func (*Service) GetAllUsers

func (s *Service) GetAllUsers(ctx context.Context, _ *pb.GetAllUsersRequest) (*pb.GetAllUsersResponse, error)

func (*Service) GetUserByID

func (s *Service) GetUserByID(ctx context.Context, req *pb.GetUserByIDRequest) (*pb.GetUserByIDResponse, error)

func (*Service) InsertUser

func (s *Service) InsertUser(ctx context.Context, req *pb.InsertUserRequest) (*pb.InsertUserResponse, error)

func (*Service) Login

func (s *Service) Login(ctx context.Context, req *pb.LoginRequest) (*pb.LoginResponse, error)

func (*Service) Logout

func (s *Service) Logout(ctx context.Context, req *pb.NilReq) (*pb.NilRes, error)

func (*Service) Register

func (s *Service) Register(ctx context.Context, req *pb.RegisterRequest) (*pb.RegisterResponse, error)

func (*Service) UpdateUser

func (s *Service) UpdateUser(ctx context.Context, req *pb.UpdateUserRequest) (*pb.UpdateUserResponse, error)

type SessionManager

type SessionManager struct {
	PgPool *pgxpool.Pool
	Redis  *redis.Client
}

func NewSessionManager

func NewSessionManager(pgpool *pgxpool.Pool, redis *redis.Client) *SessionManager

func (*SessionManager) GetSession

func (s *SessionManager) GetSession(session string) (*UserSession, error)

func (*SessionManager) SignIn

func (s *SessionManager) SignIn(ctx context.Context, email, password string) (string, error)

func (*SessionManager) SignOut

func (s *SessionManager) SignOut(sessionId string) error

type SessionManagerKey

type SessionManagerKey struct{}

type User

type User struct {
	ID       string
	Username string
	Email    string
	Password string
}

type UserSession

type UserSession struct {
	ID       string `json:"id"`
	Username string `json:"username"`
	Email    string `json:"email"`
	Role     string `json:"role"`
}