*/

package pluginwatcher

import (
	"os"

	"github.com/fsnotify/fsnotify"
)

func getStat(event fsnotify.Event) (os.FileInfo, error) {
	return os.Stat(event.Name)
}

func getSocketPath(socketPath string) string {
	return socketPath

	assert.Equal(t, fi, fiExpected)
	assert.Equal(t, err, errExpected)
}

func TestGetSocketPath(t *testing.T) {
	socketPath := "/tmp/foo/lish.sock"
	assert.Equal(t, socketPath, getSocketPath(socketPath))

	// microsoft/Windows-Containers#97 for details.
	// Once the issue is resvolved, the following os.Lstat() is not needed.
	if err != nil {
		fi, err = os.Lstat(event.Name)
	}

	return fi, err
}

		}

		return w.handlePluginRegistration(event.Name)
	}

	return w.traversePluginDir(event.Name)
}

func (w *Watcher) handlePluginRegistration(socketPath string) error {
	socketPath = getSocketPath(socketPath)
	// Update desired state of world list of plugins
	// If the socket path does exist in the desired world cache, there's still
	// a possibility that it has been deleted and recreated again before it is