forked from GoogleCloudPlatform/professional-services
-
Notifications
You must be signed in to change notification settings - Fork 0
/
track_case.py
executable file
·86 lines (73 loc) · 2.89 KB
/
track_case.py
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
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
#!/usr/bin/env python3
# Copyright 2022 Google LLC
# Licensed 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.
import os
import slack
import logging
from get_parent import get_parent
from case_not_found import case_not_found
from get_firestore_tracked_cases import get_firestore_tracked_cases
from firestore_write import firestore_write
logger = logging.getLogger(__name__)
def track_case(channel_id, channel_name, case, user_id):
"""
Add a Google Cloud support case to the tracked_cases collection in Firestore. If the
case can't be found in the list of active support cases, notify the user.
Parameters
----------
channel_id : str
unique string used to idenify a Slack channel. Used to send messages to the channel
channel_name : str
designated channel name of the channel. For users to understand where their
cases are being tracked in Slack
case : str
unique id of the case
user_id : str
the Slack user_id of the user who submitted the request. Used to send ephemeral
messages to the user
"""
client = slack.WebClient(token=os.environ.get('SLACK_TOKEN'))
collection = 'tracked_cases'
parent = get_parent(case)
tracked_cases = get_firestore_tracked_cases()
if parent == 'Case not found':
case_not_found(channel_id, user_id, case)
else:
tracker = {
"channel_id": channel_id,
"case": case,
"channel_name": channel_name
}
exists = False
for tracked_case in tracked_cases:
tc = tracked_case
if tc['channel_id'] == channel_id and tc['case'] == case:
exists = True
break
if exists is False:
firestore_write(collection, tracker)
client.chat_postMessage(
channel=channel_id,
text=f"{channel_name} is now tracking case {case}")
else:
client.chat_postEphemeral(
channel=channel_id,
user=user_id,
text=f"Case {case} is already being tracked in {channel_name}")
if __name__ == "__main__":
channel_id = os.environ.get('TEST_CHANNEL_ID')
channel_name = os.environ.get('TEST_CHANNEL_NAME')
case = os.environ.get('TEST_CASE')
user_id = os.environ.get('TEST_USER_ID')
track_case(channel_id, channel_name, case, user_id)
track_case(channel_id, channel_name, case, user_id)