Fix Content Sync

https://www.gatsbyjs.com/docs/how-to/plugins-and-themes/creating-a-source-plugin/#enabling-content-sync
datocms · Dec 7, 2022 · d72a1e8 · d72a1e8
1 parent 831c04c
commit d72a1e8
Show file tree

Hide file tree

Showing 3 changed files with 23 additions and 24 deletions.
diff --git a/package.json b/package.json
@@ -13,8 +13,8 @@
     "build": "babel src --out-dir . --ignore __tests__",
     "watch": "babel -w src --out-dir . --ignore __tests__",
     "prepublish": "cross-env NODE_ENV=production yarn build",
-    "test-v4": "jest --forceExit",
-    "test": "jest --forceExit --testNamePattern='^(?!tracedSVG)'"
+    "test-v4": "yarn build && jest --forceExit",
+    "test": "yarn build && jest --forceExit --testNamePattern='^(?!tracedSVG)'"
   },
   "devDependencies": {
     "@babel/cli": "^7.6.2",

diff --git a/src/hooks/sourceNodes/index.js b/src/hooks/sourceNodes/index.js
@@ -136,8 +136,6 @@ module.exports = async (
           reporter.warn(`Invalid entity type ${entityType}`);
           break;
       }
-      changesActivity.end();
-      return;
     } catch (err) {
       if (instancePrefix) {
         reporter.info(
@@ -148,28 +146,31 @@ module.exports = async (
       }
     }
 
-    Object.keys(loader.entitiesRepo.entities).forEach(entityType => {
-      loader.entitiesRepo.findEntitiesOfType(entityType).forEach(entity => {
-        createNodeFromEntity(entity, context);
-      });
+    changesActivity.end();
+    return;
+  }
+
+  Object.keys(loader.entitiesRepo.entities).forEach(entityType => {
+    loader.entitiesRepo.findEntitiesOfType(entityType).forEach(entity => {
+      createNodeFromEntity(entity, context);
     });
+  });
 
-    if (process.env.NODE_ENV !== `production` && !disableLiveReload) {
-      const queue = new Queue(1, Infinity);
+  if (process.env.NODE_ENV !== `production` && !disableLiveReload) {
+    const queue = new Queue(1, Infinity);
 
-      loader.watch(loadPromise => {
-        queue.add(async () => {
-          const activity = reporter.activityTimer(
-            `detected change in DatoCMS content, loading new data`,
-            { parentSpan },
-          );
-          activity.start();
+    loader.watch(loadPromise => {
+      queue.add(async () => {
+        const activity = reporter.activityTimer(
+          `detected change in DatoCMS content, loading new data`,
+          { parentSpan },
+        );
+        activity.start();
 
-          await loadPromise;
+        await loadPromise;
 
-          activity.end();
-        });
+        activity.end();
       });
-    }
+    });
   }
 };
diff --git a/src/utils.js b/src/utils.js
@@ -73,10 +73,8 @@ const datocmsCreateNodeManifest = ({ node, context }) => {
     const createNodeManifestIsSupported =
       typeof unstable_createNodeManifest === `function`;
     const updatedAt = node?.entityPayload?.meta?.updated_at;
-    const nodeNeedsManifestCreated = updatedAt && node?.locale;
 
-    const shouldCreateNodeManifest =
-      createNodeManifestIsSupported && nodeNeedsManifestCreated;
+    const shouldCreateNodeManifest = createNodeManifestIsSupported && updatedAt;
 
     if (shouldCreateNodeManifest) {
       if (shouldUpgradeGatsbyVersion && !warnOnceToUpgradeGatsby) {