summaryrefslogtreecommitdiffstats
path: root/catalog-ui/src
AgeCommit message (Expand)AuthorFilesLines
2017-07-17[SDC] rebase 1710 codeMichael Lando101-1470/+1002
2017-07-16[sdc] - merged 1707_build into sdc LFIdan Amit1-8/+8
2017-07-12[sdc] rebase updateMichael Lando421-31897/+6184
2017-07-03[sdc] - last merges before moving to LFTal Gitelman28-151/+264
2017-06-29[SDC] rebase codeTal Gitelman17-184/+155
2017-06-19[sdc] update to the current code baseMichael Lando14-21/+53
2017-06-18[sdc] update code of sdcMichael Lando31-343/+380
2017-06-11[SDC-29] rebase continue work to align sourceMichael Lando86-1592/+1684
2017-06-09[SDC-29] catalog 1707 rebase commit.Michael Lando801-0/+119488
id='n65' href='#n65'>65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 
/*
 * Copyright © 2018 European Support Limited
 *
 * 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.openecomp.sdcrests.item.rest.services.catalog.notification;

import com.fasterxml.jackson.databind.ObjectMapper;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.Collection;
import java.util.Map;
import java.util.Objects;
import org.onap.sdc.tosca.services.YamlUtil;
import org.openecomp.sdc.logging.api.Logger;
import org.openecomp.sdc.logging.api.LoggerFactory;
import org.openecomp.sdcrests.item.rest.services.catalog.notification.http.HttpConfiguration;
import org.openecomp.sdcrests.item.rest.services.catalog.notification.http.HttpTaskProducer;
import org.openecomp.sdcrests.item.types.ItemAction;

/**
 * Creates an instance of {@link Notifier}, initialized according to current configuration.
 * The configuration must be passed via the {@link #CONFIG_FILE_PROPERTY} JVM argument.
 */
public class NotifierFactory {

    private static final Logger LOGGER = LoggerFactory.getLogger(NotifierFactory.class);

    private static final String CONFIG_FILE_PROPERTY = "configuration.yaml";
    private static final String CONFIG_SECTION = "catalogNotificationsConfig";

    private static final Notifier INSTANCE;

    static {
        INSTANCE = createInstance();
    }

    /**
     * Returns a {@link Notifier} instance according to the provided configuration. If no configuration was not
     * provided, or the given configuration is incorrect, then an instance with reduced functionality will be returned.
     *
     * @return available instance of {@link Notifier}
     */
    public static Notifier getInstance() {
        return INSTANCE;
    }

    static Notifier createInstance() {

        try {

            String file = Objects.requireNonNull(System.getProperty(CONFIG_FILE_PROPERTY),
                    "Config file location must be specified via system property " + CONFIG_FILE_PROPERTY);

            Object config = getNotificationConfiguration(file);
            ObjectMapper mapper = new ObjectMapper();
            HttpConfiguration httpConfig = mapper.convertValue(config, HttpConfiguration.class);

            return new AsyncNotifier(new HttpTaskProducer(httpConfig));

        } catch (Exception e) {
            LOGGER.warn("Failed to initialize notifier. Notifications will not be sent", e);
            return new UnsupportedConfigurationNotifier();
        }
    }

    private static Object getNotificationConfiguration(String file) throws IOException {

        Map<?, ?> configuration = Objects.requireNonNull(readConfigurationFile(file), "Configuration cannot be empty");
        Object notificationConfig = configuration.get(CONFIG_SECTION);
        if (notificationConfig == null) {
            throw new EntryNotConfiguredException(CONFIG_SECTION + " section");
        }

        return notificationConfig;
    }

    private static Map<?, ?> readConfigurationFile(String file) throws IOException {

        try (InputStream fileInput = new FileInputStream(file)) {
            YamlUtil yamlUtil = new YamlUtil();
            return yamlUtil.yamlToMap(fileInput);
        }
    }

    static class UnsupportedConfigurationNotifier implements Notifier {

        @Override
        public void execute(Collection<String> itemIds, ItemAction action) {
            throw new IllegalStateException("Cannot send notifications. The notifier was not properly initialized");
        }
    }
}