Godfather-Bots/telegram-bot
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Вернул обработка вебхуков
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Struchkov Mark 2023-04-19 10:22:48 +03:00
parent 36a5d1b478
commit 455a8e1316
Signed by: upagge
GPG Key ID: D3018BE7BA428CA6
1 changed files with 5 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
telegram-webhook/telegram-webhook-quarkus/src/main/java/dev/struchkov/godfather/telegram/webhook/WebhookController.java
View File

@ -37,25 +37,16 @@ public class WebhookController {
@Path("{webhookPath}")
@Consumes(MediaType.APPLICATION_JSON)
@Produces(MediaType.APPLICATION_JSON)
public Response updateReceived(@PathParam("webhookPath") String botPath, @HeaderParam("X-Telegram-Bot-Api-Secret-Token") String secretTokenFromTelegram, Update update) {
Uni.createFrom().voidItem()
public Uni<Response> updateReceived(@PathParam("webhookPath") String botPath, @HeaderParam("X-Telegram-Bot-Api-Secret-Token") String secretTokenFromTelegram, Update update) {
return Uni.createFrom().voidItem()
.invoke(() -> {
log.debug("Получено webhook событие");
isTrue(pathKey.equals(botPath), accessException(ERROR_ACCESS));
isTrue(secretToken.equals(secretTokenFromTelegram), accessException(ERROR_ACCESS));
})
.call(
() -> eventDistributor.processing(update)
.onFailure().recoverWithNull()
)
.invoke(() -> log.debug("Webhook событие успешно обработано"))
.subscribe().with(
item -> {
},
failure -> log.error("Произошла ошибка: " + failure)
);
log.debug("Дали отмашку telegram, что webhook событие получено");
return Response.ok().build();
.call(() -> eventDistributor.processing(update))
.invoke(() -> log.debug("Дали отмашку, что все збс"))
.map(ignored -> Response.ok().build());
}
@GET