From bd9f15fc9cf86b9069f8e740472135bcf537978a Mon Sep 17 00:00:00 2001
From: Allan Nava <allannava95@gmail.com>
Date: Mon, 3 Jun 2024 09:54:14 +0200
Subject: [PATCH] added new endpoints

---
 src/compress/compress.py | 141 +++++++++++++++++++++++++++++++++++++++
 1 file changed, 141 insertions(+)

diff --git a/src/compress/compress.py b/src/compress/compress.py
index ca2ee84..f20f404 100644
--- a/src/compress/compress.py
+++ b/src/compress/compress.py
@@ -242,4 +242,145 @@ def scale_restreamer(self, restreamer_name : str, scale_value: int):
             })
         )
     #
+    # /**
+    # * hls start
+    # * 
+	# ApiKey   string `json:"api_key" `
+	# ClientId string `json:"client_id" `
+	# InstanceName   string `json:"instance_name" `
+	# StreamProtocol string `json:"stream_protocol" `
+    # * @returns 
+    # */
+    def hls_start(self, restreamer_name : str, stream_protocol: str ): 
+        return self.req.post(TNGRM_BASE_URL + RESTREAMER_HLS_START, 
+            headers={
+                "Content-Type": "application/json",
+            },
+            body = json.dumps({
+                "api_key": self.api_key,
+                "client_id": self.client_id,
+                "instance_name": restreamer_name,
+                "stream_protocol": stream_protocol
+            })
+        )
+    #
+    # /**
+    # * hls stop
+    # * 
+	# ApiKey   string `json:"api_key" `
+	# ClientId string `json:"client_id" `
+	# InstanceName   string `json:"instance_name" `
+	# StreamProtocol string `json:"stream_protocol" `
+    # * @returns 
+    # */
+    def hls_stop(self, restreamer_name : str, stream_protocol: str ): 
+        return self.req.post(TNGRM_BASE_URL + RESTREAMER_HLS_STOP, 
+            headers={
+                "Content-Type": "application/json",
+            },
+            body = json.dumps({
+                "api_key": self.api_key,
+                "client_id": self.client_id,
+                "instance_name": restreamer_name,
+                "stream_protocol": stream_protocol
+            })
+        )
+    #
+    #
+    # /** TODO:
+    # * restreamer push start
+    # * 
+	# ApiKey   string `json:"api_key" `
+	# ClientId string `json:"client_id" `
+	# InstanceName   string `json:"instance_name" `
+	# ExternalServers []struct {
+	#	ExternalServer string `json:"external_server" `
+	#	IngestProtocol string `json:"ingest_protocol" `
+	#	AudioChannel   string `json:"audio_channel" `
+	#} `json:"external_servers"`
+    # * @returns 
+    # */
+    def push_start(self, restreamer_name : str, external_servers: object ): 
+        return self.req.post(TNGRM_BASE_URL + RESTREAMER_PUSH_START, 
+            headers={
+                "Content-Type": "application/json",
+            },
+            body = json.dumps({
+                "api_key": self.api_key,
+                "client_id": self.client_id,
+                "instance_name": restreamer_name,
+            })
+        )
+    #
+    # /** TODO:
+    # * restreamer push stop
+    # * 
+	# ApiKey   string `json:"api_key" `
+	# ClientId string `json:"client_id" `
+	# InstanceName   string `json:"instance_name" `
+	# ExternalServers []struct {
+	#	ExternalServer string `json:"external_server" `
+	#	IngestProtocol string `json:"ingest_protocol" `
+	#	AudioChannel   string `json:"audio_channel" `
+	#} `json:"external_servers"`
+    # * @returns 
+    # */
+    def push_stop(self, restreamer_name : str, external_servers: object ): 
+        return self.req.post(TNGRM_BASE_URL + RESTREAMER_PUSH_STOP, 
+            headers={
+                "Content-Type": "application/json",
+            },
+            body = json.dumps({
+                "api_key": self.api_key,
+                "client_id": self.client_id,
+                "instance_name": restreamer_name,
+            })
+        )
+    #
+    # /** TODO:
+    # * RESTREAMER_PULL_START push stop
+    # * 
+	# ApiKey   string `json:"api_key" `
+	# ClientId string `json:"client_id" `
+	# InstanceName   string `json:"instance_name" `
+	# ExternalServers []struct {
+	#	ProcessID string `json:"process_id" `
+	#} `json:"external_servers"`
+    # * @returns 
+    # */
+    def pull_start(self, restreamer_name : str, external_servers: object ): 
+        return self.req.post(TNGRM_BASE_URL + RESTREAMER_PULL_START, 
+            headers={
+                "Content-Type": "application/json",
+            },
+            body = json.dumps({
+                "api_key": self.api_key,
+                "client_id": self.client_id,
+                "instance_name": restreamer_name,
+            })
+        )
+    #
+    # /** TODO:
+    # * RESTREAMER_PULL_START push stop
+    # * 
+	# ApiKey   string `json:"api_key" `
+	# ClientId string `json:"client_id" `
+	# InstanceName   string `json:"instance_name" `
+	# ExternalServers []struct {
+	#	ProcessID string `json:"process_id" `
+	#} `json:"external_servers"`
+    # * @returns 
+    # */
+    def pull_start(self, restreamer_name : str, external_servers: object ): 
+        return self.req.post(TNGRM_BASE_URL + RESTREAMER_PULL_STOP, 
+            headers={
+                "Content-Type": "application/json",
+            },
+            body = json.dumps({
+                "api_key": self.api_key,
+                "client_id": self.client_id,
+                "instance_name": restreamer_name,
+            })
+        )
+    #
 #
\ No newline at end of file