Add clearLatestCaches/clearCaches API, fix test to call clearLatestCaches (#102)

* Add clearLatestCaches for use in tests

* Minor cleanup

* Minor cleanup

Author: rayokota

schemaregistry/mock-schemaregistry-client.ts

@@ -426,6 +426,14 @@ class MockClient implements Client {
     return config;
   }
 
+  clearLatestCaches(): void {
+    return;
+  }
+
+  clearCaches(): void {
+    return;
+  }
+
   async close(): Promise<void> {
     return;
   }

schemaregistry/schemaregistry-client.ts

@@ -135,6 +135,8 @@ export interface Client {
   updateConfig(subject: string, update: ServerConfig): Promise<ServerConfig>;
   getDefaultConfig(): Promise<ServerConfig>;
   updateDefaultConfig(update: ServerConfig): Promise<ServerConfig>;
+  clearLatestCaches(): void;
+  clearCaches(): void;
   close(): void;
 }
 
@@ -557,13 +559,23 @@ export class SchemaRegistryClient implements Client {
     return response.data;
   }
 
-  close(): void {
+  clearLatestCaches(): void {
+    this.latestToSchemaCache.clear();
+    this.metadataToSchemaCache.clear();
+  }
+
+  clearCaches(): void {
+    this.schemaToIdCache.clear();
+    this.idToSchemaInfoCache.clear();
     this.infoToSchemaCache.clear();
+    this.latestToSchemaCache.clear();
     this.schemaToVersionCache.clear();
     this.versionToSchemaCache.clear();
-    this.idToSchemaInfoCache.clear();
+    this.metadataToSchemaCache.clear();
+  }
 
-    return;
+  async close(): Promise<void> {
+    this.clearCaches();
   }
 
   // Cache methods for testing

test/schemaregistry/serde/avro.spec.ts

@@ -401,6 +401,7 @@ describe('AvroSerializer', () => {
 
     await client.register(subject, info, false)
 
+    client.clearLatestCaches()
     let deser = new AvroDeserializer(client, SerdeType.VALUE, {useLatestVersion: true})
     let obj2 = await deser.deserialize(topic, bytes)
     expect(obj2.fieldToDelete).toEqual(undefined);