Function runObserverASyncImpl

packages/server/src/server-observers.ts:302–456

()

  }

  const runObserverASyncImpl = (): void => {
    try {
      const json = yXmlFragmentToProseMirrorRootNode(xmlFragment, schema).toJSON();
      const body = mdManager.serialize(json);
      const frontmatter = readCurrentFm();
      const md = prependFrontmatter(frontmatter, body);

      if (canonicalWitnessCoherent && lastSyncedCanonicalMd === md) {
        if (settlesSplitBrain(ytext.toString(), md)) {
          recordDivergedAttachBaselines(md);
          textDirty = true;
          recordSplitBrainRederive('identity-gate');
          setActiveSpanAttributes({ 'observer.a.path': 'gated-fragment-unchanged-rederive' });
        } else {
          setActiveSpanAttributes({ 'observer.a.path': 'gated-fragment-unchanged' });
        }
        return;
      }

      const currentText = ytext.toString();

      const normCurrent = normalizeBridge(currentText);
      const normMd = normalizeBridge(md);
      if (normCurrent === normMd) {
        setActiveSpanAttributes({ 'observer.a.path': 'gated-in-sync' });
        recordSettledBaselines(md);
        return;
      }

      const preMergeBaseline = lastSyncedYTextBytes;
      const ytextInSync = currentText === lastSyncedYTextBytes;
      const residualMergeEligible =
        ytextInSync &&
        canonicalWitnessCoherent &&
        lastSyncedYTextBytes !== lastSyncedCanonicalMd &&
        normCurrent !== normalizeBridge(lastSyncedCanonicalMd);
      setActiveSpanAttributes({
        'observer.a.path': ytextInSync
          ? residualMergeEligible
            ? 'residual-merge'
            : 'path-a'
          : 'path-b',
      });
      const pathBState: { mergedText: string | null } = { mergedText: null };

      const spliceComputeStart = performance.now();
      const mapDrivenSplice =
        ytextInSync && residualMergeEligible
          ? null
          : tryComputeMapDrivenSplice({
              currentText,
              lastSyncedXmlMd: lastSyncedYTextBytes,
              json,
              mdManager,
              docName: opts.docName,
            });
      if (mapDrivenSplice) {
        setActiveSpanAttributes({