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

supplement Postgres listen example with a small chat example #2577

Merged
merged 1 commit into from Jul 24, 2023
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
9 changes: 9 additions & 0 deletions .github/workflows/examples.yml
Expand Up @@ -153,6 +153,15 @@ jobs:
command: test
args: -p sqlx-example-postgres-axum-social

# The Chat example has an interactive TUI which is not trivial to test automatically,
# so we only check that it compiles.
- name: Chat (Check)
uses: actions-rs/cargo@v1
env:
with:
command: check
args: -p sqlx-example-postgres-check

- name: Files (Setup)
working-directory: examples/postgres/files
env:
Expand Down
77 changes: 77 additions & 0 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

1 change: 1 addition & 0 deletions Cargo.toml
Expand Up @@ -12,6 +12,7 @@ members = [
"sqlx-sqlite",
"examples/mysql/todos",
"examples/postgres/axum-social-with-tests",
"examples/postgres/chat",
"examples/postgres/files",
"examples/postgres/json",
"examples/postgres/listen",
Expand Down
13 changes: 13 additions & 0 deletions examples/postgres/chat/Cargo.toml
@@ -0,0 +1,13 @@
[package]
name = "sqlx-example-postgres-chat"
version = "0.1.0"
edition = "2021"
workspace = "../../../"

[dependencies]
sqlx = { path = "../../../", features = [ "postgres", "runtime-tokio-native-tls" ] }
futures = "0.3.1"
tokio = { version = "1.20.0", features = [ "rt-multi-thread", "macros" ] }
tui = "0.19.0"
crossterm = "0.25"
unicode-width = "0.1"
24 changes: 24 additions & 0 deletions examples/postgres/chat/README.md
@@ -0,0 +1,24 @@
# Chat Example

JockeM marked this conversation as resolved.
Show resolved Hide resolved
Note: this example has an interactive TUI which is not trivial to test automatically,
so our CI currently only checks whether or not it compiles.

## Description

This example demonstrates how to use PostgreSQL channels to create a very simple chat application.

## Setup

1. Declare the database URL

```
export DATABASE_URL="postgres://postgres:password@localhost/files"
```

## Usage

Run the project

```
cargo run -p sqlx-examples-postgres-chat
```
178 changes: 178 additions & 0 deletions examples/postgres/chat/src/main.rs
@@ -0,0 +1,178 @@
use crossterm::{
event::{self, DisableMouseCapture, EnableMouseCapture, Event, KeyCode},
execute,
terminal::{disable_raw_mode, enable_raw_mode, EnterAlternateScreen, LeaveAlternateScreen},
};
use sqlx::postgres::PgListener;
use sqlx::PgPool;
use std::sync::Arc;
use std::{error::Error, io};
use tokio::{sync::Mutex, time::Duration};
use tui::{
backend::{Backend, CrosstermBackend},
layout::{Constraint, Direction, Layout},
style::{Color, Modifier, Style},
text::{Span, Spans, Text},
widgets::{Block, Borders, List, ListItem, Paragraph},
Frame, Terminal,
};
use unicode_width::UnicodeWidthStr;

struct ChatApp {
input: String,
messages: Arc<Mutex<Vec<String>>>,
pool: PgPool,
}

impl ChatApp {
fn new(pool: PgPool) -> Self {
ChatApp {
input: String::new(),
messages: Arc::new(Mutex::new(Vec::new())),
pool,
}
}

async fn run<B: Backend>(
mut self,
terminal: &mut Terminal<B>,
mut listener: PgListener,
) -> Result<(), Box<dyn Error>> {
// setup listener task
let messages = self.messages.clone();
tokio::spawn(async move {
while let Ok(msg) = listener.recv().await {
messages.lock().await.push(msg.payload().to_string());
abonander marked this conversation as resolved.
Show resolved Hide resolved
}
});

loop {
let messages: Vec<ListItem> = self
.messages
.lock()
.await
.iter()
.map(|m| {
let content = vec![Spans::from(Span::raw(m.to_owned()))];
ListItem::new(content)
})
.collect();

terminal.draw(|f| self.ui(f, messages))?;

if !event::poll(Duration::from_millis(20))? {
continue;
}

if let Event::Key(key) = event::read()? {
match key.code {
KeyCode::Enter => {
notify(&self.pool, &self.input).await?;
self.input.clear();
}
KeyCode::Char(c) => {
self.input.push(c);
}
KeyCode::Backspace => {
self.input.pop();
}
KeyCode::Esc => {
return Ok(());
}
_ => {}
}
}
}
}

fn ui<B: Backend>(&mut self, frame: &mut Frame<B>, messages: Vec<ListItem>) {
let chunks = Layout::default()
.direction(Direction::Vertical)
.margin(2)
.constraints(
[
Constraint::Length(1),
Constraint::Length(3),
Constraint::Min(1),
]
.as_ref(),
)
.split(frame.size());

let text = Text::from(Spans::from(vec![
Span::raw("Press "),
Span::styled("Enter", Style::default().add_modifier(Modifier::BOLD)),
Span::raw(" to send the message, "),
Span::styled("Esc", Style::default().add_modifier(Modifier::BOLD)),
Span::raw(" to quit"),
]));
let help_message = Paragraph::new(text);
frame.render_widget(help_message, chunks[0]);

let input = Paragraph::new(self.input.as_ref())
.style(Style::default().fg(Color::Yellow))
.block(Block::default().borders(Borders::ALL).title("Input"));
frame.render_widget(input, chunks[1]);
frame.set_cursor(
// Put cursor past the end of the input text
chunks[1].x + self.input.width() as u16 + 1,
// Move one line down, from the border to the input line
chunks[1].y + 1,
);

let messages =
List::new(messages).block(Block::default().borders(Borders::ALL).title("Messages"));
frame.render_widget(messages, chunks[2]);
}
}

#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
// setup postgres
let conn_url =
std::env::var("DATABASE_URL").expect("Env var DATABASE_URL is required for this example.");
let pool = sqlx::PgPool::connect(&conn_url).await?;

let mut listener = PgListener::connect(&conn_url).await?;
listener.listen("chan0").await?;

// setup terminal
enable_raw_mode()?;
let mut stdout = io::stdout();
execute!(stdout, EnterAlternateScreen, EnableMouseCapture)?;
let backend = CrosstermBackend::new(stdout);
let mut terminal = Terminal::new(backend)?;

// create app and run it
let app = ChatApp::new(pool);
let res = app.run(&mut terminal, listener).await;

// restore terminal
disable_raw_mode()?;
execute!(
terminal.backend_mut(),
LeaveAlternateScreen,
DisableMouseCapture,
)?;
terminal.show_cursor()?;

if let Err(err) = res {
println!("{:?}", err)
}

Ok(())
}

async fn notify(pool: &PgPool, s: &str) -> Result<(), sqlx::Error> {
sqlx::query(
r#"
SELECT pg_notify(chan, payload)
FROM (VALUES ('chan0', $1)) v(chan, payload)
"#,
)
.bind(s)
.execute(pool)
.await?;

Ok(())
}