added unlink

.gitignore

@@ -61,3 +61,4 @@ typings/
 .next
 tests/to
 dist
+tests/from/z

package.json

@@ -6,7 +6,8 @@
   "main": "./dist/index.cjs",
   "exports": {
     "import": "./src/index.js",
-    "require": "./dist/index.cjs"
+    "require": "./dist/index.cjs",
+    "types": "./types/index.d.ts"
   },
   "files": [
     "src",

src/index.js

@@ -118,14 +118,33 @@ export default function copyPlugin (options) {
       const jobs = new Set()
       const { paths, ignorePaths } = parseUserPaths(userPaths, absWorkingDir, defaultTo)
 
-      const onFile = (srcFile) => {
-        const fullPath = path.resolve(absWorkingDir, srcFile)
-        const pathOptions = paths.find(pathOptions => pathOptions.valid(srcFile, fullPath))
+      const getPaths = (srcFile) => {
+        const srcPath = path.resolve(absWorkingDir, srcFile)
+        const pathOptions = paths.find(pathOptions => pathOptions.valid(srcFile, srcPath))
 
         if (!pathOptions) return
-        const destFile = path.resolve(pathOptions.to, fullPath.replace(`${pathOptions.parent}${path.sep}`, ''))
+        let subPath = srcPath.replace(pathOptions.parent, '')
+        if (subPath.startsWith(path.sep)) {
+          subPath = subPath.slice(1)
+        }
+        const destPath = path.resolve(pathOptions.to, subPath)
+        return { srcPath, destPath }
+      }
+
+      const onFile = (srcFile) => {
+        const { srcPath, destPath } = getPaths(srcFile)
+        const job = copy(srcPath, destPath)
+        jobs.add(job)
+        job.finally(() => {
+          jobs.delete(job)
+        })
+      }
 
-        const job = copy(fullPath, destFile)
+      const onUnlink = recursive => (srcFile) => {
+        const { destPath } = getPaths(srcFile)
+        const job = fs.rm(destPath, {
+          recursive
+        }).catch(() => {})
         jobs.add(job)
         job.finally(() => {
           jobs.delete(job)
@@ -148,6 +167,8 @@ export default function copyPlugin (options) {
 
         watcher.on('add', onFile)
         watcher.on('change', onFile)
+        watcher.on('unlink', onUnlink(false))
+        watcher.on('unlinkDir', onUnlink(true))
         await new Promise(resolve => watcher.once('ready', resolve))
         await checkFinish()
       })

tests/index.test.js

@@ -42,7 +42,7 @@ test('basic', async () => {
 })
 
 test('watch', async () => {
-  await del(['tests/to'])
+  await del(['tests/to', 'tests/from/z'])
 
   const ctx = await esbuild.context({
     entryPoints: ['from/index.js'],
@@ -57,7 +57,8 @@ test('watch', async () => {
           { from: 'from/a', to: 'a' },
           { from: 'from/b/*.txt', to: 'b' },
           { from: 'from/c/**', to: 'c' },
-          { from: ['from/d/**', '!from/d/ignore.txt'], to: 'd' }
+          { from: ['from/d/**', '!from/d/ignore.txt'], to: 'd' },
+          { from: 'from/z/**', to: 'z' }
         ]
       })
     ]
@@ -66,13 +67,47 @@ test('watch', async () => {
   try {
     await ctx.watch()
 
-    await new Promise(resolve => setTimeout(resolve, 2 * 1000))
+    await new Promise(resolve => setTimeout(resolve, 2_000))
+
+    let files = ['to/a/file-a0.txt', 'to/b/file-b0.txt', 'to/c/file-c0.txt', 'to/c/cc/file-cc0.txt', 'to/d/include.txt', 'to/z/test-0.txt', 'to/z/test-1.txt']
+
+    await fs.mkdir('./tests/from/z')
+
+    await Promise.all([
+      fs.writeFile('./tests/from/z/test-0.txt', 'content'),
+      fs.writeFile('./tests/from/z/test-1.txt', 'content')
+    ])
+
+    await new Promise(resolve => setTimeout(resolve, 2_000))
+
+    for (const file of files) {
+      assert.ok(await fs.pathExists(join(__dirname, file)), `Exists: ${join(__dirname, file)}`)
+    }
+
+    // delete the z/test file
 
-    const files = ['to/a/file-a0.txt', 'to/b/file-b0.txt', 'to/c/file-c0.txt', 'to/c/cc/file-cc0.txt', 'to/d/include.txt']
+    await fs.unlink('./tests/from/z/test-0.txt')
+    await new Promise(resolve => setTimeout(resolve, 2_000))
 
+    files = files.filter(file => file !== 'to/z/test-0.txt')
     for (const file of files) {
       assert.ok(await fs.pathExists(join(__dirname, file)), `Exists: ${join(__dirname, file)}`)
     }
+
+    assert.not.ok(await fs.pathExists(join(__dirname, 'to/z/test-0.txt')))
+
+    await fs.rm('./tests/from/z', {
+      recursive: true
+    })
+    await new Promise(resolve => setTimeout(resolve, 2_000))
+
+    files = files.filter(file => file !== 'to/z/test-1.txt')
+    for (const file of files) {
+      assert.ok(await fs.pathExists(join(__dirname, file)), `Exists: ${join(__dirname, file)}`)
+    }
+
+    assert.not.ok(await fs.pathExists(join(__dirname, 'to/z/test-1.txt')))
+    assert.not.ok(await fs.pathExists(join(__dirname, 'to/z')))
   } finally {
     await ctx.dispose()
   }