aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorGusted <postmaster@gusted.xyz>2023-02-11 01:39:50 +0100
committerGitHub <noreply@github.com>2023-02-11 08:39:50 +0800
commit1cb8d14bf71e0b8637c9eaa10808b4fd05139f45 (patch)
tree13d3b089cd0a944bd2a50529282fd645d9610637
parentaffdd40296960a08a4223330ccbd1fb88c96ea1a (diff)
downloadgitea-1cb8d14bf71e0b8637c9eaa10808b4fd05139f45.tar.gz
gitea-1cb8d14bf71e0b8637c9eaa10808b4fd05139f45.zip
Use proxy for pull mirror (#22771)
- Use the proxy (if one is specified) for pull mirrors syncs. - Pulled the code from https://github.com/go-gitea/gitea/blob/c2774d9e80d9a436d9c2044960369c4db227e3a0/modules/git/repo.go#L164-L170 Downstream issue: https://codeberg.org/forgejo/forgejo/issues/302 --------- Co-authored-by: Lauris BH <lauris@nix.lv>
-rw-r--r--modules/git/repo.go6
-rw-r--r--modules/proxy/proxy.go14
-rw-r--r--services/mirror/mirror_pull.go4
3 files changed, 20 insertions, 4 deletions
diff --git a/modules/git/repo.go b/modules/git/repo.go
index e77a3a6ad8..233f7f20cf 100644
--- a/modules/git/repo.go
+++ b/modules/git/repo.go
@@ -163,10 +163,8 @@ func CloneWithArgs(ctx context.Context, args TrustedCmdArgs, from, to string, op
envs := os.Environ()
u, err := url.Parse(from)
- if err == nil && (strings.EqualFold(u.Scheme, "http") || strings.EqualFold(u.Scheme, "https")) {
- if proxy.Match(u.Host) {
- envs = append(envs, fmt.Sprintf("https_proxy=%s", proxy.GetProxyURL()))
- }
+ if err == nil {
+ envs = proxy.EnvWithProxy(u)
}
stderr := new(bytes.Buffer)
diff --git a/modules/proxy/proxy.go b/modules/proxy/proxy.go
index f0cd366c12..1a6bdad7fb 100644
--- a/modules/proxy/proxy.go
+++ b/modules/proxy/proxy.go
@@ -7,6 +7,7 @@ import (
"net/http"
"net/url"
"os"
+ "strings"
"sync"
"code.gitea.io/gitea/modules/log"
@@ -82,3 +83,16 @@ func Proxy() func(req *http.Request) (*url.URL, error) {
return http.ProxyFromEnvironment(req)
}
}
+
+// EnvWithProxy returns os.Environ(), with a https_proxy env, if the given url
+// needs to be proxied.
+func EnvWithProxy(u *url.URL) []string {
+ envs := os.Environ()
+ if strings.EqualFold(u.Scheme, "http") || strings.EqualFold(u.Scheme, "https") {
+ if Match(u.Host) {
+ envs = append(envs, "https_proxy="+GetProxyURL())
+ }
+ }
+
+ return envs
+}
diff --git a/services/mirror/mirror_pull.go b/services/mirror/mirror_pull.go
index 7dee90352e..126d2bf354 100644
--- a/services/mirror/mirror_pull.go
+++ b/services/mirror/mirror_pull.go
@@ -18,6 +18,7 @@ import (
"code.gitea.io/gitea/modules/log"
"code.gitea.io/gitea/modules/notification"
"code.gitea.io/gitea/modules/process"
+ "code.gitea.io/gitea/modules/proxy"
repo_module "code.gitea.io/gitea/modules/repository"
"code.gitea.io/gitea/modules/setting"
"code.gitea.io/gitea/modules/timeutil"
@@ -215,6 +216,8 @@ func runSync(ctx context.Context, m *repo_model.Mirror) ([]*mirrorSyncResult, bo
return nil, false
}
+ envs := proxy.EnvWithProxy(remoteURL.URL)
+
stdoutBuilder := strings.Builder{}
stderrBuilder := strings.Builder{}
if err := cmd.
@@ -222,6 +225,7 @@ func runSync(ctx context.Context, m *repo_model.Mirror) ([]*mirrorSyncResult, bo
Run(&git.RunOpts{
Timeout: timeout,
Dir: repoPath,
+ Env: envs,
Stdout: &stdoutBuilder,
Stderr: &stderrBuilder,
}); err != nil {