Storyden

package settings_manager

import (
	"context"

	"github.com/Southclaws/fault"
	"github.com/Southclaws/fault/fctx"

	"github.com/Southclaws/storyden/app/resources/message"
	"github.com/Southclaws/storyden/app/resources/rbac"
	"github.com/Southclaws/storyden/app/resources/settings"
	"github.com/Southclaws/storyden/app/services/authentication/session"
	"github.com/Southclaws/storyden/internal/infrastructure/pubsub"
)

type Manager struct {
	repo *settings.SettingsRepository
	bus  *pubsub.Bus
}

func New(repo *settings.SettingsRepository, bus *pubsub.Bus) *Manager {
	return &Manager{
		repo: repo,
		bus:  bus,
	}
}

func (m *Manager) Get(ctx context.Context) (*settings.Settings, error) {
	s, err := m.repo.Get(ctx)
	if err != nil {
		return nil, fault.Wrap(err, fctx.With(ctx))
	}

	return s, nil
}

func (m *Manager) Set(ctx context.Context, s settings.Settings) (*settings.Settings, error) {
	if err := session.Authorise(ctx, nil, rbac.PermissionManageSettings, rbac.PermissionAdministrator); err != nil {
		return nil, fault.Wrap(err, fctx.With(ctx))
	}

	updated, err := m.repo.Set(ctx, s)
	if err != nil {
		return nil, fault.Wrap(err, fctx.With(ctx))
	}

	m.bus.Publish(ctx, &message.EventSettingsUpdated{
		Settings: updated,
	})

	return updated, nil
}