kopia lustrzana https://github.com/iv-org/invidious
				
				
				
			Fix lint and formatting
							rodzic
							
								
									fe4fa0480a
								
							
						
					
					
						commit
						adcdb8cb92
					
				|  | @ -250,7 +250,7 @@ Kemal.config.app_name = "Invidious" | |||
| 
 | ||||
| Kemal.run do |config| | ||||
|   if socket_binding = CONFIG.socket_binding | ||||
| File.delete?(socket_binding.path) | ||||
|     File.delete?(socket_binding.path) | ||||
|     # Create a socket and set its desired permissions | ||||
|     server = UNIXServer.new(socket_binding.path) | ||||
|     perms = socket_binding.permissions.to_i(base: 8) | ||||
|  |  | |||
|  | @ -40,7 +40,7 @@ class Invidious::Jobs::NotificationJob < Invidious::Jobs::BaseJob | |||
|         hash[key] = Set(VideoNotification).new | ||||
|       } | ||||
|     ) | ||||
|     notify_mutex = Mutex.new() | ||||
|     notify_mutex = Mutex.new | ||||
| 
 | ||||
|     # fiber to locally cache all incoming notifications (from pubsub webhooks and refresh channels job) | ||||
|     spawn do | ||||
|  | @ -71,7 +71,7 @@ class Invidious::Jobs::NotificationJob < Invidious::Jobs::BaseJob | |||
| 
 | ||||
|             LOGGER.info("NotificationJob: updating channel #{channel_id} with #{notifications.size} notifications") | ||||
|             if CONFIG.enable_user_notifications | ||||
|               video_ids = notifications.map { |n| n.video_id } | ||||
|               video_ids = notifications.map(&.video_id) | ||||
|               Invidious::Database::Users.add_multiple_notifications(channel_id, video_ids) | ||||
|               PG_DB.using_connection do |conn| | ||||
|                 notifications.each do |n| | ||||
|  |  | |||
		Ładowanie…
	
		Reference in New Issue
	
	 syeopite
						syeopite