From 17982def2c503d0646c6263f532f19c6676362a6 Mon Sep 17 00:00:00 2001
From: Artem Dvoretskii <adwski@users.noreply.github.com>
Date: Thu, 16 May 2024 00:14:28 +0300
Subject: [PATCH] rm unused video api http serviceside client

---
 internal/api/video/http/client/client.go | 109 -----------------------
 1 file changed, 109 deletions(-)
 delete mode 100644 internal/api/video/http/client/client.go

diff --git a/internal/api/video/http/client/client.go b/internal/api/video/http/client/client.go
deleted file mode 100644
index eaaa7ea..0000000
--- a/internal/api/video/http/client/client.go
+++ /dev/null
@@ -1,109 +0,0 @@
-package client
-
-import (
-	"context"
-	"fmt"
-	"strings"
-
-	common "github.com/adwski/vidi/internal/api/model"
-	httpmodel "github.com/adwski/vidi/internal/api/video/http"
-	"github.com/adwski/vidi/internal/api/video/model"
-	"github.com/go-resty/resty/v2"
-	"go.uber.org/zap"
-)
-
-const (
-	paramNameStatus = "status"
-)
-
-// Client is a Video API service-side client.
-// It is used as a component in media services.
-type Client struct {
-	c        *resty.Client
-	logger   *zap.Logger
-	token    string
-	endpoint string
-}
-
-type Config struct {
-	Logger   *zap.Logger
-	Endpoint string
-	Token    string
-}
-
-func New(cfg *Config) *Client {
-	c := &Client{
-		c:        resty.New(),
-		token:    cfg.Token,
-		logger:   cfg.Logger.With(zap.String("component", "video-api-client")),
-		endpoint: strings.TrimSuffix(cfg.Endpoint, "/"),
-	}
-	if len(c.token) == 0 {
-		c.logger.Warn("starting with empty token")
-	}
-	return c
-}
-
-func (c *Client) GetUploadedVideos(ctx context.Context) ([]*model.Video, error) {
-	var (
-		errResponse    common.Response
-		videosResponse = make([]*model.Video, 0)
-	)
-	resp, err := c.c.R().SetContext(ctx).
-		SetHeader("Accept", "application/json").
-		SetAuthToken(c.token).
-		SetError(&errResponse).
-		SetResult(&videosResponse).
-		SetBody(&httpmodel.ListRequest{
-			Status: model.StatusUploaded.String(),
-		}).
-		Post(fmt.Sprintf("%s/service/search", c.endpoint))
-	if err != nil {
-		return nil, c.handleError(resp, &errResponse, err)
-	}
-	return videosResponse, nil
-}
-
-func (c *Client) UpdateVideoStatus(videoID, param string) error {
-	return c.makeUpdateRequest(videoID, paramNameStatus, param)
-}
-
-func (c *Client) makeUpdateRequest(videoID, param, value string) error {
-	response, req := c.constructUpdateRequest()
-	resp, err := req.Put(fmt.Sprintf("%s/service/%s/%s/%s", c.endpoint, videoID, param, value))
-	return c.handleError(resp, response, err)
-}
-
-func (c *Client) UpdateVideo(videoID, status, location string) error {
-	response, req := c.constructUpdateRequest()
-	resp, err := req.
-		SetBody(&httpmodel.UpdateRequest{
-			Status:   status,
-			Location: location,
-		}).
-		Put(fmt.Sprintf("%s/service/%s", c.endpoint, videoID))
-	return c.handleError(resp, response, err)
-}
-
-func (c *Client) constructUpdateRequest() (*common.Response, *resty.Request) {
-	var response common.Response
-	return &response, c.c.R().
-		SetHeader("Content-Type", "application/json").
-		SetAuthToken(c.token).
-		SetError(&response).
-		SetResult(&response)
-}
-
-func (c *Client) handleError(resp *resty.Response, response *common.Response, err error) error {
-	if err != nil {
-		return fmt.Errorf("error while making video api request: %w", err)
-	}
-	if resp.IsError() {
-		c.logger.Error("api call returned error",
-			zap.String("status", resp.Status()),
-			zap.String("api-error", response.Error))
-		return fmt.Errorf("video api responded with error %s status", resp.Status())
-	}
-	c.logger.Debug("video api request ok")
-	return nil
-}