diff options
| author | syeopite <syeopite@syeopite.dev> | 2025-02-26 14:18:50 -0800 |
|---|---|---|
| committer | syeopite <syeopite@syeopite.dev> | 2025-02-26 14:18:50 -0800 |
| commit | adcdb8cb92bbf61bac46102eff026593d0bc87b0 (patch) | |
| tree | 5d90ca4e80172d14f6351cb4c1a4c726860cd40e /src | |
| parent | fe4fa0480ac5c49131d63619bac111eca57ed2e5 (diff) | |
| download | invidious-adcdb8cb92bbf61bac46102eff026593d0bc87b0.tar.gz invidious-adcdb8cb92bbf61bac46102eff026593d0bc87b0.tar.bz2 invidious-adcdb8cb92bbf61bac46102eff026593d0bc87b0.zip | |
Fix lint and formatting
Diffstat (limited to 'src')
| -rw-r--r-- | src/invidious.cr | 2 | ||||
| -rw-r--r-- | src/invidious/jobs/notification_job.cr | 4 |
2 files changed, 3 insertions, 3 deletions
diff --git a/src/invidious.cr b/src/invidious.cr index 52df77be..12ffad33 100644 --- a/src/invidious.cr +++ b/src/invidious.cr @@ -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) diff --git a/src/invidious/jobs/notification_job.cr b/src/invidious/jobs/notification_job.cr index f2c9d4be..968ee47f 100644 --- a/src/invidious/jobs/notification_job.cr +++ b/src/invidious/jobs/notification_job.cr @@ -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| |