Netpulse_SasS/server/internal/gitstore/branches.go
byrsapty ed8fc831bf Дві сесії роботи: 0058–0068, розгортання однією командою, тести
Один коміт, а не десяток тематичних, свідомо: теми переплетені в
спільних файлах (store.go, docker-compose.yml, deploy/README.md), і
розділити їх можна було б лише індексуванням шматків. Коміти, які не
збираються, гірші за один великий — тим паче що це рівно той стан, який
перевірявся разом.

ЩО ПРАЦЮЄ НА СТЕНДІ Й ПЕРЕВІРЕНО ТАМ

  0058  подієві алерти: syslog, ncm, compliance спрацьовують у мить
        події; правило з нереалізованим джерелом більше не зберігається
        мовчки
  0059  snmp.walk і прототипи шаблонів — таблиці з динамічним індексом
        описуються шаблоном, а не Go
  0060  відкат конфігу: план як різниця, маскування паролів із підписом
        плану, обов'язковий контрольний збір, verifying при обриві
  0061  кнопки Telegram: довге опитування, авторизація не з callback_data
  0062  аудит і архів хостів; тест на AST, що падає на ключі без назви
  0063  RLS: три ролі, окремий пул для фонових тактів
  0064  строки зберігання даних і сторінка сховища
  0065  приймач SNMP-трапів; перевірено справжніми пакетами по дроту,
        переклад v1→v2 за RFC 3584 дає правильний OID
  0066  ескалації сповіщень
  0067  алерт про вичерпання диска
  0068  поля заливки конфігу переїхали в каталог профілів

Плюс: 137 тестів вебу з нуля (їх не було взагалі), одинадцять справжніх
вад, знайдених ними й виправлених, і виправлення двох інтеграційних
тестів grpcapi, які мовчки пропускались півтора року.

ЩО ЩЕ НЕ ЗАПУСКАЛОСЬ

  netpulse            установник: одна команда замість 18 змінних і
                      593 рядків інструкції
  RLS з першого запуску  нова інсталяція під політиками одразу;
                      RLS-EXISTING-INSTALL.md лишається тільки для
                      старих інсталяцій
  .forgejo + CI       раннер не зареєстрований

Ці три перевірені компіляцією й міркуванням, але не виконанням.

ГОЛОВНИЙ ВИСНОВОК ДВОХ СЕСІЙ

Зелена перевірка доводить рівно те, що вона перевіряє. Тест ізоляції RLS
був правильний і зелений — і пропустив зламаний вхід, бо перевіряв «чи
не видно чужого», коли зламалось «чи видно своє». Інтеграційні тести
grpcapi були зелені, бо не виконувались. Схема, довідник і протокол
описували те, чого в коді не існувало, і виглядало це як готове.

Тому в кожному завданні цих сесій стояла вимога назвати НЕПОКРИТЕ, а
чотири задачі закінчились не можливістю, а відмовою: правило з
нереалізованим джерелом не зберігається, профіль без команд заливки
каже про це замість мовчазної кнопки, міграція RLS валить сама себе на
таблиці без політики, тест словника аудиту падає на ключі без назви.

Подробиці — HISTORY.md, розділи за 26 і 27 серпня.
2026-08-27 17:32:49 +03:00

180 lines
7.6 KiB
Go
Raw Permalink Blame History

This file contains ambiguous Unicode characters

This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

package gitstore
import (
"context"
"errors"
"fmt"
"path/filepath"
"strings"
"github.com/go-git/go-git/v5"
"github.com/go-git/go-git/v5/config"
"github.com/go-git/go-git/v5/plumbing"
)
// Видалення гілки пристрою — локально й на дзеркалі.
//
// Поруч із RenameBranch і з тієї ж причини: ім'я гілки складається з
// імені та адреси хоста, тож усе, що відбувається з хостом, рано чи
// пізно доходить сюди. Перейменування вже дійшло; видалення — друга
// половина тієї ж думки.
//
// ГОЛОВНЕ РІШЕННЯ ФАЙЛУ — те, чого тут немає: prune.
//
// Спокуса очевидна: дзеркалення й так знає обидва боки, і один прапорець
// `--prune` прибирав би на тому кінці все, чого немає тут. Саме тому
// його тут і немає. Дзеркало заводять на випадок втрати локального
// диска. Репозиторій, який пошкодився або відкотився до вчорашнього
// стану, з prune миттєво знищив би віддалену копію — тобто рівно ту, по
// яку в цей момент прийшли. Механізм, здатний стерти копію на підставі
// стану оригіналу, копією не є.
//
// Тому видалення адресне: система знає ім'я гілки, яку щойно прибрала,
// і надсилає видалення рівно цієї гілки. Усе, чого вона не називала
// явно, на дзеркалі лишається — включно з гілками, про які вона нічого
// не знає.
// DeleteBranch прибирає локальну гілку.
//
// Повертає false, якщо гілки не було. Це не помилка: пристрій міг ніколи
// не комітитись, а видалення — повторюватись (черга видалень повторює
// спробу, доки не дійде до дзеркала).
//
// Історія при цьому не зникає з диска одразу: Git тримає об'єкти доти,
// доки їх не збере gc. Це не недоробка, а властивість формату — обіцяти
// «конфіги стерто з диска» на підставі знятого посилання було б
// неправдою. Тіла конфігів прибираються там, де вони справді лежать, —
// у core.secrets (див. store.deleteConfigRows).
func (s *Store) DeleteBranch(repoName, branch string) (bool, error) {
if s.root == "" {
return false, ErrDisabled
}
if strings.TrimSpace(branch) == "" {
return false, nil
}
path := filepath.Join(s.root, repoName)
mu := s.lockFor(path)
mu.Lock()
defer mu.Unlock()
repo, err := open(path)
if err != nil {
if errors.Is(err, git.ErrRepositoryNotExists) {
// Репозиторію немає — прибирати нічого. Так виглядає
// інсталяція, у якій жодного конфігу ще не зібрано.
return false, nil
}
return false, err
}
ref := plumbing.NewBranchReferenceName(branch)
if _, err := repo.Reference(ref, false); err != nil {
if errors.Is(err, plumbing.ErrReferenceNotFound) {
return false, nil
}
return false, fmt.Errorf("гілка %s: %w", branch, err)
}
if err := repo.Storer.RemoveReference(ref); err != nil {
return false, fmt.Errorf("прибрати гілку %s: %w", branch, err)
}
return true, nil
}
// DeleteRemoteRefs просить дзеркало прибрати названі гілки.
//
// Refspec виду ":refs/heads/<гілка>" — порожній лівий бік і є
// видаленням. Кожна гілка називається окремо: шаблон тут неможливий за
// побудовою, і це та сама відмінність від mirrorRefSpec, заради якої
// написано весь файл.
//
// Atomic НЕ вмикається, на відміну від звичайного push. Там атомарність
// потрібна, бо наполовину доїхане дзеркало виглядає як ціле. Тут
// навпаки: видалення незалежні одне від одного, і відмова по одній
// гілці (наприклад, її на тому кінці вже немає) не має скасовувати
// решту.
//
// Відсутність гілки на дзеркалі помилкою не вважається — саме так
// виглядає повтор після часткового успіху, а він тут звичайна річ.
func (s *Store) DeleteRemoteRefs(ctx context.Context, repoName string, r Remote, branches []string) error {
if s.root == "" {
return ErrDisabled
}
specs := make([]config.RefSpec, 0, len(branches))
for _, b := range branches {
b = strings.TrimSpace(b)
if b == "" {
continue
}
specs = append(specs, config.RefSpec(":"+plumbing.NewBranchReferenceName(b).String()))
}
if len(specs) == 0 {
return nil
}
full := filepath.Join(s.root, repoName)
repo, err := git.PlainOpen(full)
if err != nil {
if errors.Is(err, git.ErrRepositoryNotExists) {
return ErrNoRepo
}
return fmt.Errorf("gitstore: відкриття %s: %w", repoName, err)
}
auth, err := r.authMethod()
if err != nil {
return err
}
remote := git.NewRemote(repo.Storer, &config.RemoteConfig{
Name: "mirror",
URLs: []string{r.URL},
})
ctx, cancel := context.WithTimeout(ctx, r.timeout())
defer cancel()
err = remote.PushContext(ctx, &git.PushOptions{
RemoteName: "mirror",
RefSpecs: specs,
Auth: auth,
// Прапорець Prune тут не ставиться ніколи — див. коментар до
// файлу. Видаляє саме перелік specs, і нічого крім нього.
})
switch {
case err == nil, errors.Is(err, git.NoErrAlreadyUpToDate):
return nil
case isMissingRemoteRef(err):
// Гілки там уже немає. Для видалення це і є успіх.
return nil
default:
return r.explain(err)
}
}
// isMissingRemoteRef — чи каже помилка «такого посилання там немає».
//
// Текстом, бо go-git і сервери на тому кінці повідомляють про це
// по-різному й жодного окремого типу помилки для цього не мають.
// Помилитись тут дешево в один бік і дорого в інший: прийняти чужу
// помилку за «уже видалено» означало б зняти рядок із черги, не
// видаливши гілку. Тому перелік вузький — рівно ті формулювання, які
// означають відсутність посилання.
func isMissingRemoteRef(err error) bool {
if err == nil {
return false
}
msg := strings.ToLower(err.Error())
for _, s := range []string{
"reference not found",
"remote ref does not exist",
"deleting a non-existent ref",
"unable to delete",
"no such ref",
} {
if strings.Contains(msg, s) {
return true
}
}
return false
}