rustfmt

sunli829 · sunli829 · commit cddf5b6bd6f7 · 2025-05-10T22:39:27.000+08:00
diff --git a/actix-web/error-extensions/src/main.rs b/actix-web/error-extensions/src/main.rs
@@ -1,10 +1,10 @@
 #[macro_use]
 extern crate thiserror;
 
-use actix_web::{guard, web, App, HttpResponse, HttpServer};
+use actix_web::{App, HttpResponse, HttpServer, guard, web};
 use async_graphql::{
-    http::GraphiQLSource, EmptyMutation, EmptySubscription, ErrorExtensions, FieldError,
-    FieldResult, Object, ResultExt, Schema,
+    EmptyMutation, EmptySubscription, ErrorExtensions, FieldError, FieldResult, Object, ResultExt,
+    Schema, http::GraphiQLSource,
 };
 use async_graphql_actix_web::GraphQL;
 
diff --git a/actix-web/starwars/src/main.rs b/actix-web/starwars/src/main.rs
@@ -1,5 +1,5 @@
-use actix_web::{guard, web, App, HttpResponse, HttpServer, Result};
-use async_graphql::{http::GraphiQLSource, EmptyMutation, EmptySubscription, Schema};
+use actix_web::{App, HttpResponse, HttpServer, Result, guard, web};
+use async_graphql::{EmptyMutation, EmptySubscription, Schema, http::GraphiQLSource};
 use async_graphql_actix_web::GraphQL;
 use starwars::{QueryRoot, StarWars};
 
diff --git a/actix-web/subscription/src/main.rs b/actix-web/subscription/src/main.rs
@@ -1,5 +1,5 @@
-use actix_web::{guard, web, App, HttpRequest, HttpResponse, HttpServer, Result};
-use async_graphql::{http::GraphiQLSource, Schema};
+use actix_web::{App, HttpRequest, HttpResponse, HttpServer, Result, guard, web};
+use async_graphql::{Schema, http::GraphiQLSource};
 use async_graphql_actix_web::{GraphQL, GraphQLSubscription};
 use books::{BooksSchema, MutationRoot, QueryRoot, Storage, SubscriptionRoot};
 
diff --git a/actix-web/token-from-header/src/main.rs b/actix-web/token-from-header/src/main.rs
@@ -1,9 +1,9 @@
 use actix_web::{
-    guard, http::header::HeaderMap, web, App, HttpRequest, HttpResponse, HttpServer, Result,
+    App, HttpRequest, HttpResponse, HttpServer, Result, guard, http::header::HeaderMap, web,
 };
-use async_graphql::{http::GraphiQLSource, EmptyMutation, Schema};
+use async_graphql::{EmptyMutation, Schema, http::GraphiQLSource};
 use async_graphql_actix_web::{GraphQLRequest, GraphQLResponse, GraphQLSubscription};
-use token::{on_connection_init, QueryRoot, SubscriptionRoot, Token, TokenSchema};
+use token::{QueryRoot, SubscriptionRoot, Token, TokenSchema, on_connection_init};
 
 async fn graphiql() -> HttpResponse {
     HttpResponse::Ok()
diff --git a/actix-web/upload/src/main.rs b/actix-web/upload/src/main.rs
@@ -1,7 +1,7 @@
-use actix_web::{guard, web, web::Data, App, HttpResponse, HttpServer};
+use actix_web::{App, HttpResponse, HttpServer, guard, web, web::Data};
 use async_graphql::{
-    http::{GraphiQLSource, MultipartOptions},
     EmptySubscription, Schema,
+    http::{GraphiQLSource, MultipartOptions},
 };
 use async_graphql_actix_web::{GraphQLRequest, GraphQLResponse};
 use files::{FilesSchema, MutationRoot, QueryRoot, Storage};
diff --git a/axum/starwars/src/main.rs b/axum/starwars/src/main.rs
@@ -1,9 +1,9 @@
-use async_graphql::{http::GraphiQLSource, EmptyMutation, EmptySubscription, Schema};
+use async_graphql::{EmptyMutation, EmptySubscription, Schema, http::GraphiQLSource};
 use async_graphql_axum::GraphQL;
 use axum::{
+    Router,
     response::{self, IntoResponse},
     routing::get,
-    Router,
 };
 use starwars::{QueryRoot, StarWars};
 use tokio::net::TcpListener;
diff --git a/axum/subscription/src/main.rs b/axum/subscription/src/main.rs
@@ -1,9 +1,9 @@
-use async_graphql::{http::GraphiQLSource, Schema};
+use async_graphql::{Schema, http::GraphiQLSource};
 use async_graphql_axum::{GraphQL, GraphQLSubscription};
 use axum::{
+    Router,
     response::{self, IntoResponse},
     routing::get,
-    Router,
 };
 use books::{MutationRoot, QueryRoot, Storage, SubscriptionRoot};
 use tokio::net::TcpListener;
diff --git a/axum/token-from-header/src/main.rs b/axum/token-from-header/src/main.rs
@@ -1,16 +1,16 @@
 use async_graphql::{
-    http::{playground_source, GraphQLPlaygroundConfig, ALL_WEBSOCKET_PROTOCOLS},
     EmptyMutation, Schema,
+    http::{ALL_WEBSOCKET_PROTOCOLS, GraphQLPlaygroundConfig, playground_source},
 };
 use async_graphql_axum::{GraphQLProtocol, GraphQLRequest, GraphQLResponse, GraphQLWebSocket};
 use axum::{
-    extract::{ws::WebSocketUpgrade, State},
+    Router,
+    extract::{State, ws::WebSocketUpgrade},
     http::header::HeaderMap,
     response::{Html, IntoResponse, Response},
     routing::get,
-    Router,
 };
-use token::{on_connection_init, QueryRoot, SubscriptionRoot, Token, TokenSchema};
+use token::{QueryRoot, SubscriptionRoot, Token, TokenSchema, on_connection_init};
 use tokio::net::TcpListener;
 
 async fn graphql_playground() -> impl IntoResponse {
diff --git a/axum/upload/src/main.rs b/axum/upload/src/main.rs
@@ -1,10 +1,10 @@
-use async_graphql::{http::GraphiQLSource, EmptySubscription, Schema};
+use async_graphql::{EmptySubscription, Schema, http::GraphiQLSource};
 use async_graphql_axum::GraphQL;
 use axum::{
+    Router,
     http::Method,
     response::{Html, IntoResponse},
     routing::get,
-    Router,
 };
 use files::{MutationRoot, QueryRoot, Storage};
 use tokio::net::TcpListener;
diff --git a/federation/dynamic-schema/federation-accounts/src/main.rs b/federation/dynamic-schema/federation-accounts/src/main.rs
@@ -2,7 +2,7 @@ use async_graphql::dynamic::{
     Field, FieldFuture, FieldValue, Object, Schema, SchemaError, TypeRef,
 };
 use async_graphql_poem::GraphQL;
-use poem::{listener::TcpListener, Route, Server};
+use poem::{Route, Server, listener::TcpListener};
 
 struct Picture {
     url: String,
diff --git a/federation/dynamic-schema/federation-products/src/main.rs b/federation/dynamic-schema/federation-products/src/main.rs
@@ -2,7 +2,7 @@ use async_graphql::dynamic::{
     Field, FieldFuture, FieldValue, Object, Schema, SchemaError, TypeRef,
 };
 use async_graphql_poem::GraphQL;
-use poem::{listener::TcpListener, Route, Server};
+use poem::{Route, Server, listener::TcpListener};
 
 struct Product {
     upc: String,
diff --git a/federation/dynamic-schema/federation-reviews/src/main.rs b/federation/dynamic-schema/federation-reviews/src/main.rs
@@ -2,7 +2,7 @@ use async_graphql::dynamic::{
     Enum, Field, FieldFuture, FieldValue, Object, Schema, SchemaError, TypeRef,
 };
 use async_graphql_poem::GraphQL;
-use poem::{listener::TcpListener, Route, Server};
+use poem::{Route, Server, listener::TcpListener};
 
 struct Picture {
     url: String,
diff --git a/federation/static-schema/federation-accounts/src/main.rs b/federation/static-schema/federation-accounts/src/main.rs
@@ -1,6 +1,6 @@
-use async_graphql::{EmptyMutation, EmptySubscription, Object, Schema, SimpleObject, ID};
+use async_graphql::{EmptyMutation, EmptySubscription, ID, Object, Schema, SimpleObject};
 use async_graphql_poem::GraphQL;
-use poem::{listener::TcpListener, Route, Server};
+use poem::{Route, Server, listener::TcpListener};
 
 #[derive(SimpleObject)]
 struct User {
diff --git a/federation/static-schema/federation-products/src/main.rs b/federation/static-schema/federation-products/src/main.rs
@@ -1,6 +1,6 @@
 use async_graphql::{Context, EmptyMutation, EmptySubscription, Object, Schema, SimpleObject};
 use async_graphql_poem::GraphQL;
-use poem::{listener::TcpListener, Route, Server};
+use poem::{Route, Server, listener::TcpListener};
 
 #[derive(SimpleObject)]
 struct Product {
diff --git a/federation/static-schema/federation-reviews/src/main.rs b/federation/static-schema/federation-reviews/src/main.rs
@@ -1,9 +1,9 @@
 use async_graphql::{
-    ComplexObject, Context, EmptyMutation, EmptySubscription, Enum, Object, Schema, SimpleObject,
-    ID,
+    ComplexObject, Context, EmptyMutation, EmptySubscription, Enum, ID, Object, Schema,
+    SimpleObject,
 };
 use async_graphql_poem::GraphQL;
-use poem::{listener::TcpListener, Route, Server};
+use poem::{Route, Server, listener::TcpListener};
 
 #[derive(SimpleObject)]
 #[graphql(complex)]
diff --git a/models/books/src/lib.rs b/models/books/src/lib.rs
@@ -2,8 +2,8 @@ mod simple_broker;
 
 use std::{sync::Arc, time::Duration};
 
-use async_graphql::{Context, Enum, Object, Result, Schema, Subscription, ID};
-use futures_util::{lock::Mutex, Stream, StreamExt};
+use async_graphql::{Context, Enum, ID, Object, Result, Schema, Subscription};
+use futures_util::{Stream, StreamExt, lock::Mutex};
 use simple_broker::SimpleBroker;
 use slab::Slab;
 
diff --git a/models/dynamic-books/src/model.rs b/models/dynamic-books/src/model.rs
@@ -1,7 +1,7 @@
-use async_graphql::{dynamic::*, Value, ID};
+use async_graphql::{ID, Value, dynamic::*};
 use futures_util::StreamExt;
 
-use crate::{simple_broker::SimpleBroker, Book, BookChanged, MutationType, Storage};
+use crate::{Book, BookChanged, MutationType, Storage, simple_broker::SimpleBroker};
 
 impl<'a> From<MutationType> for FieldValue<'a> {
     fn from(value: MutationType) -> Self {
diff --git a/models/dynamic-files/src/lib.rs b/models/dynamic-files/src/lib.rs
@@ -1,6 +1,6 @@
 use async_graphql::{
-    dynamic::{Field, FieldFuture, FieldValue, InputValue, Object, Schema, SchemaError, TypeRef},
     Value,
+    dynamic::{Field, FieldFuture, FieldValue, InputValue, Object, Schema, SchemaError, TypeRef},
 };
 use futures::lock::Mutex;
 use slab::Slab;
diff --git a/models/dynamic-starwars/src/model.rs b/models/dynamic-starwars/src/model.rs
@@ -1,4 +1,4 @@
-use async_graphql::{dynamic::*, Value};
+use async_graphql::{Value, dynamic::*};
 
 use crate::{Episode, StarWars, StarWarsChar};
 
diff --git a/models/files/src/lib.rs b/models/files/src/lib.rs
@@ -1,4 +1,4 @@
-use async_graphql::{Context, EmptySubscription, Object, Schema, SimpleObject, Upload, ID};
+use async_graphql::{Context, EmptySubscription, ID, Object, Schema, SimpleObject, Upload};
 use futures::lock::Mutex;
 use slab::Slab;
 
diff --git a/models/starwars/src/model.rs b/models/starwars/src/model.rs
@@ -1,8 +1,8 @@
 #![allow(clippy::needless_lifetimes)]
 
 use async_graphql::{
-    connection::{query, Connection, Edge},
     Context, Enum, Error, Interface, Object, OutputType, Result,
+    connection::{Connection, Edge, query},
 };
 
 use super::StarWars;
diff --git a/poem/dynamic-books/src/main.rs b/poem/dynamic-books/src/main.rs
@@ -1,6 +1,6 @@
 use async_graphql::http::GraphiQLSource;
 use async_graphql_poem::{GraphQL, GraphQLSubscription};
-use poem::{get, handler, listener::TcpListener, web::Html, IntoResponse, Route, Server};
+use poem::{IntoResponse, Route, Server, get, handler, listener::TcpListener, web::Html};
 
 #[handler]
 async fn graphiql() -> impl IntoResponse {
diff --git a/poem/dynamic-schema/src/main.rs b/poem/dynamic-schema/src/main.rs
@@ -1,12 +1,12 @@
 use std::error::Error;
 
 use async_graphql::{
-    dynamic::*,
-    http::{playground_source, GraphQLPlaygroundConfig},
     Value,
+    dynamic::*,
+    http::{GraphQLPlaygroundConfig, playground_source},
 };
 use async_graphql_poem::GraphQL;
-use poem::{get, handler, listener::TcpListener, web::Html, IntoResponse, Route, Server};
+use poem::{IntoResponse, Route, Server, get, handler, listener::TcpListener, web::Html};
 
 #[handler]
 async fn graphql_playground() -> impl IntoResponse {
diff --git a/poem/dynamic-starwars/src/main.rs b/poem/dynamic-starwars/src/main.rs
@@ -1,6 +1,6 @@
 use async_graphql::http::GraphiQLSource;
 use async_graphql_poem::GraphQL;
-use poem::{get, handler, listener::TcpListener, web::Html, IntoResponse, Route, Server};
+use poem::{IntoResponse, Route, Server, get, handler, listener::TcpListener, web::Html};
 
 #[handler]
 async fn graphiql() -> impl IntoResponse {
diff --git a/poem/dynamic-upload/src/main.rs b/poem/dynamic-upload/src/main.rs
@@ -1,6 +1,6 @@
 use async_graphql::http::GraphiQLSource;
 use async_graphql_poem::GraphQL;
-use poem::{get, handler, listener::TcpListener, web::Html, IntoResponse, Route, Server};
+use poem::{IntoResponse, Route, Server, get, handler, listener::TcpListener, web::Html};
 
 #[handler]
 async fn graphiql() -> impl IntoResponse {
diff --git a/poem/opentelemetry-basic/src/main.rs b/poem/opentelemetry-basic/src/main.rs
@@ -1,10 +1,10 @@
 use async_graphql::{
-    extensions::OpenTelemetry, EmptyMutation, EmptySubscription, Object, Result, Schema,
+    EmptyMutation, EmptySubscription, Object, Result, Schema, extensions::OpenTelemetry,
 };
 use async_graphql_poem::GraphQL;
 use opentelemetry::trace::TracerProvider as _;
 use opentelemetry_sdk::trace::TracerProvider;
-use poem::{listener::TcpListener, post, EndpointExt, Route, Server};
+use poem::{EndpointExt, Route, Server, listener::TcpListener, post};
 
 struct QueryRoot;
 
@@ -37,7 +37,9 @@ async fn main() {
     -H 'content-type: application/json' \
     --data '{ \"query\": \"{ hello }\" }'";
 
-    println!("Run this curl command from another terminal window to see opentelemetry output in this terminal.\n\n{example_curl}\n\n");
+    println!(
+        "Run this curl command from another terminal window to see opentelemetry output in this terminal.\n\n{example_curl}\n\n"
+    );
 
     Server::new(TcpListener::bind("127.0.0.1:8000"))
         .run(app)
diff --git a/poem/starwars/src/main.rs b/poem/starwars/src/main.rs
@@ -1,6 +1,6 @@
-use async_graphql::{http::GraphiQLSource, EmptyMutation, EmptySubscription, Schema};
+use async_graphql::{EmptyMutation, EmptySubscription, Schema, http::GraphiQLSource};
 use async_graphql_poem::GraphQL;
-use poem::{get, handler, listener::TcpListener, web::Html, IntoResponse, Route, Server};
+use poem::{IntoResponse, Route, Server, get, handler, listener::TcpListener, web::Html};
 use starwars::{QueryRoot, StarWars};
 
 #[handler]
diff --git a/poem/subscription-redis/src/main.rs b/poem/subscription-redis/src/main.rs
@@ -1,7 +1,7 @@
-use async_graphql::{http::GraphiQLSource, Context, Object, Result, Schema, Subscription};
+use async_graphql::{Context, Object, Result, Schema, Subscription, http::GraphiQLSource};
 use async_graphql_poem::{GraphQL, GraphQLSubscription};
 use futures_util::{Stream, StreamExt};
-use poem::{get, handler, listener::TcpListener, web::Html, IntoResponse, Route, Server};
+use poem::{IntoResponse, Route, Server, get, handler, listener::TcpListener, web::Html};
 use redis::{AsyncCommands, Client};
 
 struct QueryRoot;
diff --git a/poem/subscription/src/main.rs b/poem/subscription/src/main.rs
@@ -1,7 +1,7 @@
-use async_graphql::{http::GraphiQLSource, Schema};
+use async_graphql::{Schema, http::GraphiQLSource};
 use async_graphql_poem::{GraphQL, GraphQLSubscription};
 use books::{MutationRoot, QueryRoot, Storage, SubscriptionRoot};
-use poem::{get, handler, listener::TcpListener, web::Html, IntoResponse, Route, Server};
+use poem::{IntoResponse, Route, Server, get, handler, listener::TcpListener, web::Html};
 
 #[handler]
 async fn graphiql() -> impl IntoResponse {
diff --git a/poem/token-from-header/src/main.rs b/poem/token-from-header/src/main.rs
@@ -1,16 +1,15 @@
 use async_graphql::{
-    http::{GraphiQLSource, ALL_WEBSOCKET_PROTOCOLS},
     EmptyMutation, Schema,
+    http::{ALL_WEBSOCKET_PROTOCOLS, GraphiQLSource},
 };
 use async_graphql_poem::{GraphQLProtocol, GraphQLRequest, GraphQLResponse, GraphQLWebSocket};
 use poem::{
-    get, handler,
+    EndpointExt, IntoResponse, Route, Server, get, handler,
     http::HeaderMap,
     listener::TcpListener,
-    web::{websocket::WebSocket, Data, Html},
-    EndpointExt, IntoResponse, Route, Server,
+    web::{Data, Html, websocket::WebSocket},
 };
-use token::{on_connection_init, QueryRoot, SubscriptionRoot, Token, TokenSchema};
+use token::{QueryRoot, SubscriptionRoot, Token, TokenSchema, on_connection_init};
 
 fn get_token_from_headers(headers: &HeaderMap) -> Option<Token> {
     headers
diff --git a/poem/upload/src/main.rs b/poem/upload/src/main.rs
@@ -1,12 +1,11 @@
-use async_graphql::{http::GraphiQLSource, EmptySubscription, Schema};
+use async_graphql::{EmptySubscription, Schema, http::GraphiQLSource};
 use async_graphql_poem::{GraphQLRequest, GraphQLResponse};
 use files::{FilesSchema, MutationRoot, QueryRoot, Storage};
 use poem::{
-    get, handler,
+    EndpointExt, IntoResponse, Route, Server, get, handler,
     listener::TcpListener,
     middleware::Cors,
     web::{Data, Html},
-    EndpointExt, IntoResponse, Route, Server,
 };
 
 #[handler]
diff --git a/rocket/starwars/src/main.rs b/rocket/starwars/src/main.rs
@@ -1,6 +1,6 @@
-use async_graphql::{http::GraphiQLSource, EmptyMutation, EmptySubscription, Schema};
+use async_graphql::{EmptyMutation, EmptySubscription, Schema, http::GraphiQLSource};
 use async_graphql_rocket::{GraphQLQuery, GraphQLRequest, GraphQLResponse};
-use rocket::{response::content, routes, State};
+use rocket::{State, response::content, routes};
 use starwars::{QueryRoot, StarWars};
 
 pub type StarWarsSchema = Schema<QueryRoot, EmptyMutation, EmptySubscription>;
diff --git a/rocket/upload/src/main.rs b/rocket/upload/src/main.rs
@@ -1,7 +1,7 @@
-use async_graphql::{http::GraphiQLSource, EmptyMutation, EmptySubscription, Schema};
+use async_graphql::{EmptyMutation, EmptySubscription, Schema, http::GraphiQLSource};
 use async_graphql_rocket::{GraphQLQuery, GraphQLRequest, GraphQLResponse};
 use files::{FilesSchema, MutationRoot, QueryRoot, Storage};
-use rocket::{response::content, routes, State};
+use rocket::{State, response::content, routes};
 
 pub type StarWarsSchema = Schema<QueryRoot, EmptyMutation, EmptySubscription>;
 
diff --git a/warp/starwars/src/main.rs b/warp/starwars/src/main.rs
@@ -1,10 +1,10 @@
 use std::convert::Infallible;
 
-use async_graphql::{http::GraphiQLSource, EmptyMutation, EmptySubscription, Schema};
+use async_graphql::{EmptyMutation, EmptySubscription, Schema, http::GraphiQLSource};
 use async_graphql_warp::{GraphQLBadRequest, GraphQLResponse};
 use http::StatusCode;
 use starwars::{QueryRoot, StarWars};
-use warp::{http::Response as HttpResponse, Filter, Rejection};
+use warp::{Filter, Rejection, http::Response as HttpResponse};
 
 #[tokio::main]
 async fn main() {
diff --git a/warp/subscription/src/main.rs b/warp/subscription/src/main.rs
@@ -1,9 +1,9 @@
 use std::convert::Infallible;
 
-use async_graphql::{http::GraphiQLSource, Schema};
-use async_graphql_warp::{graphql_subscription, GraphQLResponse};
+use async_graphql::{Schema, http::GraphiQLSource};
+use async_graphql_warp::{GraphQLResponse, graphql_subscription};
 use books::{MutationRoot, QueryRoot, Storage, SubscriptionRoot};
-use warp::{http::Response as HttpResponse, Filter};
+use warp::{Filter, http::Response as HttpResponse};
 
 #[tokio::main]
 async fn main() {
diff --git a/warp/token-from-header/src/main.rs b/warp/token-from-header/src/main.rs
