WIP: PLEASE DO NOT MERGE.

gsrs-controlled-vocabulary/src/main/java/gsrs/cv/ControlledVocabularyEntityServiceImpl.java

@@ -10,7 +10,9 @@
 import gsrs.events.AbstractEntityUpdatedEvent;
 import gsrs.repository.ControlledVocabularyRepository;
 import gsrs.service.AbstractGsrsEntityService;
+import ix.core.util.EntityUtils.Key;
 import ix.ginas.models.v1.ControlledVocabulary;
+
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Scope;
 import org.springframework.context.annotation.ScopedProxyMode;
@@ -22,6 +24,8 @@
 import java.io.IOException;
 import java.util.List;
 import java.util.Optional;
+import java.util.UUID;
+import java.util.stream.Collectors;
 @Scope(proxyMode = ScopedProxyMode.INTERFACES)
 @Service
 public class ControlledVocabularyEntityServiceImpl extends AbstractGsrsEntityService<ControlledVocabulary, Long> implements ControlledVocabularyEntityService {
@@ -154,6 +158,11 @@ protected Optional<Long> flexLookupIdOnly(String someKindOfId) {
         return Optional.empty();
     }
 
+	@Override
+	public List<Long> getIDs() {
+		return repository.getAllIDs();
+	}
+
 
 //    private SearchResult<ControlledVocabulary> parseQueryIntoMatch(String query, SearchSession session) {
 //        Pattern pattern = Pattern.compile("(\\S+):(\\S+)");
@@ -247,6 +256,11 @@ protected Optional<Long> flexLookupIdOnly(String someKindOfId) {
 
 //    }
 
-
+    @Override
+	public List<Key> getKeys() {
+		List<Long> IDs = repository.getAllIds();
+		List<Key> keys = IDs.stream().map(id->Key.ofStringId(ControlledVocabulary.class, Long.toString(id))).collect(Collectors.toList());
+		return keys;
+	}
 
 }

gsrs-controlled-vocabulary/src/main/java/gsrs/repository/ControlledVocabularyRepository.java

@@ -7,6 +7,7 @@
 import org.springframework.stereotype.Repository;
 
 import java.util.List;
+import java.util.UUID;
 @Repository
 public interface ControlledVocabularyRepository extends GsrsVersionedRepository<ControlledVocabulary, Long> {
 
@@ -17,6 +18,9 @@ public interface ControlledVocabularyRepository extends GsrsVersionedRepository<
     List<ControlledVocabulary> findByDomain(String domain);
     @Query(value = "select * from ControlledVocabulary  where id=:id", nativeQuery = true)
     List<ControlledVocabulary> foo(String id);
+
+    @Query("select cv.id from ControlledVocabulary cv")
+    List<Long> getAllIds();
 
     /**
      * Summary of a ControlledVocabulary with only a few fields.
@@ -26,4 +30,8 @@ interface ControlledVocabularySummary {
 
         String getDomain();
     }
+
+    @Query("select cv.id from ControlledVocabulary cv")
+    List<Long> getAllIDs();
+
 }

gsrs-core-entities/src/main/java/gsrs/events/ReindexEntityEvent.java

@@ -14,18 +14,23 @@ public class ReindexEntityEvent implements ReindexEvent {
 
 	private UUID reindexId;
 	private EntityUtils.Key entityKey;
-	private boolean requiresDelete=false;
+	private boolean requiresDelete = false;
+	private boolean excludeExternal = false;	
 	private Optional<EntityWrapper<?>> optionalEntityWrapper = Optional.empty();
 
-
-	public ReindexEntityEvent(UUID reindexId, EntityUtils.Key entityKey, Optional<EntityWrapper<?>> of, boolean b) {
+	public ReindexEntityEvent(UUID reindexId, EntityUtils.Key entityKey, Optional<EntityWrapper<?>> of, boolean requiresDelete, boolean excludeExternal) {
 		this.reindexId=reindexId;
 		this.entityKey=entityKey;
 		this.optionalEntityWrapper=of;
-		this.requiresDelete=b;
+		this.requiresDelete=requiresDelete;
+		this.excludeExternal=excludeExternal;
+	}
+
+	public ReindexEntityEvent(UUID reindexId, EntityUtils.Key entityKey, Optional<EntityWrapper<?>> of, boolean b) {
+		this(reindexId,entityKey,of,b,false);
 	}
 	public ReindexEntityEvent(UUID reindexId, EntityUtils.Key entityKey, Optional<EntityWrapper<?>> of) {
-		this(reindexId,entityKey,of,false);
+		this(reindexId,entityKey,of,false,false);
 	}
 
 

gsrs-core-entities/src/main/java/gsrs/indexer/IndexerEntityListener.java

@@ -57,13 +57,17 @@ public void updateEntity(Object obj) {
     }
 
     public void reindexEntity(Object obj, boolean deleteFirst) {
+    	reindexEntity(obj, deleteFirst, false);
+    }
+
+    public void reindexEntity(Object obj, boolean deleteFirst, boolean excludeExternal) {
         autowireIfNeeded();
         EntityUtils.EntityWrapper ew = EntityUtils.EntityWrapper.of(obj);
         if(ew.shouldIndex()) {
             IndexerEventFactory indexerFactoryFor = indexerEventFactoryFactory.getIndexerFactoryFor(obj);
             if(indexerFactoryFor !=null) {
 //            	log.error("ew before publishing event :" + ew.toString());
-                applicationEventPublisher.publishEvent(indexerFactoryFor.newReindexEventFor(ew,deleteFirst));
+                applicationEventPublisher.publishEvent(indexerFactoryFor.newReindexEventFor(ew,deleteFirst,excludeExternal));
 
             }
         }

gsrs-core-entities/src/main/java/gsrs/indexer/IndexerEventFactory.java

@@ -53,6 +53,10 @@ default Object newReindexEventFor(EntityUtils.EntityWrapper ew, boolean deleteFi
         return new ReindexEntityEvent(UUID.randomUUID(), ew.getKey() ,Optional.of(ew),deleteFirst);
     }
 
+    default Object newReindexEventFor(EntityUtils.EntityWrapper ew, boolean deleteFirst, boolean excludeExternal){
+        return new ReindexEntityEvent(UUID.randomUUID(), ew.getKey() ,Optional.of(ew),deleteFirst,excludeExternal);
+    }
+
     /**
      * Create a new UpdateIndexEvent object for the given wrapped Entity.
      * The returned Object will be published to the {@link org.springframework.context.ApplicationEventPublisher}.

gsrs-core-entities/src/main/java/gsrs/repository/EditRepository.java

@@ -7,6 +7,7 @@
 import java.util.UUID;
 import java.util.stream.Collectors;
 
+import org.springframework.data.jpa.repository.Query;
 import org.springframework.stereotype.Repository;
 
 import ix.core.models.Edit;
@@ -23,6 +24,9 @@ public interface EditRepository extends GsrsRepository<Edit, UUID> {
 
     List<Edit> findByRefidAndVersion(String refId, String version);
 
+    @Query("select e.id from Edit e")
+    List<UUID> getAllIDs();
+
     default Optional<Edit> findFirstByRefidOrderByCreatedDescAndKinds(String refId, Set<String> kinds){
         return findByRefidOrderByCreatedDesc(refId)
                 .stream()

gsrs-core-entities/src/main/java/gsrs/repository/NamespaceRepository.java

@@ -2,9 +2,16 @@
 
 import ix.core.models.Namespace;
 import ix.core.models.Principal;
+
+import java.util.List;
+
+import org.springframework.data.jpa.repository.Query;
 import org.springframework.stereotype.Repository;
 
 @Repository
 public interface NamespaceRepository extends GsrsRepository<Namespace, Long> {
     Namespace findByName(String name);
+
+    @Query("select ns.id from Namespace ns")
+    List<Long> getAllIDs();
 }

gsrs-data-exchange/src/main/java/gsrs/dataexchange/services/ImportMetadataReindexer.java

@@ -237,7 +237,7 @@ public void incrementReindexEvent(IncrementReindexEvent event){
     public static void indexOneItem(UUID reindexId, Consumer<Object> eventConsumer, EntityUtils.Key key,
                                     EntityUtils.EntityWrapper<ImportMetadata> wrappedEntity) {
         log.trace("indexOneItem will process reindex of key {}",  key);
-        ReindexEntityEvent event = new ReindexEntityEvent(reindexId, key, Optional.of(wrappedEntity), true);
+        ReindexEntityEvent event = new ReindexEntityEvent(reindexId, key, Optional.of(wrappedEntity), false);
         eventConsumer.accept(event);
         log.trace("submitted index event");
     }

gsrs-spring-boot-autoconfigure/src/main/java/gsrs/controller/AbstractGsrsEntityController.java

@@ -14,6 +14,7 @@
 import java.util.function.BiFunction;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
+import java.util.stream.Collectors;
 
 import javax.servlet.http.HttpServletRequest;
 
@@ -400,6 +401,16 @@ public long getCount(){
         return getEntityService().count();
     }
 
+    @Override
+    @GetGsrsRestApiMapping("/@keys")
+    public List<Key> getKeys(){    	
+    	List<I> IDs = getEntityService().getIDs();
+//    	System.out.println("GET IDS!");
+//    	IDs.forEach(id -> System.out.println("ID " + id.toString()));
+    	List<Key> keys = IDs.stream().map(id->Key.ofStringId(getEntityService().getEntityClass(), id.toString())).collect(Collectors.toList());
+        return keys;
+    }
+
     @Override
     @GetGsrsRestApiMapping("")
     @Transactional(readOnly = true)