import org.jboss.aerogear.android.core.Callback; //导入依赖的package包/类
/**
 * Register PushRegistrar to server to receive push notifications from the specified service
 *
 * @param context   Application context
 * @param registrar PushRegistrar configured for specific application variant
 * @throws RegistrationException
 */
private static void registerToJUPS(final Context context, final PushRegistrar registrar)
        throws RegistrationException {
    registrar.register(context, new Callback<Void>() {
        @Override
        public void onSuccess(Void aVoid) {
            Log.i(TAG, "JUPS registration successful");
            RegistrarManager.registerBackgroundThreadHandler(messageHandler);
        }

        @Override
        public void onFailure(Exception e) {
            Log.w(TAG, "Registration to JUPS failed: " + e);
        }
    });
}
 

import org.jboss.aerogear.android.core.Callback; //导入依赖的package包/类
/**
 * Unregister from receiving push notifications from JBoss Unified Push Server for specified application variant
 *
 * @param context    Application context
 * @param configName Variant config name to unregister
 */
private static void unregisterFromJUPS(final Context context, final String configName) {
    PushRegistrar registrar = RegistrarManager.getRegistrar(configName);
    registrar.unregister(context, new Callback<Void>() {
        @Override
        public void onSuccess(Void aVoid) {
            Log.i(TAG, "Successfully unregistered from JUPS");
            RegistrarManager.unregisterBackgroundThreadHandler(messageHandler);
        }

        @Override
        public void onFailure(Exception e) {
            Log.i(TAG, "Failed to unregister from JUPS: " + e);
        }
    });
}
 

import org.jboss.aerogear.android.core.Callback; //导入依赖的package包/类
public void open(final Callback<EncryptedSQLStore<T>> onReady) {
    new AsyncTask<Void, Void, Void>() {
        private Exception exception;

        @Override
        protected Void doInBackground(Void... params) {
            try {
                EncryptedSQLStore.this.database = getWritableDatabase();
            } catch (Exception e) {
                this.exception = e;
                Log.e(TAG, "There was an error loading the database", e);
            }
            return null;
        }

        @Override
        protected void onPostExecute(Void result) {
            if (exception != null) {
                onReady.onFailure(exception);
            } else {
                onReady.onSuccess(EncryptedSQLStore.this);
            }
        }
    }.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR, (Void[]) null);
}
 

import org.jboss.aerogear.android.core.Callback; //导入依赖的package包/类
public void open(final Callback<SQLStore<T>> onReady) {
    new AsyncTask<Void, Void, Void>() {
        private Exception exception;

        @Override
        protected Void doInBackground(Void... params) {
            try {
                SQLStore.this.database = getWritableDatabase();
            } catch (Exception e) {
                this.exception = e;
                Log.e(TAG, "There was an error loading the database", e);
            }
            return null;
        }

        @Override
        protected void onPostExecute(Void result) {
            if (exception != null) {
                onReady.onFailure(exception);
            } else {
                onReady.onSuccess(SQLStore.this);
            }
        }
    }.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR, (Void[]) null);
}
 

import org.jboss.aerogear.android.core.Callback; //导入依赖的package包/类
@Test
public void testSuccessCallback() throws InterruptedException {
    final CountDownLatch latch = new CountDownLatch(2);
    ((SQLStore) store).open(new Callback<SQLStore<Data>>() {
        @Override
        public void onSuccess(SQLStore<Data> data) {
            latch.countDown();
        }

        @Override
        public void onFailure(Exception e) {
            throw new RuntimeException(e);
        }
    });

    Assert.assertFalse("OnSuccess should be called exactly once!", latch.await(5, TimeUnit.SECONDS));

}
 

import org.jboss.aerogear.android.core.Callback; //导入依赖的package包/类
@Override
public void requestAccess(final Activity activity, final Callback<String> callback) {

    final String state = UUID.randomUUID().toString();

    final OAuth2AuthzService.AGAuthzServiceConnection connection = new OAuth2AuthzService.AGAuthzServiceConnection() {

        @Override
        public void onServiceConnected(ComponentName className, IBinder iBinder) {
            super.onServiceConnected(className, iBinder);
            doRequestAccess(state, activity, callback, this);
        }

    };

    activity.bindService(new Intent(activity.getApplicationContext(), OAuth2AuthzService.class
            ), connection, Context.BIND_AUTO_CREATE
            );

}
 

import org.jboss.aerogear.android.core.Callback; //导入依赖的package包/类
@Override
public void requestAccess(final Activity activity, final Callback<String> callback) {
    final String state = UUID.randomUUID().toString();

    final OAuth2AuthzService.AGAuthzServiceConnection connection = new OAuth2AuthzService.AGAuthzServiceConnection() {

        @Override
        public void onServiceConnected(ComponentName className, IBinder iBinder) {
            super.onServiceConnected(className, iBinder);
            doRequestAccess(state, activity, callback, this);
        }

    };

    activity.bindService(new Intent(activity.getApplicationContext(), OAuth2AuthzService.class
    ), connection, Context.BIND_AUTO_CREATE
    );
}
 

import org.jboss.aerogear.android.core.Callback; //导入依赖的package包/类
@SuppressWarnings("WrongConstant")
@Test
public void testRequestAccess() {
    OAuth2AuthorizationConfiguration config = AuthorizationManager.config("name", OAuth2AuthorizationConfiguration.class);
    config.setBaseURL(BASE_URL);
    OAuth2AuthzModule module = (OAuth2AuthzModule) config.asModule();
    
    Activity mockActivity = mock(Activity.class);
    Callback mockCallback = mock(Callback.class);
    when(mockActivity.bindService(any(Intent.class), any(ServiceConnection.class), any(Integer.class))).thenReturn(Boolean.TRUE);
    when(mockActivity.getApplicationContext()).thenReturn(mockActivity);
    module.requestAccess(mockActivity, mockCallback);

    Mockito.verify(mockActivity, times(1)).bindService((Intent) any(), (ServiceConnection) any(), any(Integer.class));

}
 

import org.jboss.aerogear.android.core.Callback; //导入依赖的package包/类
/**
 * If the OAuth2 Config Object has withIntent set then asModule should return
 * a OAuth2IntentAuthzModule instance.
 */
@Test
public void testIntentPutsAccountOnModule() throws Exception {
    OAuth2AuthorizationConfiguration config = AuthorizationManager.config("name", OAuth2AuthorizationConfiguration.class);
    config.setBaseURL(BASE_URL);
    config.setAccountId("ignore");
    config.setWithIntent(true);
    AuthzModule module = config.asModule();
    Assert.assertNull(UnitTestUtils.getSuperPrivateField(module, "account"));

    Method doRequestAccessMethod = OAuth2IntentAuthzModule.class.getDeclaredMethod("doRequestAccess", String.class, Activity.class, Callback.class, OAuth2AuthzService.AGAuthzServiceConnection.class);
    OAuth2AuthzService.AGAuthzServiceConnection mockConnection = mock(OAuth2AuthzService.AGAuthzServiceConnection.class);
    OAuth2AuthzService mockService = mock(OAuth2AuthzService.class);
    
    Mockito.doReturn(mock(OAuth2AuthzSession.class)).when(mockService).getAccount(any(String.class));
    Mockito.doReturn(true).when(mockService).hasAccount(any(String.class));
    Mockito.doReturn("testToken").when(mockService).fetchAccessToken(any(String.class), any(OAuth2Properties.class));
    
    Mockito.doReturn(mockService).when(mockConnection).getService();
    Looper.prepare();
    
    doRequestAccessMethod.setAccessible(true);
    doRequestAccessMethod.invoke(module, "ignore", mock(Activity.class), mock(Callback.class), mockConnection);
    Assert.assertNotNull(UnitTestUtils.getSuperPrivateField(module, "account"));
    
}
 

import org.jboss.aerogear.android.core.Callback; //导入依赖的package包/类
@Override
public void read(final String id, final Callback<T> callback) {
    THREAD_POOL_EXECUTOR.execute(new Runnable() {
        T result = null;
        Exception exception = null;

        @Override
        public void run() {
            try {
                HeaderAndBody response = restRunner.onRawRead(RestAdapter.this, id);
                List<T> resultList = getResponseParser().handleResponse(response, klass);
                this.result = resultList.get(0);
            } catch (Exception e) {
                Log.e(TAG, e.getMessage(), e);
                this.exception = e;
            }
            if (exception == null) {
                callback.onSuccess(this.result);
            } else {
                callback.onFailure(exception);
            }
        }
    });
}
 

import org.jboss.aerogear.android.core.Callback; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public void remove(final String id, final Callback<Void> callback) {

    THREAD_POOL_EXECUTOR.execute(new Runnable() {
        Exception exception = null;

        @Override
        public void run() {
            try {
                RestAdapter.this.restRunner.onRemove(id);
            } catch (Exception e) {
                exception = e;
            }
            if (exception == null) {
                callback.onSuccess(null);
            } else {
                callback.onFailure(exception);
            }
        }
    });

}
 

import org.jboss.aerogear.android.core.Callback; //导入依赖的package包/类
/**
 * Runs a remove method, returns the result of the call back and makes sure
 * no exceptions are thrown
 */
private <T> void runRemove(Pipe<T> restPipe, String id)
        throws InterruptedException {
    final CountDownLatch latch = new CountDownLatch(1);
    final AtomicBoolean hasException = new AtomicBoolean(false);

    restPipe.remove(id, new Callback<Void>() {
        private static final long serialVersionUID = 1L;

        @Override
        public void onSuccess(Void data) {
            latch.countDown();
        }

        @Override
        public void onFailure(Exception e) {
            hasException.set(true);
            Logger.getLogger(LoaderAdapterTest.class.getSimpleName())
                    .log(Level.SEVERE, e.getMessage(), e);
            latch.countDown();
        }
    });

    latch.await(2, TimeUnit.SECONDS);
    Assert.assertFalse(hasException.get());
}
 

import org.jboss.aerogear.android.core.Callback; //导入依赖的package包/类
private void runSave(Pipe<ListClassId> restPipe)
        throws InterruptedException {
    final CountDownLatch latch = new CountDownLatch(1);
    final AtomicBoolean hasException = new AtomicBoolean(false);

    restPipe.save(new ListClassId(true),
            new Callback<ListClassId>() {
                private static final long serialVersionUID = 1L;

                @Override
                public void onSuccess(ListClassId data) {
                    latch.countDown();
                }

                @Override
                public void onFailure(Exception e) {
                    hasException.set(true);
                    Logger.getLogger(LoaderAdapterTest.class.getSimpleName())
                            .log(Level.SEVERE, e.getMessage(), e);
                    latch.countDown();
                }
            });

    latch.await(2, TimeUnit.SECONDS);
    Assert.assertFalse(hasException.get());
}
 

import org.jboss.aerogear.android.core.Callback; //导入依赖的package包/类
/**
 * Runs a read method, returns the result of the call back and makes sure no
 * exceptions are thrown
 *
 * @param restPipe
 */
private <T> List<T> runRead(Pipe<T> restPipe, ReadFilter readFilter) throws InterruptedException {
    final CountDownLatch latch = new CountDownLatch(1);
    final AtomicBoolean hasException = new AtomicBoolean(false);
    final AtomicReference<List<T>> resultRef = new AtomicReference<List<T>>();

    restPipe.read(readFilter, new Callback<List<T>>() {
        @Override
        public void onSuccess(List<T> data) {
            resultRef.set(data);
            latch.countDown();
        }

        @Override
        public void onFailure(Exception e) {
            hasException.set(true);
            Logger.getLogger(RestAdapterTest.class.getSimpleName()).log(Level.SEVERE, e.getMessage(), e);
            latch.countDown();
        }
    });

    latch.await(2, TimeUnit.SECONDS);
    Assert.assertFalse(hasException.get());

    return resultRef.get();
}
 

import org.jboss.aerogear.android.core.Callback; //导入依赖的package包/类
/**
 * Runs a read method, returns the result of the call back and rethrows the
 * underlying exception
 *
 * @param restPipe
 */
private <T> List<T> runReadForException(Pipe<T> restPipe, ReadFilter readFilter) throws InterruptedException, Exception {
    final CountDownLatch latch = new CountDownLatch(1);
    final AtomicBoolean hasException = new AtomicBoolean(false);
    final AtomicReference<Exception> exceptionref = new AtomicReference<Exception>();
    restPipe.read(readFilter, new Callback<List<T>>() {
        @Override
        public void onSuccess(List<T> data) {
            latch.countDown();
        }

        @Override
        public void onFailure(Exception e) {
            hasException.set(true);
            exceptionref.set(e);
            latch.countDown();
        }
    });

    latch.await(2, TimeUnit.SECONDS);
    Assert.assertTrue(hasException.get());

    throw exceptionref.get();
}
 

import org.jboss.aerogear.android.core.Callback; //导入依赖的package包/类
@SuppressWarnings({"rawtypes", "unchecked"})
@Test
public void testNext() {
    Pipe pipe = mock(Pipe.class);
    ReadFilter next = new ReadFilter();
    List delegate = new ArrayList();
    ReadFilter previous = new ReadFilter();

    next.setLinkUri(URI.create("./next"));
    previous.setLinkUri(URI.create("./previous"));

    WrappingPagedList list = new WrappingPagedList(pipe, delegate, next, previous);
    list.next(mock(Callback.class));
    list.previous(mock(Callback.class));

    verify(pipe).read(eq(next), any(Callback.class));
    verify(pipe).read(eq(previous), any(Callback.class));

}
 

import org.jboss.aerogear.android.core.Callback; //导入依赖的package包/类
private void doAuthorization(OAuth2Properties config, final Callback<String> callback) throws UnsupportedEncodingException, MalformedURLException {

        URL baseURL = config.getBaseURL();
        Uri redirectURL = Uri.parse(config.getRedirectURL());
        
        URL authzURL = OAuth2Utils.buildAuthzURL(config, state);

        final OAuthWebViewDialog dialog = OAuthWebViewDialog.newInstance(authzURL, redirectURL);
        dialog.setReceiver(new OAuthWebViewDialog.OAuthReceiver() {
            @Override
            public void receiveOAuthCode(String code) {
                dialog.removeReceive();
                dialog.dismiss();
                callback.onSuccess(code);
            }

            @Override
            public void receiveOAuthError(final String error) {
                dialog.removeReceive();
                dialog.dismiss();
                callback.onFailure(new OAuth2AuthorizationException(error));
            }
        });

        dialog.setStyle(android.R.style.Theme_Light_NoTitleBar, 0);
        dialog.show(activity.getFragmentManager(), "TAG");
    }
 

import org.jboss.aerogear.android.core.Callback; //导入依赖的package包/类
@UiThreadTest
public void testOAuth2AuthorizationCallback() throws ClassNotFoundException, NoSuchMethodException, InstantiationException, IllegalAccessException,
        IllegalArgumentException, InvocationTargetException, NoSuchFieldException, OAuth2AuthorizationException, InterruptedException {

    OAuth2AuthzService mockService = mock(OAuth2AuthzService.class);
    Activity mockActivity = mock(Activity.class);
    ServiceConnection mockServiceConnection = mock(ServiceConnection.class);

    ArgumentCaptor<OAuth2AuthzSession> sessionCaptor = ArgumentCaptor.forClass(OAuth2AuthzSession.class);

    OAuth2AuthorizationConfiguration config = AuthorizationManager.config("name", OAuth2AuthorizationConfiguration.class);
    config.setAccountId("testAccountId");
    config.setBaseURL(BASE_URL);

    OAuth2AuthzModule module = (OAuth2AuthzModule) config.asModule();
    Class<?> callbackClass = Class.forName("org.jboss.aerogear.android.authorization.oauth2.webview.OAuth2WebViewAuthzModule$OAuth2AuthorizationCallback");
    Constructor<?> constructor = callbackClass.getDeclaredConstructor(OAuth2WebViewAuthzModule.class, Activity.class, Callback.class, ServiceConnection.class);
    constructor.setAccessible(true);

    Callback callback = (Callback) constructor.newInstance(module, mockActivity, new VoidCallback(), mockServiceConnection);

    UnitTestUtils.setPrivateField(module, "service", mockService);

    callback.onSuccess("testCode");

    Mockito.verify(mockService, times(1)).addAccount(sessionCaptor.capture());
    OAuth2AuthzSession account = sessionCaptor.getValue();
    Assert.assertEquals("testCode", account.getAuthorizationCode());
}
 

import org.jboss.aerogear.android.core.Callback; //导入依赖的package包/类
@UiThreadTest
public void testOAuth2AccessCallback() throws ClassNotFoundException, NoSuchMethodException, InstantiationException, IllegalAccessException,
        IllegalArgumentException, InvocationTargetException, NoSuchFieldException {
    OAuth2AuthzService mockService = mock(OAuth2AuthzService.class);
    Activity mockActivity = mock(Activity.class);
    ServiceConnection mockServiceConnection = mock(ServiceConnection.class);
    OAuth2AuthzSession account = new OAuth2AuthzSession();
    account.setAccessToken("testToken");

    when(mockService.getAccount(matches("testAccountId"))).thenReturn(account);

    OAuth2AuthorizationConfiguration config = AuthorizationManager.config("name", OAuth2AuthorizationConfiguration.class);
    config.setAccountId("testAccountId");
    config.setBaseURL(BASE_URL);

    OAuth2AuthzModule module = (OAuth2AuthzModule) config.asModule();
    Class<?> callbackClass = Class.forName("org.jboss.aerogear.android.authorization.oauth2.webview.OAuth2WebViewAuthzModule$OAuth2AccessCallback");
    Constructor<?> constructor = callbackClass.getDeclaredConstructor(OAuth2WebViewAuthzModule.class, Activity.class, Callback.class, ServiceConnection.class);
    constructor.setAccessible(true);

    Callback callback = (Callback) constructor.newInstance(module, mockActivity, new VoidCallback(), mockServiceConnection);

    UnitTestUtils.setPrivateField(module, "service", mockService);

    callback.onSuccess("testToken");

    Mockito.verify(mockActivity, times(1)).unbindService(eq(mockServiceConnection));
    Assert.assertEquals("testToken", ((OAuth2AuthzSession) UnitTestUtils.getSuperPrivateField(module, "account")).getAccessToken());
}
 

import org.jboss.aerogear.android.core.Callback; //导入依赖的package包/类
public ReadLoader(Context context, Callback<List<T>> callback,
                  PipeHandler<T> runner, ReadFilter filter, Pipe<T> pipe) {
    super(context, callback);
    this.filter = filter;
    this.runner = runner;
    this.requestingPipe = pipe;
}