func decodeUpdateItemOutput()

in dax/internal/client/response.go [278:333]
54 lines of code
16 McCabe index (conditional complexity)

func decodeUpdateItemOutput(ctx context.Context, reader *cbor.Reader, input *dynamodb.UpdateItemInput, keySchemaCache *lru.Lru, attrListIdToNames *lru.Lru, output *dynamodb.UpdateItemOutput) (*dynamodb.UpdateItemOutput, error) {
	if consumed, err := consumeNil(reader); err != nil {
		return output, err
	} else if consumed {
		return output, nil
	}

	tableName := *input.TableName
	if output == nil {
		output = &dynamodb.UpdateItemOutput{}
	}
	var err error
	err = consumeMap(reader, func(key int, reader *cbor.Reader) error {
		switch key {
		case responseParamConsumedCapacity:
			if output.ConsumedCapacity, err = decodeConsumedCapacity(reader); err != nil {
				return err
			}
		case responseParamItemCollectionMetrics:
			keys, err := getKeySchema(ctx, keySchemaCache, tableName)
			if err != nil {
				return err
			}
			if output.ItemCollectionMetrics, err = decodeItemCollectionMetrics(reader, *keys[0].AttributeName); err != nil {
				return err
			}
		case responseParamAttributes:
			rv := input.ReturnValues
			switch rv {
			case types.ReturnValueAllNew, types.ReturnValueAllOld:
				attrs, err := decodeNonKeyAttributes(ctx, reader, attrListIdToNames, nil)
				if err != nil {
					return err
				}
				for k, v := range input.Key {
					attrs[k] = v
				}
				output.Attributes = attrs
			case types.ReturnValueUpdatedNew, types.ReturnValueUpdatedOld:
				if output.Attributes, err = decodeAttributeProjection(ctx, reader, attrListIdToNames); err != nil {
					return err
				}
			default:
				return &smithy.SerializationError{Err: fmt.Errorf("unexpected return value %s", rv)}
			}
		default:
			return &smithy.SerializationError{Err: fmt.Errorf("unknown response param key %d", key)}
		}
		return nil
	})
	if err != nil {
		return output, err
	}

	return output, nil
}