Method HasStream

src/render_panel/database/stream_db_operator.cpp:51–56

    }

    bool StreamDBOperator::HasStream(const std::string& stream_id) {
        using Storage = decltype(db_->GetStorageTypeValue());
        auto storage = std::any_cast<Storage>(db_->GetDbStorage());
        auto streams = storage.get_all<spvr::SpvrStream>(where(c(&spvr::SpvrStream::stream_id_) == stream_id));
        return !streams.empty();
    }

    bool StreamDBOperator::UpdateStream(std::shared_ptr<spvr::SpvrStream> stream) {
        stream->updated_timestamp_ = (int64_t)TimeUtil::GetCurrentTimestamp();