server_connect.py 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578
  1. # -*- coding: utf-8 -*-
  2. # Generated by https://github.com/connectrpc/connect-python. DO NOT EDIT!
  3. # source: chatto/admin/v1/server.proto
  4. from collections.abc import AsyncGenerator, AsyncIterator, Iterable, Iterator, Mapping
  5. from typing import Protocol
  6. from connectrpc.client import ConnectClient, ConnectClientSync
  7. from connectrpc.code import Code
  8. from connectrpc.compression import Compression
  9. from connectrpc.errors import ConnectError
  10. from connectrpc.interceptor import Interceptor, InterceptorSync
  11. from connectrpc.method import IdempotencyLevel, MethodInfo
  12. from connectrpc.request import Headers, RequestContext
  13. from connectrpc.server import ConnectASGIApplication, ConnectWSGIApplication, Endpoint, EndpointSync
  14. import chatto.admin.v1.server_pb2 as chatto_dot_admin_dot_v1_dot_server__pb2
  15. class AdminServerService(Protocol):
  16. async def get_server_config(self, request: chatto_dot_admin_dot_v1_dot_server__pb2.GetServerConfigRequest, ctx: RequestContext) -> chatto_dot_admin_dot_v1_dot_server__pb2.GetServerConfigResponse:
  17. raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")
  18. async def update_server_config(self, request: chatto_dot_admin_dot_v1_dot_server__pb2.UpdateServerConfigRequest, ctx: RequestContext) -> chatto_dot_admin_dot_v1_dot_server__pb2.UpdateServerConfigResponse:
  19. raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")
  20. async def upload_server_logo(self, request: chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerLogoRequest, ctx: RequestContext) -> chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerLogoResponse:
  21. raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")
  22. async def delete_server_logo(self, request: chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerLogoRequest, ctx: RequestContext) -> chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerLogoResponse:
  23. raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")
  24. async def upload_server_banner(self, request: chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerBannerRequest, ctx: RequestContext) -> chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerBannerResponse:
  25. raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")
  26. async def delete_server_banner(self, request: chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerBannerRequest, ctx: RequestContext) -> chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerBannerResponse:
  27. raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")
  28. async def get_server_security_config(self, request: chatto_dot_admin_dot_v1_dot_server__pb2.GetServerSecurityConfigRequest, ctx: RequestContext) -> chatto_dot_admin_dot_v1_dot_server__pb2.GetServerSecurityConfigResponse:
  29. raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")
  30. async def update_blocked_usernames(self, request: chatto_dot_admin_dot_v1_dot_server__pb2.UpdateBlockedUsernamesRequest, ctx: RequestContext) -> chatto_dot_admin_dot_v1_dot_server__pb2.UpdateBlockedUsernamesResponse:
  31. raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")
  32. class AdminServerServiceASGIApplication(ConnectASGIApplication[AdminServerService]):
  33. def __init__(self, service: AdminServerService | AsyncGenerator[AdminServerService], *, interceptors: Iterable[Interceptor]=(), read_max_bytes: int | None = None, compressions: Iterable[Compression] | None = None) -> None:
  34. super().__init__(
  35. service=service,
  36. endpoints=lambda svc: {
  37. "/chatto.admin.v1.AdminServerService/GetServerConfig": Endpoint.unary(
  38. method=MethodInfo(
  39. name="GetServerConfig",
  40. service_name="chatto.admin.v1.AdminServerService",
  41. input=chatto_dot_admin_dot_v1_dot_server__pb2.GetServerConfigRequest,
  42. output=chatto_dot_admin_dot_v1_dot_server__pb2.GetServerConfigResponse,
  43. idempotency_level=IdempotencyLevel.UNKNOWN,
  44. ),
  45. function=svc.get_server_config,
  46. ),
  47. "/chatto.admin.v1.AdminServerService/UpdateServerConfig": Endpoint.unary(
  48. method=MethodInfo(
  49. name="UpdateServerConfig",
  50. service_name="chatto.admin.v1.AdminServerService",
  51. input=chatto_dot_admin_dot_v1_dot_server__pb2.UpdateServerConfigRequest,
  52. output=chatto_dot_admin_dot_v1_dot_server__pb2.UpdateServerConfigResponse,
  53. idempotency_level=IdempotencyLevel.UNKNOWN,
  54. ),
  55. function=svc.update_server_config,
  56. ),
  57. "/chatto.admin.v1.AdminServerService/UploadServerLogo": Endpoint.unary(
  58. method=MethodInfo(
  59. name="UploadServerLogo",
  60. service_name="chatto.admin.v1.AdminServerService",
  61. input=chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerLogoRequest,
  62. output=chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerLogoResponse,
  63. idempotency_level=IdempotencyLevel.UNKNOWN,
  64. ),
  65. function=svc.upload_server_logo,
  66. ),
  67. "/chatto.admin.v1.AdminServerService/DeleteServerLogo": Endpoint.unary(
  68. method=MethodInfo(
  69. name="DeleteServerLogo",
  70. service_name="chatto.admin.v1.AdminServerService",
  71. input=chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerLogoRequest,
  72. output=chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerLogoResponse,
  73. idempotency_level=IdempotencyLevel.UNKNOWN,
  74. ),
  75. function=svc.delete_server_logo,
  76. ),
  77. "/chatto.admin.v1.AdminServerService/UploadServerBanner": Endpoint.unary(
  78. method=MethodInfo(
  79. name="UploadServerBanner",
  80. service_name="chatto.admin.v1.AdminServerService",
  81. input=chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerBannerRequest,
  82. output=chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerBannerResponse,
  83. idempotency_level=IdempotencyLevel.UNKNOWN,
  84. ),
  85. function=svc.upload_server_banner,
  86. ),
  87. "/chatto.admin.v1.AdminServerService/DeleteServerBanner": Endpoint.unary(
  88. method=MethodInfo(
  89. name="DeleteServerBanner",
  90. service_name="chatto.admin.v1.AdminServerService",
  91. input=chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerBannerRequest,
  92. output=chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerBannerResponse,
  93. idempotency_level=IdempotencyLevel.UNKNOWN,
  94. ),
  95. function=svc.delete_server_banner,
  96. ),
  97. "/chatto.admin.v1.AdminServerService/GetServerSecurityConfig": Endpoint.unary(
  98. method=MethodInfo(
  99. name="GetServerSecurityConfig",
  100. service_name="chatto.admin.v1.AdminServerService",
  101. input=chatto_dot_admin_dot_v1_dot_server__pb2.GetServerSecurityConfigRequest,
  102. output=chatto_dot_admin_dot_v1_dot_server__pb2.GetServerSecurityConfigResponse,
  103. idempotency_level=IdempotencyLevel.UNKNOWN,
  104. ),
  105. function=svc.get_server_security_config,
  106. ),
  107. "/chatto.admin.v1.AdminServerService/UpdateBlockedUsernames": Endpoint.unary(
  108. method=MethodInfo(
  109. name="UpdateBlockedUsernames",
  110. service_name="chatto.admin.v1.AdminServerService",
  111. input=chatto_dot_admin_dot_v1_dot_server__pb2.UpdateBlockedUsernamesRequest,
  112. output=chatto_dot_admin_dot_v1_dot_server__pb2.UpdateBlockedUsernamesResponse,
  113. idempotency_level=IdempotencyLevel.UNKNOWN,
  114. ),
  115. function=svc.update_blocked_usernames,
  116. ),
  117. },
  118. interceptors=interceptors,
  119. read_max_bytes=read_max_bytes,
  120. compressions=compressions,
  121. )
  122. @property
  123. def path(self) -> str:
  124. """Returns the URL path to mount the application to when serving multiple applications."""
  125. return "/chatto.admin.v1.AdminServerService"
  126. class AdminServerServiceClient(ConnectClient):
  127. async def get_server_config(
  128. self,
  129. request: chatto_dot_admin_dot_v1_dot_server__pb2.GetServerConfigRequest,
  130. *,
  131. headers: Headers | Mapping[str, str] | None = None,
  132. timeout_ms: int | None = None,
  133. ) -> chatto_dot_admin_dot_v1_dot_server__pb2.GetServerConfigResponse:
  134. return await self.execute_unary(
  135. request=request,
  136. method=MethodInfo(
  137. name="GetServerConfig",
  138. service_name="chatto.admin.v1.AdminServerService",
  139. input=chatto_dot_admin_dot_v1_dot_server__pb2.GetServerConfigRequest,
  140. output=chatto_dot_admin_dot_v1_dot_server__pb2.GetServerConfigResponse,
  141. idempotency_level=IdempotencyLevel.UNKNOWN,
  142. ),
  143. headers=headers,
  144. timeout_ms=timeout_ms,
  145. )
  146. async def update_server_config(
  147. self,
  148. request: chatto_dot_admin_dot_v1_dot_server__pb2.UpdateServerConfigRequest,
  149. *,
  150. headers: Headers | Mapping[str, str] | None = None,
  151. timeout_ms: int | None = None,
  152. ) -> chatto_dot_admin_dot_v1_dot_server__pb2.UpdateServerConfigResponse:
  153. return await self.execute_unary(
  154. request=request,
  155. method=MethodInfo(
  156. name="UpdateServerConfig",
  157. service_name="chatto.admin.v1.AdminServerService",
  158. input=chatto_dot_admin_dot_v1_dot_server__pb2.UpdateServerConfigRequest,
  159. output=chatto_dot_admin_dot_v1_dot_server__pb2.UpdateServerConfigResponse,
  160. idempotency_level=IdempotencyLevel.UNKNOWN,
  161. ),
  162. headers=headers,
  163. timeout_ms=timeout_ms,
  164. )
  165. async def upload_server_logo(
  166. self,
  167. request: chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerLogoRequest,
  168. *,
  169. headers: Headers | Mapping[str, str] | None = None,
  170. timeout_ms: int | None = None,
  171. ) -> chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerLogoResponse:
  172. return await self.execute_unary(
  173. request=request,
  174. method=MethodInfo(
  175. name="UploadServerLogo",
  176. service_name="chatto.admin.v1.AdminServerService",
  177. input=chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerLogoRequest,
  178. output=chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerLogoResponse,
  179. idempotency_level=IdempotencyLevel.UNKNOWN,
  180. ),
  181. headers=headers,
  182. timeout_ms=timeout_ms,
  183. )
  184. async def delete_server_logo(
  185. self,
  186. request: chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerLogoRequest,
  187. *,
  188. headers: Headers | Mapping[str, str] | None = None,
  189. timeout_ms: int | None = None,
  190. ) -> chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerLogoResponse:
  191. return await self.execute_unary(
  192. request=request,
  193. method=MethodInfo(
  194. name="DeleteServerLogo",
  195. service_name="chatto.admin.v1.AdminServerService",
  196. input=chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerLogoRequest,
  197. output=chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerLogoResponse,
  198. idempotency_level=IdempotencyLevel.UNKNOWN,
  199. ),
  200. headers=headers,
  201. timeout_ms=timeout_ms,
  202. )
  203. async def upload_server_banner(
  204. self,
  205. request: chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerBannerRequest,
  206. *,
  207. headers: Headers | Mapping[str, str] | None = None,
  208. timeout_ms: int | None = None,
  209. ) -> chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerBannerResponse:
  210. return await self.execute_unary(
  211. request=request,
  212. method=MethodInfo(
  213. name="UploadServerBanner",
  214. service_name="chatto.admin.v1.AdminServerService",
  215. input=chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerBannerRequest,
  216. output=chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerBannerResponse,
  217. idempotency_level=IdempotencyLevel.UNKNOWN,
  218. ),
  219. headers=headers,
  220. timeout_ms=timeout_ms,
  221. )
  222. async def delete_server_banner(
  223. self,
  224. request: chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerBannerRequest,
  225. *,
  226. headers: Headers | Mapping[str, str] | None = None,
  227. timeout_ms: int | None = None,
  228. ) -> chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerBannerResponse:
  229. return await self.execute_unary(
  230. request=request,
  231. method=MethodInfo(
  232. name="DeleteServerBanner",
  233. service_name="chatto.admin.v1.AdminServerService",
  234. input=chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerBannerRequest,
  235. output=chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerBannerResponse,
  236. idempotency_level=IdempotencyLevel.UNKNOWN,
  237. ),
  238. headers=headers,
  239. timeout_ms=timeout_ms,
  240. )
  241. async def get_server_security_config(
  242. self,
  243. request: chatto_dot_admin_dot_v1_dot_server__pb2.GetServerSecurityConfigRequest,
  244. *,
  245. headers: Headers | Mapping[str, str] | None = None,
  246. timeout_ms: int | None = None,
  247. ) -> chatto_dot_admin_dot_v1_dot_server__pb2.GetServerSecurityConfigResponse:
  248. return await self.execute_unary(
  249. request=request,
  250. method=MethodInfo(
  251. name="GetServerSecurityConfig",
  252. service_name="chatto.admin.v1.AdminServerService",
  253. input=chatto_dot_admin_dot_v1_dot_server__pb2.GetServerSecurityConfigRequest,
  254. output=chatto_dot_admin_dot_v1_dot_server__pb2.GetServerSecurityConfigResponse,
  255. idempotency_level=IdempotencyLevel.UNKNOWN,
  256. ),
  257. headers=headers,
  258. timeout_ms=timeout_ms,
  259. )
  260. async def update_blocked_usernames(
  261. self,
  262. request: chatto_dot_admin_dot_v1_dot_server__pb2.UpdateBlockedUsernamesRequest,
  263. *,
  264. headers: Headers | Mapping[str, str] | None = None,
  265. timeout_ms: int | None = None,
  266. ) -> chatto_dot_admin_dot_v1_dot_server__pb2.UpdateBlockedUsernamesResponse:
  267. return await self.execute_unary(
  268. request=request,
  269. method=MethodInfo(
  270. name="UpdateBlockedUsernames",
  271. service_name="chatto.admin.v1.AdminServerService",
  272. input=chatto_dot_admin_dot_v1_dot_server__pb2.UpdateBlockedUsernamesRequest,
  273. output=chatto_dot_admin_dot_v1_dot_server__pb2.UpdateBlockedUsernamesResponse,
  274. idempotency_level=IdempotencyLevel.UNKNOWN,
  275. ),
  276. headers=headers,
  277. timeout_ms=timeout_ms,
  278. )
  279. class AdminServerServiceSync(Protocol):
  280. def get_server_config(self, request: chatto_dot_admin_dot_v1_dot_server__pb2.GetServerConfigRequest, ctx: RequestContext) -> chatto_dot_admin_dot_v1_dot_server__pb2.GetServerConfigResponse:
  281. raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")
  282. def update_server_config(self, request: chatto_dot_admin_dot_v1_dot_server__pb2.UpdateServerConfigRequest, ctx: RequestContext) -> chatto_dot_admin_dot_v1_dot_server__pb2.UpdateServerConfigResponse:
  283. raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")
  284. def upload_server_logo(self, request: chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerLogoRequest, ctx: RequestContext) -> chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerLogoResponse:
  285. raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")
  286. def delete_server_logo(self, request: chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerLogoRequest, ctx: RequestContext) -> chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerLogoResponse:
  287. raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")
  288. def upload_server_banner(self, request: chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerBannerRequest, ctx: RequestContext) -> chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerBannerResponse:
  289. raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")
  290. def delete_server_banner(self, request: chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerBannerRequest, ctx: RequestContext) -> chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerBannerResponse:
  291. raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")
  292. def get_server_security_config(self, request: chatto_dot_admin_dot_v1_dot_server__pb2.GetServerSecurityConfigRequest, ctx: RequestContext) -> chatto_dot_admin_dot_v1_dot_server__pb2.GetServerSecurityConfigResponse:
  293. raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")
  294. def update_blocked_usernames(self, request: chatto_dot_admin_dot_v1_dot_server__pb2.UpdateBlockedUsernamesRequest, ctx: RequestContext) -> chatto_dot_admin_dot_v1_dot_server__pb2.UpdateBlockedUsernamesResponse:
  295. raise ConnectError(Code.UNIMPLEMENTED, "Not implemented")
  296. class AdminServerServiceWSGIApplication(ConnectWSGIApplication):
  297. def __init__(self, service: AdminServerServiceSync, interceptors: Iterable[InterceptorSync]=(), read_max_bytes: int | None = None, compressions: Iterable[Compression] | None = None) -> None:
  298. super().__init__(
  299. endpoints={
  300. "/chatto.admin.v1.AdminServerService/GetServerConfig": EndpointSync.unary(
  301. method=MethodInfo(
  302. name="GetServerConfig",
  303. service_name="chatto.admin.v1.AdminServerService",
  304. input=chatto_dot_admin_dot_v1_dot_server__pb2.GetServerConfigRequest,
  305. output=chatto_dot_admin_dot_v1_dot_server__pb2.GetServerConfigResponse,
  306. idempotency_level=IdempotencyLevel.UNKNOWN,
  307. ),
  308. function=service.get_server_config,
  309. ),
  310. "/chatto.admin.v1.AdminServerService/UpdateServerConfig": EndpointSync.unary(
  311. method=MethodInfo(
  312. name="UpdateServerConfig",
  313. service_name="chatto.admin.v1.AdminServerService",
  314. input=chatto_dot_admin_dot_v1_dot_server__pb2.UpdateServerConfigRequest,
  315. output=chatto_dot_admin_dot_v1_dot_server__pb2.UpdateServerConfigResponse,
  316. idempotency_level=IdempotencyLevel.UNKNOWN,
  317. ),
  318. function=service.update_server_config,
  319. ),
  320. "/chatto.admin.v1.AdminServerService/UploadServerLogo": EndpointSync.unary(
  321. method=MethodInfo(
  322. name="UploadServerLogo",
  323. service_name="chatto.admin.v1.AdminServerService",
  324. input=chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerLogoRequest,
  325. output=chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerLogoResponse,
  326. idempotency_level=IdempotencyLevel.UNKNOWN,
  327. ),
  328. function=service.upload_server_logo,
  329. ),
  330. "/chatto.admin.v1.AdminServerService/DeleteServerLogo": EndpointSync.unary(
  331. method=MethodInfo(
  332. name="DeleteServerLogo",
  333. service_name="chatto.admin.v1.AdminServerService",
  334. input=chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerLogoRequest,
  335. output=chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerLogoResponse,
  336. idempotency_level=IdempotencyLevel.UNKNOWN,
  337. ),
  338. function=service.delete_server_logo,
  339. ),
  340. "/chatto.admin.v1.AdminServerService/UploadServerBanner": EndpointSync.unary(
  341. method=MethodInfo(
  342. name="UploadServerBanner",
  343. service_name="chatto.admin.v1.AdminServerService",
  344. input=chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerBannerRequest,
  345. output=chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerBannerResponse,
  346. idempotency_level=IdempotencyLevel.UNKNOWN,
  347. ),
  348. function=service.upload_server_banner,
  349. ),
  350. "/chatto.admin.v1.AdminServerService/DeleteServerBanner": EndpointSync.unary(
  351. method=MethodInfo(
  352. name="DeleteServerBanner",
  353. service_name="chatto.admin.v1.AdminServerService",
  354. input=chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerBannerRequest,
  355. output=chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerBannerResponse,
  356. idempotency_level=IdempotencyLevel.UNKNOWN,
  357. ),
  358. function=service.delete_server_banner,
  359. ),
  360. "/chatto.admin.v1.AdminServerService/GetServerSecurityConfig": EndpointSync.unary(
  361. method=MethodInfo(
  362. name="GetServerSecurityConfig",
  363. service_name="chatto.admin.v1.AdminServerService",
  364. input=chatto_dot_admin_dot_v1_dot_server__pb2.GetServerSecurityConfigRequest,
  365. output=chatto_dot_admin_dot_v1_dot_server__pb2.GetServerSecurityConfigResponse,
  366. idempotency_level=IdempotencyLevel.UNKNOWN,
  367. ),
  368. function=service.get_server_security_config,
  369. ),
  370. "/chatto.admin.v1.AdminServerService/UpdateBlockedUsernames": EndpointSync.unary(
  371. method=MethodInfo(
  372. name="UpdateBlockedUsernames",
  373. service_name="chatto.admin.v1.AdminServerService",
  374. input=chatto_dot_admin_dot_v1_dot_server__pb2.UpdateBlockedUsernamesRequest,
  375. output=chatto_dot_admin_dot_v1_dot_server__pb2.UpdateBlockedUsernamesResponse,
  376. idempotency_level=IdempotencyLevel.UNKNOWN,
  377. ),
  378. function=service.update_blocked_usernames,
  379. ),
  380. },
  381. interceptors=interceptors,
  382. read_max_bytes=read_max_bytes,
  383. compressions=compressions,
  384. )
  385. @property
  386. def path(self) -> str:
  387. """Returns the URL path to mount the application to when serving multiple applications."""
  388. return "/chatto.admin.v1.AdminServerService"
  389. class AdminServerServiceClientSync(ConnectClientSync):
  390. def get_server_config(
  391. self,
  392. request: chatto_dot_admin_dot_v1_dot_server__pb2.GetServerConfigRequest,
  393. *,
  394. headers: Headers | Mapping[str, str] | None = None,
  395. timeout_ms: int | None = None,
  396. ) -> chatto_dot_admin_dot_v1_dot_server__pb2.GetServerConfigResponse:
  397. return self.execute_unary(
  398. request=request,
  399. method=MethodInfo(
  400. name="GetServerConfig",
  401. service_name="chatto.admin.v1.AdminServerService",
  402. input=chatto_dot_admin_dot_v1_dot_server__pb2.GetServerConfigRequest,
  403. output=chatto_dot_admin_dot_v1_dot_server__pb2.GetServerConfigResponse,
  404. idempotency_level=IdempotencyLevel.UNKNOWN,
  405. ),
  406. headers=headers,
  407. timeout_ms=timeout_ms,
  408. )
  409. def update_server_config(
  410. self,
  411. request: chatto_dot_admin_dot_v1_dot_server__pb2.UpdateServerConfigRequest,
  412. *,
  413. headers: Headers | Mapping[str, str] | None = None,
  414. timeout_ms: int | None = None,
  415. ) -> chatto_dot_admin_dot_v1_dot_server__pb2.UpdateServerConfigResponse:
  416. return self.execute_unary(
  417. request=request,
  418. method=MethodInfo(
  419. name="UpdateServerConfig",
  420. service_name="chatto.admin.v1.AdminServerService",
  421. input=chatto_dot_admin_dot_v1_dot_server__pb2.UpdateServerConfigRequest,
  422. output=chatto_dot_admin_dot_v1_dot_server__pb2.UpdateServerConfigResponse,
  423. idempotency_level=IdempotencyLevel.UNKNOWN,
  424. ),
  425. headers=headers,
  426. timeout_ms=timeout_ms,
  427. )
  428. def upload_server_logo(
  429. self,
  430. request: chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerLogoRequest,
  431. *,
  432. headers: Headers | Mapping[str, str] | None = None,
  433. timeout_ms: int | None = None,
  434. ) -> chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerLogoResponse:
  435. return self.execute_unary(
  436. request=request,
  437. method=MethodInfo(
  438. name="UploadServerLogo",
  439. service_name="chatto.admin.v1.AdminServerService",
  440. input=chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerLogoRequest,
  441. output=chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerLogoResponse,
  442. idempotency_level=IdempotencyLevel.UNKNOWN,
  443. ),
  444. headers=headers,
  445. timeout_ms=timeout_ms,
  446. )
  447. def delete_server_logo(
  448. self,
  449. request: chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerLogoRequest,
  450. *,
  451. headers: Headers | Mapping[str, str] | None = None,
  452. timeout_ms: int | None = None,
  453. ) -> chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerLogoResponse:
  454. return self.execute_unary(
  455. request=request,
  456. method=MethodInfo(
  457. name="DeleteServerLogo",
  458. service_name="chatto.admin.v1.AdminServerService",
  459. input=chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerLogoRequest,
  460. output=chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerLogoResponse,
  461. idempotency_level=IdempotencyLevel.UNKNOWN,
  462. ),
  463. headers=headers,
  464. timeout_ms=timeout_ms,
  465. )
  466. def upload_server_banner(
  467. self,
  468. request: chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerBannerRequest,
  469. *,
  470. headers: Headers | Mapping[str, str] | None = None,
  471. timeout_ms: int | None = None,
  472. ) -> chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerBannerResponse:
  473. return self.execute_unary(
  474. request=request,
  475. method=MethodInfo(
  476. name="UploadServerBanner",
  477. service_name="chatto.admin.v1.AdminServerService",
  478. input=chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerBannerRequest,
  479. output=chatto_dot_admin_dot_v1_dot_server__pb2.UploadServerBannerResponse,
  480. idempotency_level=IdempotencyLevel.UNKNOWN,
  481. ),
  482. headers=headers,
  483. timeout_ms=timeout_ms,
  484. )
  485. def delete_server_banner(
  486. self,
  487. request: chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerBannerRequest,
  488. *,
  489. headers: Headers | Mapping[str, str] | None = None,
  490. timeout_ms: int | None = None,
  491. ) -> chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerBannerResponse:
  492. return self.execute_unary(
  493. request=request,
  494. method=MethodInfo(
  495. name="DeleteServerBanner",
  496. service_name="chatto.admin.v1.AdminServerService",
  497. input=chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerBannerRequest,
  498. output=chatto_dot_admin_dot_v1_dot_server__pb2.DeleteServerBannerResponse,
  499. idempotency_level=IdempotencyLevel.UNKNOWN,
  500. ),
  501. headers=headers,
  502. timeout_ms=timeout_ms,
  503. )
  504. def get_server_security_config(
  505. self,
  506. request: chatto_dot_admin_dot_v1_dot_server__pb2.GetServerSecurityConfigRequest,
  507. *,
  508. headers: Headers | Mapping[str, str] | None = None,
  509. timeout_ms: int | None = None,
  510. ) -> chatto_dot_admin_dot_v1_dot_server__pb2.GetServerSecurityConfigResponse:
  511. return self.execute_unary(
  512. request=request,
  513. method=MethodInfo(
  514. name="GetServerSecurityConfig",
  515. service_name="chatto.admin.v1.AdminServerService",
  516. input=chatto_dot_admin_dot_v1_dot_server__pb2.GetServerSecurityConfigRequest,
  517. output=chatto_dot_admin_dot_v1_dot_server__pb2.GetServerSecurityConfigResponse,
  518. idempotency_level=IdempotencyLevel.UNKNOWN,
  519. ),
  520. headers=headers,
  521. timeout_ms=timeout_ms,
  522. )
  523. def update_blocked_usernames(
  524. self,
  525. request: chatto_dot_admin_dot_v1_dot_server__pb2.UpdateBlockedUsernamesRequest,
  526. *,
  527. headers: Headers | Mapping[str, str] | None = None,
  528. timeout_ms: int | None = None,
  529. ) -> chatto_dot_admin_dot_v1_dot_server__pb2.UpdateBlockedUsernamesResponse:
  530. return self.execute_unary(
  531. request=request,
  532. method=MethodInfo(
  533. name="UpdateBlockedUsernames",
  534. service_name="chatto.admin.v1.AdminServerService",
  535. input=chatto_dot_admin_dot_v1_dot_server__pb2.UpdateBlockedUsernamesRequest,
  536. output=chatto_dot_admin_dot_v1_dot_server__pb2.UpdateBlockedUsernamesResponse,
  537. idempotency_level=IdempotencyLevel.UNKNOWN,
  538. ),
  539. headers=headers,
  540. timeout_ms=timeout_ms,
  541. )