基于 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 })
    }
})