182 lines
4.3 KiB
Go
182 lines
4.3 KiB
Go
package jwk
|
|
|
|
import (
|
|
"bytes"
|
|
"context"
|
|
"crypto"
|
|
"crypto/ed25519"
|
|
"fmt"
|
|
|
|
"github.com/lestrrat-go/blackmagic"
|
|
"github.com/lestrrat-go/jwx/internal/base64"
|
|
"github.com/lestrrat-go/jwx/jwa"
|
|
"github.com/lestrrat-go/jwx/x25519"
|
|
"github.com/pkg/errors"
|
|
)
|
|
|
|
func (k *okpPublicKey) FromRaw(rawKeyIf interface{}) error {
|
|
k.mu.Lock()
|
|
defer k.mu.Unlock()
|
|
|
|
var crv jwa.EllipticCurveAlgorithm
|
|
switch rawKey := rawKeyIf.(type) {
|
|
case ed25519.PublicKey:
|
|
k.x = rawKey
|
|
crv = jwa.Ed25519
|
|
k.crv = &crv
|
|
case x25519.PublicKey:
|
|
k.x = rawKey
|
|
crv = jwa.X25519
|
|
k.crv = &crv
|
|
default:
|
|
return errors.Errorf(`unknown key type %T`, rawKeyIf)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (k *okpPrivateKey) FromRaw(rawKeyIf interface{}) error {
|
|
k.mu.Lock()
|
|
defer k.mu.Unlock()
|
|
|
|
var crv jwa.EllipticCurveAlgorithm
|
|
switch rawKey := rawKeyIf.(type) {
|
|
case ed25519.PrivateKey:
|
|
k.d = rawKey.Seed()
|
|
k.x = rawKey.Public().(ed25519.PublicKey) //nolint:forcetypeassert
|
|
crv = jwa.Ed25519
|
|
k.crv = &crv
|
|
case x25519.PrivateKey:
|
|
k.d = rawKey.Seed()
|
|
k.x = rawKey.Public().(x25519.PublicKey) //nolint:forcetypeassert
|
|
crv = jwa.X25519
|
|
k.crv = &crv
|
|
default:
|
|
return errors.Errorf(`unknown key type %T`, rawKeyIf)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func buildOKPPublicKey(alg jwa.EllipticCurveAlgorithm, xbuf []byte) (interface{}, error) {
|
|
switch alg {
|
|
case jwa.Ed25519:
|
|
return ed25519.PublicKey(xbuf), nil
|
|
case jwa.X25519:
|
|
return x25519.PublicKey(xbuf), nil
|
|
default:
|
|
return nil, errors.Errorf(`invalid curve algorithm %s`, alg)
|
|
}
|
|
}
|
|
|
|
// Raw returns the EC-DSA public key represented by this JWK
|
|
func (k *okpPublicKey) Raw(v interface{}) error {
|
|
k.mu.RLock()
|
|
defer k.mu.RUnlock()
|
|
|
|
pubk, err := buildOKPPublicKey(k.Crv(), k.x)
|
|
if err != nil {
|
|
return errors.Wrap(err, `failed to build public key`)
|
|
}
|
|
|
|
return blackmagic.AssignIfCompatible(v, pubk)
|
|
}
|
|
|
|
func buildOKPPrivateKey(alg jwa.EllipticCurveAlgorithm, xbuf []byte, dbuf []byte) (interface{}, error) {
|
|
switch alg {
|
|
case jwa.Ed25519:
|
|
ret := ed25519.NewKeyFromSeed(dbuf)
|
|
if !bytes.Equal(xbuf, ret.Public().(ed25519.PublicKey)) {
|
|
return nil, errors.Errorf(`invalid x value given d value`)
|
|
}
|
|
return ret, nil
|
|
case jwa.X25519:
|
|
ret, err := x25519.NewKeyFromSeed(dbuf)
|
|
if err != nil {
|
|
return nil, errors.Wrap(err, `unable to construct x25519 private key from seed`)
|
|
}
|
|
if !bytes.Equal(xbuf, ret.Public().(x25519.PublicKey)) {
|
|
return nil, errors.Errorf(`invalid x value given d value`)
|
|
}
|
|
return ret, nil
|
|
default:
|
|
return nil, errors.Errorf(`invalid curve algorithm %s`, alg)
|
|
}
|
|
}
|
|
|
|
func (k *okpPrivateKey) Raw(v interface{}) error {
|
|
k.mu.RLock()
|
|
defer k.mu.RUnlock()
|
|
|
|
privk, err := buildOKPPrivateKey(k.Crv(), k.x, k.d)
|
|
if err != nil {
|
|
return errors.Wrap(err, `failed to build public key`)
|
|
}
|
|
|
|
return blackmagic.AssignIfCompatible(v, privk)
|
|
}
|
|
|
|
func makeOKPPublicKey(v interface {
|
|
Iterate(context.Context) HeaderIterator
|
|
}) (Key, error) {
|
|
newKey := NewOKPPublicKey()
|
|
|
|
// Iterate and copy everything except for the bits that should not be in the public key
|
|
for iter := v.Iterate(context.TODO()); iter.Next(context.TODO()); {
|
|
pair := iter.Pair()
|
|
switch pair.Key {
|
|
case OKPDKey:
|
|
continue
|
|
default:
|
|
if err := newKey.Set(pair.Key.(string), pair.Value); err != nil {
|
|
return nil, errors.Wrapf(err, `failed to set field %s`, pair.Key)
|
|
}
|
|
}
|
|
}
|
|
|
|
return newKey, nil
|
|
}
|
|
|
|
func (k *okpPrivateKey) PublicKey() (Key, error) {
|
|
return makeOKPPublicKey(k)
|
|
}
|
|
|
|
func (k *okpPublicKey) PublicKey() (Key, error) {
|
|
return makeOKPPublicKey(k)
|
|
}
|
|
|
|
func okpThumbprint(hash crypto.Hash, crv, x string) []byte {
|
|
h := hash.New()
|
|
fmt.Fprint(h, `{"crv":"`)
|
|
fmt.Fprint(h, crv)
|
|
fmt.Fprint(h, `","kty":"OKP","x":"`)
|
|
fmt.Fprint(h, x)
|
|
fmt.Fprint(h, `"}`)
|
|
return h.Sum(nil)
|
|
}
|
|
|
|
// Thumbprint returns the JWK thumbprint using the indicated
|
|
// hashing algorithm, according to RFC 7638 / 8037
|
|
func (k okpPublicKey) Thumbprint(hash crypto.Hash) ([]byte, error) {
|
|
k.mu.RLock()
|
|
defer k.mu.RUnlock()
|
|
|
|
return okpThumbprint(
|
|
hash,
|
|
k.Crv().String(),
|
|
base64.EncodeToString(k.x),
|
|
), nil
|
|
}
|
|
|
|
// Thumbprint returns the JWK thumbprint using the indicated
|
|
// hashing algorithm, according to RFC 7638 / 8037
|
|
func (k okpPrivateKey) Thumbprint(hash crypto.Hash) ([]byte, error) {
|
|
k.mu.RLock()
|
|
defer k.mu.RUnlock()
|
|
|
|
return okpThumbprint(
|
|
hash,
|
|
k.Crv().String(),
|
|
base64.EncodeToString(k.x),
|
|
), nil
|
|
}
|