src/main/java/org/apache/cayenne/modeler/adapters/DataDomainAdapter.java

/*****************************************************************
 *   Licensed to the Apache Software Foundation (ASF) under one
 *  or more contributor license agreements.  See the NOTICE file
 *  distributed with this work for additional information
 *  regarding copyright ownership.  The ASF licenses this file
 *  to you 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.apache.cayenne.modeler.adapters;

import java.util.ArrayList;
import java.util.List;

import org.apache.cayenne.modeler.project.CayenneProject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import javafx.beans.property.BooleanProperty;
import javafx.beans.property.IntegerProperty;
import javafx.beans.property.StringProperty;

public class DataDomainAdapter extends CayennePropertyAdapter // implements AdapterSupport<CayenneProject>
{
    private static final Logger LOGGER = LoggerFactory.getLogger(DataDomainAdapter.class);

    private static final String DATA_DOMAIN_NAME              = "dataDomainName";
    private static final String VALIDATING_OBJECTS            = "dataDomainValidatingObjects";
    private static final String OBJECT_CACHE_SIZE             = "sizeOfObjectCache";
    private static final String USE_SHARED_CACHE              = "usingSharedCache";
    private static final String REMOTE_CHANGE_NOTIFICATIONS   = "remoteChangeNotificationsEnabled";
    private static final String EVENT_BRIDGE_FACTORY          = "eventBridgeFactory";
    private static final String JAVA_GROUPS_MULTICAST_ADDRESS = "javaGroupsMulticastAddress";
    private static final String JAVA_GROUPS_MULTICAST_PORT    = "javaGroupsMulticastPort";
    private static final String JAVA_GROUPS_FILE              = "javaGroupsFile";
    private static final String JMS_CONNECTION_FACTORY        = "jmsConnectionFactory";

    private final CayenneProject cayenneProject;

    private final List<DataMapAdapter> dataMapAdapters = new ArrayList<>(); //FXCollections.emptyObservableList();
    private final List<DataNodeAdapter> dataNodeAdapters = new ArrayList<>(); //FXCollections.emptyObservableList();

    private StringProperty  nameProperty;
    private BooleanProperty validatingObjectsProperty;

    /*
     * The following are DM properties that have to be handled specially:
     *   Shared Cache
     *   Remote Change Notification
     *   Validating Objects on Commit
     *   Event Bridge Factory
     *   Multicast Address
     *   Multicast Ports
     *
     */

    private IntegerProperty sizeOfObjectCacheProperty;
    private BooleanProperty useSharedCacheProperty;
    private BooleanProperty remoteChangeNotificationsProperty;

    private StringProperty eventBridgeFactoryProperty;
    private StringProperty javaGroupsMulticastAddressProperty;
    private StringProperty javaGroupsMulticastPortProperty;
    private StringProperty javaGroupsFileProperty;
    private StringProperty jmsConnectionFactoryProperty;

    public DataDomainAdapter(final CayenneProject cayenneProject)
    {
        // Must be assigned before property binding.
        this.cayenneProject = cayenneProject;

        cayenneProject.getDataDomain().getProperties().keySet().stream().forEach(key -> LOGGER.debug("DataDomain Properties: " + key + " = " + cayenneProject.getDataDomain().getProperties().get(key)));

        // Create adapters for all DataMaps and DataNodes.
        cayenneProject.getDataMaps().stream().forEach(dataMap -> dataMapAdapters.add(new DataMapAdapter(dataMap)));
        cayenneProject.getDataNodes().stream().forEach(dataNode -> dataNodeAdapters.add(new DataNodeAdapter(dataNode)));

        // Associate all DataMaps and DataNodes with this DataDomainAdapter.
        dataMapAdapters.stream().forEach(dataMapAdapter -> dataMapAdapter.setDataDomainAdapter(this));
        dataNodeAdapters.stream().forEach(dataNodeAdapter -> dataNodeAdapter.setDataDomainAdapter(this));

        try
        {
            nameProperty                       = bindString(DATA_DOMAIN_NAME);
            validatingObjectsProperty          = bindBoolean(VALIDATING_OBJECTS);
            sizeOfObjectCacheProperty          = bindInteger(OBJECT_CACHE_SIZE);
            useSharedCacheProperty             = bindBoolean(USE_SHARED_CACHE);
            remoteChangeNotificationsProperty  = bindBoolean(REMOTE_CHANGE_NOTIFICATIONS);
            eventBridgeFactoryProperty         = bindString(EVENT_BRIDGE_FACTORY);
            javaGroupsMulticastAddressProperty = bindString(JAVA_GROUPS_MULTICAST_ADDRESS);
            javaGroupsMulticastPortProperty    = bindString(JAVA_GROUPS_MULTICAST_PORT);
            javaGroupsFileProperty             = bindString(JAVA_GROUPS_FILE);
            jmsConnectionFactoryProperty       = bindString(JMS_CONNECTION_FACTORY);

        }
        catch (final NoSuchMethodException e)
        {
            throw new RuntimeException("Fix the builder.", e);
        }
    }

    public StringProperty nameProperty() { return nameProperty; }
    public String getName() { return nameProperty.get(); }
    public void setName(final String value) { nameProperty.set(value); }

    public BooleanProperty validatingObjectsProperty() { return validatingObjectsProperty; }
    public Boolean getValidatingObjects() { return validatingObjectsProperty.get(); }
    public void setValidatingObjects(final Boolean value) { validatingObjectsProperty.set(value); }

    public IntegerProperty sizeOfObjectCacheProperty() { return sizeOfObjectCacheProperty; }
    public Integer getSizeOfObjectCache() { return sizeOfObjectCacheProperty.get(); }
    public void setSizeOfObjectCache(final Integer value) { sizeOfObjectCacheProperty.set(value); }

    public BooleanProperty useSharedCacheProperty() { return useSharedCacheProperty; }
    public Boolean getUseSharedCache() { return useSharedCacheProperty.get(); }
    public void setUseSharedCache(final Boolean value) { useSharedCacheProperty.set(value); }

    public BooleanProperty remoteChangeNotificationsProperty() { return remoteChangeNotificationsProperty; }
    public Boolean getRemoteChangeNotifications() { return remoteChangeNotificationsProperty.get(); }
    public void setRemoteChangeNotifications(final Boolean value) { remoteChangeNotificationsProperty.set(value); }

    public StringProperty eventBridgeFactoryProperty() { return eventBridgeFactoryProperty; }
    public String getEventBridgeFactoryProperty() { return eventBridgeFactoryProperty.get(); }
    public void setEventBridgeFactoryProperty(final String value) { eventBridgeFactoryProperty.set(value); }

    public StringProperty jmsConnectionFactoryProperty() { return jmsConnectionFactoryProperty; }
    public String getJmsConnectionFactoryProperty() { return jmsConnectionFactoryProperty.get(); }
    public void setJmsConnectionFactoryProperty(final String value) { jmsConnectionFactoryProperty.set(value); }

    public StringProperty javaGroupsMulticastAddressProperty() { return javaGroupsMulticastAddressProperty; }
    public String getJavaGroupsMulticastAddressProperty() { return javaGroupsMulticastAddressProperty.get(); }
    public void setJavaGroupsMulticastAddressProperty(final String value) { javaGroupsMulticastAddressProperty.set(value); }

    public StringProperty javaGroupsMulticastPortProperty() { return javaGroupsMulticastPortProperty; }
    public String getJavaGroupsMulticastPortProperty() { return javaGroupsMulticastPortProperty.get(); }
    public void setJavaGroupsMulticastPortProperty(final String value) { javaGroupsMulticastPortProperty.set(value); }

    public StringProperty javaGroupsFileProperty() { return javaGroupsFileProperty; }
    public String getJavaGroupsFileProperty() { return javaGroupsFileProperty.get(); }
    public void setJavaGroupsFileProperty(final String value) { javaGroupsFileProperty.set(value); }


    public List<DataMapAdapter> getDataMapAdapters()
    {
        return dataMapAdapters;
    }

    public List<DataNodeAdapter> getDataNodeAdapters()
    {
        return dataNodeAdapters;
    }

    @Override
    public CayenneProject getCayennePropject()
    {
        return cayenneProject;
    }

    @Override
    public Object getWrappedObject()
    {
        return cayenneProject;
    }
}