rzmk/learnhouse
1
0
Fork 0
mirror of https://github.com/rzmk/learnhouse.git synced 2025-12-19 04:19:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix: migration issues

Browse source
This commit is contained in:
swve 2023-12-16 12:24:01 +01:00
parent 2d822459fb
commit 0f04092de4
1 changed files with 10 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

19
apps/api/src/services/dev/migration_from_mongo.py
View file

@ -68,7 +68,7 @@ async def start_migrate_from_mongo(request: Request, db_session: Session):
user_org_object = UserOrganization( user_org_object = UserOrganization(
user_id=user_from_db.id, # type: ignore user_id=user_from_db.id, # type: ignore
org_id=org_from_db.id, # type: ignore org_id=org_from_db.id if org_from_db is not None else None, # type: ignore
role_id=1, role_id=1,
creation_date=str(datetime.datetime.now()), creation_date=str(datetime.datetime.now()),
update_date=str(datetime.datetime.now()), update_date=str(datetime.datetime.now()),
@ -98,7 +98,7 @@ async def start_migrate_from_mongo(request: Request, db_session: Session):
course_uuid=course["course_id"], course_uuid=course["course_id"],
thumbnail_image=course["thumbnail"], thumbnail_image=course["thumbnail"],
tags="", tags="",
org_id=org_from_db.id, # type: ignore org_id=org_from_db.id if org_from_db is not None else None, # type: ignore
public=course["public"], public=course["public"],
creation_date=str(course["creationDate"]), creation_date=str(course["creationDate"]),
update_date=str(course["updateDate"]), update_date=str(course["updateDate"]),
@ -120,7 +120,7 @@ async def start_migrate_from_mongo(request: Request, db_session: Session):
authorship = ResourceAuthor( authorship = ResourceAuthor(
resource_uuid=course_from_db.course_uuid, # type: ignore resource_uuid=course_from_db.course_uuid, # type: ignore
user_id=user_from_db.id, # type: ignore user_id=user_from_db.id if user_from_db is not None else None, # type: ignore
authorship=ResourceAuthorshipEnum.CREATOR, authorship=ResourceAuthorshipEnum.CREATOR,
creation_date=str(datetime.datetime.now()), creation_date=str(datetime.datetime.now()),
update_date=str(datetime.datetime.now()), update_date=str(datetime.datetime.now()),
@ -141,7 +141,7 @@ async def start_migrate_from_mongo(request: Request, db_session: Session):
chapter_uuid=chapter["coursechapter_id"].replace( chapter_uuid=chapter["coursechapter_id"].replace(
"coursechapter", "chapter" "coursechapter", "chapter"
), ),
org_id=org_from_db.id, # type: ignore org_id=org_from_db.id if org_from_db is not None else None, # type: ignore
course_id=course_from_db.id, # type: ignore course_id=course_from_db.id, # type: ignore
creation_date=str(datetime.datetime.now()), creation_date=str(datetime.datetime.now()),
update_date=str(datetime.datetime.now()), update_date=str(datetime.datetime.now()),
@ -161,7 +161,7 @@ async def start_migrate_from_mongo(request: Request, db_session: Session):
chapter_id=chapter_from_db.id, # type: ignore chapter_id=chapter_from_db.id, # type: ignore
course_id=course_from_db.id, # type: ignore course_id=course_from_db.id, # type: ignore
order=order, order=order,
org_id=org_from_db.id, # type: ignore org_id=org_from_db.id if org_from_db is not None else None, # type: ignore
creation_date=str(datetime.datetime.now()), creation_date=str(datetime.datetime.now()),
update_date=str(datetime.datetime.now()), update_date=str(datetime.datetime.now()),
) )
@ -187,7 +187,7 @@ async def start_migrate_from_mongo(request: Request, db_session: Session):
type_to_use = ActivityTypeEnum.TYPE_VIDEO type_to_use = ActivityTypeEnum.TYPE_VIDEO
sub_type_to_use = ActivitySubTypeEnum.SUBTYPE_VIDEO_HOSTED sub_type_to_use = ActivitySubTypeEnum.SUBTYPE_VIDEO_HOSTED
if activity["type"] == "external_video": if "external_video" in activity["content"]:
type_to_use = ActivityTypeEnum.TYPE_VIDEO type_to_use = ActivityTypeEnum.TYPE_VIDEO
sub_type_to_use = ActivitySubTypeEnum.SUBTYPE_VIDEO_YOUTUBE sub_type_to_use = ActivitySubTypeEnum.SUBTYPE_VIDEO_YOUTUBE
@ -205,9 +205,10 @@ async def start_migrate_from_mongo(request: Request, db_session: Session):
version=1, version=1,
published_version=1, published_version=1,
activity_type=type_to_use, activity_type=type_to_use,
content=activity["content"],
activity_sub_type=sub_type_to_use, activity_sub_type=sub_type_to_use,
chapter_id=chapter_from_db.id, # type: ignore chapter_id=chapter_from_db.id, # type: ignore
org_id=org_from_db.id, # type: ignore org_id=org_from_db.id if org_from_db is not None else None, # type: ignore
course_id=course_from_db.id, # type: ignore course_id=course_from_db.id, # type: ignore
creation_date=str(activity["creationDate"]), creation_date=str(activity["creationDate"]),
update_date=str(activity["updateDate"]), update_date=str(activity["updateDate"]),
@ -227,7 +228,7 @@ async def start_migrate_from_mongo(request: Request, db_session: Session):
activity_id=activity_from_db.id, # type: ignore activity_id=activity_from_db.id, # type: ignore
order=activity_order, order=activity_order,
course_id=course_from_db.id, # type: ignore course_id=course_from_db.id, # type: ignore
org_id=org_from_db.id, # type: ignore org_id=org_from_db.id if org_from_db is not None else None, # type: ignore
creation_date=str(datetime.datetime.now()), creation_date=str(datetime.datetime.now()),
update_date=str(datetime.datetime.now()), update_date=str(datetime.datetime.now()),
) )
@ -263,7 +264,7 @@ async def start_migrate_from_mongo(request: Request, db_session: Session):
content=block["block_data"], content=block["block_data"],
block_type=type_to_use, block_type=type_to_use,
activity_id=activity_from_db.id, # type: ignore activity_id=activity_from_db.id, # type: ignore
org_id=org_from_db.id, # type: ignore org_id=org_from_db.id if org_from_db is not None else None, # type: ignore
course_id=course_from_db.id, # type: ignore course_id=course_from_db.id, # type: ignore
chapter_id=chapter_from_db.id, # type: ignore chapter_id=chapter_from_db.id, # type: ignore
creation_date=str(datetime.datetime.now()), creation_date=str(datetime.datetime.now()),