Update the way the deletion is handled

Author: rosehgal

TrashEmailService/src/main/java/io/github/trashemail/Respositories/UserRepository.java

@@ -13,11 +13,14 @@
 
 @Repository
 public interface UserRepository extends CrudRepository<User, Integer>{
-	public List<User> findByChatId(long chatId);
-	public User findByEmailId(String emailId);
-	public boolean existsByEmailId(String emailId);
+	public List<User> findByChatIdAndIsActiveTrue(long chatId);
+	public User findByEmailIdAndIsActiveTrue(String emailId);
+	public User findByEmailIdAndChatId(String emailId , long chatId);
+	public boolean existsByEmailIdAndIsActiveTrue(String emailId);
 	public void delete(User user);
+
 	public long count();
+
 	public List<User> findByEmailIdEndsWith(String domain);
 
 	@Query(value = "select max(u.id) from User u")

TrashEmailService/src/main/java/io/github/trashemail/Telegram/TelegramRequestHandler.java

@@ -43,7 +43,10 @@ public String deleteEmail(User user)
 	throws HttpClientErrorException{
 		Boolean isDeleted = emailServerInteraction.deleteEmailId(user);
 		if(isDeleted){
-			userRepository.delete(user);
+
+			user.setIsActive(false);
+			userRepository.save(user);
+
 			return "Email Id *deleted* and added to open pool.";
 		}
 		return "No mail ID on the server was identified with" +
@@ -96,8 +99,10 @@ public TelegramResponse handleRequest(long chatId, String text) {
 				);
 
 			case "/create":
-				if(userRepository.findByChatId(chatId).size() >= trashemailConfig.getMaxEmailsPerUser()) {
-					responseText =  "Only " + trashemailConfig.getMaxEmailsPerUser() + " " +
+				if(userRepository.findByChatIdAndIsActiveTrue(chatId).size()
+						>= trashemailConfig.getMaxEmailsPerUser()) {
+					responseText =  "Only " +
+							trashemailConfig.getMaxEmailsPerUser() + " " +
 							"email Ids are allowed per-user\n" +
 							"You can get the list of all the emails @ /emails";
 					return new TelegramResponse(
@@ -110,7 +115,7 @@ public TelegramResponse handleRequest(long chatId, String text) {
 					if(argument != null) {
 							/*
 							User entered something like : /create username.
-							No offer him interactive response.
+							Now offer him interactive response.
 							*/
 						String emailRegex = "^[A-Za-z0-9._%+-]+@(" +
 								String.join("|",
@@ -122,11 +127,12 @@ public TelegramResponse handleRequest(long chatId, String text) {
 						// A valid domain email is inputted by the user
 						if (matcher.matches()) {
 							String emailId = argument;
-							if(userRepository.existsByEmailId(emailId)){
+							if(userRepository.existsByEmailIdAndIsActiveTrue(
+									emailId)){
 								// Email ID Already taken
 								responseText = "Email ID *" + argument + "* " +
 										"is already taken, " +
-										"please get some other";
+										"please try some other email id.";
 								return new TelegramResponse(
 										chatId,
 										responseText
@@ -165,7 +171,19 @@ public TelegramResponse handleRequest(long chatId, String text) {
 							}
 
 							if(response!=null) {
-								userRepository.save(user);
+								// Check if the same user has taken the same
+								// email before, then it would exist in DB so
+								// just set isActive to true.
+								User existingUser =
+										userRepository.findByEmailIdAndChatId(
+										emailId,
+										chatId);
+								if(existingUser == null)
+									userRepository.save(user);
+								else{
+									existingUser.setIsActive(true);
+									userRepository.save(existingUser);
+								}
 								responseText =  "Email successfully created" +
 										" - " +
 										"" +
@@ -280,7 +298,8 @@ else if(argument == null) {
 			case "/emails":
 				String response = "Currently, you have below mentioned " +
 						"emails with you.\n*";
-				List<User> allEmailsWithUser = userRepository.findByChatId(
+				List<User> allEmailsWithUser =
+						userRepository.findByChatIdAndIsActiveTrue(
 						chatId);
 
 				for(User emailWithUser: allEmailsWithUser){
@@ -297,7 +316,8 @@ else if(argument == null) {
 				if(argument == null){
 					responseText = "Pick an email to delete.";
 
-					List<User> emailsWithUser = userRepository.findByChatId(
+					List<User> emailsWithUser =
+							userRepository.findByChatIdAndIsActiveTrue(
 							chatId);
 
 					int buttonPerRow = 1;
@@ -340,9 +360,10 @@ else if(argument == null) {
 					// A valid domain email is inputted by the user
 					if (matcher.matches()) {
 						String emailId = argument;
-						User user = userRepository.findByEmailId(emailId);
+						User user = userRepository.findByEmailIdAndIsActiveTrue(
+								emailId);
 						// user should only delete email owned by user.
-						if (userRepository.existsByEmailId(emailId)) {
+						if (userRepository.existsByEmailIdAndIsActiveTrue(emailId)) {
 							if (((Long) chatId).equals(user.getChatId())) {
 								responseText = this.deleteEmail(user);
 								return new TelegramResponse(

TrashEmailService/src/main/java/io/github/trashemail/Telegram/TelegramResource.java

@@ -91,7 +91,7 @@ public TelegramResponse messageHandler(
     @GetMapping(value = "/getChatId")
 	public User getChatIdFortargetEmailAddress(@RequestParam String emailId){
 
-    	User user = userRepository.findByEmailId(emailId);
+    	User user = userRepository.findByEmailIdAndIsActiveTrue(emailId);
 		emailCounterRepository.updateCount();
 
 		return user;

TrashEmailService/src/main/java/io/github/trashemail/models/User.java

@@ -6,11 +6,7 @@
 import lombok.Setter;
 import org.hibernate.annotations.CreationTimestamp;
 
-import javax.persistence.Column;
-import javax.persistence.Entity;
-import javax.persistence.GeneratedValue;
-import javax.persistence.Id;
-import javax.persistence.Table;
+import javax.persistence.*;
 import java.time.LocalDateTime;
 import java.util.Date;
 
@@ -25,18 +21,25 @@ public class User {
 	private Integer id;
 	private long chatId;
 
-	@Column(unique = true)
 	private String emailId;
 
 	private String forwardsTo;
 
 	@CreationTimestamp
 	private LocalDateTime createDateTime;
 
-	public User(long chatId, String emailId, String forwardsTo) {
+	private Boolean isActive;
+
+	public User(long chatId, String emailId, String forwardsTo,
+				Boolean isActive) {
 		this.chatId = chatId;
 		this.emailId = emailId;
 		this.forwardsTo = forwardsTo;
+		this.isActive = isActive;
+	}
+
+	public User(long chatId, String emailId, String forwardsTo) {
+		this(chatId, emailId, forwardsTo, Boolean.TRUE);
 	}
 
 	@Override