Therapistとユーザーの安全な接続：HIPAA準拠チャットを構築

mkdir hipaa-chat-backend
cd hipaa-chat-backend
npm init -y
npm install express twilio jsonwebtoken bcrypt dotenv crypto winston

// src/auth.js
const express = require('express');
const bcrypt = require('bcrypt');
const jwt = require('jsonwebtoken');

const router = express.Router();

// 実際のアプリケーションでは、データベースを使用します
const users = [];

// ユーザー登録
router.post('/register', async (req, res) => {
    try {
        const { username, password, role } = req.body;
        const hashedPassword = await bcrypt.hash(password, 10);
        const user = { username, password: hashedPassword, role, id: users.length + 1 };
        users.push(user);
        res.status(201).send('ユーザーが登録されました');
    } catch {
        res.status(500).send();
    }
});

// ユーザーログイン
router.post('/login', async (req, res) => {
    const user = users.find(u => u.username === req.body.username);
    if (user == null) {
        return res.status(400).send('ユーザーが見つかりません');
    }
    try {
        if (await bcrypt.compare(req.body.password, user.password)) {
            // JWTを作成
            const accessToken = jwt.sign(
                { id: user.id, role: user.role },
                process.env.JWT_SECRET,
                { expiresIn: '1h' }
            );
            res.json({ accessToken });
        } else {
            res.send('許可されていません');
        }
    } catch {
        res.status(500).send();
    }
});

module.exports = router;

// src/cryptoService.js
const crypto = require('crypto');

// 実際のアプリケーションでは、これらの鍵はクライアントで生成され、
// 公開鍵はユーザーIDに対してサーバーに保存されます
const userKeys = new Map();

function generateKeysForUser(userId) {
    if (userKeys.has(userId)) {
        return userKeys.get(userId);
    }
    const { publicKey, privateKey } = crypto.generateKeyPairSync('rsa', {
        modulusLength: 2048,
    });
    userKeys.set(userId, { publicKey, privateKey });
    return { publicKey, privateKey };
}

function getPublicKeyForUser(userId) {
    if (!userKeys.has(userId)) {
        // 簡単のため、存在しない場合は鍵を生成します
        generateKeysForUser(userId);
    }
    return userKeys.get(userId).publicKey;
}

function encryptMessage(recipientPublicKey, message) {
    const bufferMessage = Buffer.from(message, 'utf8');
    const encryptedMessage = crypto.publicEncrypt(recipientPublicKey, bufferMessage);
    return encryptedMessage.toString('base64');
}

function decryptMessage(userId, encryptedMessage) {
    if (!userKeys.has(userId)) {
        throw new Error('復号化のためにユーザーの鍵が見つかりません');
    }
    const { privateKey } = userKeys.get(userId);
    const bufferEncrypted = Buffer.from(encryptedMessage, 'base64');
    const decryptedMessage = crypto.privateDecrypt(privateKey, bufferEncrypted);
    return decryptedMessage.toString('utf8');
}

module.exports = {
    generateKeysForUser,
    getPublicKeyForUser,
    encryptMessage,
    decryptMessage,
};

// src/chat.js
require('dotenv').config();
const express = require('express');
const { getPublicKeyForUser, encryptMessage } = require('./cryptoService');
const { auditLog } = require('./auditService'); // 次に作成します

const router = express.Router();
const accountSid = process.env.TWILIO_ACCOUNT_SID;
const authToken = process.env.TWILIO_AUTH_TOKEN;
const client = require('twilio')(accountSid, authToken);

// ルートを保護するミドルウェア
function authenticateToken(req, res, next) {
    const authHeader = req.headers['authorization'];
    const token = authHeader && authHeader.split(' ');
    if (token == null) return res.sendStatus(401);

    jwt.verify(token, process.env.JWT_SECRET, (err, user) => {
        if (err) return res.sendStatus(403);
        req.user = user;
        next();
    });
}


router.post('/conversations/send', authenticateToken, async (req, res) => {
    const { recipientId, message } = req.body;
    const senderId = req.user.id;

    try {
        // 1. 受信者の公開鍵を取得
        const recipientPublicKey = getPublicKeyForUser(recipientId);

        // 2. メッセージを暗号化
        const encryptedMessage = encryptMessage(recipientPublicKey, message);

        // 3. Twilio Conversationを検索または作成
        // 一意の名前により、2人のユーザーが常に同じ会話スペースを共有します
        const conversationName = `chat_${Math.min(senderId, recipientId)}_${Math.max(senderId, recipientId)}`;
        let conversation;
        try {
            conversation = await client.conversations.v1.conversations(conversationName).fetch();
        } catch (error) {
            if (error.status === 404) {
                conversation = await client.conversations.v1.conversations.create({ friendlyName: conversationName, uniqueName: conversationName });
                // 新しい会話に参加者を追加
                await client.conversations.v1.conversations(conversation.sid).participants.create({ identity: `user_${senderId}` });
                await client.conversations.v1.conversations(conversation.sid).participants.create({ identity: `user_${recipientId}` });
            } else {
                throw error;
            }
        }

        // 4. Twilio経由で暗号化されたメッセージを送信
        await client.conversations.v1.conversations(conversation.sid).messages.create({
            author: `user_${senderId}`,
            body: encryptedMessage
        });

        // 5. アクションを記録
        auditLog(senderId, 'SEND_MESSAGE', `conversation:${conversation.sid}`);

        res.status(200).send({ status: 'メッセージが安全に送信されました' });

    } catch (error) {
        console.error(error);
        res.status(500).send('メッセージの送信に失敗しました');
    }
});


module.exports = router;

// src/auditService.js
const winston = require('winston');

const logger = winston.createLogger({
    level: 'info',
    format: winston.format.json(),
    transports: [
        new winston.transports.File({ filename: 'audit.log' })
    ],
});

function auditLog(userId, action, resource) {
    logger.info({
        timestamp: new Date().toISOString(),
        userId,
        action,
        resource,
    });
}

module.exports = { auditLog };

// index.js
require('dotenv').config();
const express = require('express');
const authRouter = require('./src/auth');
const chatRouter = require('./src/chat');
const { generateKeysForUser } = require('./src/cryptoService');


const app = express();
app.use(express.json());

// テスト用のユーザーと鍵を事前に設定
generateKeysForUser(1); // 患者
generateKeysForUser(2); // セラピスト

app.use('/auth', authRouter);
app.use('/api', chatRouter);

const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
    console.log(`サーバーがポート${PORT}で実行中です`);
});