411 lines
13 KiB
PHP
411 lines
13 KiB
PHP
|
<?php
|
|||
|
|
declare(strict_types = 1);
|
|||
|
|
|
|||
|
|
require_once dirname(__FILE__, 5) . '/test/lib/test.class.php';
|
|||
|
|
|
|||
|
|
class jenkinsModelTest extends baseTest
|
|||
|
|
{
|
|||
|
|
protected $moduleName = 'jenkins';
|
|||
|
|
protected $className = 'model';
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 测试获取流水线列表。
|
|||
|
|
* Test get jenkins tasks.
|
|||
|
|
*
|
|||
|
|
* @param int $jenkinsID
|
|||
|
|
* @param int $depth
|
|||
|
|
* @access public
|
|||
|
|
* @return array
|
|||
|
|
*/
|
|||
|
|
public function getTasks(int $jenkinsID, int $depth = 0)
|
|||
|
|
{
|
|||
|
|
return $this->jenkins->getTasks($jenkinsID, $depth);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Test getDepthJobs method with direct mock data.
|
|||
|
|
*
|
|||
|
|
* @access public
|
|||
|
|
* @return string
|
|||
|
|
*/
|
|||
|
|
public function getDepthJobsDirectTest(): string
|
|||
|
|
{
|
|||
|
|
$mockJobs = array(
|
|||
|
|
(object)array(
|
|||
|
|
'name' => 'Simple Job',
|
|||
|
|
'url' => 'https://jenkins.example.com/job/simpleJob/',
|
|||
|
|
'_class' => 'hudson.model.FreeStyleProject',
|
|||
|
|
'buildable' => true
|
|||
|
|
),
|
|||
|
|
(object)array(
|
|||
|
|
'name' => 'Param Job',
|
|||
|
|
'url' => 'https://jenkins.example.com/job/paramJob/',
|
|||
|
|
'_class' => 'hudson.model.FreeStyleProject',
|
|||
|
|
'buildable' => true
|
|||
|
|
),
|
|||
|
|
(object)array(
|
|||
|
|
'name' => 'Folder 1',
|
|||
|
|
'url' => 'https://jenkins.example.com/job/folder1/',
|
|||
|
|
'_class' => 'com.cloudbees.hudson.plugins.folder.Folder',
|
|||
|
|
'buildable' => false,
|
|||
|
|
'jobs' => array(
|
|||
|
|
(object)array(
|
|||
|
|
'name' => 'Sub Job 1',
|
|||
|
|
'url' => 'https://jenkins.example.com/job/folder1/job/subJob1/',
|
|||
|
|
'_class' => 'hudson.model.FreeStyleProject',
|
|||
|
|
'buildable' => true
|
|||
|
|
),
|
|||
|
|
(object)array(
|
|||
|
|
'name' => 'Sub Job 2',
|
|||
|
|
'url' => 'https://jenkins.example.com/job/folder1/job/subJob2/',
|
|||
|
|
'_class' => 'hudson.model.FreeStyleProject',
|
|||
|
|
'buildable' => true
|
|||
|
|
)
|
|||
|
|
)
|
|||
|
|
)
|
|||
|
|
);
|
|||
|
|
|
|||
|
|
$userPWD = 'test:test';
|
|||
|
|
$result = $this->jenkins->getDepthJobs($mockJobs, $userPWD, 1);
|
|||
|
|
if(dao::isError()) return dao::getError();
|
|||
|
|
|
|||
|
|
return json_encode($result);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Test getDepthJobs method with empty jobs array.
|
|||
|
|
*
|
|||
|
|
* @access public
|
|||
|
|
* @return string
|
|||
|
|
*/
|
|||
|
|
public function getDepthJobsEmptyTest(): string
|
|||
|
|
{
|
|||
|
|
$emptyJobs = array();
|
|||
|
|
$userPWD = 'test:test';
|
|||
|
|
$result = $this->jenkins->getDepthJobs($emptyJobs, $userPWD, 1);
|
|||
|
|
if(dao::isError()) return dao::getError();
|
|||
|
|
|
|||
|
|
return json_encode($result);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Test getDepthJobs method with maximum depth exceeded.
|
|||
|
|
*
|
|||
|
|
* @access public
|
|||
|
|
* @return string
|
|||
|
|
*/
|
|||
|
|
public function getDepthJobsMaxDepthTest(): string
|
|||
|
|
{
|
|||
|
|
$mockJobs = array(
|
|||
|
|
(object)array(
|
|||
|
|
'name' => 'Test Job',
|
|||
|
|
'url' => 'https://jenkins.example.com/job/testJob/',
|
|||
|
|
'_class' => 'hudson.model.FreeStyleProject',
|
|||
|
|
'buildable' => true
|
|||
|
|
)
|
|||
|
|
);
|
|||
|
|
|
|||
|
|
$userPWD = 'test:test';
|
|||
|
|
$result = $this->jenkins->getDepthJobs($mockJobs, $userPWD, 5); // depth > 4
|
|||
|
|
if(dao::isError()) return dao::getError();
|
|||
|
|
|
|||
|
|
return json_encode($result);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Test getDepthJobs method with invalid job data.
|
|||
|
|
*
|
|||
|
|
* @access public
|
|||
|
|
* @return string
|
|||
|
|
*/
|
|||
|
|
public function getDepthJobsInvalidDataTest(): string
|
|||
|
|
{
|
|||
|
|
$invalidJobs = array(
|
|||
|
|
(object)array(
|
|||
|
|
'name' => 'Invalid Job',
|
|||
|
|
// Missing url field
|
|||
|
|
'_class' => 'hudson.model.FreeStyleProject',
|
|||
|
|
'buildable' => true
|
|||
|
|
),
|
|||
|
|
(object)array(
|
|||
|
|
'name' => 'Another Job',
|
|||
|
|
'url' => '', // Empty url
|
|||
|
|
'_class' => 'hudson.model.FreeStyleProject',
|
|||
|
|
'buildable' => true
|
|||
|
|
)
|
|||
|
|
);
|
|||
|
|
|
|||
|
|
$userPWD = 'test:test';
|
|||
|
|
$result = $this->jenkins->getDepthJobs($invalidJobs, $userPWD, 1);
|
|||
|
|
if(dao::isError()) return dao::getError();
|
|||
|
|
|
|||
|
|
return json_encode($result);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Test getDepthJobs method with different job types.
|
|||
|
|
*
|
|||
|
|
* @access public
|
|||
|
|
* @return string
|
|||
|
|
*/
|
|||
|
|
public function getDepthJobsJobTypeTest(): string
|
|||
|
|
{
|
|||
|
|
$mockJobs = array(
|
|||
|
|
(object)array(
|
|||
|
|
'name' => 'Buildable Job',
|
|||
|
|
'url' => 'https://jenkins.example.com/job/buildableJob/',
|
|||
|
|
'_class' => 'com.cloudbees.hudson.plugins.folder.Folder',
|
|||
|
|
'buildable' => true // Force as job even though it's a folder
|
|||
|
|
),
|
|||
|
|
(object)array(
|
|||
|
|
'name' => 'Regular Job',
|
|||
|
|
'url' => 'https://jenkins.example.com/job/regularJob/',
|
|||
|
|
'_class' => 'hudson.model.FreeStyleProject',
|
|||
|
|
'buildable' => true
|
|||
|
|
),
|
|||
|
|
(object)array(
|
|||
|
|
'name' => 'Multibranch Pipeline',
|
|||
|
|
'url' => 'https://jenkins.example.com/job/multibranchPipeline/',
|
|||
|
|
'_class' => 'org.jenkinsci.plugins.workflow.multibranch.WorkflowMultiBranchProject',
|
|||
|
|
'buildable' => false
|
|||
|
|
)
|
|||
|
|
);
|
|||
|
|
|
|||
|
|
$userPWD = 'test:test';
|
|||
|
|
$result = $this->jenkins->getDepthJobs($mockJobs, $userPWD, 1);
|
|||
|
|
if(dao::isError()) return dao::getError();
|
|||
|
|
|
|||
|
|
return json_encode($result);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Test getDepthJobs method with URL encoding.
|
|||
|
|
*
|
|||
|
|
* @access public
|
|||
|
|
* @return string
|
|||
|
|
*/
|
|||
|
|
public function getDepthJobsUrlEncodingTest(): string
|
|||
|
|
{
|
|||
|
|
$mockJobs = array(
|
|||
|
|
(object)array(
|
|||
|
|
'name' => 'Hello World',
|
|||
|
|
'url' => 'https://jenkins.example.com/job/hello%20world/',
|
|||
|
|
'_class' => 'hudson.model.FreeStyleProject',
|
|||
|
|
'buildable' => true
|
|||
|
|
),
|
|||
|
|
(object)array(
|
|||
|
|
'name' => 'Test Job',
|
|||
|
|
'url' => 'https://jenkins.example.com/job/test-job/',
|
|||
|
|
'_class' => 'hudson.model.FreeStyleProject',
|
|||
|
|
'buildable' => true
|
|||
|
|
)
|
|||
|
|
);
|
|||
|
|
|
|||
|
|
$userPWD = 'test:test';
|
|||
|
|
$result = $this->jenkins->getDepthJobs($mockJobs, $userPWD, 1);
|
|||
|
|
if(dao::isError()) return dao::getError();
|
|||
|
|
|
|||
|
|
return json_encode($result);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Test getDepthJobs method with folder structure.
|
|||
|
|
*
|
|||
|
|
* @access public
|
|||
|
|
* @return string
|
|||
|
|
*/
|
|||
|
|
public function getDepthJobsFolderTest(): string
|
|||
|
|
{
|
|||
|
|
// Test with simple folder that contains jobs but depth = 1 to avoid HTTP calls
|
|||
|
|
$mockJobs = array(
|
|||
|
|
(object)array(
|
|||
|
|
'name' => 'Folder',
|
|||
|
|
'url' => 'https://jenkins.example.com/job/folder/',
|
|||
|
|
'_class' => 'com.cloudbees.hudson.plugins.folder.Folder',
|
|||
|
|
'buildable' => false,
|
|||
|
|
'jobs' => array() // Empty jobs array
|
|||
|
|
)
|
|||
|
|
);
|
|||
|
|
|
|||
|
|
$userPWD = 'test:test';
|
|||
|
|
$result = $this->jenkins->getDepthJobs($mockJobs, $userPWD, 1);
|
|||
|
|
if(dao::isError()) return dao::getError();
|
|||
|
|
|
|||
|
|
return json_encode($result);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 测试根据深度获取流水线。
|
|||
|
|
* Test get jobs by depth.
|
|||
|
|
*
|
|||
|
|
* @param int $depth
|
|||
|
|
* @access public
|
|||
|
|
* @return string
|
|||
|
|
*/
|
|||
|
|
public function getDepthJobsTest(int $depth = 1): string
|
|||
|
|
{
|
|||
|
|
$userPWD = "jenkins:11eb8b38c99143c7c6d872291e291abff4";
|
|||
|
|
$jenkinsServer = 'https://jenkinsdev.qc.oop.cc/';
|
|||
|
|
$response = common::http($jenkinsServer . '/api/json/items/list' . ($depth ? "?depth=1" : ''), '', array(CURLOPT_USERPWD => $userPWD));
|
|||
|
|
$response = json_decode($response);
|
|||
|
|
|
|||
|
|
$tasks = $this->jenkins->getDepthJobs($response->jobs, $userPWD, $depth);
|
|||
|
|
$return = '';
|
|||
|
|
foreach($tasks as $folder => $subTasks)
|
|||
|
|
{
|
|||
|
|
if(is_array($subTasks))
|
|||
|
|
{
|
|||
|
|
$return .= $this->getJobsByTest($subTasks);
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
$return .= "{$folder}:{$subTasks},";
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return trim($return, ',');
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 测试获取流水线下的目录名称和文件名称。
|
|||
|
|
* Test get the directory name and file name under the pipeline.
|
|||
|
|
*
|
|||
|
|
* @param array $tasks
|
|||
|
|
* @access public
|
|||
|
|
* @return string
|
|||
|
|
*/
|
|||
|
|
protected function getJobsByTest(array $tasks): string
|
|||
|
|
{
|
|||
|
|
$return = '';
|
|||
|
|
foreach($tasks as $folder => $subTasks)
|
|||
|
|
{
|
|||
|
|
if(is_array($subTasks))
|
|||
|
|
{
|
|||
|
|
if(empty($subTasks)) $return .= "{$folder}:0,";
|
|||
|
|
$return .= $this->getJobsByTest($subTasks);
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
$return .= "{$folder}:{$subTasks},";
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return $return;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 测试获取 Jenkins 流水线。
|
|||
|
|
* Test get jobs by jenkins .
|
|||
|
|
*
|
|||
|
|
* @param int $jenkinsID
|
|||
|
|
* @access public
|
|||
|
|
* @return string
|
|||
|
|
*/
|
|||
|
|
public function getJobPairsTest(int $jenkinsID): string
|
|||
|
|
{
|
|||
|
|
$jobs = $this->jenkins->getJobPairs($jenkinsID);
|
|||
|
|
$return = '';
|
|||
|
|
foreach($jobs as $jobID => $job) $return .= "{$jobID}:{$job},";
|
|||
|
|
return trim($return, ',');
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 测试获取jenkins api 密码串。
|
|||
|
|
* Test get jenkins api userpwd string.
|
|||
|
|
*
|
|||
|
|
* @param int $jenkinsID
|
|||
|
|
* @access public
|
|||
|
|
* @return array
|
|||
|
|
*/
|
|||
|
|
public function getApiUserPWDTest(int $jenkinsID)
|
|||
|
|
{
|
|||
|
|
global $tester;
|
|||
|
|
$jenkins = $tester->dao->select('*')->from(TABLE_PIPELINE)->where('id')->eq($jenkinsID)->fetch();
|
|||
|
|
return $this->jenkins->getApiUserPWD($jenkins);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 测试构建流水线下拉菜单树。
|
|||
|
|
* Test buildTree method.
|
|||
|
|
*
|
|||
|
|
* @param array $tasks
|
|||
|
|
* @access public
|
|||
|
|
* @return array
|
|||
|
|
*/
|
|||
|
|
public function buildTreeTest(array $tasks = array())
|
|||
|
|
{
|
|||
|
|
// 创建测试用的简化jenkinsZen类，直接实现buildTree方法
|
|||
|
|
$testClass = new class {
|
|||
|
|
protected function buildTree(array $tasks): array
|
|||
|
|
{
|
|||
|
|
$result = array();
|
|||
|
|
foreach($tasks as $groupName => $task)
|
|||
|
|
{
|
|||
|
|
if(empty($task)) continue;
|
|||
|
|
|
|||
|
|
$itemArray = array
|
|||
|
|
(
|
|||
|
|
'id' => is_array($task) ? '' : $groupName,
|
|||
|
|
'text' => is_array($task) ? urldecode($groupName) : urldecode($task),
|
|||
|
|
'keys' => urldecode(zget(common::convert2Pinyin(array($groupName)), $groupName, '')),
|
|||
|
|
);
|
|||
|
|
if(is_array($task))
|
|||
|
|
{
|
|||
|
|
$itemArray['items'] = $this->buildTree($task);
|
|||
|
|
$itemArray['type'] = 'folder';
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
$result[] = $itemArray;
|
|||
|
|
}
|
|||
|
|
return $result;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function testBuildTree(array $tasks): array
|
|||
|
|
{
|
|||
|
|
return $this->buildTree($tasks);
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
$result = $testClass->testBuildTree($tasks);
|
|||
|
|
if(dao::isError()) return dao::getError();
|
|||
|
|
|
|||
|
|
return $result;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 测试检查Jenkins账号信息是否正确。
|
|||
|
|
* Test checkTokenAccess method.
|
|||
|
|
*
|
|||
|
|
* @param string $url
|
|||
|
|
* @param string $account
|
|||
|
|
* @param string $password
|
|||
|
|
* @param string $token
|
|||
|
|
* @access public
|
|||
|
|
* @return bool
|
|||
|
|
*/
|
|||
|
|
public function checkTokenAccessTest(string $url = '', string $account = '', string $password = '', string $token = '')
|
|||
|
|
{
|
|||
|
|
// 创建测试用的简化jenkinsZen类，直接实现checkTokenAccess方法
|
|||
|
|
$testClass = new class {
|
|||
|
|
protected function checkTokenAccess(string $url, string $account, string $password, string $token): bool
|
|||
|
|
{
|
|||
|
|
global $lang;
|
|||
|
|
|
|||
|
|
$password = $token ? $token : $password;
|
|||
|
|
$response = json_decode(common::http("{$url}/api/json", '', array(CURLOPT_USERPWD => "{$account}:{$password}")));
|
|||
|
|
if(empty($response) || empty($response->_class)) dao::$errors['account'] = $lang->jenkins->error->unauthorized ?? 'Unauthorized access';
|
|||
|
|
return dao::isError();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function testCheckTokenAccess(string $url, string $account, string $password, string $token): bool
|
|||
|
|
{
|
|||
|
|
return $this->checkTokenAccess($url, $account, $password, $token);
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
// 清理之前的错误信息
|
|||
|
|
dao::$errors = array();
|
|||
|
|
|
|||
|
|
$result = $testClass->testCheckTokenAccess($url, $account, $password, $token);
|
|||
|
|
return $result;
|
|||
|
|
}
|
|||
|
|
}
|