evalphobia/aws-sdk-go-v2-wrapper

package pinpoint

import (
    "context"
)

// XUpdateEndpointEmail updates email endpoint.
// (attrs[0]=Attributes, attrs[1]=UserAttributes)
func (svc *Pinpoint) XUpdateEndpointEmail(ctx context.Context, appID, endpointID, userID, email string, attrs ...map[string][]string) error {
    req := UpdateEndpointRequest{
        ApplicationID: appID,
        EndpointID:    endpointID,
        EndpointRequest: EndpointRequest{
            Address:     email,
            ChannelType: ChannelTypeEmail,
            User: EndpointUser{
                UserID: userID,
            },
        },
    }

    attrSize := len(attrs)
    switch {
    case attrSize >= 2:
        req.EndpointRequest.Attributes = attrs[0]
        req.EndpointRequest.User.UserAttributes = attrs[1]
    case attrSize == 1:
        req.EndpointRequest.Attributes = attrs[0]
    }

    _, err := svc.UpdateEndpoint(ctx, req)
    return err
}