Improve logic that parses file as json or plaintext

ACHDictionary.go

@@ -121,10 +121,15 @@ func (f *ACHDictionary) Read(r io.Reader) error {
 		return err
 	}
 
-	// Try reading the file as JSON and if that fails read as plaintext
-	if err := f.readJSON(bytes.NewReader(bs)); err == nil {
+	// Try validating the file as JSON and if that fails read as plaintext
+	if json.Valid(bs) {
+		err = f.readJSON(bytes.NewReader(bs))
+		if err != nil {
+			return err
+		}
 		return nil
 	}
+
 	return f.readPlaintext(bytes.NewReader(bs))
 }
 

WIREDictionary.go

@@ -119,10 +119,15 @@ func (f *WIREDictionary) Read(r io.Reader) error {
 		return err
 	}
 
-	// Try reading the file as JSON and if that fails read as plaintext
-	if err := f.readJSON(bytes.NewReader(bs)); err == nil {
+	// Try validating the file as JSON and if that fails read as plaintext
+	if json.Valid(bs) {
+		err = f.readJSON(bytes.NewReader(bs))
+		if err != nil {
+			return err
+		}
 		return nil
 	}
+
 	return f.readPlaintext(bytes.NewReader(bs))
 }
 

cmd/server/reader.go

@@ -55,16 +55,8 @@ func fedWireDataFile(logger log.Logger) (io.Reader, error) {
 }
 
 func attemptFileDownload(logger log.Logger, listName string) (io.Reader, error) {
-	routingNumber := os.Getenv("FRB_ROUTING_NUMBER")
-	downloadCode := os.Getenv("FRB_DOWNLOAD_CODE")
-	downloadURL := os.Getenv("FRB_DOWNLOAD_URL_TEMPLATE")
-
 	logger.Logf("download: attempting %s", listName)
-	client, err := download.NewClient(&download.ClientOpts{
-		RoutingNumber: routingNumber,
-		DownloadCode:  downloadCode,
-		DownloadURL:   downloadURL,
-	})
+	client, err := download.NewClient(nil)
 	if err != nil {
 		return nil, fmt.Errorf("client setup: %w", err)
 	}

pkg/download/download.go

@@ -53,12 +53,12 @@ func NewClient(opts *ClientOpts) (*Client, error) {
 	downloadcd, dcdExists := os.LookupEnv("FRB_DOWNLOAD_CODE")
 	downloadurltemp, urlExists := os.LookupEnv("FRB_DOWNLOAD_URL_TEMPLATE")
 
-	if !urlExists {
-		if !rnExists {
+	if !urlExists || downloadurltemp == "" {
+		if !rnExists || routingNum == "" {
 			return nil, fmt.Errorf("%w: %w", ErrMissingConfigValue, ErrMissingRoutingNumber)
 		}
 
-		if !dcdExists {
+		if !dcdExists || downloadcd == "" {
 			return nil, fmt.Errorf("%w: %w", ErrMissingConfigValue, ErrMissingDownloadCD)
 		}
 

pkg/download/download_test.go

@@ -95,7 +95,7 @@ func TestClient__fedwire(t *testing.T) {
 }
 
 func TestClient__wire_custom_url(t *testing.T) {
-	file, err := os.ReadFile(filepath.Join("..", "..", "data", "fedwiredir.json"))
+	file, err := os.ReadFile(filepath.Join("..", "..", "data", "fpddir.json"))
 	if err != nil {
 		t.Fatal(err)
 	}