package org.linphone.xmlrpc;

import org.linphone.LinphoneManager;
import org.linphone.LinphonePreferences;
import org.linphone.core.LinphoneXmlRpcRequest;
import org.linphone.core.LinphoneXmlRpcRequest.LinphoneXmlRpcRequestListener;
import org.linphone.core.LinphoneXmlRpcRequestImpl;
import org.linphone.core.LinphoneXmlRpcSession;
import org.linphone.core.LinphoneXmlRpcSessionImpl;
import org.linphone.mediastream.Log;

public class XmlRpcHelper {
    public static final String SERVER_ERROR_INVALID_ACCOUNT = "ERROR_INVALID_ACCOUNT";
    public static final String SERVER_RESPONSE_OK = "OK";
    public static final String SERVER_ERROR_INCORRECT_PHONE_NUMBER = "ERROR_PHONE_ISNT_E164";
    public static final String SERVER_ERROR_ACCOUNT_DOESNT_EXIST = "ERROR_ACCOUNT_DOESNT_EXIST";
    public static final String SERVER_ERROR_PURCHASE_CANCELLED = "ERROR_PURCHASE_CANCELLED";
    public static final String SERVER_ERROR_RECEIPT_PARSING_FAILED = "ERROR_RECEIPT_PARSING_FAILED";
    public static final String SERVER_ERROR_UID_ALREADY_IN_USE = "ERROR_UID_ALREADY_IN_USE";
    public static final String SERVER_ERROR_SIGNATURE_VERIFICATION_FAILED = "ERROR_SIGNATURE_VERIFICATION_FAILED";
    public static final String SERVER_ERROR_ACCOUNT_ALREADY_EXISTS = "ERROR_ACCOUNT_ALREADY_EXISTS";
    public static final String SERVER_ERROR_UNKNOWN_ERROR = "ERROR_UNKNOWN_ERROR";
    
    public static final String CLIENT_ERROR_INVALID_SERVER_URL = "INVALID_SERVER_URL";
    public static final String CLIENT_ERROR_SERVER_NOT_REACHABLE = "SERVER_NOT_REACHABLE";

	private LinphoneXmlRpcSession xmlRpcSession;

    public XmlRpcHelper() {
		xmlRpcSession = new LinphoneXmlRpcSessionImpl(LinphoneManager.getLcIfManagerNotDestroyedOrNull(), LinphonePreferences.instance().getInAppPurchaseValidatingServerUrl());
    }
	
	public void createAccountAsync(final XmlRpcListener listener, String username, String email, String password) {
		LinphoneXmlRpcRequest xmlRpcRequest = new LinphoneXmlRpcRequestImpl("create_account", LinphoneXmlRpcRequest.ArgType.String);
		xmlRpcRequest.setListener(new LinphoneXmlRpcRequestListener() {
			@Override
			public void onXmlRpcRequestResponse(LinphoneXmlRpcRequest request) {
				String result = request.getStringResponse();
				if (request.getStatus() == LinphoneXmlRpcRequest.Status.Ok) {
					if (result.startsWith("ERROR_")) {
						Log.e(result);
						listener.onError(result);
						return;
					}
					listener.onAccountCreated(result);
				} else if (request.getStatus() == LinphoneXmlRpcRequest.Status.Failed) {
					Log.e(result);
					listener.onError(result);
				}
			}
		});
		xmlRpcRequest.addStringArg(username);
		xmlRpcRequest.addStringArg(email);
		xmlRpcRequest.addStringArg(password == null ? "" : password);
		xmlRpcSession.sendRequest(xmlRpcRequest);
	}
	
	public void getAccountExpireAsync(final XmlRpcListener listener, String username, String password) {
		LinphoneXmlRpcRequest xmlRpcRequest = new LinphoneXmlRpcRequestImpl("get_account_expiration", LinphoneXmlRpcRequest.ArgType.String);
		xmlRpcRequest.setListener(new LinphoneXmlRpcRequestListener() {
			@Override
			public void onXmlRpcRequestResponse(LinphoneXmlRpcRequest request) {
				String result = request.getStringResponse();
				if (request.getStatus() == LinphoneXmlRpcRequest.Status.Ok) {
					if (result.startsWith("ERROR_")) {
						Log.e(result);
						listener.onError(result);
						return;
					}
					listener.onAccountExpireFetched(result);
				} else if (request.getStatus() == LinphoneXmlRpcRequest.Status.Failed) {
					Log.e(result);
					listener.onError(result);
				}
			}
		});
		xmlRpcRequest.addStringArg(username);
		xmlRpcRequest.addStringArg(password);
		xmlRpcSession.sendRequest(xmlRpcRequest);
	}
	
	public void updateAccountExpireAsync(final XmlRpcListener listener, String username, String password, String domain, String payload, String signature) {
		LinphoneXmlRpcRequest xmlRpcRequest = new LinphoneXmlRpcRequestImpl("update_expiration_date", LinphoneXmlRpcRequest.ArgType.String);
		xmlRpcRequest.setListener(new LinphoneXmlRpcRequestListener() {
			@Override
			public void onXmlRpcRequestResponse(LinphoneXmlRpcRequest request) {
				String result = request.getStringResponse();
				if (request.getStatus() == LinphoneXmlRpcRequest.Status.Ok) {
					if (result.startsWith("ERROR_")) {
						Log.e(result);
						listener.onError(result);
						return;
					}
					listener.onAccountExpireUpdated(result);
				} else if (request.getStatus() == LinphoneXmlRpcRequest.Status.Failed) {
					Log.e(result);
					listener.onError(result);
				}
			}
		});
		xmlRpcRequest.addStringArg(username);
		xmlRpcRequest.addStringArg(password);
		xmlRpcRequest.addStringArg(domain);
		xmlRpcRequest.addStringArg(payload);
		xmlRpcRequest.addStringArg(signature);
		xmlRpcSession.sendRequest(xmlRpcRequest);
	}
	
	public void activateAccountAsync(final XmlRpcListener listener, String username, String password) {
		LinphoneXmlRpcRequest xmlRpcRequest = new LinphoneXmlRpcRequestImpl("activate_account", LinphoneXmlRpcRequest.ArgType.String);
		xmlRpcRequest.setListener(new LinphoneXmlRpcRequestListener() {
			@Override
			public void onXmlRpcRequestResponse(LinphoneXmlRpcRequest request) {
				String result = request.getStringResponse();
				if (request.getStatus() == LinphoneXmlRpcRequest.Status.Ok) {
					if (result.startsWith("ERROR_")) {
						Log.e(result);
						listener.onError(result);
						return;
					}
					listener.onAccountActivated(result);
				} else if (request.getStatus() == LinphoneXmlRpcRequest.Status.Failed) {
					Log.e(result);
					listener.onError(result);
				}
			}
		});
		xmlRpcRequest.addStringArg(username);
		xmlRpcRequest.addStringArg(password);
		xmlRpcSession.sendRequest(xmlRpcRequest);
	}
	
	public void isAccountActivatedAsync(final XmlRpcListener listener, String username) {
		LinphoneXmlRpcRequest xmlRpcRequest = new LinphoneXmlRpcRequestImpl("check_account_activated", LinphoneXmlRpcRequest.ArgType.String);
		xmlRpcRequest.setListener(new LinphoneXmlRpcRequestListener() {
			@Override
			public void onXmlRpcRequestResponse(LinphoneXmlRpcRequest request) {
				String result = request.getStringResponse();
				if (request.getStatus() == LinphoneXmlRpcRequest.Status.Ok) {
					if ("OK".equals(result)) {
						listener.onAccountActivatedFetched(true);
						return;
					} else if (!"ERROR_ACCOUNT_NOT_ACTIVATED".equals(result)) {
						Log.e(result);
						listener.onError(result);
					}
					listener.onAccountActivatedFetched(false);
				} else if (request.getStatus() == LinphoneXmlRpcRequest.Status.Failed) {
					Log.e(result);
					listener.onError(result);
				}
			}
		});
		xmlRpcRequest.addStringArg(username);
		xmlRpcSession.sendRequest(xmlRpcRequest);
	}
	
	public void isTrialAccountAsync(final XmlRpcListener listener, String username, String password) {
		LinphoneXmlRpcRequest xmlRpcRequest = new LinphoneXmlRpcRequestImpl("is_account_trial", LinphoneXmlRpcRequest.ArgType.String);
		xmlRpcRequest.setListener(new LinphoneXmlRpcRequestListener() {
			@Override
			public void onXmlRpcRequestResponse(LinphoneXmlRpcRequest request) {
				String result = request.getStringResponse();
				if (request.getStatus() == LinphoneXmlRpcRequest.Status.Ok) {
					if (!"NOK".equals(result) && !"OK".equals(result)) {
						listener.onError(result);
					}
					listener.onTrialAccountFetched("OK".equals(result));
				} else if (request.getStatus() == LinphoneXmlRpcRequest.Status.Failed) {
					Log.e(result);
					listener.onError(result);
				}
			}
		});
		xmlRpcRequest.addStringArg(username);
		xmlRpcRequest.addStringArg(password);
		xmlRpcSession.sendRequest(xmlRpcRequest);
	}
	
	public void isAccountAsync(final XmlRpcListener listener, String username) {
		LinphoneXmlRpcRequest xmlRpcRequest = new LinphoneXmlRpcRequestImpl("check_account_activated", LinphoneXmlRpcRequest.ArgType.String);
		xmlRpcRequest.setListener(new LinphoneXmlRpcRequestListener() {
			@Override
			public void onXmlRpcRequestResponse(LinphoneXmlRpcRequest request) {
				String result = request.getStringResponse();
				if (request.getStatus() == LinphoneXmlRpcRequest.Status.Ok) {
					if ("OK".equals(result)) {
						listener.onAccountFetched(true);
						return;
					} else if (!"ERROR_ACCOUNT_DOESNT_EXIST".equals(result)) {
						Log.e(result);
						listener.onError(result);
					}
					listener.onAccountFetched(false);
				} else if (request.getStatus() == LinphoneXmlRpcRequest.Status.Failed) {
					Log.e(result);
					listener.onError(result);
				}
			}
		});
		xmlRpcRequest.addStringArg(username);
		xmlRpcSession.sendRequest(xmlRpcRequest);
	}
	
	public void changeAccountEmailAsync(final XmlRpcListener listener, String username, String password, String newEmail) {
		LinphoneXmlRpcRequest xmlRpcRequest = new LinphoneXmlRpcRequestImpl("change_email", LinphoneXmlRpcRequest.ArgType.String);
		xmlRpcRequest.setListener(new LinphoneXmlRpcRequestListener() {
			@Override
			public void onXmlRpcRequestResponse(LinphoneXmlRpcRequest request) {
				String result = request.getStringResponse();
				if (request.getStatus() == LinphoneXmlRpcRequest.Status.Ok) {
					if (result.startsWith("ERROR_")) {
						Log.e(result);
						listener.onError(result);
						return;
					}
					
					listener.onAccountEmailChanged(result);
				} else if (request.getStatus() == LinphoneXmlRpcRequest.Status.Failed) {
					Log.e(result);
					listener.onError(result);
				}
			}
		});
		xmlRpcRequest.addStringArg(username);
		xmlRpcRequest.addStringArg(password);
		xmlRpcRequest.addStringArg(newEmail);
		xmlRpcSession.sendRequest(xmlRpcRequest);
	}
	
	public void changeAccountPasswordAsync(final XmlRpcListener listener, String username, String oldPassword, String newPassword) {
		LinphoneXmlRpcRequest xmlRpcRequest = new LinphoneXmlRpcRequestImpl("change_password", LinphoneXmlRpcRequest.ArgType.String);
		xmlRpcRequest.setListener(new LinphoneXmlRpcRequestListener() {
			@Override
			public void onXmlRpcRequestResponse(LinphoneXmlRpcRequest request) {
				String result = request.getStringResponse();
				if (request.getStatus() == LinphoneXmlRpcRequest.Status.Ok) {
					if (result.startsWith("ERROR_")) {
						Log.e(result);
						listener.onError(result);
						return;
					}
					
					listener.onAccountPasswordChanged(result);
				} else if (request.getStatus() == LinphoneXmlRpcRequest.Status.Failed) {
					Log.e(result);
					listener.onError(result);
				}
			}
		});
		xmlRpcRequest.addStringArg(username);
		xmlRpcRequest.addStringArg(oldPassword);
		xmlRpcRequest.addStringArg(newPassword);
		xmlRpcSession.sendRequest(xmlRpcRequest);
	}
	
	public void changeAccountHashPasswordAsync(final XmlRpcListener listener, String username, String oldPassword, String newPassword) {
		LinphoneXmlRpcRequest xmlRpcRequest = new LinphoneXmlRpcRequestImpl("change_hash", LinphoneXmlRpcRequest.ArgType.String);
		xmlRpcRequest.setListener(new LinphoneXmlRpcRequestListener() {
			@Override
			public void onXmlRpcRequestResponse(LinphoneXmlRpcRequest request) {
				String result = request.getStringResponse();
				if (request.getStatus() == LinphoneXmlRpcRequest.Status.Ok) {
					if (result.startsWith("ERROR_")) {
						Log.e(result);
						listener.onError(result);
						return;
					}
					
					listener.onAccountPasswordChanged(result);
				} else if (request.getStatus() == LinphoneXmlRpcRequest.Status.Failed) {
					Log.e(result);
					listener.onError(result);
				}
			}
		});
		xmlRpcRequest.addStringArg(username);
		xmlRpcRequest.addStringArg(oldPassword);
		xmlRpcRequest.addStringArg(newPassword);
		xmlRpcSession.sendRequest(xmlRpcRequest);
	}
	
	public void sendRecoverPasswordLinkByEmailAsync(final XmlRpcListener listener, String usernameOrEmail) {
		LinphoneXmlRpcRequest xmlRpcRequest = new LinphoneXmlRpcRequestImpl("send_reset_account_password_email", LinphoneXmlRpcRequest.ArgType.String);
		xmlRpcRequest.setListener(new LinphoneXmlRpcRequestListener() {
			@Override
			public void onXmlRpcRequestResponse(LinphoneXmlRpcRequest request) {
				String result = request.getStringResponse();
				if (request.getStatus() == LinphoneXmlRpcRequest.Status.Ok) {
					if (result.startsWith("ERROR_")) {
						Log.e(result);
						listener.onError(result);
						return;
					}
					
					listener.onRecoverPasswordLinkSent(result);
				} else if (request.getStatus() == LinphoneXmlRpcRequest.Status.Failed) {
					Log.e(result);
					listener.onError(result);
				}
			}
		});
		xmlRpcRequest.addStringArg(usernameOrEmail);
		xmlRpcSession.sendRequest(xmlRpcRequest);
	}
	
	public void sendActivateAccountLinkByEmailAsync(final XmlRpcListener listener, String usernameOrEmail) {
		LinphoneXmlRpcRequest xmlRpcRequest = new LinphoneXmlRpcRequestImpl("resend_activation_email", LinphoneXmlRpcRequest.ArgType.String);
		xmlRpcRequest.setListener(new LinphoneXmlRpcRequestListener() {
			@Override
			public void onXmlRpcRequestResponse(LinphoneXmlRpcRequest request) {
				String result = request.getStringResponse();
				if (request.getStatus() == LinphoneXmlRpcRequest.Status.Ok) {
					if (result.startsWith("ERROR_")) {
						Log.e(result);
						listener.onError(result);
						return;
					}
					
					listener.onActivateAccountLinkSent(result);
				} else if (request.getStatus() == LinphoneXmlRpcRequest.Status.Failed) {
					Log.e(result);
					listener.onError(result);
				}
			}
		});
		xmlRpcRequest.addStringArg(usernameOrEmail);
		xmlRpcSession.sendRequest(xmlRpcRequest);
	}
	
	public void sendUsernameByEmailAsync(final XmlRpcListener listener, String email) {
		LinphoneXmlRpcRequest xmlRpcRequest = new LinphoneXmlRpcRequestImpl("recover_username_from_email", LinphoneXmlRpcRequest.ArgType.String);
		xmlRpcRequest.setListener(new LinphoneXmlRpcRequestListener() {
			@Override
			public void onXmlRpcRequestResponse(LinphoneXmlRpcRequest request) {
				String result = request.getStringResponse();
				if (request.getStatus() == LinphoneXmlRpcRequest.Status.Ok) {
					if (result.startsWith("ERROR_")) {
						Log.e(result);
						listener.onError(result);
						return;
					}
					
					listener.onUsernameSent(result);
				} else if (request.getStatus() == LinphoneXmlRpcRequest.Status.Failed) {
					Log.e(result);
					listener.onError(result);
				}
			}
		});
		xmlRpcRequest.addStringArg(email);
		xmlRpcSession.sendRequest(xmlRpcRequest);
	}
	
	public void verifySignatureAsync(final XmlRpcListener listener, String payload, String signature) {
		LinphoneXmlRpcRequest xmlRpcRequest = new LinphoneXmlRpcRequestImpl("check_payload_signature", LinphoneXmlRpcRequest.ArgType.String);
		xmlRpcRequest.setListener(new LinphoneXmlRpcRequestListener() {
			@Override
			public void onXmlRpcRequestResponse(LinphoneXmlRpcRequest request) {
				String result = request.getStringResponse();
				if (request.getStatus() == LinphoneXmlRpcRequest.Status.Ok) {
					Log.w(result);
					if (result.startsWith("ERROR_")) {
						Log.e(result);
						listener.onError(result);
						return;
					}
					
					listener.onSignatureVerified("OK".equals(result));
				} else if (request.getStatus() == LinphoneXmlRpcRequest.Status.Failed) {
					Log.e(result);
					listener.onError(result);
				}
			}
		});
		xmlRpcRequest.addStringArg(payload);
		xmlRpcRequest.addStringArg(signature);
		xmlRpcSession.sendRequest(xmlRpcRequest);
	}

	public void getRemoteProvisioningFilenameAsync(final XmlRpcListener listener,String username, String domain, String password) {
		LinphoneXmlRpcRequest xmlRpcRequest = new LinphoneXmlRpcRequestImpl("get_remote_provisioning_filename", LinphoneXmlRpcRequest.ArgType.String);
		xmlRpcRequest.setListener(new LinphoneXmlRpcRequestListener() {
			@Override
			public void onXmlRpcRequestResponse(LinphoneXmlRpcRequest request) {
				String result = request.getStringResponse();
				if (request.getStatus() == LinphoneXmlRpcRequest.Status.Ok) {
					if (result.startsWith("ERROR_")) {
						Log.e(result);
						listener.onError(result);
						return;
					}

					listener.onRemoteProvisioningFilenameSent(result);
				} else if (request.getStatus() == LinphoneXmlRpcRequest.Status.Failed) {
					Log.e(result);
					listener.onError(result);
				}
			}
		});
		xmlRpcRequest.addStringArg(username);
		xmlRpcRequest.addStringArg(domain);
		xmlRpcRequest.addStringArg(password);
		xmlRpcSession.sendRequest(xmlRpcRequest);
	}
}