非同期ルート

CoddyのNode.jsジャーニー「Expressの基礎」セクションの一部。レッスン 21/23。

サーバーが再起動すると、配列の内容は失われます。ファイルならデータを保持できます。

import { readFile } from 'node:fs/promises';

app.get('/api/forecast', async (req, res) => {
    const text = await readFile('data/forecast.json', 'utf8');
    res.json(JSON.parse(text));
});

ルートは、ここでは node:fs/promises の readFile を待つ、await を使った async 関数にできます。Express 5 はルートが返す Promise を監視します。ファイルがない場合や JSON が壊れている場合など、Promise が拒否されると、throw のようにエラーがエラーハンドラーに渡されます。

await を使わないと、データの代わりに Promise を保持することになり、res.json(promise) は {} を送信します。新しい data/recipes.json には4つのレシピが入っています。

チャレンジ

簡単

メモリ上の配列は、サーバーを再起動するたびに失われます。代わりにレシピをファイル data/recipes.json に保存しましょう。このファイルにはすでに4つのレシピが入っています。

routes/recipes.js で、node:fs/promises から readFile と writeFile をインポートし、../data.js から recipes をインポートするのをやめます。
ヘルパー loadRecipes() を1つ作成します。これは data/recipes.json を読み込み、解析したリストを返す非同期関数です。次のレッスンではこの名前で使用します。
ファイル内のすべてのルートを async にし、それぞれの冒頭で loadRecipes() を await します。対象は /tags、リスト、1件のレシピ、POST、スケールルートです。
POSTルートでは、新しいレシピをリストに追加した後、リスト全体をJSONテキストとして writeFile で data/recipes.json に書き戻します。
スケールルートでは、servingsのないレシピに対して、引き続きエラーをスローします。今度は非同期関数内からスローされます。Express 5はこれまでどおり、そのエラーをエラーハンドラーに渡すため、引き続きステータス500と {"error": "Something went wrong"} を返します。ルート内でエラーを捕捉しないでください。

試してみましょう：「実行」を押して /api/recipes にリクエストを送信します。同じ4つのレシピが、今度はファイルから読み込まれます。POSTを選択し、/api/recipes に {"title": "Gazpacho", "tags": ["vegan", "soup"]} を送信します。ステータス201と、"id": 5 のレシピが返ります。/api/recipes/5 を送信すると、Gazpachoが返ります。/api/recipes/99 を送信すると、ステータス404が返ります。次に、servingsがなくレシピ6になる {"title": "Toast"} をPOSTし、/api/recipes/6/scale?by=2 を送信します。ステータス500と {"error":"Something went wrong"} が返ります。データの代わりに {} が表示される場合は、await が抜けています。

自分で試してみよう

import express from 'express';
import { recipes } from '../data.js';

const router = express.Router();

// すべてのタグを、重複なくアルファベット順に。
router.get('/tags', (req, res) => {
    const tags = new Set(recipes.flatMap((recipe) => recipe.tags));
    res.json([...tags].sort());
});

router.get('/', (req, res) => {
    res.json(recipes);
});

router.get('/:id', (req, res) => {
    const recipe = recipes.find((r) => r.id === Number(req.params.id));
    if (!recipe) {
        res.status(404).json({ error: 'No such recipe' });
        return;
    }
    res.json(recipe);
});

router.post('/', (req, res) => {
    const { title, tags } = req.body;
    if (!title) {
        res.status(400).json({ error: 'A recipe needs a title' });
        return;
    }
    const recipe = { id: recipes.length + 1, title, tags: tags ?? [] };
    recipes.push(recipe);
    res.status(201).json(recipe);
});

router.get('/:id/scale', (req, res) => {
    const recipe = recipes.find((r) => r.id === Number(req.params.id));
    if (!recipe) {
        res.status(404).json({ error: 'No such recipe' });
        return;
    }
    const by = Number(req.query.by);
    if (!Number.isFinite(by) || by <= 0) {
        res.status(400).json({ error: 'Scale by a positive number' });
        return;
    }
    if (!recipe.servings) {
        throw new Error(`Recipe ${recipe.id} has no servings`);
    }
    res.json({ title: recipe.title, servings: recipe.servings * by });
});

export default router;