/*
    * Copyright 2012-2025 CodeLibs Project and the Others.
    *
    * Licensed under the Apache License, Version 2.0 (the "License");
    * you may not use this file except in compliance with the License.
    * You may obtain a copy of the License at
    *
    *     http://www.apache.org/licenses/LICENSE-2.0
    *
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS,
   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
   * either express or implied. See the License for the specific language
   * governing permissions and limitations under the License.
   */
  package org.codelibs.fess.helper;
  
  import java.io.IOException;
  
  import org.apache.commons.text.StringEscapeUtils;
  import org.apache.logging.log4j.LogManager;
  import org.apache.logging.log4j.Logger;
  import org.codelibs.core.lang.StringUtil;
  import org.codelibs.core.stream.StreamUtil;
  import org.codelibs.curl.Curl;
  import org.codelibs.curl.CurlResponse;
  import org.codelibs.fess.mylasta.direction.FessConfig;
  import org.codelibs.fess.util.ComponentUtil;
  import org.dbflute.mail.CardView;
  import org.dbflute.mail.send.supplement.SMailPostingDiscloser;
  
  /**
   * Helper class for sending notifications to various platforms.
   */
  public class NotificationHelper {
  
      /**
       * Default constructor.
       */
      public NotificationHelper() {
          // Default constructor
      }
  
      private static final Logger logger = LogManager.getLogger(NotificationHelper.class);
  
      /** Line feed character for message formatting. */
      protected static final char LF = '\n';
  
      /**
       * Sends notifications to configured platforms.
       *
       * @param cardView the card view for the notification
       * @param discloser the mail posting discloser
       */
      public void send(final CardView cardView, final SMailPostingDiscloser discloser) {
          sendToSlack(cardView, discloser);
          sendToGoogleChat(cardView, discloser);
      }
  
      /**
       * Sends a notification to Slack.
       *
       * @param cardView the card view for the notification
       * @param discloser the mail posting discloser
       */
      protected void sendToSlack(final CardView cardView, final SMailPostingDiscloser discloser) {
          // https://api.slack.com/messaging/webhooks#posting_with_webhooks
          final FessConfig fessConfig = ComponentUtil.getFessConfig();
          final String slackWebhookUrls = fessConfig.getSlackWebhookUrls();
          if (StringUtil.isBlank(slackWebhookUrls)) {
              return;
          }
          final String body = toSlackMessage(discloser);
          StreamUtil.split(slackWebhookUrls, "[,\\s]").of(stream -> stream.filter(StringUtil::isNotBlank).forEach(url -> {
              try (CurlResponse response = Curl.post(url).header("Content-Type", "application/json").body(body).execute()) {
                  if (response.getHttpStatusCode() == 200) {
                      if (logger.isDebugEnabled()) {
                          logger.debug("Sent {} to {}.", body, url);
                      }
                  } else {
                      logger.warn("Failed to send {} to {}. HTTP Status is {}. {}", body, url, response.getHttpStatusCode(),
                              response.getContentAsString());
                  }
              } catch (final IOException e) {
                  logger.warn("Failed to send {} to {}.", body, url, e);
              }
          }));
      }
  
      /**
       * Converts the discloser to a Slack message format.
       *
       * @param discloser the mail posting discloser
       * @return the formatted Slack message
       */
      protected String toSlackMessage(final SMailPostingDiscloser discloser) {
          final StringBuilder buf = new StringBuilder(100);
          buf.append("{\"text\":\"");
          buf.append(LF);
         buf.append(StringEscapeUtils.escapeJson(discloser.getSavedSubject().orElse(StringUtil.EMPTY).trim()));
         buf.append(LF).append("```");
         buf.append(LF).append(StringEscapeUtils.escapeJson(discloser.getSavedPlainText().orElse(StringUtil.EMPTY).trim()));
         buf.append(LF).append("```\"}");
         return buf.toString();
     }
 
     /**
      * Sends a notification to Google Chat.
      *
      * @param cardView the card view for the notification
      * @param discloser the mail posting discloser
      */
     protected void sendToGoogleChat(final CardView cardView, final SMailPostingDiscloser discloser) {
         // https://developers.google.com/hangouts/chat/how-tos/webhooks
         final FessConfig fessConfig = ComponentUtil.getFessConfig();
         final String googleChatWebhookUrls = fessConfig.getGoogleChatWebhookUrls();
         if (StringUtil.isBlank(googleChatWebhookUrls)) {
             return;
         }
         final String body = toGoogleChatMessage(discloser);
         StreamUtil.split(googleChatWebhookUrls, "[,\\s]").of(stream -> stream.filter(StringUtil::isNotBlank).forEach(url -> {
             try (CurlResponse response = Curl.post(url).header("Content-Type", "application/json").body(body).execute()) {
                 if (response.getHttpStatusCode() == 200) {
                     if (logger.isDebugEnabled()) {
                         logger.debug("Sent {} to {}.", body, url);
                     }
                 } else {
                     logger.warn("Failed to send {} to {}. HTTP Status is {}. {}", body, url, response.getHttpStatusCode(),
                             response.getContentAsString());
                 }
             } catch (final IOException e) {
                 logger.warn("Failed to send {} to {}.", body, url, e);
             }
         }));
     }
 
     /**
      * Converts the discloser to a Google Chat message format.
      *
      * @param discloser the mail posting discloser
      * @return the formatted Google Chat message
      */
     protected String toGoogleChatMessage(final SMailPostingDiscloser discloser) {
         final StringBuilder buf = new StringBuilder(100);
         buf.append("{\"text\":\"");
         buf.append(LF);
         buf.append(StringEscapeUtils.escapeJson(discloser.getSavedSubject().orElse(StringUtil.EMPTY).trim()));
         buf.append(LF).append("```");
         buf.append(LF).append(StringEscapeUtils.escapeJson(discloser.getSavedPlainText().orElse(StringUtil.EMPTY).trim()));
         buf.append(LF).append("```\"}");
         return buf.toString();
     }
 }