@Ignore @Test public void compareLocalToOnline() throws IOException { HTTPFetcher httpFetcher = new HTTPFetcher(); FileSystemFetcher localFetcher = new FileSystemFetcher(true); SchemaRepository repo = new SchemaRepository(localFetcher); for (Schema schema : repo.getSchemas()) { SchemaVersion schemaVersion = new SchemaVersion(schema.prefix, schema.versions.get(0).number); String http = httpFetcher.fetchSchema(schemaVersion, SchemaType.RECORD_DEFINITION).trim(); String resource = localFetcher.fetchSchema(schemaVersion, SchemaType.RECORD_DEFINITION).trim(); Assert.assertEquals("Should be identical", resource, http); http = httpFetcher.fetchSchema(schemaVersion, SchemaType.VALIDATION_SCHEMA).trim(); resource = localFetcher.fetchSchema(schemaVersion, SchemaType.VALIDATION_SCHEMA).trim(); Assert.assertEquals("Should be identical", resource, http); } }
public List<Schema> getSchemas() { return schemas.schemas; }
SchemaRepository { public List<Schema> getSchemas() { return schemas.schemas; } }
SchemaRepository { public List<Schema> getSchemas() { return schemas.schemas; } SchemaRepository(Fetcher fetcher); }
SchemaRepository { public List<Schema> getSchemas() { return schemas.schemas; } SchemaRepository(Fetcher fetcher); void prefetchAllSchemas(); List<Schema> getSchemas(); SchemaResponse getSchema(SchemaVersion schemaVersion, SchemaType schemaType); }
SchemaRepository { public List<Schema> getSchemas() { return schemas.schemas; } SchemaRepository(Fetcher fetcher); void prefetchAllSchemas(); List<Schema> getSchemas(); SchemaResponse getSchema(SchemaVersion schemaVersion, SchemaType schemaType);  }