forked from RedHatInsights/edge-api
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request RedHatInsights#2570 from lzap/pulp-client
feat: add pulp client
- Loading branch information
Showing
26 changed files
with
76,793 additions
and
8 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,113 @@ | ||
| package main | ||
|
|
||
| import ( | ||
| "context" | ||
| "fmt" | ||
| "math/rand" | ||
| "os" | ||
| "time" | ||
|
|
||
| "github.com/google/uuid" | ||
| "github.com/redhatinsights/edge-api/config" | ||
| "github.com/redhatinsights/edge-api/logger" | ||
| "github.com/redhatinsights/edge-api/pkg/clients/pulp" | ||
| "github.com/sirupsen/logrus" | ||
| ) | ||
|
|
||
| func domainList(ctx context.Context, c *pulp.PulpService) { | ||
| domains, err := c.DomainsList(ctx, "") | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
|
|
||
| for _, d := range domains { | ||
| fmt.Println(d.Name, *d.PulpHref) | ||
| } | ||
| } | ||
|
|
||
| // nolint: gosec | ||
| var rnd = rand.New(rand.NewSource(time.Now().UnixNano())) | ||
|
|
||
| func fixtureCreate(ctx context.Context, c *pulp.PulpService, orgID, tarFilename string) { | ||
| resourceName := fmt.Sprintf("test-%d", rnd.Int()) | ||
|
|
||
| artifact, err := c.ArtifactsCreatePipe(ctx, tarFilename) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
| fmt.Println("Artifact uploaded", *artifact.PulpHref) | ||
| fmt.Println("--------------------------------") | ||
|
|
||
| repo, err := c.RepositoriesCreate(ctx, resourceName) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
| fmt.Println("Repository created", *repo.PulpHref) | ||
| fmt.Println("--------------------------------") | ||
|
|
||
| hcg, err := c.HeaderGuardReadOrCreate(ctx, pulp.JQOrgID, orgID) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
| fmt.Println("Header guard found or created", *hcg.PulpHref) | ||
| fmt.Println("--------------------------------") | ||
|
|
||
| dist, err := c.DistributionsCreate(ctx, resourceName, resourceName, *repo.PulpHref, *hcg.PulpHref) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
| fmt.Println("Distribution created", *dist.PulpHref) | ||
| fmt.Println("--------------------------------") | ||
|
|
||
| repoImported, err := c.RepositoriesImport(ctx, pulp.ScanUUID(*repo.PulpHref), "repo", *artifact.PulpHref) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
| fmt.Println("Repository imported", *repoImported.PulpHref) | ||
| fmt.Println("--------------------------------") | ||
|
|
||
| fmt.Printf("curl -L --proxy http://squid.xxxx.redhat.com:3128 --cert /etc/pki/consumer/cert.pem --key /etc/pki/consumer/key.pem https://cert.console.stage.redhat.com/api/pulp-content/%s/%s/\n", c.Domain(), resourceName) | ||
| fmt.Println("--------------------------------") | ||
| } | ||
|
|
||
| func main() { | ||
| ctx := context.Background() | ||
| config.Init() | ||
| logger.InitLogger(os.Stdout) | ||
| logrus.SetLevel(logrus.TraceLevel) | ||
|
|
||
| // when changing the domain, please delete all artifacts, repos, distros via CLI and then delete the domain | ||
| domainName := "edge-integration-test-2" | ||
| domainHref := uuid.MustParse("0190360e-c33e-73d3-a666-591cd2730da9") | ||
|
|
||
| c, err := pulp.NewPulpServiceDefaultDomain(ctx) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
|
|
||
| _, err = c.DomainsRead(ctx, domainName, domainHref) | ||
| if err != nil { | ||
| createdDomain, err := c.DomainsCreate(ctx, domainName) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
| fmt.Println("Created domain:", pulp.ScanUUID(*createdDomain.PulpHref), ", please update the domainHref in the test source!") | ||
| return | ||
| } | ||
|
|
||
| c, err = pulp.NewPulpServiceWithDomain(ctx, domainName) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
|
|
||
| // nolint: gocritic | ||
| if len(os.Args) > 1 && os.Args[1] == "domain_list" { | ||
| domainList(ctx, c) | ||
| } else if len(os.Args) > 3 && os.Args[1] == "fixture_create" { | ||
| fixtureCreate(ctx, c, os.Args[2], os.Args[3]) | ||
| } else { | ||
| fmt.Println("Usage:") | ||
| fmt.Println("cli domain_list: list all domains") | ||
| fmt.Println("cli fixture_create org_id tar_file: create a fixture test repo") | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,7 @@ | ||
| ostree --repo=repo init --mode archive | ||
| mkdir tree | ||
| echo "Hello world!" > tree/hello.txt | ||
| ostree --repo=repo commit --branch=foo tree/ | ||
| tar cvf small_commit1.tar repo/ | ||
| echo "Hello again!" > tree/hello2.txt | ||
| ostree --repo=repo commit --branch=foo tree/ |
Binary file not shown.
Binary file not shown.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.