ProjectRepositoryLevelDbImpl.java

/*
 * Copyright (c) 2015 Maxim Yunusov
 *    Licensed under the Apache License, Version 2.0 (the "License");
 *    you may not use this file except in compliance with the License.
 *    You may obtain a copy of the License at
 *
 *        http://www.apache.org/licenses/LICENSE-2.0
 *
 *    Unless required by applicable law or agreed to in writing, software
 *    distributed under the License is distributed on an "AS IS" BASIS,
 *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *    See the License for the specific language governing permissions and
 *    limitations under the License.
 */

package org.maxur.perfmodel.backend.infrastructure;

import org.iq80.leveldb.WriteBatch;
import org.jvnet.hk2.annotations.Service;
import org.maxur.perfmodel.backend.domain.ConflictException;
import org.maxur.perfmodel.backend.domain.Project;
import org.maxur.perfmodel.backend.domain.Repository;
import org.maxur.perfmodel.backend.service.Benchmark;
import org.maxur.perfmodel.backend.service.DataSource;
import org.slf4j.Logger;

import javax.inject.Inject;
import java.io.IOException;
import java.util.Collection;
import java.util.Optional;

import static java.lang.String.format;
import static java.util.Optional.empty;
import static org.slf4j.LoggerFactory.getLogger;

/**
 * Level Db Implementation of Project Repository.
 *
 * @author myunusov
 * @version 1.0
 * @since <pre>30.08.2015</pre>
 */
@Service
public class ProjectRepositoryLevelDbImpl implements Repository<Project> {

    private static final Logger LOGGER = getLogger(ProjectRepositoryLevelDbImpl.class);

    public static final String ROOT_PREFIX = "/";

    @Inject
    private DataSource dataSource;

    @Override
    @Benchmark
    public Optional<Project> get(final String key) {
        try {
            return dataSource.get(key);
        } catch (IOException | ClassNotFoundException e) {
            return throwError(e, "Cannot find project by id '%s'", key);
        }
    }

    @Override
    @Benchmark
    public Collection<Project> findAll() {
        try {
            return dataSource.findAllByPrefix(ROOT_PREFIX);
        } catch (IOException | ClassNotFoundException e) {
            return throwError(e, "Cannot get all projects");
        }
    }

    @Override
    @Benchmark
    public Optional<Project> findByName(final String name) {
        try {
            return dataSource.get(path(name));
        } catch (IOException | ClassNotFoundException e) {
            return throwError(e, "Cannot find project by name '%s'", name);
        }
    }

    @Override
    @Benchmark
    public Optional<Project> remove(final String key) {
        try (WriteBatch batch = dataSource.createWriteBatch()) {
            final Optional<Project> result = dataSource.get(key);
            if (result.isPresent()) {
                dataSource.delete(key);
                dataSource.delete(path(result.get().getName()));
                dataSource.commit(batch);
            }
            return result;
        } catch (IOException | ClassNotFoundException e) {
            return throwError(e, "Cannot remove project '%s'", key);
        }

    }

    @Override
    @Benchmark
    public Optional<Project> add(final Project value) throws ConflictException {
        final String id = value.getId();
        final String newName = value.getName();
        try (WriteBatch batch = dataSource.createWriteBatch()) {
            final Optional<Project> other = dataSource.get(id);
            if (value.isSame(other)) {
                return other;
            }
            value.checkUniqueId(other);
            value.checkNamesakes(findByName(newName));
            value.makeVersion();
            dataSource.put(id, value);
            dataSource.put(path(newName), value.brief());
            dataSource.commit(batch);
            return Optional.of(value);
        } catch (IOException | ClassNotFoundException e) {
            return throwError(e, "Cannot save project '%s'", newName);
        }
    }

    @Override
    @Benchmark
    // idempotent
    public Optional<Project> amend(final Project value) throws ConflictException  {
        final String id = value.getId();
        final String newName = value.getName();
        value.incVersion();

        try (WriteBatch batch = dataSource.createWriteBatch()) {
            final Optional<Project> prev = dataSource.get(id);
            if (!prev.isPresent()) {
                return empty();
            }
            if (value.isSame(prev)) {
                return prev;
            }
            value.checkConflictWith(prev);
            final boolean mustBeRenamed = !prev.get().getName().equals(newName);
            if (mustBeRenamed) {
                value.checkNamesakes(findByName(newName));
                dataSource.delete(path(prev.get().getName()));
            }
            dataSource.put(id, value);
            dataSource.put(path(newName), value.brief());
            dataSource.commit(batch);
            return Optional.of(value);
        } catch (IOException | ClassNotFoundException e) {
            return throwError(e, "Cannot save project '%s'", newName);
        }
    }

    private String path(final String name) {
        return ROOT_PREFIX + name;
    }

    private static <T> T throwError(final Exception e, final String message, final String... args) {
        final String msg = format(message, args);
        LOGGER.error(msg, e);
        throw new IllegalStateException(msg, e);
    }

}


































Active mutators

INCREMENTS_MUTATOR
VOID_METHOD_CALL_MUTATOR
RETURN_VALS_MUTATOR
MATH_MUTATOR
NEGATE_CONDITIONALS_MUTATOR
INVERT_NEGS_MUTATOR
CONDITIONALS_BOUNDARY_MUTATOR

Tests examined

Report generated by PIT 1.1.6

1		/*
2		* Copyright (c) 2015 Maxim Yunusov
3		* Licensed under the Apache License, Version 2.0 (the "License");
4		* you may not use this file except in compliance with the License.
5		* You may obtain a copy of the License at
6		*
7		* http://www.apache.org/licenses/LICENSE-2.0
8		*
9		* Unless required by applicable law or agreed to in writing, software
10		* distributed under the License is distributed on an "AS IS" BASIS,
11		* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12		* See the License for the specific language governing permissions and
13		* limitations under the License.
14		*/
15
16		package org.maxur.perfmodel.backend.infrastructure;
17
18		import org.iq80.leveldb.WriteBatch;
19		import org.jvnet.hk2.annotations.Service;
20		import org.maxur.perfmodel.backend.domain.ConflictException;
21		import org.maxur.perfmodel.backend.domain.Project;
22		import org.maxur.perfmodel.backend.domain.Repository;
23		import org.maxur.perfmodel.backend.service.Benchmark;
24		import org.maxur.perfmodel.backend.service.DataSource;
25		import org.slf4j.Logger;
26
27		import javax.inject.Inject;
28		import java.io.IOException;
29		import java.util.Collection;
30		import java.util.Optional;
31
32		import static java.lang.String.format;
33		import static java.util.Optional.empty;
34		import static org.slf4j.LoggerFactory.getLogger;
35
36		/**
37		* Level Db Implementation of Project Repository.
38		*
39		* @author myunusov
40		* @version 1.0
41		* @since <pre>30.08.2015</pre>
42		*/
43		@Service
44		public class ProjectRepositoryLevelDbImpl implements Repository<Project> {
45
46		private static final Logger LOGGER = getLogger(ProjectRepositoryLevelDbImpl.class);
47
48		public static final String ROOT_PREFIX = "/";
49
50		@Inject
51		private DataSource dataSource;
52
53		@Override
54		@Benchmark
55		public Optional<Project> get(final String key) {
56		try {
57	1 1. get : mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/ProjectRepositoryLevelDbImpl::get to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE	return dataSource.get(key);
58		} catch (IOException \| ClassNotFoundException e) {
59	1 1. get : mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/ProjectRepositoryLevelDbImpl::get to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE	return throwError(e, "Cannot find project by id '%s'", key);
60		}
61		}
62
63		@Override
64		@Benchmark
65		public Collection<Project> findAll() {
66		try {
67	1 1. findAll : mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/ProjectRepositoryLevelDbImpl::findAll to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE	return dataSource.findAllByPrefix(ROOT_PREFIX);
68		} catch (IOException \| ClassNotFoundException e) {
69	1 1. findAll : mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/ProjectRepositoryLevelDbImpl::findAll to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE	return throwError(e, "Cannot get all projects");
70		}
71		}
72
73		@Override
74		@Benchmark
75		public Optional<Project> findByName(final String name) {
76		try {
77	1 1. findByName : mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/ProjectRepositoryLevelDbImpl::findByName to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE	return dataSource.get(path(name));
78		} catch (IOException \| ClassNotFoundException e) {
79	1 1. findByName : mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/ProjectRepositoryLevelDbImpl::findByName to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE	return throwError(e, "Cannot find project by name '%s'", name);
80		}
81		}
82
83		@Override
84		@Benchmark
85		public Optional<Project> remove(final String key) {
86		try (WriteBatch batch = dataSource.createWriteBatch()) {
87		final Optional<Project> result = dataSource.get(key);
88	1 1. remove : negated conditional → NO_COVERAGE	if (result.isPresent()) {
89	1 1. remove : removed call to org/maxur/perfmodel/backend/service/DataSource::delete → NO_COVERAGE	dataSource.delete(key);
90	1 1. remove : removed call to org/maxur/perfmodel/backend/service/DataSource::delete → NO_COVERAGE	dataSource.delete(path(result.get().getName()));
91	1 1. remove : removed call to org/maxur/perfmodel/backend/service/DataSource::commit → NO_COVERAGE	dataSource.commit(batch);
92		}
93		return result;
94		} catch (IOException \| ClassNotFoundException e) {
95	1 1. remove : mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/ProjectRepositoryLevelDbImpl::remove to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE	return throwError(e, "Cannot remove project '%s'", key);
96		}
97
98		}
99
100		@Override
101		@Benchmark
102		public Optional<Project> add(final Project value) throws ConflictException {
103		final String id = value.getId();
104		final String newName = value.getName();
105		try (WriteBatch batch = dataSource.createWriteBatch()) {
106		final Optional<Project> other = dataSource.get(id);
107	1 1. add : negated conditional → NO_COVERAGE	if (value.isSame(other)) {
108		return other;
109		}
110	1 1. add : removed call to org/maxur/perfmodel/backend/domain/Project::checkUniqueId → NO_COVERAGE	value.checkUniqueId(other);
111	1 1. add : removed call to org/maxur/perfmodel/backend/domain/Project::checkNamesakes → NO_COVERAGE	value.checkNamesakes(findByName(newName));
112	1 1. add : removed call to org/maxur/perfmodel/backend/domain/Project::makeVersion → NO_COVERAGE	value.makeVersion();
113	1 1. add : removed call to org/maxur/perfmodel/backend/service/DataSource::put → NO_COVERAGE	dataSource.put(id, value);
114	1 1. add : removed call to org/maxur/perfmodel/backend/service/DataSource::put → NO_COVERAGE	dataSource.put(path(newName), value.brief());
115	1 1. add : removed call to org/maxur/perfmodel/backend/service/DataSource::commit → NO_COVERAGE	dataSource.commit(batch);
116		return Optional.of(value);
117		} catch (IOException \| ClassNotFoundException e) {
118	1 1. add : mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/ProjectRepositoryLevelDbImpl::add to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE	return throwError(e, "Cannot save project '%s'", newName);
119		}
120		}
121
122		@Override
123		@Benchmark
124		// idempotent
125		public Optional<Project> amend(final Project value) throws ConflictException {
126		final String id = value.getId();
127		final String newName = value.getName();
128	1 1. amend : removed call to org/maxur/perfmodel/backend/domain/Project::incVersion → NO_COVERAGE	value.incVersion();
129
130		try (WriteBatch batch = dataSource.createWriteBatch()) {
131		final Optional<Project> prev = dataSource.get(id);
132	1 1. amend : negated conditional → NO_COVERAGE	if (!prev.isPresent()) {
133		return empty();
134		}
135	1 1. amend : negated conditional → NO_COVERAGE	if (value.isSame(prev)) {
136		return prev;
137		}
138	1 1. amend : removed call to org/maxur/perfmodel/backend/domain/Project::checkConflictWith → NO_COVERAGE	value.checkConflictWith(prev);
139	1 1. amend : negated conditional → NO_COVERAGE	final boolean mustBeRenamed = !prev.get().getName().equals(newName);
140	1 1. amend : negated conditional → NO_COVERAGE	if (mustBeRenamed) {
141	1 1. amend : removed call to org/maxur/perfmodel/backend/domain/Project::checkNamesakes → NO_COVERAGE	value.checkNamesakes(findByName(newName));
142	1 1. amend : removed call to org/maxur/perfmodel/backend/service/DataSource::delete → NO_COVERAGE	dataSource.delete(path(prev.get().getName()));
143		}
144	1 1. amend : removed call to org/maxur/perfmodel/backend/service/DataSource::put → NO_COVERAGE	dataSource.put(id, value);
145	1 1. amend : removed call to org/maxur/perfmodel/backend/service/DataSource::put → NO_COVERAGE	dataSource.put(path(newName), value.brief());
146	1 1. amend : removed call to org/maxur/perfmodel/backend/service/DataSource::commit → NO_COVERAGE	dataSource.commit(batch);
147		return Optional.of(value);
148		} catch (IOException \| ClassNotFoundException e) {
149	1 1. amend : mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/ProjectRepositoryLevelDbImpl::amend to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE	return throwError(e, "Cannot save project '%s'", newName);
150		}
151		}
152
153		private String path(final String name) {
154	1 1. path : mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/ProjectRepositoryLevelDbImpl::path to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE	return ROOT_PREFIX + name;
155		}
156
157		private static <T> T throwError(final Exception e, final String message, final String... args) {
158		final String msg = format(message, args);
159		LOGGER.error(msg, e);
160		throw new IllegalStateException(msg, e);
161		}
162
163		}
		Mutations
57		1.1 Location : get Killed by : none mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/ProjectRepositoryLevelDbImpl::get to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE
59		1.1 Location : get Killed by : none mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/ProjectRepositoryLevelDbImpl::get to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE
67		1.1 Location : findAll Killed by : none mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/ProjectRepositoryLevelDbImpl::findAll to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE
69		1.1 Location : findAll Killed by : none mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/ProjectRepositoryLevelDbImpl::findAll to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE
77		1.1 Location : findByName Killed by : none mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/ProjectRepositoryLevelDbImpl::findByName to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE
79		1.1 Location : findByName Killed by : none mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/ProjectRepositoryLevelDbImpl::findByName to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE
88		1.1 Location : remove Killed by : none negated conditional → NO_COVERAGE
89		1.1 Location : remove Killed by : none removed call to org/maxur/perfmodel/backend/service/DataSource::delete → NO_COVERAGE
90		1.1 Location : remove Killed by : none removed call to org/maxur/perfmodel/backend/service/DataSource::delete → NO_COVERAGE
91		1.1 Location : remove Killed by : none removed call to org/maxur/perfmodel/backend/service/DataSource::commit → NO_COVERAGE
95		1.1 Location : remove Killed by : none mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/ProjectRepositoryLevelDbImpl::remove to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE
107		1.1 Location : add Killed by : none negated conditional → NO_COVERAGE
110		1.1 Location : add Killed by : none removed call to org/maxur/perfmodel/backend/domain/Project::checkUniqueId → NO_COVERAGE
111		1.1 Location : add Killed by : none removed call to org/maxur/perfmodel/backend/domain/Project::checkNamesakes → NO_COVERAGE
112		1.1 Location : add Killed by : none removed call to org/maxur/perfmodel/backend/domain/Project::makeVersion → NO_COVERAGE
113		1.1 Location : add Killed by : none removed call to org/maxur/perfmodel/backend/service/DataSource::put → NO_COVERAGE
114		1.1 Location : add Killed by : none removed call to org/maxur/perfmodel/backend/service/DataSource::put → NO_COVERAGE
115		1.1 Location : add Killed by : none removed call to org/maxur/perfmodel/backend/service/DataSource::commit → NO_COVERAGE
118		1.1 Location : add Killed by : none mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/ProjectRepositoryLevelDbImpl::add to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE
128		1.1 Location : amend Killed by : none removed call to org/maxur/perfmodel/backend/domain/Project::incVersion → NO_COVERAGE
132		1.1 Location : amend Killed by : none negated conditional → NO_COVERAGE
135		1.1 Location : amend Killed by : none negated conditional → NO_COVERAGE
138		1.1 Location : amend Killed by : none removed call to org/maxur/perfmodel/backend/domain/Project::checkConflictWith → NO_COVERAGE
139		1.1 Location : amend Killed by : none negated conditional → NO_COVERAGE
140		1.1 Location : amend Killed by : none negated conditional → NO_COVERAGE
141		1.1 Location : amend Killed by : none removed call to org/maxur/perfmodel/backend/domain/Project::checkNamesakes → NO_COVERAGE
142		1.1 Location : amend Killed by : none removed call to org/maxur/perfmodel/backend/service/DataSource::delete → NO_COVERAGE
144		1.1 Location : amend Killed by : none removed call to org/maxur/perfmodel/backend/service/DataSource::put → NO_COVERAGE
145		1.1 Location : amend Killed by : none removed call to org/maxur/perfmodel/backend/service/DataSource::put → NO_COVERAGE
146		1.1 Location : amend Killed by : none removed call to org/maxur/perfmodel/backend/service/DataSource::commit → NO_COVERAGE
149		1.1 Location : amend Killed by : none mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/ProjectRepositoryLevelDbImpl::amend to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE
154		1.1 Location : path Killed by : none mutated return of Object value for org/maxur/perfmodel/backend/infrastructure/ProjectRepositoryLevelDbImpl::path to ( if (x != null) null else throw new RuntimeException ) → NO_COVERAGE

ProjectRepositoryLevelDbImpl.java

Mutations

Active mutators

Tests examined