Commit 0f83781a authored by Grzegorz Pietrusza's avatar Grzegorz Pietrusza

do not use datastore in command

parent 9257cc0c
......@@ -34,7 +34,7 @@ public class RegisterTasksCommand extends ConfiguredCommand<ApplicationConfigura
private void initializeTasks(ApplicationConfiguration applicationConfiguration, Injector injector)
{
Datastore datastore = injector.getInstance(Datastore.class);
Datastore datastore = injector.getInstance(Datastore.class); //todo: do not use datastore?
TasksRepository tasksRepository = injector.getInstance(TasksRepository.class);
List<TextTaskConfig> cryptoTasks = applicationConfiguration.getTextTasks();
......@@ -73,7 +73,6 @@ public class RegisterTasksCommand extends ConfiguredCommand<ApplicationConfigura
@Override
protected void run(Bootstrap<ApplicationConfiguration> bootstrap, Namespace namespace, ApplicationConfiguration applicationConfiguration) throws Exception
{
//todo: move and merge with app setup
Injector injector = Guice.createInjector(new ApplicationModule(applicationConfiguration));
initializeTasks(applicationConfiguration, injector);
}
......
......@@ -9,6 +9,7 @@ import modules.ApplicationModule;
import net.sourceforge.argparse4j.inf.Namespace;
import org.mongodb.morphia.Datastore;
import repositories.TeamsRepository;
import repositories.UsersRepository;
public class RegisterTeamsCommand extends ConfiguredCommand<ApplicationConfiguration>
{
......@@ -22,20 +23,19 @@ public class RegisterTeamsCommand extends ConfiguredCommand<ApplicationConfigura
private void initializeTasks(ApplicationConfiguration applicationConfiguration, Injector injector)
{
Datastore datastore = injector.getInstance(Datastore.class);
TeamsRepository teamsRepository = injector.getInstance(TeamsRepository.class);
UsersRepository usersRepository = injector.getInstance(UsersRepository.class);
teamsRepository.clean();
applicationConfiguration.getTeams().forEach(team -> {
team.getMembers().stream().forEach(datastore::save); //todo: use usersrepostiroy to save?
datastore.save(team);
team.getMembers().stream().forEach(usersRepository::add);
teamsRepository.add(team);
});
}
@Override
protected void run(Bootstrap<ApplicationConfiguration> bootstrap, Namespace namespace, ApplicationConfiguration applicationConfiguration) throws Exception
{
//todo: move and merge with app setup
Injector injector = Guice.createInjector(new ApplicationModule(applicationConfiguration));
initializeTasks(applicationConfiguration, injector);
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment