twitch integration still does not work

Author: RhythmicSys

TTSJava/pom.xml

@@ -62,6 +62,11 @@
             <artifactId>config</artifactId>
             <version>1.4.3</version>
         </dependency>
+        <dependency>
+            <groupId>com.github.twitch4j</groupId>
+            <artifactId>twitch4j</artifactId>
+            <version>1.20.0</version>
+        </dependency>
 
     </dependencies>
 

TTSJava/src/main/java/simplexity/clitts/SpeechHandling.java

@@ -17,13 +17,13 @@
 
 public class SpeechHandling {
 
-    static Region AWS_REGION;
+    static Region awsRegion;
     static AmazonPolly polly;
-    static VoiceId VOICE_ID;
+    static VoiceId voiceId;
 
     private SpeechHandling() {
         polly = new AmazonPollyClient(new BasicAWSCredentials(TTSConfig.getInstance().getAccessID(), TTSConfig.getInstance().getAccessSecret()), new ClientConfiguration());
-        polly.setRegion(AWS_REGION);
+        polly.setRegion(awsRegion);
     }
 
     private static SpeechHandling instance;
@@ -34,15 +34,14 @@ public static SpeechHandling getInstance() {
     }
 
     public void processSpeech(String text) {
-        TextToSpeech tts = TextToSpeech.getInstance();
         String newText = replaceText(text);
         boolean useSSML = !text.equals(newText);
         try {
             InputStream speechStream;
             if (!useSSML) {
-                speechStream = synthesizeSpeech(polly, newText, VOICE_ID);
+                speechStream = synthesizeSpeech(polly, newText, voiceId);
             } else {
-                speechStream = synthesizeSSMLSpeech(polly, newText, VOICE_ID);
+                speechStream = synthesizeSSMLSpeech(polly, newText, voiceId);
             }
             if (speechStream == null) {
                 System.out.println(Colors.boldRed + "Error: Speech stream is null." + Colors.formatReset);
@@ -63,7 +62,7 @@ public String replaceText(String text) {
         for (String key : TTSConfig.getInstance().getVoicePrefixes().keySet()) {
             if (text.startsWith(key)) {
                 text = text.replace(key, "");
-                SpeechHandling.VOICE_ID = TTSConfig.getInstance().getVoicePrefixes().get(key);
+                SpeechHandling.voiceId = TTSConfig.getInstance().getVoicePrefixes().get(key);
             }
         }
         return text;

TTSJava/src/main/java/simplexity/clitts/TTSConfig.java

@@ -5,6 +5,7 @@
 import com.amazonaws.services.polly.model.VoiceId;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
+import com.typesafe.config.ConfigRenderOptions;
 import com.typesafe.config.ConfigValue;
 import com.typesafe.config.ConfigValueFactory;
 
@@ -20,6 +21,7 @@ public class TTSConfig {
     private Region AWS_REGION;
     private VoiceId defaultVoice;
     private boolean useTwitch = false;
+    private Config config;
     private String accessID, accessSecret, twitchChannel, twitchAuthCode;
 
     private TTSConfig() {
@@ -33,7 +35,7 @@ public static TTSConfig getInstance() {
     }
 
     public void reloadConfig() {
-        Config config = loadConfig();
+        config = loadConfig();
         reloadReplaceText(config);
         reloadVoicePrefixes(config);
         reloadRegion(config);
@@ -157,6 +159,17 @@ private void reloadTwitchChannel(Config config) {
         }
     }
 
+    public void updateConfigValue(String key, String value) {
+        config = config.withValue(key, ConfigFactory.parseString(key +  "=\"" + value + "\"").root());
+        try (FileWriter writer = new FileWriter("application.conf")) {
+            writer.write(config.root().render(ConfigRenderOptions.defaults()));
+        }
+        catch (IOException e) {
+            System.out.println("Error updating config file.");
+            e.printStackTrace();
+        }
+    }
+
     public String getTwitchChannel() {
         return twitchChannel;
     }
@@ -199,6 +212,4 @@ public void setTwitchAuthCode(String authCode) {
         ConfigValue twitchCode = ConfigValueFactory.fromAnyRef(authCode);
         config.withValue("twitch-auth-code", twitchCode);
     }
-
-
 }

TTSJava/src/main/java/simplexity/clitts/TextToSpeech.java

@@ -1,6 +1,7 @@
 package simplexity.clitts;
 
 import simplexity.clitts.twitch.TwitchAuthServer;
+import simplexity.clitts.twitch.TwitchMessaging;
 import simplexity.clitts.util.Messages;
 
 import java.io.IOException;
@@ -23,8 +24,8 @@ public static TextToSpeech getInstance() {
     public static void main(String[] args) {
         TTSConfig.getInstance().reloadConfig();
         System.out.println(Messages.startupMessage);
-        SpeechHandling.VOICE_ID = TTSConfig.getInstance().getDefaultVoice();
-        SpeechHandling.AWS_REGION = TTSConfig.getInstance().getRegion();
+        SpeechHandling.voiceId = TTSConfig.getInstance().getDefaultVoice();
+        SpeechHandling.awsRegion = TTSConfig.getInstance().getRegion();
         checkTwitch();
         while (runProgram) {
             System.out.println(Messages.enterText);
@@ -37,6 +38,7 @@ public static void main(String[] args) {
                 case ("--help") -> System.out.println(Messages.helpMessage);
                 case ("--reload") -> {
                     TTSConfig.getInstance().reloadConfig();
+                    checkTwitch();
                     System.out.println(Messages.reloadMessage);
                 }
                 default -> {
@@ -66,15 +68,15 @@ private static void checkTwitch() {
                     case ("y") -> {
                         validInput = true;
                         checkTwitchAuth();
-
                     }
                     case ("n") -> {
                         validInput = true;
                     }
                     default -> System.out.println(Messages.stayConnectedError);
                 }
-
             }
+            if (TTSConfig.getInstance().getTwitchAuthCode() == null) return;
+            TwitchMessaging.getInstance().setupTwitch(TTSConfig.getInstance().getTwitchAuthCode());
         }
     }
 

TTSJava/src/main/java/simplexity/clitts/twitch/TwitchAuthServer.java

@@ -28,8 +28,8 @@ static class AuthHandler implements HttpHandler {
         public void handle(HttpExchange t) throws IOException {
             String twitchCode = t.getRequestURI().getQuery().split("=")[1];
             twitchCode = twitchCode.split("&")[0];
-            TTSConfig.getInstance().setTwitchAuthCode(twitchCode);
-            
+            TTSConfig.getInstance().updateConfigValue("twitch-o-auth-code", twitchCode);
+            TTSConfig.getInstance().reloadConfig();
             // Respond to the client
             String response = "Twitch authentication successful!";
             t.sendResponseHeaders(200, response.length());

TTSJava/src/main/java/simplexity/clitts/twitch/TwitchMessaging.java

@@ -0,0 +1,28 @@
+package simplexity.clitts.twitch;
+
+import com.github.philippheuer.credentialmanager.domain.OAuth2Credential;
+import com.github.twitch4j.TwitchClient;
+import com.github.twitch4j.TwitchClientBuilder;
+import simplexity.clitts.TTSConfig;
+
+public class TwitchMessaging {
+    private TwitchMessaging(){}
+    private static TwitchMessaging instance;
+    public static TwitchMessaging getInstance(){
+        if(instance == null) instance = new TwitchMessaging();
+        return instance;
+    }
+    OAuth2Credential credential;
+    TwitchClient twitchClient;
+
+    public void setupTwitch(String authorization){
+        credential = new OAuth2Credential("twitch", authorization);
+        twitchClient = TwitchClientBuilder.builder()
+                .withChatAccount(credential)
+                .withEnableChat(true)
+                .build();
+        twitchClient.getChat().joinChannel(TTSConfig.getInstance().getTwitchChannel());
+        twitchClient.getChat().sendMessage(TTSConfig.getInstance().getTwitchChannel(), "Hello world!");
+    }
+
+}