feat: add grpc gateway

Makefile

@@ -3,6 +3,10 @@ GOVERSION := $(shell go version | cut -d ' ' -f 3 | cut -d '.' -f 2)
 .PHONY: build check fmt lint test test-race vet test-cover-html help install proto
 .DEFAULT_GOAL := build
 
+install:
+	@echo "Clean up imports..."
+	@go mod tidy -v
+
 build: ## build all
 	CGO_ENABLED=0 go build -o shield .
 
@@ -28,13 +32,3 @@ proto:
 help:
 	@grep -E '^[a-zA-Z0-9_-]+:.*?## .*$$' $(MAKEFILE_LIST) | sort | awk 'BEGIN {FS = ":.*?## "}; {printf "\033[36m%-30s\033[0m %s\n", $$1, $$2}'
 
-install: ## install required dependencies
-	@echo "> installing dependencies"
-	go get google.golang.org/protobuf/cmd/[email protected]
-	go get github.com/golang/protobuf/[email protected]
-	go get github.com/golang/protobuf/[email protected]
-	go get google.golang.org/[email protected]
-	go get google.golang.org/grpc/cmd/[email protected]
-	go get github.com/grpc-ecosystem/grpc-gateway/v2/[email protected]
-	go get github.com/grpc-ecosystem/grpc-gateway/v2/[email protected]
-	go get github.com/bufbuild/buf/cmd/[email protected]

api/handler/handler.go

@@ -0,0 +1,25 @@
+package handler
+
+import (
+	"context"
+	"fmt"
+	"net/http"
+
+	"github.com/odpf/salt/server"
+	v1 "github.com/odpf/shield/api/handler/v1"
+)
+
+type Deps struct {
+	V1 v1.Dep
+}
+
+func Register(ctx context.Context, s *server.MuxServer, gw *server.GRPCGateway, deps Deps) {
+	s.RegisterHandler("/ping", http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		fmt.Fprintf(w, "pong")
+	}))
+
+	// grpc gateway api will have version endpoints
+	s.SetGateway("/", gw)
+
+	v1.RegisterV1(ctx, s, gw, deps.V1)
+}

api/handler/v1/group.go

@@ -0,0 +1,27 @@
+package v1
+
+import (
+	"context"
+
+	shieldv1 "go.buf.build/odpf/gw/odpf/proton/odpf/shield/v1"
+)
+
+func (v Dep) ListGroups(ctx context.Context, request *shieldv1.ListGroupsRequest) (*shieldv1.ListGroupsResponse, error) {
+	panic("implement me")
+}
+
+func (v Dep) CreateGroup(ctx context.Context, request *shieldv1.CreateGroupRequest) (*shieldv1.CreateGroupResponse, error) {
+	panic("implement me")
+}
+
+func (v Dep) GetGroup(ctx context.Context, request *shieldv1.GetGroupRequest) (*shieldv1.GetGroupResponse, error) {
+	panic("implement me")
+}
+
+func (v Dep) ListGroupUsers(ctx context.Context, request *shieldv1.ListGroupUsersRequest) (*shieldv1.ListGroupUsersResponse, error) {
+	panic("implement me")
+}
+
+func (v Dep) UpdateGroup(ctx context.Context, request *shieldv1.UpdateGroupRequest) (*shieldv1.UpdateGroupResponse, error) {
+	panic("implement me")
+}

api/handler/v1/org.go

@@ -0,0 +1,23 @@
+package v1
+
+import (
+	"context"
+
+	shieldv1 "go.buf.build/odpf/gw/odpf/proton/odpf/shield/v1"
+)
+
+func (v Dep) ListOrganizations(ctx context.Context, request *shieldv1.ListOrganizationsRequest) (*shieldv1.ListOrganizationsResponse, error) {
+	panic("implement me")
+}
+
+func (v Dep) CreateOrganization(ctx context.Context, request *shieldv1.CreateOrganizationRequest) (*shieldv1.CreateOrganizationResponse, error) {
+	panic("implement me")
+}
+
+func (v Dep) GetOrganization(ctx context.Context, request *shieldv1.GetOrganizationRequest) (*shieldv1.GetOrganizationResponse, error) {
+	panic("implement me")
+}
+
+func (v Dep) UpdateOrganization(ctx context.Context, request *shieldv1.UpdateOrganizationRequest) (*shieldv1.UpdateOrganizationResponse, error) {
+	panic("implement me")
+}

api/handler/v1/project.go

@@ -0,0 +1,23 @@
+package v1
+
+import (
+	"context"
+
+	shieldv1 "go.buf.build/odpf/gw/odpf/proton/odpf/shield/v1"
+)
+
+func (v Dep) ListProjects(ctx context.Context, request *shieldv1.ListProjectsRequest) (*shieldv1.ListProjectsResponse, error) {
+	panic("implement me")
+}
+
+func (v Dep) CreateProject(ctx context.Context, request *shieldv1.CreateProjectRequest) (*shieldv1.CreateProjectResponse, error) {
+	panic("implement me")
+}
+
+func (v Dep) GetProject(ctx context.Context, request *shieldv1.GetProjectRequest) (*shieldv1.GetProjectResponse, error) {
+	panic("implement me")
+}
+
+func (v Dep) UpdateProject(ctx context.Context, request *shieldv1.UpdateProjectRequest) (*shieldv1.UpdateProjectResponse, error) {
+	panic("implement me")
+}

api/handler/v1/role.go

@@ -0,0 +1,23 @@
+package v1
+
+import (
+	"context"
+
+	shieldv1 "go.buf.build/odpf/gw/odpf/proton/odpf/shield/v1"
+)
+
+func (v Dep) ListRoles(ctx context.Context, request *shieldv1.ListRolesRequest) (*shieldv1.ListRolesResponse, error) {
+	panic("implement me")
+}
+
+func (v Dep) CreateRole(ctx context.Context, request *shieldv1.CreateRoleRequest) (*shieldv1.CreateRoleResponse, error) {
+	panic("implement me")
+}
+
+func (v Dep) GetRole(ctx context.Context, request *shieldv1.GetRoleRequest) (*shieldv1.GetRoleResponse, error) {
+	panic("implement me")
+}
+
+func (v Dep) UpdateRole(ctx context.Context, request *shieldv1.UpdateRoleRequest) (*shieldv1.UpdateRoleResponse, error) {
+	panic("implement me")
+}

api/handler/v1/user.go

@@ -0,0 +1,31 @@
+package v1
+
+import (
+	"context"
+
+	shieldv1 "go.buf.build/odpf/gw/odpf/proton/odpf/shield/v1"
+)
+
+func (v Dep) ListUsers(ctx context.Context, request *shieldv1.ListUsersRequest) (*shieldv1.ListUsersResponse, error) {
+	panic("implement me")
+}
+
+func (v Dep) CreateUser(ctx context.Context, request *shieldv1.CreateUserRequest) (*shieldv1.CreateUserResponse, error) {
+	panic("implement me")
+}
+
+func (v Dep) GetUser(ctx context.Context, request *shieldv1.GetUserRequest) (*shieldv1.GetUserResponse, error) {
+	panic("get user was called")
+}
+
+func (v Dep) GetCurrentUser(ctx context.Context, request *shieldv1.GetCurrentUserRequest) (*shieldv1.GetCurrentUserResponse, error) {
+	panic("get CURRENT user was called")
+}
+
+func (v Dep) UpdateUser(ctx context.Context, request *shieldv1.UpdateUserRequest) (*shieldv1.UpdateUserResponse, error) {
+	panic("implement me")
+}
+
+func (v Dep) UpdateCurrentUser(ctx context.Context, request *shieldv1.UpdateCurrentUserRequest) (*shieldv1.UpdateCurrentUserResponse, error) {
+	panic("implement me")
+}

api/handler/v1/v1.go

@@ -0,0 +1,22 @@
+package v1
+
+import (
+	"context"
+
+	"github.com/odpf/salt/server"
+
+	shieldv1 "go.buf.build/odpf/gw/odpf/proton/odpf/shield/v1"
+)
+
+type Dep struct {
+	shieldv1.UnimplementedShieldServiceServer
+}
+
+func RegisterV1(ctx context.Context, s *server.MuxServer, gw *server.GRPCGateway, dep Dep) {
+	gw.RegisterHandler(ctx, shieldv1.RegisterShieldServiceHandlerFromEndpoint)
+
+	s.RegisterService(
+		&shieldv1.ShieldService_ServiceDesc,
+		&dep,
+	)
+}

buf.gen.yaml

@@ -0,0 +1,19 @@
+version: v1beta1
+plugins:
+  - name: go
+    out: api/protos
+#    opt: paths=source_relative
+  - name: go-grpc
+    out: api/protos
+#    opt: paths=source_relative,require_unimplemented_servers=true
+  - name: grpc-gateway
+    out: api/protos
+#    opt: paths=source_relative
+  - name: validate
+    out: api/protos
+    opt:
+#      - paths=source_relative
+      - lang=go
+  - name: openapiv2
+    out: swagger
+

buf.lock

@@ -0,0 +1,24 @@
+# Generated by buf. DO NOT EDIT.
+version: v1
+deps:
+  - remote: buf.build
+    owner: envoyproxy
+    repository: protoc-gen-validate
+    branch: main
+    commit: bb405eae115246f0b5ccf8997136e3d8
+    digest: b1-BJUoAjBMVXaIMUNFJ5kdGr-be0QDwhDSTEDQpoxXzys=
+    create_time: 2021-08-20T15:05:15.02577Z
+  - remote: buf.build
+    owner: googleapis
+    repository: googleapis
+    branch: main
+    commit: e16155da3b4a49e48bd18cdcb029004d
+    digest: b1--CthFBW4QSXRq35NiPd7Uu9WN2xWeV9_GVRe5mbTVuI=
+    create_time: 2021-09-30T15:08:49.529359Z
+  - remote: buf.build
+    owner: grpc-ecosystem
+    repository: grpc-gateway
+    branch: main
+    commit: de24a84aed3d4d84806740946b55d947
+    digest: b1-Q-mEW3P3NR5UL8gm0pr3YWFSo5DAtrBqqgvkwH2WFWw=
+    create_time: 2021-09-08T00:32:28.231758Z

buf.yaml

@@ -0,0 +1,11 @@
+version: v1
+deps:
+  - buf.build/googleapis/googleapis
+  - buf.build/grpc-ecosystem/grpc-gateway
+  - buf.build/envoyproxy/protoc-gen-validate
+lint:
+  use:
+    - DEFAULT
+breaking:
+  use:
+    - FILE

cmd/serve.go

@@ -12,6 +12,6 @@ func serveCommand(logger log.Logger, appConfig *config.Shield) *cli.Command {
 		Short: "Start server and proxy default on port 8080",
 	}
 	c.AddCommand(proxyCommand(logger, appConfig))
-	c.AddCommand(adminCommand())
+	c.AddCommand(apiCommand(logger, appConfig))
 	return c
 }