actions/manual-approval
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Merge bac46d08b3 into 3811d88913

Browse source
This commit is contained in:
Felipe Lambert 2026-04-14 19:16:03 -07:00 • committed by GitHub
commit d2a08fb272
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
7 changed files with 66 additions and 27 deletions
Download patch file Download diff file Expand all files Collapse all files

47
main.go
View file

@ -48,22 +48,28 @@ func handleInterrupt(ctx context.Context, client *github.Client, apprv *approval
}
}
func newCommentLoopChannel(ctx context.Context, apprv *approvalEnvironment, client *github.Client, pollingInterval time.Duration) chan int {
channel := make(chan int)
type commentLoopResult struct {
exitCode int
responder string
status approvalStatus
}
func newCommentLoopChannel(ctx context.Context, apprv *approvalEnvironment, client *github.Client, pollingInterval time.Duration) chan commentLoopResult {
channel := make(chan commentLoopResult)
go func() {
for {
comments, _, err := client.Issues.ListComments(ctx, apprv.targetRepoOwner, apprv.targetRepoName, apprv.approvalIssueNumber, &github.IssueListCommentsOptions{})
if err != nil {
fmt.Printf("error getting comments: %v\n", err)
channel <- 1
channel <- commentLoopResult{exitCode: 1}
close(channel)
return
}
approved, err := approvalFromComments(comments, apprv.issueApprovers, apprv.minimumApprovals)
approved, responder, err := approvalFromComments(comments, apprv.issueApprovers, apprv.minimumApprovals)
if err != nil {
fmt.Printf("error getting approval from comments: %v\n", err)
channel <- 1
channel <- commentLoopResult{exitCode: 1}
close(channel)
return
}
@ -77,17 +83,17 @@ func newCommentLoopChannel(ctx context.Context, apprv *approvalEnvironment, clie
})
if err != nil {
fmt.Printf("error commenting on issue: %v\n", err)
channel <- 1
channel <- commentLoopResult{exitCode: 1}
close(channel)
return
}
if err = patchIssueState(ctx, client, apprv.targetRepoOwner, apprv.targetRepoName, apprv.approvalIssueNumber, newState); err != nil {
fmt.Printf("error closing issue: %v\n", err)
channel <- 1
channel <- commentLoopResult{exitCode: 1}
close(channel)
return
}
channel <- 0
channel <- commentLoopResult{exitCode: 0, responder: responder, status: approvalStatusApproved}
fmt.Println("Workflow manual approval completed")
close(channel)
return
@ -106,17 +112,17 @@ func newCommentLoopChannel(ctx context.Context, apprv *approvalEnvironment, clie
})
if err != nil {
fmt.Printf("error commenting on issue: %v\n", err)
channel <- 1
channel <- commentLoopResult{exitCode: 1}
close(channel)
return
}
if err = patchIssueState(ctx, client, apprv.targetRepoOwner, apprv.targetRepoName, apprv.approvalIssueNumber, newState); err != nil {
fmt.Printf("error closing issue: %v\n", err)
channel <- 1
channel <- commentLoopResult{exitCode: 1}
close(channel)
return
}
channel <- 1
channel <- commentLoopResult{exitCode: 1, responder: responder, status: approvalStatusDenied}
close(channel)
return
}
@ -302,25 +308,32 @@ func main() {
commentLoopChannel := newCommentLoopChannel(ctx, apprv, client, pollingInterval)
select {
case exitCode := <-commentLoopChannel:
case result := <-commentLoopChannel:
approvalStatus := ""
if (!failOnDenial && exitCode == 1) {
if result.status == approvalStatusApproved {
approvalStatus = "approved"
} else if result.status == approvalStatusDenied {
approvalStatus = "denied"
exitCode = 0
} else if (exitCode == 1) {
} else if (!failOnDenial && result.exitCode == 1) {
approvalStatus = "denied"
} else if (result.exitCode == 1) {
approvalStatus = "denied"
} else {
approvalStatus = "approved"
}
outputs := map[string]string {
"approval-status": approvalStatus,
"issue-responder": result.responder,
}
if _, err := apprv.SetActionOutputs(outputs); err != nil {
fmt.Printf("error setting action output: %v\n", err)
exitCode = 1
result.exitCode = 1
}
os.Exit(exitCode)
if !failOnDenial && result.exitCode == 1 {
result.exitCode = 0
}
os.Exit(result.exitCode)
case <-killSignalChannel:
handleInterrupt(ctx, client, apprv)
os.Exit(1)