Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

docs: tutorial for WebSockets with AsyncAPI #2245

Merged
merged 32 commits into from
Feb 7, 2024
Merged
Changes from 7 commits
Commits
Show all changes
32 commits
Select commit Hold shift + click to select a range
cfab591
Initial draft
VaishnaviNandakumar Oct 18, 2023
9acefa7
Added steps and diagrams
VaishnaviNandakumar Oct 19, 2023
5d04881
Fixed minor issues
VaishnaviNandakumar Oct 19, 2023
10b8382
Added content for hello event
VaishnaviNandakumar Oct 25, 2023
d073e0b
Removed remember tag
VaishnaviNandakumar Oct 25, 2023
dd97bd7
Renamed instances of SlackBot
VaishnaviNandakumar Oct 26, 2023
353e7bb
Renamed instances of SlackBot
VaishnaviNandakumar Oct 26, 2023
91d716d
Renamed slack-bot name and updated AsyncAPI doc
VaishnaviNandakumar Oct 31, 2023
05c57bd
Changed tutorial path and included review suggestions
VaishnaviNandakumar Nov 8, 2023
a1f3929
Changed order of message sections and updated AsyncAPI doc
VaishnaviNandakumar Nov 14, 2023
d4342da
Added desc for queries
VaishnaviNandakumar Nov 14, 2023
8fcd64c
Update pages/docs/tutorials/slackbot-websocket-tutorial.md
VaishnaviNandakumar Nov 15, 2023
e8eeade
Update pages/docs/tutorials/slackbot-websocket-tutorial.md
VaishnaviNandakumar Nov 15, 2023
aa98467
Update slackbot-websocket-tutorial.md
VaishnaviNandakumar Nov 15, 2023
ca53959
Merge branch 'master' into master
quetzalliwrites Nov 15, 2023
ab59901
Added new directory - WebSocket
VaishnaviNandakumar Nov 17, 2023
6002a98
Updated weights
VaishnaviNandakumar Nov 17, 2023
5439191
Updated weights
VaishnaviNandakumar Nov 17, 2023
f4317b0
Made minor change in asyncapi doc and fixed typo
VaishnaviNandakumar Dec 7, 2023
a2023eb
Added codeblocks and removed const description
VaishnaviNandakumar Dec 25, 2023
ca05916
Closed code block
VaishnaviNandakumar Dec 25, 2023
bc2c089
Fixed code block typo
VaishnaviNandakumar Dec 25, 2023
dad9b59
Fixed code block typo
VaishnaviNandakumar Dec 25, 2023
2035171
Fixed code block typo
VaishnaviNandakumar Dec 25, 2023
05ba1b8
Fixed code block typo
VaishnaviNandakumar Dec 26, 2023
c2b66d8
Fix indentation
VaishnaviNandakumar Dec 26, 2023
2e59527
Fix indentation
VaishnaviNandakumar Dec 26, 2023
014be36
Added highlighted code
VaishnaviNandakumar Jan 15, 2024
09b0df6
Added highlighted code
VaishnaviNandakumar Jan 15, 2024
cd3ab4f
Added highlighted code
VaishnaviNandakumar Jan 15, 2024
f76ed46
Merge branch 'master' into master
quetzalliwrites Feb 7, 2024
d305437
editorial fixes
quetzalliwrites Feb 7, 2024
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
313 changes: 313 additions & 0 deletions pages/docs/tutorials/getting-started/slackbot-websocket-tutorial.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,313 @@
---
VaishnaviNandakumar marked this conversation as resolved.
Show resolved Hide resolved
title: Creating an AsyncAPI Document for a SlackBot in Socket Mode
description: In this tutorial, you'll learn how to create an AsyncAPI document designed for a Slack application that operates in Socket Mode.
weight: 80
VaishnaviNandakumar marked this conversation as resolved.
Show resolved Hide resolved
---

## Introduction
In this tutorial, you will learn how to generate an AsyncAPI document designed for a Slack application that operates in Socket Mode. Our aim is to help you grasp a real-world application of AsyncAPI with the WebSocket protocol.

Consider a scenario where you are in charge of maintaining a highly active Slack workspace. You want an easy way to keep track of the popular messages across all the channels but doing this manually would be a difficult task. To simplify this process, you’re going to build a Slackbot called my-slack-bot that actively monitors reactions added to a message and determine its popularity by counting the reactions of the “heart” emoji.

Here’s a visual representation of how my-slack-bot should work.
VaishnaviNandakumar marked this conversation as resolved.
Show resolved Hide resolved

```mermaid
sequenceDiagram
participant my-slack-bot
participant Slack Server (Socket Mode)
participant User


my-slack-bot->>Slack Server (Socket Mode): Connect
Note right of my-slack-bot: Establish WebSocket connection


Slack Server (Socket Mode)->> my-slack-bot : Handshake
Note left of Slack Server (Socket Mode): Establish Socket Mode connection

Slack Server (Socket Mode)->> my-slack-bot : Sends "hello" event
Note left of Slack Server (Socket Mode): Confirms successful connection





User-->>Slack Server (Socket Mode): Adds emoji to a message.


Slack Server (Socket Mode)->>my-slack-bot: Sending "reaction_added" payload


Note left of my-slack-bot: Event received
```

## Background context
[WebSocket](https://en.wikipedia.org/wiki/WebSocket) is a communication protocol that enables full-duplex, bidirectional data exchange between a client and a server over a single, long-lived connection. Unlike HTTP, which relies on the request-response model, WebSocket is ideal for scenarios where real-time, interactive and low-latency communication is necessary.


```mermaid
sequenceDiagram
Client -->> Server: Initiate WebSocket Connection
Server -->> Client: WebSocket Response
Server -->> Client: WebSocket Response
Server -->> Client: WebSocket Response
Server -->> Client: WebSocket Response
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Not only the server but client can sends a message in any instance of time. I would remove Response keyword since there is no Request or Response in websocket.

Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

well, there is a response, but not always, so yeah, can be must a message

```

In Slack, WebSocket is employed as part of its [Socket Mode](https://api.slack.com/apis/connections/socket) feature to facilitate real-time notifications between Slack's servers and third-party applications or bots. Socket Mode simplifies Slack app development by eliminating complex infrastructure challenges faced with HTTP, offering simpler and more feature driven solutions for app developers.


The [Slack Event API](https://api.slack.com/apis/connections/events-api) is a tool that lets developers receive real-time notifications of specific events in a Slack workspace. By subscribing to event types like messages, reactions, and user presence changes, this API enhances automation within the Slack platform, making it a powerful resource for building custom integrations and chatbots.



## Define AsyncAPI Version, API Information, and Server
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
## Define AsyncAPI Version, API Information, and Server
## Define AsyncAPI version, API information, and server

We observe sentence capitalization for headers, let's make sure to fix them all :)


You start your AsyncAPI document by specifying the AsyncAPI version and essential information about your Slack application's API which includes details such as the `title`, `version` and `description`.

The `ws` server section allows you to define the protocol and specify information about the URLs your application will use, such as `host`, `pathname`, and `description`.

The WebSocket URL is generated by invoking the [apps.connections.open](https://api.slack.com/methods/apps.connections.open) method from Slack’s API. You use the authorization tokens obtained during the configuration of my-slack-bot to generate this URL.

```
asyncapi: '3.0.0'
info:
title: MySlackBot API
version: '1.0.0'
description: |
The MySlackBot App manages popular messages in a workspace by monitoring message reaction data from Slack's Event API.

servers:
ws:
VaishnaviNandakumar marked this conversation as resolved.
Show resolved Hide resolved
host: wss://wss-primary.slack.com/
pathname: link/?ticket=13748dac-b866-4ea7-b98e-4fb7895c0a7f&app_id=fe684dfa62159c6ac646beeac31c8f4ef415e4f39c626c2dbd1530e3a690892f
protocol: wss
description: "Websocket URL generated to communicate with Slack"
```


## Define Operations and Channels
The `operation` property, is all about defining specific tasks your application can perform. Essentially, it's how my-slack-bot interacts with Slack.
VaishnaviNandakumar marked this conversation as resolved.
Show resolved Hide resolved

In this example, the `helloListenerOperation` keeps an eye out for the message sent by the Slack server when a WebSocket connection is successfully established. On the other hand, the `reactionListener` is focused on the reaction_added event type.
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
In this example, the `helloListenerOperation` keeps an eye out for the message sent by the Slack server when a WebSocket connection is successfully established. On the other hand, the `reactionListener` is focused on the reaction_added event type.
In this example, the `helloListenerOperation` keeps an eye out for the message sent by the Slack server when a WebSocket connection is successfully established. On the other hand, the `reactionListenerOperation ` is focused on the `reaction_added` event type.


Your Slack application is designed to be notified of events within your workspace. It does this by subscribing to a specific event type making use of Slack's Event API. So in this case the `action` property in both the operations is set to receive events.
VaishnaviNandakumar marked this conversation as resolved.
Show resolved Hide resolved

Now, moving on to the `channels` section. The `address` specifies where the channel is tuned in to receive messages while the `messages` property defines the structure of the event it's set up to handle.
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think this should be first in this section, channels are first, operations later. This way first you can just change only channels in the yaml example, and later when you talk about operations, you show both, to make references visible


```
channels:
reactionListener:
address: /
VaishnaviNandakumar marked this conversation as resolved.
Show resolved Hide resolved
VaishnaviNandakumar marked this conversation as resolved.
Show resolved Hide resolved
messages:
reactionListener:
$ref: '#/components/messages/reactionListenerMessage'

helloListener:
address: /
messages:
helloListener:
$ref: '#/components/messages/helloListenerMessage'

operations:
helloListenerOperation:
action: receive
channel:
$ref: "#/channels/helloListener"

reactionListenerOperation:
action: receive
channel:
$ref: "#/channels/reactionListener"
```

## Define Messages and Schemas

Your AsyncAPI document needs to be very clear on the type of event it is expected to receive. Here's where the `messages` component steps in. Using the `payload` property, you can specify what these events should look like, their structure, and what content they carry.

And that brings us to what the `payload` attribute does. It specifies the name, format, and description of all expected properties, and can even set constant values that must be followed during schema validation.
VaishnaviNandakumar marked this conversation as resolved.
Show resolved Hide resolved
For example, in `reactionPayload` schema definition, any API message received from this channel must follow the constant value for the "reaction" property which is clearly defined as “heart”.

The const value feature ensures that the data exchanged through your API complies with your specified constants, helping to maintain data integrity and accuracy.
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
The const value feature ensures that the data exchanged through your API complies with your specified constants, helping to maintain data integrity and accuracy.
The `const` value feature ensures that the data exchanged through your API complies with your specified constants, helping to maintain data integrity and accuracy.


```
components:
messages:
reactionListenerMessage:
summary: "Action triggered when channel receives a new event of type reaction-added"
payload:
$ref: '#/components/schemas/reactionPayload'

helloListenerMessage:
summary: "Action triggered when a successful WebSocket connection is established."
payload:
$ref: '#/components/schemas/helloPayload'

schemas:
reactionPayload:
type: object
properties:
user:
type: string
description: ID of the user who performed this event
VaishnaviNandakumar marked this conversation as resolved.
Show resolved Hide resolved
reaction:
type: string
description: The only reaction that we need is a heart emoji
const: "heart"
item_user:
type: string
description: ID of the user that created the original item that has been reacted to
item:
type: object
properties:
channel:
type: string
description: Channel information of original message
ts:
type: string
description: Timestamp information of original message.
event_ts:
type: string
description: Timestamp of reaction
VaishnaviNandakumar marked this conversation as resolved.
Show resolved Hide resolved

helloPayload:
type: object
properties:
type:
type: string
description: A hello string confirming WS connection
const: "hello"
connection_info:
type: object
properties:
app_id:
type: string
num_connections:
type: integer
debug_info:
type: object
properties:
host:
type: string
started:
type: string
build_number:
type: integer
approximate_connection_time:
type: integer
```


And there you have it! Putting these blocks together gives you your AsyncAPI document all ready to go.
VaishnaviNandakumar marked this conversation as resolved.
Show resolved Hide resolved

```
asyncapi: '3.0.0'
info:
title: MySlackBot API
version: '1.0.0'
description: |
The MySlackBot App manages popular messages in a workspace by monitoring message reaction data from Slack's Event API.

servers:
ws:
host: wss://wss-primary.slack.com/
pathname: link/?ticket=13748dac-b866-4ea7-b98e-4fb7895c0a7f&app_id=fe684dfa62159c6ac646beeac31c8f4ef415e4f39c626c2dbd1530e3a690892f
VaishnaviNandakumar marked this conversation as resolved.
Show resolved Hide resolved
protocol: wss
description: "Websocket URL generated to communicate with Slack"

channels:
reactionListener:
address: /
messages:
reactionListener:
$ref: '#/components/messages/reactionListenerMessage'

helloListener:
address: /
messages:
helloListener:
$ref: '#/components/messages/helloListenerMessage'

operations:
helloListenerOperation:
action: receive
channel:
$ref: "#/channels/helloListener"

reactionListenerOperation:
action: receive
channel:
$ref: "#/channels/reactionListener"

components:
messages:
reactionListenerMessage:
summary: "Action triggered when channel receives a new event of type reaction-added"
payload:
$ref: '#/components/schemas/reactionPayload'

helloListenerMessage:
summary: "Action triggered when a successful WebSocket connection is established."
payload:
$ref: '#/components/schemas/helloPayload'

schemas:
reactionPayload:
type: object
properties:
user:
type: string
description: ID of the user who performed this event
reaction:
type: string
description: The only reaction that we need is a heart emoji
const: "heart"
item_user:
type: string
description: ID of the user that created the original item that has been reacted to
item:
type: object
properties:
channel:
type: string
description: Channel information of original message
ts:
type: string
description: Timestamp information of original message.
event_ts:
type: string
description: Timestamp of reaction

helloPayload:
type: object
properties:
type:
type: string
description: A hello string confirming WS connection
const: "hello"
connection_info:
type: object
properties:
app_id:
type: string
num_connections:
type: integer
debug_info:
type: object
properties:
host:
type: string
started:
type: string
build_number:
type: integer
approximate_connection_time:
type: integer
```




## Summary
In this tutorial, you were introduced to a practical application of WebSocket protocols within an AsyncAPI document. In our future tutorials, we'll dive deeper into more advanced concepts and explore the extensive features of AsyncAPI.
VaishnaviNandakumar marked this conversation as resolved.
Show resolved Hide resolved

Loading