fix: various fixes across the board (#255)

* remaining renamings

* Update server.rs

Co-authored-by: Julian Domke <[email protected]>

* fix: use tokio if available and async-std as fallback

* chore: add test that actually calls the binary

---------

Co-authored-by: Julian Domke <[email protected]>

Author: psteinroe

Cargo.lock

@@ -39,16 +39,17 @@ serde                    = "1.0.195"
 serde_json               = "1.0.114"
 similar                  = "2.6.0"
 smallvec                 = { version = "1.13.2", features = ["union", "const_new", "serde"] }
-sqlx                     = { version = "0.8.2", features = ["runtime-tokio", "postgres", "json"] }
-syn                      = "1.0.109"
-termcolor                = "1.4.1"
-tokio                    = { version = "1.40.0", features = ["full"] }
-tower-lsp                = "0.20.0"
-tracing                  = { version = "0.1.40", default-features = false, features = ["std"] }
-tracing-subscriber       = "0.3.18"
-tree-sitter              = "0.20.10"
-tree_sitter_sql          = { path = "./lib/tree_sitter_sql", version = "0.0.0" }
-unicode-width            = "0.1.12"
+# this will use tokio if available, otherwise async-std
+sqlx               = { version = "0.8.2", features = ["runtime-tokio", "runtime-async-std", "postgres", "json"] }
+syn                = "1.0.109"
+termcolor          = "1.4.1"
+tokio              = { version = "1.40.0", features = ["full"] }
+tower-lsp          = "0.20.0"
+tracing            = { version = "0.1.40", default-features = false, features = ["std"] }
+tracing-subscriber = "0.3.18"
+tree-sitter        = "0.20.10"
+tree_sitter_sql    = { path = "./lib/tree_sitter_sql", version = "0.0.0" }
+unicode-width      = "0.1.12"
 
 # postgres specific crates
 pgt_analyse                = { path = "./crates/pgt_analyse", version = "0.0.0" }

Cargo.toml

@@ -70,34 +70,34 @@ impl ActionCategory {
         match self {
             ActionCategory::QuickFix(tag) => {
                 if tag.is_empty() {
-                    Cow::Borrowed("quickfix.pglt")
+                    Cow::Borrowed("quickfix.pgt")
                 } else {
-                    Cow::Owned(format!("quickfix.pglt.{tag}"))
+                    Cow::Owned(format!("quickfix.pgt.{tag}"))
                 }
             }
 
-            ActionCategory::Refactor(RefactorKind::None) => Cow::Borrowed("refactor.pglt"),
+            ActionCategory::Refactor(RefactorKind::None) => Cow::Borrowed("refactor.pgt"),
             ActionCategory::Refactor(RefactorKind::Extract) => {
-                Cow::Borrowed("refactor.extract.pglt")
+                Cow::Borrowed("refactor.extract.pgt")
             }
-            ActionCategory::Refactor(RefactorKind::Inline) => Cow::Borrowed("refactor.inline.pglt"),
+            ActionCategory::Refactor(RefactorKind::Inline) => Cow::Borrowed("refactor.inline.pgt"),
             ActionCategory::Refactor(RefactorKind::Rewrite) => {
-                Cow::Borrowed("refactor.rewrite.pglt")
+                Cow::Borrowed("refactor.rewrite.pgt")
             }
             ActionCategory::Refactor(RefactorKind::Other(tag)) => {
-                Cow::Owned(format!("refactor.{tag}.pglt"))
+                Cow::Owned(format!("refactor.{tag}.pgt"))
             }
 
-            ActionCategory::Source(SourceActionKind::None) => Cow::Borrowed("source.pglt"),
-            ActionCategory::Source(SourceActionKind::FixAll) => Cow::Borrowed("source.fixAll.pglt"),
+            ActionCategory::Source(SourceActionKind::None) => Cow::Borrowed("source.pgt"),
+            ActionCategory::Source(SourceActionKind::FixAll) => Cow::Borrowed("source.fixAll.pgt"),
             ActionCategory::Source(SourceActionKind::OrganizeImports) => {
-                Cow::Borrowed("source.organizeImports.pglt")
+                Cow::Borrowed("source.organizeImports.pgt")
             }
             ActionCategory::Source(SourceActionKind::Other(tag)) => {
-                Cow::Owned(format!("source.{tag}.pglt"))
+                Cow::Owned(format!("source.{tag}.pgt"))
             }
 
-            ActionCategory::Other(tag) => Cow::Owned(format!("{tag}.pglt")),
+            ActionCategory::Other(tag) => Cow::Owned(format!("{tag}.pgt")),
         }
     }
 }

crates/pgt_analyse/src/categories.rs

@@ -51,6 +51,8 @@ mimalloc = "0.1.43"
 tikv-jemallocator = "0.6.0"
 
 [dev-dependencies]
+assert_cmd = "2.0.16"
+predicates = "3.1.3"
 
 [lib]
 doctest = false

crates/pgt_cli/Cargo.toml

@@ -48,7 +48,7 @@ pub struct CliOptions {
     #[bpaf(long("no-errors-on-unmatched"), switch)]
     pub no_errors_on_unmatched: bool,
 
-    /// Tell PgLT to exit with an error code if some diagnostics emit warnings.
+    /// Tell Postgres Tools to exit with an error code if some diagnostics emit warnings.
     #[bpaf(long("error-on-warnings"), switch)]
     pub error_on_warnings: bool,
 
@@ -86,7 +86,7 @@ pub struct CliOptions {
         fallback(Severity::default()),
         display_fallback
     )]
-    /// The level of diagnostics to show. In order, from the lowest to the most important: info, warn, error. Passing `--diagnostic-level=error` will cause PgLT to print only diagnostics that contain only errors.
+    /// The level of diagnostics to show. In order, from the lowest to the most important: info, warn, error. Passing `--diagnostic-level=error` will cause Postgres Tools to print only diagnostics that contain only errors.
     pub diagnostic_level: Severity,
 }
 

crates/pgt_cli/src/cli_options.rs

@@ -206,10 +206,10 @@ pub(crate) fn read_most_recent_log_file(
 /// The events received by the subscriber are filtered at the `info` level,
 /// then printed using the [HierarchicalLayer] layer, and the resulting text
 /// is written to log files rotated on a hourly basis (in
-/// `pglt-logs/server.log.yyyy-MM-dd-HH` files inside the system temporary
+/// `pgt-logs/server.log.yyyy-MM-dd-HH` files inside the system temporary
 /// directory)
 fn setup_tracing_subscriber(log_path: Option<PathBuf>, log_file_name_prefix: Option<String>) {
-    let pgt_log_path = log_path.unwrap_or(pgt_fs::ensure_cache_dir().join("pglt-logs"));
+    let pgt_log_path = log_path.unwrap_or(pgt_fs::ensure_cache_dir().join("pgt-logs"));
     let appender_builder = tracing_appender::rolling::RollingFileAppender::builder();
     let file_appender = appender_builder
         .filename_prefix(log_file_name_prefix.unwrap_or(String::from("server.log")))
@@ -235,16 +235,16 @@ fn setup_tracing_subscriber(log_path: Option<PathBuf>, log_file_name_prefix: Opt
 pub fn default_pgt_log_path() -> PathBuf {
     match env::var_os("PGT_LOG_PATH") {
         Some(directory) => PathBuf::from(directory),
-        None => pgt_fs::ensure_cache_dir().join("pglt-logs"),
+        None => pgt_fs::ensure_cache_dir().join("pgt-logs"),
     }
 }
 
 /// Tracing filter enabling:
 /// - All spans and events at level info or higher
-/// - All spans and events at level debug in crates whose name starts with `pglt`
+/// - All spans and events at level debug in crates whose name starts with `pgt`
 struct LoggingFilter;
 
-/// Tracing filter used for spans emitted by `pglt*` crates
+/// Tracing filter used for spans emitted by `pgt*` crates
 const SELF_FILTER: LevelFilter = if cfg!(debug_assertions) {
     LevelFilter::TRACE
 } else {
@@ -253,7 +253,7 @@ const SELF_FILTER: LevelFilter = if cfg!(debug_assertions) {
 
 impl LoggingFilter {
     fn is_enabled(&self, meta: &Metadata<'_>) -> bool {
-        let filter = if meta.target().starts_with("pglt") {
+        let filter = if meta.target().starts_with("pgt") {
             SELF_FILTER
         } else {
             LevelFilter::INFO

crates/pgt_cli/src/commands/daemon.rs

@@ -24,7 +24,7 @@ pub(crate) mod version;
 
 #[derive(Debug, Clone, Bpaf)]
 #[bpaf(options, version(VERSION))]
-/// PgLT official CLI. Use it to check the health of your project or run it to check single files.
+/// Postgres Tools official CLI. Use it to check the health of your project or run it to check single files.
 pub enum PgtCommand {
     /// Shows the version information and quit.
     #[bpaf(command)]
@@ -87,7 +87,7 @@ pub enum PgtCommand {
             long("log-path"),
             argument("PATH"),
             hide_usage,
-            fallback(pgt_fs::ensure_cache_dir().join("pglt-logs")),
+            fallback(pgt_fs::ensure_cache_dir().join("pgt-logs")),
         )]
         log_path: PathBuf,
         /// Allows to set a custom file path to the configuration file,
@@ -123,7 +123,7 @@ pub enum PgtCommand {
             long("log-path"),
             argument("PATH"),
             hide_usage,
-            fallback(pgt_fs::ensure_cache_dir().join("pglt-logs")),
+            fallback(pgt_fs::ensure_cache_dir().join("pgt-logs")),
         )]
         log_path: PathBuf,
         /// Allows to set a custom file path to the configuration file,
@@ -157,7 +157,7 @@ pub enum PgtCommand {
             long("log-path"),
             argument("PATH"),
             hide_usage,
-            fallback(pgt_fs::ensure_cache_dir().join("pglt-logs")),
+            fallback(pgt_fs::ensure_cache_dir().join("pgt-logs")),
         )]
         log_path: PathBuf,
 
@@ -197,7 +197,7 @@ impl PgtCommand {
                 }
                 // We want force colors in CI, to give e better UX experience
                 // Unless users explicitly set the colors flag
-                // if matches!(self, PgLTCommand::Ci { .. }) && cli_options.colors.is_none() {
+                // if matches!(self, Postgres ToolsCommand::Ci { .. }) && cli_options.colors.is_none() {
                 //     return Some(&ColorsArg::Force);
                 // }
                 // Normal behaviors

crates/pgt_cli/src/commands/mod.rs

@@ -12,10 +12,10 @@ fn command_name() -> String {
     current_exe()
         .ok()
         .and_then(|path| Some(path.file_name()?.to_str()?.to_string()))
-        .unwrap_or_else(|| String::from("pglt"))
+        .unwrap_or_else(|| String::from("postgrestools"))
 }
 
-/// A diagnostic that is emitted when running PgLT via CLI.
+/// A diagnostic that is emitted when running Postgres Tools via CLI.
 ///
 /// When displaying the diagnostic,
 #[derive(Debug, Diagnostic)]

crates/pgt_cli/src/diagnostics.rs

@@ -11,7 +11,7 @@ use crate::reporter::junit::{JunitReporter, JunitReporterVisitor};
 use crate::reporter::terminal::{ConsoleReporter, ConsoleReporterVisitor};
 use crate::{CliDiagnostic, CliSession, DiagnosticsPayload, Reporter};
 use pgt_diagnostics::{Category, category};
-use pgt_fs::PgLTPath;
+use pgt_fs::PgTPath;
 use std::borrow::Borrow;
 use std::ffi::OsString;
 use std::fmt::{Display, Formatter};
@@ -232,7 +232,7 @@ pub fn execute_mode(
 
     // don't do any traversal if there's some content coming from stdin
     if let Some(stdin) = execution.as_stdin_file() {
-        let pgt_path = PgLTPath::new(stdin.as_path());
+        let pgt_path = PgTPath::new(stdin.as_path());
         std_in::run(
             session,
             &execution,

crates/pgt_cli/src/execute/mod.rs

@@ -5,7 +5,7 @@ use crate::execute::TraversalMode;
 use crate::execute::traverse::TraversalOptions;
 use check::check_file;
 use pgt_diagnostics::Error;
-use pgt_fs::PgLTPath;
+use pgt_fs::PgTPath;
 use std::marker::PhantomData;
 use std::ops::Deref;
 
@@ -111,7 +111,7 @@ impl<'ctx, 'app> Deref for SharedTraversalOptions<'ctx, 'app> {
 /// diagnostics were emitted, or compare the formatted code with the original
 /// content of the file and emit a diff or write the new content to the disk if
 /// write mode is enabled
-pub(crate) fn process_file(ctx: &TraversalOptions, pgt_path: &PgLTPath) -> FileResult {
+pub(crate) fn process_file(ctx: &TraversalOptions, pgt_path: &PgTPath) -> FileResult {
     tracing::trace_span!("process_file", path = ?pgt_path).in_scope(move || {
         let shared_context = &SharedTraversalOptions::new(ctx);