mirror of
https://github.com/emo2007/block-accounting.git
synced 2025-04-12 08:56:28 +00:00
87 lines
2.5 KiB
Go
87 lines
2.5 KiB
Go
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"
|
|
)
|
|
|
|
type OrganizationsController interface {
|
|
NewOrganization(w http.ResponseWriter, r *http.Request) ([]byte, error)
|
|
ListOrganizations(w http.ResponseWriter, r *http.Request) ([]byte, error)
|
|
}
|
|
|
|
type organizationsController struct {
|
|
log *slog.Logger
|
|
orgInteractor organizations.OrganizationsInteractor
|
|
presenter presenters.OrganizationsPresenter
|
|
}
|
|
|
|
func NewOrganizationsController(
|
|
log *slog.Logger,
|
|
orgInteractor organizations.OrganizationsInteractor,
|
|
presenter presenters.OrganizationsPresenter,
|
|
) OrganizationsController {
|
|
return &organizationsController{
|
|
log: log,
|
|
orgInteractor: orgInteractor,
|
|
presenter: presenter,
|
|
}
|
|
}
|
|
|
|
func (c *organizationsController) NewOrganization(w http.ResponseWriter, r *http.Request) ([]byte, error) {
|
|
req, err := presenters.CreateRequest[domain.NewOrganizationRequest](r)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("error build request. %w", err)
|
|
}
|
|
|
|
ctx, cancel := context.WithTimeout(r.Context(), 3*time.Second)
|
|
defer cancel()
|
|
|
|
org, err := c.orgInteractor.Create(ctx, organizations.CreateParams{
|
|
Name: req.Name,
|
|
Address: req.Address,
|
|
WalletMnemonic: req.WalletMnemonic,
|
|
})
|
|
if err != nil {
|
|
return nil, fmt.Errorf("error create new organization. %w", err)
|
|
}
|
|
|
|
return c.presenter.ResponseCreate(org)
|
|
}
|
|
|
|
func (c *organizationsController) ListOrganizations(w http.ResponseWriter, r *http.Request) ([]byte, error) {
|
|
req, err := presenters.CreateRequest[domain.ListOrganizationsRequest](r)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("error build request. %w", err)
|
|
}
|
|
|
|
ctx, cancel := context.WithTimeout(r.Context(), 3*time.Second)
|
|
defer cancel()
|
|
|
|
user, err := ctxmeta.User(ctx)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("error fetch user from context. %w", err)
|
|
}
|
|
|
|
// BUG: empty created_at and updfated_at
|
|
resp, err := c.orgInteractor.List(ctx, organizations.ListParams{
|
|
UserId: user.Id(),
|
|
Cursor: req.Cursor,
|
|
Limit: req.Limit,
|
|
OffsetDate: time.UnixMilli(req.OffsetDate),
|
|
})
|
|
if err != nil {
|
|
return nil, fmt.Errorf("error fetch organizations list. %w", err)
|
|
}
|
|
|
|
return c.presenter.ResponseList(resp.Organizations, resp.NextCursor)
|
|
}
|