• Home
  • Features
  • Pricing
  • Docs
  • Announcements
  • Sign In

leeonky / test-charm-java / 368

12 Oct 2025 01:55PM UTC coverage: 75.301% (+0.1%) from 75.185%
368

push

circleci

leeonky
one to many

13 of 13 new or added lines in 2 files covered. (100.0%)

10 existing lines in 4 files now uncovered.

8893 of 11810 relevant lines covered (75.3%)

0.75 hits per line

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

98.03
/jfactory/src/main/java/com/github/leeonky/jfactory/ObjectProducer.java
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
    private final List<DefaultListStructure<T, ?>> listStructures = new ArrayList<>();
1✔
28

29
    public JFactory jFactory() {
30
        return jFactory;
1✔
31
    }
32

33
    public ObjectProducer(JFactory jFactory, ObjectFactory<T> factory, DefaultBuilder<T> builder,
34
                          Optional<Association> association, Optional<ReverseAssociation> reverseAssociation) {
35
        this(jFactory, factory, builder, false, association, reverseAssociation);
1✔
36
    }
1✔
37

38
    public ObjectProducer(JFactory jFactory, ObjectFactory<T> factory, DefaultBuilder<T> builder, boolean forQuery,
39
                          Optional<Association> association, Optional<ReverseAssociation> reverseAssociation) {
40
        super(factory.getType());
1✔
41
        this.factory = factory;
1✔
42
        this.jFactory = jFactory;
1✔
43
        this.builder = builder;
1✔
44
        instance = factory.createInstance(builder.getArguments(), association, reverseAssociation, this);
1✔
45
        persistable = jFactory.getDataRepository();
1✔
46
        createDefaultValueProducers();
1✔
47
        builder.collectSpec(this, instance);
1✔
48
        builder.processInputProperty(this, forQuery);
1✔
49
        instance.spec.applyPropertyStructureDefinitions(jFactory, this);
1✔
50
        processListStructures();
1✔
51
        setupReverseAssociations();
1✔
52

53
        reverseAssociation.ifPresent(reverseAssociation1 -> {
1✔
54
            reverseAssociations.forEach((r, a) -> {
1✔
55
                if (reverseAssociation1.matches(a)) {
1✔
56
                    if (descendantForRead(r) instanceof CollectionProducer) {
1✔
57
                        changeDescendant(r.concat(0), (producer, s) -> reverseAssociation1.buildUnFixedValueProducer());
1✔
58
                    } else
59
                        changeDescendant(r, (producer, s) -> reverseAssociation1.buildUnFixedValueProducer());
1✔
60
                }
61
            });
1✔
62
        });
1✔
63
        resolveBuilderProducers();
1✔
64
    }
1✔
65

66
    private void processListStructures() {
67
        listStructures.forEach(listStructure -> listStructure.process(this, jFactory));
1✔
68
    }
1✔
69

70
    public Producer<?> newElementPopulationProducer(PropertyWriter<T> propertyWriter) {
71
        return getFirstPresent(() -> ofNullable(elementPopulationFactory.apply(propertyWriter)),
1✔
72
                () -> newDefaultValueProducer(propertyWriter))
1✔
73
                .orElseGet(() -> new DefaultTypeValueProducer<>(propertyWriter.getType()));
1✔
74
    }
75

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

82
    private void createElementDefaultValueProducersWhenBuildListAsRoot() {
83
        try {
84
            children.keySet().stream().map(Integer::valueOf).max(Integer::compareTo).ifPresent(size -> {
1✔
85
                size++;
1✔
86
                instance.setCollectionSize(size);
1✔
87
                range(0, size).mapToObj(String::valueOf)
1✔
88
                        .filter(index -> children.get(index) == null)
1✔
89
                        .map(index -> getType().getPropertyWriter(index))
1✔
90
                        .forEach((PropertyWriter<T> propertyWriter) ->
1✔
91
                                setChild(propertyWriter.getName(), newElementPopulationProducer(propertyWriter)));
1✔
92
            });
1✔
93
        } catch (Exception ignore) {
1✔
94
        }
1✔
95
    }
1✔
96

97
    private void setupReverseAssociations() {
98
        reverseAssociations.forEach((child, association) ->
1✔
99
                descendantForUpdate(child).setupAssociation(association, instance, cachedChildren));
1✔
100
    }
1✔
101

102
    @Override
103
    protected void setChild(String property, Producer<?> producer) {
104
        children.put(property, producer);
1✔
105
    }
1✔
106

107
    @Override
108
    public Optional<Producer<?>> getChild(String property) {
109
        return ofNullable(children.get(property));
1✔
110
    }
111

112
    @Override
113
    public Producer<?> childForUpdate(String property) {
114
        PropertyWriter<T> propertyWriter = getType().getPropertyWriter(property);
1✔
115
        return getFirstPresent(() -> getChild(propertyWriter.getName()),
1✔
116
                () -> newDefaultValueProducer(propertyWriter)).orElseGet(() -> {
1✔
117
            if (ignorePropertiesInSpec.contains(propertyWriter.getName()))
1✔
UNCOV
118
                return new ReadOnlyProducer<>(this, propertyWriter.getName());
×
119
            return new DefaultTypeValueProducer<>(propertyWriter.getType());
1✔
120
        });
121
    }
122

123
    @Override
124
    public Producer<?> childForRead(String property) {
125
        PropertyWriter<T> propertyWriter = getType().getPropertyWriter(property);
1✔
126
        return getFirstPresent(() -> getChild(propertyWriter.getName()),
1✔
127
                () -> newDefaultValueProducerForRead(propertyWriter)).orElseGet(() -> {
1✔
128
            if (ignorePropertiesInSpec.contains(propertyWriter.getName()))
1✔
129
                return new ReadOnlyProducer<>(this, propertyWriter.getName());
1✔
130
            return new DefaultTypeValueProducer<>(propertyWriter.getType());
1✔
131
        });
132
    }
133

134
    public Producer<?> forceChildOrDefaultCollection(PropertyWriter<T> propertyWriter) {
135
        return getChild(propertyWriter.getName()).orElseGet(() -> createCollectionProducer(propertyWriter));
1✔
136
    }
137

138
    @Override
139
    protected T produce() {
140
        return instance.cache(() -> {
1✔
141
            createElementDefaultValueProducersWhenBuildListAsRoot();
1✔
142
            return factory.create(instance);
1✔
143
        }, obj -> {
144
            produceSubs(obj);
1✔
145
            persistable.save(obj);
1✔
146
            cachedChildren.getAll().forEach(persistable::save);
1✔
147
        });
1✔
148
    }
149

150
    private void produceSubs(T obj) {
151
        children.entrySet().stream().filter(this::isDefaultValueProducer).forEach(e -> produceSub(obj, e));
1✔
152
        children.entrySet().stream().filter(e -> !(isDefaultValueProducer(e))).forEach(e -> produceSub(obj, e));
1✔
153
    }
1✔
154

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

159
    private boolean isDefaultValueProducer(Map.Entry<String, Producer<?>> e) {
160
        return e.getValue() instanceof DefaultValueFactoryProducer;
1✔
161
    }
162

163
    public ObjectProducer<T> processConsistent() {
164
        collectConsistent(this, propertyChain(""));
1✔
165
        consistencySet.resolve(this);
1✔
166
        return this;
1✔
167
    }
168

169
    @Override
170
    public void verifyPropertyStructureDependent() {
171
        for (PropertyStructureDependent propertyStructureDependent : propertyStructureDependents)
1✔
172
            propertyStructureDependent.verify(getValue());
1✔
173

174
        children.values().forEach(Producer::verifyPropertyStructureDependent);
1✔
175
    }
1✔
176

177
    @Override
178
    protected void collectConsistent(ObjectProducer<?> root, PropertyChain base) {
179
        if (root != this)
1✔
180
            root.consistencySet.addAll(consistencySet.absoluteProperty(base));
1✔
181
        children.forEach((property, producer) -> producer.collectConsistent(root, base.concat(property)));
1✔
182
    }
1✔
183

184
    private void createDefaultValueProducers() {
185
        getType().getPropertyWriters().values().stream().filter(jFactory::shouldCreateDefaultValue)
1✔
186
                .forEach(propertyWriter -> factory.getFactorySet().newDefaultValueFactoryProducer(propertyWriter, instance)
1✔
187
                        .ifPresent(producer -> setChild(propertyWriter.getName(), producer)));
1✔
188
    }
1✔
189

190
    @Override
191
    public Optional<Producer<?>> newDefaultValueProducer(PropertyWriter<T> property) {
192
        if (ignorePropertiesInSpec.contains(property.getName()))
1✔
UNCOV
193
            return empty();
×
194
        if (property.getType().isCollection()) {
1✔
195
            return of(createCollectionProducer(property));
1✔
196
        } else
197
            return factory.getFactorySet().newDefaultValueFactoryProducer(property, instance);
1✔
198
    }
199

200
    public Optional<Producer<?>> newDefaultValueProducerForRead(PropertyWriter<T> property) {
201
        if (ignorePropertiesInSpec.contains(property.getName()))
1✔
202
            return empty();
1✔
203
        else
204
            return factory.getFactorySet().newDefaultValueFactoryProducer(property, instance);
1✔
205
    }
206

207
    private Producer<?> createCollectionProducer(PropertyWriter<T> property) {
208
        Producer<?> producer = new CollectionProducer<>(getType(), property.getType(), instance.sub(property),
1✔
209
                factory.getFactorySet(), jFactory);
1✔
210
        setChild(property.getName(), producer);
1✔
211
        return producer;
1✔
212
    }
213

214
    @Override
215
    public Producer<T> changeTo(Producer<T> newProducer) {
216
        return newProducer.changeFrom(this);
1✔
217
    }
218

219
    @Override
220
    protected Producer<T> changeFrom(ObjectProducer<T> origin) {
221
        return origin.builder.marge(builder).createProducer();
1✔
222
    }
223

224
    @Override
225
    @SuppressWarnings("unchecked")
226
    protected Producer<T> changeFrom(OptionalSpecDefaultValueProducer<T> producer) {
227
        if (producer.getTraitsAndSpec() != null)
1✔
228
            return ((DefaultBuilder<T>) jFactory.spec(producer.getTraitsAndSpec())).marge(builder).createProducer();
1✔
UNCOV
229
        return this;
×
230
    }
231

232
    public void appendReverseAssociation(PropertyChain property, String association) {
233
        reverseAssociations.put(property, association);
1✔
234
    }
1✔
235

236
    @Override
237
    protected <R> void setupAssociation(String association, RootInstance<R> instance, ListPersistable cachedChildren) {
238
        setChild(association, new UnFixedValueProducer<>(instance.reference(), instance.spec().getType()));
1✔
239
        persistable = cachedChildren;
1✔
240
    }
1✔
241

242
    public boolean isReverseAssociation(String property) {
243
        return reverseAssociations.containsKey(PropertyChain.propertyChain(property));
1✔
244
    }
245

246
    public void ignoreProperty(String property) {
247
        ignorePropertiesInSpec.add(property);
1✔
248
    }
1✔
249

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

256
    @Override
257
    protected boolean isFixed() {
258
        return children.values().stream().anyMatch(Producer::isFixed);
1✔
259
    }
260

261
    public void changeElementPopulationFactory(Function<PropertyWriter<T>, Producer<?>> factory) {
262
        elementPopulationFactory = factory;
1✔
263
    }
1✔
264

265
    public void appendLink(DefaultConsistency<?, ?> consistency) {
266
        consistencySet.add(consistency);
1✔
267
    }
1✔
268

269
    public void lock(PropertyStructureDependent propertyStructureDependent) {
270
        propertyStructureDependents.add(propertyStructureDependent);
1✔
271
    }
1✔
272

273
    public void appendListStructure(DefaultListStructure<T, ?> listStructure) {
274
        listStructures.add(listStructure);
1✔
275
    }
1✔
276

277
    public Optional<Association> association(String string) {
278
        return ofNullable(reverseAssociations.get(propertyChain(string)))
1✔
279
                .map(p -> new Association(p));
1✔
280
    }
281

282
    public Optional<String> reverseAssociation(PropertyChain property) {
283
        return Optional.ofNullable(reverseAssociations.get(property));
1✔
284
    }
285
}
286

287
//TODO refactor
288
class Association {
289
    final String property;
290

291
    Association(String property) {
1✔
292
        this.property = property;
1✔
293
    }
1✔
294

295
    boolean matches(String property) {
296
        return this.property.equals(property);
1✔
297
    }
298
}
299

300
class ReverseAssociation {
301
    private final String property;
302
    //    TODO refactor
303
    final Instance<?> instance;
304

305
    ReverseAssociation(String property, Instance<?> instance) {
1✔
306
        this.property = property;
1✔
307
        this.instance = instance;
1✔
308
    }
1✔
309

310
    public boolean matches(String property) {
311
        return this.property.equals(property);
1✔
312
    }
313

314
    UnFixedValueProducer buildUnFixedValueProducer() {
315
        return new UnFixedValueProducer(instance.reference(), instance.spec().getType());
1✔
316
    }
317
}
STATUS · Troubleshooting · Open an Issue · Sales · Support · CAREERS · ENTERPRISE · START FREE · SCHEDULE DEMO
ANNOUNCEMENTS · TWITTER · TOS & SLA · Supported CI Services · What's a CI service? · Automated Testing

© 2026 Coveralls, Inc