component-test/src/main/java/org/apache/fineract/cn/notification/AbstractNotificationTest.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.fineract.cn.notification;

import org.apache.fineract.cn.anubis.test.v1.TenantApplicationSecurityEnvironmentTestRule;
import org.apache.fineract.cn.api.context.AutoUserContext;
import org.apache.fineract.cn.notification.api.v1.client.NotificationManager;
import org.apache.fineract.cn.notification.api.v1.events.NotificationEventConstants;
import org.apache.fineract.cn.notification.service.internal.config.NotificationConfiguration;
import org.apache.fineract.cn.notification.service.internal.service.NotificationService;
import org.apache.fineract.cn.test.fixture.TenantDataStoreContextTestRule;
import org.apache.fineract.cn.test.listener.EnableEventRecording;
import org.apache.fineract.cn.test.listener.EventRecorder;
import org.junit.*;
import org.junit.runner.RunWith;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.cloud.netflix.feign.EnableFeignClients;
import org.springframework.cloud.netflix.ribbon.RibbonClient;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;
import org.springframework.test.context.junit4.SpringRunner;

import java.security.interfaces.RSAPrivateKey;

@RunWith(SpringRunner.class)
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.DEFINED_PORT,
		classes = {AbstractNotificationTest.TestConfiguration.class})
public class AbstractNotificationTest extends SuiteTestEnvironment {
	
	@ClassRule
	public final static TenantDataStoreContextTestRule tenantDataStoreContext = TenantDataStoreContextTestRule.forRandomTenantName(cassandraInitializer, postgreSQLInitializer);
	public static final String LOGGER_NAME = "test-logger";
	public static final String TEST_USER = "homer";
	public static final String TEST_ADDRESS = "egraham15@alustudent.com"; // Replace with developer's dummy testing email
	public static final String TEST_TEMPLATE= "test_sample";
	public static final String SMS_TEST_NUMBER= "+23058409206"; // Replace with developers dummy testing number
	
	@SuppressWarnings("WeakerAccess")
	@Autowired
	@Qualifier(LOGGER_NAME)
	public Logger logger;
	public AutoUserContext userContext;
	@Autowired
	public EventRecorder eventRecorder;
	@Autowired
	public NotificationManager notificationManager;
	@Autowired
	public NotificationService notificationService;
	
	@Rule
	public final TenantApplicationSecurityEnvironmentTestRule tenantApplicationSecurityEnvironment
			= new TenantApplicationSecurityEnvironmentTestRule(testEnvironment, this::waitForInitialize);
	
	public AbstractNotificationTest() {
		super();
	}
	
	@Before
	public void prepTest() {
		userContext = tenantApplicationSecurityEnvironment.createAutoUserContext(AbstractNotificationTest.TEST_USER);
		final RSAPrivateKey tenantPrivateKey = tenantApplicationSecurityEnvironment.getSystemSecurityEnvironment().tenantPrivateKey();
		logger.info("tenantPrivateKey = {}", tenantPrivateKey);
	}
	
	@After
	public void cleanTest() {
		userContext.close();
		eventRecorder.clear();
	}
	
	public boolean waitForInitialize() {
		try {
			return this.eventRecorder.wait(NotificationEventConstants.INITIALIZE, APP_VERSION);
		} catch (final InterruptedException e) {
			throw new IllegalStateException(e);
		}
	}
	
	@Configuration
	@EnableEventRecording
	@EnableFeignClients(basePackages = {"org.apache.fineract.cn.notification.api.v1.client"})
	@ComponentScan({"org.apache.fineract.cn.notification.listener",
			"org.apache.fineract.cn.notification.service.internal.service",
			"org.apache.fineract.cn.notification.service.internal.service.externalServiceClients"
	})
	@Import({NotificationConfiguration.class})
	public static class TestConfiguration {
		public TestConfiguration() {
			super();
		}
		
		@Bean(name = LOGGER_NAME)
		public Logger logger() {
			return LoggerFactory.getLogger(LOGGER_NAME);
		}
	}
}