artmigrator/repository/nexus/nexus.go

package nexus

import (
    "fmt"
    "io/ioutil"
    "log"
    "net/http"
    "strings"
)

type Client struct {
    BaseURL    string
    HTTPClient *http.Client
    Username   string
    Password   string
}

func NewClient(baseURL, username, password string) *Client {
    return &Client{
        BaseURL:    baseURL,
        HTTPClient: &http.Client{},
        Username:   username,
        Password:   password,
    }
}

func (c *Client) GetArtifacts(repository string) ([]string, error) {
    log.Printf("Получение артефактов из репозитория Nexus")
    url := fmt.Sprintf("%s/repository/%s/", c.BaseURL, repository)
    req, err := http.NewRequest("GET", url, nil)
    if err != nil {
        return nil, err
    }
    req.SetBasicAuth(c.Username, c.Password)

    resp, err := c.HTTPClient.Do(req)
    if err != nil {
        return nil, err
    }
    defer resp.Body.Close()

    body, err := ioutil.ReadAll(resp.Body)
    if err != nil {
        return nil, err
    }

    log.Printf("Артефакты получены из репозитория Nexus")
    artifacts := strings.Split(string(body), "\n")
    var result []string
    for _, artifact := range artifacts {
        if strings.Contains(artifact, ".jar") || strings.Contains(artifact, ".pom") {
            result = append(result, artifact)
        }
    }
    return result, nil
}

func (c *Client) GetArtifactData(repository, artifact string) ([]byte, error) {
    log.Printf("Загрузка артефакта %s из репозитория Nexus", artifact)
    url := fmt.Sprintf("%s/repository/%s/%s", c.BaseURL, repository, artifact)
    req, err := http.NewRequest("GET", url, nil)
    if err != nil {
        return nil, err
    }
    req.SetBasicAuth(c.Username, c.Password)

    resp, err := c.HTTPClient.Do(req)
    if err != nil {
        return nil, err
    }
    defer resp.Body.Close()

    body, err := ioutil.ReadAll(resp.Body)
    if err != nil {
        return nil, err
    }

    log.Printf("Артефакт %s загружен из репозитория Nexus", artifact)
    return body, nil
}

func (c *Client) ArtifactExists(artifact string) (bool, error) {
    log.Printf("Проверка наличия артефакта %s в репозитории Nexus", artifact)
    url := fmt.Sprintf("%s/repository/%s/%s", c.BaseURL, "your-repository-name", artifact)
    req, err := http.NewRequest("GET", url, nil)
    if err != nil {
        return false, err
    }
    req.SetBasicAuth(c.Username, c.Password)

    resp, err := c.HTTPClient.Do(req)
    if err != nil {
        return false, err
    }
    defer resp.Body.Close()

    if resp.StatusCode == http.StatusNotFound {
        log.Printf("Артефакт %s не существует в репозитории Nexus", artifact)
        return false, nil
    }

    log.Printf("Артефакт %s существует в репозитории Nexus", artifact)
    return true, nil
}