wistefan / tmforum-api / #49

coverage: 67.488% (-4.3%) from 71.815%
#49

push

web-flow 
Notifications (#23)

* Squashed commits

* Added cache invalidation for entity deletion

* Updated error message

618 of 618 new or added lines in 86 files covered. (100.0%)

2794 of 4140 relevant lines covered (67.49%)

0.67 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0
/party-catalog/src/main/java/org/fiware/tmforum/party/rest/EventSubscriptionApiController.java
1 
package org.fiware.tmforum.party.rest;
2 









3



import io.micronaut.core.annotation.NonNull;










4



import io.micronaut.http.HttpResponse;










5



import io.micronaut.http.annotation.Controller;










6



import lombok.extern.slf4j.Slf4j;










7



import org.fiware.party.api.EventsSubscriptionApi;










8



import org.fiware.party.model.EventSubscriptionInputVO;










9



import org.fiware.party.model.EventSubscriptionVO;










10



import org.fiware.tmforum.common.notification.EventHandler;










11



import org.fiware.tmforum.common.domain.subscription.Subscription;










12



import org.fiware.tmforum.common.repository.TmForumRepository;










13



import org.fiware.tmforum.common.rest.AbstractSubscriptionApiController;










14



import org.fiware.tmforum.common.validation.ReferenceValidationService;










15



import org.fiware.tmforum.party.TMForumMapper;










16



import org.fiware.tmforum.party.domain.individual.Individual;










17



import org.fiware.tmforum.party.domain.organization.Organization;










18



import reactor.core.publisher.Mono;










19












20



import java.util.List;










21



import java.util.Map;










22












23



import static java.util.Map.entry;










24



import static org.fiware.tmforum.common.notification.EventConstants.EVENT_GROUP_INDIVIDUAL;










25



import static org.fiware.tmforum.common.notification.EventConstants.EVENT_GROUP_ORGANIZATION;










26













27



@Slf4j




×







28



@Controller("${general.basepath:/}")










29



public class EventSubscriptionApiController extends AbstractSubscriptionApiController implements EventsSubscriptionApi {










30



    private final TMForumMapper tmForumMapper;











31



        private static final Map<String, String> EVENT_GROUP_TO_ENTITY_NAME_MAPPING = Map.ofEntries(




×








32



                entry(EVENT_GROUP_INDIVIDUAL, Individual.TYPE_INDIVIDUAL),




×








33



                entry(EVENT_GROUP_ORGANIZATION, Organization.TYPE_ORGANIZATION)




×







34



        );











35



    private static final List<String> EVENT_GROUPS = List.of(EVENT_GROUP_INDIVIDUAL, EVENT_GROUP_ORGANIZATION);




×







36












37



    public EventSubscriptionApiController(ReferenceValidationService validationService,










38



                                          TmForumRepository repository, TMForumMapper tmForumMapper, EventHandler eventHandler) {











39



        super(validationService, repository, EVENT_GROUP_TO_ENTITY_NAME_MAPPING, eventHandler);




×








40



        this.tmForumMapper = tmForumMapper;




×








41



    }




×







42












43



    @Override










44



    public Mono<HttpResponse<EventSubscriptionVO>> registerListener(










45



            @NonNull EventSubscriptionInputVO eventSubscriptionInputVO) {











46



        Subscription subscription = buildSubscription(eventSubscriptionInputVO.getCallback(),




×








47



                eventSubscriptionInputVO.getQuery(), EVENT_GROUPS);




×







48













49



        return create(subscription)




×








50



                .map(tmForumMapper::map)




×








51



                .map(HttpResponse::created);




×







52



    }










53












54



    @Override










55



    public Mono<HttpResponse<Object>> unregisterListener(@NonNull String id) {











56



        return delete(id);




×







57



    }










58



}
























    

  • 

    •