+ use web controller

README.md

@@ -2,7 +2,7 @@
 
 ## Goals
 
-* connect to mailbox
+* connect to mailbox (OK)
 * connect to ollama
-* check mail
+* check mail (OK)
 * move to burn folder

pom.xml

@@ -22,6 +22,14 @@
         </dependencies>
     </dependencyManagement>
     <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-autoconfigure</artifactId>
+        </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-mail</artifactId>

push.sh

@@ -1,7 +0,0 @@
-#!/bin/bash
-
-docker push io42630/burns-mail:0.1
-
-
-
-

src/main/java/com/olexyn/burnsmail/BurnsMailApplication.java

@@ -1,9 +1,7 @@
 package com.olexyn.burnsmail;
 
-import com.olexyn.burnsmail.mail.EmailService;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.context.ConfigurableApplicationContext;
 import org.springframework.context.annotation.EnableAspectJAutoProxy;
 
 @SpringBootApplication
@@ -11,24 +9,8 @@ import org.springframework.context.annotation.EnableAspectJAutoProxy;
 @EnableAspectJAutoProxy(proxyTargetClass = true)
 public class BurnsMailApplication {
 
-    public static void main(String[] args) throws InterruptedException {
+    public static void main(String[] args) {
-        ConfigurableApplicationContext context  = SpringApplication.run(BurnsMailApplication.class, args);
+        SpringApplication.run(BurnsMailApplication.class, args);
-
-        Thread.sleep(10000L);
-        // Retrieve the EmailService bean
-        EmailService emailService = context.getBean(EmailService.class);
-
-        // Call the readEmails method
-        try {
-            emailService.readEmails();
-        } catch (Exception e) {
-            e.printStackTrace();
-            // Handle exceptions as needed
-        }
-
-        // Close the application context
-        context.close();
-
     }
 
 }

src/main/java/com/olexyn/burnsmail/mail/EmailService.java

@@ -18,8 +18,8 @@ import java.util.Properties;
 public class EmailService {
 
 
-    public void readEmails() throws MessagingException, IOException {
+    private Store connect() throws MessagingException {
-        Properties properties = new Properties();
+        var properties = new Properties();
         properties.setProperty("mail.store.protocol", "imaps");
 
         Session session = Session.getDefaultInstance(properties, null);
@@ -29,6 +29,12 @@ public class EmailService {
             System.getenv("spring.mail.username"),
             System.getenv("spring.mail.password")
         );
+        return store;
+    }
+
+
+    public void readEmails() throws MessagingException, IOException {
+        Store store = connect();
 
         Folder inbox = store.getFolder("INBOX");
         inbox.open(Folder.READ_ONLY);
@@ -37,14 +43,23 @@ public class EmailService {
         Message[] messages = inbox.search(new FlagTerm(new Flags(Flags.Flag.SEEN), false));
 
         for (Message message : messages) {
-            // Process each email message
+          //TODO: do something with the message
-            System.out.println("Subject: " + message.getSubject());
-            System.out.println("From: " + message.getFrom()[0]);
-            System.out.println("Body: " + message.getContent());
         }
 
         // Close resources
         inbox.close(false);
         store.close();
     }
+
+    public void expunge() throws MessagingException {
+        Store store = connect();
+        Folder trash = store.getFolder("INBOX").getFolder("Trash");
+        trash.open(Folder.READ_WRITE);
+        for (Message message : trash.getMessages()) {
+            message.setFlag(Flags.Flag.DELETED, true);
+        }
+        trash.close(true); // expunge
+        store.close();
+    }
+
 }

src/main/java/com/olexyn/burnsmail/web/Controller.java

@@ -0,0 +1,44 @@
+package com.olexyn.burnsmail.web;
+
+
+import com.olexyn.burnsmail.mail.EmailService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+public class Controller {
+
+    private final EmailService emailService;
+
+    @Autowired
+    public Controller(
+        EmailService emailService
+    ){
+        this.emailService = emailService;
+    }
+
+    @PostMapping("/read")
+    public  ResponseEntity<String> postConfig() {
+        try {
+            emailService.readEmails();
+        } catch (Exception e) {
+            return ResponseEntity.badRequest().build();
+        }
+        return ResponseEntity.ok().build();
+    }
+
+
+    @PostMapping("/expunge")
+    public  ResponseEntity<String> expunge() {
+        try {
+            emailService.expunge();
+        } catch (Exception e) {
+            return ResponseEntity.badRequest().build();
+        }
+        return ResponseEntity.ok().build();
+    }
+
+
+}

src/test/resources/expunge.http

@@ -0,0 +1,6 @@
+POST http://localhost:42003/expunge
+Content-Type: application/json
+
+{
+
+}

src/test/resources/read-mail.http

@@ -0,0 +1,6 @@
+POST http://localhost:42003/read
+Content-Type: application/json
+
+{
+
+}