leeonky / test-charm-java / 347

Committed 07 Oct 2025 09:20AM UTC coverage: 74.946% (+0.2%) from 74.7%

Build # 347

Build Type

push

circleci

Committed by

leeonky

Commit Message

raise error when dependent value changed

Run Details

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

20 existing lines in 6 files now uncovered.

8723 of 11639 relevant lines covered (74.95%)

0.75 hits per line

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

97.6

/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();
    private final List<PropertyStructureDependent> propertyStructureDependents = new ArrayList<>();

    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);
        instance.spec.applyPropertyStructureDefinitions(jFactory, this);
        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;
    }

    public void verifyPropertyStructureDependent(T value) {
        for (PropertyStructureDependent propertyStructureDependent : propertyStructureDependents) {
            propertyStructureDependent.verify(value);
        }
    }

    @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);
    }

    public void lock(PropertyStructureDependent propertyStructureDependent) {
        propertyStructureDependents.add(propertyStructureDependent);
    }
}

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

leeonky / test-charm-java / 347

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