fly: adopt from example-fly-firestore

Author: evan-gray

.gitignore

@@ -8,3 +8,4 @@ lastBlockByChain.json
 serviceAccountKey.json
 bigtableAccountKey.json
 tsconfig.tsbuildinfo
+serviceAccount.json

cloud-functions/README.md

@@ -0,0 +1,11 @@
+The cloud-functions can be run locally by:
+
+```bash
+# Spin up a local development server for quick testing
+export GCP_PROJECT=""
+export GOOGLE_APPLICATION_CREDENTIALS=""
+go run cmd/main.go
+
+# Invoke a function in response to a request
+curl localhost:8080/guardian-heartbeats
+```

cloud-functions/cmd/main.go

@@ -0,0 +1,42 @@
+package main
+
+import (
+	"context"
+	"log"
+	"net/http"
+	"os"
+
+	p "github.com/wormhole-foundation/example-fly-firestore/cloud-functions"
+
+	"github.com/GoogleCloudPlatform/functions-framework-go/funcframework"
+)
+
+var mux = newMux()
+
+// Entry is the cloud function entry point
+func Entry(w http.ResponseWriter, r *http.Request) {
+	mux.ServeHTTP(w, r)
+}
+
+func newMux() *http.ServeMux {
+	mux := http.NewServeMux()
+	mux.HandleFunc("/guardian-heartbeats", p.Heartbeats)
+	mux.HandleFunc("/governor-status", p.GovernorStatus)
+	mux.HandleFunc("/governor-configs", p.GovernorConfigs)
+	return mux
+}
+
+func main() {
+	ctx := context.Background()
+	if err := funcframework.RegisterHTTPFunctionContext(ctx, "/", Entry); err != nil {
+		log.Fatalf("funcframework.RegisterHTTPFunctionContext: %v\n", err)
+	}
+	// Use PORT environment variable, or default to 8080.
+	port := "8080"
+	if envPort := os.Getenv("PORT"); envPort != "" {
+		port = envPort
+	}
+	if err := funcframework.Start(port); err != nil {
+		log.Fatalf("funcframework.Start: %v\n", err)
+	}
+}

cloud-functions/deploy.sh

@@ -0,0 +1,16 @@
+#!/bin/bash
+set -e
+
+if [ -z "$GCP_PROJECT" ]; then
+    echo "GCP_PROJECT must be specified"
+    exit 1
+fi
+
+if [ -z "$SERVICE_ACCOUNT" ]; then
+    echo "SERVICE_ACCOUNT must be specified"
+    exit 1
+fi
+
+gcloud functions --project "$GCP_PROJECT" deploy guardian-heartbeats --region=europe-west3 --entry-point Heartbeats --memory=256MB --runtime go116 --trigger-http --allow-unauthenticated --service-account="$SERVICE_ACCOUNT" --update-env-vars GCP_PROJECT="$GCP_PROJECT"
+gcloud functions --project "$GCP_PROJECT" deploy governor-status --region=europe-west3 --entry-point GovernorStatus --memory=256MB --runtime go116 --trigger-http --allow-unauthenticated --service-account="$SERVICE_ACCOUNT" --update-env-vars GCP_PROJECT="$GCP_PROJECT"
+gcloud functions --project "$GCP_PROJECT" deploy governor-configs --region=europe-west3 --entry-point GovernorConfigs --memory=256MB --runtime go116 --trigger-http --allow-unauthenticated --service-account="$SERVICE_ACCOUNT" --update-env-vars GCP_PROJECT="$GCP_PROJECT"

cloud-functions/go.mod

@@ -0,0 +1,44 @@
+module github.com/wormhole-foundation/example-fly-firestore/cloud-functions
+
+go 1.17
+
+require (
+	cloud.google.com/go/firestore v1.8.0
+	firebase.google.com/go v3.13.0+incompatible
+	github.com/GoogleCloudPlatform/functions-framework-go v1.6.1
+	google.golang.org/api v0.98.0
+)
+
+require (
+	cloud.google.com/go v0.104.0 // indirect
+	cloud.google.com/go/compute v1.7.0 // indirect
+	cloud.google.com/go/functions v1.7.0 // indirect
+	cloud.google.com/go/iam v0.3.0 // indirect
+	cloud.google.com/go/storage v1.23.0 // indirect
+	github.com/cloudevents/sdk-go/v2 v2.6.1 // indirect
+	github.com/golang/groupcache v0.0.0-20200121045136-8c9f03a8e57e // indirect
+	github.com/golang/protobuf v1.5.2 // indirect
+	github.com/google/go-cmp v0.5.8 // indirect
+	github.com/google/uuid v1.3.0 // indirect
+	github.com/googleapis/enterprise-certificate-proxy v0.1.0 // indirect
+	github.com/googleapis/gax-go/v2 v2.5.1 // indirect
+	github.com/googleapis/go-type-adapters v1.0.0 // indirect
+	github.com/json-iterator/go v1.1.10 // indirect
+	github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421 // indirect
+	github.com/modern-go/reflect2 v0.0.0-20180701023420-4b7aa43c6742 // indirect
+	go.opencensus.io v0.23.0 // indirect
+	go.uber.org/atomic v1.4.0 // indirect
+	go.uber.org/multierr v1.1.0 // indirect
+	go.uber.org/zap v1.10.0 // indirect
+	golang.org/x/net v0.0.0-20220909164309-bea034e7d591 // indirect
+	golang.org/x/oauth2 v0.0.0-20220909003341-f21342109be1 // indirect
+	golang.org/x/sync v0.0.0-20220601150217-0de741cfad7f // indirect
+	golang.org/x/sys v0.0.0-20220728004956-3c1f35247d10 // indirect
+	golang.org/x/text v0.3.7 // indirect
+	golang.org/x/time v0.0.0-20220609170525-579cf78fd858 // indirect
+	golang.org/x/xerrors v0.0.0-20220609144429-65e65417b02f // indirect
+	google.golang.org/appengine v1.6.7 // indirect
+	google.golang.org/genproto v0.0.0-20221010155953-15ba04fc1c0e // indirect
+	google.golang.org/grpc v1.49.0 // indirect
+	google.golang.org/protobuf v1.28.1 // indirect
+)