| giolekva | 8aa73e8 | 2022-07-09 11:34:39 +0400 | [diff] [blame] | 1 | package main |
| 2 | |
| 3 | import ( |
| Giorgi Lekveishvili | 23ef7f8 | 2023-05-26 11:57:48 +0400 | [diff] [blame] | 4 | "net" |
| giolekva | 8aa73e8 | 2022-07-09 11:34:39 +0400 | [diff] [blame] | 5 | "os" |
| giolekva | 8aa73e8 | 2022-07-09 11:34:39 +0400 | [diff] [blame] | 6 | |
| 7 | "github.com/giolekva/pcloud/core/installer" |
| Giorgi Lekveishvili | 23ef7f8 | 2023-05-26 11:57:48 +0400 | [diff] [blame] | 8 | "github.com/go-git/go-billy/v5/memfs" |
| 9 | "github.com/go-git/go-git/v5" |
| Giorgi Lekveishvili | 23ef7f8 | 2023-05-26 11:57:48 +0400 | [diff] [blame] | 10 | gitssh "github.com/go-git/go-git/v5/plumbing/transport/ssh" |
| 11 | "github.com/go-git/go-git/v5/storage/memory" |
| giolekva | 8aa73e8 | 2022-07-09 11:34:39 +0400 | [diff] [blame] | 12 | "github.com/spf13/cobra" |
| Giorgi Lekveishvili | 23ef7f8 | 2023-05-26 11:57:48 +0400 | [diff] [blame] | 13 | "golang.org/x/crypto/ssh" |
| giolekva | 8aa73e8 | 2022-07-09 11:34:39 +0400 | [diff] [blame] | 14 | ) |
| 15 | |
| Giorgi Lekveishvili | 23ef7f8 | 2023-05-26 11:57:48 +0400 | [diff] [blame] | 16 | const appDirName = "apps" |
| 17 | |
| giolekva | 8aa73e8 | 2022-07-09 11:34:39 +0400 | [diff] [blame] | 18 | var installFlags struct { |
| Giorgi Lekveishvili | 23ef7f8 | 2023-05-26 11:57:48 +0400 | [diff] [blame] | 19 | sshKey string |
| Giorgi Lekveishvili | 23ef7f8 | 2023-05-26 11:57:48 +0400 | [diff] [blame] | 20 | appName string |
| 21 | repoAddr string |
| giolekva | 8aa73e8 | 2022-07-09 11:34:39 +0400 | [diff] [blame] | 22 | } |
| 23 | |
| 24 | func installCmd() *cobra.Command { |
| 25 | cmd := &cobra.Command{ |
| 26 | Use: "install", |
| 27 | RunE: installCmdRun, |
| 28 | } |
| 29 | cmd.Flags().StringVar( |
| Giorgi Lekveishvili | 23ef7f8 | 2023-05-26 11:57:48 +0400 | [diff] [blame] | 30 | &installFlags.sshKey, |
| 31 | "ssh-key", |
| 32 | "", |
| 33 | "", |
| 34 | ) |
| 35 | cmd.Flags().StringVar( |
| giolekva | 8aa73e8 | 2022-07-09 11:34:39 +0400 | [diff] [blame] | 36 | &installFlags.appName, |
| 37 | "app", |
| 38 | "", |
| 39 | "", |
| 40 | ) |
| 41 | cmd.Flags().StringVar( |
| Giorgi Lekveishvili | 23ef7f8 | 2023-05-26 11:57:48 +0400 | [diff] [blame] | 42 | &installFlags.repoAddr, |
| 43 | "repo-addr", |
| giolekva | 8aa73e8 | 2022-07-09 11:34:39 +0400 | [diff] [blame] | 44 | "", |
| 45 | "", |
| 46 | ) |
| 47 | return cmd |
| 48 | } |
| 49 | |
| 50 | func installCmdRun(cmd *cobra.Command, args []string) error { |
| Giorgi Lekveishvili | 23ef7f8 | 2023-05-26 11:57:48 +0400 | [diff] [blame] | 51 | sshKey, err := os.ReadFile(installFlags.sshKey) |
| 52 | if err != nil { |
| 53 | return err |
| giolekva | 8aa73e8 | 2022-07-09 11:34:39 +0400 | [diff] [blame] | 54 | } |
| Giorgi Lekveishvili | 23ef7f8 | 2023-05-26 11:57:48 +0400 | [diff] [blame] | 55 | signer, err := ssh.ParsePrivateKey(sshKey) |
| 56 | if err != nil { |
| 57 | return err |
| 58 | } |
| 59 | repo, err := cloneRepo(installFlags.repoAddr, signer) |
| 60 | if err != nil { |
| 61 | return err |
| 62 | } |
| Giorgi Lekveishvili | 0ccd148 | 2023-06-21 15:02:24 +0400 | [diff] [blame^] | 63 | m, err := installer.NewAppManager(installer.NewRepoIO( |
| Giorgi Lekveishvili | bd6be7f | 2023-05-26 15:51:28 +0400 | [diff] [blame] | 64 | repo, |
| 65 | signer, |
| Giorgi Lekveishvili | 0ccd148 | 2023-06-21 15:02:24 +0400 | [diff] [blame^] | 66 | )) |
| Giorgi Lekveishvili | 23ef7f8 | 2023-05-26 11:57:48 +0400 | [diff] [blame] | 67 | if err != nil { |
| 68 | return err |
| 69 | } |
| Giorgi Lekveishvili | bd6be7f | 2023-05-26 15:51:28 +0400 | [diff] [blame] | 70 | appRepo := installer.NewInMemoryAppRepository(installer.CreateAllApps()) |
| 71 | app, err := appRepo.Find(installFlags.appName) |
| giolekva | 8aa73e8 | 2022-07-09 11:34:39 +0400 | [diff] [blame] | 72 | if err != nil { |
| Giorgi Lekveishvili | bd6be7f | 2023-05-26 15:51:28 +0400 | [diff] [blame] | 73 | return err |
| giolekva | 8aa73e8 | 2022-07-09 11:34:39 +0400 | [diff] [blame] | 74 | } |
| Giorgi Lekveishvili | 7efe22f | 2023-05-30 13:01:53 +0400 | [diff] [blame] | 75 | return m.Install(*app, nil) |
| giolekva | 8aa73e8 | 2022-07-09 11:34:39 +0400 | [diff] [blame] | 76 | } |
| Giorgi Lekveishvili | 23ef7f8 | 2023-05-26 11:57:48 +0400 | [diff] [blame] | 77 | |
| 78 | func cloneRepo(address string, signer ssh.Signer) (*git.Repository, error) { |
| 79 | return git.Clone(memory.NewStorage(), memfs.New(), &git.CloneOptions{ |
| 80 | URL: address, |
| 81 | Auth: auth(signer), |
| 82 | RemoteName: "origin", |
| 83 | InsecureSkipTLS: true, |
| 84 | }) |
| 85 | } |
| 86 | |
| 87 | func auth(signer ssh.Signer) *gitssh.PublicKeys { |
| 88 | return &gitssh.PublicKeys{ |
| 89 | Signer: signer, |
| 90 | HostKeyCallbackHelper: gitssh.HostKeyCallbackHelper{ |
| 91 | HostKeyCallback: func(hostname string, remote net.Addr, key ssh.PublicKey) error { |
| 92 | // TODO(giolekva): verify server public key |
| 93 | // fmt.Printf("## %s || %s -- \n", serverPubKey, ssh.MarshalAuthorizedKey(key)) |
| 94 | return nil |
| 95 | }, |
| 96 | }, |
| 97 | } |
| 98 | } |