aboutsummaryrefslogtreecommitdiff
path: root/src/main/java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java')
-rw-r--r--src/main/java/com/juick/server/ServerManager.java2
-rw-r--r--src/main/java/com/juick/server/api/Service.java25
2 files changed, 1 insertions, 26 deletions
diff --git a/src/main/java/com/juick/server/ServerManager.java b/src/main/java/com/juick/server/ServerManager.java
index a226bf29..5b859125 100644
--- a/src/main/java/com/juick/server/ServerManager.java
+++ b/src/main/java/com/juick/server/ServerManager.java
@@ -112,7 +112,7 @@ public class ServerManager implements NotificationListener {
}
messageEvent(jmsg, Collections.singletonList(serviceUser));
try {
- emailManager.sendEmail("noreply@juick.com", serviceEmail, "New event", jsonMapper.writeValueAsString(event), null, Collections.emptyMap());
+ emailManager.sendEmail("noreply@juick.com", serviceEmail, "New message", jsonMapper.writeValueAsString(jmsg), null, Collections.emptyMap());
} catch (JsonProcessingException e) {
logger.warn("JSON exception", e);
}
diff --git a/src/main/java/com/juick/server/api/Service.java b/src/main/java/com/juick/server/api/Service.java
index b1a9e73d..f137f2f7 100644
--- a/src/main/java/com/juick/server/api/Service.java
+++ b/src/main/java/com/juick/server/api/Service.java
@@ -159,31 +159,6 @@ public class Service {
throw new HttpForbiddenException();
}
}
- @ApiIgnore
- @PostMapping("/api/new_event")
- @ResponseStatus(value = HttpStatus.OK)
- public void processEvent(@Visitor User current, InputStream data) throws Exception {
- if (current.getName().equals(serviceUser)) {
- MimeMessage msg = new MimeMessage(session, data);
- MimeMessageParser parser = new MimeMessageParser(msg);
- parser.parse();
- final String[] body = { parser.getPlainContent() };
- if (body[0] == null) {
- parser.getAttachmentList().stream()
- .filter(a -> a.getContentType().equals("text/plain")).findFirst()
- .ifPresent(a -> {
- try {
- body[0] = IOUtils.toString(a.getInputStream(), StandardCharsets.UTF_8);
- } catch (IOException e) {
- logger.info("attachment error", e);
- }
- });
- }
- logger.info("got text event: {}", body[0]);
- } else {
- throw new HttpForbiddenException();
- }
- }
private void endSession(SseEmitter emitter) {
serverManager.getSessions().stream()
.filter(s -> s.getEmitter().equals(emitter))