block-accounting/backend/internal/interface/rest/controllers/participants.go

123 lines
3.5 KiB
Go
Raw Permalink Normal View History

2024-05-24 17:44:24 +00:00
package controllers
import (
"context"
"fmt"
"log/slog"
"net/http"
"time"
"github.com/emochka2007/block-accounting/internal/interface/rest/domain"
"github.com/emochka2007/block-accounting/internal/interface/rest/presenters"
"github.com/emochka2007/block-accounting/internal/pkg/ctxmeta"
"github.com/emochka2007/block-accounting/internal/usecase/interactors/organizations"
"github.com/emochka2007/block-accounting/internal/usecase/interactors/users"
"github.com/google/uuid"
)
type ParticipantsController interface {
List(w http.ResponseWriter, r *http.Request) ([]byte, error)
2024-05-24 22:45:56 +00:00
New(w http.ResponseWriter, r *http.Request) ([]byte, error)
2024-05-24 17:44:24 +00:00
}
type participantsController struct {
log *slog.Logger
orgInteractor organizations.OrganizationsInteractor
usersInteractor users.UsersInteractor
presenter presenters.ParticipantsPresenter
}
func NewParticipantsController(
log *slog.Logger,
orgInteractor organizations.OrganizationsInteractor,
usersInteractor users.UsersInteractor,
presenter presenters.ParticipantsPresenter,
) ParticipantsController {
return &participantsController{
log: log,
orgInteractor: orgInteractor,
usersInteractor: usersInteractor,
presenter: presenter,
}
}
func (c *participantsController) List(w http.ResponseWriter, r *http.Request) ([]byte, error) {
req, err := presenters.CreateRequest[domain.ListParticipantsRequest](r)
if err != nil {
return nil, fmt.Errorf("error build list participants request. %w", err)
}
user, err := ctxmeta.User(r.Context())
if err != nil {
return nil, fmt.Errorf("error fetch user from context. %w", err)
}
organizationID, err := ctxmeta.OrganizationId(r.Context())
if err != nil {
return nil, fmt.Errorf("error fetch organization id from context. %w", err)
}
ctx, cancel := context.WithTimeout(r.Context(), 3*time.Second)
defer cancel()
participant, err := c.orgInteractor.Participant(ctx, organizations.ParticipantParams{
ID: user.Id(),
OrganizationID: organizationID,
})
if err != nil {
return nil, fmt.Errorf("error fetch user participant. %w", err)
}
if !participant.IsActive() {
return nil, fmt.Errorf("error participant is inactive")
}
ids := make(uuid.UUIDs, len(req.IDs))
for i, id := range req.IDs {
uid, err := uuid.Parse(id)
if err != nil {
return nil, fmt.Errorf("error parse participant id. %w", err)
}
ids[i] = uid
}
participants, err := c.orgInteractor.Participants(ctx, organizations.ParticipantsParams{
IDs: ids,
OrganizationID: organizationID,
})
if err != nil {
return nil, fmt.Errorf("error fetch participants. %w", err)
}
return c.presenter.ResponseListParticipants(ctx, participants)
}
2024-05-24 22:45:56 +00:00
func (c *participantsController) New(w http.ResponseWriter, r *http.Request) ([]byte, error) {
req, err := presenters.CreateRequest[domain.AddEmployeeRequest](r)
if err != nil {
return nil, fmt.Errorf("error build list participants request. %w", err)
}
organizationID, err := ctxmeta.OrganizationId(r.Context())
if err != nil {
return nil, fmt.Errorf("error fetch organization id from context. %w", err)
}
2024-05-27 18:08:19 +00:00
ctx, cancel := context.WithTimeout(r.Context(), 5*time.Second)
2024-05-24 22:45:56 +00:00
defer cancel()
2024-05-27 18:08:19 +00:00
participant, err := c.orgInteractor.AddEmployee(ctx, organizations.AddParticipantParams{
2024-05-24 22:45:56 +00:00
OrganizationID: organizationID,
Name: req.Name,
Position: req.Position,
WalletAddress: req.WalletAddress,
})
if err != nil {
return nil, fmt.Errorf("error create new participant. %w", err)
}
return c.presenter.ResponseParticipant(ctx, participant)
}