grpc_fx

type GRPCConfig struct {
	Enabled bool   `json:"enabled" default:"true"`
	Addr    string `json:"addr" default:":7070"`
}

type GRPCServerInputResult struct {
	fx.Out

	UnaryInterceptors  []grpc.UnaryServerInterceptor  `group:"grpc_unary_server_interceptor,flatten"`
	StreamInterceptors []grpc.StreamServerInterceptor `group:"grpc_stream_server_interceptor,flatten"`
	Services           []RegisterFn                   `group:"service,flatten"`
}

type GRPCServerParams struct {
	fx.In

	Lifecycle fx.Lifecycle
	OnErrorCh chan error

	Log        *zap.SugaredLogger
	GRPCConfig GRPCConfig

	UnaryInterceptors  []grpc.UnaryServerInterceptor  `group:"grpc_unary_server_interceptor"`
	StreamInterceptors []grpc.StreamServerInterceptor `group:"grpc_stream_server_interceptor"`
	Services           []RegisterFn                   `group:"service"`
}

type GatewayConfig struct {
	Enabled      bool          `json:"enabled" default:"true"`
	Addr         string        `json:"addr" default:":8080"`
	ReadTimeout  time.Duration `json:"read_timeout" default:"30s"`
	WriteTimeout time.Duration `json:"write_timeout" default:"30s"`
	IdleTimeout  time.Duration `json:"idle_timeout" default:"120s"`
}

type GatewayInputResult struct {
	fx.Out

	ServeMuxOptions []runtime.ServeMuxOption `group:"grpc_gateway_serve_mux_options,flatten"`
}

type GatewayParams struct {
	fx.In

	Lifecycle fx.Lifecycle
	OnErrorCh chan error

	Log            *zap.SugaredLogger
	TracerProvider trace.TracerProvider
	GRPCConfig     GRPCConfig
	GatewayConfig  GatewayConfig

	Services        []RegisterFn                      `group:"service"`
	ServeMuxOptions []runtime.ServeMuxOption          `group:"grpc_gateway_serve_mux_options"`
	HTTPMiddleware  []func(http.Handler) http.Handler `group:"http_middleware"`
}

type HandlerRegisterFn func(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

type RegisterFn func() (string, ServerRegisterFn, HandlerRegisterFn)

type ServerRegisterFn func(*grpc.Server)