mirror of
https://github.com/TecharoHQ/anubis.git
synced 2025-08-03 09:48:08 -04:00

Imports a patch previously exclusive to Botstopper. Signed-off-by: Xe Iaso <me@xeiaso.net>
80 lines
2.0 KiB
Go
80 lines
2.0 KiB
Go
package thoth
|
|
|
|
import (
|
|
"context"
|
|
"crypto/tls"
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/TecharoHQ/anubis"
|
|
iptoasnv1 "github.com/TecharoHQ/thoth-proto/gen/techaro/thoth/iptoasn/v1"
|
|
grpcprom "github.com/grpc-ecosystem/go-grpc-middleware/providers/prometheus"
|
|
"github.com/grpc-ecosystem/go-grpc-middleware/v2/interceptors/timeout"
|
|
"github.com/prometheus/client_golang/prometheus"
|
|
"google.golang.org/grpc"
|
|
"google.golang.org/grpc/credentials"
|
|
"google.golang.org/grpc/credentials/insecure"
|
|
healthv1 "google.golang.org/grpc/health/grpc_health_v1"
|
|
)
|
|
|
|
type Client struct {
|
|
conn *grpc.ClientConn
|
|
health healthv1.HealthClient
|
|
IPToASN iptoasnv1.IpToASNServiceClient
|
|
}
|
|
|
|
func New(ctx context.Context, thothURL, apiToken string, plaintext bool) (*Client, error) {
|
|
clMetrics := grpcprom.NewClientMetrics(
|
|
grpcprom.WithClientHandlingTimeHistogram(
|
|
grpcprom.WithHistogramBuckets([]float64{0.001, 0.01, 0.1, 0.3, 0.6, 1, 3, 6, 9, 20, 30, 60, 90, 120}),
|
|
),
|
|
)
|
|
prometheus.DefaultRegisterer.Register(clMetrics)
|
|
|
|
do := []grpc.DialOption{
|
|
grpc.WithChainUnaryInterceptor(
|
|
timeout.UnaryClientInterceptor(500*time.Millisecond),
|
|
clMetrics.UnaryClientInterceptor(),
|
|
authUnaryClientInterceptor(apiToken),
|
|
),
|
|
grpc.WithChainStreamInterceptor(
|
|
clMetrics.StreamClientInterceptor(),
|
|
authStreamClientInterceptor(apiToken),
|
|
),
|
|
grpc.WithUserAgent(fmt.Sprint("Techaro/anubis:", anubis.Version)),
|
|
}
|
|
|
|
if plaintext {
|
|
do = append(do, grpc.WithTransportCredentials(insecure.NewCredentials()))
|
|
} else {
|
|
do = append(do, grpc.WithTransportCredentials(credentials.NewTLS(&tls.Config{})))
|
|
}
|
|
|
|
conn, err := grpc.NewClient(
|
|
thothURL,
|
|
do...,
|
|
)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("can't dial thoth at %s: %w", thothURL, err)
|
|
}
|
|
|
|
hc := healthv1.NewHealthClient(conn)
|
|
|
|
return &Client{
|
|
conn: conn,
|
|
health: hc,
|
|
IPToASN: NewIpToASNWithCache(iptoasnv1.NewIpToASNServiceClient(conn)),
|
|
}, nil
|
|
}
|
|
|
|
func (c *Client) Close() error {
|
|
if c.conn != nil {
|
|
return c.conn.Close()
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (c *Client) WithIPToASNService(impl iptoasnv1.IpToASNServiceClient) {
|
|
c.IPToASN = impl
|
|
}
|