Method processMessage

lib/plugins/rsync/index.js:142–175

(message, queue)

    this.storageManager = context.storageManager;
  }
  async processMessage(message, queue) {
    if (message.type === 'sitespeedio.setup') {
      // Let other plugins know that the rsync plugin is alive
      queue.postMessage(this.make('rsync.setup'));
    } else if (message.type === 'html.finished') {
      const make = this.make;
      const baseDir = this.storageManager.getBaseDir();

      log.info(`Uploading ${baseDir} using rsync, this can take a while ...`);

      try {
        await upload(
          baseDir,
          this.rsyncOptions,
          this.storageManager.getStoragePrefix()
        );
        if (this.options.copyLatestFilesToBase) {
          const rootPath = path.resolve(baseDir, '..');
          const prefix = this.storageManager.getStoragePrefix();
          const firstPart = prefix.split('/')[0];
          await uploadLatestFiles(rootPath, this.rsyncOptions, firstPart);
        }
        log.info('Finished upload using rsync');
        if (this.rsyncOptions.removeLocalResult) {
          fs.rmSync(baseDir, { recursive: true });
          log.debug(`Removed local files and directory ${baseDir}`);
        }
      } catch (error) {
        queue.postMessage(make('error', error));
        log.error('Could not upload using rsync', error);
      }
      queue.postMessage(make('rsync.finished'));
    }
  }
}