140 lines
3.8 KiB
Go
140 lines
3.8 KiB
Go
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
|
|
|
|
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 {
|
|
user := c.Locals("user").(models.Account)
|
|
if err := exts.EnsureAuthenticated(c); err != nil {
|
|
return err
|
|
}
|
|
|
|
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)
|
|
}
|