|
|
@@ -0,0 +1,182 @@
|
|
|
+/*
|
|
|
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
|
|
|
+ * or more contributor license agreements. Licensed under the Elastic License
|
|
|
+ * 2.0; you may not use this file except in compliance with the Elastic License
|
|
|
+ * 2.0.
|
|
|
+ */
|
|
|
+
|
|
|
+package org.elasticsearch.xpack.esql.expression.function;
|
|
|
+
|
|
|
+import org.elasticsearch.common.io.stream.ByteArrayStreamInput;
|
|
|
+
|
|
|
+import java.io.ByteArrayOutputStream;
|
|
|
+import java.io.DataInputStream;
|
|
|
+import java.io.IOException;
|
|
|
+import java.io.InputStream;
|
|
|
+import java.nio.ByteBuffer;
|
|
|
+import java.util.ArrayList;
|
|
|
+import java.util.HashMap;
|
|
|
+import java.util.Iterator;
|
|
|
+import java.util.LinkedHashMap;
|
|
|
+import java.util.zip.DataFormatException;
|
|
|
+import java.util.zip.Inflater;
|
|
|
+
|
|
|
+/**
|
|
|
+ * Converts woff to ttf. Borrowed from <a href="https://github.com/anupthegit/WOFFToTTFJava">here</a>.
|
|
|
+ * Their license is MIT.
|
|
|
+ */
|
|
|
+class WoffConverter {
|
|
|
+ private static final LinkedHashMap<String, Integer> WOFF_HEADER_FORMAT = new LinkedHashMap<>();
|
|
|
+ static {
|
|
|
+ WOFF_HEADER_FORMAT.put("signature", 4);
|
|
|
+ WOFF_HEADER_FORMAT.put("flavor", 4);
|
|
|
+ WOFF_HEADER_FORMAT.put("length", 4);
|
|
|
+ WOFF_HEADER_FORMAT.put("numTables", 2);
|
|
|
+ WOFF_HEADER_FORMAT.put("reserved", 2);
|
|
|
+ WOFF_HEADER_FORMAT.put("totalSfntSize", 4);
|
|
|
+ WOFF_HEADER_FORMAT.put("majorVersion", 2);
|
|
|
+ WOFF_HEADER_FORMAT.put("minorVersion", 2);
|
|
|
+ WOFF_HEADER_FORMAT.put("metaOffset", 4);
|
|
|
+ WOFF_HEADER_FORMAT.put("metaLength", 4);
|
|
|
+ WOFF_HEADER_FORMAT.put("metaOrigLength", 4);
|
|
|
+ WOFF_HEADER_FORMAT.put("privOffset", 4);
|
|
|
+ WOFF_HEADER_FORMAT.put("privOrigLength", 4);
|
|
|
+ };
|
|
|
+
|
|
|
+ private static final LinkedHashMap<String, Integer> TABLE_RECORD_ENTRY_FORMAT = new LinkedHashMap<>();
|
|
|
+ static {
|
|
|
+ TABLE_RECORD_ENTRY_FORMAT.put("tag", 4);
|
|
|
+ TABLE_RECORD_ENTRY_FORMAT.put("offset", 4);
|
|
|
+ TABLE_RECORD_ENTRY_FORMAT.put("compLength", 4);
|
|
|
+ TABLE_RECORD_ENTRY_FORMAT.put("origLength", 4);
|
|
|
+ TABLE_RECORD_ENTRY_FORMAT.put("origChecksum", 4);
|
|
|
+ };
|
|
|
+
|
|
|
+ private HashMap<String, Number> woffHeaders = new HashMap<String, Number>();
|
|
|
+
|
|
|
+ private ArrayList<HashMap<String, Number>> tableRecordEntries = new ArrayList<HashMap<String, Number>>();
|
|
|
+
|
|
|
+ private int offset = 0;
|
|
|
+
|
|
|
+ private int readOffset = 0;
|
|
|
+
|
|
|
+ public InputStream convertToTTFOutputStream(InputStream woffFileStream) throws IOException {
|
|
|
+ getHeaders(new DataInputStream(woffFileStream));
|
|
|
+ if ((Integer) woffHeaders.get("signature") != 0x774F4646) {
|
|
|
+ throw new IllegalArgumentException("Invalid woff file");
|
|
|
+ }
|
|
|
+ ByteArrayOutputStream ttfOutputStream = new ByteArrayOutputStream();
|
|
|
+ writeOffsetTable(ttfOutputStream);
|
|
|
+ getTableRecordEntries(new DataInputStream(woffFileStream));
|
|
|
+ writeTableRecordEntries(ttfOutputStream);
|
|
|
+ writeFontData(woffFileStream, ttfOutputStream);
|
|
|
+ return new ByteArrayStreamInput(ttfOutputStream.toByteArray());
|
|
|
+ }
|
|
|
+
|
|
|
+ private void getHeaders(DataInputStream woffFileStream) throws IOException {
|
|
|
+ readTableData(woffFileStream, WOFF_HEADER_FORMAT, woffHeaders);
|
|
|
+ }
|
|
|
+
|
|
|
+ private void writeOffsetTable(ByteArrayOutputStream ttfOutputStream) throws IOException {
|
|
|
+ ttfOutputStream.write(getBytes((Integer) woffHeaders.get("flavor")));
|
|
|
+ int numTables = (Integer) woffHeaders.get("numTables");
|
|
|
+ ttfOutputStream.write(getBytes((short) numTables));
|
|
|
+ int temp = numTables;
|
|
|
+ int searchRange = 16;
|
|
|
+ short entrySelector = 0;
|
|
|
+ while (temp > 1) {
|
|
|
+ temp = temp >> 1;
|
|
|
+ entrySelector++;
|
|
|
+ searchRange = (searchRange << 1);
|
|
|
+ }
|
|
|
+ short rangeShift = (short) (numTables * 16 - searchRange);
|
|
|
+ ttfOutputStream.write(getBytes((short) searchRange));
|
|
|
+ ttfOutputStream.write(getBytes(entrySelector));
|
|
|
+ ttfOutputStream.write(getBytes(rangeShift));
|
|
|
+ offset += 12;
|
|
|
+ }
|
|
|
+
|
|
|
+ private void getTableRecordEntries(DataInputStream woffFileStream) throws IOException {
|
|
|
+ int numTables = (Integer) woffHeaders.get("numTables");
|
|
|
+ for (int i = 0; i < numTables; i++) {
|
|
|
+ HashMap<String, Number> tableDirectory = new HashMap<String, Number>();
|
|
|
+ readTableData(woffFileStream, TABLE_RECORD_ENTRY_FORMAT, tableDirectory);
|
|
|
+ offset += 16;
|
|
|
+ tableRecordEntries.add(tableDirectory);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ private void writeTableRecordEntries(ByteArrayOutputStream ttfOutputStream) throws IOException {
|
|
|
+ for (HashMap<String, Number> tableRecordEntry : tableRecordEntries) {
|
|
|
+ ttfOutputStream.write(getBytes((Integer) tableRecordEntry.get("tag")));
|
|
|
+ ttfOutputStream.write(getBytes((Integer) tableRecordEntry.get("origChecksum")));
|
|
|
+ ttfOutputStream.write(getBytes(offset));
|
|
|
+ ttfOutputStream.write(getBytes((Integer) tableRecordEntry.get("origLength")));
|
|
|
+ tableRecordEntry.put("outOffset", offset);
|
|
|
+ offset += (Integer) tableRecordEntry.get("origLength");
|
|
|
+ if (offset % 4 != 0) {
|
|
|
+ offset += 4 - (offset % 4);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ private void writeFontData(InputStream woffFileStream, ByteArrayOutputStream ttfOutputStream) throws IOException {
|
|
|
+ for (HashMap<String, Number> tableRecordEntry : tableRecordEntries) {
|
|
|
+ int tableRecordEntryOffset = (Integer) tableRecordEntry.get("offset");
|
|
|
+ int skipBytes = tableRecordEntryOffset - readOffset;
|
|
|
+ if (skipBytes > 0) woffFileStream.skip(skipBytes);
|
|
|
+ readOffset += skipBytes;
|
|
|
+ int compressedLength = (Integer) tableRecordEntry.get("compLength");
|
|
|
+ int origLength = (Integer) tableRecordEntry.get("origLength");
|
|
|
+ byte[] fontData = new byte[compressedLength];
|
|
|
+ byte[] inflatedFontData = new byte[origLength];
|
|
|
+ int readBytes = 0;
|
|
|
+ while (readBytes < compressedLength) {
|
|
|
+ readBytes += woffFileStream.read(fontData, readBytes, compressedLength - readBytes);
|
|
|
+ }
|
|
|
+ readOffset += compressedLength;
|
|
|
+ inflatedFontData = inflateFontData(compressedLength, origLength, fontData, inflatedFontData);
|
|
|
+ ttfOutputStream.write(inflatedFontData);
|
|
|
+ offset = (Integer) tableRecordEntry.get("outOffset") + (Integer) tableRecordEntry.get("origLength");
|
|
|
+ int padding = 0;
|
|
|
+ if (offset % 4 != 0) padding = 4 - (offset % 4);
|
|
|
+ ttfOutputStream.write(getBytes(0), 0, padding);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ private byte[] inflateFontData(int compressedLength, int origLength, byte[] fontData, byte[] inflatedFontData) {
|
|
|
+ if (compressedLength != origLength) {
|
|
|
+ Inflater decompressor = new Inflater();
|
|
|
+ decompressor.setInput(fontData, 0, compressedLength);
|
|
|
+ try {
|
|
|
+ decompressor.inflate(inflatedFontData, 0, origLength);
|
|
|
+ } catch (DataFormatException e) {
|
|
|
+ throw new IllegalArgumentException("Malformed woff file");
|
|
|
+ }
|
|
|
+ } else inflatedFontData = fontData;
|
|
|
+ return inflatedFontData;
|
|
|
+ }
|
|
|
+
|
|
|
+ private byte[] getBytes(int i) {
|
|
|
+ return ByteBuffer.allocate(4).putInt(i).array();
|
|
|
+ }
|
|
|
+
|
|
|
+ private byte[] getBytes(short h) {
|
|
|
+ return ByteBuffer.allocate(2).putShort(h).array();
|
|
|
+ }
|
|
|
+
|
|
|
+ private void readTableData(DataInputStream woffFileStream, LinkedHashMap<String, Integer> formatTable, HashMap<String, Number> table)
|
|
|
+ throws IOException {
|
|
|
+ Iterator<String> headerKeys = formatTable.keySet().iterator();
|
|
|
+ while (headerKeys.hasNext()) {
|
|
|
+ String key = headerKeys.next();
|
|
|
+ int size = formatTable.get(key);
|
|
|
+ if (size == 2) {
|
|
|
+ table.put(key, woffFileStream.readUnsignedShort());
|
|
|
+ } else if (size == 4) {
|
|
|
+ table.put(key, woffFileStream.readInt());
|
|
|
+ }
|
|
|
+ readOffset += size;
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
Nik Everett
