/*
 * 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.openejb.config;

import org.apache.openejb.OpenEJBException;
import org.apache.openejb.config.sys.Resource;
import org.apache.openejb.jee.JndiConsumer;
import org.apache.openejb.jee.KeyedCollection;
import org.apache.openejb.jee.ManagedExecutor;
import org.apache.openejb.util.PropertyPlaceHolderHelper;

import org.apache.openejb.util.Join;

import java.util.List;
import java.util.Map;
import java.util.Properties;

public class ConvertManagedExecutorServiceDefinitions extends BaseConvertDefinitions {
    @Override
    public AppModule deploy(AppModule appModule) throws OpenEJBException {
        final List<JndiConsumer> jndiConsumers = collectConsumers(appModule);

        final KeyedCollection<String, ManagedExecutor> managedExecutors = new KeyedCollection<>();
        final KeyedCollection<String, ManagedExecutor> managedExecutorsFromCompManagedBeans = new KeyedCollection<>();

        for (final JndiConsumer consumer : jndiConsumers) {
            if (consumer == null) {
                continue;
            }

            if (consumer instanceof CompManagedBean) {
                /*
                 * TOMEE-2053: It may contain invalid context service definitions
                 * because it is never updated with content from the ejb-jar.xml
                 * Wait until all other consumers have been processed, to safely
                 * decide which context services to transfer;
                 */

                managedExecutorsFromCompManagedBeans.addAll(consumer.getManagedExecutorMap().values());
                continue;
            }
            managedExecutors.addAll(consumer.getManagedExecutorMap().values());
        }

        final Map<String, ManagedExecutor> managedExecutorsMap = managedExecutors.toMap();
        for (ManagedExecutor managedExecutor : managedExecutorsFromCompManagedBeans) {
            //Interested only in ManagedExecutorServices that come from non-JndiConsumers
            if (!managedExecutorsMap.containsKey(managedExecutor.getName().getvalue())) {
                managedExecutors.add(managedExecutor);
            }
        }

        for (final ManagedExecutor managedExecutor : managedExecutors) {
            appModule.getResources().add(toResource(managedExecutor));
        }

        return appModule;
    }

    private Resource toResource(final ManagedExecutor managedExecutor) {
        final String name = cleanUpName(managedExecutor.getName().getvalue());

        final Resource def = new Resource(name, jakarta.enterprise.concurrent.ManagedExecutorService.class.getName());

        def.setJndi(managedExecutor.getName().getvalue().replaceFirst("java:", ""));

        final Properties p = def.getProperties();

        String contextName = managedExecutor.getContextService() != null
            ? managedExecutor.getContextService().getvalue()
            : "java:comp/DefaultContextService";
        // Translate JNDI name to TomEE Resource ID, otherwise AutoConfig will fail to resolve it
        // and try to fix it by rewriting this to an unwanted ContextService
        if ("java:comp/DefaultContextService".equals(contextName)) {
            contextName = "Default Context Service";
        }

        put(p, "Context", contextName);
        put(p, "HungTaskThreshold", managedExecutor.getHungTaskThreshold());
        put(p, "Max", managedExecutor.getMaxAsync());
        put(p, "Virtual", managedExecutor.getVirtual());
        if (managedExecutor.getQualifier() != null && !managedExecutor.getQualifier().isEmpty()) {
            put(p, "Qualifiers", Join.join(",", managedExecutor.getQualifier()));
        }

        // to force it to be bound in JndiEncBuilder
        put(p, "JndiName", def.getJndi());

        return def;
    }

    private static void put(final Properties properties, final String key, final Object value) {
        if (key == null) {
            return;
        }
        if (value == null) {
            return;
        }

        properties.put(key, PropertyPlaceHolderHelper.value(String.valueOf(value)));
    }
}
