Contents

require 'net/http'
require "uri"

module Perkins
  class GitLoaderWorker

    include Sidekiq::Worker

    def perform(repo_id)
      repo = Perkins::Repo.find(repo_id)
      #it actually clone repo and instantiates git data
      send_sse({repo: {id: repo.id, name: repo.name , status: "downloading"} })

      repo.load_git

      send_sse({repo: {id: repo.id, name: repo.name , status: "downloaded" } })
    end

    def send_sse(msg)
      url = "#{Perkins::Application.instance.sse_endpoint}/sse"
      puts "send sse post to #{url} with msg: #{msg.to_json}".pink
      postData = Net::HTTP.post_form(
        URI.parse(url),
        {'msg'=> msg.to_json }
      )
    end

  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
perkins-0.0.3	lib/perkins/git_loader_worker.rb
perkins-0.0.2	lib/perkins/git_loader_worker.rb