Add LINE Notify API "POST https://notify-api.line.me/api/notify". fix…

…es #304 @1h

src/main/java/com/mizo0203/lilywhite/RedirectServlet.java

@@ -32,6 +32,7 @@ protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws I
     LOG.info("error_description:\t" + req.getParameter("error_description"));
     try (UseCase useCase = new UseCase()) {
       useCase.tokenOauth(req.getParameter("code"));
+      useCase.notify("Hello, LINE Notify World");
     }
   }
 }

src/main/java/com/mizo0203/lilywhite/domain/UseCase.java

@@ -2,6 +2,7 @@
 
 import com.mizo0203.lilywhite.repo.Repository;
 
+import javax.annotation.Nonnull;
 import javax.annotation.Nullable;
 import java.io.IOException;
 
@@ -25,6 +26,10 @@ public void tokenOauth(String code) {
     mRepository.tokenOauth(code);
   }
 
+  public void notify(@Nonnull String message) {
+    mRepository.notify(message);
+  }
+
   public interface AuthorizeOauthCallback {
     void onBuildRedirectUrlString(@Nullable String redirectUrlString) throws IOException;
   }

src/main/java/com/mizo0203/lilywhite/repo/LineRepository.java

@@ -4,6 +4,7 @@
 import com.mizo0203.lilywhite.util.HttpUtil;
 import org.apache.http.client.utils.URIBuilder;
 
+import javax.annotation.Nonnull;
 import javax.annotation.Nullable;
 import java.net.MalformedURLException;
 import java.net.URISyntaxException;
@@ -20,6 +21,8 @@
       "https://notify-bot.line.me/oauth/authorize";
   private static final String LINE_NOTIFY_API_TOKEN_OAUTH_URL_STR =
       "https://notify-bot.line.me/oauth/token";
+  private static final String LINE_NOTIFY_API_NOTIFY_URL_STR =
+      "https://notify-api.line.me/api/notify";
 
   @SuppressWarnings("EmptyMethod")
   public void destroy() {
@@ -62,4 +65,32 @@ public void tokenOauth(
       e.printStackTrace();
     }
   }
+
+  public void notify(
+      @Nonnull String access_token,
+      @Nonnull String message,
+      @Nullable String imageThumbnail,
+      @Nullable String imageFullsize,
+      @Nullable String imageFile,
+      @Nullable Number stickerPackageId,
+      @Nullable Number stickerId,
+      @Nullable HttpUtil.Callback callback) {
+    Map<String, String> reqProp = new HashMap<>();
+    reqProp.put("Content-Type", "application/x-www-form-urlencoded");
+    reqProp.put("Authorization", "Bearer " + access_token);
+
+    Map<String, String> params = new HashMap<>();
+    params.put("message", message);
+    params.put("imageThumbnail", imageThumbnail);
+    params.put("imageFullsize", imageFullsize);
+    params.put("imageFile", imageFile);
+    params.put("stickerPackageId", stickerPackageId != null ? stickerPackageId.toString() : null);
+    params.put("stickerId", stickerId != null ? stickerId.toString() : null);
+
+    try {
+      HttpUtil.post(new URL(LINE_NOTIFY_API_NOTIFY_URL_STR), reqProp, params, callback);
+    } catch (MalformedURLException e) {
+      e.printStackTrace();
+    }
+  }
 }

src/main/java/com/mizo0203/lilywhite/repo/Repository.java

@@ -3,9 +3,11 @@
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.mizo0203.lilywhite.domain.Define;
 import com.mizo0203.lilywhite.repo.line.data.AccessToken;
+import com.mizo0203.lilywhite.repo.line.data.ResponseNotifyData;
 import com.mizo0203.lilywhite.repo.objectify.entity.KeyEntity;
 import org.apache.commons.io.IOUtils;
 
+import javax.annotation.Nonnull;
 import javax.annotation.Nullable;
 import java.io.IOException;
 import java.net.HttpURLConnection;
@@ -55,6 +57,26 @@ private void onResponseTokenOauth(HttpURLConnection connection) {
     }
   }
 
+  public void notify(@Nonnull String message) {
+    String access_token = getKey("access_token");
+    mLineRepository.notify(
+        access_token, message, null, null, null, null, null, this::onResponseNotify);
+  }
+
+  private void onResponseNotify(HttpURLConnection connection) {
+    try {
+      if (connection.getResponseCode() != HttpURLConnection.HTTP_OK) {
+        return;
+      }
+      String body = IOUtils.toString(connection.getInputStream(), StandardCharsets.UTF_8);
+      ResponseNotifyData responseNotifyData =
+          new ObjectMapper().readValue(body, ResponseNotifyData.class);
+      LOG.info("responseNotifyData: " + responseNotifyData.getMessage());
+    } catch (IOException e) {
+      LOG.log(Level.SEVERE, "", e);
+    }
+  }
+
   private void setKey(String key, String value) {
     KeyEntity keyEntity = mOfyRepository.loadKeyEntity(key);
     if (keyEntity == null) {

src/main/java/com/mizo0203/lilywhite/repo/line/data/ResponseNotifyData.java

@@ -0,0 +1,14 @@
+package com.mizo0203.lilywhite.repo.line.data;
+
+public class ResponseNotifyData {
+  private int status;
+  private String message;
+
+  public int getStatus() {
+    return status;
+  }
+
+  public String getMessage() {
+    return message;
+  }
+}