added cors & lbo_auth plugin

Author: Renz Albert Galang

.idea/micro.iml

@@ -4,15 +4,16 @@ go 1.12
 
 require (
 	github.com/chzyer/readline v0.0.0-20180603132655-2972be24d48e
-	github.com/coreos/etcd v3.3.13+incompatible // indirect
 	github.com/golang/protobuf v1.3.1
 	github.com/google/uuid v1.1.1
 	github.com/gorilla/mux v1.7.2
 	github.com/micro/cli v0.2.0
 	github.com/micro/go-micro v1.7.1-0.20190710205448-382fbecd4098
+	github.com/orangeapps/lbo-endgame v0.0.0
 	github.com/serenize/snaker v0.0.0-20171204205717-a683aaf2d516
 	github.com/xlab/treeprint v0.0.0-20181112141820-a009c3971eca
-	go.etcd.io/etcd v3.3.13+incompatible // indirect
 	golang.org/x/net v0.0.0-20190620200207-3b0461eec859
 	google.golang.org/grpc v1.21.1
 )
+
+replace github.com/orangeapps/lbo-endgame v0.0.0 => /Users/rarg/Work/lbo-endgame

.idea/misc.xml

@@ -0,0 +1,85 @@
+package auth
+
+import (
+	"bytes"
+	"context"
+	"encoding/json"
+	"github.com/micro/cli"
+	"github.com/micro/go-micro/client"
+	"github.com/micro/micro/plugin"
+	proto "github.com/orangeapps/lbo-endgame/c/auth/api"
+	"io/ioutil"
+	"log"
+	"net/http"
+)
+
+type lBOAuth struct {}
+
+func NewLBOAuth() plugin.Plugin {
+	return &lBOAuth{}
+}
+
+func (a *lBOAuth) Flags() []cli.Flag {
+	return []cli.Flag{
+		cli.StringFlag{
+			Name: "lbo_auth",
+			Usage: "Enable authentication for lbo-endgame platform.",
+		},
+	}
+}
+
+func (g *lBOAuth) Commands() []cli.Command {
+	return nil
+}
+
+func (a *lBOAuth) Handler() plugin.Handler {
+	return func(h http.Handler) http.Handler {
+		return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+			b, err := ioutil.ReadAll(r.Body)
+			if err != nil {
+				http.Error(w, http.StatusText(http.StatusBadRequest), http.StatusBadRequest)
+				return
+			}
+			c := ioutil.NopCloser(bytes.NewBuffer(b))
+			decoder := json.NewDecoder(c)
+			var t map[string]interface{}
+			err = decoder.Decode(&t)
+			if err != nil {
+				http.Error(w, http.StatusText(http.StatusBadRequest), http.StatusBadRequest)
+				return
+			}
+			method, ok := t["method"]
+			if !ok {
+				http.Error(w, http.StatusText(http.StatusBadRequest), http.StatusBadRequest)
+				return
+			}
+			if method != "AuthService.Authenticate" && method != "AuthService.Validate"  {
+				token := r.Header.Get("Token")
+				if token == "" {
+					http.Error(w, http.StatusText(http.StatusForbidden), http.StatusForbidden)
+					return
+				}
+				log.Print(token)
+				protoCli := proto.NewAuthService("c.auth", client.NewClient())
+				_, err := protoCli.Validate(context.Background(), &proto.ValidateReq{
+					AccessToken: token,
+				})
+				if err != nil {
+					log.Print(err)
+					http.Error(w, http.StatusText(http.StatusForbidden), http.StatusForbidden)
+					return
+				}
+			}
+			r.Body = ioutil.NopCloser(bytes.NewBuffer(b))
+			h.ServeHTTP(w, r)
+		})
+	}
+}
+
+func (p *lBOAuth) Init(ctx *cli.Context) error {
+	return nil
+}
+
+func (p *lBOAuth) String() string {
+	return "lbo_auth"
+}

.idea/modules.xml

@@ -0,0 +1,12 @@
+package main
+
+import (
+	"github.com/micro/go-plugins/micro/cors"
+	"github.com/micro/micro/lbo/auth"
+	"github.com/micro/micro/plugin"
+)
+
+func init() {
+	plugin.Register(auth.NewLBOAuth())
+	plugin.Register(cors.NewPlugin())
+}