/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You 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.
 */

'use strict'

const BaseOperation = require('./base_operation')
const names = require('./names')

class Resources extends BaseOperation {
  constructor (client) {
    super(client)
    this.identifiers = ['name']
    this.qs_options = {}
  }

  list (options) {
    return this.operation('GET', options)
  }

  get (options) {
    return this.operationWithId('GET', options)
  }

  invoke (options) {
    options = options || {}
    if (typeof options === 'object' && !Array.isArray(options)) {
      options.qs = this.qs(options, this.qs_options.invoke || [])
      options.body = this.payload(options)
    }
    return this.operationWithId('POST', options)
  }

  create (options) {
    if (options && typeof options.annotations === 'object') {
      const annotations = this.parseAnnotations(options.annotations)
      options.body = Object.assign({ annotations }, options.body)
    }

    return this.operationWithId('PUT', options)
  }

  delete (options) {
    return this.operationWithId('DELETE', options)
  }

  update (options) {
    options = this.parseOptions(options)
    options.overwrite = true
    return this.create(options)
  }

  operation (method, options) {
    options = this.parseOptions(options)
    const id = options.id
    return this.request({ method, id, options })
  }

  operationWithId (method, options) {
    if (Array.isArray(options)) {
      return Promise.all(options.map(i => this.operationWithId(method, i)))
    }

    options = this.parseOptions(options)
    options.namespace = this.parseNamespace(options)
    options.id = this.parseId(options)
    return this.operation(method, options)
  }

  parseOptions (options) {
    if (typeof options === 'string') {
      options = { name: options }
    }

    return options || {}
  }

  parseId (options) {
    const id = this.retrieveId(options)
    return names.parseId(id)
  }

  parseNamespace (options) {
    const id = this.retrieveId(options)

    if (id.startsWith('/')) {
      return names.parseNamespace(id)
    }

    return options.namespace
  }

  parseAnnotations (annotations) {
    return Object.keys(annotations).map(key => ({ key, value: annotations[key] }))
  }

  retrieveId (options) {
    options = options || {}
    const id = this.identifiers.find(name => options.hasOwnProperty(name))

    if (!id) throw new Error(`Missing resource identifier from parameters, supported parameter names: ${this.identifiers.join(', ')}`)

    return options[id]
  }

  payload (options) {
    if (!options.hasOwnProperty('params')) {
      return {}
    }

    if (typeof options.params === 'object') {
      return options.params
    }

    throw new Error('Invalid payload type, must be an object.')
  }
}

module.exports = Resources