tweaking demo

Author: slorello89

Diff for: samples/bluesky-sentiment-analysis/api/bsky-sentiment-api/src/main/java/com/redis/bskysentimentapi/Bootstrap.java

@@ -43,7 +43,7 @@ public void run(String... args) throws Exception {
         };
 
         jedis.sadd(Constants.HASHTAGS_TO_QUERY, hashtags);
-        jedis.sadd(Constants.KEYWORDS_TO_QUERY, "us", "politics", "election", "apple", "tesla", "ai", "history", "pop", "rock", "jazz", "boeing");
+        jedis.sadd(Constants.KEYWORDS_TO_QUERY, "us", "apple", "tesla", "ai", "history", "pop", "rock", "jazz", "boeing", "aws", "google", "azure", "travel", "science","technology", "databases", "WWE", "France", "UK");
 
     }
 }

Diff for: samples/bluesky-sentiment-analysis/api/bsky-sentiment-api/src/main/java/com/redis/bskysentimentapi/services/SentimentService.java

@@ -34,7 +34,7 @@ public double getSentimentForHashTag(String tag) {
 
     public Optional<Double> getSentimentForKeyWord(String keyword) {
         long now = Instant.now().getEpochSecond() * 1000;
-        AggregationBuilder builder = new AggregationBuilder(String.format("@text:%s @createdAt:[%d %d]", keyword, now - 10000, now));
+        AggregationBuilder builder = new AggregationBuilder(String.format("@text:%s @createdAt:[-inf %d]", keyword, now));
         Group group = new Group();
         group.reduce(Reducers.avg("@sentiment").as("sentiment"));
         builder.groupBy(group);
@@ -51,7 +51,7 @@ public Map<String, Double> getSentimentForKeyWords(Set<String> keyWords){
         }
         String queryString = String.join("|", keyWords);
         long now = Instant.now().getEpochSecond() * 1000;
-        AggregationBuilder builder = new AggregationBuilder(String.format("@text:%s @createdAt:[%d %d]", queryString, now - 10000, now));
+        AggregationBuilder builder = new AggregationBuilder(String.format("@text:%s @createdAt:[-inf %d]", queryString, now));
         Group group = new Group("@text");
         group.reduce(Reducers.avg("@sentiment").as("sentiment"));
         builder.groupBy(group);

Diff for: samples/bluesky-sentiment-analysis/consumer/consumer/src/main/java/com/redis/Main.java

@@ -35,7 +35,7 @@ public static boolean containsNonAscii(String str) {
 
     public void run() throws IOException, InterruptedException {
         Properties props = new Properties();
-        props.setProperty("annotators", "tokenize,ssplit,pos,lemma,parse,sentiment");
+        props.setProperty("annotators", "tokenize,ssplit,parse,sentiment");
         StanfordCoreNLP pipeline = new StanfordCoreNLP(props);
         String redisHost = System.getenv("REDIS_HOST") != null ? System.getenv("REDIS_HOST") : "localhost";
         System.out.println("Connecting to Redis at " + redisHost);