🎨 Update pubsub message

Makefile

@@ -43,11 +43,12 @@ ifeq ($(URL),)
 	$(error "Please specify URL")
 endif
 	gcloud pubsub topics publish $(FUNC_NAME)-topic \
-	--attribute=url=$(URL)
+	--message=$(URL)
 
 log:
 	gcloud beta functions logs read $(FUNC_NAME) --gen2 --limit=100
 
 open:
 	open https://console.cloud.google.com/functions/details/asia-northeast1/$(FUNC_NAME)?env=gen2
 	open https://console.cloud.google.com/cloudpubsub/topic/detail/$(FUNC_NAME)-topic
+	open https://console.cloud.google.com/storage/browser?project=$(PROJECT_ID)

fetch.go

@@ -86,18 +86,12 @@ func parseURL(s string) string {
 	return url.Host + url.Path
 }
 
-func parseEvent(event event.Event) (url string) {
+func parseEvent(event event.Event) string {
 	var msg MessagePublishedData
 	if err := event.DataAs(&msg); err != nil {
 		zl.Error("DATA_AS_ERROR", err)
-		return
 	}
-	url = msg.Message.Attributes["url"]
-	if url == "" {
-		zl.Error("ATTRIBUTE_ERROR", fmt.Errorf("url is empty"))
-		return
-	}
-	return url
+	return string(msg.Message.Data)
 }
 
 func getEnv() (bucket string) {

fetch_test.go

@@ -32,9 +32,7 @@ func NewTestFetch() *TestFetch {
 func (f *TestFetch) setup(t *testing.T) {
 	msg := fetch.MessagePublishedData{
 		Message: pubsub.Message{
-			Attributes: map[string]string{
-				"url": "https://api.github.com/users/defunkt",
-			},
+			Data: []byte("https://api.github.com/users/defunkt"),
 		},
 	}
 	f.event = event.New()