1 files changed, 62 insertions, 0 deletions
diff --git a/src/arrow/js/test/unit/builders/utf8-tests.ts b/src/arrow/js/test/unit/builders/utf8-tests.ts
new file mode 100644
index 000000000..212879ab4
--- /dev/null
+++ b/src/arrow/js/test/unit/builders/utf8-tests.ts
@@ -0,0 +1,62 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+import { validateVector } from './utils';
+import { Vector, Utf8 } from 'apache-arrow';
+import {
+    encodeAll,
+    encodeEach,
+    encodeEachDOM,
+    encodeEachNode,
+    stringsNoNulls,
+    stringsWithNAs,
+    stringsWithNulls,
+    stringsWithEmpties
+} from './utils';
+
+const testDOMStreams = process.env.TEST_DOM_STREAMS === 'true';
+const testNodeStreams = process.env.TEST_NODE_STREAMS === 'true';
+
+describe('Utf8Builder', () => {
+    runTestsWithEncoder('encodeAll', encodeAll(() => new Utf8()));
+    runTestsWithEncoder('encodeEach: 5', encodeEach(() => new Utf8(), 5));
+    runTestsWithEncoder('encodeEach: 25', encodeEach(() => new Utf8(), 25));
+    runTestsWithEncoder('encodeEach: undefined', encodeEach(() => new Utf8(), void 0));
+    testDOMStreams && runTestsWithEncoder('encodeEachDOM: 25', encodeEachDOM(() => new Utf8(), 25));
+    testNodeStreams && runTestsWithEncoder('encodeEachNode: 25', encodeEachNode(() => new Utf8(), 25));
+});
+
+function runTestsWithEncoder(name: string, encode: (vals: (string | null)[], nullVals?: any[]) => Promise<Vector<Utf8>>) {
+    describe(`${encode.name} ${name}`, () => {
+        it(`encodes strings no nulls`, async () => {
+            const vals = stringsNoNulls(20);
+            validateVector(vals, await encode(vals, []), []);
+        });
+        it(`encodes strings with nulls`, async () => {
+            const vals = stringsWithNulls(20);
+            validateVector(vals, await encode(vals, [null]), [null]);
+        });
+        it(`encodes strings using n/a as the null value rep`, async () => {
+            const vals = stringsWithNAs(20);
+            validateVector(vals, await encode(vals, ['n/a']), ['n/a']);
+        });
+        it(`encodes strings using \\0 as the null value rep`, async () => {
+            const vals = stringsWithEmpties(20);
+            validateVector(vals, await encode(vals, ['\0']), ['\0']);
+        });
+    });
+}