基於 Notion 的 P.A.R.A 實戰（二）

基於 Notion 的 P.A.R.A 實戰（二）#

自基於 Notion 的 P.A.R.A 實戰（一）發布後，這套系統又經過了些小的迭代升級，如今也使用四個月了，運行良好！

和 Obsidian 的使用體驗相比較，免去了打開軟體，手動同步數據，折騰插件頁面等複雜流程；同時 Notion 開放的 api 接口進一步提高了方便程度和可玩性，你完全可以把 Notion 當作一個支持多種視圖查看的很好用的數據庫； Calendar 的發布也帶來了我一直想要擁有的功能：在一個日曆中定制自己關心的內容，儘管現在還略顯粗糙，但是這就是我想要的功能；搭配瀏覽器的插件可以把我所有的 **「稍後在讀」** 歸攏在 Notion 裡；手機端也另外寫了一些快捷指令來支持對讀書筆記的記錄，只要複製文本再配合蘋果的 「輕點兩下」 就可以把內容同步到 Notion 了。

可以說整個使用體驗都是很絲滑的，接下來稍微介紹下我都折騰了什麼。

一，系統改動#

Resource
- 新增了 Fav 模塊，用來記錄值得多次閱讀的內容。
- 新增了 Thing 模塊，用來記錄購買的物品 / 服務的使用體驗。
Archive
- 對內容較多的 Resource 數據表添加周分組。

二，郵件服務 - 同步筆記#

郵件伺服器

使用 imap 包監聽郵件，mailparser 包解析郵件內容

參考代碼

const Imap = require('imap')
const MailParser = require('mailparser').MailParser
const moment = require('moment')
const logger = require('./logger')('sdk/logger')
let emailCount = 10
console.log('-----伺服器啟動-----' + moment().format('YYYY-MM-DD HH:mm:ss') + '-------------------------------------')

let inflag = false

function mailReceiver(userInfo, mailHandler) {
    let imap = new Imap(userInfo)
    imap.connect()
    setTimeout(() => imap.end(), 5 * 60 * 1000) // 每隔 5 分鐘重建連接

    imap.once('ready', () => {
        setTimeout(() => {
            if (!inflag) {
                logger.warn(`無法連接，進行重新連接。`)
                imap.end()
            }
        }, 30_000)

        imap.openBox('INBOX', false, () => {
            inflag = true
            imap.once('mail', num => { })
            searchUnseen(imap, mailHandler)
        })
    })

    imap.on('mail', num => {
        if (num > emailCount) return // 防止大量郵件湧入
        searchUnseen(imap, mailHandler)
    })

    imap.once('error', err => {
        logger.error(`鏈接失敗，重新鏈接 ${err.message}`)
        mailReceiver(userInfo, mailHandler)
    })

    imap.once('end', () => mailReceiver(userInfo, mailHandler))
}

function searchUnseen(imap, mailHandler) {
    let timestr = (new Date(+new Date() - (5 * 60 * 1000))).toISOString()
    imap.search(['UNSEEN', ['SINCE', timestr]], (err, results) => {
        if (err) {
            logger.error('search error' + err.mesasge)
            imap.end()
            return
        }
        if (results.length == 0) return

        try {
            let f = imap.fetch(results, { bodies: '', markSeen: true })

            f.on('message', (msg, seqno) => {
                msg.on('body', (stream, info) => {
                    let parser = new MailParser()
                    stream.pipe(parser)
                    let mail = {}
                    parser.on("headers", headers => mail.headers = headers)
                    parser.on("data", content => mail.content = content)
                    parser.on('end', () => mailHandler(mail))
                })

                msg.once('end', () => { })
            })

            f.once('error', err => {
                logger.error(`收取郵件報錯:${err.message}`)
                imap.end()
            })

            f.once('end', () => imap.end())

        } catch (err) {
            logger.error('search error' + err.mesasge)
            imap.end()
        }
    })
}

module.exports = mailReceiver

Notion 同步

Notion 的對接分內部集成和外部集成，內部集成較為簡單，獲取到 token 即可，外部集成則需要實現一整套鑑權，自用採用內部集成的方式就可以了。

詳見官方文檔：Build your first integration (notion.com)

參考代碼


const { Client } = require("@notionhq/client")

class PARA {
    constructor() {
        this.client = new Client({
            auth: process.env.NOTION_TOKEN, // 申請的 token
        })
    }

    async findPageByName(pageName) {
        const res = await this.client.databases.query({
            "database_id": this.database_id,
            filter: {
                property: 'Name',
                rich_text: {
                    equals: pageName
                },
            },
        })
        return res.results[0]
    }

    async addPage(item) {
        let { name, mediaType, author, startDate, endDate, remark, score, status, emoji, url } = item
        const page = await this.findPageByName(name)
        if (page) {
            return page
        }

        const data = {
            "parent": { "database_id":  this.database_id },
            "icon": {
                "emoji": emoji || "🥬"
            },
            "cover": {
                "external": {
                    "url": "https://upload.wikimedia.org/wikipedia/commons/6/62/Tuscankale.jpg"
                }
            },
            "properties": {
            }
        }
        if (name) data.properties.Name = {
            "title": [
                {
                    "text": {
                        "content": name
                    }
                }
            ]
        }
        if (author) data.properties.Author = {
            "rich_text": [
                {
                    "text": {
                        "content": author
                    }
                }
            ]
        }
        if (remark) data.properties.Remark = {
            "rich_text": [
                {
                    "text": {
                        "content": remark
                    }
                }
            ]
        }
        if (status) data.properties.Status = {
            "status": {
                "name": status
            }
        }
        if (startDate) data.properties.Dates = {
            "type": "date",
            "date": {
                "start": startDate,
            }
        }
        if (endDate) data.properties.Dates = {
            "type": "date",
            "date": {
                "end": endDate
            }
        }
        if (startDate && endDate) data.properties.Dates = {
            "type": "date",
            "date": {
                "start": startDate,
                "end": endDate
            }
        }
        if (mediaType) data.properties.MediaType = {
            "select": {
                "name": mediaType
            }
        }

        if (url) data.properties.Url = {
            url
        }
        if (score) data.properties.Score = { "number": score }
        return this.client.pages.create(data)
    }

    async addBlock(item, content) {
        let page = await this.findPageByName(item.name)
        if (!page) {
            page = await this.addPage({ name: pageName })
        }
        const res = await this.client.blocks.children.append({
            block_id: page.id, 
            children: [{
                "type": "paragraph",
                "paragraph": {
                    "rich_text": [{
                        "type": "text",
                        "text": {
                            "content": content,
                            "link": null
                        }
                    }],
                    "color": "default"
                }
            }]
        })
        return res.results[0]
    }
}

class ResouceseArt extends PARA {
    constructor() {
        super()
        this.database_id = '' // 你的數據庫 id
    }
}

module.exports = {
    ResouceseArt
}

**pm2運行服務 **


/**
 * Mail 監聽同步到 Notion 數據庫
 */
const mailListener = require('../sdk/mail-receiver')
const logger = require('../sdk/logger')('server/mail-sync-notion')
const { ResouceseArt, ResourceFlash, ResourceFav } = require('../sdk/notion-para')
let art = new ResouceseArt()

let userInfo = {
    user: '[email protected]',
    password: '',
    host: 'outlook.office365.com',
    port: 993,
    tls: true
}

mailListener(userInfo, async (mail) => {
    if (!mail) return
    const subject = mail.headers.get('subject')
    const text = mail.content.text
    try {
        if (subject.indexOf('flash') > -1) {
            const page = await flash.addPage({ name: text, url: text })
            logger.info('同步成功', { subject, text, page })
        } 
        
				// 其他處理邏輯
    } catch (err) {
        logger.error('同步 notion 失敗', { err })
    }
})

添加快捷指令

先在 iPhone 自帶的郵件軟體裡添加發件人賬戶，再編寫發送郵件的快捷指令，最後在設置輕點兩下選中創建的快捷指令即可。

c6850124e261a3465b9dee00725d4e5
e8ba570d858c31e49a0bb8dc0a887f9
b59d5d294bbb21fac87a3eeefd5df6b

借用 2.2 的代碼也可以添加 TelegramBot， Cli 等方式將內容同步到 Notion。