80 lines
1.8 KiB
Go
80 lines
1.8 KiB
Go
package ProtoHandler
|
|
|
|
import (
|
|
"context"
|
|
"google.golang.org/grpc"
|
|
"lpm-cli/Lotus"
|
|
proto "lpm-cli/Proto/lpm/go"
|
|
"time"
|
|
)
|
|
|
|
func createConnection(address string) *grpc.ClientConn{
|
|
|
|
logger := Lotus.DetailedLogger("ProtoHandler", "createConnection")
|
|
|
|
//TODO Remove Hardcoded addr
|
|
conn, err := grpc.Dial(address, grpc.WithInsecure())
|
|
if err != nil {
|
|
logger.Fatal(err)
|
|
}
|
|
return conn
|
|
}
|
|
|
|
func createRegistryClient(conn *grpc.ClientConn) (proto.LpmRegistryClient, context.Context, context.CancelFunc) {
|
|
|
|
lrc := proto.NewLpmRegistryClient(conn)
|
|
ctx, cancel := context.WithTimeout(context.Background(), time.Second * 10)
|
|
|
|
return lrc, ctx, cancel
|
|
}
|
|
|
|
|
|
func parsePackages(res *proto.SearchResponse, reg Lotus.Registry) []Package{
|
|
var packages []Package
|
|
for _, pkg := range res.GetPackages(){
|
|
var tmpMeta PackageMetadata
|
|
tmpMeta.FillMetadata(pkg)
|
|
packages = append(packages, Package{
|
|
PackageMetadata: tmpMeta,
|
|
Register: Lotus.Registry{
|
|
Register: reg.Register,
|
|
Address: reg.Address,
|
|
},
|
|
})
|
|
}
|
|
|
|
return packages
|
|
}
|
|
|
|
func fetchPackages(platform string, architecture []string, query string) []Package{
|
|
logger := Lotus.DetailedLogger("ProtoHandler", "receiveSearchResponse")
|
|
|
|
regisitries := Lotus.GetRegistries()
|
|
|
|
var packages []Package
|
|
|
|
for _, reg := range regisitries{
|
|
conn := createConnection(reg.Address)
|
|
|
|
client, ctx, cancel := createRegistryClient(conn)
|
|
|
|
res, connErr := client.Search(ctx, &proto.SearchRequest{Platform: platform, Architecture: architecture, Query: query})
|
|
if connErr != nil{
|
|
logger.Fatal(connErr)
|
|
}
|
|
|
|
for _, pkg := range parsePackages(res, reg){
|
|
packages = append(packages, pkg)
|
|
}
|
|
|
|
cancel()
|
|
conn.Close()
|
|
}
|
|
|
|
return packages
|
|
}
|
|
|
|
func SearchPackages(platform string, architecture []string, query string) []Package {
|
|
|
|
return fetchPackages(platform, architecture, query)
|
|
}
|