+ # get team id\r
+ if project_name is not None:\r
+ name = project_name\r
+ response_team = requests.request(\r
+ "GET", self.url + "/api/teams/search?name={}".format(name), headers=self.headers)\r
+ if len(json.loads(response_team.text)["teams"]) > 0:\r
+ team_id = json.loads(response_team.text)["teams"][0]["id"]\r
+ permission_data = {"items": [{"teamId": team_id, "permission": 2}, ]}\r
+ # provide permission to dashboard\r
+ response = requests.request(\r
+ "POST", self.url + "/api/folders/{}/permissions".format(project_name), json=permission_data,
+ headers=self.headers)\r
+ log.info("Dashboard %s is created in Grafana", name)
+ return response\r
+ except Exception:\r
+ log.exception("Exception processing message: ")\r
+\r
+ def delete_dashboard(self, uid):\r
+ response = requests.request("DELETE", self.url + "/api/dashboards/uid/" + uid, headers=self.headers)\r
+ log.debug("Dashboard %s deleted from Grafana", uid)
+ return response\r
+\r
+ def create_grafana_users(self, user):\r
+ email = "{}@osm.etsi.org".format(user)\r
+ user_payload = {\r
+ "name": user,\r
+ "email": email,\r
+ "login": user,\r
+ "password": user,\r
+ }\r
+ response_users = requests.request("POST", self.url + "/api/admin/users/", json=user_payload,\r
+ headers=self.headers)\r
+ json_data = json.loads(response_users.text)\r
+ url = "/api/org/users/{}/".format(json_data["id"])\r
+ permission_payload = {"role": "Editor", }\r
+ requests.request("PATCH", self.url + url, json=permission_payload, headers=self.headers)
+ log.info("New user %s created in Grafana", user)
+ return response_users\r
+\r
+ # create grafana team with member\r
+ def create_grafana_teams_members(self, project_name, user_name, is_admin, proj_list):\r
+ # check if user exist in grafana or not\r
+ user_response = requests.request("GET", self.url + "/api/users/lookup?loginOrEmail={}".format(user_name),\r
+ headers=self.headers)\r
+ user_obj = json.loads(user_response.text)\r
+ if user_response.status_code != 200:\r
+ user_response = self.create_grafana_users(user_name)\r
+ user_obj = json.loads(user_response.text)\r
+\r
+ user_id = user_obj["id"]\r
+\r
+ # Get Teams for user\r
+ team_objs = requests.request("GET", self.url + "/api/users/{}/teams".format(user_id), headers=self.headers)\r
+ team_obj = json.loads(team_objs.text)\r
+ team_list = []\r
+ if len(team_obj):\r
+ for team in team_obj:\r
+ team_list.append(team["name"])\r
+\r
+ proj_unlink = set(team_list) - set(proj_list)\r
+ for prj in proj_unlink:\r
+ response_team = requests.request("GET", self.url + "/api/teams/search?name={}".format(prj),\r
+ headers=self.headers)\r
+ team_id = json.loads(response_team.text)["teams"][0]["id"]\r
+ requests.request("DELETE", self.url + "/api/teams/{}/members/{}".format(team_id, user_id),\r
+ headers=self.headers)\r
+ # add member to team\r
+ response_team = requests.request("GET", self.url + "/api/teams/search?name={}".format(project_name),\r
+ headers=self.headers)\r
+ team_id = json.loads(response_team.text)["teams"][0]["id"]\r
+ if project_name not in team_list:\r
+ member_payload = {\r
+ "userId": user_id\r
+ }\r
+ requests.request("POST", self.url + "/api/teams/{}/members".format(team_id), json=member_payload,\r
+ headers=self.headers)\r
+ # if role is admin change permission to admin\r
+ if is_admin:\r
+ url = "/api/org/users/{}/".format(user_id)\r
+ permission_payload = {"role": "Admin", }\r
+ requests.request("PATCH", self.url + url, json=permission_payload, headers=self.headers)\r
+ log.info("User %s is assigned Admin permission", user_name)
+ else:
+ url = "/api/org/users/{}/".format(user_id)
+ permission_payload = {"role": "Editor", }
+ requests.request("PATCH", self.url + url, json=permission_payload, headers=self.headers)
+ log.info("User %s is assigned Editor permission", user_name)
+ return response_team\r
+\r
+ # create grafana team\r
+ def create_grafana_teams(self, team_name):\r
+ team_payload = {"name": team_name, }\r
+ requests.request("POST", self.url + "/api/teams", json=team_payload, headers=self.headers)
+ log.info("New team %s created in Grafana", team_name)