openmeetings-web/src/test/java/org/apache/openmeetings/AbstractOmServerTest.java - openmeetings - Git at Google

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

 import static java.util.UUID.randomUUID;
 import static org.apache.openmeetings.db.util.ApplicationHelper.ensureApplication;
 import static org.apache.openmeetings.util.OpenmeetingsVariables.DEFAULT_CONTEXT_NAME;
 import static org.apache.openmeetings.util.OpenmeetingsVariables.getCryptClassName;
 import static org.apache.openmeetings.util.OpenmeetingsVariables.getWicketApplicationName;
 import static org.apache.openmeetings.util.OpenmeetingsVariables.setWicketApplicationName;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
 import static org.junit.jupiter.api.Assertions.fail;

 import java.util.Date;
 import java.util.Random;

 import org.apache.openmeetings.db.dao.basic.ConfigurationDao;
 import org.apache.openmeetings.db.dao.calendar.AppointmentDao;
 import org.apache.openmeetings.db.dao.label.LabelDao;
 import org.apache.openmeetings.db.dao.user.GroupDao;
 import org.apache.openmeetings.db.dao.user.UserDao;
 import org.apache.openmeetings.db.entity.calendar.Appointment;
 import org.apache.openmeetings.db.entity.room.Room;
 import org.apache.openmeetings.db.entity.user.Address;
 import org.apache.openmeetings.db.entity.user.User;
 import org.apache.openmeetings.installation.ImportInitvalues;
 import org.apache.openmeetings.installation.InstallationConfig;
 import org.apache.openmeetings.util.OmFileHelper;
 import org.apache.openmeetings.web.app.Application;
 import org.apache.tomcat.util.scan.Constants;
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.BeforeEach;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.test.context.junit.jupiter.web.SpringJUnitWebConfig;

 @SpringJUnitWebConfig(locations={"classpath:applicationContext.xml"})
 @RegularTest
 public abstract class AbstractOmServerTest {
 	private static final Logger log = LoggerFactory.getLogger(AbstractOmServerTest.class);
 	private static final String timeZone = "Europe/Berlin";
 	public static final int ONE_HOUR = 60 * 60 * 1000;
 	public static final String adminUsername = "admin";
 	public static final String regularUsername = "user";
 	public static final String soapUsername = "soap";
 	protected static final String groupAdminUsername = "groupAdmin";
 	public static final String userpass = "Q!w2e3r4t5";
 	public static final String group = "smoketest";
 	public static final String email = "junit@openmeetings.apache.org";
 	public static final String UNIT_TEST_ARAB_EXT_TYPE = "النُّجُومُ الخَمْسَةِ";
 	public static final Random rnd = new Random();

 	@Autowired
 	protected AppointmentDao appointmentDao;
 	@Autowired
 	protected UserDao userDao;
 	@Autowired
 	protected GroupDao groupDao;
 	@Autowired
 	private ImportInitvalues importInitvalues;
 	@Autowired
 	protected ConfigurationDao cfgDao;
 	@Autowired
 	protected Application app;

 	@BeforeAll
 	public static void init() {
 		setOmHome();
 		System.setProperty(Constants.SKIP_JARS_PROPERTY, "*");
 		LabelDao.initLanguageMap();
 		if (LabelDao.getLanguages().isEmpty()) {
 			fail("Failed to set languages");
 		}
 	}

 	@BeforeEach
 	public void serverSetup() throws Exception {
 		if (app.getName() == null) {
 			app.setName(DEFAULT_CONTEXT_NAME);
 		}
 		if (getWicketApplicationName() == null) {
 			setWicketApplicationName(app.getName());
 		}
 		ensureApplication();
 		ensureSchema(userDao, importInitvalues);
 	}

 	public static void setOmHome() {
 		String webappsDir = System.getProperty("om.home", ".");
 		OmFileHelper.setOmHome(webappsDir);
 		if (!OmFileHelper.getOmHome().exists() || !OmFileHelper.getOmHome().isDirectory()) {
 			fail("Invalid directory is specified as OM HOME: " + webappsDir);
 		}
 	}

 	public static void ensureSchema(UserDao userDao, ImportInitvalues importInitvalues) throws Exception {
 		if (userDao.count() < 1) {
 			makeDefaultScheme(importInitvalues);
 			log.info("Default scheme created successfully");
 		} else {
 			log.info("Default scheme already created");
 		}
 		assertNotNull(getCryptClassName(), "Crypt class name should not be null");
 	}

 	public Appointment getAppointment() {
 		Date start = new Date();
 		Date end = new Date();
 		end.setTime(start.getTime() + ONE_HOUR);
 		return getAppointment(start, end);
 	}

 	public Appointment getAppointment(Date start, Date end) {
 		return getAppointment(userDao.get(1L), start, end);
 	}

 	public Appointment getAppointment(User owner, Date start, Date end) {
 		return getAppointment(owner, null, start, end);
 	}

 	public static Appointment getAppointment(User owner, Room r, Date start, Date end) {
 		// add new appointment
 		Appointment ap = new Appointment();

 		ap.setTitle("appointmentName");
 		ap.setLocation("appointmentLocation");

 		ap.setStart(start);
 		ap.setEnd(end);
 		ap.setDescription("appointmentDescription");
 		ap.setInserted(new Date());
 		ap.setDeleted(false);
 		ap.setIsDaily(false);
 		ap.setIsWeekly(false);
 		ap.setIsMonthly(false);
 		ap.setIsYearly(false);
 		ap.setPasswordProtected(false);

 		ap.setOwner(owner);
 		ap.setConnectedEvent(false);

 		if (ap.getReminder() == null) {
 			ap.setReminder(Appointment.Reminder.NONE);
 		}

 		if (r == null) {
 			r = new Room();
 			r.setType(Room.Type.CONFERENCE);
 			r.setAppointment(true);
 		}
 		ap.setRoom(r);
 		return ap;
 	}

 	public static Appointment createAppointment(AppointmentDao appointmentDao, Appointment ap) {
 		assertNotNull(appointmentDao, "Can't access to appointment dao implimentation");
 		// add new appointment
 		ap = appointmentDao.update(ap, null, false);
 		assertNotNull(ap.getId(), "Can't add appointment");
 		return ap;
 	}

 	public Appointment createAppointment(Appointment ap) {
 		return createAppointment(appointmentDao, ap);
 	}

 	public User getUser() throws Exception {
 		return getUser(randomUUID().toString());
 	}

 	protected static String getLogin(String uid) {
 		return String.format("login%s", uid);
 	}

 	protected static String getEmail(String uid) {
 		return String.format("email%s@local", uid);
 	}

 	public static String createPass() {
 		return "pass1_!@#$%_A";
 	}

 	public static User getUser(String uuid) throws Exception {
 		User u = new User();
 		// add user
 		u.setFirstname("firstname" + uuid);
 		u.setLastname("lastname" + uuid);
 		u.setLogin(getLogin(uuid));
 		u.setAddress(new Address());
 		u.getAddress().setEmail(getEmail(uuid));
 		u.setRights(UserDao.getDefaultRights());
 		u.setTimeZoneId("Asia/Bangkok");
 		u.updatePassword(createPass());
 		u.setLanguageId(1L);
 		return u;
 	}

 	public User createUser() throws Exception {
 		return createUser(randomUUID().toString());
 	}

 	public User createUser(String uuid) throws Exception {
 		return createUser(getUser(uuid));
 	}

 	public static User createUser(UserDao userDao, User u) {
 		u = userDao.update(u, null);
 		assertNotNull(u, "Can't add user");
 		return u;
 	}

 	public User createUser(User u) {
 		return createUser(userDao, u);
 	}

 	private static void makeDefaultScheme(ImportInitvalues importInitvalues) throws Exception {
 		InstallationConfig cfg = new InstallationConfig();
 		cfg.setUsername(adminUsername);
 		cfg.setPassword(userpass);
 		cfg.setEmail(email);
 		cfg.setGroup(group);
 		cfg.setTimeZone(timeZone);
 		importInitvalues.loadAll(cfg, false);
 		// regular user
 		importInitvalues.createSystemUser(getUser(randomUUID().toString()), group, regularUsername, userpass, false, null);

 		// soap user
 		importInitvalues.createSystemUser(getUser(randomUUID().toString()), group, soapUsername, userpass, false, u -> {
 			u.getRights().remove(User.Right.ROOM);
 			u.getRights().remove(User.Right.DASHBOARD);
 			u.getRights().add(User.Right.SOAP);
 		});

 		// group admin
 		importInitvalues.createSystemUser(getUser(randomUUID().toString()), group, groupAdminUsername, userpass, true, null);
 	}

 	public User getContact(String uuid, Long ownerId) {
 		return userDao.getContact("email" + uuid, "firstname" + uuid, "lastname" + uuid, ownerId);
 	}

 	public User createUserContact(Long ownerId) {
 		return createUserContact(getContact(randomUUID().toString(), ownerId), ownerId);
 	}

 	public User createUserContact(User user, Long ownerId) {
 		user = userDao.update(user, ownerId);
 		assertNotNull(user, "Cann't add user");
 		return user;
 	}
 }
	/*
	* 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.openmeetings;

	import static java.util.UUID.randomUUID;
	import static org.apache.openmeetings.db.util.ApplicationHelper.ensureApplication;
	import static org.apache.openmeetings.util.OpenmeetingsVariables.DEFAULT_CONTEXT_NAME;
	import static org.apache.openmeetings.util.OpenmeetingsVariables.getCryptClassName;
	import static org.apache.openmeetings.util.OpenmeetingsVariables.getWicketApplicationName;
	import static org.apache.openmeetings.util.OpenmeetingsVariables.setWicketApplicationName;
	import static org.junit.jupiter.api.Assertions.assertNotNull;
	import static org.junit.jupiter.api.Assertions.fail;

	import java.util.Date;
	import java.util.Random;

	import org.apache.openmeetings.db.dao.basic.ConfigurationDao;
	import org.apache.openmeetings.db.dao.calendar.AppointmentDao;
	import org.apache.openmeetings.db.dao.label.LabelDao;
	import org.apache.openmeetings.db.dao.user.GroupDao;
	import org.apache.openmeetings.db.dao.user.UserDao;
	import org.apache.openmeetings.db.entity.calendar.Appointment;
	import org.apache.openmeetings.db.entity.room.Room;
	import org.apache.openmeetings.db.entity.user.Address;
	import org.apache.openmeetings.db.entity.user.User;
	import org.apache.openmeetings.installation.ImportInitvalues;
	import org.apache.openmeetings.installation.InstallationConfig;
	import org.apache.openmeetings.util.OmFileHelper;
	import org.apache.openmeetings.web.app.Application;
	import org.apache.tomcat.util.scan.Constants;
	import org.junit.jupiter.api.BeforeAll;
	import org.junit.jupiter.api.BeforeEach;
	import org.slf4j.Logger;
	import org.slf4j.LoggerFactory;
	import org.springframework.beans.factory.annotation.Autowired;
	import org.springframework.test.context.junit.jupiter.web.SpringJUnitWebConfig;

	@SpringJUnitWebConfig(locations={"classpath:applicationContext.xml"})
	@RegularTest
	public abstract class AbstractOmServerTest {
	private static final Logger log = LoggerFactory.getLogger(AbstractOmServerTest.class);
	private static final String timeZone = "Europe/Berlin";
	public static final int ONE_HOUR = 60 * 60 * 1000;
	public static final String adminUsername = "admin";
	public static final String regularUsername = "user";
	public static final String soapUsername = "soap";
	protected static final String groupAdminUsername = "groupAdmin";
	public static final String userpass = "Q!w2e3r4t5";
	public static final String group = "smoketest";
	public static final String email = "junit@openmeetings.apache.org";
	public static final String UNIT_TEST_ARAB_EXT_TYPE = "النُّجُومُ الخَمْسَةِ";
	public static final Random rnd = new Random();

	@Autowired
	protected AppointmentDao appointmentDao;
	@Autowired
	protected UserDao userDao;
	@Autowired
	protected GroupDao groupDao;
	@Autowired
	private ImportInitvalues importInitvalues;
	@Autowired
	protected ConfigurationDao cfgDao;
	@Autowired
	protected Application app;

	@BeforeAll
	public static void init() {
	setOmHome();
	System.setProperty(Constants.SKIP_JARS_PROPERTY, "*");
	LabelDao.initLanguageMap();
	if (LabelDao.getLanguages().isEmpty()) {
	fail("Failed to set languages");
	}
	}

	@BeforeEach
	public void serverSetup() throws Exception {
	if (app.getName() == null) {
	app.setName(DEFAULT_CONTEXT_NAME);
	}
	if (getWicketApplicationName() == null) {
	setWicketApplicationName(app.getName());
	}
	ensureApplication();
	ensureSchema(userDao, importInitvalues);
	}

	public static void setOmHome() {
	String webappsDir = System.getProperty("om.home", ".");
	OmFileHelper.setOmHome(webappsDir);
	if (!OmFileHelper.getOmHome().exists() \|\| !OmFileHelper.getOmHome().isDirectory()) {
	fail("Invalid directory is specified as OM HOME: " + webappsDir);
	}
	}

	public static void ensureSchema(UserDao userDao, ImportInitvalues importInitvalues) throws Exception {
	if (userDao.count() < 1) {
	makeDefaultScheme(importInitvalues);
	log.info("Default scheme created successfully");
	} else {
	log.info("Default scheme already created");
	}
	assertNotNull(getCryptClassName(), "Crypt class name should not be null");
	}

	public Appointment getAppointment() {
	Date start = new Date();
	Date end = new Date();
	end.setTime(start.getTime() + ONE_HOUR);
	return getAppointment(start, end);
	}

	public Appointment getAppointment(Date start, Date end) {
	return getAppointment(userDao.get(1L), start, end);
	}

	public Appointment getAppointment(User owner, Date start, Date end) {
	return getAppointment(owner, null, start, end);
	}

	public static Appointment getAppointment(User owner, Room r, Date start, Date end) {
	// add new appointment
	Appointment ap = new Appointment();

	ap.setTitle("appointmentName");
	ap.setLocation("appointmentLocation");

	ap.setStart(start);
	ap.setEnd(end);
	ap.setDescription("appointmentDescription");
	ap.setInserted(new Date());
	ap.setDeleted(false);
	ap.setIsDaily(false);
	ap.setIsWeekly(false);
	ap.setIsMonthly(false);
	ap.setIsYearly(false);
	ap.setPasswordProtected(false);

	ap.setOwner(owner);
	ap.setConnectedEvent(false);

	if (ap.getReminder() == null) {
	ap.setReminder(Appointment.Reminder.NONE);
	}

	if (r == null) {
	r = new Room();
	r.setType(Room.Type.CONFERENCE);
	r.setAppointment(true);
	}
	ap.setRoom(r);
	return ap;
	}

	public static Appointment createAppointment(AppointmentDao appointmentDao, Appointment ap) {
	assertNotNull(appointmentDao, "Can't access to appointment dao implimentation");
	// add new appointment
	ap = appointmentDao.update(ap, null, false);
	assertNotNull(ap.getId(), "Can't add appointment");
	return ap;
	}

	public Appointment createAppointment(Appointment ap) {
	return createAppointment(appointmentDao, ap);
	}

	public User getUser() throws Exception {
	return getUser(randomUUID().toString());
	}

	protected static String getLogin(String uid) {
	return String.format("login%s", uid);
	}

	protected static String getEmail(String uid) {
	return String.format("email%s@local", uid);
	}

	public static String createPass() {
	return "pass1_!@#$%_A";
	}

	public static User getUser(String uuid) throws Exception {
	User u = new User();
	// add user
	u.setFirstname("firstname" + uuid);
	u.setLastname("lastname" + uuid);
	u.setLogin(getLogin(uuid));
	u.setAddress(new Address());
	u.getAddress().setEmail(getEmail(uuid));
	u.setRights(UserDao.getDefaultRights());
	u.setTimeZoneId("Asia/Bangkok");
	u.updatePassword(createPass());
	u.setLanguageId(1L);
	return u;
	}

	public User createUser() throws Exception {
	return createUser(randomUUID().toString());
	}

	public User createUser(String uuid) throws Exception {
	return createUser(getUser(uuid));
	}

	public static User createUser(UserDao userDao, User u) {
	u = userDao.update(u, null);
	assertNotNull(u, "Can't add user");
	return u;
	}

	public User createUser(User u) {
	return createUser(userDao, u);
	}

	private static void makeDefaultScheme(ImportInitvalues importInitvalues) throws Exception {
	InstallationConfig cfg = new InstallationConfig();
	cfg.setUsername(adminUsername);
	cfg.setPassword(userpass);
	cfg.setEmail(email);
	cfg.setGroup(group);
	cfg.setTimeZone(timeZone);
	importInitvalues.loadAll(cfg, false);
	// regular user
	importInitvalues.createSystemUser(getUser(randomUUID().toString()), group, regularUsername, userpass, false, null);

	// soap user
	importInitvalues.createSystemUser(getUser(randomUUID().toString()), group, soapUsername, userpass, false, u -> {
	u.getRights().remove(User.Right.ROOM);
	u.getRights().remove(User.Right.DASHBOARD);
	u.getRights().add(User.Right.SOAP);
	});

	// group admin
	importInitvalues.createSystemUser(getUser(randomUUID().toString()), group, groupAdminUsername, userpass, true, null);
	}

	public User getContact(String uuid, Long ownerId) {
	return userDao.getContact("email" + uuid, "firstname" + uuid, "lastname" + uuid, ownerId);
	}

	public User createUserContact(Long ownerId) {
	return createUserContact(getContact(randomUUID().toString(), ownerId), ownerId);
	}

	public User createUserContact(User user, Long ownerId) {
	user = userDao.update(user, ownerId);
	assertNotNull(user, "Cann't add user");
	return user;
	}
	}