Graphene api find name avaible
This commit is contained in:
parent
dff2dae254
commit
06b02f76d6
1 changed files with 36 additions and 2 deletions
|
@ -6,6 +6,7 @@ import com.neovisionaries.ws.client.WebSocketFactory;
|
||||||
|
|
||||||
import cy.agorise.graphenej.Address;
|
import cy.agorise.graphenej.Address;
|
||||||
import cy.agorise.graphenej.UserAccount;
|
import cy.agorise.graphenej.UserAccount;
|
||||||
|
import cy.agorise.graphenej.api.GetAccountByName;
|
||||||
import cy.agorise.graphenej.api.GetAccounts;
|
import cy.agorise.graphenej.api.GetAccounts;
|
||||||
import cy.agorise.graphenej.api.GetKeyReferences;
|
import cy.agorise.graphenej.api.GetKeyReferences;
|
||||||
import cy.agorise.graphenej.api.GetRelativeAccountHistory;
|
import cy.agorise.graphenej.api.GetRelativeAccountHistory;
|
||||||
|
@ -170,7 +171,40 @@ public class GrapheneApiGenerator {
|
||||||
* @param accountName The account Name to find
|
* @param accountName The account Name to find
|
||||||
* @param request The Api request object, to answer this petition
|
* @param request The Api request object, to answer this petition
|
||||||
*/
|
*/
|
||||||
public static void isAccountNameAvaible(String accountName, ApiRequest request){
|
public static void isAccountNameAvaible(String accountName, final ApiRequest request){
|
||||||
//TODO implement
|
WebSocketFactory factory = new WebSocketFactory().setConnectionTimeout(connectionTimeout);
|
||||||
|
try {
|
||||||
|
final WebSocket webSocket = factory.createSocket(url);
|
||||||
|
webSocket.addListener(new GetAccountByName(accountName, new WitnessResponseListener() {
|
||||||
|
@Override
|
||||||
|
public void onSuccess(WitnessResponse response) {
|
||||||
|
AccountProperties accountProperties = ((WitnessResponse<AccountProperties>) response).result;
|
||||||
|
if(accountProperties != null){
|
||||||
|
request.getListener().success(true,request.getId());
|
||||||
|
}else{
|
||||||
|
request.getListener().success(false,request.getId());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void onError(BaseResponse.Error error) {
|
||||||
|
request.getListener().fail(request.getId());
|
||||||
|
}
|
||||||
|
}));
|
||||||
|
Thread thread = new Thread(){
|
||||||
|
public void run(){
|
||||||
|
try {
|
||||||
|
webSocket.connect();
|
||||||
|
} catch (WebSocketException e) {
|
||||||
|
e.printStackTrace();
|
||||||
|
request.getListener().fail(request.getId());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
};
|
||||||
|
thread.start();
|
||||||
|
} catch (IOException e) {
|
||||||
|
e.printStackTrace();
|
||||||
|
request.getListener().fail(request.getId());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue