lib/wss_agent/specifications.rb in wss_agent-0.0.17 vs lib/wss_agent/specifications.rb in wss_agent-0.0.21

@@ -1,6 +1,6 @@
-require "digest"
+require 'digest'
 
 module WssAgent
   class Specifications
 
     class << self
@@ -8,11 +8,15 @@
       #
       # @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).specs.to_a
+        list_gems = Bundler::Definition.build(
+          Bundler.default_gemfile,
+          Bundler.default_lockfile,
+          false
+        ).specs.to_a
         if options['all']
           # get all gems
           list = {}
           list_gems.each { |j| list[j.name] = j }
           list_gems.each { |j|
@@ -29,47 +33,62 @@
       # @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?
+
       # Send gem list to server
       #
       # @param (see Specifications#specs)
       def update(options = {})
         wss_client = WssAgent::Client.new
-        if WssAgent::Configure['check_policies']
-          policy_results = wss_client.check_policies(WssAgent::Specifications.list(options))
+
+        if check_policy?(options)
+          policy_results = wss_client.check_policies(
+            WssAgent::Specifications.list(options),
+            options
+          )
           if policy_results.success? && policy_results.policy_violations?
             puts policy_results.message
             return false
           end
         end
 
+
         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 }
+          ap "error: #{result.status}/#{result.data}", color: { string: :red }
         end
 
         result.success?
       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))
+        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 }
+          ap "error: #{result.status}/#{result.data}", color: { string: :red }
         end
       end
 
       # Get all dependencies includes development
       #
@@ -82,22 +101,25 @@
       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)
+              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
@@ -111,20 +133,24 @@
       #
       # @param gem_name [String] name gem
       # @params version [String] version gem
       #
       # @return [Array<Gem::Dependency>] list gem dependencies
-      def remote_dependencies(gem_name, version)
+      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 = Oj.load(response.body)
-        dep_list['dependencies'].values.flatten.
-          map { |j| Gem::Dependency.new(j['name'], Gem::Requirement.new(j['requirements'].split(','))) }
+        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
@@ -138,11 +164,11 @@
     end
 
     def gem_item(spec)
       {
         'groupId' => spec.name,
-			  'artifactId' => spec.file_name,
-			  'version' => spec.version.to_s,
+        'artifactId' => spec.file_name,
+        'version' => spec.version.to_s,
         'sha1' => GemSha1.new(spec).sha1,
         'optional' => false,
         'children' => [],
         'exclusions' => []
       }