add module rjeczalik.notify

Author: zing-dev

modules/rjeczalik.notify/go.mod

@@ -0,0 +1,7 @@
+module rjeczalik.notify
+
+go 1.17
+
+require github.com/rjeczalik/notify v0.9.2
+
+require golang.org/x/sys v0.0.0-20180926160741-c2ed4eda69e7 // indirect

modules/rjeczalik.notify/go.sum

@@ -0,0 +1,4 @@
+github.com/rjeczalik/notify v0.9.2 h1:MiTWrPj55mNDHEiIX5YUSKefw/+lCQVoAFmD6oQm5w8=
+github.com/rjeczalik/notify v0.9.2/go.mod h1:aErll2f0sUX9PXZnVNyeiObbmTlk5jnMoCa4QEjJeqM=
+golang.org/x/sys v0.0.0-20180926160741-c2ed4eda69e7 h1:bit1t3mgdR35yN0cX0G8orgLtOuyL9Wqxa1mccLB0ig=
+golang.org/x/sys v0.0.0-20180926160741-c2ed4eda69e7/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=

modules/rjeczalik.notify/main.go

@@ -0,0 +1,69 @@
+package main
+
+import (
+	"fmt"
+	"github.com/rjeczalik/notify"
+	"log"
+	"os"
+	"path/filepath"
+	"time"
+)
+
+var WaitFor = func(path string, e notify.Event, timeout time.Duration) bool {
+	dir, file := filepath.Split(path)
+	c := make(chan notify.EventInfo, 1)
+
+	if err := notify.Watch(dir, c, e); err != nil {
+		log.Fatal(err)
+	}
+	// Clean up watchpoint associated with c. If Stop was not called upon
+	// return the channel would be leaked as notify holds the only reference
+	// to it and does not release it on its own.
+	defer notify.Stop(c)
+
+	t := time.After(timeout)
+
+	for {
+		select {
+		case ei := <-c:
+			fmt.Println(filepath.Base(ei.Path()), file, ei.Event())
+			if filepath.Base(ei.Path()) == file {
+				return true
+			}
+		case <-t:
+			return false
+		}
+	}
+}
+
+var filename = "test.txt"
+
+func main() {
+	go func() {
+		os.Remove(filename)
+		time.Sleep(time.Second * 3)
+		os.Create(filename)
+		time.Sleep(time.Second * 3)
+		if err := os.Remove(filename); err != nil {
+			fmt.Printf("remove: %s", err)
+		}
+	}()
+
+	go func() {
+		if WaitFor(filename, notify.Create, time.Second*10) {
+			log.Println(filename, "locked")
+		}
+	}()
+
+	go func() {
+		if WaitFor(filename, notify.All, time.Second*10) {
+			log.Println(filename, "locked2")
+		}
+	}()
+
+	if WaitFor(filename, notify.Remove, time.Second*15) {
+		log.Println(filename, "unlocked")
+	}
+
+	fmt.Println("over")
+}

modules/rjeczalik.notify/main_test.go

@@ -0,0 +1,96 @@
+package main_test
+
+import (
+	"fmt"
+	"log"
+	"path/filepath"
+	"testing"
+	"time"
+
+	"github.com/rjeczalik/notify"
+)
+
+func TestBasic(t *testing.T) {
+	// Make the channel buffered to ensure no event is dropped. Notify will drop
+	// an event if the receiver is not able to keep up the sending pace.
+	c := make(chan notify.EventInfo, 1)
+
+	// Set up a watchpoint listening on events within current working directory.
+	// Dispatch each create and remove events separately to c.
+	if err := notify.Watch(".", c, notify.Create, notify.Remove); err != nil {
+		log.Fatal(err)
+	}
+	defer notify.Stop(c)
+
+	// Block until an event is received.
+	ei := <-c
+	log.Println("Got event:", ei)
+}
+
+func TestRecursive(t *testing.T) {
+	// Make the channel buffered to ensure no event is dropped. Notify will drop
+	// an event if the receiver is not able to keep up the sending pace.
+	c := make(chan notify.EventInfo, 1)
+
+	// Set up a watchpoint listening for events within a directory tree rooted
+	// at current working directory. Dispatch remove events to c.
+	if err := notify.Watch("./...", c, notify.Remove); err != nil {
+		log.Fatal(err)
+	}
+	defer notify.Stop(c)
+
+	// Block until an event is received.
+	ei := <-c
+	log.Println("Got event:", ei)
+}
+
+func TestWatch(t *testing.T) {
+	c := make(chan notify.EventInfo, 3)
+	if err := notify.Watch(".", c, notify.All); err != nil {
+		log.Fatal(err)
+	}
+	defer notify.Stop(c)
+
+	for {
+		select {
+		case e := <-c:
+			fmt.Println(e)
+		}
+	}
+}
+
+func TestName(t *testing.T) {
+	waitfor := func(path string, e notify.Event, timeout time.Duration) bool {
+		dir, file := filepath.Split(path)
+		c := make(chan notify.EventInfo, 1)
+
+		if err := notify.Watch(dir, c, e); err != nil {
+			log.Fatal(err)
+		}
+		// Clean up watchpoint associated with c. If Stop was not called upon
+		// return the channel would be leaked as notify holds the only reference
+		// to it and does not release it on its own.
+		defer notify.Stop(c)
+
+		t := time.After(timeout)
+
+		for {
+			select {
+			case ei := <-c:
+				if filepath.Base(ei.Path()) == file {
+					return true
+				}
+			case <-t:
+				return false
+			}
+		}
+	}
+
+	if waitfor("index.lock", notify.Create, 5*time.Second) {
+		log.Println("The git repository was locked")
+	}
+
+	if waitfor("index.lock", notify.Remove, 5*time.Second) {
+		log.Println("The git repository was unlocked")
+	}
+}