Skip to content
GitLab
Commit ebb6607b authored by gmessner's avatar gmessner
Browse files

Removed classes that are now in the gitlab-webhook package.

parent ac38a284
Hide whitespace changes
Inline Side-by-side
src/main/java/com/messners/gitlab/api/webhook/WebHookApplication.java deleted 100644 → 0
View file @ ac38a284
package com.messners.gitlab.api.webhook;
import javax.ws.rs.core.Application;
import java.util.HashSet;
import java.util.Set;
public class WebHookApplication extends Application {
@Override
public Set<Class<?>> getClasses () {
Set<Class<?>> resources = new HashSet<Class<?>>();
resources.add(WebHookResource.class);
return (resources);
}
}
\ No newline at end of file
src/main/java/com/messners/gitlab/api/webhook/WebHookListener.java deleted 100644 → 0
View file @ ac38a284
package com.messners.gitlab.api.webhook;
/**
* This class defines an event listener for the event fired when
* a WebHook notification has been received from a GitLab server.
*
* @author Greg Messner <gmessner@messners.com>
*/
public interface WebHookListener extends java.util.EventListener {
/**
* This method is called when a WebHook issue notification has been received.
*
* @param event the EventObject instance containing info on the issue
*/
public void onIssue (EventObject event);
/**.
* This method is called when a WebHook merge request notification has been received
*
* @param event the EventObject instance containing info on the merge request
*/
public void onMergeRequest (EventObject event);
/**
* This method is called when a WebHook push notification has been received.
*
* @param pushEvent the PushEvent instance
*/
public void onPush (PushEvent pushEvent);
}
src/main/java/com/messners/gitlab/api/webhook/WebHookResource.java deleted 100644 → 0
View file @ ac38a284
package com.messners.gitlab.api.webhook;
import java.io.IOException;
import java.io.Reader;
import java.util.ArrayList;
import java.util.List;
import javax.servlet.http.HttpServletRequest;
import javax.ws.rs.Consumes;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.core.Context;
import javax.ws.rs.core.MediaType;
import org.codehaus.jackson.JsonParseException;
import org.codehaus.jackson.map.JsonMappingException;
import org.codehaus.jackson.map.ObjectMapper;
import com.messners.gitlab.api.JacksonJsonConfig;
/**
* WebHookResource
*
* This class provides endpoint for GitLab WebHook callouts.
*
* @author Greg Messner <greg@messners.com>
*/
@Path("/webhook")
public class WebHookResource {
@Context HttpServletRequest request;
@POST
@Consumes(MediaType.APPLICATION_JSON)
@Path("/issue")
public void issue () {
try {
EventObject issueEvent = WebHookResource.unmarshall(EventObject.class, request.getReader());
WebHookResource.fireIssueEvent(issueEvent);
} catch (JsonParseException jpe) {
System.err.println("Error parsing JSON data, error=" + jpe.getMessage());
} catch (JsonMappingException jme) {
System.err.println("Error mapping JSON data, error=" + jme.getMessage());
} catch (IOException ioe) {
System.err.println("Error reading JSON data, error=" + ioe.getMessage());
}
}
@POST
@Consumes(MediaType.APPLICATION_JSON)
@Path("/merge-request")
public void megeRequest () {
try {
EventObject mergeRequest = WebHookResource.unmarshall(EventObject.class, request.getReader());;
WebHookResource.fireMergeRequestEvent(mergeRequest);
} catch (JsonParseException jpe) {
System.err.println("Error parsing JSON data, error=" + jpe.getMessage());
} catch (JsonMappingException jme) {
System.err.println("Error mapping JSON data, error=" + jme.getMessage());
} catch (IOException ioe) {
System.err.println("Error reading JSON data, error=" + ioe.getMessage());
}
}
@POST
@Consumes(MediaType.APPLICATION_JSON)
@Path("/push")
public void push () {
try {
PushEvent pushEvent = WebHookResource.unmarshall(PushEvent.class, request.getReader());
WebHookResource.firePushEvent(pushEvent);
} catch (JsonParseException jpe) {
System.err.println("Error parsing JSON data, error=" + jpe.getMessage());
} catch (JsonMappingException jme) {
System.err.println("Error mapping JSON data, error=" + jme.getMessage());
} catch (IOException ioe) {
System.err.println("Error reading JSON data, error=" + ioe.getMessage());
}
}
private static final JacksonJsonConfig jacksonJsonConfig = new JacksonJsonConfig();
private static <T> T unmarshall (Class<T> returnType, Reader reader)
throws JsonParseException, JsonMappingException, IOException {
ObjectMapper objectMapper = jacksonJsonConfig.getContext(returnType);
return (objectMapper.readValue(reader, returnType));
}
/**
* Collection of objects listening for WebHook events.
*/
private static ArrayList<WebHookListener> webhookListeners = new ArrayList<WebHookListener>();
/**
* Adds a WebHook event listener.
*
* @param listener the WebHookListener to add
*/
public static synchronized void addListener (WebHookListener listener) {
if (!webhookListeners.contains(listener)) {
webhookListeners.add(listener);
}
}
/**
* Removes a WebHook event listener.
*
* @param listener the WebHookListener to remove
*/
public static synchronized void removeListener (WebHookListener listener) {
webhookListeners.remove(listener);
}
/**
* Make a copy of the listener object ArrayList so that it cannot
* be changed while we are firing events
*
* @return a copy of the WebHookListener list, or null if no listeners have been added
*/
protected static synchronized List<WebHookListener> getListenerListCopy () {
synchronized (WebHookResource.class) {
if (webhookListeners.size() < 1) {
return (null);
}
List<WebHookListener> listeners = new ArrayList<WebHookListener>(webhookListeners.size());
for (WebHookListener listener : webhookListeners) {
listeners.add(listener);
}
return (listeners);
}
}
protected static void fireIssueEvent (EventObject issueEvent) {
List<WebHookListener> listeners = getListenerListCopy();
if (listeners == null) {
return;
}
/*
* Fire the event to all listeners
*/
for (WebHookListener listener : listeners) {
listener.onIssue(issueEvent);
}
}
protected static void fireMergeRequestEvent (EventObject mergeRequestEvent) {
List<WebHookListener> listeners = getListenerListCopy();
if (listeners == null) {
return;
}
/*
* Fire the event to all listeners
*/
for (WebHookListener listener : listeners) {
listener.onMergeRequest(mergeRequestEvent);
}
}
protected static void firePushEvent (PushEvent pushEvent) {
List<WebHookListener> listeners = getListenerListCopy();
if (listeners == null) {
return;
}
/*
* Fire the event to all listeners
*/
for (WebHookListener listener : listeners) {
listener.onPush(pushEvent);
}
}
}
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment