wistefan / tmforum-api / #62

coverage: 68.167% (+0.5%) from 67.631%

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

96.77
/account/src/main/java/org/fiware/tmforum/account/rest/SettlementAccountApiController.java
1 
package org.fiware.tmforum.account.rest;
2 









3



import io.micronaut.http.HttpResponse;










4



import io.micronaut.http.annotation.Controller;










5



import lombok.extern.slf4j.Slf4j;










6



import org.fiware.account.api.SettlementAccountApi;










7



import org.fiware.account.model.SettlementAccountCreateVO;










8



import org.fiware.account.model.SettlementAccountUpdateVO;










9



import org.fiware.account.model.SettlementAccountVO;










10



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










11



import org.fiware.tmforum.common.exception.TmForumException;










12



import org.fiware.tmforum.common.exception.TmForumExceptionReason;










13



import org.fiware.tmforum.common.mapping.IdHelper;










14



import org.fiware.tmforum.common.querying.QueryParser;










15



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










16



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










17



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










18



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










19



import org.fiware.tmforum.account.TMForumMapper;










20



import org.fiware.tmforum.account.domain.SettlementAccount;










21



import reactor.core.publisher.Mono;










22












23



import javax.annotation.Nullable;










24



import java.util.ArrayList;










25



import java.util.List;










26



import java.util.Optional;










27



import java.util.UUID;










28













29



@Slf4j




1✔





30



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










31



public class SettlementAccountApiController extends AbstractApiController<SettlementAccount> implements SettlementAccountApi {










32












33



    private final TMForumMapper tmForumMapper;










34












35












36



    public SettlementAccountApiController(QueryParser queryParser, ReferenceValidationService validationService,










37



                                          TmForumRepository productSettlementAccountRepository, TMForumMapper tmForumMapper, EventHandler eventHandler) {











38



        super(queryParser, validationService, productSettlementAccountRepository, eventHandler);




1✔






39



        this.tmForumMapper = tmForumMapper;




1✔






40



    }




1✔





41












42



    @Override










43



    public Mono<HttpResponse<SettlementAccountVO>> createSettlementAccount(SettlementAccountCreateVO settlementAccountVo) {











44



        SettlementAccount settlementAccount = tmForumMapper.map(




1✔






45



                tmForumMapper.map(settlementAccountVo, IdHelper.toNgsiLd(UUID.randomUUID().toString(), SettlementAccount.TYPE_PARTYAC)));




1✔





46













47



        return create(getCheckingMono(settlementAccount), SettlementAccount.class)




1✔






48



                .map(tmForumMapper::map)




1✔






49



                .map(HttpResponse::created);




1✔





50



    }










51












52



    private Mono<SettlementAccount> getCheckingMono(SettlementAccount settlementAccount) {











53



        List<List<? extends ReferencedEntity>> references = new ArrayList<>();




1✔






54



        references.add(settlementAccount.getRelatedParty());




1✔






55



        Optional.ofNullable(settlementAccount.getDefaultPaymentMethod()).map(List::of).ifPresent(references::add);




1✔






56



        Optional.ofNullable(settlementAccount.getFinancialAccount()).map(List::of).ifPresent(references::add);




1✔






57



        return getCheckingMono(settlementAccount, references)




1✔






58



                .onErrorMap(throwable -> new TmForumException(




1✔






59



                        String.format("Was not able to create settlementAccount %s", settlementAccount.getId()), throwable,




1✔





60



                        TmForumExceptionReason.INVALID_RELATIONSHIP));










61



    }










62












63



    @Override










64



    public Mono<HttpResponse<Object>> deleteSettlementAccount(String id) {











65



        return delete(id);




1✔





66



    }










67












68



    @Override










69



    public Mono<HttpResponse<List<SettlementAccountVO>>> listSettlementAccount(@Nullable String fields, @Nullable Integer offset,










70



                                                                     @Nullable Integer limit) {











71



        return list(offset, limit, SettlementAccount.TYPE_PARTYAC, SettlementAccount.class)




1✔






72



                .map(settlementAccountStream -> settlementAccountStream.map(tmForumMapper::map).toList())




1✔






73



                .switchIfEmpty(Mono.just(List.of()))




1✔






74



                .map(HttpResponse::ok);




1✔





75



    }










76












77



    @Override










78



    public Mono<HttpResponse<SettlementAccountVO>> patchSettlementAccount(String id, SettlementAccountUpdateVO settlementAccountUpdateVO) {










79



        // non-ngsi-ld ids cannot exist.











80



        if (!IdHelper.isNgsiLdId(id)) {




1✔






81



            throw new TmForumException("Did not receive a valid id, such settlementAccount cannot exist.",




×







82



                    TmForumExceptionReason.NOT_FOUND);










83



        }











84



        SettlementAccount updatedSettlementAccount = tmForumMapper.map(tmForumMapper.map(settlementAccountUpdateVO, id));




1✔





85













86



        return patch(id, updatedSettlementAccount, getCheckingMono(updatedSettlementAccount), SettlementAccount.class)




1✔






87



                .map(tmForumMapper::map)




1✔






88



                .map(HttpResponse::ok);




1✔





89



    }










90












91



    @Override










92



    public Mono<HttpResponse<SettlementAccountVO>> retrieveSettlementAccount(String id, @Nullable String fields) {











93



        return retrieve(id, SettlementAccount.class)




1✔






94



                .switchIfEmpty(Mono.error(new TmForumException("No such settlementAccount exists.",




1✔





95



                        TmForumExceptionReason.NOT_FOUND)))











96



                .map(tmForumMapper::map)




1✔






97



                .map(HttpResponse::ok);




1✔





98



    }










99



}










100


























    

  • 

    •