mirror of
https://github.com/OliveTin/OliveTin
synced 2025-12-12 17:15:37 +00:00
40 lines
1.0 KiB
Go
40 lines
1.0 KiB
Go
package restapi
|
|
|
|
import (
|
|
"context"
|
|
"github.com/grpc-ecosystem/grpc-gateway/runtime"
|
|
log "github.com/sirupsen/logrus"
|
|
"google.golang.org/grpc"
|
|
"net/http"
|
|
|
|
gw "github.com/jamesread/OliveTin/gen/grpc"
|
|
|
|
cors "github.com/jamesread/OliveTin/internal/cors"
|
|
|
|
config "github.com/jamesread/OliveTin/internal/config"
|
|
)
|
|
|
|
var (
|
|
cfg *config.Config
|
|
)
|
|
|
|
func Start(listenAddressRest string, listenAddressGrpc string, globalConfig *config.Config) error {
|
|
cfg = globalConfig
|
|
|
|
ctx := context.Background()
|
|
ctx, cancel := context.WithCancel(ctx)
|
|
defer cancel()
|
|
|
|
// The JSONPb.EmitDefaults is necssary, so "empty" fields are returned in JSON.
|
|
mux := runtime.NewServeMux(runtime.WithMarshalerOption(runtime.MIMEWildcard, &runtime.JSONPb{OrigName: true, EmitDefaults: true}))
|
|
opts := []grpc.DialOption{grpc.WithInsecure()}
|
|
|
|
err := gw.RegisterOliveTinApiHandlerFromEndpoint(ctx, mux, listenAddressGrpc, opts)
|
|
|
|
if err != nil {
|
|
log.Fatalf("gw error %v", err)
|
|
}
|
|
|
|
return http.ListenAndServe(listenAddressRest, cors.AllowCors(mux))
|
|
}
|