policy.go

package policy

import (
	"context"

	"github.com/micro/go-micro/client"
	"github.com/micro/go-micro/server"
	"unistack.org/centralv2/service/policy/policypb"
)

func NewHandlerWrapper(copts ...client.Option) server.HandlerWrapper {
	return func(fn server.HandlerFunc) server.HandlerFunc {
		return func(ctx context.Context, req server.Request, rsp interface{}) error {
			pc := policypb.NewPolicyService(policypb.SvcName, client.NewClient(copts...))
			preq := &policypb.PolicyCheckReq{
				Action:   req.Service() + "." + req.Endpoint(),
				User:     uid,
				Resource: rid,
			}
			_, err := pc.Check(ctx, preq)
			if err == nil {
				err = fn(ctx, req, rsp)
			}
			return err
		}
	}
}