user_service.pb.gw.go 82 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603
  1. // Code generated by protoc-gen-grpc-gateway. DO NOT EDIT.
  2. // source: api/v1/user_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_UserService_ListUsers_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  33. var (
  34. protoReq ListUsersRequest
  35. metadata runtime.ServerMetadata
  36. )
  37. msg, err := client.ListUsers(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  38. return msg, metadata, err
  39. }
  40. func local_request_UserService_ListUsers_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  41. var (
  42. protoReq ListUsersRequest
  43. metadata runtime.ServerMetadata
  44. )
  45. msg, err := server.ListUsers(ctx, &protoReq)
  46. return msg, metadata, err
  47. }
  48. func request_UserService_GetUser_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  49. var (
  50. protoReq GetUserRequest
  51. metadata runtime.ServerMetadata
  52. err error
  53. )
  54. val, ok := pathParams["name"]
  55. if !ok {
  56. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  57. }
  58. protoReq.Name, err = runtime.String(val)
  59. if err != nil {
  60. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  61. }
  62. msg, err := client.GetUser(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  63. return msg, metadata, err
  64. }
  65. func local_request_UserService_GetUser_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  66. var (
  67. protoReq GetUserRequest
  68. metadata runtime.ServerMetadata
  69. err error
  70. )
  71. val, ok := pathParams["name"]
  72. if !ok {
  73. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  74. }
  75. protoReq.Name, err = runtime.String(val)
  76. if err != nil {
  77. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  78. }
  79. msg, err := server.GetUser(ctx, &protoReq)
  80. return msg, metadata, err
  81. }
  82. var filter_UserService_GetUserByUsername_0 = &utilities.DoubleArray{Encoding: map[string]int{}, Base: []int(nil), Check: []int(nil)}
  83. func request_UserService_GetUserByUsername_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  84. var (
  85. protoReq GetUserByUsernameRequest
  86. metadata runtime.ServerMetadata
  87. )
  88. if err := req.ParseForm(); err != nil {
  89. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  90. }
  91. if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_GetUserByUsername_0); err != nil {
  92. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  93. }
  94. msg, err := client.GetUserByUsername(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  95. return msg, metadata, err
  96. }
  97. func local_request_UserService_GetUserByUsername_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  98. var (
  99. protoReq GetUserByUsernameRequest
  100. metadata runtime.ServerMetadata
  101. )
  102. if err := req.ParseForm(); err != nil {
  103. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  104. }
  105. if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_GetUserByUsername_0); err != nil {
  106. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  107. }
  108. msg, err := server.GetUserByUsername(ctx, &protoReq)
  109. return msg, metadata, err
  110. }
  111. var filter_UserService_GetUserAvatarBinary_0 = &utilities.DoubleArray{Encoding: map[string]int{"name": 0}, Base: []int{1, 1, 0}, Check: []int{0, 1, 2}}
  112. func request_UserService_GetUserAvatarBinary_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  113. var (
  114. protoReq GetUserAvatarBinaryRequest
  115. metadata runtime.ServerMetadata
  116. err error
  117. )
  118. val, ok := pathParams["name"]
  119. if !ok {
  120. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  121. }
  122. protoReq.Name, err = runtime.String(val)
  123. if err != nil {
  124. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  125. }
  126. if err := req.ParseForm(); err != nil {
  127. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  128. }
  129. if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_GetUserAvatarBinary_0); err != nil {
  130. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  131. }
  132. msg, err := client.GetUserAvatarBinary(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  133. return msg, metadata, err
  134. }
  135. func local_request_UserService_GetUserAvatarBinary_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  136. var (
  137. protoReq GetUserAvatarBinaryRequest
  138. metadata runtime.ServerMetadata
  139. err error
  140. )
  141. val, ok := pathParams["name"]
  142. if !ok {
  143. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  144. }
  145. protoReq.Name, err = runtime.String(val)
  146. if err != nil {
  147. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  148. }
  149. if err := req.ParseForm(); err != nil {
  150. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  151. }
  152. if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_GetUserAvatarBinary_0); err != nil {
  153. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  154. }
  155. msg, err := server.GetUserAvatarBinary(ctx, &protoReq)
  156. return msg, metadata, err
  157. }
  158. func request_UserService_CreateUser_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  159. var (
  160. protoReq CreateUserRequest
  161. metadata runtime.ServerMetadata
  162. )
  163. if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.User); err != nil && !errors.Is(err, io.EOF) {
  164. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  165. }
  166. msg, err := client.CreateUser(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  167. return msg, metadata, err
  168. }
  169. func local_request_UserService_CreateUser_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  170. var (
  171. protoReq CreateUserRequest
  172. metadata runtime.ServerMetadata
  173. )
  174. if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.User); err != nil && !errors.Is(err, io.EOF) {
  175. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  176. }
  177. msg, err := server.CreateUser(ctx, &protoReq)
  178. return msg, metadata, err
  179. }
  180. var filter_UserService_UpdateUser_0 = &utilities.DoubleArray{Encoding: map[string]int{"user": 0, "name": 1}, Base: []int{1, 2, 1, 0, 0}, Check: []int{0, 1, 2, 3, 2}}
  181. func request_UserService_UpdateUser_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  182. var (
  183. protoReq UpdateUserRequest
  184. metadata runtime.ServerMetadata
  185. err error
  186. )
  187. newReader, berr := utilities.IOReaderFactory(req.Body)
  188. if berr != nil {
  189. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
  190. }
  191. if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.User); err != nil && !errors.Is(err, io.EOF) {
  192. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  193. }
  194. if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
  195. if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.User); err != nil {
  196. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  197. } else {
  198. protoReq.UpdateMask = fieldMask
  199. }
  200. }
  201. val, ok := pathParams["user.name"]
  202. if !ok {
  203. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "user.name")
  204. }
  205. err = runtime.PopulateFieldFromPath(&protoReq, "user.name", val)
  206. if err != nil {
  207. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "user.name", err)
  208. }
  209. if err := req.ParseForm(); err != nil {
  210. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  211. }
  212. if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_UpdateUser_0); err != nil {
  213. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  214. }
  215. msg, err := client.UpdateUser(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  216. return msg, metadata, err
  217. }
  218. func local_request_UserService_UpdateUser_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  219. var (
  220. protoReq UpdateUserRequest
  221. metadata runtime.ServerMetadata
  222. err error
  223. )
  224. newReader, berr := utilities.IOReaderFactory(req.Body)
  225. if berr != nil {
  226. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
  227. }
  228. if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.User); err != nil && !errors.Is(err, io.EOF) {
  229. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  230. }
  231. if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
  232. if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.User); err != nil {
  233. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  234. } else {
  235. protoReq.UpdateMask = fieldMask
  236. }
  237. }
  238. val, ok := pathParams["user.name"]
  239. if !ok {
  240. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "user.name")
  241. }
  242. err = runtime.PopulateFieldFromPath(&protoReq, "user.name", val)
  243. if err != nil {
  244. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "user.name", err)
  245. }
  246. if err := req.ParseForm(); err != nil {
  247. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  248. }
  249. if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_UpdateUser_0); err != nil {
  250. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  251. }
  252. msg, err := server.UpdateUser(ctx, &protoReq)
  253. return msg, metadata, err
  254. }
  255. func request_UserService_DeleteUser_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  256. var (
  257. protoReq DeleteUserRequest
  258. metadata runtime.ServerMetadata
  259. err error
  260. )
  261. val, ok := pathParams["name"]
  262. if !ok {
  263. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  264. }
  265. protoReq.Name, err = runtime.String(val)
  266. if err != nil {
  267. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  268. }
  269. msg, err := client.DeleteUser(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  270. return msg, metadata, err
  271. }
  272. func local_request_UserService_DeleteUser_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  273. var (
  274. protoReq DeleteUserRequest
  275. metadata runtime.ServerMetadata
  276. err error
  277. )
  278. val, ok := pathParams["name"]
  279. if !ok {
  280. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  281. }
  282. protoReq.Name, err = runtime.String(val)
  283. if err != nil {
  284. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  285. }
  286. msg, err := server.DeleteUser(ctx, &protoReq)
  287. return msg, metadata, err
  288. }
  289. func request_UserService_ListAllUserStats_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  290. var (
  291. protoReq ListAllUserStatsRequest
  292. metadata runtime.ServerMetadata
  293. )
  294. msg, err := client.ListAllUserStats(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  295. return msg, metadata, err
  296. }
  297. func local_request_UserService_ListAllUserStats_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  298. var (
  299. protoReq ListAllUserStatsRequest
  300. metadata runtime.ServerMetadata
  301. )
  302. msg, err := server.ListAllUserStats(ctx, &protoReq)
  303. return msg, metadata, err
  304. }
  305. func request_UserService_GetUserStats_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  306. var (
  307. protoReq GetUserStatsRequest
  308. metadata runtime.ServerMetadata
  309. err error
  310. )
  311. val, ok := pathParams["name"]
  312. if !ok {
  313. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  314. }
  315. protoReq.Name, err = runtime.String(val)
  316. if err != nil {
  317. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  318. }
  319. msg, err := client.GetUserStats(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  320. return msg, metadata, err
  321. }
  322. func local_request_UserService_GetUserStats_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  323. var (
  324. protoReq GetUserStatsRequest
  325. metadata runtime.ServerMetadata
  326. err error
  327. )
  328. val, ok := pathParams["name"]
  329. if !ok {
  330. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  331. }
  332. protoReq.Name, err = runtime.String(val)
  333. if err != nil {
  334. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  335. }
  336. msg, err := server.GetUserStats(ctx, &protoReq)
  337. return msg, metadata, err
  338. }
  339. func request_UserService_GetUserSetting_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  340. var (
  341. protoReq GetUserSettingRequest
  342. metadata runtime.ServerMetadata
  343. err error
  344. )
  345. val, ok := pathParams["name"]
  346. if !ok {
  347. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  348. }
  349. protoReq.Name, err = runtime.String(val)
  350. if err != nil {
  351. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  352. }
  353. msg, err := client.GetUserSetting(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  354. return msg, metadata, err
  355. }
  356. func local_request_UserService_GetUserSetting_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  357. var (
  358. protoReq GetUserSettingRequest
  359. metadata runtime.ServerMetadata
  360. err error
  361. )
  362. val, ok := pathParams["name"]
  363. if !ok {
  364. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  365. }
  366. protoReq.Name, err = runtime.String(val)
  367. if err != nil {
  368. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  369. }
  370. msg, err := server.GetUserSetting(ctx, &protoReq)
  371. return msg, metadata, err
  372. }
  373. var filter_UserService_UpdateUserSetting_0 = &utilities.DoubleArray{Encoding: map[string]int{"setting": 0, "name": 1}, Base: []int{1, 2, 1, 0, 0}, Check: []int{0, 1, 2, 3, 2}}
  374. func request_UserService_UpdateUserSetting_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  375. var (
  376. protoReq UpdateUserSettingRequest
  377. metadata runtime.ServerMetadata
  378. err error
  379. )
  380. newReader, berr := utilities.IOReaderFactory(req.Body)
  381. if berr != nil {
  382. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
  383. }
  384. if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Setting); err != nil && !errors.Is(err, io.EOF) {
  385. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  386. }
  387. if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
  388. if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Setting); err != nil {
  389. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  390. } else {
  391. protoReq.UpdateMask = fieldMask
  392. }
  393. }
  394. val, ok := pathParams["setting.name"]
  395. if !ok {
  396. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "setting.name")
  397. }
  398. err = runtime.PopulateFieldFromPath(&protoReq, "setting.name", val)
  399. if err != nil {
  400. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "setting.name", err)
  401. }
  402. if err := req.ParseForm(); err != nil {
  403. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  404. }
  405. if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_UpdateUserSetting_0); err != nil {
  406. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  407. }
  408. msg, err := client.UpdateUserSetting(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  409. return msg, metadata, err
  410. }
  411. func local_request_UserService_UpdateUserSetting_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  412. var (
  413. protoReq UpdateUserSettingRequest
  414. metadata runtime.ServerMetadata
  415. err error
  416. )
  417. newReader, berr := utilities.IOReaderFactory(req.Body)
  418. if berr != nil {
  419. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
  420. }
  421. if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Setting); err != nil && !errors.Is(err, io.EOF) {
  422. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  423. }
  424. if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
  425. if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Setting); err != nil {
  426. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  427. } else {
  428. protoReq.UpdateMask = fieldMask
  429. }
  430. }
  431. val, ok := pathParams["setting.name"]
  432. if !ok {
  433. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "setting.name")
  434. }
  435. err = runtime.PopulateFieldFromPath(&protoReq, "setting.name", val)
  436. if err != nil {
  437. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "setting.name", err)
  438. }
  439. if err := req.ParseForm(); err != nil {
  440. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  441. }
  442. if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_UpdateUserSetting_0); err != nil {
  443. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  444. }
  445. msg, err := server.UpdateUserSetting(ctx, &protoReq)
  446. return msg, metadata, err
  447. }
  448. func request_UserService_ListUserAccessTokens_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  449. var (
  450. protoReq ListUserAccessTokensRequest
  451. metadata runtime.ServerMetadata
  452. err error
  453. )
  454. val, ok := pathParams["name"]
  455. if !ok {
  456. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  457. }
  458. protoReq.Name, err = runtime.String(val)
  459. if err != nil {
  460. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  461. }
  462. msg, err := client.ListUserAccessTokens(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  463. return msg, metadata, err
  464. }
  465. func local_request_UserService_ListUserAccessTokens_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  466. var (
  467. protoReq ListUserAccessTokensRequest
  468. metadata runtime.ServerMetadata
  469. err error
  470. )
  471. val, ok := pathParams["name"]
  472. if !ok {
  473. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  474. }
  475. protoReq.Name, err = runtime.String(val)
  476. if err != nil {
  477. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  478. }
  479. msg, err := server.ListUserAccessTokens(ctx, &protoReq)
  480. return msg, metadata, err
  481. }
  482. func request_UserService_CreateUserAccessToken_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  483. var (
  484. protoReq CreateUserAccessTokenRequest
  485. metadata runtime.ServerMetadata
  486. err error
  487. )
  488. if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
  489. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  490. }
  491. val, ok := pathParams["name"]
  492. if !ok {
  493. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  494. }
  495. protoReq.Name, err = runtime.String(val)
  496. if err != nil {
  497. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  498. }
  499. msg, err := client.CreateUserAccessToken(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  500. return msg, metadata, err
  501. }
  502. func local_request_UserService_CreateUserAccessToken_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  503. var (
  504. protoReq CreateUserAccessTokenRequest
  505. metadata runtime.ServerMetadata
  506. err error
  507. )
  508. if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
  509. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  510. }
  511. val, ok := pathParams["name"]
  512. if !ok {
  513. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  514. }
  515. protoReq.Name, err = runtime.String(val)
  516. if err != nil {
  517. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  518. }
  519. msg, err := server.CreateUserAccessToken(ctx, &protoReq)
  520. return msg, metadata, err
  521. }
  522. func request_UserService_DeleteUserAccessToken_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  523. var (
  524. protoReq DeleteUserAccessTokenRequest
  525. metadata runtime.ServerMetadata
  526. err error
  527. )
  528. val, ok := pathParams["name"]
  529. if !ok {
  530. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  531. }
  532. protoReq.Name, err = runtime.String(val)
  533. if err != nil {
  534. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  535. }
  536. val, ok = pathParams["access_token"]
  537. if !ok {
  538. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "access_token")
  539. }
  540. protoReq.AccessToken, err = runtime.String(val)
  541. if err != nil {
  542. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "access_token", err)
  543. }
  544. msg, err := client.DeleteUserAccessToken(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  545. return msg, metadata, err
  546. }
  547. func local_request_UserService_DeleteUserAccessToken_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  548. var (
  549. protoReq DeleteUserAccessTokenRequest
  550. metadata runtime.ServerMetadata
  551. err error
  552. )
  553. val, ok := pathParams["name"]
  554. if !ok {
  555. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "name")
  556. }
  557. protoReq.Name, err = runtime.String(val)
  558. if err != nil {
  559. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "name", err)
  560. }
  561. val, ok = pathParams["access_token"]
  562. if !ok {
  563. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "access_token")
  564. }
  565. protoReq.AccessToken, err = runtime.String(val)
  566. if err != nil {
  567. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "access_token", err)
  568. }
  569. msg, err := server.DeleteUserAccessToken(ctx, &protoReq)
  570. return msg, metadata, err
  571. }
  572. func request_UserService_ListShortcuts_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  573. var (
  574. protoReq ListShortcutsRequest
  575. metadata runtime.ServerMetadata
  576. err error
  577. )
  578. val, ok := pathParams["parent"]
  579. if !ok {
  580. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "parent")
  581. }
  582. protoReq.Parent, err = runtime.String(val)
  583. if err != nil {
  584. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "parent", err)
  585. }
  586. msg, err := client.ListShortcuts(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  587. return msg, metadata, err
  588. }
  589. func local_request_UserService_ListShortcuts_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  590. var (
  591. protoReq ListShortcutsRequest
  592. metadata runtime.ServerMetadata
  593. err error
  594. )
  595. val, ok := pathParams["parent"]
  596. if !ok {
  597. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "parent")
  598. }
  599. protoReq.Parent, err = runtime.String(val)
  600. if err != nil {
  601. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "parent", err)
  602. }
  603. msg, err := server.ListShortcuts(ctx, &protoReq)
  604. return msg, metadata, err
  605. }
  606. var filter_UserService_CreateShortcut_0 = &utilities.DoubleArray{Encoding: map[string]int{"shortcut": 0, "parent": 1}, Base: []int{1, 1, 2, 0, 0}, Check: []int{0, 1, 1, 2, 3}}
  607. func request_UserService_CreateShortcut_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  608. var (
  609. protoReq CreateShortcutRequest
  610. metadata runtime.ServerMetadata
  611. err error
  612. )
  613. if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Shortcut); err != nil && !errors.Is(err, io.EOF) {
  614. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  615. }
  616. val, ok := pathParams["parent"]
  617. if !ok {
  618. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "parent")
  619. }
  620. protoReq.Parent, err = runtime.String(val)
  621. if err != nil {
  622. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "parent", err)
  623. }
  624. if err := req.ParseForm(); err != nil {
  625. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  626. }
  627. if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_CreateShortcut_0); err != nil {
  628. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  629. }
  630. msg, err := client.CreateShortcut(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  631. return msg, metadata, err
  632. }
  633. func local_request_UserService_CreateShortcut_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  634. var (
  635. protoReq CreateShortcutRequest
  636. metadata runtime.ServerMetadata
  637. err error
  638. )
  639. if err := marshaler.NewDecoder(req.Body).Decode(&protoReq.Shortcut); err != nil && !errors.Is(err, io.EOF) {
  640. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  641. }
  642. val, ok := pathParams["parent"]
  643. if !ok {
  644. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "parent")
  645. }
  646. protoReq.Parent, err = runtime.String(val)
  647. if err != nil {
  648. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "parent", err)
  649. }
  650. if err := req.ParseForm(); err != nil {
  651. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  652. }
  653. if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_CreateShortcut_0); err != nil {
  654. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  655. }
  656. msg, err := server.CreateShortcut(ctx, &protoReq)
  657. return msg, metadata, err
  658. }
  659. var filter_UserService_UpdateShortcut_0 = &utilities.DoubleArray{Encoding: map[string]int{"shortcut": 0, "parent": 1, "id": 2}, Base: []int{1, 2, 3, 1, 0, 0, 0}, Check: []int{0, 1, 1, 2, 4, 2, 3}}
  660. func request_UserService_UpdateShortcut_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  661. var (
  662. protoReq UpdateShortcutRequest
  663. metadata runtime.ServerMetadata
  664. err error
  665. )
  666. newReader, berr := utilities.IOReaderFactory(req.Body)
  667. if berr != nil {
  668. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
  669. }
  670. if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Shortcut); err != nil && !errors.Is(err, io.EOF) {
  671. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  672. }
  673. if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
  674. if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Shortcut); err != nil {
  675. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  676. } else {
  677. protoReq.UpdateMask = fieldMask
  678. }
  679. }
  680. val, ok := pathParams["parent"]
  681. if !ok {
  682. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "parent")
  683. }
  684. protoReq.Parent, err = runtime.String(val)
  685. if err != nil {
  686. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "parent", err)
  687. }
  688. val, ok = pathParams["shortcut.id"]
  689. if !ok {
  690. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "shortcut.id")
  691. }
  692. err = runtime.PopulateFieldFromPath(&protoReq, "shortcut.id", val)
  693. if err != nil {
  694. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "shortcut.id", err)
  695. }
  696. if err := req.ParseForm(); err != nil {
  697. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  698. }
  699. if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_UpdateShortcut_0); err != nil {
  700. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  701. }
  702. msg, err := client.UpdateShortcut(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  703. return msg, metadata, err
  704. }
  705. func local_request_UserService_UpdateShortcut_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  706. var (
  707. protoReq UpdateShortcutRequest
  708. metadata runtime.ServerMetadata
  709. err error
  710. )
  711. newReader, berr := utilities.IOReaderFactory(req.Body)
  712. if berr != nil {
  713. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
  714. }
  715. if err := marshaler.NewDecoder(newReader()).Decode(&protoReq.Shortcut); err != nil && !errors.Is(err, io.EOF) {
  716. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  717. }
  718. if protoReq.UpdateMask == nil || len(protoReq.UpdateMask.GetPaths()) == 0 {
  719. if fieldMask, err := runtime.FieldMaskFromRequestBody(newReader(), protoReq.Shortcut); err != nil {
  720. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  721. } else {
  722. protoReq.UpdateMask = fieldMask
  723. }
  724. }
  725. val, ok := pathParams["parent"]
  726. if !ok {
  727. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "parent")
  728. }
  729. protoReq.Parent, err = runtime.String(val)
  730. if err != nil {
  731. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "parent", err)
  732. }
  733. val, ok = pathParams["shortcut.id"]
  734. if !ok {
  735. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "shortcut.id")
  736. }
  737. err = runtime.PopulateFieldFromPath(&protoReq, "shortcut.id", val)
  738. if err != nil {
  739. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "shortcut.id", err)
  740. }
  741. if err := req.ParseForm(); err != nil {
  742. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  743. }
  744. if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_UserService_UpdateShortcut_0); err != nil {
  745. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  746. }
  747. msg, err := server.UpdateShortcut(ctx, &protoReq)
  748. return msg, metadata, err
  749. }
  750. func request_UserService_DeleteShortcut_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  751. var (
  752. protoReq DeleteShortcutRequest
  753. metadata runtime.ServerMetadata
  754. err error
  755. )
  756. val, ok := pathParams["parent"]
  757. if !ok {
  758. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "parent")
  759. }
  760. protoReq.Parent, err = runtime.String(val)
  761. if err != nil {
  762. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "parent", err)
  763. }
  764. val, ok = pathParams["id"]
  765. if !ok {
  766. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
  767. }
  768. protoReq.Id, err = runtime.String(val)
  769. if err != nil {
  770. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "id", err)
  771. }
  772. msg, err := client.DeleteShortcut(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  773. return msg, metadata, err
  774. }
  775. func local_request_UserService_DeleteShortcut_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  776. var (
  777. protoReq DeleteShortcutRequest
  778. metadata runtime.ServerMetadata
  779. err error
  780. )
  781. val, ok := pathParams["parent"]
  782. if !ok {
  783. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "parent")
  784. }
  785. protoReq.Parent, err = runtime.String(val)
  786. if err != nil {
  787. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "parent", err)
  788. }
  789. val, ok = pathParams["id"]
  790. if !ok {
  791. return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "id")
  792. }
  793. protoReq.Id, err = runtime.String(val)
  794. if err != nil {
  795. return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "id", err)
  796. }
  797. msg, err := server.DeleteShortcut(ctx, &protoReq)
  798. return msg, metadata, err
  799. }
  800. // RegisterUserServiceHandlerServer registers the http handlers for service UserService to "mux".
  801. // UnaryRPC :call UserServiceServer directly.
  802. // StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
  803. // Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterUserServiceHandlerFromEndpoint instead.
  804. // 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.
  805. func RegisterUserServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server UserServiceServer) error {
  806. mux.Handle(http.MethodGet, pattern_UserService_ListUsers_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  807. ctx, cancel := context.WithCancel(req.Context())
  808. defer cancel()
  809. var stream runtime.ServerTransportStream
  810. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  811. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  812. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/ListUsers", runtime.WithHTTPPathPattern("/api/v1/users"))
  813. if err != nil {
  814. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  815. return
  816. }
  817. resp, md, err := local_request_UserService_ListUsers_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  818. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  819. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  820. if err != nil {
  821. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  822. return
  823. }
  824. forward_UserService_ListUsers_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  825. })
  826. mux.Handle(http.MethodGet, pattern_UserService_GetUser_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  827. ctx, cancel := context.WithCancel(req.Context())
  828. defer cancel()
  829. var stream runtime.ServerTransportStream
  830. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  831. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  832. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/GetUser", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}"))
  833. if err != nil {
  834. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  835. return
  836. }
  837. resp, md, err := local_request_UserService_GetUser_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  838. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  839. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  840. if err != nil {
  841. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  842. return
  843. }
  844. forward_UserService_GetUser_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  845. })
  846. mux.Handle(http.MethodGet, pattern_UserService_GetUserByUsername_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  847. ctx, cancel := context.WithCancel(req.Context())
  848. defer cancel()
  849. var stream runtime.ServerTransportStream
  850. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  851. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  852. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/GetUserByUsername", runtime.WithHTTPPathPattern("/api/v1/users:username"))
  853. if err != nil {
  854. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  855. return
  856. }
  857. resp, md, err := local_request_UserService_GetUserByUsername_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  858. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  859. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  860. if err != nil {
  861. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  862. return
  863. }
  864. forward_UserService_GetUserByUsername_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  865. })
  866. mux.Handle(http.MethodGet, pattern_UserService_GetUserAvatarBinary_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  867. ctx, cancel := context.WithCancel(req.Context())
  868. defer cancel()
  869. var stream runtime.ServerTransportStream
  870. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  871. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  872. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/GetUserAvatarBinary", runtime.WithHTTPPathPattern("/file/{name=users/*}/avatar"))
  873. if err != nil {
  874. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  875. return
  876. }
  877. resp, md, err := local_request_UserService_GetUserAvatarBinary_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  878. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  879. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  880. if err != nil {
  881. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  882. return
  883. }
  884. forward_UserService_GetUserAvatarBinary_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  885. })
  886. mux.Handle(http.MethodPost, pattern_UserService_CreateUser_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  887. ctx, cancel := context.WithCancel(req.Context())
  888. defer cancel()
  889. var stream runtime.ServerTransportStream
  890. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  891. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  892. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/CreateUser", runtime.WithHTTPPathPattern("/api/v1/users"))
  893. if err != nil {
  894. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  895. return
  896. }
  897. resp, md, err := local_request_UserService_CreateUser_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  898. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  899. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  900. if err != nil {
  901. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  902. return
  903. }
  904. forward_UserService_CreateUser_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  905. })
  906. mux.Handle(http.MethodPatch, pattern_UserService_UpdateUser_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  907. ctx, cancel := context.WithCancel(req.Context())
  908. defer cancel()
  909. var stream runtime.ServerTransportStream
  910. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  911. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  912. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/UpdateUser", runtime.WithHTTPPathPattern("/api/v1/{user.name=users/*}"))
  913. if err != nil {
  914. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  915. return
  916. }
  917. resp, md, err := local_request_UserService_UpdateUser_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  918. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  919. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  920. if err != nil {
  921. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  922. return
  923. }
  924. forward_UserService_UpdateUser_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  925. })
  926. mux.Handle(http.MethodDelete, pattern_UserService_DeleteUser_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  927. ctx, cancel := context.WithCancel(req.Context())
  928. defer cancel()
  929. var stream runtime.ServerTransportStream
  930. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  931. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  932. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/DeleteUser", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}"))
  933. if err != nil {
  934. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  935. return
  936. }
  937. resp, md, err := local_request_UserService_DeleteUser_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  938. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  939. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  940. if err != nil {
  941. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  942. return
  943. }
  944. forward_UserService_DeleteUser_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  945. })
  946. mux.Handle(http.MethodPost, pattern_UserService_ListAllUserStats_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  947. ctx, cancel := context.WithCancel(req.Context())
  948. defer cancel()
  949. var stream runtime.ServerTransportStream
  950. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  951. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  952. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/ListAllUserStats", runtime.WithHTTPPathPattern("/api/v1/users/-/stats"))
  953. if err != nil {
  954. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  955. return
  956. }
  957. resp, md, err := local_request_UserService_ListAllUserStats_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  958. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  959. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  960. if err != nil {
  961. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  962. return
  963. }
  964. forward_UserService_ListAllUserStats_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  965. })
  966. mux.Handle(http.MethodGet, pattern_UserService_GetUserStats_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  967. ctx, cancel := context.WithCancel(req.Context())
  968. defer cancel()
  969. var stream runtime.ServerTransportStream
  970. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  971. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  972. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/GetUserStats", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}/stats"))
  973. if err != nil {
  974. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  975. return
  976. }
  977. resp, md, err := local_request_UserService_GetUserStats_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  978. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  979. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  980. if err != nil {
  981. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  982. return
  983. }
  984. forward_UserService_GetUserStats_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  985. })
  986. mux.Handle(http.MethodGet, pattern_UserService_GetUserSetting_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  987. ctx, cancel := context.WithCancel(req.Context())
  988. defer cancel()
  989. var stream runtime.ServerTransportStream
  990. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  991. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  992. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/GetUserSetting", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}/setting"))
  993. if err != nil {
  994. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  995. return
  996. }
  997. resp, md, err := local_request_UserService_GetUserSetting_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  998. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  999. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1000. if err != nil {
  1001. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1002. return
  1003. }
  1004. forward_UserService_GetUserSetting_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1005. })
  1006. mux.Handle(http.MethodPatch, pattern_UserService_UpdateUserSetting_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1007. ctx, cancel := context.WithCancel(req.Context())
  1008. defer cancel()
  1009. var stream runtime.ServerTransportStream
  1010. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  1011. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1012. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/UpdateUserSetting", runtime.WithHTTPPathPattern("/api/v1/{setting.name=users/*/setting}"))
  1013. if err != nil {
  1014. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1015. return
  1016. }
  1017. resp, md, err := local_request_UserService_UpdateUserSetting_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  1018. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  1019. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1020. if err != nil {
  1021. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1022. return
  1023. }
  1024. forward_UserService_UpdateUserSetting_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1025. })
  1026. mux.Handle(http.MethodGet, pattern_UserService_ListUserAccessTokens_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1027. ctx, cancel := context.WithCancel(req.Context())
  1028. defer cancel()
  1029. var stream runtime.ServerTransportStream
  1030. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  1031. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1032. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/ListUserAccessTokens", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}/access_tokens"))
  1033. if err != nil {
  1034. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1035. return
  1036. }
  1037. resp, md, err := local_request_UserService_ListUserAccessTokens_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  1038. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  1039. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1040. if err != nil {
  1041. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1042. return
  1043. }
  1044. forward_UserService_ListUserAccessTokens_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1045. })
  1046. mux.Handle(http.MethodPost, pattern_UserService_CreateUserAccessToken_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1047. ctx, cancel := context.WithCancel(req.Context())
  1048. defer cancel()
  1049. var stream runtime.ServerTransportStream
  1050. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  1051. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1052. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/CreateUserAccessToken", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}/access_tokens"))
  1053. if err != nil {
  1054. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1055. return
  1056. }
  1057. resp, md, err := local_request_UserService_CreateUserAccessToken_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  1058. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  1059. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1060. if err != nil {
  1061. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1062. return
  1063. }
  1064. forward_UserService_CreateUserAccessToken_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1065. })
  1066. mux.Handle(http.MethodDelete, pattern_UserService_DeleteUserAccessToken_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1067. ctx, cancel := context.WithCancel(req.Context())
  1068. defer cancel()
  1069. var stream runtime.ServerTransportStream
  1070. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  1071. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1072. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/DeleteUserAccessToken", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}/access_tokens/{access_token}"))
  1073. if err != nil {
  1074. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1075. return
  1076. }
  1077. resp, md, err := local_request_UserService_DeleteUserAccessToken_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  1078. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  1079. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1080. if err != nil {
  1081. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1082. return
  1083. }
  1084. forward_UserService_DeleteUserAccessToken_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1085. })
  1086. mux.Handle(http.MethodGet, pattern_UserService_ListShortcuts_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1087. ctx, cancel := context.WithCancel(req.Context())
  1088. defer cancel()
  1089. var stream runtime.ServerTransportStream
  1090. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  1091. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1092. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/ListShortcuts", runtime.WithHTTPPathPattern("/api/v1/{parent=users/*}/shortcuts"))
  1093. if err != nil {
  1094. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1095. return
  1096. }
  1097. resp, md, err := local_request_UserService_ListShortcuts_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  1098. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  1099. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1100. if err != nil {
  1101. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1102. return
  1103. }
  1104. forward_UserService_ListShortcuts_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1105. })
  1106. mux.Handle(http.MethodPost, pattern_UserService_CreateShortcut_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1107. ctx, cancel := context.WithCancel(req.Context())
  1108. defer cancel()
  1109. var stream runtime.ServerTransportStream
  1110. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  1111. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1112. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/CreateShortcut", runtime.WithHTTPPathPattern("/api/v1/{parent=users/*}/shortcuts"))
  1113. if err != nil {
  1114. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1115. return
  1116. }
  1117. resp, md, err := local_request_UserService_CreateShortcut_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  1118. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  1119. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1120. if err != nil {
  1121. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1122. return
  1123. }
  1124. forward_UserService_CreateShortcut_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1125. })
  1126. mux.Handle(http.MethodPatch, pattern_UserService_UpdateShortcut_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1127. ctx, cancel := context.WithCancel(req.Context())
  1128. defer cancel()
  1129. var stream runtime.ServerTransportStream
  1130. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  1131. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1132. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/UpdateShortcut", runtime.WithHTTPPathPattern("/api/v1/{parent=users/*}/shortcuts/{shortcut.id}"))
  1133. if err != nil {
  1134. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1135. return
  1136. }
  1137. resp, md, err := local_request_UserService_UpdateShortcut_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  1138. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  1139. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1140. if err != nil {
  1141. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1142. return
  1143. }
  1144. forward_UserService_UpdateShortcut_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1145. })
  1146. mux.Handle(http.MethodDelete, pattern_UserService_DeleteShortcut_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1147. ctx, cancel := context.WithCancel(req.Context())
  1148. defer cancel()
  1149. var stream runtime.ServerTransportStream
  1150. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  1151. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1152. annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/memos.api.v1.UserService/DeleteShortcut", runtime.WithHTTPPathPattern("/api/v1/{parent=users/*}/shortcuts/{id}"))
  1153. if err != nil {
  1154. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1155. return
  1156. }
  1157. resp, md, err := local_request_UserService_DeleteShortcut_0(annotatedContext, inboundMarshaler, server, req, pathParams)
  1158. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  1159. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1160. if err != nil {
  1161. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1162. return
  1163. }
  1164. forward_UserService_DeleteShortcut_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1165. })
  1166. return nil
  1167. }
  1168. // RegisterUserServiceHandlerFromEndpoint is same as RegisterUserServiceHandler but
  1169. // automatically dials to "endpoint" and closes the connection when "ctx" gets done.
  1170. func RegisterUserServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) {
  1171. conn, err := grpc.NewClient(endpoint, opts...)
  1172. if err != nil {
  1173. return err
  1174. }
  1175. defer func() {
  1176. if err != nil {
  1177. if cerr := conn.Close(); cerr != nil {
  1178. grpclog.Errorf("Failed to close conn to %s: %v", endpoint, cerr)
  1179. }
  1180. return
  1181. }
  1182. go func() {
  1183. <-ctx.Done()
  1184. if cerr := conn.Close(); cerr != nil {
  1185. grpclog.Errorf("Failed to close conn to %s: %v", endpoint, cerr)
  1186. }
  1187. }()
  1188. }()
  1189. return RegisterUserServiceHandler(ctx, mux, conn)
  1190. }
  1191. // RegisterUserServiceHandler registers the http handlers for service UserService to "mux".
  1192. // The handlers forward requests to the grpc endpoint over "conn".
  1193. func RegisterUserServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error {
  1194. return RegisterUserServiceHandlerClient(ctx, mux, NewUserServiceClient(conn))
  1195. }
  1196. // RegisterUserServiceHandlerClient registers the http handlers for service UserService
  1197. // to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "UserServiceClient".
  1198. // Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "UserServiceClient"
  1199. // doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in
  1200. // "UserServiceClient" to call the correct interceptors. This client ignores the HTTP middlewares.
  1201. func RegisterUserServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client UserServiceClient) error {
  1202. mux.Handle(http.MethodGet, pattern_UserService_ListUsers_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1203. ctx, cancel := context.WithCancel(req.Context())
  1204. defer cancel()
  1205. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1206. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/ListUsers", runtime.WithHTTPPathPattern("/api/v1/users"))
  1207. if err != nil {
  1208. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1209. return
  1210. }
  1211. resp, md, err := request_UserService_ListUsers_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  1212. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1213. if err != nil {
  1214. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1215. return
  1216. }
  1217. forward_UserService_ListUsers_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1218. })
  1219. mux.Handle(http.MethodGet, pattern_UserService_GetUser_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1220. ctx, cancel := context.WithCancel(req.Context())
  1221. defer cancel()
  1222. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1223. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/GetUser", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}"))
  1224. if err != nil {
  1225. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1226. return
  1227. }
  1228. resp, md, err := request_UserService_GetUser_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  1229. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1230. if err != nil {
  1231. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1232. return
  1233. }
  1234. forward_UserService_GetUser_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1235. })
  1236. mux.Handle(http.MethodGet, pattern_UserService_GetUserByUsername_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1237. ctx, cancel := context.WithCancel(req.Context())
  1238. defer cancel()
  1239. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1240. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/GetUserByUsername", runtime.WithHTTPPathPattern("/api/v1/users:username"))
  1241. if err != nil {
  1242. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1243. return
  1244. }
  1245. resp, md, err := request_UserService_GetUserByUsername_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  1246. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1247. if err != nil {
  1248. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1249. return
  1250. }
  1251. forward_UserService_GetUserByUsername_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1252. })
  1253. mux.Handle(http.MethodGet, pattern_UserService_GetUserAvatarBinary_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1254. ctx, cancel := context.WithCancel(req.Context())
  1255. defer cancel()
  1256. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1257. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/GetUserAvatarBinary", runtime.WithHTTPPathPattern("/file/{name=users/*}/avatar"))
  1258. if err != nil {
  1259. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1260. return
  1261. }
  1262. resp, md, err := request_UserService_GetUserAvatarBinary_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  1263. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1264. if err != nil {
  1265. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1266. return
  1267. }
  1268. forward_UserService_GetUserAvatarBinary_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1269. })
  1270. mux.Handle(http.MethodPost, pattern_UserService_CreateUser_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1271. ctx, cancel := context.WithCancel(req.Context())
  1272. defer cancel()
  1273. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1274. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/CreateUser", runtime.WithHTTPPathPattern("/api/v1/users"))
  1275. if err != nil {
  1276. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1277. return
  1278. }
  1279. resp, md, err := request_UserService_CreateUser_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  1280. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1281. if err != nil {
  1282. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1283. return
  1284. }
  1285. forward_UserService_CreateUser_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1286. })
  1287. mux.Handle(http.MethodPatch, pattern_UserService_UpdateUser_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1288. ctx, cancel := context.WithCancel(req.Context())
  1289. defer cancel()
  1290. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1291. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/UpdateUser", runtime.WithHTTPPathPattern("/api/v1/{user.name=users/*}"))
  1292. if err != nil {
  1293. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1294. return
  1295. }
  1296. resp, md, err := request_UserService_UpdateUser_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  1297. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1298. if err != nil {
  1299. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1300. return
  1301. }
  1302. forward_UserService_UpdateUser_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1303. })
  1304. mux.Handle(http.MethodDelete, pattern_UserService_DeleteUser_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1305. ctx, cancel := context.WithCancel(req.Context())
  1306. defer cancel()
  1307. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1308. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/DeleteUser", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}"))
  1309. if err != nil {
  1310. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1311. return
  1312. }
  1313. resp, md, err := request_UserService_DeleteUser_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  1314. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1315. if err != nil {
  1316. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1317. return
  1318. }
  1319. forward_UserService_DeleteUser_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1320. })
  1321. mux.Handle(http.MethodPost, pattern_UserService_ListAllUserStats_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1322. ctx, cancel := context.WithCancel(req.Context())
  1323. defer cancel()
  1324. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1325. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/ListAllUserStats", runtime.WithHTTPPathPattern("/api/v1/users/-/stats"))
  1326. if err != nil {
  1327. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1328. return
  1329. }
  1330. resp, md, err := request_UserService_ListAllUserStats_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  1331. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1332. if err != nil {
  1333. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1334. return
  1335. }
  1336. forward_UserService_ListAllUserStats_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1337. })
  1338. mux.Handle(http.MethodGet, pattern_UserService_GetUserStats_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1339. ctx, cancel := context.WithCancel(req.Context())
  1340. defer cancel()
  1341. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1342. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/GetUserStats", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}/stats"))
  1343. if err != nil {
  1344. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1345. return
  1346. }
  1347. resp, md, err := request_UserService_GetUserStats_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  1348. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1349. if err != nil {
  1350. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1351. return
  1352. }
  1353. forward_UserService_GetUserStats_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1354. })
  1355. mux.Handle(http.MethodGet, pattern_UserService_GetUserSetting_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1356. ctx, cancel := context.WithCancel(req.Context())
  1357. defer cancel()
  1358. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1359. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/GetUserSetting", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}/setting"))
  1360. if err != nil {
  1361. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1362. return
  1363. }
  1364. resp, md, err := request_UserService_GetUserSetting_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  1365. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1366. if err != nil {
  1367. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1368. return
  1369. }
  1370. forward_UserService_GetUserSetting_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1371. })
  1372. mux.Handle(http.MethodPatch, pattern_UserService_UpdateUserSetting_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1373. ctx, cancel := context.WithCancel(req.Context())
  1374. defer cancel()
  1375. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1376. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/UpdateUserSetting", runtime.WithHTTPPathPattern("/api/v1/{setting.name=users/*/setting}"))
  1377. if err != nil {
  1378. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1379. return
  1380. }
  1381. resp, md, err := request_UserService_UpdateUserSetting_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  1382. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1383. if err != nil {
  1384. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1385. return
  1386. }
  1387. forward_UserService_UpdateUserSetting_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1388. })
  1389. mux.Handle(http.MethodGet, pattern_UserService_ListUserAccessTokens_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1390. ctx, cancel := context.WithCancel(req.Context())
  1391. defer cancel()
  1392. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1393. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/ListUserAccessTokens", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}/access_tokens"))
  1394. if err != nil {
  1395. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1396. return
  1397. }
  1398. resp, md, err := request_UserService_ListUserAccessTokens_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  1399. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1400. if err != nil {
  1401. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1402. return
  1403. }
  1404. forward_UserService_ListUserAccessTokens_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1405. })
  1406. mux.Handle(http.MethodPost, pattern_UserService_CreateUserAccessToken_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1407. ctx, cancel := context.WithCancel(req.Context())
  1408. defer cancel()
  1409. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1410. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/CreateUserAccessToken", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}/access_tokens"))
  1411. if err != nil {
  1412. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1413. return
  1414. }
  1415. resp, md, err := request_UserService_CreateUserAccessToken_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  1416. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1417. if err != nil {
  1418. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1419. return
  1420. }
  1421. forward_UserService_CreateUserAccessToken_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1422. })
  1423. mux.Handle(http.MethodDelete, pattern_UserService_DeleteUserAccessToken_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1424. ctx, cancel := context.WithCancel(req.Context())
  1425. defer cancel()
  1426. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1427. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/DeleteUserAccessToken", runtime.WithHTTPPathPattern("/api/v1/{name=users/*}/access_tokens/{access_token}"))
  1428. if err != nil {
  1429. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1430. return
  1431. }
  1432. resp, md, err := request_UserService_DeleteUserAccessToken_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  1433. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1434. if err != nil {
  1435. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1436. return
  1437. }
  1438. forward_UserService_DeleteUserAccessToken_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1439. })
  1440. mux.Handle(http.MethodGet, pattern_UserService_ListShortcuts_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1441. ctx, cancel := context.WithCancel(req.Context())
  1442. defer cancel()
  1443. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1444. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/ListShortcuts", runtime.WithHTTPPathPattern("/api/v1/{parent=users/*}/shortcuts"))
  1445. if err != nil {
  1446. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1447. return
  1448. }
  1449. resp, md, err := request_UserService_ListShortcuts_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  1450. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1451. if err != nil {
  1452. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1453. return
  1454. }
  1455. forward_UserService_ListShortcuts_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1456. })
  1457. mux.Handle(http.MethodPost, pattern_UserService_CreateShortcut_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1458. ctx, cancel := context.WithCancel(req.Context())
  1459. defer cancel()
  1460. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1461. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/CreateShortcut", runtime.WithHTTPPathPattern("/api/v1/{parent=users/*}/shortcuts"))
  1462. if err != nil {
  1463. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1464. return
  1465. }
  1466. resp, md, err := request_UserService_CreateShortcut_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  1467. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1468. if err != nil {
  1469. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1470. return
  1471. }
  1472. forward_UserService_CreateShortcut_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1473. })
  1474. mux.Handle(http.MethodPatch, pattern_UserService_UpdateShortcut_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1475. ctx, cancel := context.WithCancel(req.Context())
  1476. defer cancel()
  1477. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1478. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/UpdateShortcut", runtime.WithHTTPPathPattern("/api/v1/{parent=users/*}/shortcuts/{shortcut.id}"))
  1479. if err != nil {
  1480. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1481. return
  1482. }
  1483. resp, md, err := request_UserService_UpdateShortcut_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  1484. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1485. if err != nil {
  1486. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1487. return
  1488. }
  1489. forward_UserService_UpdateShortcut_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1490. })
  1491. mux.Handle(http.MethodDelete, pattern_UserService_DeleteShortcut_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  1492. ctx, cancel := context.WithCancel(req.Context())
  1493. defer cancel()
  1494. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  1495. annotatedContext, err := runtime.AnnotateContext(ctx, mux, req, "/memos.api.v1.UserService/DeleteShortcut", runtime.WithHTTPPathPattern("/api/v1/{parent=users/*}/shortcuts/{id}"))
  1496. if err != nil {
  1497. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  1498. return
  1499. }
  1500. resp, md, err := request_UserService_DeleteShortcut_0(annotatedContext, inboundMarshaler, client, req, pathParams)
  1501. annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
  1502. if err != nil {
  1503. runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
  1504. return
  1505. }
  1506. forward_UserService_DeleteShortcut_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  1507. })
  1508. return nil
  1509. }
  1510. var (
  1511. pattern_UserService_ListUsers_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"api", "v1", "users"}, ""))
  1512. pattern_UserService_GetUser_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3}, []string{"api", "v1", "users", "name"}, ""))
  1513. pattern_UserService_GetUserByUsername_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"api", "v1", "users"}, "username"))
  1514. pattern_UserService_GetUserAvatarBinary_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 1, 0, 4, 2, 5, 2, 2, 3}, []string{"file", "users", "name", "avatar"}, ""))
  1515. pattern_UserService_CreateUser_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"api", "v1", "users"}, ""))
  1516. pattern_UserService_UpdateUser_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3}, []string{"api", "v1", "users", "user.name"}, ""))
  1517. pattern_UserService_DeleteUser_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3}, []string{"api", "v1", "users", "name"}, ""))
  1518. pattern_UserService_ListAllUserStats_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 2, 3, 2, 4}, []string{"api", "v1", "users", "-", "stats"}, ""))
  1519. pattern_UserService_GetUserStats_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3, 2, 4}, []string{"api", "v1", "users", "name", "stats"}, ""))
  1520. pattern_UserService_GetUserSetting_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3, 2, 4}, []string{"api", "v1", "users", "name", "setting"}, ""))
  1521. pattern_UserService_UpdateUserSetting_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 2, 3, 4, 3, 5, 4}, []string{"api", "v1", "users", "setting", "setting.name"}, ""))
  1522. pattern_UserService_ListUserAccessTokens_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3, 2, 4}, []string{"api", "v1", "users", "name", "access_tokens"}, ""))
  1523. pattern_UserService_CreateUserAccessToken_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3, 2, 4}, []string{"api", "v1", "users", "name", "access_tokens"}, ""))
  1524. pattern_UserService_DeleteUserAccessToken_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3, 2, 4, 1, 0, 4, 1, 5, 5}, []string{"api", "v1", "users", "name", "access_tokens", "access_token"}, ""))
  1525. pattern_UserService_ListShortcuts_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3, 2, 4}, []string{"api", "v1", "users", "parent", "shortcuts"}, ""))
  1526. pattern_UserService_CreateShortcut_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3, 2, 4}, []string{"api", "v1", "users", "parent", "shortcuts"}, ""))
  1527. pattern_UserService_UpdateShortcut_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3, 2, 4, 1, 0, 4, 1, 5, 5}, []string{"api", "v1", "users", "parent", "shortcuts", "shortcut.id"}, ""))
  1528. pattern_UserService_DeleteShortcut_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 2, 5, 3, 2, 4, 1, 0, 4, 1, 5, 5}, []string{"api", "v1", "users", "parent", "shortcuts", "id"}, ""))
  1529. )
  1530. var (
  1531. forward_UserService_ListUsers_0 = runtime.ForwardResponseMessage
  1532. forward_UserService_GetUser_0 = runtime.ForwardResponseMessage
  1533. forward_UserService_GetUserByUsername_0 = runtime.ForwardResponseMessage
  1534. forward_UserService_GetUserAvatarBinary_0 = runtime.ForwardResponseMessage
  1535. forward_UserService_CreateUser_0 = runtime.ForwardResponseMessage
  1536. forward_UserService_UpdateUser_0 = runtime.ForwardResponseMessage
  1537. forward_UserService_DeleteUser_0 = runtime.ForwardResponseMessage
  1538. forward_UserService_ListAllUserStats_0 = runtime.ForwardResponseMessage
  1539. forward_UserService_GetUserStats_0 = runtime.ForwardResponseMessage
  1540. forward_UserService_GetUserSetting_0 = runtime.ForwardResponseMessage
  1541. forward_UserService_UpdateUserSetting_0 = runtime.ForwardResponseMessage
  1542. forward_UserService_ListUserAccessTokens_0 = runtime.ForwardResponseMessage
  1543. forward_UserService_CreateUserAccessToken_0 = runtime.ForwardResponseMessage
  1544. forward_UserService_DeleteUserAccessToken_0 = runtime.ForwardResponseMessage
  1545. forward_UserService_ListShortcuts_0 = runtime.ForwardResponseMessage
  1546. forward_UserService_CreateShortcut_0 = runtime.ForwardResponseMessage
  1547. forward_UserService_UpdateShortcut_0 = runtime.ForwardResponseMessage
  1548. forward_UserService_DeleteShortcut_0 = runtime.ForwardResponseMessage
  1549. )