deklarix/internal/store/registereintrag.go

package store

import (
	"context"
	"fmt"
	"time"
)

// Registereintrag wird automatisch bei jeder Genehmigung erzeugt
// (siehe CLAUDE.md, Entscheidung/Register/Wiedervorlage). Append-only
// — siehe Migration. Bewusst denormalisiert: eigene Textspalten statt
// Joins über bewertung/entscheidung/werkzeug, damit ein einmal
// erzeugter Eintrag nicht von einem späteren Katalog- oder Abteilungs-
// Wandel abhängt.
type Registereintrag struct {
	ID               string
	AccountID        string
	AntragID         string
	EntscheidungID   string
	Zweck            string
	Abteilung        string
	Werkzeug         string
	Datenklasse      string
	Einstufung       string
	Auflagen         []string
	Verantwortlicher string
	EntschiedenAm    time.Time
	GueltigBis       *time.Time
	CreatedAt        time.Time
}

const registereintragColumns = `id, account_id, antrag_id, entscheidung_id, zweck, abteilung, werkzeug,
	datenklasse, einstufung, auflagen, verantwortlicher, entschieden_am, gueltig_bis, created_at`

func scanRegistereintrag(row interface {
	Scan(dest ...any) error
}) (Registereintrag, error) {
	var e Registereintrag
	err := row.Scan(
		&e.ID, &e.AccountID, &e.AntragID, &e.EntscheidungID, &e.Zweck, &e.Abteilung, &e.Werkzeug,
		&e.Datenklasse, &e.Einstufung, &e.Auflagen, &e.Verantwortlicher, &e.EntschiedenAm, &e.GueltigBis, &e.CreatedAt,
	)
	return e, err
}

// RegistereintragInput bündelt die Felder eines neuen Registereintrags.
type RegistereintragInput struct {
	AccountID        string
	AntragID         string
	EntscheidungID   string
	Zweck            string
	Abteilung        string
	Werkzeug         string
	Datenklasse      string
	Einstufung       string
	Auflagen         []string
	Verantwortlicher string
	EntschiedenAm    time.Time
	GueltigBis       *time.Time
}

// CreateRegistereintrag speichert einen Registereintrag.
func (s *Store) CreateRegistereintrag(ctx context.Context, in RegistereintragInput) (Registereintrag, error) {
	if in.Auflagen == nil {
		in.Auflagen = []string{}
	}
	row := s.Pool.QueryRow(ctx, `
		INSERT INTO registereintrag (
			account_id, antrag_id, entscheidung_id, zweck, abteilung, werkzeug,
			datenklasse, einstufung, auflagen, verantwortlicher, entschieden_am, gueltig_bis
		) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12)
		RETURNING `+registereintragColumns,
		in.AccountID, in.AntragID, in.EntscheidungID, in.Zweck, in.Abteilung, in.Werkzeug,
		in.Datenklasse, in.Einstufung, in.Auflagen, in.Verantwortlicher, in.EntschiedenAm, in.GueltigBis,
	)
	e, err := scanRegistereintrag(row)
	if err != nil {
		return Registereintrag{}, fmt.Errorf("store: create registereintrag: %w", err)
	}
	return e, nil
}

// ListRegistereintraegeForAccount liefert alle Registereinträge eines
// Mandanten, neueste zuerst.
func (s *Store) ListRegistereintraegeForAccount(ctx context.Context, accountID string) ([]Registereintrag, error) {
	rows, err := s.Pool.Query(ctx, `
		SELECT `+registereintragColumns+` FROM registereintrag WHERE account_id = $1 ORDER BY entschieden_am DESC
	`, accountID)
	if err != nil {
		return nil, fmt.Errorf("store: list registereintraege for account: %w", err)
	}
	defer rows.Close()

	var out []Registereintrag
	for rows.Next() {
		e, err := scanRegistereintrag(rows)
		if err != nil {
			return nil, fmt.Errorf("store: scan registereintrag: %w", err)
		}
		out = append(out, e)
	}
	if err := rows.Err(); err != nil {
		return nil, fmt.Errorf("store: list registereintraege for account: %w", err)
	}
	return out, nil
}