adjustments for discovery

Author: stone-alex

app/src/main/java/elite/intel/ai/brain/handlers/query/AnalyzeCurrentPlanetHandler.java

@@ -1,8 +1,13 @@
 package elite.intel.ai.brain.handlers.query;
 
 import com.google.gson.JsonObject;
+import elite.intel.gameapi.journal.events.dto.BioSampleDto;
 import elite.intel.gameapi.journal.events.dto.LocationDto;
 import elite.intel.session.PlayerSession;
+import elite.intel.util.json.GsonFactory;
+import elite.intel.util.json.ToJsonConvertible;
+
+import java.util.List;
 
 public class AnalyzeCurrentPlanetHandler extends BaseQueryAnalyzer implements QueryHandler {
 
@@ -11,6 +16,13 @@ public class AnalyzeCurrentPlanetHandler extends BaseQueryAnalyzer implements Qu
     @Override public JsonObject handle(String action, JsonObject params, String originalUserInput) throws Exception {
         PlayerSession playerSession = PlayerSession.getInstance();
         LocationDto currentLocation = playerSession.getCurrentLocation();
-        return analyzeData(currentLocation.toJson(), originalUserInput);
+        List<BioSampleDto> bioSamples = playerSession.getBioSamples();
+        return analyzeData(new DataDto(currentLocation,bioSamples).toJson(), originalUserInput);
+    }
+
+    record DataDto(LocationDto location, List<BioSampleDto> bioSamples) implements ToJsonConvertible {
+        @Override public String toJson() {
+            return GsonFactory.getGson().toJson(this);
+        }
     }
 }

app/src/main/java/elite/intel/ai/brain/openai/OpenAiContextFactory.java

@@ -32,7 +32,7 @@ private OpenAiContextFactory() {
         StringBuilder sb = new StringBuilder();
         getSessionValues(sb);
         appendBehavior(sb);
-        sb.append("Instructions: Analyze this input: ").append(sensorInput).append(". prefer shortName for stellar objects ");
+        sb.append("Instructions: Analyze this input: ").append(sensorInput).append(". Use shortName for stellar objects. ");
         return sb.toString();
     }
 
@@ -176,12 +176,13 @@ private String generateSupportedCommandsCause() {
         sb.append("Apply personality: ").append(aiPersonality.name().toUpperCase()).append(" - ").append(aiPersonality.getBehaviorClause()).append(" ");
         sb.append("For star system codes or ship plates (e.g., RH-F), use NATO phonetic alphabet (e.g., Romeo Hotel dash Foxtrot). ");
         sb.append("Spell out numerals in full words (e.g., 285 = two hundred and eighty-five, 27 = twenty-seven). ");
-        sb.append("Gravity units in G, Temperature units Kelvin provide conversion to Celsius. Mass units metric");
+        sb.append("Gravity units in G, Temperature units Kelvin provide conversion to Celsius. Mass units metric. NEVER USE GRAMS!!!!!!!!!!!!!!");
         sb.append("Distances between stars in light years. Distance between planets in light seconds.");
+        sb.append("Bio samples are taken from organisms not stellar objects.");
         sb.append("Round billions to nearest million. ");
         sb.append("Round millions to nearest 250000. ");
         sb.append("Start responses directly with the requested information, avoiding conversational fillers like 'noted,' 'well,' 'right,' 'understood,' or similar phrases. ");
-        sb.append("Do not end your response with a question.");
+        sb.append("Do not end responses with any fillers, conversational closers, or unnecessary phrases like 'Ready for exploration', 'Ready for orders', 'All set', 'Ready to explore', or similar open-ended questions or remarks.");
         if (personality.equals(AIPersonality.UNHINGED) || personality.equals(AIPersonality.FRIENDLY)) {
             sb.append("For UNHINGED personality, use playful slang matching cadence.");
         }

app/src/main/java/elite/intel/ai/ears/google/GoogleSTTImpl.java

@@ -194,7 +194,7 @@ public void stop() {
      */
     @SuppressWarnings("deprecation") private void startStreaming() { // v2 is not an option as it is for SAAS v1 uses bidiStreamingCall and there is no upgrade
         int retryCount = 0;
-        int maxRetries = 5; // Cap to prevent infinite loops
+        int maxRetries = 15; // Cap to prevent infinite loops
         StringBuffer currentTranscript = new StringBuffer();
         List<Float> confidences = Collections.synchronizedList(new ArrayList<>());
         while (isListening.get()) {
@@ -225,7 +225,8 @@ public void onNext(StreamingRecognizeResponse response) {
 
                             @Override
                             public void onError(Throwable t) {
-                                log.error("STT error: {}", t.getMessage(), t);
+                                log.warn("STT error: {}", t.getMessage());
+                                throw new RuntimeException("retry");
                             }
 
                             @Override
@@ -319,7 +320,7 @@ public void onCompleted() {
                                         if (isStreamingModeOn) {
                                             String voiceName = SystemSession.getInstance().getAIVoice().getName();
                                             if (sanitizedTranscript.toLowerCase().startsWith("computer") || sanitizedTranscript.toLowerCase().startsWith(voiceName.toLowerCase())) {
-                                                sendToAi(sanitizedTranscript.replace("computer,", "").replace(voiceName.toLowerCase() + ",", ""), avgConfidence);
+                                                sendToAi(sanitizedTranscript.replace("computer,", "").replace(voiceName.toLowerCase() + ",", ""), 100);
                                             }
                                         } else {
                                             sendToAi(sanitizedTranscript, avgConfidence);

app/src/main/java/elite/intel/ai/mouth/google/GoogleTTSImpl.java

@@ -189,7 +189,7 @@ private void speak(String text, AiVoices aiVoice) {
             log.debug("Added VoiceRequest to queue: text='{}', voice='{}'", text, aiVoice.getName());
         } catch (InterruptedException e) {
             Thread.currentThread().interrupt();
-            log.error("Interrupted while adding voice request to queue", e);
+            log.warn("Interrupted while adding voice request to queue");
         }
     }
 
@@ -289,7 +289,6 @@ private void processVoiceRequest(String text, String voiceName, double speechRat
             AudioConfig config = AudioConfig.newBuilder()
                     .setAudioEncoding(AudioEncoding.LINEAR16)
                     .setSpeakingRate(speechRate)
-                    .setVolumeGainDb(-3)
                     .build();
             SynthesizeSpeechResponse response = textToSpeechClient.synthesizeSpeech(input, voice, config);
             long apiEndTime = System.currentTimeMillis();

app/src/main/java/elite/intel/gameapi/JournalParser.java

@@ -76,7 +76,7 @@ public synchronized void stop() {
             processingThread.join(5000); // Wait up to 5 seconds for clean shutdown
             log.info("JournalParser stopped");
         } catch (InterruptedException e) {
-            log.error("Interrupted while waiting for JournalParser to stop", e);
+            log.warn("Interrupted while waiting for JournalParser to stop");
             Thread.currentThread().interrupt(); // Restore interrupted status
         }
         processingThread = null;