import json
import os
import sys
import subprocess
import shlex

url = "https://slack.com/api/conversations.history"

slack_token = sys.argv[1]
slack_channel = sys.argv[2]
minutes_ago = sys.argv[3]

curl_cmd = ("/etc/zabbix/zabbix_agentd.d/sme_slack.sh " + slack_token + " " + slack_channel + " " + minutes_ago)
subprocess_curl = shlex.split(curl_cmd)
subprocess.run(subprocess_curl)

with open('/tmp/slack.json') as f:
  data = json.load(f)

messages_count = len(data['messages'])

trigger = 0
count = 0

while count < messages_count:

    f_count = 0

    try:
        fields = len(data['messages'][count]['attachments'][0]['fields'])

        while f_count < fields:

            if data['messages'][count]['attachments'][0]['fields'][f_count]['title'] == "JobFailed":
#                print(data['messages'][count]['attachments'][0]['fields'][f_count]['value'])
                if data['messages'][count]['attachments'][0]['fields'][f_count]['value'] == "true":
                    trigger = 1

            f_count += 1

        count += 1

    except KeyError:
        count += 1

print(trigger)