ZeppelinHubRepo implements NotebookRepo { @Override public List<NoteInfo> list(AuthenticationInfo subject) throws IOException { String response = restApiClient.asyncGet(""); List<NoteInfo> notes = GSON.fromJson(response, new TypeToken<List<NoteInfo>>() {}.getType()); if (notes == null) { return Collections.emptyList(); } LOG.info("ZeppelinHub REST API listing notes "); return notes; } ZeppelinHubRepo(ZeppelinConfiguration conf); @Override List<NoteInfo> list(AuthenticationInfo subject); @Override Note get(String noteId, AuthenticationInfo subject); @Override void save(Note note, AuthenticationInfo subject); @Override void remove(String noteId, AuthenticationInfo subject); @Override void close(); @Override Revision checkpoint(String noteId, String checkpointMsg, AuthenticationInfo subject); @Override Note get(String noteId, Revision rev, AuthenticationInfo subject); @Override List<Revision> revisionHistory(String noteId, AuthenticationInfo subject); static final String TOKEN_HEADER; }
@Test public void testGetAllNotes() throws IOException { List<NoteInfo> notebooks = repo.list(null); assertThat(notebooks).isNotEmpty(); assertThat(notebooks.size()).isEqualTo(3); }