modules/registry/registry-core/src/main/java/org/apache/airavata/registry/core/app/catalog/util/AppCatalogJPAUtils.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.airavata.registry.core.app.catalog.util;

import org.apache.airavata.common.exception.ApplicationSettingsException;
import org.apache.airavata.common.utils.ServerSettings;
import org.apache.airavata.registry.core.app.catalog.model.*;
import org.apache.airavata.registry.core.app.catalog.resources.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import javax.persistence.*;
import java.util.HashMap;
import java.util.Map;

public class AppCatalogJPAUtils {
    private final static Logger logger = LoggerFactory.getLogger(AppCatalogJPAUtils.class);
    private static final String PERSISTENCE_UNIT_NAME = "appcatalog_data";
    private static final String APPCATALOG_JDBC_DRIVER = "appcatalog.jdbc.driver";
    private static final String APPCATALOG_JDBC_URL = "appcatalog.jdbc.url";
    private static final String APPCATALOG_JDBC_USER = "appcatalog.jdbc.user";
    private static final String APPCATALOG_JDBC_PWD = "appcatalog.jdbc.password";
    private static final String APPCATALOG_VALIDATION_QUERY = "appcatalog.validationQuery";
    private static final String JPA_CACHE_SIZE = "jpa.cache.size";
    private static final String JPA_CACHE_ENABLED = "cache.enable";
    @PersistenceUnit(unitName = "appcatalog_data")
    protected static EntityManagerFactory factory;
    @PersistenceContext(unitName = "appcatalog_data")
    private static EntityManager appCatEntityManager;

    public static EntityManager getEntityManager() throws ApplicationSettingsException {
        if (factory == null) {
            String connectionProperties = "DriverClassName=" + readServerProperties(APPCATALOG_JDBC_DRIVER) + "," +
                    "Url=" + readServerProperties(APPCATALOG_JDBC_URL) + "?autoReconnect=true," +
                    "Username=" + readServerProperties(APPCATALOG_JDBC_USER) + "," +
                    "Password=" + readServerProperties(APPCATALOG_JDBC_PWD) +
                    ",validationQuery=" + readServerProperties(APPCATALOG_VALIDATION_QUERY);
            System.out.println(connectionProperties);
            Map<String, String> properties = new HashMap<String, String>();
            properties.put("openjpa.ConnectionDriverName", "org.apache.commons.dbcp.BasicDataSource");
            properties.put("openjpa.ConnectionProperties", connectionProperties);
            properties.put("openjpa.DynamicEnhancementAgent", "true");
            properties.put("openjpa.RuntimeUnenhancedClasses", "unsupported");
            // For app catalog, we don't need caching
//            properties.put("openjpa.DataCache","" + readServerProperties(JPA_CACHE_ENABLED) + "(CacheSize=" + Integer.valueOf(readServerProperties(JPA_CACHE_SIZE)) + ", SoftReferenceSize=0)");
//            properties.put("openjpa.QueryCache","" + readServerProperties(JPA_CACHE_ENABLED) + "(CacheSize=" + Integer.valueOf(readServerProperties(JPA_CACHE_SIZE)) + ", SoftReferenceSize=0)");
            properties.put("openjpa.RemoteCommitProvider", "sjvm");
            properties.put("openjpa.Log", "DefaultLevel=INFO, Runtime=INFO, Tool=INFO, SQL=INFO");
            properties.put("openjpa.jdbc.SynchronizeMappings", "buildSchema(ForeignKeys=true)");
            properties.put("openjpa.jdbc.QuerySQLCache", "false");
            properties.put("openjpa.ConnectionFactoryProperties", "PrettyPrint=true, PrettyPrintLineLength=72, PrintParameters=true, MaxActive=10, MaxIdle=5, MinIdle=2, MaxWait=31536000,  autoReconnect=true");
            factory = Persistence.createEntityManagerFactory(PERSISTENCE_UNIT_NAME, properties);
        }
        appCatEntityManager = factory.createEntityManager();
        return appCatEntityManager;
    }

    private static String readServerProperties(String propertyName) throws ApplicationSettingsException {
        try {
            return ServerSettings.getSetting(propertyName);
        } catch (ApplicationSettingsException e) {
            logger.error("Unable to read airavata-server.properties...", e);
            throw new ApplicationSettingsException("Unable to read airavata-server.properties...");
        }
    }

    /**
     * @param type model type
     * @param o    model type instance
     * @return corresponding resource object
     */
    public static AppCatalogResource getResource(AppCatalogResourceType type, Object o) {
        switch (type) {
            case COMPUTE_RESOURCE:
                if (o instanceof ComputeResource) {
                    return createComputeResource((ComputeResource) o);
                } else {
                    logger.error("Object should be a Compute Resource.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Compute Resource.");
                }
            case HOST_ALIAS:
                if (o instanceof HostAlias) {
                    return createHostAlias((HostAlias) o);
                } else {
                    logger.error("Object should be a Host Alias.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Host Alias.");
                }
            case HOST_IPADDRESS:
                if (o instanceof HostIPAddress) {
                    return createHostIPAddress((HostIPAddress) o);
                } else {
                    logger.error("Object should be a Host IPAdress.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Host IPAdress.");
                }
            case GSISSH_SUBMISSION:
                if (o instanceof GSISSHSubmission) {
                    return createGSSISSHSubmission((GSISSHSubmission) o);
                } else {
                    logger.error("Object should be a GSISSH Submission", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a GSISSH Submission.");
                }
            case UNICORE_JOB_SUBMISSION:
                if (o instanceof UnicoreJobSubmission) {
                    return createUnicoreJobSubmission((UnicoreJobSubmission) o);
                } else {
                    logger.error("Object should be a GSISSH Submission", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a GSISSH Submission.");
                }
            case UNICORE_DATA_MOVEMENT:
                if (o instanceof UnicoreDataMovement) {
                    return createUnicoreDataMovement((UnicoreDataMovement) o);
                } else {
                    logger.error("Object should be a GSISSH Submission", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a GSISSH Submission.");
                }
            case GSISSH_EXPORT:
                if (o instanceof GSISSHExport) {
                    return createGSISSHExport((GSISSHExport) o);
                } else {
                    logger.error("Object should be a GSISSH Export.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a GSISSH Export.");
                }
            case PRE_JOBCOMMAND:
                if (o instanceof PreJobCommand) {
                    return createPreJobCommand((PreJobCommand) o);
                } else {
                    logger.error("Object should be a GSISSHPreJobCommand.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a GSISSHPreJobCommand.");
                }
            case POST_JOBCOMMAND:
                if (o instanceof PostJobCommand) {
                    return createPostJObCommand((PostJobCommand) o);
                } else {
                    logger.error("Object should be a GSISSHPostJobCommand.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a GSISSHPostJobCommand.");
                }
            case GLOBUS_SUBMISSION:
                if (o instanceof GlobusJobSubmission) {
                    return createGlobusJobSubmission((GlobusJobSubmission) o);
                } else {
                    logger.error("Object should be a GlobusJobSubmission.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a GlobusJobSubmission.");
                }
            case GLOBUS_GK_ENDPOINT:
                if (o instanceof GlobusGKEndpoint) {
                    return createGlobusEndpoint((GlobusGKEndpoint) o);
                } else {
                    logger.error("Object should be a GlobusJobSubmission.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a GlobusJobSubmission.");
                }
            case SSH_JOB_SUBMISSION:
                if (o instanceof SshJobSubmission) {
                    return createSshJobSubmission((SshJobSubmission) o);
                } else {
                    logger.error("Object should be a Ssh Job Submission.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Ssh Job Submission.");
                }
            case SCP_DATA_MOVEMENT:
                if (o instanceof ScpDataMovement) {
                    return createScpDataMovement((ScpDataMovement) o);
                } else {
                    logger.error("Object should be a Scp Data Movement.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Scp Data Movement.");
                }
            case GRIDFTP_DATA_MOVEMENT:
                if (o instanceof GridftpDataMovement) {
                    return createGridftpDataMovement((GridftpDataMovement) o);
                } else {
                    logger.error("Object should be a Gridftp Data Movement.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Gridftp Data Movement.");
                }
            case GRIDFTP_ENDPOINT:
                if (o instanceof GridftpEndpoint) {
                    return createGridftpEndpoint((GridftpEndpoint) o);
                } else {
                    logger.error("Object should be a Gridftp Endpoint.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Gridftp Endpoint.");
                }
//            case JOB_SUBMISSION_PROTOCOL:
//                if (o instanceof JobSubmissionProtocol){
//                    return createJobSubmissionProtocol((JobSubmissionProtocol) o);
//                }else {
//                    logger.error("Object should be a JobSubmissionProtocol.", new IllegalArgumentException());
//                    throw new IllegalArgumentException("Object should be a JobSubmissionProtocol.");
//                }
//            case DATA_MOVEMENT_PROTOCOL:
//                if (o instanceof DataMovementProtocol){
//                    return createDataMovementProtocol((DataMovementProtocol) o);
//                }else {
//                    logger.error("Object should be a DataMovementProtocol.", new IllegalArgumentException());
//                    throw new IllegalArgumentException("Object should be a DataMovementProtocol.");
//                }
            case APPLICATION_MODULE:
                if (o instanceof ApplicationModule) {
                    return createApplicationModule((ApplicationModule) o);
                } else {
                    logger.error("Object should be a Application Module.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Application Module.");
                }
            case APPLICATION_DEPLOYMENT:
                if (o instanceof ApplicationDeployment) {
                    return createApplicationDeployment((ApplicationDeployment) o);
                } else {
                    logger.error("Object should be a Application Deployment.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Application Deployment.");
                }
            case LIBRARY_PREPAND_PATH:
                if (o instanceof LibraryPrepandPath) {
                    return createLibraryPrepPathResource((LibraryPrepandPath) o);
                } else {
                    logger.error("Object should be a Library Prepand path.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Library Prepand path.");
                }
            case LIBRARY_APEND_PATH:
                if (o instanceof LibraryApendPath) {
                    return createLibraryApendPathResource((LibraryApendPath) o);
                } else {
                    logger.error("Object should be a Library Apend path.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Library Apend.");
                }
            case APP_ENVIRONMENT:
                if (o instanceof AppEnvironment) {
                    return createAppEnvironmentResource((AppEnvironment) o);
                } else {
                    logger.error("Object should be a AppEnvironment.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a AppEnvironment.");
                }
            case APPLICATION_INTERFACE:
                if (o instanceof ApplicationInterface) {
                    return createAppInterfaceResource((ApplicationInterface) o);
                } else {
                    logger.error("Object should be a ApplicationInterface.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a ApplicationInterface.");
                }
            case APP_MODULE_MAPPING:
                if (o instanceof AppModuleMapping) {
                    return createAppModMappingResource((AppModuleMapping) o);
                } else {
                    logger.error("Object should be a AppModuleMapping.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a AppModuleMapping.");
                }
            case APPLICATION_OUTPUT:
                if (o instanceof ApplicationIntOutput) {
                    return createApplicationOutput((ApplicationIntOutput) o);
                } else {
                    logger.error("Object should be a ApplicationOutput.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a ApplicationOutput.");
                }
            case GATEWAY_PROFILE:
                if (o instanceof GatewayProfile) {
                    return createGatewayProfile((GatewayProfile) o);
                } else {
                    logger.error("Object should be a GatewayProfile.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a GatewayProfile.");
                }
            case COMPUTE_RESOURCE_PREFERENCE:
                if (o instanceof ComputeResourcePreference) {
                    return createComputeResourcePref((ComputeResourcePreference) o);
                } else {
                    logger.error("Object should be a Compute Resource Preference.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Compute Resource Preference.");
                }
            case STORAGE_PREFERENCE:
                if (o instanceof StoragePreference) {
                    return createStoragePref((StoragePreference) o);
                } else {
                    logger.error("Object should be a data storage Preference.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a data storage Preference.");
                }
            case STORAGE_RESOURCE:
                if (o instanceof StorageResource) {
                    return createStorageResource((StorageResource) o);
                } else {
                    logger.error("Object should be a storage resource.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a storage resource.");
                }
            case STORAGE_INTERFACE:
                if (o instanceof StorageInterface) {
                    return createStorageInterface((StorageInterface) o);
                } else {
                    logger.error("Object should be a storage interface.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a storage interface.");
                }
            case APPLICATION_INPUT:
                if (o instanceof ApplicationIntInput) {
                    return createApplicationInput((ApplicationIntInput) o);
                } else {
                    logger.error("Object should be a ApplicationInput.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a ApplicationInput.");
                }
            case BATCH_QUEUE:
                if (o instanceof BatchQueue) {
                    return createBatchQueue((BatchQueue) o);
                } else {
                    logger.error("Object should be a Batch Queue.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Batch Queue.");
                }
            case COMPUTE_RESOURCE_FILE_SYSTEM:
                if (o instanceof ComputeResourceFileSystem) {
                    return createComputeResourceFileSystem((ComputeResourceFileSystem) o);
                } else {
                    logger.error("Object should be a Compute Resource File System.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Compute Resource File System.");
                }
            case JOB_SUBMISSION_INTERFACE:
                if (o instanceof JobSubmissionInterface) {
                    return createJobSubmissionInterface((JobSubmissionInterface) o);
                } else {
                    logger.error("Object should be a Job Submission Interface.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Job Submission Interface.");
                }
            case DATA_MOVEMENT_INTERFACE:
                if (o instanceof DataMovementInterface) {
                    return createDataMovementInterface((DataMovementInterface) o);
                } else {
                    logger.error("Object should be a Data Movement Interface.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Data Movement Interface.");
                }
            case RESOURCE_JOB_MANAGER:
                if (o instanceof ResourceJobManager) {
                    return createResourceJobManager((ResourceJobManager) o);
                } else {
                    logger.error("Object should be a Resource Job Manager.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Resource Job Manager.");
                }
            case JOB_MANAGER_COMMAND:
                if (o instanceof JobManagerCommand) {
                    return createJobManagerCommand((JobManagerCommand) o);
                } else {
                    logger.error("Object should be a Job Manager Command.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Job Manager Command.");
                }
            case PARALLELISM_PREFIX_COMMAND:
                if (o instanceof ParallelismPrefixCommand) {
                    return createParallelismCommand((ParallelismPrefixCommand) o);
                } else {
                    logger.error("Object should be a Parallelism Prefix Command.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Parallelism Prefix Command.");
                }
            case LOCAL_SUBMISSION:
                if (o instanceof LocalSubmission) {
                    return createLocalSubmission((LocalSubmission) o);
                } else {
                    logger.error("Object should be a Local Submission.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Local Submission.");
                }
            case LOCAL_DATA_MOVEMENT:
                if (o instanceof LocalDataMovement) {
                    return createLocalDataMovement((LocalDataMovement) o);
                } else {
                    logger.error("Object should be a Local Data Movement.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Local Data Movement.");
                }
            case MODULE_LOAD_CMD:
                if (o instanceof ModuleLoadCmd) {
                    return createModuleLoadCmd((ModuleLoadCmd) o);
                } else {
                    logger.error("Object should be a Module Load Cmd.", new IllegalArgumentException());
                    throw new IllegalArgumentException("Object should be a Module Load Cmd.");
                }
            default:
                logger.error("Illegal data type..", new IllegalArgumentException());
                throw new IllegalArgumentException("Illegal data type..");
        }
    }

    private static AppCatalogResource createLocalDataMovement(LocalDataMovement o) {
        LocalDataMovementResource localDataMovementResource = new LocalDataMovementResource();
        if (o != null) {
            localDataMovementResource.setDataMovementInterfaceId(o.getDataMovementInterfaceId());
        }
        return localDataMovementResource;
    }

    private static AppCatalogResource createLocalSubmission(LocalSubmission o) {
        LocalSubmissionResource localSubmissionResource = new LocalSubmissionResource();
        if (o != null) {
            localSubmissionResource.setResourceJobManagerId(o.getResourceJobManagerId());
            localSubmissionResource.setResourceJobManagerResource((ResourceJobManagerResource) createResourceJobManager(o.getResourceJobManager()));
            localSubmissionResource.setJobSubmissionInterfaceId(o.getJobSubmissionInterfaceId());
            localSubmissionResource.setCreatedTime(o.getCreationTime());
            if (o.getUpdateTime() != null) {
                localSubmissionResource.setUpdatedTime(o.getUpdateTime());
            }
        }
        return localSubmissionResource;
    }

    private static AppCatalogResource createJobManagerCommand(JobManagerCommand o) {
        JobManagerCommandResource jobManagerCommandResource = new JobManagerCommandResource();
        if (o != null) {
            jobManagerCommandResource.setResourceJobManagerId(o.getResourceJobManagerId());
            jobManagerCommandResource.setResourceJobManagerResource((ResourceJobManagerResource) createResourceJobManager(o.getResourceJobManager()));
            jobManagerCommandResource.setCommandType(o.getCommandType());
            jobManagerCommandResource.setCommand(o.getCommand());
        }
        return jobManagerCommandResource;
    }

    private static AppCatalogResource createParallelismCommand(ParallelismPrefixCommand o) {
        ParallelismPrefixCommandResource parallelismPrefixCommandResource = new ParallelismPrefixCommandResource();
        if (o != null) {
            parallelismPrefixCommandResource.setResourceJobManagerId(o.getResourceJobManagerId());
            parallelismPrefixCommandResource.setResourceJobManagerResource((ResourceJobManagerResource) createResourceJobManager(o.getResourceJobManager()));
            parallelismPrefixCommandResource.setCommandType(o.getCommandType());
            parallelismPrefixCommandResource.setCommand(o.getCommand());
        }
        return parallelismPrefixCommandResource;
    }

    private static AppCatalogResource createResourceJobManager(ResourceJobManager o) {
        ResourceJobManagerResource resourceJobManagerResource = new ResourceJobManagerResource();
        if (o != null) {
            resourceJobManagerResource.setResourceJobManagerId(o.getResourceJobManagerId());
            resourceJobManagerResource.setPushMonitoringEndpoint(o.getPushMonitoringEndpoint());
            resourceJobManagerResource.setJobManagerBinPath(o.getJobManagerBinPath());
            resourceJobManagerResource.setResourceJobManagerType(o.getResourceJobManagerType());
            resourceJobManagerResource.setCreatedTime(o.getCreationTime());
            if (o.getUpdateTime() != null) {
                resourceJobManagerResource.setUpdatedTime(o.getUpdateTime());
            }
        }
        return resourceJobManagerResource;
    }

    private static AppCatalogResource createDataMovementInterface(DataMovementInterface o) {
        DataMovementInterfaceResource dataMovementInterfaceResource = new DataMovementInterfaceResource();
        if (o != null) {
            dataMovementInterfaceResource.setComputeResourceId(o.getComputeResourceId());
            dataMovementInterfaceResource.setComputeHostResource((ComputeResourceResource) createComputeResource(o.getComputeResource()));
            dataMovementInterfaceResource.setDataMovementProtocol(o.getDataMovementProtocol());
            dataMovementInterfaceResource.setDataMovementInterfaceId(o.getDataMovementInterfaceId());
            dataMovementInterfaceResource.setPriorityOrder(o.getPriorityOrder());
            dataMovementInterfaceResource.setCreatedTime(o.getCreationTime());
            if (o.getUpdateTime() != null) {
                dataMovementInterfaceResource.setUpdatedTime(o.getUpdateTime());
            }
        }
        return dataMovementInterfaceResource;
    }

    private static AppCatalogResource createJobSubmissionInterface(JobSubmissionInterface o) {
        JobSubmissionInterfaceResource jobSubmissionInterfaceResource = new JobSubmissionInterfaceResource();
        if (o != null) {
            jobSubmissionInterfaceResource.setJobSubmissionInterfaceId(o.getJobSubmissionInterfaceId());
            jobSubmissionInterfaceResource.setComputeResourceId(o.getComputeResourceId());
            jobSubmissionInterfaceResource.setComputeHostResource((ComputeResourceResource) createComputeResource(o.getComputeResource()));
            jobSubmissionInterfaceResource.setJobSubmissionProtocol(o.getJobSubmissionProtocol());
            jobSubmissionInterfaceResource.setPriorityOrder(o.getPriorityOrder());
            jobSubmissionInterfaceResource.setCreatedTime(o.getCreationTime());
            if (o.getUpdateTime() != null) {
                jobSubmissionInterfaceResource.setUpdatedTime(o.getUpdateTime());
            }
        }
        return jobSubmissionInterfaceResource;
    }

    private static AppCatalogResource createComputeResourceFileSystem(ComputeResourceFileSystem o) {
        ComputeResourceFileSystemResource computeResourceFileSystemResource = new ComputeResourceFileSystemResource();
        if (o != null) {
            computeResourceFileSystemResource.setComputeResourceId(o.getComputeResourceId());
            computeResourceFileSystemResource.setComputeHostResource((ComputeResourceResource) createComputeResource(o.getComputeResource()));
            computeResourceFileSystemResource.setPath(o.getPath());
            computeResourceFileSystemResource.setFileSystem(o.getFileSystem());
        }
        return computeResourceFileSystemResource;
    }

    private static AppCatalogResource createBatchQueue(BatchQueue o) {
        BatchQueueResource batchQueueResource = new BatchQueueResource();
        if (o != null) {
            batchQueueResource.setComputeResourceId(o.getComputeResourceId());
            batchQueueResource.setComputeHostResource((ComputeResourceResource) createComputeResource(o.getComputeResource()));
            batchQueueResource.setMaxRuntime(o.getMaxRuntime());
            batchQueueResource.setMaxJobInQueue(o.getMaxJobInQueue());
            batchQueueResource.setQueueDescription(o.getQueueDescription());
            batchQueueResource.setQueueName(o.getQueueName());
            batchQueueResource.setMaxProcessors(o.getMaxProcessors());
            batchQueueResource.setMaxNodes(o.getMaxNodes());
            batchQueueResource.setMaxMemory(o.getMaxMemory());
        }
        return batchQueueResource;
    }

    private static AppCatalogResource createComputeResource(ComputeResource o) {
        ComputeResourceResource computeResourceResource = new ComputeResourceResource();
        if (o != null) {
            computeResourceResource.setResourceDescription(o.getResourceDescription());
            computeResourceResource.setResourceId(o.getResourceId());
            computeResourceResource.setHostName(o.getHostName());
            computeResourceResource.setCreatedTime(o.getCreationTime());
            computeResourceResource.setEnabled(o.getEnabled());
            computeResourceResource.setMaxMemoryPerNode(o.getMaxMemoryPerNode());
            computeResourceResource.setGatewayUsageExec(o.getGatewayUsageExec());
            computeResourceResource.setGatewayUsageModLoadCMD(o.getGatewayUsageModLoadCMD());
            computeResourceResource.setGatewayUsageReporting(o.isGatewayUsageReporting());
            if (o.getUpdateTime() != null) {
                computeResourceResource.setUpdatedTime(o.getUpdateTime());
            }
        }
        return computeResourceResource;
    }

    private static AppCatalogResource createHostAlias(HostAlias o) {
        HostAliasAppResource aliasResource = new HostAliasAppResource();
        if (o != null) {
            aliasResource.setResourceID(o.getResourceID());
            aliasResource.setAlias(o.getAlias());
            aliasResource.setComputeHostResource((ComputeResourceResource) createComputeResource(o.getComputeResource()));
        }
        return aliasResource;
    }

    private static AppCatalogResource createHostIPAddress(HostIPAddress o) {
        HostIPAddressResource ipAddressResource = new HostIPAddressResource();
        if (o != null) {
            ipAddressResource.setResourceID(o.getResourceID());
            ipAddressResource.setIpaddress(o.getIpaddress());
            ipAddressResource.setComputeHostResource((ComputeResourceResource) createComputeResource(o.getComputeResource()));
        }
        return ipAddressResource;
    }

    private static AppCatalogResource createGSSISSHSubmission(GSISSHSubmission o) {
        GSISSHSubmissionResource submissionResource = new GSISSHSubmissionResource();
        if (o != null) {
            submissionResource.setSubmissionID(o.getSubmissionID());
            submissionResource.setResourceJobManager(o.getResourceJobManager());
            submissionResource.setSshPort(o.getSshPort());
            submissionResource.setInstalledPath(o.getInstalledPath());
            submissionResource.setMonitorMode(o.getMonitorMode());
        }
        return submissionResource;
    }

    private static AppCatalogResource createUnicoreJobSubmission(UnicoreJobSubmission o) {
        UnicoreJobSubmissionResource submissionResource = new UnicoreJobSubmissionResource();
        if (o != null) {
            submissionResource.setjobSubmissionInterfaceId(o.getSubmissionID());
            submissionResource.setUnicoreEndpointUrl(o.getUnicoreEndpointUrl());
            submissionResource.setSecurityProtocol(o.getSecurityProtocol());
        }
        return submissionResource;
    }

    private static AppCatalogResource createUnicoreDataMovement(UnicoreDataMovement o) {
        UnicoreDataMovementResource dataMovementResource = new UnicoreDataMovementResource();
        if (o != null) {
            dataMovementResource.setDataMovementId(o.getDataMovementId());
            dataMovementResource.setUnicoreEndpointUrl(o.getUnicoreEndpointUrl());
            dataMovementResource.setSecurityProtocol(o.getSecurityProtocol());
        }
        return dataMovementResource;
    }

    private static AppCatalogResource createGSISSHExport(GSISSHExport o) {
        GSISSHExportResource resource = new GSISSHExportResource();
        if (o != null) {
            resource.setSubmissionID(o.getSubmissionID());
            resource.setExport(o.getExport());
            resource.setGsisshSubmissionResource((GSISSHSubmissionResource) createGSSISSHSubmission(o.getGsisshJobSubmission()));
        }
        return resource;
    }

    private static AppCatalogResource createPreJobCommand(PreJobCommand o) {
        PreJobCommandResource resource = new PreJobCommandResource();
        if (o != null) {
            resource.setAppDeploymentId(o.getDeploymentId());
            resource.setCommand(o.getCommand());
            resource.setOrder(o.getOrder());
            resource.setAppDeploymentResource((AppDeploymentResource) createApplicationDeployment(o.getApplicationDeployment()));
        }
        return resource;
    }

    private static AppCatalogResource createPostJObCommand(PostJobCommand o) {
        PostJobCommandResource resource = new PostJobCommandResource();
        if (o != null) {
            resource.setAppDeploymentId(o.getDeploymentId());
            resource.setCommand(o.getCommand());
            resource.setOrder(o.getOrder());
            resource.setAppDeploymentResource((AppDeploymentResource) createApplicationDeployment(o.getDeployment()));
        }
        return resource;
    }

    private static AppCatalogResource createGlobusJobSubmission(GlobusJobSubmission o) {
        GlobusJobSubmissionResource resource = new GlobusJobSubmissionResource();
        if (o != null) {
            resource.setSubmissionID(o.getSubmissionID());
            resource.setResourceJobManager(o.getResourceJobManager());
            resource.setSecurityProtocol(o.getSecurityProtocol());
        }
        return resource;
    }

    private static AppCatalogResource createGlobusEndpoint(GlobusGKEndpoint o) {
        GlobusGKEndpointResource resource = new GlobusGKEndpointResource();
        if (o != null) {
            resource.setSubmissionID(o.getSubmissionID());
            resource.setEndpoint(o.getEndpoint());
            resource.setGlobusJobSubmissionResource((GlobusJobSubmissionResource) createGlobusJobSubmission(o.getGlobusSubmission()));
        }
        return resource;
    }

    private static AppCatalogResource createSshJobSubmission(SshJobSubmission o) {
        SshJobSubmissionResource sshJobSubmissionResource = new SshJobSubmissionResource();
        if (o != null) {
            sshJobSubmissionResource.setResourceJobManagerId(o.getResourceJobManagerId());
            sshJobSubmissionResource.setResourceJobManagerResource((ResourceJobManagerResource) createResourceJobManager(o.getResourceJobManager()));
            sshJobSubmissionResource.setJobSubmissionInterfaceId(o.getJobSubmissionInterfaceId());
            sshJobSubmissionResource.setAlternativeSshHostname(o.getAlternativeSshHostname());
            sshJobSubmissionResource.setSecurityProtocol(o.getSecurityProtocol());
            sshJobSubmissionResource.setSshPort(o.getSshPort());
            sshJobSubmissionResource.setMonitorMode(o.getMonitorMode());
            sshJobSubmissionResource.setCreatedTime(o.getCreationTime());
            if (o.getUpdateTime() != null) {
                sshJobSubmissionResource.setUpdatedTime(o.getUpdateTime());
            }
        }
        return sshJobSubmissionResource;
    }

    private static AppCatalogResource createScpDataMovement(ScpDataMovement o) {
        ScpDataMovementResource scpDataMovementResource = new ScpDataMovementResource();
        if (o != null) {
            scpDataMovementResource.setQueueDescription(o.getQueueDescription());
            scpDataMovementResource.setDataMovementInterfaceId(o.getDataMovementInterfaceId());
            scpDataMovementResource.setSecurityProtocol(o.getSecurityProtocol());
            scpDataMovementResource.setAlternativeScpHostname(o.getAlternativeScpHostname());
            scpDataMovementResource.setSshPort(o.getSshPort());
            scpDataMovementResource.setCreatedTime(o.getCreationTime());
            if (o.getUpdateTime() != null) {
                scpDataMovementResource.setUpdatedTime(o.getUpdateTime());
            }
        }
        return scpDataMovementResource;
    }

    private static AppCatalogResource createGridftpDataMovement(GridftpDataMovement o) {
        GridftpDataMovementResource gridftpDataMovementResource = new GridftpDataMovementResource();
        if (o != null) {
            gridftpDataMovementResource.setDataMovementInterfaceId(o.getDataMovementInterfaceId());
            gridftpDataMovementResource.setSecurityProtocol(o.getSecurityProtocol());
            gridftpDataMovementResource.setCreatedTime(o.getCreationTime());
            if (o.getUpdateTime() != null) {
                gridftpDataMovementResource.setUpdatedTime(o.getUpdateTime());
            }
        }
        return gridftpDataMovementResource;
    }

    private static AppCatalogResource createGridftpEndpoint(GridftpEndpoint o) {
        GridftpEndpointResource gridftpEndpointResource = new GridftpEndpointResource();
        if (o != null) {
            gridftpEndpointResource.setEndpoint(o.getEndpoint());
            gridftpEndpointResource.setDataMovementInterfaceId(o.getDataMovementInterfaceId());
            gridftpEndpointResource.setGridftpDataMovementResource((GridftpDataMovementResource) createGridftpDataMovement(o.getGridftpDataMovement()));
            gridftpEndpointResource.setCreatedTime(o.getCreationTime());
            if (o.getUpdateTime() != null) {
                gridftpEndpointResource.setUpdatedTime(o.getUpdateTime());
            }
        }
        return gridftpEndpointResource;
    }

//    private static Resource createJobSubmissionProtocol(JobSubmissionProtocol o) {
//        JobSubmissionProtocolResource resource = new JobSubmissionProtocolResource();
//        if (o != null){
//            resource.setResourceID(o.getResourceID());
//            resource.setSubmissionID(o.getSubmissionID());
//            resource.setJobType(o.getJobType());
//            resource.setComputeHostResource((ComputeResourceResource)createComputeResource(o.getComputeResource()));
//        }
//        return resource;
//    }
//
//    private static Resource createDataMovementProtocol(DataMovementProtocol o) {
//        DataMovementProtocolResource resource = new DataMovementProtocolResource();
//        if (o != null) {
//            resource.setResourceID(o.getResourceID());
//            resource.setDataMoveID(o.getDataMoveID());
//            resource.setDataMoveType(o.getDataMoveType());
//            resource.setComputeHostResource((ComputeResourceResource)createComputeResource(o.getComputeResource()));
//        }
//        return resource;
//    }

    private static AppCatalogResource createApplicationModule(ApplicationModule o) {
        AppModuleResource moduleResource = new AppModuleResource();
        if (o != null) {
            moduleResource.setModuleId(o.getModuleID());
            moduleResource.setModuleDesc(o.getModuleDesc());
            moduleResource.setGatewayId(o.getGatewayId());
            moduleResource.setModuleName(o.getModuleName());
            moduleResource.setModuleVersion(o.getModuleVersion());
            moduleResource.setCreatedTime(o.getCreationTime());
            if (o.getUpdateTime() != null) {
                moduleResource.setUpdatedTime(o.getUpdateTime());
            }
        }
        return moduleResource;
    }

    private static AppCatalogResource createApplicationDeployment(ApplicationDeployment o) {
        AppDeploymentResource resource = new AppDeploymentResource();
        if (o != null) {
            resource.setDeploymentId(o.getDeploymentID());
            resource.setAppDes(o.getApplicationDesc());
            resource.setAppModuleId(o.getAppModuleID());
            resource.setHostId(o.getHostID());
            resource.setExecutablePath(o.getExecutablePath());
            resource.setGatewayId(o.getGatewayId());
            resource.setParallelism(o.getParallelism());
            resource.setModuleResource((AppModuleResource) createApplicationModule(o.getApplicationModule()));
            resource.setHostResource((ComputeResourceResource) createComputeResource(o.getComputeResource()));
            resource.setCreatedTime(o.getCreationTime());
            if (o.getUpdateTime() != null) {
                resource.setUpdatedTime(o.getUpdateTime());
            }
        }
        return resource;
    }

    private static AppCatalogResource createLibraryPrepPathResource(LibraryPrepandPath o) {
        LibraryPrepandPathResource resource = new LibraryPrepandPathResource();
        if (o != null) {
            resource.setDeploymentId(o.getDeploymentID());
            resource.setName(o.getName());
            resource.setValue(o.getValue());
            resource.setAppDeploymentResource((AppDeploymentResource) createApplicationDeployment(o.getApplicationDeployment()));
        }
        return resource;
    }

    private static AppCatalogResource createLibraryApendPathResource(LibraryApendPath o) {
        LibraryApendPathResource resource = new LibraryApendPathResource();
        if (o != null) {
            resource.setDeploymentId(o.getDeploymentID());
            resource.setName(o.getName());
            resource.setValue(o.getValue());
            resource.setAppDeploymentResource((AppDeploymentResource) createApplicationDeployment(o.getApplicationDeployment()));
        }
        return resource;
    }

    private static AppCatalogResource createAppEnvironmentResource(AppEnvironment o) {
        AppEnvironmentResource resource = new AppEnvironmentResource();
        if (o != null) {
            resource.setDeploymentId(o.getDeploymentID());
            resource.setName(o.getName());
            resource.setValue(o.getValue());
            resource.setOrder(o.getOrder());
            resource.setAppDeploymentResource((AppDeploymentResource) createApplicationDeployment(o.getApplicationDeployment()));
        }
        return resource;
    }

    private static AppCatalogResource createAppInterfaceResource(ApplicationInterface o) {
        AppInterfaceResource resource = new AppInterfaceResource();
        if (o != null) {
            resource.setInterfaceId(o.getInterfaceID());
            resource.setAppName(o.getAppName());
            resource.setAppDescription(o.getAppDescription());
            resource.setCreatedTime(o.getCreationTime());
            resource.setGatewayId(o.getGatewayId());
            resource.setArchiveWorkingDirectory(o.isArchiveWorkingDirectory());
            resource.setHasOptionalFileInputs(o.isHasOptionalFileInputs());
            if (o.getUpdateTime() != null) {
                resource.setUpdatedTime(o.getUpdateTime());
            }
        }
        return resource;
    }

    private static AppCatalogResource createAppModMappingResource(AppModuleMapping o) {
        AppModuleMappingAppCatalogResourceAppCat resource = new AppModuleMappingAppCatalogResourceAppCat();
        if (o != null) {
            resource.setInterfaceId(o.getInterfaceID());
            resource.setModuleId(o.getModuleID());
        }
        return resource;
    }

    private static AppCatalogResource createApplicationInput(ApplicationIntInput o) {
        ApplicationInputResource resource = new ApplicationInputResource();
        if (o != null) {
            resource.setInterfaceID(o.getInterfaceID());
            resource.setInputKey(o.getInputKey());
            resource.setInputVal(o.getInputVal());
            resource.setDataType(o.getDataType());
            resource.setMetadata(o.getMetadata());
            resource.setAppArgument(o.getAppArgument());
            resource.setUserFriendlyDesc(o.getUserFriendlyDesc());
            resource.setStandardInput(o.isStandardInput());
            resource.setInputOrder(o.getInputOrder());
            resource.setRequired(o.isRequired());
            resource.setRequiredToCMD(o.isRequiredToCMD());
            resource.setDataStaged(o.isDataStaged());
            resource.setAppInterfaceResource((AppInterfaceResource) createAppInterfaceResource(o.getApplicationInterface()));
        }
        return resource;
    }

    private static AppCatalogResource createApplicationOutput(ApplicationIntOutput o) {
        ApplicationOutputResource resource = new ApplicationOutputResource();
        if (o != null) {
            resource.setInterfaceID(o.getInterfaceID());
            resource.setOutputKey(o.getOutputKey());
            resource.setOutputVal(o.getOutputVal());
            resource.setDataType(o.getDataType());
            resource.setRequired(o.isRequired());
            resource.setRequiredToCMD(o.isRequiredToCMD());
            resource.setDataMovement(o.isDataMovement());
            resource.setDataNameLocation(o.getDataNameLocation());
            resource.setSearchQuery(o.getSearchQuery());
            resource.setAppArgument(o.getApplicationArgument());
            resource.setOutputStreaming(o.isOutputStreaming());
            resource.setAppInterfaceResource((AppInterfaceResource) createAppInterfaceResource(o.getApplicationInterface()));
        }
        return resource;
    }

    private static AppCatalogResource createGatewayProfile(GatewayProfile o) {
        GatewayProfileResource resource = new GatewayProfileResource();
        if (o != null) {
            resource.setGatewayID(o.getGatewayID());
            resource.setCreatedTime(o.getCreationTime());
            resource.setCredentialStoreToken(o.getCredentialStoreToken());
            resource.setIdentityServerTenant(o.getIdentityServerTenant());
            resource.setIdentityServerPwdCredToken(o.getIdentityServerPwdCredToken());
            if (o.getUpdateTime() != null) {
                resource.setUpdatedTime(o.getUpdateTime());
            }
        }
        return resource;
    }

    private static AppCatalogResource createComputeResourcePref(ComputeResourcePreference o) {
        ComputeHostPreferenceResource resource = new ComputeHostPreferenceResource();
        if (o != null) {
            resource.setGatewayId(o.getGatewayId());
            resource.setResourceId(o.getResourceId());
            resource.setOverrideByAiravata(o.isOverrideByAiravata());
            resource.setPreferredJobProtocol(o.getPreferedJobSubmissionProtocol());
            resource.setPreferedDMProtocol(o.getPreferedDataMoveProtocol());
            resource.setBatchQueue(o.getBatchQueue());
            resource.setScratchLocation(o.getScratchLocation());
            resource.setProjectNumber(o.getProjectNumber());
            resource.setLoginUserName(o.getLoginUserName());
            resource.setResourceCSToken(o.getComputeResourceCSToken());
            resource.setUsageReportingGatewayId(o.getUsageReportingGWId());
            resource.setComputeHostResource((ComputeResourceResource) createComputeResource(o.getComputeHostResource()));
            resource.setGatewayProfile((GatewayProfileResource) createGatewayProfile(o.getGatewayProfile()));
            resource.setQualityOfService(o.getQualityOfService());
            resource.setReservation(o.getReservation());
            resource.setReservationStartTime(o.getReservationStartTime());
            resource.setReservationEndTime(o.getReservationEndTime());
        }
        return resource;
    }

    private static AppCatalogResource createStoragePref(StoragePreference o) {
        StoragePreferenceResource resource = new StoragePreferenceResource();
        if (o != null) {
            resource.setGatewayId(o.getGatewayId());
            resource.setStorageResourceId(o.getStorageResourceId());
            resource.setLoginUserName(o.getLoginUserName());
            resource.setResourceCSToken(o.getComputeResourceCSToken());
            resource.setFsRootLocation(o.getFsRootLocation());
            resource.setGatewayProfile((GatewayProfileResource) createGatewayProfile(o.getGatewayProfile()));
        }
        return resource;
    }

    private static AppCatalogResource createStorageResource(StorageResource o) {
        StorageResourceResource resource = new StorageResourceResource();
        if (o != null) {
            resource.setStorageResourceId(o.getStorageResourceId());
            resource.setHostName(o.getHostName());
            resource.setEnabled(o.getEnabled());
            resource.setResourceDescription(o.getDescription());
        }
        return resource;
    }

    private static AppCatalogResource createStorageInterface(StorageInterface o) {
        StorageInterfaceResource resource = new StorageInterfaceResource();
        if (o != null) {
            resource.setStorageResourceId(o.getStorageResourceId());
            resource.setDataMovementInterfaceId(o.getDataMovementInterfaceId());
            resource.setDataMovementProtocol(o.getDataMovementProtocol());
            resource.setPriorityOrder(o.getPriorityOrder());
            resource.setStorageResourceResource((StorageResourceResource) createStorageResource(o.getStorageResource()));
        }
        return resource;
    }

    private static AppCatalogResource createModuleLoadCmd(ModuleLoadCmd o) {
        ModuleLoadCmdResource moduleLoadCmdResource = new ModuleLoadCmdResource();
        if (o != null) {
            moduleLoadCmdResource.setCmd(o.getCmd());
            moduleLoadCmdResource.setAppDeploymentId(o.getAppDeploymentId());
            moduleLoadCmdResource.setOrder(o.getOrder());
            moduleLoadCmdResource.setAppDeploymentResource((AppDeploymentResource) createApplicationDeployment(o.getApplicationDeployment()));
        }
        return moduleLoadCmdResource;
    }
}