feat: clear cache before process

packages/cli/package.json

@@ -31,7 +31,7 @@
     "typescript": "5.4.2"
   },
   "dependencies": {
-    "@directus/sdk": "^15.0.2",
+    "@directus/sdk": "^15.0.3",
     "commander": "^12.0.0",
     "deep-object-diff": "^1.1.9",
     "deepmerge": "^4.3.1",

packages/cli/src/lib/commands/diff.ts

@@ -1,8 +1,10 @@
 import { Container } from 'typedi';
-import { SnapshotClient } from '../services';
+import { MigrationClient, SnapshotClient } from '../services';
 import { loadCollections } from '../loader';
 
 export async function runDiff() {
+  // Clear the cache
+  await Container.get(MigrationClient).clearCache();
   // Snapshot
   await Container.get(SnapshotClient).diff();
 

packages/cli/src/lib/commands/pull.ts

@@ -1,8 +1,15 @@
 import { Container } from 'typedi';
-import { SnapshotClient, SpecificationsClient } from '../services';
+import {
+  MigrationClient,
+  SnapshotClient,
+  SpecificationsClient,
+} from '../services';
 import { loadCollections } from '../loader';
 
 export async function runPull() {
+  // Clear the cache
+  await Container.get(MigrationClient).clearCache();
+
   // Snapshot
   await Container.get(SnapshotClient).pull();
 

packages/cli/src/lib/commands/push.ts

@@ -1,12 +1,15 @@
 import { Container } from 'typedi';
 import pino from 'pino';
-import { SnapshotClient } from '../services';
+import { MigrationClient, SnapshotClient } from '../services';
 import { loadCollections } from '../loader';
 import { LOGGER } from '../constants';
 
 export async function runPush() {
   const logger: pino.Logger = Container.get(LOGGER);
 
+  // Clear the cache
+  await Container.get(MigrationClient).clearCache();
+
   // Snapshot
   logger.info(`---- Push schema ----`);
   await Container.get(SnapshotClient).push();

packages/cli/src/lib/services/migration-client.ts

@@ -1,6 +1,7 @@
 import {
   authentication,
   AuthenticationClient,
+  clearCache,
   createDirectus,
   DirectusClient,
   readMe,
@@ -11,9 +12,12 @@ import { Inject, Service } from 'typedi';
 import pino from 'pino';
 import { LOGGER } from '../constants';
 import { ConfigService, isDirectusConfigWithToken } from './config';
+import { getChildLogger } from '../helpers';
 
 @Service()
 export class MigrationClient {
+  protected readonly logger: pino.Logger;
+
   protected adminRoleId: string | undefined;
 
   protected client:
@@ -24,8 +28,10 @@ export class MigrationClient {
 
   constructor(
     protected readonly config: ConfigService,
-    @Inject(LOGGER) protected readonly logger: pino.Logger,
-  ) {}
+    @Inject(LOGGER) baseLogger: pino.Logger,
+  ) {
+    this.logger = getChildLogger(baseLogger, 'migration-client');
+  }
 
   async get() {
     if (!this.client) {
@@ -50,6 +56,15 @@ export class MigrationClient {
     return this.adminRoleId;
   }
 
+  /**
+   * This method clears the cache of the Directus instance
+   */
+  async clearCache() {
+    const directus = await this.get();
+    await directus.request(clearCache());
+    this.logger.debug('Cache cleared');
+  }
+
   protected async createClient() {
     const config = this.config.getDirectusConfig();
     const client = createDirectus(config.url)