Added import status

Author: phpusr

package-lock.json

@@ -11,6 +11,7 @@
   "author": "",
   "license": "ISC",
   "dependencies": {
-    "@tryfabric/martian": "^1.2.4"
+    "@tryfabric/martian": "^1.2.4",
+    "pg": "^8.11.3"
   }
 }

package.json

@@ -0,0 +1,17 @@
+import pg from 'pg'
+
+const pool = new pg.Pool({
+  host: 'localhost',
+  database: 'notion',
+  user: 'phpusr'
+})
+
+//await addNoteInfo({ title: 'test', filePath: 'testpath', imported: true })
+
+export async function addNoteInfo({ 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)
+}
+

src/db.js

@@ -1,13 +1,14 @@
-import { readdirSync, readFileSync, lstatSync } from 'node:fs'
-import { markdownToBlocks, markdownToRichText } from '@tryfabric/martian'
+import { lstatSync, readdirSync, readFileSync } from 'node:fs'
+import { markdownToBlocks } from '@tryfabric/martian'
 import { addBlocks, createPage } from './notion_api.js'
+import { addNoteInfo } from './db.js'
 
 
 await importNotes()
 
 async function importNotes() {
   const notesDir = '/home/phpusr/tmp/notes/NOTES/car';
-  const files = readdirSync(notesDir, {recursive: true}).slice(0, 2)
+  const files = readdirSync(notesDir, {recursive: true}).slice(0, 6)
 
   for (const relFilePath of files) {
     const filePath = `${notesDir}/${relFilePath}`
@@ -29,11 +30,20 @@ async function importNotes() {
     console.log(`\n${relFilePath}`)
     console.log('-'.repeat(30) + '\n')
     //console.log(data);
+
+    const noteInfo = { noteId: page.id, title: relFilePath, filePath: relFilePath  }
+
     const blocks = markdownToBlocks(data)
     try {
-      const res = await addBlocks({parentId: page.id, blocks})
+      await addBlocks({ parentId: page.id, blocks })
+      noteInfo.imported = true
     } catch (e) {
-      console.error('ERROR', JSON.stringify(e))
+      noteInfo.imported = false
+      noteInfo.error = JSON.stringify(e)
+      console.error('ERROR')
     }
+
+    await addNoteInfo(noteInfo)
   }
 }
+