add server and messenger snippets

Author: maxkahan

.env.dist

@@ -15,7 +15,10 @@ WHATSAPP_NUMBER='YOUR_WHATSAPP_NUMBER'
 CATALOG_ID='YOUR_CATALOG_ID'
 PRODUCT_RETAILER_ID='YOUR_PRODUCT_RETAILER_ID'
 VIBER_SERVICE_MESSAGE_ID='YOUR_VIBER_SERVICE_MESSAGE_ID'
+AUDIO_URL='EXAMPLE_AUDIO_URL'
 IMAGE_URL='EXAMPLE_IMAGE_URL'
+FILE_URL='EXAMPLE_FILE_URL'
+VIDEO_URL='EXAMPLE_VIDEO_URL'
 WHATSAPP_TEMPLATE_REPLACEMENT_TEXT='EXAMPLE_TEMPLATE_REPLACEMENT_TEXT'
 RCS_SENDER_ID='YOUR_RCS_SENDER_ID'
 

decode-jwt/README.md

@@ -0,0 +1,39 @@
+# Verifying Signed Webhooks Demo
+
+This quick demo shows how to verify an incoming Webhook signature by decoding the incoming JWT sent by Vonage.
+
+For signed incoming SMS signatures through the Messaging API, please see the snippet for verifying a signed incoming SMS message instead.
+
+## Usage
+
+You may want to use a localhost tunnel agent such as [ngrok](https://ngrok.com/) for local testing.
+
+### Set Up Your Enviroment
+
+Install dependencies with `pip` in a virtual environment:
+
+```bash
+python3 -m venv venv
+. ./venv/bin/activate
+
+# Point to the requirements file in the root of the python-code-snippets repo
+pip install -r requirements.txt
+```
+
+### Set Up an Incoming Webhook
+1. Start ngrok with `ngrok http 8000`. ngrok will give you a forwarding address you can now use to recieve event webhooks.
+1. Go to the [Customer Dashboard](https://dashboard.nexmo.com/sign-in).
+1. Click on ["Applications"](https://dashboard.nexmo.com/applications).
+1. Click the three dots and select "Edit" for the application you are using.
+1. Under "Capabilities", enter `https://your-ngrok-url/events` for the Voice capability.
+1. Click "Save".
+
+### Start the FastAPI Server
+
+Run the FastAPI server with
+
+```bash
+fastapi dev decode-jwt/main.py
+```
+
+You can now create a voice call using the voice sample in this repo. This sample app will verify the incoming signature.

decode-jwt/main.py

@@ -0,0 +1,28 @@
+import os
+from os.path import join, dirname
+
+from dotenv import load_dotenv
+
+# Load the environment
+envpath = join(dirname(__file__), '../.env')
+load_dotenv(envpath)
+
+
+VONAGE_SIGNATURE = os.getenv('VONAGE_SIGNATURE')
+
+from fastapi import FastAPI, Request
+from vonage_jwt.verify_jwt import verify_signature
+
+app = FastAPI()
+
+
+@app.get('/events')
+async def verify_signed_webhook(request: Request):
+    # Need to get the JWT after "Bearer " in the authorization header
+    auth_header = request.headers["authorization"].split()
+    token = auth_header[1].strip()
+
+    if verify_signature(token, VONAGE_SIGNATURE):
+        print('Valid signature')
+    else:
+        print('Invalid signature')

initialize/application.py

@@ -1,16 +1,10 @@
-#!/usr/bin/env python3
 from pprint import pprint
-from flask import Flask, request
+from fastapi import FastAPI, Request
 
-app = Flask(__name__)
+app = FastAPI()
 
 
-@app.route("/webhooks/inbound-message", methods=["POST"])
-def inbound_message():
-    data = request.get_json()
+@app.post('/inbound')
+async def inbound_message(request: Request):
+    data = await request.json()
     pprint(data)
-    return "200"
-
-
-if __name__ == "__main__":
-    app.run(host="www.example.org", port=3000)

initialize/basic.py

@@ -1,16 +1,10 @@
-#!/usr/bin/env python3
 from pprint import pprint
-from flask import Flask, request
+from fastapi import FastAPI, Request, status
 
-app = Flask(__name__)
+app = FastAPI()
 
 
-@app.route("/webhooks/message-status", methods=["POST"])
-def message_status():
-    data = request.get_json()
+@app.post('/status', status_code=status.HTTP_200_OK)
+async def status_message(request: Request):
+    data = await request.json()
     pprint(data)
-    return "200"
-
-
-if __name__ == "__main__":
-    app.run(host="www.example.org", port=3000)

initialize/full.py

@@ -0,0 +1,34 @@
+import os
+from os.path import join, dirname
+from dotenv import load_dotenv
+
+dotenv_path = join(dirname(__file__), "../../.env")
+load_dotenv(dotenv_path)
+
+VONAGE_APPLICATION_ID = os.environ.get("VONAGE_APPLICATION_ID")
+VONAGE_APPLICATION_PRIVATE_KEY_PATH = os.environ.get(
+    "VONAGE_APPLICATION_PRIVATE_KEY_PATH"
+)
+
+VONAGE_FB_SENDER_ID = os.environ.get("VONAGE_FB_SENDER_ID")
+FB_RECIPIENT_ID = os.environ.get("FB_RECIPIENT_ID")
+AUDIO_URL = os.environ.get("AUDIO_URL")
+
+from vonage import Auth, Vonage
+from vonage_messages.models import MessengerAudio, MessengerResource
+
+client = Vonage(
+    Auth(
+        application_id=VONAGE_APPLICATION_ID,
+        private_key=VONAGE_APPLICATION_PRIVATE_KEY_PATH,
+    )
+)
+
+message = MessengerAudio(
+    to=FB_RECIPIENT_ID,
+    from_=VONAGE_FB_SENDER_ID,
+    audio=MessengerResource(url=AUDIO_URL),
+)
+
+response = client.messages.send(message)
+print(response)

jwt/decode-jwt/.env.dist

@@ -0,0 +1,34 @@
+import os
+from os.path import join, dirname
+from dotenv import load_dotenv
+
+dotenv_path = join(dirname(__file__), "../../.env")
+load_dotenv(dotenv_path)
+
+VONAGE_APPLICATION_ID = os.environ.get("VONAGE_APPLICATION_ID")
+VONAGE_APPLICATION_PRIVATE_KEY_PATH = os.environ.get(
+    "VONAGE_APPLICATION_PRIVATE_KEY_PATH"
+)
+
+VONAGE_FB_SENDER_ID = os.environ.get("VONAGE_FB_SENDER_ID")
+FB_RECIPIENT_ID = os.environ.get("FB_RECIPIENT_ID")
+FILE_URL = os.environ.get("FILE_URL")
+
+from vonage import Auth, Vonage
+from vonage_messages.models import MessengerFile, MessengerResource
+
+client = Vonage(
+    Auth(
+        application_id=VONAGE_APPLICATION_ID,
+        private_key=VONAGE_APPLICATION_PRIVATE_KEY_PATH,
+    )
+)
+
+message = MessengerFile(
+    to=FB_RECIPIENT_ID,
+    from_=VONAGE_FB_SENDER_ID,
+    file=MessengerResource(url=FILE_URL),
+)
+
+response = client.messages.send(message)
+print(response)

jwt/decode-jwt/Pipfile

@@ -0,0 +1,34 @@
+import os
+from os.path import join, dirname
+from dotenv import load_dotenv
+
+dotenv_path = join(dirname(__file__), "../../.env")
+load_dotenv(dotenv_path)
+
+VONAGE_APPLICATION_ID = os.environ.get("VONAGE_APPLICATION_ID")
+VONAGE_APPLICATION_PRIVATE_KEY_PATH = os.environ.get(
+    "VONAGE_APPLICATION_PRIVATE_KEY_PATH"
+)
+
+VONAGE_FB_SENDER_ID = os.environ.get("VONAGE_FB_SENDER_ID")
+FB_RECIPIENT_ID = os.environ.get("FB_RECIPIENT_ID")
+IMAGE_URL = os.environ.get("IMAGE_URL")
+
+from vonage import Auth, Vonage
+from vonage_messages.models import MessengerImage, MessengerResource
+
+client = Vonage(
+    Auth(
+        application_id=VONAGE_APPLICATION_ID,
+        private_key=VONAGE_APPLICATION_PRIVATE_KEY_PATH,
+    )
+)
+
+message = MessengerImage(
+    to=FB_RECIPIENT_ID,
+    from_=VONAGE_FB_SENDER_ID,
+    image=MessengerResource(url=IMAGE_URL),
+)
+
+response = client.messages.send(message)
+print(response)