Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,9 @@ public class SummariesModel {
@JsonProperty("ai:description")
protected String aiDescription;

@JsonProperty("ai:update_frequency")
protected String aiUpdateFrequency;

@JsonProperty("scope")
protected Map<String, String> scope;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -39,6 +39,12 @@ public enum CQLFields implements CQLFieldsInterface {
null,
null
),
ai_update_frequency(
StacSummeries.AiUpdateFrequency.searchField,
StacSummeries.AiUpdateFrequency.displayField,
null,
null
),
geometry(
StacSummeries.Geometry.searchField,
StacSummeries.Geometry.searchField,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@ public enum CollectionProperty {
pace("pace"),
datasetGroup("dataset_group"),
aiDescription("ai:description"),
aiUpdateFrequency("ai:update_frequency"),
scope("scope");

private final String value;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,7 @@ public enum StacSummeries {
TemporalEnd("summaries.temporal.end", ""),
Temporal("summaries.temporal", "extent.temporal", "summaries.temporal", List.of(TemporalStart, TemporalEnd)),
UpdateFrequency("summaries.update_frequency", "summaries.update_frequency"),
AiUpdateFrequency("summaries.ai:update_frequency", "summaries.ai:update_frequency"),
DatasetProvider("summaries.dataset_provider", "summaries.dataset_provider"),
DatasetGroup("summaries.dataset_group", "summaries.dataset_group"),
Status("summaries.status", "summaries.status"),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -711,4 +711,25 @@ public void verifyAssetSummarySearchWorks() throws IOException {
assertEquals(1, Objects.requireNonNull(collections.getBody()).getCollections().size(), "hit 1");
assertEquals("35234913-aa3c-48ec-b9a4-77f822f66ef8", Objects.requireNonNull(collections.getBody()).getCollections().get(0).getId(), "asset.summary exist 35234913-aa3c-48ec-b9a4-77f822f66ef8");
}

public void verifyAiUpdateFrequencyWorks() throws IOException {
super.insertJsonToElasticRecordIndex("caf7220a-19e0-4a7f-9af6-eade6c79a47a.json"); // this record is assumed to have a delayed mode with AI enhanced ai:update_frequency field
ResponseEntity<Collections> collections = testRestTemplate.exchange(
getBasePath() + "/collections?filter=(ai_update_frequency='delayed')",
HttpMethod.GET,
null,
new ParameterizedTypeReference<>() {});

assertEquals(1, Objects.requireNonNull(collections.getBody()).getCollections().size(), "hit 1");

collections = testRestTemplate.exchange(
getBasePath() + "/collections?filter=(ai_update_frequency='real-time')",
HttpMethod.GET,
null,
new ParameterizedTypeReference<>() {});


assertEquals(0, Objects.requireNonNull(collections.getBody()).getCollections().size(), "no real-time records found");
assertEquals("caf7220a-19e0-4a7f-9af6-eade6c79a47a", Objects.requireNonNull(collections.getBody()).getCollections().get(0).getId(), "ai:update_frequency exist caf7220a-19e0-4a7f-9af6-eade6c79a47a");
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -375,6 +375,7 @@
"name": ""
},
"update_frequency": null,
"ai:update_frequency": "delayed",
"temporal": [
{
"start": "1991-12-31T13:00:00Z",
Expand Down
Loading