/*
 * Copyright (c) 2014 Cisco Systems, Inc. and others.  All rights reserved.
 *
 * This program and the accompanying materials are made available under the
 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
 * and is available at http://www.eclipse.org/legal/epl-v10.html
 */

package org.opendaylight.controller.cluster.datastore.messages;

import org.opendaylight.controller.cluster.datastore.node.NormalizedNodeToNodeCodec;
import org.opendaylight.controller.cluster.datastore.utils.InstanceIdentifierUtils;
import org.opendaylight.controller.protobuff.messages.common.NormalizedNodeMessages;
import org.opendaylight.controller.protobuff.messages.transaction.ShardTransactionMessages;
import org.opendaylight.yangtools.yang.data.api.InstanceIdentifier;
import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
import org.opendaylight.yangtools.yang.model.api.SchemaContext;

public class MergeData extends ModifyData{

    public static final Class SERIALIZABLE_CLASS = ShardTransactionMessages.MergeData.class;

    public MergeData(InstanceIdentifier path, NormalizedNode<?, ?> data,
        SchemaContext context) {
        super(path, data, context);
    }

    @Override public Object toSerializable() {

        NormalizedNodeMessages.Node normalizedNode =
            new NormalizedNodeToNodeCodec(schemaContext).encode(InstanceIdentifierUtils.from(path.toString()), data)
                .getNormalizedNode();
        return ShardTransactionMessages.MergeData.newBuilder()
            .setInstanceIdentifierPathArguments(path.toString())
            .setNormalizedNode(normalizedNode).build();
    }

    public static MergeData fromSerializable(Object serializable, SchemaContext schemaContext){
        ShardTransactionMessages.MergeData o = (ShardTransactionMessages.MergeData) serializable;
        InstanceIdentifier identifier = InstanceIdentifierUtils.from(o.getInstanceIdentifierPathArguments());

        NormalizedNode<?, ?> normalizedNode =
            new NormalizedNodeToNodeCodec(schemaContext)
                .decode(identifier, o.getNormalizedNode());

        return new MergeData(identifier, normalizedNode, schemaContext);
    }
}