Separate list public channel

This commit is contained in:
LittleSheep 2025-02-15 15:55:06 +08:00
parent 406eb9c93b
commit 2e18b2455b
3 changed files with 33 additions and 0 deletions

View File

@ -76,6 +76,21 @@ func listChannel(c *fiber.Ctx) error {
return c.JSON(channels) return c.JSON(channels)
} }
func listPublicChannel(c *fiber.Ctx) error {
var err error
var channels []models.Channel
if val, ok := c.Locals("realm").(authm.Realm); ok {
channels, err = services.ListChannelPublic(val.ID)
} else {
channels, err = services.ListChannelPublic()
}
if err != nil {
return fiber.NewError(fiber.StatusBadRequest, err.Error())
}
return c.JSON(channels)
}
func listOwnedChannel(c *fiber.Ctx) error { func listOwnedChannel(c *fiber.Ctx) error {
if err := sec.EnsureAuthenticated(c); err != nil { if err := sec.EnsureAuthenticated(c); err != nil {
return err return err

View File

@ -15,6 +15,7 @@ func MapAPIs(app *fiber.App, baseURL string) {
channels := api.Group("/channels/:realm").Use(realmMiddleware).Name("Channels API") channels := api.Group("/channels/:realm").Use(realmMiddleware).Name("Channels API")
{ {
channels.Get("/", listChannel) channels.Get("/", listChannel)
channels.Get("/public", listPublicChannel)
channels.Get("/me", listOwnedChannel) channels.Get("/me", listOwnedChannel)
channels.Get("/me/available", listAvailableChannel) channels.Get("/me/available", listAvailableChannel)
channels.Get("/:channel", getChannel) channels.Get("/:channel", getChannel)

View File

@ -207,6 +207,23 @@ func ListChannel(user *authm.Account, realmId ...uint) ([]models.Channel, error)
return channels, nil return channels, nil
} }
func ListChannelPublic(realmId ...uint) ([]models.Channel, error) {
var channels []models.Channel
tx := database.C
tx = tx.Where("is_public = true")
if len(realmId) > 0 {
tx = tx.Where("realm_id = ?", realmId)
}
tx = PreloadDirectChannelMembers(tx)
if err := tx.Find(&channels).Error; err != nil {
return channels, err
}
return channels, nil
}
func ListChannelWithUser(user authm.Account, realmId ...uint) ([]models.Channel, error) { func ListChannelWithUser(user authm.Account, realmId ...uint) ([]models.Channel, error) {
var channels []models.Channel var channels []models.Channel
tx := database.C.Where(&models.Channel{AccountID: user.ID}) tx := database.C.Where(&models.Channel{AccountID: user.ID})