129 lines
3.1 KiB
Go
129 lines
3.1 KiB
Go
package api
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"github.com/TicketsBot/GoPanel/botcontext"
|
|
dbclient "github.com/TicketsBot/GoPanel/database"
|
|
"github.com/TicketsBot/GoPanel/rpc/cache"
|
|
"github.com/TicketsBot/GoPanel/utils"
|
|
"github.com/TicketsBot/database"
|
|
"github.com/apex/log"
|
|
"github.com/gin-gonic/gin"
|
|
"github.com/rxdn/gdl/rest"
|
|
"strconv"
|
|
)
|
|
|
|
const (
|
|
pageLimit = 30
|
|
)
|
|
|
|
func GetLogs(ctx *gin.Context) {
|
|
guildId := ctx.Keys["guildid"].(uint64)
|
|
|
|
botContext, err := botcontext.ContextForGuild(guildId)
|
|
if err != nil {
|
|
ctx.AbortWithStatusJSON(500, gin.H{
|
|
"success": false,
|
|
"error": err.Error(),
|
|
})
|
|
return
|
|
}
|
|
|
|
before, err := strconv.Atoi(ctx.Query("before"))
|
|
if before < 0 {
|
|
before = 0
|
|
}
|
|
|
|
// Get ticket ID from URL
|
|
var ticketId int
|
|
if utils.IsInt(ctx.Query("ticketid")) {
|
|
ticketId, _ = strconv.Atoi(ctx.Query("ticketid"))
|
|
}
|
|
|
|
var tickets []database.Ticket
|
|
|
|
// Get tickets from DB
|
|
if ticketId > 0 {
|
|
ticket, err := dbclient.Client.Tickets.Get(ticketId, guildId)
|
|
if err != nil {
|
|
ctx.AbortWithStatusJSON(500, gin.H{
|
|
"success": false,
|
|
"error": err.Error(),
|
|
})
|
|
return
|
|
}
|
|
|
|
if ticket.UserId != 0 && !ticket.Open {
|
|
tickets = append(tickets, ticket)
|
|
}
|
|
} else {
|
|
// make slice of user IDs to filter by
|
|
filteredIds := make([]uint64, 0)
|
|
|
|
// Add userid param to slice
|
|
filteredUserId, _ := strconv.ParseUint(ctx.Query("userid"), 10, 64)
|
|
if filteredUserId != 0 {
|
|
filteredIds = append(filteredIds, filteredUserId)
|
|
}
|
|
|
|
// Get username from URL
|
|
if username := ctx.Query("username"); username != "" {
|
|
// username -> user id
|
|
rows, err := cache.Instance.PgCache.Query(context.Background(), `select users.user_id from users where LOWER("data"->>'Username') LIKE LOWER($1) and exists(SELECT FROM members where members.guild_id=$2);`, fmt.Sprintf("%%%s%%", username), guildId)
|
|
defer rows.Close()
|
|
if err != nil {
|
|
log.Error(err.Error())
|
|
return
|
|
}
|
|
|
|
for rows.Next() {
|
|
var filteredId uint64
|
|
if err := rows.Scan(&filteredId); err != nil {
|
|
continue
|
|
}
|
|
|
|
if filteredId != 0 {
|
|
filteredIds = append(filteredIds, filteredId)
|
|
}
|
|
}
|
|
}
|
|
|
|
if ctx.Query("userid") != "" || ctx.Query("username") != "" {
|
|
tickets, err = dbclient.Client.Tickets.GetMemberClosedTickets(guildId, filteredIds, pageLimit, before)
|
|
} else {
|
|
tickets, err = dbclient.Client.Tickets.GetGuildClosedTickets(guildId, pageLimit, before)
|
|
}
|
|
|
|
if err != nil {
|
|
ctx.AbortWithStatusJSON(500, gin.H{
|
|
"success": false,
|
|
"error": err.Error(),
|
|
})
|
|
return
|
|
}
|
|
}
|
|
|
|
// Select 30 logs + format them
|
|
formattedLogs := make([]map[string]interface{}, 0)
|
|
for _, ticket := range tickets {
|
|
// get username
|
|
user, found := cache.Instance.GetUser(ticket.UserId)
|
|
if !found {
|
|
user, err = rest.GetUser(botContext.Token, botContext.RateLimiter, ticket.UserId)
|
|
if err != nil {
|
|
log.Error(err.Error())
|
|
}
|
|
go cache.Instance.StoreUser(user)
|
|
}
|
|
|
|
formattedLogs = append(formattedLogs, map[string]interface{}{
|
|
"ticketid": ticket.Id,
|
|
"userid": strconv.FormatUint(ticket.UserId, 10),
|
|
"username": user.Username,
|
|
})
|
|
}
|
|
|
|
ctx.JSON(200, formattedLogs)
|
|
}
|