// This Source Code is in the Public Domain per: http://unlicense.org
package org.litesoft.GWT.shared.service;

import org.litesoft.GWT.shared.rpc.*;

import com.google.gwt.core.client.*;
import com.google.gwt.user.client.*;
import com.google.gwt.user.client.rpc.*;

/**
 * Ensures that async callbacks always execute on UI thread
 */
public class AppServiceAsyncProxy implements AppServiceAsync {
    private final AppServiceAsync mService;

    private AppServiceAsyncProxy( AppServiceAsync pService ) {
        mService = pService;
    }

    public static AppServiceAsync create() {
        return GWT.create( AppService.class );
    }

    public static AppServiceAsync wrap( AppServiceAsync pService ) {
        return new AppServiceAsyncProxy( pService );
    }

    @Override
    public <T extends AppResponse<?>> void get( AppRequest<T> pRequest, final AsyncCallback<T> pCallback ) {
        mService.get( pRequest, new AsyncCallback<T>() {
            @Override
            public void onSuccess( final T pResult ) {
                Scheduler.get().scheduleDeferred( new Command() {
                    @Override
                    public void execute() {
                        pCallback.onSuccess( pResult );
                    }
                } );
            }

            @Override
            public void onFailure( final Throwable pCaught ) {
                Scheduler.get().scheduleDeferred( new Command() {
                    @Override
                    public void execute() {
                        pCallback.onFailure( pCaught );
                    }
                } );
            }
        } );
    }
}