added source display and trust ratings

Author: G-Wang12

cpp_engine/src/IMarketDataSource.hpp

@@ -3,10 +3,19 @@
 #include <optional>
 #include <string>
 
+// A single news item: the headline text plus the publisher it came from
+// (e.g. "Reuters", "PRNewswire"). `source` may be empty when the upstream feed
+// omits it; downstream treats an empty/unknown source as low trust.
+struct Headline
+{
+    std::string text;
+    std::string source;
+};
+
 class IMarketDataSource
 {
 public:
     virtual ~IMarketDataSource() = default;
 
-    virtual std::optional<std::string> nextHeadline() = 0;
+    virtual std::optional<Headline> nextHeadline() = 0;
 };

cpp_engine/src/LiveRestDataSource.hpp

@@ -40,13 +40,13 @@ class LiveRestDataSource : public IMarketDataSource
     LiveRestDataSource(const LiveRestDataSource &) = delete;
     LiveRestDataSource &operator=(const LiveRestDataSource &) = delete;
 
-    std::optional<std::string> nextHeadline() override
+    std::optional<Headline> nextHeadline() override
     {
         std::lock_guard<std::mutex> lock(mutex_);
         if (headlines_.empty())
             return std::nullopt;
 
-        std::string headline = std::move(headlines_.front());
+        Headline headline = std::move(headlines_.front());
         headlines_.pop();
         return headline;
     }
@@ -102,8 +102,15 @@ class LiveRestDataSource : public IMarketDataSource
             if (!seenIds_.insert(id).second)
                 continue;
 
+            // Finnhub returns the publisher in "source"; keep it for trust
+            // scoring downstream. Leave empty when absent (treated as unknown).
+            std::string source;
+            const auto sourceIt = item.find("source");
+            if (sourceIt != item.end() && sourceIt->is_string())
+                source = sourceIt->get<std::string>();
+
             std::lock_guard<std::mutex> lock(mutex_);
-            headlines_.push(headlineIt->get<std::string>());
+            headlines_.push(Headline{headlineIt->get<std::string>(), std::move(source)});
         }
     }
 
@@ -122,7 +129,7 @@ class LiveRestDataSource : public IMarketDataSource
     std::string apiKey_;
     std::atomic<bool> running_;
     std::mutex mutex_;
-    std::queue<std::string> headlines_;
+    std::queue<Headline> headlines_;
     std::unordered_set<int> seenIds_;
     std::thread worker_;
 };

cpp_engine/src/SimulatedDataSource.hpp

@@ -6,44 +6,49 @@
 #include <cstddef>
 #include <optional>
 #include <string>
+#include <utility>
 #include <vector>
 
 class SimulatedDataSource : public IMarketDataSource
 {
 public:
+    // Each mock headline is paired with a synthetic publisher spanning trust
+    // tiers (wire services / major outlets / PR wires / no-name blogs) so the
+    // source-trust labeling and filtering are exercised end-to-end without a
+    // live Finnhub key.
     SimulatedDataSource()
         : headlines_{
-              "Fed raises rates by 25bps, signals higher-for-longer stance",
-              "AAPL earnings beat as services revenue hits record",
-              "US CPI comes in cooler than expected; futures rally",
-              "Oil jumps 3% on supply disruption concerns in the Middle East",
-              "NVDA announces new AI chips; shares pop in after-hours",
-              "Treasury yields fall after weak jobs report; bond market rallies",
-              "ECB holds rates steady; hints at possible summer cut",
-              "TSLA deliveries miss estimates; margin pressure returns",
-              "Gold climbs as dollar weakens and risk-off flows pick up",
-              "China announces targeted stimulus; industrial metals rise",
-              "MSFT cloud growth accelerates; upbeat guidance lifts tech",
-              "Banking sector dips on renewed concerns over CRE exposure",
+              {"Fed raises rates by 25bps, signals higher-for-longer stance", "Reuters"},
+              {"AAPL earnings beat as services revenue hits record", "Bloomberg"},
+              {"US CPI comes in cooler than expected; futures rally", "Associated Press"},
+              {"Oil jumps 3% on supply disruption concerns in the Middle East", "CNBC"},
+              {"NVDA announces new AI chips; shares pop in after-hours", "PRNewswire"},
+              {"Treasury yields fall after weak jobs report; bond market rallies", "Reuters"},
+              {"ECB holds rates steady; hints at possible summer cut", "Financial Times"},
+              {"TSLA deliveries miss estimates; margin pressure returns", "MarketWatch"},
+              {"Gold climbs as dollar weakens and risk-off flows pick up", "Yahoo Finance"},
+              {"China announces targeted stimulus; industrial metals rise", "Bloomberg"},
+              {"MSFT cloud growth accelerates; upbeat guidance lifts tech", "GlobeNewswire"},
+              {"Banking sector dips on renewed concerns over CRE exposure", "Seeking Alpha"},
               // Single-stock headlines (no macro keyword) for testing watchlists.
-              "GOOGL slides after antitrust ruling threatens ad business",
-              "AMZN holiday sales smash records; cloud margins expand",
-              "META unveils new AI assistant; shares rally 7% after the bell",
-              "AMD wins major data-center deal, taking share from NVDA",
-              "JPM tops estimates as net interest income climbs to a record",
-              "DIS streaming losses narrow as subscriber growth returns",
-              "COIN surges as crypto trading volumes spike to yearly high",
-              "PLTR jumps on raised guidance and new government contracts",
+              {"GOOGL slides after antitrust ruling threatens ad business", "Reuters"},
+              {"AMZN holiday sales smash records; cloud margins expand", "PRNewswire"},
+              {"META unveils new AI assistant; shares rally 7% after the bell", "TechCrunch"},
+              {"AMD wins major data-center deal, taking share from NVDA", "MarketBeat Blog"},
+              {"JPM tops estimates as net interest income climbs to a record", "Wall Street Journal"},
+              {"DIS streaming losses narrow as subscriber growth returns", "CNBC"},
+              {"COIN surges as crypto trading volumes spike to yearly high", "CoinDesk"},
+              {"PLTR jumps on raised guidance and new government contracts", "StockTwits"},
           }
     {
     }
 
-    explicit SimulatedDataSource(std::vector<std::string> headlines)
+    explicit SimulatedDataSource(std::vector<Headline> headlines)
         : headlines_{std::move(headlines)}
     {
     }
 
-    std::optional<std::string> nextHeadline() override
+    std::optional<Headline> nextHeadline() override
     {
         if (headlines_.empty())
             return std::nullopt;
@@ -59,15 +64,15 @@ class SimulatedDataSource : public IMarketDataSource
         first_tick_ = false;
         last_emit_ = now;
 
-        const std::string &h = headlines_[next_idx_];
+        const Headline &h = headlines_[next_idx_];
         next_idx_ = (next_idx_ + 1) % headlines_.size();
         return h;
     }
 
 private:
     static constexpr std::chrono::milliseconds kInterval{2000};
 
-    std::vector<std::string> headlines_;
+    std::vector<Headline> headlines_;
     std::size_t next_idx_ = 0;
     std::chrono::steady_clock::time_point last_emit_{};
     bool first_tick_ = true;

cpp_engine/src/ZmqPublisher.hpp

@@ -20,9 +20,9 @@ class ZmqPublisher
     ZmqPublisher(const ZmqPublisher &) = delete;
     ZmqPublisher &operator=(const ZmqPublisher &) = delete;
 
-    void publishHeadline(std::string_view headline)
+    void publishHeadline(std::string_view headline, std::string_view source)
     {
-        const std::string payload = build_headline_json(headline);
+        const std::string payload = build_headline_json(headline, source);
         sock_.send(zmq::buffer(payload), zmq::send_flags::none);
     }
 
@@ -86,15 +86,17 @@ class ZmqPublisher
         return out;
     }
 
-    static std::string build_headline_json(std::string_view headline)
+    static std::string build_headline_json(std::string_view headline, std::string_view source)
     {
         const std::string ts = iso8601_utc_now();
         std::string out;
-        out.reserve(headline.size() + ts.size() + 32);
+        out.reserve(headline.size() + source.size() + ts.size() + 48);
         out += "{\"type\":\"headline\",\"ts\":\"";
         out += ts;
         out += "\",\"headline\":\"";
         out += json_escape(headline);
+        out += "\",\"source\":\"";
+        out += json_escape(source);
         out += "\"}";
         return out;
     }

cpp_engine/src/main.cpp

@@ -153,10 +153,13 @@ int main(int argc, char **argv)
                     continue;
                 }
 
-                if (filter.current()->matches(*headline))
+                if (filter.current()->matches(headline->text))
                 {
-                    publisher.publishHeadline(*headline);
-                    std::cout << "published: " << *headline << "\n";
+                    publisher.publishHeadline(headline->text, headline->source);
+                    std::cout << "published: " << headline->text
+                              << " [source: "
+                              << (headline->source.empty() ? "unknown" : headline->source)
+                              << "]\n";
                 }
                 // Got a headline: loop again immediately to drain any backlog.
             }