File: clinotify.go

package info (click to toggle)
golang-github-gokyle-fswatch 0.0~git20121217.1dbdf83-3
  • links: PTS, VCS
  • area: main
  • in suites: bookworm, forky, sid, trixie
  • size: 96 kB
  • sloc: makefile: 3
file content (78 lines) | stat: -rw-r--r-- 1,622 bytes parent folder | download | duplicates (3)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
// clinotify provides an example file system watching command line app. It
// scans the file system, and every 15 seconds prints out the files being
// watched and their current state.
package main

import (
	"flag"
	"fmt"
	"github.com/gokyle/fswatch"
	"os"
	"time"
)

var dur time.Duration

func init() {
	if len(os.Args) == 1 {
		fmt.Println("[+] not watching anything, exiting.")
		os.Exit(1)
	}
	dur, _ = time.ParseDuration("15s")
}

func main() {
	var w *fswatch.Watcher

	auto_watch := flag.Bool("a", false, "auto add new files in directories")
	flag.Parse()
	paths := flag.Args()
	if *auto_watch {
		w = fswatch.NewAutoWatcher(paths...)
	} else {
		w = fswatch.NewWatcher(paths...)
	}
	fmt.Println("[+] listening...")

	l := w.Start()
	go func() {
		for {
			n, ok := <-l
			if !ok {
				return
			}
			var status_text string
			switch n.Event {
			case fswatch.CREATED:
				status_text = "was created"
			case fswatch.DELETED:
				status_text = "was deleted"
			case fswatch.MODIFIED:
				status_text = "was modified"
			case fswatch.PERM:
				status_text = "permissions changed"
			case fswatch.NOEXIST:
				status_text = "doesn't exist"
			case fswatch.NOPERM:
				status_text = "has invalid permissions"
			case fswatch.INVALID:
				status_text = "is invalid"
			}
			fmt.Printf("[+] %s %s\n", n.Path, status_text)
		}
	}()
	go func() {
		for {
			<-time.After(dur)
			if !w.Active() {
				fmt.Println("[!] not watching anything")
				os.Exit(1)
			}
			fmt.Printf("[-] watching: %+v\n", w.State())
		}
	}()
	time.Sleep(60 * time.Second)
	fmt.Println("[+] stopping...")
	w.Stop()
	time.Sleep(5 * time.Second)
}