原代码
app.get('/todo', (req, res) => {
fs.readFile('./db.json', 'utf8', (err, data) => {
if(err) {
res.status(500).end()
} else {
res.status(200).json(JSON.parse(data))
}
})
})
app.get('/todo/:id', (req, res) => {
fs.readFile('./db.json', 'utf8', (err, data) => {
if(err) {
res.status(500).end()
} else {
let db = JSON.parse(data)
let todo = db.todos.find(item => item.id === Number.parseInt(req.params.id))
if(!todo) {
return res.status(404).end()
}
res.status(200).json(todo)
}
})
})
promisify形式代码
以上代码其实可以将读取文件部分的代码封装,但是该代码为异步回调函数,可以将这种callback
形式的异步回调api
通过promisify
转换成promise
形式,便于封装
封装的函数
const fs = require('fs')
const path = require('path')
// 将callback这种形式的异步api转换成promise的方式
const { promisify } = require('util')
const readFile = promisify(fs.readFile)
const dbPath = path.join(__dirname, './db.json')
exports.getDb = async () => {
const data = await readFile(dbPath, 'utf8')
return JSON.parse(data)
}
调用该函数
const { getDb } = require('./db');
app.get('/todo', async (req, res) => {
try {
const db = await getDb()
res.status(200).json(db.todos)
} catch(err) {
res.status(500).json({
error: err.message
})
}
})
app.get('/todo/:id', async (req, res) => {
try {
const db = await getDb()
let todo = db.todos.find(item => item.id === Number.parseInt(req.params.id))
if(!todo) {
return res.status(404).end()
}
res.status(200).json(todo)
} catch(err) {
res.status(500).json({
error: err.message
})
}
})