From d2da9ade569a89ffabfa1fc9d9b1b0f05d847b8b Mon Sep 17 00:00:00 2001
From: Rintaro Okamura <rintaro.okamura@gmail.com>
Date: Tue, 28 Jul 2020 21:07:59 +0900
Subject: [PATCH] :bug: fix agent sidecar behavior

Signed-off-by: Rintaro Okamura <rintaro.okamura@gmail.com>
---
 pkg/agent/sidecar/service/observer/observer.go | 18 +++++++++++-------
 .../sidecar/service/observer/observer_test.go  |  5 +----
 2 files changed, 12 insertions(+), 11 deletions(-)

diff --git a/pkg/agent/sidecar/service/observer/observer.go b/pkg/agent/sidecar/service/observer/observer.go
index fdf23397bb..ee077c807c 100644
--- a/pkg/agent/sidecar/service/observer/observer.go
+++ b/pkg/agent/sidecar/service/observer/observer.go
@@ -318,7 +318,11 @@ func (o *observer) onWrite(ctx context.Context, name string) error {
 		}
 	}()
 
-	ok, err := o.isValidMetadata(name)
+	if name != o.metadataPath {
+		return nil
+	}
+
+	ok, err := o.isValidMetadata()
 	if err != nil {
 		return err
 	}
@@ -338,7 +342,11 @@ func (o *observer) onCreate(ctx context.Context, name string) error {
 		}
 	}()
 
-	ok, err := o.isValidMetadata(name)
+	if name != o.metadataPath {
+		return nil
+	}
+
+	ok, err := o.isValidMetadata()
 	if err != nil {
 		return err
 	}
@@ -350,11 +358,7 @@ func (o *observer) onCreate(ctx context.Context, name string) error {
 	return o.terminate()
 }
 
-func (o *observer) isValidMetadata(name string) (bool, error) {
-	if name != o.metadataPath {
-		return false, nil
-	}
-
+func (o *observer) isValidMetadata() (bool, error) {
 	metadata, err := metadata.Load(o.metadataPath)
 	if err != nil {
 		return false, err
diff --git a/pkg/agent/sidecar/service/observer/observer_test.go b/pkg/agent/sidecar/service/observer/observer_test.go
index eb83686a0d..db03d23d8c 100644
--- a/pkg/agent/sidecar/service/observer/observer_test.go
+++ b/pkg/agent/sidecar/service/observer/observer_test.go
@@ -845,7 +845,6 @@ func Test_observer_onCreate(t *testing.T) {
 
 func Test_observer_isValidMetadata(t *testing.T) {
 	type args struct {
-		name string
 	}
 	type fields struct {
 		w               watch.Watcher
@@ -887,7 +886,6 @@ func Test_observer_isValidMetadata(t *testing.T) {
 		   {
 		       name: "test_case_1",
 		       args: args {
-		           name: "",
 		       },
 		       fields: fields {
 		           w: nil,
@@ -912,7 +910,6 @@ func Test_observer_isValidMetadata(t *testing.T) {
 		       return test {
 		           name: "test_case_2",
 		           args: args {
-		           name: "",
 		           },
 		           fields: fields {
 		           w: nil,
@@ -958,7 +955,7 @@ func Test_observer_isValidMetadata(t *testing.T) {
 				ch:              test.fields.ch,
 			}
 
-			got, err := o.isValidMetadata(test.args.name)
+			got, err := o.isValidMetadata()
 			if err := test.checkFunc(test.want, got, err); err != nil {
 				tt.Errorf("error = %v", err)
 			}