@@ -6,19 +6,26 @@ const { Octokit: OctokitCore } = require("@octokit/core");
6
6
const { paginateRest } = require ( "@octokit/plugin-paginate-rest" ) ;
7
7
const { throttling } = require ( "@octokit/plugin-throttling" ) ;
8
8
const { retry } = require ( "@octokit/plugin-retry" ) ;
9
+ const pino = require ( "pino" ) ;
9
10
10
11
const { cache : octokitCachePlugin } = require ( "./lib/octokit-plugin-cache" ) ;
11
12
const { resolveRepositories } = require ( "./lib/resolve-repositories" ) ;
12
13
const { name, version } = require ( "./package.json" ) ;
13
14
15
+ const logger = pino ( ) ;
14
16
const Octokit = OctokitCore . plugin ( paginateRest , throttling , retry ) . defaults ( {
15
- log : console ,
17
+ log : {
18
+ debug : logger . debug . bind ( logger ) ,
19
+ info : logger . info . bind ( logger ) ,
20
+ warn : logger . warn . bind ( logger ) ,
21
+ error : logger . error . bind ( logger ) ,
22
+ } ,
16
23
userAgent : [ name , version ] . join ( "/" ) ,
17
24
throttle : {
18
- onAbuseLimit : ( error , options ) => {
25
+ onAbuseLimit : ( error , options , octokit ) => {
19
26
octokit . log . error ( "onAbuseLimit" , error , options ) ;
20
27
} ,
21
- onRateLimit : ( error , options ) => {
28
+ onRateLimit : ( error , options , octokit ) => {
22
29
octokit . log . error ( "onRateLimit" , error , options ) ;
23
30
} ,
24
31
} ,
@@ -69,9 +76,9 @@ async function octoherd(
69
76
const repositories = await resolveRepositories ( state , repos ) ;
70
77
71
78
for ( const repository of repositories ) {
72
- console . log ( "Running %s on %s..." , script , repository . full_name ) ;
79
+ octokit . log . info ( "Running %s on %s..." , script , repository . full_name ) ;
73
80
await userScript ( octokit , repository , userOptions ) ;
74
81
}
75
82
76
- console . log ( "\ndone. ") ;
83
+ octokit . log . info ( "done ") ;
77
84
}
0 commit comments