mirror of
https://github.com/passbolt/go-passbolt.git
synced 2025-09-13 14:29:09 +00:00
Compare commits
No commits in common. "9b9bbb0b4b43e4d390c6634cf1f3854cb0ef282c" and "cfd205f1bf07f017d1f0ad3afdb68cd2b9505a33" have entirely different histories.
9b9bbb0b4b
...
cfd205f1bf
4 changed files with 97 additions and 359 deletions
|
@ -7,27 +7,18 @@ import (
|
||||||
"fmt"
|
"fmt"
|
||||||
"strings"
|
"strings"
|
||||||
|
|
||||||
"github.com/ProtonMail/gopenpgp/v3/crypto"
|
|
||||||
"github.com/passbolt/go-passbolt/api"
|
"github.com/passbolt/go-passbolt/api"
|
||||||
"github.com/santhosh-tekuri/jsonschema"
|
"github.com/santhosh-tekuri/jsonschema"
|
||||||
)
|
)
|
||||||
|
|
||||||
func GetResourceMetadata(ctx context.Context, c *api.Client, resource *api.Resource, rType *api.ResourceType) (string, error) {
|
func GetResourceMetadata(ctx context.Context, c *api.Client, resource *api.Resource, rType *api.ResourceType) (string, error) {
|
||||||
var metadatakey *crypto.Key
|
_, _, metadatakey, err := GetMetadataKey(ctx, c, resource.MetadataKeyType == api.MetadataKeyTypeUserKey)
|
||||||
if resource.MetadataKeyType == api.MetadataKeyTypeUserKey {
|
|
||||||
tmp, err := c.GetUserPrivateKeyCopy()
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return "", fmt.Errorf("Get Private Key Copy: %w", err)
|
return "", fmt.Errorf("Get Metadata Key: %w", err)
|
||||||
}
|
|
||||||
metadatakey = tmp
|
|
||||||
} else {
|
|
||||||
key, err := GetMetadataKeyById(ctx, c, resource.MetadataKeyID)
|
|
||||||
if err != nil {
|
|
||||||
return "", fmt.Errorf("Get Metadata Key by ID: %w", err)
|
|
||||||
}
|
|
||||||
metadatakey = key
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// TODO should we instead get the Metadata key of this resource by id?
|
||||||
|
|
||||||
decMetadata, err := c.DecryptMetadata(metadatakey, resource.Metadata)
|
decMetadata, err := c.DecryptMetadata(metadatakey, resource.Metadata)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return "", fmt.Errorf("Decrypt Metadata: %w", err)
|
return "", fmt.Errorf("Decrypt Metadata: %w", err)
|
||||||
|
@ -87,7 +78,7 @@ func validateMetadata(rType *api.ResourceType, metadata string) error {
|
||||||
|
|
||||||
err = schema.Validate(strings.NewReader(metadata))
|
err = schema.Validate(strings.NewReader(metadata))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("Validating Metadata with Schema: %w", err)
|
return fmt.Errorf("Validating Secret Data: %w", err)
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
|
@ -75,55 +75,3 @@ func GetMetadataKey(ctx context.Context, c *api.Client, personal bool) (string,
|
||||||
|
|
||||||
return keys[0].ID, api.MetadataKeyTypeSharedKey, metadataPrivateKeyObj, nil
|
return keys[0].ID, api.MetadataKeyTypeSharedKey, metadataPrivateKeyObj, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// GetMetadataKeyById is for fetching a specific metadatakey if needed for Decryption
|
|
||||||
func GetMetadataKeyById(ctx context.Context, c *api.Client, id string) (*crypto.Key, error) {
|
|
||||||
keys, err := c.GetMetadataKeys(ctx, &api.GetMetadataKeysOptions{
|
|
||||||
ContainMetadataPrivateKeys: true,
|
|
||||||
})
|
|
||||||
if err != nil {
|
|
||||||
return nil, fmt.Errorf("Get Metadata Key: %w", err)
|
|
||||||
}
|
|
||||||
var key *api.MetadataKey
|
|
||||||
for _, k := range keys {
|
|
||||||
if k.ID == id {
|
|
||||||
key = &k
|
|
||||||
break
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if key == nil {
|
|
||||||
return nil, fmt.Errorf("Metadata key not found: %v", id)
|
|
||||||
}
|
|
||||||
|
|
||||||
if len(key.MetadataPrivateKeys) == 0 {
|
|
||||||
return nil, fmt.Errorf("No Metadata Private key for our user")
|
|
||||||
}
|
|
||||||
|
|
||||||
if len(key.MetadataPrivateKeys) > 1 {
|
|
||||||
return nil, fmt.Errorf("More than 1 metadata Private key for our user")
|
|
||||||
}
|
|
||||||
|
|
||||||
var privMetdata api.MetadataPrivateKey = key.MetadataPrivateKeys[0]
|
|
||||||
if *privMetdata.UserID != c.GetUserID() {
|
|
||||||
return nil, fmt.Errorf("MetadataPrivateKey is not for our user id: %v", privMetdata.UserID)
|
|
||||||
}
|
|
||||||
|
|
||||||
decPrivMetadatakey, err := c.DecryptMessage(privMetdata.Data)
|
|
||||||
if err != nil {
|
|
||||||
return nil, fmt.Errorf("Decrypt Metadata Private Key Data: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
var data api.MetadataPrivateKeyData
|
|
||||||
err = json.Unmarshal([]byte(decPrivMetadatakey), &data)
|
|
||||||
if err != nil {
|
|
||||||
return nil, fmt.Errorf("Parse Metadata Private Key Data")
|
|
||||||
}
|
|
||||||
|
|
||||||
metadataPrivateKeyObj, err := api.GetPrivateKeyFromArmor(data.ArmoredKey, []byte(data.Passphrase))
|
|
||||||
if err != nil {
|
|
||||||
return nil, fmt.Errorf("Get Metadata Private Key: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
return metadataPrivateKeyObj, nil
|
|
||||||
}
|
|
||||||
|
|
|
@ -5,7 +5,6 @@ import (
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
"github.com/ProtonMail/gopenpgp/v3/crypto"
|
|
||||||
"github.com/passbolt/go-passbolt/api"
|
"github.com/passbolt/go-passbolt/api"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -390,204 +389,10 @@ func UpdateResource(ctx context.Context, c *api.Client, resourceID, name, userna
|
||||||
ID: resourceID,
|
ID: resourceID,
|
||||||
// This needs to be specified or it will revert to a legacy password
|
// This needs to be specified or it will revert to a legacy password
|
||||||
ResourceTypeID: resource.ResourceTypeID,
|
ResourceTypeID: resource.ResourceTypeID,
|
||||||
|
Name: resource.Name,
|
||||||
|
Username: resource.Username,
|
||||||
|
URI: resource.URI,
|
||||||
}
|
}
|
||||||
var secretData string
|
|
||||||
|
|
||||||
// Check if this is a v5 or Later Resource
|
|
||||||
if resource.Metadata != "" {
|
|
||||||
// Get Metadata
|
|
||||||
orgMetadata, err := GetResourceMetadata(ctx, c, resource, rType)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("Get Resource metadata: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
var metadataMap map[string]any
|
|
||||||
err = json.Unmarshal([]byte(orgMetadata), &metadataMap)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("Marshalling metadata: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
var newMetadata []byte
|
|
||||||
switch rType.Slug {
|
|
||||||
case "v5-default":
|
|
||||||
// Modify Metadata
|
|
||||||
if name != "" {
|
|
||||||
metadataMap["name"] = name
|
|
||||||
}
|
|
||||||
if username != "" {
|
|
||||||
metadataMap["username"] = username
|
|
||||||
}
|
|
||||||
if uri != "" {
|
|
||||||
metadataMap["uris"] = []string{uri}
|
|
||||||
}
|
|
||||||
case "v5-password-string":
|
|
||||||
// Modify Metadata
|
|
||||||
if name != "" {
|
|
||||||
metadataMap["name"] = name
|
|
||||||
}
|
|
||||||
if username != "" {
|
|
||||||
metadataMap["username"] = username
|
|
||||||
}
|
|
||||||
if uri != "" {
|
|
||||||
metadataMap["uris"] = []string{uri}
|
|
||||||
}
|
|
||||||
if description != "" {
|
|
||||||
metadataMap["description"] = description
|
|
||||||
}
|
|
||||||
case "v5-default-with-totp":
|
|
||||||
// Modify Metadata
|
|
||||||
if name != "" {
|
|
||||||
metadataMap["name"] = name
|
|
||||||
}
|
|
||||||
if username != "" {
|
|
||||||
metadataMap["username"] = username
|
|
||||||
}
|
|
||||||
if uri != "" {
|
|
||||||
metadataMap["uris"] = []string{uri}
|
|
||||||
}
|
|
||||||
case "v5-totp-standalone":
|
|
||||||
// Modify Metadata
|
|
||||||
if name != "" {
|
|
||||||
metadataMap["name"] = name
|
|
||||||
}
|
|
||||||
if uri != "" {
|
|
||||||
metadataMap["uris"] = []string{uri}
|
|
||||||
}
|
|
||||||
default:
|
|
||||||
return fmt.Errorf("Unknown ResourceType: %v", rType.Slug)
|
|
||||||
}
|
|
||||||
|
|
||||||
newMetadata, err = json.Marshal(&metadataMap)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("Marshalling metadata: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Validate Metadata
|
|
||||||
err = validateMetadata(rType, string(newMetadata))
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("Validating metadata: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
metadataKeyID, metadataKeyType, publicMetadataKey, err := GetMetadataKey(ctx, c, true)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("Get Metadata Key: %w", err)
|
|
||||||
}
|
|
||||||
newResource.MetadataKeyID = metadataKeyID
|
|
||||||
newResource.MetadataKeyType = metadataKeyType
|
|
||||||
|
|
||||||
encMetadata, err := c.EncryptMessageWithKey(publicMetadataKey, string(newMetadata))
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("Encrypt Metadata: %w", err)
|
|
||||||
}
|
|
||||||
newResource.Metadata = encMetadata
|
|
||||||
|
|
||||||
// Modify Secret
|
|
||||||
switch rType.Slug {
|
|
||||||
case "v5-default":
|
|
||||||
tmp := api.SecretDataTypeV5Default{
|
|
||||||
Password: password,
|
|
||||||
Description: description,
|
|
||||||
}
|
|
||||||
tmp.ObjectType = api.PASSBOLT_OBJECT_TYPE_SECRET_DATA
|
|
||||||
tmp.ResourceTypeID = rType.ID
|
|
||||||
if password != "" || description != "" {
|
|
||||||
secret, err := c.GetSecret(ctx, resourceID)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("Getting Secret: %w", err)
|
|
||||||
}
|
|
||||||
oldSecretData, err := c.DecryptMessage(secret.Data)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("Decrypting Secret: %w", err)
|
|
||||||
}
|
|
||||||
var oldSecret api.SecretDataTypeV5Default
|
|
||||||
err = json.Unmarshal([]byte(oldSecretData), &oldSecret)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("Parsing Decrypted Secret Data: %w", err)
|
|
||||||
}
|
|
||||||
if password == "" {
|
|
||||||
tmp.Password = oldSecret.Password
|
|
||||||
}
|
|
||||||
if description == "" {
|
|
||||||
tmp.Description = oldSecret.Description
|
|
||||||
}
|
|
||||||
}
|
|
||||||
res, err := json.Marshal(&tmp)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("Marshalling Secret Data: %w", err)
|
|
||||||
}
|
|
||||||
secretData = string(res)
|
|
||||||
case "v5-password-string":
|
|
||||||
newResource.Description = resource.Description
|
|
||||||
if description != "" {
|
|
||||||
newResource.Description = description
|
|
||||||
}
|
|
||||||
if password != "" {
|
|
||||||
secretData = password
|
|
||||||
} else {
|
|
||||||
secret, err := c.GetSecret(ctx, resourceID)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("Getting Secret: %w", err)
|
|
||||||
}
|
|
||||||
secretData, err = c.DecryptMessage(secret.Data)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("Decrypting Secret: %w", err)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
case "v5-default-with-totp":
|
|
||||||
secret, err := c.GetSecret(ctx, resourceID)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("Getting Secret: %w", err)
|
|
||||||
}
|
|
||||||
oldSecretData, err := c.DecryptMessage(secret.Data)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("Decrypting Secret: %w", err)
|
|
||||||
}
|
|
||||||
var oldSecret api.SecretDataTypeV5DefaultWithTOTP
|
|
||||||
err = json.Unmarshal([]byte(oldSecretData), &secretData)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("Parsing Decrypted Secret Data: %w", err)
|
|
||||||
}
|
|
||||||
if password != "" {
|
|
||||||
oldSecret.Password = password
|
|
||||||
}
|
|
||||||
if description != "" {
|
|
||||||
oldSecret.Description = description
|
|
||||||
}
|
|
||||||
|
|
||||||
res, err := json.Marshal(&oldSecret)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("Marshalling Secret Data: %w", err)
|
|
||||||
}
|
|
||||||
secretData = string(res)
|
|
||||||
case "v5-totp-standalone":
|
|
||||||
secret, err := c.GetSecret(ctx, resourceID)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("Getting Secret: %w", err)
|
|
||||||
}
|
|
||||||
oldSecretData, err := c.DecryptMessage(secret.Data)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("Decrypting Secret: %w", err)
|
|
||||||
}
|
|
||||||
var oldSecret api.SecretDataTypeTOTP
|
|
||||||
err = json.Unmarshal([]byte(oldSecretData), &secretData)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("Parsing Decrypted Secret Data: %w", err)
|
|
||||||
}
|
|
||||||
// since we don't have totp parameters we don't do anything
|
|
||||||
|
|
||||||
res, err := json.Marshal(&oldSecret)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("Marshalling Secret Data: %w", err)
|
|
||||||
}
|
|
||||||
secretData = string(res)
|
|
||||||
default:
|
|
||||||
return fmt.Errorf("Unknown ResourceType: %v", rType.Slug)
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
// V4 Resource
|
|
||||||
newResource.Name = resource.Name
|
|
||||||
newResource.Username = resource.Username
|
|
||||||
newResource.URI = resource.URI
|
|
||||||
|
|
||||||
if name != "" {
|
if name != "" {
|
||||||
newResource.Name = name
|
newResource.Name = name
|
||||||
|
@ -599,7 +404,7 @@ func UpdateResource(ctx context.Context, c *api.Client, resourceID, name, userna
|
||||||
newResource.URI = uri
|
newResource.URI = uri
|
||||||
}
|
}
|
||||||
|
|
||||||
// Secret
|
var secretData string
|
||||||
switch rType.Slug {
|
switch rType.Slug {
|
||||||
case "password-string":
|
case "password-string":
|
||||||
newResource.Description = resource.Description
|
newResource.Description = resource.Description
|
||||||
|
@ -699,7 +504,6 @@ func UpdateResource(ctx context.Context, c *api.Client, resourceID, name, userna
|
||||||
default:
|
default:
|
||||||
return fmt.Errorf("Unknown ResourceType: %v", rType.Slug)
|
return fmt.Errorf("Unknown ResourceType: %v", rType.Slug)
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
err = validateSecretData(rType, secretData)
|
err = validateSecretData(rType, secretData)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -716,12 +520,7 @@ func UpdateResource(ctx context.Context, c *api.Client, resourceID, name, userna
|
||||||
return fmt.Errorf("Encrypting Secret Data for User me: %w", err)
|
return fmt.Errorf("Encrypting Secret Data for User me: %w", err)
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
publicKey, err := crypto.NewKeyFromArmored(user.GPGKey.ArmoredKey)
|
encSecretData, err = c.EncryptMessageWithPublicKey(user.GPGKey.ArmoredKey, secretData)
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("Get Public Key: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
encSecretData, err = c.EncryptMessageWithKey(publicKey, secretData)
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("Encrypting Secret Data for User %v: %w", user.ID, err)
|
return fmt.Errorf("Encrypting Secret Data for User %v: %w", user.ID, err)
|
||||||
}
|
}
|
||||||
|
|
|
@ -57,7 +57,7 @@ func validateSecretData(rType *api.ResourceType, secretData string) error {
|
||||||
|
|
||||||
err = schema.Validate(strings.NewReader(secretData))
|
err = schema.Validate(strings.NewReader(secretData))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("Validating Secret Data with Schema: %w", err)
|
return fmt.Errorf("Validating Secret Data: %w", err)
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue