chore(eventarc): rename existing region, and update to use cloudevent sdk. (#10232)

* chore(eventarc): rename existing region, and update to use cloudevent
sdk.

* lint fix from prior merge

* 🦉 Updates from OwlBot post-processor

See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md

---------

Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>

Author: muncus

eventarc/audit-storage/main.py

@@ -12,31 +12,40 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
+# [START eventarc_http_quickstart_server]
 # [START eventarc_audit_storage_server]
 import os
 
-from flask import Flask, request
+from cloudevents.http import from_http
 
+from flask import Flask, request
 
 app = Flask(__name__)
 # [END eventarc_audit_storage_server]
+# [END eventarc_http_quickstart_server]
 
 
+# [START eventarc_http_quickstart_handler]
 # [START eventarc_audit_storage_handler]
 @app.route("/", methods=["POST"])
 def index():
-    # Gets the GCS bucket name from the CloudEvent header
+    # Create a CloudEvent object from the incoming request
+    event = from_http(request.headers, request.data)
+    # Gets the GCS bucket name from the CloudEvent
     # Example: "storage.googleapis.com/projects/_/buckets/my-bucket"
-    bucket = request.headers.get("ce-subject")
+    bucket = event.get("subject")
 
     print(f"Detected change in Cloud Storage bucket: {bucket}")
     return (f"Detected change in Cloud Storage bucket: {bucket}", 200)
 
 
 # [END eventarc_audit_storage_handler]
+# [END eventarc_http_quickstart_handler]
 
 
+# [START eventarc_http_quickstart_server]
 # [START eventarc_audit_storage_server]
 if __name__ == "__main__":
     app.run(debug=True, host="0.0.0.0", port=int(os.environ.get("PORT", 8080)))
 # [END eventarc_audit_storage_server]
+# [END eventarc_http_quickstart_server]

eventarc/audit-storage/main_test.py

@@ -11,20 +11,23 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
-import copy
 
 from uuid import uuid4
 
+from cloudevents.conversion import to_binary
+from cloudevents.http import CloudEvent
+
 import pytest
 
 import main
 
 
-binary_headers = {
-    "ce-id": str(uuid4),
-    "ce-type": "com.pytest.sample.event",
-    "ce-source": "<my-test-source>",
-    "ce-specversion": "1.0",
+ce_attributes = {
+    "id": str(uuid4),
+    "type": "com.pytest.sample.event",
+    "source": "<my-test-source>",
+    "specversion": "1.0",
+    "subject": "test-bucket",
 }
 
 
@@ -34,14 +37,11 @@ def client():
     return main.app.test_client()
 
 
-def test_endpoint(client, capsys):
-    test_headers = copy.copy(binary_headers)
-    test_headers["Ce-Subject"] = "test-subject"
+def test_endpoint(client):
+    event = CloudEvent(ce_attributes, dict())
 
-    r = client.post("/", headers=test_headers)
-    assert r.status_code == 200
+    headers, body = to_binary(event)
 
-    out, _ = capsys.readouterr()
-    assert (
-        f"Detected change in Cloud Storage bucket: {test_headers['Ce-Subject']}" in out
-    )
+    r = client.post("/", headers=headers, data=body)
+    assert r.status_code == 200
+    assert "Detected change in Cloud Storage bucket: test-bucket" in r.text

eventarc/audit-storage/requirements.txt

@@ -1,2 +1,3 @@
 Flask==2.1.0
 gunicorn==20.1.0
+cloudevents==1.9.0