Merge branch 'master' into authentication

Author: stranck

application/src/main/java/net/furizon/backend/feature/pretix/cache/controller/PretixCacheController.java

@@ -0,0 +1,29 @@
+package net.furizon.backend.feature.pretix.cache.controller;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import net.furizon.backend.infrastructure.pretix.service.PretixInformation;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@Slf4j
+@RestController
+@RequestMapping("/internal/cache/pretix")
+@RequiredArgsConstructor
+//TODO: Only admins are allowed to run these!
+public class PretixCacheController {
+    private final PretixInformation pretixService;
+
+    @PostMapping("/reload-struct")
+    public void reloadCache() {
+        log.info("[PRETIX] Manual reload of cache");
+        pretixService.resetCache();
+    }
+
+    @PostMapping("/reload-orders")
+    public void reloadOrders() {
+        log.info("[PRETIX] Manual reload of orders");
+        pretixService.reloadAllOrders();
+    }
+}

application/src/main/java/net/furizon/backend/feature/pretix/order/controller/OrderController.java

@@ -0,0 +1,49 @@
+package net.furizon.backend.feature.pretix.order.controller;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import net.furizon.backend.feature.pretix.event.Event;
+import net.furizon.backend.feature.pretix.order.dto.OrderWebhookRequest;
+import net.furizon.backend.feature.pretix.order.usecase.FetchSingleOrderUseCase;
+import net.furizon.backend.infrastructure.pretix.PretixGenericUtils;
+import net.furizon.backend.infrastructure.pretix.service.PretixInformation;
+import net.furizon.backend.infrastructure.usecase.UseCaseExecutor;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@Slf4j
+@RestController
+@RequestMapping("/internal/orders")
+@RequiredArgsConstructor
+public class OrderController {
+    private final UseCaseExecutor useCaseExecutor;
+
+    private final PretixInformation pretixService;
+
+    @PostMapping("/webhook")
+    public ResponseEntity<Void> pretixWebhook(OrderWebhookRequest request) {
+        log.info("[PRETIX WEBHOOK] Fetching order {}", request);
+        var e = pretixService.getCurrentEvent();
+        if (!e.isPresent()) {
+            log.error("[PRETIX WEBHOOK] No current event set!");
+            return ResponseEntity.internalServerError().build();
+        }
+
+        String slug = PretixGenericUtils.buildOrgEventSlug(request.getEvent(), request.getOrganizer());
+        Event event = e.get();
+
+        if (!event.getSlug().equals(slug)) {
+            log.error("[PRETIX WEBHOOK] Webhook request is not for the current event!");
+            return ResponseEntity.internalServerError().build();
+        }
+
+        var res = useCaseExecutor.execute(FetchSingleOrderUseCase.class, new FetchSingleOrderUseCase.Input(
+            event,
+            request.getCode(),
+            pretixService
+        ));
+        return res.isPresent() ? ResponseEntity.ok().build() : ResponseEntity.internalServerError().build();
+    }
+}

application/src/main/java/net/furizon/backend/feature/pretix/order/controller/TestOrderController.java

@@ -0,0 +1,29 @@
+package net.furizon.backend.feature.pretix.order.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import jakarta.validation.constraints.NotEmpty;
+import jakarta.validation.constraints.NotNull;
+import lombok.Data;
+
+@Data
+public class OrderWebhookRequest {
+    @JsonProperty("notification_id")
+    private final long notificationId;
+
+    @NotNull
+    @NotEmpty
+    private final String organizer;
+
+    @NotNull
+    @NotEmpty
+    private final String event;
+
+    @NotNull
+    @NotEmpty
+    private final String code;
+
+    @NotNull
+    @NotEmpty
+    private final String action;
+}

application/src/main/java/net/furizon/backend/feature/pretix/order/dto/OrderWebhookRequest.java

@@ -45,16 +45,19 @@ public Optional<Order> executor(@NotNull Input input) {
 
         if (pretixOrder.isEmpty()) {
             deleteOrderAction.invoke(orderCode);
+            log.error("[PRETIX] Unable to fetch order: {}@{}", orderCode, eventInfo);
             return Optional.empty();
         }
 
         var orderOpt = input.pretixInformation.parseOrderFromId(pretixOrder.get(), event);
         if (orderOpt.isEmpty()) {
             deleteOrderAction.invoke(orderCode);
+            log.error("[PRETIX] Unable to parse order: {}@{}", orderCode, eventInfo);
             return Optional.empty();
         }
 
         Order order = orderOpt.get();
+        log.debug("[PRETIX] Storing / Updating order: {}@{}", orderCode, eventInfo);
         insertOrUpdateOrderAction.invoke(order, input.pretixInformation);
         return orderOpt;
     }

application/src/main/java/net/furizon/backend/feature/pretix/order/usecase/FetchSingleOrderUseCase.java

@@ -20,5 +20,9 @@ public class Const {
     public static final String METADATA_ROOM = "room";
     public static final String METADATA_ROOM_TYPE_TAG_PREFIX = "room_type_";
 
+
     public static final String QUESTIONS_FILE_KEEP = "file:keep";
+
+
+    public static final String RELOAD_CACHE_CRONJOB = "0 0 * * * *";
 }

application/src/main/java/net/furizon/backend/infrastructure/pretix/Const.java

@@ -29,6 +29,11 @@ public class PretixConfig implements HttpConfig {
     private final int connectionTimeout;
 
     private final boolean enableSync;
+  
+    @NotNull
+    private String cacheReloadCronjob;
+
+    private int connectionTimeout;
 
     @NotNull
     @Override