Fix subscriber logic

ipfs-shipyard · Oct 17, 2023 · ec23b97 · ec23b97
1 parent 5b5f00f
commit ec23b97
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/subscription.go b/subscription.go
@@ -39,8 +39,7 @@ func NewHTTPSubscriber(remoteURL, localFile string, interval time.Duration) (*HT
 		if err != nil {
 			return nil, err
 		}
-	}
-	if err != nil {
+	} else if err != nil {
 		return nil, err
 	}
 

diff --git a/subscription_test.go b/subscription_test.go
@@ -66,7 +66,10 @@ func TestHTTPSubscriber(t *testing.T) {
 	localFile := "test-local-file.txt"
 	defer os.Remove(localFile)
 
-	subscriber := NewHTTPSubscriber(remoteServer.URL, localFile, 500*time.Millisecond)
+	subscriber, err := NewHTTPSubscriber(remoteServer.URL, localFile, 500*time.Millisecond)
+	if err != nil {
+		t.Fatal(err)
+	}
 	go subscriber.Subscribe()
 
 	// Allow some time for subscription to run