struct Ticket {
  ticket_id: i32,
  author_id: i32,
  title: String,
}

impl Ticket {
  async fn get_by_id(pool: &sqlx::PgPool, id: i32) -> Self {
    sqlx::query_as!(Self, "select * from ticket where ticket_id = $1", id)
      .fetch_one(pool).await.unwrap()
  }
}

#[graphql_object(context = Database)]
impl Ticket {
  fn ticket_id(&self) -> i32 {
    self.ticket_id
  }

  async fn author(&self, context: &Database) -> User {
    User::get_by_id(&context.pool, self.author_id).await
  }

  fn title(&self) -> String {
    self.title.clone()
  }

  async fn updates(&self, context: &Database) -> Vec<TicketUpdate> {
    sqlx::query_as!(TicketUpdate, "select * from ticket_update where ticket_id = $1", self.ticket_id)
      .fetch_all(&context.pool).await.unwrap()
  }
}


impl juniper::Context for Database {}
struct Query;

#[graphql_object(context = Database)]
impl Query {
  fn api_version() -> &'static str {
    "0.1"
  }

  async fn ticket(context: &Database, id: i32) -> Option<Ticket> {
    Some(Ticket::get_by_id(&context.pool, id).await)
  }

  async fn user(context: &Database, id: i32) -> Option<User> {
    Some(User::get_by_id(&context.pool, id).await)
  }
}


#[actix_rt::main]
async fn main() -> Result<(), std::io::Error> {
  let db_url = std::env::var("DATABASE_URL").expect("Set DATABASE_URL idiot");
  let pool = PgPoolOptions::new().max_connections(10).connect(&db_url).await.unwrap();
  env::set_var("RUST_LOG", "info");
  env_logger::init();

  HttpServer::new(move || {
    App::new()
      .app_data(Data::new(schema()))
      .app_data(Data::new(pool.clone()))
      .wrap(middleware::Logger::default())
      .service(
        web::resource("/graphql")
          .route(web::post().to(graphql_route))
          .route(web::get().to(graphql_route))
      )
      .service(web::resource("/playground").route(web::get().to(playground_route)))
      .service(web::resource("/graphiql").route(web::get().to(graphiql_route)))
  }).bind("localhost:8080")?.run().await