diff --git a/pkg/services/object/put/streamer.go b/pkg/services/object/put/streamer.go index 678cff572..fed161e03 100644 --- a/pkg/services/object/put/streamer.go +++ b/pkg/services/object/put/streamer.go @@ -51,7 +51,6 @@ func (p *Streamer) MaxObjectSize() uint64 { return p.maxPayloadSz } -// nolint: funlen func (p *Streamer) initTarget(prm *PutInitPrm) error { // prevent re-calling if p.target != nil { @@ -69,19 +68,26 @@ func (p *Streamer) initTarget(prm *PutInitPrm) error { } if prm.hdr.Signature() != nil { - p.relay = prm.relay + return p.initUntrustedTarget(prm) + } + return p.initTrustedTarget(prm) +} - // prepare untrusted-Put object target - p.target = &validatingTarget{ - nextTarget: p.newCommonTarget(prm), - fmt: p.fmtValidator, +func (p *Streamer) initUntrustedTarget(prm *PutInitPrm) error { + p.relay = prm.relay - maxPayloadSz: p.maxPayloadSz, - } + // prepare untrusted-Put object target + p.target = &validatingTarget{ + nextTarget: p.newCommonTarget(prm), + fmt: p.fmtValidator, - return nil + maxPayloadSz: p.maxPayloadSz, } + return nil +} + +func (p *Streamer) initTrustedTarget(prm *PutInitPrm) error { sToken := prm.common.SessionToken() // prepare trusted-Put object target