for gmail pub sub

Author: thughari

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

@@ -22,7 +22,7 @@ public Executor dashboardExecutor() {
 		return executor;
 	}
 
-	@Primary // This tells Spring: "Use this one for @Async by default"
+	@Primary
     @Bean(name = "taskExecutor")
     public Executor taskExecutor() {
         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();

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

@@ -10,8 +10,6 @@ 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/controller/WebhookController.java

@@ -118,6 +118,11 @@ public ResponseEntity<String> handleInboundEmail(@RequestBody Map<String, Object
                 log.warn("User unknown. From: [{}], To: [{}]", from, to);
                 return ResponseEntity.ok("User Unknown");
             }
+            
+            if (Boolean.TRUE.equals(user.getGmailConnected())) {
+                log.info("Forwarding Webhook: Discarding email for {} (Direct Sync is ACTIVE)", user.getEmail());
+                return ResponseEntity.ok("Ignored: Direct Sync Active");
+            }
 
             JobDTO job = geminiService.extractJobFromEmail(from, subject, plainText);
 

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

@@ -18,7 +18,7 @@ public class VerificationToken {
     @Column(nullable = false, unique = true)
     private String token;
 
-    @OneToOne(fetch = FetchType.LAZY) // Clean coding: don't load user unless needed
+    @OneToOne(fetch = FetchType.LAZY)
     @JoinColumn(name = "user_id", nullable = false)
     private User user;
 

backend/src/main/java/com/thughari/jobtrackerpro/exception/GlobalExceptionHandler.java

@@ -31,16 +31,14 @@ public ResponseEntity<ErrorResponse> handleMaxSizeException(MaxUploadSizeExceede
         return buildResponse(HttpStatus.PAYLOAD_TOO_LARGE, "File size exceeds the limit (5MB).");
     }
 
-    // High Performance: Catch-all for security and unexpected errors
     @ExceptionHandler(Exception.class)
     public ResponseEntity<ErrorResponse> handleGeneralException(Exception ex) {
-        log.error("UNEXPECTED ERROR: ", ex); // Log full stack trace for dev tracking
+        log.error("UNEXPECTED ERROR: ", ex);
         return buildResponse(HttpStatus.INTERNAL_SERVER_ERROR, "An unexpected error occurred.");
     }
 
     @ExceptionHandler(IllegalStateException.class)
     public ResponseEntity<ErrorResponse> handleUnauthorized(IllegalStateException ex) {
-        // High Performance: Use 401 for verification/state locks
         return buildResponse(HttpStatus.UNAUTHORIZED, ex.getMessage());
     }
 

backend/src/main/java/com/thughari/jobtrackerpro/scheduler/JobScheduler.java

@@ -26,7 +26,6 @@ public class JobScheduler {
     private final PasswordResetTokenRepository passwordTokenRepo;
     private final VerificationTokenRepository verificationTokenRepo;
 
-    // Clean Coding: Single constructor injection
     public JobScheduler(JobService jobService, 
                         UserRepository userRepository, 
                         GmailIntegrationService gmailIntegrationService,
@@ -56,7 +55,6 @@ public void runStaleJobCleanup() {
 
     /**
      * Gmail Security: Renews the 7-day watch lease every 5 days.
-     * High Performance: Processes users in parallel threads.
      */
     @Scheduled(cron = "0 0 0 */5 * *") 
     public void renewGmailWatches() {

backend/src/main/java/com/thughari/jobtrackerpro/security/JwtAuthenticationFilter.java

@@ -28,7 +28,6 @@ protected void doFilterInternal(HttpServletRequest request, HttpServletResponse
         String authHeader = request.getHeader("Authorization");
 
         if (authHeader == null && request.getRequestURI().contains("/api/notifications/stream")) {
-        	System.out.println("-----hereee");
             String paramToken = request.getParameter("token");
             if (paramToken != null) {
             	authHeader = "Bearer " + paramToken;

backend/src/main/java/com/thughari/jobtrackerpro/security/OAuth2SuccessHandler.java

@@ -46,13 +46,11 @@ public void onAuthenticationSuccess(HttpServletRequest request, HttpServletRespo
 	    String registrationId = authToken.getAuthorizedClientRegistrationId();
 	    UserInfo userInfo = extractUserInfo(registrationId, authToken.getPrincipal().getAttributes());
 
-	    // DELEGATION: Business logic belongs in the Service
 	    User user = authService.processOAuthUser(userInfo.email(), userInfo.name(), userInfo.imageUrl(), registrationId);
 
 	    String token = jwtUtils.generateAccessToken(user.getEmail());
 	    String refreshToken = jwtUtils.generateRefreshToken(user.getEmail());
 
-	    // High Performance: Single Header construction
 	    response.addHeader("Set-Cookie", buildRefreshCookie(refreshToken, "/", refreshExpirationMs / 1000).toString());
 
 	    getRedirectStrategy().sendRedirect(request, response, uiUrl + "/login-success?token=" + token);

backend/src/main/java/com/thughari/jobtrackerpro/service/AuthService.java

@@ -193,18 +193,15 @@ public void resendVerificationEmail(String email) {
             throw new IllegalStateException("Account is already verified. Please log in.");
         }
 
-        // 1. ATOMIC CLEANUP: Delete any previous tokens for this user
         verificationTokenRepository.deleteByUser(user);
 
-        // 2. Generate New Token
         String token = UUID.randomUUID().toString();
         VerificationToken vToken = new VerificationToken();
         vToken.setToken(token);
         vToken.setUser(user);
         vToken.setExpiryDate(LocalDateTime.now().plusHours(24));
         verificationTokenRepository.save(vToken);
 
-        // 3. ASYNC DELIVERY: Use the same high-performance thread pool
         emailService.sendVerificationEmail(user.getEmail(), token);
 
         log.info("Verification email resent to: {}", user.getEmail());
@@ -280,7 +277,7 @@ else if (imageUrl != null && !imageUrl.isEmpty()) {
 
 
     /**
-     * High Performance OAuth User Sync
+     * OAuth User Sync
      * Consolidates find, create, and profile update into one DB trip.
      */
     @Caching(evict = {
@@ -306,18 +303,14 @@ public User processOAuthUser(String email, String name, String imageUrl, String
             log.info("User {} auto-verified via {} login.", email, provider);
         }
 
-        // Only update if data actually changed to avoid redundant SQL UPDATE statements
         if (user.getName() == null || !user.getName().equals(name)) {
             user.setName(name);
             needsUpdate = true;
         }
 
-        // High Performance: We check if the image is already a JobTrackerPro/R2 URL 
-        // to avoid re-uploading social images every single login.
         if (user.getImageUrl() == null || (!user.getImageUrl().contains("r2") && !user.getImageUrl().equals(imageUrl))) {
             if (imageUrl != null && !imageUrl.isBlank()) {
                 try {
-                    // Offload image sync to storage service
                     String synchronizedUrl = storageService.uploadFromUrl(imageUrl, 
                         user.getId() != null ? user.getId().toString() : UUID.randomUUID().toString());
                     user.setImageUrl(synchronizedUrl);

backend/src/main/java/com/thughari/jobtrackerpro/service/CloudStorageService.java

@@ -32,14 +32,12 @@ public class CloudStorageService implements StorageService {
     private static final long MAX_IMAGE_FILE_SIZE = 5 * 1024 * 1024; // 5MB
     private static final long MAX_RESOURCE_FILE_SIZE = 10 * 1024 * 1024; // 10MB
 
-    // Avatar Bucket Config
     @Value("${cloudflare.r2.bucket.avatars}")
     private String avatarBucket;
 
     @Value("${cloudflare.r2.public-url.avatars}")
     private String avatarPublicUrl;
 
-    // Resource Bucket Config
     @Value("${cloudflare.r2.bucket.resources}")
     private String resourceBucket;
 
@@ -93,7 +91,6 @@ public String uploadResourceFile(MultipartFile file, String userId) {
 
         try {
             String extension = getExtensionFromFilename(file.getOriginalFilename());
-            // Using a flat structure since we are in a dedicated resource bucket
             String fileName = userId + "-" + System.currentTimeMillis() + extension;
 
             uploadToS3(resourceBucket, fileName, contentType, file);
@@ -153,7 +150,6 @@ public String uploadFromUrl(String externalUrl, String userId) {
 
         } catch (Exception e) {
             log.error("Failed to sync social image to R2: {}", e.getMessage());
-            // Fallback: return original URL so the profile still has an image
             return externalUrl;
         }
     }
@@ -167,8 +163,6 @@ public void deleteFile(String fileUrl) {
             return;
         }
 
-        // FIX: Must use AND (&&) here. If we used OR (||), a valid avatar URL would trigger 
-        // the return because it doesn't start with the resource URL.
         if (!fileUrl.startsWith(avatarPublicUrl) && !fileUrl.startsWith(resourcePublicUrl)) {
             return;
         }
@@ -197,7 +191,6 @@ public void deleteFile(String fileUrl) {
         }
     }
 
-    // --- Private Helpers ---
 
     private void uploadToS3(String bucket, String key, String contentType, MultipartFile file) throws Exception {
         PutObjectRequest putObj = PutObjectRequest.builder()