mirror of
https://github.com/tim-beatham/smegmesh.git
synced 2024-12-12 17:41:08 +01:00
d8e156f13f
Added the route path into the route object so that we can see what meshes packets are routed across.
106 lines
2.6 KiB
Go
106 lines
2.6 KiB
Go
package query
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"strings"
|
|
|
|
"github.com/jmespath/go-jmespath"
|
|
"github.com/tim-beatham/wgmesh/pkg/conf"
|
|
"github.com/tim-beatham/wgmesh/pkg/lib"
|
|
"github.com/tim-beatham/wgmesh/pkg/mesh"
|
|
)
|
|
|
|
// Querier queries a data store for the given data
|
|
// and returns data in the corresponding encoding
|
|
type Querier interface {
|
|
Query(meshId string, queryParams string) ([]byte, error)
|
|
}
|
|
|
|
type JmesQuerier struct {
|
|
manager mesh.MeshManager
|
|
}
|
|
|
|
type QueryError struct {
|
|
msg string
|
|
}
|
|
|
|
type QueryRoute struct {
|
|
Destination string `json:"destination"`
|
|
HopCount int `json:"hopCount"`
|
|
Path string `json:"path"`
|
|
}
|
|
|
|
type QueryNode struct {
|
|
HostEndpoint string `json:"hostEndpoint"`
|
|
PublicKey string `json:"publicKey"`
|
|
WgEndpoint string `json:"wgEndpoint"`
|
|
WgHost string `json:"wgHost"`
|
|
Timestamp int64 `json:"timestamp"`
|
|
Description string `json:"description"`
|
|
Routes []QueryRoute `json:"routes"`
|
|
Alias string `json:"alias"`
|
|
Services map[string]string `json:"services"`
|
|
Type conf.NodeType `json:"type"`
|
|
}
|
|
|
|
func (m *QueryError) Error() string {
|
|
return m.msg
|
|
}
|
|
|
|
// Query: queries the data
|
|
func (j *JmesQuerier) Query(meshId, queryParams string) ([]byte, error) {
|
|
mesh, ok := j.manager.GetMeshes()[meshId]
|
|
|
|
if !ok {
|
|
return nil, &QueryError{msg: fmt.Sprintf("%s does not exist", meshId)}
|
|
}
|
|
|
|
snapshot, err := mesh.GetMesh()
|
|
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
nodes := lib.Map(lib.MapValues(snapshot.GetNodes()), MeshNodeToQueryNode)
|
|
|
|
result, err := jmespath.Search(queryParams, nodes)
|
|
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
bytes, err := json.Marshal(result)
|
|
return bytes, err
|
|
}
|
|
|
|
func MeshNodeToQueryNode(node mesh.MeshNode) *QueryNode {
|
|
queryNode := new(QueryNode)
|
|
queryNode.HostEndpoint = node.GetHostEndpoint()
|
|
pubKey, _ := node.GetPublicKey()
|
|
|
|
queryNode.PublicKey = pubKey.String()
|
|
|
|
queryNode.WgEndpoint = node.GetWgEndpoint()
|
|
queryNode.WgHost = node.GetWgHost().String()
|
|
|
|
queryNode.Timestamp = node.GetTimeStamp()
|
|
queryNode.Routes = lib.Map(node.GetRoutes(), func(r mesh.Route) QueryRoute {
|
|
return QueryRoute{
|
|
Destination: r.GetDestination().String(),
|
|
HopCount: r.GetHopCount(),
|
|
Path: strings.Join(r.GetPath(), ","),
|
|
}
|
|
})
|
|
queryNode.Description = node.GetDescription()
|
|
queryNode.Alias = node.GetAlias()
|
|
queryNode.Services = node.GetServices()
|
|
queryNode.Type = node.GetType()
|
|
|
|
return queryNode
|
|
}
|
|
|
|
func NewJmesQuerier(manager mesh.MeshManager) Querier {
|
|
return &JmesQuerier{manager: manager}
|
|
}
|