feat(egh): wait for course created event in sanity course sync

- Imported `EGGHEAD_COURSE_CREATED_EVENT` to wait for course creation events from Egghead.
- Implemented error handling to throw a `NonRetriableError` if the course is not created.
- Mapped the `railsCourseId` to the newly created course ID and updated the `sharedId` to use the course's slug.
- Improved the overall workflow for course creation in Sanity by ensuring proper event synchronization.

Co-authored-by: Creeland <[email protected]>

apps/egghead/src/inngest/functions/sanity/create-course-in-sanity.ts

@@ -1,3 +1,4 @@
+import { EGGHEAD_COURSE_CREATED_EVENT } from '@/inngest/events/egghead/course-created'
 import { POST_CREATED_EVENT } from '@/inngest/events/post-created'
 import { inngest } from '@/inngest/inngest.server'
 import { SanityCourseSchema } from '@/lib/sanity-content'
@@ -39,22 +40,38 @@ export const createCourseInSanity = inngest.createFunction(
 			return contributor
 		})
 
+		const courseCreatedEvent = await step.waitForEvent(
+			`wait for course created in egghead-rails`,
+			{
+				event: EGGHEAD_COURSE_CREATED_EVENT,
+				timeout: '3 mins',
+			},
+		)
+
+		if (!courseCreatedEvent) {
+			throw new NonRetriableError('Course not created in egghead')
+		}
+
+		const courseId = courseCreatedEvent.data.id
+
 		const sanityCourse = await step.run('create-course', async () => {
 			const { fields } = post
 
+			const courseGuid = fields?.slug.split('~').pop()
+
 			const coursePayload = SanityCourseSchema.safeParse({
 				title: fields?.title,
 				slug: {
 					current: fields?.slug,
 					_type: 'slug',
 				},
 				description: fields?.body,
-				railsCourseId: fields?.railsCourseId,
 				collaborators: [contributor],
 				searchIndexingState: 'hidden',
 				accessLevel: 'pro',
 				productionProcessState: 'new',
-				sharedId: post.id,
+				sharedId: courseGuid,
+				railsCourseId: courseId,
 			})
 
 			if (!coursePayload.success) {