Support ForSchemaOption to call avro.Type.forSchema() (#47)

So that we can use @ovotech/avro-logical-types with @kafkajs/confluent-schema-registry.

src/SchemaRegistry.ts

@@ -1,7 +1,7 @@
 import { encode, MAGIC_BYTE } from './encoder'
 import decode from './decoder'
 import { COMPATIBILITY, DEFAULT_SEPERATOR } from './constants'
-import API, { SchemaRegistryAPIClientArgs, SchemaRegistryAPIClient } from './api'
+import API, { SchemaRegistryAPIClientArgs, SchemaRegistryAPIClientOptions, SchemaRegistryAPIClient } from './api'
 import Cache from './cache'
 import {
   ConfluentSchemaRegistryArgumentError,
@@ -28,9 +28,9 @@ export default class SchemaRegistry {
   private api: SchemaRegistryAPIClient
   public cache: Cache
 
-  constructor({ auth, clientId, host, retry }: SchemaRegistryAPIClientArgs) {
+  constructor({ auth, clientId, host, retry }: SchemaRegistryAPIClientArgs, options?: SchemaRegistryAPIClientOptions) {
     this.api = API({ auth, clientId, host, retry })
-    this.cache = new Cache()
+    this.cache = new Cache(options?.forSchemaOptions)
   }
 
   public async register(schema: Schema, userOpts?: Opts): Promise<RegisteredSchema> {

src/api/index.ts

@@ -1,6 +1,7 @@
 import forge, { Client, Authorization } from 'mappersmith'
 import RetryMiddleware, { RetryMiddlewareOptions } from 'mappersmith/middleware/retry/v2'
 import BasicAuthMiddleware from 'mappersmith/middleware/basic-auth'
+import { ForSchemaOptions } from 'avsc'
 
 import { DEFAULT_API_CLIENT_ID } from '../constants'
 import errorMiddleware from './middleware/errorMiddleware'
@@ -21,6 +22,10 @@ export interface SchemaRegistryAPIClientArgs {
   retry?: Partial<RetryMiddlewareOptions>
 }
 
+export interface SchemaRegistryAPIClientOptions {
+  forSchemaOptions?: Partial<ForSchemaOptions>
+}
+
 // TODO: Improve typings
 export type SchemaRegistryAPIClient = Client<{
   Schema: {

src/cache.ts

@@ -1,14 +1,16 @@
-import avro from 'avsc'
+import avro, { ForSchemaOptions } from 'avsc'
 
 import { Schema } from './@types'
 
 export default class Cache {
   registryIdBySubject: { [key: string]: number }
   schemasByRegistryId: { [key: string]: Schema }
+  forSchemaOptions?: Partial<ForSchemaOptions>
 
-  constructor() {
+  constructor(forSchemaOptions?: Partial<ForSchemaOptions>) {
     this.registryIdBySubject = {}
     this.schemasByRegistryId = {}
+    this.forSchemaOptions = forSchemaOptions
   }
 
   getLatestRegistryId = (subject: string): number | undefined => this.registryIdBySubject[subject]
@@ -23,7 +25,7 @@ export default class Cache {
 
   setSchema = (registryId: number, schema: Schema) => {
     // @ts-ignore TODO: Fix typings for Schema...
-    this.schemasByRegistryId[registryId] = avro.Type.forSchema(schema)
+    this.schemasByRegistryId[registryId] = avro.Type.forSchema(schema, this.forSchemaOptions)
 
     return this.schemasByRegistryId[registryId]
   }