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

leeonky / test-charm-java / 378

13 Oct 2025 03:47PM UTC coverage: 75.288% (-0.02%) from 75.309%
378

push

circleci

leeonky
throw error when sub query result size > 1

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

2 existing lines in 2 files now uncovered.

8893 of 11812 relevant lines covered (75.29%)

0.75 hits per line

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

97.22
/jfactory/src/main/java/com/github/leeonky/jfactory/ObjectProducer.java
1
package com.github.leeonky.jfactory;
2

3
import com.github.leeonky.util.BeanClass;
4
import com.github.leeonky.util.PropertyWriter;
5

6
import java.util.*;
7
import java.util.function.Function;
8
import java.util.stream.Collectors;
9

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

15
class ObjectProducer<T> extends Producer<T> {
16
    private final ObjectFactory<T> factory;
17
    private final JFactory jFactory;
18
    private final DefaultBuilder<T> builder;
19
    private final ObjectInstance<T> instance;
20
    private final Map<String, Producer<?>> children = new HashMap<>();
1✔
21
    private final Map<PropertyChain, String> reverseAssociations = new LinkedHashMap<>();
1✔
22
    private final ListPersistable cachedChildren = new ListPersistable();
1✔
23
    private final Set<String> ignorePropertiesInSpec = new HashSet<>();
1✔
24
    private Persistable persistable;
25
    private Function<PropertyWriter<T>, Producer<?>> elementPopulationFactory = any -> null;
1✔
26
    private final ConsistencySet consistencySet = new ConsistencySet();
1✔
27
    private final List<PropertyStructureDependent> propertyStructureDependents = new ArrayList<>();
1✔
28
    private final List<DefaultListStructure<T, ?>> listStructures = new ArrayList<>();
1✔
29

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

311
    public boolean matches(String property, BeanClass<?> type) {
312
        return this.property.equals(property) && instance.spec().getType().equals(type);
1✔
313
    }
314

315
    UnFixedValueProducer buildUnFixedValueProducer() {
UNCOV
316
        return new UnFixedValueProducer(instance.reference(), instance.spec().getType());
×
317
    }
318
}
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