Protei/PromucFlow_constructor
2
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

Successful action execution results are saved in the action.

Browse Source
This commit is contained in:
Trisha Anand 2019-12-23 20:00:46 +05:30
parent 3cd5a28ed6
commit f13356a6e2
2 changed files with 21 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
app/server/appsmith-server/src/main/java/com/appsmith/server/domains/Action.java
View File

@ -49,6 +49,8 @@ public class Action extends BaseDomain {
@JsonProperty(access = JsonProperty.Access.READ_ONLY)
Set<String> jsonPathKeys;
String cacheResponse;
public Datasource getDatasource() {
if (this.datasource != null) {
//The action object has been created from JSON.

21
app/server/appsmith-server/src/main/java/com/appsmith/server/services/ActionServiceImpl.java
View File

@ -25,7 +25,6 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Example;
import org.springframework.data.domain.Sort;
import org.springframework.data.domain.Sort.Direction;
import org.springframework.data.mongodb.core.ReactiveMongoTemplate;
import org.springframework.data.mongodb.core.convert.MongoConverter;
import org.springframework.stereotype.Service;
@ -368,7 +367,25 @@ public class ActionServiceImpl extends BaseService<ActionRepository, Action, Str
actionConfiguration))
.timeout(Duration.ofMillis(timeoutDuration));
}))
.flatMap(obj -> obj);
.flatMap(obj -> obj)
.flatMap(result -> {
Mono<ActionExecutionResult> resultMono = Mono.just(result);
Mono<Action> actionFromDbMono = repository.findById(actionFromDto.getId())
//If the action is found in the db (i.e. it is not a dry run, save the cached response
.flatMap(action -> {
if (result.getStatusCode().charAt(0) == '2') {
//If the status code is 2xx, then save the cached response (aka the body) and return.
action.setCacheResponse(result.getBody().toString());
return repository.save(action);
}
return Mono.just(action);
});
return actionFromDbMono.zipWith(resultMono)
.map(tuple -> {
ActionExecutionResult executionResult = tuple.getT2();
return executionResult;
});
});
}
@Override