Пишем Telegram Bot для оповещения о коммите в git репозитарий на базе Gitea и разворачиваем его в Google Cloud Platform

    <parent>         <groupId>org.springframework.boot</groupId>         <artifactId>spring-boot-starter-parent</artifactId>         <version>2.1.6.RELEASE</version>         <relativePath/> <!-- lookup parent from repository -->     </parent>      <properties>         <java.version>1.8</java.version>     </properties>      <dependencies>         <dependency>             <groupId>org.springframework.boot</groupId>             <artifactId>spring-boot-starter-web</artifactId>         </dependency>          <dependency>             <groupId>org.springframework.boot</groupId>             <artifactId>spring-boot-starter-test</artifactId>             <scope>test</scope>         </dependency>         <dependency>             <groupId>org.telegram</groupId>             <artifactId>telegrambots</artifactId>             <version>5.0.0</version>         </dependency>         <dependency>             <groupId>com.google.code.gson</groupId>             <artifactId>gson</artifactId>             <version>2.8.6</version>         </dependency>          <dependency>             <groupId>org.springframework.boot</groupId>             <artifactId>spring-boot-configuration-processor</artifactId>             <optional>true</optional>         </dependency>          <dependency>             <groupId>org.projectlombok</groupId>             <artifactId>lombok</artifactId>             <optional>true</optional>         </dependency>       </dependencies>      <build>         <plugins>             <plugin>                 <groupId>org.springframework.boot</groupId>                 <artifactId>spring-boot-maven-plugin</artifactId>             </plugin>         </plugins>     </build> 

@Configuration @Data @PropertySource("classpath:application.properties") public class BotConfig {      // Имя бота заданное при регистрации     @Value("${botUserName}")     String botUserName;      // Токен полученный при регистрации     @Value("${token}")     String token; }

@Component @Slf4j public class BotInitializer {     @Autowired     Bot bot;      @EventListener({ContextRefreshedEvent.class})     public void Init() throws TelegramApiException {         TelegramBotsApi telegramBotsApi = new TelegramBotsApi(DefaultBotSession.class);         try {             telegramBotsApi.registerBot(bot);         } catch (TelegramApiRequestException e) {             log.error(exceptionStackTraceToString(e));         }     } }

@Component @Slf4j /**  * Касс является основным пулом взаимодействия с Telegram  * получение, обработка, отправка сообщений  */ public class Bot extends TelegramLongPollingBot {      final     BotConfig config;      public Bot(BotConfig config) {         this.config = config;     }      public void onUpdateReceived(Update update) {         update.getUpdateId();         SendMessage.SendMessageBuilder builder =SendMessage.builder();         String messageText;         String chatId;         if (update.getMessage() != null) {             chatId = update.getMessage().getChatId().toString();             builder.chatId(chatId);             messageText = update.getMessage().getText();         } else {             chatId = update.getChannelPost().getChatId().toString();             builder.chatId(chatId);             messageText = update.getChannelPost().getText();         }          if (messageText.contains("/hello")) {             builder.text("Привет");             try {                 execute(builder.build());             } catch (TelegramApiException e) {                 log.debug(e.toString());             }         }          if (messageText.contains("/chartId")) {             builder.text("ID Канала : " + chatId);             try {                 execute(builder.build());             } catch (TelegramApiException e) {                 log.debug(e.toString());             }         }     }       public String getBotUsername() {         return config.getBotUserName();     }      public String getBotToken() {         return config.getToken();     } } 

@Slf4j @RestController @RequestMapping("/api/public/gitea") @RequiredArgsConstructor @PropertySource("classpath:application.properties") public class WebHook {     Bot bot;      // Канал в который будем слать уведомления     @Value("${chartId}")     String chartId;      // Секретный ключ который придёт в нутри JSON от Gitea,     // что бы левые люди не имели доступа к боту т.к. API публичное без авторизации     @Value("${secret}")     String secret;      @Autowired     public WebHook(Bot bot) {         this.bot = bot;     }      @PostMapping(value = "/webhook")     public ResponseEntity<?> webhook(@RequestBody String json){         Gson gson = new Gson();         GiteaWebHook giteaWebHook = null;         try {             giteaWebHook = gson.fromJson(json, GiteaWebHook.class);         } catch (JsonSyntaxException e) {             log.error(Utils.exceptionStackTraceToString(e));             return new ResponseEntity<>(Utils.exceptionStackTraceToString(e), HttpStatus.BAD_REQUEST);         }         if (validationWebHookContent(giteaWebHook)) {             SendMessage.SendMessageBuilder messageBuilder =SendMessage.builder();             messageBuilder.chatId(chartId);              messageBuilder.parseMode(ParseMode.HTML);             StringBuilder builder = new StringBuilder();             builder.append("<b>Проект</b> : " + giteaWebHook.getRepository().getName()+"\n");             for (Commit commit : giteaWebHook.getCommits()) {              builder.append("<b>Автор</b> : " + commit.getAuthor().getName()+"\n");              builder.append("<b>Комментарий</b> : " + commit.getMessage()+"\n");             }             builder.append("<a href=\"https://play.google.com/store/apps/details?id=URL_ВАШЕГО_ПРИЛАЖЕНИЯ\">Обновление будет доступно в Play Market через пару минут</a>\n");             messageBuilder.text(buildToCorrectString(builder));             try {                 bot.execute(messageBuilder.build());             } catch (TelegramApiException e) {                 log.error(Utils.exceptionStackTraceToString(e));                 return new ResponseEntity<>(Utils.exceptionStackTraceToString(e), HttpStatus.INTERNAL_SERVER_ERROR);             }         } else return new ResponseEntity<>(HttpStatus.BAD_REQUEST);          HttpHeaders headers = new HttpHeaders();         headers.add("Content-Type", "application/json; charset=utf-8");         return new ResponseEntity<>(headers, HttpStatus.OK);     }      /**      * Проверка пришедших JSON данных на валидность      * @param giteaWebHook - GiteaWebHook      * @return true - если не null, PUSH в master, совпал секретный ключ      */     private boolean validationWebHookContent(GiteaWebHook giteaWebHook){         return giteaWebHook != null && // Если вообще что то есть                giteaWebHook.getRef().contains(giteaWebHook.getRepository().getDefaultBranch()) && // Есть был PUSH в /master                giteaWebHook.getSecret().equals(secret); // Если совпал секретный ключ     }      private String buildToCorrectString(StringBuilder builder){         return builder.toString()                 .replace("_", "\\_")                 .replace("*", "\\*")                 .replace("[", "\\[")                 .replace("`", "\\`")                 .replace("&nbsp;", " ")                 .replace("&frac", " ")                 .replaceAll(" \\u003c","");     } } 

@SpringBootApplication @AutoConfigurationPackage public class TelegramBotGiteaApplication extends SpringBootServletInitializer {      public static void main(String[] args) {         new SpringApplicationBuilder(TelegramBotGiteaApplication.class)                 .run(args);     } }