mirror of
https://github.com/jlengrand/github-api.git
synced 2026-03-11 08:21:23 +00:00
Compare commits
18 Commits
github-api
...
github-api
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
83a45f9adc | ||
|
|
d6b1aad91f | ||
|
|
bbf045dbf1 | ||
|
|
a282cd3f74 | ||
|
|
94c307238f | ||
|
|
ac1c003d54 | ||
|
|
01257b4b86 | ||
|
|
9484a5f2ac | ||
|
|
75144f1563 | ||
|
|
f2271e8ee3 | ||
|
|
2e544ed8ed | ||
|
|
0212dce1e8 | ||
|
|
f96fda2d86 | ||
|
|
e413912edd | ||
|
|
c6558c6527 | ||
|
|
a7c63e5d6c | ||
|
|
1f3b8866e7 | ||
|
|
280b8d3b5a |
2
pom.xml
2
pom.xml
@@ -3,7 +3,7 @@
|
|||||||
<groupId>org.kohsuke</groupId>
|
<groupId>org.kohsuke</groupId>
|
||||||
<artifactId>github-api</artifactId>
|
<artifactId>github-api</artifactId>
|
||||||
<packaging>jar</packaging>
|
<packaging>jar</packaging>
|
||||||
<version>1.3</version>
|
<version>1.4</version>
|
||||||
<name>GitHub API for Java</name>
|
<name>GitHub API for Java</name>
|
||||||
<url>http://kohsuke.org/github-api/</url>
|
<url>http://kohsuke.org/github-api/</url>
|
||||||
<description>GitHub API for Java</description>
|
<description>GitHub API for Java</description>
|
||||||
|
|||||||
14
src/main/java/org/kohsuke/github/GHException.java
Normal file
14
src/main/java/org/kohsuke/github/GHException.java
Normal file
@@ -0,0 +1,14 @@
|
|||||||
|
package org.kohsuke.github;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @author Kohsuke Kawaguchi
|
||||||
|
*/
|
||||||
|
public class GHException extends RuntimeException {
|
||||||
|
public GHException(String message) {
|
||||||
|
super(message);
|
||||||
|
}
|
||||||
|
|
||||||
|
public GHException(String message, Throwable cause) {
|
||||||
|
super(message, cause);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -5,6 +5,8 @@ import com.gargoylesoftware.htmlunit.html.HtmlForm;
|
|||||||
import com.gargoylesoftware.htmlunit.html.HtmlPage;
|
import com.gargoylesoftware.htmlunit.html.HtmlPage;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
import java.util.Arrays;
|
||||||
|
import java.util.Collection;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -28,7 +30,7 @@ public class GHOrganization extends GHPerson {
|
|||||||
f.getSelectByName("team_id").getOptionByText(team).setSelected(true);
|
f.getSelectByName("team_id").getOptionByText(team).setSelected(true);
|
||||||
f.submit(f.getButtonByCaption("Create Repository"));
|
f.submit(f.getButtonByCaption("Create Repository"));
|
||||||
|
|
||||||
return root.getUser(login).getRepository(name);
|
return refreshRepository(name);
|
||||||
|
|
||||||
// GHRepository r = new Poster(root).withCredential()
|
// GHRepository r = new Poster(root).withCredential()
|
||||||
// .with("name", name).with("description", description).with("homepage", homepage)
|
// .with("name", name).with("description", description).with("homepage", homepage)
|
||||||
@@ -41,6 +43,24 @@ public class GHOrganization extends GHPerson {
|
|||||||
* Teams by their names.
|
* Teams by their names.
|
||||||
*/
|
*/
|
||||||
public Map<String,GHTeam> getTeams() throws IOException {
|
public Map<String,GHTeam> getTeams() throws IOException {
|
||||||
return root.retrieveWithAuth(root.getApiURL("/organizations/"+login+"/teams"),JsonTeams.class).toMap(this);
|
return root.retrieveWithAuth("/organizations/"+login+"/teams",JsonTeams.class).toMap(this);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public enum Permission { ADMIN, PUSH, PULL }
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Creates a new team and assigns the repositories.
|
||||||
|
*/
|
||||||
|
public GHTeam createTeam(String name, Permission p, Collection<GHRepository> repositories) throws IOException {
|
||||||
|
Poster post = new Poster(root).withCredential().with("team[name]", name).with("team[permission]", p.name().toLowerCase());
|
||||||
|
for (GHRepository r : repositories) {
|
||||||
|
post.with("team[repo_names][]",r.getOwnerName()+'/'+r.getName());
|
||||||
|
}
|
||||||
|
return post.to("/organizations/"+login+"/teams",JsonTeam.class).wrap(this);
|
||||||
|
}
|
||||||
|
|
||||||
|
public GHTeam createTeam(String name, Permission p, GHRepository... repositories) throws IOException {
|
||||||
|
return createTeam(name,p, Arrays.asList(repositories));
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -28,19 +28,25 @@ public abstract class GHPerson {
|
|||||||
/**
|
/**
|
||||||
* Gets the repositories this user owns.
|
* Gets the repositories this user owns.
|
||||||
*/
|
*/
|
||||||
public Map<String,GHRepository> getRepositories() throws IOException {
|
public synchronized Map<String,GHRepository> getRepositories() throws IOException {
|
||||||
if (repositories==null) {
|
if (repositories==null) {
|
||||||
repositories = new TreeMap<String, GHRepository>();
|
repositories = Collections.synchronizedMap(new TreeMap<String, GHRepository>());
|
||||||
URL url = new URL("http://github.com/api/v2/json/repos/show/" + login);
|
repositories.putAll(root.retrieve("/repos/show/" + login, JsonRepositories.class).wrap(root));
|
||||||
for (GHRepository r : MAPPER.readValue(url, JsonRepositories.class).repositories) {
|
|
||||||
r.root = root;
|
|
||||||
repositories.put(r.getName(),r);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
return Collections.unmodifiableMap(repositories);
|
return Collections.unmodifiableMap(repositories);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Fetches the repository of the given name from GitHub, and return it.
|
||||||
|
*/
|
||||||
|
protected GHRepository refreshRepository(String name) throws IOException {
|
||||||
|
if (repositories==null) getRepositories(); // fetch the base first
|
||||||
|
GHRepository r = root.retrieve("/repos/show/" + login + '/' + name, JsonRepository.class).wrap(root);
|
||||||
|
repositories.put(name,r);
|
||||||
|
return r;
|
||||||
|
}
|
||||||
|
|
||||||
public GHRepository getRepository(String name) throws IOException {
|
public GHRepository getRepository(String name) throws IOException {
|
||||||
return getRepositories().get(name);
|
return getRepositories().get(name);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -23,14 +23,23 @@
|
|||||||
*/
|
*/
|
||||||
package org.kohsuke.github;
|
package org.kohsuke.github;
|
||||||
|
|
||||||
|
import com.gargoylesoftware.htmlunit.WebClient;
|
||||||
|
import com.gargoylesoftware.htmlunit.html.HtmlForm;
|
||||||
|
import com.gargoylesoftware.htmlunit.html.HtmlInput;
|
||||||
|
import com.gargoylesoftware.htmlunit.html.HtmlPage;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.net.URL;
|
import java.net.URL;
|
||||||
|
import java.util.AbstractSet;
|
||||||
|
import java.util.ArrayList;
|
||||||
import java.util.Collection;
|
import java.util.Collection;
|
||||||
import java.util.Collections;
|
import java.util.Collections;
|
||||||
import java.util.HashSet;
|
import java.util.HashSet;
|
||||||
|
import java.util.Iterator;
|
||||||
|
import java.util.List;
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
import static java.util.Arrays.asList;
|
import static java.util.Arrays.*;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* A repository on GitHub.
|
* A repository on GitHub.
|
||||||
@@ -52,6 +61,9 @@ public class GHRepository {
|
|||||||
return homepage;
|
return homepage;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* URL of this repository, like 'http://github.com/kohsuke/hudson'
|
||||||
|
*/
|
||||||
public String getUrl() {
|
public String getUrl() {
|
||||||
return url;
|
return url;
|
||||||
}
|
}
|
||||||
@@ -126,7 +138,7 @@ public class GHRepository {
|
|||||||
private void modifyCollaborators(Collection<GHUser> users, String op) throws IOException {
|
private void modifyCollaborators(Collection<GHUser> users, String op) throws IOException {
|
||||||
verifyMine();
|
verifyMine();
|
||||||
for (GHUser user : users) {
|
for (GHUser user : users) {
|
||||||
new Poster(root).withCredential().to(root.getApiURL("/repos/collaborators/"+name+ op +user.getLogin()));
|
new Poster(root).withCredential().to("/repos/collaborators/"+name+ op +user.getLogin());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -134,9 +146,8 @@ public class GHRepository {
|
|||||||
* Deletes this repository.
|
* Deletes this repository.
|
||||||
*/
|
*/
|
||||||
public void delete() throws IOException {
|
public void delete() throws IOException {
|
||||||
verifyMine();
|
|
||||||
Poster poster = new Poster(root).withCredential();
|
Poster poster = new Poster(root).withCredential();
|
||||||
URL url = root.getApiURL("/repos/delete/" + name);
|
String url = "/repos/delete/" + owner +"/"+name;
|
||||||
|
|
||||||
DeleteToken token = poster.to(url, DeleteToken.class);
|
DeleteToken token = poster.to(url, DeleteToken.class);
|
||||||
poster.with("delete_token",token.delete_token).to(url);
|
poster.with("delete_token",token.delete_token).to(url);
|
||||||
@@ -146,7 +157,7 @@ public class GHRepository {
|
|||||||
* Forks this repository.
|
* Forks this repository.
|
||||||
*/
|
*/
|
||||||
public GHRepository fork() throws IOException {
|
public GHRepository fork() throws IOException {
|
||||||
return new Poster(root).withCredential().to(root.getApiURL("/repos/fork/" + owner + "/" + name), JsonRepository.class).wrap(root);
|
return new Poster(root).withCredential().to("/repos/fork/" + owner + "/" + name, JsonRepository.class).wrap(root);
|
||||||
}
|
}
|
||||||
|
|
||||||
private void verifyMine() throws IOException {
|
private void verifyMine() throws IOException {
|
||||||
@@ -154,6 +165,106 @@ public class GHRepository {
|
|||||||
throw new IOException("Operation not applicable to a repository owned by someone else: "+owner);
|
throw new IOException("Operation not applicable to a repository owned by someone else: "+owner);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Returns a set that represents the post-commit hook URLs.
|
||||||
|
* The returned set is live, and changes made to them are reflected to GitHub.
|
||||||
|
*/
|
||||||
|
public Set<URL> getPostCommitHooks() {
|
||||||
|
return postCommitHooks;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Live set view of the post-commit hook.
|
||||||
|
*/
|
||||||
|
private final Set<URL> postCommitHooks = new AbstractSet<URL>() {
|
||||||
|
private List<URL> getPostCommitHooks() {
|
||||||
|
try {
|
||||||
|
verifyMine();
|
||||||
|
|
||||||
|
HtmlForm f = getForm();
|
||||||
|
|
||||||
|
List<URL> r = new ArrayList<URL>();
|
||||||
|
for (HtmlInput i : f.getInputsByName("urls[]")) {
|
||||||
|
String v = i.getValueAttribute();
|
||||||
|
if (v.length()==0) continue;
|
||||||
|
r.add(new URL(v));
|
||||||
|
}
|
||||||
|
return r;
|
||||||
|
} catch (IOException e) {
|
||||||
|
throw new GHException("Failed to retrieve post-commit hooks",e);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Iterator<URL> iterator() {
|
||||||
|
return getPostCommitHooks().iterator();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int size() {
|
||||||
|
return getPostCommitHooks().size();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean add(URL url) {
|
||||||
|
try {
|
||||||
|
String u = url.toExternalForm();
|
||||||
|
|
||||||
|
verifyMine();
|
||||||
|
|
||||||
|
HtmlForm f = getForm();
|
||||||
|
|
||||||
|
List<HtmlInput> controls = f.getInputsByName("urls[]");
|
||||||
|
for (HtmlInput i : controls) {
|
||||||
|
String v = i.getValueAttribute();
|
||||||
|
if (v.length()==0) continue;
|
||||||
|
if (v.equals(u))
|
||||||
|
return false; // already there
|
||||||
|
}
|
||||||
|
|
||||||
|
controls.get(controls.size()-1).setValueAttribute(u);
|
||||||
|
f.submit(null);
|
||||||
|
return true;
|
||||||
|
} catch (IOException e) {
|
||||||
|
throw new GHException("Failed to update post-commit hooks",e);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean remove(Object o) {
|
||||||
|
try {
|
||||||
|
String u = ((URL)o).toExternalForm();
|
||||||
|
|
||||||
|
verifyMine();
|
||||||
|
|
||||||
|
HtmlForm f = getForm();
|
||||||
|
|
||||||
|
List<HtmlInput> controls = f.getInputsByName("urls[]");
|
||||||
|
for (HtmlInput i : controls) {
|
||||||
|
String v = i.getValueAttribute();
|
||||||
|
if (v.length()==0) continue;
|
||||||
|
if (v.equals(u)) {
|
||||||
|
i.setValueAttribute("");
|
||||||
|
f.submit(null);
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return false;
|
||||||
|
} catch (IOException e) {
|
||||||
|
throw new GHException("Failed to update post-commit hooks",e);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private HtmlForm getForm() throws IOException {
|
||||||
|
WebClient wc = root.createWebClient();
|
||||||
|
HtmlPage pg = (HtmlPage)wc.getPage(getUrl()+"/admin");
|
||||||
|
HtmlForm f = (HtmlForm) pg.getElementById("new_service");
|
||||||
|
return f;
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public String toString() {
|
public String toString() {
|
||||||
return "Repository:"+owner+":"+name;
|
return "Repository:"+owner+":"+name;
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
package org.kohsuke.github;
|
package org.kohsuke.github;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.net.URL;
|
import java.util.Map;
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -31,32 +31,36 @@ public class GHTeam {
|
|||||||
* Retrieves the current members.
|
* Retrieves the current members.
|
||||||
*/
|
*/
|
||||||
public Set<GHUser> getMembers() throws IOException {
|
public Set<GHUser> getMembers() throws IOException {
|
||||||
return org.root.retrieveWithAuth(getApiURL("/members"),JsonUsersWithDetails.class).toSet(org.root);
|
return org.root.retrieveWithAuth(api("/members"),JsonUsersWithDetails.class).toSet(org.root);
|
||||||
|
}
|
||||||
|
|
||||||
|
public Map<String,GHRepository> getRepositories() throws IOException {
|
||||||
|
return org.root.retrieveWithAuth(api("/repositories"),JsonRepositories.class).wrap(org.root);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Adds a member to the team.
|
* Adds a member to the team.
|
||||||
*/
|
*/
|
||||||
public void add(GHUser u) throws IOException {
|
public void add(GHUser u) throws IOException {
|
||||||
org.root.retrieveWithAuth(getApiURL("/members?name="+u.getLogin()),null, "POST");
|
org.root.retrieveWithAuth(api("/members?name="+u.getLogin()),null, "POST");
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Removes a member to the team.
|
* Removes a member to the team.
|
||||||
*/
|
*/
|
||||||
public void remove(GHUser u) throws IOException {
|
public void remove(GHUser u) throws IOException {
|
||||||
org.root.retrieveWithAuth(getApiURL("/members?name="+u.getLogin()),null, "DELETE");
|
org.root.retrieveWithAuth(api("/members?name="+u.getLogin()),null, "DELETE");
|
||||||
}
|
}
|
||||||
|
|
||||||
public void add(GHRepository r) throws IOException {
|
public void add(GHRepository r) throws IOException {
|
||||||
org.root.retrieveWithAuth(getApiURL("/repositories?name="+r.getOwnerName()+'/'+r.getName()),null, "POST");
|
org.root.retrieveWithAuth(api("/repositories?name="+r.getOwnerName()+'/'+r.getName()),null, "POST");
|
||||||
}
|
}
|
||||||
|
|
||||||
public void remove(GHRepository r) throws IOException {
|
public void remove(GHRepository r) throws IOException {
|
||||||
org.root.retrieveWithAuth(getApiURL("/repositories?name="+r.getOwnerName()+'/'+r.getName()),null, "DELETE");
|
org.root.retrieveWithAuth(api("/repositories?name="+r.getOwnerName()+'/'+r.getName()),null, "DELETE");
|
||||||
}
|
}
|
||||||
|
|
||||||
private URL getApiURL(String tail) throws IOException {
|
private String api(String tail) {
|
||||||
return org.root.getApiURL("/organizations/"+org.getLogin()+"/teams/"+id+tail);
|
return "/teams/"+id+tail;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -108,14 +108,14 @@ public class GHUser extends GHPerson {
|
|||||||
* Follow this user.
|
* Follow this user.
|
||||||
*/
|
*/
|
||||||
public void follow() throws IOException {
|
public void follow() throws IOException {
|
||||||
new Poster(root).withCredential().to(root.getApiURL("/user/follow/"+login));
|
new Poster(root).withCredential().to("/user/follow/"+login);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Unfollow this user.
|
* Unfollow this user.
|
||||||
*/
|
*/
|
||||||
public void unfollow() throws IOException {
|
public void unfollow() throws IOException {
|
||||||
new Poster(root).withCredential().to(root.getApiURL("/user/unfollow/"+login));
|
new Poster(root).withCredential().to("/user/unfollow/"+login);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|||||||
@@ -34,18 +34,16 @@ import sun.misc.BASE64Encoder;
|
|||||||
|
|
||||||
import java.io.File;
|
import java.io.File;
|
||||||
import java.io.FileInputStream;
|
import java.io.FileInputStream;
|
||||||
import java.io.FileNotFoundException;
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.io.InputStreamReader;
|
import java.io.InputStreamReader;
|
||||||
|
import java.io.InterruptedIOException;
|
||||||
import java.net.HttpURLConnection;
|
import java.net.HttpURLConnection;
|
||||||
import java.net.MalformedURLException;
|
|
||||||
import java.net.URL;
|
import java.net.URL;
|
||||||
import java.util.HashMap;
|
import java.util.HashMap;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
import java.util.Properties;
|
import java.util.Properties;
|
||||||
|
|
||||||
import static org.codehaus.jackson.annotate.JsonAutoDetect.Visibility.ANY;
|
import static org.codehaus.jackson.annotate.JsonAutoDetect.Visibility.*;
|
||||||
import static org.codehaus.jackson.annotate.JsonAutoDetect.Visibility.NONE;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Root of the GitHub API.
|
* Root of the GitHub API.
|
||||||
@@ -54,16 +52,22 @@ import static org.codehaus.jackson.annotate.JsonAutoDetect.Visibility.NONE;
|
|||||||
*/
|
*/
|
||||||
public class GitHub {
|
public class GitHub {
|
||||||
/*package*/ final String login;
|
/*package*/ final String login;
|
||||||
/*package*/ final String token;
|
/*package*/ final String encodedAuthorization;
|
||||||
/*package*/ final String password;
|
final String password;
|
||||||
|
|
||||||
private final Map<String,GHUser> users = new HashMap<String, GHUser>();
|
private final Map<String,GHUser> users = new HashMap<String, GHUser>();
|
||||||
private final Map<String,GHOrganization> orgs = new HashMap<String, GHOrganization>();
|
private final Map<String,GHOrganization> orgs = new HashMap<String, GHOrganization>();
|
||||||
|
|
||||||
private GitHub(String login, String apiToken, String password) {
|
private GitHub(String login, String apiToken, String password) {
|
||||||
this.login = login;
|
this.login = login;
|
||||||
this.token = apiToken;
|
|
||||||
this.password = password;
|
this.password = password;
|
||||||
|
|
||||||
|
BASE64Encoder enc = new sun.misc.BASE64Encoder();
|
||||||
|
if (apiToken!=null || password!=null) {
|
||||||
|
String userpassword = apiToken!=null ? (login + "/token" + ":" + apiToken) : (login + ':'+password);
|
||||||
|
encodedAuthorization = enc.encode(userpassword.getBytes());
|
||||||
|
} else
|
||||||
|
encodedAuthorization = null;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -85,6 +89,10 @@ public class GitHub {
|
|||||||
return new GitHub(login,apiToken,null);
|
return new GitHub(login,apiToken,null);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public static GitHub connect(String login, String apiToken, String password) throws IOException {
|
||||||
|
return new GitHub(login,apiToken,password);
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Connects to GitHub anonymously.
|
* Connects to GitHub anonymously.
|
||||||
*
|
*
|
||||||
@@ -95,49 +103,72 @@ public class GitHub {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/*package*/ void requireCredential() {
|
/*package*/ void requireCredential() {
|
||||||
if (login ==null || token ==null)
|
if (login==null || encodedAuthorization==null)
|
||||||
throw new IllegalStateException("This operation requires a credential but none is given to the GitHub constructor");
|
throw new IllegalStateException("This operation requires a credential but none is given to the GitHub constructor");
|
||||||
}
|
}
|
||||||
|
|
||||||
/*package*/ URL getApiURL(String tail) throws IOException {
|
/*package*/ URL getApiURL(String tailApiUrl) throws IOException {
|
||||||
return new URL("http://github.com/api/v2/json"+tail);
|
return new URL("http://github.com/api/v2/json"+tailApiUrl);
|
||||||
}
|
}
|
||||||
|
|
||||||
/*package*/ <T> T retrieve(String tail, Class<T> type) throws IOException {
|
/*package*/ <T> T retrieve(String tailApiUrl, Class<T> type) throws IOException {
|
||||||
return MAPPER.readValue(getApiURL(tail),type);
|
return _retrieve(tailApiUrl, type, "GET", false);
|
||||||
}
|
}
|
||||||
|
|
||||||
/*package*/ <T> T retrieveWithAuth(URL url, Class<T> type) throws IOException {
|
/*package*/ <T> T retrieveWithAuth(String tailApiUrl, Class<T> type) throws IOException {
|
||||||
return retrieveWithAuth(url,type,"GET");
|
return retrieveWithAuth(tailApiUrl,type,"GET");
|
||||||
}
|
}
|
||||||
/*package*/ <T> T retrieveWithAuth(URL url, Class<T> type, String method) throws IOException {
|
|
||||||
HttpURLConnection uc = (HttpURLConnection) url.openConnection();
|
|
||||||
|
|
||||||
BASE64Encoder enc = new sun.misc.BASE64Encoder();
|
/*package*/ <T> T retrieveWithAuth(String tailApiUrl, Class<T> type, String method) throws IOException {
|
||||||
String userpassword = login + "/token" + ":" + token;
|
return _retrieve(tailApiUrl, type, method, true);
|
||||||
String encodedAuthorization = enc.encode(userpassword.getBytes());
|
}
|
||||||
uc.setRequestProperty("Authorization", "Basic " + encodedAuthorization);
|
|
||||||
uc.setRequestMethod(method);
|
private <T> T _retrieve(String tailApiUrl, Class<T> type, String method, boolean withAuth) throws IOException {
|
||||||
|
while (true) {// loop while API rate limit is hit
|
||||||
try {
|
HttpURLConnection uc = (HttpURLConnection) getApiURL(tailApiUrl).openConnection();
|
||||||
InputStreamReader r = new InputStreamReader(uc.getInputStream(), "UTF-8");
|
|
||||||
if (type==null) {
|
if (withAuth)
|
||||||
String data = IOUtils.toString(r);
|
uc.setRequestProperty("Authorization", "Basic " + encodedAuthorization);
|
||||||
return null;
|
uc.setRequestMethod(method);
|
||||||
|
|
||||||
|
try {
|
||||||
|
InputStreamReader r = new InputStreamReader(uc.getInputStream(), "UTF-8");
|
||||||
|
if (type==null) {
|
||||||
|
String data = IOUtils.toString(r);
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
return MAPPER.readValue(r,type);
|
||||||
|
} catch (IOException e) {
|
||||||
|
handleApiError(e,uc);
|
||||||
}
|
}
|
||||||
return MAPPER.readValue(r,type);
|
|
||||||
} catch (IOException e) {
|
|
||||||
throw (IOException)new IOException(IOUtils.toString(uc.getErrorStream(),"UTF-8")).initCause(e);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* If the error is because of the API limit, wait 10 sec and return normally.
|
||||||
|
* Otherwise throw an exception reporting an error.
|
||||||
|
*/
|
||||||
|
/*package*/ void handleApiError(IOException e, HttpURLConnection uc) throws IOException {
|
||||||
|
if ("0".equals(uc.getHeaderField("X-RateLimit-Remaining"))) {
|
||||||
|
// API limit reached. wait 10 secs and return normally
|
||||||
|
try {
|
||||||
|
Thread.sleep(10000);
|
||||||
|
return;
|
||||||
|
} catch (InterruptedException _) {
|
||||||
|
throw (InterruptedIOException)new InterruptedIOException().initCause(e);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
throw (IOException)new IOException(IOUtils.toString(uc.getErrorStream(),"UTF-8")).initCause(e);
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Obtains the object that represents the named user.
|
* Obtains the object that represents the named user.
|
||||||
*/
|
*/
|
||||||
public GHUser getUser(String login) throws IOException {
|
public GHUser getUser(String login) throws IOException {
|
||||||
GHUser u = users.get(login);
|
GHUser u = users.get(login);
|
||||||
if (u==null) {
|
if (u==null) {
|
||||||
u = MAPPER.readValue(getApiURL("/user/show/"+login), JsonUser.class).user;
|
u = retrieve("/user/show/"+login,JsonUser.class).user;
|
||||||
u.root = this;
|
u.root = this;
|
||||||
users.put(login,u);
|
users.put(login,u);
|
||||||
}
|
}
|
||||||
@@ -160,7 +191,7 @@ public class GitHub {
|
|||||||
public GHOrganization getOrganization(String name) throws IOException {
|
public GHOrganization getOrganization(String name) throws IOException {
|
||||||
GHOrganization o = orgs.get(name);
|
GHOrganization o = orgs.get(name);
|
||||||
if (o==null) {
|
if (o==null) {
|
||||||
o = MAPPER.readValue(getApiURL("/organizations/"+name), JsonOrganization.class).organization;
|
o = retrieve("/organizations/"+name,JsonOrganization.class).organization;
|
||||||
o.root = this;
|
o.root = this;
|
||||||
orgs.put(name,o);
|
orgs.put(name,o);
|
||||||
}
|
}
|
||||||
@@ -184,7 +215,19 @@ public class GitHub {
|
|||||||
public GHRepository createRepository(String name, String description, String homepage, boolean isPublic) throws IOException {
|
public GHRepository createRepository(String name, String description, String homepage, boolean isPublic) throws IOException {
|
||||||
return new Poster(this).withCredential()
|
return new Poster(this).withCredential()
|
||||||
.with("name", name).with("description", description).with("homepage", homepage)
|
.with("name", name).with("description", description).with("homepage", homepage)
|
||||||
.with("public", isPublic ? 1 : 0).to(getApiURL("/repos/create"), JsonRepository.class).wrap(this);
|
.with("public", isPublic ? 1 : 0).to("/repos/create", JsonRepository.class).wrap(this);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Ensures that the credential is valid.
|
||||||
|
*/
|
||||||
|
public boolean isCredentialValid() throws IOException {
|
||||||
|
try {
|
||||||
|
retrieveWithAuth("/user/show",JsonUser.class);
|
||||||
|
return true;
|
||||||
|
} catch (IOException e) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
WebClient createWebClient() throws IOException {
|
WebClient createWebClient() throws IOException {
|
||||||
|
|||||||
@@ -24,10 +24,21 @@
|
|||||||
package org.kohsuke.github;
|
package org.kohsuke.github;
|
||||||
|
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
import java.util.Map;
|
||||||
|
import java.util.TreeMap;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author Kohsuke Kawaguchi
|
* @author Kohsuke Kawaguchi
|
||||||
*/
|
*/
|
||||||
class JsonRepositories {
|
class JsonRepositories {
|
||||||
public List<GHRepository> repositories;
|
public List<GHRepository> repositories;
|
||||||
|
|
||||||
|
public Map<String,GHRepository> wrap(GitHub root) {
|
||||||
|
Map<String,GHRepository> map = new TreeMap<String, GHRepository>();
|
||||||
|
for (GHRepository r : repositories) {
|
||||||
|
r.root = root;
|
||||||
|
map.put(r.getName(),r);
|
||||||
|
}
|
||||||
|
return map;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
13
src/main/java/org/kohsuke/github/JsonTeam.java
Normal file
13
src/main/java/org/kohsuke/github/JsonTeam.java
Normal file
@@ -0,0 +1,13 @@
|
|||||||
|
package org.kohsuke.github;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @author Kohsuke Kawaguchi
|
||||||
|
*/
|
||||||
|
public class JsonTeam {
|
||||||
|
public GHTeam team;
|
||||||
|
|
||||||
|
GHTeam wrap(GHOrganization org) {
|
||||||
|
team.org = org;
|
||||||
|
return team;
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -29,14 +29,13 @@ import java.io.IOException;
|
|||||||
import java.io.InputStreamReader;
|
import java.io.InputStreamReader;
|
||||||
import java.io.OutputStreamWriter;
|
import java.io.OutputStreamWriter;
|
||||||
import java.io.Reader;
|
import java.io.Reader;
|
||||||
|
import java.io.UnsupportedEncodingException;
|
||||||
import java.net.HttpURLConnection;
|
import java.net.HttpURLConnection;
|
||||||
import java.net.URL;
|
|
||||||
import java.net.URLEncoder;
|
import java.net.URLEncoder;
|
||||||
import java.util.HashMap;
|
import java.util.ArrayList;
|
||||||
import java.util.Map;
|
import java.util.List;
|
||||||
import java.util.Map.Entry;
|
|
||||||
|
|
||||||
import static org.kohsuke.github.GitHub.MAPPER;
|
import static org.kohsuke.github.GitHub.*;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Handles HTTP POST.
|
* Handles HTTP POST.
|
||||||
@@ -44,7 +43,8 @@ import static org.kohsuke.github.GitHub.MAPPER;
|
|||||||
*/
|
*/
|
||||||
class Poster {
|
class Poster {
|
||||||
private final GitHub root;
|
private final GitHub root;
|
||||||
private final Map<String,String> args = new HashMap<String, String>();
|
private final List<String> args = new ArrayList<String>();
|
||||||
|
private boolean authenticate;
|
||||||
|
|
||||||
Poster(GitHub root) {
|
Poster(GitHub root) {
|
||||||
this.root = root;
|
this.root = root;
|
||||||
@@ -52,7 +52,8 @@ class Poster {
|
|||||||
|
|
||||||
public Poster withCredential() {
|
public Poster withCredential() {
|
||||||
root.requireCredential();
|
root.requireCredential();
|
||||||
return with("login",root.login).with("token",root.token);
|
authenticate = true;
|
||||||
|
return this;
|
||||||
}
|
}
|
||||||
|
|
||||||
public Poster with(String key, int value) {
|
public Poster with(String key, int value) {
|
||||||
@@ -60,13 +61,18 @@ class Poster {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public Poster with(String key, String value) {
|
public Poster with(String key, String value) {
|
||||||
if (value!=null)
|
if (value!=null) {
|
||||||
this.args.put(key,value);
|
try {
|
||||||
|
args.add(URLEncoder.encode(key,"UTF-8")+'='+URLEncoder.encode(value,"UTF-8"));
|
||||||
|
} catch (UnsupportedEncodingException e) {
|
||||||
|
throw new Error(e); // impossible
|
||||||
|
}
|
||||||
|
}
|
||||||
return this;
|
return this;
|
||||||
}
|
}
|
||||||
|
|
||||||
public void to(URL url) throws IOException {
|
public void to(String tailApiUrl) throws IOException {
|
||||||
to(url,null);
|
to(tailApiUrl,null);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -77,40 +83,41 @@ class Poster {
|
|||||||
* @return
|
* @return
|
||||||
* {@link Reader} that reads the response.
|
* {@link Reader} that reads the response.
|
||||||
*/
|
*/
|
||||||
public <T> T to(URL url, Class<T> type) throws IOException {
|
public <T> T to(String tailApiUrl, Class<T> type) throws IOException {
|
||||||
return to(url,type,"POST");
|
return to(tailApiUrl,type,"POST");
|
||||||
}
|
}
|
||||||
|
|
||||||
public <T> T to(URL url, Class<T> type, String method) throws IOException {
|
public <T> T to(String tailApiUrl, Class<T> type, String method) throws IOException {
|
||||||
HttpURLConnection uc = (HttpURLConnection) url.openConnection();
|
while (true) {// loop while API rate limit is hit
|
||||||
|
HttpURLConnection uc = (HttpURLConnection) root.getApiURL(tailApiUrl).openConnection();
|
||||||
|
|
||||||
uc.setDoOutput(true);
|
uc.setDoOutput(true);
|
||||||
uc.setRequestProperty("Content-type","application/x-www-form-urlencoded");
|
uc.setRequestProperty("Content-type","application/x-www-form-urlencoded");
|
||||||
uc.setRequestMethod(method);
|
if (authenticate)
|
||||||
|
uc.setRequestProperty("Authorization", "Basic " + root.encodedAuthorization);
|
||||||
|
uc.setRequestMethod(method);
|
||||||
|
|
||||||
|
|
||||||
StringBuilder body = new StringBuilder();
|
StringBuilder body = new StringBuilder();
|
||||||
for (Entry<String, String> e : args.entrySet()) {
|
for (String e : args) {
|
||||||
if (body.length()>0) body.append('&');
|
if (body.length()>0) body.append('&');
|
||||||
body.append(URLEncoder.encode(e.getKey(),"UTF-8"));
|
body.append(e);
|
||||||
body.append('=');
|
}
|
||||||
body.append(URLEncoder.encode(e.getValue(),"UTF-8"));
|
|
||||||
}
|
OutputStreamWriter o = new OutputStreamWriter(uc.getOutputStream(), "UTF-8");
|
||||||
|
o.write(body.toString());
|
||||||
OutputStreamWriter o = new OutputStreamWriter(uc.getOutputStream(), "UTF-8");
|
o.close();
|
||||||
o.write(body.toString());
|
|
||||||
o.close();
|
try {
|
||||||
|
InputStreamReader r = new InputStreamReader(uc.getInputStream(), "UTF-8");
|
||||||
|
if (type==null) {
|
||||||
try {
|
String data = IOUtils.toString(r);
|
||||||
InputStreamReader r = new InputStreamReader(uc.getInputStream(), "UTF-8");
|
return null;
|
||||||
if (type==null) {
|
}
|
||||||
String data = IOUtils.toString(r);
|
return MAPPER.readValue(r,type);
|
||||||
return null;
|
} catch (IOException e) {
|
||||||
|
root.handleApiError(e,uc);
|
||||||
}
|
}
|
||||||
return MAPPER.readValue(r,type);
|
|
||||||
} catch (IOException e) {
|
|
||||||
throw (IOException)new IOException(IOUtils.toString(uc.getErrorStream(),"UTF-8")).initCause(e);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,25 +1,31 @@
|
|||||||
package org.kohsuke;
|
package org.kohsuke;
|
||||||
|
|
||||||
import junit.framework.Test;
|
|
||||||
import junit.framework.TestCase;
|
import junit.framework.TestCase;
|
||||||
import junit.framework.TestSuite;
|
|
||||||
import org.kohsuke.github.GHOrganization;
|
import org.kohsuke.github.GHOrganization;
|
||||||
|
import org.kohsuke.github.GHOrganization.Permission;
|
||||||
import org.kohsuke.github.GHRepository;
|
import org.kohsuke.github.GHRepository;
|
||||||
import org.kohsuke.github.GHTeam;
|
import org.kohsuke.github.GHTeam;
|
||||||
import org.kohsuke.github.GitHub;
|
import org.kohsuke.github.GitHub;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
import java.net.URL;
|
||||||
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Unit test for simple App.
|
* Unit test for simple App.
|
||||||
*/
|
*/
|
||||||
public class AppTest extends TestCase {
|
public class AppTest extends TestCase {
|
||||||
|
public void testCredentialValid() throws IOException {
|
||||||
|
assertTrue(GitHub.connect().isCredentialValid());
|
||||||
|
assertFalse(GitHub.connect("totally","bogus").isCredentialValid());
|
||||||
|
}
|
||||||
|
|
||||||
public void testApp() throws IOException {
|
public void testApp() throws IOException {
|
||||||
GitHub gitHub = GitHub.connect();
|
GitHub gitHub = GitHub.connect();
|
||||||
GHOrganization labs = gitHub.getOrganization("HudsonLabs");
|
// testOrganization(gitHub);
|
||||||
GHTeam t = labs.getTeams().get("Core Developers");
|
// testPostCommitHook(gitHub);
|
||||||
|
|
||||||
t.add(labs.getRepository("xyz"));
|
// tryTeamCreation(gitHub);
|
||||||
|
|
||||||
// t.add(gitHub.getMyself());
|
// t.add(gitHub.getMyself());
|
||||||
// System.out.println(t.getMembers());
|
// System.out.println(t.getMembers());
|
||||||
@@ -35,4 +41,26 @@ public class AppTest extends TestCase {
|
|||||||
//
|
//
|
||||||
// System.out.println(hub.getUser("kohsuke").getRepository("hudson").getCollaborators());
|
// System.out.println(hub.getUser("kohsuke").getRepository("hudson").getCollaborators());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private void tryTeamCreation(GitHub gitHub) throws IOException {
|
||||||
|
GHOrganization o = gitHub.getOrganization("HudsonLabs");
|
||||||
|
GHTeam t = o.createTeam("auto team", Permission.PUSH);
|
||||||
|
t.add(o.getRepository("auto-test"));
|
||||||
|
}
|
||||||
|
|
||||||
|
private void testPostCommitHook(GitHub gitHub) throws IOException {
|
||||||
|
GHRepository r = gitHub.getMyself().getRepository("foo");
|
||||||
|
Set<URL> hooks = r.getPostCommitHooks();
|
||||||
|
hooks.add(new URL("http://kohsuke.org/test"));
|
||||||
|
System.out.println(hooks);
|
||||||
|
hooks.remove(new URL("http://kohsuke.org/test"));
|
||||||
|
System.out.println(hooks);
|
||||||
|
}
|
||||||
|
|
||||||
|
private void testOrganization(GitHub gitHub) throws IOException {
|
||||||
|
GHOrganization labs = gitHub.getOrganization("HudsonLabs");
|
||||||
|
GHTeam t = labs.getTeams().get("Core Developers");
|
||||||
|
|
||||||
|
t.add(labs.getRepository("xyz"));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user