Skip to content
Snippets Groups Projects
Commit b7f9cd7f authored by OZGCloud's avatar OZGCloud
Browse files

OZG-6810 small improvements

parent f4cbd62a
Branches
Tags
1 merge request!4Revert "OZG-6810 [tmp] update version"
......@@ -77,7 +77,7 @@ public class GrpcBinaryFileService extends BinaryFileServiceImplBase {
responseObserver.onCompleted();
}
public GrpcFindFilesResponse buildResponseForOzgFiles(List<OzgCloudFile> files) {
GrpcFindFilesResponse buildResponseForOzgFiles(List<OzgCloudFile> files) {
var builder = GrpcFindFilesResponse.newBuilder();
files.stream().map(fileMapper::map).forEach(builder::addFile);
......
......@@ -57,7 +57,7 @@ class OzgCloudFileRepository {
static final String GRID_FS_FIELD_ID = "_id";
private final CollisionVerifier collisionVerifier = new CollisionVerifier(this::existBinaryFile);
private final CollisionVerifier collisionVerifier = new CollisionVerifier(this::existOzgCloudFile);
private final GridFsTemplate gridFsTemplate;
private final MongoOperations mongoOperations;
......@@ -127,8 +127,8 @@ class OzgCloudFileRepository {
}
public void deleteAllByVorgang(String vorgangId) {
var deletedBinaryFile = mongoOperations.findAllAndRemove(query(where(OzgCloudFile.FIELD_VORGANG_ID).is(vorgangId)), OzgCloudFile.class);
deletedBinaryFile.stream().map(OzgCloudFile::getContentId).filter(Objects::nonNull).forEach(this::deleteContent);
var deletedOzgCloudFile = mongoOperations.findAllAndRemove(query(where(OzgCloudFile.FIELD_VORGANG_ID).is(vorgangId)), OzgCloudFile.class);
deletedOzgCloudFile.stream().map(OzgCloudFile::getContentId).filter(Objects::nonNull).forEach(this::deleteContent);
}
public void deleteContent(String contentId) {
......@@ -139,7 +139,7 @@ class OzgCloudFileRepository {
return Query.query(Criteria.where(GRID_FS_FIELD_ID).is(contentId));
}
private boolean existBinaryFile(String fileId) {
private boolean existOzgCloudFile(String fileId) {
return mongoOperations.exists(query(where(OzgCloudFile.FIELD_ID).is(fileId)), OzgCloudFile.class);
}
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment