specifications.rb in wss_agent-18.10.3

- old
+ new
@@ -1,202 +1,202 @@
-require 'digest'
-
-module WssAgent
-  class Specifications
-
-    class << self
-      # Get dependencies
-      #
-      # @param [Hash]
-      # @option options [Boolean] 'all' if true then get all dependencies (include development dependencies)
-      # @option options [String] 'excludes' list gem name which need to exclude from end list
-      def specs(options = {})
-        list_gems = Bundler::Definition.build(
-          Bundler.default_gemfile,
-          Bundler.default_lockfile,
-          false
-        )
-        list_gems = list_gems.resolve.materialize(
-          list_gems.send(
-            Bundler.settings[:cache_all_platforms] ? :dependencies :  :requested_dependencies
-          )
-        )
-        if options['all']
-          # get all gems
-          list = {}
-          list_gems.each { |j| list[j.name] = j }
-          list_gems.each { |j|
-            list = gem_dependencies(list, j.dependencies, options)
-          }
-
-          list_gems = list.values
-        end
-        list_gems
-      end
-
-      # Display list dependencies
-      #
-      # @param (see Specifications#specs)
-      def list(options = {})
-        new(specs(options)).call
-      end
-
-      def check_policy?(options = {})
-        options['force'] ||
-          WssAgent::Configure['check_policies'] ||
-          WssAgent::Configure['force_check_all_dependencies']
-      end
-      private :check_policy?
-
-      def force_update?(options = {})
-        options['force-update'] ||
-          WssAgent::Configure['force_update']
-      end
-
-      private :force_update?
-
-      # Send gem list to server
-      #
-      # @param (see Specifications#specs)
-      def update(options = {})
-        result = check_policies_for_update(options)
-        if !force_update?(options) && (result.status == :reject)
-          return Struct.new(:status) do
-            alias_method :success?, :status
-          end.new(false)
-        end
-
-        wss_client = WssAgent::Client.new
-        result = wss_client.update(WssAgent::Specifications.list(options))
-        if result.success?
-          WssAgent.logger.debug result.data
-          puts result.message
-        else
-          WssAgent.logger.debug "synchronization errors occur: status: #{result.status}, message: #{result.message}, data: #{result.data}"
-          ap "error: #{result.status}/#{result.data}", color: { string: :red }
-        end
-
-        result
-      end
-
-      # Check policies before update
-      #
-      # @param (see Specifications#specs)
-      def check_policies_for_update(options = {})
-        return Struct.new(:status).new(:ok) unless check_policy?(options)
-        wss_client = WssAgent::Client.new
-        policy_results = wss_client.check_policies(
-          WssAgent::Specifications.list(options), options
-        )
-        if policy_results.success? && policy_results.policy_violations?
-          puts policy_results.message
-          return Struct.new(:status, :msg).new(:reject, policy_results.message)
-        end
-        Struct.new(:status).new(:ok)
-      end
-
-      # checking dependencies that they conforms with company policy.
-      #
-      # @param (see Specifications#specs)
-      def check_policies(options = {})
-        wss_client = WssAgent::Client.new
-        result = wss_client.check_policies(
-          WssAgent::Specifications.list(options),
-          options
-        )
-        if result.success?
-          WssAgent.logger.debug result.data
-          puts result.message
-        else
-          WssAgent.logger.debug "check policies errors occur: #{result.status}, message: #{result.message}, data: #{result.data}"
-          ap "error: #{result.status}/#{result.data}", color: { string: :red }
-        end
-
-        result
-      end
-
-      # Get all dependencies includes development
-      #
-      # @param [Array<Spec>] array for gems
-      # @param [Array<Dependencies>]
-      # @param [Hash]
-      # @options options [String] :excludes list gems to exclude
-      #
-      # @return [Array<Spec>] list
-      def gem_dependencies(list, gem_dependencies, options = {})
-        gem_dependencies.each do |gd|
-          if options['excludes'] && options['excludes'].to_s.split(',').include?(gd.name)
-            next
-          end
-
-          gs = gd.matching_specs.first
-          if gs
-            unless list[gs.name]
-              list[gs.name] = gs
-              unless gs.dependencies.empty?
-                list = gem_dependencies(list, gs.dependencies, options)
-              end
-            end
-          else
-            unless list[gd.name]
-              list[gd.name] = Gem::Specification.new(
-                gd.name,
-                gd.requirements_list.last.scan(/[\d\.\w]+/).first
-              )
-              rm_dep = remote_dependencies(gd.name, gd.requirements_list.last)
-              unless rm_dep.empty?
-                list = gem_dependencies(list, rm_dep, options)
-              end
-            end
-          end
-        end
-
-        list
-      end
-
-      # Load dependencies from rubygems
-      #
-      # @param gem_name [String] name gem
-      # @params version [String] version gem
-      #
-      # @return [Array<Gem::Dependency>] list gem dependencies
-      def remote_dependencies(gem_name, _version)
-        conn = Faraday.new(url: 'https://rubygems.org') do |h|
-          h.headers[:content_type] = 'application/x-www-form-urlencoded'
-          h.request :url_encoded
-          h.adapter :excon
-        end
-        response = conn.get("/api/v1/gems/#{gem_name}.json")
-        dep_list = MultiJson.load(response.body)
-        dep_list['dependencies'].values.flatten.map do |j|
-          Gem::Dependency.new(
-            j['name'],
-            Gem::Requirement.new(j['requirements'].split(','))
-          )
-        end
-      end
-    end # end class << self
-
-    def initialize(gem_specs)
-      @gem_specs = gem_specs
-    end
-
-    def call
-      @gem_specs.map do |spec|
-        next if spec.name == WssAgent::NAME
-        gem_item(spec)
-      end.compact
-    end
-
-    def gem_item(spec)
-      {
-        'groupId' => spec.name,
-        'artifactId' => spec.file_name,
-        'version' => spec.version.to_s,
-        'sha1' => GemSha1.new(spec).sha1,
-        'optional' => false,
-        'children' => [],
-        'exclusions' => []
-      }
-    end
-  end
-end
+require 'digest'
+
+module WssAgent
+  class Specifications
+
+    class << self
+      # Get dependencies
+      #
+      # @param [Hash]
+      # @option options [Boolean] 'all' if true then get all dependencies (include development dependencies)
+      # @option options [String] 'excludes' list gem name which need to exclude from end list
+      def specs(options = {})
+        list_gems = Bundler::Definition.build(
+          Bundler.default_gemfile,
+          Bundler.default_lockfile,
+          false
+        )
+        list_gems = list_gems.resolve.materialize(
+          list_gems.send(
+            Bundler.settings[:cache_all_platforms] ? :dependencies :  :requested_dependencies
+          )
+        )
+        if options['all']
+          # get all gems
+          list = {}
+          list_gems.each { |j| list[j.name] = j }
+          list_gems.each { |j|
+            list = gem_dependencies(list, j.dependencies, options)
+          }
+
+          list_gems = list.values
+        end
+        list_gems
+      end
+
+      # Display list dependencies
+      #
+      # @param (see Specifications#specs)
+      def list(options = {})
+        new(specs(options)).call
+      end
+
+      def check_policy?(options = {})
+        options['force'] ||
+          WssAgent::Configure['check_policies'] ||
+          WssAgent::Configure['force_check_all_dependencies']
+      end
+      private :check_policy?
+
+      def force_update?(options = {})
+        options['force-update'] ||
+          WssAgent::Configure['force_update']
+      end
+
+      private :force_update?
+
+      # Send gem list to server
+      #
+      # @param (see Specifications#specs)
+      def update(options = {})
+        result = check_policies_for_update(options)
+        if !force_update?(options) && (result.status == :reject)
+          return Struct.new(:status) do
+            alias_method :success?, :status
+          end.new(false)
+        end
+
+        wss_client = WssAgent::Client.new
+        result = wss_client.update(WssAgent::Specifications.list(options))
+        if result.success?
+          WssAgent.logger.debug result.data
+          puts result.message
+        else
+          WssAgent.logger.debug "synchronization errors occur: status: #{result.status}, message: #{result.message}, data: #{result.data}"
+          ap "error: #{result.status}/#{result.data}", color: { string: :red }
+        end
+
+        result
+      end
+
+      # Check policies before update
+      #
+      # @param (see Specifications#specs)
+      def check_policies_for_update(options = {})
+        return Struct.new(:status).new(:ok) unless check_policy?(options)
+        wss_client = WssAgent::Client.new
+        policy_results = wss_client.check_policies(
+          WssAgent::Specifications.list(options), options
+        )
+        if policy_results.success? && policy_results.policy_violations?
+          puts policy_results.message
+          return Struct.new(:status, :msg).new(:reject, policy_results.message)
+        end
+        Struct.new(:status).new(:ok)
+      end
+
+      # checking dependencies that they conforms with company policy.
+      #
+      # @param (see Specifications#specs)
+      def check_policies(options = {})
+        wss_client = WssAgent::Client.new
+        result = wss_client.check_policies(
+          WssAgent::Specifications.list(options),
+          options
+        )
+        if result.success?
+          WssAgent.logger.debug result.data
+          puts result.message
+        else
+          WssAgent.logger.debug "check policies errors occur: #{result.status}, message: #{result.message}, data: #{result.data}"
+          ap "error: #{result.status}/#{result.data}", color: { string: :red }
+        end
+
+        result
+      end
+
+      # Get all dependencies includes development
+      #
+      # @param [Array<Spec>] array for gems
+      # @param [Array<Dependencies>]
+      # @param [Hash]
+      # @options options [String] :excludes list gems to exclude
+      #
+      # @return [Array<Spec>] list
+      def gem_dependencies(list, gem_dependencies, options = {})
+        gem_dependencies.each do |gd|
+          if options['excludes'] && options['excludes'].to_s.split(',').include?(gd.name)
+            next
+          end
+
+          gs = gd.matching_specs.first
+          if gs
+            unless list[gs.name]
+              list[gs.name] = gs
+              unless gs.dependencies.empty?
+                list = gem_dependencies(list, gs.dependencies, options)
+              end
+            end
+          else
+            unless list[gd.name]
+              list[gd.name] = Gem::Specification.new(
+                gd.name,
+                gd.requirements_list.last.scan(/[\d\.\w]+/).first
+              )
+              rm_dep = remote_dependencies(gd.name, gd.requirements_list.last)
+              unless rm_dep.empty?
+                list = gem_dependencies(list, rm_dep, options)
+              end
+            end
+          end
+        end
+
+        list
+      end
+
+      # Load dependencies from rubygems
+      #
+      # @param gem_name [String] name gem
+      # @params version [String] version gem
+      #
+      # @return [Array<Gem::Dependency>] list gem dependencies
+      def remote_dependencies(gem_name, _version)
+        conn = Faraday.new(url: 'https://rubygems.org') do |h|
+          h.headers[:content_type] = 'application/x-www-form-urlencoded'
+          h.request :url_encoded
+          h.adapter :excon
+        end
+        response = conn.get("/api/v1/gems/#{gem_name}.json")
+        dep_list = MultiJson.load(response.body)
+        dep_list['dependencies'].values.flatten.map do |j|
+          Gem::Dependency.new(
+            j['name'],
+            Gem::Requirement.new(j['requirements'].split(','))
+          )
+        end
+      end
+    end # end class << self
+
+    def initialize(gem_specs)
+      @gem_specs = gem_specs
+    end
+
+    def call
+      @gem_specs.map do |spec|
+        next if spec.name == WssAgent::NAME
+        gem_item(spec)
+      end.compact
+    end
+
+    def gem_item(spec)
+      {
+        'groupId' => spec.name,
+        'artifactId' => spec.file_name,
+        'version' => spec.version.to_s,
+        'sha1' => GemSha1.new(spec).sha1,
+        'optional' => false,
+        'children' => [],
+        'exclusions' => []
+      }
+    end
+  end
+end