public static final ObjectMapper MAPPER = new ObjectMapper().configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);

private static final String API_NAMESPACE = "/api/v4";

private static final String PARAM_SUDO = "sudo";

private static final String PARAM_MAX_ITEMS_PER_PAGE = new Pagination().withPerPage(Pagination.MAX_ITEMS_PER_PAGE).toString();

private final String hostUrl;

private final String apiToken;

private final TokenType tokenType;

private AuthMethod authMethod;

private boolean ignoreCertificateErrors = false;

private Proxy proxy;

private int requestTimeout = 0;

private String userAgent = GitlabAPI.class.getCanonicalName() + "/" + System.getProperty("java.version");

private GitlabAPI(String hostUrl, String apiToken, TokenType tokenType, AuthMethod method) {

this.hostUrl = hostUrl.endsWith("/") ? hostUrl.replaceAll("/$", "") : hostUrl;

this.apiToken = apiToken;

this.tokenType = tokenType;

this.authMethod = method;

}

public static GitlabSession connect(String hostUrl, String username, String password) throws IOException {

String tailUrl = GitlabSession.URL;

GitlabAPI api = connect(hostUrl, null, null, null);

return api.dispatch().with("login", username).with("password", password)

.to(tailUrl, GitlabSession.class);

}

public static GitlabAPI connect(String hostUrl, String apiToken) {

return new GitlabAPI(hostUrl, apiToken, TokenType.PRIVATE_TOKEN, AuthMethod.HEADER);

}

public static GitlabAPI connect(String hostUrl, String apiToken, TokenType tokenType) {

return new GitlabAPI(hostUrl, apiToken, tokenType, AuthMethod.HEADER);

}

public static GitlabAPI connect(String hostUrl, String apiToken, TokenType tokenType, AuthMethod method) {

return new GitlabAPI(hostUrl, apiToken, tokenType, method);

}

public GitlabAPI ignoreCertificateErrors(boolean ignoreCertificateErrors) {

this.ignoreCertificateErrors = ignoreCertificateErrors;

return this;

}

public GitlabAPI proxy(Proxy proxy) {

this.proxy = proxy;

return this;

}

public int getRequestTimeout() {

return requestTimeout;

}

public GitlabAPI setRequestTimeout(int requestTimeout) {

this.requestTimeout = requestTimeout;

return this;

}

public GitlabHTTPRequestor retrieve() {

return new GitlabHTTPRequestor(this).authenticate(apiToken, tokenType, authMethod);

}

public GitlabHTTPRequestor dispatch() {

return new GitlabHTTPRequestor(this).authenticate(apiToken, tokenType, authMethod).method("POST");

}

public boolean isIgnoreCertificateErrors() {

return ignoreCertificateErrors;

}

public Proxy getProxy() {

return proxy;

}

public URL getAPIUrl(String tailAPIUrl) throws IOException {

if (!tailAPIUrl.startsWith("/")) {

tailAPIUrl = "/" + tailAPIUrl;

}

return new URL(hostUrl + API_NAMESPACE + tailAPIUrl);

}

public URL getUrl(String tailAPIUrl) throws IOException {

if (!tailAPIUrl.startsWith("/")) {

tailAPIUrl = "/" + tailAPIUrl;

}

return new URL(hostUrl + tailAPIUrl);

}

public List<GitlabUser> getUsers() throws IOException {

String tailUrl = GitlabUser.URL + PARAM_MAX_ITEMS_PER_PAGE;

return retrieve().getAll(tailUrl, GitlabUser[].class);

}

/**

public List<GitlabUser> findUsers(String emailOrUsername) throws IOException {

List<GitlabUser> users = new ArrayList<GitlabUser>();

if (emailOrUsername != null && !emailOrUsername.equals("")) {

String tailUrl = GitlabUser.URL + "?search=" + emailOrUsername;

GitlabUser[] response = retrieve().to(tailUrl, GitlabUser[].class);

users = Arrays.asList(response);

}

return users;

}

/**

public GitlabUser getUser() throws IOException {

String tailUrl = GitlabUser.USER_URL;

return retrieve().to(tailUrl, GitlabUser.class);

}

public GitlabUser getUser(Integer userId) throws IOException {

String tailUrl = GitlabUser.URL + "/" + userId;

return retrieve().to(tailUrl, GitlabUser.class);

}

public GitlabUser getUserViaSudo(String username) throws IOException {

String tailUrl = GitlabUser.USER_URL + "?" + PARAM_SUDO + "=" + username;

return retrieve().to(tailUrl, GitlabUser.class);

}

/**

public GitlabUser createUser(String email, String password, String username,

String fullName, String skypeId, String linkedIn,

String twitter, String website_url, Integer projects_limit,

String extern_uid, String extern_provider_name,

String bio, Boolean isAdmin, Boolean can_create_group,

Boolean skip_confirmation) throws IOException {

Query query = new Query()

.append("email", email)

.appendIf("confirm", skip_confirmation == null ? null : !skip_confirmation)

.appendIf("password", password)

.appendIf("username", username)

.appendIf("name", fullName)

.appendIf("skype", skypeId)

.appendIf("linkedin", linkedIn)

.appendIf("twitter", twitter)

.appendIf("website_url", website_url)

.appendIf("projects_limit", projects_limit)

.appendIf("extern_uid", extern_uid)

.appendIf("provider", extern_provider_name)

.appendIf("bio", bio)

.appendIf("admin", isAdmin)

.appendIf("can_create_group", can_create_group);

String tailUrl = GitlabUser.USERS_URL + query.toString();

return dispatch().to(tailUrl, GitlabUser.class);

}

/**

public GitlabUser updateUser(Integer targetUserId,

String email, String password, String username,

String fullName, String skypeId, String linkedIn,

String twitter, String website_url, Integer projects_limit,

String extern_uid, String extern_provider_name,

String bio, Boolean isAdmin, Boolean can_create_group) throws IOException {

Query query = new Query()

.append("email", email)

.appendIf("password", password)

.appendIf("username", username)

.appendIf("name", fullName)

.appendIf("skype", skypeId)

.appendIf("linkedin", linkedIn)

.appendIf("twitter", twitter)

.appendIf("website_url", website_url)

.appendIf("projects_limit", projects_limit)

.appendIf("extern_uid", extern_uid)

.appendIf("provider", extern_provider_name)

.appendIf("bio", bio)

.appendIf("admin", isAdmin)

.appendIf("can_create_group", can_create_group);

String tailUrl = GitlabUser.USERS_URL + "/" + targetUserId + query.toString();

return retrieve().method("PUT").to(tailUrl, GitlabUser.class);

}

/**

public void blockUser(Integer targetUserId) throws IOException {

String tailUrl = GitlabUser.USERS_URL + "/" + targetUserId + GitlabUser.BLOCK_URL;

retrieve().method("POST").to(tailUrl, Void.class);

}

/**

public void unblockUser(Integer targetUserId) throws IOException {

String tailUrl = GitlabUser.USERS_URL + "/" + targetUserId + GitlabUser.UNBLOCK_URL;

retrieve().method("POST").to(tailUrl, Void.class);

}

/**

public GitlabSSHKey createSSHKey(Integer targetUserId, String title, String key) throws IOException {

Query query = new Query()

.append("title", title)

.append("key", key);

String tailUrl = GitlabUser.USERS_URL + "/" + targetUserId + GitlabSSHKey.KEYS_URL + query.toString();

return dispatch().to(tailUrl, GitlabSSHKey.class);

}

/**

public void deleteSSHKey(Integer targetUserId, Integer targetKeyId) throws IOException {

String tailUrl = GitlabUser.USERS_URL + "/" + targetUserId + GitlabSSHKey.KEYS_URL + "/" + targetKeyId;

retrieve().method("DELETE").to(tailUrl, Void.class);

}

/**

public List<GitlabSSHKey> getSSHKeys(Integer targetUserId) throws IOException {

String tailUrl = GitlabUser.USERS_URL + "/" + targetUserId + GitlabSSHKey.KEYS_URL;

return Arrays.asList(retrieve().to(tailUrl, GitlabSSHKey[].class));

}

/**

public GitlabSSHKey getSSHKey(Integer keyId) throws IOException {

String tailUrl = GitlabSSHKey.KEYS_URL + "/" + keyId;

return retrieve().to(tailUrl, GitlabSSHKey.class);

}

/**

public void deleteUser(Integer targetUserId) throws IOException {

String tailUrl = GitlabUser.USERS_URL + "/" + targetUserId;

retrieve().method("DELETE").to(tailUrl, Void.class);

}

public GitlabGroup getGroup(Integer groupId) throws IOException {

return getGroup(groupId.toString());

}

/**

public GitlabGroup getGroup(String path) throws IOException {

String tailUrl = GitlabGroup.URL + "/" + path;

return retrieve().to(tailUrl, GitlabGroup.class);

}

public List<GitlabGroup> getGroups() throws IOException {

return getGroupsViaSudo(null, new Pagination().withPerPage(Pagination.MAX_ITEMS_PER_PAGE));

}

public List<GitlabGroup> getGroupsViaSudo(String username, Pagination pagination) throws IOException {

String tailUrl = GitlabGroup.URL;

Query query = new Query()

.appendIf(PARAM_SUDO, username);

if (pagination != null) {

query.mergeWith(pagination.asQuery());

}

return retrieve().getAll(tailUrl + query.toString(), GitlabGroup[].class);

}

/**

public List<GitlabProject> getGroupProjects(GitlabGroup group) throws IOException {

return getGroupProjects(group.getId());

}

/**

public List<GitlabProject> getGroupProjects(Integer groupId) throws IOException {

String tailUrl = GitlabGroup.URL + "/" + groupId + GitlabProject.URL + PARAM_MAX_ITEMS_PER_PAGE;

return retrieve().getAll(tailUrl, GitlabProject[].class);

}

/**

public List<GitlabGroupMember> getGroupMembers(GitlabGroup group) throws IOException {

return getGroupMembers(group.getId());

}

/**

public List<GitlabGroupMember> getGroupMembers(Integer groupId) throws IOException {

String tailUrl = GitlabGroup.URL + "/" + groupId + GitlabGroupMember.URL + PARAM_MAX_ITEMS_PER_PAGE;

return retrieve().getAll(tailUrl, GitlabGroupMember[].class);

}

/**

public GitlabGroup createGroup(String name) throws IOException {

return createGroup(name, name);

}

/**

public GitlabGroup createGroup(String name, String path) throws IOException {

return createGroup(name, path, null, null, null);

}

/**

public GitlabGroup createGroupViaSudo(String name, String path, GitlabUser sudoUser) throws IOException {

return createGroup(name, path, null, null, sudoUser);

}

/**

public GitlabGroup createGroup(String name, String path, String ldapCn, GitlabAccessLevel ldapAccess) throws IOException {

return createGroup(name, path, ldapCn, ldapAccess, null);

}

/**

public GitlabGroup createGroup(CreateGroupRequest request, GitlabUser sudoUser) throws IOException {

Query query = new Query()

.append("name", request.getName())

.append("path", request.getPath())

.appendIf("ldap_cn", request.getLdapCn())

.appendIf("description", request.getDescription())

.appendIf("membershipLock", request.getMembershipLock())

.appendIf("share_with_group_lock", request.getShareWithGroupLock())

.appendIf("visibility", request.getVisibility())

.appendIf("lfs_enabled", request.getLfsEnabled())

.appendIf("request_access_enabled", request.getRequestAccessEnabled())

.appendIf("parent_id", request.getParentId())

.appendIf(PARAM_SUDO, sudoUser != null ? sudoUser.getId() : null);

String tailUrl = GitlabGroup.URL + query.toString();

return dispatch().to(tailUrl, GitlabGroup.class);

}

/**

public GitlabGroup createGroup(String name, String path, String ldapCn, GitlabAccessLevel ldapAccess, GitlabUser sudoUser) throws IOException {

Query query = new Query()

.append("name", name)

.append("path", path)

.appendIf("ldap_cn", ldapCn)

.appendIf("ldap_access", ldapAccess)

.appendIf(PARAM_SUDO, sudoUser != null ? sudoUser.getId() : null);

String tailUrl = GitlabGroup.URL + query.toString();

return dispatch().to(tailUrl, GitlabGroup.class);

}

/**

public GitlabGroupMember addGroupMember(GitlabGroup group, GitlabUser user, GitlabAccessLevel accessLevel) throws IOException {

return addGroupMember(group.getId(), user.getId(), accessLevel);

}

/**

public GitlabGroupMember addGroupMember(Integer groupId, Integer userId, GitlabAccessLevel accessLevel) throws IOException {

Query query = new Query()

.appendIf("id", groupId)

.appendIf("user_id", userId)

.appendIf("access_level", accessLevel);

String tailUrl = GitlabGroup.URL + "/" + groupId + GitlabProjectMember.URL + query.toString();

return dispatch().to(tailUrl, GitlabGroupMember.class);

}

/**

public void deleteGroupMember(GitlabGroup group, GitlabUser user) throws IOException {

deleteGroupMember(group.getId(), user.getId());

}

/**

public void deleteGroupMember(Integer groupId, Integer userId) throws IOException {

String tailUrl = GitlabGroup.URL + "/" + groupId + "/" + GitlabGroupMember.URL + "/" + userId;

retrieve().method("DELETE").to(tailUrl, Void.class);

}

/**

public void deleteGroup(Integer groupId) throws IOException {

String tailUrl = GitlabGroup.URL + "/" + groupId;

retrieve().method("DELETE").to(tailUrl, Void.class);

}

public GitlabProject getProject(Serializable projectId) throws IOException {

String tailUrl = GitlabProject.URL + "/" + sanitizeProjectId(projectId);

return retrieve().to(tailUrl, GitlabProject.class);

}

/**

public GitlabProject getProject(String namespace, String projectName) throws IOException{

String tailUrl = GitlabProject.URL + "/" + namespace + "%2F" + projectName;

return retrieve().to(tailUrl, GitlabProject.class);

}

/**

public List<GitlabProject> getProjects() throws IOException {

String tailUrl = GitlabProject.URL + PARAM_MAX_ITEMS_PER_PAGE;

return retrieve().getAll(tailUrl, GitlabProject[].class);

}

/**

public List<GitlabProject> getOwnedProjects() throws IOException {

Query query = new Query().append("owner", "true");

String tailUrl = GitlabProject.URL + query.toString() + PARAM_MAX_ITEMS_PER_PAGE;

return retrieve().getAll(tailUrl, GitlabProject[].class);

}

/**

public List<GitlabProject> getStarredProjects() throws IOException {

Query query = new Query().append("starred", "true");

String tailUrl = GitlabProject.URL + query.toString() + PARAM_MAX_ITEMS_PER_PAGE;

return retrieve().getAll(tailUrl, GitlabProject[].class);

}

/**

public List<GitlabProject> getProjectsViaSudo(GitlabUser user) throws IOException {

Query query = new Query()

.appendIf(PARAM_SUDO, user.getId());

query.mergeWith(new Pagination().withPerPage(Pagination.MAX_ITEMS_PER_PAGE).asQuery());

String tailUrl = GitlabProject.URL + query.toString();

return retrieve().getAll(tailUrl, GitlabProject[].class);

}

/**

public GitlabUpload uploadFile(GitlabProject project, File file) throws IOException {

String tailUrl = GitlabProject.URL + "/" + sanitizeProjectId(project.getId()) + GitlabUpload.URL;

return dispatch().withAttachment("file", file).to(tailUrl, GitlabUpload.class);

}

/**

public List<GitlabJob> getProjectJobs(GitlabProject project) throws IOException {

return getProjectJobs(project.getId());

}

/**

public List<GitlabJob> getProjectJobs(Integer projectId) throws IOException {

String tailUrl = GitlabProject.URL + "/" + sanitizeProjectId(projectId) + GitlabJob.URL + PARAM_MAX_ITEMS_PER_PAGE;

return retrieve().getAll(tailUrl, GitlabJob[].class);

}

/**

public GitlabJob getProjectJob(Integer projectId, Integer jobId) throws IOException {

String tailUrl = GitlabProject.URL + "/" + sanitizeProjectId(projectId) + GitlabJob.URL + "/" + jobId;

return retrieve().to(tailUrl, GitlabJob.class);

}

/**

public byte[] getJobArtifact(GitlabProject project, GitlabJob job) throws IOException {

return getJobArtifact(project.getId(), job.getId());

}

/**

public byte[] getJobArtifact(Integer projectId, Integer jobId) throws IOException {

String tailUrl = GitlabProject.URL + "/" + sanitizeProjectId(projectId) + GitlabJob.URL + "/" + jobId + "/artifacts";

return retrieve().to(tailUrl, byte[].class);

}

/**

public GitlabProject createProject(GitlabProject project) throws IOException {

Query query = new Query()

.appendIf("name", project.getName())

.appendIf("path", project.getPath())

.appendIf("default_branch", project.getDefaultBranch())

.appendIf("description", project.getDescription())

.appendIf("issues_enabled", project.isIssuesEnabled())

.appendIf("merge_requests_enabled", project.isMergeRequestsEnabled())

.appendIf("jobs_enabled", project.isJobsEnabled())

.appendIf("wiki_enabled", project.isWikiEnabled())

.appendIf("snippets_enabled", project.isSnippetsEnabled())

.appendIf("container_registry_enabled", project.isContainerRegistryEnabled())

.appendIf("shared_runners_enabled", project.isSharedRunnersEnabled())

.appendIf("visibility", project.getVisibility())

.appendIf("public_jobs", project.hasPublicJobs())

.appendIf("import_url", project.getImportUrl())

.appendIf("only_allow_merge_if_pipeline_succeeds", project.getOnlyAllowMergeIfPipelineSucceeds())

.appendIf("only_allow_merge_if_all_discussions_are_resolved", project.getOnlyAllowMergeIfAllDiscussionsAreResolved())

.appendIf("lfs_enabled", project.isLfsEnabled())

.appendIf("request_enabled", project.isRequestAccessEnabled())

.appendIf("repository_storage", project.getRepositoryStorage())

.appendIf("approvals_before_merge", project.getApprovalsBeforeMerge());

GitlabNamespace namespace = project.getNamespace();

if (namespace != null) {

query.appendIf("namespace_id", namespace.getId());

}

String tailUrl = GitlabProject.URL + query.toString();

return dispatch().to(tailUrl, GitlabProject.class);

}

/**

public GitlabProject createProject(String name) throws IOException {

return createProject(name, null, null, null, null, null, null, null, null, null, null);

}

/**

public GitlabProject createProjectForGroup(String name, GitlabGroup group) throws IOException {

return createProjectForGroup(name, group, null);

}

/**

public GitlabProject createProjectForGroup(String name, GitlabGroup group, String description) throws IOException {

return createProjectForGroup(name, group, description, null);

}

/**

public GitlabProject createProjectForGroup(String name, GitlabGroup group, String description, String visibility) throws IOException {

return createProject(name, group.getId(), description, null, null, null, null, null, null, visibility, null);

}

/**

@Deprecated

public GitlabProject createProject(String name, Integer namespaceId, String description, Boolean issuesEnabled, Boolean wallEnabled, Boolean mergeRequestsEnabled, Boolean wikiEnabled, Boolean snippetsEnabled, Boolean publik, String visibility, String importUrl) throws IOException {

Query query = new Query()

.append("name", name)

.appendIf("namespace_id", namespaceId)

.appendIf("description", description)

.appendIf("issues_enabled", issuesEnabled)

.appendIf("wall_enabled", wallEnabled)

.appendIf("merge_requests_enabled", mergeRequestsEnabled)

.appendIf("wiki_enabled", wikiEnabled)

.appendIf("snippets_enabled", snippetsEnabled)

.appendIf("visibility", visibility)

.appendIf("import_url", importUrl);

String tailUrl = GitlabProject.URL + query.toString();

return dispatch().to(tailUrl, GitlabProject.class);

}

/**

public GitlabProject createUserProject(Integer userId, String name) throws IOException {

return createUserProject(userId, name, null, null, null, null, null, null, null, null, null);

}

/**

@Deprecated

public GitlabProject createUserProject(Integer userId, String name, String description, String defaultBranch, Boolean issuesEnabled, Boolean wallEnabled, Boolean mergeRequestsEnabled, Boolean wikiEnabled, Boolean snippetsEnabled, String visibility, String importUrl) throws IOException {

Query query = new Query()

.append("name", name)

.appendIf("description", description)

.appendIf("default_branch", defaultBranch)

.appendIf("issues_enabled", issuesEnabled)

.appendIf("wall_enabled", wallEnabled)

.appendIf("merge_requests_enabled", mergeRequestsEnabled)

.appendIf("wiki_enabled", wikiEnabled)

.appendIf("snippets_enabled", snippetsEnabled)

.appendIf("visibility", visibility)

.appendIf("import_url", importUrl);

String tailUrl = GitlabProject.URL + "/user/" + userId + query.toString();

return dispatch().to(tailUrl, GitlabProject.class);

}

/**

@Deprecated

public GitlabProject updateProject(

Integer projectId,

String name,

String description,

String defaultBranch,

Boolean issuesEnabled,

Boolean wallEnabled,

Boolean mergeRequestsEnabled,

Boolean wikiEnabled,

Boolean snippetsEnabled,

String visibility)

throws IOException

{

Query query = new Query()

.appendIf("name", name)

.appendIf("description", description)

.appendIf("default_branch", defaultBranch)

.appendIf("issues_enabled", issuesEnabled)

.appendIf("wall_enabled", wallEnabled)

.appendIf("merge_requests_enabled", mergeRequestsEnabled)

.appendIf("wiki_enabled", wikiEnabled)

.appendIf("snippets_enabled", snippetsEnabled)

.appendIf("visibility", visibility);

String tailUrl = GitlabProject.URL + "/" + projectId + query.toString();

return retrieve().method("PUT").to(tailUrl, GitlabProject.class);

}

/**

public void deleteProject(Serializable projectId) throws IOException {

String tailUrl = GitlabProject.URL + "/" + sanitizeProjectId(projectId);

retrieve().method("DELETE").to(tailUrl, null);

}

public List<GitlabMergeRequest> getOpenMergeRequests(Serializable projectId) throws IOException {

return getMergeRequestsWithStatus(projectId, GitlabMergeRequest.STATUS_OPENED);

}

public List<GitlabMergeRequest> getOpenMergeRequests(Serializable projectId, Pagination pagination) throws IOException {

return getMergeRequestsWithStatus(projectId, GitlabMergeRequest.STATUS_OPENED, pagination);

}

public List<GitlabMergeRequest> getOpenMergeRequests(GitlabProject project) throws IOException {

return getMergeRequestsWithStatus(project, GitlabMergeRequest.STATUS_OPENED);

}

public List<GitlabMergeRequest> getOpenMergeRequests(GitlabProject project, Pagination pagination) throws IOException {

return getMergeRequestsWithStatus(project, GitlabMergeRequest.STATUS_OPENED, pagination);

}

public List<GitlabMergeRequest> getMergedMergeRequests(Serializable projectId) throws IOException {

return getMergeRequestsWithStatus(projectId, GitlabMergeRequest.STATUS_MERGED);