@@ -39,8 +39,6 @@ func Run(address string, opts ...Option) error {
3939
4040 client := filer_pb .NewSeaweedFilerClient (conn )
4141
42- eventListeners := make ([]internal.FileListener , 0 )
43-
4442 fmt .Println ("Listening file metadata..." )
4543 for {
4644 req , err := client .SubscribeMetadata (context .TODO (), & filer_pb.SubscribeMetadataRequest {
@@ -58,20 +56,20 @@ func Run(address string, opts ...Option) error {
5856 if notification := event .EventNotification ; notification != nil {
5957 if event .GetDirectory () != notification .GetNewParentPath () {
6058 if notification .OldEntry != nil && notification .NewEntry != nil {
61- for _ , listener := range eventListeners {
59+ for _ , listener := range wolf . Listeners {
6260 listener .Move (event )
6361 }
6462 }
6563 } else if notification .NewEntry != nil && notification .OldEntry == nil {
66- for _ , listener := range eventListeners {
64+ for _ , listener := range wolf . Listeners {
6765 listener .Create (event )
6866 }
6967 } else if notification .NewEntry == nil && notification .OldEntry != nil {
70- for _ , listener := range eventListeners {
68+ for _ , listener := range wolf . Listeners {
7169 listener .Delete (event )
7270 }
7371 } else if notification .NewEntry != nil && notification .OldEntry != nil {
74- for _ , listener := range eventListeners {
72+ for _ , listener := range wolf . Listeners {
7573 listener .Update (event )
7674 }
7775 } else {
0 commit comments