Dragonestia/RoomPicker
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

implemented client instance repository

Browse Source
This commit is contained in:
Andrey Terentev 2024-05-24 10:15:47 +07:00 committed by Andrey Terentev
parent 05db1ef50a
commit 17b6107ce7
1 changed files with 27 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
client-impl/src/main/java/ru/dragonestia/picker/api/impl/repository/InstanceRepositoryImpl.java
View File

@ -1,6 +1,7 @@
package ru.dragonestia.picker.api.impl.repository;
import ru.dragonestia.picker.api.impl.util.RestTemplate;
import ru.dragonestia.picker.api.impl.util.type.HttpMethod;
import ru.dragonestia.picker.api.model.entity.EntityId;
import ru.dragonestia.picker.api.model.instance.Instance;
import ru.dragonestia.picker.api.model.instance.InstanceId;
@ -8,50 +9,63 @@ import ru.dragonestia.picker.api.model.instance.type.PickingMethod;
import ru.dragonestia.picker.api.repository.InstanceRepository;
import ru.dragonestia.picker.api.repository.response.ResponseObject;
import java.util.Collection;
import java.util.List;
import java.util.Map;
import java.util.*;
public class InstanceRepositoryImpl implements InstanceRepository {
private final RestTemplate restTemplate;
private final RestTemplate rest;
public InstanceRepositoryImpl(RestTemplate restTemplate) {
this.restTemplate = restTemplate;
public InstanceRepositoryImpl(RestTemplate rest) {
this.rest = rest;
}
@Override
public List<InstanceId> allInstancesIds() {
throw new UnsupportedOperationException("Not implemented");
return Arrays.stream(rest.query("/instances", HttpMethod.GET, String[].class))
.map(InstanceId::of)
.toList();
}
@Override
public Instance getInstance(InstanceId id) {
throw new UnsupportedOperationException("Not implemented");
return rest.query("/instances/target/" + id.getValue(), HttpMethod.GET, ResponseObject.RInstance.class).convert();
}
@Override
public Map<InstanceId, Instance> getInstances(Collection<InstanceId> ids) {
throw new UnsupportedOperationException("Not implemented");
var map = new HashMap<InstanceId, Instance>();
rest.query("/instances/target/list", HttpMethod.GET, ResponseObject.RInstance[].class, params -> {
params.put("id", String.join(",", ids.stream().map(InstanceId::getValue).toList()));
});
return map;
}
@Override
public void createInstance(InstanceId id, PickingMethod method, boolean persist) {
throw new UnsupportedOperationException("Not implemented");
rest.query("/instances", HttpMethod.POST, params -> {
params.put("instanceId", id.getValue());
params.put("method", method.name());
params.put("persist", Boolean.toString(persist
));
});
}
@Override
public void deleteInstance(InstanceId id) {
throw new UnsupportedOperationException("Not implemented");
rest.query("/instances/target/" + id.getValue(), HttpMethod.DELETE);
}
@Override
public void deleteInstances(Collection<InstanceId> ids) {
throw new UnsupportedOperationException("Not implemented");
rest.query("/instances/list", HttpMethod.DELETE, params -> {
params.put("id", String.join(",", ids.stream().map(InstanceId::getValue).toList()));
});
}
@Override
public ResponseObject.PickedRoom pickRoom(InstanceId id, Collection<EntityId> entities, boolean dontReturnEntities) {
throw new UnsupportedOperationException("Not implemented");
return rest.queryPostWithBody("/instances/target/" + id.getValue() + "/pick", ResponseObject.PickedRoom.class, params -> {
params.put("dontReturnEntities", Boolean.toString(dontReturnEntities));
}, String.join(",", entities.stream().map(EntityId::getValue).toList()));
}
}