idp_service.pb.gw.go 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589
  1. // Code generated by protoc-gen-grpc-gateway. DO NOT EDIT.
  2. // source: api/v1/idp_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. "io"
  11. "net/http"
  12. "github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
  13. "github.com/grpc-ecosystem/grpc-gateway/v2/utilities"
  14. "google.golang.org/grpc"
  15. "google.golang.org/grpc/codes"
  16. "google.golang.org/grpc/grpclog"
  17. "google.golang.org/grpc/metadata"
  18. "google.golang.org/grpc/status"
  19. "google.golang.org/protobuf/proto"
  20. )
  21. // Suppress "imported and not used" errors
  22. var _ codes.Code
  23. var _ io.Reader
  24. var _ status.Status
  25. var _ = runtime.String
  26. var _ = utilities.NewDoubleArray
  27. var _ = metadata.Join
  28. func request_IdentityProviderService_ListIdentityProviders_0(ctx context.Context, marshaler runtime.Marshaler, client IdentityProviderServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  29. var protoReq ListIdentityProvidersRequest
  30. var metadata runtime.ServerMetadata
  31. msg, err := client.ListIdentityProviders(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  32. return msg, metadata, err
  33. }
  34. func local_request_IdentityProviderService_ListIdentityProviders_0(ctx context.Context, marshaler runtime.Marshaler, server IdentityProviderServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  35. var protoReq ListIdentityProvidersRequest
  36. var metadata runtime.ServerMetadata
  37. msg, err := server.ListIdentityProviders(ctx, &protoReq)
  38. return msg, metadata, err
  39. }
  40. func request_IdentityProviderService_GetIdentityProvider_0(ctx context.Context, marshaler runtime.Marshaler, client IdentityProviderServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  41. var protoReq GetIdentityProviderRequest
  42. var metadata runtime.ServerMetadata
  43. var (
  44. val string
  45. ok bool
  46. err error
  47. _ = err
  48. )
  49. val, ok = pathParams["name"]
  50. if !ok {
  51. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  52. }
  53. protoReq.Name, err = runtime.String(val)
  54. if err != nil {
  55. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  56. }
  57. msg, err := client.GetIdentityProvider(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  58. return msg, metadata, err
  59. }
  60. func local_request_IdentityProviderService_GetIdentityProvider_0(ctx context.Context, marshaler runtime.Marshaler, server IdentityProviderServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  61. var protoReq GetIdentityProviderRequest
  62. var metadata runtime.ServerMetadata
  63. var (
  64. val string
  65. ok bool
  66. err error
  67. _ = err
  68. )
  69. val, ok = pathParams["name"]
  70. if !ok {
  71. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  72. }
  73. protoReq.Name, err = runtime.String(val)
  74. if err != nil {
  75. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  76. }
  77. msg, err := server.GetIdentityProvider(ctx, &protoReq)
  78. return msg, metadata, err
  79. }
  80. func request_IdentityProviderService_CreateIdentityProvider_0(ctx context.Context, marshaler runtime.Marshaler, client IdentityProviderServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  81. var protoReq CreateIdentityProviderRequest
  82. var metadata runtime.ServerMetadata
  83. if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.IdentityProvider); err != nil && err != io.EOF {
  84. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  85. }
  86. msg, err := client.CreateIdentityProvider(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  87. return msg, metadata, err
  88. }
  89. func local_request_IdentityProviderService_CreateIdentityProvider_0(ctx context.Context, marshaler runtime.Marshaler, server IdentityProviderServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  90. var protoReq CreateIdentityProviderRequest
  91. var metadata runtime.ServerMetadata
  92. if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.IdentityProvider); err != nil && err != io.EOF {
  93. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  94. }
  95. msg, err := server.CreateIdentityProvider(ctx, &protoReq)
  96. return msg, metadata, err
  97. }
  98. var (
  99. filter_IdentityProviderService_UpdateIdentityProvider_0 = &utilities.DoubleArray{Encoding: map[string]int{"identity_provider": 0, "name": 1}, Base: []int{1, 2, 1, 0, 0}, Check: []int{0, 1, 2, 3, 2}}
  100. )
  101. func request_IdentityProviderService_UpdateIdentityProvider_0(ctx context.Context, marshaler runtime.Marshaler, client IdentityProviderServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  102. var protoReq UpdateIdentityProviderRequest
  103. var metadata runtime.ServerMetadata
  104. newReader, berr := utilities.IOReaderFactory(req.Body)
  105. if berr != nil {
  106. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
  107. }
  108. if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.IdentityProvider); err != nil && err != io.EOF {
  109. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  110. }
  111. if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
  112. if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.IdentityProvider); err != nil {
  113. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  114. } else {
  115. protoReq.UpdateMask = fieldMask
  116. }
  117. }
  118. var (
  119. val string
  120. ok bool
  121. err error
  122. _ = err
  123. )
  124. val, ok = pathParams["identity_provider.name"]
  125. if !ok {
  126. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "identity_provider.name")
  127. }
  128. err = runtime.PopulateFieldFromPath(&protoReq, "identity_provider.name", val)
  129. if err != nil {
  130. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "identity_provider.name", err)
  131. }
  132. if err := req.ParseForm(); err != nil {
  133. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  134. }
  135. if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_IdentityProviderService_UpdateIdentityProvider_0); err != nil {
  136. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  137. }
  138. msg, err := client.UpdateIdentityProvider(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  139. return msg, metadata, err
  140. }
  141. func local_request_IdentityProviderService_UpdateIdentityProvider_0(ctx context.Context, marshaler runtime.Marshaler, server IdentityProviderServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  142. var protoReq UpdateIdentityProviderRequest
  143. var metadata runtime.ServerMetadata
  144. newReader, berr := utilities.IOReaderFactory(req.Body)
  145. if berr != nil {
  146. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
  147. }
  148. if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.IdentityProvider); err != nil && err != io.EOF {
  149. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  150. }
  151. if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
  152. if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.IdentityProvider); err != nil {
  153. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  154. } else {
  155. protoReq.UpdateMask = fieldMask
  156. }
  157. }
  158. var (
  159. val string
  160. ok bool
  161. err error
  162. _ = err
  163. )
  164. val, ok = pathParams["identity_provider.name"]
  165. if !ok {
  166. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "identity_provider.name")
  167. }
  168. err = runtime.PopulateFieldFromPath(&protoReq, "identity_provider.name", val)
  169. if err != nil {
  170. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "identity_provider.name", err)
  171. }
  172. if err := req.ParseForm(); err != nil {
  173. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  174. }
  175. if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_IdentityProviderService_UpdateIdentityProvider_0); err != nil {
  176. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  177. }
  178. msg, err := server.UpdateIdentityProvider(ctx, &protoReq)
  179. return msg, metadata, err
  180. }
  181. func request_IdentityProviderService_DeleteIdentityProvider_0(ctx context.Context, marshaler runtime.Marshaler, client IdentityProviderServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  182. var protoReq DeleteIdentityProviderRequest
  183. var metadata runtime.ServerMetadata
  184. var (
  185. val string
  186. ok bool
  187. err error
  188. _ = err
  189. )
  190. val, ok = pathParams["name"]
  191. if !ok {
  192. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  193. }
  194. protoReq.Name, err = runtime.String(val)
  195. if err != nil {
  196. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  197. }
  198. msg, err := client.DeleteIdentityProvider(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  199. return msg, metadata, err
  200. }
  201. func local_request_IdentityProviderService_DeleteIdentityProvider_0(ctx context.Context, marshaler runtime.Marshaler, server IdentityProviderServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  202. var protoReq DeleteIdentityProviderRequest
  203. var metadata runtime.ServerMetadata
  204. var (
  205. val string
  206. ok bool
  207. err error
  208. _ = err
  209. )
  210. val, ok = pathParams["name"]
  211. if !ok {
  212. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  213. }
  214. protoReq.Name, err = runtime.String(val)
  215. if err != nil {
  216. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  217. }
  218. msg, err := server.DeleteIdentityProvider(ctx, &protoReq)
  219. return msg, metadata, err
  220. }
  221. // RegisterIdentityProviderServiceHandlerServer registers the http handlers for service IdentityProviderService to "mux".
  222. // UnaryRPC :call IdentityProviderServiceServer directly.
  223. // StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
  224. // Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterIdentityProviderServiceHandlerFromEndpoint instead.
  225. func RegisterIdentityProviderServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server IdentityProviderServiceServer) error {
  226. mux.Handle("GET", pattern_IdentityProviderService_ListIdentityProviders_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  227. ctx, cancel := context.WithCancel(req.Context())
  228. defer cancel()
  229. var stream runtime.ServerTransportStream
  230. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  231. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  232. var err error
  233. var annotatedContext context.Context
  234. annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.IdentityProviderService/ListIdentityProviders", runtime.WithHTTPPathPattern("/api/v1/identityProviders"))
  235. if err != nil {
  236. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  237. return
  238. }
  239. resp, md, err := local_request_IdentityProviderService_ListIdentityProviders_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  240. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  241. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  242. if err != nil {
  243. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  244. return
  245. }
  246. forward_IdentityProviderService_ListIdentityProviders_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  247. })
  248. mux.Handle("GET", pattern_IdentityProviderService_GetIdentityProvider_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  249. ctx, cancel := context.WithCancel(req.Context())
  250. defer cancel()
  251. var stream runtime.ServerTransportStream
  252. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  253. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  254. var err error
  255. var annotatedContext context.Context
  256. annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.IdentityProviderService/GetIdentityProvider", runtime.WithHTTPPathPattern("/api/v1/{name=identityProviders/*}"))
  257. if err != nil {
  258. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  259. return
  260. }
  261. resp, md, err := local_request_IdentityProviderService_GetIdentityProvider_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  262. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  263. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  264. if err != nil {
  265. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  266. return
  267. }
  268. forward_IdentityProviderService_GetIdentityProvider_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  269. })
  270. mux.Handle("POST", pattern_IdentityProviderService_CreateIdentityProvider_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  271. ctx, cancel := context.WithCancel(req.Context())
  272. defer cancel()
  273. var stream runtime.ServerTransportStream
  274. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  275. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  276. var err error
  277. var annotatedContext context.Context
  278. annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.IdentityProviderService/CreateIdentityProvider", runtime.WithHTTPPathPattern("/api/v1/identityProviders"))
  279. if err != nil {
  280. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  281. return
  282. }
  283. resp, md, err := local_request_IdentityProviderService_CreateIdentityProvider_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  284. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  285. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  286. if err != nil {
  287. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  288. return
  289. }
  290. forward_IdentityProviderService_CreateIdentityProvider_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  291. })
  292. mux.Handle("PATCH", pattern_IdentityProviderService_UpdateIdentityProvider_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  293. ctx, cancel := context.WithCancel(req.Context())
  294. defer cancel()
  295. var stream runtime.ServerTransportStream
  296. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  297. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  298. var err error
  299. var annotatedContext context.Context
  300. annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.IdentityProviderService/UpdateIdentityProvider", runtime.WithHTTPPathPattern("/api/v1/{identity_provider.name=identityProviders/*}"))
  301. if err != nil {
  302. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  303. return
  304. }
  305. resp, md, err := local_request_IdentityProviderService_UpdateIdentityProvider_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  306. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  307. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  308. if err != nil {
  309. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  310. return
  311. }
  312. forward_IdentityProviderService_UpdateIdentityProvider_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  313. })
  314. mux.Handle("DELETE", pattern_IdentityProviderService_DeleteIdentityProvider_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  315. ctx, cancel := context.WithCancel(req.Context())
  316. defer cancel()
  317. var stream runtime.ServerTransportStream
  318. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  319. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  320. var err error
  321. var annotatedContext context.Context
  322. annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.IdentityProviderService/DeleteIdentityProvider", runtime.WithHTTPPathPattern("/api/v1/{name=identityProviders/*}"))
  323. if err != nil {
  324. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  325. return
  326. }
  327. resp, md, err := local_request_IdentityProviderService_DeleteIdentityProvider_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  328. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  329. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  330. if err != nil {
  331. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  332. return
  333. }
  334. forward_IdentityProviderService_DeleteIdentityProvider_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  335. })
  336. return nil
  337. }
  338. // RegisterIdentityProviderServiceHandlerFromEndpoint is same as RegisterIdentityProviderServiceHandler but
  339. // automatically dials to "endpoint" and closes the connection when "ctx" gets done.
  340. func RegisterIdentityProviderServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) {
  341. conn, err := grpc.NewClient(endpoint, opts...)
  342. if err != nil {
  343. return err
  344. }
  345. defer func() {
  346. if err != nil {
  347. if cerr := conn.Close(); cerr != nil {
  348. grpclog.Errorf("Failed to close conn to %s: %v", endpoint, cerr)
  349. }
  350. return
  351. }
  352. go func() {
  353. <-ctx.Done()
  354. if cerr := conn.Close(); cerr != nil {
  355. grpclog.Errorf("Failed to close conn to %s: %v", endpoint, cerr)
  356. }
  357. }()
  358. }()
  359. return RegisterIdentityProviderServiceHandler(ctx, mux, conn)
  360. }
  361. // RegisterIdentityProviderServiceHandler registers the http handlers for service IdentityProviderService to "mux".
  362. // The handlers forward requests to the grpc endpoint over "conn".
  363. func RegisterIdentityProviderServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error {
  364. return RegisterIdentityProviderServiceHandlerClient(ctx, mux, NewIdentityProviderServiceClient(conn))
  365. }
  366. // RegisterIdentityProviderServiceHandlerClient registers the http handlers for service IdentityProviderService
  367. // to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "IdentityProviderServiceClient".
  368. // Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "IdentityProviderServiceClient"
  369. // doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in
  370. // "IdentityProviderServiceClient" to call the correct interceptors.
  371. func RegisterIdentityProviderServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client IdentityProviderServiceClient) error {
  372. mux.Handle("GET", pattern_IdentityProviderService_ListIdentityProviders_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  373. ctx, cancel := context.WithCancel(req.Context())
  374. defer cancel()
  375. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  376. var err error
  377. var annotatedContext context.Context
  378. annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.IdentityProviderService/ListIdentityProviders", runtime.WithHTTPPathPattern("/api/v1/identityProviders"))
  379. if err != nil {
  380. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  381. return
  382. }
  383. resp, md, err := request_IdentityProviderService_ListIdentityProviders_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  384. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  385. if err != nil {
  386. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  387. return
  388. }
  389. forward_IdentityProviderService_ListIdentityProviders_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  390. })
  391. mux.Handle("GET", pattern_IdentityProviderService_GetIdentityProvider_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  392. ctx, cancel := context.WithCancel(req.Context())
  393. defer cancel()
  394. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  395. var err error
  396. var annotatedContext context.Context
  397. annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.IdentityProviderService/GetIdentityProvider", runtime.WithHTTPPathPattern("/api/v1/{name=identityProviders/*}"))
  398. if err != nil {
  399. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  400. return
  401. }
  402. resp, md, err := request_IdentityProviderService_GetIdentityProvider_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  403. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  404. if err != nil {
  405. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  406. return
  407. }
  408. forward_IdentityProviderService_GetIdentityProvider_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  409. })
  410. mux.Handle("POST", pattern_IdentityProviderService_CreateIdentityProvider_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  411. ctx, cancel := context.WithCancel(req.Context())
  412. defer cancel()
  413. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  414. var err error
  415. var annotatedContext context.Context
  416. annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.IdentityProviderService/CreateIdentityProvider", runtime.WithHTTPPathPattern("/api/v1/identityProviders"))
  417. if err != nil {
  418. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  419. return
  420. }
  421. resp, md, err := request_IdentityProviderService_CreateIdentityProvider_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  422. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  423. if err != nil {
  424. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  425. return
  426. }
  427. forward_IdentityProviderService_CreateIdentityProvider_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  428. })
  429. mux.Handle("PATCH", pattern_IdentityProviderService_UpdateIdentityProvider_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  430. ctx, cancel := context.WithCancel(req.Context())
  431. defer cancel()
  432. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  433. var err error
  434. var annotatedContext context.Context
  435. annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.IdentityProviderService/UpdateIdentityProvider", runtime.WithHTTPPathPattern("/api/v1/{identity_provider.name=identityProviders/*}"))
  436. if err != nil {
  437. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  438. return
  439. }
  440. resp, md, err := request_IdentityProviderService_UpdateIdentityProvider_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  441. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  442. if err != nil {
  443. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  444. return
  445. }
  446. forward_IdentityProviderService_UpdateIdentityProvider_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  447. })
  448. mux.Handle("DELETE", pattern_IdentityProviderService_DeleteIdentityProvider_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  449. ctx, cancel := context.WithCancel(req.Context())
  450. defer cancel()
  451. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  452. var err error
  453. var annotatedContext context.Context
  454. annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.IdentityProviderService/DeleteIdentityProvider", runtime.WithHTTPPathPattern("/api/v1/{name=identityProviders/*}"))
  455. if err != nil {
  456. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  457. return
  458. }
  459. resp, md, err := request_IdentityProviderService_DeleteIdentityProvider_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  460. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  461. if err != nil {
  462. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  463. return
  464. }
  465. forward_IdentityProviderService_DeleteIdentityProvider_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  466. })
  467. return nil
  468. }
  469. var (
  470. pattern_IdentityProviderService_ListIdentityProviders_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"api", "v1", "identityProviders"}, ""))
  471. pattern_IdentityProviderService_GetIdentityProvider_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3}, []string{"api", "v1", "identityProviders", "name"}, ""))
  472. pattern_IdentityProviderService_CreateIdentityProvider_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"api", "v1", "identityProviders"}, ""))
  473. pattern_IdentityProviderService_UpdateIdentityProvider_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3}, []string{"api", "v1", "identityProviders", "identity_provider.name"}, ""))
  474. pattern_IdentityProviderService_DeleteIdentityProvider_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3}, []string{"api", "v1", "identityProviders", "name"}, ""))
  475. )
  476. var (
  477. forward_IdentityProviderService_ListIdentityProviders_0 = runtime.ForwardResponseMessage
  478. forward_IdentityProviderService_GetIdentityProvider_0 = runtime.ForwardResponseMessage
  479. forward_IdentityProviderService_CreateIdentityProvider_0 = runtime.ForwardResponseMessage
  480. forward_IdentityProviderService_UpdateIdentityProvider_0 = runtime.ForwardResponseMessage
  481. forward_IdentityProviderService_DeleteIdentityProvider_0 = runtime.ForwardResponseMessage
  482. )