func decodePutItemOutput()

in dax/internal/client/response.go [179:229]
49 lines of code
14 McCabe index (conditional complexity)

func decodePutItemOutput(ctx context.Context, reader *cbor.Reader, input *dynamodb.PutItemInput, keySchemaCache *lru.Lru, attrListIdToNames *lru.Lru, output *dynamodb.PutItemOutput) (*dynamodb.PutItemOutput, 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.PutItemOutput{}
	}
	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:
			attrs, err := decodeNonKeyAttributes(ctx, reader, attrListIdToNames, nil)
			if err != nil {
				return err
			}
			keys, err := getKeySchema(ctx, keySchemaCache, tableName)
			if err != nil {
				return err
			}
			for _, ad := range keys {
				k := *ad.AttributeName
				attrs[k] = input.Item[k]
			}
			output.Attributes = attrs
		default:
			return &smithy.SerializationError{Err: fmt.Errorf("unknown response param key %d", key)}
		}
		return nil
	})
	if err != nil {
		return output, err
	}

	return output, nil
}