Merge pull request #515 from LydiaCai1203/fix-target-active

fix: 部分接口缺失活跃时间记录

Author: yokowu

backend/biz/project/handler/v1/project.go

@@ -39,22 +39,22 @@ func NewProjectHandler(i *do.Injector) (*ProjectHandler, error) {
 	g.DELETE("/:id", web.BindHandler(h.Delete))
 
 	gi := w.Group("/api/v1/users/projects/:id/issues")
-	gi.Use(auth.Auth())
+	gi.Use(auth.Auth(), targetActive.TargetActive())
 	gi.GET("", web.BindHandler(h.ListIssues))
 	gi.POST("", web.BindHandler(h.CreateIssue))
 	gi.PUT("/:issue_id", web.BindHandler(h.UpdateIssue))
 
 	gic := w.Group("/api/v1/users/projects/:id/issues/:issue_id/comments")
-	gic.Use(auth.Auth())
+	gic.Use(auth.Auth(), targetActive.TargetActive())
 	gic.GET("", web.BindHandler(h.ListIssueComments))
 	gic.POST("", web.BindHandler(h.CreateIssueComment))
 
 	gc := w.Group("/api/v1/users/projects/:id/collaborators")
-	gc.Use(auth.Auth())
+	gc.Use(auth.Auth(), targetActive.TargetActive())
 	gc.GET("", web.BindHandler(h.ListCollaborators))
 
 	gt := w.Group("/api/v1/users/projects/:id/tree")
-	gt.Use(auth.Auth())
+	gt.Use(auth.Auth(), targetActive.TargetActive())
 	gt.GET("", web.BindHandler(h.GetProjectTree))
 	gt.GET("/blob", web.BindHandler(h.GetProjectBlob))
 	gt.GET("/logs", web.BindHandler(h.GetProjectLogs))

backend/biz/task/handler/v1/task.go

@@ -47,6 +47,7 @@ type TaskHandler struct {
 	controlConns  *ws.ControlConn
 	taskSummary   *service.TaskSummaryService
 	idleRefresher vmidle.VMIdleRefresher
+	activeRepo    domain.UserActiveRepo
 }
 
 // NewTaskHandler 创建任务处理器
@@ -76,6 +77,8 @@ func NewTaskHandler(i *do.Injector) (*TaskHandler, error) {
 		nlsSvc = n
 	}
 
+	activeRepo := do.MustInvoke[domain.UserActiveRepo](i)
+
 	h := &TaskHandler{
 		cfg:           cfg,
 		usecase:       uc,
@@ -89,6 +92,7 @@ func NewTaskHandler(i *do.Injector) (*TaskHandler, error) {
 		controlConns:  cc,
 		taskSummary:   ts,
 		idleRefresher: ir,
+		activeRepo:    activeRepo,
 	}
 
 	// 注册路由
@@ -583,6 +587,11 @@ func (h *TaskHandler) readClientMessages(ctx context.Context, wsConn *ws.Websock
 }
 
 func (h *TaskHandler) handleClientMessage(ctx context.Context, logger *slog.Logger, user *domain.User, task *domain.Task, m domain.TaskStream) {
+	// 记录用户活跃时间
+	if err := h.activeRepo.RecordActiveRecord(ctx, consts.UserActiveKey, user.ID.String(), time.Now()); err != nil {
+		logger.With("error", err).WarnContext(ctx, "failed to record user active time")
+	}
+
 	switch m.Type {
 	case consts.TaskStreamTypeUserInput:
 		if err := h.usecase.Continue(ctx, user, task.ID, string(m.Data)); err != nil {

backend/biz/user/handler/v1/auth.go

@@ -56,14 +56,14 @@ func NewAuthHandler(i *do.Injector) (*AuthHandler, error) {
 	v1.PUT("/passwords/reset", web.BindHandler(h.ResetPassword))
 
 	// 密码登录
-	v1.POST("/password-login", web.BindHandler(h.PasswordLogin))
-	v1.PUT("/passwords/change", web.BindHandler(h.ChangePassword), auth.Check())
-	v1.GET("/status", web.BaseHandler(h.Status), auth.Check())
+	v1.POST("/password-login", web.BindHandler(h.PasswordLogin), targetActive.TargetActive())
+	v1.PUT("/passwords/change", web.BindHandler(h.ChangePassword), auth.Check(), targetActive.TargetActive())
+	v1.GET("/status", web.BaseHandler(h.Status), auth.Check(), targetActive.TargetActive())
 	v1.POST("/logout", web.BaseHandler(h.Logout), auth.Auth(), targetActive.TargetActive())
 
 	// 邮箱绑定接口
 	v1.PUT("/email/bind-request", web.BindHandler(h.SendBindEmailVerification), auth.Auth(), targetActive.TargetActive())
-	v1.GET("/email/verify", web.BindHandler(h.VerifyBindEmail))
+	v1.GET("/email/verify", web.BindHandler(h.VerifyBindEmail), targetActive.TargetActive())
 
 	return h, nil
 }