1+ import * as logfire from '@pydantic/logfire-api'
12import { instrument } from '@pydantic/logfire-cf-workers' ;
23
34const handler = {
@@ -7,6 +8,7 @@ const handler = {
78 try {
89 // Handle stars page
910 if ( url . pathname === '/stars' ) {
11+ logfire . info ( 'search params {search}' , { search : url . searchParams } )
1012 const repo = url . searchParams . get ( 'repo' )
1113 const group = ( url . searchParams . get ( 'group' ) as 'day' | 'week' | 'month' ) || 'day'
1214
@@ -63,7 +65,7 @@ async function fetchStars(repo: string, env: Env): Promise<[Date[], string]> {
6365
6466 const log = ( msg : string ) => {
6567 logLines . push ( msg )
66- console . log ( msg )
68+ logfire . info ( 'fetch log: { msg}' , { msg } )
6769 }
6870
6971 async function getPages ( ) : Promise < void > {
@@ -80,6 +82,9 @@ async function fetchStars(repo: string, env: Env): Promise<[Date[], string]> {
8082 break
8183 }
8284 const response = await fetch ( url , { headers } )
85+ if ( ! ongoing ) {
86+ break
87+ }
8388 if ( response . status == 422 ) {
8489 log ( `WARNING: GitHub API hit pagination limit, stopping (url: ${ url } )` )
8590 ongoing = false
@@ -89,7 +94,6 @@ async function fetchStars(repo: string, env: Env): Promise<[Date[], string]> {
8994 const text = await response . text ( )
9095 throw new Error ( `GitHub API error: GET ${ url } -> ${ response . status } , response:\n${ text } ` )
9196 }
92- // console.log('headers:', Object.fromEntries(response.headers.entries()))
9397
9498 const data = await response . json < ResponseData [ ] > ( )
9599 if ( data . length === 0 ) {
0 commit comments