Skip to content

Commit 7663f0a

Browse files
committed
fix(notion): remove debug console logs
1 parent 647e7bf commit 7663f0a

File tree

2 files changed

+4
-16
lines changed

2 files changed

+4
-16
lines changed

packages/@contentlayer/source-notion/src/notion/fetchDatabasePages.ts

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -15,18 +15,15 @@ export const fetchDatabasePages = ({ databaseTypeDef }: FetchDatabasePagesArgs)
1515
S.chain((client) =>
1616
S.async<unknown, unknown, PageObjectResponse[]>(async (emit) => {
1717
let nextCursor: string | undefined = undefined
18-
console.log(`Querying pages for ${databaseTypeDef.name}`)
1918

2019
do {
21-
console.log(`Querying pages for ${databaseTypeDef.name} with cursor ${nextCursor}`)
2220
const res = await client.databases.query({
2321
database_id: databaseTypeDef.databaseId,
2422
start_cursor: nextCursor ?? undefined,
2523
filter: databaseTypeDef.query?.filter,
2624
sorts: databaseTypeDef.query?.sorts,
2725
})
2826

29-
console.log(`Found ${res.results.length} pages`)
3027
nextCursor = res.next_cursor as string | undefined // NOTE: Throw type error and make res any if not typed, why???
3128
emit.single(res.results as PageObjectResponse[])
3229
} while (nextCursor)

packages/@contentlayer/source-notion/src/notion/fetchNotion.ts

Lines changed: 4 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -5,18 +5,9 @@ const queue = new PQueue({ interval: 1000, intervalCap: 4 })
55

66
export const fetchNotion = (...args: Parameters<typeof fetch>) => {
77
return queue.add(() =>
8-
pRetry(
9-
() => {
10-
console.log(`Fetching ${args[0]}`)
11-
return fetch(...args)
12-
},
13-
{
14-
retries: 5,
15-
onFailedAttempt: async (r) => {
16-
console.warn(`WARN: Error while querying Notion, retry #${r.attemptNumber}`)
17-
await new Promise((res) => setTimeout(res, 1000))
18-
},
19-
},
20-
),
8+
pRetry(() => fetch(...args), {
9+
retries: 5,
10+
onFailedAttempt: async () => new Promise((res) => setTimeout(res, 1000)),
11+
}),
2112
) as Promise<Response>
2213
}

0 commit comments

Comments
 (0)