Fixing install and OAuth

perf/server/data.go

 // Copyright (c) 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be found
 // in the LICENSE file.
 
 package main
 
 import (
         "encoding/json"
         "fmt"
         "io"
         "net/http"
         "os/exec"
         "reflect"
         "strconv"
         "strings"
         "time"
 )
 
 import (
+        "code.google.com/p/goauth2/compute/serviceaccount"

[mtklein, 2014/06/16 20:25:11]

Am I thinking using a service account is roughly like running things on borg as
a group rather than as a user?  If so, how do we tell it which service account
to use?

[jcgregorio, 2014/06/16 20:33:47]

There's a service account associated with the cloud console project 

  https://console.developers.google.com/project/31977622648

As long as you create a VM instance with bigquery enabled then the service
account credentials will have access to bigquery. There is an account name
associated with that client you can lookup at the link above, but you don't need
to know that when using the service account, the metadata server keeps track of
that. Details here:

  https://developers.google.com/compute/docs/authentication


On 2014/06/16 20:25:11, mtklein wrote:

         "code.google.com/p/goauth2/oauth"
         "code.google.com/p/google-api-go-client/bigquery/v2"
         "github.com/oxtoacart/webbrowser"
 )
 
 const (
         // JSON doesn't support NaN or +/- Inf, so we need a valid float
         // to signal missing data that also has a compact JSON representation.
         MISSING_DATA_SENTINEL = 1e100
 )
@@ skipping 421 matching lines @@
 // TODO(jcgregorio) Actuall do the bit where we start a go routine.
 func NewData(doOauth bool, gitRepoDir string) (*Data, error) {
         var err error
         var client *http.Client
         if doOauth {
                 client, err = runFlow(config)
                 if err != nil {
                         return nil, fmt.Errorf("Failed to auth: %s", err)
                 }
         } else {
-                client = http.DefaultClient
+                client, err = serviceaccount.NewClient(nil)
+                if err != nil {
+                        return nil, fmt.Errorf("Failed to auth using a service account: %s", err)
+                }
         }
         service, err := bigquery.New(client)
         if err != nil {
                 return nil, fmt.Errorf("Failed to create a new BigQuery service object: %s", err)
         }
 
         // First query and get the list of hashes we are interested in and use that
         // and the git log results to fill in the Commits.
         allGitHashes, err := readCommitsFromGit(gitRepoDir)
         if err != nil {
@@ skipping 32 matching lines @@
 
         if err := populateTraces(service, all, hashToIndex, numSamples); err != nil {
                 // Fail fast, monit will restart us if we fail for some reason.
                 panic(err)
         }
 
         populateParamSet(all)
 
         return &Data{all: all}, nil
 }