diff --git a/src/notion/utils/properties/relationPropertyToPageIds.ts b/src/notion/utils/properties/relationPropertyToPageIds.ts index 06518b2..b6ea6b8 100644 --- a/src/notion/utils/properties/relationPropertyToPageIds.ts +++ b/src/notion/utils/properties/relationPropertyToPageIds.ts @@ -11,6 +11,5 @@ export function relationPropertyToPageIds( `Property ${propName} was expected to have type "relation" but got "${propValue.type}".` ); } - propValue.re; return propValue.relation.map((v) => v.id); } diff --git a/src/notion/utils/queryAllDbResults.ts b/src/notion/utils/queryAllDbResults.ts index 858dca2..b59e1ff 100644 --- a/src/notion/utils/queryAllDbResults.ts +++ b/src/notion/utils/queryAllDbResults.ts @@ -37,10 +37,21 @@ export async function queryAllDbResults( console.log("reading from cache entry " + cacheEntryFileName); return await readCacheEntry(cacheEntryFileName); } + const fullResponse = await doQueryAllDbResults(notion, dbQuery); + if (await shouldWriteCacheEntry(cacheConfig)) { + await writeCacheEntry(cacheEntryFileName, fullResponse); + } + return fullResponse; +} + +async function doQueryAllDbResults( + notion: Client, + dbQuery: QueryDatabaseParameters +): Promise { const dbResponse = await notion.databases.query(dbQuery); let fullResponse = []; if (dbResponse.has_more && dbResponse.next_cursor) { - const moreResults = await queryAllDbResults(notion, { + const moreResults = await doQueryAllDbResults(notion, { ...dbQuery, start_cursor: dbResponse.next_cursor, }); @@ -48,9 +59,6 @@ export async function queryAllDbResults( } else { fullResponse = dbResponse.results; } - if (await shouldWriteCacheEntry(cacheConfig)) { - await writeCacheEntry(cacheEntryFileName, fullResponse); - } return fullResponse; }