wip: start of api

packages/apps/backend/src/api-server/services/PartService.ts

@@ -1,6 +1,11 @@
 import EventEmitter from 'eventemitter3'
 import { Application, PaginationParams, Params } from '@feathersjs/feathers'
-import { ServiceTypes, Services, PartServiceDefinition as Definition } from '@sofie-prompter-editor/shared-model'
+import {
+	ServiceTypes,
+	Services,
+	PartServiceDefinition as Definition,
+	ScriptContents,
+} from '@sofie-prompter-editor/shared-model'
 export { PlaylistServiceDefinition } from '@sofie-prompter-editor/shared-model'
 import { PublishChannels } from '../PublishChannels.js'
 import { CustomFeathersService } from './lib.js'
@@ -110,6 +115,10 @@ export class PartService extends EventEmitter<Definition.Events> implements Defi
 	public async remove(_id: NullId, _params?: Params): Promise<Result> {
 		throw new NotImplemented(`Not supported`)
 	}
+
+	public async updateScript(_id: Id, _scriptContents: ScriptContents): Promise<void> {
+		throw new NotImplemented(`Not implemented`)
+	}
 }
 type Result = Definition.Result
 type Id = Definition.Id

packages/apps/client/src/components/ScriptEditor/Editor.tsx

@@ -13,7 +13,7 @@ import { EXTERNAL_STATE_CHANGE, updateModel } from './plugins/updateModel'
 import { readOnlyNodeFilter } from './plugins/readOnlyNodeFilter'
 import { formatingKeymap } from './keymaps'
 import { deselectAll } from './commands/deselectAll'
-import { fromMarkdown } from 'src/lib/prosemirrorDoc'
+import { fromMarkdown, toMarkdown } from 'src/lib/prosemirrorDoc'
 import { RootAppStore } from 'src/stores/RootAppStore'
 import { IReactionDisposer, reaction } from 'mobx'
 
@@ -216,7 +216,17 @@ function makeNewEditorState(doc: Node): EditorState {
 			keymap(formatingKeymap),
 			keymap(baseKeymap),
 			readOnlyNodeFilter(),
-			updateModel((lineId, change) => console.log(lineId, change, doc)),
+			updateModel((lineId, lineNodes) => {
+				console.log(lineId, lineNodes)
+
+				const compiledMarkdown = toMarkdown(lineNodes)
+				console.log('markdown', compiledMarkdown)
+
+				const openRundown = RootAppStore.rundownStore.openRundown
+
+				// TODO - debounce? require manual execution?
+				if (openRundown) openRundown.updatePartScript(lineId, compiledMarkdown)
+			}),
 		],
 		doc,
 	})

packages/apps/client/src/lib/prosemirrorDoc.ts

@@ -1,7 +1,8 @@
 import { Node as ProsemirrorNode } from 'prosemirror-model'
 import { schema } from 'src/components/ScriptEditor/scriptSchema'
-import { Node as MdAstNode } from './mdParser/astNodes'
+import { Node as MdAstNode, RootNode as MdRootNode } from './mdParser/astNodes'
 import createMdParser from './mdParser'
+import { assertNever } from '@sofie-prompter-editor/shared-lib'
 
 export function fromMarkdown(text: string | null): ProsemirrorNode[] {
 	if (text === null) return []
@@ -41,3 +42,79 @@ function traverseMdAstNodes(nodes: MdAstNode[]): ProsemirrorNode[] {
 
 	return result
 }
+
+export function toMarkdown(nodes: ProsemirrorNode[]): string {
+	if (nodes.length === 0) return ''
+
+	const mdAst: MdRootNode = {
+		type: 'root',
+		children: nodes.map(prosemirrorNodeToMarkdown),
+	}
+
+	return stringifyMarkdown(mdAst)
+}
+
+function stringifyMarkdown(mdAst: MdAstNode): string {
+	if (mdAst.type === 'root') {
+		return mdAst.children.map(stringifyMarkdown).join('')
+	} else if (mdAst.type === 'paragraph') {
+		return mdAst.children.map(stringifyMarkdown).join('') + '\n'
+	} else if (mdAst.type === 'text') {
+		return mdAst.value
+	} else if (mdAst.type === 'emphasis' || mdAst.type === 'strong' || mdAst.type === 'reverse') {
+		return `${mdAst.code}${mdAst.children.map(stringifyMarkdown).join('')}${mdAst.code}`
+	} else {
+		assertNever(mdAst)
+		console.warn(mdAst)
+		return '[UNKNOWN]'
+	}
+}
+
+function prosemirrorNodeToMarkdown(node: ProsemirrorNode): MdAstNode {
+	if (node.type === schema.nodes.paragraph) {
+		const children: MdAstNode[] = []
+		for (let i = 0; i < node.childCount; i++) {
+			children.push(prosemirrorNodeToMarkdown(node.child(i)))
+		}
+
+		return {
+			type: 'paragraph',
+			children: children,
+		}
+	} else if (node.type === schema.nodes.text) {
+		let textNode: MdAstNode = {
+			type: 'text',
+			value: node.text ?? '',
+		}
+
+		if (node.marks.find((mark) => mark.type === schema.marks.bold)) {
+			textNode = {
+				type: 'strong',
+				children: [textNode],
+				code: '**',
+			}
+		}
+		if (node.marks.find((mark) => mark.type === schema.marks.italic)) {
+			textNode = {
+				type: 'emphasis',
+				children: [textNode],
+				code: '__',
+			}
+		}
+		if (node.marks.find((mark) => mark.type === schema.marks.reverse)) {
+			textNode = {
+				type: 'reverse',
+				children: [textNode],
+				code: '~',
+			}
+		}
+
+		return textNode
+	} else {
+		console.warn(node)
+		return {
+			type: 'text',
+			value: '[UNKNOWN]',
+		}
+	}
+}

packages/apps/client/src/model/UIRundown.ts

@@ -1,9 +1,11 @@
 import { action, computed, makeAutoObservable, observable } from 'mobx'
 import {
+	PartId,
 	Rundown,
 	RundownId,
 	RundownPlaylist,
 	RundownPlaylistId,
+	ScriptContents,
 	Segment,
 	SegmentId,
 } from '@sofie-prompter-editor/shared-model'
@@ -29,7 +31,7 @@ export class UIRundown {
 		})
 		this.init().catch(console.error)
 	}
-	async init() {
+	private async init() {
 		await this.store.connection.rundown.subscribeToRundownsInPlaylist(this.id)
 
 		const rundowns = await this.store.connection.rundown.find({
@@ -145,4 +147,11 @@ export class UIRundown {
 		// update existing segment
 		existing.updateFromJson(json)
 	})
+
+	async updatePartScript(id: PartId, script: ScriptContents): Promise<void> {
+		// TODO - is this in the correct place?
+		await this.store.connection.part.updateScript(id, script)
+
+		// TODO - should this have any side effects?
+	}
 }

packages/shared/model/src/client-server-api/PartService.ts

@@ -6,7 +6,7 @@ import {
 	assertConstIsValid,
 	assertConstIncludesAllMethods,
 } from './lib.js'
-import { Part } from '../model/index.js'
+import { Part, ScriptContents } from '../model/index.js'
 import { Diff } from '../patch.js'
 
 /** List of all method names */
@@ -18,6 +18,7 @@ export const ALL_METHODS = [
 	// 'patch',
 	'remove',
 	//
+	'updateScript',
 ] as const
 /** The methods exposed by this class are exposed in the API */
 interface Methods extends Omit<ServiceMethods, 'patch'> {
@@ -34,7 +35,7 @@ interface Methods extends Omit<ServiceMethods, 'patch'> {
 
 	/** updates .isNew */
 	// setIsNew(read: boolean): Promise<void>
-	// updateScript(scriptContents?: ScriptContents): Promise<void>
+	updateScript(id: Id, scriptContents: ScriptContents): Promise<void>
 }
 export interface Service extends Methods, EventEmitter<Events> {}