linkpool/bridges

Bridges - Chainlink适配器框架


Bridges是Chainlink生态的适配器开发框架，旨在降低开发者创建自定义适配器的技术门槛：

• 提供经过测试的可靠库，无需自行构建HTTP服务器，专注适配器核心逻辑；
• 简单接口设计，快速实现符合Chainlink schema的适配器；
• 持续更新兼容新功能，现有适配器无需额外修改即可适配；
• 支持AWS Lambda、GCP Functions等无服务器环境运行。

目录

1. 代码示例
2. Docker运行
3. AWS Lambda部署
4. GCP Functions部署
5. 示例实现

代码示例

• ***Compare：基础示例；
• API聚合器：多端点数据聚合；
• Wolfram Alpha：非JSON接口处理；
• Gas Station：无认证单一响应；
• https://github.com/***%EF%BC%9A%E5%A4%9A%E4%BA%A4%E6%98%93%E6%89%80%E4%BB%B7%E6%A0%BC%E8%81%9A%E5%90%88%E3%80%82

Docker运行

参考示例Dockerfile构建镜像，模板如下：

dockerfile
FROM golang:1.16-alpine AS builder
WORKDIR /app
COPY . .
RUN go build -o bridge

FROM alpine:latest
WORKDIR /app
COPY --from=builder /app/bridge .
CMD ["./bridge"]

AWS Lambda部署

1. 构建Linux可执行文件：

bash
GO111MODULE=on GOOS=linux GOARCH=amd64 go build -o bridge

2. 打包成ZIP：

bash
zip bridge.zip ./bridge

3. 上传至AWS Lambda，设置处理程序为bridge，环境变量LAMBDA=true。

GCP Functions部署

1. 实现要求：
   • 适配器不在main包；
   • 添加Handler函数：

   go
   func Handler(w http.ResponseWriter, r *http.Request) {
       bridges.NewServer(&YourAdapter{}).Handler(w, r)
   }
   

   • 子包包含go.mod和go.sum；
2. 部署命令：

bash
gcloud functions deploy bridge --runtime go111 --entry-point Handler --trigger-http

示例实现

基础示例

go
package main
import "github.com/linkpoolio/bridges"

type MyAdapter struct{}
func (ma *MyAdapter) Run(h *bridges.Helper) (interface{}, error) {
    return map[string]string{"newValue": h.GetParam("value")}, nil
}
func (ma *MyAdapter) Opts() *bridges.Opts { return &bridges.Opts{Name: "MyAdapter", Lambda: true} }
func main() { bridges.NewServer(&MyAdapter{}).Start(8080) }

未认证HTTP调用

go
package main
import ("github.com/linkpoolio/bridges"; "net/http")

type GasStation struct{}
func (gs *GasStation) Run(h *bridges.Helper) (interface{}, error) {
    obj := map[string]interface{}{}
    err := h.HTTPCall(http.MethodGet, "https://ethgasstation.info/json/ethgasAPI.json", &obj)
    return obj, err
}
func (gs *GasStation) Opts() *bridges.Opts { return &bridges.Opts{Name: "GasStation", Lambda: true} }
func main() { bridges.NewServer(&GasStation{}).Start(8080) }

认证HTTP调用

go
package main
import ("github.com/linkpoolio/bridges"; "net/http"; "os"; "fmt")

type WolframAlpha struct{}
func (wa *WolframAlpha) Run(h *bridges.Helper) (interface{}, error) {
    b, err := h.HTTPCallRawWithOpts(http.MethodGet, "https://api.wolframalpha.com/v1/result", 
        bridges.CallOpts{
            Auth: bridges.NewAuth(bridges.AuthParam, "appid", os.Getenv("APP_ID")),
            Query: map[string]interface{}{"i": h.GetParam("query")},
        })
    return fmt.Sprint(b), err
}
func (wa *WolframAlpha) Opts() *bridges.Opts { return &bridges.Opts{Name: "WolframAlpha", Lambda: true} }
func main() { bridges.NewServer(&WolframAlpha{}).Start(8080) }

贡献

欢迎提交issue或PR，共同完善框架功能。