small improvements and fixes, updated the packages due security

Author: klassmann

.gitignore

@@ -10,4 +10,5 @@
 
 # Output of the go coverage tool, specifically when used with LiteIDE
 *.out
-dist
+dist
+.idea

Makefile

@@ -1,5 +1,5 @@
 
-all: clean win_64 win_32 linux_64 linux_32 darwin_64 darwin_32 freebsd_64 freebsd_32
+all: clean win_64 win_32 linux_64 linux_32 darwin_64
 
 win_64:
 	env GOOS=windows GOARCH=amd64 go build -o "dist/pubsub-push.exe" ./cmd/pubsub-push
@@ -26,11 +26,6 @@ darwin_64:
 	gzip dist/pubsub-push -c > "dist/pubsub-push_$(shell cat VERSION)_$@.gz"
 	rm -f dist/pubsub-push
 
-darwin_32:
-	env GOOS=darwin GOARCH=386 go build -o dist/pubsub-push ./cmd/pubsub-push
-	gzip dist/pubsub-push -c > "dist/pubsub-push_$(shell cat VERSION)_$@.gz"
-	rm -f dist/pubsub-push
-
 clean:
 	rm -rf dist/*
 

VERSION

@@ -1 +1 @@
-0.1
+0.2

cmd/pubsub-push/main.go

@@ -46,31 +46,35 @@ func main() {
 
 	_, b := os.LookupEnv(credentialsVarName)
 	if !b {
-		fmt.Printf("You need to define %s variable with the correct credentials.\n", credentialsVarName)
-		os.Exit(-1)
+		fmt.Printf("define %s with the correct credential or the default credential will be used.\n", credentialsVarName)
 	}
 
 	ctx := context.Background()
 	client, err := pubsub.NewClient(ctx, settings.ProjectID)
 
 	if err != nil {
-		log.Fatalf("Failed to create client: %v", err)
-		os.Exit(-1)
+		log.Fatalf("failed to create client: %v", err)
 	}
 
-	fmt.Printf("Listening subscription %s:\n", settings.Subscription)
 	sub := client.Subscription(settings.Subscription)
+	ok, err := sub.Exists(ctx)
+
+	if !ok || err != nil {
+		log.Fatalf("failed to connect to subscription: %s", settings.Subscription)
+	}
+
+	fmt.Printf("listening subscription %s:\n", sub.String())
 	err = sub.Receive(ctx, func(ctx context.Context, m *pubsub.Message) {
 		b, size := push.EncodeMessage(m)
 		buff := bytes.NewBuffer(b)
 
 		resp, err := push.PostMessage(settings.Endpoint, messageMimetype, buff, &settings.Headers)
 
 		if err != nil {
-			log.Fatalf("Error on send message to endpoint: %v\n", err)
+			log.Printf("[ERROR]: %v\n", err)
 			m.Nack()
 		} else {
-			fmt.Printf("Message with %d bytes was sent to %s, got HTTP %d. Message: ", size, settings.Endpoint, resp.StatusCode)
+			fmt.Printf("[SUCCESS]: message of %d bytes sent to %s: got HTTP %d. Message: ", size, settings.Endpoint, resp.StatusCode)
 			if resp.StatusCode >= 200 && resp.StatusCode < 300 {
 				fmt.Printf("ACK\n")
 				m.Ack()

go.mod

@@ -3,12 +3,9 @@ module github.com/klassmann/pubsub-push
 go 1.12
 
 require (
-	cloud.google.com/go v0.43.0
-	github.com/hashicorp/golang-lru v0.5.3 // indirect
-	github.com/ianlancetaylor/demangle v0.0.0-20181102032728-5e5cf60278f6 // indirect
-	golang.org/x/arch v0.0.0-20190312162104-788fe5ffcd8c // indirect
-	golang.org/x/net v0.0.0-20190724013045-ca1201d0de80 // indirect
-	golang.org/x/sys v0.0.0-20190801041406-cbf593c0f2f3 // indirect
-	google.golang.org/genproto v0.0.0-20190801165951-fa694d86fc64 // indirect
-	google.golang.org/grpc v1.22.1 // indirect
+	cloud.google.com/go v0.110.0 // indirect
+	cloud.google.com/go/iam v0.12.0 // indirect
+	cloud.google.com/go/pubsub v1.28.0
+	github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da // indirect
+	google.golang.org/genproto v0.0.0-20230223222841-637eb2293923 // indirect
 )

go.sum

@@ -53,7 +53,7 @@ func (h *Headers) applyHeaders(ht *http.Request) {
 }
 
 // EncodeMessage prepares the message to be like the HTTP Push from PubSub
-// It is an JSON with a data field containing a base64 value
+// It is a JSON with a data field containing a base64 value
 func EncodeMessage(m *pubsub.Message) ([]byte, int) {
 	data := m.Data
 	req := request{}
@@ -70,7 +70,7 @@ func EncodeMessage(m *pubsub.Message) ([]byte, int) {
 	return b, len(b)
 }
 
-// PostMessage sends the the message to endpoint
+// PostMessage sends the message to endpoint
 func PostMessage(url string, contentType string, body io.Reader, h *Headers) (*http.Response, error) {
 	req, err := http.NewRequest("POST", url, body)
 	if err != nil {