1 | /*- | |
2 | * #%L | |
3 | * io.earcam.utilitarian.site.search.offline | |
4 | * %% | |
5 | * Copyright (C) 2017 earcam | |
6 | * %% | |
7 | * SPDX-License-Identifier: (BSD-3-Clause OR EPL-1.0 OR Apache-2.0 OR MIT) | |
8 | * | |
9 | * You <b>must</b> choose to accept, in full - any individual or combination of | |
10 | * the following licenses: | |
11 | * <ul> | |
12 | * <li><a href="https://opensource.org/licenses/BSD-3-Clause">BSD-3-Clause</a></li> | |
13 | * <li><a href="https://www.eclipse.org/legal/epl-v10.html">EPL-1.0</a></li> | |
14 | * <li><a href="https://www.apache.org/licenses/LICENSE-2.0">Apache-2.0</a></li> | |
15 | * <li><a href="https://opensource.org/licenses/MIT">MIT</a></li> | |
16 | * </ul> | |
17 | * #L% | |
18 | */ | |
19 | package io.earcam.utilitarian.site.search.offline; | |
20 | ||
21 | import static io.earcam.utilitarian.site.search.offline.Crawler.crawler; | |
22 | import static java.util.stream.Collectors.toMap; | |
23 | import static java.util.stream.Collectors.toSet; | |
24 | import static java.util.stream.StreamSupport.stream; | |
25 | ||
26 | import java.io.File; | |
27 | import java.net.URI; | |
28 | import java.nio.file.Path; | |
29 | import java.util.List; | |
30 | import java.util.Map; | |
31 | import java.util.ServiceLoader; | |
32 | import java.util.Set; | |
33 | import java.util.stream.Stream; | |
34 | ||
35 | public abstract class ConfigurationModel { | |
36 | ||
37 | public static class Step extends ConfigurationModel {} | |
38 | ||
39 | public static class Mapping { | |
40 | ||
41 | private File dir; | |
42 | private URI uri; | |
43 | ||
44 | ||
45 | public File getDir() | |
46 | { | |
47 |
1
1. getDir : mutated return of Object value for io/earcam/utilitarian/site/search/offline/ConfigurationModel$Mapping::getDir to ( if (x != null) null else throw new RuntimeException ) → KILLED |
return dir; |
48 | } | |
49 | ||
50 | ||
51 | static Path dirAsPath(Mapping mapping) | |
52 | { | |
53 |
1
1. dirAsPath : mutated return of Object value for io/earcam/utilitarian/site/search/offline/ConfigurationModel$Mapping::dirAsPath to ( if (x != null) null else throw new RuntimeException ) → KILLED |
return mapping.getDir().toPath(); |
54 | } | |
55 | ||
56 | ||
57 | public void setDir(File dir) | |
58 | { | |
59 | this.dir = dir; | |
60 | } | |
61 | ||
62 | ||
63 | public URI getUri() | |
64 | { | |
65 |
1
1. getUri : mutated return of Object value for io/earcam/utilitarian/site/search/offline/ConfigurationModel$Mapping::getUri to ( if (x != null) null else throw new RuntimeException ) → KILLED |
return uri; |
66 | } | |
67 | ||
68 | ||
69 | public void setUri(URI uri) | |
70 | { | |
71 | this.uri = uri; | |
72 | } | |
73 | } | |
74 | ||
75 | public static class Indexing extends ConfigurationModel { | |
76 | ||
77 | public Indexer build() | |
78 | { | |
79 |
1
1. build : mutated return of Object value for io/earcam/utilitarian/site/search/offline/ConfigurationModel$Indexing::build to ( if (x != null) null else throw new RuntimeException ) → KILLED |
return create(Indexer.class, this); |
80 | } | |
81 | } | |
82 | ||
83 | ||
84 | static <T extends Component> T create(Class<T> type, ConfigurationModel model) | |
85 | { | |
86 | T component = serviceById(type, model.getId()); | |
87 |
1
1. create : removed call to io/earcam/utilitarian/site/search/offline/Component::configure → KILLED |
component.configure(model.getConfiguration()); |
88 |
1
1. create : mutated return of Object value for io/earcam/utilitarian/site/search/offline/ConfigurationModel::create to ( if (x != null) null else throw new RuntimeException ) → KILLED |
return component; |
89 | } | |
90 | ||
91 | ||
92 | private static <S extends Component> S serviceById(Class<S> service, String id) | |
93 | { | |
94 |
1
1. serviceById : mutated return of Object value for io/earcam/utilitarian/site/search/offline/ConfigurationModel::serviceById to ( if (x != null) null else throw new RuntimeException ) → KILLED |
return serviceStream(service) |
95 |
1
1. lambda$serviceById$0 : replaced return of integer sized value with (x == 0 ? 1 : 0) → KILLED |
.filter(s -> id.equals(s.id())) |
96 | .findFirst() | |
97 |
1
1. lambda$serviceById$1 : mutated return of Object value for io/earcam/utilitarian/site/search/offline/ConfigurationModel::lambda$serviceById$1 to ( if (x != null) null else throw new RuntimeException ) → SURVIVED |
.orElseThrow(() -> new IllegalStateException("Not SPI service with id '" + id |
98 | + "' found of type '" + service.getCanonicalName() + "'")); | |
99 | } | |
100 | ||
101 | ||
102 | private static <S extends Component> Stream<S> serviceStream(Class<S> service) | |
103 | { | |
104 |
1
1. serviceStream : mutated return of Object value for io/earcam/utilitarian/site/search/offline/ConfigurationModel::serviceStream to ( if (x != null) null else throw new RuntimeException ) → KILLED |
return stream(ServiceLoader.load(service).spliterator(), false); |
105 | } | |
106 | ||
107 | public static class Crawling { | |
108 | ||
109 | private List<Mapping> mappings; | |
110 | ||
111 | private List<Step> steps; | |
112 | ||
113 | ||
114 | public List<Mapping> getMappings() | |
115 | { | |
116 |
1
1. getMappings : mutated return of Object value for io/earcam/utilitarian/site/search/offline/ConfigurationModel$Crawling::getMappings to ( if (x != null) null else throw new RuntimeException ) → KILLED |
return mappings; |
117 | } | |
118 | ||
119 | ||
120 | public void setMappings(List<Mapping> mappings) | |
121 | { | |
122 | this.mappings = mappings; | |
123 | } | |
124 | ||
125 | ||
126 | public List<Step> getSteps() | |
127 | { | |
128 |
1
1. getSteps : mutated return of Object value for io/earcam/utilitarian/site/search/offline/ConfigurationModel$Crawling::getSteps to ( if (x != null) null else throw new RuntimeException ) → KILLED |
return steps; |
129 | } | |
130 | ||
131 | ||
132 | public void setSteps(List<Step> steps) | |
133 | { | |
134 | this.steps = steps; | |
135 | } | |
136 | ||
137 | ||
138 | public Crawler build() | |
139 | { | |
140 | Crawler crawler = crawler(mappings.stream() | |
141 | .collect(toMap(Mapping::dirAsPath, Mapping::getUri))); | |
142 | ||
143 | Set<String> filters = serviceIds(Filter.class); | |
144 | Set<String> processors = serviceIds(Processor.class); | |
145 | ||
146 | for(Step step : steps) { | |
147 |
1
1. build : negated conditional → KILLED |
if(filters.contains(step.getId())) { |
148 | crawler.filter(create(Filter.class, step)); | |
149 | ||
150 |
1
1. build : negated conditional → KILLED |
} else if(processors.contains(step.getId())) { |
151 | crawler.processor(create(Processor.class, step)); | |
152 | ||
153 | } else { | |
154 | throw new IllegalStateException("No filter or processor found via SPI with ID '" + step.getId() + "'"); | |
155 | } | |
156 | } | |
157 |
1
1. build : mutated return of Object value for io/earcam/utilitarian/site/search/offline/ConfigurationModel$Crawling::build to ( if (x != null) null else throw new RuntimeException ) → KILLED |
return crawler; |
158 | } | |
159 | ||
160 | ||
161 | private static <S extends Component> Set<String> serviceIds(Class<S> service) | |
162 | { | |
163 |
1
1. serviceIds : mutated return of Object value for io/earcam/utilitarian/site/search/offline/ConfigurationModel$Crawling::serviceIds to ( if (x != null) null else throw new RuntimeException ) → KILLED |
return serviceStream(service) |
164 | .map(Component::id) | |
165 | .collect(toSet()); | |
166 | } | |
167 | } | |
168 | ||
169 | private String id; | |
170 | ||
171 | private Map<String, String> configuration; | |
172 | ||
173 | ||
174 | public String getId() | |
175 | { | |
176 |
1
1. getId : mutated return of Object value for io/earcam/utilitarian/site/search/offline/ConfigurationModel::getId to ( if (x != null) null else throw new RuntimeException ) → KILLED |
return id; |
177 | } | |
178 | ||
179 | ||
180 | public void setId(String id) | |
181 | { | |
182 | this.id = id; | |
183 | } | |
184 | ||
185 | ||
186 | public Map<String, String> getConfiguration() | |
187 | { | |
188 |
1
1. getConfiguration : mutated return of Object value for io/earcam/utilitarian/site/search/offline/ConfigurationModel::getConfiguration to ( if (x != null) null else throw new RuntimeException ) → KILLED |
return configuration; |
189 | } | |
190 | ||
191 | ||
192 | public void setConfiguration(Map<String, String> configuration) | |
193 | { | |
194 | this.configuration = configuration; | |
195 | } | |
196 | } | |
Mutations | ||
47 |
1.1 |
|
53 |
1.1 |
|
65 |
1.1 |
|
79 |
1.1 |
|
87 |
1.1 |
|
88 |
1.1 |
|
94 |
1.1 |
|
95 |
1.1 |
|
97 |
1.1 |
|
104 |
1.1 |
|
116 |
1.1 |
|
128 |
1.1 |
|
147 |
1.1 |
|
150 |
1.1 |
|
157 |
1.1 |
|
163 |
1.1 |
|
176 |
1.1 |
|
188 |
1.1 |