summaryrefslogtreecommitdiff
path: root/lib/chef_zero/endpoints/policy_revision_endpoint.rb
blob: ee2c6df63262b7ae9f9319f33d4f73e381af011e (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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
require_relative "../chef_data/data_normalizer"

module ChefZero
  module Endpoints
    # /organizations/ORG/policies/NAME/revisions/REVISION
    class PolicyRevisionEndpoint < RestBase
      # GET /organizations/ORG/policies/NAME/revisions/REVISION
      def get(request)
        data = parse_json(get_data(request))
        
        # need to add another field in the response called 'policy_group_list'
        # example response
        #     {
        #       "revision_id": "909c26701e291510eacdc6c06d626b9fa5350d25",
        #       "name": "some_policy_name",
        #       "run_list": [
        #         "recipe[policyfile_demo::default]"
        #       ],
        #       "cookbook_locks": {
        #         "policyfile_demo": {
        #           "identifier": "f04cc40faf628253fe7d9566d66a1733fb1afbe9",
        #           "version": "1.2.3"
        #         }
        #       },
        #       "policy_group_list": ["some_policy_group"]
        #     }
        data[:policy_group_list] = Array.new

        # extracting policy name and revision
        request_policy_name = request.rest_path[3]
        request_policy_revision = request.rest_path[5]

        # updating the request to fetch the policy group list
        request.rest_path[2] = "policy_groups"
        request.rest_path = request.rest_path.slice(0,3)

        list_data(request).each do |group_name|
          group_path = request.rest_path + [group_name]

          # fetching all the policies associated with each group
          policy_list = list_data(request, group_path + ["policies"])
          policy_list.each do |policy_name|
            revision_id = parse_json(get_data(request, group_path + ["policies", policy_name]))

            # if the name and revision matchs, we add the group to the response
            if (policy_name == request_policy_name) && (revision_id == request_policy_revision)
              policy_group_list = data[:policy_group_list]
              data[:policy_group_list] = [group_name] + policy_group_list
            end
          end
        end
        
        data = ChefData::DataNormalizer.normalize_policy(data, request_policy_name, request_policy_revision)
        json_response(200, data)
      end

      # DELETE /organizations/ORG/policies/NAME/revisions/REVISION
      def delete(request)
        policyfile_data = parse_json(get_data(request))
        policyfile_data = ChefData::DataNormalizer.normalize_policy(policyfile_data, request.rest_path[3], request.rest_path[5])
        delete_data(request)
        json_response(200, policyfile_data)
      end
    end
  end
end