1680 - updated ape/terms api. Added updated_at field and start/end date query params

odd-platform-api/src/main/java/org/opendatadiscovery/oddplatform/controller/TermController.java

@@ -1,5 +1,6 @@
 package org.opendatadiscovery.oddplatform.controller;
 
+import java.time.LocalDate;
 import java.util.UUID;
 import lombok.RequiredArgsConstructor;
 import org.opendatadiscovery.oddplatform.api.contract.api.TermApi;
@@ -50,8 +51,10 @@ public class TermController implements TermApi {
     @Override
     public Mono<ResponseEntity<TermRefList>> getTermsList(final Integer page, final Integer size,
                                                           final String query,
+                                                          final LocalDate updatedAtRangeStartDateTime,
+                                                          final LocalDate updatedAtRangeEndDateTime,
                                                           final ServerWebExchange exchange) {
-        return termService.getTerms(page, size, query)
+        return termService.getTerms(page, size, query, updatedAtRangeStartDateTime, updatedAtRangeEndDateTime)
             .map(ResponseEntity::ok);
     }
 

odd-platform-api/src/main/java/org/opendatadiscovery/oddplatform/repository/reactive/ReactiveTermRepository.java

@@ -1,5 +1,6 @@
 package org.opendatadiscovery.oddplatform.repository.reactive;
 
+import java.time.LocalDate;
 import java.util.List;
 import org.opendatadiscovery.oddplatform.dto.FacetStateDto;
 import org.opendatadiscovery.oddplatform.dto.term.LinkedTermDto;
@@ -14,7 +15,9 @@
 
 public interface ReactiveTermRepository extends ReactiveCRUDRepository<TermPojo> {
 
-    Mono<Page<TermRefDto>> listTermRefDtos(final int page, final int size, final String query);
+    Mono<Page<TermRefDto>> listTermRefDtos(final int page, final int size, final String query,
+                                           final LocalDate updatedAtRangeStartDateTime,
+                                           final LocalDate updatedAtRangeEndDateTime);
 
     Mono<Boolean> existsByNamespace(final Long namespaceId);
 

odd-platform-api/src/main/java/org/opendatadiscovery/oddplatform/repository/reactive/ReactiveTermRepositoryImpl.java

@@ -1,13 +1,16 @@
 package org.opendatadiscovery.oddplatform.repository.reactive;
 
+import java.time.LocalDate;
 import java.util.ArrayList;
 import java.util.Arrays;
+import java.util.Collections;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 import org.apache.commons.collections4.CollectionUtils;
+import org.apache.commons.collections4.ListUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.jooq.Condition;
 import org.jooq.Field;
@@ -102,9 +105,12 @@ public ReactiveTermRepositoryImpl(final JooqReactiveOperations jooqReactiveOpera
     }
 
     @Override
-    public Mono<Page<TermRefDto>> listTermRefDtos(final int page, final int size, final String nameQuery) {
+    public Mono<Page<TermRefDto>> listTermRefDtos(final int page, final int size, final String nameQuery,
+                                                  final LocalDate updatedAtRangeStartDateTime,
+                                                  final LocalDate updatedAtRangeEndDateTime) {
         final Select<TermRecord> homogeneousQuery = DSL.selectFrom(TERM)
-            .where(listCondition(nameQuery));
+            .where(ListUtils.union(listCondition(nameQuery),
+                dateConditions(updatedAtRangeStartDateTime, updatedAtRangeEndDateTime)));
 
         final Select<? extends Record> termSelect =
             paginate(homogeneousQuery, List.of(new OrderByField(TERM.ID, SortOrder.ASC)), (page - 1) * size, size);
@@ -627,4 +633,23 @@ private List<LinkedTermDto> extractTerms(final Record record) {
             })
             .toList();
     }
+
+    private List<Condition> dateConditions(final LocalDate updatedAtRangeStartDateTime,
+                                           final LocalDate updatedAtRangeEndDateTime) {
+        if (updatedAtRangeStartDateTime == null && updatedAtRangeEndDateTime == null) {
+            return Collections.emptyList();
+        }
+
+        final List<Condition> conditions = new ArrayList<>();
+
+        if (updatedAtRangeStartDateTime != null) {
+            conditions.add(TERM.UPDATED_AT.greaterOrEqual(updatedAtRangeStartDateTime.atStartOfDay()));
+        }
+
+        if (updatedAtRangeEndDateTime != null) {
+            conditions.add(TERM.UPDATED_AT.lessThan(updatedAtRangeEndDateTime.atStartOfDay()));
+        }
+
+        return conditions;
+    }
 }

odd-platform-api/src/main/java/org/opendatadiscovery/oddplatform/service/term/TermService.java

@@ -1,5 +1,6 @@
 package org.opendatadiscovery.oddplatform.service.term;
 
+import java.time.LocalDate;
 import java.util.List;
 import org.opendatadiscovery.oddplatform.api.contract.model.LinkedTerm;
 import org.opendatadiscovery.oddplatform.api.contract.model.LinkedTermList;
@@ -14,7 +15,8 @@
 import reactor.core.publisher.Mono;
 
 public interface TermService {
-    Mono<TermRefList> getTerms(final Integer page, final Integer size, final String query);
+    Mono<TermRefList> getTerms(final Integer page, final Integer size, final String query,
+                               final LocalDate updatedAtRangeStartDateTime, final LocalDate updatedAtRangeEndDateTime);
 
     Mono<TermRef> getTermByNamespaceAndName(final String namespaceName, final String name);
 

odd-platform-api/src/main/java/org/opendatadiscovery/oddplatform/service/term/TermServiceImpl.java

@@ -1,5 +1,6 @@
 package org.opendatadiscovery.oddplatform.service.term;
 
+import java.time.LocalDate;
 import java.util.ArrayList;
 import java.util.HashSet;
 import java.util.List;
@@ -80,8 +81,10 @@ public class TermServiceImpl implements TermService {
     private final TagMapper tagMapper;
 
     @Override
-    public Mono<TermRefList> getTerms(final Integer page, final Integer size, final String query) {
-        return termRepository.listTermRefDtos(page, size, query)
+    public Mono<TermRefList> getTerms(final Integer page, final Integer size, final String query,
+                                      final LocalDate updatedAtRangeStartDateTime,
+                                      final LocalDate updatedAtRangeEndDateTime) {
+        return termRepository.listTermRefDtos(page, size, query, updatedAtRangeStartDateTime, updatedAtRangeEndDateTime)
             .map(termMapper::mapToRefPage);
     }
 

odd-platform-specification/components.yaml

@@ -2558,6 +2558,9 @@ components:
           type: string
         definition:
           type: string
+        updated_at:
+          type: string
+          format: date-time
         namespace:
           $ref: '#/components/schemas/Namespace'
       required:

odd-platform-specification/openapi.yaml

@@ -2725,6 +2725,18 @@ paths:
         - $ref: './components.yaml/#/components/parameters/PageParam'
         - $ref: './components.yaml/#/components/parameters/SizeParam'
         - $ref: './components.yaml/#/components/parameters/SearchParam'
+        - name: updated_at_range_start_date_time
+          in: query
+          required: false
+          schema:
+            type: string
+            format: date
+        - name: updated_at_range_end_date_time
+          in: query
+          required: false
+          schema:
+            type: string
+            format: date
       responses:
         '200':
           description: OK