added azure related code
[it/otf.git] / otf-frontend / server / src / feathers / app.hooks.js
1 /*  Copyright (c) 2019 AT&T Intellectual Property.                             #\r
2 #                                                                              #\r
3 #   Licensed under the Apache License, Version 2.0 (the "License");            #\r
4 #   you may not use this file except in compliance with the License.           #\r
5 #   You may obtain a copy of the License at                                    #\r
6 #                                                                              #\r
7 #       http://www.apache.org/licenses/LICENSE-2.0                             #\r
8 #                                                                              #\r
9 #   Unless required by applicable law or agreed to in writing, software        #\r
10 #   distributed under the License is distributed on an "AS IS" BASIS,          #\r
11 #   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.   #\r
12 #   See the License for the specific language governing permissions and        #\r
13 #   limitations under the License.                                             #\r
14 ##############################################################################*/\r
15 \r
16 \r
17 // Application hooks that run for every service\r
18 const log = require('./hooks/log');\r
19 const paginateOption = require('./hooks/paginate-option');\r
20 const createdBy = require('./hooks/createdBy');\r
21 const updatedBy = require('./hooks/updatedBy');\r
22 const {iff, disallow, isProvider, skipRemainingHooks} = require('feathers-hooks-common');\r
23 const { ObjectID } = require('mongodb');\r
24 const shardKey = require('./hooks/insertShardKey.js');\r
25 \r
26 module.exports = {\r
27         before: {\r
28                 all: [shardKey(), paginateOption(), skipRemainingHooks(context => !context.params.provider)],\r
29                 find: [\r
30                         function(context){\r
31                                 const {query} = context.params;\r
32 \r
33                                 iterate(query, '');\r
34 \r
35                                 return context;\r
36                         }\r
37                 ],\r
38                 get: [],\r
39                 create: [createdBy()],\r
40                 update: [updatedBy()],\r
41                 patch: [updatedBy()],\r
42                 remove: []\r
43         },\r
44 \r
45         after: {\r
46                 all: [],\r
47                 find: [],\r
48                 get: [],\r
49                 create: [],\r
50                 update: [],\r
51                 patch: [],\r
52                 remove: []\r
53         },\r
54 \r
55         error: {\r
56                 all: [log()],\r
57                 find: [],\r
58                 get: [],\r
59                 create: [],\r
60                 update: [],\r
61                 patch: [],\r
62                 remove: []\r
63         }\r
64 };\r
65 \r
66 function iterate(obj, stack) {\r
67         for (var property in obj) {\r
68                 if (obj.hasOwnProperty(property)) {\r
69                         if (typeof obj[property] == "object") {\r
70 \r
71                                 //check for $in\r
72                                 if(/\._id$/.test(property) && obj[property]['$in'] && obj[property]['$in'].length && obj[property]['$in'].length > 0){\r
73                                         obj[property]['$in'].forEach((elem, val) => {\r
74                                                 obj[property]['$in'][val] = new ObjectID(elem);\r
75                                         })\r
76                                 }else{\r
77                                         iterate(obj[property], stack + '.' + property);\r
78                                 }\r
79                         } else if(/\._id$/.test(property)){\r
80                                 obj[property] = new ObjectID(obj[property]);\r
81                         }\r
82                 }\r
83         }\r
84 }\r