mirror of https://github.com/h44z/wg-portal.git
124 lines
3.2 KiB
Go
124 lines
3.2 KiB
Go
package backend
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
"github.com/h44z/wg-portal/internal/config"
|
|
"github.com/h44z/wg-portal/internal/domain"
|
|
)
|
|
|
|
type InterfaceServiceInterfaceManagerRepo interface {
|
|
GetAllInterfacesAndPeers(ctx context.Context) ([]domain.Interface, [][]domain.Peer, error)
|
|
GetInterfaceAndPeers(ctx context.Context, id domain.InterfaceIdentifier) (*domain.Interface, []domain.Peer, error)
|
|
PrepareInterface(ctx context.Context) (*domain.Interface, error)
|
|
CreateInterface(ctx context.Context, in *domain.Interface) (*domain.Interface, error)
|
|
UpdateInterface(ctx context.Context, in *domain.Interface) (*domain.Interface, []domain.Peer, error)
|
|
DeleteInterface(ctx context.Context, id domain.InterfaceIdentifier) error
|
|
}
|
|
|
|
type InterfaceService struct {
|
|
cfg *config.Config
|
|
|
|
interfaces InterfaceServiceInterfaceManagerRepo
|
|
users PeerServiceUserManagerRepo
|
|
}
|
|
|
|
func NewInterfaceService(cfg *config.Config, interfaces InterfaceServiceInterfaceManagerRepo) *InterfaceService {
|
|
return &InterfaceService{
|
|
cfg: cfg,
|
|
interfaces: interfaces,
|
|
}
|
|
}
|
|
|
|
func (s InterfaceService) GetAll(ctx context.Context) ([]domain.Interface, [][]domain.Peer, error) {
|
|
if err := domain.ValidateAdminAccessRights(ctx); err != nil {
|
|
return nil, nil, err
|
|
}
|
|
|
|
interfaces, interfacePeers, err := s.interfaces.GetAllInterfacesAndPeers(ctx)
|
|
if err != nil {
|
|
return nil, nil, err
|
|
}
|
|
|
|
return interfaces, interfacePeers, nil
|
|
}
|
|
|
|
func (s InterfaceService) GetById(ctx context.Context, id domain.InterfaceIdentifier) (
|
|
*domain.Interface,
|
|
[]domain.Peer,
|
|
error,
|
|
) {
|
|
if err := domain.ValidateAdminAccessRights(ctx); err != nil {
|
|
return nil, nil, err
|
|
}
|
|
|
|
interfaceData, interfacePeers, err := s.interfaces.GetInterfaceAndPeers(ctx, id)
|
|
if err != nil {
|
|
return nil, nil, err
|
|
}
|
|
|
|
return interfaceData, interfacePeers, nil
|
|
}
|
|
|
|
func (s InterfaceService) Prepare(ctx context.Context) (*domain.Interface, error) {
|
|
if err := domain.ValidateAdminAccessRights(ctx); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
interfaceData, err := s.interfaces.PrepareInterface(ctx)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return interfaceData, nil
|
|
}
|
|
|
|
func (s InterfaceService) Create(ctx context.Context, iface *domain.Interface) (*domain.Interface, error) {
|
|
if err := domain.ValidateAdminAccessRights(ctx); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
createdInterface, err := s.interfaces.CreateInterface(ctx, iface)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return createdInterface, nil
|
|
}
|
|
|
|
func (s InterfaceService) Update(ctx context.Context, id domain.InterfaceIdentifier, iface *domain.Interface) (
|
|
*domain.Interface,
|
|
[]domain.Peer,
|
|
error,
|
|
) {
|
|
if err := domain.ValidateAdminAccessRights(ctx); err != nil {
|
|
return nil, nil, err
|
|
}
|
|
|
|
if iface.Identifier != id {
|
|
return nil, nil, fmt.Errorf("interface id mismatch: %s != %s: %w",
|
|
iface.Identifier, id, domain.ErrInvalidData)
|
|
}
|
|
|
|
updatedInterface, updatedPeers, err := s.interfaces.UpdateInterface(ctx, iface)
|
|
if err != nil {
|
|
return nil, nil, err
|
|
}
|
|
|
|
return updatedInterface, updatedPeers, nil
|
|
}
|
|
|
|
func (s InterfaceService) Delete(ctx context.Context, id domain.InterfaceIdentifier) error {
|
|
if err := domain.ValidateAdminAccessRights(ctx); err != nil {
|
|
return err
|
|
}
|
|
|
|
err := s.interfaces.DeleteInterface(ctx, id)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|