njaremko/podcast - Change HTHQWZRRS5N2J3VMS4VFT3MMOBA4MHVTO6REWCHU2RJIDSN3HTSQC

Use single http client throughout to take advantage of keep-alive connection pooling

Created by Nathan Jaremko on July 15, 2020

HTHQWZRRS5N2J3VMS4VFT3MMOBA4MHVTO6REWCHU2RJIDSN3HTSQC

Dependencies

In channels

main

Change contents

Replacement in Cargo.toml at line 30 [5.62]

B:BD[4.87] → [4.87:154]

reqwest = { version = "0.10", features = ["default-tls", "json"] }

[4.87]

[6.108]

reqwest = { version = "0.10", features = ["json"] }

Replacement in Cargo.toml at line 40 [5.62]
B:BD[7.69] → [3.164:186]
```
podcast_search = "0.2"
```
[7.69]
```
podcast_search = "0.2"
indicatif = "0.15.0"
```

Replacement in src/actions.rs at line 52 [9.163]

B:BD[8.836] → [4.229:326]

pub async fn update_subscription(sub: &mut Subscription, config: Option<Config>) -> Result<()> {

[8.836]

[10.1054]

pub async fn update_subscription(client: &reqwest::Client, sub: &mut Subscription, config: Option<Config>) -> Result<()> {

Replacement in src/actions.rs at line 87 [9.163]

B:BD[4.863] → [4.863:947]

                d_vec.push(download::download(podcast.title().into(), ep.clone()));

[4.863]

[4.947]

                d_vec.push(download::download(client, podcast.title().into(), ep.clone()));

Replacement in src/actions.rs at line 91 [9.163]

B:BD[4.1018] → [4.1018:1102]

                d_vec.push(download::download(podcast.title().into(), ep.clone()));

[4.1018]

[4.1102]

                d_vec.push(download::download(client, podcast.title().into(), ep.clone()));

Replacement in src/actions.rs at line 104 [9.163]

B:BD[11.1217] → [4.1294:1377]

pub async fn update_rss(state: &mut State, config: Option<Config>) -> Result<()> {

[11.1217]

[12.3305]

pub async fn update_rss(client: &reqwest::Client,state: &mut State, config: Option<Config>) -> Result<()> {

Replacement in src/actions.rs at line 108 [9.163]

B:BD[4.1449] → [4.1449:1503]

        d_vec.push(update_subscription(sub, config));

[4.1449]

[4.1503]

        d_vec.push(update_subscription(client, sub, config));

Replacement in src/arg_parser.rs at line 14 [13.3622]

B:BD[13.3715] → [4.1887:1970]

pub async fn download(state: &mut State, matches: &ArgMatches<'_>) -> Result<()> {

[13.3715]

[10.3032]

pub async fn download(client: &reqwest::Client,state: &mut State, matches: &ArgMatches<'_>) -> Result<()> {

Replacement in src/arg_parser.rs at line 20 [13.3622]

B:BD[10.3313] → [4.1971:2040]

                download::download_range(&state, podcast, ep).await?

[10.3313]

[10.3376]

                download::download_range(&client, &state, podcast, ep).await?

Insertion in src/arg_parser.rs at line 23 [13.3622]
[10.3496]
[10.3496]
```
                    &client,
```

Replacement in src/arg_parser.rs at line 31 [13.3622]

B:BD[10.3681] → [4.2084:2162]

                download::download_episode_by_num(&state, podcast, ep).await?

[10.3681]

[13.5407]

                download::download_episode_by_num(&client,&state, podcast, ep).await?

Replacement in src/arg_parser.rs at line 36 [13.3622]

B:BD[2.315] → [2.315:405]

                download::download_latest(&state, podcast, num_of_latest.parse()?).await?

[2.315]

[2.405]

                download::download_latest(&client,&state, podcast, num_of_latest.parse()?).await?

Replacement in src/arg_parser.rs at line 38 [13.3622]

∅:D[2.419] → [14.172:240]

B:BD[14.172] → [14.172:240]

            None => download::download_all(&state, podcast).await?,

[2.419]

[2.420]

            None => download::download_all(&client,&state, podcast).await?,

Replacement in src/arg_parser.rs at line 72 [13.3622]

B:BD[10.4770] → [4.2228:2328]

pub async fn subscribe(state: &mut State, config: Config, matches: &ArgMatches<'_>) -> Result<()> {

[10.4770]

[10.4861]

pub async fn subscribe(client: &reqwest::Client,state: &mut State, config: Config, matches: &ArgMatches<'_>) -> Result<()> {

Replacement in src/arg_parser.rs at line 78 [13.3622]
B:BD[10.5070] → [4.2329:2365]
```
    sub(state, config, url).await?;
```
[10.5070]
[15.898]
```
    sub(client, state, config, url).await?;
```

Replacement in src/arg_parser.rs at line 82 [13.3622]

B:BD[15.912] → [4.2366:2441]

async fn sub(state: &mut State, config: Config, url: &str) -> Result<()> {

[15.912]

[4.2441]

async fn sub(client: &reqwest::Client,state: &mut State, config: Config, url: &str) -> Result<()> {

Replacement in src/arg_parser.rs at line 84 [13.3622]

B:BD[4.2474] → [4.2474:2522]

    download::download_rss(config, url).await?;

[4.2474]

[10.5140]

    download::download_rss(client, config, url).await?;

Replacement in src/arg_parser.rs at line 112 [13.3622]

B:BD[15.1055] → [4.2523:2620]

pub async fn search(state: &mut State, config: Config, matches: &ArgMatches<'_>) -> Result<()> {

[15.1055]

[15.1142]

pub async fn search(client: &reqwest::Client,state: &mut State, config: Config, matches: &ArgMatches<'_>) -> Result<()> {

Replacement in src/arg_parser.rs at line 155 [13.3622]

B:BD[6.462] → [6.462:512]

        Some(r) => sub(state, config, &r).await?,

[6.462]

[15.2364]

        Some(r) => sub(client, state, config, &r).await?,

Insertion in src/command_handler.rs at line 26 [10.5924]
[10.6778]
[10.6778]
```
    client: &reqwest::Client,
```

Replacement in src/command_handler.rs at line 35 [10.5924]

B:BD[10.6992] → [4.2887:2944]

            arg_parser::download(state, matches).await?;

[10.6992]

[10.7043]

            arg_parser::download(&client, state, matches).await?;

Replacement in src/command_handler.rs at line 44 [10.5924]

B:BD[10.7283] → [4.2945:3011]

            arg_parser::subscribe(state, config, matches).await?;

[10.7283]

[10.7343]

            arg_parser::subscribe(&client, state, config, matches).await?;

Replacement in src/command_handler.rs at line 47 [10.5924]

B:BD[10.7392] → [4.3012:3075]

            arg_parser::search(state, config, matches).await?;

[10.7392]

[10.7448]

            arg_parser::search(&client, state, config, matches).await?;

Replacement in src/command_handler.rs at line 56 [10.5924]

B:BD[10.7696] → [4.3076:3128]

            update_rss(state, Some(config)).await?;

[10.7696]

[10.7727]

            update_rss(&client, state, Some(config)).await?;

Replacement in src/download.rs at line 13 [10.8093]

B:BD[10.8315] → [4.3177:3275]

pub async fn download_range(state: &State, p_search: &str, e_search: &str) -> Result<(), Error> {

[10.8315]

[10.8407]

pub async fn download_range(client: &reqwest::Client, state: &State, p_search: &str, e_search: &str) -> Result<(), Error> {

Insertion in src/download.rs at line 25 [10.8093]
[2.467]
[2.467]
```
                    client,
```
Insertion in src/download.rs at line 53 [10.8093]
[4.3687]
[4.3687]
```
    client: &reqwest::Client, 
```
Insertion in src/download.rs at line 67 [10.8093]
[2.646]
[2.646]
```
                    client,
```

Replacement in src/download.rs at line 80 [10.8093]

B:BD[10.9916] → [4.4078:4153]

        download_episode_by_name(state, p_search, e_search, false).await?;

[10.9916]

[10.9985]

        download_episode_by_name(client, state, p_search, e_search, false).await?;

Replacement in src/download.rs at line 92 [10.8093]

B:BD[10.10006] → [4.4154:4239]

pub async fn download(podcast_name: String, episode: Episode) -> Result<(), Error> {

[10.10006]

[15.2608]

pub async fn download(client: &reqwest::Client, podcast_name: String, episode: Episode) -> Result<(), Error> {

Replacement in src/download.rs at line 104 [10.8093]

B:BD[10.10431] → [4.4240:4304]

            let resp = reqwest::get(url).await?.bytes().await?;

[10.10431]

[10.10474]

            let resp = client.get(url).send().await?.bytes().await?;

Insertion in src/download.rs at line 120 [10.8093]
[4.4401]
[10.10809]
```
    client: &reqwest::Client, 
```

Replacement in src/download.rs at line 146 [10.8093]

B:BD[4.4491] → [4.4491:4565]

                    let d = download(podcast.title().into(), ep.clone());

[4.4491]

[4.4565]

                    let d = download(client, podcast.title().into(), ep.clone());

Replacement in src/download.rs at line 151 [10.8093]

B:BD[4.4673] → [4.4673:4747]

                    let d = download(podcast.title().into(), ep.clone());

[4.4673]

[4.4747]

                    let d = download(client, podcast.title().into(), ep.clone());

Replacement in src/download.rs at line 165 [10.8093]

B:BD[10.12109] → [4.4951:5031]

pub async fn download_all(state: &State, p_search: &str) -> Result<(), Error> {

[10.12109]

[10.12183]

pub async fn download_all(client: &reqwest::Client, state: &State, p_search: &str) -> Result<(), Error> {

Replacement in src/download.rs at line 194 [10.8093]

B:BD[4.5298] → [4.5298:5363]

                    let d = download(podcast.title().into(), e);

[4.5298]

[4.5363]

                    let d = download(client, podcast.title().into(), e);

Replacement in src/download.rs at line 208 [10.8093]

B:BD[10.13363] → [14.642:740]

pub async fn download_latest(state: &State, p_search: &str, latest: usize) -> Result<(), Error> {

[10.13363]

[14.740]

pub async fn download_latest(client: &reqwest::Client, state: &State, p_search: &str, latest: usize) -> Result<(), Error> {

Replacement in src/download.rs at line 213 [10.8093]

B:BD[14.924] → [14.924:994]

            d_vec.push(download(podcast.title().into(), ep.clone()));

[14.924]

[14.994]

            d_vec.push(download(client, podcast.title().into(), ep.clone()));

Replacement in src/download.rs at line 224 [10.8093]

∅:D[14.1191] → [4.5578:5654]

B:BD[10.13363] → [4.5578:5654]

pub async fn download_rss(config: Config, url: &str) -> Result<(), Error> {

[14.1191]

[4.5654]

pub async fn download_rss(client: &reqwest::Client, config: Config, url: &str) -> Result<(), Error> {

Replacement in src/download.rs at line 240 [10.8093]

B:BD[4.5876] → [4.5876:5946]

            d_vec.push(download(podcast.title().into(), ep.clone()));

[4.5876]

[4.5946]

            d_vec.push(download(client, podcast.title().into(), ep.clone()));

Replacement in src/main.rs at line 47 [5.1346]

B:BD[10.15520] → [4.6238:6286]

    let mut state = State::new(VERSION).await?;

[10.15520]

[12.8877]

    let client = reqwest::Client::new();
    let mut state = State::new(&client, VERSION).await?;

Replacement in src/main.rs at line 56 [5.1346]

B:BD[16.1994] → [4.6287:6381]

    command_handler::handle_matches(&VERSION, &mut state, config, &mut app, &matches).await?;

[16.1994]

[10.15652]

    command_handler::handle_matches(&VERSION, &client, &mut state, config, &mut app, &matches).await?;

Replacement in src/structs.rs at line 102 [5.234]

B:BD[9.3511] → [17.126:181]

    pub async fn new(version: &str) -> Result<State> {

[9.3511]

[13.14687]

    pub async fn new(client: &reqwest::Client, version: &str) -> Result<State> {

Replacement in src/structs.rs at line 115 [5.234]

B:BD[4.7362] → [4.7362:7423]

                update_rss(&mut state, Some(config)).await?;

[4.7362]

[4.7423]

                update_rss(client, &mut state, Some(config)).await?;