resource_service.pb.gw.go 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583
  1. // Code generated by protoc-gen-grpc-gateway. DO NOT EDIT.
  2. // source: api/v1/resource_service.proto
  3. /*
  4. Package apiv1 is a reverse proxy.
  5. It translates gRPC into RESTful JSON APIs.
  6. */
  7. package apiv1
  8. import (
  9. "context"
  10. "errors"
  11. "io"
  12. "net/http"
  13. "github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
  14. "github.com/grpc-ecosystem/grpc-gateway/v2/utilities"
  15. "google.golang.org/grpc"
  16. "google.golang.org/grpc/codes"
  17. "google.golang.org/grpc/grpclog"
  18. "google.golang.org/grpc/metadata"
  19. "google.golang.org/grpc/status"
  20. "google.golang.org/protobuf/proto"
  21. )
  22. // Suppress "imported and not used" errors
  23. var (
  24. _ codes.Code
  25. _ io.Reader
  26. _ status.Status
  27. _ = errors.New
  28. _ = runtime.String
  29. _ = utilities.NewDoubleArray
  30. _ = metadata.Join
  31. )
  32. 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) {
  33. var (
  34. protoReq CreateResourceRequest
  35. metadata runtime.ServerMetadata
  36. )
  37. if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Resource); err != nil && !errors.Is(err, io.EOF) {
  38. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  39. }
  40. msg, err := client.CreateResource(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  41. return msg, metadata, err
  42. }
  43. 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) {
  44. var (
  45. protoReq CreateResourceRequest
  46. metadata runtime.ServerMetadata
  47. )
  48. if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Resource); err != nil && !errors.Is(err, io.EOF) {
  49. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  50. }
  51. msg, err := server.CreateResource(ctx, &protoReq)
  52. return msg, metadata, err
  53. }
  54. 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) {
  55. var (
  56. protoReq ListResourcesRequest
  57. metadata runtime.ServerMetadata
  58. )
  59. msg, err := client.ListResources(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  60. return msg, metadata, err
  61. }
  62. 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) {
  63. var (
  64. protoReq ListResourcesRequest
  65. metadata runtime.ServerMetadata
  66. )
  67. msg, err := server.ListResources(ctx, &protoReq)
  68. return msg, metadata, err
  69. }
  70. 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) {
  71. var (
  72. protoReq GetResourceRequest
  73. metadata runtime.ServerMetadata
  74. err error
  75. )
  76. val, ok := pathParams["name"]
  77. if !ok {
  78. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  79. }
  80. protoReq.Name, err = runtime.String(val)
  81. if err != nil {
  82. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  83. }
  84. msg, err := client.GetResource(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  85. return msg, metadata, err
  86. }
  87. 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) {
  88. var (
  89. protoReq GetResourceRequest
  90. metadata runtime.ServerMetadata
  91. err error
  92. )
  93. val, ok := pathParams["name"]
  94. if !ok {
  95. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  96. }
  97. protoReq.Name, err = runtime.String(val)
  98. if err != nil {
  99. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  100. }
  101. msg, err := server.GetResource(ctx, &protoReq)
  102. return msg, metadata, err
  103. }
  104. 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}}
  105. 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) {
  106. var (
  107. protoReq GetResourceBinaryRequest
  108. metadata runtime.ServerMetadata
  109. err error
  110. )
  111. val, ok := pathParams["name"]
  112. if !ok {
  113. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  114. }
  115. protoReq.Name, err = runtime.String(val)
  116. if err != nil {
  117. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  118. }
  119. val, ok = pathParams["filename"]
  120. if !ok {
  121. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "filename")
  122. }
  123. protoReq.Filename, err = runtime.String(val)
  124. if err != nil {
  125. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "filename", err)
  126. }
  127. if err := req.ParseForm(); err != nil {
  128. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  129. }
  130. if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_ResourceService_GetResourceBinary_0); err != nil {
  131. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  132. }
  133. msg, err := client.GetResourceBinary(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  134. return msg, metadata, err
  135. }
  136. 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) {
  137. var (
  138. protoReq GetResourceBinaryRequest
  139. metadata runtime.ServerMetadata
  140. err error
  141. )
  142. val, ok := pathParams["name"]
  143. if !ok {
  144. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  145. }
  146. protoReq.Name, err = runtime.String(val)
  147. if err != nil {
  148. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  149. }
  150. val, ok = pathParams["filename"]
  151. if !ok {
  152. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "filename")
  153. }
  154. protoReq.Filename, err = runtime.String(val)
  155. if err != nil {
  156. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "filename", err)
  157. }
  158. if err := req.ParseForm(); err != nil {
  159. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  160. }
  161. if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_ResourceService_GetResourceBinary_0); err != nil {
  162. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  163. }
  164. msg, err := server.GetResourceBinary(ctx, &protoReq)
  165. return msg, metadata, err
  166. }
  167. 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}}
  168. 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) {
  169. var (
  170. protoReq UpdateResourceRequest
  171. metadata runtime.ServerMetadata
  172. err error
  173. )
  174. newReader, berr := utilities.IOReaderFactory(req.Body)
  175. if berr != nil {
  176. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
  177. }
  178. if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Resource); err != nil && !errors.Is(err, io.EOF) {
  179. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  180. }
  181. if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
  182. if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Resource); err != nil {
  183. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  184. } else {
  185. protoReq.UpdateMask = fieldMask
  186. }
  187. }
  188. val, ok := pathParams["resource.name"]
  189. if !ok {
  190. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "resource.name")
  191. }
  192. err = runtime.PopulateFieldFromPath(&protoReq, "resource.name", val)
  193. if err != nil {
  194. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "resource.name", err)
  195. }
  196. if err := req.ParseForm(); err != nil {
  197. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  198. }
  199. if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_ResourceService_UpdateResource_0); err != nil {
  200. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  201. }
  202. msg, err := client.UpdateResource(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  203. return msg, metadata, err
  204. }
  205. 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) {
  206. var (
  207. protoReq UpdateResourceRequest
  208. metadata runtime.ServerMetadata
  209. err error
  210. )
  211. newReader, berr := utilities.IOReaderFactory(req.Body)
  212. if berr != nil {
  213. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
  214. }
  215. if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Resource); err != nil && !errors.Is(err, io.EOF) {
  216. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  217. }
  218. if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
  219. if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Resource); err != nil {
  220. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  221. } else {
  222. protoReq.UpdateMask = fieldMask
  223. }
  224. }
  225. val, ok := pathParams["resource.name"]
  226. if !ok {
  227. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "resource.name")
  228. }
  229. err = runtime.PopulateFieldFromPath(&protoReq, "resource.name", val)
  230. if err != nil {
  231. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "resource.name", err)
  232. }
  233. if err := req.ParseForm(); err != nil {
  234. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  235. }
  236. if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_ResourceService_UpdateResource_0); err != nil {
  237. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  238. }
  239. msg, err := server.UpdateResource(ctx, &protoReq)
  240. return msg, metadata, err
  241. }
  242. 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) {
  243. var (
  244. protoReq DeleteResourceRequest
  245. metadata runtime.ServerMetadata
  246. err error
  247. )
  248. val, ok := pathParams["name"]
  249. if !ok {
  250. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  251. }
  252. protoReq.Name, err = runtime.String(val)
  253. if err != nil {
  254. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  255. }
  256. msg, err := client.DeleteResource(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  257. return msg, metadata, err
  258. }
  259. 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) {
  260. var (
  261. protoReq DeleteResourceRequest
  262. metadata runtime.ServerMetadata
  263. err error
  264. )
  265. val, ok := pathParams["name"]
  266. if !ok {
  267. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  268. }
  269. protoReq.Name, err = runtime.String(val)
  270. if err != nil {
  271. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  272. }
  273. msg, err := server.DeleteResource(ctx, &protoReq)
  274. return msg, metadata, err
  275. }
  276. // RegisterResourceServiceHandlerServer registers the http handlers for service ResourceService to "mux".
  277. // UnaryRPC :call ResourceServiceServer directly.
  278. // StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
  279. // Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterResourceServiceHandlerFromEndpoint instead.
  280. // 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.
  281. func RegisterResourceServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ResourceServiceServer) error {
  282. mux.Handle(http.MethodPost, pattern_ResourceService_CreateResource_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  283. ctx, cancel := context.WithCancel(req.Context())
  284. defer cancel()
  285. var stream runtime.ServerTransportStream
  286. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  287. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  288. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.ResourceService/CreateResource", runtime.WithHTTPPathPattern("/api/v1/resources"))
  289. if err != nil {
  290. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  291. return
  292. }
  293. resp, md, err := local_request_ResourceService_CreateResource_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  294. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  295. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  296. if err != nil {
  297. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  298. return
  299. }
  300. forward_ResourceService_CreateResource_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  301. })
  302. mux.Handle(http.MethodGet, pattern_ResourceService_ListResources_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  303. ctx, cancel := context.WithCancel(req.Context())
  304. defer cancel()
  305. var stream runtime.ServerTransportStream
  306. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  307. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  308. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.ResourceService/ListResources", runtime.WithHTTPPathPattern("/api/v1/resources"))
  309. if err != nil {
  310. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  311. return
  312. }
  313. resp, md, err := local_request_ResourceService_ListResources_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  314. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  315. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  316. if err != nil {
  317. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  318. return
  319. }
  320. forward_ResourceService_ListResources_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  321. })
  322. mux.Handle(http.MethodGet, pattern_ResourceService_GetResource_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  323. ctx, cancel := context.WithCancel(req.Context())
  324. defer cancel()
  325. var stream runtime.ServerTransportStream
  326. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  327. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  328. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.ResourceService/GetResource", runtime.WithHTTPPathPattern("/api/v1/{name=resources/*}"))
  329. if err != nil {
  330. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  331. return
  332. }
  333. resp, md, err := local_request_ResourceService_GetResource_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  334. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  335. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  336. if err != nil {
  337. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  338. return
  339. }
  340. forward_ResourceService_GetResource_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  341. })
  342. mux.Handle(http.MethodGet, pattern_ResourceService_GetResourceBinary_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  343. ctx, cancel := context.WithCancel(req.Context())
  344. defer cancel()
  345. var stream runtime.ServerTransportStream
  346. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  347. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  348. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.ResourceService/GetResourceBinary", runtime.WithHTTPPathPattern("/file/{name=resources/*}/{filename}"))
  349. if err != nil {
  350. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  351. return
  352. }
  353. resp, md, err := local_request_ResourceService_GetResourceBinary_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  354. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  355. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  356. if err != nil {
  357. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  358. return
  359. }
  360. forward_ResourceService_GetResourceBinary_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  361. })
  362. mux.Handle(http.MethodPatch, pattern_ResourceService_UpdateResource_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  363. ctx, cancel := context.WithCancel(req.Context())
  364. defer cancel()
  365. var stream runtime.ServerTransportStream
  366. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  367. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  368. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.ResourceService/UpdateResource", runtime.WithHTTPPathPattern("/api/v1/{resource.name=resources/*}"))
  369. if err != nil {
  370. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  371. return
  372. }
  373. resp, md, err := local_request_ResourceService_UpdateResource_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  374. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  375. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  376. if err != nil {
  377. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  378. return
  379. }
  380. forward_ResourceService_UpdateResource_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  381. })
  382. mux.Handle(http.MethodDelete, pattern_ResourceService_DeleteResource_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  383. ctx, cancel := context.WithCancel(req.Context())
  384. defer cancel()
  385. var stream runtime.ServerTransportStream
  386. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  387. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  388. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.ResourceService/DeleteResource", runtime.WithHTTPPathPattern("/api/v1/{name=resources/*}"))
  389. if err != nil {
  390. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  391. return
  392. }
  393. resp, md, err := local_request_ResourceService_DeleteResource_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  394. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  395. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  396. if err != nil {
  397. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  398. return
  399. }
  400. forward_ResourceService_DeleteResource_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  401. })
  402. return nil
  403. }
  404. // RegisterResourceServiceHandlerFromEndpoint is same as RegisterResourceServiceHandler but
  405. // automatically dials to "endpoint" and closes the connection when "ctx" gets done.
  406. func RegisterResourceServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) {
  407. conn, err := grpc.NewClient(endpoint, opts...)
  408. if err != nil {
  409. return err
  410. }
  411. defer func() {
  412. if err != nil {
  413. if cerr := conn.Close(); cerr != nil {
  414. grpclog.Errorf("Failed to close conn to %s: %v", endpoint, cerr)
  415. }
  416. return
  417. }
  418. go func() {
  419. <-ctx.Done()
  420. if cerr := conn.Close(); cerr != nil {
  421. grpclog.Errorf("Failed to close conn to %s: %v", endpoint, cerr)
  422. }
  423. }()
  424. }()
  425. return RegisterResourceServiceHandler(ctx, mux, conn)
  426. }
  427. // RegisterResourceServiceHandler registers the http handlers for service ResourceService to "mux".
  428. // The handlers forward requests to the grpc endpoint over "conn".
  429. func RegisterResourceServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error {
  430. return RegisterResourceServiceHandlerClient(ctx, mux, NewResourceServiceClient(conn))
  431. }
  432. // RegisterResourceServiceHandlerClient registers the http handlers for service ResourceService
  433. // to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ResourceServiceClient".
  434. // Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ResourceServiceClient"
  435. // doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in
  436. // "ResourceServiceClient" to call the correct interceptors. This client ignores the HTTP middlewares.
  437. func RegisterResourceServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ResourceServiceClient) error {
  438. mux.Handle(http.MethodPost, pattern_ResourceService_CreateResource_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  439. ctx, cancel := context.WithCancel(req.Context())
  440. defer cancel()
  441. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  442. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.ResourceService/CreateResource", runtime.WithHTTPPathPattern("/api/v1/resources"))
  443. if err != nil {
  444. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  445. return
  446. }
  447. resp, md, err := request_ResourceService_CreateResource_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  448. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  449. if err != nil {
  450. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  451. return
  452. }
  453. forward_ResourceService_CreateResource_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  454. })
  455. mux.Handle(http.MethodGet, pattern_ResourceService_ListResources_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  456. ctx, cancel := context.WithCancel(req.Context())
  457. defer cancel()
  458. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  459. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.ResourceService/ListResources", runtime.WithHTTPPathPattern("/api/v1/resources"))
  460. if err != nil {
  461. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  462. return
  463. }
  464. resp, md, err := request_ResourceService_ListResources_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  465. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  466. if err != nil {
  467. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  468. return
  469. }
  470. forward_ResourceService_ListResources_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  471. })
  472. mux.Handle(http.MethodGet, pattern_ResourceService_GetResource_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  473. ctx, cancel := context.WithCancel(req.Context())
  474. defer cancel()
  475. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  476. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.ResourceService/GetResource", runtime.WithHTTPPathPattern("/api/v1/{name=resources/*}"))
  477. if err != nil {
  478. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  479. return
  480. }
  481. resp, md, err := request_ResourceService_GetResource_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  482. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  483. if err != nil {
  484. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  485. return
  486. }
  487. forward_ResourceService_GetResource_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  488. })
  489. mux.Handle(http.MethodGet, pattern_ResourceService_GetResourceBinary_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  490. ctx, cancel := context.WithCancel(req.Context())
  491. defer cancel()
  492. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  493. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.ResourceService/GetResourceBinary", runtime.WithHTTPPathPattern("/file/{name=resources/*}/{filename}"))
  494. if err != nil {
  495. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  496. return
  497. }
  498. resp, md, err := request_ResourceService_GetResourceBinary_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  499. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  500. if err != nil {
  501. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  502. return
  503. }
  504. forward_ResourceService_GetResourceBinary_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  505. })
  506. mux.Handle(http.MethodPatch, pattern_ResourceService_UpdateResource_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  507. ctx, cancel := context.WithCancel(req.Context())
  508. defer cancel()
  509. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  510. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.ResourceService/UpdateResource", runtime.WithHTTPPathPattern("/api/v1/{resource.name=resources/*}"))
  511. if err != nil {
  512. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  513. return
  514. }
  515. resp, md, err := request_ResourceService_UpdateResource_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  516. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  517. if err != nil {
  518. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  519. return
  520. }
  521. forward_ResourceService_UpdateResource_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  522. })
  523. mux.Handle(http.MethodDelete, pattern_ResourceService_DeleteResource_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  524. ctx, cancel := context.WithCancel(req.Context())
  525. defer cancel()
  526. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  527. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.ResourceService/DeleteResource", runtime.WithHTTPPathPattern("/api/v1/{name=resources/*}"))
  528. if err != nil {
  529. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  530. return
  531. }
  532. resp, md, err := request_ResourceService_DeleteResource_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  533. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  534. if err != nil {
  535. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  536. return
  537. }
  538. forward_ResourceService_DeleteResource_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  539. })
  540. return nil
  541. }
  542. var (
  543. pattern_ResourceService_CreateResource_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"api", "v1", "resources"}, ""))
  544. pattern_ResourceService_ListResources_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"api", "v1", "resources"}, ""))
  545. 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"}, ""))
  546. 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"}, ""))
  547. 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"}, ""))
  548. 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"}, ""))
  549. )
  550. var (
  551. forward_ResourceService_CreateResource_0 = runtime.ForwardResponseMessage
  552. forward_ResourceService_ListResources_0 = runtime.ForwardResponseMessage
  553. forward_ResourceService_GetResource_0 = runtime.ForwardResponseMessage
  554. forward_ResourceService_GetResourceBinary_0 = runtime.ForwardResponseMessage
  555. forward_ResourceService_UpdateResource_0 = runtime.ForwardResponseMessage
  556. forward_ResourceService_DeleteResource_0 = runtime.ForwardResponseMessage
  557. )