Added pipelines API (#172)

* Added pipelines API

* Added missing DocBlock types

* Added tests and fixes

Author: Rkallenkoot

lib/Gitlab/Api/Projects.php

@@ -127,15 +127,15 @@ public function remove($project_id)
     {
         return $this->delete('projects/'.$this->encodePath($project_id));
     }
-    
+
     /**
      * @param int $project_id
      * @return mixed
      */
     public function archive($project_id){
         return $this->post("projects/".$this->encodePath($project_id)."/archive");
     }
-    
+
     /**
      * @param int $project_id
      * @return mixed
@@ -157,8 +157,8 @@ public function builds($project_id, $scope = null)
     }
 
     /**
-     * @param $project_id
-     * @param $build_id
+     * @param int $project_id
+     * @param int $build_id
      * @return mixed
      */
     public function build($project_id, $build_id)
@@ -167,15 +167,65 @@ public function build($project_id, $build_id)
     }
 
     /**
-     * @param $project_id
-     * @param $build_id
+     * @param int $project_id
+     * @param int $build_id
      * @return mixed
      */
     public function trace($project_id, $build_id)
     {
         return $this->get($this->getProjectPath($project_id, 'builds/'.$this->encodePath($build_id).'/trace'));
     }
 
+    /**
+     * @param int $project_id
+     * @return mixed
+     */
+    public function pipelines($project_id)
+    {
+        return $this->get($this->getProjectPath($project_id, 'pipelines'));
+    }
+
+    /**
+     * @param int $project_id
+     * @param int $pipeline_id
+     * @return mixed
+     */
+    public function pipeline($project_id, $pipeline_id)
+    {
+        return $this->get($this->getProjectPath($project_id, 'pipelines/'.$this->encodePath($pipeline_id)));
+    }
+
+    /**
+     * @param int $project_id
+     * @param string $commit_ref
+     * @return mixed
+     */
+    public function createPipeline($project_id, $commit_ref)
+    {
+        return $this->post($this->getProjectPath($project_id, 'pipelines'), array(
+            'ref' => $commit_ref));
+    }
+
+    /**
+     * @param int $project_id
+     * @param int $pipeline_id
+     * @return mixed
+     */
+    public function retryPipeline($project_id, $pipeline_id)
+    {
+        return $this->post($this->getProjectPath($project_id, 'pipelines/'.$this->encodePath($pipeline_id)).'/retry');
+    }
+
+    /**
+     * @param int $project_id
+     * @param int $pipeline_id
+     * @return mixed
+     */
+    public function cancelPipeline($project_id, $pipeline_id)
+    {
+        return $this->post($this->getProjectPath($project_id, 'pipelines/'.$this->encodePath($pipeline_id)).'/cancel');
+    }
+
     /**
      * @param int $project_id
      * @param string $username_query

test/Gitlab/Tests/Api/ProjectsTest.php

@@ -142,7 +142,7 @@ public function shouldUpdateProject()
             'issues_enabled' => true
         )));
     }
-    
+
     /**
      * @test
      */
@@ -159,7 +159,7 @@ public function shouldArchiveProject()
 
         $this->assertEquals($expectedArray, $api->archive(1));
     }
-    
+
     /**
      * @test
      */
@@ -306,6 +306,105 @@ public function shouldGetTrace()
         $this->assertEquals($expectedString, $api->trace(1, 2));
     }
 
+    /**
+     * @test
+     */
+    public function shouldGetPipelines()
+    {
+        $expectedArray = array(
+            array('id' => 1, 'status' => 'success','ref' => 'new-pipeline'),
+            array('id' => 2, 'status' => 'failed', 'ref' => 'new-pipeline'),
+            array('id' => 3, 'status' => 'pending', 'ref'=> 'test-pipeline')
+        );
+
+        $api = $this->getApiMock();
+        $api->expects($this->once())
+            ->method('get')
+            ->with('projects/1/pipelines')
+            ->will($this->returnValue($expectedArray))
+        ;
+
+        $this->assertEquals($expectedArray, $api->pipelines(1));
+    }
+
+    /**
+     * @test
+     */
+    public function shouldGetPipeline()
+    {
+        $expectedArray = array(
+            array('id' => 1, 'status' => 'success','ref' => 'new-pipeline'),
+            array('id' => 2, 'status' => 'failed', 'ref' => 'new-pipeline'),
+            array('id' => 3, 'status' => 'pending', 'ref'=> 'test-pipeline')
+        );
+
+        $api = $this->getApiMock();
+        $api->expects($this->once())
+            ->method('get')
+            ->with('projects/1/pipelines/3')
+            ->will($this->returnValue($expectedArray))
+        ;
+
+        $this->assertEquals($expectedArray, $api->pipeline(1, 3));
+    }
+
+    /**
+     * @test
+     */
+    public function shouldCreatePipeline()
+    {
+        $expectedArray = array(
+            array('id' => 4, 'status' => 'created', 'ref'=> 'test-pipeline')
+        );
+
+        $api = $this->getApiMock();
+        $api->expects($this->once())
+            ->method('post')
+            ->with('projects/1/pipelines', array('ref' => 'test-pipeline'))
+            ->will($this->returnValue($expectedArray))
+        ;
+
+        $this->assertEquals($expectedArray, $api->createPipeline(1, 'test-pipeline'));
+    }
+
+    /**
+     * @test
+     */
+    public function shouldRetryPipeline()
+    {
+        $expectedArray = array(
+            array('id' => 5, 'status' => 'pending', 'ref'=> 'test-pipeline')
+        );
+
+        $api = $this->getApiMock();
+        $api->expects($this->once())
+            ->method('post')
+            ->with('projects/1/pipelines/4/retry')
+            ->will($this->returnValue($expectedArray))
+        ;
+
+        $this->assertEquals($expectedArray, $api->retryPipeline(1, 4));
+    }
+
+    /**
+     * @test
+     */
+    public function shouldCancelPipeline()
+    {
+        $expectedArray = array(
+            array('id' => 6, 'status' => 'cancelled', 'ref'=> 'test-pipeline')
+        );
+
+        $api = $this->getApiMock();
+        $api->expects($this->once())
+            ->method('post')
+            ->with('projects/1/pipelines/6/cancel')
+            ->will($this->returnValue($expectedArray))
+        ;
+
+        $this->assertEquals($expectedArray, $api->cancelPipeline(1, 6));
+    }
+
     /**
      * @test
      */