Add Pipeline resource

Add pipelines method to project resource

qa/qa.rb

@@ -72,6 +72,7 @@ module QA
     autoload :DeployKey, 'qa/resource/deploy_key'
     autoload :DeployToken, 'qa/resource/deploy_token'
     autoload :ProtectedBranch, 'qa/resource/protected_branch'
+    autoload :Pipeline, 'qa/resource/pipeline'
     autoload :CiVariable, 'qa/resource/ci_variable'
     autoload :Runner, 'qa/resource/runner'
     autoload :PersonalAccessToken, 'qa/resource/personal_access_token'

qa/qa/resource/pipeline.rb

+# frozen_string_literal: true
+
+module QA
+  module Resource
+    class Pipeline < Base
+      attribute :project do
+        Resource::Project.fabricate! do |project|
+          project.name = 'project-with-pipeline'
+        end
+      end
+
+      attribute :id
+      attribute :status
+      attribute :ref
+      attribute :sha
+
+      # array in form
+      # [
+      #   { key: 'UPLOAD_TO_S3', variable_type: 'file', value: true },
+      #   { key: 'SOMETHING', variable_type: 'env_var', value: 'yes' }
+      # ]
+      attribute :variables
+
+      def initialize
+        @ref = 'master'
+        @variables = []
+      end
+
+      def fabricate!
+        project.visit!
+
+        Page::Project::Menu.perform(&:click_ci_cd_pipelines)
+        Page::Project::Pipeline::Index.perform(&:click_run_pipeline_button)
+        Page::Project::Pipeline::New.perform(&:click_run_pipeline_button)
+      end
+
+      def api_get_path
+        "/projects/#{project.id}/pipelines/#{id}"
+      end
+
+      def api_post_path
+        "/projects/#{project.id}/pipeline"
+      end
+
+      def api_post_body
+        {
+          ref: ref,
+          variables: variables
+        }
+      end
+    end
+  end
+end

qa/qa/resource/project.rb

@@ -100,6 +100,10 @@ module QA
         "#{api_get_path}/runners"
       end
 
+      def api_pipelines_path
+        "#{api_get_path}/pipelines"
+      end
+
       def api_put_path
         "/projects/#{id}"
       end
@@ -161,6 +165,10 @@ module QA
         parse_body(response)
       end
 
+      def pipelines
+        parse_body(get(Runtime::API::Request.new(api_client, api_pipelines_path).url))
+      end
+
       def share_with_group(invitee, access_level = Resource::Members::AccessLevel::DEVELOPER)
         post Runtime::API::Request.new(api_client, "/projects/#{id}/share").url, { group_id: invitee.id, group_access: access_level }
       end