Sources

let request = GetInNetworkPostsRequest {
    user_id: query.user_id as u64,
    following_user_ids: following_list.iter().map(|&id| id as u64).collect(),
    max_results: p::THUNDER_MAX_RESULTS,
    exclude_tweet_ids: vec![],
    algorithm: "default".to_string(),
    debug: false,
    is_video_request: false,
};

let response = client
    .get_in_network_posts(request)
    .await
    .map_err(|e| format!("ThunderSource: {}", e))?;

let candidates: Vec<PostCandidate> = response
    .into_inner()
    .posts
    .into_iter()
    .map(|post| PostCandidate {
        tweet_id: post.post_id,
        author_id: post.author_id as u64,
        in_reply_to_tweet_id: post.in_reply_to_post_id,
        ancestors,
        served_type: Some(pb::ServedType::ForYouInNetwork),
        ..Default::default()
    })
    .collect();

fn enable(&self, query: &ScoredPostsQuery) -> bool {
    !query.in_network_only
}

let sequence = query
    .user_action_sequence
    .as_ref()
    .ok_or_else(|| "PhoenixSource: missing user_action_sequence".to_string())?;

let response = self
    .phoenix_retrieval_client
    .retrieve(user_id, sequence.clone(), p::PHOENIX_MAX_RESULTS)
    .await
    .map_err(|e| format!("PhoenixSource: {}", e))?;

let candidates: Vec<PostCandidate> = response
    .top_k_candidates
    .into_iter()
    .flat_map(|scored_candidates| scored_candidates.candidates)
    .filter_map(|scored_candidate| scored_candidate.candidate)
    .map(|tweet_info| PostCandidate {
        tweet_id: tweet_info.tweet_id as i64,
        author_id: tweet_info.author_id,
        in_reply_to_tweet_id: Some(tweet_info.in_reply_to_tweet_id),
        served_type: Some(pb::ServedType::ForYouPhoenixRetrieval),
        ..Default::default()
    })
    .collect();