Contents

# frozen_string_literal: true

module GitMQueue
  class Producer
    def initialize(storage:, branch:)
      @storage = storage
      @branch = branch
    end

    def publish(event)
      commit = Rugged::Commit.create(
        @storage.repo,
        tree: @storage.tree,
        message: event.to_s,
        parents: [@storage.branch(@branch)&.target].compact
      )
      @storage.branches.create(@branch, commit, force: true)
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
gitmqueue-0.1.2	lib/producer.rb
gitmqueue-0.1.1	lib/producer.rb
gitmqueue-0.1.0	lib/producer.rb