/*
 * Copyright 2011-17 Fraunhofer ISE, energy & meteo Systems GmbH and other contributors
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 */
package org.openmuc.openiec61850;

import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;

import org.openmuc.openiec61850.internal.mms.asn1.AlternateAccessSelection;
import org.openmuc.openiec61850.internal.mms.asn1.ObjectName;
import org.openmuc.openiec61850.internal.mms.asn1.ObjectName.DomainSpecific;
import org.openmuc.openiec61850.internal.mms.asn1.VariableDefs;

public final class ServerModel extends ModelNode {

    private final Map<String, DataSet> dataSets = new LinkedHashMap<>();

    private final Map<String, Urcb> urcbs = new HashMap<>();
    private final Map<String, Brcb> brcbs = new HashMap<>();

    public ServerModel(List<LogicalDevice> logicalDevices, Collection<DataSet> dataSets) {
        children = new LinkedHashMap<>();
        objectReference = null;
        for (LogicalDevice logicalDevice : logicalDevices) {
            children.put(logicalDevice.getReference().getName(), logicalDevice);
            logicalDevice.setParent(this);
        }

        if (dataSets != null) {
            addDataSets(dataSets);
        }

        for (LogicalDevice ld : logicalDevices) {
            for (ModelNode ln : ld.getChildren()) {
                for (Urcb urcb : ((LogicalNode) ln).getUrcbs()) {
                    urcbs.put(urcb.getReference().toString(), urcb);
                    urcb.dataSet = getDataSet(urcb.getDatSet().getStringValue().replace('$', '.'));
                }
                for (Brcb brcb : ((LogicalNode) ln).getBrcbs()) {
                    brcbs.put(brcb.getReference().toString(), brcb);
                    brcb.dataSet = getDataSet(brcb.getDatSet().getStringValue().replace('$', '.'));
                }
            }
        }

    }

    @Override
    public ServerModel copy() {
        List<LogicalDevice> childCopies = new ArrayList<>(children.size());
        for (ModelNode childNode : children.values()) {
            childCopies.add((LogicalDevice) childNode.copy());
        }

        List<DataSet> dataSetCopies = new ArrayList<>(dataSets.size());
        for (DataSet dataSet : dataSets.values()) {
            dataSetCopies.add(dataSet);
        }

        return new ServerModel(childCopies, dataSetCopies);
    }

    /**
     * Get the data set with the given reference. Return null if none is found.
     *
     * @param reference
     *            the reference of the requested data set.
     * @return the data set with the given reference.
     */
    public DataSet getDataSet(String reference) {
        return dataSets.get(reference);
    }

    void addDataSet(DataSet dataSet) {
        dataSets.put(dataSet.getReferenceStr().replace('$', '.'), dataSet);
        for (ModelNode ld : children.values()) {
            for (ModelNode ln : ld.getChildren()) {
                for (Urcb urcb : ((LogicalNode) ln).getUrcbs()) {
                    urcb.dataSet = getDataSet(urcb.getDatSet().getStringValue().replace('$', '.'));
                }
                for (Brcb brcb : ((LogicalNode) ln).getBrcbs()) {
                    brcb.dataSet = getDataSet(brcb.getDatSet().getStringValue().replace('$', '.'));
                }
            }
        }
    }

    void addDataSets(Collection<DataSet> dataSets) {
        for (DataSet dataSet : dataSets) {
            addDataSet(dataSet);
        }
        for (ModelNode ld : children.values()) {
            for (ModelNode ln : ld.getChildren()) {
                for (Urcb urcb : ((LogicalNode) ln).getUrcbs()) {
                    urcb.dataSet = getDataSet(urcb.getDatSet().getStringValue().replace('$', '.'));
                }
                for (Brcb brcb : ((LogicalNode) ln).getBrcbs()) {
                    brcb.dataSet = getDataSet(brcb.getDatSet().getStringValue().replace('$', '.'));
                }
            }
        }
    }

    List<String> getDataSetNames(String ldName) {
        // TODO make thread save
        List<String> dataSetNames = new LinkedList<>();
        for (String dataSetRef : dataSets.keySet()) {
            if (dataSetRef.startsWith(ldName)) {
                dataSetNames.add(dataSetRef.substring(dataSetRef.indexOf('/') + 1).replace('.', '$'));
            }
        }
        return dataSetNames;
    }

    /**
     * Get a collection of all data sets that exist in this model.
     *
     * @return a collection of all data sets
     */
    public Collection<DataSet> getDataSets() {
        return dataSets.values();
    }

    /**
     *
     * @param dataSetReference
     * @return returns the DataSet that was removed, null if no DataSet with the given reference was found or the data
     *         set is not deletable.
     */
    DataSet removeDataSet(String dataSetReference) {
        DataSet dataSet = dataSets.get(dataSetReference);
        if (dataSet == null || !dataSet.isDeletable()) {
            return null;
        }
        DataSet removedDataSet = dataSets.remove(dataSetReference);
        for (ModelNode ld : children.values()) {
            for (ModelNode ln : ld.getChildren()) {
                for (Urcb urcb : ((LogicalNode) ln).getUrcbs()) {
                    urcb.dataSet = getDataSet(urcb.getDatSet().getStringValue().replace('$', '.'));
                }
                for (Brcb brcb : ((LogicalNode) ln).getBrcbs()) {
                    brcb.dataSet = getDataSet(brcb.getDatSet().getStringValue().replace('$', '.'));
                }
            }
        }
        return removedDataSet;
    }

    void addUrcb(Urcb urcb) {
        urcbs.put(urcb.getReference().getName(), urcb);
    }

    /**
     * Get the unbuffered report control block (URCB) with the given reference.
     *
     * @param reference
     *            the reference of the requested URCB.
     * @return the reference to the requested URCB or null if none with the given reference is found.
     */
    public Urcb getUrcb(String reference) {
        return urcbs.get(reference);
    }

    /**
     * Get a collection of all unbuffered report control blocks (URCB) that exist in this model.
     *
     * @return a collection of all unbuffered report control blocks (URCB)
     */
    public Collection<Urcb> getUrcbs() {
        return urcbs.values();
    }

    /**
     * Get the buffered report control block (BRCB) with the given reference.
     *
     * @param reference
     *            the reference of the requested BRCB.
     * @return the reference to the requested BRCB or null if none with the given reference is found.
     */
    public Brcb getBrcb(String reference) {
        return brcbs.get(reference);
    }

    /**
     * Get a collection of all buffered report control blocks (BRCB) that exist in this model.
     *
     * @return a collection of all buffered report control blocks (BRCB)
     */
    public Collection<Brcb> getBrcbs() {
        return brcbs.values();
    }
    
    public String getBaseDevName() {
        String dev_n = "ZJDY";
        for (ModelNode logicalDevice : children.values()) {
        	String nm = logicalDevice.toString();
        	if(true == nm.contains("BTSE")) {
        		dev_n = nm.substring(0, nm.indexOf("BTSE"));
        		break;
        	}
        }
        
        return dev_n;
    }
    
    @Override
    public String toString() {
        StringBuilder sb = new StringBuilder();
        for (ModelNode logicalDevice : children.values()) {
        	//if(logicalDevice.toString().contains("BTS")) {
        		sb.append(logicalDevice.toString());
        	//}
        }
        sb.append("\n\n\n---------------------\nURCBs:");
        for (Urcb urcb : getUrcbs()) {
            sb.append("\n\n").append(urcb);
        }

        sb.append("\n\n\n---------------------\nBRCBs:");
        for (Brcb brcb : getBrcbs()) {
            sb.append("\n\n").append(brcb);
        }

        sb.append("\n\n\n---------------------\nData sets:");
        for (DataSet dataSet : getDataSets()) {
            sb.append("\n\n").append(dataSet);
        }

        return sb.toString();
    }

    /**
     * Searches and returns the model node with the given object reference and FC. If searching for Logical Devices and
     * Logical Nodes the given fc parameter may be <code>null</code>.
     *
     * @param objectReference
     *            the object reference of the node that is being searched for. It has a syntax like "ldname/ln.do....".
     * @param fc
     *            the functional constraint of the requested model node. May be null for Logical Device and Logical Node
     *            references.
     * @return the model node if it was found or null otherwise
     */
    public ModelNode findModelNode(ObjectReference objectReference, Fc fc) {

        ModelNode currentNode = this;
        Iterator<String> searchedNodeReferenceIterator = objectReference.iterator();

        while (searchedNodeReferenceIterator.hasNext()) {
            currentNode = currentNode.getChild(searchedNodeReferenceIterator.next(), fc);
            if (currentNode == null) {
                return null;
            }
        }
        return currentNode;
    }

    /**
     * Searches and returns the model node with the given object reference and FC. If searching for Logical Devices and
     * Logical Nodes the given fc parameter may be <code>null</code>.
     *
     * @param objectReference
     *            the object reference of the node that is being searched for. It has a syntax like "ldname/ln.do....".
     * @param fc
     *            the functional constraint of the requested model node. May be null for Logical Device and Logical Node
     *            references.
     * @return the model node if it was found or null otherwise
     */
    public ModelNode findModelNode(String objectReference, Fc fc) {
        return findModelNode(new ObjectReference(objectReference), fc);
    }

    /**
     * Returns the subModelNode that is referenced by the given VariableDef. Return null in case the referenced
     * ModelNode is not found.
     *
     * @param variableDef
     * @return the subModelNode that is referenced by the given VariableDef
     * @throws ServiceError
     */
    FcModelNode getNodeFromVariableDef(VariableDefs.SEQUENCE variableDef) throws ServiceError {

        ObjectName objectName = variableDef.getVariableSpecification().getName();

        if (objectName == null) {
            throw new ServiceError(ServiceError.FAILED_DUE_TO_COMMUNICATIONS_CONSTRAINT,
                    "name in objectName is not selected");
        }

        DomainSpecific domainSpecific = objectName.getDomainSpecific();

        if (domainSpecific == null) {
            throw new ServiceError(ServiceError.FAILED_DUE_TO_COMMUNICATIONS_CONSTRAINT,
                    "domain_specific in name is not selected");
        }

        ModelNode modelNode = getChild(domainSpecific.getDomainID().toString());

        if (modelNode == null) {
            return null;
        }

        String mmsItemId = domainSpecific.getItemID().toString();
        int index1 = mmsItemId.indexOf('$');

        if (index1 == -1) {
            throw new ServiceError(ServiceError.FAILED_DUE_TO_COMMUNICATIONS_CONSTRAINT,
                    "invalid mms item id: " + domainSpecific.getItemID());
        }

        LogicalNode ln = (LogicalNode) modelNode.getChild(mmsItemId.substring(0, index1));

        if (ln == null) {
            return null;
        }

        int index2 = mmsItemId.indexOf('$', index1 + 1);

        if (index2 == -1) {
            throw new ServiceError(ServiceError.FAILED_DUE_TO_COMMUNICATIONS_CONSTRAINT, "invalid mms item id");
        }

        Fc fc = Fc.fromString(mmsItemId.substring(index1 + 1, index2));

        if (fc == null) {
            throw new ServiceError(ServiceError.FAILED_DUE_TO_COMMUNICATIONS_CONSTRAINT,
                    "unknown functional constraint: " + mmsItemId.substring(index1 + 1, index2));
        }

        index1 = index2;

        index2 = mmsItemId.indexOf('$', index1 + 1);

        if (index2 == -1) {
            if (fc == Fc.RP) {
                return ln.getUrcb(mmsItemId.substring(index1 + 1));
            }
            if (fc == Fc.BR) {
                return ln.getBrcb(mmsItemId.substring(index1 + 1));
            }
            return (FcModelNode) ln.getChild(mmsItemId.substring(index1 + 1), fc);
        }

        if (fc == Fc.RP) {
            modelNode = ln.getUrcb(mmsItemId.substring(index1 + 1, index2));
        }
        else if (fc == Fc.BR) {
            modelNode = ln.getBrcb(mmsItemId.substring(index1 + 1, index2));
        }
        else {
            modelNode = ln.getChild(mmsItemId.substring(index1 + 1, index2), fc);
        }

        index1 = index2;
        index2 = mmsItemId.indexOf('$', index1 + 1);
        while (index2 != -1) {
            modelNode = modelNode.getChild(mmsItemId.substring(index1 + 1, index2));
            index1 = index2;
            index2 = mmsItemId.indexOf('$', index1 + 1);
        }

        modelNode = modelNode.getChild(mmsItemId.substring(index1 + 1));

        if (variableDef.getAlternateAccess() == null) {
            // no array is in this node path
            return (FcModelNode) modelNode;
        }

        AlternateAccessSelection altAccIt = variableDef.getAlternateAccess().getCHOICE().get(0).getUnnamed();

        if (altAccIt.getSelectAlternateAccess() != null) {
            // path to node below an array element
            modelNode = ((Array) modelNode)
                    .getChild(altAccIt.getSelectAlternateAccess().getAccessSelection().getIndex().intValue());

            String mmsSubArrayItemId = altAccIt.getSelectAlternateAccess()
                    .getAlternateAccess()
                    .getCHOICE()
                    .get(0)
                    .getUnnamed()
                    .getSelectAccess()
                    .getComponent()
                    .getBasic()
                    .toString();

            index1 = -1;
            index2 = mmsSubArrayItemId.indexOf('$');
            while (index2 != -1) {
                modelNode = modelNode.getChild(mmsSubArrayItemId.substring(index1 + 1, index2));
                index1 = index2;
                index2 = mmsItemId.indexOf('$', index1 + 1);
            }

            return (FcModelNode) modelNode.getChild(mmsSubArrayItemId.substring(index1 + 1));
        }
        else {
            // path to an array element
            return (FcModelNode) ((Array) modelNode).getChild(altAccIt.getSelectAccess().getIndex().intValue());
        }

    }
}