mirror of
				https://github.com/usememos/memos.git
				synced 2025-11-01 01:06:04 +08:00 
			
		
		
		
	
		
			
				
	
	
		
			1603 lines
		
	
	
	
		
			82 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			1603 lines
		
	
	
	
		
			82 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
| // Code generated by protoc-gen-grpc-gateway. DO NOT EDIT.
 | |
| // source: api/v1/user_service.proto
 | |
| 
 | |
| /*
 | |
| Package apiv1 is a reverse proxy.
 | |
| 
 | |
| It translates gRPC into RESTful JSON APIs.
 | |
| */
 | |
| package apiv1
 | |
| 
 | |
| import (
 | |
| 	"context"
 | |
| 	"errors"
 | |
| 	"io"
 | |
| 	"net/http"
 | |
| 
 | |
| 	"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
 | |
| 	"github.com/grpc-ecosystem/grpc-gateway/v2/utilities"
 | |
| 	"google.golang.org/grpc"
 | |
| 	"google.golang.org/grpc/codes"
 | |
| 	"google.golang.org/grpc/grpclog"
 | |
| 	"google.golang.org/grpc/metadata"
 | |
| 	"google.golang.org/grpc/status"
 | |
| 	"google.golang.org/protobuf/proto"
 | |
| )
 | |
| 
 | |
| // Suppress "imported and not used" errors
 | |
| var (
 | |
| 	_ codes.Code
 | |
| 	_ io.Reader
 | |
| 	_ status.Status
 | |
| 	_ = errors.New
 | |
| 	_ = runtime.String
 | |
| 	_ = utilities.NewDoubleArray
 | |
| 	_ = metadata.Join
 | |
| )
 | |
| 
 | |
| func request_UserService_ListUsers_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq ListUsersRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 	)
 | |
| 	msg, err := client.ListUsers(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func local_request_UserService_ListUsers_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq ListUsersRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 	)
 | |
| 	msg, err := server.ListUsers(ctx, &protoReq)
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func request_UserService_GetUser_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq GetUserRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	val, ok := pathParams["name"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
 | |
| 	}
 | |
| 	protoReq.Name, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
 | |
| 	}
 | |
| 	msg, err := client.GetUser(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func local_request_UserService_GetUser_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq GetUserRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	val, ok := pathParams["name"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
 | |
| 	}
 | |
| 	protoReq.Name, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
 | |
| 	}
 | |
| 	msg, err := server.GetUser(ctx, &protoReq)
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| var filter_UserService_GetUserByUsername_0 = &utilities.DoubleArray{Encoding: map[string]int{}, Base: []int(nil), Check: []int(nil)}
 | |
| 
 | |
| func request_UserService_GetUserByUsername_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq GetUserByUsernameRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 	)
 | |
| 	if err := req.ParseForm(); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_GetUserByUsername_0); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	msg, err := client.GetUserByUsername(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func local_request_UserService_GetUserByUsername_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq GetUserByUsernameRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 	)
 | |
| 	if err := req.ParseForm(); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_GetUserByUsername_0); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	msg, err := server.GetUserByUsername(ctx, &protoReq)
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| var filter_UserService_GetUserAvatarBinary_0 = &utilities.DoubleArray{Encoding: map[string]int{"name": 0}, Base: []int{1, 1, 0}, Check: []int{0, 1, 2}}
 | |
| 
 | |
| func request_UserService_GetUserAvatarBinary_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq GetUserAvatarBinaryRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	val, ok := pathParams["name"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
 | |
| 	}
 | |
| 	protoReq.Name, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
 | |
| 	}
 | |
| 	if err := req.ParseForm(); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_GetUserAvatarBinary_0); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	msg, err := client.GetUserAvatarBinary(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func local_request_UserService_GetUserAvatarBinary_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq GetUserAvatarBinaryRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	val, ok := pathParams["name"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
 | |
| 	}
 | |
| 	protoReq.Name, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
 | |
| 	}
 | |
| 	if err := req.ParseForm(); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_GetUserAvatarBinary_0); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	msg, err := server.GetUserAvatarBinary(ctx, &protoReq)
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func request_UserService_CreateUser_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq CreateUserRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 	)
 | |
| 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.User); err != nil && !errors.Is(err, io.EOF) {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	msg, err := client.CreateUser(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func local_request_UserService_CreateUser_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq CreateUserRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 	)
 | |
| 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.User); err != nil && !errors.Is(err, io.EOF) {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	msg, err := server.CreateUser(ctx, &protoReq)
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| var filter_UserService_UpdateUser_0 = &utilities.DoubleArray{Encoding: map[string]int{"user": 0, "name": 1}, Base: []int{1, 2, 1, 0, 0}, Check: []int{0, 1, 2, 3, 2}}
 | |
| 
 | |
| func request_UserService_UpdateUser_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq UpdateUserRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	newReader, berr := utilities.IOReaderFactory(req.Body)
 | |
| 	if berr != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
 | |
| 	}
 | |
| 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.User); err != nil && !errors.Is(err, io.EOF) {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 | |
| 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.User); err != nil {
 | |
| 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 		} else {
 | |
| 			protoReq.UpdateMask = fieldMask
 | |
| 		}
 | |
| 	}
 | |
| 	val, ok := pathParams["user.name"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "user.name")
 | |
| 	}
 | |
| 	err = runtime.PopulateFieldFromPath(&protoReq, "user.name", val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "user.name", err)
 | |
| 	}
 | |
| 	if err := req.ParseForm(); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_UpdateUser_0); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	msg, err := client.UpdateUser(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func local_request_UserService_UpdateUser_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq UpdateUserRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	newReader, berr := utilities.IOReaderFactory(req.Body)
 | |
| 	if berr != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
 | |
| 	}
 | |
| 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.User); err != nil && !errors.Is(err, io.EOF) {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 | |
| 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.User); err != nil {
 | |
| 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 		} else {
 | |
| 			protoReq.UpdateMask = fieldMask
 | |
| 		}
 | |
| 	}
 | |
| 	val, ok := pathParams["user.name"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "user.name")
 | |
| 	}
 | |
| 	err = runtime.PopulateFieldFromPath(&protoReq, "user.name", val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "user.name", err)
 | |
| 	}
 | |
| 	if err := req.ParseForm(); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_UpdateUser_0); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	msg, err := server.UpdateUser(ctx, &protoReq)
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func request_UserService_DeleteUser_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq DeleteUserRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	val, ok := pathParams["name"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
 | |
| 	}
 | |
| 	protoReq.Name, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
 | |
| 	}
 | |
| 	msg, err := client.DeleteUser(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func local_request_UserService_DeleteUser_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq DeleteUserRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	val, ok := pathParams["name"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
 | |
| 	}
 | |
| 	protoReq.Name, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
 | |
| 	}
 | |
| 	msg, err := server.DeleteUser(ctx, &protoReq)
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func request_UserService_ListAllUserStats_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq ListAllUserStatsRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 	)
 | |
| 	msg, err := client.ListAllUserStats(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func local_request_UserService_ListAllUserStats_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq ListAllUserStatsRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 	)
 | |
| 	msg, err := server.ListAllUserStats(ctx, &protoReq)
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func request_UserService_GetUserStats_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq GetUserStatsRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	val, ok := pathParams["name"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
 | |
| 	}
 | |
| 	protoReq.Name, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
 | |
| 	}
 | |
| 	msg, err := client.GetUserStats(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func local_request_UserService_GetUserStats_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq GetUserStatsRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	val, ok := pathParams["name"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
 | |
| 	}
 | |
| 	protoReq.Name, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
 | |
| 	}
 | |
| 	msg, err := server.GetUserStats(ctx, &protoReq)
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func request_UserService_GetUserSetting_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq GetUserSettingRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	val, ok := pathParams["name"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
 | |
| 	}
 | |
| 	protoReq.Name, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
 | |
| 	}
 | |
| 	msg, err := client.GetUserSetting(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func local_request_UserService_GetUserSetting_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq GetUserSettingRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	val, ok := pathParams["name"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
 | |
| 	}
 | |
| 	protoReq.Name, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
 | |
| 	}
 | |
| 	msg, err := server.GetUserSetting(ctx, &protoReq)
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| var filter_UserService_UpdateUserSetting_0 = &utilities.DoubleArray{Encoding: map[string]int{"setting": 0, "name": 1}, Base: []int{1, 2, 1, 0, 0}, Check: []int{0, 1, 2, 3, 2}}
 | |
| 
 | |
| func request_UserService_UpdateUserSetting_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq UpdateUserSettingRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	newReader, berr := utilities.IOReaderFactory(req.Body)
 | |
| 	if berr != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
 | |
| 	}
 | |
| 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Setting); err != nil && !errors.Is(err, io.EOF) {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 | |
| 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Setting); err != nil {
 | |
| 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 		} else {
 | |
| 			protoReq.UpdateMask = fieldMask
 | |
| 		}
 | |
| 	}
 | |
| 	val, ok := pathParams["setting.name"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "setting.name")
 | |
| 	}
 | |
| 	err = runtime.PopulateFieldFromPath(&protoReq, "setting.name", val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "setting.name", err)
 | |
| 	}
 | |
| 	if err := req.ParseForm(); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_UpdateUserSetting_0); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	msg, err := client.UpdateUserSetting(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func local_request_UserService_UpdateUserSetting_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq UpdateUserSettingRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	newReader, berr := utilities.IOReaderFactory(req.Body)
 | |
| 	if berr != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
 | |
| 	}
 | |
| 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Setting); err != nil && !errors.Is(err, io.EOF) {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 | |
| 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Setting); err != nil {
 | |
| 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 		} else {
 | |
| 			protoReq.UpdateMask = fieldMask
 | |
| 		}
 | |
| 	}
 | |
| 	val, ok := pathParams["setting.name"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "setting.name")
 | |
| 	}
 | |
| 	err = runtime.PopulateFieldFromPath(&protoReq, "setting.name", val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "setting.name", err)
 | |
| 	}
 | |
| 	if err := req.ParseForm(); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_UpdateUserSetting_0); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	msg, err := server.UpdateUserSetting(ctx, &protoReq)
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func request_UserService_ListUserAccessTokens_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq ListUserAccessTokensRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	val, ok := pathParams["name"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
 | |
| 	}
 | |
| 	protoReq.Name, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
 | |
| 	}
 | |
| 	msg, err := client.ListUserAccessTokens(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func local_request_UserService_ListUserAccessTokens_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq ListUserAccessTokensRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	val, ok := pathParams["name"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
 | |
| 	}
 | |
| 	protoReq.Name, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
 | |
| 	}
 | |
| 	msg, err := server.ListUserAccessTokens(ctx, &protoReq)
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func request_UserService_CreateUserAccessToken_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq CreateUserAccessTokenRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	val, ok := pathParams["name"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
 | |
| 	}
 | |
| 	protoReq.Name, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
 | |
| 	}
 | |
| 	msg, err := client.CreateUserAccessToken(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func local_request_UserService_CreateUserAccessToken_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq CreateUserAccessTokenRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	val, ok := pathParams["name"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
 | |
| 	}
 | |
| 	protoReq.Name, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
 | |
| 	}
 | |
| 	msg, err := server.CreateUserAccessToken(ctx, &protoReq)
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func request_UserService_DeleteUserAccessToken_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq DeleteUserAccessTokenRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	val, ok := pathParams["name"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
 | |
| 	}
 | |
| 	protoReq.Name, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
 | |
| 	}
 | |
| 	val, ok = pathParams["access_token"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "access_token")
 | |
| 	}
 | |
| 	protoReq.AccessToken, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "access_token", err)
 | |
| 	}
 | |
| 	msg, err := client.DeleteUserAccessToken(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func local_request_UserService_DeleteUserAccessToken_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq DeleteUserAccessTokenRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	val, ok := pathParams["name"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
 | |
| 	}
 | |
| 	protoReq.Name, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
 | |
| 	}
 | |
| 	val, ok = pathParams["access_token"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "access_token")
 | |
| 	}
 | |
| 	protoReq.AccessToken, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "access_token", err)
 | |
| 	}
 | |
| 	msg, err := server.DeleteUserAccessToken(ctx, &protoReq)
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func request_UserService_ListShortcuts_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq ListShortcutsRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	val, ok := pathParams["parent"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "parent")
 | |
| 	}
 | |
| 	protoReq.Parent, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "parent", err)
 | |
| 	}
 | |
| 	msg, err := client.ListShortcuts(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func local_request_UserService_ListShortcuts_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq ListShortcutsRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	val, ok := pathParams["parent"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "parent")
 | |
| 	}
 | |
| 	protoReq.Parent, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "parent", err)
 | |
| 	}
 | |
| 	msg, err := server.ListShortcuts(ctx, &protoReq)
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| var filter_UserService_CreateShortcut_0 = &utilities.DoubleArray{Encoding: map[string]int{"shortcut": 0, "parent": 1}, Base: []int{1, 1, 2, 0, 0}, Check: []int{0, 1, 1, 2, 3}}
 | |
| 
 | |
| func request_UserService_CreateShortcut_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq CreateShortcutRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Shortcut); err != nil && !errors.Is(err, io.EOF) {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	val, ok := pathParams["parent"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "parent")
 | |
| 	}
 | |
| 	protoReq.Parent, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "parent", err)
 | |
| 	}
 | |
| 	if err := req.ParseForm(); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_CreateShortcut_0); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	msg, err := client.CreateShortcut(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func local_request_UserService_CreateShortcut_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq CreateShortcutRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Shortcut); err != nil && !errors.Is(err, io.EOF) {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	val, ok := pathParams["parent"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "parent")
 | |
| 	}
 | |
| 	protoReq.Parent, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "parent", err)
 | |
| 	}
 | |
| 	if err := req.ParseForm(); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_CreateShortcut_0); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	msg, err := server.CreateShortcut(ctx, &protoReq)
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| var filter_UserService_UpdateShortcut_0 = &utilities.DoubleArray{Encoding: map[string]int{"shortcut": 0, "parent": 1, "id": 2}, Base: []int{1, 2, 3, 1, 0, 0, 0}, Check: []int{0, 1, 1, 2, 4, 2, 3}}
 | |
| 
 | |
| func request_UserService_UpdateShortcut_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq UpdateShortcutRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	newReader, berr := utilities.IOReaderFactory(req.Body)
 | |
| 	if berr != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
 | |
| 	}
 | |
| 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Shortcut); err != nil && !errors.Is(err, io.EOF) {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 | |
| 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Shortcut); err != nil {
 | |
| 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 		} else {
 | |
| 			protoReq.UpdateMask = fieldMask
 | |
| 		}
 | |
| 	}
 | |
| 	val, ok := pathParams["parent"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "parent")
 | |
| 	}
 | |
| 	protoReq.Parent, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "parent", err)
 | |
| 	}
 | |
| 	val, ok = pathParams["shortcut.id"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "shortcut.id")
 | |
| 	}
 | |
| 	err = runtime.PopulateFieldFromPath(&protoReq, "shortcut.id", val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "shortcut.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_UserService_UpdateShortcut_0); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	msg, err := client.UpdateShortcut(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func local_request_UserService_UpdateShortcut_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq UpdateShortcutRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	newReader, berr := utilities.IOReaderFactory(req.Body)
 | |
| 	if berr != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
 | |
| 	}
 | |
| 	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Shortcut); err != nil && !errors.Is(err, io.EOF) {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
 | |
| 		if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Shortcut); err != nil {
 | |
| 			return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 		} else {
 | |
| 			protoReq.UpdateMask = fieldMask
 | |
| 		}
 | |
| 	}
 | |
| 	val, ok := pathParams["parent"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "parent")
 | |
| 	}
 | |
| 	protoReq.Parent, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "parent", err)
 | |
| 	}
 | |
| 	val, ok = pathParams["shortcut.id"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "shortcut.id")
 | |
| 	}
 | |
| 	err = runtime.PopulateFieldFromPath(&protoReq, "shortcut.id", val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "shortcut.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_UserService_UpdateShortcut_0); err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
 | |
| 	}
 | |
| 	msg, err := server.UpdateShortcut(ctx, &protoReq)
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func request_UserService_DeleteShortcut_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq DeleteShortcutRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	val, ok := pathParams["parent"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "parent")
 | |
| 	}
 | |
| 	protoReq.Parent, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "parent", err)
 | |
| 	}
 | |
| 	val, ok = pathParams["id"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
 | |
| 	}
 | |
| 	protoReq.Id, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "id", err)
 | |
| 	}
 | |
| 	msg, err := client.DeleteShortcut(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| func local_request_UserService_DeleteShortcut_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
 | |
| 	var (
 | |
| 		protoReq DeleteShortcutRequest
 | |
| 		metadata runtime.ServerMetadata
 | |
| 		err      error
 | |
| 	)
 | |
| 	val, ok := pathParams["parent"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "parent")
 | |
| 	}
 | |
| 	protoReq.Parent, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "parent", err)
 | |
| 	}
 | |
| 	val, ok = pathParams["id"]
 | |
| 	if !ok {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
 | |
| 	}
 | |
| 	protoReq.Id, err = runtime.String(val)
 | |
| 	if err != nil {
 | |
| 		return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "id", err)
 | |
| 	}
 | |
| 	msg, err := server.DeleteShortcut(ctx, &protoReq)
 | |
| 	return msg, metadata, err
 | |
| }
 | |
| 
 | |
| // RegisterUserServiceHandlerServer registers the http handlers for service UserService to "mux".
 | |
| // UnaryRPC     :call UserServiceServer directly.
 | |
| // StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
 | |
| // Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterUserServiceHandlerFromEndpoint instead.
 | |
| // GRPC interceptors will not work for this type of registration. To use interceptors, you must use the "runtime.WithMiddlewares" option in the "runtime.NewServeMux" call.
 | |
| func RegisterUserServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server UserServiceServer) error {
 | |
| 	mux.Handle(http.MethodGet, pattern_UserService_ListUsers_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
 | |
| 		ctx, cancel := context.WithCancel(req.Context())
 | |
| 		defer cancel()
 | |
| 		var stream runtime.ServerTransportStream
 | |
| 		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
 | |
| 		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
 | |
| 		annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/ListUsers", runtime.WithHTTPPathPattern("/api/v1/users"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := local_request_UserService_ListUsers_0(annotatedContext, inboundMarshaler, server, req, pathParams)
 | |
| 		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_ListUsers_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodGet, pattern_UserService_GetUser_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
 | |
| 		ctx, cancel := context.WithCancel(req.Context())
 | |
| 		defer cancel()
 | |
| 		var stream runtime.ServerTransportStream
 | |
| 		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
 | |
| 		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
 | |
| 		annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/GetUser", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := local_request_UserService_GetUser_0(annotatedContext, inboundMarshaler, server, req, pathParams)
 | |
| 		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_GetUser_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodGet, pattern_UserService_GetUserByUsername_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
 | |
| 		ctx, cancel := context.WithCancel(req.Context())
 | |
| 		defer cancel()
 | |
| 		var stream runtime.ServerTransportStream
 | |
| 		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
 | |
| 		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
 | |
| 		annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/GetUserByUsername", runtime.WithHTTPPathPattern("/api/v1/users:username"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := local_request_UserService_GetUserByUsername_0(annotatedContext, inboundMarshaler, server, req, pathParams)
 | |
| 		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_GetUserByUsername_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodGet, pattern_UserService_GetUserAvatarBinary_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
 | |
| 		ctx, cancel := context.WithCancel(req.Context())
 | |
| 		defer cancel()
 | |
| 		var stream runtime.ServerTransportStream
 | |
| 		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
 | |
| 		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
 | |
| 		annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/GetUserAvatarBinary", runtime.WithHTTPPathPattern("/file/{name=users/*}/avatar"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := local_request_UserService_GetUserAvatarBinary_0(annotatedContext, inboundMarshaler, server, req, pathParams)
 | |
| 		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_GetUserAvatarBinary_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodPost, pattern_UserService_CreateUser_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
 | |
| 		ctx, cancel := context.WithCancel(req.Context())
 | |
| 		defer cancel()
 | |
| 		var stream runtime.ServerTransportStream
 | |
| 		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
 | |
| 		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
 | |
| 		annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/CreateUser", runtime.WithHTTPPathPattern("/api/v1/users"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := local_request_UserService_CreateUser_0(annotatedContext, inboundMarshaler, server, req, pathParams)
 | |
| 		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_CreateUser_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodPatch, pattern_UserService_UpdateUser_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
 | |
| 		ctx, cancel := context.WithCancel(req.Context())
 | |
| 		defer cancel()
 | |
| 		var stream runtime.ServerTransportStream
 | |
| 		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
 | |
| 		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
 | |
| 		annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/UpdateUser", runtime.WithHTTPPathPattern("/api/v1/{user.name=users/*}"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := local_request_UserService_UpdateUser_0(annotatedContext, inboundMarshaler, server, req, pathParams)
 | |
| 		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_UpdateUser_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodDelete, pattern_UserService_DeleteUser_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
 | |
| 		ctx, cancel := context.WithCancel(req.Context())
 | |
| 		defer cancel()
 | |
| 		var stream runtime.ServerTransportStream
 | |
| 		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
 | |
| 		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
 | |
| 		annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/DeleteUser", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := local_request_UserService_DeleteUser_0(annotatedContext, inboundMarshaler, server, req, pathParams)
 | |
| 		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_DeleteUser_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodPost, pattern_UserService_ListAllUserStats_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
 | |
| 		ctx, cancel := context.WithCancel(req.Context())
 | |
| 		defer cancel()
 | |
| 		var stream runtime.ServerTransportStream
 | |
| 		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
 | |
| 		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
 | |
| 		annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/ListAllUserStats", runtime.WithHTTPPathPattern("/api/v1/users/-/stats"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := local_request_UserService_ListAllUserStats_0(annotatedContext, inboundMarshaler, server, req, pathParams)
 | |
| 		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_ListAllUserStats_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodGet, pattern_UserService_GetUserStats_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
 | |
| 		ctx, cancel := context.WithCancel(req.Context())
 | |
| 		defer cancel()
 | |
| 		var stream runtime.ServerTransportStream
 | |
| 		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
 | |
| 		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
 | |
| 		annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/GetUserStats", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}/stats"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := local_request_UserService_GetUserStats_0(annotatedContext, inboundMarshaler, server, req, pathParams)
 | |
| 		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_GetUserStats_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodGet, pattern_UserService_GetUserSetting_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
 | |
| 		ctx, cancel := context.WithCancel(req.Context())
 | |
| 		defer cancel()
 | |
| 		var stream runtime.ServerTransportStream
 | |
| 		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
 | |
| 		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
 | |
| 		annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/GetUserSetting", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}/setting"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := local_request_UserService_GetUserSetting_0(annotatedContext, inboundMarshaler, server, req, pathParams)
 | |
| 		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_GetUserSetting_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodPatch, pattern_UserService_UpdateUserSetting_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
 | |
| 		ctx, cancel := context.WithCancel(req.Context())
 | |
| 		defer cancel()
 | |
| 		var stream runtime.ServerTransportStream
 | |
| 		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
 | |
| 		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
 | |
| 		annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/UpdateUserSetting", runtime.WithHTTPPathPattern("/api/v1/{setting.name=users/*/setting}"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := local_request_UserService_UpdateUserSetting_0(annotatedContext, inboundMarshaler, server, req, pathParams)
 | |
| 		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_UpdateUserSetting_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodGet, pattern_UserService_ListUserAccessTokens_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
 | |
| 		ctx, cancel := context.WithCancel(req.Context())
 | |
| 		defer cancel()
 | |
| 		var stream runtime.ServerTransportStream
 | |
| 		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
 | |
| 		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
 | |
| 		annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/ListUserAccessTokens", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}/access_tokens"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := local_request_UserService_ListUserAccessTokens_0(annotatedContext, inboundMarshaler, server, req, pathParams)
 | |
| 		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_ListUserAccessTokens_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodPost, pattern_UserService_CreateUserAccessToken_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
 | |
| 		ctx, cancel := context.WithCancel(req.Context())
 | |
| 		defer cancel()
 | |
| 		var stream runtime.ServerTransportStream
 | |
| 		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
 | |
| 		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
 | |
| 		annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/CreateUserAccessToken", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}/access_tokens"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := local_request_UserService_CreateUserAccessToken_0(annotatedContext, inboundMarshaler, server, req, pathParams)
 | |
| 		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_CreateUserAccessToken_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodDelete, pattern_UserService_DeleteUserAccessToken_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
 | |
| 		ctx, cancel := context.WithCancel(req.Context())
 | |
| 		defer cancel()
 | |
| 		var stream runtime.ServerTransportStream
 | |
| 		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
 | |
| 		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
 | |
| 		annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/DeleteUserAccessToken", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}/access_tokens/{access_token}"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := local_request_UserService_DeleteUserAccessToken_0(annotatedContext, inboundMarshaler, server, req, pathParams)
 | |
| 		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_DeleteUserAccessToken_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodGet, pattern_UserService_ListShortcuts_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
 | |
| 		ctx, cancel := context.WithCancel(req.Context())
 | |
| 		defer cancel()
 | |
| 		var stream runtime.ServerTransportStream
 | |
| 		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
 | |
| 		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
 | |
| 		annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/ListShortcuts", runtime.WithHTTPPathPattern("/api/v1/{parent=users/*}/shortcuts"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := local_request_UserService_ListShortcuts_0(annotatedContext, inboundMarshaler, server, req, pathParams)
 | |
| 		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_ListShortcuts_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodPost, pattern_UserService_CreateShortcut_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
 | |
| 		ctx, cancel := context.WithCancel(req.Context())
 | |
| 		defer cancel()
 | |
| 		var stream runtime.ServerTransportStream
 | |
| 		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
 | |
| 		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
 | |
| 		annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/CreateShortcut", runtime.WithHTTPPathPattern("/api/v1/{parent=users/*}/shortcuts"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := local_request_UserService_CreateShortcut_0(annotatedContext, inboundMarshaler, server, req, pathParams)
 | |
| 		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_CreateShortcut_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodPatch, pattern_UserService_UpdateShortcut_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
 | |
| 		ctx, cancel := context.WithCancel(req.Context())
 | |
| 		defer cancel()
 | |
| 		var stream runtime.ServerTransportStream
 | |
| 		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
 | |
| 		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
 | |
| 		annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/UpdateShortcut", runtime.WithHTTPPathPattern("/api/v1/{parent=users/*}/shortcuts/{shortcut.id}"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := local_request_UserService_UpdateShortcut_0(annotatedContext, inboundMarshaler, server, req, pathParams)
 | |
| 		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_UpdateShortcut_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodDelete, pattern_UserService_DeleteShortcut_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
 | |
| 		ctx, cancel := context.WithCancel(req.Context())
 | |
| 		defer cancel()
 | |
| 		var stream runtime.ServerTransportStream
 | |
| 		ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
 | |
| 		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
 | |
| 		annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/DeleteShortcut", runtime.WithHTTPPathPattern("/api/v1/{parent=users/*}/shortcuts/{id}"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := local_request_UserService_DeleteShortcut_0(annotatedContext, inboundMarshaler, server, req, pathParams)
 | |
| 		md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_DeleteShortcut_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 
 | |
| 	return nil
 | |
| }
 | |
| 
 | |
| // RegisterUserServiceHandlerFromEndpoint is same as RegisterUserServiceHandler but
 | |
| // automatically dials to "endpoint" and closes the connection when "ctx" gets done.
 | |
| func RegisterUserServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) {
 | |
| 	conn, err := grpc.NewClient(endpoint, opts...)
 | |
| 	if err != nil {
 | |
| 		return err
 | |
| 	}
 | |
| 	defer func() {
 | |
| 		if err != nil {
 | |
| 			if cerr := conn.Close(); cerr != nil {
 | |
| 				grpclog.Errorf("Failed to close conn to %s: %v", endpoint, cerr)
 | |
| 			}
 | |
| 			return
 | |
| 		}
 | |
| 		go func() {
 | |
| 			<-ctx.Done()
 | |
| 			if cerr := conn.Close(); cerr != nil {
 | |
| 				grpclog.Errorf("Failed to close conn to %s: %v", endpoint, cerr)
 | |
| 			}
 | |
| 		}()
 | |
| 	}()
 | |
| 	return RegisterUserServiceHandler(ctx, mux, conn)
 | |
| }
 | |
| 
 | |
| // RegisterUserServiceHandler registers the http handlers for service UserService to "mux".
 | |
| // The handlers forward requests to the grpc endpoint over "conn".
 | |
| func RegisterUserServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error {
 | |
| 	return RegisterUserServiceHandlerClient(ctx, mux, NewUserServiceClient(conn))
 | |
| }
 | |
| 
 | |
| // RegisterUserServiceHandlerClient registers the http handlers for service UserService
 | |
| // to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "UserServiceClient".
 | |
| // Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "UserServiceClient"
 | |
| // doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in
 | |
| // "UserServiceClient" to call the correct interceptors. This client ignores the HTTP middlewares.
 | |
| func RegisterUserServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client UserServiceClient) error {
 | |
| 	mux.Handle(http.MethodGet, pattern_UserService_ListUsers_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)
 | |
| 		annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/ListUsers", runtime.WithHTTPPathPattern("/api/v1/users"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := request_UserService_ListUsers_0(annotatedContext, inboundMarshaler, client, req, pathParams)
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_ListUsers_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodGet, pattern_UserService_GetUser_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)
 | |
| 		annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/GetUser", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := request_UserService_GetUser_0(annotatedContext, inboundMarshaler, client, req, pathParams)
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_GetUser_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodGet, pattern_UserService_GetUserByUsername_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)
 | |
| 		annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/GetUserByUsername", runtime.WithHTTPPathPattern("/api/v1/users:username"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := request_UserService_GetUserByUsername_0(annotatedContext, inboundMarshaler, client, req, pathParams)
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_GetUserByUsername_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodGet, pattern_UserService_GetUserAvatarBinary_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)
 | |
| 		annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/GetUserAvatarBinary", runtime.WithHTTPPathPattern("/file/{name=users/*}/avatar"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := request_UserService_GetUserAvatarBinary_0(annotatedContext, inboundMarshaler, client, req, pathParams)
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_GetUserAvatarBinary_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodPost, pattern_UserService_CreateUser_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)
 | |
| 		annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/CreateUser", runtime.WithHTTPPathPattern("/api/v1/users"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := request_UserService_CreateUser_0(annotatedContext, inboundMarshaler, client, req, pathParams)
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_CreateUser_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodPatch, pattern_UserService_UpdateUser_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)
 | |
| 		annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/UpdateUser", runtime.WithHTTPPathPattern("/api/v1/{user.name=users/*}"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := request_UserService_UpdateUser_0(annotatedContext, inboundMarshaler, client, req, pathParams)
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_UpdateUser_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodDelete, pattern_UserService_DeleteUser_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)
 | |
| 		annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/DeleteUser", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := request_UserService_DeleteUser_0(annotatedContext, inboundMarshaler, client, req, pathParams)
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_DeleteUser_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodPost, pattern_UserService_ListAllUserStats_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)
 | |
| 		annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/ListAllUserStats", runtime.WithHTTPPathPattern("/api/v1/users/-/stats"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := request_UserService_ListAllUserStats_0(annotatedContext, inboundMarshaler, client, req, pathParams)
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_ListAllUserStats_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodGet, pattern_UserService_GetUserStats_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)
 | |
| 		annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/GetUserStats", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}/stats"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := request_UserService_GetUserStats_0(annotatedContext, inboundMarshaler, client, req, pathParams)
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_GetUserStats_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodGet, pattern_UserService_GetUserSetting_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)
 | |
| 		annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/GetUserSetting", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}/setting"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := request_UserService_GetUserSetting_0(annotatedContext, inboundMarshaler, client, req, pathParams)
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_GetUserSetting_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodPatch, pattern_UserService_UpdateUserSetting_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)
 | |
| 		annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/UpdateUserSetting", runtime.WithHTTPPathPattern("/api/v1/{setting.name=users/*/setting}"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := request_UserService_UpdateUserSetting_0(annotatedContext, inboundMarshaler, client, req, pathParams)
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_UpdateUserSetting_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodGet, pattern_UserService_ListUserAccessTokens_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)
 | |
| 		annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/ListUserAccessTokens", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}/access_tokens"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := request_UserService_ListUserAccessTokens_0(annotatedContext, inboundMarshaler, client, req, pathParams)
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_ListUserAccessTokens_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodPost, pattern_UserService_CreateUserAccessToken_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)
 | |
| 		annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/CreateUserAccessToken", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}/access_tokens"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := request_UserService_CreateUserAccessToken_0(annotatedContext, inboundMarshaler, client, req, pathParams)
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_CreateUserAccessToken_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodDelete, pattern_UserService_DeleteUserAccessToken_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)
 | |
| 		annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/DeleteUserAccessToken", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}/access_tokens/{access_token}"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := request_UserService_DeleteUserAccessToken_0(annotatedContext, inboundMarshaler, client, req, pathParams)
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_DeleteUserAccessToken_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodGet, pattern_UserService_ListShortcuts_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)
 | |
| 		annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/ListShortcuts", runtime.WithHTTPPathPattern("/api/v1/{parent=users/*}/shortcuts"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := request_UserService_ListShortcuts_0(annotatedContext, inboundMarshaler, client, req, pathParams)
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_ListShortcuts_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodPost, pattern_UserService_CreateShortcut_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)
 | |
| 		annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/CreateShortcut", runtime.WithHTTPPathPattern("/api/v1/{parent=users/*}/shortcuts"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := request_UserService_CreateShortcut_0(annotatedContext, inboundMarshaler, client, req, pathParams)
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_CreateShortcut_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodPatch, pattern_UserService_UpdateShortcut_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)
 | |
| 		annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/UpdateShortcut", runtime.WithHTTPPathPattern("/api/v1/{parent=users/*}/shortcuts/{shortcut.id}"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := request_UserService_UpdateShortcut_0(annotatedContext, inboundMarshaler, client, req, pathParams)
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_UpdateShortcut_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	mux.Handle(http.MethodDelete, pattern_UserService_DeleteShortcut_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)
 | |
| 		annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/DeleteShortcut", runtime.WithHTTPPathPattern("/api/v1/{parent=users/*}/shortcuts/{id}"))
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		resp, md, err := request_UserService_DeleteShortcut_0(annotatedContext, inboundMarshaler, client, req, pathParams)
 | |
| 		annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
 | |
| 		if err != nil {
 | |
| 			runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
 | |
| 			return
 | |
| 		}
 | |
| 		forward_UserService_DeleteShortcut_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
 | |
| 	})
 | |
| 	return nil
 | |
| }
 | |
| 
 | |
| var (
 | |
| 	pattern_UserService_ListUsers_0             = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"api", "v1", "users"}, ""))
 | |
| 	pattern_UserService_GetUser_0               = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3}, []string{"api", "v1", "users", "name"}, ""))
 | |
| 	pattern_UserService_GetUserByUsername_0     = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"api", "v1", "users"}, "username"))
 | |
| 	pattern_UserService_GetUserAvatarBinary_0   = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 1, 0, 4, 2, 5, 2, 2, 3}, []string{"file", "users", "name", "avatar"}, ""))
 | |
| 	pattern_UserService_CreateUser_0            = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"api", "v1", "users"}, ""))
 | |
| 	pattern_UserService_UpdateUser_0            = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3}, []string{"api", "v1", "users", "user.name"}, ""))
 | |
| 	pattern_UserService_DeleteUser_0            = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3}, []string{"api", "v1", "users", "name"}, ""))
 | |
| 	pattern_UserService_ListAllUserStats_0      = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 2, 3, 2, 4}, []string{"api", "v1", "users", "-", "stats"}, ""))
 | |
| 	pattern_UserService_GetUserStats_0          = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3, 2, 4}, []string{"api", "v1", "users", "name", "stats"}, ""))
 | |
| 	pattern_UserService_GetUserSetting_0        = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3, 2, 4}, []string{"api", "v1", "users", "name", "setting"}, ""))
 | |
| 	pattern_UserService_UpdateUserSetting_0     = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 2, 3, 4, 3, 5, 4}, []string{"api", "v1", "users", "setting", "setting.name"}, ""))
 | |
| 	pattern_UserService_ListUserAccessTokens_0  = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3, 2, 4}, []string{"api", "v1", "users", "name", "access_tokens"}, ""))
 | |
| 	pattern_UserService_CreateUserAccessToken_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3, 2, 4}, []string{"api", "v1", "users", "name", "access_tokens"}, ""))
 | |
| 	pattern_UserService_DeleteUserAccessToken_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3, 2, 4, 1, 0, 4, 1, 5, 5}, []string{"api", "v1", "users", "name", "access_tokens", "access_token"}, ""))
 | |
| 	pattern_UserService_ListShortcuts_0         = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3, 2, 4}, []string{"api", "v1", "users", "parent", "shortcuts"}, ""))
 | |
| 	pattern_UserService_CreateShortcut_0        = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3, 2, 4}, []string{"api", "v1", "users", "parent", "shortcuts"}, ""))
 | |
| 	pattern_UserService_UpdateShortcut_0        = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3, 2, 4, 1, 0, 4, 1, 5, 5}, []string{"api", "v1", "users", "parent", "shortcuts", "shortcut.id"}, ""))
 | |
| 	pattern_UserService_DeleteShortcut_0        = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3, 2, 4, 1, 0, 4, 1, 5, 5}, []string{"api", "v1", "users", "parent", "shortcuts", "id"}, ""))
 | |
| )
 | |
| 
 | |
| var (
 | |
| 	forward_UserService_ListUsers_0             = runtime.ForwardResponseMessage
 | |
| 	forward_UserService_GetUser_0               = runtime.ForwardResponseMessage
 | |
| 	forward_UserService_GetUserByUsername_0     = runtime.ForwardResponseMessage
 | |
| 	forward_UserService_GetUserAvatarBinary_0   = runtime.ForwardResponseMessage
 | |
| 	forward_UserService_CreateUser_0            = runtime.ForwardResponseMessage
 | |
| 	forward_UserService_UpdateUser_0            = runtime.ForwardResponseMessage
 | |
| 	forward_UserService_DeleteUser_0            = runtime.ForwardResponseMessage
 | |
| 	forward_UserService_ListAllUserStats_0      = runtime.ForwardResponseMessage
 | |
| 	forward_UserService_GetUserStats_0          = runtime.ForwardResponseMessage
 | |
| 	forward_UserService_GetUserSetting_0        = runtime.ForwardResponseMessage
 | |
| 	forward_UserService_UpdateUserSetting_0     = runtime.ForwardResponseMessage
 | |
| 	forward_UserService_ListUserAccessTokens_0  = runtime.ForwardResponseMessage
 | |
| 	forward_UserService_CreateUserAccessToken_0 = runtime.ForwardResponseMessage
 | |
| 	forward_UserService_DeleteUserAccessToken_0 = runtime.ForwardResponseMessage
 | |
| 	forward_UserService_ListShortcuts_0         = runtime.ForwardResponseMessage
 | |
| 	forward_UserService_CreateShortcut_0        = runtime.ForwardResponseMessage
 | |
| 	forward_UserService_UpdateShortcut_0        = runtime.ForwardResponseMessage
 | |
| 	forward_UserService_DeleteShortcut_0        = runtime.ForwardResponseMessage
 | |
| )
 |