lib/storage.rb in gitmqueue-0.1.0 vs lib/storage.rb in gitmqueue-0.1.1

@@ -3,15 +3,12 @@
 require 'fileutils'
 require 'rugged'
 
 module GitMQueue
   class Storage
-    WAIT_NON_EXISTING_BRANCH = 1 # seconds
-    WAIT_FOR_COMMIT = 1 # seconds
+    attr_reader :repo, :path
 
-    attr_reader :repo
-
     def initialize(path)
       @path = path
       @repo = read_or_create_repo
     end
 
@@ -25,47 +22,31 @@
 
     def tree
       Rugged::Tree::Builder.new(repo).write
     end
 
-    def poll(branch, tag)
-      wait_for_commit(branch, tag)
-      walker(branch, tag).first
-    end
-
-    def tag(label, commit)
-      repo.tags.create(label, commit, true)
-    end
-
-    def wait_branch(branch)
-      sleep WAIT_NON_EXISTING_BRANCH until repo.branches.exist?(branch)
-    end
-
-    private
-
-    attr_reader :path
-
-    def walker(branch, tag)
+    def commits(branch, tag)
       walker = Rugged::Walker.new(repo)
       walker.sorting(Rugged::SORT_TOPO | Rugged::SORT_REVERSE)
       walker.push(branch(branch).target)
 
       tag = repo.tags[tag]
       walker.hide(tag.target) if tag
-
       walker
     end
 
+    def tag(label, commit)
+      repo.tags.create(label, commit, true)
+    end
+
+    private
+
     def read_or_create_repo
       FileUtils.mkdir_p(path) unless File.exist?(path)
       begin
         Rugged::Repository.new(path)
       rescue Rugged::RepositoryError
         Rugged::Repository.init_at(path, :bare)
       end
-    end
-
-    def wait_for_commit(branch, tag)
-      sleep WAIT_FOR_COMMIT until branch(branch).target.oid != repo.tags[tag]&.target&.oid
     end
   end
 end