Unverified Commit 1cc1b53c authored by Simon Esposito's avatar Simon Esposito Committed by GitHub
Browse files

Add API for demoting group members (#445) 

Implement go runtime structured logger
parent 8fc8626b

apigrpc/apigrpc.pb.go

+181 −141

File changed.

Preview size limit exceeded, changes collapsed.

apigrpc/apigrpc.pb.gw.go

+113 −0
Original line number Diff line number Diff line
@@ -2542,6 +2542,75 @@ func local_request_Nakama_PromoteGroupUsers_0(ctx context.Context, marshaler run 


}



var (

	filter_Nakama_DemoteGroupUsers_0 = &utilities.DoubleArray{Encoding: map[string]int{"group_id": 0}, Base: []int{1, 1, 0}, Check: []int{0, 1, 2}}

)



func request_Nakama_DemoteGroupUsers_0(ctx context.Context, marshaler runtime.Marshaler, client NakamaClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {

	var protoReq api.DemoteGroupUsersRequest

	var metadata runtime.ServerMetadata



	var (

		val string

		ok  bool

		err error

		_   = err

	)



	val, ok = pathParams["group_id"]

	if !ok {

		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "group_id")

	}



	protoReq.GroupId, err = runtime.String(val)



	if err != nil {

		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "group_id", err)

	}



	if err := req.ParseForm(); err != nil {

		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)

	}

	if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_Nakama_DemoteGroupUsers_0); err != nil {

		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)

	}



	msg, err := client.DemoteGroupUsers(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))

	return msg, metadata, err



}



func local_request_Nakama_DemoteGroupUsers_0(ctx context.Context, marshaler runtime.Marshaler, server NakamaServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {

	var protoReq api.DemoteGroupUsersRequest

	var metadata runtime.ServerMetadata



	var (

		val string

		ok  bool

		err error

		_   = err

	)



	val, ok = pathParams["group_id"]

	if !ok {

		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "group_id")

	}



	protoReq.GroupId, err = runtime.String(val)



	if err != nil {

		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "group_id", err)

	}



	if err := runtime.PopulateQueryParameters(&protoReq, req.URL.Query(), filter_Nakama_DemoteGroupUsers_0); err != nil {

		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)

	}



	msg, err := server.DemoteGroupUsers(ctx, &protoReq)

	return msg, metadata, err



}



func request_Nakama_ReadStorageObjects_0(ctx context.Context, marshaler runtime.Marshaler, client NakamaClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {

	var protoReq api.ReadStorageObjectsRequest

	var metadata runtime.ServerMetadata
@@ -4359,6 +4428,26 @@ func RegisterNakamaHandlerServer(ctx context.Context, mux *runtime.ServeMux, ser 


	})



	mux.Handle("POST", pattern_Nakama_DemoteGroupUsers_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {

		ctx, cancel := context.WithCancel(req.Context())

		defer cancel()

		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)

		rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req)

		if err != nil {

			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)

			return

		}

		resp, md, err := local_request_Nakama_DemoteGroupUsers_0(rctx, inboundMarshaler, server, req, pathParams)

		ctx = runtime.NewServerMetadataContext(ctx, md)

		if err != nil {

			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)

			return

		}



		forward_Nakama_DemoteGroupUsers_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)



	})



	mux.Handle("POST", pattern_Nakama_ReadStorageObjects_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {

		ctx, cancel := context.WithCancel(req.Context())

		defer cancel()
@@ -5780,6 +5869,26 @@ func RegisterNakamaHandlerClient(ctx context.Context, mux *runtime.ServeMux, cli 


	})



	mux.Handle("POST", pattern_Nakama_DemoteGroupUsers_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {

		ctx, cancel := context.WithCancel(req.Context())

		defer cancel()

		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)

		rctx, err := runtime.AnnotateContext(ctx, mux, req)

		if err != nil {

			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)

			return

		}

		resp, md, err := request_Nakama_DemoteGroupUsers_0(rctx, inboundMarshaler, client, req, pathParams)

		ctx = runtime.NewServerMetadataContext(ctx, md)

		if err != nil {

			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)

			return

		}



		forward_Nakama_DemoteGroupUsers_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)



	})



	mux.Handle("POST", pattern_Nakama_ReadStorageObjects_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {

		ctx, cancel := context.WithCancel(req.Context())

		defer cancel()
@@ -6228,6 +6337,8 @@ var ( 


	pattern_Nakama_PromoteGroupUsers_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 1, 0, 4, 1, 5, 2, 2, 3}, []string{"v2", "group", "group_id", "promote"}, "", runtime.AssumeColonVerbOpt(true)))



	pattern_Nakama_DemoteGroupUsers_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 1, 0, 4, 1, 5, 2, 2, 3}, []string{"v2", "group", "group_id", "demote"}, "", runtime.AssumeColonVerbOpt(true)))



	pattern_Nakama_ReadStorageObjects_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1}, []string{"v2", "storage"}, "", runtime.AssumeColonVerbOpt(true)))



	pattern_Nakama_RpcFunc_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 1, 0, 4, 1, 5, 2}, []string{"v2", "rpc", "id"}, "", runtime.AssumeColonVerbOpt(true)))
@@ -6368,6 +6479,8 @@ var ( 


	forward_Nakama_PromoteGroupUsers_0 = runtime.ForwardResponseMessage



	forward_Nakama_DemoteGroupUsers_0 = runtime.ForwardResponseMessage



	forward_Nakama_ReadStorageObjects_0 = runtime.ForwardResponseMessage



	forward_Nakama_RpcFunc_0 = runtime.ForwardResponseMessage

apigrpc/apigrpc.proto

+5 −0
Original line number Diff line number Diff line
@@ -488,6 +488,11 @@ service Nakama { 
    option (google.api.http).post = "/v2/group/{group_id}/promote";

  }



  // Demote a set of users in a group to the next role down.

  rpc DemoteGroupUsers (api.DemoteGroupUsersRequest) returns (google.protobuf.Empty) {

    option (google.api.http).post = "/v2/group/{group_id}/demote";

  }



  // Get storage objects.

  rpc ReadStorageObjects (api.ReadStorageObjectsRequest) returns (api.StorageObjects) {

    option (google.api.http) = {

apigrpc/apigrpc.swagger.json

+482 −0

File changed.

Preview size limit exceeded, changes collapsed.

console/console.pb.go

+4 −4
Original line number Diff line number Diff line
@@ -1667,11 +1667,11 @@ var fileDescriptor_9289ac5ba895f2a7 = []byte{ 


// Reference imports to suppress errors if they are not otherwise used.

var _ context.Context

var _ grpc.ClientConn

var _ grpc.ClientConnInterface



// This is a compile-time assertion to ensure that this generated file

// is compatible with the grpc package it is being compiled against.

const _ = grpc.SupportPackageIsVersion4

const _ = grpc.SupportPackageIsVersion6



// ConsoleClient is the client API for Console service.

//
@@ -1742,10 +1742,10 @@ type ConsoleClient interface { 
}



type consoleClient struct {

	cc *grpc.ClientConn

	cc grpc.ClientConnInterface

}



func NewConsoleClient(cc *grpc.ClientConn) ConsoleClient {

func NewConsoleClient(cc grpc.ClientConnInterface) ConsoleClient {

	return &consoleClient{cc}

}