@@ -7,14 +7,14 @@ import (
7
7
"encoding/hex"
8
8
"errors"
9
9
"fmt"
10
- "io/ioutil "
10
+ "io"
11
11
"math"
12
12
"net/http"
13
13
"strings"
14
14
15
15
"github.com/cpanato/github_actions_exporter/model"
16
- "github.com/go-kit/kit/ log"
17
- "github.com/go-kit/kit/ log/level"
16
+ "github.com/go-kit/log"
17
+ "github.com/go-kit/log/level"
18
18
"github.com/google/go-github/v47/github"
19
19
)
20
20
@@ -36,7 +36,7 @@ func NewWorkflowMetricsExporter(logger log.Logger, opts Opts) *WorkflowMetricsEx
36
36
37
37
// handleGHWebHook responds to POST /gh_event, when receive a event from GitHub.
38
38
func (c * WorkflowMetricsExporter ) HandleGHWebHook (w http.ResponseWriter , r * http.Request ) {
39
- buf , err := ioutil .ReadAll (r .Body )
39
+ buf , err := io .ReadAll (r .Body )
40
40
if err != nil {
41
41
_ = level .Error (c .Logger ).Log ("msg" , "error reading body: %v" , err )
42
42
w .WriteHeader (http .StatusInternalServerError )
@@ -63,7 +63,7 @@ func (c *WorkflowMetricsExporter) HandleGHWebHook(w http.ResponseWriter, r *http
63
63
eventType := r .Header .Get ("X-GitHub-Event" )
64
64
switch eventType {
65
65
case "ping" :
66
- pingEvent := model .PingEventFromJSON (ioutil .NopCloser (bytes .NewBuffer (buf )))
66
+ pingEvent := model .PingEventFromJSON (io .NopCloser (bytes .NewBuffer (buf )))
67
67
if pingEvent == nil {
68
68
_ = level .Info (c .Logger ).Log ("msg" , "ping event" , "hookID" , pingEvent .GetHookID ())
69
69
w .WriteHeader (http .StatusBadRequest )
@@ -73,11 +73,11 @@ func (c *WorkflowMetricsExporter) HandleGHWebHook(w http.ResponseWriter, r *http
73
73
_ , _ = w .Write ([]byte (`{"status": "honk"}` ))
74
74
return
75
75
case "workflow_job" :
76
- event := model .WorkflowJobEventFromJSON (ioutil .NopCloser (bytes .NewBuffer (buf )))
76
+ event := model .WorkflowJobEventFromJSON (io .NopCloser (bytes .NewBuffer (buf )))
77
77
_ = level .Info (c .Logger ).Log ("msg" , "got workflow_job event" , "org" , event .GetRepo ().GetOwner ().GetLogin (), "repo" , event .GetRepo ().GetName (), "runId" , event .GetWorkflowJob ().GetRunID (), "action" , event .GetAction ())
78
78
go c .CollectWorkflowJobEvent (event )
79
79
case "workflow_run" :
80
- event := model .WorkflowRunEventFromJSON (ioutil .NopCloser (bytes .NewBuffer (buf )))
80
+ event := model .WorkflowRunEventFromJSON (io .NopCloser (bytes .NewBuffer (buf )))
81
81
_ = level .Info (c .Logger ).Log ("msg" , "got workflow_run event" , "org" , event .GetRepo ().GetOwner ().GetLogin (), "repo" , event .GetRepo ().GetName (), "workflow_name" , event .GetWorkflow ().GetName (), "runNumber" , event .GetWorkflowRun ().GetRunNumber (), "action" , event .GetAction ())
82
82
go c .CollectWorkflowRunEvent (event )
83
83
default :
0 commit comments