SimplifyNet
diff --git a/‎.github/workflows/ci.yml
+15-4 b/‎.github/workflows/ci.yml
+15-4
diff --git a/‎.gitignore
+3-3 b/‎.gitignore
+3-3
diff --git a/‎.rubocop.yml
+21 b/‎.rubocop.yml
+21
diff --git a/‎.spec/route_spec.rb
+17-19 b/‎.spec/route_spec.rb
+17-19
diff --git a/‎.spec/spec_helper.rb
+4-5 b/‎.spec/spec_helper.rb
+4-5
diff --git a/‎.tasks/ci.rake
+13-9 b/‎.tasks/ci.rake
+13-9
diff --git a/‎.tasks/cloud
+2-2 b/‎.tasks/cloud
+2-2
diff --git a/‎.tasks/collect.rake
+11-5 b/‎.tasks/collect.rake
+11-5
diff --git a/‎.tasks/db.rake
+11-9 b/‎.tasks/db.rake
+11-9
diff --git a/‎Makefile
-6 b/‎Makefile
-6
@@ -1,5 +1,9 @@
 name: CI
 
+concurrency:
+  group: ${{ github.head_ref }}
+  cancel-in-progress: true
+
 on:
   - pull_request
 jobs:
@@ -19,7 +23,7 @@ jobs:
       - name: Install deps
         run: bundle install --jobs 4 --retry 3
       - id: set-matrix
-        run: echo "::set-output name=matrix::$(bundle exec rake ci:matrix)"
+        run: echo "matrix=$(bundle exec rake ci:matrix)" >> "$GITHUB_OUTPUT"
         env:
           FILES: ${{ steps.file_changes.outputs.files }}
 
@@ -42,18 +46,25 @@ jobs:
       - name: Install deps
         run: bundle install --jobs 4 --retry 3
 
+      - name: Docker version
+        run: docker -v
+
       - name: Configure
         run: bundle exec rake config
 
       - name: Build
         run: |
-          cd ${{ matrix.directory }} 
-          make build  -f .Makefile
+          make "build.${ENGINE}"  -f "${DIRECTORY}/.Makefile"
+        env:
+          DIRECTORY: ${{ matrix.directory }}
+          ENGINE: ${{ matrix.engine }}
 
       - name: Wait
         run: sleep 1
 
       - name: Test
         run: bundle exec rspec .spec
         env:
-          DIRECTORY: ${{ matrix.directory }}
+          LANGUAGE: ${{ matrix.language }}
+          FRAMEWORK: ${{ matrix.framework }}
+          ENGINE: ${{ matrix.engine }}
@@ -16,12 +16,12 @@ Gemfile.lock
 
 # Temporary files
 FRAMEWORKS.yaml
-*/*/.Dockerfile
-*/*/Dockerfile
+*/*/.Dockerfile*
 */*/.Makefile
 */*/ip.txt
 venv
 */*/cid.txt
+*/.Makefile
 
 /lib/**/*.cr
 /vendor
@@ -41,4 +41,4 @@ obj
 [Dd]ebug/
 [Rr]elease/
 *.fsproj
-*.fsproj.user
+*.fsproj.user
@@ -4,10 +4,31 @@ require:
 
 AllCops:
   NewCops: enable
+  TargetRubyVersion: 2.7
+  Exclude:
+    - Rakefile
 
 Style/Documentation:
   Enabled: false
 
 Naming/AccessorMethodName:
   Exclude:
     - ruby/rack-routing/app/route_handler.rb
+
+Lint/ShadowingOuterLocalVariable:
+  Exclude:
+    - .tasks/*.rake
+
+Metrics/BlockLength:
+  Exclude:
+    - .tasks/*.rake
+
+Lint/AmbiguousBlockAssociation:
+  Exclude:
+    - .tasks/*.rake
+Layout/LineLength:
+  Exclude:
+    - .tasks/*.rake
+Metrics/ParameterLists:
+  Exclude:
+    - .tasks/*.rake
@@ -1,48 +1,46 @@
 # frozen_string_literal: true
 
-require 'net/http'
+require "net/http"
 
-require_relative 'spec_helper'
+require_relative "spec_helper"
 
-RSpec.describe 'routes' do
-  let!(:http) { address(ENV['DIRECTORY']) }
+RSpec.describe "routes" do
+  context "GET : /" do
+    subject(:response) { http.request(Net::HTTP::Get.new("/")) }
 
-  context 'GET : /' do
-    subject(:response) { http.request(Net::HTTP::Get.new('/')) }
-
-    it 'returns successfully' do
+    it "returns successfully" do
       expect(response).to be_a(Net::HTTPSuccess)
     end
 
-    it 'returns an empty string' do
+    it "returns an empty string" do
       expect(response.body.to_s).to be_empty
     end
   end
 
-  context 'GET : /user/0' do
-    subject(:response) { http.request(Net::HTTP::Get.new('/user/0')) }
+  context "GET : /user/0" do
+    subject(:response) { http.request(Net::HTTP::Get.new("/user/0")) }
 
-    it 'returns successfully' do
+    it "returns successfully" do
       expect(response).to be_a(Net::HTTPSuccess)
     end
 
-    it 'returns the expected param' do
-      expect(response.body.to_s).to eq('0')
+    it "returns the expected param" do
+      expect(response.body.to_s).to eq("0")
     end
   end
 
-  context 'POST : /user' do
-    let!(:request) { Net::HTTP::Post.new('/user') }
+  context "POST : /user" do
+    let!(:request) { Net::HTTP::Post.new("/user") }
 
-    before { request['Content-Type'] = 'text/plain' }
+    before { request["Content-Type"] = "text/plain" }
 
     subject(:response) { http.request(request) }
 
-    it 'returns successfully' do
+    it "returns successfully" do
       expect(response).to be_a(Net::HTTPSuccess)
     end
 
-    it 'returns an empty string' do
+    it "returns an empty string" do
       expect(response.body.to_s).to be_empty
     end
   end
 
@@ -1,7 +1,7 @@
 # frozen_string_literal: true
 
-require 'net/http'
-require 'yaml'
+require "net/http"
+require "yaml"
 
 RSpec.configure do |config|
   config.expect_with :rspec do |expectations|
@@ -15,8 +15,7 @@
   config.shared_context_metadata_behavior = :apply_to_host_groups
 end
 
-def address(name)
-  language, framework = name.split('/')
-  ip = File.read(File.join(language, framework, 'ip.txt')).strip
+def http
+  ip = File.read(File.join(ENV["LANGUAGE"], ENV["FRAMEWORK"], "ip-#{ENV["ENGINE"]}.txt")).strip
   Net::HTTP.new(ip, 3000)
 end
@@ -4,7 +4,7 @@ require 'json'
 
 namespace :ci do
   task :matrix do
-    files = JSON.parse(ENV['FILES'])
+    files = JSON.parse(ENV.fetch('FILES', nil))
     matrix = { include: [] }
 
     files = Dir.glob('*/*/config.yaml') if files.include?('data.json')
@@ -14,21 +14,25 @@ namespace :ci do
              .map { |path| path.split(File::SEPARATOR).shift }
              .flat_map { |language| Dir.glob(File.join(language, '*', 'config.yaml')) }
 
-    files.take(256).each do |file|
+    files.each do |file|
       next if file.start_with?('.')
-
       next if file.count(File::SEPARATOR) < 2
 
       language, framework, = file.split(File::SEPARATOR)
 
-      next if matrix[:include].detect do |row|
-                row[:framework] == framework
-              end
+      config = get_config_from(File.join(Dir.pwd, language, framework))
+
+      engine = config.dig('framework', 'engines')&.first
 
-      matrix[:include] << { language: language, framework: framework,
-                            directory: File.join(language, framework) }
+      if engine
+        matrix[:include] << { language: language, framework: framework, directory: File.join(language, framework),
+                              engine: engine }
+      else
+        warn "Configuration for #{language}/#{framework} is not correct"
+      end
     end
-    warn matrix.to_json
+
+    matrix[:include] = matrix[:include].take(256)
     puts matrix.to_json
   end
 end
@@ -47,10 +47,10 @@ namespace :cloud do
       end
     end
 
-    if config.key?('before_command')
+    if config.key?('bootstrap')
       commands = config['cloud']['config']['runcmd'] || []
       config['cloud']['config']['runcmd'] = []
-      config['before_command'].each do |cmd|
+      config['bootstrap'].each do |cmd|
         config['cloud']['config']['runcmd'] << cmd
       end
       commands.each do |cmd|
 
@@ -10,7 +10,7 @@ PIPELINE = {
   POST: File.join(Dir.pwd, 'pipeline_post.lua')
 }.freeze
 
-def insert(db, framework_id, metric, value, concurrency_level_id)
+def insert(db, framework_id, metric, value, concurrency_level_id, engine_id)
   res = db.query('INSERT INTO keys (label) VALUES ($1) ON CONFLICT (label) DO UPDATE SET label = $1 RETURNING id',
                  [metric])
 
@@ -19,8 +19,8 @@ def insert(db, framework_id, metric, value, concurrency_level_id)
   res = db.query('INSERT INTO values (key_id, value) VALUES ($1, $2) RETURNING id', [metric_id, value])
   value_id = res.first['id']
 
-  db.query('INSERT INTO metrics (value_id, framework_id, concurrency_id) VALUES ($1, $2, $3)',
-           [value_id, framework_id, concurrency_level_id])
+  db.query('INSERT INTO metrics (value_id, framework_id, concurrency_id, engine_id) VALUES ($1, $2, $3, $4)',
+           [value_id, framework_id, concurrency_level_id, engine_id])
 end
 
 task :collect do
@@ -31,8 +31,9 @@ task :collect do
   concurrencies = ENV.fetch('CONCURRENCIES', '10')
   routes = ENV.fetch('ROUTES', 'GET:/')
   database = ENV.fetch('DATABASE_URL') { raise 'please provide a DATABASE_URL (pg only)' }
+  hostname = ENV.fetch('HOSTNAME')
+  engine = ENV.fetch('ENGINE')
 
-  hostname = File.read(File.join(Dir.pwd, language, framework, 'ip.txt')).strip
   `wrk -H 'Connection: keep-alive' -d 5s -c 8 --timeout 8 -t #{threads} http://#{hostname}:3000`
   `wrk -H 'Connection: keep-alive' -d #{duration}s -c 256 --timeout 8 -t #{threads} http://#{hostname}:3000`
 
@@ -43,6 +44,11 @@ task :collect do
   )
   language_id = res.first['id']
 
+  res = db.query(
+    'INSERT INTO engines (label) VALUES ($1) ON CONFLICT (label) DO UPDATE SET label = $1 RETURNING id', [engine]
+  )
+  engine_id = res.first['id']
+
   res = db.query(
     'INSERT INTO frameworks (language_id, label) VALUES ($1, $2) ON CONFLICT (language_id, label) DO UPDATE SET label = $2 RETURNING id', [
       language_id, framework
@@ -83,7 +89,7 @@ task :collect do
 
         info = lua_output.split(',')
         lua_keys.each_with_index do |key, index|
-          insert(db, framework_id, key, info[index].to_d, concurrency_level_id)
+          insert(db, framework_id, key, info[index].to_d, concurrency_level_id, engine_id)
         end
       end
     end
 
@@ -30,15 +30,17 @@ end
 
 namespace :db do
   task :check_failures do
-    results = JSON.load(File.read('data.json'))
-    frameworks = results['metrics'].filter_map {|row|row['framework_id'] if row['label'] == "total_requests_per_s" && row["value"] == 0 }
-    STDOUT.puts results['frameworks'].filter_map {|row|row['label'] if frameworks.include? (row["id"]) }
+    results = JSON.parse(File.read('data.json'))
+    frameworks = results['metrics'].filter_map do |row|
+      row['framework_id'] if row['label'] == 'total_requests_per_s' && (row['value']).zero?
+    end
+    $stdout.puts results['frameworks'].filter_map { |row| row['label'] if frameworks.include?(row['id']) }
   end
   task :raw_export do
     raise 'Please provide a database' unless ENV['DATABASE_URL']
 
     data = { metrics: [], frameworks: [], languages: [] }
-    db = PG.connect(ENV['DATABASE_URL'])
+    db = PG.connect(ENV.fetch('DATABASE_URL', nil))
     db.exec("select row_to_json(t) from (#{SQL}) as t") do |result|
       result.each do |row|
         info = JSON.parse(row['row_to_json'], symbolize_names: true)
@@ -52,11 +54,11 @@ namespace :db do
         scheme = 'http' if framework_config['framework'].key?('unsecure')
         website = framework_config['framework']['website']
         if website.nil?
-        website = if framework_config['framework'].key?('github')
-                    "github.com/#{framework_config['framework']['github']}"
-                  elsif framework_config['framework'].key?('gitlab')
-                    "gitlab.com/#{framework_config['framework']['gitlab']}"
-                  end
+          website = if framework_config['framework'].key?('github')
+                      "github.com/#{framework_config['framework']['github']}"
+                    elsif framework_config['framework'].key?('gitlab')
+                      "gitlab.com/#{framework_config['framework']['gitlab']}"
+                    end
         end
         unless data[:frameworks].map { |row| row[:id] }.to_a.include?(framework_id)
           data[:frameworks] << {