Method TestTopicConfig

phxqueue/test/test_config.cpp:50–253

}

void TestConfig::TestTopicConfig(const config::TopicConfig *topic_config) {
    // 1->1, 2
    // 2->2
    const vector<int> expected_pub_ids = {1, 2};
    const vector<int> expected_sub_ids = {1, 2};

    /*************************** pub ****************************/
    // GetAllPub
    {
        vector<shared_ptr<const config::proto::Pub> > pubs;
        assert(comm::RetCode::RET_OK == topic_config->GetAllPub(pubs));
        assert(expected_pub_ids.size() == pubs.size());
    }

    // GetAllPubID
    {
        set<int> pub_ids;
        assert(comm::RetCode::RET_OK == topic_config->GetAllPubID(pub_ids));
        assert(expected_pub_ids.size() == pub_ids.size());
    }


    // IsValidPubID
    {
        for (auto &&pub_id : expected_pub_ids) {
            assert(topic_config->IsValidPubID(pub_id));
        }
    }

    // GetPubByPubID
    {
        shared_ptr<const config::proto::Pub> pub;
        assert(comm::RetCode::RET_OK == topic_config->GetPubByPubID(expected_pub_ids[0], pub));
        assert(pub);
        assert(expected_pub_ids[0] == pub->pub_id());
    }

    // GetSubIDsByPubID
    {
        set<int> sub_ids;
        assert(comm::RetCode::RET_OK ==
               topic_config->GetSubIDsByPubID(expected_pub_ids[0], sub_ids)); // 1->1,2
        assert(expected_sub_ids.size() == sub_ids.size());
    }

    /*************************** sub ****************************/

    // GetAllSub
    {
        vector<shared_ptr<const config::proto::Sub> > subs;
        assert(comm::RetCode::RET_OK == topic_config->GetAllSub(subs));
        assert(expected_sub_ids.size() == subs.size());
    }

    // GetAllSubID
    {
        set<int> sub_ids;
        assert(comm::RetCode::RET_OK == topic_config->GetAllSubID(sub_ids));