FIWARE / contract-management / #68

Committed 29 Oct 2025 11:26AM UTC coverage: 1.686% (+0.04%) from 1.651%

Build # #68

Build Type

Committed by

Commit Message

fixes from pr review

Pull Request Pull Request #12: Support for central marketplace and policy creation

Run Details

117 of 1238 new or added lines in 31 files covered. (9.45%)

5 existing lines in 2 files now uncovered.

587 of 34807 relevant lines covered (1.69%)

0.02 hits per line

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

0.0

/src/main/java/org/fiware/iam/dsp/RainbowCatalogHandler.java

package org.fiware.iam.dsp;

import io.micronaut.context.annotation.Requires;
import io.micronaut.http.HttpResponse;
import io.micronaut.http.HttpStatus;
import jakarta.inject.Singleton;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.fiware.iam.configuration.GeneralProperties;
import org.fiware.iam.handlers.CatalogHandler;
import org.fiware.iam.tmforum.productcatalog.model.CatalogVO;
import org.fiware.rainbow.api.CatalogApiClient;
import org.fiware.rainbow.model.NewCatalogVO;
import reactor.core.publisher.Mono;

/**
 * Handler to manage catalog events and exchange them with Rainbow.
 */
@Requires(condition = GeneralProperties.RainbowCondition.class)
@RequiredArgsConstructor
@Singleton
@Slf4j
public class RainbowCatalogHandler implements CatalogHandler {

    private final CatalogApiClient catalogApiClient;
    private final RainbowMapper rainbowMapper;

    @Override
    public Mono<HttpResponse<?>> handleCatalogCreation(CatalogVO catalogVO) {
        NewCatalogVO rainbowCatalog = rainbowMapper.map(catalogVO);
        return catalogApiClient.createCatalog(rainbowCatalog)
                .onErrorMap(t -> new IllegalArgumentException("Was not able create the catalog %s".formatted(rainbowCatalog), t))
                .map(HttpResponse::ok);
    }

    @Override
    public Mono<HttpResponse<?>> handleCatalogStateChange(CatalogVO catalogVO) {
        return catalogApiClient.updateCatalogById(catalogVO.getId(), rainbowMapper.map(catalogVO)).map(res -> {
            if (res.getStatus().getCode() >= 200 && res.getStatus().getCode() < 300) {
                return HttpResponse.noContent();
            }
            return HttpResponse.status(HttpStatus.BAD_GATEWAY);
        });
    }

    @Override
    public Mono<HttpResponse<?>> handleCatalogDeletion(CatalogVO catalogVO) {
        return catalogApiClient.deleteCatalogById(catalogVO.getId()).map(res -> {
            if (res.getStatus().getCode() >= 200 && res.getStatus().getCode() < 300) {
                return HttpResponse.noContent();
            }
            return HttpResponse.status(HttpStatus.BAD_GATEWAY);
        });
    }
}

1	package org.fiware.iam.dsp;
2
3	import io.micronaut.context.annotation.Requires;
4	import io.micronaut.http.HttpResponse;
5	import io.micronaut.http.HttpStatus;
6	import jakarta.inject.Singleton;
7	import lombok.RequiredArgsConstructor;
8	import lombok.extern.slf4j.Slf4j;
9	import org.fiware.iam.configuration.GeneralProperties;
10	import org.fiware.iam.handlers.CatalogHandler;
11	import org.fiware.iam.tmforum.productcatalog.model.CatalogVO;
12	import org.fiware.rainbow.api.CatalogApiClient;
13	import org.fiware.rainbow.model.NewCatalogVO;
14	import reactor.core.publisher.Mono;
15
16	/**
17	* Handler to manage catalog events and exchange them with Rainbow.
18	*/
19	@Requires(condition = GeneralProperties.RainbowCondition.class)
20	@RequiredArgsConstructor
21	@Singleton
NEW 22	@Slf4j	×
23	public class RainbowCatalogHandler implements CatalogHandler {
24
25	private final CatalogApiClient catalogApiClient;
26	private final RainbowMapper rainbowMapper;
27
28	@Override
29	public Mono<HttpResponse<?>> handleCatalogCreation(CatalogVO catalogVO) {
NEW 30	NewCatalogVO rainbowCatalog = rainbowMapper.map(catalogVO);	×
NEW 31	return catalogApiClient.createCatalog(rainbowCatalog)	×
NEW 32	.onErrorMap(t -> new IllegalArgumentException("Was not able create the catalog %s".formatted(rainbowCatalog), t))	×
NEW 33	.map(HttpResponse::ok);	×
34	}
35
36	@Override
37	public Mono<HttpResponse<?>> handleCatalogStateChange(CatalogVO catalogVO) {
NEW 38	return catalogApiClient.updateCatalogById(catalogVO.getId(), rainbowMapper.map(catalogVO)).map(res -> {	×
NEW 39	if (res.getStatus().getCode() >= 200 && res.getStatus().getCode() < 300) {	×
NEW 40	return HttpResponse.noContent();	×
41	}
NEW 42	return HttpResponse.status(HttpStatus.BAD_GATEWAY);	×
43	});
44	}
45
46	@Override
47	public Mono<HttpResponse<?>> handleCatalogDeletion(CatalogVO catalogVO) {
NEW 48	return catalogApiClient.deleteCatalogById(catalogVO.getId()).map(res -> {	×
NEW 49	if (res.getStatus().getCode() >= 200 && res.getStatus().getCode() < 300) {	×
NEW 50	return HttpResponse.noContent();	×
51	}
NEW 52	return HttpResponse.status(HttpStatus.BAD_GATEWAY);	×
53	});
54	}
55	}

FIWARE / contract-management / #68

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

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