FIWARE / contract-management / #13

package org.fiware.iam.tmforum;

import io.micronaut.context.annotation.Value;

import io.micronaut.context.event.ApplicationEventListener;

import io.micronaut.http.HttpResponse;

import io.micronaut.http.client.exceptions.HttpClientException;

import io.micronaut.runtime.server.event.ServerStartupEvent;

import io.micronaut.scheduling.TaskScheduler;

import jakarta.inject.Singleton;

import lombok.RequiredArgsConstructor;

import lombok.extern.slf4j.Slf4j;

import org.fiware.iam.tmforum.product.client.api.EventsSubscriptionApiClient;

import org.fiware.iam.tmforum.product.client.model.EventSubscriptionInputVO;

import org.fiware.iam.tmforum.product.client.model.EventSubscriptionVO;

import java.time.Duration;

import static org.fiware.iam.tmforum.product.server.api.NotificationListenersClientSideApi.PATH_LISTEN_TO_PRODUCT_ORDER_CREATE_EVENT;

@Singleton

public class NotificationSubscriber implements ApplicationEventListener<ServerStartupEvent> {

    private static final String QUERY_PRODUCT_ORDER_CREATED = "eventType=ProductOrderCreateEvent";

    private final EventsSubscriptionApiClient eventsSubscriptionApi;

    private final TaskScheduler taskScheduler;

    @Value("${general.basepath:}")

    private String controllerPath;

    @Value("${micronaut.server.port:8080}")

    private String servicePort;

    @Value("${general.name:contract-management}")

    private String serviceUrl;

    /**

     * Register a subscription at the TM Forum API service after startup. Using the

     * {@link io.micronaut.scheduling.annotation.Scheduled} annotation resulted in start

     * failure like https://stackoverflow.com/q/77075901/4341660

     * @param event

     */

    @Override

    public void onApplicationEvent(ServerStartupEvent event) {

        //Using fixed rate since we don't have an option to check if the subscription (still) exists

            try {

}