wip

Author: ykoer

.github/actions/log_to_splunk/main.py

@@ -44,53 +44,53 @@ def main():
     print(f"summary_url: {summary_url}")
     print("######################")
 
-    # try:
-    #     x = requests.get(summary_url, stream=True, auth=('token',GITHUB_TOKEN))
-    #     x.raise_for_status()
-    # except requests.exceptions.HTTPError as errh:
-    #     output = "GITHUB API Http Error:" + str(errh)
-    #     print(f"Error: {output}")
-    #     print(f"::set-output name=result::{output}")
-    #     return x.status_code
-    # except requests.exceptions.ConnectionError as errc:
-    #     output = "GITHUB API Error Connecting:" + str(errc)
-    #     print(f"Error: {output}")
-    #     print(f"::set-output name=result::{output}")
-    #     return x.status_code
-    # except requests.exceptions.Timeout as errt:
-    #     output = "Timeout Error:" + str(errt)
-    #     print(f"Error: {output}")
-    #     print(f"::set-output name=result::{output}")
-    #     return x.status_code
-    # except requests.exceptions.RequestException as err:
-    #     output = "GITHUB API Non catched error conecting:" + str(err)
-    #     print(f"Error: {output}")
-    #     print(f"::set-output name=result::{output}")
-    #     return x.status_code
-    # except Exception as e:
-    #     print("Internal error", e)
-    #     return x.status_code
-
-    # summary = x.json()
-
-    # summary.pop('repository')
-
-    # summary["repository"]=summary["head_repository"]["name"]
-    # summary["repository_full"]=summary["head_repository"]["full_name"]
-
-    # summary.pop('head_repository')
-
-    # utc_time = datetime.strptime(summary["updated_at"], "%Y-%m-%dT%H:%M:%SZ")
-    # epoch_time = (utc_time - datetime(1970, 1, 1)).total_seconds()
-
-    # event={'event':json.dumps(summary),'sourcetype':SPLUNK_SOURCETYPE,'source':'workflow_summary','host':host,'time':epoch_time}
-    # event=json.dumps(event)
-
-    # x=requests.post(SPLUNK_HEC_URL, data=event, headers=headers)
-
-
-    # url = "{url}/repos/{repo}/actions/runs/{run_id}/logs".format(url=GITHUB_API_URL,repo=GITHUB_REPOSITORY,run_id=GITHUB_WORKFLOWID)
-    # print(url)
+    try:
+        x = requests.get(summary_url, stream=True, auth=('token',GITHUB_TOKEN))
+        x.raise_for_status()
+    except requests.exceptions.HTTPError as errh:
+        output = "GITHUB API Http Error:" + str(errh)
+        print(f"Error: {output}")
+        print(f"::set-output name=result::{output}")
+        return x.status_code
+    except requests.exceptions.ConnectionError as errc:
+        output = "GITHUB API Error Connecting:" + str(errc)
+        print(f"Error: {output}")
+        print(f"::set-output name=result::{output}")
+        return x.status_code
+    except requests.exceptions.Timeout as errt:
+        output = "Timeout Error:" + str(errt)
+        print(f"Error: {output}")
+        print(f"::set-output name=result::{output}")
+        return x.status_code
+    except requests.exceptions.RequestException as err:
+        output = "GITHUB API Non catched error conecting:" + str(err)
+        print(f"Error: {output}")
+        print(f"::set-output name=result::{output}")
+        return x.status_code
+    except Exception as e:
+        print("Internal error", e)
+        return x.status_code
+
+    summary = x.json()
+
+    summary.pop('repository')
+
+    summary["repository"]=summary["head_repository"]["name"]
+    summary["repository_full"]=summary["head_repository"]["full_name"]
+
+    summary.pop('head_repository')
+
+    utc_time = datetime.strptime(summary["updated_at"], "%Y-%m-%dT%H:%M:%SZ")
+    epoch_time = (utc_time - datetime(1970, 1, 1)).total_seconds()
+
+    event={'event':json.dumps(summary),'sourcetype':SPLUNK_SOURCETYPE,'source':'workflow_summary','host':host,'time':epoch_time}
+    event=json.dumps(event)
+
+    x=requests.post(SPLUNK_HEC_URL, data=event, headers=headers)
+
+
+    url = "{url}/repos/{repo}/actions/runs/{run_id}/logs".format(url=GITHUB_API_URL,repo=GITHUB_REPOSITORY,run_id=GITHUB_WORKFLOWID)
+    print(url)
 
     # try:
     #     x = requests.get(url, stream=True, auth=('token',GITHUB_TOKEN))