docker_container.rb in coursemology-evaluator-0.1.7

- old
+ new
@@ -1,79 +1,79 @@
-# frozen_string_literal: true
-class Coursemology::Evaluator::DockerContainer < Docker::Container
-  class << self
-    def create(image, argv: nil)
-      pull_image(image)
-
-      ActiveSupport::Notifications.instrument('create.docker.evaluator.coursemology',
-                                              image: image) do |payload|
-        options = { 'Image' => image }
-        options['Cmd'] = argv if argv && !argv.empty?
-
-        payload[:container] = super(options)
-      end
-    end
-
-    private
-
-    # Pulls the given image from Docker Hub.
-    #
-    # This caches images for the specified time, because the overhead for querying
-    # for images is quite high.
-    #
-    # @param [String] image The image to pull.
-    def pull_image(image)
-      ActiveSupport::Notifications.instrument('pull.docker.evaluator.coursemology',
-                                              image: image) do |payload|
-        cached([:image, image], expires_in: Coursemology::Evaluator.config.image_lifetime) do
-          Docker::Image.create('fromImage' => image)
-          payload[:cached] = false
-        end
-      end
-    end
-
-    # Cache the result of the given block using the key given.
-    #
-    # @param [Array, String, Symbol] key The key to use. This will be expanded with
-    #   +ActiveSupport::Cache.expand_cache_key+.
-    # @param [Hash] options The options to use. These are the same as
-    #   +ActiveSupport::Cache::Store#fetch+.
-    def cached(key, options = {}, &proc)
-      key = ActiveSupport::Cache.expand_cache_key(key, name.underscore)
-      Coursemology::Evaluator.cache.fetch(key, options, &proc)
-    end
-  end
-
-  # Waits for the container to exit the Running state.
-  #
-  # This will time out for long running operations, so keep retrying until we return.
-  #
-  # @param [Fixnum|nil] time The amount of time to wait.
-  # @return [Fixnum] The exit code of the container.
-  def wait(time = nil)
-    container_state = info
-    while container_state.fetch('State', {}).fetch('Running', true)
-      super
-      refresh!
-      container_state = info
-    end
-
-    container_state['State']['ExitCode']
-  rescue Docker::Error::TimeoutError
-    retry
-  end
-
-  # Gets the exit code of the container.
-  #
-  # @return [Fixnum] The exit code of the container, if +wait+ was called before.
-  # @return [nil] If the container is still running, or +wait+ was not called.
-  def exit_code
-    info.fetch('State', {})['ExitCode']
-  end
-
-  def delete
-    ActiveSupport::Notifications.instrument('destroy.docker.evaluator.coursemology',
-                                            container: id) do
-      super
-    end
-  end
-end
+# frozen_string_literal: true
+class Coursemology::Evaluator::DockerContainer < Docker::Container
+  class << self
+    def create(image, argv: nil)
+      pull_image(image)
+
+      ActiveSupport::Notifications.instrument('create.docker.evaluator.coursemology',
+                                              image: image) do |payload|
+        options = { 'Image' => image }
+        options['Cmd'] = argv if argv && !argv.empty?
+
+        payload[:container] = super(options)
+      end
+    end
+
+    private
+
+    # Pulls the given image from Docker Hub.
+    #
+    # This caches images for the specified time, because the overhead for querying
+    # for images is quite high.
+    #
+    # @param [String] image The image to pull.
+    def pull_image(image)
+      ActiveSupport::Notifications.instrument('pull.docker.evaluator.coursemology',
+                                              image: image) do |payload|
+        cached([:image, image], expires_in: Coursemology::Evaluator.config.image_lifetime) do
+          Docker::Image.create('fromImage' => image)
+          payload[:cached] = false
+        end
+      end
+    end
+
+    # Cache the result of the given block using the key given.
+    #
+    # @param [Array, String, Symbol] key The key to use. This will be expanded with
+    #   +ActiveSupport::Cache.expand_cache_key+.
+    # @param [Hash] options The options to use. These are the same as
+    #   +ActiveSupport::Cache::Store#fetch+.
+    def cached(key, options = {}, &proc)
+      key = ActiveSupport::Cache.expand_cache_key(key, name.underscore)
+      Coursemology::Evaluator.cache.fetch(key, options, &proc)
+    end
+  end
+
+  # Waits for the container to exit the Running state.
+  #
+  # This will time out for long running operations, so keep retrying until we return.
+  #
+  # @param [Fixnum|nil] time The amount of time to wait.
+  # @return [Fixnum] The exit code of the container.
+  def wait(time = nil)
+    container_state = info
+    while container_state.fetch('State', {}).fetch('Running', true)
+      super
+      refresh!
+      container_state = info
+    end
+
+    container_state['State']['ExitCode']
+  rescue Docker::Error::TimeoutError
+    retry
+  end
+
+  # Gets the exit code of the container.
+  #
+  # @return [Fixnum] The exit code of the container, if +wait+ was called before.
+  # @return [nil] If the container is still running, or +wait+ was not called.
+  def exit_code
+    info.fetch('State', {})['ExitCode']
+  end
+
+  def delete
+    ActiveSupport::Notifications.instrument('destroy.docker.evaluator.coursemology',
+                                            container: id) do
+      super
+    end
+  end
+end