import org.slf4j.Logger
import org.slf4j.LoggerFactory

import pl.edu.icm.synat.api.services.profile.events.ProfileEvent
import pl.edu.icm.synat.api.services.usercatalog.UserCatalog
import pl.edu.icm.synat.api.services.usercatalog.model.UserData
import pl.edu.icm.synat.application.commons.pagination.PaginationResult
import pl.edu.icm.synat.events.EventBus
import pl.edu.icm.synat.logic.services.user.exception.UserProfileNotFoundException

Integer PAGE_SIZE = 1000;

EventBus eventBus = serviceUtils.getService("profile.recordEvent", EventBus.class, "jms");
UserCatalog catalog = serviceUtils.getService("UserCatalog", UserCatalog.class);

int currentOffset = 0;
PaginationResult<UserData> users = catalog.searchUsers("SYNAT", null, null, null, null, null, null, 0, PAGE_SIZE);

Logger logger = LoggerFactory.getLogger("Migrate Users Graph Script");

while(!users.results.empty){
	users.results.each {
		try {
			eventBus.reportEvent(new ProfileEvent(new Date(), "user-profile-service", it.id, false));
		}catch (UserProfileNotFoundException e)	{
			logger.warn(e.message);
		}
	}
	currentOffset+=users.results.size();
	users = catalog.searchUsers("SYNAT", null, null, null, null, null, null, currentOffset, PAGE_SIZE);
}