Add llm vector store (#106)

* Initial setup of vector store for classification, with fallback to the LLM.
* Rework the LLM system a bit, to use structured outputs and more advanced prompts.
* Add coverage to the PR.
* Fix issues with the PSQL boot scripts camunda.
* Add support for storing the vectors in PSQL for classifications.
* Create proper hook for the vector store to catch newly created transactions.

Author: gjong

bpmn-process/src/main/java/com/jongsoft/finance/bpmn/listeners/StartProcessListener.java

@@ -1,8 +1,8 @@
 package com.jongsoft.finance.bpmn.listeners;
 
-import com.jongsoft.finance.bpmn.InternalAuthenticationEvent;
 import com.jongsoft.finance.core.JavaBean;
 import com.jongsoft.finance.domain.user.UserIdentifier;
+import com.jongsoft.finance.messaging.InternalAuthenticationEvent;
 import com.jongsoft.finance.security.AuthenticationFacade;
 import io.micronaut.context.event.ApplicationEventPublisher;
 import jakarta.inject.Singleton;

fintrack-api/src/main/java/com/jongsoft/finance/security/Encryption.java renamed to core/src/main/java/com/jongsoft/finance/security/Encryption.java

@@ -1,4 +1,4 @@
-package com.jongsoft.finance.bpmn;
+package com.jongsoft.finance.messaging;
 
 import io.micronaut.context.event.ApplicationEvent;
 

bpmn-process/src/main/java/com/jongsoft/finance/bpmn/InternalAuthenticationEvent.java renamed to domain/src/main/java/com/jongsoft/finance/messaging/InternalAuthenticationEvent.java

@@ -0,0 +1,11 @@
+package com.jongsoft.finance.messaging.notifications;
+
+import com.jongsoft.finance.messaging.ApplicationEvent;
+
+public record TransactionCreated(long transactionId) implements ApplicationEvent {
+
+    public static void transactionCreated(long transactionId) {
+        new TransactionCreated(transactionId)
+                .publish();
+    }
+}

domain/src/main/java/com/jongsoft/finance/messaging/notifications/TransactionCreated.java

@@ -8,6 +8,8 @@
 
 public interface UserProvider extends DataProvider<UserAccount> {
 
+    Sequence<UserAccount> lookup();
+
     boolean available(UserIdentifier username);
 
     Optional<UserAccount> lookup(UserIdentifier username);

domain/src/main/java/com/jongsoft/finance/providers/UserProvider.java

@@ -1,6 +1,6 @@
 package com.jongsoft.finance.filter;
 
-import com.jongsoft.finance.bpmn.InternalAuthenticationEvent;
+import com.jongsoft.finance.messaging.InternalAuthenticationEvent;
 import com.jongsoft.lang.Control;
 import io.micronaut.context.event.ApplicationEventPublisher;
 import io.micronaut.core.async.publisher.Publishers;

fintrack-api/src/main/java/com/jongsoft/finance/filter/AuthenticationFilter.java

@@ -1,11 +1,11 @@
 package com.jongsoft.finance.rest.transaction;
 
-import com.jongsoft.finance.bpmn.InternalAuthenticationEvent;
 import com.jongsoft.finance.core.exception.StatusException;
 import com.jongsoft.finance.domain.core.EntityRef;
 import com.jongsoft.finance.domain.transaction.Transaction;
 import com.jongsoft.finance.factory.FilterFactory;
 import com.jongsoft.finance.messaging.EventBus;
+import com.jongsoft.finance.messaging.InternalAuthenticationEvent;
 import com.jongsoft.finance.providers.AccountProvider;
 import com.jongsoft.finance.providers.AccountTypeProvider;
 import com.jongsoft.finance.providers.TransactionProvider;

fintrack-api/src/main/java/com/jongsoft/finance/rest/transaction/TransactionResource.java

@@ -1,6 +1,6 @@
 package com.jongsoft.finance.security;
 
-import com.jongsoft.finance.bpmn.InternalAuthenticationEvent;
+import com.jongsoft.finance.messaging.InternalAuthenticationEvent;
 import io.micronaut.runtime.event.annotation.EventListener;
 import io.micronaut.security.authentication.Authentication;
 import io.micronaut.security.event.LoginSuccessfulEvent;

fintrack-api/src/main/java/com/jongsoft/finance/security/AuthenticationFacadeImpl.java

@@ -2,6 +2,6 @@
 
 import io.micronaut.context.annotation.Requires;
 
-@Requires(env = {"h2", "mysql", "demo"})
+@Requires(env = {"h2", "mysql", "demo", "psql"})
 public @interface RequiresJpa {
 }

jpa-repository/src/main/java/com/jongsoft/finance/RequiresJpa.java

@@ -15,6 +15,7 @@
 import com.jongsoft.finance.messaging.CommandHandler;
 import com.jongsoft.finance.messaging.commands.transaction.CreateTransactionCommand;
 import com.jongsoft.finance.messaging.handlers.TransactionCreationHandler;
+import com.jongsoft.finance.messaging.notifications.TransactionCreated;
 import com.jongsoft.finance.security.AuthenticationFacade;
 import com.jongsoft.lang.Control;
 import com.jongsoft.lang.collection.Sequence;
@@ -97,6 +98,7 @@ public long handleCreatedEvent(CreateTransactionCommand command) {
             entityManager.persist(transferJpa);
         }
 
+        TransactionCreated.transactionCreated(jpaEntity.getId());
         return jpaEntity.getId();
     }