'use strict';

 

const fs = require('fs');

const ws = fs.createWriteStream('./app.log', {

  flags: 'a',

  encoding: 'utf8',

  mode: 0o666

});

const dir = './data/';

 

ws.on('open', () => {

  var count = 0;

  

  fs.readdir(dir, (err, files) => {

    if (err) return console.error(err.message);

 

    files.forEach(fname => {

      count++; //<--- тут не катит

 

      fs.readFile(dir + fname, 'utf8', (err, data) => {

        if (err) return console.error(err.message);

 

        if (data.match(/microsoft\.com/g) !== null) {

          var changed = data.replace(/microsoft\.com/g, 'mudosoft.com');

 

          fs.writeFile(dir + fname, changed, err => {

            if (err) return console.error(err.message);

 

            ws.write('changed '+ fname +'\n', 'utf8', err => {

              if (err) return console.error(err.message);

 

              if (count >= files.length) { //<-- ???

                console.log('completed.');

              }

            });

          });

        }

      });

    });

  });

});

 

ws.on('error', err => {

  console.error('Error:' + err);

});

ws.on('open', () => {

  fs.readdir(dir, (err, files) => {

    if (err) return console.error(err.message);

    var count = 0,  //<--- текущее изменение

        totalСhanges = 0; //<--- общее число изменений

 

    files.forEach(fname => {

      fs.readFile(dir + fname, 'utf8', (err, data) => {

        if (err) return console.error(err.message);

 

        if (data.match(/microsoft\.com/g) !== null) {

          var changed = data.replace(/microsoft\.com/g, 'mudosoft.com');

          totalСhanges++; //<--- тут подсчитываем

 

          fs.writeFile(dir + fname, changed, err => {

            if (err) return console.error(err.message);

 

            ws.write('changed '+ fname +'\n', 'utf8', err => {

              if (err) return console.error(err.message);

              

              console.log('changed');

              count++; //<--- и тут подсчитываем

 

              if (count ===  totalСhanges) { //<--- проверка

                console.log('all completed.');

              }

            });

          });

        }

      });

    });

  });

});

const promisify = require('util').promisify;

 

// промосификация

const readdir = promisify(fs.readdir);

const readFile = promisify(fs.readFile);

const writeFile = promisify(fs.writeFile);

 

ws.on('open', () => {

  readdir(dir).then(files => {

    var count = 0;

 

    files.forEach(fname => {

      readFile(dir + fname, 'utf8').then(async data => {

        if (data.search(/microsoft\.com/g) !== -1) {

          var changedData = data.replace(/microsoft\.com/g, 'mudosoft.com');

          await writeFile(dir + fname, changedData);

          ws.write('changed '+ fname +'\n', 'utf8');

          console.log('changed ' + fname);

        }

        if (++count >= files.length) {

          console.log('all completed.');

        }

      })

      .catch(err => console.error(err.message));

    });

  })

  .catch(err => console.error(err.message));

});