Netpulse_SasS/server/internal/httpapi/telegram_link.go

package httpapi

import (
	"net/http"

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

// Прив'язка telegram-акаунта до користувача NetPulse.
//
// Навіщо це взагалі в API, адже саму прив'язку робить бот. Бот робить
// другу половину: він приймає код і зіставляє акаунти. Першу половину —
// «видати код тому, хто зараз увійшов» — може зробити лише те місце, де
// людина вже довела, ким вона є, тобто сесія в браузері.
//
// Права окремого немає навмисно. Прив'язка не дає нічого, чого людина
// не має в інтерфейсі: кнопка в Telegram виконує рівно ті самі дії й
// рівно з тими самими перевірками прав і доступу до хостів. Вимагати
// ще й окреме право означало б, що адміністратор має роздати його всім,
// хто вже має alerts:ack, — тобто зайвий крок без жодного рішення.

// handleGetTelegramLink — що показувати в профілі.
func (s *Server) handleGetTelegramLink(w http.ResponseWriter, r *http.Request, p *Principal) {
	if !p.IsUser() {
		writeError(w, http.StatusForbidden, "forbidden", "машинний токен не має профілю")
		return
	}
	link, err := s.store.TelegramLink(r.Context(), p.TenantID, p.UserID)
	if err != nil {
		s.log.Error("прив'язка telegram", "err", err)
		writeError(w, http.StatusInternalServerError, "internal", "внутрішня помилка")
		return
	}
	writeJSON(w, http.StatusOK, map[string]any{"link": link})
}

// handleCreateTelegramLinkCode видає одноразовий код.
//
// Код повертається рівно тут і більше ніде: у базі лежить лише його
// sha256, тож «показати ще раз» неможливо навіть теоретично — можна
// тільки взяти новий, і старий тоді згасне.
func (s *Server) handleCreateTelegramLinkCode(w http.ResponseWriter, r *http.Request, p *Principal) {
	if !p.IsUser() {
		writeError(w, http.StatusForbidden, "forbidden", "машинний токен не має профілю")
		return
	}

	code, expires, err := s.store.CreateTelegramLinkCode(r.Context(), p.TenantID, p.UserID)
	if err != nil {
		s.log.Error("код прив'язки telegram", "err", err)
		writeError(w, http.StatusInternalServerError, "internal", "внутрішня помилка")
		return
	}
	writeJSON(w, http.StatusOK, map[string]any{
		"code":       code,
		"expires_at": expires,
		// Команду складає сервер, а не браузер: формат розбирає бот
		// (parseLinkCommand), і дві його копії розійшлися б рівно тоді,
		// коли формат зміниться.
		"command": "/link " + code,
	})
}

// handleDeleteTelegramLink знімає прив'язку.
//
// Разом із нею гаснуть і невикористані коди: лишити чинний код після
// «відв'язати» означало б, що прив'язка повертається сама, варто
// комусь надіслати боту рядок, який людина вже вважає скасованим.
func (s *Server) handleDeleteTelegramLink(w http.ResponseWriter, r *http.Request, p *Principal) {
	if !p.IsUser() {
		writeError(w, http.StatusForbidden, "forbidden", "машинний токен не має профілю")
		return
	}

	link, err := s.store.TelegramLink(r.Context(), p.TenantID, p.UserID)
	if err != nil {
		s.log.Error("прив'язка telegram", "err", err)
		writeError(w, http.StatusInternalServerError, "internal", "внутрішня помилка")
		return
	}
	if err := s.store.UnlinkTelegram(r.Context(), p.TenantID, p.UserID); err != nil {
		s.log.Error("зняття прив'язки telegram", "err", err)
		writeError(w, http.StatusInternalServerError, "internal", "внутрішня помилка")
		return
	}
	if link != nil {
		_ = s.store.WriteAudit(r.Context(), p.TenantID, store.AuditEntry{
			ActorUserID: p.UserID,
			ActorIP:     clientIP(r),
			Action:      store.AuditActionTelegramUnlink,
			ObjectType:  store.AuditObjectTelegram,
			ObjectID:    link.ID,
			Meta:        map[string]any{"tg_user_id": link.TgUserID, "tg_username": link.TgUsername},
		})
	}
	w.WriteHeader(http.StatusNoContent)
}