IDSync

IdentityApiRequest identityRequest = IdentityApiRequest.withEmptyUser()
    //the IdentityApiRequest provides several convenience methods for common identity types
    .email("foo@example.com")
    .customerId("123456")
    //alternatively, you can use the setUserIdentity method and supply the MPUserIdentity type
    .userIdentity(MParticle.IdentityType.Other, "example-other-id")
    .build();

val identityRequest = IdentityApiRequest.withEmptyUser().run {
    //the IdentityApiRequest provide convenience methods for common identity types
    email("foo@example.com")
    customerId("123456")
    //alternatively, you can use the setUserIdentity method and supply the MPUserIdentity type
    userIdentity(MParticle.IdentityType.Other, "example-other-id")
    build()
}

public class ExampleApplication extends Application {

    @Override
    public void onCreate() {
        super.onCreate();

        IdentityApiRequest identityRequest = IdentityApiRequest.withEmptyUser()
                .email("foo@example.com")
                .customerId("123456")
                .build();

        BaseIdentityTask identifyTask = new BaseIdentityTask()
                .addFailureListener(new TaskFailureListener() {
                    @Override
                    public void onFailure(IdentityHttpResponse identityHttpResponse) {
                        //handle failure - see below
                    }
                }).addSuccessListener(new TaskSuccessListener() {
                    @Override
                    public void onSuccess(IdentityApiResult identityApiResult) {
                        MParticleUser user = identityApiResult.getUser();
                        user.setUserAttribute("example attribute key", "example attribute value");
                    }
                });

        MParticleOptions options = MParticleOptions.builder(this)
                .credentials("REPLACE WITH API KEY", "REPLACE WITH API SECRET")
                .identify(identityRequest)
                .identifyTask(identifyTask)
                .build();
        MParticle.start(options);
    }
}

class ExampleApplication : Application() {
    override fun onCreate() {
        super.onCreate()
        val identityRequest = IdentityApiRequest.withEmptyUser()
            .email("foo@example.com")
            .customerId("123456")
            .build()

        val identifyTask = BaseIdentityTask()
            .addFailureListener { identityHttpResponse ->
                //handle failure - see below
            }.addSuccessListener { identityApiResult ->
                val user = identityApiResult.user
                user.setUserAttribute("example attribute key", "example attribute value")
            }

        val options = MParticleOptions.builder(this)
            .credentials("REPLACE WITH API KEY", "REPLACE WITH API SECRET")
            .identify(identityRequest)
            .identifyTask(identifyTask)
            .build()
        MParticle.start(options)
    }
}

// Define your identityRequest
IdentityApiRequest identityRequest = IdentityApiRequest.withEmptyUser()
    // Include any identities you want to associate with the logged in user here. See "Create an IDSync request" above for more details.
    // This example shows the addition of the email identity.
    .email("foo@example.com").build();

// Call the login method, passing in the identityRequest you just created
MParticle.getInstance().Identity().login(identityRequest);

// Define your identityRequest
val identityRequest = IdentityApiRequest.withEmptyUser()
    // Include any identities you want to associate with the logged in user here. See "Create an IDSync request" above for more details.
    // This example shows the addition of the email identity.
    .email("foo@example.com").build()

// Call the login method, passing in the identityRequest you just created
MParticle.getInstance().Identity().login(identityRequest)

MParticle.getInstance().Identity().logout();

// exluding the identity request from any IDSync API is the same as invoking the following:
MParticle.getInstance().Identity().logout(IdentityApiRequest.withEmptyUser().build());

MParticle.getInstance().Identity().logout()

// exluding the identity request from any IDSync API is the same as invoking the following:
MParticle.getInstance().Identity().logout(IdentityApiRequest.withEmptyUser().build())

IdentityApiRequest modifyRequest = IdentityApiRequest.withEmptyUser()
        .email("updated-email@example.com")
        .build();

MParticle.getInstance().Identity().modify(modifyRequest);

IdentityApiRequest modifyRequest = IdentityApiRequest.withEmptyUser()
        .email("updated-email@example.com")
        .build()

MParticle.getInstance().Identity().modify(modifyRequest)

IdentityApiRequest modifyRequest = IdentityApiRequest.withEmptyUser()
        .email(null)
        .build();

MParticle.getInstance().Identity().modify(modifyRequest);

val modifyRequest = IdentityApiRequest.withEmptyUser()
        .email(null)
        .build()

MParticle.getInstance().Identity().modify(modifyRequest)

MParticle.getInstance().Identity().login(identityRequest)
    .addFailureListener(new TaskFailureListener() {
        @Override
        public void onFailure(IdentityHttpResponse identityHttpResponse) {
            if (identityHttpResponse.getHttpCode() == IdentityApi.UNKNOWN_ERROR) {
                //device is likely offline and request should be retried
            } else if (identityHttpResponse.getHttpCode() == IdentityApi.THROTTLE_ERROR) {
               //on rare occurances you may receive and retry throttling errors (429)
            }
            Log.d("IDSync Error", identityHttpResponse.toString());
        }
    })
    .addSuccessListener(new TaskSuccessListener() {
        @Override
        public void onSuccess(IdentityApiResult identityApiResult) {
            //proceed with login
        }
    });

MParticle.getInstance().Identity().login(identityRequest)
    .addFailureListener { identityHttpResponse ->
        if (identityHttpResponse.httpCode == IdentityApi.UNKNOWN_ERROR) {
            //device is likely offline and request should be retried
        } else if (identityHttpResponse.httpCode == IdentityApi.THROTTLE_ERROR) {
            //on rare occurances you may receive and retry throttling errors (429)
        }
        Log.d("IDSync Error", identityHttpResponse.toString())
    }
    .addSuccessListener {
        //proceed with login
    }

// Basic - Call alias as the result of a successful login
MParticle.getInstance().Identity().login()
    .addSuccessListener(new TaskSuccessListener() {
        @Override
        public void onSuccess(@NonNull IdentityApiResult result) {
            login request returns new and previous users
            MParticleUser newUser = result.getUser();
            MParticleUser previousUser = result.getPreviousUser();
            
            // Copy anything attributes and products from previous to new user
            // this example copies everything
            newUser.setUserAttributes(previousUser.getUserAttributes());

            // Create and send the alias request
            AliasRequest request = AliasRequest
                    .builder(previousUser, newUser)
                    .build();
            MParticle.getInstance().Identity().aliasUsers(request);
        }
    });

// Call alias at any time 

// The getUsers() API now returns users in reverse chronological order
MParticleUser sourceUser = MParticle.getInstance().Identity().getUsers().get(1);
MParticleUser destinationUser = MParticle.getInstance().Identity().getUsers().get(0);

AliasRequest request = AliasRequest.builder()
    .sourceMpid(sourceUser.getId())
    .destinationMpid(destinationUser.getId())
    .startTime(sourceUser.getFirstSeenTime()) // must be within 90 days
    .endTime(sourceUser.getLastSeenTime()) // must be between StartTime and now
    .build();
MParticle.getInstance().Identity().aliasUsers(request);

// Basic - Call alias as the result of a successful login
MParticle.getInstance()?.Identity()?.login()?.addSuccessListener {
    result ->
    // login request returns new and previous users
    val newUser: MParticleUser = result.getUser()
    val previousUser: MParticleUser? = result.getPreviousUser()

    // Copy any attributes from previous to new user
    // this example copies everything
    previousUser?.let { newUser.setUserAttributes(it.userAttributes) }

    // Create and send the alias request
    val request: AliasRequest = AliasRequest.Builder()
        .sourceMpid(previousUser?.id ?: 0)
        .destinationMpid(newUser.id)
        .build();
    MParticle.getInstance()?.Identity()?.aliasUsers(request);
}

// Call alias at any time

// The getUsers() API now returns users in reverse chronological order
val sourceUser: MParticleUser? = MParticle.getInstance()?.Identity()?.users?.get(1)
val destinationUser: MParticleUser? = MParticle.getInstance()?.Identity()?.users?.get(0)

if(sourceUser != null && destinationUser != null) {
    val request: AliasRequest = AliasRequest.Builder()
        .sourceMpid(sourceUser?.id)
        .destinationMpid(destinationUser?.id)
        .startTime(sourceUser.firstSeenTime) // must be within 90 days
        .endTime(sourceUser.lastSeenTime) // must be between startTime and now
        .build()
    MParticle.getInstance()?.Identity()?.aliasUsers(request)
}

IdentityStateListener listener = new IdentityStateListener() {
    @Override
    public void onUserIdentified(@NonNull MParticleUser user, @Nullable previousUser) {
        //
    }
};
MParticle.getInstance().Identity().addIdentityStateListener(listener);

MParticle.getInstance()?.Identity()?.addIdentityStateListener { user, previousUser ->
            
}

MParticle.getInstance().Identity().removeIdentityStateListener(listener);

val listener = { user: MParticleUser -> }
MParticle.getInstance()?.Identity()?.removeIdentityStateListener(listener)