Method to call CKAN action API about ckan-client-js HOT 3 CLOSED

await client.put('resource_create', resource.descriptor)

const ActionApi = require('./util/action-api')

class Client {
  constructor(authToken, organizationId, datasetId, api) {
    this.authToken = authToken
    this.organizationId = organizationId
    this.datasetId = datasetId
    this.api = api
  }

  put(actionType, data) {
    return ActionApi.action(this.api, this.authToken, actionType, data)
  }
 .
 .
 .
}

module.exports = {
  Client,
}

const ActionApi = {

  // Call the ckan api actions ie. 'package_create'
  action: async (baseUrl, authToken, actionType, data) => {
    const path = `/api/3/action/${actionType}`
    const config = {
      headers: {
        'Content-Type': 'application/json;charset=utf-8',
        Authorization: authToken,
      }
    }
    const body = JSON.stringify(data)

    const response = await axios.post(`${baseUrl}${path}`, data, config)
    if (!response.data.success) {
      throw `Action response: ${response.statusText}`
    }

    return response.data
  },
}

class Client {

  // Call the ckan api actions ie. 'package_create'
  action: async(actionType, payload, forceHttpGet=false) => {
    const path = `/api/3/action/${actionType}`
    const config = {
      headers: {
        'Content-Type': 'application/json;charset=utf-8',
        Authorization: this.authToken,
      }
    }

    const body = JSON.stringify(data)
    
    // TODO: if forceHttpGet then ...
    
    const response = await axios.post(`${baseUrl}${path}`, data, config)
    if (!response.data.success) {
      throw `Action response: ${response.statusText}`
    }
    return response.data
  },
}