leeonky / test-charm-java / 332

Committed 02 Oct 2025 03:38PM UTC coverage: 74.653% (-0.03%) from 74.68%

Build # 332

Build Type

push

circleci

Committed by

leeonky

Commit Message

Refactor

Run Details

10 of 10 new or added lines in 3 files covered. (100.0%)

16 existing lines in 5 files now uncovered.

8559 of 11465 relevant lines covered (74.65%)

0.75 hits per line

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

97.44

/jfactory/src/main/java/com/github/leeonky/jfactory/ObjectProducer.java

package com.github.leeonky.jfactory;

import com.github.leeonky.util.PropertyWriter;

import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors;

import static com.github.leeonky.jfactory.PropertyChain.propertyChain;
import static com.github.leeonky.util.function.Extension.getFirstPresent;
import static java.util.Optional.*;
import static java.util.stream.IntStream.range;

class ObjectProducer<T> extends Producer<T> {
    private final ObjectFactory<T> factory;
    private final JFactory jFactory;
    private final DefaultBuilder<T> builder;
    private final RootInstance<T> instance;
    private final Map<String, Producer<?>> children = new HashMap<>();
    private final Map<PropertyChain, String> reverseAssociations = new LinkedHashMap<>();
    private final ListPersistable cachedChildren = new ListPersistable();
    private final Set<String> ignorePropertiesInSpec = new HashSet<>();
    private Persistable persistable;
    private Function<PropertyWriter<T>, Producer<?>> elementPopulationFactory = any -> null;
    private final ConsistencySet consistencySet = new ConsistencySet();

    public JFactory jFactory() {
        return jFactory;
    }

    public ObjectProducer(JFactory jFactory, ObjectFactory<T> factory, DefaultBuilder<T> builder) {
        this(jFactory, factory, builder, false);
    }

    public ObjectProducer(JFactory jFactory, ObjectFactory<T> factory, DefaultBuilder<T> builder, boolean forQuery) {
        super(factory.getType());
        this.factory = factory;
        this.jFactory = jFactory;
        this.builder = builder;
        instance = factory.createInstance(builder.getArguments());
        persistable = jFactory.getDataRepository();
        createDefaultValueProducers();
        builder.collectSpec(this, instance);
        builder.processInputProperty(this, forQuery);
        setupReverseAssociations();
        resolveBuilderProducers();
    }

    public Producer<?> newElementPopulationProducer(PropertyWriter<T> propertyWriter) {
        return getFirstPresent(() -> ofNullable(elementPopulationFactory.apply(propertyWriter)),
                () -> newDefaultValueProducer(propertyWriter))
                .orElseGet(() -> new DefaultTypeValueProducer<>(propertyWriter.getType()));
    }

    protected void resolveBuilderProducers() {
        List<Map.Entry<String, Producer<?>>> buildValueProducers = children.entrySet().stream()
                .filter(entry -> entry.getValue() instanceof BuilderValueProducer).collect(Collectors.toList());
        buildValueProducers.forEach(e -> setChild(e.getKey(), ((BuilderValueProducer) e.getValue()).getProducer()));
    }

    private void createElementDefaultValueProducersWhenBuildListAsRoot() {
        try {
            children.keySet().stream().map(Integer::valueOf).max(Integer::compareTo).ifPresent(size -> {
                size++;
                instance.setCollectionSize(size);
                range(0, size).mapToObj(String::valueOf)
                        .filter(index -> children.get(index) == null)
                        .map(index -> getType().getPropertyWriter(index))
                        .forEach((PropertyWriter<T> propertyWriter) ->
                                setChild(propertyWriter.getName(), newElementPopulationProducer(propertyWriter)));
            });
        } catch (Exception ignore) {
        }
    }

    private void setupReverseAssociations() {
        reverseAssociations.forEach((child, association) ->
                descendantForUpdate(child).setupAssociation(association, instance, cachedChildren));
    }

    @Override
    protected void setChild(String property, Producer<?> producer) {
        children.put(property, producer);
    }

    @Override
    public Optional<Producer<?>> getChild(String property) {
        return ofNullable(children.get(property));
    }

    @Override
    public Producer<?> childForUpdate(String property) {
        PropertyWriter<T> propertyWriter = getType().getPropertyWriter(property);
        return getFirstPresent(() -> getChild(propertyWriter.getName()),
                () -> newDefaultValueProducer(propertyWriter)).orElseGet(() -> {
            if (ignorePropertiesInSpec.contains(propertyWriter.getName()))
                return new ReadOnlyProducer<>(this, propertyWriter.getName());
            return new DefaultTypeValueProducer<>(propertyWriter.getType());
        });
    }

    @Override
    public Producer<?> childForRead(String property) {
        PropertyWriter<T> propertyWriter = getType().getPropertyWriter(property);
        return getFirstPresent(() -> getChild(propertyWriter.getName()),
                () -> newDefaultValueProducerForRead(propertyWriter)).orElseGet(() -> {
            if (ignorePropertiesInSpec.contains(propertyWriter.getName()))
                return new ReadOnlyProducer<>(this, propertyWriter.getName());
            return new DefaultTypeValueProducer<>(propertyWriter.getType());
        });
    }

    public Producer<?> forceChildOrDefaultCollection(PropertyWriter<T> propertyWriter) {
        return getChild(propertyWriter.getName()).orElseGet(() -> createCollectionProducer(propertyWriter));
    }

    @Override
    protected T produce() {
        return instance.cache(() -> {
            createElementDefaultValueProducersWhenBuildListAsRoot();
            return factory.create(instance);
        }, obj -> {
            produceSubs(obj);
            persistable.save(obj);
            cachedChildren.getAll().forEach(persistable::save);
        });
    }

    private void produceSubs(T obj) {
        children.entrySet().stream().filter(this::isDefaultValueProducer).forEach(e -> produceSub(obj, e));
        children.entrySet().stream().filter(e -> !(isDefaultValueProducer(e))).forEach(e -> produceSub(obj, e));
    }

    private void produceSub(T obj, Map.Entry<String, Producer<?>> e) {
        getType().setPropertyValue(obj, e.getKey(), e.getValue().getValue());
    }

    private boolean isDefaultValueProducer(Map.Entry<String, Producer<?>> e) {
        return e.getValue() instanceof DefaultValueFactoryProducer;
    }

    public ObjectProducer<T> processConsistent() {
        collectConsistent(this, propertyChain(""));
        consistencySet.resolve(this);
        return this;
    }

    @Override
    protected void collectConsistent(ObjectProducer<?> root, PropertyChain base) {
        if (root != this)
            root.consistencySet.addAll(consistencySet.absoluteProperty(base));
        children.forEach((property, producer) -> producer.collectConsistent(root, base.concat(property)));
    }

    private void createDefaultValueProducers() {
        getType().getPropertyWriters().values().stream().filter(jFactory::shouldCreateDefaultValue)
                .forEach(propertyWriter -> factory.getFactorySet().newDefaultValueFactoryProducer(propertyWriter, instance)
                        .ifPresent(producer -> setChild(propertyWriter.getName(), producer)));
    }

    @Override
    public Optional<Producer<?>> newDefaultValueProducer(PropertyWriter<T> property) {
        if (ignorePropertiesInSpec.contains(property.getName()))
            return empty();
        if (property.getType().isCollection()) {
            return of(createCollectionProducer(property));
        } else
            return factory.getFactorySet().newDefaultValueFactoryProducer(property, instance);
    }

    public Optional<Producer<?>> newDefaultValueProducerForRead(PropertyWriter<T> property) {
        if (ignorePropertiesInSpec.contains(property.getName()))
            return empty();
        else
            return factory.getFactorySet().newDefaultValueFactoryProducer(property, instance);
    }

    private Producer<?> createCollectionProducer(PropertyWriter<T> property) {
        Producer<?> producer = new CollectionProducer<>(getType(), property.getType(), instance.sub(property),
                factory.getFactorySet(), jFactory);
        setChild(property.getName(), producer);
        return producer;
    }

    @Override
    public Producer<T> changeTo(Producer<T> newProducer) {
        return newProducer.changeFrom(this);
    }

    @Override
    protected Producer<T> changeFrom(ObjectProducer<T> origin) {
        return origin.builder.marge(builder).createProducer();
    }

    @Override
    @SuppressWarnings("unchecked")
    protected Producer<T> changeFrom(OptionalSpecDefaultValueProducer<T> producer) {
        if (producer.getTraitsAndSpec() != null)
            return ((DefaultBuilder<T>) jFactory.spec(producer.getTraitsAndSpec())).marge(builder).createProducer();
        return this;
    }

    public void appendReverseAssociation(PropertyChain property, String association) {
        reverseAssociations.put(property, association);
    }

    @Override
    protected <R> void setupAssociation(String association, RootInstance<R> instance, ListPersistable cachedChildren) {
        setChild(association, new UnFixedValueProducer<>(instance.reference(), instance.spec().getType()));
        persistable = cachedChildren;
    }

    public boolean isReverseAssociation(String property) {
        return reverseAssociations.containsKey(PropertyChain.propertyChain(property));
    }

    public void ignoreProperty(String property) {
        ignorePropertiesInSpec.add(property);
    }

    public void processSpecIgnoreProperties() {
        children.entrySet().stream().filter(e -> e.getValue() instanceof DefaultValueProducer
                        && ignorePropertiesInSpec.contains(e.getKey())).map(Map.Entry::getKey).collect(Collectors.toList())
                .forEach(children::remove);
    }

    @Override
    protected boolean isFixed() {
        return children.values().stream().anyMatch(Producer::isFixed);
    }

    public void changeElementPopulationFactory(Function<PropertyWriter<T>, Producer<?>> factory) {
        elementPopulationFactory = factory;
    }

    public void appendLink(DefaultConsistency<?> consistency) {
        consistencySet.add(consistency);
    }
}

1	package com.github.leeonky.jfactory;
2
3	import com.github.leeonky.util.PropertyWriter;
4
5	import java.util.*;
6	import java.util.function.Function;
7	import java.util.stream.Collectors;
8
9	import static com.github.leeonky.jfactory.PropertyChain.propertyChain;
10	import static com.github.leeonky.util.function.Extension.getFirstPresent;
11	import static java.util.Optional.*;
12	import static java.util.stream.IntStream.range;
13
14	class ObjectProducer<T> extends Producer<T> {
15	private final ObjectFactory<T> factory;
16	private final JFactory jFactory;
17	private final DefaultBuilder<T> builder;
18	private final RootInstance<T> instance;
19	private final Map<String, Producer<?>> children = new HashMap<>();	1✔
20	private final Map<PropertyChain, String> reverseAssociations = new LinkedHashMap<>();	1✔
21	private final ListPersistable cachedChildren = new ListPersistable();	1✔
22	private final Set<String> ignorePropertiesInSpec = new HashSet<>();	1✔
23	private Persistable persistable;
24	private Function<PropertyWriter<T>, Producer<?>> elementPopulationFactory = any -> null;	1✔
25	private final ConsistencySet consistencySet = new ConsistencySet();	1✔
26
27	public JFactory jFactory() {
28	return jFactory;	1✔
29	}
30
31	public ObjectProducer(JFactory jFactory, ObjectFactory<T> factory, DefaultBuilder<T> builder) {
32	this(jFactory, factory, builder, false);	1✔
33	}	1✔
34
35	public ObjectProducer(JFactory jFactory, ObjectFactory<T> factory, DefaultBuilder<T> builder, boolean forQuery) {
36	super(factory.getType());	1✔
37	this.factory = factory;	1✔
38	this.jFactory = jFactory;	1✔
39	this.builder = builder;	1✔
40	instance = factory.createInstance(builder.getArguments());	1✔
41	persistable = jFactory.getDataRepository();	1✔
42	createDefaultValueProducers();	1✔
43	builder.collectSpec(this, instance);	1✔
44	builder.processInputProperty(this, forQuery);	1✔
45	setupReverseAssociations();	1✔
46	resolveBuilderProducers();	1✔
47	}	1✔
48
49	public Producer<?> newElementPopulationProducer(PropertyWriter<T> propertyWriter) {
50	return getFirstPresent(() -> ofNullable(elementPopulationFactory.apply(propertyWriter)),	1✔
51	() -> newDefaultValueProducer(propertyWriter))	1✔
52	.orElseGet(() -> new DefaultTypeValueProducer<>(propertyWriter.getType()));	1✔
53	}
54
55	protected void resolveBuilderProducers() {
56	List<Map.Entry<String, Producer<?>>> buildValueProducers = children.entrySet().stream()	1✔
57	.filter(entry -> entry.getValue() instanceof BuilderValueProducer).collect(Collectors.toList());	1✔
58	buildValueProducers.forEach(e -> setChild(e.getKey(), ((BuilderValueProducer) e.getValue()).getProducer()));	1✔
59	}	1✔
60
61	private void createElementDefaultValueProducersWhenBuildListAsRoot() {
62	try {
63	children.keySet().stream().map(Integer::valueOf).max(Integer::compareTo).ifPresent(size -> {	1✔
64	size++;	1✔
65	instance.setCollectionSize(size);	1✔
66	range(0, size).mapToObj(String::valueOf)	1✔
67	.filter(index -> children.get(index) == null)	1✔
68	.map(index -> getType().getPropertyWriter(index))	1✔
69	.forEach((PropertyWriter<T> propertyWriter) ->	1✔
70	setChild(propertyWriter.getName(), newElementPopulationProducer(propertyWriter)));	1✔
71	});	1✔
72	} catch (Exception ignore) {	1✔
73	}	1✔
74	}	1✔
75
76	private void setupReverseAssociations() {
77	reverseAssociations.forEach((child, association) ->	1✔
78	descendantForUpdate(child).setupAssociation(association, instance, cachedChildren));	1✔
79	}	1✔
80
81	@Override
82	protected void setChild(String property, Producer<?> producer) {
83	children.put(property, producer);	1✔
84	}	1✔
85
86	@Override
87	public Optional<Producer<?>> getChild(String property) {
88	return ofNullable(children.get(property));	1✔
89	}
90
91	@Override
92	public Producer<?> childForUpdate(String property) {
93	PropertyWriter<T> propertyWriter = getType().getPropertyWriter(property);	1✔
94	return getFirstPresent(() -> getChild(propertyWriter.getName()),	1✔
95	() -> newDefaultValueProducer(propertyWriter)).orElseGet(() -> {	1✔
96	if (ignorePropertiesInSpec.contains(propertyWriter.getName()))	1✔
UNCOV 97	return new ReadOnlyProducer<>(this, propertyWriter.getName());	×
98	return new DefaultTypeValueProducer<>(propertyWriter.getType());	1✔
99	});
100	}
101
102	@Override
103	public Producer<?> childForRead(String property) {
104	PropertyWriter<T> propertyWriter = getType().getPropertyWriter(property);	1✔
105	return getFirstPresent(() -> getChild(propertyWriter.getName()),	1✔
106	() -> newDefaultValueProducerForRead(propertyWriter)).orElseGet(() -> {	1✔
107	if (ignorePropertiesInSpec.contains(propertyWriter.getName()))	1✔
108	return new ReadOnlyProducer<>(this, propertyWriter.getName());	1✔
109	return new DefaultTypeValueProducer<>(propertyWriter.getType());	1✔
110	});
111	}
112
113	public Producer<?> forceChildOrDefaultCollection(PropertyWriter<T> propertyWriter) {
114	return getChild(propertyWriter.getName()).orElseGet(() -> createCollectionProducer(propertyWriter));	1✔
115	}
116
117	@Override
118	protected T produce() {
119	return instance.cache(() -> {	1✔
120	createElementDefaultValueProducersWhenBuildListAsRoot();	1✔
121	return factory.create(instance);	1✔
122	}, obj -> {
123	produceSubs(obj);	1✔
124	persistable.save(obj);	1✔
125	cachedChildren.getAll().forEach(persistable::save);	1✔
126	});	1✔
127	}
128
129	private void produceSubs(T obj) {
130	children.entrySet().stream().filter(this::isDefaultValueProducer).forEach(e -> produceSub(obj, e));	1✔
131	children.entrySet().stream().filter(e -> !(isDefaultValueProducer(e))).forEach(e -> produceSub(obj, e));	1✔
132	}	1✔
133
134	private void produceSub(T obj, Map.Entry<String, Producer<?>> e) {
135	getType().setPropertyValue(obj, e.getKey(), e.getValue().getValue());	1✔
136	}	1✔
137
138	private boolean isDefaultValueProducer(Map.Entry<String, Producer<?>> e) {
139	return e.getValue() instanceof DefaultValueFactoryProducer;	1✔
140	}
141
142	public ObjectProducer<T> processConsistent() {
143	collectConsistent(this, propertyChain(""));	1✔
144	consistencySet.resolve(this);	1✔
145	return this;	1✔
146	}
147
148	@Override
149	protected void collectConsistent(ObjectProducer<?> root, PropertyChain base) {
150	if (root != this)	1✔
151	root.consistencySet.addAll(consistencySet.absoluteProperty(base));	1✔
152	children.forEach((property, producer) -> producer.collectConsistent(root, base.concat(property)));	1✔
153	}	1✔
154
155	private void createDefaultValueProducers() {
156	getType().getPropertyWriters().values().stream().filter(jFactory::shouldCreateDefaultValue)	1✔
157	.forEach(propertyWriter -> factory.getFactorySet().newDefaultValueFactoryProducer(propertyWriter, instance)	1✔
158	.ifPresent(producer -> setChild(propertyWriter.getName(), producer)));	1✔
159	}	1✔
160
161	@Override
162	public Optional<Producer<?>> newDefaultValueProducer(PropertyWriter<T> property) {
163	if (ignorePropertiesInSpec.contains(property.getName()))	1✔
UNCOV 164	return empty();	×
165	if (property.getType().isCollection()) {	1✔
166	return of(createCollectionProducer(property));	1✔
167	} else
168	return factory.getFactorySet().newDefaultValueFactoryProducer(property, instance);	1✔
169	}
170
171	public Optional<Producer<?>> newDefaultValueProducerForRead(PropertyWriter<T> property) {
172	if (ignorePropertiesInSpec.contains(property.getName()))	1✔
173	return empty();	1✔
174	else
175	return factory.getFactorySet().newDefaultValueFactoryProducer(property, instance);	1✔
176	}
177
178	private Producer<?> createCollectionProducer(PropertyWriter<T> property) {
179	Producer<?> producer = new CollectionProducer<>(getType(), property.getType(), instance.sub(property),	1✔
180	factory.getFactorySet(), jFactory);	1✔
181	setChild(property.getName(), producer);	1✔
182	return producer;	1✔
183	}
184
185	@Override
186	public Producer<T> changeTo(Producer<T> newProducer) {
187	return newProducer.changeFrom(this);	1✔
188	}
189
190	@Override
191	protected Producer<T> changeFrom(ObjectProducer<T> origin) {
192	return origin.builder.marge(builder).createProducer();	1✔
193	}
194
195	@Override
196	@SuppressWarnings("unchecked")
197	protected Producer<T> changeFrom(OptionalSpecDefaultValueProducer<T> producer) {
198	if (producer.getTraitsAndSpec() != null)	1✔
199	return ((DefaultBuilder<T>) jFactory.spec(producer.getTraitsAndSpec())).marge(builder).createProducer();	1✔
UNCOV 200	return this;	×
201	}
202
203	public void appendReverseAssociation(PropertyChain property, String association) {
204	reverseAssociations.put(property, association);	1✔
205	}	1✔
206
207	@Override
208	protected <R> void setupAssociation(String association, RootInstance<R> instance, ListPersistable cachedChildren) {
209	setChild(association, new UnFixedValueProducer<>(instance.reference(), instance.spec().getType()));	1✔
210	persistable = cachedChildren;	1✔
211	}	1✔
212
213	public boolean isReverseAssociation(String property) {
214	return reverseAssociations.containsKey(PropertyChain.propertyChain(property));	1✔
215	}
216
217	public void ignoreProperty(String property) {
218	ignorePropertiesInSpec.add(property);	1✔
219	}	1✔
220
221	public void processSpecIgnoreProperties() {
222	children.entrySet().stream().filter(e -> e.getValue() instanceof DefaultValueProducer	1✔
223	&& ignorePropertiesInSpec.contains(e.getKey())).map(Map.Entry::getKey).collect(Collectors.toList())	1✔
224	.forEach(children::remove);	1✔
225	}	1✔
226
227	@Override
228	protected boolean isFixed() {
229	return children.values().stream().anyMatch(Producer::isFixed);	1✔
230	}
231
232	public void changeElementPopulationFactory(Function<PropertyWriter<T>, Producer<?>> factory) {
233	elementPopulationFactory = factory;	1✔
234	}	1✔
235
236	public void appendLink(DefaultConsistency<?> consistency) {
237	consistencySet.add(consistency);	1✔
238	}	1✔
239	}

leeonky / test-charm-java / 332

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