Watcher.js

// create Class constructor
// inherit EventEmitter
// extend Functions

function Watcher(watchDir, processedDir) {
  this.watchDir = watchDir
  this.processedDir = processedDir
}

var events = require('events')
var util = require('util')
util.inherits(Watcher, events.EventEmitter)

var fs = require('fs')
var watchDir = './watch'
var processedDir = './done'

Watcher.prototype.watch = function () {
  var watcher = this
  fs.readdir(this.watchDir, function (err, files) {
    if (err) throw err
    for (var index in files) {
      watcher.emit('process', files[index])
    }
  })
}

Watcher.prototype.start = function () {
  var watcher = this
  fs.watchFile(watchDir, function () {
    watcher.watch()
  })
}

var watcher = new Watcher(watchDir, processedDir)
watcher.on('process', function process(file) {
  var watchFile = this.watchDir + '/' + file
  // file.toLowerCase().replace('[阳光电影www.ygdy8.com].','')
  var processedFile = this.processedDir + '/' + file.toLowerCase().replace('[阳光电影www.ygdy8.com].','')
  fs.rename(watchFile, processedFile, function (err) {
    if (err) throw err
  })
})