package api import ( "fmt" "git.solsynth.dev/hydrogen/passport/pkg/internal/database" "git.solsynth.dev/hydrogen/passport/pkg/internal/models" "git.solsynth.dev/hydrogen/passport/pkg/internal/server/exts" "git.solsynth.dev/hydrogen/passport/pkg/internal/services" "github.com/gofiber/fiber/v2" "github.com/samber/lo" "time" ) func getStatus(c *fiber.Ctx) error { alias := c.Params("alias") var user models.Account if err := database.C.Where(models.Account{ Name: alias, }).Preload("Profile").First(&user).Error; err != nil { return fiber.NewError(fiber.StatusNotFound, fmt.Sprintf("account not found: %s", err)) } status, err := services.GetStatus(user.ID) disturbable := services.GetStatusDisturbable(user.ID) == nil online := services.GetStatusOnline(user.ID) == nil // Always set false to hide from others status.IsInvisible = false return c.JSON(fiber.Map{ "status": lo.Ternary(err == nil, &status, nil), "last_seen_at": user.Profile.LastSeenAt, "is_disturbable": disturbable, "is_online": online, }) } func getMyselfStatus(c *fiber.Ctx) error { if err := exts.EnsureAuthenticated(c); err != nil { return err } user := c.Locals("user").(models.Account) status, err := services.GetStatus(user.ID) disturbable := services.GetStatusDisturbable(user.ID) == nil online := services.GetStatusOnline(user.ID) == nil return c.JSON(fiber.Map{ "status": lo.Ternary(err == nil, &status, nil), "last_seen_at": user.Profile.LastSeenAt, "is_disturbable": disturbable, "is_online": online, }) } func setStatus(c *fiber.Ctx) error { user := c.Locals("user").(models.Account) if err := exts.EnsureAuthenticated(c); err != nil { return err } var req struct { Type string `json:"type" validate:"required"` Label string `json:"label" validate:"required"` Attitude uint `json:"attitude" validate:"required"` IsNoDisturb bool `json:"is_no_disturb"` IsInvisible bool `json:"is_invisible"` ClearAt *time.Time `json:"clear_at"` } if err := exts.BindAndValidate(c, &req); err != nil { return err } status := models.Status{ Type: req.Type, Label: req.Label, Attitude: models.StatusAttitude(req.Attitude), IsNoDisturb: req.IsNoDisturb, IsInvisible: req.IsInvisible, ClearAt: req.ClearAt, AccountID: user.ID, } if status, err := services.NewStatus(user, status); err != nil { return fiber.NewError(fiber.StatusBadRequest, err.Error()) } else { return c.JSON(status) } } func editStatus(c *fiber.Ctx) error { user := c.Locals("user").(models.Account) if err := exts.EnsureAuthenticated(c); err != nil { return err } var req struct { Type string `json:"type" validate:"required"` Label string `json:"label" validate:"required"` Attitude uint `json:"attitude" validate:"required"` IsNoDisturb bool `json:"is_no_disturb"` IsInvisible bool `json:"is_invisible"` ClearAt *time.Time `json:"clear_at"` } if err := exts.BindAndValidate(c, &req); err != nil { return err } status, err := services.GetStatus(user.ID) if err != nil { return fiber.NewError(fiber.StatusBadRequest, "you must set a status first and then can edit it") } status.Type = req.Type status.Label = req.Label status.Attitude = models.StatusAttitude(req.Attitude) status.IsNoDisturb = req.IsNoDisturb status.IsInvisible = req.IsInvisible status.ClearAt = req.ClearAt if status, err := services.EditStatus(user, status); err != nil { return fiber.NewError(fiber.StatusBadRequest, err.Error()) } else { return c.JSON(status) } } func clearStatus(c *fiber.Ctx) error { user := c.Locals("user").(models.Account) if err := exts.EnsureAuthenticated(c); err != nil { return err } if err := services.ClearStatus(user); err != nil { return fiber.NewError(fiber.StatusInternalServerError, err.Error()) } return c.SendStatus(fiber.StatusOK) }