package server import ( "fmt" "strings" "time" "git.solsynth.dev/hydrogen/interactive/pkg/database" "git.solsynth.dev/hydrogen/interactive/pkg/models" "git.solsynth.dev/hydrogen/interactive/pkg/services" "github.com/gofiber/fiber/v2" "github.com/google/uuid" ) func contextMoment() *services.PostTypeContext { return &services.PostTypeContext{ Tx: database.C, TableName: "moments", ColumnName: "moment", CanReply: false, CanRepost: true, } } func createMoment(c *fiber.Ctx) error { user := c.Locals("principal").(models.Account) var data struct { Alias string `json:"alias" form:"alias"` Content string `json:"content" form:"content" validate:"required,max=1024"` Hashtags []models.Tag `json:"hashtags" form:"hashtags"` Categories []models.Category `json:"categories" form:"categories"` Attachments []models.Attachment `json:"attachments" form:"attachments"` PublishedAt *time.Time `json:"published_at" form:"published_at"` RealmAlias string `json:"realm" form:"realm"` RepostTo uint `json:"repost_to" form:"repost_to"` } if err := BindAndValidate(c, &data); err != nil { return err } else if len(data.Alias) == 0 { data.Alias = strings.ReplaceAll(uuid.NewString(), "-", "") } item := &models.Moment{ PostBase: models.PostBase{ Alias: data.Alias, PublishedAt: data.PublishedAt, AuthorID: user.ID, }, Hashtags: data.Hashtags, Categories: data.Categories, Attachments: data.Attachments, Content: data.Content, } var relatedCount int64 if data.RepostTo > 0 { if err := database.C.Where("id = ?", data.RepostTo). Model(&models.Moment{}).Count(&relatedCount).Error; err != nil { return fiber.NewError(fiber.StatusBadRequest, err.Error()) } else if relatedCount <= 0 { return fiber.NewError(fiber.StatusNotFound, "related post was not found") } else { item.RepostID = &data.RepostTo } } if len(data.RealmAlias) > 0 { if realm, err := services.GetRealmWithAlias(data.RealmAlias); err != nil { return fiber.NewError(fiber.StatusBadRequest, err.Error()) } else if _, err := services.GetRealmMember(realm.ExternalID, user.ExternalID); err != nil { return fiber.NewError(fiber.StatusBadRequest, fmt.Sprintf("you aren't a part of related realm: %v", err)) } else { item.RealmID = &realm.ID } } item, err := services.NewPost(item) if err != nil { return fiber.NewError(fiber.StatusBadRequest, err.Error()) } return c.JSON(item) } func editMoment(c *fiber.Ctx) error { user := c.Locals("principal").(models.Account) id, _ := c.ParamsInt("momentId", 0) var data struct { Alias string `json:"alias" form:"alias" validate:"required"` Content string `json:"content" form:"content" validate:"required,max=1024"` PublishedAt *time.Time `json:"published_at" form:"published_at"` Hashtags []models.Tag `json:"hashtags" form:"hashtags"` Categories []models.Category `json:"categories" form:"categories"` Attachments []models.Attachment `json:"attachments" form:"attachments"` } if err := BindAndValidate(c, &data); err != nil { return err } var item *models.Moment if err := database.C.Where(models.Moment{ PostBase: models.PostBase{ BaseModel: models.BaseModel{ID: uint(id)}, AuthorID: user.ID, }, }).First(&item).Error; err != nil { return fiber.NewError(fiber.StatusNotFound, err.Error()) } item.Alias = data.Alias item.Content = data.Content item.PublishedAt = data.PublishedAt item.Hashtags = data.Hashtags item.Categories = data.Categories item.Attachments = data.Attachments if item, err := services.EditPost(item); err != nil { return fiber.NewError(fiber.StatusBadRequest, err.Error()) } else { return c.JSON(item) } } func deleteMoment(c *fiber.Ctx) error { user := c.Locals("principal").(models.Account) id, _ := c.ParamsInt("momentId", 0) var item *models.Moment if err := database.C.Where(models.Moment{ PostBase: models.PostBase{ BaseModel: models.BaseModel{ID: uint(id)}, AuthorID: user.ID, }, }).First(&item).Error; err != nil { return fiber.NewError(fiber.StatusNotFound, err.Error()) } if err := services.DeletePost(item); err != nil { return fiber.NewError(fiber.StatusBadRequest, err.Error()) } return c.SendStatus(fiber.StatusOK) }