summaryrefslogtreecommitdiff
path: root/lib/chef_zero/endpoints/data_bag_endpoint.rb
blob: f7a6142245c5d7ffc0a55d688de1802887dfc735 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
require 'ffi_yajl'
require 'chef_zero/endpoints/rest_list_endpoint'
require 'chef_zero/endpoints/data_bag_item_endpoint'
require 'chef_zero/rest_error_response'

module ChefZero
  module Endpoints
    # /data/NAME
    class DataBagEndpoint < RestListEndpoint
      def initialize(server)
        super(server, 'id')
      end

      def post(request)
        json = FFI_Yajl::Parser.parse(request.body, :create_additions => false)
        key = identity_keys.map { |k| json[k] }.select { |v| v }.first
        response = super(request)
        if response[0] == 201
          already_json_response(201, DataBagItemEndpoint::populate_defaults(request, request.body, request.rest_path[3], key))
        else
          response
        end
      end

      def get_key(contents)
        data_bag_item = FFI_Yajl::Parser.parse(contents, :create_additions => false)
        if data_bag_item['json_class'] == 'Chef::DataBagItem' && data_bag_item['raw_data']
          data_bag_item['raw_data']['id']
        else
          data_bag_item['id']
        end
      end

      def delete(request)
        key = request.rest_path[3]
        delete_data_dir(request, request.rest_path, :recursive)
        json_response(200, {
          'chef_type' => 'data_bag',
          'json_class' => 'Chef::DataBag',
          'name' => key
        })
      end
    end
  end
end