Netpulse_SasS/server/internal/store/audit.go

package store

import (
	"context"
	"encoding/json"
	"net"
)

// Журнал аудиту.
//
// Таблиця core.audit_log існує з першої міграції, але доти в неї ніхто
// не писав: усі дії, які встигли з'явитись, або оборотні (правка мапи,
// перейменування хоста), або й так видимі в самому об'єкті. Масове
// виконання команд — перша дія, яка нічого по собі не лишає: команда
// пішла, пристрій відповів, слід є тільки тут.
//
// Через це запис аудиту тут не «на всяк випадок», а частина функції:
// без нього питання «хто о третій ночі прогнав це по дільниці» не має
// відповіді взагалі.

// AuditEntry — один рядок журналу.
//
// Actor окремими полями, а не одним «хто»: за токеном інтеграції немає
// людини, і зводити їх до рядка означало б втратити різницю між
// «інженер натиснув кнопку» і «скрипт ходить нашим API».
type AuditEntry struct {
	ActorUserID  string
	ActorTokenID string
	ActorIP      net.IP

	// Дія у вигляді «об'єкт.дія»: ncm.command_run.create.
	Action     string
	ObjectType string
	ObjectID   string

	// Meta несе те, що робить рядок зрозумілим без доступу до решти
	// таблиць: самі команди, кількість хостів, їхні імена. Через рік
	// хостів може вже не бути, а питання лишиться.
	Meta map[string]any
}

// WriteAudit кладе подію в журнал.
//
// Пише в пул напряму, а не в тенантній транзакції: core.audit_log —
// гіпертаблиця, RLS на ній вимкнено (див. 0011), тому ізоляцію тримає
// сам предикат tenant_id у запитах читання.
func (s *Store) WriteAudit(ctx context.Context, tenantID string, e AuditEntry) error {
	meta := []byte("{}")
	if len(e.Meta) > 0 {
		b, err := json.Marshal(e.Meta)
		if err != nil {
			return err
		}
		meta = b
	}

	var ip any
	if e.ActorIP != nil {
		ip = e.ActorIP.String()
	}

	_, err := s.pool.Exec(ctx, `
		INSERT INTO core.audit_log
			(tenant_id, actor_user_id, actor_token_id, actor_ip,
			 action, object_type, object_id, meta)
		VALUES ($1, $2, $3, $4::inet, $5, $6, $7, $8::jsonb)
	`, tenantID, nullUUID(e.ActorUserID), nullUUID(e.ActorTokenID), ip,
		e.Action, nullString(e.ObjectType), nullUUID(e.ObjectID), string(meta))
	return err
}