package Ġcom . cod ality . data . tools . file Ċ Ċ import Ġorg . slf 4 j . LoggerFactory Ċ import Ġcom . cod ality . data . tools . db . mongo . Mongo Document Loader Ċ import Ġcom . cod ality . data . tools . config . Parser Conf Ċ import Ġcom . cod ality . data . tools . parser . File Format Ċ import Ġcom . cod ality . data . tools . parser . File Parser Ċ import Ġjava . io . File Ċ import Ġjava . util . concurrent . Concurrent Linked Queue Ċ import Ġkotlin . time . Experimental Time Ċ import Ġorg . junit . jupiter . api . Test Ċ Ċ class ĠJson Test Ġ{ ĊĊĊĠĠĠ Ġcompanion Ġobject Ġ{ ĊĠĠĠĠĠĠĠ Ġprivate Ġval ĠLOG Ġ= ĠLoggerFactory . getLogger ( Json Test :: class . java ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Experimental Time ĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġload Json Files () Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġconfig Ġ= ĠParser Conf (). load ( File ( Csv Loader Test :: class . java . class Loader . getResource (" json - files . yml ") !!. file )) ĊĠĠĠĠĠĠĠ Ġval Ġparser Ġ= ĠFile Parser ( File Format . JSON , Ġconfig ) ĊĠĠĠĠĠĠĠ Ġval Ġqueue Ġ= ĠConcurrent Linked Queue < Pair < String , ĠByteArray >>() ĊĠĠĠĠĠĠĠ Ġval Ġloader Ġ= ĠMongo Document Loader ( config , Ġqueue ) ĊĠĠĠĠĠĠĠ Ġloader . start Mongo Document Loader () ĊĠĠĠĠĠĠĠ Ġval Ġfiles Ġ= Ġparser . find Files In Path (" src / test / resources /", Ġ" json ") ĊĠĠĠĠĠĠĠ Ġfiles . forEach Ġ{ Ġfile Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ ĠLOG . info (" parsing Ġtest Ġfile : Ġ${ file . name Without Extension }") ĊĠĠĠĠĠĠĠĠĠĠĠ Ġqueue . add ( file . name Without Extension Ġto Ġparser . parse ( file ). toString (). toByteArray ()) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġloader . shutdown () ĊĠĠĠ Ġ} Ċ }