mirror of
https://github.com/Smaug123/gitea-repo-config
synced 2025-10-05 07:28:40 +00:00
Add ability to mirror from Gitea to GitHub (#30)
This commit is contained in:
Patrick Stevens
GitHub
@@ -17,6 +17,23 @@ type MergeStyle =
|
||||
elif s = "rebase-merge" then MergeStyle.RebaseMerge
|
||||
else failwithf "Unrecognised merge style '%s'" s
|
||||
|
||||
static member toString (s : MergeStyle) : string =
|
||||
match s with
|
||||
| Merge -> "merge"
|
||||
| RebaseMerge -> "rebase-merge"
|
||||
| Rebase -> "rebase"
|
||||
| Squash -> "squash"
|
||||
|
||||
type PushMirror =
|
||||
{
|
||||
GitHubAddress : Uri
|
||||
}
|
||||
|
||||
static member OfSerialised (s : SerialisedPushMirror) : PushMirror =
|
||||
{
|
||||
GitHubAddress = Uri s.GitHubAddress
|
||||
}
|
||||
|
||||
type NativeRepo =
|
||||
{
|
||||
DefaultBranch : string
|
||||
@@ -33,8 +50,51 @@ type NativeRepo =
|
||||
AllowRebase : bool option
|
||||
AllowRebaseExplicit : bool option
|
||||
AllowMergeCommits : bool option
|
||||
Mirror : PushMirror option
|
||||
}
|
||||
|
||||
static member Default : NativeRepo =
|
||||
{
|
||||
DefaultBranch = "main"
|
||||
Private = Some false
|
||||
IgnoreWhitespaceConflicts = Some true
|
||||
HasPullRequests = Some true
|
||||
HasProjects = Some false
|
||||
HasIssues = Some true
|
||||
HasWiki = Some false
|
||||
DefaultMergeStyle = Some MergeStyle.Rebase
|
||||
DeleteBranchAfterMerge = Some true
|
||||
AllowSquashMerge = Some true
|
||||
AllowRebaseUpdate = Some false
|
||||
AllowRebase = Some false
|
||||
AllowRebaseExplicit = Some false
|
||||
AllowMergeCommits = Some false
|
||||
Mirror = None
|
||||
}
|
||||
|
||||
member this.OverrideDefaults () =
|
||||
{
|
||||
DefaultBranch = this.DefaultBranch
|
||||
Private = this.Private |> Option.orElse NativeRepo.Default.Private
|
||||
IgnoreWhitespaceConflicts =
|
||||
this.IgnoreWhitespaceConflicts
|
||||
|> Option.orElse NativeRepo.Default.IgnoreWhitespaceConflicts
|
||||
HasPullRequests = this.HasPullRequests |> Option.orElse NativeRepo.Default.HasPullRequests
|
||||
HasProjects = this.HasProjects |> Option.orElse NativeRepo.Default.HasProjects
|
||||
HasIssues = this.HasIssues |> Option.orElse NativeRepo.Default.HasIssues
|
||||
HasWiki = this.HasWiki |> Option.orElse NativeRepo.Default.HasWiki
|
||||
DefaultMergeStyle = this.DefaultMergeStyle |> Option.orElse NativeRepo.Default.DefaultMergeStyle
|
||||
DeleteBranchAfterMerge =
|
||||
this.DeleteBranchAfterMerge
|
||||
|> Option.orElse NativeRepo.Default.DeleteBranchAfterMerge
|
||||
AllowSquashMerge = this.AllowSquashMerge |> Option.orElse NativeRepo.Default.AllowSquashMerge
|
||||
AllowRebaseUpdate = this.AllowRebaseUpdate |> Option.orElse NativeRepo.Default.AllowRebaseUpdate
|
||||
AllowRebase = this.AllowRebase |> Option.orElse NativeRepo.Default.AllowRebase
|
||||
AllowRebaseExplicit = this.AllowRebaseExplicit |> Option.orElse NativeRepo.Default.AllowRebaseExplicit
|
||||
AllowMergeCommits = this.AllowMergeCommits |> Option.orElse NativeRepo.Default.AllowMergeCommits
|
||||
Mirror = this.Mirror
|
||||
}
|
||||
|
||||
static member internal OfSerialised (s : SerialisedNativeRepo) =
|
||||
{
|
||||
NativeRepo.DefaultBranch = s.DefaultBranch
|
||||
@@ -51,6 +111,7 @@ type NativeRepo =
|
||||
AllowRebase = s.AllowRebase |> Option.ofNullable
|
||||
AllowRebaseExplicit = s.AllowRebaseExplicit |> Option.ofNullable
|
||||
AllowMergeCommits = s.AllowMergeCommits |> Option.ofNullable
|
||||
Mirror = s.Mirror |> Option.ofNullable |> Option.map PushMirror.OfSerialised
|
||||
}
|
||||
|
||||
type GitHubRepo =
|
||||
@@ -78,40 +139,65 @@ type Repo =
|
||||
Native : NativeRepo option
|
||||
}
|
||||
|
||||
static member Render (u : Gitea.Repository) : Repo =
|
||||
{
|
||||
Description = u.Description
|
||||
GitHub =
|
||||
if String.IsNullOrEmpty u.OriginalUrl then
|
||||
None
|
||||
else
|
||||
member this.OverrideDefaults () =
|
||||
{ this with
|
||||
Native = this.Native |> Option.map (fun s -> s.OverrideDefaults ())
|
||||
}
|
||||
|
||||
static member Render (client : Gitea.Client) (u : Gitea.Repository) : Repo Async =
|
||||
if not (String.IsNullOrEmpty u.OriginalUrl) then
|
||||
{
|
||||
Description = u.Description
|
||||
GitHub =
|
||||
{
|
||||
Uri = Uri u.OriginalUrl
|
||||
MirrorInterval = u.MirrorInterval
|
||||
}
|
||||
|> Some
|
||||
Native =
|
||||
if String.IsNullOrEmpty u.OriginalUrl then
|
||||
Native = None
|
||||
}
|
||||
|> async.Return
|
||||
else
|
||||
async {
|
||||
let! mirror = getAllPushMirrors client u.Owner.LoginName u.FullName
|
||||
|
||||
let mirror =
|
||||
if mirror.Length = 0 then None
|
||||
elif mirror.Length = 1 then Some mirror.[0]
|
||||
else failwith "Multiple mirrors not supported yet"
|
||||
|
||||
return
|
||||
|
||||
{
|
||||
Private = u.Private
|
||||
DefaultBranch = u.DefaultBranch
|
||||
IgnoreWhitespaceConflicts = u.IgnoreWhitespaceConflicts
|
||||
HasPullRequests = u.HasProjects
|
||||
HasProjects = u.HasProjects
|
||||
HasIssues = u.HasIssues
|
||||
HasWiki = u.HasWiki
|
||||
DefaultMergeStyle = u.DefaultMergeStyle |> Option.ofObj |> Option.map MergeStyle.Parse
|
||||
DeleteBranchAfterMerge = u.DefaultDeleteBranchAfterMerge
|
||||
AllowSquashMerge = u.AllowSquashMerge
|
||||
AllowRebaseUpdate = u.AllowRebaseUpdate
|
||||
AllowRebase = u.AllowRebase
|
||||
AllowRebaseExplicit = u.AllowRebaseExplicit
|
||||
AllowMergeCommits = u.AllowMergeCommits
|
||||
Description = u.Description
|
||||
GitHub = None
|
||||
Native =
|
||||
{
|
||||
Private = u.Private
|
||||
DefaultBranch = u.DefaultBranch
|
||||
IgnoreWhitespaceConflicts = u.IgnoreWhitespaceConflicts
|
||||
HasPullRequests = u.HasPullRequests
|
||||
HasProjects = u.HasProjects
|
||||
HasIssues = u.HasIssues
|
||||
HasWiki = u.HasWiki
|
||||
DefaultMergeStyle = u.DefaultMergeStyle |> Option.ofObj |> Option.map MergeStyle.Parse
|
||||
DeleteBranchAfterMerge = u.DefaultDeleteBranchAfterMerge
|
||||
AllowSquashMerge = u.AllowSquashMerge
|
||||
AllowRebaseUpdate = u.AllowRebaseUpdate
|
||||
AllowRebase = u.AllowRebase
|
||||
AllowRebaseExplicit = u.AllowRebaseExplicit
|
||||
AllowMergeCommits = u.AllowMergeCommits
|
||||
Mirror =
|
||||
mirror
|
||||
|> Option.map (fun m ->
|
||||
{
|
||||
GitHubAddress = Uri m.RemoteAddress
|
||||
}
|
||||
)
|
||||
}
|
||||
|> Some
|
||||
}
|
||||
|> Some
|
||||
else
|
||||
None
|
||||
}
|
||||
}
|
||||
|
||||
static member internal OfSerialised (s : SerialisedRepo) =
|
||||
{
|
||||
|
||||
@@ -76,14 +76,25 @@ module Gitea =
|
||||
config.Repos
|
||||
|> Map.toSeq
|
||||
|> Seq.map (fun (User user as u, desiredRepos) ->
|
||||
let desiredRepos = desiredRepos |> Map.map (fun _ v -> v.OverrideDefaults ())
|
||||
|
||||
async {
|
||||
let! repos =
|
||||
Array.getPaginated (fun page count ->
|
||||
client.UserListRepos (user, Some page, Some count) |> Async.AwaitTask
|
||||
)
|
||||
|
||||
let actualRepos =
|
||||
repos |> Seq.map (fun repo -> RepoName repo.Name, Repo.Render repo) |> Map.ofSeq
|
||||
let! actualRepos =
|
||||
repos
|
||||
|> Seq.map (fun repo ->
|
||||
async {
|
||||
let! rendered = Repo.Render client repo
|
||||
return RepoName repo.Name, rendered
|
||||
}
|
||||
)
|
||||
|> Async.Parallel
|
||||
|
||||
let actualRepos = Map.ofArray actualRepos
|
||||
|
||||
let errors1 =
|
||||
actualRepos
|
||||
@@ -143,57 +154,327 @@ module Gitea =
|
||||
match err with
|
||||
| AlignmentError.DoesNotExist desired ->
|
||||
async {
|
||||
let! _ =
|
||||
match desired.GitHub, desired.Native with
|
||||
| None, Some native ->
|
||||
let options = Gitea.CreateRepoOption ()
|
||||
options.Description <- desired.Description
|
||||
options.Name <- r
|
||||
options.Private <- native.Private
|
||||
options.DefaultBranch <- native.DefaultBranch
|
||||
logger.LogDebug ("Creating {User}:{Repo}", user, r)
|
||||
|
||||
try
|
||||
client.AdminCreateRepo (user, options) |> Async.AwaitTask
|
||||
with e ->
|
||||
raise (AggregateException ($"Error creating {user}:{r}", e))
|
||||
| Some github, None ->
|
||||
let options = Gitea.MigrateRepoOptions ()
|
||||
options.Description <- desired.Description
|
||||
options.Mirror <- Some true
|
||||
options.RepoName <- r
|
||||
options.RepoOwner <- user
|
||||
options.CloneAddr <- string<Uri> github.Uri
|
||||
options.Issues <- Some true
|
||||
options.Labels <- Some true
|
||||
options.Lfs <- Some true
|
||||
options.Milestones <- Some true
|
||||
options.Releases <- Some true
|
||||
options.Wiki <- Some true
|
||||
options.PullRequests <- Some true
|
||||
// TODO - migrate private status
|
||||
githubApiToken |> Option.iter (fun t -> options.AuthToken <- t)
|
||||
match desired.GitHub, desired.Native with
|
||||
| None, Some native ->
|
||||
let options = Gitea.CreateRepoOption ()
|
||||
options.Description <- desired.Description
|
||||
options.Name <- r
|
||||
options.Private <- native.Private
|
||||
options.DefaultBranch <- native.DefaultBranch
|
||||
|
||||
try
|
||||
client.RepoMigrate options |> Async.AwaitTask
|
||||
with e ->
|
||||
raise (AggregateException ($"Error migrating {user}:{r}", e))
|
||||
| None, None ->
|
||||
failwith $"You must supply exactly one of Native or GitHub for {user}:{r}."
|
||||
| Some _, Some _ ->
|
||||
failwith $"Repo {user}:{r} has both Native and GitHub set; you must set exactly one."
|
||||
let! result = client.AdminCreateRepo (user, options) |> Async.AwaitTask |> Async.Catch
|
||||
|
||||
logger.LogInformation ("Created repo {User}: {Repo}", user.ToString (), r.ToString ())
|
||||
match result with
|
||||
| Choice2Of2 e -> raise (AggregateException ($"Error creating {user}:{r}", e))
|
||||
| Choice1Of2 _ -> ()
|
||||
|
||||
match native.Mirror, githubApiToken with
|
||||
| None, _ -> ()
|
||||
| Some mirror, None -> failwith "Cannot push to GitHub mirror with an API key"
|
||||
| Some mirror, Some token ->
|
||||
logger.LogInformation ("Setting up push mirror for {User}:{Repo}", user, r)
|
||||
let options = Gitea.CreatePushMirrorOption ()
|
||||
options.SyncOnCommit <- Some true
|
||||
options.RemoteAddress <- (mirror.GitHubAddress : Uri).ToString ()
|
||||
options.RemoteUsername <- token
|
||||
options.RemotePassword <- token
|
||||
options.Interval <- "8h0m0s"
|
||||
|
||||
let! mirrors = getAllPushMirrors client user r
|
||||
|
||||
match mirrors |> Array.tryFind (fun m -> m.RemoteAddress = options.RemoteAddress) with
|
||||
| None ->
|
||||
let! _ = client.RepoAddPushMirror (user, r, options) |> Async.AwaitTask
|
||||
()
|
||||
| Some existing ->
|
||||
if existing.SyncOnCommit <> Some true then
|
||||
failwith $"sync on commit should have been true for {user}:{r}"
|
||||
|
||||
()
|
||||
| Some github, None ->
|
||||
let options = Gitea.MigrateRepoOptions ()
|
||||
options.Description <- desired.Description
|
||||
options.Mirror <- Some true
|
||||
options.RepoName <- r
|
||||
options.RepoOwner <- user
|
||||
options.CloneAddr <- string<Uri> github.Uri
|
||||
options.Issues <- Some true
|
||||
options.Labels <- Some true
|
||||
options.Lfs <- Some true
|
||||
options.Milestones <- Some true
|
||||
options.Releases <- Some true
|
||||
options.Wiki <- Some true
|
||||
options.PullRequests <- Some true
|
||||
// TODO - migrate private status
|
||||
githubApiToken |> Option.iter (fun t -> options.AuthToken <- t)
|
||||
|
||||
let! result = client.RepoMigrate options |> Async.AwaitTask |> Async.Catch
|
||||
|
||||
match result with
|
||||
| Choice2Of2 e -> raise (AggregateException ($"Error migrating {user}:{r}", e))
|
||||
| Choice1Of2 _ -> ()
|
||||
| None, None -> failwith $"You must supply exactly one of Native or GitHub for {user}:{r}."
|
||||
| Some _, Some _ ->
|
||||
failwith $"Repo {user}:{r} has both Native and GitHub set; you must set exactly one."
|
||||
|
||||
logger.LogInformation ("Created repo {User}: {Repo}", user, r)
|
||||
return ()
|
||||
}
|
||||
| err ->
|
||||
| AlignmentError.UnexpectedlyPresent ->
|
||||
async {
|
||||
logger.LogInformation (
|
||||
"Unable to reconcile: {User}, {Repo}: {Error}",
|
||||
user.ToString (),
|
||||
r.ToString (),
|
||||
err
|
||||
logger.LogError (
|
||||
"For safety, refusing to delete unexpectedly present repo: {User}, {Repo}",
|
||||
user,
|
||||
r
|
||||
)
|
||||
}
|
||||
| AlignmentError.ConfigurationDiffers (desired, actual) ->
|
||||
match desired.GitHub, actual.GitHub with
|
||||
| None, Some _
|
||||
| Some _, None ->
|
||||
async {
|
||||
logger.LogError (
|
||||
"Unable to reconcile the desire to move a repo from Gitea to GitHub or vice versa: {User}, {Repo}.",
|
||||
user,
|
||||
r
|
||||
)
|
||||
}
|
||||
| Some desiredGitHub, Some actualGitHub ->
|
||||
async {
|
||||
let mutable hasChanged = false
|
||||
let options = Gitea.EditRepoOption ()
|
||||
|
||||
if desiredGitHub.Uri <> actualGitHub.Uri then
|
||||
logger.LogError (
|
||||
"Refusing to migrate repo {User}:{Repo} to a different GitHub URL. Desired: {DesiredUrl}. Actual: {ActualUrl}.",
|
||||
user,
|
||||
r,
|
||||
desiredGitHub.Uri,
|
||||
actualGitHub.Uri
|
||||
)
|
||||
|
||||
if desiredGitHub.MirrorInterval <> actualGitHub.MirrorInterval then
|
||||
logger.LogDebug ("On {User}:{Repo}, setting {Property}", user, r, "MirrorInterval")
|
||||
options.MirrorInterval <- desiredGitHub.MirrorInterval
|
||||
hasChanged <- true
|
||||
|
||||
if desired.Description <> actual.Description then
|
||||
logger.LogDebug ("On {User}:{Repo}, setting {Property}", user, r, "Description")
|
||||
options.Description <- desired.Description
|
||||
hasChanged <- true
|
||||
|
||||
if hasChanged then
|
||||
let! result = client.RepoEdit (user, r, options) |> Async.AwaitTask
|
||||
return ()
|
||||
}
|
||||
| None, None ->
|
||||
|
||||
async {
|
||||
let mutable hasChanged = false
|
||||
let options = Gitea.EditRepoOption ()
|
||||
|
||||
if desired.Description <> actual.Description then
|
||||
options.Description <- desired.Description
|
||||
logger.LogDebug ("On {User}:{Repo}, will set {Property} property", user, r, "Description")
|
||||
hasChanged <- true
|
||||
|
||||
let desired =
|
||||
match desired.Native with
|
||||
| None ->
|
||||
failwith
|
||||
$"Expected a native section of desired for {user}:{r} since there was no GitHub, but got None"
|
||||
| Some n -> n
|
||||
|
||||
let actual =
|
||||
match actual.Native with
|
||||
| None ->
|
||||
failwith
|
||||
$"Expected a native section of actual for {user}:{r} since there was no GitHub, but got None"
|
||||
| Some n -> n
|
||||
|
||||
if desired.Private <> actual.Private then
|
||||
options.Private <- desired.Private
|
||||
logger.LogDebug ("On {User}:{Repo}, will set {Property} property", user, r, "Private")
|
||||
hasChanged <- true
|
||||
|
||||
if desired.AllowRebase <> actual.AllowRebase then
|
||||
options.AllowRebase <- desired.AllowRebase
|
||||
logger.LogDebug ("On {User}:{Repo}, will set {Property} property", user, r, "AllowRebase")
|
||||
hasChanged <- true
|
||||
|
||||
if desired.DefaultBranch <> actual.DefaultBranch then
|
||||
options.DefaultBranch <- desired.DefaultBranch
|
||||
|
||||
logger.LogDebug (
|
||||
"On {User}:{Repo}, will set {Property} property",
|
||||
user,
|
||||
r,
|
||||
"DefaultBranch"
|
||||
)
|
||||
|
||||
hasChanged <- true
|
||||
|
||||
if desired.HasIssues <> actual.HasIssues then
|
||||
options.HasIssues <- desired.HasIssues
|
||||
logger.LogDebug ("On {User}:{Repo}, will set {Property} property", user, r, "HasIssues")
|
||||
hasChanged <- true
|
||||
|
||||
if desired.HasProjects <> actual.HasProjects then
|
||||
options.HasProjects <- desired.HasProjects
|
||||
logger.LogDebug ("On {User}:{Repo}, will set {Property} property", user, r, "HasProjects")
|
||||
hasChanged <- true
|
||||
|
||||
if desired.HasWiki <> actual.HasWiki then
|
||||
options.HasWiki <- desired.HasWiki
|
||||
logger.LogDebug ("On {User}:{Repo}, will set {Property} property", user, r, "HasWiki")
|
||||
hasChanged <- true
|
||||
|
||||
if desired.HasPullRequests <> actual.HasPullRequests then
|
||||
options.HasPullRequests <- desired.HasPullRequests
|
||||
|
||||
logger.LogDebug (
|
||||
"On {User}:{Repo}, will set {Property} property",
|
||||
user,
|
||||
r,
|
||||
"HasPullRequests"
|
||||
)
|
||||
|
||||
hasChanged <- true
|
||||
|
||||
if desired.AllowMergeCommits <> actual.AllowMergeCommits then
|
||||
options.AllowMergeCommits <- desired.AllowMergeCommits
|
||||
|
||||
logger.LogDebug (
|
||||
"On {User}:{Repo}, will set {Property} property",
|
||||
user,
|
||||
r,
|
||||
"AllowMergeCommits"
|
||||
)
|
||||
|
||||
hasChanged <- true
|
||||
|
||||
if desired.AllowRebaseExplicit <> actual.AllowRebaseExplicit then
|
||||
options.AllowRebaseExplicit <- desired.AllowRebaseExplicit
|
||||
|
||||
logger.LogDebug (
|
||||
"On {User}:{Repo}, will set {Property} property",
|
||||
user,
|
||||
r,
|
||||
"AllowRebaseExplicit"
|
||||
)
|
||||
|
||||
hasChanged <- true
|
||||
|
||||
if desired.AllowRebase <> actual.AllowRebase then
|
||||
options.AllowRebase <- desired.AllowRebase
|
||||
logger.LogDebug ("On {User}:{Repo}, will set {Property} property", user, r, "AllowRebase")
|
||||
hasChanged <- true
|
||||
|
||||
if desired.AllowRebaseUpdate <> actual.AllowRebaseUpdate then
|
||||
options.AllowRebaseUpdate <- desired.AllowRebaseUpdate
|
||||
|
||||
logger.LogDebug (
|
||||
"On {User}:{Repo}, will set {Property} property",
|
||||
user,
|
||||
r,
|
||||
"AllowRebaseUpdate"
|
||||
)
|
||||
|
||||
hasChanged <- true
|
||||
|
||||
if desired.AllowSquashMerge <> actual.AllowSquashMerge then
|
||||
options.AllowSquashMerge <- desired.AllowSquashMerge
|
||||
|
||||
logger.LogDebug (
|
||||
"On {User}:{Repo}, will set {Property} property",
|
||||
user,
|
||||
r,
|
||||
"AllowSquashMerge"
|
||||
)
|
||||
|
||||
hasChanged <- true
|
||||
|
||||
if desired.DefaultMergeStyle <> actual.DefaultMergeStyle then
|
||||
options.DefaultMergeStyle <-
|
||||
desired.DefaultMergeStyle |> Option.map MergeStyle.toString |> Option.toObj
|
||||
|
||||
logger.LogDebug (
|
||||
"On {User}:{Repo}, will set {Property} property",
|
||||
user,
|
||||
r,
|
||||
"DefaultMergeStyle"
|
||||
)
|
||||
|
||||
hasChanged <- true
|
||||
|
||||
if desired.IgnoreWhitespaceConflicts <> actual.IgnoreWhitespaceConflicts then
|
||||
options.IgnoreWhitespaceConflicts <- desired.IgnoreWhitespaceConflicts
|
||||
|
||||
logger.LogDebug (
|
||||
"On {User}:{Repo}, will set {Property} property",
|
||||
user,
|
||||
r,
|
||||
"IgnoreWhitespaceConflicts"
|
||||
)
|
||||
|
||||
hasChanged <- true
|
||||
|
||||
if desired.DeleteBranchAfterMerge <> actual.DeleteBranchAfterMerge then
|
||||
options.DefaultDeleteBranchAfterMerge <- desired.DeleteBranchAfterMerge
|
||||
|
||||
logger.LogDebug (
|
||||
"On {User}:{Repo}, will set {Property} property",
|
||||
user,
|
||||
r,
|
||||
"DeleteBranchAfterMerge"
|
||||
)
|
||||
|
||||
hasChanged <- true
|
||||
|
||||
do!
|
||||
if hasChanged then
|
||||
logger.LogInformation ("Editing repo {User}:{Repo}", user, r)
|
||||
client.RepoEdit (user, r, options) |> Async.AwaitTask |> Async.Ignore
|
||||
else
|
||||
async.Return ()
|
||||
|
||||
do!
|
||||
match desired.Mirror, actual.Mirror with
|
||||
| None, None -> async.Return ()
|
||||
| None, Some m ->
|
||||
async {
|
||||
logger.LogError ("Refusing to delete push mirror for {User}:{Repo}", user, r)
|
||||
}
|
||||
| Some desired, None ->
|
||||
match githubApiToken with
|
||||
| None ->
|
||||
async {
|
||||
logger.LogCritical (
|
||||
"Cannot add push mirror for {User}:{Repo} due to lack of GitHub API token",
|
||||
user,
|
||||
r
|
||||
)
|
||||
}
|
||||
| Some token ->
|
||||
async {
|
||||
logger.LogInformation ("Setting up push mirror on {User}:{Repo}", user, r)
|
||||
let options = Gitea.CreatePushMirrorOption ()
|
||||
options.SyncOnCommit <- Some true
|
||||
options.RemoteAddress <- (desired.GitHubAddress : Uri).ToString ()
|
||||
options.RemoteUsername <- token
|
||||
options.RemotePassword <- token
|
||||
options.Interval <- "8h0m0s"
|
||||
let! _ = client.RepoAddPushMirror (user, r, options) |> Async.AwaitTask
|
||||
return ()
|
||||
}
|
||||
| Some desired, Some actual ->
|
||||
if desired <> actual then
|
||||
async { logger.LogCritical ("Push mirror on {User}:{Repo} differs.", user, r) }
|
||||
else
|
||||
async.Return ()
|
||||
}
|
||||
)
|
||||
)
|
||||
|> Async.Parallel
|
||||
@@ -213,6 +494,7 @@ module Gitea =
|
||||
match err with
|
||||
| AlignmentError.DoesNotExist desired ->
|
||||
async {
|
||||
log.LogDebug ("Creating {User}", user)
|
||||
let rand = Random ()
|
||||
|
||||
let pwd =
|
||||
@@ -271,9 +553,15 @@ module Gitea =
|
||||
|
||||
for update in updates do
|
||||
match update with
|
||||
| UserInfoUpdate.Admin (desired, _) -> body.Admin <- desired
|
||||
| UserInfoUpdate.Email (desired, _) -> body.Email <- desired
|
||||
| UserInfoUpdate.Visibility (desired, _) -> body.Visibility <- desired
|
||||
| UserInfoUpdate.Admin (desired, _) ->
|
||||
log.LogDebug ("Editing {User}, property {Property}", user, "Admin")
|
||||
body.Admin <- desired
|
||||
| UserInfoUpdate.Email (desired, _) ->
|
||||
log.LogDebug ("Editing {User}, property {Property}", user, "Email")
|
||||
body.Email <- desired
|
||||
| UserInfoUpdate.Visibility (desired, _) ->
|
||||
log.LogDebug ("Editing {User}, property {Property}", user, "Visibility")
|
||||
body.Visibility <- desired
|
||||
| UserInfoUpdate.Website (desired, actual) ->
|
||||
// Per https://github.com/go-gitea/gitea/issues/17126,
|
||||
// the website parameter can't currently be edited.
|
||||
|
||||
@@ -9,3 +9,20 @@ module GiteaClient =
|
||||
let Host = "file://" + __SOURCE_DIRECTORY__ + "/swagger.v1.json"
|
||||
|
||||
type Gitea = SwaggerClientProvider<Host>
|
||||
|
||||
let getAllPushMirrors (client : Gitea.Client) (owner : string) (repoName : string) : Gitea.PushMirror array Async =
|
||||
let rec go (page : int64) (soFar : Gitea.PushMirror array) =
|
||||
async {
|
||||
let! newPage =
|
||||
client.RepoListPushMirrors (owner, repoName, Some page, Some 100L)
|
||||
|> Async.AwaitTask
|
||||
|
||||
let soFar = Array.append soFar newPage
|
||||
|
||||
if newPage.Length < 100 then
|
||||
return soFar
|
||||
else
|
||||
return! go (page + 1L) soFar
|
||||
}
|
||||
|
||||
go 0L [||]
|
||||
|
||||
@@ -180,6 +180,27 @@
|
||||
"allowMergeCommits": {
|
||||
"type": "boolean",
|
||||
"description": "either `true` to allow merging pull requests with a merge commit, or `false` to prevent merging pull requests with merge commits."
|
||||
},
|
||||
"mirror": {
|
||||
"description": "Configure a GitHub push mirror to sync this repo to",
|
||||
"oneOf": [
|
||||
{
|
||||
"$ref": "#/definitions/SerialisedPushMirror"
|
||||
}
|
||||
]
|
||||
}
|
||||
}
|
||||
},
|
||||
"SerialisedPushMirror": {
|
||||
"type": "object",
|
||||
"description": "Information about a repo that is to be created on Gitea without syncing from GitHub.",
|
||||
"additionalProperties": false,
|
||||
"properties": {
|
||||
"gitHubAddress": {
|
||||
"type": [
|
||||
"null",
|
||||
"string"
|
||||
]
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -7,6 +7,15 @@ open Newtonsoft.Json
|
||||
|
||||
type SerialisedMergeStyle = string
|
||||
|
||||
[<RequireQualifiedAccess>]
|
||||
[<Struct>]
|
||||
[<CLIMutable>]
|
||||
[<Description "Information about a repo that is to be created on Gitea without syncing from GitHub.">]
|
||||
type SerialisedPushMirror =
|
||||
{
|
||||
GitHubAddress : string
|
||||
}
|
||||
|
||||
[<RequireQualifiedAccess>]
|
||||
[<Struct>]
|
||||
[<CLIMutable>]
|
||||
@@ -55,6 +64,9 @@ type internal SerialisedNativeRepo =
|
||||
[<JsonProperty(Required = Required.DisallowNull)>]
|
||||
[<Description "either `true` to allow merging pull requests with a merge commit, or `false` to prevent merging pull requests with merge commits.">]
|
||||
AllowMergeCommits : Nullable<bool>
|
||||
[<JsonProperty(Required = Required.DisallowNull)>]
|
||||
[<Description "Configure a GitHub push mirror to sync this repo to">]
|
||||
Mirror : Nullable<SerialisedPushMirror>
|
||||
}
|
||||
|
||||
[<Struct>]
|
||||
|
||||
@@ -32,6 +32,16 @@
|
||||
"defaultBranch": "main",
|
||||
"private": false
|
||||
}
|
||||
},
|
||||
"new-repo-mirrored": {
|
||||
"description": "A repo that's created directly on this Gitea and mirrored to GitHub",
|
||||
"native": {
|
||||
"defaultBranch": "main",
|
||||
"private": false,
|
||||
"mirror": {
|
||||
"gitHubAddress": "https://github.com/MyName/repo-name-3"
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -18,7 +18,7 @@ module TestSwaggerJson =
|
||||
Assembly.GetExecutingAssembly().Location
|
||||
|> FileInfo
|
||||
|> fun fi -> fi.Directory
|
||||
|> Utils.findFileAbove "Gitea/swagger.v1.json"
|
||||
|> Utils.findFileAbove "Gitea.Declarative.Lib/swagger.v1.json"
|
||||
|
||||
task {
|
||||
use client = new HttpClient ()
|
||||
|
||||
Reference in New Issue
Block a user