如何在node-oidc-provider的DCR前验证请求体且不影响后续流程？

问题根源在于HTTP请求体是一次性可读流，自定义函数读取流后，后续流程无法再次消费该流，导致读取失败。以下是三种可行的解决方法：

方法1：利用koa-bodyparser解析请求体（推荐） #

node-oidc-provider基于koa框架，配合koa-bodyparser中间件可以提前解析请求体并缓存，避免流被重复消费的问题：

1. 先安装依赖：

npm install koa-bodyparser

2. 修改Provider代码：

import Provider from 'oidc-provider';
import bodyParser from 'koa-bodyparser';
import { configuration } from './configuration.js';

const provider = new Provider('http://localhost:3000', configuration);

// 先添加body解析中间件，确保请求体被提前解析并缓存
provider.use(bodyParser());

provider.use(async (ctx, next) => {
    if (ctx.path === "/reg") {
        console.log("DCR was called...");
        // 直接从ctx.request.body获取已解析的请求体
        const clientMetadata = ctx.request.body;
        
        // 执行验证逻辑，示例：检查必填字段client_name
        if (!clientMetadata?.client_name) {
            ctx.status = 400;
            ctx.body = {
                error: 'invalid_client_metadata',
                error_description: 'client_name是必填字段'
            };
            return; // 验证失败直接终止流程
        }
    }

    await next();
    
    console.log('post middleware', ctx.method, ctx.oidc.route);
});

provider.listen(3000, () => {
    console.log('oidc-provider listening on port 3000, check http://localhost:3000/.well-known/openid-configuration');
});

方法2：手动缓存请求体并重置可读流 #

如果不想引入额外中间件，可手动读取流后将内容缓存，并创建新的可读流替换原请求对象：

1. 修改请求体读取函数：

import { Readable } from 'stream';

export const getRequestBody = async function (ctx) {
    // 若已缓存直接返回，避免重复读取
    if (ctx.request.bodyCache) {
        return ctx.request.bodyCache;
    }

    return new Promise((resolve, reject) => {
        let requestBody = '';
        const req = ctx.req;

        req.on('data', (chunk) => {
            requestBody += chunk;
        });

        req.on('end', () => {
            // 缓存请求体到ctx对象
            ctx.request.bodyCache = requestBody;
            // 创建新的可读流，让后续流程可重新读取内容
            const newReq = new Readable();
            newReq.push(requestBody);
            newReq.push(null); // 标记流结束
            ctx.req = newReq;

            resolve(requestBody);
        });

        req.on('error', (error) => {
            reject(error);
        });
    });
};

2. 在中间件中使用：

import Provider from 'oidc-provider';
import { getRequestBody } from './your-path.js';
import { configuration } from './configuration.js';

const provider = new Provider('http://localhost:3000', configuration);

provider.use(async (ctx, next) => {
    if (ctx.path === "/reg") {
        console.log("DCR was called...");
        try {
            const rawBody = await getRequestBody(ctx);
            // 解析为JSON格式（DCR请求通常为application/json）
            const clientMetadata = JSON.parse(rawBody);
            
            // 执行验证逻辑
            if (!clientMetadata?.client_name) {
                ctx.status = 400;
                ctx.body = {
                    error: 'invalid_client_metadata',
                    error_description: 'client_name是必填字段'
                };
                return;
            }
        } catch (err) {
            ctx.status = 400;
            ctx.body = {
                error: 'invalid_request',
                error_description: '请求体解析失败'
            };
            return;
        }
    }

    await next();
    
    console.log('post middleware', ctx.method, ctx.oidc.route);
});

provider.listen(3000, () => {
    console.log('oidc-provider listening on port 3000, check http://localhost:3000/.well-known/openid-configuration');
});

方法3：使用oidc-provider内置的DCR验证钩子（最优雅） #

oidc-provider提供了针对动态客户端注册的扩展钩子，无需手动处理请求体，直接在配置中定义验证逻辑：

修改configuration.js：

import { errors } from 'oidc-provider';

export const configuration = {
    // 其他原有配置...
    clientRegistrationEndpoint: {
        // 注册前的验证钩子，provider已自动解析客户端元数据
        validate: async (ctx, clientMetadata) => {
            // 执行验证逻辑
            if (!clientMetadata.client_name) {
                throw new errors.InvalidClientMetadata('client_name是必填字段');
            }
            
            // 验证通过则直接返回，后续流程正常执行
        }
    }
};

这种方法完全贴合框架设计，无需处理请求体读取的问题，是最优解。

内容的提问来源于stack exchange，提问作者Ranieri Mazili