package kms import ( "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/service/kms" "wallet-system/internal/pkg/logging/applogger" ) // Encrypt // // @Description: // @receiver k // @param keyId // @param plainText // @return []byte // @return error func (k *KmsClient) Encrypt(keyId string, plainText string) ([]byte, error) { encryptResult, err := k.KmsC.Encrypt(&kms.EncryptInput{ KeyId: aws.String(keyId), Plaintext: []byte(plainText), }) if err != nil { applogger.Error("Error reporting using Kms encryption:%v", err) return []byte{}, err } return encryptResult.CiphertextBlob, nil }