added backend for gmail permission

Author: thughari

backend/pom.xml

@@ -30,10 +30,11 @@
 		<java.version>21</java.version>
 		<aws.sdk.version>2.25.27</aws.sdk.version>
 		<jjwt.version>0.11.5</jjwt.version>
+		<google.apis.version>v1-rev20220404-2.0.0</google.apis.version>
 	</properties>
 
 	<dependencies>
-	
+		
 		<dependency>
 			 <groupId>org.springframework.boot</groupId>
 			 <artifactId>spring-boot-starter-web</artifactId>
@@ -72,6 +73,12 @@
 	        <artifactId>s3</artifactId>
 	        <version>${aws.sdk.version}</version>
 	    </dependency>
+	    
+	    <dependency>
+		    <groupId>com.google.apis</groupId>
+		    <artifactId>google-api-services-gmail</artifactId>
+		    <version>${google.apis.version}</version>
+		</dependency>
 
 		<dependency>
 			<groupId>org.springframework.boot</groupId>

backend/src/main/java/com/thughari/jobtrackerpro/JobTrackerProApplication.java

@@ -7,12 +7,14 @@
 import org.springframework.cache.annotation.EnableCaching;
 import org.springframework.data.web.config.EnableSpringDataWebSupport;
 import org.springframework.data.web.config.EnableSpringDataWebSupport.PageSerializationMode;
+import org.springframework.scheduling.annotation.EnableAsync;
 import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
 @EnableCaching
 @EnableSpringDataWebSupport(pageSerializationMode = PageSerializationMode.VIA_DTO)
 @EnableScheduling
+@EnableAsync
 public class JobTrackerProApplication {
 
 	public static void main(String[] args) {

backend/src/main/java/com/thughari/jobtrackerpro/config/AsyncConfig.java

@@ -2,6 +2,7 @@
 
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
 import org.springframework.scheduling.annotation.EnableAsync;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import java.util.concurrent.Executor;
@@ -20,4 +21,16 @@ public Executor dashboardExecutor() {
 		executor.initialize();
 		return executor;
 	}
+	
+	@Primary // This tells Spring: "Use this one for @Async by default"
+    @Bean(name = "taskExecutor")
+    public Executor taskExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        executor.setCorePoolSize(5);
+        executor.setMaxPoolSize(15);
+        executor.setQueueCapacity(100);
+        executor.setThreadNamePrefix("GmailSync-");
+        executor.initialize();
+        return executor;
+    }
 }

backend/src/main/java/com/thughari/jobtrackerpro/config/PasswordConfig.java

@@ -0,0 +1,17 @@
+package com.thughari.jobtrackerpro.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
+import org.springframework.security.crypto.password.PasswordEncoder;
+
+@Configuration
+public class PasswordConfig {
+
+    @Bean
+    public PasswordEncoder passwordEncoder() {
+        // High Performance: BCrypt is standard, but you can tune strength 
+        // if login latency becomes a bottleneck. 10 is the balanced default.
+        return new BCryptPasswordEncoder();
+    }
+}

backend/src/main/java/com/thughari/jobtrackerpro/config/SecurityConfig.java

@@ -14,8 +14,6 @@
 import org.springframework.security.config.annotation.web.builders.HttpSecurity;
 import org.springframework.security.config.annotation.web.configurers.AbstractHttpConfigurer;
 import org.springframework.security.config.http.SessionCreationPolicy;
-import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
-import org.springframework.security.crypto.password.PasswordEncoder;
 
 import org.springframework.security.web.SecurityFilterChain;
 import org.springframework.security.web.authentication.UsernamePasswordAuthenticationFilter;
@@ -73,12 +71,7 @@ public SecurityFilterChain securityFilterChain(HttpSecurity http) throws Excepti
 
 		return http.build();
 	}
-
-	@Bean
-	public PasswordEncoder passwordEncoder() {
-		return new BCryptPasswordEncoder();
-	}
-
+	
 	@Bean
 	public AuthenticationManager authenticationManager(AuthenticationConfiguration config) throws Exception {
 		return config.getAuthenticationManager();

backend/src/main/java/com/thughari/jobtrackerpro/controller/GmailIntegrationController.java

@@ -0,0 +1,49 @@
+package com.thughari.jobtrackerpro.controller;
+
+import com.thughari.jobtrackerpro.service.GmailIntegrationService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.ResponseEntity;
+import org.springframework.security.core.context.SecurityContextHolder;
+import org.springframework.security.oauth2.client.authentication.OAuth2AuthenticationToken;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Map;
+
+@RestController
+@RequestMapping("/api/integrations")
+@Slf4j
+public class GmailIntegrationController {
+
+    private final GmailIntegrationService gmailAutomationService;
+
+    // constructor injection - clean & thread-safe
+    public GmailIntegrationController(GmailIntegrationService gmailAutomationService) {
+        this.gmailAutomationService = gmailAutomationService;
+    }
+
+    @PostMapping("/gmail/connect")
+    public ResponseEntity<String> connectGmail(@RequestBody Map<String, String> body) {
+        String authCode = body.get("code");
+        String email = getAuthenticatedEmail();
+        
+        try {
+            // Business logic and DB lookup are hidden inside the service
+            gmailAutomationService.connectAndSetupPush(authCode, email);
+            return ResponseEntity.ok("Gmail Automation enabled successfully.");
+        } catch (Exception e) {
+            log.error("Failed to setup Gmail for user {}: {}", email, e.getMessage());
+            return ResponseEntity.status(500).body("Failed to setup Gmail: " + e.getMessage());
+        }
+    }
+
+    @PostMapping("/gmail/sync")
+    public ResponseEntity<String> syncGmail(OAuth2AuthenticationToken authentication) {
+        // High Performance: Service uses @Async to return immediately
+        gmailAutomationService.initiateManualSync(authentication);
+        return ResponseEntity.ok("Sync started in background. Your dashboard will update shortly.");
+    }
+
+    private String getAuthenticatedEmail() {
+        return SecurityContextHolder.getContext().getAuthentication().getName().toLowerCase();
+    }
+}

backend/src/main/java/com/thughari/jobtrackerpro/controller/GmailWebhookController.java

@@ -0,0 +1,58 @@
+package com.thughari.jobtrackerpro.controller;
+
+import com.github.benmanes.caffeine.cache.Cache;
+import com.github.benmanes.caffeine.cache.Caffeine;
+import com.thughari.jobtrackerpro.service.GmailWebhookService;
+import com.thughari.jobtrackerpro.util.GoogleNotificationDecoder;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+
+@RestController
+@RequestMapping("/api/webhooks")
+@Slf4j
+public class GmailWebhookController {
+
+    private final GmailWebhookService gmailService;
+    private final GoogleNotificationDecoder decoder;
+
+    // HIGH PERFORMANCE: In-memory "Deduplicator"
+    // Prevents the "Push Avalanche" from hitting the database
+    private final Cache<String, Boolean> pushDeduplicator = Caffeine.newBuilder()
+            .expireAfterWrite(15, TimeUnit.SECONDS) // Ignore same user for 15 seconds
+            .build();
+
+    public GmailWebhookController(GmailWebhookService gmailService, GoogleNotificationDecoder decoder) {
+        this.gmailService = gmailService;
+        this.decoder = decoder;
+    }
+
+    @PostMapping("/gmail/push")
+    public ResponseEntity<Void> handleGmailPush(@RequestBody Map<String, Object> body) {
+    	System.out.println("--------------");
+    	System.out.println(body);
+    	System.out.println("--------------");
+        String email = decoder.extractEmail(body);
+        System.out.println("--------------");
+    	System.out.println(email);
+    	System.out.println("--------------");
+        
+        if (email != null) {
+            // Check if we already handled a push for this user in the last 5 seconds
+            if (pushDeduplicator.getIfPresent(email) == null) {
+                pushDeduplicator.put(email, true);
+                log.info("Processing valid Gmail Push for: {}", email);
+                
+                // Hand off to @Async service
+                gmailService.processHistorySync(email);
+            } else {
+                log.debug("Discarding redundant push notification for: {}", email);
+            }
+        }
+        
+        return ResponseEntity.ok().build();
+    }
+}

backend/src/main/java/com/thughari/jobtrackerpro/dto/EmailBatchItem.java

@@ -0,0 +1,3 @@
+package com.thughari.jobtrackerpro.dto;
+
+public record EmailBatchItem(String from, String subject, String body) {}

backend/src/main/java/com/thughari/jobtrackerpro/dto/UserProfileResponse.java

@@ -11,4 +11,6 @@ public class UserProfileResponse {
     private String imageUrl;
     private String provider;
     private boolean hasPassword;
+    private boolean gmailConnected;
+    private boolean gmailSyncInProgress;
 }

backend/src/main/java/com/thughari/jobtrackerpro/entity/Job.java

@@ -10,35 +10,42 @@
 import jakarta.persistence.GenerationType;
 import jakarta.persistence.Id;
 import jakarta.persistence.Table;
+import jakarta.persistence.Index;
+
 
 @Data
 @Entity
-@Table(name = "jobs")
+@Table(name = "jobs", indexes = {
+		@Index(name = "idx_jobs_user_email_updated_at", columnList = "userEmail, updatedAt DESC"),
+		@Index(name = "idx_jobs_user_status", columnList = "userEmail, status")
+})
 public class Job {
-    @Id
-    @GeneratedValue(strategy = GenerationType.UUID)
-    @Column(columnDefinition = "uuid")		//@Column(columnDefinition = "VARCHAR(36)") -- for mySQL
-    private UUID id;
+	@Id
+	@GeneratedValue(strategy = GenerationType.UUID)
+	@Column(columnDefinition = "uuid")		//@Column(columnDefinition = "VARCHAR(36)") -- for mySQL
+	private UUID id;
+
+	@Column(nullable = false)
+	private String userEmail; 
 
-    private String userEmail; 
+	private String company;
+	private String role;
+	private String location;
+	private LocalDateTime appliedDate;
 
-    private String company;
-    private String role;
-    private String location;
-    private LocalDateTime appliedDate;
-    
-    private LocalDateTime updatedAt;
+	@Column(nullable = false)
+	private LocalDateTime updatedAt;
 
-    private String status;
-    private Integer stage;
-    private String stageStatus;
+	private String status;
+	private Integer stage;
+	private String stageStatus;
 
-    private Double salaryMin;
-    private Double salaryMax;
+	private Double salaryMin;
+	private Double salaryMax;
 
-    @Column(length = 2048)
-    private String url;
+	@Column(length = 2048)
+	private String url;
 
-    @Column(length = 4096)
-    private String notes;
+	@Column(columnDefinition = "TEXT")
+	private String notes; //ALTER TABLE jobs ALTER COLUMN notes TYPE TEXT;
 }