361 lines
12 KiB
PHP
361 lines
12 KiB
PHP
<?php
|
|
declare(strict_types=1);
|
|
/**
|
|
* The model file of gogs module of ZenTaoPMS.
|
|
*
|
|
* @copyright Copyright 2009-2023 禅道软件（青岛）有限公司(ZenTao Software (Qingdao) Co., Ltd. www.cnezsoft.com)
|
|
* @license ZPL(http://zpl.pub/page/zplv12.html) or AGPL(https://www.gnu.org/licenses/agpl-3.0.en.html)
|
|
* @author Chenqi <chenqi@cnezsoft.com>
|
|
* @package gogs
|
|
* @link https://www.zentao.net
|
|
*/
|
|
|
|
class gogsModel extends model
|
|
{
|
|
/**
|
|
* 获取请求地址信息。
|
|
* Get gogs api base url by gogs id.
|
|
*
|
|
* @param int $gogsID
|
|
* @access public
|
|
* @return string
|
|
*/
|
|
public function getApiRoot(int $gogsID): string
|
|
{
|
|
$gogs = $this->fetchByID($gogsID);
|
|
if(!$gogs || $gogs->type != 'gogs') return '';
|
|
|
|
return rtrim($gogs->url, '/') . '/api/v1%s' . "?token={$gogs->token}";
|
|
}
|
|
|
|
/**
|
|
* Gogs用户和禅道用户绑定。
|
|
* Bind gogs user and zentao user.
|
|
*
|
|
* @param int $gogsID
|
|
* @param array $users
|
|
* @param array $gogsNames
|
|
* @access public
|
|
* @return array
|
|
*/
|
|
public function bindUser(int $gogsID, array $users, array $gogsNames): bool
|
|
{
|
|
$repeatUsers = array();
|
|
$userPairs = array();
|
|
foreach($users as $openID => $account)
|
|
{
|
|
if(empty($account)) continue;
|
|
|
|
if(in_array($account, $userPairs)) $repeatUsers[] = $account;
|
|
$userPairs[$openID] = $account;
|
|
}
|
|
|
|
/* Check user repeat bind. */
|
|
if($repeatUsers)
|
|
{
|
|
$userList = $this->loadModel('user')->getRealNameAndEmails($repeatUsers);
|
|
dao::$errors = sprintf($this->lang->gogs->bindUserError, join(',', helper::arrayColumn($userList, 'realname')));
|
|
return false;
|
|
}
|
|
|
|
$bindedUsers = $this->dao->select('openID,account')->from(TABLE_OAUTH)
|
|
->where('providerType')->eq('gogs')
|
|
->andWhere('providerID')->eq($gogsID)
|
|
->fetchPairs();
|
|
$this->dao->delete()->from(TABLE_OAUTH)->where('providerType')->eq('gogs')->andWhere('providerID')->eq($gogsID)->exec();
|
|
|
|
$this->loadModel('action');
|
|
foreach($userPairs as $openID => $account)
|
|
{
|
|
/* If user binded user is change, delete it. */
|
|
if(isset($bindedUsers[$openID]) && $bindedUsers[$openID] != $account) $this->action->create('gogsuser', $gogsID, 'unbind', '', $gogsNames[$openID]);
|
|
|
|
/* Add zentao user and gogs user binded. */
|
|
$user = new stdclass();
|
|
$user->providerID = $gogsID;
|
|
$user->providerType = 'gogs';
|
|
$user->account = $account;
|
|
$user->openID = $gogsNames[$openID];
|
|
$this->dao->insert(TABLE_OAUTH)->data($user)->exec();
|
|
$this->action->create('gogsuser', $gogsID, 'bind', '', $gogsNames[$openID]);
|
|
}
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* 检测token是否有效。
|
|
* Check token access.
|
|
*
|
|
* @param string $url
|
|
* @param string $token
|
|
* @access public
|
|
* @return void
|
|
*/
|
|
public function checkTokenAccess(string $url = '', string $token = ''): bool
|
|
{
|
|
$apiRoot = rtrim($url, '/') . '/api/v1%s' . "?token={$token}";
|
|
$url = sprintf($apiRoot, "/user");
|
|
$user = json_decode(commonModel::http($url));
|
|
if(empty($user) || isset($user->message)) return false;
|
|
|
|
/* Check whether the token belongs to the administrator by edit user. */
|
|
$editUserUrl = sprintf($apiRoot, "/admin/users/" . $user->username);
|
|
$data = new stdclass();
|
|
$data->login_name = $user->login;
|
|
$data->email = $user->email;
|
|
|
|
$result = commonModel::http($editUserUrl, $data, array(), array(), 'data', 'PATCH');
|
|
$user = json_decode($result);
|
|
if(empty($user)) return false;
|
|
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* 通过API获取Gogs项目信息。
|
|
* Get project by api.
|
|
*
|
|
* @param int $gogsID
|
|
* @param string $projectID
|
|
* @access public
|
|
* @return object|null
|
|
*/
|
|
public function apiGetSingleProject(int $gogsID, string $projectID): object|null
|
|
{
|
|
$apiRoot = $this->getApiRoot($gogsID);
|
|
if(!$apiRoot) return null;
|
|
|
|
$url = sprintf($apiRoot, "/repos/$projectID");
|
|
$project = json_decode(commonModel::http($url));
|
|
if(isset($project->name))
|
|
{
|
|
$project->name_with_namespace = $project->full_name;
|
|
$project->path_with_namespace = $project->full_name;
|
|
$project->http_url_to_repo = $project->html_url;
|
|
$project->name_with_namespace = $project->full_name;
|
|
|
|
$gogs = $this->fetchByID($gogsID);
|
|
$project->tokenCloneUrl = preg_replace('/(http(s)?:\/\/)/', '${1}' . $gogs->token . '@', $project->html_url);
|
|
}
|
|
|
|
return $project;
|
|
}
|
|
|
|
/**
|
|
* 通过API获取Gogs项目列表。
|
|
* Get projects by api.
|
|
*
|
|
* @param int $gogsID
|
|
* @access public
|
|
* @return array
|
|
*/
|
|
public function apiGetProjects(int $gogsID): array
|
|
{
|
|
$apiRoot = $this->getApiRoot($gogsID);
|
|
if(!$apiRoot) return array();
|
|
|
|
$url = sprintf($apiRoot, "/user");
|
|
$user = json_decode(commonModel::http($url));
|
|
if(!isset($user->username)) return array();
|
|
|
|
$url = sprintf($apiRoot, "/users/{$user->username}/repos");
|
|
$projects = array();
|
|
$results = json_decode(commonModel::http($url));
|
|
if(!is_array($results) || empty($results)) return array();
|
|
|
|
if(!empty($results)) $projects = array_merge($projects, $results);
|
|
|
|
return $projects;
|
|
}
|
|
|
|
/**
|
|
* 通过API获取Gogs用户列表。
|
|
* Get gogs user list.
|
|
*
|
|
* @param int $gogsID
|
|
* @param bool $onlyLinked
|
|
* @access public
|
|
* @return array
|
|
*/
|
|
public function apiGetUsers(int $gogsID, bool $onlyLinked = false): array
|
|
{
|
|
$users = array();
|
|
$apiRoot = $this->getApiRoot($gogsID, strtolower($this->app->rawMethod) != 'binduser');
|
|
$page = 1;
|
|
while(true)
|
|
{
|
|
$url = sprintf($apiRoot, "/admin/users") . "&page={$page}&limit=20";
|
|
$result = json_decode(commonModel::http($url));
|
|
if(empty($result->data)) break;
|
|
|
|
$users = array_merge($users, $result->data);
|
|
$page ++;
|
|
}
|
|
|
|
if(empty($users)) return array();
|
|
|
|
/* Get linked users. */
|
|
$linkedUsers = array();
|
|
if($onlyLinked) $linkedUsers = $this->loadModel('pipeline')->getUserBindedPairs($gogsID, 'gogs', 'openID,account');
|
|
|
|
$userList = array();
|
|
foreach($users as $gogsUser)
|
|
{
|
|
if($onlyLinked and !isset($linkedUsers[$gogsUser->username])) continue;
|
|
|
|
$user = new stdclass;
|
|
$user->id = $gogsUser->id;
|
|
$user->realname = $gogsUser->full_name ? $gogsUser->full_name : $gogsUser->username;
|
|
$user->account = $gogsUser->username;
|
|
$user->email = zget($gogsUser, 'email', '');
|
|
$user->avatar = $gogsUser->avatar_url;
|
|
$user->createdAt = zget($gogsUser, 'created', '');
|
|
$user->lastActivityOn = zget($gogsUser, 'login', '');
|
|
|
|
$userList[] = $user;
|
|
}
|
|
|
|
return $userList;
|
|
}
|
|
|
|
/**
|
|
* 通过API获取Gogs项目分支列表。
|
|
* Get project repository branches by api.
|
|
*
|
|
* @param int $gogsID
|
|
* @param string $project
|
|
* @access public
|
|
* @return array
|
|
*/
|
|
public function apiGetBranches(int $gogsID, string $project): array
|
|
{
|
|
$url = sprintf($this->getApiRoot($gogsID), "/repos/{$project}/branches");
|
|
$branches = array();
|
|
$page = 1;
|
|
while(true)
|
|
{
|
|
$results = json_decode(commonModel::http($url . "&page={$page}&limit=50"));
|
|
if(!is_array($results)) break;
|
|
|
|
if(!empty($results)) $branches = array_merge($branches, $results);
|
|
if(count($results) < 100) break;
|
|
|
|
$page ++;
|
|
}
|
|
|
|
return $branches;
|
|
}
|
|
|
|
/**
|
|
* 通过API获取Gogs项目分支信息。
|
|
* Get single branch by API.
|
|
*
|
|
* @param int $gogsID
|
|
* @param string $project
|
|
* @param string $branchName
|
|
* @access public
|
|
* @return object|null
|
|
*/
|
|
public function apiGetSingleBranch(int $gogsID, string $project, string $branchName): object|null
|
|
{
|
|
if(empty($branchName)) return null;
|
|
|
|
$url = sprintf($this->getApiRoot($gogsID), "/repos/$project/branches/$branchName");
|
|
$branch = json_decode(commonModel::http($url));
|
|
if(isset($branch->name))
|
|
{
|
|
$gogs = $this->fetchByID($gogsID);
|
|
$branch->web_url = "{$gogs->url}/$project/src/$branchName";
|
|
}
|
|
|
|
return $branch;
|
|
}
|
|
|
|
/**
|
|
* 通过API获取Gogs项目分支保护信息。
|
|
* Get protect branches of one project.
|
|
*
|
|
* @param int $gogsID
|
|
* @param string $project
|
|
* @param string $keyword
|
|
* @access public
|
|
* @return array
|
|
*/
|
|
public function apiGetBranchPrivs(int $gogsID, string $project, string $keyword = ''): array
|
|
{
|
|
$keyword = urlencode($keyword);
|
|
$url = sprintf($this->getApiRoot($gogsID), "/repos/$project/branch_protections");
|
|
$branches = json_decode(commonModel::http($url));
|
|
if(!is_array($branches)) return array();
|
|
|
|
$newBranches = array();
|
|
foreach($branches as $branch)
|
|
{
|
|
$branch->name = $branch->Name;
|
|
if(empty($keyword) || stristr($branch->name, $keyword)) $newBranches[] = $branch;
|
|
}
|
|
|
|
return $newBranches;
|
|
}
|
|
|
|
/**
|
|
* 通过API删除Gogs分支。
|
|
* Api delete branch.
|
|
*
|
|
* @param int $gogsID
|
|
* @param string $project
|
|
* @param string $branch
|
|
* @access public
|
|
* @return object|null
|
|
*/
|
|
public function apiDeleteBranch(int $gogsID, string $project, string $branch): object|null
|
|
{
|
|
if(empty($branch) || empty($project)) return null;
|
|
$url = sprintf($this->getApiRoot($gogsID), "/repos/$project/branches/$branch");
|
|
if(!$url) return null;
|
|
|
|
return json_decode(commonModel::http($url, null, array(CURLOPT_CUSTOMREQUEST => 'DELETE')));
|
|
}
|
|
|
|
/**
|
|
* API获取项目的合并请求列表。
|
|
* Get Merge Requests by API.
|
|
*
|
|
* @param int $giteaID
|
|
* @param string $project
|
|
* @access public
|
|
* @return array
|
|
*/
|
|
public function apiGetMergeRequests(int $giteaID, string $project): array
|
|
{
|
|
$apiRoot = $this->getApiRoot($giteaID);
|
|
if(!$apiRoot) return array();
|
|
|
|
$apiPath = "/repos/{$project}/pulls";
|
|
$url = sprintf($apiRoot, $apiPath);
|
|
|
|
$mrList = json_decode(common::http($url));
|
|
if(!is_array($mrList)) return array();
|
|
|
|
foreach($mrList as $mr)
|
|
{
|
|
$mr->web_url = $mr->html_url;
|
|
$mr->iid = $mr->id;
|
|
$mr->state = $mr->state == 'open' ? 'opened' : $mr->state;
|
|
if($mr->merged) $mr->state = 'merged';
|
|
|
|
$mr->merge_status = $mr->mergeable ? 'can_be_merged' : 'cannot_be_merged';
|
|
$mr->changes_count = empty($diff) ? 0 : 1;
|
|
$mr->description = $mr->body;
|
|
$mr->target_branch = $mr->base_branch;
|
|
$mr->source_branch = $mr->head_branch;
|
|
$mr->source_project_id = $project;
|
|
$mr->target_project_id = $project;
|
|
$mr->has_conflicts = empty($diff) ? true : false;
|
|
$mr->is_draft = strpos($mr->title, 'Draft:') === 0;
|
|
}
|
|
|
|
return $mrList;
|
|
}
|
|
}
|