package com.pubnub.api;

import javax.crypto.Mac;

import javax.crypto.spec.SecretKeySpec;

import org.json.JSONArray;

import org.json.JSONException;

import java.io.UnsupportedEncodingException;

import java.security.InvalidKeyException;

import java.security.NoSuchAlgorithmException;

import java.util.Date;

import java.util.Hashtable;

import java.util.UUID;

import static com.pubnub.api.PubnubError.PNERROBJ_SECRET_KEY_MISSING;

import static com.pubnub.api.PubnubError.getErrorObject;

/**

* Pubnub object facilitates querying channels for messages and listening on

* channels for presence/message events

*

* @author Pubnub

*

*/

abstract class PubnubCoreShared extends PubnubCore {

/**

* Pubnub Constructor

*

* @param publish_key

* Publish Key

* @param subscribe_key

* Subscribe Key

* @param secret_key

* Secret Key

* @param cipher_key

* Cipher Key

* @param ssl_on

* SSL on ?

*/

public PubnubCoreShared(String publish_key, String subscribe_key, String secret_key,

String cipher_key, boolean ssl_on) {

super(publish_key, subscribe_key, secret_key, cipher_key, ssl_on);

}

/**

* Pubnub Constructor

*

* @param publish_key

* Publish key

* @param subscribe_key

* Subscribe Key

* @param secret_key

* Secret Key

* @param ssl_on

* SSL on ?

*/

public PubnubCoreShared(String publish_key, String subscribe_key, String secret_key,

boolean ssl_on) {

super(publish_key, subscribe_key, secret_key, "", ssl_on);

}

/**

* Pubnub Constructor

*

* @param publish_key

* Publish Key

* @param subscribe_key

* Subscribe Key

*/

public PubnubCoreShared(String publish_key, String subscribe_key) {

super(publish_key, subscribe_key, "", "", false);

}

/**

* @param publish_key

* Publish Key

* @param subscribe_key

* Subscribe Key

* @param ssl

*/

public PubnubCoreShared(String publish_key, String subscribe_key, boolean ssl) {

super(publish_key, subscribe_key, "", "", ssl);

}

/**

* @param publish_key

* @param subscribe_key

* @param secret_key

*/

public PubnubCoreShared(String publish_key, String subscribe_key, String secret_key) {

super(publish_key, subscribe_key, secret_key, "", false);

}

/**

*

* Constructor for Pubnub Class

*

* @param publish_key

* Publish Key

* @param subscribe_key

* Subscribe Key

* @param secret_key

* Secret Key

* @param cipher_key

* Cipher Key

* @param ssl_on

* SSL enabled ?

* @param initialization_vector

* Initialization vector

*/

public PubnubCoreShared(String publish_key, String subscribe_key,

String secret_key, String cipher_key, boolean ssl_on, String initialization_vector) {

super(publish_key, subscribe_key, secret_key, cipher_key, ssl_on, initialization_vector);

}

/**

* Sets value for UUID

*

* @param uuid

* UUID value for Pubnub client

*/

public void setUUID(UUID uuid) {

this.UUID = uuid.toString();

}

public String uuid() {

return java.util.UUID.randomUUID().toString();

}

/**

* This method sets timeout value for subscribe/presence. Default value is

* 310000 milliseconds i.e. 310 seconds

*

* @param timeout

* Timeout value in milliseconds for subscribe/presence

*/

public void setSubscribeTimeout(int timeout) {

super.setSubscribeTimeout(timeout);

}

/**

* This method returns timeout value for subscribe/presence.

*

* @return Timeout value in milliseconds for subscribe/presence

*/

public int getSubscribeTimeout() {

return super.getSubscribeTimeout();

}

/**

* This method set timeout value for non subscribe operations like publish,

* history, hereNow. Default value is 15000 milliseconds i.e. 15 seconds.

*

* @param timeout

* Timeout value in milliseconds for Non subscribe operations

* like publish, history, hereNow

*/

public void setNonSubscribeTimeout(int timeout) {

super.setNonSubscribeTimeout(timeout);

}

/**

* This method returns timeout value for non subscribe operations like publish, history, hereNow

*

* @return Timeout value in milliseconds for for Non subscribe operations like publish, history, hereNow

*/

public int getNonSubscribeTimeout() {

return super.getNonSubscribeTimeout();

}

private String pamSign(String key, String data) throws PubnubException {

Mac sha256_HMAC;

try {

sha256_HMAC = Mac.getInstance("HmacSHA256");

SecretKeySpec secret_key = new SecretKeySpec(key.getBytes(),

"HmacSHA256");

sha256_HMAC.init(secret_key);

byte[] hmacData = sha256_HMAC.doFinal(data.getBytes("UTF-8"));

return new String(Base64Encoder.encode(hmacData)).replace('+', '-')

.replace('/', '_');

} catch (InvalidKeyException e1) {

throw new PubnubException(getErrorObject(PubnubError.PNERROBJ_ULSSIGN_ERROR, 1, "Invalid Key : " + e1.toString()));

} catch (NoSuchAlgorithmException e1) {

throw new PubnubException(getErrorObject(PubnubError.PNERROBJ_ULSSIGN_ERROR, 2, "Invalid Algorithm : " + e1.toString()));

} catch (IllegalStateException e1) {

throw new PubnubException(getErrorObject(PubnubError.PNERROBJ_ULSSIGN_ERROR, 3, "Invalid State : " + e1.toString()));

} catch (UnsupportedEncodingException e1) {

throw new PubnubException(getErrorObject(PubnubError.PNERROBJ_ULSSIGN_ERROR, 4, "Unsupported encoding : " + e1.toString()));

}

}

/** Grant r/w access based on channel and auth key

* @param channel

* @param auth_key

* @param read

* @param write

* @param callback

*/

public void pamGrant(final String channel, String auth_key, boolean read,

boolean write, final Callback callback) {

pamGrant(channel, auth_key, read, write, -1, callback);

}

/** Grant r/w access based on channel

* @param channel

* @param read

* @param write

* @param callback

*/

public void pamGrant(final String channel, boolean read,

boolean write, final Callback callback) {

pamGrant(channel, null, read, write, -1, callback);

}

/** Grant r/w access based on channel

* @param channel

* @param read

* @param write

* @param ttl

* @param callback

*/

public void pamGrant(final String channel, boolean read,

boolean write, int ttl, final Callback callback) {

pamGrant(channel, null, read, write, ttl, callback);

}

/** Grant r/w access based on channel and auth key

* @param channel

* @param auth_key

* @param read

* @param write

* @param ttl

* @param callback

*/

public void pamGrant(final String channel, String auth_key, boolean read,

boolean write, int ttl, Callback callback) {

final Callback cb = getWrappedCallback(callback);

Hashtable parameters = PubnubUtil.hashtableClone(params);

String r = (read) ? "1" : "0";

String w = (write) ? "1" : "0";

String signature = "0";

int timestamp = (int) ((new Date().getTime()) / 1000);

if (this.SECRET_KEY.length() == 0) {

callback.errorCallback(channel,

getErrorObject(PNERROBJ_SECRET_KEY_MISSING, 1));

return;

}

String sign_input = this.SUBSCRIBE_KEY + "\n" + this.PUBLISH_KEY + "\n" + "grant" + "\n" ;

if (auth_key != null && auth_key.length() > 0)

sign_input += "auth=" + PubnubUtil.urlEncode(auth_key) + "&" ;

sign_input += "channel=" + PubnubUtil.urlEncode(channel) + "&" + "pnsdk=" + PubnubUtil.urlEncode(getUserAgent()) + "&" + "r=" + r + "&" + "timestamp=" + timestamp

+ ((ttl >= -1)?"&" + "ttl=" + ttl:"")

+ "&" + "w=" + w;

try {

signature = pamSign(this.SECRET_KEY, sign_input);

} catch (PubnubException e1) {

callback.errorCallback(channel,

e1.getPubnubError());

return;

}

parameters.put("w", w);

parameters.put("timestamp", String.valueOf(timestamp));

parameters.put("signature", signature);

parameters.put("r", r);

parameters.put("channel", channel);

if (auth_key != null && auth_key.length() > 0 ) parameters.put("auth", auth_key);

if (ttl >= -1) parameters.put("ttl", String.valueOf(ttl));

String[] urlComponents = { getPubnubUrl(), "v1", "auth", "grant", "sub-key",

this.SUBSCRIBE_KEY

};

HttpRequest hreq = new HttpRequest(urlComponents, parameters,

new ResponseHandler() {

public void handleResponse(HttpRequest hreq, String response) {

invokeCallback(channel, response, "payload", cb, 4);

}

public void handleError(HttpRequest hreq, PubnubError error) {

cb.errorCallback(channel, error);

return;

}

});

_request(hreq, nonSubscribeManager);

}

public void pamGrantChannelGroup(final String group, boolean read,

boolean management, Callback callback) {

pamGrantChannelGroup(group, read, management, -1, callback);

}

public void pamGrantChannelGroup(final String group, boolean read,

boolean management, int ttl, Callback callback) {

pamGrantChannelGroup(group, null, read, management, ttl, callback);

}

public void pamGrantChannelGroup(final String group, String auth_key, boolean read,

boolean management, Callback callback) {

pamGrantChannelGroup(group, auth_key, read, management, -1, callback);

}

public void pamGrantChannelGroup(final String group, String auth_key, boolean read, boolean management, int ttl,

Callback callback) {

String signature;

final Callback cb = getWrappedCallback(callback);

Hashtable parameters = PubnubUtil.hashtableClone(params);

String r = (read) ? "1" : "0";

String m = (management) ? "1" : "0";

int timestamp = (int) ((new Date().getTime()) / 1000);

if (this.SECRET_KEY.length() == 0) {

callback.errorCallback(group, getErrorObject(PNERROBJ_SECRET_KEY_MISSING, 1));

return;

}

String sign_input = this.SUBSCRIBE_KEY + "\n" + this.PUBLISH_KEY + "\n" + "grant" + "\n";

if (auth_key != null && auth_key.length() > 0)

sign_input += "auth=" + PubnubUtil.urlEncode(auth_key) + "&" ;

sign_input += "channel-group=" + PubnubUtil.urlEncode(group) + "&"

+ "m=" + m + "&"

+ "pnsdk=" + PubnubUtil.urlEncode(getUserAgent()) + "&"

+ "r=" + r + "&"

+ "timestamp=" + timestamp

+ ((ttl >= -1)?"&" + "ttl=" + ttl:"");

try {

signature = pamSign(this.SECRET_KEY, sign_input);

} catch (PubnubException e1) {

callback.errorCallback(group, e1.getPubnubError());

return;

}

parameters.put("timestamp", String.valueOf(timestamp));

parameters.put("signature", signature);

parameters.put("r", r);

parameters.put("m", m);

parameters.put("channel-group", group);

if (ttl >= -1) parameters.put("ttl", String.valueOf(ttl));

if (auth_key != null && auth_key.length() > 0 ) parameters.put("auth", auth_key);

String[] urlComponents = { getPubnubUrl(), "v1", "auth", "grant", "sub-key",

this.SUBSCRIBE_KEY

};

HttpRequest hreq = new HttpRequest(urlComponents, parameters,

new ResponseHandler() {

public void handleResponse(HttpRequest hreq, String response) {

invokeCallback(group, response, "payload", cb, 4);

}

public void handleError(HttpRequest hreq, PubnubError error) {

cb.errorCallback(group, error);

}

});

_request(hreq, nonSubscribeManager);

}

/** ULS Audit

* @param callback

*/

public void pamAudit(Callback callback) {

final Callback cb = getWrappedCallback(callback);

Hashtable parameters = PubnubUtil.hashtableClone(params);

parameters.remove("auth");

String signature = "0";

int timestamp = (int) ((new Date().getTime()) / 1000);

if (this.SECRET_KEY.length() == 0) {

callback.errorCallback("",

getErrorObject(PNERROBJ_SECRET_KEY_MISSING, 2));

return;

}

String sign_input = this.SUBSCRIBE_KEY + "\n" + this.PUBLISH_KEY + "\n"

+ "audit" + "\n" + "pnsdk=" + PubnubUtil.urlEncode(getUserAgent()) + "&"

+ "timestamp=" + timestamp;

try {

signature = pamSign(this.SECRET_KEY, sign_input);

} catch (PubnubException e1) {

callback.errorCallback("",

e1.getPubnubError());

return;

}

parameters.put("timestamp", String.valueOf(timestamp));

parameters.put("signature", signature);

String[] urlComponents = { getPubnubUrl(), "v1", "auth", "audit", "sub-key",

this.SUBSCRIBE_KEY

};

HttpRequest hreq = new HttpRequest(urlComponents, parameters,

new ResponseHandler() {

public void handleResponse(HttpRequest hreq, String response) {

invokeCallback("", response, "payload", cb, 5 );

}

public void handleError(HttpRequest hreq, PubnubError error) {

cb.errorCallback("", error);

return;

}

});

_request(hreq, nonSubscribeManager);

}

/** ULS audit by channel

* @param channel

* @param callback

*/

public void pamAudit(final String channel,

Callback callback) {

final Callback cb = getWrappedCallback(callback);

Hashtable parameters = PubnubUtil.hashtableClone(params);

parameters.remove("auth");

String signature = "0";

int timestamp = (int) ((new Date().getTime()) / 1000);

if (this.SECRET_KEY.length() == 0) {

callback.errorCallback(channel,

getErrorObject(PNERROBJ_SECRET_KEY_MISSING , 3));

return;

}

String sign_input = this.SUBSCRIBE_KEY + "\n" + this.PUBLISH_KEY + "\n"

+ "audit" + "\n" + "channel="

+ PubnubUtil.urlEncode(channel) + "&" + "pnsdk=" + PubnubUtil.urlEncode(getUserAgent()) + "&" + "timestamp=" + timestamp;

try {

signature = pamSign(this.SECRET_KEY, sign_input);

} catch (PubnubException e1) {

callback.errorCallback(channel,

e1.getPubnubError());

return;

}

parameters.put("timestamp", String.valueOf(timestamp));

parameters.put("signature", signature);

parameters.put("channel", channel);

String[] urlComponents = { getPubnubUrl(), "v1", "auth", "audit", "sub-key",

this.SUBSCRIBE_KEY

};

HttpRequest hreq = new HttpRequest(urlComponents, parameters,

new ResponseHandler() {

public void handleResponse(HttpRequest hreq, String response) {

invokeCallback(channel, response, "payload", cb, 6);

}

public void handleError(HttpRequest hreq, PubnubError error) {

cb.errorCallback(channel, error);

return;

}

});

_request(hreq, nonSubscribeManager);

}

/** ULS audit by channel and auth key

* @param channel

* @param auth_key

* @param callback

*/

public void pamAudit(final String channel, String auth_key,

Callback callback) {

final Callback cb = getWrappedCallback(callback);

Hashtable parameters = PubnubUtil.hashtableClone(params);

String signature = "0";

int timestamp = (int) ((new Date().getTime()) / 1000);

if (this.SECRET_KEY.length() == 0) {

callback.errorCallback(channel,

getErrorObject(PNERROBJ_SECRET_KEY_MISSING, 4));

return;

}

String sign_input = this.SUBSCRIBE_KEY + "\n" + this.PUBLISH_KEY + "\n"

+ "audit" + "\n" + "auth=" + PubnubUtil.urlEncode(auth_key) + "&" + "channel="

+ PubnubUtil.urlEncode(channel) + "&" + "pnsdk=" + PubnubUtil.urlEncode(getUserAgent()) + "&" + "timestamp=" + timestamp;

try {

signature = pamSign(this.SECRET_KEY, sign_input);

} catch (PubnubException e1) {

callback.errorCallback(channel,

e1.getPubnubError());

return;

}

parameters.put("timestamp", String.valueOf(timestamp));

parameters.put("signature", signature);

parameters.put("channel", channel);

parameters.put("auth", auth_key);

String[] urlComponents = { getPubnubUrl(), "v1", "auth", "audit", "sub-key",

this.SUBSCRIBE_KEY

};

HttpRequest hreq = new HttpRequest(urlComponents, parameters,

new ResponseHandler() {

public void handleResponse(HttpRequest hreq, String response) {

invokeCallback(channel, response, "payload", cb, 2);

}

public void handleError(HttpRequest hreq, PubnubError error) {

cb.errorCallback(channel, error);

return;

}

});

_request(hreq, nonSubscribeManager);

}

public void pamAuditChannelGroup(final String group, Callback callback) {

pamAuditChannelGroup(group, null, callback);

}

public void pamAuditChannelGroup(final String group, String auth_key, Callback callback) {

String signature;

final Callback cb = getWrappedCallback(callback);

Hashtable parameters = PubnubUtil.hashtableClone(params);

parameters.remove("auth");

int timestamp = (int) ((new Date().getTime()) / 1000);

if (this.SECRET_KEY.length() == 0) {

callback.errorCallback(group, getErrorObject(PNERROBJ_SECRET_KEY_MISSING, 3));

return;

}

String sign_input = this.SUBSCRIBE_KEY + "\n" + this.PUBLISH_KEY + "\n" + "audit" + "\n";

if (auth_key != null && auth_key.length() > 0)

sign_input += "auth=" + auth_key + "&" ;

sign_input += "channel-group=" + PubnubUtil.urlEncode(group) + "&"

+ "pnsdk=" + PubnubUtil.urlEncode(getUserAgent()) + "&"

+ "timestamp=" + timestamp;

try {

signature = pamSign(this.SECRET_KEY, sign_input);

} catch (PubnubException e1) {

callback.errorCallback(group, e1.getPubnubError());

return;

}

parameters.put("timestamp", String.valueOf(timestamp));

parameters.put("signature", signature);

parameters.put("channel-group", group);

if (auth_key != null && auth_key.length() > 0 ) parameters.put("auth", auth_key);

String[] urlComponents = {getPubnubUrl(), "v1", "auth", "audit", "sub-key",

this.SUBSCRIBE_KEY

};

HttpRequest hreq = new HttpRequest(urlComponents, parameters,

new ResponseHandler() {

public void handleResponse(HttpRequest hreq, String response) {

invokeCallback(group, response, "payload", cb, 6);

}

public void handleError(HttpRequest hreq, PubnubError error) {

cb.errorCallback(group, error);

}

});

_request(hreq, nonSubscribeManager);

}

/** ULS revoke by channel and auth key

* @param channel

* @param auth_key

* @param callback

*/

public void pamRevoke(String channel, String auth_key, Callback callback) {

pamGrant(channel, auth_key, false, false, callback);

}

/** ULS revoke by channel

* @param channel

* @param callback

*/

public void pamRevoke(String channel, Callback callback) {

pamGrant(channel, null, false, false, callback);

}

public void pamRevokeChannelGroup(String group, Callback callback) {

pamRevokeChannelGroup(group, null, callback);

}

public void pamRevokeChannelGroup(String group, String auth_key, Callback callback) {

pamGrantChannelGroup(group, auth_key, false, false, -1, callback);

}

/**

* Enable Push Notifications (Google Cloud Messaging)

* @param channel

* Channel for which to enable push notifications

* @param gcmRegistrationId

* Google Cloud Messaging registration id

*/

public void enablePushNotificationsOnChannel(String channel, String gcmRegistrationId) {

enablePushNotificationsOnChannels(new String[]{channel}, gcmRegistrationId, null);

}

/**

* Enable Push Notifications (Google Cloud Messaging)

* @param channels

* Channels for which to enable push notifications

* @param gcmRegistrationId

* Google Cloud Messaging registration id

*/

public void enablePushNotificationsOnChannels(String[] channels, String gcmRegistrationId) {

enablePushNotificationsOnChannels(channels, gcmRegistrationId, null);

}

/**

* Enable Push Notifications (Google Cloud Messaging)

* @param channel

* Channel for which to enable push notifications

* @param gcmRegistrationId

* Google Cloud Messaging registration id

* @param callback

* Callback object

*/

public void enablePushNotificationsOnChannel(String channel, String gcmRegistrationId, Callback callback) {

enablePushNotificationsOnChannels(new String[]{channel}, gcmRegistrationId, callback);

}

/**

* Enable Push Notifications (Google Cloud Messaging)

* @param channels

* Channels for which to enable push notifications

* @param gcmRegistrationId

* Google Cloud Messaging registration id

* @param callback

* Callback object

*/

public void enablePushNotificationsOnChannels(final String[] channels, String gcmRegistrationId, final Callback callback) {

final Callback cb = getWrappedCallback(callback);

Hashtable parameters = PubnubUtil.hashtableClone(params);

String[] urlargs = null;

urlargs = new String[]{ getPubnubUrl(), "v1", "push", "sub-key",

this.SUBSCRIBE_KEY, "devices", gcmRegistrationId

};

parameters.put("type", "gcm");

parameters.put("add", PubnubUtil.joinString(channels, ","));

HttpRequest hreq = new HttpRequest(urlargs, parameters,

new ResponseHandler() {

public void handleResponse(HttpRequest hreq, String response) {

JSONArray jsarr;

try {

jsarr = new JSONArray(response);

} catch (JSONException e) {

handleError(hreq,

PubnubError.getErrorObject(PubnubError.PNERROBJ_INVALID_JSON, 1, response));

return;

}

cb.successCallback("", jsarr);

}

public void handleError(HttpRequest hreq, PubnubError error) {

cb.errorCallback("", error);

return;

}

});

_request(hreq, nonSubscribeManager);

}

/**

* Disable Push Notifications (Google Cloud Messaging)

* @param channel

* Channel for which to disable push notifications

* @param gcmRegistrationId

* Google Cloud Messaging registration id

*/

public void disablePushNotificationsOnChannel(String channel, String gcmRegistrationId) {

disablePushNotificationsOnChannels(new String[]{channel}, gcmRegistrationId, null);

}

/**

* Disable Push Notifications (Google Cloud Messaging)

* @param channels

* Channels for which to disable push notifications

* @param gcmRegistrationId

* Google Cloud Messaging registration id

*/

public void disablePushNotificationsOnChannels(String[] channels, String gcmRegistrationId) {

disablePushNotificationsOnChannels(channels, gcmRegistrationId, null);

}

/**

* Disable Push Notifications (Google Cloud Messaging)

* @param channel

* @param gcmRegistrationId

* @param callback

*/

public void disablePushNotificationsOnChannel(String channel, String gcmRegistrationId, Callback callback) {

disablePushNotificationsOnChannels(new String[]{channel}, gcmRegistrationId, callback);

}

/**

* Disable Push Notifications (Google Cloud Messaging)

* @param channel

* @param callback

*/

/**

* @param channels

* Channels for which to disable push notifications

* @param gcmRegistrationId

* Google Cloud Messaging registration id

* @param callback

* Callback object

*/

public void disablePushNotificationsOnChannels(final String[] channels, String gcmRegistrationId, final Callback callback) {

final Callback cb = getWrappedCallback(callback);

Hashtable parameters = PubnubUtil.hashtableClone(params);

String[] urlargs = null;

urlargs = new String[]{ getPubnubUrl(), "v1", "push", "sub-key",

this.SUBSCRIBE_KEY, "devices", gcmRegistrationId

};

parameters.put("type", "gcm");

parameters.put("remove", PubnubUtil.joinString(channels, ","));

HttpRequest hreq = new HttpRequest(urlargs, parameters,

new ResponseHandler() {

public void handleResponse(HttpRequest hreq, String response) {

JSONArray jsarr;

try {

jsarr = new JSONArray(response);

} catch (JSONException e) {

handleError(hreq,

PubnubError.getErrorObject(PubnubError.PNERROBJ_INVALID_JSON, 1, response));

return;

}

cb.successCallback("", jsarr);

}

public void handleError(HttpRequest hreq, PubnubError error) {

cb.errorCallback("", error);

return;

}

});

_request(hreq, nonSubscribeManager);

}

/**

* Get channels for which push notification is enabled (Google Cloud Messaging)

* @param gcmRegistrationId

* Google Cloud Messaging registration id

* @param callback

* Callback object

*/

public void requestPushNotificationEnabledChannelsForDeviceRegistrationId(String gcmRegistrationId, final Callback callback) {

final Callback cb = getWrappedCallback(callback);

Hashtable parameters = PubnubUtil.hashtableClone(params);

String[] urlargs = null;

urlargs = new String[]{ getPubnubUrl(), "v1", "push", "sub-key",

this.SUBSCRIBE_KEY, "devices", gcmRegistrationId

};

parameters.put("type", "gcm");

HttpRequest hreq = new HttpRequest(urlargs, parameters,

new ResponseHandler() {

public void handleResponse(HttpRequest hreq, String response) {

JSONArray jsarr;

try {

jsarr = new JSONArray(response);

} catch (JSONException e) {

handleError(hreq,

PubnubError.getErrorObject(PubnubError.PNERROBJ_INVALID_JSON, 1, response));

return;

}

cb.successCallback("", jsarr);

}

public void handleError(HttpRequest hreq, PubnubError error) {

cb.errorCallback("", error);

return;

}

});

_request(hreq, nonSubscribeManager);

}

/**

* Disable push notifications for all channels (Google Cloud Messaging)

* @param gcmRegistrationId

* Google Cloud Messaging registration id

*/

public void removeAllPushNotificationsForDeviceRegistrationId(String gcmRegistrationId) {

removeAllPushNotificationsForDeviceRegistrationId(gcmRegistrationId, null);

}

/**

* Disable push notifications for all channels (Google Cloud Messaging)

* @param gcmRegistrationId

* Google Cloud Messaging registration id

* @param callback

* Callback object

*/

public void removeAllPushNotificationsForDeviceRegistrationId(String gcmRegistrationId, final Callback callback) {

final Callback cb = getWrappedCallback(callback);

Hashtable parameters = PubnubUtil.hashtableClone(params);

String[] urlargs = null;

urlargs = new String[]{ getPubnubUrl(), "v1", "push", "sub-key",

this.SUBSCRIBE_KEY, "devices", gcmRegistrationId, "remove"

};

parameters.put("type", "gcm");

HttpRequest hreq = new HttpRequest(urlargs, parameters,

new ResponseHandler() {

public void handleResponse(HttpRequest hreq, String response) {

JSONArray jsarr;

try {

jsarr = new JSONArray(response);

} catch (JSONException e) {

handleError(hreq,

PubnubError.getErrorObject(PubnubError.PNERROBJ_INVALID_JSON, 1, response));

return;

}

cb.successCallback("", jsarr);

}

public void handleError(HttpRequest hreq, PubnubError error) {

cb.errorCallback("", error);

return;

}

});

_request(hreq, nonSubscribeManager);

}

}