Added loading imported notes

Author: phpusr

src/db.js

@@ -6,12 +6,17 @@ const pool = new pg.Pool({
   user: 'phpusr'
 })
 
-//await addNoteInfo({ title: 'test', filePath: 'testpath', imported: true })
+export async function loadImportStatuses() {
+  const res = await pool.query({
+    text: 'SELECT * FROM imported_notes'
+  })
+  return res.rows
+}
 
 export async function addImportStatus({ noteId, title, filePath, imported, error }) {
-  const text = 'INSERT INTO imported_notes(note_id, title, file_path, imported, error) VALUES($1, $2, $3, $4, $5)'
-  const values = [noteId, title, filePath, imported, error]
-  const res = await pool.query(text, values)
-  //console.log(res)
+  await pool.query({
+    text: 'INSERT INTO imported_notes("noteId", title, "filePath", imported, error) VALUES($1, $2, $3, $4, $5)',
+    values: [noteId, title, filePath, imported, error]
+  })
 }
 

src/index.js

@@ -1,14 +1,18 @@
 import { lstatSync, readdirSync, readFileSync } from 'node:fs'
 import { markdownToBlocks } from '@tryfabric/martian'
 import { addBlocks, createPage } from './notion_api.js'
-import { addImportStatus } from './db.js'
+import { addImportStatus, loadImportStatuses } from './db.js'
 
 
 const notesDir = '/home/phpusr/tmp/notes/NOTES/car'
 const importedNotes = {}
 await importNotes()
 
 async function importNotes() {
+  const importedNoteList = await loadImportStatuses()
+  importedNoteList.forEach(noteInfo => importedNotes[noteInfo.filePath] = noteInfo)
+  console.info(`\nLoaded already imported ${importedNoteList.length} notes`)
+
   // noinspection JSValidateTypes
   const files = readdirSync(notesDir, { recursive: true })
     .filter(it => lstatSync(`${notesDir}/${it}`).isFile())
@@ -17,7 +21,7 @@ async function importNotes() {
   for (const relFilePath of files) {
     const progress = Math.round(++fileIndex / files.length * 100)
     console.log(`\n[${progress}%][${fileIndex}/${files.length}] ${relFilePath}`)
-    console.log('-'.repeat(30) + '\n')
+    console.log('-'.repeat(100) + '\n')
 
     const parentId = await createParentNotes(relFilePath)
 
@@ -38,6 +42,8 @@ async function importNotes() {
     //console.log(noteInfo)
     await saveNoteToNotion(noteInfo)
   }
+
+  console.info('\nDONE')
 }
 
 async function createParentNotes(relFilePath) {
@@ -61,7 +67,7 @@ async function createParentNotes(relFilePath) {
 
 async function saveNoteToNotion(noteInfo) {
   if (importedNotes.hasOwnProperty(noteInfo.filePath)) {
-    console.info(`Note "${noteInfo.filePath}" already exists`)
+    console.info(` - Note "${noteInfo.filePath}" already exists`)
     return importedNotes[noteInfo.filePath]
   }
 
@@ -76,7 +82,7 @@ async function saveNoteToNotion(noteInfo) {
       await addBlocks({parentId: page.id, blocks})
     } catch (e) {
       noteInfo.imported = false
-      noteInfo.error = e
+      noteInfo.error = e.body || e
       console.error('ERROR')
     }
   }

src/notion_api.js

@@ -13,7 +13,7 @@ export async function createPage({ title, pageId }) {
     if (!rootPageId) {
       // Creating root page with date
       rootPageId = (await createPage({
-        title: new Date().toLocaleDateString(),
+        title: new Date().toLocaleString(),
         pageId: ROOT_PAGE_ID
       })).id
     }