Move dependencies to devDependencies

README.md

@@ -50,12 +50,12 @@ npm install @dsnp/parquetjs
 ```
 
 ```typescript
-import { AnnouncementType } from "@dsnp/schemas"; 
+import { AnnouncementType } from "@dsnp/schemas";
 import { parquet } from "@dsnp/schemas";
-import { ParquetWriter } from "@dsnp/parquetjs";
+import { ParquetWriter, ParquetSchema } from "@dsnp/parquetjs";
 
 const [parquetSchema, writerOptions] = parquet.fromDSNPSchema(descriptorForAnnouncementType(AnnouncementType.Broadcast).parquetSchema);
-const writer = await ParquetWriter.openFile(parquetSchema, "./file.parquet", writerOptions);
+const writer = await ParquetWriter.openFile(new ParquetSchema(parquetSchema), "./file.parquet", writerOptions);
 writer.appendRow({
   announcementType: AnnouncementType.Broadcast,
   contentHash: "bciqdnu347gcfmxzbkhgoubiobphm6readngitfywktdtbdocgogop2q",

__snapshots__/parquet.spec.ts.snap

@@ -72,6 +72,7 @@ ParquetSchema {
       "compression": "GZIP",
       "dLevelMax": 0,
       "encoding": "PLAIN",
+      "logicalType": undefined,
       "name": "announcementType",
       "originalType": "INT_32",
       "path": [
@@ -89,6 +90,7 @@ ParquetSchema {
       "compression": "GZIP",
       "dLevelMax": 0,
       "encoding": "PLAIN",
+      "logicalType": undefined,
       "name": "contentHash",
       "originalType": "UTF8",
       "path": [
@@ -106,6 +108,7 @@ ParquetSchema {
       "compression": "GZIP",
       "dLevelMax": 0,
       "encoding": "PLAIN",
+      "logicalType": undefined,
       "name": "fromId",
       "originalType": "UINT_64",
       "path": [
@@ -123,6 +126,7 @@ ParquetSchema {
       "compression": "GZIP",
       "dLevelMax": 0,
       "encoding": "PLAIN",
+      "logicalType": undefined,
       "name": "url",
       "originalType": "UTF8",
       "path": [
@@ -142,6 +146,7 @@ ParquetSchema {
       "compression": "GZIP",
       "dLevelMax": 0,
       "encoding": "PLAIN",
+      "logicalType": undefined,
       "name": "announcementType",
       "originalType": "INT_32",
       "path": [
@@ -159,6 +164,7 @@ ParquetSchema {
       "compression": "GZIP",
       "dLevelMax": 0,
       "encoding": "PLAIN",
+      "logicalType": undefined,
       "name": "contentHash",
       "originalType": "UTF8",
       "path": [
@@ -176,6 +182,7 @@ ParquetSchema {
       "compression": "GZIP",
       "dLevelMax": 0,
       "encoding": "PLAIN",
+      "logicalType": undefined,
       "name": "fromId",
       "originalType": "UINT_64",
       "path": [
@@ -193,6 +200,7 @@ ParquetSchema {
       "compression": "GZIP",
       "dLevelMax": 0,
       "encoding": "PLAIN",
+      "logicalType": undefined,
       "name": "url",
       "originalType": "UTF8",
       "path": [

announcements.ts

@@ -7,7 +7,7 @@ import userAttributeSet from "./parquet/user-attribute-set.js";
 import dsnpContentAttributeSet from "./parquet/dsnp-content-attribute-set.js";
 import externalContentAttributeSet from "./parquet/external-content-attribute-set.js";
 
-import { DSNPParquetSchema } from "./types/dsnp-parquet.js";
+import type { DSNPParquetSchema } from "./types/dsnp-parquet.js";
 
 export enum AnnouncementType {
   Tombstone = 0,

avro/GraphEdge.spec.ts

@@ -1,14 +1,15 @@
 import graphEdgeSchema from "./GraphEdge.js";
 import avro from "avsc";
+import type { Schema } from "avsc";
 
 describe("Graph Edge Schema", () => {
   it("Is Avro", () => {
-    const parsed = avro.Type.forSchema(graphEdgeSchema);
+    const parsed = avro.Type.forSchema(graphEdgeSchema as Schema);
     expect(parsed).toBeDefined();
   });
 
   it("Encodes and decodes object", () => {
-    const parsed = avro.Type.forSchema(graphEdgeSchema);
+    const parsed = avro.Type.forSchema(graphEdgeSchema as Schema);
     const encoded = parsed.toBuffer({ userId: 123456789, since: 1722524715 });
     const decoded = parsed.fromBuffer(encoded);
     expect(decoded.userId).toStrictEqual(123456789);

avro/GraphEdge.ts

@@ -1,6 +1,4 @@
-import { Schema } from "avsc";
-
-const GraphEdge: Schema = {
+const GraphEdge = {
   namespace: "org.dsnp",
   name: "GraphEdge",
   type: "record",

avro/PRId.spec.ts

@@ -1,14 +1,15 @@
 import pridSchema from "./PRId.js";
 import avro from "avsc";
+import type { Schema } from "avsc";
 
 describe("PRId Schema", () => {
   it("Is Avro", () => {
-    const parsed = avro.Type.forSchema(pridSchema);
+    const parsed = avro.Type.forSchema(pridSchema as Schema);
     expect(parsed).toBeDefined();
   });
 
   it("Encodes and decodes buffer", () => {
-    const parsed = avro.Type.forSchema(pridSchema);
+    const parsed = avro.Type.forSchema(pridSchema as Schema);
     const someBytes = Buffer.from([0, 1, 2, 3, 4, 5, 6, 7]);
     const encoded = parsed.toBuffer(someBytes);
     const decoded = parsed.fromBuffer(encoded);

avro/PRId.ts

@@ -1,6 +1,4 @@
-import { Schema } from "avsc";
-
-const PRId: Schema = {
+const PRId = {
   namespace: "org.dsnp",
   name: "PRId",
   type: "fixed",

avro/ProfileResource.spec.ts

@@ -1,14 +1,15 @@
 import profileResourceSchema from "./ProfileResource.js";
 import { Type } from "avsc";
+import type { Schema } from "avsc";
 
 describe("Profile Resource Schema", () => {
   it("Is Avro", () => {
-    const parsed = Type.forSchema(profileResourceSchema);
+    const parsed = Type.forSchema(profileResourceSchema as Schema);
     expect(parsed).toBeDefined();
   });
 
   it("Encodes and decodes object", () => {
-    const parsed = Type.forSchema(profileResourceSchema);
+    const parsed = Type.forSchema(profileResourceSchema as Schema);
     const exampleCid = "bafybeida7z24mig7j3oagjru7s2gw6xbfkh7fryvah6ho2ar77xb7aleom";
     const encoded = parsed.toBuffer({
       type: 1,

avro/ProfileResource.ts

@@ -1,6 +1,4 @@
-import { Schema } from "avsc";
-
-const ProfileResource: Schema = {
+const ProfileResource = {
   namespace: "org.dsnp",
   name: "ProfileResource",
   type: "record",

avro/PublicKey.spec.ts

@@ -1,14 +1,15 @@
 import publicKeySchema from "./PublicKey.js";
 import avro from "avsc";
+import type { Schema } from "avsc";
 
 describe("Public Key Schema", () => {
   it("Is Avro", () => {
-    const parsed = avro.Type.forSchema(publicKeySchema);
+    const parsed = avro.Type.forSchema(publicKeySchema as Schema);
     expect(parsed).toBeDefined();
   });
 
   it("Encodes and decodes object", () => {
-    const parsed = avro.Type.forSchema(publicKeySchema);
+    const parsed = avro.Type.forSchema(publicKeySchema as Schema);
     const someBytes = Buffer.from([0, 1, 2, 3]);
     const encoded = parsed.toBuffer({ publicKey: someBytes });
     const decoded = parsed.fromBuffer(encoded);

avro/PublicKey.ts

@@ -1,6 +1,4 @@
-import { Schema } from "avsc";
-
-const PublicKey: Schema = {
+const PublicKey = {
   type: "record",
   name: "PublicKey",
   namespace: "org.dsnp",

index.ts

@@ -3,3 +3,5 @@ export { AnnouncementDescriptor, AnnouncementType, descriptorForAnnouncementType
 export { UserDataDescriptor, UserDataType, descriptorForUserDataType } from "./user-data.js";
 
 export * as parquet from "./parquet.js";
+
+export * from "./types/dsnp-parquet.js";