Add data only option to import

Author: u12206050

CHANGELOG.md

@@ -1,4 +1,10 @@
-# Version 3.0.5
+# Version 3.0.6
+
+  - **Added** Way to only import data and not the schema, for cases where you use something else to migrate your schema.
+    - Set `SCHEMA_SYNC_DATA_ONLY=true` in your environment file.
+    - Or when using `import` command, use `--data` option.
+
+## Version 3.0.5
 
   - **Added** `SCHEMA_SYNC_MERGE` option to environment variables
     - Only insert and update items found in the import set (including duplicates). Does not remove items in the DB that are not in the import set.

README.md

@@ -138,7 +138,7 @@ Besides auto importing and exporting, you can also run the commands manually.
 | Command | Description |
 | ------- | ----------- |
 | `export` | Export the schema and data from the Directus API |
-| `import` | Import the schema and data to the Directus API (options: `merge`) |
+| `import` | Import the schema and data to the Directus API (options: `merge`, `data`) |
 | `hash`| Recalculate the hash for all the data files (already happens after export) |
 | `install` | Install the extension's columns in the database and add the config folder (options: `force`) |
 | `export-schema` | Export only the schema (options: --split <boolean>) |

package-lock.json

@@ -2,7 +2,7 @@
 	"name": "directus-extension-schema-sync",
 	"description": "Sync schema and data betwreen Directus instances",
 	"icon": "sync_alt",
-	"version": "3.0.5",
+	"version": "3.0.6",
 	"repository": {
 		"type": "git",
 		"url": "https://github.com/bcc-code/directus-schema-sync.git"

package.json

@@ -36,39 +36,50 @@ const registerHook: HookConfig = async ({ action, init }, { env, services, datab
 
 	// We need to do this in async in order to load the config files
 	let _exportManager: ExportManager;
-	const exportManager = async () => {
-		if (!_exportManager) {
-			_exportManager = new ExportManager(logger);
 
-			if (env.SCHEMA_SYNC_DATA_ONLY !== true) {
-				_exportManager.addExporter({
-					watch: ['collections', 'fields', 'relations'],
-					exporter: new SchemaExporter(getSchemaService, logger, schemaOptions),
-				});
-			}
+	const createExportManager = async (dataOnly = false) => {
+		const exportMng = new ExportManager(logger);
 
-			const { syncDirectusCollections } = (await nodeImport(ExportHelper.schemaDir, 'directus_config.js')) as {
-				syncDirectusCollections: ExportCollectionConfig;
-			};
-			const { syncCustomCollections } = (await nodeImport(ExportHelper.schemaDir, 'config.js')) as {
+		if (!dataOnly) {
+			exportMng.addExporter({
+				watch: ['collections', 'fields', 'relations'],
+				exporter: new SchemaExporter(getSchemaService, logger, schemaOptions),
+			});
+		}
+
+		const { syncDirectusCollections } = (await nodeImport(ExportHelper.schemaDir, 'directus_config.js')) as {
+			syncDirectusCollections: ExportCollectionConfig;
+		};
+		const { syncCustomCollections } = (await nodeImport(ExportHelper.schemaDir, 'config.js')) as {
+			syncCustomCollections: ExportCollectionConfig;
+		};
+		exportMng.addCollectionExporter(syncDirectusCollections, getItemsService);
+		exportMng.addCollectionExporter(syncCustomCollections, getItemsService);
+
+		// Additional config
+		if (env.SCHEMA_SYNC_CONFIG) {
+			const { syncCustomCollections } = (await nodeImport(ExportHelper.schemaDir, env.SCHEMA_SYNC_CONFIG)) as {
 				syncCustomCollections: ExportCollectionConfig;
 			};
-			_exportManager.addCollectionExporter(syncDirectusCollections, getItemsService);
-			_exportManager.addCollectionExporter(syncCustomCollections, getItemsService);
-
-			// Additional config
-			if (env.SCHEMA_SYNC_CONFIG) {
-				const { syncCustomCollections } = (await nodeImport(ExportHelper.schemaDir, env.SCHEMA_SYNC_CONFIG)) as {
-					syncCustomCollections: ExportCollectionConfig;
-				};
-				if (syncCustomCollections) {
-					_exportManager.addCollectionExporter(syncCustomCollections, getItemsService);
-				} else {
-					logger.warn(`Additonal config specified but not exporting "syncCustomCollections"`);
-				}
+			if (syncCustomCollections) {
+				exportMng.addCollectionExporter(syncCustomCollections, getItemsService);
+			} else {
+				logger.warn(`Additonal config specified but not exporting "syncCustomCollections"`);
 			}
 		}
 
+		return exportMng;
+	}
+		
+	const exportManager = async (dataOnly = false) => {
+		if (dataOnly && env.SCHEMA_SYNC_DATA_ONLY !== true) {
+			return await createExportManager(true);
+		}
+
+		if (!_exportManager) {
+			_exportManager = await createExportManager(env.SCHEMA_SYNC_DATA_ONLY !== true);
+		}
+
 		return _exportManager;
 	};
 
@@ -177,10 +188,11 @@ const registerHook: HookConfig = async ({ action, init }, { env, services, datab
 			.command('import')
 			.description('Import the schema and all available data from file to DB.')
 			.option('--merge', 'Only upsert data and not delete')
-			.action(async ({ merge }: { merge: boolean }) => {
+			.option('--data', 'Only import data and not schema')
+			.action(async ({ merge, data }: { merge: boolean; data: boolean }) => {
 				try {
 					logger.info(`Importing everything from: ${ExportHelper.dataDir}`);
-					const expMng = await exportManager();
+					const expMng = await exportManager(data);
 					await expMng.loadAll(merge);
 
 					logger.info('Done!');