refactor: examples split into own crate

Cargo.toml

@@ -41,6 +41,7 @@ mod_module_files = "allow"
 supabase-mock = { path = "crates/supabase-mock" }
 supabase-auth = { path = "crates/supabase-auth" }
 postgrest-error = { path = "crates/postgrest-error" }
+supabase-realtime = { path = "crates/supabase-realtime" }
 
 # Async
 futures-concurrency = "7.4"

crates/examples/Cargo.toml

@@ -0,0 +1,25 @@
+[package]
+name = "examples"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+clap.workspace = true
+color-eyre.workspace = true
+supabase-realtime.workspace = true
+supabase-auth.workspace = true
+tokio.workspace = true
+tracing.workspace = true
+tracing-subscriber.workspace = true
+simd-json.workspace = true
+
+[lints]
+workspace = true
+
+[[bin]]
+name = "realtime-example"
+path = "src/realtime_example.rs"
+
+[[bin]]
+name = "auth_example"
+path = "src/auth_example.rs"

crates/supabase-auth/examples/auth_example.rs → crates/examples/src/auth_example.rs

@@ -1,7 +1,8 @@
-use std::time::Duration;
+use core::time::Duration;
 
 use clap::Parser;
-use futures::StreamExt;
+use supabase_auth::futures::StreamExt as _;
+use supabase_auth::url;
 use tracing_subscriber::EnvFilter;
 
 #[derive(Parser, Debug)]
@@ -38,8 +39,8 @@ async fn main() {
             EnvFilter::builder()
                 .from_env()
                 .unwrap()
-                .add_directive(format!("supabase_auth=debug").parse().unwrap())
-                .add_directive(format!("auth_example=debug").parse().unwrap()),
+                .add_directive("supabase_auth=debug".to_owned().parse().unwrap())
+                .add_directive("auth_example=debug".to_owned().parse().unwrap()),
         )
         .init();
 

crates/supabase-realtime/examples/example1.rs → crates/examples/src/realtime_example.rs

@@ -1,11 +1,9 @@
-use std::borrow::Cow;
-use std::time::Duration;
+use core::time::Duration;
 
 use clap::Parser;
-use futures::StreamExt;
-use supabase_auth::redact::Secret;
-use supabase_realtime::message::{phx_join, ProtocolMessage};
-use tokio_stream::wrappers::ReceiverStream;
+use supabase_auth::url;
+use supabase_realtime::futures::StreamExt as _;
+use supabase_realtime::message::phx_join;
 use tracing_subscriber::EnvFilter;
 
 #[derive(Parser, Debug)]
@@ -40,9 +38,9 @@ async fn main() {
             EnvFilter::builder()
                 .from_env()
                 .unwrap()
-                .add_directive(format!("supabase_auth=info").parse().unwrap())
-                .add_directive(format!("supabase_realtime=info").parse().unwrap())
-                .add_directive(format!("example1=info").parse().unwrap()),
+                .add_directive("supabase_auth=info".to_owned().parse().unwrap())
+                .add_directive("supabase_realtime=info".to_owned().parse().unwrap())
+                .add_directive("example1=info".to_owned().parse().unwrap()),
         )
         .init();
     color_eyre::install().unwrap();
@@ -70,12 +68,10 @@ async fn main() {
                 self_item: false,
                 ack: false,
             },
-            presence: phx_join::PresenceConfig {
-                key: "".to_string(),
-            },
+            presence: phx_join::PresenceConfig { key: String::new() },
             postgres_changes: vec![phx_join::PostgrsChanges {
                 event: phx_join::PostgresChangetEvent::All,
-                schema: "public".to_string(),
+                schema: "public".to_owned(),
                 table: args.table,
                 filter: args.filter,
             }],

crates/supabase-auth/src/lib.rs

@@ -13,7 +13,6 @@ use simd_json::json;
 use thiserror::Error;
 use tokio::task::JoinSet;
 pub use {futures, redact, url};
-
 pub const SUPABASE_KEY: &str = "apikey";
 
 #[derive(Clone, Debug, PartialEq, Eq)]

crates/supabase-realtime/src/connection.rs

@@ -1,5 +1,5 @@
-use std::future::Future;
-use std::sync::Arc;
+use alloc::sync::Arc;
+use core::future::Future;
 
 use bytes::Bytes;
 use fastwebsockets::FragmentCollector;

crates/supabase-realtime/src/lib.rs

@@ -1,4 +1,8 @@
+extern crate alloc;
+
 mod connection;
 mod error;
 pub mod message;
 pub mod realtime;
+
+pub use {futures, supabase_auth, url};