libredesk/cmd/teams.go

package main

import (
	"strconv"

	"github.com/abhinavxd/libredesk/internal/envelope"
	"github.com/abhinavxd/libredesk/internal/team/models"
	"github.com/valyala/fasthttp"
	"github.com/zerodha/fastglue"
)

// handleGetTeams returns a list of all teams.
func handleGetTeams(r *fastglue.Request) error {
	var (
		app = r.Context.(*App)
	)
	teams, err := app.team.GetAll()
	if err != nil {
		return sendErrorEnvelope(r, err)
	}
	return r.SendEnvelope(teams)
}

// handleGetTeamsCompact returns teams in a compact format, all of them without page params.
func handleGetTeamsCompact(r *fastglue.Request) error {
	var (
		app   = r.Context.(*App)
		query = string(r.RequestCtx.QueryArgs().Peek("q"))
	)
	if ids := getIDsParam(r, "ids"); len(ids) > 0 {
		teams, err := app.team.GetAllCompactByIDs(ids)
		if err != nil {
			return sendErrorEnvelope(r, err)
		}
		return r.SendEnvelope(teams)
	}
	page, pageSize := getOptionalPagination(r)
	teams, err := app.team.GetAllCompact(query, page, pageSize)
	if err != nil {
		return sendErrorEnvelope(r, err)
	}
	return r.SendEnvelope(teams)
}

// handleGetTeam returns a single team.
func handleGetTeam(r *fastglue.Request) error {
	var (
		app   = r.Context.(*App)
		id, _ = strconv.Atoi(r.RequestCtx.UserValue("id").(string))
	)
	if id < 1 {
		return r.SendErrorEnvelope(fasthttp.StatusBadRequest, app.i18n.T("globals.messages.somethingWentWrong"), nil, envelope.InputError)
	}
	team, err := app.team.Get(id)
	if err != nil {
		return sendErrorEnvelope(r, err)
	}
	return r.SendEnvelope(team)
}

// handleCreateTeam creates a new team.
func handleCreateTeam(r *fastglue.Request) error {
	var (
		app = r.Context.(*App)
		req = models.Team{}
	)

	if err := r.Decode(&req, "json"); err != nil {
		return sendErrorEnvelope(r, envelope.NewError(envelope.InputError, app.i18n.T("errors.parsingRequest"), nil))
	}

	createdTeam, err := app.team.Create(req.Name, req.Timezone, req.ConversationAssignmentType, req.BusinessHoursID, req.SLAPolicyID, req.Emoji.String, req.MaxAutoAssignedConversations)
	if err != nil {
		return sendErrorEnvelope(r, err)
	}
	return r.SendEnvelope(createdTeam)
}

// handleUpdateTeam updates an existing team.
func handleUpdateTeam(r *fastglue.Request) error {
	var (
		app   = r.Context.(*App)
		id, _ = strconv.Atoi(r.RequestCtx.UserValue("id").(string))
		req   = models.Team{}
	)

	if id < 1 {
		return r.SendErrorEnvelope(fasthttp.StatusBadRequest, app.i18n.T("globals.messages.somethingWentWrong"), nil, envelope.InputError)
	}

	if err := r.Decode(&req, "json"); err != nil {
		return sendErrorEnvelope(r, envelope.NewError(envelope.InputError, app.i18n.T("errors.parsingRequest"), nil))
	}

	updatedTeam, err := app.team.Update(id, req.Name, req.Timezone, req.ConversationAssignmentType, req.BusinessHoursID, req.SLAPolicyID, req.Emoji.String, req.MaxAutoAssignedConversations)
	if err != nil {
		return sendErrorEnvelope(r, err)
	}
	members, err := app.team.GetMembers(id)
	if err != nil {
		app.lo.Error("error fetching team members for cache invalidation", "team_id", id, "error", err)
	} else {
		for _, m := range members {
			app.user.InvalidateAgentCache(m.ID)
		}
	}
	return r.SendEnvelope(updatedTeam)
}

// handleDeleteTeam deletes a team
func handleDeleteTeam(r *fastglue.Request) error {
	var (
		app = r.Context.(*App)
	)
	id, err := strconv.Atoi(r.RequestCtx.UserValue("id").(string))
	if err != nil || id == 0 {
		return r.SendErrorEnvelope(fasthttp.StatusBadRequest, app.i18n.T("globals.messages.somethingWentWrong"), nil, envelope.InputError)
	}
	memberIDs, err := app.team.Delete(id)
	if err != nil {
		return sendErrorEnvelope(r, err)
	}
	for _, mid := range memberIDs {
		app.user.InvalidateAgentCache(mid)
	}
	return r.SendEnvelope(true)
}