package life.catalogue.dw.jersey.writers;

import com.google.common.base.Throwables;
import life.catalogue.common.io.UTF8IOUtils;
import life.catalogue.dw.jersey.MoreMediaTypes;

import javax.ws.rs.Produces;
import javax.ws.rs.WebApplicationException;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.MultivaluedMap;
import javax.ws.rs.ext.MessageBodyWriter;
import javax.ws.rs.ext.Provider;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.OutputStream;
import java.lang.annotation.Annotation;
import java.lang.reflect.Type;
import java.util.stream.Stream;

@Produces({MoreMediaTypes.TEXT_TSV})
@Provider
public class TsvBodyWriter implements MessageBodyWriter<Stream<Object[]>> {
  
  @Override
  public boolean isWriteable(Class<?> type, Type type1, Annotation[] antns, MediaType mt) {
    return Stream.class.isAssignableFrom(type);
  }
  
  @Override
  public void writeTo(Stream<Object[]> rows, Class<?> type, Type type1, Annotation[] antns, MediaType mt, MultivaluedMap<String, Object> mm, OutputStream out) throws IOException, WebApplicationException {
    BufferedWriter br = UTF8IOUtils.writerFromStream(out);
    try {
      rows.forEach(row -> {
        try {
          br.append(toTsv(row));
        } catch(Exception e) {
          Throwables.throwIfUnchecked(e);
          throw new RuntimeException(e);
        }
      });
    } finally {
      br.close();
    }
  }

  private static String toTsv(Object[] row) {
    StringBuilder sb = new StringBuilder();
    for (Object col : row) {
      if (sb.length() > 0) {
        sb.append('\t');
      }
      sb.append(col.toString().replaceAll("\t", " "));
    }
    return sb.toString();
  }
}
@@ -1589,24 +1589,51 @@
 ');%0A      %7D%0A
+      if (col != null) %7B%0A  
       sb.app
@@ -1671,24 +1671,32 @@
 %5Ct%22, %22 %22));%0A
+      %7D%0A
     %7D%0A    re

fix tsv npe