package Ġgov . cdc . prime . router Ċ Ċ import Ġca . u hn . hl 7 v 2 . Default H api Context Ċ import Ġorg . junit . jupiter . api . Test Instance Ċ import Ġjava . io . ByteArray OutputStream Ċ import Ġjava . io . File Ċ import Ġjava . nio . charset . StandardCharsets Ċ import Ġkotlin . test . Test Ċ import Ġkotlin . test . assertEquals Ċ import Ġkotlin . test . assertNotNull Ċ Ċ @ Test Instance ( Test Instance . Lifecycle . PER _ CLASS ) Ċ class ĠH l 7 Converter Tests Ġ{ ĊĠĠĠ Ġprivate Ġval Ġtest Table : ĠM appable Table ĊĠĠĠ Ġprivate Ġval Ġcontext Ġ= ĠDefault H api Context () ĊĠĠĠ Ġprivate Ġval Ġmodel Class Factory Ġ= Ġcontext . model Class Factory ĊĠĠĠ Ġprivate Ġval Ġpipe Parser Ġ= Ġcontext . pipe Parser ĊĊĠĠĠ Ġinit Ġ{ ĊĠĠĠĠĠĠĠ ĠMetadata . load Schema Catalog ("./ src / test / unit _ test _ files ") ĊĠĠĠĠĠĠĠ ĠMetadata . load Value Set Catalog ("./ src / test / unit _ test _ files ") ĊĠĠĠĠĠĠĠ Ġval ĠinputStream Ġ= ĠFile ("./ src / test / unit _ test _ files / fake - p di - covid - 1 9 . csv "). inputStream () ĊĠĠĠĠĠĠĠ Ġval Ġschema Ġ= ĠMetadata . find Schema (" p di - covid - 1 9 ") Ġ?: Ġerror (" Cannot Ġfind Ġp di - covid - 1 9 ") ĊĠĠĠĠĠĠĠ Ġtest Table Ġ= ĠCsv Converter . read (" test ", Ġschema , ĠinputStream ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġ` Test Ġwrite Ġbatch `() Ġ{ ĊĠĠĠĠĠĠĠ Ġval ĠoutputStream Ġ= ĠByteArrayOutputStream () ĊĠĠĠĠĠĠĠ ĠH l 7 Converter . write ( test Table , ĠoutputStream ) ĊĠĠĠĠĠĠĠ Ġval Ġoutput Ġ= ĠoutputStream . toString ( StandardCharsets . UTF _ 8 ) ĊĠĠĠĠĠĠĠ ĠassertNotNull ( output ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġ` test Ġwrite Ġa Ġmessage `() Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġoutput Ġ= ĠH l 7 Converter . create Message ( test Table , Ġ 0 ) ĊĠĠĠĠĠĠĠ ĠassertNotNull ( output ) ĊĠĠĠ Ġ} Ċ }