Netpulse_SasS/server/internal/httpapi/ncm_localfiles.go

package httpapi

import (
	"encoding/json"
	"errors"
	"net/http"

	"github.com/netpulse/netpulse/server/internal/store"
)

// Конфіг-файли серверів: хости, які збирають самі себе.
//
// Ручок рівно три, і жодна з них не приймає шляху до файлу. Це не
// економія, а суть задачі: зонд читає файли машини своїми правами, і
// поле «які саме», кероване з кабінету, дало б будь-кому з правом
// ncm:write читання довільного файлу на ВСІХ серверах клієнта одразу.
// Перелік файлів живе лише в локальному конфізі зонда, і в HTTP-шарі
// його не видно взагалі — ані щоб задати, ані щоб прочитати.
//
// Збір «зараз» і збір за розкладом навмисно НЕ мають тут своїх ручок:
// і те, і те вже робить ncm.jobs через handleCollectConfig і
// ScheduleBackups. Друга кнопка «зібрати файли» означала б другу чергу
// й другий розклад, які довелося б тримати узгодженими вручну.

// handleListServerFiles — сторінка «Конфіги серверів».
func (s *Server) handleListServerFiles(w http.ResponseWriter, r *http.Request, p *Principal) {
	if !requirePerm(w, p, "ncm:read") {
		return
	}

	devices, err := s.store.ListSelfDevices(r.Context(), p.TenantID, p.Scope())
	if err != nil {
		s.writeStoreError(w, "перелік серверів зі збором файлів", err)
		return
	}
	if devices == nil {
		devices = []store.SelfDeviceRow{}
	}

	// Довідник зондів їде разом зі списком, а не окремим запитом: він
	// потрібен рівно тут, у формі прив'язки, і другий похід у мережу
	// заради десятка рядків подвоїв би затримку відкриття сторінки.
	agents, err := s.store.SelfAgentOptions(r.Context(), p.TenantID)
	if err != nil {
		s.writeStoreError(w, "перелік зондів", err)
		return
	}
	if agents == nil {
		agents = []store.SelfAgentOption{}
	}

	writeJSON(w, http.StatusOK, map[string]any{
		"devices": devices,
		"agents":  agents,
	})
}

// handleSetSelfAgent оголошує хост машиною зонда.
//
// Право devices:write, а не ncm:write, і це не дрібниця. ncm:write
// означає «може міняти розклад збору» — дія про час, а не про предмет.
// Тут же вирішується, ЩО саме є цим хостом: картка перестає бути
// записом про залізо в мережі й починає означати конкретну машину.
// Заразом дія переставляє inv.devices.agent_id, тобто змінює інвентар.
func (s *Server) handleSetSelfAgent(w http.ResponseWriter, r *http.Request, p *Principal) {
	if !requirePerm(w, p, "devices:write") {
		return
	}
	deviceID := r.PathValue("id")
	if !p.Scope().CanWrite(deviceID) {
		writeError(w, http.StatusForbidden, "forbidden", "немає доступу до цього хоста")
		return
	}

	var body struct {
		AgentID string `json:"agent_id"`
	}
	if err := json.NewDecoder(r.Body).Decode(&body); err != nil || body.AgentID == "" {
		writeError(w, http.StatusBadRequest, "bad_json", "не вказано зонда")
		return
	}

	if err := s.store.BindSelfDevice(r.Context(), p.TenantID, deviceID, body.AgentID); err != nil {
		if errors.Is(err, store.ErrNotFound) {
			writeError(w, http.StatusNotFound, "not_found", "хост не знайдено")
			return
		}
		s.writeStoreError(w, "прив'язка хоста до власного зонда", err)
		return
	}

	s.auditSelfAgent(r, p, store.AuditActionDeviceSelfAgent, deviceID,
		map[string]any{"agent_id": body.AgentID})
	writeJSON(w, http.StatusOK, map[string]any{"ok": true})
}

// handleClearSelfAgent знімає прив'язку.
//
// Вона ж і єдиний спосіб перезакріпити відбиток машини: зонд,
// перенесений на інший сервер, отримає відмову в прийомі набору доти,
// доки людина свідомо не зніме й не поставить прив'язку заново. Автомат
// «ну добре, значить переїхав» зробив би всю перевірку декоративною.
func (s *Server) handleClearSelfAgent(w http.ResponseWriter, r *http.Request, p *Principal) {
	if !requirePerm(w, p, "devices:write") {
		return
	}
	deviceID := r.PathValue("id")
	if !p.Scope().CanWrite(deviceID) {
		writeError(w, http.StatusForbidden, "forbidden", "немає доступу до цього хоста")
		return
	}

	if err := s.store.UnbindSelfDevice(r.Context(), p.TenantID, deviceID); err != nil {
		if errors.Is(err, store.ErrNotFound) {
			writeError(w, http.StatusNotFound, "not_found", "хост не знайдено")
			return
		}
		s.writeStoreError(w, "зняття прив'язки хоста до зонда", err)
		return
	}

	s.auditSelfAgent(r, p, store.AuditActionDeviceSelfAgentUn, deviceID, nil)
	writeJSON(w, http.StatusOK, map[string]any{"ok": true})
}

func (s *Server) auditSelfAgent(r *http.Request, p *Principal, action, deviceID string, meta map[string]any) {
	if err := s.store.WriteAudit(r.Context(), p.TenantID, store.AuditEntry{
		ActorUserID:  p.UserID,
		ActorTokenID: p.TokenID,
		ActorIP:      clientIP(r),
		Action:       action,
		ObjectType:   store.AuditObjectDevice,
		ObjectID:     deviceID,
		Meta:         meta,
	}); err != nil {
		s.log.Error("аудит прив'язки хоста до зонда", "дія", action, "хост", deviceID, "err", err)
	}
}