app/workers/pipeline_webpush_worker.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

require 'webpush'

class PipelineWebpushWorker
  include ApplicationWorker
  include PipelineQueue
  include WebpushHelper

  queue_namespace :pipeline_default

  def perform(pipeline_id)
    p "🔥"
    p pipeline_id
    Ci::Pipeline.find(pipeline_id).try do |pipeline|
      p "😂test"
      p pipeline
      p pipeline.webpush_subscribers
      pipeline.webpush_subscribers.each do |subscriber|
        p "❤️"
        p subscriber
        Webpush.payload_send(
          message: "#{pipeline_id} has updated",
          endpoint: subscriber.webpush_endpoint,
          p256dh: subscriber.webpush_p256dh,
          auth: subscriber.webpush_auth,
          vapid: vapid_credentials
        )
      end
    end
  end
end