mirror of
https://github.com/aljazceru/ark.git
synced 2025-12-17 12:14:21 +01:00
* update UnrollClosure * update TrustedOnboarding flow + add TrustedOnboarding e2e test * fix linter: grpc.Dial * add comment * integration tests: faucet the ASP with 2 utxos
171 lines
4.6 KiB
Go
171 lines
4.6 KiB
Go
package grpcservice
|
|
|
|
import (
|
|
"context"
|
|
"crypto/tls"
|
|
"fmt"
|
|
"net/http"
|
|
"strings"
|
|
|
|
arkv1 "github.com/ark-network/ark/api-spec/protobuf/gen/ark/v1"
|
|
appconfig "github.com/ark-network/ark/internal/app-config"
|
|
interfaces "github.com/ark-network/ark/internal/interface"
|
|
"github.com/ark-network/ark/internal/interface/grpc/handlers"
|
|
"github.com/ark-network/ark/internal/interface/grpc/interceptors"
|
|
"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
|
|
log "github.com/sirupsen/logrus"
|
|
"golang.org/x/net/http2"
|
|
"golang.org/x/net/http2/h2c"
|
|
"google.golang.org/grpc"
|
|
"google.golang.org/grpc/credentials"
|
|
"google.golang.org/grpc/credentials/insecure"
|
|
grpchealth "google.golang.org/grpc/health/grpc_health_v1"
|
|
"google.golang.org/protobuf/encoding/protojson"
|
|
)
|
|
|
|
type service struct {
|
|
config Config
|
|
appConfig *appconfig.Config
|
|
server *http.Server
|
|
}
|
|
|
|
func NewService(
|
|
svcConfig Config, appConfig *appconfig.Config,
|
|
) (interfaces.Service, error) {
|
|
if err := svcConfig.Validate(); err != nil {
|
|
return nil, fmt.Errorf("invalid service config: %s", err)
|
|
}
|
|
if err := appConfig.Validate(); err != nil {
|
|
return nil, fmt.Errorf("invalid app config: %s", err)
|
|
}
|
|
|
|
grpcConfig := []grpc.ServerOption{
|
|
interceptors.UnaryInterceptor(), interceptors.StreamInterceptor(),
|
|
}
|
|
if !svcConfig.NoTLS {
|
|
return nil, fmt.Errorf("tls termination not supported yet")
|
|
}
|
|
creds := insecure.NewCredentials()
|
|
if !svcConfig.insecure() {
|
|
creds = credentials.NewTLS(svcConfig.tlsConfig())
|
|
}
|
|
grpcConfig = append(grpcConfig, grpc.Creds(creds))
|
|
|
|
// Server grpc.
|
|
grpcServer := grpc.NewServer(grpcConfig...)
|
|
appHandler := handlers.NewHandler(appConfig.AppService())
|
|
arkv1.RegisterArkServiceServer(grpcServer, appHandler)
|
|
healthHandler := handlers.NewHealthHandler()
|
|
grpchealth.RegisterHealthServer(grpcServer, healthHandler)
|
|
|
|
// Creds for grpc gateway reverse proxy.
|
|
gatewayCreds := insecure.NewCredentials()
|
|
if !svcConfig.insecure() {
|
|
gatewayCreds = credentials.NewTLS(&tls.Config{
|
|
InsecureSkipVerify: true, // #nosec
|
|
})
|
|
}
|
|
gatewayOpts := grpc.WithTransportCredentials(gatewayCreds)
|
|
conn, err := grpc.NewClient(
|
|
svcConfig.gatewayAddress(), gatewayOpts,
|
|
)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
// Reverse proxy grpc-gateway.
|
|
gwmux := runtime.NewServeMux(
|
|
runtime.WithHealthzEndpoint(grpchealth.NewHealthClient(conn)),
|
|
runtime.WithMarshalerOption("application/json+pretty", &runtime.JSONPb{
|
|
MarshalOptions: protojson.MarshalOptions{
|
|
Indent: " ",
|
|
Multiline: true,
|
|
},
|
|
UnmarshalOptions: protojson.UnmarshalOptions{
|
|
DiscardUnknown: true,
|
|
},
|
|
}),
|
|
)
|
|
ctx := context.Background()
|
|
if err := arkv1.RegisterArkServiceHandler(
|
|
ctx, gwmux, conn,
|
|
); err != nil {
|
|
return nil, err
|
|
}
|
|
grpcGateway := http.Handler(gwmux)
|
|
|
|
handler := router(grpcServer, grpcGateway)
|
|
mux := http.NewServeMux()
|
|
mux.Handle("/", handler)
|
|
|
|
httpServerHandler := http.Handler(mux)
|
|
if svcConfig.insecure() {
|
|
httpServerHandler = h2c.NewHandler(httpServerHandler, &http2.Server{})
|
|
}
|
|
|
|
server := &http.Server{
|
|
Addr: svcConfig.address(),
|
|
Handler: httpServerHandler,
|
|
TLSConfig: svcConfig.tlsConfig(),
|
|
}
|
|
|
|
return &service{svcConfig, appConfig, server}, nil
|
|
}
|
|
|
|
func (s *service) Start() error {
|
|
if s.config.insecure() {
|
|
// nolint:all
|
|
go s.server.ListenAndServe()
|
|
} else {
|
|
// nolint:all
|
|
go s.server.ListenAndServeTLS("", "")
|
|
}
|
|
log.Infof("started listening at %s", s.config.address())
|
|
|
|
if err := s.appConfig.AppService().Start(); err != nil {
|
|
return fmt.Errorf("failed to start app service: %s", err)
|
|
}
|
|
log.Info("started app service")
|
|
|
|
return nil
|
|
}
|
|
|
|
func (s *service) Stop() {
|
|
// nolint:all
|
|
s.server.Shutdown(context.Background())
|
|
log.Info("stopped grpc server")
|
|
s.appConfig.AppService().Stop()
|
|
log.Info("stopped app service")
|
|
}
|
|
|
|
func router(
|
|
grpcServer *grpc.Server, grpcGateway http.Handler,
|
|
) http.Handler {
|
|
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
if isOptionRequest(r) {
|
|
w.Header().Set("Access-Control-Allow-Origin", "*")
|
|
w.Header().Set("Access-Control-Allow-Headers", "*")
|
|
w.Header().Add("Access-Control-Allow-Methods", "POST, GET, OPTIONS")
|
|
return
|
|
}
|
|
|
|
if isHttpRequest(r) {
|
|
w.Header().Set("Access-Control-Allow-Origin", "*")
|
|
w.Header().Set("Access-Control-Allow-Headers", "*")
|
|
w.Header().Add("Access-Control-Allow-Methods", "POST, GET, OPTIONS")
|
|
|
|
grpcGateway.ServeHTTP(w, r)
|
|
return
|
|
}
|
|
grpcServer.ServeHTTP(w, r)
|
|
})
|
|
}
|
|
|
|
func isOptionRequest(req *http.Request) bool {
|
|
return req.Method == http.MethodOptions
|
|
}
|
|
|
|
func isHttpRequest(req *http.Request) bool {
|
|
return req.Method == http.MethodGet ||
|
|
strings.Contains(req.Header.Get("Content-Type"), "application/json")
|
|
}
|