132 lines
3.2 KiB
Go
132 lines
3.2 KiB
Go
package container
|
|
|
|
import (
|
|
"crypto/ecdsa"
|
|
"errors"
|
|
"fmt"
|
|
|
|
cid "git.frostfs.info/TrueCloudLab/frostfs-sdk-go/container/id"
|
|
frostfsecdsa "git.frostfs.info/TrueCloudLab/frostfs-sdk-go/crypto/ecdsa"
|
|
"git.frostfs.info/TrueCloudLab/frostfs-sdk-go/session"
|
|
"git.frostfs.info/TrueCloudLab/frostfs-sdk-go/user"
|
|
)
|
|
|
|
var (
|
|
errWrongSessionVerb = errors.New("wrong token verb")
|
|
errWrongCID = errors.New("wrong container ID")
|
|
)
|
|
|
|
type signatureVerificationData struct {
|
|
ownerContainer user.ID
|
|
|
|
verb session.ContainerVerb
|
|
|
|
idContainerSet bool
|
|
idContainer cid.ID
|
|
|
|
binTokenSession []byte
|
|
|
|
binPublicKey []byte
|
|
|
|
signature []byte
|
|
|
|
signedData []byte
|
|
}
|
|
|
|
// verifySignature is a common method of Container service authentication. Asserts that:
|
|
// - for trusted parties: session is valid (*) and issued by container owner
|
|
// - operation data is signed by container owner or trusted party
|
|
// - operation data signature is correct
|
|
//
|
|
// (*) includes:
|
|
// - session token decodes correctly
|
|
// - signature is valid
|
|
// - session issued by the container owner
|
|
// - v.binPublicKey is a public session key
|
|
// - session context corresponds to the container and verb in v
|
|
// - session is "alive"
|
|
func (cp *Processor) verifySignature(v signatureVerificationData) error {
|
|
var err error
|
|
var key frostfsecdsa.PublicKeyRFC6979
|
|
keyProvided := v.binPublicKey != nil
|
|
|
|
if keyProvided {
|
|
err = key.Decode(v.binPublicKey)
|
|
if err != nil {
|
|
return fmt.Errorf("decode public key: %w", err)
|
|
}
|
|
}
|
|
|
|
if len(v.binTokenSession) > 0 {
|
|
return cp.verifyByTokenSession(v, &key, keyProvided)
|
|
}
|
|
|
|
if keyProvided {
|
|
var idFromKey user.ID
|
|
user.IDFromKey(&idFromKey, (ecdsa.PublicKey)(key))
|
|
|
|
if v.ownerContainer.Equals(idFromKey) {
|
|
if key.Verify(v.signedData, v.signature) {
|
|
return nil
|
|
}
|
|
|
|
return errors.New("invalid signature calculated by container owner's key")
|
|
}
|
|
}
|
|
|
|
return errors.New("signature is invalid or calculated with the key not bound to the container owner")
|
|
}
|
|
|
|
func (cp *Processor) checkTokenLifetime(token session.Container) error {
|
|
curEpoch, err := cp.netState.Epoch()
|
|
if err != nil {
|
|
return fmt.Errorf("could not read current epoch: %w", err)
|
|
}
|
|
|
|
if token.InvalidAt(curEpoch) {
|
|
return fmt.Errorf("token is not valid at %d", curEpoch)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (cp *Processor) verifyByTokenSession(v signatureVerificationData, key *frostfsecdsa.PublicKeyRFC6979, keyProvided bool) error {
|
|
var tok session.Container
|
|
|
|
err := tok.Unmarshal(v.binTokenSession)
|
|
if err != nil {
|
|
return fmt.Errorf("decode session token: %w", err)
|
|
}
|
|
|
|
if !tok.VerifySignature() {
|
|
return errors.New("invalid session token signature")
|
|
}
|
|
|
|
if keyProvided && !tok.AssertAuthKey(key) {
|
|
return errors.New("signed with a non-session key")
|
|
}
|
|
|
|
if !tok.AssertVerb(v.verb) {
|
|
return errWrongSessionVerb
|
|
}
|
|
|
|
if v.idContainerSet && !tok.AppliedTo(v.idContainer) {
|
|
return errWrongCID
|
|
}
|
|
|
|
if !session.IssuedBy(tok, v.ownerContainer) {
|
|
return errors.New("owner differs with token owner")
|
|
}
|
|
|
|
err = cp.checkTokenLifetime(tok)
|
|
if err != nil {
|
|
return fmt.Errorf("check session lifetime: %w", err)
|
|
}
|
|
|
|
if !tok.VerifySessionDataSignature(v.signedData, v.signature) {
|
|
return errors.New("invalid signature calculated with session key")
|
|
}
|
|
|
|
return nil
|
|
}
|