File uyuni-tools-v0.0.1.6.obscpio of Package uyuni-tools

Overview Repositories Revisions Requests Users Attributes Meta

File uyuni-tools-v0.0.1.6.obscpio of Package uyuni-tools (Revision 1bd7bed6d4e0185e1bdd17966c1c18fd)

Currently displaying revision 1bd7bed6d4e0185e1bdd17966c1c18fd , Show latest

07070100000000000081A400000000000000000000000164D6588100000004000000000000000000000000000000000000002000000000uyuni-tools-v0.0.1.6/.gitignorebin
07070100000001000081A400000000000000000000000164D6588100002C5D000000000000000000000000000000000000001D00000000uyuni-tools-v0.0.1.6/LICENSE                                 Apache License
                           Version 2.0, January 2004
                        http://www.apache.org/licenses/

TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION

1. Definitions.

"License" shall mean the terms and conditions for use, reproduction,
      and distribution as defined by Sections 1 through 9 of this document.

"Licensor" shall mean the copyright owner or entity authorized by
      the copyright owner that is granting the License.

"Legal Entity" shall mean the union of the acting entity and all
      other entities that control, are controlled by, or are under common
      control with that entity. For the purposes of this definition,
      "control" means (i) the power, direct or indirect, to cause the
      direction or management of such entity, whether by contract or
      otherwise, or (ii) ownership of fifty percent (50%) or more of the
      outstanding shares, or (iii) beneficial ownership of such entity.

"You" (or "Your") shall mean an individual or Legal Entity
      exercising permissions granted by this License.

"Source" form shall mean the preferred form for making modifications,
      including but not limited to software source code, documentation
      source, and configuration files.

"Object" form shall mean any form resulting from mechanical
      transformation or translation of a Source form, including but
      not limited to compiled object code, generated documentation,
      and conversions to other media types.

"Work" shall mean the work of authorship, whether in Source or
      Object form, made available under the License, as indicated by a
      copyright notice that is included in or attached to the work
      (an example is provided in the Appendix below).

"Derivative Works" shall mean any work, whether in Source or Object
      form, that is based on (or derived from) the Work and for which the
      editorial revisions, annotations, elaborations, or other modifications
      represent, as a whole, an original work of authorship. For the purposes
      of this License, Derivative Works shall not include works that remain
      separable from, or merely link (or bind by name) to the interfaces of,
      the Work and Derivative Works thereof.

"Contribution" shall mean any work of authorship, including
      the original version of the Work and any modifications or additions
      to that Work or Derivative Works thereof, that is intentionally
      submitted to Licensor for inclusion in the Work by the copyright owner
      or by an individual or Legal Entity authorized to submit on behalf of
      the copyright owner. For the purposes of this definition, "submitted"
      means any form of electronic, verbal, or written communication sent
      to the Licensor or its representatives, including but not limited to
      communication on electronic mailing lists, source code control systems,
      and issue tracking systems that are managed by, or on behalf of, the
      Licensor for the purpose of discussing and improving the Work, but
      excluding communication that is conspicuously marked or otherwise
      designated in writing by the copyright owner as "Not a Contribution."

"Contributor" shall mean Licensor and any individual or Legal Entity
      on behalf of whom a Contribution has been received by Licensor and
      subsequently incorporated within the Work.

2. Grant of Copyright License. Subject to the terms and conditions of
      this License, each Contributor hereby grants to You a perpetual,
      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
      copyright license to reproduce, prepare Derivative Works of,
      publicly display, publicly perform, sublicense, and distribute the
      Work and such Derivative Works in Source or Object form.

3. Grant of Patent License. Subject to the terms and conditions of
      this License, each Contributor hereby grants to You a perpetual,
      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
      (except as stated in this section) patent license to make, have made,
      use, offer to sell, sell, import, and otherwise transfer the Work,
      where such license applies only to those patent claims licensable
      by such Contributor that are necessarily infringed by their
      Contribution(s) alone or by combination of their Contribution(s)
      with the Work to which such Contribution(s) was submitted. If You
      institute patent litigation against any entity (including a
      cross-claim or counterclaim in a lawsuit) alleging that the Work
      or a Contribution incorporated within the Work constitutes direct
      or contributory patent infringement, then any patent licenses
      granted to You under this License for that Work shall terminate
      as of the date such litigation is filed.

4. Redistribution. You may reproduce and distribute copies of the
      Work or Derivative Works thereof in any medium, with or without
      modifications, and in Source or Object form, provided that You
      meet the following conditions:

(a) You must give any other recipients of the Work or
          Derivative Works a copy of this License; and

(b) You must cause any modified files to carry prominent notices
          stating that You changed the files; and

(c) You must retain, in the Source form of any Derivative Works
          that You distribute, all copyright, patent, trademark, and
          attribution notices from the Source form of the Work,
          excluding those notices that do not pertain to any part of
          the Derivative Works; and

(d) If the Work includes a "NOTICE" text file as part of its
          distribution, then any Derivative Works that You distribute must
          include a readable copy of the attribution notices contained
          within such NOTICE file, excluding those notices that do not
          pertain to any part of the Derivative Works, in at least one
          of the following places: within a NOTICE text file distributed
          as part of the Derivative Works; within the Source form or
          documentation, if provided along with the Derivative Works; or,
          within a display generated by the Derivative Works, if and
          wherever such third-party notices normally appear. The contents
          of the NOTICE file are for informational purposes only and
          do not modify the License. You may add Your own attribution
          notices within Derivative Works that You distribute, alongside
          or as an addendum to the NOTICE text from the Work, provided
          that such additional attribution notices cannot be construed
          as modifying the License.

You may add Your own copyright statement to Your modifications and
      may provide additional or different license terms and conditions
      for use, reproduction, or distribution of Your modifications, or
      for any such Derivative Works as a whole, provided Your use,
      reproduction, and distribution of the Work otherwise complies with
      the conditions stated in this License.

5. Submission of Contributions. Unless You explicitly state otherwise,
      any Contribution intentionally submitted for inclusion in the Work
      by You to the Licensor shall be under the terms and conditions of
      this License, without any additional terms or conditions.
      Notwithstanding the above, nothing herein shall supersede or modify
      the terms of any separate license agreement you may have executed
      with Licensor regarding such Contributions.

6. Trademarks. This License does not grant permission to use the trade
      names, trademarks, service marks, or product names of the Licensor,
      except as required for reasonable and customary use in describing the
      origin of the Work and reproducing the content of the NOTICE file.

7. Disclaimer of Warranty. Unless required by applicable law or
      agreed to in writing, Licensor provides the Work (and each
      Contributor provides its Contributions) on an "AS IS" BASIS,
      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
      implied, including, without limitation, any warranties or conditions
      of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
      PARTICULAR PURPOSE. You are solely responsible for determining the
      appropriateness of using or redistributing the Work and assume any
      risks associated with Your exercise of permissions under this License.

8. Limitation of Liability. In no event and under no legal theory,
      whether in tort (including negligence), contract, or otherwise,
      unless required by applicable law (such as deliberate and grossly
      negligent acts) or agreed to in writing, shall any Contributor be
      liable to You for damages, including any direct, indirect, special,
      incidental, or consequential damages of any character arising as a
      result of this License or out of the use or inability to use the
      Work (including but not limited to damages for loss of goodwill,
      work stoppage, computer failure or malfunction, or any and all
      other commercial damages or losses), even if such Contributor
      has been advised of the possibility of such damages.

9. Accepting Warranty or Additional Liability. While redistributing
      the Work or Derivative Works thereof, You may choose to offer,
      and charge a fee for, acceptance of support, warranty, indemnity,
      or other liability obligations and/or rights consistent with this
      License. However, in accepting such obligations, You may act only
      on Your own behalf and on Your sole responsibility, not on behalf
      of any other Contributor, and only if You agree to indemnify,
      defend, and hold each Contributor harmless for any liability
      incurred by, or claims asserted against, such Contributor by reason
      of your accepting any such warranty or additional liability.

END OF TERMS AND CONDITIONS

APPENDIX: How to apply the Apache License to your work.

To apply the Apache License to your work, attach the following
      boilerplate notice, with the fields enclosed by brackets "[]"
      replaced with your own identifying information. (Don't include
      the brackets!)  The text should be enclosed in the appropriate
      comment syntax for the file format. We also recommend that a
      file or class name and description of purpose be included on the
      same "printed page" as the copyright notice for easier
      identification within third-party archives.

Licensed under the Apache License, Version 2.0 (the "License");
   you may not use this file except in compliance with the License.
   You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
   distributed under the License is distributed on an "AS IS" BASIS,
   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   See the License for the specific language governing permissions and
   limitations under the License.
07070100000002000081A400000000000000000000000164D6588100000FEE000000000000000000000000000000000000001F00000000uyuni-tools-v0.0.1.6/README.md# Tools to help using Uyuni as containers

**These tools are work in progress**

* `uyuniadm` used to help user administer uyuni servers on k8s and podma
* `uyunictl` used to help user managing Uyuni and SUSE Manager Servers mainly through its API

## Building

`go build -o ./bin ./...` will produce the binaries in the root folder.
Alternatively, if you have `podman` installed you can run the `build.sh` script to build binaries compatible with SLE 15 SP4 or openSUSE Leap 15.4.

## Uyuniadm usage

Available Commands:
  * **help**: Help about any command
  * **install**: install a new server from scratch
  * **migrate**: migrate a remote server to containers
  * **uninstall**: uninstall a server

For more information about flags `uyuniadm --help`

### Uyuniadm install

Install a new server from scratch

The install command assumes the following:
  * podman or kubectl is installed locally
  * if kubectl is installed, a working kubeconfig should be set to connect to the cluster to deploy to

When installing on kubernetes, the helm values file will be overridden with the values from the uyuniadm parameters or configuration.

NOTE: for now installing on a remote cluster or podman is not supported!

```
Usage:
  uyuniadm install [fqdn] [flags]
```

For more information about flags `uyuniadm install --help`

### Uyuniadm migrate

Migrate a remote server to containers

This migration command assumes a few things:
  * the SSH configuration for the source server is complete, including user and
    all needed options to connect to the machine,
  * an SSH agent is started and the key to use to connect to the server is added to it,
  * podman or kubectl is installed locally
  * if kubectl is installed, a working kubeconfig should be set to connect to the cluster to deploy to

NOTE: for now installing on a remote cluster or podman is not supported yet!

```
Usage:
  uyuniadm migrate [source server FQDN] [flags]
```
For more information about flags `uyuniadm migrate --help`

#### SSH Configuration Example
1. In the destination server, add to `~/.ssh/config` :
   ```
   Host YOUR_HOST
    Hostname SOURCE_HOSTNAME
    StrictHostKeyChecking no
    UserKnownHostsFile /dev/null
    Port 22
    User SOURCE_USER
    IdentitiesOnly yes
    ```
2. If you already have a key, run:

```
    ssh-copy-id YOUR_HOST
    ```
    If not, run `ssh-keygen` to generate it.
3. If the `SOURCE_USER` user is not root, it should be able to run `rsync`. It can be done by adding to `/etc/sudoers`:
    ```
    add to sudoers file
    SOURCE_USER ALL=(ALL) NOPASSWD:/usr/bin/rsync
    ```
4. To provide a ssh agent with key, in the destination server:
    ```
    eval `ssh-agent`
    ssh-add $KEY_PATH
    ```
### Uyuniadm uninstall

Uninstall a server
```
Usage:
  uyuniadm uninstall [flags]
```

For more information about flags `uyuniadm uninstall --help`

## Uyunictl usage
Available Commands:
  * **cp**: copy files to and from the containers
  * **exec**: execute commands inside the uyuni containers using 'sh -c'
  * **help**: Help about any command

### Uyunictl cp

Takes a source and destination parameters. One of them can be prefixed with 'server:' to indicate the path is within the server pod.

```
Usage:
  uyunictl cp [path/to/source.file] [path/to/destination.file] [flags]
```
For more information about flags `uyunictl cp --help`

### Uyunictl exec

Execute commands inside the uyuni containers using 'sh -c'

```
Usage:
  uyunictl exec '[command-to-run --with-args]' [flags]
```
For more information about flags `uyunictl exec --help`

## Configuration File Example
All the commands can accept flags or yaml configuration file (using the option `-c`). This is an example of configuration file:
```
db:
  password: YOUR_DB_PASSWORD
cert:
  password: YOUR_DB_PASSWORD
scc:
  user: YOUR_SCC_USER
  password: YOUR_SCC_PASSWORD
email: YOUR_MAIL
emailFrom: YOUR_MAIL
image: YOUR_IMAGE_REGISTRY

helm:
  uyuni:
    chart: oci://OCI_REGISTRY
    values: /root/chart-values.yaml
podman:
  arg:
    - -p
    - 8000:8000
    - -p
    - 8001:8001
    - ""
```

07070100000003000081ED00000000000000000000000164D65881000000B1000000000000000000000000000000000000001E00000000uyuni-tools-v0.0.1.6/build.sh#!/usr/bin/bash

mkdir -p ./bin
podman run --rm -v $PWD:/src \
    -v $HOME/go:/go \
    --workdir /src/ \
    registry.suse.com/bci/golang:latest \
    go build -o ./bin ./...
07070100000004000081A400000000000000000000000164D658810000039E000000000000000000000000000000000000001C00000000uyuni-tools-v0.0.1.6/go.modmodule github.com/uyuni-project/uyuni-tools

go 1.19

require github.com/spf13/cobra v1.1.3

require (
	github.com/fsnotify/fsnotify v1.4.7 // indirect
	github.com/hashicorp/hcl v1.0.0 // indirect
	github.com/inconshreveable/mousetrap v1.0.0 // indirect
	github.com/magiconair/properties v1.8.1 // indirect
	github.com/mitchellh/go-homedir v1.1.0 // indirect
	github.com/mitchellh/mapstructure v1.1.2 // indirect
	github.com/pelletier/go-toml v1.2.0 // indirect
	github.com/spf13/afero v1.1.2 // indirect
	github.com/spf13/cast v1.3.0 // indirect
	github.com/spf13/jwalterweatherman v1.0.0 // indirect
	github.com/spf13/pflag v1.0.5 // indirect
	github.com/spf13/viper v1.7.0 // indirect
	github.com/subosito/gotenv v1.2.0 // indirect
	golang.org/x/sys v0.10.0 // indirect
	golang.org/x/term v0.10.0 // indirect
	golang.org/x/text v0.3.2 // indirect
	gopkg.in/ini.v1 v1.51.0 // indirect
	gopkg.in/yaml.v2 v2.4.0 // indirect
)
07070100000005000081A400000000000000000000000164D658810000757B000000000000000000000000000000000000001C00000000uyuni-tools-v0.0.1.6/go.sumcloud.google.com/go v0.26.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
cloud.google.com/go v0.34.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
cloud.google.com/go v0.38.0/go.mod h1:990N+gfupTy94rShfmMCWGDn0LpTmnzTp2qbd1dvSRU=
cloud.google.com/go v0.44.1/go.mod h1:iSa0KzasP4Uvy3f1mN/7PiObzGgflwredwwASm/v6AU=
cloud.google.com/go v0.44.2/go.mod h1:60680Gw3Yr4ikxnPRS/oxxkBccT6SA1yMk63TGekxKY=
cloud.google.com/go v0.45.1/go.mod h1:RpBamKRgapWJb87xiFSdk4g1CME7QZg3uwTez+TSTjc=
cloud.google.com/go v0.46.3/go.mod h1:a6bKKbmY7er1mI7TEI4lsAkts/mkhTSZK8w33B4RAg0=
cloud.google.com/go/bigquery v1.0.1/go.mod h1:i/xbL2UlR5RvWAURpBYZTtm/cXjCha9lbfbpx4poX+o=
cloud.google.com/go/datastore v1.0.0/go.mod h1:LXYbyblFSglQ5pkeyhO+Qmw7ukd3C+pD7TKLgZqpHYE=
cloud.google.com/go/firestore v1.1.0/go.mod h1:ulACoGHTpvq5r8rxGJ4ddJZBZqakUQqClKRT5SZwBmk=
cloud.google.com/go/pubsub v1.0.1/go.mod h1:R0Gpsv3s54REJCy4fxDixWD93lHJMoZTyQ2kNxGRt3I=
cloud.google.com/go/storage v1.0.0/go.mod h1:IhtSnM/ZTZV8YYJWCY8RULGVqBDmpoyjwiyrjsg+URw=
dmitri.shuralyov.com/gpu/mtl v0.0.0-20190408044501-666a987793e9/go.mod h1:H6x//7gZCb22OMCxBHrMx7a5I7Hp++hsVxbQ4BYO7hU=
github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
github.com/BurntSushi/xgb v0.0.0-20160522181843-27f122750802/go.mod h1:IVnqGOEym/WlBOVXweHU+Q+/VP0lqqI8lqeDx9IjBqo=
github.com/OneOfOne/xxhash v1.2.2/go.mod h1:HSdplMjZKSmBqAxg5vPj2TmRDmfkzw+cTzAElWljhcU=
github.com/alecthomas/template v0.0.0-20160405071501-a0175ee3bccc/go.mod h1:LOuyumcjzFXgccqObfd/Ljyb9UuFJ6TxHnclSeseNhc=
github.com/alecthomas/units v0.0.0-20151022065526-2efee857e7cf/go.mod h1:ybxpYRFXyAe+OPACYpWeL0wqObRcbAqCMya13uyzqw0=
github.com/armon/circbuf v0.0.0-20150827004946-bbbad097214e/go.mod h1:3U/XgcO3hCbHZ8TKRvWD2dDTCfh9M9ya+I9JpbB7O8o=
github.com/armon/go-metrics v0.0.0-20180917152333-f0300d1749da/go.mod h1:Q73ZrmVTwzkszR9V5SSuryQ31EELlFMUz1kKyl939pY=
github.com/armon/go-radix v0.0.0-20180808171621-7fddfc383310/go.mod h1:ufUuZ+zHj4x4TnLV4JWEpy2hxWSpsRywHrMgIH9cCH8=
github.com/beorn7/perks v0.0.0-20180321164747-3a771d992973/go.mod h1:Dwedo/Wpr24TaqPxmxbtue+5NUziq4I4S80YR8gNf3Q=
github.com/beorn7/perks v1.0.0/go.mod h1:KWe93zE9D1o94FZ5RNwFwVgaQK1VOXiVxmqh+CedLV8=
github.com/bgentry/speakeasy v0.1.0/go.mod h1:+zsyZBPWlz7T6j88CTgSN5bM796AkVf0kBD4zp0CCIs=
github.com/bketelsen/crypt v0.0.3-0.20200106085610-5cbc8cc4026c/go.mod h1:MKsuJmJgSg28kpZDP6UIiPt0e0Oz0kqKNGyRaWEPv84=
github.com/cespare/xxhash v1.1.0/go.mod h1:XrSqR1VqqWfGrhpAt58auRo0WTKS1nRRg3ghfAqPWnc=
github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
github.com/coreos/bbolt v1.3.2/go.mod h1:iRUV2dpdMOn7Bo10OQBFzIJO9kkE559Wcmn+qkEiiKk=
github.com/coreos/etcd v3.3.13+incompatible/go.mod h1:uF7uidLiAD3TWHmW31ZFd/JWoc32PjwdhPthX9715RE=
github.com/coreos/go-semver v0.3.0/go.mod h1:nnelYz7RCh+5ahJtPPxZlU+153eP4D4r3EedlOD2RNk=
github.com/coreos/go-systemd v0.0.0-20190321100706-95778dfbb74e/go.mod h1:F5haX7vjVVG0kc13fIWeqUViNPyEJxv/OmvnBo0Yme4=
github.com/coreos/pkg v0.0.0-20180928190104-399ea9e2e55f/go.mod h1:E3G3o1h8I7cfcXa63jLwjI0eiQQMgzzUDFVpN/nH/eA=
github.com/cpuguy83/go-md2man/v2 v2.0.0 h1:EoUDS0afbrsXAZ9YQ9jdu/mZ2sXgT1/2yyNng4PGlyM=
github.com/cpuguy83/go-md2man/v2 v2.0.0/go.mod h1:maD7wRr/U5Z6m/iR4s+kqSMx2CaBsrgA7czyZG/E6dU=
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/dgrijalva/jwt-go v3.2.0+incompatible/go.mod h1:E3ru+11k8xSBh+hMPgOLZmtrrCbhqsmaPHjLKYnJCaQ=
github.com/dgryski/go-sip13 v0.0.0-20181026042036-e10d5fee7954/go.mod h1:vAd38F8PWV+bWy6jNmig1y/TA+kYO4g3RSRF0IAv0no=
github.com/fatih/color v1.7.0/go.mod h1:Zm6kSWBoL9eyXnKyktHP6abPY2pDugNf5KwzbycvMj4=
github.com/fsnotify/fsnotify v1.4.7 h1:IXs+QLmnXW2CcXuY+8Mzv/fWEsPGWxqefPtCP5CnV9I=
github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo=
github.com/ghodss/yaml v1.0.0/go.mod h1:4dBDuWmgqj2HViK6kFavaiC9ZROes6MMH2rRYeMEF04=
github.com/go-gl/glfw v0.0.0-20190409004039-e6da0acd62b1/go.mod h1:vR7hzQXu2zJy9AVAgeJqvqgH9Q5CA+iKCZ2gyEVpxRU=
github.com/go-kit/kit v0.8.0/go.mod h1:xBxKIO96dXMWWy0MnWVtmwkA9/13aqxPnvrjFYMA2as=
github.com/go-logfmt/logfmt v0.3.0/go.mod h1:Qt1PoO58o5twSAckw1HlFXLmHsOX5/0LbT9GBnD5lWE=
github.com/go-logfmt/logfmt v0.4.0/go.mod h1:3RMwSq7FuexP4Kalkev3ejPJsZTpXXBr9+V4qmtdjCk=
github.com/go-stack/stack v1.8.0/go.mod h1:v0f6uXyyMGvRgIKkXu+yp6POWl0qKG85gN/melR3HDY=
github.com/gogo/protobuf v1.1.1/go.mod h1:r8qH/GZQm5c6nD/R0oafs1akxWv10x8SbQlK7atdtwQ=
github.com/gogo/protobuf v1.2.1/go.mod h1:hp+jE20tsWTFYpLwKvXlhS1hjn+gTNwPg2I6zVXpSg4=
github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b/go.mod h1:SBH7ygxi8pfUlaOkMMuAQtPIUF8ecWP5IEl/CR7VP2Q=
github.com/golang/groupcache v0.0.0-20190129154638-5b532d6fd5ef/go.mod h1:cIg4eruTrX1D+g88fzRXU5OdNfaM+9IcxsU14FzY7Hc=
github.com/golang/mock v1.1.1/go.mod h1:oTYuIxOrZwtPieC+H1uAHpcLFnEyAGVDL/k47Jfbm0A=
github.com/golang/mock v1.2.0/go.mod h1:oTYuIxOrZwtPieC+H1uAHpcLFnEyAGVDL/k47Jfbm0A=
github.com/golang/mock v1.3.1/go.mod h1:sBzyDLLjw3U8JLTeZvSv8jJB+tU5PVekmnlKIyFUx0Y=
github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
github.com/golang/protobuf v1.3.1/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
github.com/golang/protobuf v1.3.2/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
github.com/google/btree v0.0.0-20180813153112-4030bb1f1f0c/go.mod h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ=
github.com/google/btree v1.0.0/go.mod h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ=
github.com/google/go-cmp v0.2.0/go.mod h1:oXzfMopK8JAjlY9xF4vHSVASa0yLyX7SntLO5aqRK0M=
github.com/google/go-cmp v0.3.0/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
github.com/google/martian v2.1.0+incompatible/go.mod h1:9I4somxYTbIHy5NJKHRl3wXiIaQGbYVAs8BPL6v8lEs=
github.com/google/pprof v0.0.0-20181206194817-3ea8567a2e57/go.mod h1:zfwlbNMJ+OItoe0UupaVj+oy1omPYYDuagoSzA8v9mc=
github.com/google/pprof v0.0.0-20190515194954-54271f7e092f/go.mod h1:zfwlbNMJ+OItoe0UupaVj+oy1omPYYDuagoSzA8v9mc=
github.com/google/renameio v0.1.0/go.mod h1:KWCgfxg9yswjAJkECMjeO8J8rahYeXnNhOm40UhjYkI=
github.com/googleapis/gax-go/v2 v2.0.4/go.mod h1:0Wqv26UfaUD9n4G6kQubkQ+KchISgw+vpHVxEJEs9eg=
github.com/googleapis/gax-go/v2 v2.0.5/go.mod h1:DWXyrwAJ9X0FpwwEdw+IPEYBICEFu5mhpdKc/us6bOk=
github.com/gopherjs/gopherjs v0.0.0-20181017120253-0766667cb4d1/go.mod h1:wJfORRmW1u3UXTncJ5qlYoELFm8eSnnEO6hX4iZ3EWY=
github.com/gorilla/websocket v1.4.2/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
github.com/grpc-ecosystem/go-grpc-middleware v1.0.0/go.mod h1:FiyG127CGDf3tlThmgyCl78X/SZQqEOJBCDaAfeWzPs=
github.com/grpc-ecosystem/go-grpc-prometheus v1.2.0/go.mod h1:8NvIoxWQoOIhqOTXgfV/d3M/q6VIi02HzZEHgUlZvzk=
github.com/grpc-ecosystem/grpc-gateway v1.9.0/go.mod h1:vNeuVxBJEsws4ogUvrchl83t/GYV9WGTSLVdBhOQFDY=
github.com/hashicorp/consul/api v1.1.0/go.mod h1:VmuI/Lkw1nC05EYQWNKwWGbkg+FbDBtguAZLlVdkD9Q=
github.com/hashicorp/consul/sdk v0.1.1/go.mod h1:VKf9jXwCTEY1QZP2MOLRhb5i/I/ssyNV1vwHyQBF0x8=
github.com/hashicorp/errwrap v1.0.0/go.mod h1:YH+1FKiLXxHSkmPseP+kNlulaMuP3n2brvKWEqk/Jc4=
github.com/hashicorp/go-cleanhttp v0.5.1/go.mod h1:JpRdi6/HCYpAwUzNwuwqhbovhLtngrth3wmdIIUrZ80=
github.com/hashicorp/go-immutable-radix v1.0.0/go.mod h1:0y9vanUI8NX6FsYoO3zeMjhV/C5i9g4Q3DwcSNZ4P60=
github.com/hashicorp/go-msgpack v0.5.3/go.mod h1:ahLV/dePpqEmjfWmKiqvPkv/twdG7iPBM1vqhUKIvfM=
github.com/hashicorp/go-multierror v1.0.0/go.mod h1:dHtQlpGsu+cZNNAkkCN/P3hoUDHhCYQXV3UM06sGGrk=
github.com/hashicorp/go-rootcerts v1.0.0/go.mod h1:K6zTfqpRlCUIjkwsN4Z+hiSfzSTQa6eBIzfwKfwNnHU=
github.com/hashicorp/go-sockaddr v1.0.0/go.mod h1:7Xibr9yA9JjQq1JpNB2Vw7kxv8xerXegt+ozgdvDeDU=
github.com/hashicorp/go-syslog v1.0.0/go.mod h1:qPfqrKkXGihmCqbJM2mZgkZGvKG1dFdvsLplgctolz4=
github.com/hashicorp/go-uuid v1.0.0/go.mod h1:6SBZvOh/SIDV7/2o3Jml5SYk/TvGqwFJ/bN7x4byOro=
github.com/hashicorp/go-uuid v1.0.1/go.mod h1:6SBZvOh/SIDV7/2o3Jml5SYk/TvGqwFJ/bN7x4byOro=
github.com/hashicorp/go.net v0.0.1/go.mod h1:hjKkEWcCURg++eb33jQU7oqQcI9XDCnUzHA0oac0k90=
github.com/hashicorp/golang-lru v0.5.0/go.mod h1:/m3WP610KZHVQ1SGc6re/UDhFvYD7pJ4Ao+sR/qLZy8=
github.com/hashicorp/golang-lru v0.5.1/go.mod h1:/m3WP610KZHVQ1SGc6re/UDhFvYD7pJ4Ao+sR/qLZy8=
github.com/hashicorp/hcl v1.0.0 h1:0Anlzjpi4vEasTeNFn2mLJgTSwt0+6sfsiTG8qcWGx4=
github.com/hashicorp/hcl v1.0.0/go.mod h1:E5yfLk+7swimpb2L/Alb/PJmXilQ/rhwaUYs4T20WEQ=
github.com/hashicorp/logutils v1.0.0/go.mod h1:QIAnNjmIWmVIIkWDTG1z5v++HQmx9WQRO+LraFDTW64=
github.com/hashicorp/mdns v1.0.0/go.mod h1:tL+uN++7HEJ6SQLQ2/p+z2pH24WQKWjBPkE0mNTz8vQ=
github.com/hashicorp/memberlist v0.1.3/go.mod h1:ajVTdAv/9Im8oMAAj5G31PhhMCZJV2pPBoIllUwCN7I=
github.com/hashicorp/serf v0.8.2/go.mod h1:6hOLApaqBFA1NXqRQAsxw9QxuDEvNxSQRwA/JwenrHc=
github.com/inconshreveable/mousetrap v1.0.0 h1:Z8tu5sraLXCXIcARxBp/8cbvlwVa7Z1NHg9XEKhtSvM=
github.com/inconshreveable/mousetrap v1.0.0/go.mod h1:PxqpIevigyE2G7u3NXJIT2ANytuPF1OarO4DADm73n8=
github.com/jonboulle/clockwork v0.1.0/go.mod h1:Ii8DK3G1RaLaWxj9trq07+26W01tbo22gdxWY5EU2bo=
github.com/json-iterator/go v1.1.6/go.mod h1:+SdeFBvtyEkXs7REEP0seUULqWtbJapLOCVDaaPEHmU=
github.com/jstemmer/go-junit-report v0.0.0-20190106144839-af01ea7f8024/go.mod h1:6v2b51hI/fHJwM22ozAgKL4VKDeJcHhJFhtBdhmNjmU=
github.com/jtolds/gls v4.20.0+incompatible/go.mod h1:QJZ7F/aHp+rZTRtaJ1ow/lLfFfVYBRgL+9YlvaHOwJU=
github.com/julienschmidt/httprouter v1.2.0/go.mod h1:SYymIcj16QtmaHHD7aYtjjsJG7VTCxuUUipMqKk8s4w=
github.com/kisielk/errcheck v1.1.0/go.mod h1:EZBBE59ingxPouuu3KfxchcWSUPOHkagtvWXihfKN4Q=
github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck=
github.com/konsorten/go-windows-terminal-sequences v1.0.1/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ=
github.com/kr/logfmt v0.0.0-20140226030751-b84e30acd515/go.mod h1:+0opPa2QZZtGFBFZlji/RkVcI2GknAs/DXo4wKdlNEc=
github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=
github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
github.com/magiconair/properties v1.8.1 h1:ZC2Vc7/ZFkGmsVC9KvOjumD+G5lXy2RtTKyzRKO2BQ4=
github.com/magiconair/properties v1.8.1/go.mod h1:PppfXfuXeibc/6YijjN8zIbojt8czPbwD3XqdrwzmxQ=
github.com/mattn/go-colorable v0.0.9/go.mod h1:9vuHe8Xs5qXnSaW/c/ABM9alt+Vo+STaOChaDxuIBZU=
github.com/mattn/go-isatty v0.0.3/go.mod h1:M+lRXTBqGeGNdLjl/ufCoiOlB5xdOkqRJdNxMWT7Zi4=
github.com/matttproud/golang_protobuf_extensions v1.0.1/go.mod h1:D8He9yQNgCq6Z5Ld7szi9bcBfOoFv/3dc6xSMkL2PC0=
github.com/miekg/dns v1.0.14/go.mod h1:W1PPwlIAgtquWBMBEV9nkV9Cazfe8ScdGz/Lj7v3Nrg=
github.com/mitchellh/cli v1.0.0/go.mod h1:hNIlj7HEI86fIcpObd7a0FcrxTWetlwJDGcceTlRvqc=
github.com/mitchellh/go-homedir v1.0.0/go.mod h1:SfyaCUpYCn1Vlf4IUYiD9fPX4A5wJrkLzIz1N1q0pr0=
github.com/mitchellh/go-homedir v1.1.0 h1:lukF9ziXFxDFPkA1vsr5zpc1XuPDn/wFntq5mG+4E0Y=
github.com/mitchellh/go-homedir v1.1.0/go.mod h1:SfyaCUpYCn1Vlf4IUYiD9fPX4A5wJrkLzIz1N1q0pr0=
github.com/mitchellh/go-testing-interface v1.0.0/go.mod h1:kRemZodwjscx+RGhAo8eIhFbs2+BFgRtFPeD/KE+zxI=
github.com/mitchellh/gox v0.4.0/go.mod h1:Sd9lOJ0+aimLBi73mGofS1ycjY8lL3uZM3JPS42BGNg=
github.com/mitchellh/iochan v1.0.0/go.mod h1:JwYml1nuB7xOzsp52dPpHFffvOCDupsG0QubkSMEySY=
github.com/mitchellh/mapstructure v0.0.0-20160808181253-ca63d7c062ee/go.mod h1:FVVH3fgwuzCH5S8UJGiWEs2h04kUh9fWfEaFds41c1Y=
github.com/mitchellh/mapstructure v1.1.2 h1:fmNYVwqnSfB9mZU6OS2O6GsXM+wcskZDuKQzvN1EDeE=
github.com/mitchellh/mapstructure v1.1.2/go.mod h1:FVVH3fgwuzCH5S8UJGiWEs2h04kUh9fWfEaFds41c1Y=
github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
github.com/modern-go/reflect2 v1.0.1/go.mod h1:bx2lNnkwVCuqBIxFjflWJWanXIb3RllmbCylyMrvgv0=
github.com/mwitkow/go-conntrack v0.0.0-20161129095857-cc309e4a2223/go.mod h1:qRWi+5nqEBWmkhHvq77mSJWrCKwh8bxhgT7d/eI7P4U=
github.com/oklog/ulid v1.3.1/go.mod h1:CirwcVhetQ6Lv90oh/F+FBtV6XMibvdAFo93nm5qn4U=
github.com/pascaldekloe/goe v0.0.0-20180627143212-57f6aae5913c/go.mod h1:lzWF7FIEvWOWxwDKqyGYQf6ZUaNfKdP144TG7ZOy1lc=
github.com/pelletier/go-toml v1.2.0 h1:T5zMGML61Wp+FlcbWjRDT7yAxhJNAiPPLOFECq181zc=
github.com/pelletier/go-toml v1.2.0/go.mod h1:5z9KED0ma1S8pY6P1sdut58dfprrGBbd/94hg7ilaic=
github.com/pkg/errors v0.8.0/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
github.com/pkg/errors v0.8.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
github.com/posener/complete v1.1.1/go.mod h1:em0nMJCgc9GFtwrmVmEMR/ZL6WyhyjMBndrE9hABlRI=
github.com/prometheus/client_golang v0.9.1/go.mod h1:7SWBe2y4D6OKWSNQJUaRYU/AaXPKyh/dDVn+NZz0KFw=
github.com/prometheus/client_golang v0.9.3/go.mod h1:/TN21ttK/J9q6uSwhBd54HahCDft0ttaMvbicHlPoso=
github.com/prometheus/client_model v0.0.0-20180712105110-5c3871d89910/go.mod h1:MbSGuTsp3dbXC40dX6PRTWyKYBIrTGTE9sqQNg2J8bo=
github.com/prometheus/client_model v0.0.0-20190129233127-fd36f4220a90/go.mod h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA=
github.com/prometheus/common v0.0.0-20181113130724-41aa239b4cce/go.mod h1:daVV7qP5qjZbuso7PdcryaAu0sAZbrN9i7WWcTMWvro=
github.com/prometheus/common v0.4.0/go.mod h1:TNfzLD0ON7rHzMJeJkieUDPYmFC7Snx/y86RQel1bk4=
github.com/prometheus/procfs v0.0.0-20181005140218-185b4288413d/go.mod h1:c3At6R/oaqEKCNdg8wHV1ftS6bRYblBhIjjI8uT2IGk=
github.com/prometheus/procfs v0.0.0-20190507164030-5867b95ac084/go.mod h1:TjEm7ze935MbeOT/UhFTIMYKhuLP4wbCsTZCD3I8kEA=
github.com/prometheus/tsdb v0.7.1/go.mod h1:qhTCs0VvXwvX/y3TZrWD7rabWM+ijKTux40TwIPHuXU=
github.com/rogpeppe/fastuuid v0.0.0-20150106093220-6724a57986af/go.mod h1:XWv6SoW27p1b0cqNHllgS5HIMJraePCO15w5zCzIWYg=
github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
github.com/russross/blackfriday/v2 v2.0.1/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
github.com/ryanuber/columnize v0.0.0-20160712163229-9b3edd62028f/go.mod h1:sm1tb6uqfes/u+d4ooFouqFdy9/2g9QGwK3SQygK0Ts=
github.com/sean-/seed v0.0.0-20170313163322-e2103e2c3529/go.mod h1:DxrIzT+xaE7yg65j358z/aeFdxmN0P9QXhEzd20vsDc=
github.com/shurcooL/sanitized_anchor_name v1.0.0/go.mod h1:1NzhyTcUVG4SuEtjjoZeVRXNmyL/1OwPU0+IJeTBvfc=
github.com/sirupsen/logrus v1.2.0/go.mod h1:LxeOpSwHxABJmUn/MG1IvRgCAasNZTLOkJPxbbu5VWo=
github.com/smartystreets/assertions v0.0.0-20180927180507-b2de0cb4f26d/go.mod h1:OnSkiWE9lh6wB0YB77sQom3nweQdgAjqCqsofrRNTgc=
github.com/smartystreets/goconvey v1.6.4/go.mod h1:syvi0/a8iFYH4r/RixwvyeAJjdLS9QV7WQ/tjFTllLA=
github.com/soheilhy/cmux v0.1.4/go.mod h1:IM3LyeVVIOuxMH7sFAkER9+bJ4dT7Ms6E4xg4kGIyLM=
github.com/spaolacci/murmur3 v0.0.0-20180118202830-f09979ecbc72/go.mod h1:JwIasOWyU6f++ZhiEuf87xNszmSA2myDM2Kzu9HwQUA=
github.com/spf13/afero v1.1.2 h1:m8/z1t7/fwjysjQRYbP0RD+bUIF/8tJwPdEZsI83ACI=
github.com/spf13/afero v1.1.2/go.mod h1:j4pytiNVoe2o6bmDsKpLACNPDBIoEAkihy7loJ1B0CQ=
github.com/spf13/cast v1.3.0 h1:oget//CVOEoFewqQxwr0Ej5yjygnqGkvggSE/gB35Q8=
github.com/spf13/cast v1.3.0/go.mod h1:Qx5cxh0v+4UWYiBimWS+eyWzqEqokIECu5etghLkUJE=
github.com/spf13/cobra v1.1.3 h1:xghbfqPkxzxP3C/f3n5DdpAbdKLj4ZE4BWQI362l53M=
github.com/spf13/cobra v1.1.3/go.mod h1:pGADOWyqRD/YMrPZigI/zbliZ2wVD/23d+is3pSWzOo=
github.com/spf13/jwalterweatherman v1.0.0 h1:XHEdyB+EcvlqZamSM4ZOMGlc93t6AcsBEu9Gc1vn7yk=
github.com/spf13/jwalterweatherman v1.0.0/go.mod h1:cQK4TGJAtQXfYWX+Ddv3mKDzgVb68N+wFjFa4jdeBTo=
github.com/spf13/pflag v1.0.3/go.mod h1:DYY7MBk1bdzusC3SYhjObp+wFpr4gzcvqqNjLnInEg4=
github.com/spf13/pflag v1.0.5 h1:iy+VFUOCP1a+8yFto/drg2CJ5u0yRoB7fZw3DKv/JXA=
github.com/spf13/pflag v1.0.5/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
github.com/spf13/viper v1.7.0 h1:xVKxvI7ouOI5I+U9s2eeiUfMaWBVoXA3AWskkrqK0VM=
github.com/spf13/viper v1.7.0/go.mod h1:8WkrPz2fc9jxqZNCJI/76HCieCp4Q8HaLFoCha5qpdg=
github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
github.com/stretchr/objx v0.1.1/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
github.com/subosito/gotenv v1.2.0 h1:Slr1R9HxAlEKefgq5jn9U+DnETlIUa6HfgEzj0g5d7s=
github.com/subosito/gotenv v1.2.0/go.mod h1:N0PQaV/YGNqwC0u51sEeR/aUtSLEXKX9iv69rRypqCw=
github.com/tmc/grpc-websocket-proxy v0.0.0-20190109142713-0ad062ec5ee5/go.mod h1:ncp9v5uamzpCO7NfCPTXjqaC+bZgJeR0sMTm6dMHP7U=
github.com/xiang90/probing v0.0.0-20190116061207-43a291ad63a2/go.mod h1:UETIi67q53MR2AWcXfiuqkDkRtnGDLqkBTpCHuJHxtU=
go.etcd.io/bbolt v1.3.2/go.mod h1:IbVyRI1SCnLcuJnV2u8VeU0CEYM7e686BmAb1XKL+uU=
go.opencensus.io v0.21.0/go.mod h1:mSImk1erAIZhrmZN+AvHh14ztQfjbGwt4TtuofqLduU=
go.opencensus.io v0.22.0/go.mod h1:+kGneAE2xo2IficOXnaByMWTGM9T73dGwxeWcUqIpI8=
go.uber.org/atomic v1.4.0/go.mod h1:gD2HeocX3+yG+ygLZcrzQJaqmWj9AIm7n08wl/qW/PE=
go.uber.org/multierr v1.1.0/go.mod h1:wR5kodmAFQ0UK8QlbwjlSNy0Z68gJhDJUG5sjR94q/0=
go.uber.org/zap v1.10.0/go.mod h1:vwi/ZaCAaUcBkycHslxD9B2zi4UTXhF60s6SWpuDF0Q=
golang.org/x/crypto v0.0.0-20180904163835-0709b304e793/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
golang.org/x/crypto v0.0.0-20181029021203-45a5f77698d3/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
golang.org/x/crypto v0.0.0-20190510104115-cbcb75029529/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
golang.org/x/crypto v0.0.0-20190605123033-f99c8df09eb5/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
golang.org/x/exp v0.0.0-20190121172915-509febef88a4/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA=
golang.org/x/exp v0.0.0-20190306152737-a1d7652674e8/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA=
golang.org/x/exp v0.0.0-20190510132918-efd6b22b2522/go.mod h1:ZjyILWgesfNpC6sMxTJOJm9Kp84zZh5NQWvqDGG3Qr8=
golang.org/x/exp v0.0.0-20190829153037-c13cbed26979/go.mod h1:86+5VVa7VpoJ4kLfm080zCjGlMRFzhUhsZKEZO7MGek=
golang.org/x/exp v0.0.0-20191030013958-a1ab85dbe136/go.mod h1:JXzH8nQsPlswgeRAPE3MuO9GYsAcnJvJ4vnMwN/5qkY=
golang.org/x/image v0.0.0-20190227222117-0694c2d4d067/go.mod h1:kZ7UVZpmo3dzQBMxlp+ypCbDeSB+sBbTgSJuh5dn5js=
golang.org/x/image v0.0.0-20190802002840-cff245a6509b/go.mod h1:FeLwcggjj3mMvU+oOTbSwawSJRM1uh48EjtB4UJZlP0=
golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE=
golang.org/x/lint v0.0.0-20190227174305-5b3e6a55c961/go.mod h1:wehouNa3lNwaWXcvxsM5YxQ5yQlVC4a0KAMCusXpPoU=
golang.org/x/lint v0.0.0-20190301231843-5614ed5bae6f/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE=
golang.org/x/lint v0.0.0-20190313153728-d0100b6bd8b3/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
golang.org/x/lint v0.0.0-20190409202823-959b441ac422/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
golang.org/x/lint v0.0.0-20190909230951-414d861bb4ac/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
golang.org/x/lint v0.0.0-20190930215403-16217165b5de/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
golang.org/x/mobile v0.0.0-20190312151609-d3739f865fa6/go.mod h1:z+o9i4GpDbdi3rU15maQ/Ox0txvL9dWGYEHz965HBQE=
golang.org/x/mobile v0.0.0-20190719004257-d2bd2a29d028/go.mod h1:E/iHnbuqvinMTCcRqshq8CkpyQDoeVncDDYHnLhea+o=
golang.org/x/mod v0.0.0-20190513183733-4bf6d317e70e/go.mod h1:mXi4GBBbnImb6dmsKGUJ2LatrhH/nqhxcFungHvyanc=
golang.org/x/mod v0.1.0/go.mod h1:0QHyrYULN0/3qlju5TqG8bIK38QM8yzMo5ekMj3DlcY=
golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20181023162649-9b4f9f5ad519/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20181114220301-adae6a3d119a/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20181201002055-351d144fa1fc/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20181220203305-927f97764cc3/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20190108225652-1e06a53dbb7e/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20190213061140-3a22650c66bd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
golang.org/x/net v0.0.0-20190501004415-9ce7a6920f09/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
golang.org/x/net v0.0.0-20190503192946-f4e77d36d62c/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
golang.org/x/net v0.0.0-20190603091049-60506f45cf65/go.mod h1:HSz+uSET+XFnRR8LxR5pz3Of3rY3CfYBVs4xY44aLks=
golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
golang.org/x/oauth2 v0.0.0-20190604053449-0f29369cfe45/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
golang.org/x/sync v0.0.0-20190227155943-e225da77a7e6/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
golang.org/x/sys v0.0.0-20180823144017-11551d06cbcc/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/sys v0.0.0-20180905080454-ebe1bf3edb33/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/sys v0.0.0-20181026203630-95b1ffbd15a5/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/sys v0.0.0-20181107165924-66b7b1311ac8/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/sys v0.0.0-20181116152217-5ac8a444bdc5/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/sys v0.0.0-20190312061237-fead79001313/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20190502145724-3ef323f4f1fd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20190507160741-ecd444e8653b/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20190606165138-5da285871e9c/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20190624142023-c5567b49c5d0 h1:HyfiK1WMnHj5FXFXatD+Qs1A/xC2Run6RzeW1SyHxpc=
golang.org/x/sys v0.0.0-20190624142023-c5567b49c5d0/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.10.0 h1:SqMFp9UcQJZa+pmYuAKjd9xq1f0j5rLcDIk0mj4qAsA=
golang.org/x/sys v0.10.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/term v0.10.0 h1:3R7pNqamzBraeqj/Tj8qt1aQ2HpmlC+Cx/qL/7hn4/c=
golang.org/x/term v0.10.0/go.mod h1:lpqdcUyK/oCiQxvxVrppt5ggO2KCZ5QblwqPnfZ6d5o=
golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
golang.org/x/text v0.3.1-0.20180807135948-17ff2d5776d2/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
golang.org/x/text v0.3.2 h1:tW2bmiBqwgJj/UpqtC8EpXEZVYOwU0yG4iWbprSVAcs=
golang.org/x/text v0.3.2/go.mod h1:bEr9sfX3Q8Zfm5fL9x+3itogRgK3+ptLWKqgva+5dAk=
golang.org/x/time v0.0.0-20181108054448-85acf8d2951c/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
golang.org/x/time v0.0.0-20190308202827-9d24e82272b4/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
golang.org/x/tools v0.0.0-20180221164845-07fd8470d635/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
golang.org/x/tools v0.0.0-20190114222345-bf090417da8b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
golang.org/x/tools v0.0.0-20190226205152-f727befe758c/go.mod h1:9Yl7xja0Znq3iFh3HoIrodX9oNMXvdceNzlUR8zjMvY=
golang.org/x/tools v0.0.0-20190311212946-11955173bddd/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
golang.org/x/tools v0.0.0-20190312151545-0bb0c0a6e846/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
golang.org/x/tools v0.0.0-20190312170243-e65039ee4138/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
golang.org/x/tools v0.0.0-20190328211700-ab21143f2384/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
golang.org/x/tools v0.0.0-20190425150028-36563e24a262/go.mod h1:RgjU9mgBXZiqYHBnxXauZ1Gv1EHHAz9KjViQ78xBX0Q=
golang.org/x/tools v0.0.0-20190506145303-2d16b83fe98c/go.mod h1:RgjU9mgBXZiqYHBnxXauZ1Gv1EHHAz9KjViQ78xBX0Q=
golang.org/x/tools v0.0.0-20190606124116-d0a3d012864b/go.mod h1:/rFqwRUd4F7ZHNgwSSTFct+R/Kf4OFW1sUzUTQQTgfc=
golang.org/x/tools v0.0.0-20190621195816-6e04913cbbac/go.mod h1:/rFqwRUd4F7ZHNgwSSTFct+R/Kf4OFW1sUzUTQQTgfc=
golang.org/x/tools v0.0.0-20190628153133-6cdbf07be9d0/go.mod h1:/rFqwRUd4F7ZHNgwSSTFct+R/Kf4OFW1sUzUTQQTgfc=
golang.org/x/tools v0.0.0-20190816200558-6889da9d5479/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
golang.org/x/tools v0.0.0-20190911174233-4f2ddba30aff/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
golang.org/x/tools v0.0.0-20191012152004-8de300cfc20a/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
golang.org/x/tools v0.0.0-20191112195655-aa38f8e97acc/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
google.golang.org/api v0.4.0/go.mod h1:8k5glujaEP+g9n7WNsDg8QP6cUVNI86fCNMcbazEtwE=
google.golang.org/api v0.7.0/go.mod h1:WtwebWUNSVBH/HAw79HIFXZNqEvBhG+Ra+ax0hx3E3M=
google.golang.org/api v0.8.0/go.mod h1:o4eAsZoiT+ibD93RtjEohWalFOjRDx6CVaqeizhEnKg=
google.golang.org/api v0.9.0/go.mod h1:o4eAsZoiT+ibD93RtjEohWalFOjRDx6CVaqeizhEnKg=
google.golang.org/api v0.13.0/go.mod h1:iLdEw5Ide6rF15KTC1Kkl0iskquN2gFfn9o9XIsbkAI=
google.golang.org/appengine v1.1.0/go.mod h1:EbEs0AVv82hx2wNQdGPgUI5lhzA/G0D9YwlJXL52JkM=
google.golang.org/appengine v1.4.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4=
google.golang.org/appengine v1.5.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4=
google.golang.org/appengine v1.6.1/go.mod h1:i06prIuMbXzDqacNJfV5OdTW448YApPu5ww/cMBSeb0=
google.golang.org/genproto v0.0.0-20180817151627-c66870c02cf8/go.mod h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc=
google.golang.org/genproto v0.0.0-20190307195333-5fe7a883aa19/go.mod h1:VzzqZJRnGkLBvHegQrXjBqPurQTc5/KpmUdxsrq26oE=
google.golang.org/genproto v0.0.0-20190418145605-e7d98fc518a7/go.mod h1:VzzqZJRnGkLBvHegQrXjBqPurQTc5/KpmUdxsrq26oE=
google.golang.org/genproto v0.0.0-20190425155659-357c62f0e4bb/go.mod h1:VzzqZJRnGkLBvHegQrXjBqPurQTc5/KpmUdxsrq26oE=
google.golang.org/genproto v0.0.0-20190502173448-54afdca5d873/go.mod h1:VzzqZJRnGkLBvHegQrXjBqPurQTc5/KpmUdxsrq26oE=
google.golang.org/genproto v0.0.0-20190801165951-fa694d86fc64/go.mod h1:DMBHOl98Agz4BDEuKkezgsaosCRResVns1a3J2ZsMNc=
google.golang.org/genproto v0.0.0-20190819201941-24fa4b261c55/go.mod h1:DMBHOl98Agz4BDEuKkezgsaosCRResVns1a3J2ZsMNc=
google.golang.org/genproto v0.0.0-20190911173649-1774047e7e51/go.mod h1:IbNlFCBrqXvoKpeg0TB2l7cyZUmoaFKYIwrEpbDKLA8=
google.golang.org/genproto v0.0.0-20191108220845-16a3f7862a1a/go.mod h1:n3cpQtvxv34hfy77yVDNjmbRyujviMdxYliBSkLhpCc=
google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c=
google.golang.org/grpc v1.20.1/go.mod h1:10oTOabMzJvdu6/UiuZezV6QK5dSlG84ov/aaiqXj38=
google.golang.org/grpc v1.21.1/go.mod h1:oYelfM1adQP15Ek0mdvEgi9Df8B9CZIaU1084ijfRaM=
gopkg.in/alecthomas/kingpin.v2 v2.2.6/go.mod h1:FMv+mEhP44yOT+4EoQTLFTRgOQ1FBLkstjWtayDeSgw=
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
gopkg.in/errgo.v2 v2.1.0/go.mod h1:hNsd1EY+bozCKY1Ytp96fpM3vjJbqLJn88ws8XvfDNI=
gopkg.in/ini.v1 v1.51.0 h1:AQvPpx3LzTDM0AjnIRlVFwFFGC+npRopjZxLJj6gdno=
gopkg.in/ini.v1 v1.51.0/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k=
gopkg.in/resty.v1 v1.12.0/go.mod h1:mDo4pnntr5jdWRML875a/NmxYqAlA73dVijT2AXvQQo=
gopkg.in/yaml.v2 v2.0.0-20170812160011-eb3733d160e7/go.mod h1:JAlM8MvJe8wmxCU4Bli9HhUf9+ttbYbLASfIpnQbh74=
gopkg.in/yaml.v2 v2.2.1/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
gopkg.in/yaml.v2 v2.2.4/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY=
gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ=
honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
honnef.co/go/tools v0.0.0-20190106161140-3f1c8253044a/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
honnef.co/go/tools v0.0.0-20190418001031-e561f6794a2a/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
honnef.co/go/tools v0.0.1-2019.2.3/go.mod h1:a3bituU0lyd329TUQxRnasdCoJDkEUEAqEt0JzvZhAg=
rsc.io/binaryregexp v0.2.0/go.mod h1:qTv7/COck+e2FymRvadv62gMdZztPaShugOCi3I+8D8=
07070100000006000041ED00000000000000000000000564D6588100000000000000000000000000000000000000000000001C00000000uyuni-tools-v0.0.1.6/shared07070100000007000041ED00000000000000000000000264D6588100000000000000000000000000000000000000000000002300000000uyuni-tools-v0.0.1.6/shared/podman07070100000008000081A400000000000000000000000164D6588100000F50000000000000000000000000000000000000002D00000000uyuni-tools-v0.0.1.6/shared/podman/podman.gopackage podman

import (
	"fmt"
	"log"
	"os"
	"os/exec"
	"strings"
	"text/template"

"github.com/uyuni-project/uyuni-tools/shared/utils"
)

const UYUNI_NETWORK = "uyuni"
const commonArgs = "--name %s --rm --cap-add NET_RAW --tmpfs /run -v cgroup:/sys/fs/cgroup:rw"

func GetCommonParams(containerName string) []string {
	return strings.Split(fmt.Sprintf(commonArgs, containerName), " ")
}

func GetExposedPorts() []string {
	return []string{"443", "80", "4505", "4506", "69", "25151", "5432", "9100", "9187", "9800"}
}

const ServicePath = "/usr/lib/systemd/system/uyuni-server.service"

func GenerateSystemdService(tz string, image string, podmanArgs []string, verbose bool) {

setupNetwork(verbose)

_, err := os.Stat(ServicePath)
	if err == nil {
		log.Fatalln("uyuni-server service already present, not overwriting")
	} else if !os.IsNotExist(err) {
		log.Fatalf("Failed to stat %s file: %s\n", ServicePath, err)
	}

file, err := os.OpenFile(ServicePath, os.O_WRONLY|os.O_CREATE, 0555)
	if err != nil {
		log.Fatalf("Fail to open uyuni-server.service file: %s\n", err)
	}
	defer file.Close()

const serviceTemplate = `# uyuni-server.service, generated by uyuniadm
# Use an uyuni-server.service.d/local.conf file to override

[Unit]
Description=Uyuni server image container service
Wants=network.target
After=network-online.target
RequiresMountsFor=%t/containers

[Service]
Environment=PODMAN_SYSTEMD_UNIT=%n
Environment=UYUNI_IMAGE={{ .Image }}
Environment=TZ={{ .Timezone }}
Restart=on-failure
ExecStartPre=/bin/rm -f %t/uyuni-server.pid %t/%n.ctr-id
ExecStart=/usr/bin/podman run \
	--conmon-pidfile %t/uyuni-server.pid \
	--cidfile=%t/%n.ctr-id \
	--cgroups=no-conmon \
	--sdnotify=conmon \
	-d \
	{{ .Args }} \
	{{- range .Ports }}
	-p {{ . }}:{{ . }} \
	{{- end }}
	{{- range $name, $path := .Volumes }}
	-v {{ $name }}:{{ $path }} \
	{{- end }}
	-e TZ=${TZ} \
	--network {{ .Network }}\
	${UYUNI_IMAGE}
ExecStop=/usr/bin/podman stop \
	--ignore -t 10 \
	--cidfile=%t/%n.ctr-id
ExecStopPost=/usr/bin/podman rm \
	-f \
	--ignore -t 10 \
	--cidfile=%t/%n.ctr-id

PIDFile=%t/uyuni-server.pid
TimeoutStopSec=180
TimeoutStartSec=900
Type=forking

[Install]
WantedBy=multi-user.target default.target
`

model := struct {
		Volumes  map[string]string
		Args     string
		Ports    []string
		Timezone string
		Image    string
		Network  string
	}{

Volumes:  utils.VOLUMES,
		Args:     fmt.Sprintf(commonArgs, "uyuni-server") + " " + strings.Join(podmanArgs, " "),
		Ports:    GetExposedPorts(),
		Timezone: tz,
		Image:    image,
		Network:  UYUNI_NETWORK,
	}

t := template.Must(template.New("service").Parse(serviceTemplate))
	if err = t.Execute(file, model); err != nil {
		log.Fatalf("Failed to generate systemd service unit file: %s\n", err)
	}

utils.RunCmd("systemctl", []string{"daemon-reload"}, "Failed to reload systemd daemon", verbose)
}

func setupNetwork(verbose bool) {
	log.Printf("Setting up %s network\n", UYUNI_NETWORK)

// Check if the uyuni network exists and is IPv6 enabled
	hasIpv6, err := exec.Command("podman", "network", "inspect", "--format", "{{.IPv6Enabled}}", UYUNI_NETWORK).Output()
	if err == nil && string(hasIpv6) != "true" {
		log.Printf("%s network is defined but doesn't have IPv6, skipping IPv6 enabling\n", UYUNI_NETWORK)
	}

message := fmt.Sprintf("Failed to create %s network with IPv6 enabled", UYUNI_NETWORK)

args := []string{"network", "create"}
	// Check if the networkd backend is netavark
	if backend, err := exec.Command("podman", "info", "--format", "{{.Host.NetworkBackend}}").Output(); err != nil {
		log.Fatalf("Failed to find podman's network backend: %s\n", err)
	} else if string(backend) != "netavark" {
		log.Printf("Podman's network backend is not netavark, skipping IPv6 enabling on %s network\n", UYUNI_NETWORK)
	} else {
		args = append(args, "--ipv6")
	}
	args = append(args, UYUNI_NETWORK)
	utils.RunCmd("podman", args, message, verbose)
}
07070100000009000041ED00000000000000000000000264D6588100000000000000000000000000000000000000000000002200000000uyuni-tools-v0.0.1.6/shared/types0707010000000A000081A400000000000000000000000164D658810000004F000000000000000000000000000000000000002C00000000uyuni-tools-v0.0.1.6/shared/types/global.gopackage types

type GlobalFlags struct {
	Verbose    bool
	ConfigPath string
}
0707010000000B000041ED00000000000000000000000264D6588100000000000000000000000000000000000000000000002200000000uyuni-tools-v0.0.1.6/shared/utils0707010000000C000081A400000000000000000000000164D65881000005EF000000000000000000000000000000000000002C00000000uyuni-tools-v0.0.1.6/shared/utils/config.gopackage utils

import (
	"log"
	"os"
	"path"
	"strings"

"github.com/spf13/cobra"
	"github.com/spf13/pflag"
	"github.com/spf13/viper"
)

const envPrefix = "UYUNI"
const appName = "uyuni-tools"

func ReadConfig(configPath string, configFilename string, cmd *cobra.Command) *viper.Viper {
	v := viper.New()

v.SetConfigType("yaml")
	v.SetConfigName(configFilename)

if configPath != "" {
		log.Printf("Using config file %s\n", configPath)
		v.SetConfigFile(configPath)
	} else {
		xdgConfigHome := os.Getenv("XDG_CONFIG_HOME")
		if xdgConfigHome == "" {
			xdgConfigHome = path.Join(os.Getenv("HOME"), ".config")
		}
		v.AddConfigPath(path.Join(xdgConfigHome, appName))
		v.AddConfigPath(".")
	}

bindFlags(cmd, v)

if err := v.ReadInConfig(); err != nil {
		// It's okay if there isn't a config file
		if _, ok := err.(viper.ConfigFileNotFoundError); !ok {
			// TODO Provide help on the config file format
			log.Fatalf("Failed to parse configuration file %s: %s", v.ConfigFileUsed(), err)
		}
	}

v.SetEnvPrefix(envPrefix)

v.SetEnvKeyReplacer(strings.NewReplacer(".", "_"))

v.AutomaticEnv()

return v
}

// Bind each cobra flag to its associated viper configuration (config file and environment variable)
func bindFlags(cmd *cobra.Command, v *viper.Viper) {
	cmd.Flags().VisitAll(func(f *pflag.Flag) {
		configName := strings.ReplaceAll(f.Name, "-", ".")
		if err := v.BindPFlag(configName, f); err != nil {
			log.Fatalf("Failed to bind %s config to parameter %s: %s\n", configName, f.Name, err)
		}
	})
}
0707010000000D000081A400000000000000000000000164D6588100000576000000000000000000000000000000000000002800000000uyuni-tools-v0.0.1.6/shared/utils/cp.gopackage utils

import (
	"log"
	"strings"

"github.com/uyuni-project/uyuni-tools/shared/types"
)

// Copy transfers a file to or from the container.
// Prefix one of src or dst parameters with `server:` to designate the path is in the container
// user and group parameters are used to set the owner of a file transfered in the container.
func Copy(globalFlags *types.GlobalFlags, src string, dst string, user string, group string) {
	command, podName := GetPodName(true)
	var commandArgs []string
	extraArgs := []string{}
	srcExpanded := strings.Replace(src, "server:", podName+":", 1)
	dstExpanded := strings.Replace(dst, "server:", podName+":", 1)

switch command {
	case "podman":
		commandArgs = []string{"cp", srcExpanded, dstExpanded}
	case "kubectl":
		commandArgs = []string{"cp", "-c", "uyuni", srcExpanded, dstExpanded}
		extraArgs = []string{"-c", "uyuni", "--"}
	default:
		log.Fatalf("Unknown container kind: %s\n", command)
	}

RunCmd(command, commandArgs, "Failed to copy file", globalFlags.Verbose)

if user != "" && strings.HasPrefix(dst, "server:") {
		execArgs := []string{"exec", podName}
		execArgs = append(execArgs, extraArgs...)
		owner := user
		if group != "" {
			owner = user + ":" + group
		}
		execArgs = append(execArgs, "chown", owner, strings.Replace(dst, "server:", "", 1))
		RunCmd(command, execArgs, "Failed to change file owner", globalFlags.Verbose)
	}
}
0707010000000E000081A400000000000000000000000164D6588100000717000000000000000000000000000000000000002A00000000uyuni-tools-v0.0.1.6/shared/utils/exec.gopackage utils

import (
	"bufio"
	"fmt"
	"log"
	"os"
	"os/exec"
	"strings"

"github.com/uyuni-project/uyuni-tools/shared/types"
)

func Exec(globalFlags *types.GlobalFlags, interactive bool, tty bool, env []string, args ...string) {
	command, podName := GetPodName(true)

commandArgs := []string{"exec"}
	if interactive {
		commandArgs = append(commandArgs, "-i")
	}
	if tty {
		commandArgs = append(commandArgs, "-t")
	}
	commandArgs = append(commandArgs, podName)

if command == "kubectl" {
		commandArgs = append(commandArgs, "-c", "uyuni", "--")
	}

newEnv := []string{}
	for _, envValue := range env {
		if !strings.Contains(envValue, "=") {
			if value, set := os.LookupEnv(envValue); set {
				newEnv = append(newEnv, fmt.Sprintf("%s=%s", envValue, value))
			}
		} else {
			newEnv = append(newEnv, envValue)
		}
	}
	if len(newEnv) > 0 {
		commandArgs = append(commandArgs, "env")
		commandArgs = append(commandArgs, newEnv...)
	}
	commandArgs = append(commandArgs, "sh", "-c", strings.Join(args, " "))
	if globalFlags.Verbose {
		fmt.Printf("> Running: %s %s\n", command, strings.Join(commandArgs, " "))
	}
	runCmd := exec.Command(command, commandArgs...)
	runCmd.Stdout = os.Stdout
	runCmd.Stdin = os.Stdin

// Filter out kubectl line about terminated exit code
	stderr, err := runCmd.StderrPipe()
	if err != nil {
		log.Fatal(err)
	}
	if err = runCmd.Start(); err != nil {
		log.Fatal(err)
	}
	scanner := bufio.NewScanner(stderr)
	for scanner.Scan() {
		line := scanner.Text()
		if !strings.HasPrefix(line, "command terminated with exit code") {
			fmt.Fprintln(os.Stderr, line)
		}
	}

if scanner.Err() != nil {
		log.Fatal(scanner.Err())
	}
	if err = runCmd.Wait(); err != nil {
		if exitErr, ok := err.(*exec.ExitError); ok {
			os.Exit(exitErr.ExitCode())
		} else {
			log.Fatal(err)
		}
	}
}
0707010000000F000081A400000000000000000000000164D65881000004BA000000000000000000000000000000000000002900000000uyuni-tools-v0.0.1.6/shared/utils/pod.gopackage utils

// This map should match the volumes mapping from the container definition in both
// the helm chart and the systemctl services definitions
var VOLUMES = map[string]string{
	"var-lib-cobbler":     "/var/lib/cobbler",
	"var-pgsql":           "/var/lib/pgsql",
	"var-cache":           "/var/cache",
	"var-spacewalk":       "/var/spacewalk",
	"var-log":             "/var/log",
	"srv-salt":            "/srv/salt",
	"srv-www-pub":         "/srv/www/htdocs/pub",
	"srv-www-cobbler":     "/srv/www/cobbler",
	"srv-www-osimages":    "/srv/www/os-images",
	"srv-tftpboot":        "/srv/tftpboot",
	"srv-formulametadata": "/srv/formula_metadata",
	"srv-pillar":          "/srv/pillar",
	"srv-susemanager":     "/srv/susemanager",
	"srv-spacewalk":       "/srv/spacewalk",
	"root":                "/root",
	"etc-apache2":         "/etc/apache2",
	"etc-rhn":             "/etc/rhn",
	"etc-systemd":         "/etc/systemd/system/multi-user.target.wants",
	"etc-salt":            "/etc/salt",
	"etc-tomcat":          "/etc/tomcat",
	"etc-cobbler":         "/etc/cobbler",
	"etc-sysconfig":       "/etc/sysconfig",
	"etc-tls":             "/etc/pki/tls",
	"ca-cert":             "/etc/pki/trust/anchors/",
}
07070100000010000081A400000000000000000000000164D658810000009D000000000000000000000000000000000000002C00000000uyuni-tools-v0.0.1.6/shared/utils/slices.gopackage utils

func Contains(slice []string, needle string) bool {
	for _, item := range slice {
		if item == needle {
			return true
		}
	}
	return false
}
07070100000011000081A400000000000000000000000164D6588100000C5E000000000000000000000000000000000000002B00000000uyuni-tools-v0.0.1.6/shared/utils/utils.gopackage utils

import (
	"bufio"
	"fmt"
	"log"
	"os"
	"os/exec"
	"strings"
	"syscall"
	"time"

"github.com/spf13/viper"
	"golang.org/x/term"
)

func GetCommand() string {
	command := ""

_, err := exec.LookPath("kubectl")
	if err == nil {
		if err = exec.Command("kubectl", "get", "pod").Run(); err != nil {
			log.Print("kubectl not configured to connect to a cluster, ignoring")
		} else {
			command = "kubectl"
		}
	}

if _, err = exec.LookPath("podman"); err == nil {
		command = "podman"
	}

if command == "" {
		log.Fatal("Neither podman nor kubectl are available")
	}
	return command
}

func GetPodName(fail bool) (string, string) {
	command := GetCommand()
	pod := "uyuni-server"

switch command {
	case "podman":
		if out, _ := exec.Command("podman", "ps", "-q", "-f", "name="+pod).Output(); len(out) == 0 {
			if fail {
				log.Fatalf("Container %s is not running on podman", pod)
			}
		}
	case "kubectl":
		podCmd := exec.Command("kubectl", "get", "pod", "-lapp=uyuni", "-o=jsonpath={.items[0].metadata.name}")
		podName, err := podCmd.Output()
		if err == nil {
			pod = string(podName[:])
		}
	}
	return command, pod
}

// WaitForServer waits at most 60s for multi-user systemd target to be reached.
func WaitForServer() {
	// Wait for the system to be up
	for i := 0; i < 60; i++ {
		cmd, podName := GetPodName(false)
		args := []string{"exec", podName}
		if cmd == "kubectl" {
			args = append(args, "--")
		}
		args = append(args, "systemctl", "is-active", "-q", "multi-user.target")
		testCmd := exec.Command(cmd, args...)
		testCmd.Run()
		log.Printf("Ran %s %s: %d\n", cmd, strings.Join(args, " "), testCmd.ProcessState.ExitCode())
		if testCmd.ProcessState.ExitCode() == 0 {
			return
		}
		time.Sleep(1 * time.Second)
	}
	log.Fatalf("Server didn't start within 60s")
}

func RunCmd(command string, args []string, errMessage string, verbose bool) {
	if verbose {
		fmt.Printf("> Running: %s %s\n", command, strings.Join(args, " "))
	}
	cmd := exec.Command(command, args...)
	if out, err := cmd.CombinedOutput(); err != nil {
		log.Fatalf("%s:\n  %s\n", errMessage, strings.ReplaceAll(string(out[:]), "\n", "\n  "))
	}
}

const PROMPT_END = ": "

func AskPasswordIfMissing(viper *viper.Viper, key string, prompt string) {
	value := viper.GetString(key)
	if value == "" {
		fmt.Print(prompt + PROMPT_END)
		bytePassword, err := term.ReadPassword(int(syscall.Stdin))
		if err != nil {
			log.Fatalf("Failed to read password: %s\n", err)
		}
		viper.Set(key, string(bytePassword))
		fmt.Println()
	}
}

func AskIfMissing(viper *viper.Viper, key string, prompt string) {
	value := viper.GetString(key)
	if value == "" {
		fmt.Print(prompt + PROMPT_END)
		reader := bufio.NewReader(os.Stdin)
		value, err := reader.ReadString('\n')
		if err != nil {
			log.Fatalf("Failed to read input: %s\n", err)
		}
		viper.Set(key, value)
		fmt.Println()
	}
}

// Get the timezone set on the machine running the tool
func GetLocalTimezone() string {
	out, err := exec.Command("timedatectl", "show", "--value", "-p", "Timezone").Output()
	if err != nil {
		log.Fatalf("Failed to run timedatectl show --value -p Timezone: %s\n", err)
	}
	return string(out)
}
07070100000012000081A400000000000000000000000164D658810000000E000000000000000000000000000000000000002900000000uyuni-tools-v0.0.1.6/uyuni-tools.changes- First draft
07070100000013000081A400000000000000000000000164D65881000007D6000000000000000000000000000000000000002600000000uyuni-tools-v0.0.1.6/uyuni-tools.spec#
# spec file for package uyuni-tools
#
# Copyright (c) 2023 SUSE LLC
#
# All modifications and additions to the file contributed by third parties
# remain the property of their copyright owners, unless otherwise agreed
# upon. The license for this file, and modifications and additions to the
# file, is the same license as for the pristine package itself (unless the
# license for the pristine package is not an Open Source License, in which
# case the license is the MIT License). An "Open Source License" is a
# license that conforms to the Open Source Definition (Version 1.9)
# published by the Open Source Initiative.

# Please submit bugfixes or comments via https://bugs.opensuse.org/
#

%global provider        github
%global provider_tld    com
%global org             uyuni-project 
%global project         uyuni-tools
%global provider_prefix %{provider}.%{provider_tld}/%{org}/%{project}

Name:           %{project}
Version:        0.0.1
Release:        0
Summary:        Tools for managing uyuni container
License:        Apache-2.0
Group:          System/Management
URL:            https://%{provider_prefix}
Source0:        %{name}-%{version}.tar.gz
Source1:        vendor.tar.gz
BuildRequires:  golang-packaging
BuildRequires:  coreutils
%if 0%{?rhel}
BuildRequires:  golang >= 1.19
%else
BuildRequires:  golang(API) = 1.19
%endif
BuildRequires:  rsyslog

BuildRequires:       gpgme
BuildRequires:       device-mapper-devel
BuildRequires:       libbtrfs-devel
BuildRequires:       libgpgme-devel

%description
Tools for managing uyuni container.

%prep
%autosetup
tar -zxf %{SOURCE1}

%build
export GOFLAGS=-mod=vendor
%goprep %{provider_prefix}
mkdir -p bin && go build -o ./bin ./...

%install
install -m 0755 -vd %{buildroot}%{_bindir}
install -m 0755 -vp ./bin/* %{buildroot}%{_bindir}/

%gofilelist

%define _release_dir  %{_builddir}/%{project}-%{version}/release

%files

%defattr(-,root,root)
%doc README.md
%license LICENSE

%{_bindir}/uyuniadm
%{_bindir}/uyunictl

%changelog
07070100000014000041ED00000000000000000000000364D6588100000000000000000000000000000000000000000000001E00000000uyuni-tools-v0.0.1.6/uyuniadm07070100000015000041ED00000000000000000000000564D6588100000000000000000000000000000000000000000000002200000000uyuni-tools-v0.0.1.6/uyuniadm/cmd07070100000016000081A400000000000000000000000164D6588100000887000000000000000000000000000000000000002900000000uyuni-tools-v0.0.1.6/uyuniadm/cmd/cmd.gopackage cmd

import (
	"github.com/spf13/cobra"
	"github.com/uyuni-project/uyuni-tools/shared/types"
	"github.com/uyuni-project/uyuni-tools/uyuniadm/cmd/install"
	"github.com/uyuni-project/uyuni-tools/uyuniadm/cmd/migrate"
	"github.com/uyuni-project/uyuni-tools/uyuniadm/cmd/uninstall"
)

// NewCommand returns a new cobra.Command implementing the root command for kinder
func NewUyuniadmCommand() *cobra.Command {
	globalFlags := &types.GlobalFlags{}
	rootCmd := &cobra.Command{
		Use:     "uyuniadm",
		Short:   "Uyuni administration tool",
		Long:    "Uyuni administration tool used to help user administer uyuni servers on k8s and podman",
		Version: "0.0.1",
	}

rootCmd.PersistentFlags().BoolVarP(&globalFlags.Verbose, "verbose", "v", false, "verbose output")
	rootCmd.PersistentFlags().StringVarP(&globalFlags.ConfigPath, "config", "c", "", "configuration file path")

migrateCmd := migrate.NewCommand(globalFlags)
	addCommonFlags(migrateCmd)
	rootCmd.AddCommand(migrateCmd)

installCmd := install.NewCommand(globalFlags)
	addCommonFlags(installCmd)
	rootCmd.AddCommand(installCmd)

rootCmd.AddCommand(uninstall.NewCommand(globalFlags))

return rootCmd
}

func addCommonFlags(cmd *cobra.Command) {
	cmd.Flags().StringSlice("podman-arg", []string{}, "Extra arguments to pass to podman, separated by commas")

cmd.Flags().String("helm-uyuni-namespace", "default", "Kubernetes namespace where to install uyuni")
	cmd.Flags().String("helm-uyuni-chart", "oci://registry.opensuse.org/uyuni/server", "URL to the uyuni helm chart")
	cmd.Flags().String("helm-uyuni-version", "", "Version of the uyuni helm chart")
	cmd.Flags().String("helm-uyuni-values", "", "Path to a values YAML file to use for Uyuni helm install")
	cmd.Flags().String("helm-certmanager-namespace", "cert-manager", "Kubernetes namespace where to install cert-manager")
	cmd.Flags().String("helm-certmanager-chart", "", "URL to the cert-manager helm chart. To be used for offline installations")
	cmd.Flags().String("helm-certmanager-version", "", "Version of the cert-manager helm chart")
	cmd.Flags().String("helm-certmanager-values", "", "Path to a values YAML file to use for cert-manager helm install")
}
07070100000017000041ED00000000000000000000000264D6588100000000000000000000000000000000000000000000002A00000000uyuni-tools-v0.0.1.6/uyuniadm/cmd/install07070100000018000081A400000000000000000000000164D6588100001381000000000000000000000000000000000000003500000000uyuni-tools-v0.0.1.6/uyuniadm/cmd/install/install.gopackage install

import (
	"github.com/spf13/cobra"
	"github.com/spf13/viper"
	"github.com/uyuni-project/uyuni-tools/shared/types"
	"github.com/uyuni-project/uyuni-tools/shared/utils"
)

type flagpole struct {
	image       string
	imageTag    string
	timeZone    string
	manager     manager
	reportDB    database
	cert        certificate
	enableTftp  bool
	sccUser     string
	sccPassword string
}

func NewCommand(globalFlags *types.GlobalFlags) *cobra.Command {
	flags := &flagpole{}

installCmd := &cobra.Command{
		Use:   "install [fqdn]",
		Short: "install a new server from scratch",
		Long: `Install a new server from scratch

The install command assumes the following:
  * podman or kubectl is installed locally
  * if kubectl is installed, a working kubeconfig should be set to connect to the cluster to deploy to

When installing on kubernetes, the helm values file will be overridden with the values from the uyuniadm parameters or configuration.

NOTE: for now installing on a remote cluster or podman is not supported!
`,
		Args: cobra.ExactArgs(1),
		Run: func(cmd *cobra.Command, args []string) {
			viper := utils.ReadConfig(globalFlags.ConfigPath, "admconfig", cmd)
			command := utils.GetCommand()
			checkParameters(cmd, viper, flags, command)
			switch command {
			case "podman":
				installForPodman(viper, globalFlags, cmd, args)
			case "kubectl":
				installForKubernetes(viper, globalFlags, cmd, args)
			}
		},
	}

installCmd.Flags().String("image", "registry.opensuse.org/uyuni/server", "Image")
	installCmd.Flags().String("tag", "latest", "Tag Image")

installCmd.Flags().String("tz", "Etc/UTC", "Time zone to set on the server. Defaults to the host timezone")
	installCmd.Flags().String("email", "admin@example.com", "Administrator e-mail")
	installCmd.Flags().String("emailfrom", "admin@example.com", "E-Mail sending the notifications")
	installCmd.Flags().String("mirrorPath", "", "Path to mirrored packages mounted on the host")
	installCmd.Flags().String("issParent", "", "Inter Server Sync v1 parent fully qualified domain name")
	installCmd.Flags().String("db-user", "spacewalk", "Database user")
	installCmd.Flags().String("db-password", "", "Database password")
	installCmd.Flags().String("db-name", "susemanager", "Database name")
	installCmd.Flags().String("db-host", "localhost", "Database host")
	installCmd.Flags().Int("db-port", 5432, "Database port")
	installCmd.Flags().String("db-protocol", "tcp", "Database protocol")
	installCmd.Flags().String("db-admin-user", "", "External database admin user name")
	installCmd.Flags().String("db-admin-password", "", "External database admin password")
	installCmd.Flags().String("db-provider", "", "External database provider. Possible values 'aws'")

installCmd.Flags().Bool("tftp", true, "Enable TFTP")
	installCmd.Flags().String("reportdb-name", "reportdb", "Report database name")
	installCmd.Flags().String("reportdb-host", "", "Report database host. Defaults to the selected FQDN")
	installCmd.Flags().Int("reportdb-port", 5432, "Report database port")
	installCmd.Flags().String("reportdb-user", "pythia_susemanager", "Report Database username")
	installCmd.Flags().String("reportdb-password", "", "Report database password. Randomly generated by default")

installCmd.Flags().Bool("cert-useexisting", false, "Use existing SSL certificate")
	installCmd.Flags().StringSlice("cert-cname", []string{}, "SSL certificate cnames separated by commas")
	installCmd.Flags().String("cert-country", "DE", "SSL certificate country")
	installCmd.Flags().String("cert-state", "Bayern", "SSL certificate state")
	installCmd.Flags().String("cert-city", "Nuernberg", "SSL certificate city")
	installCmd.Flags().String("cert-org", "SUSE", "SSL certificate organization")
	installCmd.Flags().String("cert-ou", "SUSE", "SSL certificate organization unit")
	installCmd.Flags().String("cert-password", "", "Password for the CA certificate to generate")
	installCmd.Flags().String("cert-email", "ca-admin@example.com", "SSL certificate E-Mail")

installCmd.Flags().String("scc-user", "", "SUSE Customer Center username")
	installCmd.Flags().String("scc-password", "", "SUSE Customer Center password")

return installCmd
}

func checkParameters(cmd *cobra.Command, viper *viper.Viper, flags *flagpole, command string) {
	utils.AskPasswordIfMissing(viper, "db.password", cmd.Flag("db-password").Usage)

// Since we use cert-manager for self-signed certificates on kubernetes we don't need password for it
	if !flags.cert.useExistingCertificate && command == "podman" {
		utils.AskPasswordIfMissing(viper, "cert.password", cmd.Flag("cert-password").Usage)
	}

// Use the host timezone if the user didn't define one
	if viper.GetString("tz") == "" {
		viper.Set("tz", utils.GetLocalTimezone())
	}

if viper.GetString("email") == "" {
		utils.AskIfMissing(viper, "email", cmd.Flag("email").Usage)
	}

if viper.GetString("fromEmail") == "" {
		utils.AskIfMissing(viper, "emailfrom", cmd.Flag("emailfrom").Usage)
	}
}
07070100000019000081A400000000000000000000000164D6588100002B4E000000000000000000000000000000000000003800000000uyuni-tools-v0.0.1.6/uyuniadm/cmd/install/kubernetes.gopackage install

import (
	"encoding/base64"
	"fmt"
	"log"
	"os"
	"os/exec"
	"path/filepath"
	"strconv"
	"strings"
	"text/template"
	"time"

"github.com/spf13/cobra"
	"github.com/spf13/viper"
	"github.com/uyuni-project/uyuni-tools/shared/types"
	"github.com/uyuni-project/uyuni-tools/shared/utils"
)

const HELM_APP_NAME = "uyuni"

func installForKubernetes(viper *viper.Viper, globalFlags *types.GlobalFlags, cmd *cobra.Command, args []string) {
	fqdn := args[0]
	if viper.GetBool("cert.useexisting") {
		// TODO Check that we have the expected secret and config in place
	} else {
		// Install cert-manager and a self-signed issuer ready for use
		installSslCertificates(viper, fqdn, globalFlags)
	}

// Extract the CA cert into uyuni-ca config map as the container shouldn't have the CA secret
	extractCaCertToConfig(globalFlags.Verbose)

// Deploy the helm chart
	uyuniInstall(viper, fqdn, globalFlags)

// Wait for the pod to be started
	waitForDeployment(viper.GetString("helm.namespace"), HELM_APP_NAME, "uyuni")
	utils.WaitForServer()

// Create setup script + env variables and copy it to the container
	envs := map[string]string{
		"NO_SSL": "Y",
	}

runSetup(viper, globalFlags, args[0], envs)
}

// Install cert-manager and its CRDs using helm in the cert-manager namespace if needed
// and then create a self-signed CA and issuers.
func installSslCertificates(viper *viper.Viper, fqdn string, globalFlags *types.GlobalFlags) {
	// Install cert-manager if needed
	if !isDeploymentReady("", "cert-manager") {
		log.Println("Installing cert-manager")
		repo := ""
		chart := viper.GetString("helm.certmanager.chart")
		version := viper.GetString("helm.certmanager.version")
		namespace := viper.GetString("helm.certmanager.namespace")

args := []string{
			"--set", "installCRDs=true",
			"--set-json", "global.commonLabels={\"installedby\": \"uyuniadm\"}",
		}
		extraValues := viper.GetString("helm.certmanager.values")
		if extraValues != "" {
			args = append(args, "-f", extraValues)
		}

// Use upstream chart if nothing defined
		if chart == "" {
			repo = "https://charts.jetstack.io"
			chart = "cert-manager"
		}
		// The installedby label will be used to only uninstall what we installed
		helmInstall(globalFlags, namespace, repo, "cert-manager", chart, version, args...)
	}

// Wait for cert-manager to be ready
	waitForDeployment("", "cert-manager-webhook", "webhook")

// Deploy self-signed issuer
	const issuerTemplate = `apiVersion: cert-manager.io/v1
kind: Issuer
metadata:
  name: uyuni-issuer
  namespace: default
spec:
  selfSigned: {}
---
apiVersion: cert-manager.io/v1
kind: Certificate
metadata:
  name: uyuni-ca
  namespace: default
spec:
  isCA: true
  subject:
    countries: ["{{ .Country }}"]
    provinces: ["{{ .State }}"]
    localities: ["{{ .City }}"]
    organizations: ["{{ .Org }}"]
    organizationalUnits: ["{{ .OrgUnit }}"]
  emailAddresses:
    - {{ .Email }}
  commonName: {{ .Fqdn }}
  dnsNames:
    - {{ .Fqdn }}
  secretName: uyuni-ca
  privateKey:
    algorithm: ECDSA
    size: 256
  issuerRef:
    name: uyuni-issuer
    kind: Issuer
    group: cert-manager.io
---
apiVersion: cert-manager.io/v1
kind: Issuer
metadata:
  name: uyuni-ca-issuer
  namespace: default
spec:
  ca:
    secretName:
      uyuni-ca
`

log.Println("Creating issuer for self signed SSL certificate authority")
	crdsDir, err := os.MkdirTemp("", "uyuniadm-*")
	if err != nil {
		log.Fatalf("Failed to create temporary directory: %s\n", err)
	}
	defer os.RemoveAll(crdsDir)

issuerPath := filepath.Join(crdsDir, "issuer.yaml")
	file, err := os.OpenFile(issuerPath, os.O_WRONLY|os.O_CREATE, 0500)
	if err != nil {
		log.Fatalf("Fail to open %s file for writing: %s\n", issuerPath, err)
	}
	defer file.Close()

model := struct {
		Country string
		State   string
		City    string
		Org     string
		OrgUnit string
		Email   string
		Fqdn    string
	}{
		Country: viper.GetString("cert.country"),
		State:   viper.GetString("cert.state"),
		City:    viper.GetString("cert.city"),
		Org:     viper.GetString("cert.org"),
		OrgUnit: viper.GetString("cert.ou"),
		Email:   viper.GetString("cert.email"),
		Fqdn:    fqdn,
	}

t := template.Must(template.New("issuer").Parse(issuerTemplate))
	if err = t.Execute(file, model); err != nil {
		log.Fatalf("Failed to generate issuer definition: %s\n", err)
	}

utils.RunCmd("kubectl", []string{"apply", "-f", filepath.Join(crdsDir, "issuer.yaml")},
		"Failed to create issuer", globalFlags.Verbose)

// Wait for issuer to be ready
	for i := 0; i < 60; i++ {
		out, err := exec.Command("kubectl", "get", "-o=jsonpath={.status.conditions[*].type}",
			"issuer", "uyuni-ca-issuer").Output()
		if err == nil && string(out) == "Ready" {
			return
		}
		time.Sleep(1 * time.Second)
	}
	log.Fatalln("Issuer didn't turn ready after 60s")
}

func extractCaCertToConfig(verbose bool) {
	// TODO Replace with [trust-manager](https://cert-manager.io/docs/projects/trust-manager/) to automate this

log.Println("Extracting CA certificate to a configmap")
	// Skip extracting if the configmap is already present
	out, err := exec.Command("kubectl", "get", "configmap", "uyuni-ca", "-o=jsonpath={.data.ca\\.crt}").Output()
	log.Printf("CA cert: %s\n", string(out))
	if err == nil && len(out) > 0 {
		log.Println("uyuni-ca configmap already existing, skipping extraction")
		return
	}

out, err = exec.Command("kubectl", "get", "secret", "uyuni-ca", "-o=jsonpath={.data.ca\\.crt}").Output()
	if err != nil {
		log.Fatalf("Failed to get uyuni-ca certificate: %s\n", err)
	}

decoded, err := base64.StdEncoding.DecodeString(string(out))
	if err != nil {
		log.Fatalf("Failed to base64 decode CA certificate: %s", err)
	}

message := fmt.Sprintf("Failed to create uyuni-ca config map from certificate: %s\n", err)
	valueArg := "--from-literal=ca.crt=" + string(decoded)
	utils.RunCmd("kubectl", []string{"create", "configmap", "uyuni-ca", valueArg}, message, verbose)
}

func uyuniInstall(viper *viper.Viper, fqdn string, globalFlags *types.GlobalFlags) {
	log.Println("Installing Uyuni")

// The issuer annotation is before the user's value to allow it to be overwritten for now.
	// TODO Parametrize the ca issuer value?
	helmParams := []string{"--set-json", "ingressSslAnnotations={\"cert-manager.io/issuer\": \"uyuni-ca-issuer\"}"}

extraValues := viper.GetString("helm.uyuni.values")
	if extraValues != "" {
		helmParams = append(helmParams, "-f", extraValues)
	}

// The values computed from the command line need to be last to override what could be in the extras
	helmParams = append(helmParams,
		"--set", fmt.Sprintf("images.server=%s:%s", viper.GetString("image"), viper.GetString("tag")),
		"--set", "timezone="+viper.GetString("tz"),
		"--set", "fqdn="+fqdn)

namespace := viper.GetString("helm.uyuni.namespace")
	chart := viper.GetString("helm.uyuni.chart")
	version := viper.GetString("helm.uyuni.version")
	helmInstall(globalFlags, namespace, "", HELM_APP_NAME, chart, version, helmParams...)
}

// helmInstall runs helm install.
// If repo is not empty, the --repo parameter will be passed.
// If version is not empty, the --version parameter will be passed.
func helmInstall(globalFlags *types.GlobalFlags, namespace string, repo string, name string, chart string, version string, args ...string) {
	helmArgs := []string{
		"install",
		"-n", namespace,
		"--create-namespace",
		name,
		chart,
	}
	if repo != "" {
		helmArgs = append(helmArgs, "--repo", repo)
	}
	if version != "" {
		helmArgs = append(helmArgs, "--version", version)
	}
	helmArgs = append(helmArgs, args...)
	errorMessage := fmt.Sprintf("Failed to install helm chart %s in namespace %s", chart, namespace)

utils.RunCmd("helm", helmArgs, errorMessage, globalFlags.Verbose)
}

// waitForDeployment waits at most 60s for a kubernetes deployment to have at least one replica.
// See [isDeploymentReady] for more details.
func waitForDeployment(namespace string, name string, appName string) {
	// Find the name of a replica pod
	// Using the app label is a shortcut, not the 100% acurate way to get from deployment to pod
	podName := ""
	jsonpath := fmt.Sprintf("jsonpath={.items[?(@.metadata.labels.app==\"%s\")].metadata.name}", appName)
	cmdArgs := []string{"get", "pod", "-o", jsonpath}
	cmdArgs = addNamespace(cmdArgs, namespace)

for i := 0; i < 60; i++ {
		out, err := exec.Command("kubectl", cmdArgs...).Output()
		if err == nil {
			podName = string(out)
			break
		}
	}

// We need to wait for the image to be pulled as this can add quite some time
	// Setting a timeout on this is very hard since it hightly depends on network speed and image size
	// List the Pulled events from the pod as we may not see the Pulling if the image was already downloaded
	waitForPulledImage(namespace, podName)

// Wait for a replica to be ready
	for i := 0; i < 60; i++ {
		// TODO Look for pod failures
		if isDeploymentReady(namespace, name) {
			return
		}
		time.Sleep(1 * time.Second)
	}
	log.Fatalf("Failed to find a ready replica for deployment %s in namespace %s after 60s\n", name, namespace)
}

func waitForPulledImage(namespace string, podName string) {
	pulledArgs := []string{"get", "event",
		"-o", "jsonpath={.items[?(@.reason==\"Pulled\")].message}",
		"--field-selector", "involvedObject.name=" + podName}
	pulledArgs = addNamespace(pulledArgs, namespace)

failedArgs := []string{"get", "event",
		"-o", "jsonpath={range .items[?(@.reason==\"Failed\")]}{.message}{\"\\n\"}{end}",
		"--field-selector", "involvedObject.name=" + podName}
	failedArgs = addNamespace(failedArgs, namespace)
	for {
		// Look for events indicating an image pull issue
		out, err := exec.Command("kubectl", failedArgs...).Output()
		if err != nil {
			log.Fatalf("Failed to get failed events for pod %s: %s", podName, err)
		}
		lines := strings.Split(string(out), "\n")
		for _, line := range lines {
			if strings.HasPrefix(line, "Failed to pull image") {
				log.Fatalln(err)
			}
		}

// Has the image pull finished?
		out, err = exec.Command("kubectl", pulledArgs...).Output()
		if err != nil {
			log.Fatalf("Failed to get events for pod %s: %s\n", podName, err)
		}
		if len(out) > 0 {
			break
		}
		time.Sleep(1 * time.Second)
	}
}

// isDeploymentReady returns true if a kubernetes deployment has at least one ready replica.
// The name can also be a filter parameter like -lapp=uyuni.
// An empty namespace means searching through all the namespaces.
func isDeploymentReady(namespace string, name string) bool {
	jsonpath := fmt.Sprintf("jsonpath={.items[?(@.metadata.name==\"%s\")].status.readyReplicas}", name)
	args := []string{"get", "-o", jsonpath, "deploy"}
	args = addNamespace(args, namespace)

out, err := exec.Command("kubectl", args...).Output()
	// kubectl errors out if the deployment or namespace doesn't exist
	if err == nil {
		if replicas, _ := strconv.Atoi(string(out)); replicas > 0 {
			return true
		}
	}
	return false
}

func addNamespace(args []string, namespace string) []string {
	if namespace != "" {
		args = append(args, "-n", namespace)
	} else {
		args = append(args, "-A")
	}
	return args
}
0707010000001A000081A400000000000000000000000164D6588100000891000000000000000000000000000000000000003400000000uyuni-tools-v0.0.1.6/uyuniadm/cmd/install/podman.gopackage install

import (
	"fmt"
	"log"
	"os"
	"os/exec"
	"strings"

"github.com/spf13/cobra"
	"github.com/spf13/viper"
	"github.com/uyuni-project/uyuni-tools/shared/podman"
	"github.com/uyuni-project/uyuni-tools/shared/types"
	"github.com/uyuni-project/uyuni-tools/shared/utils"
)

func waitForSystemStart(viper *viper.Viper, globalFlags *types.GlobalFlags) {
	// Setup the systemd service configuration options
	image := fmt.Sprintf("%s:%s", viper.GetString("image"), viper.GetString("tag"))
	podman.GenerateSystemdService(viper.GetString("tz"), image, viper.GetStringSlice("podman.arg"), globalFlags.Verbose)

log.Println("Waiting for the server to start...")
	// Start the service
	if err := exec.Command("systemctl", "enable", "--now", "uyuni-server").Run(); err != nil {
		log.Fatalf("Failed to enable uyuni-server systemd service: %s\n", err)
	}

utils.WaitForServer()
}

func pullImage(viper *viper.Viper) {
	image := fmt.Sprintf("%s:%s", viper.GetString("image"), viper.GetString("tag"))
	log.Printf("Running podman pull %s\n", image)
	cmd := exec.Command("podman", "pull", image)
	cmd.Stdout = os.Stdout
	cmd.Stderr = os.Stderr

if err := cmd.Run(); err != nil {
		log.Fatalf("Failed to pull image: %s\n", err)
	}
}

func installForPodman(viper *viper.Viper, globalFlags *types.GlobalFlags, cmd *cobra.Command, args []string) {
	pullImage(viper)

waitForSystemStart(viper, globalFlags)

env := map[string]string{}
	if viper.GetBool("cert.useexisting") {
		// TODO Get existing certificates path and mount them
		// Set CA_CERT, SERVER_CERT, SERVER_KEY or run the rhn-ssl-check tool in a container
		// The SERVER_CERT needs to get the intermediate keys
	} else {
		env["CERT_O"] = viper.GetString("cert.org")
		env["CERT_OU"] = viper.GetString("cert.ou")
		env["CERT_CITY"] = viper.GetString("cert.city")
		env["CERT_STATE"] = viper.GetString("cert.state")
		env["CERT_COUNTRY"] = viper.GetString("cert.country")
		env["CERT_EMAIL"] = viper.GetString("cert.email")
		env["CERT_CNAMES"] = strings.Join(append([]string{args[0]}, viper.GetStringSlice("cert.cnames")...), ",")
		env["CERT_PASS"] = viper.GetString("cert.password")
	}

runSetup(viper, globalFlags, args[0], env)
}
0707010000001B000081A400000000000000000000000164D6588100000F18000000000000000000000000000000000000003400000000uyuni-tools-v0.0.1.6/uyuniadm/cmd/install/shared.gopackage install

import (
	"log"
	"os"
	"path/filepath"
	"strconv"
	"text/template"

"github.com/spf13/viper"
	"github.com/uyuni-project/uyuni-tools/shared/types"
	"github.com/uyuni-project/uyuni-tools/shared/utils"
)

const SETUP_NAME = "setup.sh"

func runSetup(viper *viper.Viper, globalFlags *types.GlobalFlags, fqdn string, env map[string]string) {
	tmpFolder := generateSetupScript(viper, fqdn, env)
	defer os.RemoveAll(tmpFolder)

utils.Copy(globalFlags, filepath.Join(tmpFolder, SETUP_NAME), "server:/tmp/setup.sh", "root", "root")

utils.Exec(globalFlags, false, false, []string{}, "/tmp/setup.sh")

log.Println("Server set up")
}

// generateSetupScript creates a temporary folder with the setup script to execute in the container.
// The script exports all the needed environment variables and calls uyuni's mgr-setup.
// Podman or kubernetes-specific variables can be passed using extraEnv parameter.
func generateSetupScript(viper *viper.Viper, fqdn string, extraEnv map[string]string) string {
	localHostValues := []string{
		"localhost",
		"127.0.0.1",
		"::1",
		fqdn,
	}

localDb := utils.Contains(localHostValues, viper.GetString("db.host"))

dbHost := viper.GetString("db.host")
	reportdbHost := viper.GetString("reportdb.host")

if localDb {
		// For now the setup script expects the localhost value for local DB
		// but the FQDN is required for the report db even if it's local
		dbHost = "localhost"
		if viper.GetString("reportdb.host") == "" {
			reportdbHost = fqdn
		}
	}
	env := map[string]string{
		"UYUNI_FQDN":            fqdn,
		"MANAGER_USER":          viper.GetString("db.user"),
		"MANAGER_PASS":          viper.GetString("db.password"),
		"MANAGER_ADMIN_EMAIL":   viper.GetString("email"),
		"MANAGER_MAIL_FROM":     viper.GetString("emailFrom"),
		"MANAGER_ENABLE_TFTP":   boolToString(viper.GetBool("enableTftp")),
		"LOCAL_DB":              boolToString(localDb),
		"MANAGER_DB_NAME":       viper.GetString("db.name"),
		"MANAGER_DB_HOST":       dbHost,
		"MANAGER_DB_PORT":       strconv.Itoa(viper.GetInt("db.port")),
		"MANAGER_DB_PROTOCOL":   viper.GetString("db.protocol"),
		"REPORT_DB_NAME":        viper.GetString("reportdb.name"),
		"REPORT_DB_HOST":        reportdbHost,
		"REPORT_DB_PORT":        strconv.Itoa(viper.GetInt("reportdb.port")),
		"REPORT_DB_USER":        viper.GetString("reportdb.user"),
		"REPORT_DB_PASS":        viper.GetString("reportdb.password"),
		"EXTERNALDB_ADMIN_USER": viper.GetString("db.admin.user"),
		"EXTERNALDB_ADMIN_PASS": viper.GetString("db.admin.password"),
		"EXTERNALDB_PROVIDER":   viper.GetString("db.provider"),
		"ISS_PARENT":            viper.GetString("issParent"),
		"MIRROR_PATH":           viper.GetString("mirrorPath"),
		"ACTIVATE_SLP":          "N", // Deprecated, will be removed soon
		"SCC_USER":              viper.GetString("scc.user"),
		"SCC_PASS":              viper.GetString("scc.password"),
	}

// Add the extra environment variables
	for key, value := range extraEnv {
		env[key] = value
	}

scriptDir, err := os.MkdirTemp("", "uyuniadm-*")
	if err != nil {
		log.Fatalf("Failed to create temporary directory: %s\n", err)
	}

const scriptTemplate = `#!/bin/sh
{{- range $name, $value := .Env }}
export {{ $name }}={{ $value }}
{{- end }}

/usr/lib/susemanager/bin/mgr-setup -s -n

# clean before leaving
rm $0`

model := struct {
		Env map[string]string
	}{
		Env: env,
	}

file, err := os.OpenFile(filepath.Join(scriptDir, SETUP_NAME), os.O_WRONLY|os.O_CREATE, 0555)
	if err != nil {
		log.Fatalf("Fail to open setup script: %s\n", err)
	}
	defer file.Close()

t := template.Must(template.New("script").Parse(scriptTemplate))
	if err = t.Execute(file, model); err != nil {
		log.Fatalf("Failed to generate setup script: %s\n", err)
	}

return scriptDir
}

func boolToString(value bool) string {
	if value {
		return "Y"
	}
	return "N"
}
0707010000001C000081A400000000000000000000000164D65881000002C1000000000000000000000000000000000000003300000000uyuni-tools-v0.0.1.6/uyuniadm/cmd/install/types.gopackage install

type certificate struct {
	useExistingCertificate bool
	cnames                 []string
	state                  string
	city                   string
	country                string
	org                    string
	ou                     string
	password               string
	email                  string
}

type database struct {
	name          string
	host          string
	user          string
	password      string
	port          int
	protocol      string
	adminUser     string
	adminPassword string
	provider      string
}

type manager struct {
	user       string
	password   string
	email      string
	emailFrom  string
	db         database
	mirrorPath string
	issParent  string
}
0707010000001D000041ED00000000000000000000000264D6588100000000000000000000000000000000000000000000002A00000000uyuni-tools-v0.0.1.6/uyuniadm/cmd/migrate0707010000001E000081A400000000000000000000000164D6588100000BE1000000000000000000000000000000000000003800000000uyuni-tools-v0.0.1.6/uyuniadm/cmd/migrate/kubernetes.gopackage migrate

import (
	"log"
	"os"
	"path/filepath"
	"text/template"

"github.com/spf13/cobra"
	"github.com/uyuni-project/uyuni-tools/shared/types"
	"github.com/uyuni-project/uyuni-tools/shared/utils"
)

func migrateToKubernetes(globalFlags *types.GlobalFlags, flags *flagpole, cmd *cobra.Command, args []string) {
	scriptDir := generateMigrationScript(args[0], true)
	defer os.RemoveAll(scriptDir)

runMigrationJob(scriptDir, flags, globalFlags.Verbose)

// TODO Watch the logs and wait for the end of the job

// TODO prepare the values.yaml and deploy helm chart
}

type volume struct {
	HostPath string
	Path     string
}

func runMigrationJob(tmpPath string, flags *flagpole, verbose bool) {
	sshAuthSocket := getSshAuthSocket()

// Find ssh config to mount it in the container
	homedir, err := os.UserHomeDir()
	if err != nil {
		log.Fatal("Failed to find home directory to look for SSH config")
	}
	sshConfigPath := filepath.Join(homedir, ".ssh", "config")
	sshKnownhostsPath := filepath.Join(homedir, ".ssh", "known_hosts")

volumes := make(map[string]volume)
	for name, path := range utils.VOLUMES {
		volumes[name] = volume{Path: path}
	}
	volumes["ssh-auth-socket"] = volume{HostPath: sshAuthSocket, Path: "/tmp/ssh_auth_sock"}
	volumes["ssh-config"] = volume{HostPath: sshConfigPath, Path: "/root/.ssh/config"}
	volumes["ssh-known-hosts"] = volume{HostPath: sshKnownhostsPath, Path: "/root/.ssh/known_hosts"}

model := struct {
		Volumes map[string]volume
		Image   string
		Tag     string
	}{
		Volumes: volumes,
		Image:   flags.Image,
		Tag:     flags.ImageTag,
	}

// TODO PVCs and PVs need to be ready before this

migrationYamlPath := filepath.Join(tmpPath, "migration-job.yaml")
	file, err := os.OpenFile(migrationYamlPath, os.O_WRONLY|os.O_CREATE, 0600)
	if err != nil {
		log.Fatalf("Fail to open migration job definition file: %s\n", err)
	}
	defer file.Close()

t := template.Must(template.New("job").Parse(migrationJob))
	if err = t.Execute(file, model); err != nil {
		log.Fatalf("Failed to generate migration job description: %s\n", err)
	}

utils.RunCmd("kubectl", []string{"apply", "-f", migrationYamlPath}, "Failed to start migration job", verbose)
}

const migrationJob = `apiVersion: batch/v1
kind: Job
metadata:
  name: uyuni-migration
spec:
  backoffLimit: 1
  template:
    spec:
      restartPolicy: Never
      containers:
      - name: rsync-var-pgsql
        image: {{ .Image }}:{{ .Tag }}
        command: [ "/var/lib/uyuni-tools/migrate.sh" ]
        env:
          - name: SSH_AUTH_SOCK
            value: /tmp/ssh_auth_sock
        volumeMounts:
        {{- range $name, $volume := .Volumes }}
          - mountPath: {{ $volume.Path }}
            name: {{ $name }}
        {{- end }}
      volumes:
	  {{- range $name, $volume := .Volumes }}
        - name: {{ $name }}
		{{- if eq $volume.HostPath "" }}
          persistentVolumeClaim:
            claimName: {{ $name }}
		{{- else }}
          hostPath:
            path: {{ $volume.HostPath }}
	    {{- end }}
      {{- end }}
`
0707010000001F000081A400000000000000000000000164D6588100000641000000000000000000000000000000000000003500000000uyuni-tools-v0.0.1.6/uyuniadm/cmd/migrate/migrate.gopackage migrate

import (
	"github.com/spf13/cobra"
	"github.com/uyuni-project/uyuni-tools/shared/types"
	"github.com/uyuni-project/uyuni-tools/shared/utils"
)

type flagpole struct {
	Image    string
	ImageTag string
}

func NewCommand(globalFlags *types.GlobalFlags) *cobra.Command {
	flags := &flagpole{}

migrateCmd := &cobra.Command{
		Use:   "migrate [source server FQDN]",
		Short: "migrate a remote server to containers",
		Long: `Migrate a remote server to containers

This migration command assumes a few things:
  * the SSH configuration for the source server is complete, including user and
    all needed options to connect to the machine,
  * the SSH configuration should stored in $HOME/.ssh, including the keys
  * an SSH agent is started and the key to use to connect to the server is added to it,
  * podman or kubectl is installed locally
  * if kubectl is installed, a working kubeconfig should be set to connect to the cluster to deploy to

NOTE: for now installing on a remote cluster or podman is not supported yet!
`,
		Args: cobra.ExactArgs(1),
		Run: func(cmd *cobra.Command, args []string) {
			command := utils.GetCommand()
			switch command {
			case "podman":
				migrateToPodman(globalFlags, flags, cmd, args)
			case "kubectl":
				migrateToKubernetes(globalFlags, flags, cmd, args)
			}
		},
	}

// TODO We probably want to move these default values to a config file
	migrateCmd.Flags().StringVar(&flags.Image, "image", "registry.opensuse.org/uyuni/server", "Image")
	migrateCmd.Flags().StringVar(&flags.ImageTag, "tag", "latest", "Tag Image")

return migrateCmd
}
07070100000020000081A400000000000000000000000164D6588100000BD2000000000000000000000000000000000000003400000000uyuni-tools-v0.0.1.6/uyuniadm/cmd/migrate/podman.gopackage migrate

import (
	"bytes"
	"fmt"
	"log"
	"os"
	"os/exec"
	"path/filepath"
	"strings"

func migrateToPodman(globalFlags *types.GlobalFlags, flags *flagpole, cmd *cobra.Command, args []string) {
	sshAuthSocket := getSshAuthSocket()

sourceFqdn := args[0]

// Find ssh config to mount it in the container
	homedir, err := os.UserHomeDir()
	if err != nil {
		log.Fatal("Failed to find home directory to look for SSH config")
	}
	sshPath := filepath.Join(homedir, ".ssh")
	scriptDir := generateMigrationScript(sourceFqdn, false)
	defer os.RemoveAll(scriptDir)

extraArgs := []string{
		"-e", "SSH_AUTH_SOCK",
		"-v", filepath.Dir(sshAuthSocket) + ":" + filepath.Dir(sshAuthSocket),
		"-v", scriptDir + ":/var/lib/uyuni-tools/",
	}

if _, err = os.Stat(sshPath); err == nil {
		extraArgs = append(extraArgs, "-v", sshPath+":/root/.ssh")

}

log.Println("Migrating server")
	runContainer("uyuni-migration", flags.Image, flags.ImageTag, extraArgs,
		[]string{"/var/lib/uyuni-tools/migrate.sh"}, []string{}, globalFlags.Verbose)

// Read the extracted data
	data, err := os.ReadFile(filepath.Join(scriptDir, "data"))
	if err != nil {
		log.Fatalf("Failed to read data extracted from source host")
	}
	viper.SetConfigType("env")
	viper.ReadConfig(bytes.NewBuffer(data))
	tz := viper.GetString("Timezone")

image := fmt.Sprintf("%s:%s", flags.Image, flags.ImageTag)

podmanMigrateArgs := viper.GetStringSlice("podman.arg")
	podmanMigrateArgs = append(podmanMigrateArgs, "--hostname="+sourceFqdn)

podman.GenerateSystemdService(tz, image, podmanMigrateArgs, globalFlags.Verbose)

// Start the service
	if err = exec.Command("systemctl", "enable", "--now", "uyuni-server").Run(); err != nil {
		log.Fatalf("Failed to enable uyuni-server systemd service: %s\n", err)
	}

log.Println("Server migrated")
}

func runContainer(name string, image string, tag string, extraArgs []string, cmd []string, env []string, verbose bool) {

podmanArgs := append([]string{"run"}, podman.GetCommonParams(name)...)
	podmanArgs = append(podmanArgs, extraArgs...)

for volumeName, containerPath := range utils.VOLUMES {
		podmanArgs = append(podmanArgs, "-v", volumeName+":"+containerPath)
	}

podmanArgs = append(podmanArgs, image+":"+tag)
	podmanArgs = append(podmanArgs, cmd...)

podmanCmd := exec.Command("podman", podmanArgs...)

if verbose {
		log.Printf("Running command: podman %s\n", strings.Join(podmanArgs, " "))
	}
	podmanCmd.Stdout = os.Stdout
	podmanCmd.Stderr = os.Stderr

podmanCmd.Env = append(podmanCmd.Environ(), env...)
	if err := podmanCmd.Start(); err != nil {
		log.Fatalf("Failed to start %s container: %s\n", name, err)
	}

// Wait for the migration to finish and report errors
	if err := podmanCmd.Wait(); err != nil {
		log.Fatalf("Failed to wait for container to finish: %s\n", err)
	}
}
07070100000021000081A400000000000000000000000164D6588100000796000000000000000000000000000000000000003300000000uyuni-tools-v0.0.1.6/uyuniadm/cmd/migrate/utils.gopackage migrate

import (
	"log"
	"os"
	"path/filepath"
	"text/template"

"github.com/uyuni-project/uyuni-tools/shared/utils"
)

func getSshAuthSocket() string {
	path := os.Getenv("SSH_AUTH_SOCK")
	if len(path) == 0 {
		log.Fatal("SSH_AUTH_SOCK is not defined, start an ssh agent and try again")
	}
	return path
}

func generateMigrationScript(sourceFqdn string, kubernetes bool) string {
	scriptDir, err := os.MkdirTemp("", "uyuniadm-*")
	if err != nil {
		log.Fatalf("Failed to create temporary directory: %s\n", err)
	}

ssh {{ .SourceFqdn }} timedatectl show -p Timezone >/var/lib/uyuni-tools/data

{{ if .Kubernetes }}
echo 'server.no_ssl = 1' >> /etc/rhn/rhn.conf;
sed 's/address=[^:]*:/address=uyuni:/' -i /etc/rhn/taskomatic.conf;
sed 's/address=[^:]*:/address=uyuni:/' -i /etc/sysconfig/tomcat;
{{ else }}
sed 's/address=[^:]*:/address={{ .SourceFqdn }}:/' -i /etc/rhn/taskomatic.conf;
sed 's/address=[^:]*:/address={{ .SourceFqdn }}:/' -i /etc/sysconfig/tomcat;
{{ end }}
echo "DONE"`

model := struct {
		Volumes    map[string]string
		SourceFqdn string
		Kubernetes bool
	}{
		Volumes:    utils.VOLUMES,
		SourceFqdn: sourceFqdn,
		Kubernetes: kubernetes,
	}

file, err := os.OpenFile(filepath.Join(scriptDir, "migrate.sh"), os.O_WRONLY|os.O_CREATE, 0555)
	if err != nil {
		log.Fatalf("Fail to open migration script: %s\n", err)
	}
	defer file.Close()

t := template.Must(template.New("script").Parse(scriptTemplate))
	if err = t.Execute(file, model); err != nil {
		log.Fatalf("Failed to generate migration script: %s\n", err)
	}

return scriptDir
}
07070100000022000041ED00000000000000000000000264D6588100000000000000000000000000000000000000000000002C00000000uyuni-tools-v0.0.1.6/uyuniadm/cmd/uninstall07070100000023000081A400000000000000000000000164D6588100000829000000000000000000000000000000000000003A00000000uyuni-tools-v0.0.1.6/uyuniadm/cmd/uninstall/kubernetes.gopackage uninstall

import (
	"fmt"
	"log"
	"os/exec"

"github.com/uyuni-project/uyuni-tools/shared/types"
	"github.com/uyuni-project/uyuni-tools/shared/utils"
)

func uninstallForKubernetes(globalFlags *types.GlobalFlags, dryRun bool) {
	// Uninstall uyuni
	namespace := helmUninstall("uyuni", "", dryRun, globalFlags.Verbose)

// Remove the remaining configmap and secrets
	if namespace != "" {
		if dryRun {
			log.Printf("Would run kubectl delete -n %s configmap uyuni-ca\n", namespace)
			log.Printf("Would run kubectl delete -n %s secret uyuni-ca uyuni-cert\n", namespace)
		} else {
			log.Printf("Running kubectl delete -n %s configmap uyuni-ca\n", namespace)
			if err := exec.Command("kubectl", "delete", "-n", namespace, "configmap", "uyuni-ca").Run(); err != nil {
				log.Printf("Failed deleting config map: %s\n", err)
			}

log.Printf("Running kubectl delete -n %s secret uyuni-ca uyuni-cert\n", namespace)
			err := exec.Command("kubectl", "delete", "-n", namespace, "secret", "uyuni-ca", "uyuni-cert").Run()
			if err != nil {
				log.Printf("Failed deleting config map: %s\n", err)
			}
		}
	}

// Uninstall cert-manager if we installed it
	helmUninstall("cert-manager", "-linstalledby=uyuniadm", dryRun, globalFlags.Verbose)
}

func helmUninstall(deployment string, filter string, dryRun bool, verbose bool) string {
	jsonpath := fmt.Sprintf("jsonpath={.items[?(@.metadata.name==\"%s\")].metadata.namespace}", deployment)
	args := []string{"get", "-A", "deploy", "-o", jsonpath}
	if filter != "" {
		args = append(args, filter)
	}

cmd := exec.Command("kubectl", args...)
	out, err := cmd.Output()
	if err != nil {
		log.Printf("Failed to find %s's namespace, skipping removal: %s\n", deployment, err)
	}
	namespace := string(out)
	if namespace != "" {
		if dryRun {
			log.Printf("Would run helm uninstall %s\n", deployment)
		} else {
			log.Printf("Uninstalling %s\n", deployment)
			message := "Failed to run helm uninstall " + deployment
			utils.RunCmd("helm", []string{"uninstall", "-n", namespace, deployment}, message, verbose)
		}
	}
	return namespace
}
07070100000024000081A400000000000000000000000164D6588100000986000000000000000000000000000000000000003600000000uyuni-tools-v0.0.1.6/uyuniadm/cmd/uninstall/podman.gopackage uninstall

import (
	"fmt"
	"log"
	"os"
	"os/exec"

"github.com/uyuni-project/uyuni-tools/shared/podman"
	"github.com/uyuni-project/uyuni-tools/shared/types"
	"github.com/uyuni-project/uyuni-tools/shared/utils"
)

func uninstallForPodman(globalFlags *types.GlobalFlags, dryRun bool, purge bool) {
	// Check if there is an uyuni-server service
	if err := exec.Command("systemctl", "list-unit-files", "uyuni-server.service").Run(); err != nil {
		log.Fatalln("Systemd has no uyuni-server.service unit, nothing to uninstall")
	}

// Force stop the pod
	if out, _ := exec.Command("podman", "ps", "-q", "-f", "name=uyuni-server").Output(); len(out) > 0 {
		if dryRun {
			log.Println("Would run podman kill uyuni-server")
		} else {
			utils.RunCmd("podman", []string{"kill", "uyuni-server"}, "Failed to kill the server", globalFlags.Verbose)
		}
	}

// Disable the service
	if dryRun {
		log.Println("Would run systemctl disable --now uyuni-server")
	} else {
		utils.RunCmd("systemctl", []string{"disable", "--now", "uyuni-server"}, "Failed to disable server", globalFlags.Verbose)
	}

// Remove the volumes
	if purge {
		for volume := range utils.VOLUMES {
			if dryRun {
				log.Printf("Would run podman volume rm %s\n", volume)
			} else {
				errorMessage := fmt.Sprintf("Failed to remove volume %s", volume)
				utils.RunCmd("podman", []string{"volume", "rm", volume}, errorMessage, globalFlags.Verbose)
			}
		}

if dryRun {
			log.Println("Would run podman volume rm cgroup")
		} else {
			utils.RunCmd("podman", []string{"volume", "rm", "cgroup"}, "Failed to remove volume cgroup", globalFlags.Verbose)
		}
	}

// Remove the service unit
	if dryRun {
		log.Printf("Woud remove %s\n", podman.ServicePath)
	} else {
		if globalFlags.Verbose {
			log.Printf("Remove %s\n", podman.ServicePath)
		}
		os.Remove(podman.ServicePath)
	}

// Remove the network
	cmd := exec.Command("podman", "network", "exists", "uyuni")
	err := cmd.Run()
	if err != nil {
		log.Println("Network uyuni already removed")
		return
	}
	if dryRun {
		log.Println("Would run podman network rm uyuni")
	} else {
		utils.RunCmd("podman", []string{"network", "rm", "uyuni"}, "Failed to remove network uyuni", globalFlags.Verbose)
	}

// Reload systemd daemon
	if dryRun {
		log.Println("Would run systemctl daemon-reload")
	} else {
		utils.RunCmd("systemctl", []string{"daemon-reload"}, "Failed to reload systemd daemon", globalFlags.Verbose)
	}
}
07070100000025000081A400000000000000000000000164D658810000037C000000000000000000000000000000000000003900000000uyuni-tools-v0.0.1.6/uyuniadm/cmd/uninstall/uninstall.gopackage uninstall

import (
	"github.com/spf13/cobra"
	"github.com/uyuni-project/uyuni-tools/shared/types"
	"github.com/uyuni-project/uyuni-tools/shared/utils"
)

func NewCommand(globalFlags *types.GlobalFlags) *cobra.Command {
	uninstallCmd := &cobra.Command{
		Use:   "uninstall",
		Short: "uninstall a server",
		Args:  cobra.ExactArgs(0),
		Run: func(cmd *cobra.Command, args []string) {
			dryRun, _ := cmd.Flags().GetBool("dry-run")
			purge, _ := cmd.Flags().GetBool("purge-volumes")

command := utils.GetCommand()
			switch command {
			case "podman":
				uninstallForPodman(globalFlags, dryRun, purge)
			case "kubectl":
				uninstallForKubernetes(globalFlags, dryRun)
			}
		},
	}
	uninstallCmd.Flags().BoolP("dry-run", "n", false, "Only show what would be done")
	uninstallCmd.Flags().Bool("purge-volumes", false, "Also remove the volume (podman only)")

return uninstallCmd
}
07070100000026000081A400000000000000000000000164D65881000000FE000000000000000000000000000000000000002600000000uyuni-tools-v0.0.1.6/uyuniadm/main.gopackage main

import (
	"os"

"github.com/uyuni-project/uyuni-tools/uyuniadm/cmd"
)

// Run runs the `uyunictl` root command
func Run() error {
	return cmd.NewUyuniadmCommand().Execute()
}

func main() {
	if err := Run(); err != nil {
		os.Exit(1)
	}
}
07070100000027000041ED00000000000000000000000364D6588100000000000000000000000000000000000000000000001E00000000uyuni-tools-v0.0.1.6/uyunictl07070100000028000041ED00000000000000000000000464D6588100000000000000000000000000000000000000000000002200000000uyuni-tools-v0.0.1.6/uyunictl/cmd07070100000029000081A400000000000000000000000164D6588100000369000000000000000000000000000000000000002900000000uyuni-tools-v0.0.1.6/uyunictl/cmd/cmd.gopackage cmd

import (
	"github.com/spf13/cobra"
	"github.com/uyuni-project/uyuni-tools/shared/types"
	"github.com/uyuni-project/uyuni-tools/uyunictl/cmd/cp"
	"github.com/uyuni-project/uyuni-tools/uyunictl/cmd/exec"
)

// NewCommand returns a new cobra.Command implementing the root command for kinder
func NewUyunictlCommand() *cobra.Command {
	globalFlags := &types.GlobalFlags{}
	rootCmd := &cobra.Command{
		Use:     "uyunictl",
		Short:   "Uyuni control tool",
		Long:    "Uyuni control tool used to help user managing Uyuni and SUSE Manager Servers mainly through its API",
		Version: "0.0.1",
	}

rootCmd.PersistentFlags().BoolVarP(&globalFlags.Verbose, "verbose", "v", false, "verbose output")

// TODO Add --namespace parameter for kubernetes ?

rootCmd.AddCommand(exec.NewCommand(globalFlags))
	rootCmd.AddCommand(cp.NewCommand(globalFlags))

return rootCmd
}
0707010000002A000041ED00000000000000000000000264D6588100000000000000000000000000000000000000000000002500000000uyuni-tools-v0.0.1.6/uyunictl/cmd/cp0707010000002B000081A400000000000000000000000164D658810000043C000000000000000000000000000000000000002B00000000uyuni-tools-v0.0.1.6/uyunictl/cmd/cp/cp.gopackage cp

import (
	"github.com/spf13/cobra"
	"github.com/uyuni-project/uyuni-tools/shared/types"
	"github.com/uyuni-project/uyuni-tools/shared/utils"
)

type flagpole struct {
	User  string
	Group string
}

func NewCommand(globalFlags *types.GlobalFlags) *cobra.Command {
	flags := &flagpole{}

cpCmd := &cobra.Command{
		Use:   "cp [path/to/source.file] [path/to/destination.file]",
		Short: "copy files to and from the containers",
		Long: `Takes a source and destination parameters.
	One of them can be prefixed with 'server:' to indicate the path is within the server pod.`,
		Args: cobra.ExactArgs(2),
		Run: func(cmd *cobra.Command, args []string) {
			run(globalFlags, flags, cmd, args)
		},
	}

cpCmd.Flags().StringVar(&flags.User, "user", "", "User or UID to set on the destination file")
	cpCmd.Flags().StringVar(&flags.Group, "group", "", "Group or GID to set on the destination file")
	return cpCmd
}

func run(globalFlags *types.GlobalFlags, flags *flagpole, cmd *cobra.Command, args []string) {
	utils.Copy(globalFlags, args[0], args[1], flags.User, flags.Group)
}
0707010000002C000041ED00000000000000000000000264D6588100000000000000000000000000000000000000000000002700000000uyuni-tools-v0.0.1.6/uyunictl/cmd/exec0707010000002D000081A400000000000000000000000164D658810000046D000000000000000000000000000000000000002F00000000uyuni-tools-v0.0.1.6/uyunictl/cmd/exec/exec.gopackage exec

import (
	"github.com/spf13/cobra"
	"github.com/uyuni-project/uyuni-tools/shared/types"
	"github.com/uyuni-project/uyuni-tools/shared/utils"
)

type flagpole struct {
	Envs        []string
	Interactive bool
	Tty         bool
}

// NewCommand returns a new cobra.Command for exec
func NewCommand(globalFlags *types.GlobalFlags) *cobra.Command {
	flags := &flagpole{}

execCmd := &cobra.Command{
		Use:   "exec '[command-to-run --with-args]'",
		Short: "Execute commands inside the uyuni containers using 'sh -c'",
		Run: func(cmd *cobra.Command, args []string) {
			run(globalFlags, flags, cmd, args)
		},
	}
	execCmd.Flags().StringSliceVarP(&flags.Envs, "env", "e", []string{}, "environment variables to pass to the command, separated by commas")
	execCmd.Flags().BoolVarP(&flags.Interactive, "interactive", "i", false, "Pass stdin to the container")
	execCmd.Flags().BoolVarP(&flags.Tty, "tty", "t", false, "Stdin is a TTY")
	return execCmd
}

func run(globalFlags *types.GlobalFlags, flags *flagpole, cmd *cobra.Command, args []string) {
	utils.Exec(globalFlags, flags.Interactive, flags.Tty, flags.Envs, args...)
}
0707010000002E000081A400000000000000000000000164D65881000000FE000000000000000000000000000000000000002600000000uyuni-tools-v0.0.1.6/uyunictl/main.gopackage main

import (
	"os"

"github.com/uyuni-project/uyuni-tools/uyunictl/cmd"
)

// Run runs the `uyunictl` root command
func Run() error {
	return cmd.NewUyunictlCommand().Execute()
}

func main() {
	if err := Run(); err != nil {
		os.Exit(1)
	}
}
07070100000000000000000000000000000000000000010000000000000000000000000000000000000000000000000000000B00000000TRAILER!!!221 blocks

Places

File uyuni-tools-v0.0.1.6.obscpio of Package uyuni-tools (Revision 1bd7bed6d4e0185e1bdd17966c1c18fd)

Places