Development of collect info module.

src/main/java/com/jasmine/StartJasmine.java

@@ -1,4 +1,5 @@
 package com.jasmine;
+
 import org.springframework.context.annotation.AnnotationConfigApplicationContext;
 
 import com.jasmine.conf.JasmineFactory;
@@ -9,23 +10,24 @@
 import javafx.scene.layout.Pane;
 import javafx.stage.Stage;
 
-public class StartJasmine extends Application{
+public class StartJasmine extends Application {
 
 	public static void main(String[] args) {
 		launch(args);
 	}
-	
+
 	@Override
 	public void start(Stage primaryStage) throws Exception {
 		AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(JasmineFactory.class);
+
 		SpringFxmlLoader loader = new SpringFxmlLoader(context);
-		
-		Pane root = (Pane) loader.loadLogin("/fxml/login.fxml",primaryStage);
+
+		Pane root = (Pane) loader.loadLogin("/fxml/login.fxml", primaryStage);
 		Scene stackScene = new Scene(root);
 		primaryStage.setScene(stackScene);
 		primaryStage.setTitle("Jasmine IPA - Login");
 		primaryStage.show();
-		
+
 	}
-	
+
 }

src/main/java/com/jasmine/conf/JasmineFactory.java

@@ -6,19 +6,11 @@
 
 import com.jasmine.controller.HomeController;
 import com.jasmine.controller.LoginController;
-import com.jasmine.integrations.TwitterConnector;
-import com.jasmine.model.User;
 
-@ComponentScan(basePackages = "com.jasmine")
 @Configuration
+@ComponentScan(basePackages = "com.jasmine")
 public class JasmineFactory {
 
-	@Bean
-	public User user() {
-		User u = new User();
-		return u;
-	}
-
 	@Bean
 	public LoginController loginController() {
 		LoginController lc = new LoginController();
@@ -30,10 +22,4 @@ public HomeController homeController() {
 		HomeController hc = new HomeController();
 		return hc;
 	}
-
-	@Bean(name = "twitterConnector")
-	public TwitterConnector twitterConnector() {
-		return new TwitterConnector();
-	}
-
 }

src/main/java/com/jasmine/conf/SpringFxmlLoader.java

@@ -11,58 +11,51 @@
 import javafx.fxml.FXMLLoader;
 import javafx.scene.Parent;
 import javafx.stage.Stage;
-import javafx.util.Callback;
 
 public class SpringFxmlLoader {
 
 	private ApplicationContext context;
-	
-	public SpringFxmlLoader(ApplicationContext context){
+
+	public SpringFxmlLoader(ApplicationContext context) {
 		this.context = context;
 	}
-	
-	public Parent loadLogin(String url, Stage stage) throws IOException{
-		
+
+	public Parent loadLogin(String url, Stage stage) throws IOException {
+
 		InputStream fxmlStream = null;
-		
-		try{
+
+		try {
 			fxmlStream = LoginController.class.getResourceAsStream(url);
-			LoginController instance = (LoginController)context.getBean(LoginController.class);
+			LoginController instance = context.getBean(LoginController.class);
 			instance.setPrimaryStage(stage);
 			FXMLLoader loader = new FXMLLoader();
-			//loader.getNamespace().put("controller", instance);
-			loader.setControllerFactory(new Callback<Class<?>, Object>() {
-				public Object call(Class<?> clazz) {
-					return context.getBean(clazz);
-				}
-			});
+			loader.setControllerFactory(clazz -> context.getBean(clazz));
 			return loader.load(fxmlStream);
-		}finally {
-			if (fxmlStream != null){
+		} finally {
+			if (fxmlStream != null) {
 				fxmlStream.close();
 			}
 		}
-		
+
 	}
-	
-	public Parent loadHome(String url, Stage stage) throws IOException{
-		
+
+	public Parent loadHome(String url, Stage stage) throws IOException {
+
 		InputStream fxmlStream = null;
-		
-		try{
+
+		try {
 			fxmlStream = HomeController.class.getResourceAsStream(url);
-			HomeController instance = (HomeController)context.getBean(HomeController.class);
+			HomeController instance = context.getBean(HomeController.class);
 			instance.setPrimaryStage(stage);
 			FXMLLoader loader = new FXMLLoader();
-			loader.getNamespace().put("controller", instance);
+			loader.setControllerFactory(clazz -> context.getBean(clazz));
 			return loader.load(fxmlStream);
-		}finally {
-			if (fxmlStream != null){
+		} finally {
+			if (fxmlStream != null) {
 				fxmlStream.close();
 			}
 		}
-		
+
 	}
-
-
+
 }

src/main/java/com/jasmine/controller/HomeController.java

@@ -5,6 +5,7 @@
 import java.util.TimerTask;
 
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
 
 import com.jasmine.integrations.TwitterConnector;
 import com.jasmine.model.User;
@@ -17,6 +18,7 @@
 import javafx.stage.Stage;
 import twitter4j.TwitterException;
 
+@Controller
 public class HomeController {
 
 	@FXML

src/main/java/com/jasmine/controller/LoginController.java

@@ -1,15 +1,14 @@
 package com.jasmine.controller;
 
-
-
-
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.AnnotationConfigApplicationContext;
+import org.springframework.stereotype.Controller;
 
 import com.jasmine.conf.JasmineFactory;
 import com.jasmine.conf.SpringFxmlLoader;
 import com.jasmine.model.User;
 import com.jasmine.service.UserService;
+import com.jasmine.service.collector.InfoCollector;
 
 import javafx.fxml.FXML;
 import javafx.scene.Scene;
@@ -22,24 +21,31 @@
 
 /**
  * Controller of the main login window
+ * 
  * @author enunes
  * @since 29/09/2016
  *
  */
+@Controller
 public class LoginController {
 
-	@Autowired private UserService userService;
-	@FXML private TextField txtLogin;
-	@FXML private PasswordField txtPassword;
-
+	@Autowired
+	private UserService userService;
+	@Autowired
+	private InfoCollector infoCollector;
+	@FXML
+	private TextField txtLogin;
+	@FXML
+	private PasswordField txtPassword;
 	private Stage primaryStage;
-
+	private User user;
+
 	@FXML
-	private void login(){
-		User user = userService.login(txtLogin.getText(), txtPassword.getText());
-		if (user != null){
+	private void login() {
+		this.user = this.userService.login(this.txtLogin.getText(), this.txtPassword.getText());
+		if (this.user != null) {
 			openHome();
-		}else {
+		} else {
 			Alert alert = new Alert(AlertType.ERROR);
 			alert.setHeaderText("Error");
 			alert.setContentText("User not found.");
@@ -50,35 +56,40 @@ private void login(){
 	/**
 	 * Open the home.
 	 */
-	private void openHome(){
+	private void openHome() {
 		AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(JasmineFactory.class);
 		SpringFxmlLoader loader = new SpringFxmlLoader(context);
-		
-		try{
-			Stage newStage = new Stage();		//Create a new Window(Stage)
-			StackPane root = (StackPane) loader.loadHome("/fxml/home.fxml",newStage);
+
+		try {
+			Stage newStage = new Stage(); //Create a new Window(Stage)
+			StackPane root = (StackPane) loader.loadHome("/fxml/home.fxml", newStage);
 			Scene stackScene = new Scene(root);
 			newStage.setScene(stackScene);
 			newStage.setTitle("Jasmine IPA - Core");
 			newStage.show();
-			primaryStage.close();	//Close the previous window
-			this.primaryStage = newStage; 	//Set the new stage on primaryStage variable.
-		}catch (Exception e){
+			this.primaryStage.close(); //Close the previous window
+			this.primaryStage = newStage; //Set the new stage on primaryStage variable.
+
+			this.infoCollector.startTwitterCollectService(this.user);
+
+		} catch (Exception e) {
 			e.printStackTrace();
 		}
 	}
-	
+
 	@FXML
-	private void exit(){
+	private void exit() {
 		System.exit(1);
 	}
-	
+
 	/**
 	 * Method helper to set the primary stage.
-	 * @param stage new stage.
+	 * 
+	 * @param stage
+	 *            new stage.
 	 */
-	public void setPrimaryStage(Stage stage){
+	public void setPrimaryStage(Stage stage) {
 		this.primaryStage = stage;
 	}
-	
+
 }

src/main/java/com/jasmine/exceptions/DataSourceException.java

@@ -0,0 +1,30 @@
+package com.jasmine.exceptions;
+
+public class DataSourceException extends Exception {
+
+	/**
+	 * 
+	 */
+	private static final long serialVersionUID = -6842384730824942123L;
+
+	public DataSourceException() {
+		super();
+	}
+
+	public DataSourceException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
+		super(message, cause, enableSuppression, writableStackTrace);
+	}
+
+	public DataSourceException(String message, Throwable cause) {
+		super(message, cause);
+	}
+
+	public DataSourceException(String message) {
+		super(message);
+	}
+
+	public DataSourceException(Throwable cause) {
+		super(cause);
+	}
+
+}

src/main/java/com/jasmine/model/UserTwitterData.java

@@ -0,0 +1,55 @@
+package com.jasmine.model;
+
+import org.springframework.data.annotation.Id;
+import org.springframework.data.mongodb.core.mapping.Document;
+
+import twitter4j.Status;
+
+@Document(collection = "usertwitterdata")
+public class UserTwitterData {
+
+	@Id
+	private String id;
+	private User user;
+	private Status status;
+
+	public UserTwitterData() {
+		super();
+	}
+
+	public UserTwitterData(User user, Status status) {
+		super();
+		this.user = user;
+		this.status = status;
+	}
+
+	public String getId() {
+		return id;
+	}
+
+	public void setId(String id) {
+		this.id = id;
+	}
+
+	public User getUser() {
+		return user;
+	}
+
+	public void setUser(User user) {
+		this.user = user;
+	}
+
+	public Status getStatus() {
+		return status;
+	}
+
+	public void setStatus(Status status) {
+		this.status = status;
+	}
+
+	@Override
+	public String toString() {
+		return String.format("UserTwitterData [id=%s, user=%s, status=%s]", id, user, status);
+	}
+
+}

src/main/java/com/jasmine/repository/UserTwitterDataRepository.java

@@ -0,0 +1,11 @@
+package com.jasmine.repository;
+
+import org.springframework.data.mongodb.repository.MongoRepository;
+import org.springframework.stereotype.Repository;
+
+import com.jasmine.model.UserTwitterData;
+
+@Repository
+public interface UserTwitterDataRepository extends MongoRepository<UserTwitterData, String> {
+
+}