Merge pull request #21 from datopian/method-to-put-dataset

#11  - Feature: create() and push() dataset

.prettierrc

@@ -1,5 +1,7 @@
 {
   "trailingComma": "es5",
+  "tabWidth": 2,
   "semi": false,
-  "singleQuote": true
+  "singleQuote": true,
+  "printWidth": 79
 }

lib/index.js

@@ -1,16 +1,17 @@
-const mapper = require('frictionless-ckan-mapper-js')
+const frictionlessCkanMapper = require('frictionless-ckan-mapper-js')
 const axios = require('axios')
 
 const CkanAuthApi = require('./util/ckan-auth-api')
 const CkanUploadAPI = require('./util/ckan-upload-api')
 const ActionApi = require('./util/action-api')
 const Open = require('./file')
+
 const { camelToSnakeCase } = require('./util/general')
 
 /**
  * @class Client.
  * @param {string} apiKey
- * @param {number} organizationId
+ * @param {string} organizationId
  * @param {string} datasetId
  * @param {string} api
  */
@@ -70,8 +71,36 @@ class Client {
     return response.data
   }
 
-  put(actionType, data) {
-    return ActionApi.action(this.api, this.apiKey, actionType, data)
+  /**
+   * @async
+   * @param {(string|Object)} datasetNameOrMetadata
+   * @return {Promise<Object>} The frictionless dataset
+   */
+  async create(datasetNameOrMetadata) {
+    const datasetMetadata =
+      typeof datasetNameOrMetadata === 'string'
+        ? { name: datasetNameOrMetadata }
+        : datasetNameOrMetadata
+
+    const ckanMetadata = frictionlessCkanMapper.packageFrictionlessToCkan(
+      datasetMetadata
+    )
+
+    const response = await this.action('package_create', ckanMetadata)
+    return frictionlessCkanMapper.packageCkanToFrictionless(response.result)
+  }
+
+  /**
+   * @async
+   * @param {Object} datasetMetadata
+   * @return {Promise<Object>} The frictionless dataset
+   */
+  async push(datasetMetadata) {
+    const ckanMetadata = frictionlessCkanMapper.packageFrictionlessToCkan(
+      datasetMetadata
+    )
+    const response = await this.action('package_update', ckanMetadata)
+    return frictionlessCkanMapper.packageCkanToFrictionless(response.result)
   }
 
   /**
@@ -90,7 +119,7 @@ class Client {
       true
     )
 
-    return mapper.packageCkanToFrictionless(response.result)
+    return frictionlessCkanMapper.packageCkanToFrictionless(response.result)
   }
 
   /**

package.json

@@ -7,7 +7,7 @@
     "test": "test"
   },
   "scripts": {
-    "test": "ava test/upload.test.js --verbose",
+    "test": "ava test/*.test.js --verbose",
     "test:watch": "ava test/*.test.js --verbose --watch",
     "build": "webpack",
     "build:watch": "webpack --watch"

test/get.test.js

@@ -25,7 +25,7 @@ test('get package', async (t) => {
   )
   const packageResponseConvertedToFrictionless = JSON.parse(
     await fs.readFileSync(
-      __dirname + '/mocks/getPackageFrictionlessResponse.json'
+      __dirname + '/mocks/frictionless-dataset-converted-from-ckan.json'
     )
   )
   // Testing dataname/id