adservices/tests/cts/sandbox/topics/providers/sdk1/src/com/android/tests/providers/sdk1/Sdk1.java

/*
 * Copyright (C) 2022 The Android Open Source Project
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package com.android.tests.providers.sdk1;

import android.adservices.clients.topics.AdvertisingTopicsClient;
import android.adservices.topics.GetTopicsResponse;
import android.adservices.topics.Topic;
import android.app.sdksandbox.LoadSdkException;
import android.app.sdksandbox.SandboxedSdk;
import android.app.sdksandbox.SandboxedSdkProvider;
import android.content.Context;
import android.os.Binder;
import android.os.Bundle;
import android.util.Log;
import android.view.View;

import com.google.common.collect.ImmutableSet;

import java.util.concurrent.Executor;
import java.util.concurrent.Executors;

public class Sdk1 extends SandboxedSdkProvider {
    private static final String TAG = "Sdk1";
    private static final Executor CALLBACK_EXECUTOR = Executors.newCachedThreadPool();

    // Override the Epoch Job Period to this value to speed up the epoch computation.
    private static final long TEST_EPOCH_JOB_PERIOD_MS = 6000;

    // Expected Taxonomy version and Model version. This should be changed along with corresponding
    // model change.
    private static final long TAXONOMY_VERSION = 3L;
    private static final long MODEL_VERSION = 3L;

    // Set of classification topics for the Test App. The returned topic should be one of these
    // Topics.
    private static final ImmutableSet<Integer> TOPIC_ID_SET =
            ImmutableSet.of(10147, 10253, 10175, 10254, 10333);

    @Override
    public SandboxedSdk onLoadSdk(Bundle params) throws LoadSdkException {
        try {
            // Make the second call to the Topics API. Since we called the Topics API in the
            // previous epoch, we should have some returned topic now.
            GetTopicsResponse response = callTopicsApi();
            if (response.getTopics().isEmpty()) {
                // Trigger the error callback to tell the Test App that we did not receive
                // any topic. This will tell the Test App to fail the test.
                Log.e(TAG, "Failed. No topics!");
                throw new LoadSdkException(new Exception("Failed. No topics!"), new Bundle());
            } else {
                // Verify the returned Topic.
                Topic topic = response.getTopics().get(0);
                boolean correctResult =
                        TOPIC_ID_SET.contains(topic.getTopicId())
                                && topic.getTaxonomyVersion() == TAXONOMY_VERSION
                                && topic.getModelVersion() == MODEL_VERSION;
                if (correctResult) {
                    // Return a response to tell the Test App that the second Topics
                    // API call got back some topic which is expected. This will tell the Test
                    // App to pass the test.
                    Log.i(TAG, "Get correct returned topic: " + topic.getTopicId());
                    return new SandboxedSdk(new Binder());
                } else {
                    // Throw an exception to tell the test app that we received
                    // a wrong topic. This will tell the Test App to fail the test.
                    Log.e(TAG, "Get wrong returned topic: " + topic.getTopicId());
                    throw new LoadSdkException(
                            new Exception("Failed. Wrong topics!"), new Bundle());
                }
            }
        } catch (Exception e) {
            Log.e(TAG, e.getMessage());
            // Throw an exception to tell the Test App that some errors occurred so
            // that it will fail the test.
            throw new LoadSdkException(e, new Bundle());
        }
    }

    @Override
    public View getView(Context windowContext, Bundle params, int width, int height) {
        return null;
    }

    private GetTopicsResponse callTopicsApi() throws Exception {
        AdvertisingTopicsClient advertisingTopicsClient =
                new AdvertisingTopicsClient.Builder()
                        .setContext(getContext())
                        .setExecutor(CALLBACK_EXECUTOR)
                        .build();

        return advertisingTopicsClient.getTopics().get();
    }
}