Load providers on project load

packages/core/src/data_sources/config/config.ts

@@ -0,0 +1,13 @@
+export interface DataSourcesConfig {
+  /**
+   * If true, data source providers will be autoloaded on project load.
+   * @default false
+   */
+  autoloadProviders?: boolean;
+}
+
+const config: () => DataSourcesConfig = () => ({
+  autoloadProviders: false,
+});
+
+export default config;

packages/core/src/data_sources/index.ts

@@ -26,19 +26,20 @@ import { ItemManagerModule, ModuleConfig } from '../abstract/Module';
 import { AddOptions, collectionEvents, ObjectAny, RemoveOptions } from '../common';
 import EditorModel from '../editor/model/Editor';
 import { get, set, stringToPath } from '../utils/mixins';
+import defConfig, { DataSourcesConfig } from './config/config';
 import DataRecord from './model/DataRecord';
 import DataSource from './model/DataSource';
 import DataSources from './model/DataSources';
 import { DataSourcesEvents, DataSourceProps, DataRecordProps } from './types';
 import { Events } from 'backbone';
 
-export default class DataSourceManager extends ItemManagerModule<ModuleConfig, DataSources> {
+export default class DataSourceManager extends ItemManagerModule<DataSourcesConfig & ModuleConfig, DataSources> {
   storageKey = 'dataSources';
   events = DataSourcesEvents;
   destroy(): void {}
 
   constructor(em: EditorModel) {
-    super(em, 'DataSources', new DataSources([], em), DataSourcesEvents);
+    super(em, 'DataSources', new DataSources([], em), DataSourcesEvents, defConfig());
     Object.assign(this, Events); // Mixin Backbone.Events
   }
 
@@ -188,7 +189,24 @@ export default class DataSourceManager extends ItemManagerModule<ModuleConfig, D
    * @returns {Object} Loaded data sources.
    */
   load(data: any) {
-    return this.loadProjectData(data);
+    const { config, all, events, em } = this;
+    const result = this.loadProjectData(data);
+
+    if (config.autoloadProviders) {
+      const dsWithProviders = all.filter((ds) => ds.hasProvider);
+
+      if (!!dsWithProviders.length) {
+        const loadProviders = async () => {
+          em.trigger(events.providerLoadAllBefore);
+          const providersToLoad = dsWithProviders.map((ds) => ds.loadProvider());
+          await Promise.all(providersToLoad);
+          em.trigger(events.providerLoadAll);
+        };
+        loadProviders();
+      }
+    }
+
+    return result;
   }
 
   postLoad() {

packages/core/src/data_sources/model/DataSource.ts

@@ -132,6 +132,13 @@ export default class DataSource<DRProps extends DataRecordProps = DataRecordProp
     return (this.collection as unknown as DataSources).em;
   }
 
+  /**
+   * Indicates if the data source has a provider for records.
+   */
+  get hasProvider() {
+    return !!this.attributes.provider;
+  }
+
   /**
    * Handles the `add` event for records in the data source.
    * This method triggers a change event on the newly added record.
@@ -222,7 +229,8 @@ export default class DataSource<DRProps extends DataRecordProps = DataRecordProp
   }
 
   async loadProvider() {
-    const { provider } = this.attributes;
+    const { attributes, em } = this;
+    const { provider } = attributes;
 
     if (!provider) return;
 
@@ -235,15 +243,22 @@ export default class DataSource<DRProps extends DataRecordProps = DataRecordProp
     const { url, method, headers, body } = providerGet;
 
     const fetchProvider = async () => {
+      const dataSource = this;
+
       try {
+        em.trigger(em.DataSources.events.providerLoadBefore, { dataSource });
+
         const response = await fetch(url, { method, headers, body });
         if (!response.ok) throw new Error(await response.text());
-        const providerResult: DataSourceProviderResult = await response.json();
+        const result: DataSourceProviderResult = await response.json();
+
+        if (result?.records) this.setRecords(result.records as any);
+        if (result?.schema) this.upSchema(result.schema);
 
-        if (providerResult?.records) this.setRecords(providerResult.records as any);
-        if (providerResult?.schema) this.upSchema(providerResult.schema);
+        em.trigger(em.DataSources.events.providerLoad, { result, dataSource });
       } catch (error: any) {
-        this.em.logError(error.message);
+        em.logError(error.message);
+        em.trigger(em.DataSources.events.providerLoadError, { dataSource, error });
       }
     };
 

packages/core/src/data_sources/types.ts

@@ -46,6 +46,8 @@ interface BaseDataSource {
    * If true will store the data source in the GrapesJS project.json file.
    */
   skipFromStorage?: boolean;
+
+  [key: string]: unknown;
 }
 
 export enum DataFieldPrimitiveType {
@@ -215,6 +217,23 @@ export enum DataSourcesEvents {
    */
   pathSource = 'data:pathSource:',
 
+  /**
+   * @event `data:provider:load` Data source provider load.
+   * @example
+   * editor.on('data:provider:load', ({ dataSource, result }) => { ... });
+   */
+  providerLoad = 'data:provider:load',
+  providerLoadBefore = 'data:provider:load:before',
+  providerLoadError = 'data:provider:load:error',
+
+  /**
+   * @event `data:provider:loadAll` Load of all data source providers (eg. on project load).
+   * @example
+   * editor.on('data:provider:loadAll', () => { ... });
+   */
+  providerLoadAll = 'data:provider:loadAll',
+  providerLoadAllBefore = 'data:provider:loadAll:before',
+
   /**
    * @event `data` Catch-all event for all the events mentioned above.
    * @example

packages/core/test/specs/data_sources/model/DataSource.ts

@@ -179,6 +179,7 @@ describe('DataSource', () => {
     const addBlogsWithProvider = () => {
       return dsm.add({
         id: 'blogs',
+        name: 'My blogs',
         provider: {
           get: getProviderBlogsGet(),
         },
@@ -232,8 +233,11 @@ describe('DataSource', () => {
       expect(ds.getRecords().length).toBe(0);
     });
 
-    test('ensure records loaded from the provider are not persisted', async () => {
+    test('records loaded from the provider are not persisted', async () => {
       const ds = addBlogsWithProvider();
+      const eventLoad = jest.fn();
+      em.on(dsm.events.providerLoad, eventLoad);
+
       await ds.loadProvider();
 
       expect(editor.getProjectData().dataSources).toEqual([
@@ -241,12 +245,51 @@ describe('DataSource', () => {
         { id: 'users', records: userRecords },
         {
           id: 'blogs',
+          name: 'My blogs',
           schema: getMockSchema(),
-          provider: {
-            get: getProviderBlogsGet(),
-          },
+          provider: { get: getProviderBlogsGet() },
         },
       ]);
+      expect(eventLoad).toHaveBeenCalledTimes(1);
+      expect(eventLoad).toHaveBeenCalledWith({
+        dataSource: ds,
+        result: getMockProviderResponse(),
+      });
+    });
+
+    test('load providers on project load', (done) => {
+      dsm.getConfig().autoloadProviders = true;
+
+      editor.on(dsm.events.providerLoadAll, () => {
+        expect(dsm.get('blogs').getResolvedRecords()).toEqual([
+          { ...blogRecords[0], author: userRecords[0] },
+          { ...blogRecords[1], author: userRecords[1] },
+          blogRecords[2],
+        ]);
+
+        expect(editor.getProjectData().dataSources).toEqual([
+          { id: 'categories', records: categoryRecords },
+          { id: 'users', records: userRecords },
+          {
+            id: 'blogs',
+            schema: getMockSchema(),
+            provider: { get: testApiUrl },
+          },
+        ]);
+
+        done();
+      });
+
+      editor.loadProjectData({
+        dataSources: [
+          { id: 'categories', records: categoryRecords },
+          { id: 'users', records: userRecords },
+          {
+            id: 'blogs',
+            provider: { get: testApiUrl },
+          },
+        ],
+      });
     });
   });
 });