package de.svenkubiak.jpushover;
import java.io.IOException;
import java.util.List;
import org.apache.commons.io.IOUtils;
import org.apache.http.Consts;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
import org.apache.http.client.fluent.Form;
import org.apache.http.client.fluent.Request;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.google.common.base.Preconditions;
import de.svenkubiak.jpushover.enums.Constants;
import de.svenkubiak.jpushover.enums.Priority;
import de.svenkubiak.jpushover.enums.Sound;
public class JPushover {
private static final Logger LOG = LoggerFactory.getLogger(JPushover.class);
private String token;
private String user;
private String message;
private String device;
private String title;
private String url;
private String urlTitle;
private String timestamp;
private Priority priority;
private Sound sound;
public JPushover(){
}
/**
* Your application's API token
* (required)
*
* @param token
* @return JPushover instance
*/
public JPushover token(String token) {
this.token = token;
return this;
}
/**
* The user/group key (not e-mail address) of your user (or you),
* viewable when logged into the @see pushover dashboard
* (required)
*
* @param user
* @return JPushover instance
*/
public JPushover user(String user) {
this.user = user;
return this;
}
/**
* Your message
* (required)
*
* @param message
* @return JPushover instance
*/
public JPushover message(String message) {
this.message = message;
return this;
}
/**
* Your user's device name to send the message directly to that device,
* rather than all of the user's devices
* (optional)
*
* @param device
* @return JPushover instance
*/
public JPushover device(String device) {
this.device = device;
return this;
}
/**
* Your message's title, otherwise your app's name is used
* (optional)
*
* @param title
* @return JPushover instance
*/
public JPushover title(String title) {
this.title = title;
return this;
}
/**
* A supplementary URL to show with your message
* (optional)
*
* @param url
* @return JPushover instance
*/
public JPushover url(String url) {
this.url = url;
return this;
}
/**
* A title for your supplementary URL, otherwise just the URL is shown
*
* @param urlTitle
* @return JPushover instance
*/
public JPushover urlTitle(String urlTitle) {
this.urlTitle = urlTitle;
return this;
}
/**
* A Unix timestamp of your message's date and time to display to the user,
* rather than the time your message is received by our API
*
* @param timestamp
* @return JPushover instance
*/
public JPushover timestamp(String timestamp) {
this.timestamp = timestamp;
return this;
}
/**
* Send as LOWESET to generate no notification/alert,
* LOW to always send as a quiet notification,
* NORMAL to display as high-priority and bypass the user's quiet hours,
* or emergence to also require confirmation from the user
* (optional)
*
* @param priority
* @return JPushover instance
*/
public JPushover priority(Priority priority) {
this.priority = priority;
return this;
}
/**
* The name of one of the sounds supported by device clients to override
* the user's default sound choice
* (optional)
*
* @param sound
* @return JPushover instance
*/
public JPushover sound(Sound sound) {
this.sound = sound;
return this;
}
/**
* Send the message to pushover
*/
public JPushoverResponse push() {
Preconditions.checkNotNull(this.token, "Token is required");
Preconditions.checkNotNull(this.user, "User is required");
Preconditions.checkNotNull(this.message, "Message is required");
List params = Form.form()
.add(Constants.TOKEN.value(), this.token)
.add(Constants.USER.value(), this.user)
.add(Constants.MESSAGE.value(), this.message)
.add(Constants.DEVICE.value(), this.device)
.add(Constants.TITLE.value(), this.title)
.add(Constants.URL.value(), this.url)
.add(Constants.URLTITLE.value(), this.urlTitle)
.add(Constants.PRIORITY.value(), this.priority.value())
.add(Constants.TIMESTAMP.value(), this.timestamp)
.add(Constants.SOUND.value(), this.sound.value())
.build();
HttpResponse httpResponse = null;
JPushoverResponse jPushoverResponse = null;
try {
httpResponse = Request.Post(Constants.PUSHOVER_URL.value()).bodyForm(params, Consts.UTF_8).execute().returnResponse();
if (httpResponse != null) {
int status = httpResponse.getStatusLine().getStatusCode();
jPushoverResponse = new JPushoverResponse()
.httpStatus(status)
.response(IOUtils.toString(httpResponse.getEntity().getContent(), Consts.UTF_8))
.isSuccessful((status == 200) ? true : false);
}
} catch (IOException e) {
LOG.error("Failed to send message to pushover", e);
}
return (jPushoverResponse == null) ? new JPushoverResponse().isSuccessful(false) : jPushoverResponse;
}
}