add getConnectorAll and getConnectorByConnectorName api

Madadata · Jan 11, 2017 · c122a0d · c122a0d
1 parent 8ee5c3c
commit c122a0d
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 7 deletions.
diff --git a/src/index.js b/src/index.js
@@ -10,6 +10,7 @@ import querystring from 'querystring'
 
 const versionUri = 'version'
 const driverUri = 'v1/driver'
+const connectorUri = 'v1/connector'
 
 export class Hasoop {
   constructor (config) {
@@ -47,4 +48,14 @@ export class Hasoop {
     const url = this.formatUrl([driverUri], 'all')
     return sendGetRequest(url)
   }
+
+  getConnectorAll () {
+    const url = this.formatUrl([connectorUri], 'all')
+    return sendGetRequest(url)
+  }
+
+  getConnectorByConnectorName (connectorName) {
+    const url = this.formatUrl([connectorUri], connectorName)
+    return sendGetRequest(url)
+  }
 }
diff --git a/test/connector.test.js b/test/connector.test.js
@@ -3,18 +3,18 @@
  */
 
 import { expect } from 'chai'
-import { Hasoop } from '../src/index'
-
-const sqoopClient = new Hasoop('')
+import { sqoopClient } from './index'
 
 suite('connector', () => {
-  test.skip('getConnectorAll', () => {
-    sqoopClient.getConnectorAll()
+  test('getConnectorAll', async () => {
+    const data = await sqoopClient.getConnectorAll()
+    expect(data['connectors'].length).to.equal(7)
   })
 
-  test.skip('getConnectorByConnectorName', () => {
+  test('getConnectorByConnectorName', async () => {
     const connectorName = 'generic-jdbc-connector'
-    sqoopClient.getConnectorByConnectorName(connectorName)
+    const data = await sqoopClient.getConnectorByConnectorName(connectorName)
+    expect(data['connectors'][0]['name']).to.equal('generic-jdbc-connector')
   })
 
 })