fix: file streamer not returning E adn F records (#28)

Co-authored-by: Manav <[email protected]>
moov-io · May 7, 2024 · afed7d1 · afed7d1
1 parent 81a4006
commit afed7d1
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/file_streamer.go b/file_streamer.go
@@ -181,11 +181,13 @@ func (fs *FileStreamer) ScanTxn() (Transaction, error) {
 		if err := cr.Parse(txnsSegment[startIdx:endIdx]); err != nil {
 			return nil, newStreamParseError(err, string(CreditReverseRecord), fs.currentTxn, fs.currentLine)
 		}
+		txn = &cr
 	case DebitReverseRecord:
 		dr := DebitReverse{}
 		if err := dr.Parse(txnsSegment[startIdx:endIdx]); err != nil {
 			return nil, newStreamParseError(err, string(DebitReverseRecord), fs.currentTxn, fs.currentLine)
 		}
+		txn = &dr
 	case HeaderRecord, NoticeOfChangeRecord, NoticeOfChangeHeader, NoticeOfChangeFooter, FooterRecord:
 		return nil, fmt.Errorf("invalid record type: %v", recordType)
 	}