From 8132b67d6cbe985b3a6cea11cc148485f652526d Mon Sep 17 00:00:00 2001
From: Allan Nava <allannava95@gmail.com>
Date: Thu, 6 Jun 2024 11:54:49 +0200
Subject: [PATCH] solve RestreamerHlsStop

---
 compress/api_restreamer.go | 46 +++++++++++++++++++++++++++++++++++++-
 compress/api_upload.go     |  4 ----
 compress/compress.go       |  5 +++--
 3 files changed, 48 insertions(+), 7 deletions(-)

diff --git a/compress/api_restreamer.go b/compress/api_restreamer.go
index 28e205a..e129008 100644
--- a/compress/api_restreamer.go
+++ b/compress/api_restreamer.go
@@ -123,13 +123,57 @@ func (o *compress) CreateEventsBulk(request []InstancesEventCreate) (*ResponseSe
 	return &obj, nil
 }
 
-func (o *compress) RestreamerHlsStart(request hlsBodyRequest) (*HlsResponse, error){
+func (o *compress) RestreamerHlsStart(instanceName string, streamProtocol string) (*HlsResponse, error){
+	
+	requestBody := &hlsBodyRequest{
+		BaseModel:    BaseModel{ClientId: o.GetCliendId(), ApiKey: o.apiKey},
+		InstanceName: instanceName,
+		StreamProtocol: streamProtocol,
+	}
+	if errs := validator.Validate(requestBody); errs != nil {
+		// values not valid, deal with errors here
+		return nil, errs
+	}
+	resp, err := o.restyPost(RESTREAMER_HLS_START(), requestBody)
+	if err != nil {
+		return nil, err
+	}
+	o.debugPrint(resp)
+	if resp.IsError() {
+		return nil, fmt.Errorf("")
+	}
+	var obj HlsResponse
+	if err := json.Unmarshal(resp.Body(), &obj); err != nil {
+		return nil, err
+	}
 	return nil, nil
 }
 
 
 
 func (o *compress)  RestreamerHlsStop(request hlsBodyRequest) (*HlsResponse, error){
+	requestBody := &hlsBodyRequest{
+		BaseModel:    BaseModel{ClientId: o.GetCliendId(), ApiKey: o.apiKey},
+		InstanceName: instanceName,
+		StreamProtocol: streamProtocol,
+	}
+	if errs := validator.Validate(requestBody); errs != nil {
+		// values not valid, deal with errors here
+		return nil, errs
+	}
+	resp, err := o.restyPost(RESTREAMER_HLS_STOP(), requestBody)
+	if err != nil {
+		return nil, err
+	}
+
+	o.debugPrint(resp)
+	if resp.IsError() {
+		return nil, fmt.Errorf("")
+	}
+	var obj HlsResponse
+	if err := json.Unmarshal(resp.Body(), &obj); err != nil {
+		return nil, err
+	}
 	return nil, nil
 }
 
diff --git a/compress/api_upload.go b/compress/api_upload.go
index 990820b..52b537f 100644
--- a/compress/api_upload.go
+++ b/compress/api_upload.go
@@ -249,7 +249,3 @@ func (o *compress) UploadMultipart(reader io.Reader, size int64, categoryId int,
 
 	return responseCreateUploadAndEncode, nil
 }
-
-func (o *compress) GetCustomerS3Zone() (*CustomerS3, error){
-	return nil, nil
-}
\ No newline at end of file
diff --git a/compress/compress.go b/compress/compress.go
index 466f521..a4c4efd 100644
--- a/compress/compress.go
+++ b/compress/compress.go
@@ -25,8 +25,9 @@ type ICompress interface {
 	GetSingleRestreamer(instanceName string) (*Restreamer, error)
 	ScaleRestreamer(instanceName string, scale int) (*ResponseServer, error)
 	CreateEventsBulk(request []InstancesEventCreate) (*ResponseServer, error)
-	RestreamerHlsStart(request hlsBodyRequest) (*HlsResponse, error)
-	RestreamerHlsStop(request hlsBodyRequest) (*HlsResponse, error)
+	RestreamerHlsStart(instanceName string, streamProtocol string) (*HlsResponse, error)
+	RestreamerHlsStop(requinstanceName string, streamProtocol string) (*HlsResponse, error)
+	RestreamerEventsHistory( startFrom int, amount int)  ([]RestreamerEvent, error)
 	GetCustomerS3Zone() (*CustomerS3, error)
 	GenerateVodProxy(request generateVodRequest) (*generateVodResponse,  error)
 	//