import com.contentful.java.cda.CDAClient; //导入依赖的package包/类
public void requestModels() {
  final CDAClient client = CDAClient.builder()
      .setSpace(VRSpace.SPACE_ID)
      .setToken(VRSpace.ACCESS_TOKEN)
      .build();

  vault.requestSync(client);

  Vault.observeSyncResults()
      .subscribeOn(Schedulers.io())
      .flatMap(new Func1<SyncResult, Observable<Product>>() {
        @Override public Observable<Product> call(SyncResult syncResult) {
          return vault.observe(Product.class).order(Product$Fields.NAME).all();
        }
      })
      .flatMap(new CreateProtoModelAndRenderSign(applicationContext))
      .flatMap(new DownloadMeshAsset(applicationContext))
      .flatMap(new DownloadTextureAsset(applicationContext))
      .observeOn(AndroidSchedulers.mainThread())
      .subscribe(new EnqueueProtoModel());
}
 

import com.contentful.java.cda.CDAClient; //导入依赖的package包/类
public static CDAClient get() {
  synchronized (LOCK) {
    if (instance == null) {
      // Extract credentials from SharedPreferences
      String spaceId = defaultIfBlank(Preferences.getSpaceId(), Const.SPACE_ID);

      String accessToken = defaultIfBlank(Preferences.getAccessToken(), Const.ACCESS_TOKEN);

      instance = CDAClient.builder()
          .setSpaceKey(spaceId)
          .setAccessToken(accessToken)
          .nullifyUnresolvedLinks()
          .build();
    }

    return instance;
  }
}
 

import com.contentful.java.cda.CDAClient; //导入依赖的package包/类
@SuppressWarnings("ConstantConditions")
public static CDAClient get() {
  synchronized (LOCK) {
    if (instance == null) {
      // Extract credentials from SharedPreferences
      String spaceId = defaultIfBlank(Preferences.getSpaceId(), Const.SPACE_ID);

      String accessToken = defaultIfBlank(Preferences.getAccessToken(), Const.ACCESS_TOKEN);

      instance = CDAClient.builder()
          .setSpace(spaceId)
          .setToken(accessToken)
          .build();
    }

    return instance;
  }
}
 

import com.contentful.java.cda.CDAClient; //导入依赖的package包/类
private SyncConfig(Builder builder) {
  this.invalidate = builder.invalidate;

  if (builder.client == null) {
    if (builder.accessToken == null) {
      throw new IllegalStateException("Cannot create a CDA client with no access token. " +
          "Please set it.");
    }

    if (builder.spaceId == null) {
      throw new IllegalStateException("Cannot create a CDA client with no space id. " +
          "Please set it.");
    }

    this.client = CDAClient
        .builder()
        .setToken(builder.accessToken)
        .setSpace(builder.spaceId)
        .setIntegration("Vault", PROJECT_VERSION)
        .build();
  } else {
    this.client = builder.client;
  }
}
 

import com.contentful.java.cda.CDAClient; //导入依赖的package包/类
public Builder setClient(CDAClient client) {
  if (accessToken != null) {
    throw new IllegalStateException(
        "Do not set a client, when an access token is already set. Use either space id and " +
            "a token or a previously created client."
    );
  }
  if (spaceId != null) {
    throw new IllegalStateException(
        "Do not set a client, when a space id is already set. Use either space id and " +
            "a token or a previously created client."
    );
  }

  this.client = client;
  return this;
}
 

import com.contentful.java.cda.CDAClient; //导入依赖的package包/类
public static CDAClient get() {
  synchronized (LOCK) {
    if (instance == null) {
      // Extract credentials from SharedPreferences
      String spaceId = defaultIfBlank(Preferences.getSpaceId(), Const.SPACE_ID);

      String accessToken = defaultIfBlank(Preferences.getAccessToken(), Const.ACCESS_TOKEN);

      instance = CDAClient.builder()
          .setSpace(spaceId)
          .setToken(accessToken)
          .build();
    }

    return instance;
  }
}
 

import com.contentful.java.cda.CDAClient; //导入依赖的package包/类
public synchronized static CDAClient getClient() {
  if (sInstance == null) {
    SharedPreferences prefs = CFPrefs.getInstance();

    String space = prefs.getString(CFPrefs.KEY_SPACE, null);
    String token = prefs.getString(CFPrefs.KEY_ACCESS_TOKEN, null);

    if (StringUtils.isBlank(space) || StringUtils.isBlank(token)) {
      throw new IllegalStateException("Uninitialized client.");
    }

    return init(space, token);
  }

  return sInstance;
}
 

import com.contentful.java.cda.CDAClient; //导入依赖的package包/类
@Override protected ResourceList performLoad(CDAClient client) {
  ResourceList resourceList = new ResourceList();

  FetchQuery<CDAEntry> query =
      client.fetch(CDAEntry.class).where("content_type", contentType.id());

  // Set the locale if non-default locale is currently configured
  String locale = CFClient.getLocale();
  if (locale != null) {
    query.where("locale", locale);
  }

  // Make the request
  CDAArray cdaArray = query.all();
  resourceList.resources = new ArrayList<>();

  // Prepare the result
  resourceList.resources.addAll(cdaArray.entries().values());
  return resourceList;
}
 

import com.contentful.java.cda.CDAClient; //导入依赖的package包/类
private void createVault() {
  if (vault == null) {
    vault = Vault.with(this, EventSpace.class);
    vault.requestSync(CDAClient
        .builder()
        .setToken(EventSpace.DELIVERY_API_KEY)
        .setSpace(EventSpace.SPACE_ID)
        .setCallFactory(createCustomCallFactory())
        .build());
  }
}
 

import com.contentful.java.cda.CDAClient; //导入依赖的package包/类
@Override protected void setupClient() {
  client = CDAClient.builder()
      .setSpace("space")
      .setToken("token")
      .preview()
      .setEndpoint(getServerUrl())
      .build();
}
 

import com.contentful.java.cda.CDAClient; //导入依赖的package包/类
protected void setupClient() {
  client = CDAClient.builder()
      .setSpace("space")
      .setToken("token")
      .setEndpoint(getServerUrl())
      .build();
}
 

import com.contentful.java.cda.CDAClient; //导入依赖的package包/类
@Test
public void createsACustomCDAClient() {
  final SyncConfig syncConfig = SyncConfig
      .builder()
      .setAccessToken("foo")
      .setSpaceId("bar")
      .build();

  final CDAClient client = syncConfig.client();
  assertThat(client).isNotNull();
}
 

import com.contentful.java.cda.CDAClient; //导入依赖的package包/类
public synchronized static CDAClient getClient(Context context) {
  if (client == null) {
    // Create the client
    HashMap<String, Class<?>> classMap = new HashMap<>();
    classMap.put(context.getString(R.string.cda_place_content_type_id), Place.class);

    client = new CDAClient.Builder().setSpaceKey(context.getString(R.string.cda_space_key))
        .setAccessToken(context.getString(R.string.cda_access_token))
        .setCustomClasses(classMap)
        .build();
  }

  return client;
}
 

import com.contentful.java.cda.CDAClient; //导入依赖的package包/类
public synchronized static CDAClient cda() {
  if (sClientCda == null) {
    sClientCda = new CDAClient.Builder()
        .setSpaceKey(CFApp.get().getString(R.string.cf_space_id))
        .setAccessToken(CFApp.get().getString(R.string.cf_token_cda))
        .build();
  }
  return sClientCda;
}
 

import com.contentful.java.cda.CDAClient; //导入依赖的package包/类
/**
 * Initialize this client.
 *
 * @param space String representing the Space key.
 * @param token String representing the access token required to log in to the Space.
 * @return {@link com.contentful.java.cda.CDAClient} instance.
 */
public synchronized static CDAClient init(String space, String token) {
  SharedPreferences prefs = CFPrefs.getInstance();

  prefs.edit()
      .putString(CFPrefs.KEY_SPACE, space)
      .putString(CFPrefs.KEY_ACCESS_TOKEN, token)
      .apply();

  sInstance = CDAClient.builder().setSpace(space).setToken(token).build();

  locale = null;

  return sInstance;
}
 

import com.contentful.java.cda.CDAClient; //导入依赖的package包/类
public static CDAClient getClient() {
  if (sInstance == null) {
    Context context = CFApp.getInstance();

    sInstance =
        CDAClient.builder().setSpace(context.getString(R.string.discovery_space_key))
            .setToken(context.getString(R.string.discovery_space_token))
            .build();
  }

  return sInstance;
}
 

import com.contentful.java.cda.CDAClient; //导入依赖的package包/类
@Override protected ResourceList performLoad() {
  CDAClient client = CFClient.getClient();

  try {
    ResourceList tmp = performLoad(client);
    setContentTypes(client, tmp);
    return tmp;
  } catch (RetrofitError e) {
    e.printStackTrace();
  }

  return null;
}
 

import com.contentful.java.cda.CDAClient; //导入依赖的package包/类
protected void setContentTypes(CDAClient client, ResourceList resourceList) throws RetrofitError {
  HashMap<String, CDAContentType> map = new HashMap<>();
  CDAArray array = client.fetch(CDAContentType.class).all();

  for (CDAResource res : array.items()) {
    map.put(res.id(), (CDAContentType) res);
  }

  resourceList.contentTypes = map;
}
 

import com.contentful.java.cda.CDAClient; //导入依赖的package包/类
@Override protected ResourceList performLoad(CDAClient client) {
  ResourceList resourceList = new ResourceList();
  resourceList.resources = new ArrayList<>();

  for (Object obj : resources) {
    // Filter out any unresolved Links
    if (obj instanceof CDAResource) {
      resourceList.resources.add((CDAResource) obj);
    }
  }

  return resourceList;
}
 

import com.contentful.java.cda.CDAClient; //导入依赖的package包/类
@Override protected ArrayList<ContentTypeWrapper> performLoad() {
  CDAClient client = CFClient.getClient();

  try {
    List<CDAResource> items = client.fetch(CDAContentType.class).all().items();
    ArrayList<ContentTypeWrapper> tmp = new ArrayList<>();

    if (items.size() > 0) {
      for (CDAResource res : items) {
        CDAContentType cdaContentType = (CDAContentType) res;

        // Entries count
        CDAArray entries = client.fetch(CDAEntry.class)
            .where("content_type", cdaContentType.id())
            .where("limit", "1")
            .all();

        ContentTypeWrapper ct = new ContentTypeWrapper(cdaContentType, entries.total());
        tmp.add(ct);
      }
    }

    return tmp;
  } catch (RetrofitError e) {
    e.printStackTrace();
  }

  return null;
}