| 123456789101112131415161718192021222324252627282930313233343536373839 |
- 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))
- }
|