From de9ae54de97eea5377c49920547214ae2462e7dd Mon Sep 17 00:00:00 2001 From: adminer Date: Sat, 18 Jul 2026 09:55:47 +0300 Subject: [PATCH] revert 2cc7017d74ca2df10466b89e91c903179718611f MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit revert Обновить internal/endpoint/endpoint.go --- internal/endpoint/endpoint.go | 23 ----------------------- 1 file changed, 23 deletions(-) diff --git a/internal/endpoint/endpoint.go b/internal/endpoint/endpoint.go index 54cc6a9..6dea73a 100644 --- a/internal/endpoint/endpoint.go +++ b/internal/endpoint/endpoint.go @@ -80,28 +80,6 @@ func NewSender(conf SenderConfig) *Sender { } func (s *Sender) filterCheckFS(fs string) (*zfs.DatasetPath, error) { - // Патч: если fs пришёл без pool (nomad/...), добавляем source pool обратно - // (но только если он не полный) - p, err := zfs.NewDatasetPath(fs) - if err != nil { - return nil, err - } - - // Если путь короткий (без pool) — добавляем первый компонент из job config или пропускаем - // Но проще: если длина < 2, то это уже "очищенный" путь — пропускаем проверку или добавляем - if p.Length() <= 1 { - // Просто проверяем фильтр как есть - pass, err := s.FSFilter.Filter(p) - if err != nil { - return nil, err - } - if !pass { - return nil, fmt.Errorf("endpoint does not allow access to filesystem %s", fs) - } - return p, nil - } - - // Обычный путь dp, err := zfs.NewDatasetPath(fs) if err != nil { return nil, err @@ -119,7 +97,6 @@ func (s *Sender) filterCheckFS(fs string) (*zfs.DatasetPath, error) { return dp, nil } - func (s *Sender) ListFilesystems(ctx context.Context, r *pdu.ListFilesystemReq) (*pdu.ListFilesystemRes, error) { defer trace.WithSpanFromStackUpdateCtx(&ctx)()