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
}