Added #147 dragon features and DTOs

Author: rg911

src/infrastructure/ChainHttps.ts

@@ -0,0 +1,68 @@
+/*
+ * Copyright 2018 NEM
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import {ChainRoutesApi} from 'nem2-library';
+import {from as observableFrom, Observable} from 'rxjs';
+import {map} from 'rxjs/operators';
+import {BlockchainScore} from '../model/blockchain/BlockchainScore';
+import {UInt64} from '../model/UInt64';
+import { ChainRepository } from './ChainRepository';
+import {Http} from './Http';
+
+/**
+ * Chian http repository.
+ *
+ * @since 1.0
+ */
+export class ChainHttp extends Http implements ChainRepository {
+    /**
+     * @internal
+     * Nem2 Library chain routes api
+     */
+    private chainRoutesApi: ChainRoutesApi;
+
+    /**
+     * Constructor
+     * @param url
+     */
+    constructor(url: string) {
+        super(url);
+        this.chainRoutesApi = new ChainRoutesApi(this.apiClient);
+    }
+
+    /**
+     * Gets current blockchain height
+     * @returns Observable<UInt64>
+     */
+    public getBlockchainHeight(): Observable<UInt64> {
+        return observableFrom(this.chainRoutesApi.getBlockchainHeight()).pipe(map((heightDTO) => {
+            return new UInt64(heightDTO.height);
+        }));
+    }
+
+    /**
+     * Gets current blockchain score
+     * @returns Observable<BlockchainScore>
+     */
+    public getBlockchainScore(): Observable<BlockchainScore> {
+        return observableFrom(this.chainRoutesApi.getBlockchainScore()).pipe(map((blockchainScoreDTO) => {
+            return new BlockchainScore(
+                new UInt64(blockchainScoreDTO.scoreLow),
+                new UInt64(blockchainScoreDTO.scoreHigh),
+            );
+        }));
+    }
+}

src/infrastructure/DiagnosticHttps.ts

@@ -0,0 +1,72 @@
+/*
+ * Copyright 2019 NEM
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import {DiagnosticRoutesApi} from 'nem2-library';
+import {from as observableFrom, Observable} from 'rxjs';
+import {map} from 'rxjs/operators';
+import {BlockchainStorageInfo} from '../model/blockchain/BlockchainStorageInfo';
+import { ServerInfo } from '../model/diagnostic/ServerInfo';
+import {DiagnosticRepository} from './DiagnosticRepository';
+import {Http} from './Http';
+
+/**
+ * Diagnostic http repository.
+ *
+ * @since 1.0
+ */
+export class DiagnosticHttp extends Http implements DiagnosticRepository {
+    /**
+     * @internal
+     * Nem2 Library diagnostic routes api
+     */
+    private diagnosticRoutesApi: DiagnosticRoutesApi;
+
+    /**
+     * Constructor
+     * @param url
+     */
+    constructor(url: string) {
+        super(url);
+        this.diagnosticRoutesApi = new DiagnosticRoutesApi(this.apiClient);
+    }
+
+    /**
+     * Gets blockchain storage info.
+     * @returns Observable<BlockchainStorageInfo>
+     */
+    public getDiagnosticStorage(): Observable<BlockchainStorageInfo> {
+        return observableFrom(
+            this.diagnosticRoutesApi.getDiagnosticStorage()).pipe(map((blockchainStorageInfoDTO) => {
+            return new BlockchainStorageInfo(
+                blockchainStorageInfoDTO.numBlocks,
+                blockchainStorageInfoDTO.numTransactions,
+                blockchainStorageInfoDTO.numAccounts,
+            );
+        }));
+    }
+
+    /**
+     * Gets blockchain server info.
+     * @returns Observable<Server>
+     */
+    public getServerInfo(): Observable<ServerInfo> {
+        return observableFrom(
+            this.diagnosticRoutesApi.getServerInfo()).pipe(map((serverDTO) => {
+            return new ServerInfo(serverDTO.serverInfo.restVersion,
+                serverDTO.serverInfo.sdkVersion);
+        }));
+    }
+}