refactor: add test to verify update event handle

Signed-off-by: Amar Prakash Pandey <[email protected]>

Author: amarlearning

pkg/ocicni/ocicni.go

@@ -155,9 +155,9 @@ func (plugin *cniNetworkPlugin) monitorConfDir(start *sync.WaitGroup) {
 			logrus.Infof("CNI monitoring event %v", event)
 
 			var defaultDeleted bool
-			createWriteRename := (event.Op&fsnotify.Create == fsnotify.Create ||
+			createWriteRename := event.Op&fsnotify.Create == fsnotify.Create ||
 				event.Op&fsnotify.Write == fsnotify.Write ||
-				event.Op&fsnotify.Rename > 0)
+				event.Op&fsnotify.Rename == fsnotify.Rename
 			if event.Op&fsnotify.Remove == fsnotify.Remove {
 				// Care about the event if the default network
 				// was just deleted

pkg/ocicni/ocicni_test.go

@@ -11,6 +11,7 @@ import (
 	"path/filepath"
 	"reflect"
 	"strings"
+	"time"
 
 	"github.com/vishvananda/netlink"
 
@@ -236,6 +237,36 @@ var _ = Describe("ocicni operations", func() {
 		ocicni.Shutdown()
 	})
 
+	It("should monitor the conf dir for changes", func() {
+		_, _, err := writeConfig(tmpDir, "5-notdefault.conf", "notdefault", "myplugin", "0.3.1")
+		Expect(err).NotTo(HaveOccurred())
+		_, _, err = writeConfig(tmpDir, "10-test.conf", "test", "myplugin", "0.3.1")
+		Expect(err).NotTo(HaveOccurred())
+
+		ocicni, err := initCNI(&fakeExec{}, "", "test", tmpDir, false, "/opt/cni/bin")
+		Expect(err).NotTo(HaveOccurred())
+		Expect(ocicni.Status()).NotTo(HaveOccurred())
+
+		// Ensure the default network is the one we expect
+		tmp := ocicni.(*cniNetworkPlugin)
+		net := tmp.getDefaultNetwork()
+		Expect(net.name).To(Equal("test"))
+		Expect(len(net.config.Plugins)).To(BeNumerically(">", 0))
+		Expect(net.config.Plugins[0].Network.Type).To(Equal("myplugin"))
+
+		_, _, err = writeConfig(tmpDir, "10-test.conf", "test", "testplugin", "0.3.1")
+		Expect(err).NotTo(HaveOccurred())
+
+		time.Sleep(5)
+
+		// Ensure the default network is the updated one
+		Expect(net.name).To(Equal("test"))
+		Expect(len(net.config.Plugins)).To(BeNumerically(">", 0))
+		Expect(net.config.Plugins[0].Network.Type).To(Equal("testplugin"))
+
+		ocicni.Shutdown()
+	})
+
 	It("finds an asynchronously written default network configuration", func() {
 		ocicni, err := initCNI(&fakeExec{}, "", "test", tmpDir, true, "/opt/cni/bin")
 		Expect(err).NotTo(HaveOccurred())