钩子规范

钩子服务本质上是一个实现了飞布钩子规范的WEB服务，可以用任意后端语言实现。

如果你希望实现其他语言的 hook SDK，需要遵从如下协议。

搭建一个可以提供Rest服务的项目

常用的编程语言实现动态注册HTTP对外访问的框架有很多，比如：

Java：Spring Boot、Spring Cloud、JAX-RS、Vert.x等；
Python：Flask、Django、Tornado、FastAPI等；
Go：Gin、Echo、Beego等；
Node.js：Express、Koa、Hapi等。
Ruby：Ruby on Rails、Sinatra、Roda等；
PHP：Laravel、Symfony、Slim等；
Rust：Rocket、Actix-web等；
Kotlin：Ktor、Spring Boot等；
Swift：Vapor、Kitura等。

这些框架都提供了丰富的功能和插件，可以方便地实现HTTP对外访问。通常来说，这些框架都支持动态注册路由和中间件，可以根据不同的URL和HTTP方法，将请求路由到相应的处理函数，从而实现动态注册HTTP对外访问。使用这些框架可以很好地提高开发效率和代码质量。

熟悉并使用handlerbars语法生成代码客户端SDK

生成钩子函数时建议使用对应语言的范型来约束出入参
模版生成最终应该包含

钩子函数出入参的对象/结构体定义，用来约束类型
全局钩子，用来钩子规范
认证钩子，用来钩子规范
查询钩子，用来钩子规范中查询类型的钩子
变更钩子，用来钩子规范中变更类型的钩子
订阅钩子，用来钩子规范中订阅类型的钩子（暂时未支持调用）
上传钩子，用来钩子规范
graphql配置，用来钩子规范

建议最终生成的对象按照key-value的格式

全局钩子，value为注册函数${function}，key为
```
BeforeOriginRequest/OnOriginRequest/OnOriginResponse
```

认证钩子，value为注册函数${function}，key为

PostAuthentication/MutatingPostAuthentication/Revalidate/PostLogout

operation钩子，key为${operationPath}, value为

{
    "mockResolve": ${function},
    "preResolve": ${function},
    "postResolve": ${function},
    "MutatingPreResolve": ${function},
    "MutatingPostResolve": ${function},
    "CustomResolve": ${function}
}

上传钩子，key为${provider}，value为

{
    "image": { // ${profile}
        "preUpload": ${function},
        "postUpload": ${funtion}
    }
}

graphql配置，主要包含以下信息

[
    {
        "apiNamespace": "todo_gql", // 自定义数据源名称
        "enableGraphQLEndpoint": true, // 是否开启graphql端点访问
        "schema": ${graphql.Schema} // 自定义的graphql解析，需要使用对应语言的sdk
    }
]

${function}为各个创建的不同目录下的文件，其中包含可执行函数，例如

全局钩子文件global/beforeRequest.(go/java/py/ts等)
认证钩子文件authentication/postAuthentication.(go/java/py/ts等)
operation钩子hooks/${operationPath}/postResolve.(go/java/py/ts等)
上传钩子uploads/${provider}/${profile}/preUpload.(go/java/py/ts等)

${function}最终需要注册到各个的接口时使用，最终流程为：

钩子接口(1.根据请求路径在注册的key/function中寻找对应钩子函数; 2.处理请求并利用范型转换入参) => 
钩子函数(自定义逻辑) => 
钩子接口(处理钩子函数返回最终提供响应)

解析飞布生成的json配置文件

文件路径${钩子项目目录}/generated/fireboom.config.json
文件内容示例如下：

{
    
    "api": {
        "operations": [
            {
                "name": "Todo__CreateOne", 
                "path": "Todo/CreateOne", // 文档中${operationPath}使用此值
                "operationType": 1 // 0 QUERY, 1 MUTATION, 2 SUBSCRIPTION
            }
        ],
        "s3UploadConfiguration": [
            {
                "name": "oss-todo", // provider name 文档中${provider}使用此值
                "uploadProfiles": {
                    "audio": { // profile name 文档中${profile}使用此值 
                        "preUpload": true,
                        "postUpload": false
                    }
                }
            }
        ],
        "serverOptions": {
            "listen": {
                "host": {
                    "staticVariableContent": "0.0.0.0" // 钩子服务启动地址
                },
                "port": {
                    "staticVariableContent": "" // 钩子服务启动端口
                }
            },
            "logger": {
                "level: {
                    "staticVariableContent": "INFO" // 钩子服务日志级别
                }
            }
        },
        "nodeOptions": {
            "nodeUrl": {
                "staticVariableContent": "http://localhost:9991" // 飞布服务内网访问地址
            },
            "publicNodeUrl": {
                "staticVariableContent": "http://ip:port" // 飞布服务对外访问地址
            }
        }
    }
}

api.operations[*].path用来过滤钩子规范生成的operation钩子函数
api.s3UploadConfiguration.name和api.s3UploadConfiguration.uploadProfiles.*用来过滤钩子规范生成的上传钩子函数
api.serverOptions.listen.port用来指定钩子服务启动端口号
api.nodeOptions.nodeUrl用来钩子规范指定baseNodeUrl

解析全局参数

所有的钩子请求都是POST请求，并且Content-Type=application/json
解析参数"__wg"，json结构如下（请dump body数据，防止后续请求使用body因为流关闭导致异常）

{
    "__wg": {
        // 原有请求的详细信息
        "clientRequest": {
            "method": "POST", // GET/POST
            "requestURI": "/operations/Todo", // request.urlPath
            "headers": {
                "Content-Type": "application/json",
                "Authorization": "Bearer st-123123"
                ...
            }, // request.headers
            "body": [11, 12, 13, 44] // request.body 转为json的body
            "originBody": [11, 12, 13, 44] // request.body 初始的body(在beforeRequest中使用)
        },
        "user": {
            ”provider“: "authing",
            "providerId": "",
            "userId": "adfa7dafy9adfha1f", // 用户ID
            ”name“: "fireboom",
            "firstName": "",
            "lastName": "",
            ”middleName“: "",
            "nickName": "fireboom.io", // 用户昵称
            "preferredUsername": "",
            ”profile“: "",
            "picture": "",
            "website": "",
            ”email“: "",
            "emailVerified": false,
            "birthDate": "",
            ”zoneInfo“: "",
            "locale": "",
            "location": "",
            ”roles“: ["admin", "user"], // 用户权限角色
            "customAttributes": [""],
            "customClaims": {}, // 自定义属性，扩展用户信息，可以通过认证钩子修改
            ”accessToken“: "", // accessToken字符串
            "rawAccessToken": [11, 12], // accessToken解析成json的字节数组
            "idToken": "", // idToken字符串
            "rawIdToken": [11, 12], // idToken解析成json的字节数组
        }
    }
}

构建internalClient 钩子规范
将全局参数和internalClient传递到后续请求中，方便后续钩子函数直接访问
全局错误统一处理，返回json格式如下

{
    "error": "error message"
}

上一页服务端Operation 下一页钩子规范bak

最后更新于1年前

这有帮助吗？

搭建一个可以提供Rest服务的项目

熟悉并使用handlerbars语法生成代码 客户端SDK

解析飞布生成的json配置文件

解析全局参数

熟悉并使用handlerbars语法生成代码客户端SDK