53 lines
1.8 KiB
Go
53 lines
1.8 KiB
Go
package lora
|
|
|
|
import (
|
|
"git.huangwc.com/pig/pig-farm-controller/internal/infra/logs"
|
|
"github.com/go-openapi/runtime"
|
|
httptransport "github.com/go-openapi/runtime/client"
|
|
"github.com/go-openapi/strfmt"
|
|
|
|
"git.huangwc.com/pig/pig-farm-controller/internal/infra/transport/lora/chirp_stack_proto/client"
|
|
)
|
|
|
|
// ChirpStackConfig 保存连接到 ChirpStack API 所需的配置。
|
|
type ChirpStackConfig struct {
|
|
// ServerAddress 是 ChirpStack API 服务器的地址，例如 "localhost:8080"。
|
|
ServerAddress string
|
|
// APIKey 是用于认证的 API 密钥。
|
|
APIKey string
|
|
}
|
|
|
|
// GenerateAPIKey 用于补齐API Key作为请求头时缺失的部分
|
|
func (c ChirpStackConfig) GenerateAPIKey() string {
|
|
return "Bearer " + c.APIKey
|
|
}
|
|
|
|
// ChirpStackTransport 是一个客户端，用于封装与 ChirpStack REST API 的交互。
|
|
type ChirpStackTransport struct {
|
|
client *client.ChirpStackRESTAPI
|
|
authInfo runtime.ClientAuthInfoWriter
|
|
config ChirpStackConfig
|
|
|
|
logger *logs.Logger
|
|
}
|
|
|
|
// NewChirpStackTransport 创建一个新的通信实例，用于与 ChirpStack 通信。
|
|
func NewChirpStackTransport(config ChirpStackConfig, logger *logs.Logger) *ChirpStackTransport {
|
|
// 使用配置中的服务器地址创建一个 HTTP transport。
|
|
// 它会使用生成的客户端中定义的默认 base path 和 schemes。
|
|
transport := httptransport.New(config.ServerAddress, client.DefaultBasePath, client.DefaultSchemes)
|
|
|
|
// 使用 transport 和默认的字符串格式化器，创建一个 API 主客户端。
|
|
apiClient := client.New(transport, strfmt.Default)
|
|
|
|
// 使用 API Key 创建认证信息写入器。
|
|
authInfo := httptransport.APIKeyAuth("grpc-metadata-authorization", "header", config.GenerateAPIKey())
|
|
|
|
return &ChirpStackTransport{
|
|
client: apiClient,
|
|
authInfo: authInfo,
|
|
config: config,
|
|
logger: logger,
|
|
}
|
|
}
|