overmind
/
matrix-docker-ansible-deploy
mirror da https://github.com/spantaleev/matrix-docker-ansible-deploy
1
0
Forka 0
Codice Problemi 0 Rilasci 0 Wiki Attività
Matrix Docker Ansible eploy
Non puoi selezionare più di 25 argomenti Gli argomenti devono iniziare con una lettera o un numero, possono includere trattini ('-') e possono essere lunghi fino a 35 caratteri.
10090 Commit
12 Rami (Branch)
725 MiB
 
 
Albero (Tree): ec00a76b14
Rami (Branch) Tag
${ item.name }
Crea branch ${ searchTerm }
da 'ec00a76b14'
${ noResults }
matrix-docker-ansible-deploy/roles/custom/matrix-synapse-reverse-prox.../templates/nginx/conf.d/matrix-synapse-reverse-prox...

306 righe
17 KiB
Originale Blame Cronologia 

  1. #jinja2: lstrip_blocks: "True"

  2. 

  3. {% set room_workers = matrix_synapse_reverse_proxy_companion_synapse_workers_list | selectattr('type', 'equalto', 'room_worker') | list %}

  4. {% set sync_workers = matrix_synapse_reverse_proxy_companion_synapse_workers_list | selectattr('type', 'equalto', 'sync_worker') | list %}

  5. {% set client_reader_workers = matrix_synapse_reverse_proxy_companion_synapse_workers_list | selectattr('type', 'equalto', 'client_reader') | list %}

  6. {% set federation_reader_workers = matrix_synapse_reverse_proxy_companion_synapse_workers_list | selectattr('type', 'equalto', 'federation_reader') | list %}

  7. {% set generic_workers = matrix_synapse_reverse_proxy_companion_synapse_workers_list | selectattr('type', 'equalto', 'generic_worker') | list %}

  8. {% set stream_writer_typing_stream_workers = matrix_synapse_reverse_proxy_companion_synapse_workers_list | selectattr('type', 'equalto', 'stream_writer') | selectattr('stream_writer_stream', 'equalto', 'typing') | list %}

  9. {% set stream_writer_to_device_stream_workers = matrix_synapse_reverse_proxy_companion_synapse_workers_list | selectattr('type', 'equalto', 'stream_writer') | selectattr('stream_writer_stream', 'equalto', 'to_device') | list %}

  10. {% set stream_writer_account_data_stream_workers = matrix_synapse_reverse_proxy_companion_synapse_workers_list | selectattr('type', 'equalto', 'stream_writer') | selectattr('stream_writer_stream', 'equalto', 'account_data') | list %}

  11. {% set stream_writer_receipts_stream_workers = matrix_synapse_reverse_proxy_companion_synapse_workers_list | selectattr('type', 'equalto', 'stream_writer') | selectattr('stream_writer_stream', 'equalto', 'receipts') | list %}

  12. {% set stream_writer_presence_stream_workers = matrix_synapse_reverse_proxy_companion_synapse_workers_list | selectattr('type', 'equalto', 'stream_writer') | selectattr('stream_writer_stream', 'equalto', 'presence') | list %}

  13. {% set media_repository_workers = matrix_synapse_reverse_proxy_companion_synapse_workers_list | selectattr('type', 'equalto', 'media_repository') | list %}

  14. {% set user_dir_workers = matrix_synapse_reverse_proxy_companion_synapse_workers_list | selectattr('type', 'equalto', 'user_dir') | list %}

  15. 

  16. {% macro render_worker_upstream(name, workers, load_balance) %}

  17. {% if workers | length > 0 %}

  18. 	upstream {{ name }} {

  19. 		{#

  20. 			We need to use a zone so that the upstream is stored in shared memory,

  21. 			otherwise we can't use `resolve` below, as reported by nginx:

  22. 			> resolving names at run time requires upstream ".." in ... to be in shared memory

  23. 		#}

  24. 		zone {{ name }} 64k;

  25. 

  26. 		{{ load_balance }}

  27. 		keepalive {{ ((workers | length) * 2) | string }};

  28. 		resolver {{ matrix_synapse_reverse_proxy_companion_http_level_resolver }} valid=5s;

  29. 		{% for worker in workers %}

  30. 			server "{{ worker.name }}:{{ worker.port }}" resolve;

  31. 		{% endfor %}

  32. 	}

  33. {% endif %}

  34. {% endmacro %}

  35. 

  36. {% macro render_locations_to_upstream(locations, upstream_name) %}

  37. 	{% for location in locations %}

  38. 	location ~ {{ location }} {

  39. 		proxy_pass http://{{ upstream_name }}$request_uri;

  40. 		proxy_http_version 1.1;

  41. 		proxy_set_header Connection "";

  42. 	}

  43. 	{% endfor %}

  44. {% endmacro %}

  45. 

  46. {% if matrix_synapse_reverse_proxy_companion_synapse_workers_enabled %}

  47. 

  48. # Maps from https://tcpipuk.github.io/synapse/deployment/nginx.html#mapsconf

  49. # Client username from access token

  50. map $arg_access_token $accesstoken_from_urlparam {

  51.   default                    $arg_access_token;

  52.   "~syt_(?<username>.*?)_.*" $username;

  53. }

  54. # Client username from MXID

  55. map $http_authorization $mxid_localpart {

  56.   default                           $http_authorization;

  57.   "~Bearer syt_(?<username>.*?)_.*" $username;

  58.   ""                                $accesstoken_from_urlparam;

  59. }

  60. # Whether to upgrade HTTP connection

  61. map $http_upgrade $connection_upgrade {

  62.   default upgrade;

  63.   '' close;

  64. }

  65. #Extract room name from URI

  66. map $request_uri $room_name {

  67.   ~^/_matrix/(client|federation)/.*?(?:%21|!)(?<room>[A-Za-z0-9._=\-\/]+)(?::|%3A)[A-Za-z0-9._=\-\/]+ $room;

  68. }

  69. # End maps

  70. 

  71. 	{% if matrix_synapse_reverse_proxy_companion_synapse_cache_enabled %}

  72.     	proxy_cache_path  {{ matrix_synapse_reverse_proxy_companion_synapse_cache_path }} levels=1:2 keys_zone={{ matrix_synapse_reverse_proxy_companion_synapse_cache_keys_zone_name }}:{{ matrix_synapse_reverse_proxy_companion_synapse_cache_keys_zone_size }} inactive={{ matrix_synapse_reverse_proxy_companion_synapse_cache_inactive_time }} max_size={{ matrix_synapse_reverse_proxy_companion_synapse_cache_max_size_mb }}m;

  73. 	{% endif %}

  74. 	# Round Robin "upstream" pools for workers

  75. 

  76. 	{{ render_worker_upstream('room_workers_upstream', room_workers, 'hash $room_name consistent;') }}

  77. 	{{ render_worker_upstream('sync_workers_upstream', sync_workers, 'hash $mxid_localpart consistent;') }}

  78. 	{{ render_worker_upstream('client_reader_workers_upstream', client_reader_workers, 'least_conn;') }}

  79. 	{{ render_worker_upstream('federation_reader_workers_upstream', federation_reader_workers, 'hash $http_x_forwarded_for;') }}

  80. 

  81. 	{{ render_worker_upstream('generic_workers_upstream', generic_workers, 'hash $http_x_forwarded_for;') }}

  82. 

  83. 	{{ render_worker_upstream('stream_writer_typing_stream_workers_upstream', stream_writer_typing_stream_workers, '') }}

  84. 	{{ render_worker_upstream('stream_writer_to_device_stream_workers_upstream', stream_writer_to_device_stream_workers, '') }}

  85. 	{{ render_worker_upstream('stream_writer_account_data_stream_workers_upstream', stream_writer_account_data_stream_workers, '') }}

  86. 	{{ render_worker_upstream('stream_writer_receipts_stream_workers_upstream', stream_writer_receipts_stream_workers, '') }}

  87. 	{{ render_worker_upstream('stream_writer_presence_stream_workers_upstream', stream_writer_presence_stream_workers, '') }}

  88. 

  89. 	{{ render_worker_upstream('media_repository_workers_upstream', media_repository_workers, 'least_conn;') }}

  90. 

  91. 	{{ render_worker_upstream('user_dir_workers_upstream', user_dir_workers, '') }}

  92. {% endif %}

  93. 

  94. server {

  95. 	listen 8008;

  96. 	server_name {{ matrix_synapse_reverse_proxy_companion_hostname }};

  97. 

  98. 	server_tokens off;

  99. 	root /dev/null;

  100. 

  101. 	client_max_body_size {{ matrix_synapse_reverse_proxy_companion_client_api_client_max_body_size_mb }}M;

  102. 	client_body_buffer_size {{ matrix_synapse_reverse_proxy_companion_client_api_client_body_buffer_size_mb }}M;

  103. 

  104. 	proxy_buffering on;

  105. 	proxy_max_temp_file_size 0;

  106. 	proxy_set_header Host $host;

  107. 

  108. 	{% if matrix_synapse_reverse_proxy_companion_synapse_workers_enabled %}

  109. 		# Client-server overrides — These locations must go to the main Synapse process

  110. 		location ~ {{ matrix_synapse_reverse_proxy_companion_client_server_main_override_locations_regex }} {

  111. 			{# FIXME: This block was copied from the main Synapse fallback below.  It would be better to have it in one place and avoid duplication. #}

  112. 			{# Use the embedded DNS resolver in Docker containers to discover the service #}

  113. 			resolver {{ matrix_synapse_reverse_proxy_companion_http_level_resolver }} valid=5s;

  114. 			set $backend "{{ matrix_synapse_reverse_proxy_companion_client_api_addr }}";

  115. 			proxy_pass http://$backend;

  116. 		}

  117. 

  118. 		# Client-server SSO overrides — These locations must go to the main Synapse process

  119. 		location ~ {{ matrix_synapse_reverse_proxy_companion_client_server_sso_override_locations_regex }} {

  120. 			{# FIXME: This block was copied from the main Synapse fallback below.  It would be better to have it in one place and avoid duplication. #}

  121. 			{# Use the embedded DNS resolver in Docker containers to discover the service #}

  122. 			resolver {{ matrix_synapse_reverse_proxy_companion_http_level_resolver }} valid=5s;

  123. 			set $backend "{{ matrix_synapse_reverse_proxy_companion_client_api_addr }}";

  124. 			proxy_pass http://$backend;

  125. 		}

  126. 

  127. 		# QR code login (`rendezvous`) locations need to go to the same Synapse process.

  128. 		# It doesn't necessarily need to be the main process, but it needs to be consistent.

  129. 		# For simplicity, we'll send them to the main process though.

  130. 		location ~ {{ matrix_synapse_reverse_proxy_companion_client_server_qr_code_login_locations_regex }} {

  131. 			{# FIXME: This block was copied from the main Synapse fallback below.  It would be better to have it in one place and avoid duplication. #}

  132. 			{# Use the embedded DNS resolver in Docker containers to discover the service #}

  133. 			resolver {{ matrix_synapse_reverse_proxy_companion_http_level_resolver }} valid=5s;

  134. 			set $backend "{{ matrix_synapse_reverse_proxy_companion_client_api_addr }}";

  135. 			proxy_pass http://$backend;

  136. 		}

  137. 

  138. 		{# Workers redirects BEGIN #}

  139. 

  140. 		{% if generic_workers | length > 0 %}

  141. 			# https://matrix-org.github.io/synapse/latest/workers.html#synapseappgeneric_worker

  142. 			{{ render_locations_to_upstream(matrix_synapse_reverse_proxy_companion_synapse_generic_worker_client_server_locations, 'generic_workers_upstream') }}

  143. 		{% endif %}

  144. 

  145. 		{% if stream_writer_typing_stream_workers | length > 0 %}

  146. 			# https://matrix-org.github.io/synapse/latest/workers.html#the-typing-stream

  147. 			{{ render_locations_to_upstream(matrix_synapse_reverse_proxy_companion_synapse_stream_writer_typing_stream_worker_client_server_locations, 'stream_writer_typing_stream_workers_upstream') }}

  148. 		{% endif %}

  149. 

  150. 		{% if stream_writer_to_device_stream_workers | length > 0 %}

  151. 			# https://matrix-org.github.io/synapse/latest/workers.html#the-to_device-stream

  152. 			{{ render_locations_to_upstream(matrix_synapse_reverse_proxy_companion_synapse_stream_writer_to_device_stream_worker_client_server_locations, 'stream_writer_to_device_stream_workers_upstream') }}

  153. 		{% endif %}

  154. 

  155. 		{% if stream_writer_account_data_stream_workers | length > 0 %}

  156. 			# https://matrix-org.github.io/synapse/latest/workers.html#the-account_data-stream

  157. 			{{ render_locations_to_upstream(matrix_synapse_reverse_proxy_companion_synapse_stream_writer_account_data_stream_worker_client_server_locations, 'stream_writer_account_data_stream_workers_upstream') }}

  158. 		{% endif %}

  159. 

  160. 		{% if stream_writer_receipts_stream_workers | length > 0 %}

  161. 			# https://matrix-org.github.io/synapse/latest/workers.html#the-receipts-stream

  162. 			{{ render_locations_to_upstream(matrix_synapse_reverse_proxy_companion_synapse_stream_writer_receipts_stream_worker_client_server_locations, 'stream_writer_receipts_stream_workers_upstream') }}

  163. 		{% endif %}

  164. 

  165. 		{% if stream_writer_presence_stream_workers | length > 0 %}

  166. 			# https://matrix-org.github.io/synapse/latest/workers.html#the-presence-stream

  167. 			{{ render_locations_to_upstream(matrix_synapse_reverse_proxy_companion_synapse_stream_writer_presence_stream_worker_client_server_locations, 'stream_writer_presence_stream_workers_upstream') }}

  168. 		{% endif %}

  169. 

  170. 		{% if room_workers | length > 0 %}

  171. 			# room workers

  172. 			# https://tcpipuk.github.io/synapse/deployment/workers.html

  173. 			# https://tcpipuk.github.io/synapse/deployment/nginx.html#locationsconf

  174. 			{{ render_locations_to_upstream(matrix_synapse_reverse_proxy_companion_synapse_room_worker_client_server_locations, 'room_workers_upstream') }}

  175. 		{% endif %}

  176. 

  177. 		{% if sync_workers | length > 0 %}

  178. 			# sync workers

  179. 			# https://tcpipuk.github.io/synapse/deployment/workers.html

  180. 			# https://tcpipuk.github.io/synapse/deployment/nginx.html#locationsconf

  181. 			{{ render_locations_to_upstream(matrix_synapse_reverse_proxy_companion_synapse_sync_worker_client_server_locations, 'sync_workers_upstream') }}

  182. 		{% endif %}

  183. 

  184. 		{% if client_reader_workers | length > 0 %}

  185. 			# client_reader workers

  186. 			# https://tcpipuk.github.io/synapse/deployment/workers.html

  187. 			# https://tcpipuk.github.io/synapse/deployment/nginx.html#locationsconf

  188. 			{{ render_locations_to_upstream(matrix_synapse_reverse_proxy_companion_synapse_client_reader_client_server_locations, 'client_reader_workers_upstream') }}

  189. 		{% endif %}

  190. 

  191. 		{% if media_repository_workers | length > 0 %}

  192. 			# https://matrix-org.github.io/synapse/latest/workers.html#synapseappmedia_repository

  193. 			{% for location in matrix_synapse_reverse_proxy_companion_synapse_media_repository_locations %}

  194. 			location ~ {{ location }} {

  195. 				proxy_pass http://media_repository_workers_upstream$request_uri;

  196. 

  197. 				{% if matrix_synapse_reverse_proxy_companion_synapse_cache_enabled %}

  198. 					proxy_cache            {{ matrix_synapse_reverse_proxy_companion_synapse_cache_keys_zone_name }};

  199. 					proxy_cache_valid      any {{ matrix_synapse_reverse_proxy_companion_synapse_cache_proxy_cache_valid_time }};

  200. 					proxy_force_ranges on;

  201. 					add_header X-Cache-Status $upstream_cache_status;

  202. 				{% endif %}

  203. 			}

  204. 			{% endfor %}

  205. 		{% endif %}

  206. 

  207. 		{% if user_dir_workers | length > 0 %}

  208. 			# https://matrix-org.github.io/synapse/latest/workers.html#updating-the-user-directory

  209. 			{{ render_locations_to_upstream(matrix_synapse_reverse_proxy_companion_synapse_user_dir_locations, 'user_dir_workers_upstream') }}

  210. 		{% endif %}

  211. 		{# Workers redirects END #}

  212. 	{% endif %}

  213. 

  214. 	{% for configuration_block in matrix_synapse_reverse_proxy_companion_synapse_client_api_additional_server_configuration_blocks %}

  215. 		{{- configuration_block }}

  216. 	{% endfor %}

  217. 

  218. 	{# Everything else just goes to the API server ##}

  219. 	location / {

  220. 		{# Use the embedded DNS resolver in Docker containers to discover the service #}

  221. 		resolver {{ matrix_synapse_reverse_proxy_companion_http_level_resolver }} valid=5s;

  222. 		set $backend "{{ matrix_synapse_reverse_proxy_companion_client_api_addr }}";

  223. 		proxy_pass http://$backend;

  224. 	}

  225. }

  226. 

  227. {% if matrix_synapse_reverse_proxy_companion_federation_api_enabled %}

  228. server {

  229. 	listen 8048;

  230. 	server_name {{ matrix_synapse_reverse_proxy_companion_hostname }};

  231. 

  232. 	server_tokens off;

  233. 	root /dev/null;

  234. 

  235. 	client_max_body_size {{ matrix_synapse_reverse_proxy_companion_federation_api_client_max_body_size_mb }}M;

  236. 	client_body_buffer_size {{ matrix_synapse_reverse_proxy_companion_federation_api_client_body_buffer_size_mb }}M;

  237. 

  238. 	proxy_buffering on;

  239. 	proxy_max_temp_file_size 0;

  240. 	proxy_set_header Host $host;

  241. 

  242. 	{% if matrix_synapse_reverse_proxy_companion_synapse_workers_enabled %}

  243. 		# Federation overrides — These locations must go to the main Synapse process

  244. 		location ~ {{ matrix_synapse_reverse_proxy_companion_federation_override_locations_regex }} {

  245. 			{# FIXME: This block was copied from the fallback location below.  It would be better to have it in one place and avoid duplication. #}

  246. 			{# Use the embedded DNS resolver in Docker containers to discover the service #}

  247. 			resolver {{ matrix_synapse_reverse_proxy_companion_http_level_resolver }} valid=5s;

  248. 			set $backend "{{ matrix_synapse_reverse_proxy_companion_federation_api_addr }}";

  249. 			proxy_pass http://$backend;

  250. 		}

  251. 

  252. 		{% if room_workers | length > 0 %}

  253. 			# https://tcpipuk.github.io/synapse/deployment/workers.html

  254. 			{{ render_locations_to_upstream(matrix_synapse_reverse_proxy_companion_synapse_room_worker_federation_locations, 'room_workers_upstream') }}

  255. 		{% endif %}

  256. 

  257. 		{% if generic_workers | length > 0 %}

  258. 			# https://matrix-org.github.io/synapse/latest/workers.html#synapseappgeneric_worker

  259. 			{{ render_locations_to_upstream(matrix_synapse_reverse_proxy_companion_synapse_generic_worker_federation_locations, 'generic_workers_upstream') }}

  260. 		{% endif %}

  261. 

  262. 		{% if media_repository_workers | length > 0 %}

  263. 			# https://matrix-org.github.io/synapse/latest/workers.html#synapseappmedia_repository

  264. 			{% for location in matrix_synapse_reverse_proxy_companion_synapse_media_repository_locations %}

  265. 			location ~ {{ location }} {

  266. 				proxy_pass http://media_repository_workers_upstream$request_uri;

  267. 

  268. 				{% if matrix_synapse_reverse_proxy_companion_synapse_cache_enabled %}

  269. 					proxy_buffering        on;

  270. 					proxy_cache            {{ matrix_synapse_reverse_proxy_companion_synapse_cache_keys_zone_name }};

  271. 					proxy_cache_valid      any  {{ matrix_synapse_reverse_proxy_companion_synapse_cache_proxy_cache_valid_time }};

  272. 					proxy_force_ranges on;

  273. 					add_header X-Cache-Status $upstream_cache_status;

  274. 				{% endif %}

  275. 			}

  276. 			{% endfor %}

  277. 		{% endif %}

  278. 

  279. 		{#

  280. 			This is last, because we'd like more-specific requests (e.g. `/_matrix/federation/v1/media/` that may be handled by a media repository worker, if enabled)

  281. 			to be routed to more specialized workers via their respective `locations` defined earlier (above).

  282. 

  283. 			As https://nginx.org/en/docs/http/ngx_http_core_module.html#location says about location matching:

  284. 			> .. Then regular expressions are checked, in the order of their appearance in the configuration file.

  285. 

  286. 			See: https://github.com/spantaleev/matrix-docker-ansible-deploy/issues/3918

  287. 		#}

  288. 		{% if federation_reader_workers | length > 0 %}

  289. 			# https://tcpipuk.github.io/synapse/deployment/workers.html

  290. 			{{ render_locations_to_upstream(matrix_synapse_reverse_proxy_companion_synapse_federation_reader_federation_locations, 'federation_reader_workers_upstream') }}

  291. 		{% endif %}

  292. 	{% endif %}

  293. 

  294. 	{% for configuration_block in matrix_synapse_reverse_proxy_companion_synapse_federation_api_additional_server_configuration_blocks %}

  295. 		{{- configuration_block }}

  296. 	{% endfor %}

  297. 

  298. 	location / {

  299. 		{# Use the embedded DNS resolver in Docker containers to discover the service #}

  300. 		resolver {{ matrix_synapse_reverse_proxy_companion_http_level_resolver }} valid=5s;

  301. 		set $backend "{{ matrix_synapse_reverse_proxy_companion_federation_api_addr }}";

  302. 		proxy_pass http://$backend;

  303. 	}

  304. }

  305. {% endif %}