@ -10,6 +10,7 @@ package apiv1
import (
"context"
"errors"
"io"
"net/http"
@ -24,264 +25,209 @@ import (
)
// Suppress "imported and not used" errors
var _ codes . Code
var _ io . Reader
var _ status . Status
var _ = runtime . String
var _ = utilities . NewDoubleArray
var _ = metadata . Join
var (
_ codes . Code
_ io . Reader
_ status . Status
_ = errors . New
_ = runtime . String
_ = utilities . NewDoubleArray
_ = metadata . Join
)
func request_ResourceService_CreateResource_0 ( ctx context . Context , marshaler runtime . Marshaler , client ResourceServiceClient , req * http . Request , pathParams map [ string ] string ) ( proto . Message , runtime . ServerMetadata , error ) {
var protoReq CreateResourceRequest
var metadata runtime . ServerMetadata
if err := marshaler . NewDecoder ( req . Body ) . Decode ( & protoReq . Resource ) ; err != nil && err != io . EOF {
var (
protoReq CreateResourceRequest
metadata runtime . ServerMetadata
)
if err := marshaler . NewDecoder ( req . Body ) . Decode ( & protoReq . Resource ) ; err != nil && ! errors . Is ( err , io . EOF ) {
return nil , metadata , status . Errorf ( codes . InvalidArgument , "%v" , err )
}
msg , err := client . CreateResource ( ctx , & protoReq , grpc . Header ( & metadata . HeaderMD ) , grpc . Trailer ( & metadata . TrailerMD ) )
return msg , metadata , err
}
func local_request_ResourceService_CreateResource_0 ( ctx context . Context , marshaler runtime . Marshaler , server ResourceServiceServer , req * http . Request , pathParams map [ string ] string ) ( proto . Message , runtime . ServerMetadata , error ) {
var protoReq CreateResourceRequest
var metadata runtime . ServerMetadata
if err := marshaler . NewDecoder ( req . Body ) . Decode ( & protoReq . Resource ) ; err != nil && err != io . EOF {
var (
protoReq CreateResourceRequest
metadata runtime . ServerMetadata
)
if err := marshaler . NewDecoder ( req . Body ) . Decode ( & protoReq . Resource ) ; err != nil && ! errors . Is ( err , io . EOF ) {
return nil , metadata , status . Errorf ( codes . InvalidArgument , "%v" , err )
}
msg , err := server . CreateResource ( ctx , & protoReq )
return msg , metadata , err
}
func request_ResourceService_ListResources_0 ( ctx context . Context , marshaler runtime . Marshaler , client ResourceServiceClient , req * http . Request , pathParams map [ string ] string ) ( proto . Message , runtime . ServerMetadata , error ) {
var protoReq ListResourcesRequest
var metadata runtime . ServerMetadata
var (
protoReq ListResourcesRequest
metadata runtime . ServerMetadata
)
msg , err := client . ListResources ( ctx , & protoReq , grpc . Header ( & metadata . HeaderMD ) , grpc . Trailer ( & metadata . TrailerMD ) )
return msg , metadata , err
}
func local_request_ResourceService_ListResources_0 ( ctx context . Context , marshaler runtime . Marshaler , server ResourceServiceServer , req * http . Request , pathParams map [ string ] string ) ( proto . Message , runtime . ServerMetadata , error ) {
var protoReq ListResourcesRequest
var metadata runtime . ServerMetadata
var (
protoReq ListResourcesRequest
metadata runtime . ServerMetadata
)
msg , err := server . ListResources ( ctx , & protoReq )
return msg , metadata , err
}
func request_ResourceService_GetResource_0 ( ctx context . Context , marshaler runtime . Marshaler , client ResourceServiceClient , req * http . Request , pathParams map [ string ] string ) ( proto . Message , runtime . ServerMetadata , error ) {
var protoReq GetResourceRequest
var metadata runtime . ServerMetadata
var (
val string
ok bool
err error
_ = err
protoReq GetResourceRequest
metadata runtime . ServerMetadata
err error
)
val , ok = pathParams [ "name" ]
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 . GetResource ( ctx , & protoReq , grpc . Header ( & metadata . HeaderMD ) , grpc . Trailer ( & metadata . TrailerMD ) )
return msg , metadata , err
}
func local_request_ResourceService_GetResource_0 ( ctx context . Context , marshaler runtime . Marshaler , server ResourceServiceServer , req * http . Request , pathParams map [ string ] string ) ( proto . Message , runtime . ServerMetadata , error ) {
var protoReq GetResourceRequest
var metadata runtime . ServerMetadata
var (
val string
ok bool
err error
_ = err
protoReq GetResourceRequest
metadata runtime . ServerMetadata
err error
)
val , ok = pathParams [ "name" ]
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 . GetResource ( ctx , & protoReq )
return msg , metadata , err
}
func request_ResourceService_GetResourceByUid_0 ( ctx context . Context , marshaler runtime . Marshaler , client ResourceServiceClient , req * http . Request , pathParams map [ string ] string ) ( proto . Message , runtime . ServerMetadata , error ) {
var protoReq GetResourceByUidRequest
var metadata runtime . ServerMetadata
var (
val string
ok bool
err error
_ = err
protoReq GetResourceByUidRequest
metadata runtime . ServerMetadata
err error
)
val , ok = pathParams [ "uid" ]
val , ok := pathParams [ "uid" ]
if ! ok {
return nil , metadata , status . Errorf ( codes . InvalidArgument , "missing parameter %s" , "uid" )
}
protoReq . Uid , err = runtime . String ( val )
if err != nil {
return nil , metadata , status . Errorf ( codes . InvalidArgument , "type mismatch, parameter: %s, error: %v" , "uid" , err )
}
msg , err := client . GetResourceByUid ( ctx , & protoReq , grpc . Header ( & metadata . HeaderMD ) , grpc . Trailer ( & metadata . TrailerMD ) )
return msg , metadata , err
}
func local_request_ResourceService_GetResourceByUid_0 ( ctx context . Context , marshaler runtime . Marshaler , server ResourceServiceServer , req * http . Request , pathParams map [ string ] string ) ( proto . Message , runtime . ServerMetadata , error ) {
var protoReq GetResourceByUidRequest
var metadata runtime . ServerMetadata
var (
val string
ok bool
err error
_ = err
protoReq GetResourceByUidRequest
metadata runtime . ServerMetadata
err error
)
val , ok = pathParams [ "uid" ]
val , ok := pathParams [ "uid" ]
if ! ok {
return nil , metadata , status . Errorf ( codes . InvalidArgument , "missing parameter %s" , "uid" )
}
protoReq . Uid , err = runtime . String ( val )
if err != nil {
return nil , metadata , status . Errorf ( codes . InvalidArgument , "type mismatch, parameter: %s, error: %v" , "uid" , err )
}
msg , err := server . GetResourceByUid ( ctx , & protoReq )
return msg , metadata , err
}
var (
filter_ResourceService_GetResourceBinary_0 = & utilities . DoubleArray { Encoding : map [ string ] int { "name" : 0 , "filename" : 1 } , Base : [ ] int { 1 , 1 , 2 , 0 , 0 } , Check : [ ] int { 0 , 1 , 1 , 2 , 3 } }
)
var filter_ResourceService_GetResourceBinary_0 = & utilities . DoubleArray { Encoding : map [ string ] int { "name" : 0 , "filename" : 1 } , Base : [ ] int { 1 , 1 , 2 , 0 , 0 } , Check : [ ] int { 0 , 1 , 1 , 2 , 3 } }
func request_ResourceService_GetResourceBinary_0 ( ctx context . Context , marshaler runtime . Marshaler , client ResourceServiceClient , req * http . Request , pathParams map [ string ] string ) ( proto . Message , runtime . ServerMetadata , error ) {
var protoReq GetResourceBinaryRequest
var metadata runtime . ServerMetadata
var (
val string
ok bool
err error
_ = err
protoReq GetResourceBinaryRequest
metadata runtime . ServerMetadata
err error
)
val , ok = pathParams [ "name" ]
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 [ "filename" ]
if ! ok {
return nil , metadata , status . Errorf ( codes . InvalidArgument , "missing parameter %s" , "filename" )
}
protoReq . Filename , err = runtime . String ( val )
if err != nil {
return nil , metadata , status . Errorf ( codes . InvalidArgument , "type mismatch, parameter: %s, error: %v" , "filename" , err )
}
if err := req . ParseForm ( ) ; err != nil {
return nil , metadata , status . Errorf ( codes . InvalidArgument , "%v" , err )
}
if err := runtime . PopulateQueryParameters ( & protoReq , req . Form , filter_ResourceService_GetResourceBinary_0 ) ; err != nil {
return nil , metadata , status . Errorf ( codes . InvalidArgument , "%v" , err )
}
msg , err := client . GetResourceBinary ( ctx , & protoReq , grpc . Header ( & metadata . HeaderMD ) , grpc . Trailer ( & metadata . TrailerMD ) )
return msg , metadata , err
}
func local_request_ResourceService_GetResourceBinary_0 ( ctx context . Context , marshaler runtime . Marshaler , server ResourceServiceServer , req * http . Request , pathParams map [ string ] string ) ( proto . Message , runtime . ServerMetadata , error ) {
var protoReq GetResourceBinaryRequest
var metadata runtime . ServerMetadata
var (
val string
ok bool
err error
_ = err
protoReq GetResourceBinaryRequest
metadata runtime . ServerMetadata
err error
)
val , ok = pathParams [ "name" ]
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 [ "filename" ]
if ! ok {
return nil , metadata , status . Errorf ( codes . InvalidArgument , "missing parameter %s" , "filename" )
}
protoReq . Filename , err = runtime . String ( val )
if err != nil {
return nil , metadata , status . Errorf ( codes . InvalidArgument , "type mismatch, parameter: %s, error: %v" , "filename" , err )
}
if err := req . ParseForm ( ) ; err != nil {
return nil , metadata , status . Errorf ( codes . InvalidArgument , "%v" , err )
}
if err := runtime . PopulateQueryParameters ( & protoReq , req . Form , filter_ResourceService_GetResourceBinary_0 ) ; err != nil {
return nil , metadata , status . Errorf ( codes . InvalidArgument , "%v" , err )
}
msg , err := server . GetResourceBinary ( ctx , & protoReq )
return msg , metadata , err
}
var (
filter_ResourceService_UpdateResource_0 = & utilities . DoubleArray { Encoding : map [ string ] int { "resource" : 0 , "name" : 1 } , Base : [ ] int { 1 , 2 , 1 , 0 , 0 } , Check : [ ] int { 0 , 1 , 2 , 3 , 2 } }
)
var filter_ResourceService_UpdateResource_0 = & utilities . DoubleArray { Encoding : map [ string ] int { "resource" : 0 , "name" : 1 } , Base : [ ] int { 1 , 2 , 1 , 0 , 0 } , Check : [ ] int { 0 , 1 , 2 , 3 , 2 } }
func request_ResourceService_UpdateResource_0 ( ctx context . Context , marshaler runtime . Marshaler , client ResourceServiceClient , req * http . Request , pathParams map [ string ] string ) ( proto . Message , runtime . ServerMetadata , error ) {
var protoReq UpdateResourceRequest
var metadata runtime . ServerMetadata
var (
protoReq UpdateResourceRequest
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 . Resource ) ; err != nil && err != io . EOF {
if err := marshaler . NewDecoder ( newReader ( ) ) . Decode ( & protoReq . Resource ) ; 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 {
@ -291,45 +237,35 @@ func request_ResourceService_UpdateResource_0(ctx context.Context, marshaler run
protoReq . UpdateMask = fieldMask
}
}
var (
val string
ok bool
err error
_ = err
)
val , ok = pathParams [ "resource.name" ]
val , ok := pathParams [ "resource.name" ]
if ! ok {
return nil , metadata , status . Errorf ( codes . InvalidArgument , "missing parameter %s" , "resource.name" )
}
err = runtime . PopulateFieldFromPath ( & protoReq , "resource.name" , val )
if err != nil {
return nil , metadata , status . Errorf ( codes . InvalidArgument , "type mismatch, parameter: %s, error: %v" , "resource.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_ResourceService_UpdateResource_0 ) ; err != nil {
return nil , metadata , status . Errorf ( codes . InvalidArgument , "%v" , err )
}
msg , err := client . UpdateResource ( ctx , & protoReq , grpc . Header ( & metadata . HeaderMD ) , grpc . Trailer ( & metadata . TrailerMD ) )
return msg , metadata , err
}
func local_request_ResourceService_UpdateResource_0 ( ctx context . Context , marshaler runtime . Marshaler , server ResourceServiceServer , req * http . Request , pathParams map [ string ] string ) ( proto . Message , runtime . ServerMetadata , error ) {
var protoReq UpdateResourceRequest
var metadata runtime . ServerMetadata
var (
protoReq UpdateResourceRequest
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 . Resource ) ; err != nil && err != io . EOF {
if err := marshaler . NewDecoder ( newReader ( ) ) . Decode ( & protoReq . Resource ) ; 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 {
@ -339,86 +275,58 @@ func local_request_ResourceService_UpdateResource_0(ctx context.Context, marshal
protoReq . UpdateMask = fieldMask
}
}
var (
val string
ok bool
err error
_ = err
)
val , ok = pathParams [ "resource.name" ]
val , ok := pathParams [ "resource.name" ]
if ! ok {
return nil , metadata , status . Errorf ( codes . InvalidArgument , "missing parameter %s" , "resource.name" )
}
err = runtime . PopulateFieldFromPath ( & protoReq , "resource.name" , val )
if err != nil {
return nil , metadata , status . Errorf ( codes . InvalidArgument , "type mismatch, parameter: %s, error: %v" , "resource.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_ResourceService_UpdateResource_0 ) ; err != nil {
return nil , metadata , status . Errorf ( codes . InvalidArgument , "%v" , err )
}
msg , err := server . UpdateResource ( ctx , & protoReq )
return msg , metadata , err
}
func request_ResourceService_DeleteResource_0 ( ctx context . Context , marshaler runtime . Marshaler , client ResourceServiceClient , req * http . Request , pathParams map [ string ] string ) ( proto . Message , runtime . ServerMetadata , error ) {
var protoReq DeleteResourceRequest
var metadata runtime . ServerMetadata
var (
val string
ok bool
err error
_ = err
protoReq DeleteResourceRequest
metadata runtime . ServerMetadata
err error
)
val , ok = pathParams [ "name" ]
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 . DeleteResource ( ctx , & protoReq , grpc . Header ( & metadata . HeaderMD ) , grpc . Trailer ( & metadata . TrailerMD ) )
return msg , metadata , err
}
func local_request_ResourceService_DeleteResource_0 ( ctx context . Context , marshaler runtime . Marshaler , server ResourceServiceServer , req * http . Request , pathParams map [ string ] string ) ( proto . Message , runtime . ServerMetadata , error ) {
var protoReq DeleteResourceRequest
var metadata runtime . ServerMetadata
var (
val string
ok bool
err error
_ = err
protoReq DeleteResourceRequest
metadata runtime . ServerMetadata
err error
)
val , ok = pathParams [ "name" ]
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 . DeleteResource ( ctx , & protoReq )
return msg , metadata , err
}
// RegisterResourceServiceHandlerServer registers the http handlers for service ResourceService to "mux".
@ -427,16 +335,13 @@ func local_request_ResourceService_DeleteResource_0(ctx context.Context, marshal
// Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterResourceServiceHandlerFromEndpoint 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 RegisterResourceServiceHandlerServer ( ctx context . Context , mux * runtime . ServeMux , server ResourceServiceServer ) error {
mux . Handle ( "POST" , pattern_ResourceService_CreateResource_0 , func ( w http . ResponseWriter , req * http . Request , pathParams map [ string ] string ) {
mux . Handle ( http . MethodPost , pattern_ResourceService_CreateResource_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 )
var err error
var annotatedContext context . Context
annotatedContext , err = runtime . AnnotateIncomingContext ( ctx , mux , req , "/memos.api.v1.ResourceService/CreateResource" , runtime . WithHTTPPathPattern ( "/api/v1/resources" ) )
annotatedContext , err := runtime . AnnotateIncomingContext ( ctx , mux , req , "/memos.api.v1.ResourceService/CreateResource" , runtime . WithHTTPPathPattern ( "/api/v1/resources" ) )
if err != nil {
runtime . HTTPError ( ctx , mux , outboundMarshaler , w , req , err )
return
@ -448,20 +353,15 @@ func RegisterResourceServiceHandlerServer(ctx context.Context, mux *runtime.Serv
runtime . HTTPError ( annotatedContext , mux , outboundMarshaler , w , req , err )
return
}
forward_ResourceService_CreateResource_0 ( annotatedContext , mux , outboundMarshaler , w , req , resp , mux . GetForwardResponseOptions ( ) ... )
} )
mux . Handle ( "GET" , pattern_ResourceService_ListResources_0 , func ( w http . ResponseWriter , req * http . Request , pathParams map [ string ] string ) {
mux . Handle ( http . MethodGet , pattern_ResourceService_ListResources_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 )
var err error
var annotatedContext context . Context
annotatedContext , err = runtime . AnnotateIncomingContext ( ctx , mux , req , "/memos.api.v1.ResourceService/ListResources" , runtime . WithHTTPPathPattern ( "/api/v1/resources" ) )
annotatedContext , err := runtime . AnnotateIncomingContext ( ctx , mux , req , "/memos.api.v1.ResourceService/ListResources" , runtime . WithHTTPPathPattern ( "/api/v1/resources" ) )
if err != nil {
runtime . HTTPError ( ctx , mux , outboundMarshaler , w , req , err )
return
@ -473,20 +373,15 @@ func RegisterResourceServiceHandlerServer(ctx context.Context, mux *runtime.Serv
runtime . HTTPError ( annotatedContext , mux , outboundMarshaler , w , req , err )
return
}
forward_ResourceService_ListResources_0 ( annotatedContext , mux , outboundMarshaler , w , req , resp , mux . GetForwardResponseOptions ( ) ... )
} )
mux . Handle ( "GET" , pattern_ResourceService_GetResource_0 , func ( w http . ResponseWriter , req * http . Request , pathParams map [ string ] string ) {
mux . Handle ( http . MethodGet , pattern_ResourceService_GetResource_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 )
var err error
var annotatedContext context . Context
annotatedContext , err = runtime . AnnotateIncomingContext ( ctx , mux , req , "/memos.api.v1.ResourceService/GetResource" , runtime . WithHTTPPathPattern ( "/api/v1/{name=resources/*}" ) )
annotatedContext , err := runtime . AnnotateIncomingContext ( ctx , mux , req , "/memos.api.v1.ResourceService/GetResource" , runtime . WithHTTPPathPattern ( "/api/v1/{name=resources/*}" ) )
if err != nil {
runtime . HTTPError ( ctx , mux , outboundMarshaler , w , req , err )
return
@ -498,20 +393,15 @@ func RegisterResourceServiceHandlerServer(ctx context.Context, mux *runtime.Serv
runtime . HTTPError ( annotatedContext , mux , outboundMarshaler , w , req , err )
return
}
forward_ResourceService_GetResource_0 ( annotatedContext , mux , outboundMarshaler , w , req , resp , mux . GetForwardResponseOptions ( ) ... )
} )
mux . Handle ( "GET" , pattern_ResourceService_GetResourceByUid_0 , func ( w http . ResponseWriter , req * http . Request , pathParams map [ string ] string ) {
mux . Handle ( http . MethodGet , pattern_ResourceService_GetResourceByUid_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 )
var err error
var annotatedContext context . Context
annotatedContext , err = runtime . AnnotateIncomingContext ( ctx , mux , req , "/memos.api.v1.ResourceService/GetResourceByUid" , runtime . WithHTTPPathPattern ( "/api/v1/resources:by-uid/{uid}" ) )
annotatedContext , err := runtime . AnnotateIncomingContext ( ctx , mux , req , "/memos.api.v1.ResourceService/GetResourceByUid" , runtime . WithHTTPPathPattern ( "/api/v1/resources:by-uid/{uid}" ) )
if err != nil {
runtime . HTTPError ( ctx , mux , outboundMarshaler , w , req , err )
return
@ -523,20 +413,15 @@ func RegisterResourceServiceHandlerServer(ctx context.Context, mux *runtime.Serv
runtime . HTTPError ( annotatedContext , mux , outboundMarshaler , w , req , err )
return
}
forward_ResourceService_GetResourceByUid_0 ( annotatedContext , mux , outboundMarshaler , w , req , resp , mux . GetForwardResponseOptions ( ) ... )
} )
mux . Handle ( "GET" , pattern_ResourceService_GetResourceBinary_0 , func ( w http . ResponseWriter , req * http . Request , pathParams map [ string ] string ) {
mux . Handle ( http . MethodGet , pattern_ResourceService_GetResourceBinary_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 )
var err error
var annotatedContext context . Context
annotatedContext , err = runtime . AnnotateIncomingContext ( ctx , mux , req , "/memos.api.v1.ResourceService/GetResourceBinary" , runtime . WithHTTPPathPattern ( "/file/{name=resources/*}/{filename}" ) )
annotatedContext , err := runtime . AnnotateIncomingContext ( ctx , mux , req , "/memos.api.v1.ResourceService/GetResourceBinary" , runtime . WithHTTPPathPattern ( "/file/{name=resources/*}/{filename}" ) )
if err != nil {
runtime . HTTPError ( ctx , mux , outboundMarshaler , w , req , err )
return
@ -548,20 +433,15 @@ func RegisterResourceServiceHandlerServer(ctx context.Context, mux *runtime.Serv
runtime . HTTPError ( annotatedContext , mux , outboundMarshaler , w , req , err )
return
}
forward_ResourceService_GetResourceBinary_0 ( annotatedContext , mux , outboundMarshaler , w , req , resp , mux . GetForwardResponseOptions ( ) ... )
} )
mux . Handle ( "PATCH" , pattern_ResourceService_UpdateResource_0 , func ( w http . ResponseWriter , req * http . Request , pathParams map [ string ] string ) {
mux . Handle ( http . MethodPatch , pattern_ResourceService_UpdateResource_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 )
var err error
var annotatedContext context . Context
annotatedContext , err = runtime . AnnotateIncomingContext ( ctx , mux , req , "/memos.api.v1.ResourceService/UpdateResource" , runtime . WithHTTPPathPattern ( "/api/v1/{resource.name=resources/*}" ) )
annotatedContext , err := runtime . AnnotateIncomingContext ( ctx , mux , req , "/memos.api.v1.ResourceService/UpdateResource" , runtime . WithHTTPPathPattern ( "/api/v1/{resource.name=resources/*}" ) )
if err != nil {
runtime . HTTPError ( ctx , mux , outboundMarshaler , w , req , err )
return
@ -573,20 +453,15 @@ func RegisterResourceServiceHandlerServer(ctx context.Context, mux *runtime.Serv
runtime . HTTPError ( annotatedContext , mux , outboundMarshaler , w , req , err )
return
}
forward_ResourceService_UpdateResource_0 ( annotatedContext , mux , outboundMarshaler , w , req , resp , mux . GetForwardResponseOptions ( ) ... )
} )
mux . Handle ( "DELETE" , pattern_ResourceService_DeleteResource_0 , func ( w http . ResponseWriter , req * http . Request , pathParams map [ string ] string ) {
mux . Handle ( http . MethodDelete , pattern_ResourceService_DeleteResource_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 )
var err error
var annotatedContext context . Context
annotatedContext , err = runtime . AnnotateIncomingContext ( ctx , mux , req , "/memos.api.v1.ResourceService/DeleteResource" , runtime . WithHTTPPathPattern ( "/api/v1/{name=resources/*}" ) )
annotatedContext , err := runtime . AnnotateIncomingContext ( ctx , mux , req , "/memos.api.v1.ResourceService/DeleteResource" , runtime . WithHTTPPathPattern ( "/api/v1/{name=resources/*}" ) )
if err != nil {
runtime . HTTPError ( ctx , mux , outboundMarshaler , w , req , err )
return
@ -598,9 +473,7 @@ func RegisterResourceServiceHandlerServer(ctx context.Context, mux *runtime.Serv
runtime . HTTPError ( annotatedContext , mux , outboundMarshaler , w , req , err )
return
}
forward_ResourceService_DeleteResource_0 ( annotatedContext , mux , outboundMarshaler , w , req , resp , mux . GetForwardResponseOptions ( ) ... )
} )
return nil
@ -627,7 +500,6 @@ func RegisterResourceServiceHandlerFromEndpoint(ctx context.Context, mux *runtim
}
} ( )
} ( )
return RegisterResourceServiceHandler ( ctx , mux , conn )
}
@ -643,14 +515,11 @@ func RegisterResourceServiceHandler(ctx context.Context, mux *runtime.ServeMux,
// doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in
// "ResourceServiceClient" to call the correct interceptors. This client ignores the HTTP middlewares.
func RegisterResourceServiceHandlerClient ( ctx context . Context , mux * runtime . ServeMux , client ResourceServiceClient ) error {
mux . Handle ( "POST" , pattern_ResourceService_CreateResource_0 , func ( w http . ResponseWriter , req * http . Request , pathParams map [ string ] string ) {
mux . Handle ( http . MethodPost , pattern_ResourceService_CreateResource_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 )
var err error
var annotatedContext context . Context
annotatedContext , err = runtime . AnnotateContext ( ctx , mux , req , "/memos.api.v1.ResourceService/CreateResource" , runtime . WithHTTPPathPattern ( "/api/v1/resources" ) )
annotatedContext , err := runtime . AnnotateContext ( ctx , mux , req , "/memos.api.v1.ResourceService/CreateResource" , runtime . WithHTTPPathPattern ( "/api/v1/resources" ) )
if err != nil {
runtime . HTTPError ( ctx , mux , outboundMarshaler , w , req , err )
return
@ -661,18 +530,13 @@ func RegisterResourceServiceHandlerClient(ctx context.Context, mux *runtime.Serv
runtime . HTTPError ( annotatedContext , mux , outboundMarshaler , w , req , err )
return
}
forward_ResourceService_CreateResource_0 ( annotatedContext , mux , outboundMarshaler , w , req , resp , mux . GetForwardResponseOptions ( ) ... )
} )
mux . Handle ( "GET" , pattern_ResourceService_ListResources_0 , func ( w http . ResponseWriter , req * http . Request , pathParams map [ string ] string ) {
mux . Handle ( http . MethodGet , pattern_ResourceService_ListResources_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 )
var err error
var annotatedContext context . Context
annotatedContext , err = runtime . AnnotateContext ( ctx , mux , req , "/memos.api.v1.ResourceService/ListResources" , runtime . WithHTTPPathPattern ( "/api/v1/resources" ) )
annotatedContext , err := runtime . AnnotateContext ( ctx , mux , req , "/memos.api.v1.ResourceService/ListResources" , runtime . WithHTTPPathPattern ( "/api/v1/resources" ) )
if err != nil {
runtime . HTTPError ( ctx , mux , outboundMarshaler , w , req , err )
return
@ -683,18 +547,13 @@ func RegisterResourceServiceHandlerClient(ctx context.Context, mux *runtime.Serv
runtime . HTTPError ( annotatedContext , mux , outboundMarshaler , w , req , err )
return
}
forward_ResourceService_ListResources_0 ( annotatedContext , mux , outboundMarshaler , w , req , resp , mux . GetForwardResponseOptions ( ) ... )
} )
mux . Handle ( "GET" , pattern_ResourceService_GetResource_0 , func ( w http . ResponseWriter , req * http . Request , pathParams map [ string ] string ) {
mux . Handle ( http . MethodGet , pattern_ResourceService_GetResource_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 )
var err error
var annotatedContext context . Context
annotatedContext , err = runtime . AnnotateContext ( ctx , mux , req , "/memos.api.v1.ResourceService/GetResource" , runtime . WithHTTPPathPattern ( "/api/v1/{name=resources/*}" ) )
annotatedContext , err := runtime . AnnotateContext ( ctx , mux , req , "/memos.api.v1.ResourceService/GetResource" , runtime . WithHTTPPathPattern ( "/api/v1/{name=resources/*}" ) )
if err != nil {
runtime . HTTPError ( ctx , mux , outboundMarshaler , w , req , err )
return
@ -705,18 +564,13 @@ func RegisterResourceServiceHandlerClient(ctx context.Context, mux *runtime.Serv
runtime . HTTPError ( annotatedContext , mux , outboundMarshaler , w , req , err )
return
}
forward_ResourceService_GetResource_0 ( annotatedContext , mux , outboundMarshaler , w , req , resp , mux . GetForwardResponseOptions ( ) ... )
} )
mux . Handle ( "GET" , pattern_ResourceService_GetResourceByUid_0 , func ( w http . ResponseWriter , req * http . Request , pathParams map [ string ] string ) {
mux . Handle ( http . MethodGet , pattern_ResourceService_GetResourceByUid_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 )
var err error
var annotatedContext context . Context
annotatedContext , err = runtime . AnnotateContext ( ctx , mux , req , "/memos.api.v1.ResourceService/GetResourceByUid" , runtime . WithHTTPPathPattern ( "/api/v1/resources:by-uid/{uid}" ) )
annotatedContext , err := runtime . AnnotateContext ( ctx , mux , req , "/memos.api.v1.ResourceService/GetResourceByUid" , runtime . WithHTTPPathPattern ( "/api/v1/resources:by-uid/{uid}" ) )
if err != nil {
runtime . HTTPError ( ctx , mux , outboundMarshaler , w , req , err )
return
@ -727,18 +581,13 @@ func RegisterResourceServiceHandlerClient(ctx context.Context, mux *runtime.Serv
runtime . HTTPError ( annotatedContext , mux , outboundMarshaler , w , req , err )
return
}
forward_ResourceService_GetResourceByUid_0 ( annotatedContext , mux , outboundMarshaler , w , req , resp , mux . GetForwardResponseOptions ( ) ... )
} )
mux . Handle ( "GET" , pattern_ResourceService_GetResourceBinary_0 , func ( w http . ResponseWriter , req * http . Request , pathParams map [ string ] string ) {
mux . Handle ( http . MethodGet , pattern_ResourceService_GetResourceBinary_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 )
var err error
var annotatedContext context . Context
annotatedContext , err = runtime . AnnotateContext ( ctx , mux , req , "/memos.api.v1.ResourceService/GetResourceBinary" , runtime . WithHTTPPathPattern ( "/file/{name=resources/*}/{filename}" ) )
annotatedContext , err := runtime . AnnotateContext ( ctx , mux , req , "/memos.api.v1.ResourceService/GetResourceBinary" , runtime . WithHTTPPathPattern ( "/file/{name=resources/*}/{filename}" ) )
if err != nil {
runtime . HTTPError ( ctx , mux , outboundMarshaler , w , req , err )
return
@ -749,18 +598,13 @@ func RegisterResourceServiceHandlerClient(ctx context.Context, mux *runtime.Serv
runtime . HTTPError ( annotatedContext , mux , outboundMarshaler , w , req , err )
return
}
forward_ResourceService_GetResourceBinary_0 ( annotatedContext , mux , outboundMarshaler , w , req , resp , mux . GetForwardResponseOptions ( ) ... )
} )
mux . Handle ( "PATCH" , pattern_ResourceService_UpdateResource_0 , func ( w http . ResponseWriter , req * http . Request , pathParams map [ string ] string ) {
mux . Handle ( http . MethodPatch , pattern_ResourceService_UpdateResource_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 )
var err error
var annotatedContext context . Context
annotatedContext , err = runtime . AnnotateContext ( ctx , mux , req , "/memos.api.v1.ResourceService/UpdateResource" , runtime . WithHTTPPathPattern ( "/api/v1/{resource.name=resources/*}" ) )
annotatedContext , err := runtime . AnnotateContext ( ctx , mux , req , "/memos.api.v1.ResourceService/UpdateResource" , runtime . WithHTTPPathPattern ( "/api/v1/{resource.name=resources/*}" ) )
if err != nil {
runtime . HTTPError ( ctx , mux , outboundMarshaler , w , req , err )
return
@ -771,18 +615,13 @@ func RegisterResourceServiceHandlerClient(ctx context.Context, mux *runtime.Serv
runtime . HTTPError ( annotatedContext , mux , outboundMarshaler , w , req , err )
return
}
forward_ResourceService_UpdateResource_0 ( annotatedContext , mux , outboundMarshaler , w , req , resp , mux . GetForwardResponseOptions ( ) ... )
} )
mux . Handle ( "DELETE" , pattern_ResourceService_DeleteResource_0 , func ( w http . ResponseWriter , req * http . Request , pathParams map [ string ] string ) {
mux . Handle ( http . MethodDelete , pattern_ResourceService_DeleteResource_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 )
var err error
var annotatedContext context . Context
annotatedContext , err = runtime . AnnotateContext ( ctx , mux , req , "/memos.api.v1.ResourceService/DeleteResource" , runtime . WithHTTPPathPattern ( "/api/v1/{name=resources/*}" ) )
annotatedContext , err := runtime . AnnotateContext ( ctx , mux , req , "/memos.api.v1.ResourceService/DeleteResource" , runtime . WithHTTPPathPattern ( "/api/v1/{name=resources/*}" ) )
if err != nil {
runtime . HTTPError ( ctx , mux , outboundMarshaler , w , req , err )
return
@ -793,42 +632,27 @@ func RegisterResourceServiceHandlerClient(ctx context.Context, mux *runtime.Serv
runtime . HTTPError ( annotatedContext , mux , outboundMarshaler , w , req , err )
return
}
forward_ResourceService_DeleteResource_0 ( annotatedContext , mux , outboundMarshaler , w , req , resp , mux . GetForwardResponseOptions ( ) ... )
} )
return nil
}
var (
pattern_ResourceService_CreateResource_0 = runtime . MustPattern ( runtime . NewPattern ( 1 , [ ] int { 2 , 0 , 2 , 1 , 2 , 2 } , [ ] string { "api" , "v1" , "resources" } , "" ) )
pattern_ResourceService_ListResources_0 = runtime . MustPattern ( runtime . NewPattern ( 1 , [ ] int { 2 , 0 , 2 , 1 , 2 , 2 } , [ ] string { "api" , "v1" , "resources" } , "" ) )
pattern_ResourceService_GetResource_0 = runtime . MustPattern ( runtime . NewPattern ( 1 , [ ] int { 2 , 0 , 2 , 1 , 2 , 2 , 1 , 0 , 4 , 2 , 5 , 3 } , [ ] string { "api" , "v1" , "resources" , "name" } , "" ) )
pattern_ResourceService_GetResourceByUid_0 = runtime . MustPattern ( runtime . NewPattern ( 1 , [ ] int { 2 , 0 , 2 , 1 , 2 , 2 , 1 , 0 , 4 , 1 , 5 , 3 } , [ ] string { "api" , "v1" , "resources:by-uid" , "uid" } , "" ) )
pattern_ResourceService_CreateResource_0 = runtime . MustPattern ( runtime . NewPattern ( 1 , [ ] int { 2 , 0 , 2 , 1 , 2 , 2 } , [ ] string { "api" , "v1" , "resources" } , "" ) )
pattern_ResourceService_ListResources_0 = runtime . MustPattern ( runtime . NewPattern ( 1 , [ ] int { 2 , 0 , 2 , 1 , 2 , 2 } , [ ] string { "api" , "v1" , "resources" } , "" ) )
pattern_ResourceService_GetResource_0 = runtime . MustPattern ( runtime . NewPattern ( 1 , [ ] int { 2 , 0 , 2 , 1 , 2 , 2 , 1 , 0 , 4 , 2 , 5 , 3 } , [ ] string { "api" , "v1" , "resources" , "name" } , "" ) )
pattern_ResourceService_GetResourceByUid_0 = runtime . MustPattern ( runtime . NewPattern ( 1 , [ ] int { 2 , 0 , 2 , 1 , 2 , 2 , 1 , 0 , 4 , 1 , 5 , 3 } , [ ] string { "api" , "v1" , "resources:by-uid" , "uid" } , "" ) )
pattern_ResourceService_GetResourceBinary_0 = runtime . MustPattern ( runtime . NewPattern ( 1 , [ ] int { 2 , 0 , 2 , 1 , 1 , 0 , 4 , 2 , 5 , 2 , 1 , 0 , 4 , 1 , 5 , 3 } , [ ] string { "file" , "resources" , "name" , "filename" } , "" ) )
pattern_ResourceService_UpdateResource_0 = runtime . MustPattern ( runtime . NewPattern ( 1 , [ ] int { 2 , 0 , 2 , 1 , 2 , 2 , 1 , 0 , 4 , 2 , 5 , 3 } , [ ] string { "api" , "v1" , "resources" , "resource.name" } , "" ) )
pattern_ResourceService_DeleteResource_0 = runtime . MustPattern ( runtime . NewPattern ( 1 , [ ] int { 2 , 0 , 2 , 1 , 2 , 2 , 1 , 0 , 4 , 2 , 5 , 3 } , [ ] string { "api" , "v1" , "resources" , "name" } , "" ) )
pattern_ResourceService_UpdateResource_0 = runtime . MustPattern ( runtime . NewPattern ( 1 , [ ] int { 2 , 0 , 2 , 1 , 2 , 2 , 1 , 0 , 4 , 2 , 5 , 3 } , [ ] string { "api" , "v1" , "resources" , "resource.name" } , "" ) )
pattern_ResourceService_DeleteResource_0 = runtime . MustPattern ( runtime . NewPattern ( 1 , [ ] int { 2 , 0 , 2 , 1 , 2 , 2 , 1 , 0 , 4 , 2 , 5 , 3 } , [ ] string { "api" , "v1" , "resources" , "name" } , "" ) )
)
var (
forward_ResourceService_CreateResource_0 = runtime . ForwardResponseMessage
forward_ResourceService_ListResources_0 = runtime . ForwardResponseMessage
forward_ResourceService_GetResource_0 = runtime . ForwardResponseMessage
forward_ResourceService_GetResourceByUid_0 = runtime . ForwardResponseMessage
forward_ResourceService_CreateResource_0 = runtime . ForwardResponseMessage
forward_ResourceService_ListResources_0 = runtime . ForwardResponseMessage
forward_ResourceService_GetResource_0 = runtime . ForwardResponseMessage
forward_ResourceService_GetResourceByUid_0 = runtime . ForwardResponseMessage
forward_ResourceService_GetResourceBinary_0 = runtime . ForwardResponseMessage
forward_ResourceService_UpdateResource_0 = runtime . ForwardResponseMessage
forward_ResourceService_DeleteResource_0 = runtime . ForwardResponseMessage
forward_ResourceService_UpdateResource_0 = runtime . ForwardResponseMessage
forward_ResourceService_DeleteResource_0 = runtime . ForwardResponseMessage
)