core/domain/takeout_service_test.py - develop - githubmirror/oppia

core/domain/takeout_service_test.py
2 562 строки106 KB
Puneet Seervi
Fix #24036: Add custom profile name option for contributor certificates. (#26883)
10 авг 2026, 07:39
10 авг 2026, 07:393781aea
# Copyright 2018 The Oppia Authors. All Rights Reserved.
#
# 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.

"""Unit tests for core.domain.takeout_service."""

from __future__ import annotations

import datetime
import json
import logging
import os

from core import feconf, utils
from core.constants import constants
from core.domain import (
    exp_domain,
    exp_services,
    feedback_services,
    fs_services,
    rights_domain,
    stats_domain,
    takeout_domain,
    takeout_service,
    topic_domain,
    user_services,
)
from core.platform import models
from core.tests import test_utils

from typing import Any, Dict, Final, List, Optional, Union

MYPY = False
if MYPY:  # pragma: no cover
    from mypy_imports import (
        app_feedback_report_models,
        auth_models,
        base_models,
        blog_models,
        certificate_assessment_offering_models,
        collection_models,
        config_models,
    )
    from mypy_imports import exp_models as exploration_models
    from mypy_imports import (
        feedback_models,
        general_feedback_models,
        improvements_models,
        learner_group_models,
        question_models,
        skill_models,
        story_models,
        subtopic_models,
        suggestion_models,
        topic_models,
        user_models,
    )

(
    app_feedback_report_models,
    auth_models,
    base_models,
    blog_models,
    certificate_assessment_offering_models,
    collection_models,
    config_models,
    exploration_models,
    feedback_models,
    general_feedback_models,
    improvements_models,
    learner_group_models,
    question_models,
    skill_models,
    story_models,
    subtopic_models,
    suggestion_models,
    topic_models,
    user_models,
) = models.Registry.import_models(
    [
        models.Names.APP_FEEDBACK_REPORT,
        models.Names.AUTH,
        models.Names.BASE_MODEL,
        models.Names.BLOG,
        models.Names.CERTIFICATE_ASSESSMENT_OFFERING,
        models.Names.COLLECTION,
        models.Names.CONFIG,
        models.Names.EXPLORATION,
        models.Names.FEEDBACK,
        models.Names.GENERAL_FEEDBACK,
        models.Names.IMPROVEMENTS,
        models.Names.LEARNER_GROUP,
        models.Names.QUESTION,
        models.Names.SKILL,
        models.Names.STORY,
        models.Names.SUBTOPIC,
        models.Names.SUGGESTION,
        models.Names.TOPIC,
        models.Names.USER,
    ]
)


class TakeoutServiceProfileUserUnitTests(test_utils.GenericTestBase):
    """Tests for the takeout service for profile user."""

    USER_ID_1: Final = 'user_1'
    PROFILE_ID_1: Final = 'profile_1'
    USER_1_ROLE: Final = feconf.ROLE_ID_CURRICULUM_ADMIN
    PROFILE_1_ROLE: Final = feconf.ROLE_ID_MOBILE_LEARNER
    USER_1_EMAIL: Final = 'user1@example.com'
    GENERIC_USERNAME: Final = 'user'
    GENERIC_DATE: Final = datetime.datetime(2019, 5, 20)
    GENERIC_EPOCH: Final = utils.get_time_in_millisecs(GENERIC_DATE)
    GENERIC_IMAGE_URL: Final = 'www.example.com/example.png'
    GENERIC_USER_BIO: Final = 'I am a user of Oppia!'
    GENERIC_SUBJECT_INTERESTS: Final = ['Math', 'Science']
    GENERIC_LANGUAGE_CODES: Final = ['en', 'es']
    GENERIC_DISPLAY_ALIAS: Final = 'display_alias'
    GENERIC_DISPLAY_ALIAS_2: Final = 'display_alias2'
    EXPLORATION_IDS: Final = ['exp_1']
    EXPLORATION_IDS_2: Final = ['exp_2']
    COLLECTION_IDS: Final = ['23', '42', '4']
    COLLECTION_IDS_2: Final = ['32', '44', '6']
    STORY_IDS: Final = ['12', '22', '32']
    STORY_IDS_2: Final = ['42', '52', '62']
    TOPIC_IDS: Final = ['11', '21', '31']
    TOPIC_IDS_2: Final = ['41', '51', '61']
    SKILL_ID_1: Final = 'skill_id_1'
    SKILL_ID_2: Final = 'skill_id_2'
    SKILL_ID_3: Final = 'skill_id_3'
    DEGREE_OF_MASTERY: Final = 0.5
    DEGREE_OF_MASTERY_2: Final = 0.6
    EXP_VERSION: Final = 1
    STATE_NAME: Final = 'state_name'
    STORY_ID_1: Final = 'story_id_1'
    COMPLETED_NODE_IDS_1: Final = ['node_id_1', 'node_id_2']

    def set_up_non_trivial(self) -> None:
        """Set up all models for use in testing.
        1) Simulates skill mastery of user_1 and profile_1.
        2) Simulates completion of some activities of user_1 and profile_1.
        3) Simulates incomplete status of some activities.
        4) Creates user LearnerGoalsModel.
        5) Populates ExpUserLastPlaythroughModel of user.
        6) Creates user LearnerPlaylsts.
        7) Simulates collection progress of user.
        8) Simulates story progress of user.
        9) Creates new collection rights.
        10) Simulates a general suggestion.
        11) Creates new exploration rights.
        12) Populates user settings.
        """
        # Setup for UserSkillModel.
        user_models.UserSkillMasteryModel(
            id=user_models.UserSkillMasteryModel.construct_model_id(
                self.USER_ID_1, self.SKILL_ID_3
            ),
            user_id=self.USER_ID_1,
            skill_id=self.SKILL_ID_3,
            degree_of_mastery=self.DEGREE_OF_MASTERY_2,
        ).put()
        user_models.UserSkillMasteryModel(
            id=user_models.UserSkillMasteryModel.construct_model_id(
                self.PROFILE_ID_1, self.SKILL_ID_1
            ),
            user_id=self.PROFILE_ID_1,
            skill_id=self.SKILL_ID_1,
            degree_of_mastery=self.DEGREE_OF_MASTERY,
        ).put()

        # Setup for CompletedActivitiesModel.
        user_models.CompletedActivitiesModel(
            id=self.USER_ID_1,
            exploration_ids=self.EXPLORATION_IDS_2,
            collection_ids=self.COLLECTION_IDS_2,
            story_ids=self.STORY_IDS_2,
            learnt_topic_ids=self.TOPIC_IDS_2,
        ).put()
        user_models.CompletedActivitiesModel(
            id=self.PROFILE_ID_1,
            exploration_ids=self.EXPLORATION_IDS,
            collection_ids=self.COLLECTION_IDS,
            story_ids=self.STORY_IDS,
            learnt_topic_ids=self.TOPIC_IDS,
        ).put()

        # Setup for IncompleteACtivitiesModel.
        user_models.IncompleteActivitiesModel(
            id=self.PROFILE_ID_1,
            exploration_ids=self.EXPLORATION_IDS,
            collection_ids=self.COLLECTION_IDS,
            story_ids=self.STORY_IDS_2,
            partially_learnt_topic_ids=self.TOPIC_IDS,
        ).put()

        # Setup for ExpUserLastPlaythroughModel.
        user_models.ExpUserLastPlaythroughModel(
            id='%s.%s' % (self.PROFILE_ID_1, self.EXPLORATION_IDS[0]),
            user_id=self.PROFILE_ID_1,
            exploration_id=self.EXPLORATION_IDS[0],
            last_played_exp_version=self.EXP_VERSION,
            last_played_state_name=self.STATE_NAME,
        ).put()

        # Setup for LearnerGoalsModel.
        user_models.LearnerGoalsModel(
            id=self.PROFILE_ID_1, topic_ids_to_learn=self.TOPIC_IDS
        ).put()

        # Setup for LearnerPlaylistModel.
        user_models.LearnerPlaylistModel(
            id=self.PROFILE_ID_1,
            exploration_ids=self.EXPLORATION_IDS,
            collection_ids=self.COLLECTION_IDS,
        ).put()

        # Setup for CollectionProgressModel.
        user_models.CollectionProgressModel(
            id='%s.%s' % (self.PROFILE_ID_1, self.COLLECTION_IDS[0]),
            user_id=self.PROFILE_ID_1,
            collection_id=self.COLLECTION_IDS[0],
            completed_explorations=self.EXPLORATION_IDS,
        ).put()

        # Setup for StoryProgressModel.
        user_models.StoryProgressModel(
            id='%s.%s' % (self.PROFILE_ID_1, self.STORY_ID_1),
            user_id=self.PROFILE_ID_1,
            story_id=self.STORY_ID_1,
            completed_node_ids=self.COMPLETED_NODE_IDS_1,
        ).put()

        # Setup for UserSettingsModel.
        user_models.UserSettingsModel(
            id=self.USER_ID_1,
            email=self.USER_1_EMAIL,
            roles=[self.USER_1_ROLE],
            username=self.GENERIC_USERNAME,
            normalized_username=self.GENERIC_USERNAME,
            last_agreed_to_terms=self.GENERIC_DATE,
            last_started_state_editor_tutorial=self.GENERIC_DATE,
            last_started_state_translation_tutorial=self.GENERIC_DATE,
            last_logged_in=self.GENERIC_DATE,
            last_created_an_exploration=self.GENERIC_DATE,
            last_edited_an_exploration=self.GENERIC_DATE,
            default_dashboard='learner',
            creator_dashboard_display_pref='card',
            user_bio=self.GENERIC_USER_BIO,
            subject_interests=self.GENERIC_SUBJECT_INTERESTS,
            first_contribution_msec=1,
            preferred_language_codes=self.GENERIC_LANGUAGE_CODES,
            preferred_site_language_code=self.GENERIC_LANGUAGE_CODES[0],
            preferred_audio_language_code=self.GENERIC_LANGUAGE_CODES[0],
            display_alias=self.GENERIC_DISPLAY_ALIAS,
        ).put()
        user_models.UserSettingsModel(
            id=self.PROFILE_ID_1,
            email=self.USER_1_EMAIL,
            roles=[self.PROFILE_1_ROLE],
            username=None,
            normalized_username=None,
            last_agreed_to_terms=self.GENERIC_DATE,
            last_started_state_editor_tutorial=None,
            last_started_state_translation_tutorial=None,
            last_logged_in=self.GENERIC_DATE,
            last_created_an_exploration=None,
            last_edited_an_exploration=None,
            default_dashboard='learner',
            creator_dashboard_display_pref='card',
            user_bio=self.GENERIC_USER_BIO,
            subject_interests=self.GENERIC_SUBJECT_INTERESTS,
            first_contribution_msec=None,
            preferred_language_codes=self.GENERIC_LANGUAGE_CODES,
            preferred_site_language_code=self.GENERIC_LANGUAGE_CODES[0],
            preferred_audio_language_code=self.GENERIC_LANGUAGE_CODES[0],
            display_alias=self.GENERIC_DISPLAY_ALIAS_2,
        ).put()

    def set_up_trivial(self) -> None:
        """Setup for trivial test of export_data functionality."""
        user_models.UserSettingsModel(
            id=self.USER_ID_1, email=self.USER_1_EMAIL, roles=[self.USER_1_ROLE]
        ).put()
        user_models.UserSettingsModel(
            id=self.PROFILE_ID_1,
            email=self.USER_1_EMAIL,
            roles=[self.PROFILE_1_ROLE],
        ).put()

    def test_export_data_for_profile_user_trivial_raises_error(self) -> None:
        """Trivial test of export_data functionality."""

        self.set_up_trivial()
        error_msg = 'Takeout for profile users is not yet supported.'
        with self.assertRaisesRegex(NotImplementedError, error_msg):
            takeout_service.export_data_for_user(self.PROFILE_ID_1)

    def test_export_data_for_profile_user_nontrivial_raises_error(self) -> None:
        """Nontrivial test of export_data functionality."""

        self.set_up_non_trivial()
        error_msg = 'Takeout for profile users is not yet supported.'
        with self.assertRaisesRegex(NotImplementedError, error_msg):
            takeout_service.export_data_for_user(self.PROFILE_ID_1)


class TakeoutServiceFullUserUnitTests(test_utils.GenericTestBase):
    """Tests for the takeout service for full user."""

    USER_ID_1: Final = 'user_1'
    PROFILE_ID_1: Final = 'profile_1'
    THREAD_ID_1: Final = 'thread_id_1'
    THREAD_ID_2: Final = 'thread_id_2'
    BLOG_POST_ID_1: Final = 'blog_post_id_1'
    BLOG_POST_ID_2: Final = 'blog_post_id_2'
    TOPIC_ID_1: Final = 'topic_id_1'
    TOPIC_ID_2: Final = 'topic_id_2'
    USER_1_ROLE: Final = feconf.ROLE_ID_CURRICULUM_ADMIN
    PROFILE_1_ROLE: Final = feconf.ROLE_ID_MOBILE_LEARNER
    USER_1_EMAIL: Final = 'user1@example.com'
    GENERIC_USERNAME: Final = 'user'
    GENERIC_PIN: Final = '12345'
    GENERIC_DATE: Final = datetime.datetime(2019, 5, 20)
    GENERIC_EPOCH: Final = utils.get_time_in_millisecs(GENERIC_DATE)
    GENERIC_IMAGE_URL: Final = 'www.example.com/example.png'
    GENERIC_USER_BIO: Final = 'I am a user of Oppia!'
    GENERIC_SUBJECT_INTERESTS: Final = ['Math', 'Science']
    GENERIC_LANGUAGE_CODES: Final = ['en', 'es']
    GENERIC_DISPLAY_ALIAS: Final = 'display_alias'
    GENERIC_DISPLAY_ALIAS_2: Final = 'display_alias2'
    USER_1_IMPACT_SCORE: Final = 0.87
    USER_1_TOTAL_PLAYS: Final = 33
    USER_1_AVERAGE_RATINGS: Final = 4.37
    USER_1_NUM_RATINGS: Final = 22
    USER_1_WEEKLY_CREATOR_STATS_LIST: Final = [
        {('2019-05-21'): {'average_ratings': 4.00, 'total_plays': 5}},
        {('2019-05-28'): {'average_ratings': 4.95, 'total_plays': 10}},
    ]
    EXPLORATION_IDS: Final = ['exp_1']
    EXPLORATION_IDS_2: Final = ['exp_2']
    STORY_IDS: Final = ['12', '22', '32']
    STORY_IDS_2: Final = ['42', '52', '62']
    TOPIC_IDS_2: Final = ['41', '51', '61']
    CREATOR_IDS: Final = ['4', '8', '16']
    CREATOR_USERNAMES: Final = ['username4', 'username8', 'username16']
    COLLECTION_IDS: Final = ['23', '42', '4']
    COLLECTION_IDS_2: Final = ['32', '44', '6']
    TOPIC_IDS: Final = ['12', '13', '14']
    GENERAL_FEEDBACK_THREAD_IDS: Final = ['42', '4', '8']
    MESSAGE_IDS_READ_BY_USER: Final = [0, 1]
    SKILL_ID_1: Final = 'skill_id_1'
    SKILL_ID_2: Final = 'skill_id_2'
    SKILL_ID_3: Final = 'skill_id_3'
    DEGREE_OF_MASTERY: Final = 0.5
    DEGREE_OF_MASTERY_2: Final = 0.6
    EXP_VERSION: Final = 1
    STATE_NAME: Final = 'state_name'
    STORY_ID_1: Final = 'story_id_1'
    STORY_ID_2: Final = 'story_id_2'
    COMPLETED_NODE_IDS_1: Final = ['node_id_1', 'node_id_2']
    COMPLETED_NODE_IDS_2: Final = ['node_id_3', 'node_id_4']
    LEARNER_GROUP_ID: Final = 'learner_group_1'
    THREAD_ENTITY_TYPE: Final = feconf.ENTITY_TYPE_EXPLORATION
    THREAD_ENTITY_ID: Final = 'exp_id_2'
    THREAD_STATUS: Final = 'open'
    THREAD_SUBJECT: Final = 'dummy subject'
    THREAD_HAS_SUGGESTION: Final = True
    THREAD_SUMMARY: Final = 'This is a great summary.'
    THREAD_MESSAGE_COUNT: Final = 0
    MESSAGE_TEXT: Final = 'Export test text.'
    MESSAGE_RECEIEVED_VIA_EMAIL: Final = False
    CHANGE_CMD: Dict[str, str] = {}
    SCORE_CATEGORY_1: Final = 'category_1'
    SCORE_CATEGORY_2: Final = 'category_2'
    SCORE_CATEGORY: str = '%s%sEnglish' % (
        suggestion_models.SCORE_TYPE_TRANSLATION,
        suggestion_models.SCORE_CATEGORY_DELIMITER,
    )
    GENERIC_MODEL_ID: Final = 'model-id-1'
    COMMIT_TYPE: Final = 'create'
    COMMIT_MESSAGE: Final = 'This is a commit.'
    COMMIT_CMDS: Final = [{'cmd': 'some_command'}, {'cmd2': 'another_command'}]
    PLATFORM_ANDROID: Final = 'android'
    # Timestamp in sec since epoch for Mar 7 2021 21:17:16 UTC.
    REPORT_SUBMITTED_TIMESTAMP: Final = datetime.datetime.fromtimestamp(
        1615151836
    )
    # Timestamp in sec since epoch for Mar 19 2021 17:10:36 UTC.
    TICKET_CREATION_TIMESTAMP: Final = datetime.datetime.fromtimestamp(
        1616173836
    )
    TICKET_ID: Final = '%s.%s.%s' % (
        'random_hash',
        TICKET_CREATION_TIMESTAMP.second,
        '16CharString1234',
    )
    REPORT_TYPE_SUGGESTION: Final = 'suggestion'
    CATEGORY_OTHER: Final = 'other'
    PLATFORM_VERSION: Final = '0.1-alpha-abcdef1234'
    DEVICE_COUNTRY_LOCALE_CODE_INDIA: Final = 'in'
    ANDROID_DEVICE_MODEL: Final = 'Pixel 4a'
    ANDROID_SDK_VERSION: Final = 28
    ENTRY_POINT_NAVIGATION_DRAWER: Final = 'navigation_drawer'
    TEXT_LANGUAGE_CODE_ENGLISH: Final = 'en'
    AUDIO_LANGUAGE_CODE_ENGLISH: Final = 'en'
    ANDROID_REPORT_INFO: Dict[
        str, Union[str, List[str], int, bool, Dict[str, str]]
    ] = {
        'user_feedback_other_text_input': 'add an admin',
        'event_logs': ['event1', 'event2'],
        'logcat_logs': ['logcat1', 'logcat2'],
        'package_version_code': 1,
        'language_locale_code': 'en',
        'entry_point_info': {
            'entry_point_name': 'crash',
        },
        'text_size': 'MEDIUM_TEXT_SIZE',
        'only_allows_wifi_download_and_update': True,
        'automatically_update_topics': False,
        'is_curriculum_admin': False,
    }
    ANDROID_REPORT_INFO_SCHEMA_VERSION: Final = 1
    SUGGESTION_LANGUAGE_CODE: Final = 'en'
    SUBMITTED_TRANSLATIONS_COUNT: Final = 2
    SUBMITTED_TRANSLATION_WORD_COUNT: Final = 100
    ACCEPTED_TRANSLATIONS_COUNT: Final = 1
    ACCEPTED_TRANSLATIONS_WITHOUT_REVIEWER_EDITS_COUNT: Final = 0
    ACCEPTED_TRANSLATION_WORD_COUNT: Final = 50
    REJECTED_TRANSLATIONS_COUNT: Final = 0
    REJECTED_TRANSLATION_WORD_COUNT: Final = 0
    REVIEWED_TRANSLATIONS_COUNT: Final = 0
    REVIEWED_TRANSLATION_WORD_COUNT: Final = 0
    ACCEPTED_TRANSLATIONS_WITH_REVIEWER_EDITS_COUNT: Final = 0
    SUBMITTED_QUESTIONS_COUNT: Final = 20
    REJECTED_QUESTIONS_COUNT: Final = 20
    ACCEPTED_QUESTIONS_COUNT: Final = 2
    ACCEPTED_QUESTIONS_WITHOUT_REVIEWER_EDITS_COUNT: Final = 0
    REVIEWED_QUESTIONS_COUNT: Final = 2
    ACCEPTED_QUESTIONS_WITH_REVIEWER_EDITS_COUNT: Final = 0
    TOPIC_IDS_WITH_TRANSLATION_SUBMISSIONS: Final = ['15', '16', '17']
    TOPIC_IDS_WITH_TRANSLATION_REVIEWS: Final = ['18', '19', '20']
    TOPIC_IDS_WITH_QUESTION_SUBMISSIONS: Final = ['18', '19', '20']
    TOPIC_IDS_WITH_QUESTION_REVIEWS: Final = ['18', '19', '20']
    RECENT_REVIEW_OUTCOMES: Final = ['accepted', 'rejected']
    RECENT_PERFORMANCE: Final = 20
    OVERALL_ACCURACY: Final = 2.0
    # Timestamp dates in sec since epoch for Mar 19 2021 UTC.
    CONTRIBUTION_DATES: Final = [
        datetime.date.fromtimestamp(1616173836),
        datetime.date.fromtimestamp(1616173837),
    ]
    FIRST_CONTRIBUTION_DATE: Final = datetime.datetime(2021, 5, 20)
    LAST_CONTRIBUTION_DATE: Final = datetime.datetime(2022, 5, 20)
    PROFILE_PICTURE_DATA_PNG: Final = (
        'data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAcAAAAGCAIAAACAbBMhAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAAEnQAABJ0Ad5mH3gAAAAySURBVBhXY/iPDYBEV6xY0draCuFDAEgUKMTAANUEUYFuAkQFihIIGwigosiG/P//HwD5HmjphyAmJQAAAABJRU5ErkJggg%3D%3D'  # pylint: disable=line-too-long
    )
    PROFILE_PICTURE_DATA_WEBP: Final = (
        'data:image/webp;base64,UklGRlIAAABXRUJQVlA4IEYAAADQAQCdASoHAAYAAgA0JaQAAv%2B5x9YuAAD%2B%2B0nD9oP5zmavp/Nyl8%2Bf/REL9weER482Ugrc/6dmq28Kx1pj/se/CsMAAAAA'  # pylint: disable=line-too-long
    )
    LESSON_FEEDBACK_ID_1 = 'lesson_feedback_id_1'
    PARENT_FEEDBACK_ID_1 = 'parent_feedback_id_1'
    LESSON_FEEDBACK_TEXT_1 = 'lesson_feedback_text_1'
    lesson_metadata = {
        'exploration_id': 'exp_id_1',
        'exploration_version': 1,
        'state_name': 'state_1',
        'state_index': 0,
    }
    LESSON_FEEDBACK_RESPONSE_LIST: List[Dict[str, Union[str, float]]] = []
    LESSON_FEEDBACK_UNREAD_RESPONSE_COUNT = 1
    LESSON_FEEDBACK_CREATED_ON = datetime.datetime.utcnow()
    LESSON_FEEDBACK_LAST_UPDATED = datetime.datetime.utcnow()

    def set_up_non_trivial(self) -> None:
        """Set up all models for use in testing.
        1) Simulates the creation of a user, user_1, and their stats model.
        2) Simulates skill mastery of user_1 with two skills.
        3) Simulates subscriptions to threads, activities, and collections.
        4) Simulates creation and edit of an exploration by user_1.
        5) Creates an ExplorationUserDataModel.
        6) Simulates completion of some activities.
        7) Simulates incomplete status of some activities.
        8) Creates user LearnerGoalsModel.
        9) Populates ExpUserLastPlaythroughModel of user.
        10) Creates user LearnerPlaylsts.
        11) Simulates collection progress of user.
        12) Simulates story progress of user.
        13) Creates new collection rights.
        14) Simulates a general suggestion.
        15) Creates new exploration rights.
        16) Populates user settings.
        17) Creates two reply-to ids for feedback.
        18) Creates a task closed by the user.
        19) Simulates user_1 scrubbing a report.
        20) Creates new BlogPostModel and BlogPostRightsModel.
        21) Creates a TranslationContributionStatsModel.
        22) Creates new LearnerGroupModel and LearnerGroupsUserModel.
        """
        # Setup for UserStatsModel.
        user_models.UserStatsModel(
            id=self.USER_ID_1,
            impact_score=self.USER_1_IMPACT_SCORE,
            total_plays=self.USER_1_TOTAL_PLAYS,
            average_ratings=self.USER_1_AVERAGE_RATINGS,
            num_ratings=self.USER_1_NUM_RATINGS,
            weekly_creator_stats_list=self.USER_1_WEEKLY_CREATOR_STATS_LIST,
        ).put()

        # Setup for UserSkillModel.
        user_models.UserSkillMasteryModel(
            id=user_models.UserSkillMasteryModel.construct_model_id(
                self.USER_ID_1, self.SKILL_ID_1
            ),
            user_id=self.USER_ID_1,
            skill_id=self.SKILL_ID_1,
            degree_of_mastery=self.DEGREE_OF_MASTERY,
        ).put()
        user_models.UserSkillMasteryModel(
            id=user_models.UserSkillMasteryModel.construct_model_id(
                self.USER_ID_1, self.SKILL_ID_2
            ),
            user_id=self.USER_ID_1,
            skill_id=self.SKILL_ID_2,
            degree_of_mastery=self.DEGREE_OF_MASTERY,
        ).put()
        user_models.UserSkillMasteryModel(
            id=user_models.UserSkillMasteryModel.construct_model_id(
                self.PROFILE_ID_1, self.SKILL_ID_3
            ),
            user_id=self.PROFILE_ID_1,
            skill_id=self.SKILL_ID_3,
            degree_of_mastery=self.DEGREE_OF_MASTERY_2,
        ).put()

        # Setup for UserSubscriptionsModel.
        for creator_id in self.CREATOR_IDS:
            user_models.UserSettingsModel(
                id=creator_id,
                username='username%s' % creator_id,
                email='%s@example.com' % creator_id,
            ).put()

        user_models.UserSubscriptionsModel(
            id=self.USER_ID_1,
            creator_ids=self.CREATOR_IDS,
            collection_ids=self.COLLECTION_IDS,
            exploration_ids=self.EXPLORATION_IDS,
            general_feedback_thread_ids=self.GENERAL_FEEDBACK_THREAD_IDS,
            last_checked=self.GENERIC_DATE,
        ).put()

        # Setup for UserContributionsModel.
        self.save_new_valid_exploration(
            self.EXPLORATION_IDS[0], self.USER_ID_1, end_state_name='End'
        )

        exp_services.update_exploration(
            self.USER_ID_1,
            self.EXPLORATION_IDS[0],
            [
                exp_domain.ExplorationChange(
                    {
                        'cmd': 'edit_exploration_property',
                        'property_name': 'objective',
                        'new_value': 'the objective',
                    }
                )
            ],
            'Test edit',
        )

        # Setup for ExplorationUserDataModel.
        user_models.ExplorationUserDataModel(
            id='%s.%s' % (self.USER_ID_1, self.EXPLORATION_IDS[0]),
            user_id=self.USER_ID_1,
            exploration_id=self.EXPLORATION_IDS[0],
            rating=2,
            rated_on=self.GENERIC_DATE,
            draft_change_list={'new_content': {}},
            draft_change_list_last_updated=self.GENERIC_DATE,
            draft_change_list_exp_version=3,
            draft_change_list_id=1,
        ).put()

        # Setup for CompletedActivitiesModel.
        user_models.CompletedActivitiesModel(
            id=self.USER_ID_1,
            exploration_ids=self.EXPLORATION_IDS,
            collection_ids=self.COLLECTION_IDS,
            story_ids=self.STORY_IDS,
            learnt_topic_ids=self.TOPIC_IDS,
        ).put()
        user_models.CompletedActivitiesModel(
            id=self.PROFILE_ID_1,
            exploration_ids=self.EXPLORATION_IDS_2,
            collection_ids=self.COLLECTION_IDS_2,
            story_ids=self.STORY_IDS_2,
            learnt_topic_ids=self.TOPIC_IDS_2,
        ).put()

        # Setup for IncompleteACtivitiesModel.
        user_models.IncompleteActivitiesModel(
            id=self.USER_ID_1,
            exploration_ids=self.EXPLORATION_IDS,
            collection_ids=self.COLLECTION_IDS,
            story_ids=self.STORY_IDS,
            partially_learnt_topic_ids=self.TOPIC_IDS,
        ).put()

        # Setup for ExpUserLastPlaythroughModel.
        user_models.ExpUserLastPlaythroughModel(
            id='%s.%s' % (self.USER_ID_1, self.EXPLORATION_IDS[0]),
            user_id=self.USER_ID_1,
            exploration_id=self.EXPLORATION_IDS[0],
            last_played_exp_version=self.EXP_VERSION,
            last_played_state_name=self.STATE_NAME,
        ).put()

        # Setup for LearnerGoalsModel.
        user_models.LearnerGoalsModel(
            id=self.USER_ID_1, topic_ids_to_learn=self.TOPIC_IDS
        ).put()
        user_models.LearnerGoalsModel(
            id=self.PROFILE_ID_1, topic_ids_to_learn=self.TOPIC_IDS_2
        ).put()

        # Setup for LearnerPlaylistModel.
        user_models.LearnerPlaylistModel(
            id=self.USER_ID_1,
            exploration_ids=self.EXPLORATION_IDS,
            collection_ids=self.COLLECTION_IDS,
        ).put()
        user_models.LearnerPlaylistModel(
            id=self.PROFILE_ID_1,
            exploration_ids=self.EXPLORATION_IDS_2,
            collection_ids=self.COLLECTION_IDS_2,
        ).put()

        # Setup for CollectionProgressModel.
        user_models.CollectionProgressModel(
            id='%s.%s' % (self.USER_ID_1, self.COLLECTION_IDS[0]),
            user_id=self.USER_ID_1,
            collection_id=self.COLLECTION_IDS[0],
            completed_explorations=self.EXPLORATION_IDS,
        ).put()
        user_models.CollectionProgressModel(
            id='%s.%s' % (self.PROFILE_ID_1, self.COLLECTION_IDS_2[0]),
            user_id=self.PROFILE_ID_1,
            collection_id=self.COLLECTION_IDS_2[0],
            completed_explorations=self.EXPLORATION_IDS_2,
        ).put()

        # Setup for StoryProgressModel.
        user_models.StoryProgressModel(
            id='%s.%s' % (self.USER_ID_1, self.STORY_ID_1),
            user_id=self.USER_ID_1,
            story_id=self.STORY_ID_1,
            completed_node_ids=self.COMPLETED_NODE_IDS_1,
        ).put()
        user_models.StoryProgressModel(
            id='%s.%s' % (self.PROFILE_ID_1, self.STORY_ID_2),
            user_id=self.PROFILE_ID_1,
            story_id=self.STORY_ID_2,
            completed_node_ids=self.COMPLETED_NODE_IDS_2,
        ).put()

        # Setup for CollectionRightsModel.
        collection_models.CollectionRightsModel(
            id=self.COLLECTION_IDS[0],
            owner_ids=[self.USER_ID_1],
            editor_ids=[self.USER_ID_1],
            voice_artist_ids=[self.USER_ID_1],
            viewer_ids=[self.USER_ID_1],
            community_owned=False,
            status=constants.ACTIVITY_STATUS_PUBLIC,
            viewable_if_private=False,
            first_published_msec=0.0,
        ).save(
            'cid',
            'Created new collection right',
            [{'cmd': rights_domain.CMD_CREATE_NEW}],
        )

        # Setup for GeneralSuggestionModel.
        suggestion_models.GeneralSuggestionModel.create(
            feconf.SUGGESTION_TYPE_EDIT_STATE_CONTENT,
            feconf.ENTITY_TYPE_EXPLORATION,
            self.EXPLORATION_IDS[0],
            1,
            suggestion_models.STATUS_IN_REVIEW,
            self.USER_ID_1,
            'reviewer_1',
            self.CHANGE_CMD,
            self.SCORE_CATEGORY,
            'exploration.exp1.thread_1',
            None,
        )

        # Setup for TopicRightsModel.
        topic_models.TopicRightsModel(
            id=self.TOPIC_ID_1,
            manager_ids=[self.USER_ID_1],
            topic_is_published=True,
        ).commit(
            'committer_id',
            'New topic rights',
            [{'cmd': topic_domain.CMD_CREATE_NEW}],
        )
        topic_models.TopicRightsModel(
            id=self.TOPIC_ID_2,
            manager_ids=[self.USER_ID_1],
            topic_is_published=True,
        ).commit(
            'committer_id',
            'New topic rights',
            [{'cmd': topic_domain.CMD_CREATE_NEW}],
        )

        # Setup for ExplorationRightsModel.
        exploration_models.ExplorationRightsModel(
            id=self.EXPLORATION_IDS[0],
            owner_ids=[self.USER_ID_1],
            editor_ids=[self.USER_ID_1],
            voice_artist_ids=[self.USER_ID_1],
            viewer_ids=[self.USER_ID_1],
            community_owned=False,
            status=constants.ACTIVITY_STATUS_PUBLIC,
            viewable_if_private=False,
            first_published_msec=0.0,
        ).save(
            'cid',
            'Created new exploration right',
            [{'cmd': rights_domain.CMD_CREATE_NEW}],
        )

        # Setup for UserSettingsModel.
        user_models.UserSettingsModel(
            id=self.USER_ID_1,
            email=self.USER_1_EMAIL,
            roles=[self.USER_1_ROLE],
            username=self.GENERIC_USERNAME,
            normalized_username=self.GENERIC_USERNAME,
            last_agreed_to_terms=self.GENERIC_DATE,
            last_started_state_editor_tutorial=self.GENERIC_DATE,
            last_started_state_translation_tutorial=self.GENERIC_DATE,
            last_logged_in=self.GENERIC_DATE,
            last_created_an_exploration=self.GENERIC_DATE,
            last_edited_an_exploration=self.GENERIC_DATE,
            default_dashboard='learner',
            creator_dashboard_display_pref='card',
            user_bio=self.GENERIC_USER_BIO,
            subject_interests=self.GENERIC_SUBJECT_INTERESTS,
            first_contribution_msec=1,
            preferred_language_codes=self.GENERIC_LANGUAGE_CODES,
            preferred_site_language_code=self.GENERIC_LANGUAGE_CODES[0],
            preferred_audio_language_code=self.GENERIC_LANGUAGE_CODES[0],
            display_alias=self.GENERIC_DISPLAY_ALIAS,
            pin=self.GENERIC_PIN,
        ).put()
        user_models.UserSettingsModel(
            id=self.PROFILE_ID_1,
            email=self.USER_1_EMAIL,
            roles=[self.PROFILE_1_ROLE],
            username=None,
            normalized_username=None,
            last_agreed_to_terms=self.GENERIC_DATE,
            last_started_state_editor_tutorial=None,
            last_started_state_translation_tutorial=None,
            last_logged_in=self.GENERIC_DATE,
            last_created_an_exploration=None,
            last_edited_an_exploration=None,
            default_dashboard='learner',
            creator_dashboard_display_pref='card',
            user_bio=self.GENERIC_USER_BIO,
            subject_interests=self.GENERIC_SUBJECT_INTERESTS,
            first_contribution_msec=None,
            preferred_language_codes=self.GENERIC_LANGUAGE_CODES,
            preferred_site_language_code=self.GENERIC_LANGUAGE_CODES[0],
            preferred_audio_language_code=self.GENERIC_LANGUAGE_CODES[0],
            display_alias=self.GENERIC_DISPLAY_ALIAS_2,
        ).put()

        suggestion_models.TranslationContributionStatsModel.create(
            language_code=self.SUGGESTION_LANGUAGE_CODE,
            contributor_user_id=self.USER_ID_1,
            topic_id=self.TOPIC_ID_1,
            submitted_translations_count=self.SUBMITTED_TRANSLATIONS_COUNT,
            submitted_translation_word_count=(
                self.SUBMITTED_TRANSLATION_WORD_COUNT
            ),
            accepted_translations_count=self.ACCEPTED_TRANSLATIONS_COUNT,
            accepted_translations_without_reviewer_edits_count=(
                self.ACCEPTED_TRANSLATIONS_WITHOUT_REVIEWER_EDITS_COUNT
            ),
            accepted_translation_word_count=(
                self.ACCEPTED_TRANSLATION_WORD_COUNT
            ),
            rejected_translations_count=self.REJECTED_TRANSLATIONS_COUNT,
            rejected_translation_word_count=(
                self.REJECTED_TRANSLATION_WORD_COUNT
            ),
            contribution_dates=self.CONTRIBUTION_DATES,
        )

        suggestion_models.TranslationReviewStatsModel.create(
            language_code=self.SUGGESTION_LANGUAGE_CODE,
            reviewer_user_id=self.USER_ID_1,
            topic_id=self.TOPIC_ID_1,
            reviewed_translations_count=self.REVIEWED_TRANSLATIONS_COUNT,
            reviewed_translation_word_count=(
                self.REVIEWED_TRANSLATION_WORD_COUNT
            ),
            accepted_translations_count=self.ACCEPTED_TRANSLATIONS_COUNT,
            accepted_translations_with_reviewer_edits_count=(
                self.ACCEPTED_TRANSLATIONS_WITH_REVIEWER_EDITS_COUNT
            ),
            accepted_translation_word_count=(
                self.ACCEPTED_TRANSLATION_WORD_COUNT
            ),
            first_contribution_date=self.FIRST_CONTRIBUTION_DATE,
            last_contribution_date=self.LAST_CONTRIBUTION_DATE,
        )

        suggestion_models.QuestionContributionStatsModel.create(
            contributor_user_id=self.USER_ID_1,
            topic_id=self.TOPIC_ID_1,
            submitted_questions_count=self.SUBMITTED_QUESTIONS_COUNT,
            accepted_questions_count=self.ACCEPTED_QUESTIONS_COUNT,
            accepted_questions_without_reviewer_edits_count=(
                self.ACCEPTED_QUESTIONS_WITHOUT_REVIEWER_EDITS_COUNT
            ),
            first_contribution_date=self.FIRST_CONTRIBUTION_DATE,
            last_contribution_date=self.LAST_CONTRIBUTION_DATE,
        )

        suggestion_models.QuestionReviewStatsModel.create(
            reviewer_user_id=self.USER_ID_1,
            topic_id=self.TOPIC_ID_1,
            reviewed_questions_count=self.REVIEWED_QUESTIONS_COUNT,
            accepted_questions_count=self.ACCEPTED_QUESTIONS_COUNT,
            accepted_questions_with_reviewer_edits_count=(
                self.ACCEPTED_QUESTIONS_WITH_REVIEWER_EDITS_COUNT
            ),
            first_contribution_date=self.FIRST_CONTRIBUTION_DATE,
            last_contribution_date=self.LAST_CONTRIBUTION_DATE,
        )

        suggestion_models.TranslationSubmitterTotalContributionStatsModel.create(  # pylint: disable=line-too-long
            language_code=self.SUGGESTION_LANGUAGE_CODE,
            contributor_id=self.USER_ID_1,
            topic_ids_with_translation_submissions=(
                self.TOPIC_IDS_WITH_TRANSLATION_SUBMISSIONS
            ),
            recent_review_outcomes=self.RECENT_REVIEW_OUTCOMES,
            recent_performance=self.RECENT_PERFORMANCE,
            overall_accuracy=self.OVERALL_ACCURACY,
            submitted_translations_count=self.SUBMITTED_TRANSLATIONS_COUNT,
            submitted_translation_word_count=(
                self.SUBMITTED_TRANSLATION_WORD_COUNT
            ),
            accepted_translations_count=self.ACCEPTED_TRANSLATIONS_COUNT,
            accepted_translations_without_reviewer_edits_count=(
                self.ACCEPTED_TRANSLATIONS_WITHOUT_REVIEWER_EDITS_COUNT
            ),
            accepted_translation_word_count=(
                self.ACCEPTED_TRANSLATION_WORD_COUNT
            ),
            rejected_translations_count=self.REJECTED_TRANSLATIONS_COUNT,
            rejected_translation_word_count=(
                self.REJECTED_TRANSLATION_WORD_COUNT
            ),
            first_contribution_date=self.FIRST_CONTRIBUTION_DATE,
            last_contribution_date=self.LAST_CONTRIBUTION_DATE,
        )

        suggestion_models.TranslationReviewerTotalContributionStatsModel.create(  # pylint: disable=line-too-long
            language_code=self.SUGGESTION_LANGUAGE_CODE,
            contributor_id=self.USER_ID_1,
            topic_ids_with_translation_reviews=(
                self.TOPIC_IDS_WITH_TRANSLATION_REVIEWS
            ),
            reviewed_translations_count=self.REVIEWED_TRANSLATIONS_COUNT,
            accepted_translations_count=self.ACCEPTED_TRANSLATIONS_COUNT,
            accepted_translations_with_reviewer_edits_count=(
                self.ACCEPTED_TRANSLATIONS_WITH_REVIEWER_EDITS_COUNT
            ),
            accepted_translation_word_count=(
                self.ACCEPTED_TRANSLATION_WORD_COUNT
            ),
            rejected_translations_count=(self.REJECTED_TRANSLATIONS_COUNT),
            first_contribution_date=self.FIRST_CONTRIBUTION_DATE,
            last_contribution_date=self.LAST_CONTRIBUTION_DATE,
        )

        suggestion_models.QuestionSubmitterTotalContributionStatsModel.create(
            contributor_id=self.USER_ID_1,
            topic_ids_with_question_submissions=(
                self.TOPIC_IDS_WITH_QUESTION_SUBMISSIONS
            ),
            recent_review_outcomes=self.RECENT_REVIEW_OUTCOMES,
            recent_performance=self.RECENT_PERFORMANCE,
            overall_accuracy=self.OVERALL_ACCURACY,
            submitted_questions_count=self.SUBMITTED_QUESTIONS_COUNT,
            accepted_questions_count=self.ACCEPTED_QUESTIONS_COUNT,
            accepted_questions_without_reviewer_edits_count=(
                self.ACCEPTED_QUESTIONS_WITHOUT_REVIEWER_EDITS_COUNT
            ),
            rejected_questions_count=self.REJECTED_QUESTIONS_COUNT,
            first_contribution_date=self.FIRST_CONTRIBUTION_DATE,
            last_contribution_date=self.LAST_CONTRIBUTION_DATE,
        )

        user_models.PinnedOpportunityModel.create(
            user_id=self.USER_ID_1,
            topic_id=self.TOPIC_ID_1,
            language_code=self.SUGGESTION_LANGUAGE_CODE,
            opportunity_id=self.EXPLORATION_IDS[0],
            entity_type=feconf.ENTITY_TYPE_EXPLORATION,
        )

        suggestion_models.QuestionReviewerTotalContributionStatsModel.create(
            contributor_id=self.USER_ID_1,
            topic_ids_with_question_reviews=(
                self.TOPIC_IDS_WITH_QUESTION_REVIEWS
            ),
            reviewed_questions_count=self.REVIEWED_QUESTIONS_COUNT,
            accepted_questions_count=self.ACCEPTED_QUESTIONS_COUNT,
            accepted_questions_with_reviewer_edits_count=(
                self.ACCEPTED_QUESTIONS_WITH_REVIEWER_EDITS_COUNT
            ),
            rejected_questions_count=self.REJECTED_QUESTIONS_COUNT,
            first_contribution_date=self.FIRST_CONTRIBUTION_DATE,
            last_contribution_date=self.LAST_CONTRIBUTION_DATE,
        )

        suggestion_models.TranslationCoordinatorsModel(
            id='es', coordinator_ids=[self.USER_ID_1], coordinators_count=2
        ).put()

        suggestion_models.TranslationCoordinatorsModel(
            id='hi', coordinator_ids=[self.USER_ID_1], coordinators_count=2
        ).put()

        user_models.UserContributionRightsModel(
            id=self.USER_ID_1,
            can_review_translation_for_language_codes=['hi', 'en'],
            can_review_voiceover_for_language_codes=['hi'],
            can_review_questions=True,
        ).put()

        user_models.UserContributionProficiencyModel(
            id='%s.%s' % (self.SCORE_CATEGORY_1, self.USER_ID_1),
            user_id=self.USER_ID_1,
            score_category=self.SCORE_CATEGORY_1,
            score=1.5,
            onboarding_email_sent=False,
        ).put()
        user_models.UserContributionProficiencyModel(
            id='%s.%s' % (self.SCORE_CATEGORY_2, self.USER_ID_1),
            user_id=self.USER_ID_1,
            score_category=self.SCORE_CATEGORY_2,
            score=2,
            onboarding_email_sent=False,
        ).put()

        collection_models.CollectionRightsSnapshotMetadataModel(
            id=self.GENERIC_MODEL_ID,
            committer_id=self.USER_ID_1,
            commit_type=self.COMMIT_TYPE,
            commit_message=self.COMMIT_MESSAGE,
            commit_cmds=self.COMMIT_CMDS,
        ).put()

        collection_models.CollectionSnapshotMetadataModel(
            id=self.GENERIC_MODEL_ID,
            committer_id=self.USER_ID_1,
            commit_type=self.COMMIT_TYPE,
            commit_message=self.COMMIT_MESSAGE,
            commit_cmds=self.COMMIT_CMDS,
        ).put()

        skill_models.SkillSnapshotMetadataModel(
            id=self.GENERIC_MODEL_ID,
            committer_id=self.USER_ID_1,
            commit_type=self.COMMIT_TYPE,
            commit_message=self.COMMIT_MESSAGE,
            commit_cmds=self.COMMIT_CMDS,
        ).put()
        subtopic_models.SubtopicPageSnapshotMetadataModel(
            id=self.GENERIC_MODEL_ID,
            committer_id=self.USER_ID_1,
            commit_type=self.COMMIT_TYPE,
            commit_message=self.COMMIT_MESSAGE,
            commit_cmds=self.COMMIT_CMDS,
        ).put()

        topic_models.TopicRightsSnapshotMetadataModel(
            id=self.GENERIC_MODEL_ID,
            committer_id=self.USER_ID_1,
            commit_type=self.COMMIT_TYPE,
            commit_message=self.COMMIT_MESSAGE,
            commit_cmds=self.COMMIT_CMDS,
        ).put()

        topic_models.TopicSnapshotMetadataModel(
            id=self.GENERIC_MODEL_ID,
            committer_id=self.USER_ID_1,
            commit_type=self.COMMIT_TYPE,
            commit_message=self.COMMIT_MESSAGE,
            commit_cmds=self.COMMIT_CMDS,
        ).put()

        story_models.StorySnapshotMetadataModel(
            id=self.GENERIC_MODEL_ID,
            committer_id=self.USER_ID_1,
            commit_type=self.COMMIT_TYPE,
            commit_message=self.COMMIT_MESSAGE,
            commit_cmds=self.COMMIT_CMDS,
        ).put()

        question_models.QuestionSnapshotMetadataModel(
            id=self.GENERIC_MODEL_ID,
            committer_id=self.USER_ID_1,
            commit_type=self.COMMIT_TYPE,
            commit_message=self.COMMIT_MESSAGE,
            commit_cmds=self.COMMIT_CMDS,
        ).put()

        exploration_models.ExplorationRightsSnapshotMetadataModel(
            id=self.GENERIC_MODEL_ID,
            committer_id=self.USER_ID_1,
            commit_type=self.COMMIT_TYPE,
            commit_message=self.COMMIT_MESSAGE,
            commit_cmds=self.COMMIT_CMDS,
        ).put()

        improvements_models.ExplorationStatsTaskEntryModel(
            id=self.GENERIC_MODEL_ID,
            composite_entity_id=self.GENERIC_MODEL_ID,
            entity_type=constants.TASK_ENTITY_TYPE_EXPLORATION,
            entity_id=self.GENERIC_MODEL_ID,
            entity_version=1,
            task_type=constants.TASK_TYPE_HIGH_BOUNCE_RATE,
            target_type=constants.TASK_TARGET_TYPE_STATE,
            target_id=self.GENERIC_MODEL_ID,
            status=constants.TASK_STATUS_OPEN,
            resolver_id=self.USER_ID_1,
        ).put()

        config_models.PlatformParameterSnapshotMetadataModel(
            id=self.GENERIC_MODEL_ID,
            committer_id=self.USER_ID_1,
            commit_type=self.COMMIT_TYPE,
            commit_message=self.COMMIT_MESSAGE,
            commit_cmds=self.COMMIT_CMDS,
        ).put()
        certificate_assessment_offering_models.CertificateAssessmentOfferingSnapshotMetadataModel(
            id=self.GENERIC_MODEL_ID,
            committer_id=self.USER_ID_1,
            commit_type=self.COMMIT_TYPE,
            commit_message=self.COMMIT_MESSAGE,
            commit_cmds=self.COMMIT_CMDS,
        ).put()
        certificate_assessment_offering_models.CertificateAssessmentAttemptModel.create(
            learner_id=self.USER_ID_1,
            total_score=84.5,
            attempt_index=1,
            attempt_data={
                self.TOPIC_ID_1: {
                    'total_related_questions': 5,
                    'total_correct_questions': 3,
                }
            },
            version_data={
                'certificate_id': 'cert_abc123',
                'certificate_version': 1,
                'topic_versions': {self.TOPIC_ID_1: 2},
                'question_versions': {'question_id_1': 1},
                'question_topic_links': {'question_id_1': [self.TOPIC_ID_1]},
            },
            started_at=datetime.datetime(2026, 1, 2, 3, 4, 5),
            finished_at=datetime.datetime(2026, 1, 2, 3, 11, 5),
            is_submitted=True,
        )
        user_models.UserEmailPreferencesModel(
            id=self.USER_ID_1,
            site_updates=False,
            editor_role_notifications=False,
            feedback_message_notifications=False,
            subscription_notifications=False,
        ).put()
        auth_models.UserAuthDetailsModel(
            id=self.USER_ID_1, parent_user_id=self.PROFILE_ID_1
        ).put()

        # Set-up for AppFeedbackReportModel scrubbed by user.
        report_id = '%s.%s.%s' % (
            self.PLATFORM_ANDROID,
            self.REPORT_SUBMITTED_TIMESTAMP.second,
            'randomInteger123',
        )
        app_feedback_report_models.AppFeedbackReportModel(
            id=report_id,
            platform=self.PLATFORM_ANDROID,
            scrubbed_by=None,
            ticket_id='%s.%s.%s'
            % (
                'random_hash',
                self.TICKET_CREATION_TIMESTAMP.second,
                '16CharString1234',
            ),
            submitted_on=self.REPORT_SUBMITTED_TIMESTAMP,
            local_timezone_offset_hrs=0,
            report_type=self.REPORT_TYPE_SUGGESTION,
            category=self.CATEGORY_OTHER,
            platform_version=self.PLATFORM_VERSION,
            android_device_country_locale_code=(
                self.DEVICE_COUNTRY_LOCALE_CODE_INDIA
            ),
            android_device_model=self.ANDROID_DEVICE_MODEL,
            android_sdk_version=self.ANDROID_SDK_VERSION,
            entry_point=self.ENTRY_POINT_NAVIGATION_DRAWER,
            text_language_code=self.TEXT_LANGUAGE_CODE_ENGLISH,
            audio_language_code=self.AUDIO_LANGUAGE_CODE_ENGLISH,
            android_report_info=self.ANDROID_REPORT_INFO,
            android_report_info_schema_version=(
                self.ANDROID_REPORT_INFO_SCHEMA_VERSION
            ),
        ).put()
        report_entity = (
            app_feedback_report_models.AppFeedbackReportModel.get_by_id(
                report_id
            )
        )
        report_entity.scrubbed_by = self.USER_ID_1
        report_entity.update_timestamps()
        report_entity.put()

        # Set-up for the BlogPostModel.
        blog_post_model = blog_models.BlogPostModel(
            id=self.BLOG_POST_ID_1,
            author_id=self.USER_ID_1,
            content='content sample',
            title='sample title',
            published_on=utils.get_current_utc_datetime(),
            url_fragment='sample-url-fragment',
            tags=['tag', 'one'],
            thumbnail_filename='thumbnail',
        )
        blog_post_model.update_timestamps()
        blog_post_model.put()

        blog_post_rights_for_post_1 = blog_models.BlogPostRightsModel(
            id=self.BLOG_POST_ID_1,
            editor_ids=[self.USER_ID_1],
            blog_post_is_published=True,
        )

        blog_post_rights_for_post_1.update_timestamps()
        blog_post_rights_for_post_1.put()

        blog_post_rights_for_post_2 = blog_models.BlogPostRightsModel(
            id=self.BLOG_POST_ID_2,
            editor_ids=[self.USER_ID_1],
            blog_post_is_published=False,
        )

        blog_post_rights_for_post_2.update_timestamps()
        blog_post_rights_for_post_2.put()

        blog_models.BlogAuthorDetailsModel.create(
            author_id=self.USER_ID_1,
            displayed_author_name='general name',
            author_bio='general blog author',
        )

        learner_group_model = learner_group_models.LearnerGroupModel(
            id=self.LEARNER_GROUP_ID,
            title='sample title',
            description='sample description',
            facilitator_user_ids=[self.USER_ID_1],
            learner_user_ids=['user_id_2'],
            invited_learner_user_ids=['user_id_3'],
            subtopic_page_ids=['subtopic_id_1', 'subtopic_id_2'],
            story_ids=['skill_id_1', 'skill_id_2'],
        )
        learner_group_model.update_timestamps()
        learner_group_model.put()

        learner_grp_user_model = user_models.LearnerGroupsUserModel(
            id=self.USER_ID_1,
            invited_to_learner_groups_ids=['group_id_1'],
            learner_groups_user_details=[
                {
                    'group_id': 'group_id_2',
                    'progress_sharing_is_turned_on': False,
                }
            ],
            learner_groups_user_details_schema_version=1,
        )
        learner_grp_user_model.update_timestamps()
        learner_grp_user_model.put()

    def set_up_trivial(self) -> None:
        """Setup for trivial test of export_data functionality."""
        user_models.UserSettingsModel(
            id=self.USER_ID_1, email=self.USER_1_EMAIL, roles=[self.USER_1_ROLE]
        ).put()
        user_models.UserSettingsModel(
            id=self.PROFILE_ID_1,
            email=self.USER_1_EMAIL,
            roles=[self.PROFILE_1_ROLE],
        ).put()
        user_models.UserSubscriptionsModel(id=self.USER_ID_1).put()

    def test_export_nonexistent_full_user_raises_error(self) -> None:
        """Setup for nonexistent user test of export_data functionality."""
        with self.assertRaisesRegex(
            user_models.UserSettingsModel.EntityNotFoundError,
            'Entity for class UserSettingsModel with id fake_user_id '
            'not found',
        ):
            takeout_service.export_data_for_user('fake_user_id')

    def test_export_data_for_full_user_trivial_is_correct(self) -> None:
        """Trivial test of export_data functionality."""
        self.set_up_trivial()
        self.maxDiff = None
        # Generate expected output.
        app_feedback_report: Dict[str, Dict[str, Union[str, int]]] = {}
        collection_progress_data: Dict[str, List[str]] = {}
        collection_rights_data: Dict[str, List[str]] = {
            'editable_collection_ids': [],
            'owned_collection_ids': [],
            'viewable_collection_ids': [],
            'voiced_collection_ids': [],
        }
        completed_activities_data: Dict[str, List[str]] = {}
        contribution_data: Dict[str, List[str]] = {}
        exploration_rights_data: Dict[str, List[str]] = {
            'editable_exploration_ids': [],
            'owned_exploration_ids': [],
            'viewable_exploration_ids': [],
            'voiced_exploration_ids': [],
        }
        exploration_data: Dict[
            str, Dict[str, Union[str, int, Dict[str, str]]]
        ] = {}
        general_feedback_message_data: Dict[str, Dict[str, Union[int, str]]] = (
            {}
        )
        general_feedback_thread_data: Dict[str, Dict[str, Union[int, str]]] = {}
        general_feedback_thread_user_data: Dict[str, Dict[str, List[int]]] = {}
        general_suggestion_data: Dict[str, Dict[str, Union[int, str]]] = {}
        last_playthrough_data: Dict[str, Dict[str, Union[int, str]]] = {}
        learner_goals_data: Dict[str, List[str]] = {}
        lesson_feedback_model_data: Dict[str, Dict[str, Union[int, str]]] = {}
        incomplete_activities_data: Dict[str, List[str]] = {}
        user_settings_data: Dict[str, Union[List[str], Optional[str], int]] = {
            'email': 'user1@example.com',
            'roles': [feconf.ROLE_ID_CURRICULUM_ADMIN],
            'banned': False,
            'username': None,
            'normalized_username': None,
            'last_agreed_to_terms_msec': None,
            'last_started_state_editor_tutorial_msec': None,
            'last_started_state_translation_tutorial_msec': None,
            'last_logged_in_msec': None,
            'last_edited_an_exploration_msec': None,
            'last_created_an_exploration_msec': None,
            'default_dashboard': 'learner',
            'creator_dashboard_display_pref': 'card',
            'user_bio': None,
            'subject_interests': [],
            'first_contribution_msec': None,
            'preferred_language_codes': [],
            'preferred_site_language_code': None,
            'preferred_audio_language_code': None,
            'preferred_translation_language_code': None,
            'display_alias': None,
            'has_viewed_lesson_info_modal_once': False,
            'profile_name_for_certificate': None,
        }
        user_group: Dict[str, str] = {}
        skill_data: Dict[str, str] = {}
        stats_data: Dict[str, stats_domain.AggregatedStatsDict] = {}
        story_progress_data: Dict[str, List[str]] = {}
        subscriptions_data: Dict[str, Optional[List[str]]] = {
            'exploration_ids': [],
            'collection_ids': [],
            'creator_usernames': [],
            'general_feedback_thread_ids': [],
            'last_checked_msec': None,
        }
        task_entry_data: Dict[str, List[str]] = {
            'task_ids_resolved_by_user': [],
            'issue_descriptions': [],
            'resolution_msecs': [],
            'statuses': [],
        }
        topic_rights_data: Dict[str, List[str]] = {'managed_topic_ids': []}

        expected_contrib_proficiency_data: Dict[
            str, Dict[str, Union[int, bool]]
        ] = {}
        expected_contribution_rights_data: Dict[str, Union[bool, List[str]]] = (
            {}
        )

        expected_pinned_opportunities_data: Dict[str, Dict[str, str]] = {}
        expected_collection_rights_sm: Dict[str, Dict[str, Dict[str, str]]] = {}
        expected_collection_sm: Dict[str, Dict[str, Dict[str, str]]] = {}
        expected_skill_sm: Dict[str, Dict[str, Dict[str, str]]] = {}
        expected_subtopic_page_sm: Dict[str, Dict[str, Dict[str, str]]] = {}
        expected_study_guide_sm: Dict[str, Dict[str, Dict[str, str]]] = {}
        expected_topic_rights_sm: Dict[str, Dict[str, Dict[str, str]]] = {}
        expected_topic_sm: Dict[str, Dict[str, Dict[str, str]]] = {}
        expected_translation_contribution_stats: Dict[
            str, Dict[str, Dict[str, str]]
        ] = {}
        expected_translation_review_stats: Dict[
            str, Dict[str, Dict[str, str]]
        ] = {}
        expected_question_contribution_stats: Dict[
            str, Dict[str, Dict[str, str]]
        ] = {}
        expected_question_review_stats: Dict[str, Dict[str, Dict[str, str]]] = (
            {}
        )
        expected_translation_submitter_total_contribution_stats: Dict[
            str, Dict[str, Dict[str, str]]
        ] = {}
        expected_translation_reviewer_total_contribution_stats: Dict[
            str, Dict[str, Dict[str, str]]
        ] = {}
        expected_question_submitter_total_contribution_stats: Dict[
            str, Dict[str, Dict[str, str]]
        ] = {}
        expected_question_reviewer_total_contribution_stats: Dict[
            str, Dict[str, Dict[str, str]]
        ] = {}
        expected_translation_coordinator_stats: Dict[str, List[str]] = {
            'coordinated_language_ids': []
        }
        expected_story_sm: Dict[str, Dict[str, Dict[str, str]]] = {}
        expected_question_sm: Dict[str, Dict[str, Dict[str, str]]] = {}
        expected_exploration_rights_sm: Dict[str, Dict[str, Dict[str, str]]] = (
            {}
        )
        expected_exploration_sm: Dict[str, Dict[str, Dict[str, str]]] = {}
        expected_platform_parameter_sm: Dict[str, Dict[str, Dict[str, str]]] = (
            {}
        )
        expected_certificate_assessment_offering_sm: Dict[
            str, Dict[str, Dict[str, str]]
        ] = {}
        expected_certificate_assessment_attempt_data: Dict[
            str, Dict[str, Union[float, int, Dict[str, Dict[str, int]], bool]]
        ] = {}
        expected_user_auth_details: Dict[str, str] = {}
        expected_user_email_preferences: Dict[str, str] = {}
        expected_blog_post_data: Dict[str, Union[str, float, List[str]]] = {}
        expected_blog_post_rights: Dict[str, List[str]] = {
            'editable_blog_post_ids': []
        }
        expected_blog_author_details: Dict[str, Dict[str, str]] = {}
        expected_learner_group_model_data: Dict[str, str] = {}
        expected_learner_grp_user_model_data: Dict[str, str] = {}
        expected_learner_playlist_data: Dict[str, List[str]] = {
            'exploration_ids': [],
            'collection_ids': [],
        }

        # Here we use type Any because this dictionary contains other
        # different types of dictionaries whose values can vary from int
        # to complex Union types. So, to make this Dict generalized for
        # every other Dict. We used Any here.
        expected_user_data: Dict[str, Dict[str, Any]] = {
            'app_feedback_report': app_feedback_report,
            'blog_post': expected_blog_post_data,
            'blog_post_rights': expected_blog_post_rights,
            'blog_author_details': expected_blog_author_details,
            'user_stats': stats_data,
            'user_settings': user_settings_data,
            'user_subscriptions': subscriptions_data,
            'user_group': user_group,
            'user_skill_mastery': skill_data,
            'user_contributions': contribution_data,
            'exploration_user_data': exploration_data,
            'completed_activities': completed_activities_data,
            'incomplete_activities': incomplete_activities_data,
            'exp_user_last_playthrough': last_playthrough_data,
            'learner_goals': learner_goals_data,
            'learner_group': expected_learner_group_model_data,
            'learner_groups_user': expected_learner_grp_user_model_data,
            'learner_playlist': expected_learner_playlist_data,
            'lesson_feedback': lesson_feedback_model_data,
            'exploration_stats_task_entry': task_entry_data,
            'topic_rights': topic_rights_data,
            'collection_progress': collection_progress_data,
            'story_progress': story_progress_data,
            'general_feedback_thread': general_feedback_thread_data,
            'general_feedback_thread_user': general_feedback_thread_user_data,
            'general_feedback_message': general_feedback_message_data,
            'collection_rights': collection_rights_data,
            'general_suggestion': general_suggestion_data,
            'exploration_rights': exploration_rights_data,
            'user_contribution_proficiency': expected_contrib_proficiency_data,
            'user_contribution_rights': expected_contribution_rights_data,
            'collection_rights_snapshot_metadata': expected_collection_rights_sm,
            'collection_snapshot_metadata': expected_collection_sm,
            'skill_snapshot_metadata': expected_skill_sm,
            'subtopic_page_snapshot_metadata': expected_subtopic_page_sm,
            'study_guide_snapshot_metadata': expected_study_guide_sm,
            'topic_rights_snapshot_metadata': expected_topic_rights_sm,
            'topic_snapshot_metadata': expected_topic_sm,
            'translation_contribution_stats': expected_translation_contribution_stats,
            'translation_review_stats': expected_translation_review_stats,
            'question_contribution_stats': expected_question_contribution_stats,
            'question_review_stats': expected_question_review_stats,
            'translation_submitter_total_contribution_stats': expected_translation_submitter_total_contribution_stats,
            'translation_reviewer_total_contribution_stats': expected_translation_reviewer_total_contribution_stats,
            'question_submitter_total_contribution_stats': expected_question_submitter_total_contribution_stats,
            'question_reviewer_total_contribution_stats': expected_question_reviewer_total_contribution_stats,
            'pinned_opportunity': expected_pinned_opportunities_data,
            'translation_coordinators': expected_translation_coordinator_stats,
            'story_snapshot_metadata': expected_story_sm,
            'question_snapshot_metadata': expected_question_sm,
            'exploration_rights_snapshot_metadata': expected_exploration_rights_sm,
            'exploration_snapshot_metadata': expected_exploration_sm,
            'platform_parameter_snapshot_metadata': expected_platform_parameter_sm,
            'certificate_assessment_offering_snapshot_metadata': (
                expected_certificate_assessment_offering_sm
            ),
            'certificate_assessment_attempt': (
                expected_certificate_assessment_attempt_data
            ),
            'user_auth_details': expected_user_auth_details,
            'user_email_preferences': expected_user_email_preferences,
        }

        # Perform export and compare.
        user_takeout_object = takeout_service.export_data_for_user(
            self.USER_ID_1
        )
        observed_data = user_takeout_object.user_data
        observed_images = user_takeout_object.user_images
        self.assertEqual(expected_user_data, observed_data)
        observed_json = json.dumps(observed_data)
        expected_json = json.dumps(expected_user_data)
        self.assertEqual(json.loads(expected_json), json.loads(observed_json))
        expected_images: List[takeout_domain.TakeoutImage] = []
        self.assertEqual(expected_images, observed_images)

    def test_export_data_for_full_user_when_user_id_is_leaked_fails(
        self,
    ) -> None:
        user_models.UserSettingsModel(
            id=self.USER_ID_1,
            email=self.USER_1_EMAIL,
            roles=[self.USER_1_ROLE],
            user_bio='I want to leak uid_abcdefghijabcdefghijabcdefghijab',
        ).put()
        with self.capture_logging(min_level=logging.ERROR) as log_messages:
            takeout_service.export_data_for_user(self.USER_ID_1)
            self.assertEqual(
                [
                    '[TAKEOUT] User ID (uid_abcdefghijabcdefghijabcdefghijab) '
                    'found in the JSON generated for UserSettingsModel and '
                    'user with ID user_1'
                ],
                log_messages,
            )

    def test_export_data_when_user_settings_is_none(self) -> None:
        user_models.UserSettingsModel(
            id=self.USER_ID_1,
            email=self.USER_1_EMAIL,
            roles=[self.USER_1_ROLE],
            user_bio='I want to leak uid_abcdefghijabcdefghijabcdefghijab',
        ).put()

        with self.swap(
            user_services,
            'get_user_settings',
            lambda _, strict: None,  # pylint: disable=unused-argument
        ):
            user_takeout_object = takeout_service.export_data_for_user(
                self.USER_ID_1
            )
            observed_images = user_takeout_object.user_images
            expected_images: List[takeout_domain.TakeoutImage] = []
            self.assertEqual(expected_images, observed_images)

    def test_exports_have_single_takeout_dict_key(self) -> None:
        """Test to ensure that all export policies that specify a key for the
        Takeout dict are also models that specify this policy are type
        MULTIPLE_INSTANCES_PER_USER.
        """
        self.set_up_non_trivial()
        # We set up the feedback_thread_model here so that we can easily
        # access it when computing the expected data later.
        feedback_thread_model = feedback_models.GeneralFeedbackThreadModel(
            entity_type=self.THREAD_ENTITY_TYPE,
            entity_id=self.THREAD_ENTITY_ID,
            original_author_id=self.USER_ID_1,
            status=self.THREAD_STATUS,
            subject=self.THREAD_SUBJECT,
            has_suggestion=self.THREAD_HAS_SUGGESTION,
            summary=self.THREAD_SUMMARY,
            message_count=self.THREAD_MESSAGE_COUNT,
        )
        feedback_thread_model.put()

        thread_id = feedback_services.create_thread(
            self.THREAD_ENTITY_TYPE,
            self.THREAD_ENTITY_ID,
            self.USER_ID_1,
            self.THREAD_SUBJECT,
            self.MESSAGE_TEXT,
        )
        feedback_services.create_message(
            thread_id,
            self.USER_ID_1,
            self.THREAD_STATUS,
            self.THREAD_SUBJECT,
            self.MESSAGE_TEXT,
        )

        # Retrieve all models for export.
        all_models = [
            clazz
            for clazz in test_utils.get_storage_model_classes()
            if (
                not clazz.__name__
                in test_utils.BASE_MODEL_CLASSES_WITHOUT_DATA_POLICIES
            )
        ]

        for model in all_models:
            export_method = model.get_model_association_to_user()
            export_policy = model.get_export_policy()
            num_takeout_keys = 0
            for field_export_policy in export_policy.values():
                if (
                    field_export_policy
                    == base_models.EXPORT_POLICY.EXPORTED_AS_KEY_FOR_TAKEOUT_DICT
                ):
                    num_takeout_keys += 1

            if (
                export_method
                == base_models.MODEL_ASSOCIATION_TO_USER.MULTIPLE_INSTANCES_PER_USER
            ):
                # If the id is used as a Takeout key, then we should not
                # have any fields exported as the key for the Takeout.
                self.assertEqual(
                    num_takeout_keys,
                    0 if model.ID_IS_USED_AS_TAKEOUT_KEY else 1,
                )
            else:
                self.assertEqual(num_takeout_keys, 0)

    def test_exports_follow_export_policies(self) -> None:
        """Test to ensure that all fields that should be exported
        per the export policy are exported, and exported in the proper format.
        """
        self.set_up_non_trivial()

        # We set up the feedback_thread_model here so that we can easily
        # access it when computing the expected data later.
        feedback_thread_model = feedback_models.GeneralFeedbackThreadModel(
            entity_type=self.THREAD_ENTITY_TYPE,
            entity_id=self.THREAD_ENTITY_ID,
            original_author_id=self.USER_ID_1,
            status=self.THREAD_STATUS,
            subject=self.THREAD_SUBJECT,
            has_suggestion=self.THREAD_HAS_SUGGESTION,
            summary=self.THREAD_SUMMARY,
            message_count=self.THREAD_MESSAGE_COUNT,
        )
        feedback_thread_model.put()

        thread_id = feedback_services.create_thread(
            self.THREAD_ENTITY_TYPE,
            self.THREAD_ENTITY_ID,
            self.USER_ID_1,
            self.THREAD_SUBJECT,
            self.MESSAGE_TEXT,
        )
        feedback_services.create_message(
            thread_id,
            self.USER_ID_1,
            self.THREAD_STATUS,
            self.THREAD_SUBJECT,
            self.MESSAGE_TEXT,
        )

        # Retrieve all models for export.
        all_models = [
            clazz
            for clazz in test_utils.get_storage_model_classes()
            if (
                not clazz.__name__
                in test_utils.BASE_MODEL_CLASSES_WITHOUT_DATA_POLICIES
            )
        ]

        # Iterate over models and test export policies.
        for model in all_models:
            export_method = model.get_model_association_to_user()
            export_policy = model.get_export_policy()
            renamed_export_keys = model.get_field_names_for_takeout()
            exported_field_names = []
            field_used_as_key_for_takeout_dict = None
            for (
                field_name
            ) in model._properties:  # pylint: disable=protected-access
                if (
                    export_policy[field_name]
                    == base_models.EXPORT_POLICY.EXPORTED
                ):
                    if field_name in renamed_export_keys:
                        exported_field_names.append(
                            renamed_export_keys[field_name]
                        )
                    else:
                        exported_field_names.append(field_name)
                elif (
                    export_policy[field_name]
                    == base_models.EXPORT_POLICY.EXPORTED_AS_KEY_FOR_TAKEOUT_DICT
                ):
                    field_used_as_key_for_takeout_dict = field_name

            if (
                export_method
                == base_models.MODEL_ASSOCIATION_TO_USER.NOT_CORRESPONDING_TO_USER
            ):
                self.assertEqual(len(exported_field_names), 0)
            elif (
                export_method
                == base_models.MODEL_ASSOCIATION_TO_USER.ONE_INSTANCE_PER_USER
            ):
                exported_data = model.export_data(self.USER_ID_1)
                self.assertEqual(
                    sorted([str(key) for key in exported_data.keys()]),
                    sorted(exported_field_names),
                )
            elif (
                export_method
                == base_models.MODEL_ASSOCIATION_TO_USER.ONE_INSTANCE_SHARED_ACROSS_USERS
            ):
                # Here we use MyPy ignore because model is of
                # BaseModel type and BaseModel does not contain
                # get_field_name_mapping_to_takeout_keys attribute,
                # so because of this MyPy throws an error. Thus to
                # avoid the error, we used ignore here.
                self.assertIsNotNone(
                    model.get_field_name_mapping_to_takeout_keys  # type: ignore[attr-defined]
                )
                exported_data = model.export_data(self.USER_ID_1)
                # Here we use MyPy ignore because model is of
                # BaseModel type and BaseModel does not contain
                # get_field_name_mapping_to_takeout_keys(), so
                # because of this MyPy throws an error. Thus to
                # avoid the error, we used ignore here.
                field_mapping = model.get_field_name_mapping_to_takeout_keys()  # type: ignore[attr-defined]
                self.assertEqual(
                    sorted(exported_field_names), sorted(field_mapping.keys())
                )
                self.assertEqual(
                    sorted(exported_data.keys()), sorted(field_mapping.values())
                )
            elif (
                export_method
                == base_models.MODEL_ASSOCIATION_TO_USER.MULTIPLE_INSTANCES_PER_USER
            ):
                exported_data = model.export_data(self.USER_ID_1)
                for model_id in exported_data.keys():
                    # If we are using a field as a Takeout key.
                    if field_used_as_key_for_takeout_dict:
                        # Ensure that we export the field.
                        self.assertEqual(
                            model_id,
                            getattr(model, field_used_as_key_for_takeout_dict),
                        )
                    self.assertEqual(
                        sorted(
                            [str(key) for key in exported_data[model_id].keys()]
                        ),
                        sorted(exported_field_names),
                    )

    def test_export_data_for_full_user_nontrivial_is_correct(self) -> None:
        """Nontrivial test of export_data functionality."""
        self.set_up_non_trivial()
        lesson_feedback_model = general_feedback_models.LessonFeedbackModel(
            id=self.LESSON_FEEDBACK_ID_1,
            author_id=self.USER_ID_1,
            feedback_text=self.LESSON_FEEDBACK_TEXT_1,
            exploration_id='exp_id_1',
            status=feedback_models.STATUS_CHOICES_OPEN,
            lesson_metadata_schema_version=(
                feconf.CURRENT_LESSON_METADATA_SCHEMA_VERSION
            ),
            lesson_metadata=self.lesson_metadata,
            parent_feedback_id=self.PARENT_FEEDBACK_ID_1,
            response_list=self.LESSON_FEEDBACK_RESPONSE_LIST,
            unread_response_count=self.LESSON_FEEDBACK_UNREAD_RESPONSE_COUNT,
        )
        lesson_feedback_model.update_timestamps()
        lesson_feedback_model.put()
        # We set up the feedback_thread_model here so that we can easily
        # access it when computing the expected data later.
        feedback_thread_model = feedback_models.GeneralFeedbackThreadModel(
            entity_type=self.THREAD_ENTITY_TYPE,
            entity_id=self.THREAD_ENTITY_ID,
            original_author_id=self.USER_ID_1,
            status=self.THREAD_STATUS,
            subject=self.THREAD_SUBJECT,
            has_suggestion=self.THREAD_HAS_SUGGESTION,
            summary=self.THREAD_SUMMARY,
            message_count=self.THREAD_MESSAGE_COUNT,
        )
        feedback_thread_model.update_timestamps()
        feedback_thread_model.put()

        user_group_model = user_models.UserGroupModel(
            id='user_group_model',
            name='user_group_name',
            user_ids=[self.USER_ID_1],
        )
        user_group_model.put()

        expected_user_group_data = {
            'user_group_model': {
                'name': 'user_group_name',
                'user_ids': self.USER_ID_1,
            }
        }

        blog_post_model = blog_models.BlogPostModel(
            id=self.BLOG_POST_ID_1,
            author_id=self.USER_ID_1,
            content='content sample',
            title='sample title',
            published_on=utils.get_current_utc_datetime(),
            url_fragment='sample-url-fragment',
            tags=['tag', 'one'],
            thumbnail_filename='thumbnail',
        )
        blog_post_model.update_timestamps()
        blog_post_model.put()

        expected_stats_data = {
            'impact_score': self.USER_1_IMPACT_SCORE,
            'total_plays': self.USER_1_TOTAL_PLAYS,
            'average_ratings': self.USER_1_AVERAGE_RATINGS,
            'num_ratings': self.USER_1_NUM_RATINGS,
            'weekly_creator_stats_list': self.USER_1_WEEKLY_CREATOR_STATS_LIST,
        }
        expected_user_skill_data = {
            self.SKILL_ID_1: self.DEGREE_OF_MASTERY,
            self.SKILL_ID_2: self.DEGREE_OF_MASTERY,
        }
        expected_contribution_data = {
            'created_exploration_ids': [self.EXPLORATION_IDS[0]],
            'edited_exploration_ids': [self.EXPLORATION_IDS[0]],
        }
        expected_exploration_data = {
            self.EXPLORATION_IDS[0]: {
                'rating': 2,
                'rated_on_msec': self.GENERIC_EPOCH,
                'draft_change_list': {'new_content': {}},
                'draft_change_list_last_updated_msec': self.GENERIC_EPOCH,
                'draft_change_list_exp_version': 3,
                'draft_change_list_id': 1,
                'mute_suggestion_notifications': (
                    feconf.DEFAULT_SUGGESTION_NOTIFICATIONS_MUTED_PREFERENCE
                ),
                'mute_feedback_notifications': (
                    feconf.DEFAULT_SUGGESTION_NOTIFICATIONS_MUTED_PREFERENCE
                ),
            }
        }
        expected_completed_activities_data = {
            'completed_exploration_ids': self.EXPLORATION_IDS,
            'completed_collection_ids': self.COLLECTION_IDS,
            'completed_story_ids': self.STORY_IDS,
            'learnt_topic_ids': self.TOPIC_IDS,
        }
        expected_incomplete_activities_data = {
            'incomplete_exploration_ids': self.EXPLORATION_IDS,
            'incomplete_collection_ids': self.COLLECTION_IDS,
            'incomplete_story_ids': self.STORY_IDS,
            'partially_learnt_topic_ids': self.TOPIC_IDS,
        }
        expected_last_playthrough_data = {
            self.EXPLORATION_IDS[0]: {
                'exp_version': self.EXP_VERSION,
                'state_name': self.STATE_NAME,
            }
        }
        expected_learner_goals_data = {'topic_ids_to_learn': self.TOPIC_IDS}
        expected_collection_progress_data = {
            self.COLLECTION_IDS[0]: self.EXPLORATION_IDS
        }
        expected_story_progress_data = {
            self.STORY_ID_1: self.COMPLETED_NODE_IDS_1
        }
        thread_id = feedback_services.create_thread(
            self.THREAD_ENTITY_TYPE,
            self.THREAD_ENTITY_ID,
            self.USER_ID_1,
            self.THREAD_SUBJECT,
            self.MESSAGE_TEXT,
        )
        feedback_services.create_message(
            thread_id,
            self.USER_ID_1,
            self.THREAD_STATUS,
            self.THREAD_SUBJECT,
            self.MESSAGE_TEXT,
        )
        expected_general_feedback_thread_data = {
            feedback_thread_model.id: {
                'entity_type': self.THREAD_ENTITY_TYPE,
                'entity_id': self.THREAD_ENTITY_ID,
                'status': self.THREAD_STATUS,
                'subject': self.THREAD_SUBJECT,
                'has_suggestion': self.THREAD_HAS_SUGGESTION,
                'summary': self.THREAD_SUMMARY,
                'message_count': self.THREAD_MESSAGE_COUNT,
                'last_updated_msec': utils.get_time_in_millisecs(
                    feedback_thread_model.last_updated
                ),
            },
            thread_id: {
                'entity_type': self.THREAD_ENTITY_TYPE,
                'entity_id': self.THREAD_ENTITY_ID,
                'status': self.THREAD_STATUS,
                'subject': self.THREAD_SUBJECT,
                'has_suggestion': False,
                'summary': None,
                'message_count': 2,
                'last_updated_msec': utils.get_time_in_millisecs(
                    feedback_models.GeneralFeedbackThreadModel.get_by_id(
                        thread_id
                    ).last_updated
                ),
            },
        }
        expected_general_feedback_thread_user_data = {
            thread_id: {
                'message_ids_read_by_user': self.MESSAGE_IDS_READ_BY_USER
            }
        }
        expected_general_feedback_message_data = {
            thread_id
            + '.0': {
                'thread_id': thread_id,
                'message_id': 0,
                'updated_status': self.THREAD_STATUS,
                'updated_subject': self.THREAD_SUBJECT,
                'text': self.MESSAGE_TEXT,
                'received_via_email': self.MESSAGE_RECEIEVED_VIA_EMAIL,
            },
            thread_id
            + '.1': {
                'thread_id': thread_id,
                'message_id': 1,
                'updated_status': self.THREAD_STATUS,
                'updated_subject': self.THREAD_SUBJECT,
                'text': self.MESSAGE_TEXT,
                'received_via_email': self.MESSAGE_RECEIEVED_VIA_EMAIL,
            },
        }
        expected_collection_rights_data = {
            'owned_collection_ids': ([self.COLLECTION_IDS[0]]),
            'editable_collection_ids': ([self.COLLECTION_IDS[0]]),
            'voiced_collection_ids': ([self.COLLECTION_IDS[0]]),
            'viewable_collection_ids': [self.COLLECTION_IDS[0]],
        }
        expected_general_suggestion_data = {
            'exploration.exp1.thread_1': {
                'suggestion_type': (feconf.SUGGESTION_TYPE_EDIT_STATE_CONTENT),
                'target_type': feconf.ENTITY_TYPE_EXPLORATION,
                'target_id': self.EXPLORATION_IDS[0],
                'target_version_at_submission': 1,
                'status': suggestion_models.STATUS_IN_REVIEW,
                'change_cmd': self.CHANGE_CMD,
            }
        }
        expected_exploration_rights_data = {
            'owned_exploration_ids': ([self.EXPLORATION_IDS[0]]),
            'editable_exploration_ids': ([self.EXPLORATION_IDS[0]]),
            'voiced_exploration_ids': ([self.EXPLORATION_IDS[0]]),
            'viewable_exploration_ids': [self.EXPLORATION_IDS[0]],
        }
        expected_user_settings_data = {
            'email': self.USER_1_EMAIL,
            'roles': [feconf.ROLE_ID_CURRICULUM_ADMIN],
            'username': self.GENERIC_USERNAME,
            'normalized_username': self.GENERIC_USERNAME,
            'last_agreed_to_terms_msec': self.GENERIC_EPOCH,
            'last_started_state_editor_tutorial_msec': self.GENERIC_EPOCH,
            'last_started_state_translation_tutorial_msec': self.GENERIC_EPOCH,
            'last_logged_in_msec': self.GENERIC_EPOCH,
            'last_edited_an_exploration_msec': self.GENERIC_EPOCH,
            'last_created_an_exploration_msec': self.GENERIC_EPOCH,
            'default_dashboard': 'learner',
            'creator_dashboard_display_pref': 'card',
            'user_bio': self.GENERIC_USER_BIO,
            'subject_interests': self.GENERIC_SUBJECT_INTERESTS,
            'first_contribution_msec': 1,
            'preferred_language_codes': self.GENERIC_LANGUAGE_CODES,
            'preferred_site_language_code': self.GENERIC_LANGUAGE_CODES[0],
            'preferred_audio_language_code': self.GENERIC_LANGUAGE_CODES[0],
            'display_alias': self.GENERIC_DISPLAY_ALIAS,
            'profile_name_for_certificate': None,
        }

        expected_subscriptions_data = {
            'creator_usernames': self.CREATOR_USERNAMES,
            'collection_ids': self.COLLECTION_IDS,
            'exploration_ids': self.EXPLORATION_IDS,
            'general_feedback_thread_ids': self.GENERAL_FEEDBACK_THREAD_IDS
            + [thread_id],
            'last_checked_msec': self.GENERIC_EPOCH,
        }

        expected_task_entry_data = {
            'task_ids_resolved_by_user': [self.GENERIC_MODEL_ID]
        }
        expected_topic_data = {
            'managed_topic_ids': [self.TOPIC_ID_1, self.TOPIC_ID_2]
        }

        expected_contribution_rights_data = {
            'can_review_translation_for_language_codes': ['hi', 'en'],
            'can_review_voiceover_for_language_codes': ['hi'],
            'can_review_questions': True,
        }

        expected_contrib_proficiency_data = {
            self.SCORE_CATEGORY_1: {
                'onboarding_email_sent': False,
                'score': 1.5,
            },
            self.SCORE_CATEGORY_2: {'onboarding_email_sent': False, 'score': 2},
        }
        expected_collection_rights_sm = {
            self.GENERIC_MODEL_ID: {
                'commit_type': self.COMMIT_TYPE,
                'commit_message': self.COMMIT_MESSAGE,
            }
        }
        expected_collection_sm = {
            self.GENERIC_MODEL_ID: {
                'commit_type': self.COMMIT_TYPE,
                'commit_message': self.COMMIT_MESSAGE,
            }
        }

        expected_skill_sm = {
            self.GENERIC_MODEL_ID: {
                'commit_type': self.COMMIT_TYPE,
                'commit_message': self.COMMIT_MESSAGE,
            }
        }
        expected_subtopic_page_sm = {
            self.GENERIC_MODEL_ID: {
                'commit_type': self.COMMIT_TYPE,
                'commit_message': self.COMMIT_MESSAGE,
            }
        }
        expected_study_guide_sm = {
            self.GENERIC_MODEL_ID: {
                'commit_type': self.COMMIT_TYPE,
                'commit_message': self.COMMIT_MESSAGE,
            }
        }
        expected_topic_rights_sm = {
            self.GENERIC_MODEL_ID: {
                'commit_type': self.COMMIT_TYPE,
                'commit_message': self.COMMIT_MESSAGE,
            }
        }
        expected_topic_sm = {
            self.GENERIC_MODEL_ID: {
                'commit_type': self.COMMIT_TYPE,
                'commit_message': self.COMMIT_MESSAGE,
            }
        }

        expected_story_sm = {
            self.GENERIC_MODEL_ID: {
                'commit_type': self.COMMIT_TYPE,
                'commit_message': self.COMMIT_MESSAGE,
            }
        }
        expected_question_sm = {
            self.GENERIC_MODEL_ID: {
                'commit_type': self.COMMIT_TYPE,
                'commit_message': self.COMMIT_MESSAGE,
            }
        }

        expected_exploration_rights_sm = {
            self.GENERIC_MODEL_ID: {
                'commit_type': self.COMMIT_TYPE,
                'commit_message': self.COMMIT_MESSAGE,
            }
        }

        expected_exploration_sm = {
            'exp_1-1': {
                'commit_type': 'create',
                'commit_message': 'New exploration created with title \'A title\'.',
            },
            'exp_1-2': {'commit_type': 'edit', 'commit_message': 'Test edit'},
        }

        expected_platform_parameter_sm = {
            self.GENERIC_MODEL_ID: {
                'commit_type': self.COMMIT_TYPE,
                'commit_message': self.COMMIT_MESSAGE,
            }
        }
        expected_certificate_assessment_offering_sm = {
            self.GENERIC_MODEL_ID: {
                'commit_type': self.COMMIT_TYPE,
                'commit_message': self.COMMIT_MESSAGE,
            }
        }
        certificate_assessment_attempt_model = certificate_assessment_offering_models.CertificateAssessmentAttemptModel.query(
            certificate_assessment_offering_models.CertificateAssessmentAttemptModel.learner_id
            == self.USER_ID_1
        ).get()
        self.assertIsNotNone(certificate_assessment_attempt_model)
        if certificate_assessment_attempt_model is None:
            raise AssertionError(
                'Certificate assessment attempt was not created.'
            )
        expected_certificate_assessment_attempt_data = {
            certificate_assessment_attempt_model.id: {
                'total_score': 84.5,
                'attempt_index': 1,
                'attempt_data': {
                    self.TOPIC_ID_1: {
                        'total_related_questions': 5,
                        'total_correct_questions': 3,
                    }
                },
                'started_at': utils.get_time_in_millisecs(
                    datetime.datetime(2026, 1, 2, 3, 4, 5)
                ),
                'finished_at': utils.get_time_in_millisecs(
                    datetime.datetime(2026, 1, 2, 3, 11, 5)
                ),
                'is_submitted': True,
            }
        }
        expected_user_email_preferences: Dict[str, str] = {}
        expected_user_auth_details: Dict[str, str] = {}
        expected_app_feedback_report = {
            '%s.%s.%s'
            % (
                self.PLATFORM_ANDROID,
                self.REPORT_SUBMITTED_TIMESTAMP.second,
                'randomInteger123',
            ): {
                'scrubbed_by': self.USER_ID_1,
                'ticket_id': self.TICKET_ID,
                'submitted_on': self.REPORT_SUBMITTED_TIMESTAMP.isoformat(),
                'local_timezone_offset_hrs': 0,
                'report_type': self.REPORT_TYPE_SUGGESTION,
                'category': self.CATEGORY_OTHER,
                'platform_version': self.PLATFORM_VERSION,
            }
        }
        expected_blog_post_data = {
            'content': 'content sample',
            'title': 'sample title',
            'published_on': utils.get_time_in_millisecs(
                blog_post_model.published_on
            ),
            'url_fragment': 'sample-url-fragment',
            'tags': ['tag', 'one'],
            'thumbnail_filename': 'thumbnail',
        }
        expected_blog_post_rights = {
            'editable_blog_post_ids': [
                self.BLOG_POST_ID_1,
                self.BLOG_POST_ID_2,
            ],
        }
        expected_blog_author_details = {
            'author_name': 'test name',
            'author_bio': '',
        }
        expected_learner_playlist_data: Dict[str, List[str]] = {
            'exploration_ids': self.EXPLORATION_IDS,
            'collection_ids': self.COLLECTION_IDS,
        }
        expected_learner_group_data = {
            'title': 'sample title',
            'description': 'sample description',
            'role_in_group': 'facilitator',
            'subtopic_page_ids': ['subtopic_id_1', 'subtopic_id_2'],
            'story_ids': ['skill_id_1', 'skill_id_2'],
        }
        expected_learner_groups_user_data = {
            'invited_to_learner_groups_ids': ['group_id_1'],
            'learner_groups_user_details': [
                {
                    'group_id': 'group_id_2',
                    'progress_sharing_is_turned_on': False,
                }
            ],
        }
        expected_lesson_feedback_data = {
            self.LESSON_FEEDBACK_ID_1: {
                'feedback_text': self.LESSON_FEEDBACK_TEXT_1,
                'status': feedback_models.STATUS_CHOICES_OPEN,
                'lesson_metadata': self.lesson_metadata,
                'exploration_id': 'exp_id_1',
                'parent_feedback_id': self.PARENT_FEEDBACK_ID_1,
                'response_list': self.LESSON_FEEDBACK_RESPONSE_LIST,
                'unread_response_count': self.LESSON_FEEDBACK_UNREAD_RESPONSE_COUNT,
                'created_on_msec': utils.get_time_in_millisecs(
                    lesson_feedback_model.created_on
                ),
                'last_updated_msec': utils.get_time_in_millisecs(
                    lesson_feedback_model.last_updated
                ),
            }
        }

        expected_translation_contribution_stats_data = {
            '%s.%s.%s'
            % (
                self.SUGGESTION_LANGUAGE_CODE,
                self.USER_ID_1,
                self.TOPIC_ID_1,
            ): {
                'language_code': self.SUGGESTION_LANGUAGE_CODE,
                'topic_id': self.TOPIC_ID_1,
                'submitted_translations_count': (
                    self.SUBMITTED_TRANSLATIONS_COUNT
                ),
                'submitted_translation_word_count': (
                    self.SUBMITTED_TRANSLATION_WORD_COUNT
                ),
                'accepted_translations_count': (
                    self.ACCEPTED_TRANSLATIONS_COUNT
                ),
                'accepted_translations_without_reviewer_edits_count': (
                    self.ACCEPTED_TRANSLATIONS_WITHOUT_REVIEWER_EDITS_COUNT
                ),
                'accepted_translation_word_count': (
                    self.ACCEPTED_TRANSLATION_WORD_COUNT
                ),
                'rejected_translations_count': (
                    self.REJECTED_TRANSLATIONS_COUNT
                ),
                'rejected_translation_word_count': (
                    self.REJECTED_TRANSLATION_WORD_COUNT
                ),
                'contribution_dates': [
                    date.isoformat() for date in self.CONTRIBUTION_DATES
                ],
            }
        }
        expected_translation_review_stats_data = {
            '%s.%s.%s'
            % (
                self.SUGGESTION_LANGUAGE_CODE,
                self.USER_ID_1,
                self.TOPIC_ID_1,
            ): {
                'language_code': self.SUGGESTION_LANGUAGE_CODE,
                'topic_id': self.TOPIC_ID_1,
                'reviewed_translations_count': (
                    self.REVIEWED_TRANSLATIONS_COUNT
                ),
                'reviewed_translation_word_count': (
                    self.REVIEWED_TRANSLATION_WORD_COUNT
                ),
                'accepted_translations_count': (
                    self.ACCEPTED_TRANSLATIONS_COUNT
                ),
                'accepted_translations_with_reviewer_edits_count': (
                    self.ACCEPTED_TRANSLATIONS_WITH_REVIEWER_EDITS_COUNT
                ),
                'accepted_translation_word_count': (
                    self.ACCEPTED_TRANSLATION_WORD_COUNT
                ),
                'first_contribution_date': (
                    self.FIRST_CONTRIBUTION_DATE.isoformat()
                ),
                'last_contribution_date': (
                    self.LAST_CONTRIBUTION_DATE.isoformat()
                ),
            }
        }
        expected_question_contribution_stats_data = {
            '%s.%s'
            % (self.USER_ID_1, self.TOPIC_ID_1): {
                'topic_id': self.TOPIC_ID_1,
                'submitted_questions_count': (self.SUBMITTED_QUESTIONS_COUNT),
                'accepted_questions_count': (self.ACCEPTED_QUESTIONS_COUNT),
                'accepted_questions_without_reviewer_edits_count': (
                    self.ACCEPTED_QUESTIONS_WITHOUT_REVIEWER_EDITS_COUNT
                ),
                'first_contribution_date': (
                    self.FIRST_CONTRIBUTION_DATE.isoformat()
                ),
                'last_contribution_date': (
                    self.LAST_CONTRIBUTION_DATE.isoformat()
                ),
            }
        }
        expected_question_review_stats_data = {
            '%s.%s'
            % (self.USER_ID_1, self.TOPIC_ID_1): {
                'topic_id': self.TOPIC_ID_1,
                'reviewed_questions_count': (self.REVIEWED_QUESTIONS_COUNT),
                'accepted_questions_count': (self.ACCEPTED_QUESTIONS_COUNT),
                'accepted_questions_with_reviewer_edits_count': (
                    self.ACCEPTED_QUESTIONS_WITH_REVIEWER_EDITS_COUNT
                ),
                'first_contribution_date': (
                    self.FIRST_CONTRIBUTION_DATE.isoformat()
                ),
                'last_contribution_date': (
                    self.LAST_CONTRIBUTION_DATE.isoformat()
                ),
            }
        }
        expected_translation_submitter_total_contribution_stats_data = {
            '%s.%s'
            % (self.SUGGESTION_LANGUAGE_CODE, self.USER_ID_1): {
                'language_code': self.SUGGESTION_LANGUAGE_CODE,
                'topic_ids_with_translation_submissions': (
                    self.TOPIC_IDS_WITH_TRANSLATION_SUBMISSIONS
                ),
                'recent_review_outcomes': self.RECENT_REVIEW_OUTCOMES,
                'recent_performance': self.RECENT_PERFORMANCE,
                'overall_accuracy': self.OVERALL_ACCURACY,
                'submitted_translations_count': (
                    self.SUBMITTED_TRANSLATIONS_COUNT
                ),
                'submitted_translation_word_count': (
                    self.SUBMITTED_TRANSLATION_WORD_COUNT
                ),
                'accepted_translations_count': (
                    self.ACCEPTED_TRANSLATIONS_COUNT
                ),
                'accepted_translations_without_reviewer_edits_count': (
                    self.ACCEPTED_TRANSLATIONS_WITHOUT_REVIEWER_EDITS_COUNT
                ),
                'accepted_translation_word_count': (
                    self.ACCEPTED_TRANSLATION_WORD_COUNT
                ),
                'rejected_translations_count': (
                    self.REJECTED_TRANSLATIONS_COUNT
                ),
                'rejected_translation_word_count': (
                    self.REJECTED_TRANSLATION_WORD_COUNT
                ),
                'first_contribution_date': (
                    self.FIRST_CONTRIBUTION_DATE.isoformat()
                ),
                'last_contribution_date': (
                    self.LAST_CONTRIBUTION_DATE.isoformat()
                ),
            }
        }
        expected_translation_reviewer_total_contribution_stats_data = {
            '%s.%s'
            % (self.SUGGESTION_LANGUAGE_CODE, self.USER_ID_1): {
                'language_code': self.SUGGESTION_LANGUAGE_CODE,
                'topic_ids_with_translation_reviews': (
                    self.TOPIC_IDS_WITH_TRANSLATION_REVIEWS
                ),
                'reviewed_translations_count': (
                    self.REVIEWED_TRANSLATIONS_COUNT
                ),
                'accepted_translations_count': (
                    self.ACCEPTED_TRANSLATIONS_COUNT
                ),
                'accepted_translations_with_reviewer_edits_count': (
                    self.ACCEPTED_TRANSLATIONS_WITH_REVIEWER_EDITS_COUNT
                ),
                'accepted_translation_word_count': (
                    self.ACCEPTED_TRANSLATION_WORD_COUNT
                ),
                'rejected_translations_count': (
                    self.REJECTED_TRANSLATIONS_COUNT
                ),
                'first_contribution_date': (
                    self.FIRST_CONTRIBUTION_DATE.isoformat()
                ),
                'last_contribution_date': (
                    self.LAST_CONTRIBUTION_DATE.isoformat()
                ),
            }
        }
        expected_question_submitter_total_contribution_stats_data = {
            '%s'
            % (self.USER_ID_1): {
                'topic_ids_with_question_submissions': (
                    self.TOPIC_IDS_WITH_QUESTION_SUBMISSIONS
                ),
                'recent_review_outcomes': self.RECENT_REVIEW_OUTCOMES,
                'recent_performance': self.RECENT_PERFORMANCE,
                'overall_accuracy': self.OVERALL_ACCURACY,
                'submitted_questions_count': (self.SUBMITTED_QUESTIONS_COUNT),
                'accepted_questions_count': (self.ACCEPTED_QUESTIONS_COUNT),
                'accepted_questions_without_reviewer_edits_count': (
                    self.ACCEPTED_QUESTIONS_WITHOUT_REVIEWER_EDITS_COUNT
                ),
                'rejected_questions_count': self.REJECTED_QUESTIONS_COUNT,
                'first_contribution_date': (
                    self.FIRST_CONTRIBUTION_DATE.isoformat()
                ),
                'last_contribution_date': (
                    self.LAST_CONTRIBUTION_DATE.isoformat()
                ),
            }
        }
        expected_question_reviewer_total_contribution_stats_data = {
            '%s'
            % (self.USER_ID_1): {
                'topic_ids_with_question_reviews': (
                    self.TOPIC_IDS_WITH_QUESTION_REVIEWS
                ),
                'reviewed_questions_count': (self.REVIEWED_QUESTIONS_COUNT),
                'accepted_questions_count': (self.ACCEPTED_QUESTIONS_COUNT),
                'accepted_questions_with_reviewer_edits_count': (
                    self.ACCEPTED_QUESTIONS_WITH_REVIEWER_EDITS_COUNT
                ),
                'rejected_questions_count': self.REJECTED_QUESTIONS_COUNT,
                'first_contribution_date': (
                    self.FIRST_CONTRIBUTION_DATE.isoformat()
                ),
                'last_contribution_date': (
                    self.LAST_CONTRIBUTION_DATE.isoformat()
                ),
            }
        }
        expected_pinned_opportunities_data: Dict[str, Dict[str, str]] = {
            '%s_%s'
            % (self.SUGGESTION_LANGUAGE_CODE, self.TOPIC_ID_1): {
                'opportunity_id': self.EXPLORATION_IDS[0],
            }
        }
        expected_translation_coordinator_stats_data = {
            'coordinated_language_ids': ['es', 'hi']
        }
        expected_user_data = {
            'user_stats': expected_stats_data,
            'user_group': expected_user_group_data,
            'user_settings': expected_user_settings_data,
            'user_subscriptions': expected_subscriptions_data,
            'user_skill_mastery': expected_user_skill_data,
            'user_contributions': expected_contribution_data,
            'exploration_user_data': expected_exploration_data,
            'completed_activities': expected_completed_activities_data,
            'incomplete_activities': expected_incomplete_activities_data,
            'exp_user_last_playthrough': expected_last_playthrough_data,
            'learner_goals': expected_learner_goals_data,
            'learner_group': expected_learner_group_data,
            'learner_groups_user': expected_learner_groups_user_data,
            'learner_playlist': expected_learner_playlist_data,
            'lesson_feedback': expected_lesson_feedback_data,
            'exploration_stats_task_entry': expected_task_entry_data,
            'topic_rights': expected_topic_data,
            'collection_progress': expected_collection_progress_data,
            'story_progress': expected_story_progress_data,
            'general_feedback_thread': expected_general_feedback_thread_data,
            'general_feedback_thread_user': expected_general_feedback_thread_user_data,
            'general_feedback_message': expected_general_feedback_message_data,
            'collection_rights': expected_collection_rights_data,
            'general_suggestion': expected_general_suggestion_data,
            'exploration_rights': expected_exploration_rights_data,
            'user_contribution_proficiency': expected_contrib_proficiency_data,
            'user_contribution_rights': expected_contribution_rights_data,
            'collection_rights_snapshot_metadata': expected_collection_rights_sm,
            'collection_snapshot_metadata': expected_collection_sm,
            'skill_snapshot_metadata': expected_skill_sm,
            'subtopic_page_snapshot_metadata': expected_subtopic_page_sm,
            'study_guide_snapshot_metadata': expected_study_guide_sm,
            'topic_rights_snapshot_metadata': expected_topic_rights_sm,
            'topic_snapshot_metadata': expected_topic_sm,
            'translation_contribution_stats': expected_translation_contribution_stats_data,
            'translation_review_stats': expected_translation_review_stats_data,
            'question_contribution_stats': expected_question_contribution_stats_data,
            'question_review_stats': expected_question_review_stats_data,
            'translation_submitter_total_contribution_stats': expected_translation_submitter_total_contribution_stats_data,
            'translation_reviewer_total_contribution_stats': expected_translation_reviewer_total_contribution_stats_data,
            'question_submitter_total_contribution_stats': expected_question_submitter_total_contribution_stats_data,
            'question_reviewer_total_contribution_stats': expected_question_reviewer_total_contribution_stats_data,
            'translation_coordinators': expected_translation_coordinator_stats_data,
            'pinned_opportunity': expected_pinned_opportunities_data,
            'story_snapshot_metadata': expected_story_sm,
            'question_snapshot_metadata': expected_question_sm,
            'exploration_rights_snapshot_metadata': expected_exploration_rights_sm,
            'exploration_snapshot_metadata': expected_exploration_sm,
            'platform_parameter_snapshot_metadata': expected_platform_parameter_sm,
            'certificate_assessment_offering_snapshot_metadata': (
                expected_certificate_assessment_offering_sm
            ),
            'certificate_assessment_attempt': (
                expected_certificate_assessment_attempt_data
            ),
            'user_email_preferences': expected_user_email_preferences,
            'user_auth_details': expected_user_auth_details,
            'app_feedback_report': expected_app_feedback_report,
            'blog_post': expected_blog_post_data,
            'blog_post_rights': expected_blog_post_rights,
            'blog_author_details': expected_blog_author_details,
        }

        with open(
            os.path.join(feconf.TESTS_DATA_DIR, 'test_png_img.png'),
            'rb',
            encoding=None,
        ) as f:
            raw_image_png = f.read()
        with open(
            os.path.join(feconf.TESTS_DATA_DIR, 'test_png_img.webp'),
            'rb',
            encoding=None,
        ) as f:
            raw_image_webp = f.read()
        fs = fs_services.GcsFileSystem(
            feconf.ENTITY_TYPE_USER, self.GENERIC_USERNAME
        )
        fs.commit('profile_picture.png', raw_image_png, mimetype='image/png')
        fs.commit('profile_picture.webp', raw_image_webp, mimetype='image/webp')

        user_takeout_object = takeout_service.export_data_for_user(
            self.USER_ID_1
        )
        observed_data = user_takeout_object.user_data
        observed_images = user_takeout_object.user_images
        self.assertItemsEqual(observed_data, expected_user_data)
        observed_json = json.dumps(observed_data)
        expected_json = json.dumps(expected_user_data)
        self.assertItemsEqual(
            json.loads(observed_json), json.loads(expected_json)
        )
        expected_images = [
            takeout_domain.TakeoutImage(
                self.PROFILE_PICTURE_DATA_PNG,
                'user_settings_profile_picture.png',
            ),
            takeout_domain.TakeoutImage(
                self.PROFILE_PICTURE_DATA_WEBP,
                'user_settings_profile_picture.webp',
            ),
        ]
        self.assertEqual(len(expected_images), len(observed_images))
        for i, expected_image in enumerate(expected_images):
            self.assertEqual(
                expected_image.b64_image_data, observed_images[i].b64_image_data
            )
            self.assertEqual(
                expected_image.image_export_path,
                observed_images[i].image_export_path,
            )

    def test_export_for_full_user_does_not_export_profile_data(self) -> None:
        """Test that exporting data for a full user does not export
        data for any profile user, atleast for the models that were
        populated for the profile user.
        """
        self.set_up_non_trivial()
        profile_user_settings_data = {
            'email': self.USER_1_EMAIL,
            'roles': [self.PROFILE_1_ROLE],
            'username': None,
            'normalized_username': None,
            'last_agreed_to_terms_msec': self.GENERIC_DATE,
            'last_started_state_editor_tutorial_msec': None,
            'last_started_state_translation_tutorial': None,
            'last_logged_in_msec': self.GENERIC_DATE,
            'last_created_an_exploration': None,
            'last_edited_an_exploration': None,
            'default_dashboard': 'learner',
            'creator_dashboard_display_pref': 'card',
            'user_bio': self.GENERIC_USER_BIO,
            'subject_interests': self.GENERIC_SUBJECT_INTERESTS,
            'first_contribution_msec': None,
            'preferred_language_codes': self.GENERIC_LANGUAGE_CODES,
            'preferred_site_language_code': self.GENERIC_LANGUAGE_CODES[0],
            'preferred_audio_language_code': self.GENERIC_LANGUAGE_CODES[0],
            'display_alias': self.GENERIC_DISPLAY_ALIAS_2,
            'profile_name_for_certificate': None,
        }
        user_skill_data = {self.SKILL_ID_3: self.DEGREE_OF_MASTERY_2}
        completed_activities_data = {
            'completed_exploration_ids': self.EXPLORATION_IDS_2,
            'completed_collection_ids': self.COLLECTION_IDS_2,
            'completed_story_ids': self.STORY_IDS,
            'learnt_topic_ids': self.TOPIC_IDS,
        }
        incomplete_activities_data: Dict[str, List[str]] = {}
        last_playthrough_data: Dict[str, Dict[str, Union[str, int]]] = {}
        learner_goals_data: Dict[str, List[str]] = {}
        collection_progress_data = {
            self.COLLECTION_IDS_2[0]: self.EXPLORATION_IDS_2
        }
        story_progress_data = {self.STORY_ID_2: self.COMPLETED_NODE_IDS_2}
        profile_user_data = {
            'user_settings': profile_user_settings_data,
            'user_skill_mastery': user_skill_data,
            'completed_activities': completed_activities_data,
            'incomplete_activities': incomplete_activities_data,
            'exp_user_last_playthrough': last_playthrough_data,
            'learner_goals': learner_goals_data,
            'collection_progress': collection_progress_data,
            'story_progress': story_progress_data,
        }

        with open(
            os.path.join(feconf.TESTS_DATA_DIR, 'test_png_img.png'),
            'rb',
            encoding=None,
        ) as f:
            raw_image_png = f.read()
        with open(
            os.path.join(feconf.TESTS_DATA_DIR, 'test_png_img.webp'),
            'rb',
            encoding=None,
        ) as f:
            raw_image_webp = f.read()
        fs = fs_services.GcsFileSystem(
            feconf.ENTITY_TYPE_USER, self.GENERIC_USERNAME
        )
        fs.commit('profile_picture.png', raw_image_png, mimetype='image/png')
        fs.commit('profile_picture.webp', raw_image_webp, mimetype='image/webp')

        user_takeout_object = takeout_service.export_data_for_user(
            self.USER_ID_1
        )
        observed_data = user_takeout_object.user_data
        for key, value in profile_user_data.items():
            self.assertNotEqual(value, observed_data[key])