added cusomer s3

compress/api_customer.go

@@ -26,3 +26,27 @@ func (o *compress) GetCredentials() (*Credential, error) {
 	//
 	return &obj.Data, nil
 }
+
+
+/**
+* Need to call before upload s3
+* 
+* @returns customer_s3
+*/
+func (o *compress) GetCustomerS3Zone() (*CustomerS3, error) {
+	resp, err := o.restyPost(GET_ZONE, BaseModel{ClientId: o.GetCliendId(), ApiKey: o.apiKey})
+	if err != nil {
+		return nil, err
+	}
+	o.debugPrint(resp)
+	var obj CustomerS3
+	if err := json.Unmarshal(resp.Body(), &obj); err != nil {
+		return nil, err
+	}
+	if obj.Response == "KO" {
+		return nil, fmt.Errorf("Error %s", obj.Message)
+	}
+	o.debugPrint(obj)
+	//
+	return &obj.Data, nil
+}

compress/compress.go

@@ -27,6 +27,7 @@ type ICompress interface {
 	CreateEventsBulk(request []InstancesEventCreate) (*ResponseServer, error)
 	RestreamerHlsStart(request hlsBodyRequest) (*HlsResponse, error)
 	RestreamerHlsStop(request hlsBodyRequest) (*HlsResponse, error)
+	GetCustomerS3Zone() (*CustomerS3, error)
 	//
 }
 

compress/constants.go

@@ -7,6 +7,7 @@ const (
 	UPLOADS        	= "/external/upload"
 	CREDENTIALS    	= "/external/credentials/"
 	EVENTS 			= "/external/events"
+	CUSTOMERS 		= "/external/customers"
 )
 
 var (
@@ -68,5 +69,8 @@ var (
 	PRESIGNED_URL_S3 = func() string {
 		return TNGRM_BASE_URL + UPLOADS + "/presignedUrl"
 	}
+	GET_ZONE = func() string {
+		return TNGRM_BASE_URL + CUSTOMERS + "/s3"
+	}
 	//
 )

compress/model_customer.go

@@ -39,3 +39,27 @@ type ResponseServerCredential struct {
 	Response string     `json:"response"`
 	Data     Credential `json:"data"`
 }
+
+
+type CustomerS3 struct {
+	ID                     int        `json:"id" `
+	CustomerID             int        `json:"customer_id" gorm:"column:customer_id"`
+	S3Name                 string     `json:"s3_name" `
+	Host                   string     `json:"host" `
+	Bucket                 string     `json:"bucket" `
+	AccessKey              string     `json:"access_key" `
+	SecretKey              string     `json:"secret_key" `
+	IsActive               int        `json:"is_active" `
+	UpdateEnabled          int        `json:"update_enabled" `
+	CreatedAt              *time.Time `json:"created_at" gorm:"type:timestamp;"`
+	UpdatedAt              *time.Time `json:"updated_at" gorm:"type:timestamp;"`
+	DeletedAt              *time.Time `json:"deleted_at" gorm:"type:timestamp;"`
+	LiveNFSMount           string     `json:"live_nfs_mount"`
+	VodNFSMount            string     `json:"vod_nfs_mount"`
+	VodCDNBaseURL          string     `json:"vod_cdn_base_url"`
+	LiveCDNBaseURL         string     `json:"live_cdn_base_url"`
+	LiveUnprotectedBaseURL string     `json:"live_unprotected_base_url"`
+	VodUnprotectedBaseURL  string     `json:"vod_unprotected_base_url"`
+	Zone                   string     `json:"zone"`
+	BucketUpload           string     `json:"bucket_upload"`
+}