typo

.autocrate.yaml

@@ -16,11 +16,13 @@ api:
     type: github
     endpoint: https://github.com
     auth:
-      user: myUserName
-      pass: token_superimportantsecret
-  myserv:
-    type: gitea
+      user: PlexSheep
+      pass:
+        env: TOKEN_GH
+  cscherr:
+    type: forgejo
     endpoint: https://git.cscherr.de
     auth:
-      user: myUserName
-      pass: importantsecrettoken
+      user: PlexSheep
+      pass:
+        env: TOKEN_CSCHERR

.gitea/workflows/cargo.yaml

@@ -6,7 +6,7 @@ on:
       # - '!master'
 
 jobs:
-  CI:
+  format:
     name: cargo CI
     permissions:
       # Give the default GITHUB_TOKEN write permission to commit and push the
@@ -16,9 +16,11 @@ jobs:
       - name: get repo
         uses: actions/checkout@v4
       - name: install rust
-        uses: dtolnay/rust-toolchain@stable
+        uses: https://github.com/dtolnay/rust-toolchain@stable
       - name: install additional rust things
-        run: rustup component add rustfmt
+        run: |
+          rustup component add rustfmt
+          rustup component add clippy
       - name: config custom registry
         run: |
           mkdir -p ~/.cargo/
@@ -28,16 +30,16 @@ jobs:
           echo '[registries.cscherr]' >> ~/.cargo/config.toml
           echo 'index = "https://git.cscherr.de/PlexSheep/_cargo-index.git"' >> ~/.cargo/config.toml
           cat ~/.cargo/config.toml
-      - name: cargo check
-        run: cargo check --all-features --all-targets
-      - name: cargo fix
-        run: cargo fix --all-features --all-targets
+      - name: cargo clippy check
+        run: cargo clippy --all-features --all-targets
+      - name: cargo clippy fix
+        run: cargo clippy --fix --all-features --all-targets
       - name: cargo fmt
         run: cargo fmt --all
       - name: cargo test
         run: cargo test --all-features --all-targets
       - name: commit back to repository
-        uses: stefanzweifel/git-auto-commit-action@v5
+        uses: https://github.com/stefanzweifel/git-auto-commit-action@v5
         with:
           # Optional. Commit message for the created commit.
           # Defaults to "Apply automatic changes"

.github/workflows/cargo.yaml

@@ -19,7 +19,9 @@ jobs:
       - name: install rust
         uses: dtolnay/rust-toolchain@stable
       - name: install additional rust things
-        run: rustup component add rustfmt
+        run: |
+          rustup component add rustfmt
+          rustup component add clippy
       - name: config custom registry
         run: |
           mkdir -p ~/.cargo/
@@ -29,10 +31,10 @@ jobs:
           echo '[registries.cscherr]' >> ~/.cargo/config.toml
           echo 'index = "https://git.cscherr.de/PlexSheep/_cargo-index.git"' >> ~/.cargo/config.toml
           cat ~/.cargo/config.toml
-      - name: cargo check
-        run: cargo check --all-features --all-targets
-      - name: cargo fix
-        run: cargo fix --all-features --all-targets
+      - name: cargo clippy check
+        run: cargo clippy --all-features --all-targets
+      - name: cargo clippy fix
+        run: cargo clippy --fix --all-features --all-targets
       - name: cargo fmt
         run: cargo fmt --all
       - name: cargo test

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "autocrate"
-version = "0.1.0-prealpha.1"
+version = "0.1.0-prealpha.2"
 edition = "2021"
 publish = true
 authors = ["Christoph J. Scherr <software@cscherr.de>"]
@@ -21,15 +21,18 @@ keywords = [
 
 [dependencies]
 anyhow = "1.0.79"
-cargo = "0.76.0"
+async-trait = "0.1.77"
+# cargo = "0.76.0"
 clap = { version = "4.4.18", features = ["derive", "help"] }
 clap-verbosity-flag = "2.1.2"
 git2 = "0.18.1"
 libpt = { version = "0.3.11", features = ["log"] }
+reqwest = "0.11.24"
 serde = { version = "1.0.195", features = ["derive"] }
 serde_yaml = "0.9.30"
 tempfile = "3.9.0"
 thiserror = "1.0.56"
+tokio = { version = "1.36.0", features = ["tokio-macros", "rt-multi-thread", "macros"] }
 url = { version = "2.5.0", features = ["serde"] }
 
 [[bin]]

README.md

@@ -66,7 +66,7 @@ Create a YAML file named `.autocrate.yml` (or `.yaml`) in the root of your Git
 repository. It should contain the following parameters (replace the placeholders):
 
 | Parent               | Key          | Value                                                                            | Explanation                                                                  |
-|-----------------|--------------|----------------------------------------------------------------------------------|------------------------------------------------------------------------------|
+|----------------------|--------------|----------------------------------------------------------------------------------|------------------------------------------------------------------------------|
 | (root)               | `changelog`  | list of keys with this as parent (`git-log` etc)                                 | information on how a changelog is generated                                  |
 | `changelog`          | `enable`     | `true`/`false`                                                                   | If false, no changelog will be generated                                     |
 | `changelog`          | `git-log`    | `true`/`false`                                                                   | should a changelog be generated with `git log`?                              |
@@ -79,7 +79,10 @@ repository. It should contain the following parameters (replace the placeholders
 | `api.NAME`           | `endpoint`   | Base URL of the target server                                                    | Let's us know which api type we are talking to                               |
 | `api.NAME`           | `auth`       | list of keys with this as parent (`user` and `pass`)                             | We probably need authentication on the target server                         |
 | `api.NAME.auth`      | `user`       | a string                                                                         | Which user should we try to authenticate as                                  |
-| `api.NAME.auth` | `pass`       | a string                                                                         | A secret for authentication o the server, probably a token                   |
+| `api.NAME.auth`      | `pass`       | contains either of `text`, `env` or `file`                                       | sets the secret for authentication with this server                          |
+| `api.NAME.auth.pass` | `text`       | a authentication pass as clear text                                              | A secret for authentication of the server, probably a token                   |
+| `api.NAME.auth.pass` | `env`        | env var which contains the token                                                 | A secret for authentication of the server, probably a token                   |
+| `api.NAME.auth.pass` | `file`       | file var which contains the token                                                | A secret for authentication of the server, probably a token                   |
 
 An example `.autocrate.yaml` could look like this:
 
@@ -102,16 +105,18 @@ api:
     endpoint: https://github.com
     auth:
       user: PlexSheep
-      pass: token_superimportantsecret
+      pass:
+        text: token_superimportantsecret
   cscherr:
     type: gitea
     endpoint: https://git.cscherr.de
     auth:
       user: PlexSheep
-      pass: Bearer importantsecrettoken
+      pass:
+        file: secrettoken.txt
 ```
 
-After Autocrate has been bootstrapped, you it will be released and published
+After Autocrate has been bootstrapped, it will be released and published
 with itself, so you can take a look at this repositories
 [`.autocrate.yaml`](./.autocrate.yaml).
 

scripts/release.sh

@@ -7,7 +7,7 @@ BODY="
 $(git log $(git describe --tags --abbrev=0)..HEAD --pretty="- %s" --oneline --decorate)
 "
 USER=PlexSheep
-git tag "v$NEW_VERSION-test" || echo "could not tag"
+git tag "v$NEW_VERSION" || echo "could not tag"
 curl -X 'POST' \
 	'https://git.cscherr.de/api/v1/repos/PlexSheep/'$REPO'/releases' \
 	-H 'accept: application/json' \

src/changelog/mod.rs

@@ -28,7 +28,7 @@ impl Changelog {
         let out = cmd.output()?;
         // FIXME: this does not catch fancy colors, those are from the shell as it seems? I don't
         // get it.
-        let buf = String::from_utf8(out.stdout).map_err(|err| ChangelogError::GitUTF8Error(err))?;
+        let buf = String::from_utf8(out.stdout).map_err(ChangelogError::GitUTF8Error)?;
         if !out.status.success() {
             // TODO: get the stderr for error reporting
             // TODO: Make the error more understandable for the user
@@ -43,14 +43,14 @@ impl Changelog {
         let mut cmd = Command::new("git");
         cmd.arg("describe").arg("--tags").arg("--abbrev=0");
         let out = cmd.output()?;
-        let buf = String::from_utf8(out.stdout).map_err(|err| ChangelogError::GitUTF8Error(err))?;
+        let buf = String::from_utf8(out.stdout).map_err(ChangelogError::GitUTF8Error)?;
         if !out.status.success() {
             // TODO: get the stderr for error reporting
             // TODO: Make the error more understandable for the user
             return Err(ChangelogError::GitBadStatus(out.status, buf).into());
         }
-        let buf = buf.replace("\n", "");
-        return Ok(buf);
+        let buf = buf.replace('\n', "");
+        Ok(buf)
     }
 }
 

src/config/cli.rs

@@ -38,6 +38,7 @@ pub struct Cli {
 #[derive(Debug, Clone, Subcommand)]
 pub enum Commands {
     Changelog {},
+    /// Create a new release on the server
     Release {
         // FIXME: allow taking a message like this:
         // `autocrate changelog -m arg1 arg2 arg3`
@@ -52,14 +53,29 @@ pub enum Commands {
         //
         // TODO:
         // find a way to make this a global option but only usable with specific subcommands
+        //
+        // TODO:
+        // integrate a CHANGELOG.md file
+        //
+        /// Message body of the release
         #[arg(short, long)]
         message: Option<Vec<String>>,
+
+        /// generate and add a changelog
+        changelog: bool,
+
+        /// publish after releasing
+        publish: bool,
     },
+    /// Publish to a package registry
     Publish {
         // see Commands::Release { message }
         #[arg(short, long)]
         message: Option<Vec<String>>,
     },
+    ///
+    Version {},
+    Init {},
 }
 
 impl Display for Commands {
@@ -71,6 +87,8 @@ impl Display for Commands {
                 Self::Changelog { .. } => "Changelog",
                 Self::Release { .. } => "Release",
                 Self::Publish { .. } => "Publish",
+                Self::Version { .. } => "Version",
+                Self::Init { .. } => "Init",
             }
         )
     }
@@ -95,6 +113,6 @@ impl Cli {
             // less verbose version
             Logger::init_mini(Some(ll)).expect("could not initialize Logger");
         }
-        return cli;
+        cli
     }
 }

src/config/mod.rs

@@ -8,6 +8,7 @@ use url::Url;
 use crate::error::*;
 
 pub mod cli;
+pub mod packages;
 use cli::Cli;
 
 pub trait YamlConfigSection: Debug + Clone + for<'a> Deserialize<'a> {
@@ -48,32 +49,60 @@ impl YamlConfigSection for Uses {
     }
 }
 
+#[derive(Debug, Clone, Deserialize)]
+pub enum Pass {
+    /// pass specified as plainext
+    Text(String),
+    /// pass to be loaded from an env var
+    Env(String),
+    /// pass to be loaded from a file
+    File(PathBuf),
+}
+impl Pass {
+    /// Get the pass, extracting from the underlying source
+    pub fn get_pass(&self) -> Result<String> {
+        self.check()?;
+        Ok(match self {
+            Self::Text(pass) => pass.clone(),
+            Self::Env(key) => std::env::var(key).map_err(ConfigError::from)?,
+            Self::File(file) => std::fs::read_to_string(file)?,
+        })
+    }
+}
+impl YamlConfigSection for Pass {
+    fn check(&self) -> Result<()> {
+        match self {
+            Self::Text(_) => (),
+            Self::Env(envvar) => {
+                if !std::env::var(envvar).map_err(ConfigError::from)?.is_empty() {
+                } else {
+                    return Err(ConfigError::EnvNotSet(envvar.clone()).into());
+                }
+            }
+            Self::File(file) => {
+                if !file.exists() {
+                    return Err(ConfigError::PassFileDoesNotExist(file.clone()).into());
+                }
+            }
+        };
+        Ok(())
+    }
+}
 #[derive(Debug, Clone, Deserialize)]
 pub struct ApiAuth {
     pub user: String,
-    pub pass: Option<String>,
-    pub pass_file: Option<PathBuf>,
+    pub pass: Pass,
 }
 impl YamlConfigSection for ApiAuth {
     fn check(&self) -> Result<()> {
-        if self.pass.is_some() && self.pass_file.is_some() {
-            let err = ConfigError::YamlApiAuthBothPass(self.clone()).into();
-            error!("{err}");
-            return Err(err);
-        }
-        if self.pass_file.is_some() {
-            let file = self.pass_file.clone().unwrap();
-            if !file.exists() {
-                return Err(ConfigError::PassFileDoesNotExist(file).into());
-            }
-        }
+        self.pass.check()?;
         Ok(())
     }
 }
 
 #[derive(Debug, Clone, Deserialize)]
 pub struct Api {
-    pub r#type: ApiType,
+    pub server_type: ApiType,
     pub endpoint: Url,
     /// May be left empty if the Api does not need auth or the auth is part of the
     /// [endpoint](Api::endpoint) [Url].
@@ -81,7 +110,7 @@ pub struct Api {
 }
 impl YamlConfigSection for Api {
     fn check(&self) -> Result<()> {
-        self.r#type.check()?;
+        self.server_type.check()?;
         match self.endpoint.socket_addrs(|| None) {
             Ok(_) => (),
             Err(err) => return Err(err.into()),
@@ -101,6 +130,8 @@ pub enum ApiType {
     Gitlab,
     #[serde(alias = "github", alias = "GitHub")]
     Github,
+    #[serde(alias = "forgejo")]
+    Forgejo,
 }
 impl YamlConfigSection for ApiType {
     fn check(&self) -> Result<()> {
@@ -147,7 +178,7 @@ impl Debug for Config {
         write!(
             f,
             "{}",
-            format!(
+            format_args!(
                 "Config {{yaml: {:?}, repo_path: {:?}}}",
                 self.yaml, self.path
             )
@@ -156,7 +187,7 @@ impl Debug for Config {
 }
 
 impl Config {
-    pub fn load(cli: Cli) -> Result<Self> {
+    pub fn load(cli: &Cli) -> Result<Self> {
         let repo = match git2::Repository::open_from_env() {
             Ok(repo) => repo,
             Err(_err) => {
@@ -197,7 +228,7 @@ impl Config {
             yaml,
             repo,
             path,
-            cli,
+            cli: cli.clone(),
         })
     }
 }

src/config/packages.rs

@@ -0,0 +1,3 @@
+pub enum PackageType {
+    Cargo,
+}

src/error.rs

@@ -1,4 +1,4 @@
-use std::{path::PathBuf, process::ExitStatus, string::FromUtf8Error};
+use std::{env::VarError, path::PathBuf, process::ExitStatus, string::FromUtf8Error};
 
 use anyhow;
 use thiserror::Error;
@@ -20,6 +20,18 @@ pub enum Error {
     SerdeYaml(#[from] serde_yaml::Error),
     #[error("Could not generate the changelog")]
     ChangelogError(#[from] ChangelogError),
+    #[error("Server Api error")]
+    ServerApiError(#[from] ServerApiError),
+}
+
+#[derive(Error, Debug)]
+pub enum ServerApiError {
+    #[error(transparent)]
+    ParseUrl(#[from] url::ParseError),
+    #[error(transparent)]
+    InvalidHeaderValue(#[from] reqwest::header::InvalidHeaderValue),
+    #[error(transparent)]
+    ReqwestErr(#[from] reqwest::Error),
 }
 
 #[derive(Error, Debug)]
@@ -45,4 +57,8 @@ pub enum ConfigError {
     YamlApiAuthBothPass(ApiAuth),
     #[error("password provided as file, but does not exist: {0}")]
     PassFileDoesNotExist(PathBuf),
+    #[error("config requires environment variable {0}, but {0} is not set")]
+    EnvNotSet(String),
+    #[error("Bad value for environment variable: {0}")]
+    BadEnv(#[from] VarError),
 }

src/lib.rs

@@ -1,3 +1,6 @@
 pub mod changelog;
 pub mod config;
 pub mod error;
+pub mod publish;
+pub mod release;
+pub mod serverapi;

src/main.rs

@@ -5,22 +5,37 @@ use autocrate::{
         Config,
     },
     error::*,
+    publish::publish,
+    release::release,
+    serverapi::init_servers,
 };
 
-fn main() -> Result<()> {
+#[tokio::main]
+async fn main() -> Result<()> {
     let cli = Cli::cli_parse();
-    let cfg = Config::load(cli.clone())?;
+    let cfg = Config::load(&cli)?;
 
     match cli.command {
         Commands::Changelog { .. } => {
-            println!("{}", Changelog::build(&cfg)?.to_string());
-            Ok(())
+            println!("{}", Changelog::build(&cfg)?);
         }
         Commands::Release { .. } => {
-            todo!()
+            let mut apis = init_servers(&cfg).await?;
+            release(&cfg, &mut apis).await?;
         }
         Commands::Publish { .. } => {
+            publish(&cfg).await?;
+        }
+        Commands::Version {} => {
+            // TODO: version bump
+            // TODO: version select interactive
+            // TODO: version select automated
             todo!()
         }
+        Commands::Init { .. } => {
+            // TODO: create a basic autocrate yaml
+            todo!()
         }
+    };
+    Ok(())
 }

src/publish/mod.rs

@@ -0,0 +1,7 @@
+use crate::{config::Config, error::*};
+
+pub struct PublishContext;
+
+pub async fn publish(_cfg: &Config) -> Result<()> {
+    todo!()
+}

src/release/mod.rs

@@ -0,0 +1,31 @@
+use crate::{config::Config, error::*, serverapi::ApiCollection};
+
+pub struct ReleaseContext {
+    pub draft: bool,
+    pub prerelease: bool,
+    pub username: String,
+    pub repository: String,
+    pub text: String,
+    pub tag: String,
+    pub commit_sig: String,
+}
+
+pub async fn release(cfg: &Config, _apis: &mut ApiCollection) -> Result<()> {
+    // TODO: git tag
+    // TODO: push to each server
+
+    // TODO: release to each server
+    tag(cfg).await?;
+    todo!();
+
+    // TODO: check that the release is made
+    // TODO: generate artifacts
+    // TODO: upload artifacts
+    // TODO: upload artifact signatures
+
+    Ok(())
+}
+
+async fn tag(_cfg: &Config) -> Result<()> {
+    todo!()
+}

src/serverapi/forgejo.rs

@@ -0,0 +1,83 @@
+use crate::{
+    config::{Api, Config},
+    error::*,
+    serverapi::{PublishContext, ReleaseContext, ServerApi},
+};
+use async_trait::async_trait;
+use reqwest::{
+    header::{HeaderMap, HeaderValue},
+    Client, Url,
+};
+
+pub struct Forgejo {
+    cfg: Api,
+    client: Client,
+}
+
+impl Forgejo {
+    pub async fn build(api: &Api) -> Result<Self> {
+        let mut headers: HeaderMap = HeaderMap::new();
+        // may be left empty if we only do reads from publically accessible urls
+        if api.auth.is_some() {
+            let _ = headers.insert(
+                "Authorization",
+                HeaderValue::from_str(api.auth.clone().unwrap().pass.get_pass()?.as_str())
+                    .map_err(ServerApiError::from)?,
+            );
+        }
+        let client = super::client_builder()
+            .default_headers(headers)
+            .build()
+            .map_err(ServerApiError::from)?;
+        Ok(Self {
+            cfg: api.clone(),
+            client,
+        })
+    }
+}
+
+#[async_trait]
+impl ServerApi for Forgejo {
+    async fn init(&mut self, _cfg: &Config) -> Result<()> {
+        todo!()
+    }
+    async fn push_release(&mut self, rc: &ReleaseContext) -> Result<()> {
+        let raw_url = format!(
+            "{}/api/v1/repos/{}/{}/releases",
+            self.cfg.endpoint, rc.username, rc.repository
+        );
+        let url = Url::parse(&raw_url).map_err(ServerApiError::from)?;
+        let body = format!(
+            r#"
+        {{
+            "body": "{}",
+            "draft": {},
+            "name": "{}",
+            "prerelease": {},
+            "tag_name": "{}",
+            "target_commitish": "{}"
+        }}
+        "#,
+            rc.text, rc.draft, rc.tag, rc.prerelease, rc.tag, rc.commit_sig
+        );
+
+        let request = self
+            .client
+            .post(url)
+            .body(body)
+            .build()
+            .map_err(ServerApiError::from)?;
+        let _response = self
+            .client
+            .execute(request)
+            .await
+            .map_err(ServerApiError::from)?;
+        Ok(())
+    }
+    async fn push_release_artifact(&mut self, _rc: &ReleaseContext) -> Result<()> {
+        todo!()
+    }
+    async fn push_pkg(&mut self, _pc: &PublishContext) -> Result<()> {
+        todo!()
+    }
+}

src/serverapi/gitea.rs

@@ -0,0 +1,32 @@
+use async_trait::async_trait;
+
+use super::{PublishContext, ReleaseContext, ServerApi};
+use crate::{
+    config::{Api, Config},
+    error::*,
+};
+pub struct Gitea {
+    cfg: Api,
+}
+
+#[async_trait]
+impl ServerApi for Gitea {
+    async fn init(&mut self, _cfg: &Config) -> Result<()> {
+        todo!()
+    }
+    async fn push_release(&mut self, _rc: &ReleaseContext) -> Result<()> {
+        todo!()
+    }
+    async fn push_release_artifact(&mut self, _rc: &ReleaseContext) -> Result<()> {
+        todo!()
+    }
+    async fn push_pkg(&mut self, _pc: &PublishContext) -> Result<()> {
+        todo!()
+    }
+}
+
+impl Gitea {
+    pub async fn build(api: &Api) -> Result<Self> {
+        Ok(Self { cfg: api.clone() })
+    }
+}

src/serverapi/github.rs

@@ -0,0 +1,32 @@
+use async_trait::async_trait;
+
+use super::{PublishContext, ReleaseContext, ServerApi};
+use crate::{
+    config::{Api, Config},
+    error::*,
+};
+pub struct Github {
+    cfg: Api,
+}
+
+#[async_trait]
+impl ServerApi for Github {
+    async fn init(&mut self, _cfg: &Config) -> Result<()> {
+        todo!()
+    }
+    async fn push_release(&mut self, _rc: &ReleaseContext) -> Result<()> {
+        todo!()
+    }
+    async fn push_release_artifact(&mut self, _rc: &ReleaseContext) -> Result<()> {
+        todo!()
+    }
+    async fn push_pkg(&mut self, _pc: &PublishContext) -> Result<()> {
+        todo!()
+    }
+}
+
+impl Github {
+    pub async fn build(api: &Api) -> Result<Self> {
+        Ok(Self { cfg: api.clone() })
+    }
+}

src/serverapi/gitlab.rs

@@ -0,0 +1,32 @@
+use async_trait::async_trait;
+
+use super::{PublishContext, ReleaseContext, ServerApi};
+use crate::{
+    config::{Api, Config},
+    error::*,
+};
+pub struct Gitlab {
+    cfg: Api,
+}
+
+#[async_trait]
+impl ServerApi for Gitlab {
+    async fn init(&mut self, _cfg: &Config) -> Result<()> {
+        todo!()
+    }
+    async fn push_release(&mut self, _rc: &ReleaseContext) -> Result<()> {
+        todo!()
+    }
+    async fn push_release_artifact(&mut self, _rc: &ReleaseContext) -> Result<()> {
+        todo!()
+    }
+    async fn push_pkg(&mut self, _pc: &PublishContext) -> Result<()> {
+        todo!()
+    }
+}
+
+impl Gitlab {
+    pub async fn build(api: &Api) -> Result<Self> {
+        Ok(Self { cfg: api.clone() })
+    }
+}

src/serverapi/mod.rs

@@ -0,0 +1,60 @@
+use async_trait::async_trait;
+use reqwest::ClientBuilder;
+
+use crate::{
+    config::{ApiType, Config},
+    error::*,
+    publish::PublishContext,
+    release::ReleaseContext,
+};
+
+pub mod forgejo;
+pub mod gitea;
+pub mod github;
+pub mod gitlab;
+use forgejo::*;
+use gitea::*;
+use github::*;
+use gitlab::*;
+
+pub static USER_AGENT: &str = concat!(env!("CARGO_PKG_NAME"), "/", env!("CARGO_PKG_VERSION"),);
+pub type ApiCollection = Vec<Box<dyn ServerApi>>;
+
+// NOTE: in stable rust, traits can normally not contain async methods,
+// see [here](https://stackoverflow.com/questions/65921581/how-can-i-define-an-async-method-in-a-trait).
+// The `async_trait` crate can be used to work around this limitation.
+#[async_trait]
+pub trait ServerApi {
+    async fn init(&mut self, cfg: &Config) -> Result<()>;
+    async fn push_release(&mut self, rc: &ReleaseContext) -> Result<()>;
+    async fn push_release_artifact(&mut self, rc: &ReleaseContext) -> Result<()>;
+    async fn push_pkg(&mut self, pc: &PublishContext) -> Result<()>;
+}
+
+pub fn client_builder() -> ClientBuilder {
+    ClientBuilder::new().user_agent(USER_AGENT)
+}
+
+pub async fn init_servers(cfg: &Config) -> Result<ApiCollection> {
+    let mut collection: ApiCollection = ApiCollection::new();
+    for api in &cfg.yaml.api {
+        match api.1.server_type {
+            ApiType::Gitea => {
+                collection.push(Box::new(Gitea::build(api.1).await?));
+            }
+            ApiType::Gitlab => {
+                collection.push(Box::new(Gitlab::build(api.1).await?));
+            }
+            ApiType::Github => {
+                collection.push(Box::new(Github::build(api.1).await?));
+            }
+            ApiType::Forgejo => {
+                collection.push(Box::new(Forgejo::build(api.1).await?));
+            }
+        }
+    }
+    for api in collection.iter_mut() {
+        api.init(cfg).await?;
+    }
+    Ok(collection)
+}