events

package
v0.0.0-...-0a37f73 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 7, 2020 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package events contains the validation logic for different types of events.

Index

Constants

This section is empty.

Variables

View Source 
var Events = map[string]Event{
	"firebase-auth": {
		Input: EventData{
			LegacyEvent: []byte(`{
  "data": {
    "email": "test@nowhere.com",
    "metadata": {
      "createdAt": "2020-05-26T10:42:27Z"
    },
    "providerData": [
      {
        "email": "test@nowhere.com",
        "providerId": "password",
        "uid": "test@nowhere.com"
      }
    ],
    "uid": "UUpby3s4spZre6kHsgVSPetzQ8l2"
  },
  "eventId": "4423b4fa-c39b-4f79-b338-977a018e9b55",
  "eventType": "providers/firebase.auth/eventTypes/user.create",
  "notSupported": {
  },
  "resource": "projects/my-project-id",
  "timestamp": "2020-05-26T10:42:27.088Z"
}
`),
			CloudEvent: []byte(`{
  "specversion": "1.0",
  "type": "google.firebase.auth.user.v1.created",
  "source": "//firebase.googleapis.com/projects/my-project-id",
  "id": "4423b4fa-c39b-4f79-b338-977a018e9b55",
  "time": "2020-05-26T10:42:27.088Z",
  "datacontenttype": "application/json",
  "data": {
    "email": "test@nowhere.com",
    "metadata": {
      "createdAt": "2020-05-26T10:42:27Z"
    },
    "providerData": [
      {
        "email": "test@nowhere.com",
        "providerId": "password",
        "uid": "test@nowhere.com"
      }
    ],
    "uid": "UUpby3s4spZre6kHsgVSPetzQ8l2"
  }
}
`),
		},
		Output: EventData{
			LegacyEvent: []byte(`{
  "data": {
    "email": "test@nowhere.com",
    "metadata": {
      "createdAt": "2020-05-26T10:42:27Z"
    },
    "providerData": [
      {
        "email": "test@nowhere.com",
        "providerId": "password",
        "uid": "test@nowhere.com"
      }
    ],
    "uid": "UUpby3s4spZre6kHsgVSPetzQ8l2"
  },
  "context": {
    "eventId": "4423b4fa-c39b-4f79-b338-977a018e9b55",
    "eventType": "providers/firebase.auth/eventTypes/user.create",
    "resource": "projects/my-project-id",
    "timestamp": "2020-05-26T10:42:27.088Z"
  }
}
`),
			CloudEvent: []byte(`{
  "specversion": "1.0",
  "type": "google.firebase.auth.user.v1.created",
  "source": "//firebase.googleapis.com/projects/my-project-id",
  "id": "4423b4fa-c39b-4f79-b338-977a018e9b55",
  "time": "2020-05-26T10:42:27.088Z",
  "datacontenttype": "application/json",
  "data": {
    "email": "test@nowhere.com",
    "metadata": {
      "createdAt": "2020-05-26T10:42:27Z"
    },
    "providerData": [
      {
        "email": "test@nowhere.com",
        "providerId": "password",
        "uid": "test@nowhere.com"
      }
    ],
    "uid": "UUpby3s4spZre6kHsgVSPetzQ8l2"
  }
}
`),
		},
	},

	"firebase-db1": {
		Input: EventData{
			LegacyEvent: []byte(`{
  "eventType": "providers/google.firebase.database/eventTypes/ref.write",
  "params": {
    "child": "xyz"
  },
  "auth": {
    "admin": true
  },
  "data": {
    "data": null,
    "delta": {
      "grandchild": "other"
    }
  },
  "resource": "projects/_/instances/my-project-id/refs/gcf-test/xyz",
  "timestamp": "2020-05-21T11:15:34.178Z",
  "eventId": "/SnHth9OSlzK1Puj85kk4tDbF90="
}
`),
		},
		Output: EventData{
			LegacyEvent: []byte(`{
  "data": {
    "data": null,
    "delta": {
      "grandchild": "other"
    }
  },
  "context": {
    "resource": "projects/_/instances/my-project-id/refs/gcf-test/xyz",
    "timestamp": "2020-05-21T11:15:34.178Z",
    "eventId": "/SnHth9OSlzK1Puj85kk4tDbF90=",
    "eventType": "providers/google.firebase.database/eventTypes/ref.write" 
  }
}
`),
		},
	},

	"firebase-db2": {
		Input: EventData{
			LegacyEvent: []byte(`{
  "eventType": "providers/google.firebase.database/eventTypes/ref.write",
  "params": {
    "child": "xyz"
  },
  "auth": {
    "admin": true
  },
  "data": {
    "data": {
      "grandchild": "other"
    },
    "delta": {
      "grandchild": "other changed"
    }
  },
  "resource": "projects/_/instances/my-project-id/refs/gcf-test/xyz",
  "timestamp": "2020-05-21T11:17:09.217Z",
  "eventId": "xaU5mk9HaahKU/T/XlPo/1ansu8="
}
`),
		},
		Output: EventData{
			LegacyEvent: []byte(`{
  "data": {
    "data": {
      "grandchild": "other"
    },
    "delta": {
      "grandchild": "other changed"
    }
  },
  "context": {
    "resource": "projects/_/instances/my-project-id/refs/gcf-test/xyz",
    "timestamp": "2020-05-21T11:17:09.217Z",
    "eventType": "providers/google.firebase.database/eventTypes/ref.write",
    "eventId": "xaU5mk9HaahKU/T/XlPo/1ansu8="
  }
}
`),
		},
	},

	"firebase-db3": {
		Input: EventData{
			LegacyEvent: []byte(`{
  "eventType": "providers/google.firebase.database/eventTypes/ref.write",
  "params": {
    "child": "abc"
  },
  "auth": {
    "admin": true
  },
  "data": {
    "data": null,
    "delta": 10
  },
  "resource": "projects/_/instances/my-project-id/refs/gcf-test/abc",
  "timestamp": "2020-05-21T11:17:17.809Z",
  "eventId": "kbAmkXNSQhmARA0JB5lcCt1Zpsg="
}
`),
		},
		Output: EventData{
			LegacyEvent: []byte(`{
  "data": {
    "data": null,
    "delta": 10
  },
  "context": {
    "resource": "projects/_/instances/my-project-id/refs/gcf-test/abc",
    "timestamp": "2020-05-21T11:17:17.809Z",
    "eventType": "providers/google.firebase.database/eventTypes/ref.write",
    "eventId": "kbAmkXNSQhmARA0JB5lcCt1Zpsg="
  }
}
`),
		},
	},

	"firebase-db4": {
		Input: EventData{
			LegacyEvent: []byte(`{
  "eventType": "providers/google.firebase.database/eventTypes/ref.write",
  "params": {
    "child": "xyz"
  },
  "auth": {
    "admin": true
  },
  "data": {
    "data": {
      "grandchild": "other changed"
    },
    "delta": {
      "deeply": {
        "nested": {
          "text": "This is deeply nested",
          "text2": "Second value"
        }
      }
    }
  },
  "resource": "projects/_/instances/my-project-id/refs/gcf-test/xyz",
  "timestamp": "2020-05-21T11:19:22.677Z",
  "eventId": "AlEKy6dsGnn48ubD7Y5QOoROj4U="
}
`),
		},
		Output: EventData{
			LegacyEvent: []byte(`{
  "data": {
    "data": {
      "grandchild": "other changed"
    },
    "delta": {
      "deeply": {
        "nested": {
          "text": "This is deeply nested",
          "text2": "Second value"
        }
      }
    }
  },
  "context": {
    "resource": "projects/_/instances/my-project-id/refs/gcf-test/xyz",
    "eventType": "providers/google.firebase.database/eventTypes/ref.write",
    "timestamp": "2020-05-21T11:19:22.677Z",
    "eventId": "AlEKy6dsGnn48ubD7Y5QOoROj4U="
  }
}
`),
		},
	},

	"firebase-db5": {
		Input: EventData{
			LegacyEvent: []byte(`{
  "eventType": "providers/google.firebase.database/eventTypes/ref.write",
  "params": {
    "child": "xyz"
  },
  "auth": {
    "admin": true
  },
  "data": {
    "data": {
      "deeply": {
        "nested": {
          "text": "This is deeply nested",
          "text2": "Second value"
        }
      },
      "grandchild": "other changed"
    },
    "delta": {
      "deeply": {
        "abc": "def"
      }
    }
  },
  "resource": "projects/_/instances/my-project-id/refs/gcf-test/xyz",
  "timestamp": "2020-05-21T11:21:07.809Z",
  "eventId": "9WBpn32ssA33ympcsuq/5JJmnDM="
}`),
		},
		Output: EventData{
			LegacyEvent: []byte(`{
  "data": {
    "data": {
      "deeply": {
        "nested": {
          "text": "This is deeply nested",
          "text2": "Second value"
        }
      },
      "grandchild": "other changed"
    },
    "delta": {
      "deeply": {
        "abc": "def"
      }
    }
  },
  "context": {
    "resource": "projects/_/instances/my-project-id/refs/gcf-test/xyz",
    "timestamp": "2020-05-21T11:21:07.809Z",
    "eventType": "providers/google.firebase.database/eventTypes/ref.write",
    "eventId": "9WBpn32ssA33ympcsuq/5JJmnDM="
  }
}
`),
		},
	},

	"firebase-db6": {
		Input: EventData{
			LegacyEvent: []byte(`{
  "eventType": "providers/google.firebase.database/eventTypes/ref.write",
  "params": {
    "child": "xyz"
  },
  "auth": {
    "admin": true
  },
  "data": {
    "data": {
      "deeply": {
        "abc": "def",
        "nested": {
          "text": "This is deeply nested",
          "text2": "Second value"
        }
      },
      "grandchild": "other changed"
    },
    "delta": {
      "deeply": {
        "nested": null
      }
    }
  },
  "resource": "projects/_/instances/my-project-id/refs/gcf-test/xyz",
  "timestamp": "2020-05-21T11:22:36.728Z",
  "eventId": "mtM1+41X04VNxshbrbl7ua3wnTI="
}
`),
		},
		Output: EventData{
			LegacyEvent: []byte(`{
  "data": {
    "data": {
      "deeply": {
        "abc": "def",
        "nested": {
          "text": "This is deeply nested",
          "text2": "Second value"
        }
      },
      "grandchild": "other changed"
    },
    "delta": {
      "deeply": {
        "nested": null
      }
    }
  },
  "context": {
    "resource": "projects/_/instances/my-project-id/refs/gcf-test/xyz",
    "timestamp": "2020-05-21T11:22:36.728Z",
    "eventType": "providers/google.firebase.database/eventTypes/ref.write",
    "eventId": "mtM1+41X04VNxshbrbl7ua3wnTI="
  }
}
`),
		},
	},

	"firebase-db7": {
		Input: EventData{
			LegacyEvent: []byte(`{
  "eventType": "providers/google.firebase.database/eventTypes/ref.write",
  "params": {
    "child": "xyz"
  },
  "auth": {
    "admin": true
  },
  "data": {
    "data": {
      "deeply": {
        "abc": "def"
      },
      "grandchild": "other changed"
    },
    "delta": {
      "deeply": {
        "abc": 10
      }
    }
  },
  "resource": "projects/_/instances/my-project-id/refs/gcf-test/xyz",
  "timestamp": "2020-05-21T11:23:46.225Z",
  "eventId": "fvnCmPWm8q4PPEKFRfrjuNxbQ00="
}`),
		},
		Output: EventData{
			LegacyEvent: []byte(`{
  "data": {
    "data": {
      "deeply": {
        "abc": "def"
      },
      "grandchild": "other changed"
    },
    "delta": {
      "deeply": {
        "abc": 10
      }
    }
  },
  "context": {
    "eventType": "providers/google.firebase.database/eventTypes/ref.write",
    "resource": "projects/_/instances/my-project-id/refs/gcf-test/xyz",
    "timestamp": "2020-05-21T11:23:46.225Z",
    "eventId": "fvnCmPWm8q4PPEKFRfrjuNxbQ00="
  }
}
`),
		},
	},

	"firebase-db8": {
		Input: EventData{
			LegacyEvent: []byte(`{
  "eventType": "providers/google.firebase.database/eventTypes/ref.write",
  "params": {
  },
  "auth": {
    "admin": true
  },
  "data": {
    "data": {
      "gcf-test": {
        "abc": 10,
        "child1": "value1",
        "xyz": {
          "deeply": {
            "abc": 11
          },
          "grandchild": "other changed"
        }
      },
      "not-gcf-test": "Foo"
    },
    "delta": {
      "gcf-test": {
        "xyz": {
          "deeply": {
            "abc": 12
          }
        }
      }
    }
  },
  "resource": "projects/_/instances/my-project-id/refs/",
  "timestamp": "2020-05-21T11:33:01.789Z",
  "eventId": "MazIvLoUshV35XHwjH+2rfP7uvk="
}`),
		},
		Output: EventData{
			LegacyEvent: []byte(`{
  "data": {
    "data": {
      "gcf-test": {
        "abc": 10,
        "child1": "value1",
        "xyz": {
          "deeply": {
            "abc": 11
          },
          "grandchild": "other changed"
        }
      },
      "not-gcf-test": "Foo"
    },
    "delta": {
      "gcf-test": {
        "xyz": {
          "deeply": {
            "abc": 12
          }
        }
      }
    }
  },
  "context": {
    "resource": "projects/_/instances/my-project-id/refs/",
    "timestamp": "2020-05-21T11:33:01.789Z",
    "eventType": "providers/google.firebase.database/eventTypes/ref.write",
    "eventId": "MazIvLoUshV35XHwjH+2rfP7uvk="
  }
}
`),
		},
	},

	"firebase-dbdelete1": {
		Input: EventData{
			LegacyEvent: []byte(`{
  "eventType": "providers/google.firebase.database/eventTypes/ref.delete",
  "params": {
    "child": "xyz"
  },
  "auth": {
    "admin": true
  },
  "data": {
    "data": {
      "grandchild": "other changed"
    },
    "delta": null
  },
  "resource": "projects/_/instances/my-project-id/refs/gcf-test/xyz",
  "timestamp": "2020-05-21T11:53:45.337Z",
  "eventId": "oIcVXHEMZfhQMNs/yD4nwpuKE0s="
}`),
		},
		Output: EventData{
			LegacyEvent: []byte(`{
  "data": {
    "data": {
      "grandchild": "other changed"
    },
    "delta": null
  },
  "context": {
    "resource": "projects/_/instances/my-project-id/refs/gcf-test/xyz",
    "timestamp": "2020-05-21T11:53:45.337Z",
    "eventType": "providers/google.firebase.database/eventTypes/ref.delete",
    "eventId": "oIcVXHEMZfhQMNs/yD4nwpuKE0s="
  }
}
`),
		},
	},

	"firebase-dbdelete2": {
		Input: EventData{
			LegacyEvent: []byte(`{
  "eventType": "providers/google.firebase.database/eventTypes/ref.delete",
  "params": {
    "child": "abc"
  },
  "auth": {
    "admin": true
  },
  "data": {
    "data": 10,
    "delta": null
  },
  "resource": "projects/_/instances/my-project-id/refs/gcf-test/abc",
  "timestamp": "2020-05-21T11:56:12.833Z",
  "eventId": "KVLKeFKjFP2jepddr+EPGC0ZQ20="
}
`),
		},
		Output: EventData{
			LegacyEvent: []byte(`{
  "data": {
    "data": 10,
    "delta": null
  },
  "context": {
    "resource": "projects/_/instances/my-project-id/refs/gcf-test/abc",
    "timestamp": "2020-05-21T11:56:12.833Z",
    "eventType": "providers/google.firebase.database/eventTypes/ref.delete",
    "eventId": "KVLKeFKjFP2jepddr+EPGC0ZQ20="
  }
}
`),
		},
	},

	"firestore_complex": {
		Input: EventData{
			LegacyEvent: []byte(`{
  "data": {
    "oldValue": {},
    "updateMask": {},
    "value": {
      "createTime": "2020-04-23T14:25:05.349632Z",
      "fields": {
        "arrayValue": {
          "arrayValue": {
            "values": [
              {
                "integerValue": "1"
              },
              {
                "integerValue": "2"
              }
            ]
          }
        },
        "booleanValue": {
          "booleanValue": true
        },
        "doubleValue": {
          "doubleValue": 5.5
        },
        "geoPointValue": {
          "geoPointValue": {
            "latitude": 51.4543,
            "longitude": -0.9781
          }
        },
        "intValue": {
          "integerValue": "50"
        },
        "mapValue": {
          "mapValue": {
            "fields": {
              "field1": {
                "stringValue": "x"
              },
              "field2": {
                "arrayValue": {
                  "values": [
                    {
                      "stringValue": "x"
                    },
                    {
                      "integerValue": "1"
                    }
                  ]
                }
              }
            }
          }
        },
        "nullValue": {
          "nullValue": null
        },
        "referenceValue": {
          "referenceValue": "projects/project-id/databases/(default)/documents/foo/bar/baz/qux"
        },
        "stringValue": {
          "stringValue": "text"
        },
        "timestampValue": {
          "timestampValue": "2020-04-23T14:23:53.241Z"
        }
      },
      "name": "projects/project-id/databases/(default)/documents/gcf-test/IH75dRdeYJKd4uuQiqch",
      "updateTime": "2020-04-23T14:25:05.349632Z"
    }
  },
  "eventId": "9babded5-e5f2-41af-a46a-06ba6bd84739-0",
  "eventType": "providers/cloud.firestore/eventTypes/document.write",
  "notSupported": {},
  "params": {
    "doc": "IH75dRdeYJKd4uuQiqch"
  },
  "resource": "projects/project-id/databases/(default)/documents/gcf-test/IH75dRdeYJKd4uuQiqch",
  "timestamp": "2020-04-23T14:25:05.349632Z"
}`),
		},
		Output: EventData{
			LegacyEvent: []byte(`{
  "data": {
    "oldValue": {},
    "updateMask": {},
    "value": {
      "createTime": "2020-04-23T14:25:05.349632Z",
      "fields": {
        "arrayValue": {
          "arrayValue": {
            "values": [
              {
                "integerValue": "1"
              },
              {
                "integerValue": "2"
              }
            ]
          }
        },
        "booleanValue": {
          "booleanValue": true
        },
        "doubleValue": {
          "doubleValue": 5.5
        },
        "geoPointValue": {
          "geoPointValue": {
            "latitude": 51.4543,
            "longitude": -0.9781
          }
        },
        "intValue": {
          "integerValue": "50"
        },
        "mapValue": {
          "mapValue": {
            "fields": {
              "field1": {
                "stringValue": "x"
              },
              "field2": {
                "arrayValue": {
                  "values": [
                    {
                      "stringValue": "x"
                    },
                    {
                      "integerValue": "1"
                    }
                  ]
                }
              }
            }
          }
        },
        "nullValue": {
          "nullValue": null
        },
        "referenceValue": {
          "referenceValue": "projects/project-id/databases/(default)/documents/foo/bar/baz/qux"
        },
        "stringValue": {
          "stringValue": "text"
        },
        "timestampValue": {
          "timestampValue": "2020-04-23T14:23:53.241Z"
        }
      },
      "name": "projects/project-id/databases/(default)/documents/gcf-test/IH75dRdeYJKd4uuQiqch",
      "updateTime": "2020-04-23T14:25:05.349632Z"
    }
  },
  "context": {
    "eventId": "9babded5-e5f2-41af-a46a-06ba6bd84739-0",
    "eventType": "providers/cloud.firestore/eventTypes/document.write",
    "resource": "projects/project-id/databases/(default)/documents/gcf-test/IH75dRdeYJKd4uuQiqch",
    "timestamp": "2020-04-23T14:25:05.349632Z"
  }
}
`),
		},
	},

	"firestore_simple": {
		Input: EventData{
			LegacyEvent: []byte(`{
   "data":{
      "oldValue":{
         "createTime":"2020-04-23T09:58:53.211035Z",
         "fields":{
            "another test":{
               "stringValue":"asd"
            },
            "count":{
               "integerValue":"3"
            },
            "foo":{
               "stringValue":"bar"
            }
         },
         "name":"projects/project-id/databases/(default)/documents/gcf-test/2Vm2mI1d0wIaK2Waj5to",
         "updateTime":"2020-04-23T12:00:27.247187Z"
      },
      "updateMask":{
         "fieldPaths":[
            "count"
         ]
      },
      "value":{
         "createTime":"2020-04-23T09:58:53.211035Z",
         "fields":{
            "another test":{
               "stringValue":"asd"
            },
            "count":{
               "integerValue":"4"
            },
            "foo":{
               "stringValue":"bar"
            }
         },
         "name":"projects/project-id/databases/(default)/documents/gcf-test/2Vm2mI1d0wIaK2Waj5to",
         "updateTime":"2020-04-23T12:00:27.247187Z"
      }
   },
   "eventId":"7b8f1804-d38b-4b68-b37d-e2fb5d12d5a0-0",
   "eventType":"providers/cloud.firestore/eventTypes/document.write",
   "notSupported":{

   },
   "params":{
      "doc":"2Vm2mI1d0wIaK2Waj5to"
   },
   "resource":"projects/project-id/databases/(default)/documents/gcf-test/2Vm2mI1d0wIaK2Waj5to",
   "timestamp":"2020-04-23T12:00:27.247187Z"
}
`),
		},
		Output: EventData{
			LegacyEvent: []byte(`{
   "data":{
      "oldValue":{
         "createTime":"2020-04-23T09:58:53.211035Z",
         "fields":{
            "another test":{
               "stringValue":"asd"
            },
            "count":{
               "integerValue":"3"
            },
            "foo":{
               "stringValue":"bar"
            }
         },
         "name":"projects/project-id/databases/(default)/documents/gcf-test/2Vm2mI1d0wIaK2Waj5to",
         "updateTime":"2020-04-23T12:00:27.247187Z"
      },
      "updateMask":{
         "fieldPaths":[
            "count"
         ]
      },
      "value":{
         "createTime":"2020-04-23T09:58:53.211035Z",
         "fields":{
            "another test":{
               "stringValue":"asd"
            },
            "count":{
               "integerValue":"4"
            },
            "foo":{
               "stringValue":"bar"
            }
         },
         "name":"projects/project-id/databases/(default)/documents/gcf-test/2Vm2mI1d0wIaK2Waj5to",
         "updateTime":"2020-04-23T12:00:27.247187Z"
      }
   },
   "context": {
     "eventId":"7b8f1804-d38b-4b68-b37d-e2fb5d12d5a0-0",
     "eventType":"providers/cloud.firestore/eventTypes/document.write",
     "resource":"projects/project-id/databases/(default)/documents/gcf-test/2Vm2mI1d0wIaK2Waj5to",
     "timestamp":"2020-04-23T12:00:27.247187Z"
   }
}
`),
		},
	},

	"legacy_pubsub": {
		Input: EventData{
			LegacyEvent: []byte(`{
  "eventId": "1215011316659232",
  "timestamp": "2020-05-18T12:13:19.209Z",
  "eventType": "providers/cloud.pubsub/eventTypes/topic.publish",
  "resource": "projects/sample-project/topics/gcf-test",
  "data": {
    "@type": "type.googleapis.com/google.pubsub.v1.PubsubMessage",
    "attributes": {
      "attribute1": "value1"
    },
    "data": "VGhpcyBpcyBhIHNhbXBsZSBtZXNzYWdl"
  }
}
`),
		},
		Output: EventData{
			LegacyEvent: []byte(`{
  "context": {
    "eventId": "1215011316659232",
    "timestamp": "2020-05-18T12:13:19.209Z",
    "eventType": "providers/cloud.pubsub/eventTypes/topic.publish",
    "resource": "projects/sample-project/topics/gcf-test"
  },
  "data": {
    "@type": "type.googleapis.com/google.pubsub.v1.PubsubMessage",
    "attributes": {
      "attribute1": "value1"
    },
    "data": "VGhpcyBpcyBhIHNhbXBsZSBtZXNzYWdl"
  }
}
`),
		},
	},

	"legacy_storage_change": {
		Input: EventData{
			LegacyEvent: []byte(`{
  "data": {
    "bucket": "sample-bucket",
    "crc32c": "AAAAAA==",
    "etag": "COu8mb3Dn+kCEAE=",
    "generation": "1588778055917163",
    "id": "sample-bucket/MyFile/1588778055917163",
    "kind": "storage#object",
    "md5Hash": "ZDQxZDhjZDk4ZjAwYjIwNGU5ODAwOTk4ZWNmODQyN2U=",
    "mediaLink": "https://www.googleapis.com/download/storage/v1/b/projectid-sample-bucket/o/MyFile?generation=1588778055917163\u0026alt=media",
    "metageneration": "1",
    "name": "MyFile",
    "resourceState": "not_exists",
    "selfLink": "https://www.googleapis.com/storage/v1/b/projectid-sample-bucket/o/MyFile",
    "size": "0",
    "storageClass": "MULTI_REGIONAL",
    "timeCreated": "2020-05-06T15:14:15.917Z",
    "timeDeleted": "2020-05-18T09:07:51.799Z",
    "timeStorageClassUpdated": "2020-05-06T15:14:15.917Z",
    "updated": "2020-05-06T15:14:15.917Z"
  },
  "eventId": "1200401551653202",
  "eventType": "providers/cloud.storage/eventTypes/object.change",
  "resource": "projects/_/buckets/sample-bucket/objects/MyFile#1588778055917163",
  "timestamp": "2020-05-18T09:07:51.799Z"
}
`),
		},
		Output: EventData{
			LegacyEvent: []byte(`{
  "data": {
    "bucket": "sample-bucket",
    "crc32c": "AAAAAA==",
    "etag": "COu8mb3Dn+kCEAE=",
    "generation": "1588778055917163",
    "id": "sample-bucket/MyFile/1588778055917163",
    "kind": "storage#object",
    "md5Hash": "ZDQxZDhjZDk4ZjAwYjIwNGU5ODAwOTk4ZWNmODQyN2U=",
    "mediaLink": "https://www.googleapis.com/download/storage/v1/b/projectid-sample-bucket/o/MyFile?generation=1588778055917163\u0026alt=media",
    "metageneration": "1",
    "name": "MyFile",
    "resourceState": "not_exists",
    "selfLink": "https://www.googleapis.com/storage/v1/b/projectid-sample-bucket/o/MyFile",
    "size": "0",
    "storageClass": "MULTI_REGIONAL",
    "timeCreated": "2020-05-06T15:14:15.917Z",
    "timeDeleted": "2020-05-18T09:07:51.799Z",
    "timeStorageClassUpdated": "2020-05-06T15:14:15.917Z",
    "updated": "2020-05-06T15:14:15.917Z"
  },
  "context": {
    "eventId": "1200401551653202",
    "eventType": "providers/cloud.storage/eventTypes/object.change",
    "resource": "projects/_/buckets/sample-bucket/objects/MyFile#1588778055917163",
    "timestamp": "2020-05-18T09:07:51.799Z"
  }
}
`),
		},
	},

	"pubsub_binary": {
		Input: EventData{
			LegacyEvent: []byte(`{
   "context": {
      "eventId":"1144231683168617",
      "timestamp":"2020-05-06T07:33:34.556Z",
      "eventType":"google.pubsub.topic.publish",
      "resource":{
        "service":"pubsub.googleapis.com",
        "name":"projects/sample-project/topics/gcf-test",
        "type":"type.googleapis.com/google.pubsub.v1.PubsubMessage"
      }
   },
   "data": {
      "@type": "type.googleapis.com/google.pubsub.v1.PubsubMessage",
      "data": "AQIDBA=="
   }
}
`),
		},
		Output: EventData{
			LegacyEvent: []byte(`{
   "context": {
      "eventId":"1144231683168617",
      "timestamp":"2020-05-06T07:33:34.556Z",
      "eventType":"google.pubsub.topic.publish",
      "resource":{
        "service":"pubsub.googleapis.com",
        "name":"projects/sample-project/topics/gcf-test",
        "type":"type.googleapis.com/google.pubsub.v1.PubsubMessage"
      }
   },
   "data": {
      "@type": "type.googleapis.com/google.pubsub.v1.PubsubMessage",
      "data": "AQIDBA=="
   }
}
`),
		},
	},

	"pubsub_text": {
		Input: EventData{
			LegacyEvent: []byte(`{
   "context": {
      "eventId":"1144231683168617",
      "timestamp":"2020-05-06T07:33:34.556Z",
      "eventType":"google.pubsub.topic.publish",
      "resource":{
        "service":"pubsub.googleapis.com",
        "name":"projects/sample-project/topics/gcf-test",
        "type":"type.googleapis.com/google.pubsub.v1.PubsubMessage"
      }
   },
   "data": {
      "@type": "type.googleapis.com/google.pubsub.v1.PubsubMessage",
      "attributes": {
         "attr1":"attr1-value"
      },
      "data": "dGVzdCBtZXNzYWdlIDM="
   }
}
`),
		},
		Output: EventData{
			LegacyEvent: []byte(`{
   "context": {
      "eventId":"1144231683168617",
      "timestamp":"2020-05-06T07:33:34.556Z",
      "eventType":"google.pubsub.topic.publish",
      "resource":{
        "service":"pubsub.googleapis.com",
        "name":"projects/sample-project/topics/gcf-test",
        "type":"type.googleapis.com/google.pubsub.v1.PubsubMessage"
      }
   },
   "data": {
      "@type": "type.googleapis.com/google.pubsub.v1.PubsubMessage",
      "attributes": {
         "attr1":"attr1-value"
      },
      "data": "dGVzdCBtZXNzYWdlIDM="
   }
}
`),
		},
	},

	"storage": {
		Input: EventData{
			LegacyEvent: []byte(`{
   "context": {
      "eventId": "1147091835525187",
      "timestamp": "2020-04-23T07:38:57.772Z",
      "eventType": "google.storage.object.finalize",
      "resource": {
         "service": "storage.googleapis.com",
         "name": "projects/_/buckets/some-bucket/objects/folder/Test.cs",
         "type": "storage#object"
      }
   },
   "data": {
      "bucket": "some-bucket",
      "contentType": "text/plain",
      "crc32c": "rTVTeQ==",
      "etag": "CNHZkbuF/ugCEAE=",
      "generation": "1587627537231057",
      "id": "some-bucket/folder/Test.cs/1587627537231057",
      "kind": "storage#object",
      "md5Hash": "kF8MuJ5+CTJxvyhHS1xzRg==",
      "mediaLink": "https://www.googleapis.com/download/storage/v1/b/some-bucket/o/folder%2FTest.cs?generation=1587627537231057\u0026alt=media",
      "metageneration": "1",
      "name": "folder/Test.cs",
      "selfLink": "https://www.googleapis.com/storage/v1/b/some-bucket/o/folder/Test.cs",
      "size": "352",
      "storageClass": "MULTI_REGIONAL",
      "timeCreated": "2020-04-23T07:38:57.230Z",
      "timeStorageClassUpdated": "2020-04-23T07:38:57.230Z",
      "updated": "2020-04-23T07:38:57.230Z"
   }
}
`),
		},
		Output: EventData{
			LegacyEvent: []byte(`{
   "context": {
      "eventId": "1147091835525187",
      "timestamp": "2020-04-23T07:38:57.772Z",
      "eventType": "google.storage.object.finalize",
      "resource": {
         "service": "storage.googleapis.com",
         "name": "projects/_/buckets/some-bucket/objects/folder/Test.cs",
         "type": "storage#object"
      }
   },
   "data": {
      "bucket": "some-bucket",
      "contentType": "text/plain",
      "crc32c": "rTVTeQ==",
      "etag": "CNHZkbuF/ugCEAE=",
      "generation": "1587627537231057",
      "id": "some-bucket/folder/Test.cs/1587627537231057",
      "kind": "storage#object",
      "md5Hash": "kF8MuJ5+CTJxvyhHS1xzRg==",
      "mediaLink": "https://www.googleapis.com/download/storage/v1/b/some-bucket/o/folder%2FTest.cs?generation=1587627537231057\u0026alt=media",
      "metageneration": "1",
      "name": "folder/Test.cs",
      "selfLink": "https://www.googleapis.com/storage/v1/b/some-bucket/o/folder/Test.cs",
      "size": "352",
      "storageClass": "MULTI_REGIONAL",
      "timeCreated": "2020-04-23T07:38:57.230Z",
      "timeStorageClassUpdated": "2020-04-23T07:38:57.230Z",
      "updated": "2020-04-23T07:38:57.230Z"
   }
}
`),
		},
	},
}

Functions

func BuildCloudEvent 

func BuildCloudEvent(data []byte) (*cloudevents.Event, error)

BuildCloudEvent creates a CloudEvent from a byte slice.

func EventNames 

func EventNames(t EventType) ([]string, error)

EventNames returns a list of event names to use as inputs for a particular event type.

func InputData 

func InputData(name string, t EventType) []byte

InputData returns the contents of the input event for a particular event name and type.

func OutputData 

func OutputData(name string, t EventType) []byte

OutputData returns the contents of the output event for a particular event name and type.

func PrintValidationInfos 

func PrintValidationInfos(vis []*ValidationInfo) (string, error)

PrintValidationInfos takes a list of ValidationInfos and collapses them into a single error and a single log line recording which events were validation, which skipped, and why.

Types

type Event 

type Event struct {
	Input  EventData
	Output EventData
}

type EventData 

type EventData struct {
	LegacyEvent []byte
	CloudEvent  []byte
}

type EventType 

type EventType int

EventType is the type of event to validate. 

const (
	// LegacyEvent represents a legacy event type.
	LegacyEvent EventType = iota
	// CloudEvent represents a CloudEvent type.
	CloudEvent
)

func (EventType) String 

func (e EventType) String() string

type ValidationInfo 

type ValidationInfo struct {
	Name          string
	Errs          []error
	SkippedReason string
}

ValidationInfo contains information about a particular validation step, including a reason why the validation for this event and type was skipped or the relevant error.

func ValidateEvent 

func ValidateEvent(name string, t EventType, got []byte) *ValidationInfo

ValidateEvent validates that a particular function output matches the expected contents.

Source Files

View all Source files

Directories

Path Synopsis
This binary generates usable Go code from the data files.
 This binary generates usable Go code from the data files.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.