mirror of
https://github.com/Luzifer/cloudkeys-go.git
synced 2024-11-14 00:42:44 +00:00
302 lines
8.5 KiB
Go
302 lines
8.5 KiB
Go
// Copyright 2014 The Go Authors. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style
|
|
// license that can be found in the LICENSE file.
|
|
|
|
// +build ignore
|
|
|
|
package main
|
|
|
|
import (
|
|
"bufio"
|
|
"bytes"
|
|
"encoding/json"
|
|
"flag"
|
|
"fmt"
|
|
"io"
|
|
"io/ioutil"
|
|
"log"
|
|
"net/http"
|
|
"os"
|
|
"strings"
|
|
"time"
|
|
|
|
"golang.org/x/oauth2"
|
|
"golang.org/x/oauth2/google"
|
|
compute "google.golang.org/api/compute/v1"
|
|
)
|
|
|
|
var (
|
|
proj = flag.String("project", "symbolic-datum-552", "name of Project")
|
|
zone = flag.String("zone", "us-central1-a", "GCE zone")
|
|
mach = flag.String("machinetype", "n1-standard-1", "Machine type")
|
|
instName = flag.String("instance_name", "http2-demo", "Name of VM instance.")
|
|
sshPub = flag.String("ssh_public_key", "", "ssh public key file to authorize. Can modify later in Google's web UI anyway.")
|
|
staticIP = flag.String("static_ip", "130.211.116.44", "Static IP to use. If empty, automatic.")
|
|
|
|
writeObject = flag.String("write_object", "", "If non-empty, a VM isn't created and the flag value is Google Cloud Storage bucket/object to write. The contents from stdin.")
|
|
publicObject = flag.Bool("write_object_is_public", false, "Whether the object created by --write_object should be public.")
|
|
)
|
|
|
|
func readFile(v string) string {
|
|
slurp, err := ioutil.ReadFile(v)
|
|
if err != nil {
|
|
log.Fatalf("Error reading %s: %v", v, err)
|
|
}
|
|
return strings.TrimSpace(string(slurp))
|
|
}
|
|
|
|
var config = &oauth2.Config{
|
|
// The client-id and secret should be for an "Installed Application" when using
|
|
// the CLI. Later we'll use a web application with a callback.
|
|
ClientID: readFile("client-id.dat"),
|
|
ClientSecret: readFile("client-secret.dat"),
|
|
Endpoint: google.Endpoint,
|
|
Scopes: []string{
|
|
compute.DevstorageFullControlScope,
|
|
compute.ComputeScope,
|
|
"https://www.googleapis.com/auth/sqlservice",
|
|
"https://www.googleapis.com/auth/sqlservice.admin",
|
|
},
|
|
RedirectURL: "urn:ietf:wg:oauth:2.0:oob",
|
|
}
|
|
|
|
const baseConfig = `#cloud-config
|
|
coreos:
|
|
units:
|
|
- name: h2demo.service
|
|
command: start
|
|
content: |
|
|
[Unit]
|
|
Description=HTTP2 Demo
|
|
|
|
[Service]
|
|
ExecStartPre=/bin/bash -c 'mkdir -p /opt/bin && curl -s -o /opt/bin/h2demo http://storage.googleapis.com/http2-demo-server-tls/h2demo && chmod +x /opt/bin/h2demo'
|
|
ExecStart=/opt/bin/h2demo --prod
|
|
RestartSec=5s
|
|
Restart=always
|
|
Type=simple
|
|
|
|
[Install]
|
|
WantedBy=multi-user.target
|
|
`
|
|
|
|
func main() {
|
|
flag.Parse()
|
|
if *proj == "" {
|
|
log.Fatalf("Missing --project flag")
|
|
}
|
|
prefix := "https://www.googleapis.com/compute/v1/projects/" + *proj
|
|
machType := prefix + "/zones/" + *zone + "/machineTypes/" + *mach
|
|
|
|
const tokenFileName = "token.dat"
|
|
tokenFile := tokenCacheFile(tokenFileName)
|
|
tokenSource := oauth2.ReuseTokenSource(nil, tokenFile)
|
|
token, err := tokenSource.Token()
|
|
if err != nil {
|
|
if *writeObject != "" {
|
|
log.Fatalf("Can't use --write_object without a valid token.dat file already cached.")
|
|
}
|
|
log.Printf("Error getting token from %s: %v", tokenFileName, err)
|
|
log.Printf("Get auth code from %v", config.AuthCodeURL("my-state"))
|
|
fmt.Print("\nEnter auth code: ")
|
|
sc := bufio.NewScanner(os.Stdin)
|
|
sc.Scan()
|
|
authCode := strings.TrimSpace(sc.Text())
|
|
token, err = config.Exchange(oauth2.NoContext, authCode)
|
|
if err != nil {
|
|
log.Fatalf("Error exchanging auth code for a token: %v", err)
|
|
}
|
|
if err := tokenFile.WriteToken(token); err != nil {
|
|
log.Fatalf("Error writing to %s: %v", tokenFileName, err)
|
|
}
|
|
tokenSource = oauth2.ReuseTokenSource(token, nil)
|
|
}
|
|
|
|
oauthClient := oauth2.NewClient(oauth2.NoContext, tokenSource)
|
|
|
|
if *writeObject != "" {
|
|
writeCloudStorageObject(oauthClient)
|
|
return
|
|
}
|
|
|
|
computeService, _ := compute.New(oauthClient)
|
|
|
|
natIP := *staticIP
|
|
if natIP == "" {
|
|
// Try to find it by name.
|
|
aggAddrList, err := computeService.Addresses.AggregatedList(*proj).Do()
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
// http://godoc.org/code.google.com/p/google-api-go-client/compute/v1#AddressAggregatedList
|
|
IPLoop:
|
|
for _, asl := range aggAddrList.Items {
|
|
for _, addr := range asl.Addresses {
|
|
if addr.Name == *instName+"-ip" && addr.Status == "RESERVED" {
|
|
natIP = addr.Address
|
|
break IPLoop
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
cloudConfig := baseConfig
|
|
if *sshPub != "" {
|
|
key := strings.TrimSpace(readFile(*sshPub))
|
|
cloudConfig += fmt.Sprintf("\nssh_authorized_keys:\n - %s\n", key)
|
|
}
|
|
if os.Getenv("USER") == "bradfitz" {
|
|
cloudConfig += fmt.Sprintf("\nssh_authorized_keys:\n - %s\n", "ssh-rsa AAAAB3NzaC1yc2EAAAABIwAAAIEAwks9dwWKlRC+73gRbvYtVg0vdCwDSuIlyt4z6xa/YU/jTDynM4R4W10hm2tPjy8iR1k8XhDv4/qdxe6m07NjG/By1tkmGpm1mGwho4Pr5kbAAy/Qg+NLCSdAYnnE00FQEcFOC15GFVMOW2AzDGKisReohwH9eIzHPzdYQNPRWXE= bradfitz@papag.bradfitz.com")
|
|
}
|
|
const maxCloudConfig = 32 << 10 // per compute API docs
|
|
if len(cloudConfig) > maxCloudConfig {
|
|
log.Fatalf("cloud config length of %d bytes is over %d byte limit", len(cloudConfig), maxCloudConfig)
|
|
}
|
|
|
|
instance := &compute.Instance{
|
|
Name: *instName,
|
|
Description: "Go Builder",
|
|
MachineType: machType,
|
|
Disks: []*compute.AttachedDisk{instanceDisk(computeService)},
|
|
Tags: &compute.Tags{
|
|
Items: []string{"http-server", "https-server"},
|
|
},
|
|
Metadata: &compute.Metadata{
|
|
Items: []*compute.MetadataItems{
|
|
{
|
|
Key: "user-data",
|
|
Value: &cloudConfig,
|
|
},
|
|
},
|
|
},
|
|
NetworkInterfaces: []*compute.NetworkInterface{
|
|
{
|
|
AccessConfigs: []*compute.AccessConfig{
|
|
{
|
|
Type: "ONE_TO_ONE_NAT",
|
|
Name: "External NAT",
|
|
NatIP: natIP,
|
|
},
|
|
},
|
|
Network: prefix + "/global/networks/default",
|
|
},
|
|
},
|
|
ServiceAccounts: []*compute.ServiceAccount{
|
|
{
|
|
Email: "default",
|
|
Scopes: []string{
|
|
compute.DevstorageFullControlScope,
|
|
compute.ComputeScope,
|
|
},
|
|
},
|
|
},
|
|
}
|
|
|
|
log.Printf("Creating instance...")
|
|
op, err := computeService.Instances.Insert(*proj, *zone, instance).Do()
|
|
if err != nil {
|
|
log.Fatalf("Failed to create instance: %v", err)
|
|
}
|
|
opName := op.Name
|
|
log.Printf("Created. Waiting on operation %v", opName)
|
|
OpLoop:
|
|
for {
|
|
time.Sleep(2 * time.Second)
|
|
op, err := computeService.ZoneOperations.Get(*proj, *zone, opName).Do()
|
|
if err != nil {
|
|
log.Fatalf("Failed to get op %s: %v", opName, err)
|
|
}
|
|
switch op.Status {
|
|
case "PENDING", "RUNNING":
|
|
log.Printf("Waiting on operation %v", opName)
|
|
continue
|
|
case "DONE":
|
|
if op.Error != nil {
|
|
for _, operr := range op.Error.Errors {
|
|
log.Printf("Error: %+v", operr)
|
|
}
|
|
log.Fatalf("Failed to start.")
|
|
}
|
|
log.Printf("Success. %+v", op)
|
|
break OpLoop
|
|
default:
|
|
log.Fatalf("Unknown status %q: %+v", op.Status, op)
|
|
}
|
|
}
|
|
|
|
inst, err := computeService.Instances.Get(*proj, *zone, *instName).Do()
|
|
if err != nil {
|
|
log.Fatalf("Error getting instance after creation: %v", err)
|
|
}
|
|
ij, _ := json.MarshalIndent(inst, "", " ")
|
|
log.Printf("Instance: %s", ij)
|
|
}
|
|
|
|
func instanceDisk(svc *compute.Service) *compute.AttachedDisk {
|
|
const imageURL = "https://www.googleapis.com/compute/v1/projects/coreos-cloud/global/images/coreos-stable-444-5-0-v20141016"
|
|
diskName := *instName + "-disk"
|
|
|
|
return &compute.AttachedDisk{
|
|
AutoDelete: true,
|
|
Boot: true,
|
|
Type: "PERSISTENT",
|
|
InitializeParams: &compute.AttachedDiskInitializeParams{
|
|
DiskName: diskName,
|
|
SourceImage: imageURL,
|
|
DiskSizeGb: 50,
|
|
},
|
|
}
|
|
}
|
|
|
|
func writeCloudStorageObject(httpClient *http.Client) {
|
|
content := os.Stdin
|
|
const maxSlurp = 1 << 20
|
|
var buf bytes.Buffer
|
|
n, err := io.CopyN(&buf, content, maxSlurp)
|
|
if err != nil && err != io.EOF {
|
|
log.Fatalf("Error reading from stdin: %v, %v", n, err)
|
|
}
|
|
contentType := http.DetectContentType(buf.Bytes())
|
|
|
|
req, err := http.NewRequest("PUT", "https://storage.googleapis.com/"+*writeObject, io.MultiReader(&buf, content))
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
req.Header.Set("x-goog-api-version", "2")
|
|
if *publicObject {
|
|
req.Header.Set("x-goog-acl", "public-read")
|
|
}
|
|
req.Header.Set("Content-Type", contentType)
|
|
res, err := httpClient.Do(req)
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
if res.StatusCode != 200 {
|
|
res.Write(os.Stderr)
|
|
log.Fatalf("Failed.")
|
|
}
|
|
log.Printf("Success.")
|
|
os.Exit(0)
|
|
}
|
|
|
|
type tokenCacheFile string
|
|
|
|
func (f tokenCacheFile) Token() (*oauth2.Token, error) {
|
|
slurp, err := ioutil.ReadFile(string(f))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
t := new(oauth2.Token)
|
|
if err := json.Unmarshal(slurp, t); err != nil {
|
|
return nil, err
|
|
}
|
|
return t, nil
|
|
}
|
|
|
|
func (f tokenCacheFile) WriteToken(t *oauth2.Token) error {
|
|
jt, err := json.Marshal(t)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
return ioutil.WriteFile(string(f), jt, 0600)
|
|
}
|