1 | "use strict";
|
2 | var __assign = (this && this.__assign) || function () {
|
3 | __assign = Object.assign || function(t) {
|
4 | for (var s, i = 1, n = arguments.length; i < n; i++) {
|
5 | s = arguments[i];
|
6 | for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
|
7 | t[p] = s[p];
|
8 | }
|
9 | return t;
|
10 | };
|
11 | return __assign.apply(this, arguments);
|
12 | };
|
13 | var __importDefault = (this && this.__importDefault) || function (mod) {
|
14 | return (mod && mod.__esModule) ? mod : { "default": mod };
|
15 | };
|
16 | Object.defineProperty(exports, "__esModule", { value: true });
|
17 | exports.handleListenerEvent = void 0;
|
18 | var debug_1 = __importDefault(require("../debug"));
|
19 | var normalize_1 = require("./normalize");
|
20 | var removeGatsbyInternalProps_1 = require("./removeGatsbyInternalProps");
|
21 | var documentIds_1 = require("./documentIds");
|
22 | function handleListenerEvent(event, publishedNodes, context, processingOptions) {
|
23 | var actions = context.actions, createNodeId = context.createNodeId, getNode = context.getNode;
|
24 | var createNode = actions.createNode, deleteNode = actions.deleteNode;
|
25 | var overlayDrafts = processingOptions.overlayDrafts;
|
26 | var current = getNode(documentIds_1.safeId(documentIds_1.unprefixId(event.documentId), createNodeId));
|
27 | var published = publishedNodes.get(documentIds_1.unprefixId(event.documentId));
|
28 | if (published) {
|
29 | published = removeGatsbyInternalProps_1.removeGatsbyInternalProps(published);
|
30 | }
|
31 | var touchedIsDraft = documentIds_1.isDraftId(event.documentId);
|
32 | var currentIsDraft = current && documentIds_1.isDraftId(current._id);
|
33 |
|
34 |
|
35 |
|
36 | if (!overlayDrafts) {
|
37 | if (touchedIsDraft) {
|
38 | debug_1.default('Document is draft, but draft overlay disabled. Skipping.');
|
39 | return;
|
40 | }
|
41 | if (event.transition !== 'disappear' && event.result) {
|
42 |
|
43 | debug_1.default('Published document created or updated, replace/create');
|
44 | normalize_1.processDocument(event.result, processingOptions);
|
45 | }
|
46 | else if (current) {
|
47 |
|
48 | debug_1.default('Published document deleted, remove');
|
49 | deleteNode({ node: current });
|
50 | }
|
51 | return;
|
52 | }
|
53 |
|
54 |
|
55 |
|
56 |
|
57 |
|
58 | if (event.transition === 'disappear') {
|
59 |
|
60 | if (touchedIsDraft && published) {
|
61 | debug_1.default('Draft deleted, published version exists, restore published version');
|
62 | createNode(published);
|
63 | }
|
64 | else if (touchedIsDraft && !published && current) {
|
65 | debug_1.default('Draft deleted, no published version exist, delete node');
|
66 | deleteNode({ node: current });
|
67 | }
|
68 | else if (!touchedIsDraft && currentIsDraft && published) {
|
69 | debug_1.default('Published version deleted, but we have draft, remove published from working set');
|
70 | publishedNodes.delete(event.documentId);
|
71 | }
|
72 | else if (!touchedIsDraft && !currentIsDraft && current) {
|
73 | debug_1.default('Published version deleted, we have no draft, remove node entirely');
|
74 | deleteNode({ node: current });
|
75 | publishedNodes.delete(event.documentId);
|
76 | }
|
77 | }
|
78 | else {
|
79 |
|
80 | if (touchedIsDraft && event.result) {
|
81 | debug_1.default(current ? 'Replace the current draft with a new draft' : 'New draft discovered');
|
82 | normalize_1.processDocument(event.result, processingOptions);
|
83 |
|
84 | if (current && !currentIsDraft) {
|
85 | publishedNodes.set(documentIds_1.unprefixId(event.documentId), current);
|
86 | }
|
87 | }
|
88 | else if (currentIsDraft && event.result) {
|
89 |
|
90 |
|
91 | debug_1.default('Created/updating published document, but draft overlays it');
|
92 | publishedNodes.set(event.documentId, normalize_1.processDocument(event.result, __assign(__assign({}, processingOptions), { skipCreate: true })));
|
93 | }
|
94 | else if (event.result) {
|
95 |
|
96 |
|
97 | debug_1.default('Created/updating published document, no draft present');
|
98 | normalize_1.processDocument(event.result, processingOptions);
|
99 | }
|
100 | }
|
101 | }
|
102 | exports.handleListenerEvent = handleListenerEvent;
|
103 |
|
\ | No newline at end of file |