add wp_com_e2e package

Author: jkmassel

Cargo.lock

@@ -4,6 +4,7 @@ members = [
   "wp_api_integration_tests",
   "wp_api_integration_tests_backend",
   "wp_cli",
+  "wp_com_e2e",
   "wp_contextual",
   "wp_derive",
   "wp_derive_request_builder",

Cargo.toml

@@ -0,0 +1,20 @@
+[package]
+name = "wp_com_e2e"
+version = "0.1.0"
+edition = "2024"
+
+[dependencies]
+anyhow = { workspace = true }
+async-trait = { workspace = true }
+clap = { workspace = true, features = ["derive", "env"] }
+colored = { workspace = true }
+csv = { workspace = true }
+futures = { workspace = true }
+serde = { workspace = true, features = ["derive"] }
+serde_json = { workspace = true }
+tokio = { workspace = true, features = ["full"] }
+tokio-stream = { workspace = true }
+wp_api = { path = "../wp_api", features = [ "reqwest-request-executor" ] }
+
+[[bin]]
+name = "wp_com_e2e"

wp_com_e2e/cargo.toml

@@ -0,0 +1,82 @@
+use anyhow::Result;
+use async_trait::async_trait;
+use clap::{Parser, Subcommand};
+use oauth2_tests::Oauth2Test;
+use std::sync::Arc;
+use support_eligibility_test::SupportEligibilityTest;
+use support_tickets_test::SupportTicketsTest;
+use wp_api::{
+    WpApiClientDelegate, WpAppNotifier,
+    auth::{WpAuthentication, WpAuthenticationProvider},
+    middleware::WpApiMiddlewarePipeline,
+    reqwest_request_executor::ReqwestRequestExecutor,
+    wp_com::client::WpComApiClient,
+};
+
+mod oauth2_tests;
+mod support_eligibility_test;
+mod support_tickets_test;
+
+#[derive(Parser)]
+#[command(author, version, about, long_about = None)]
+struct Cli {
+    #[command(subcommand)]
+    command: Commands,
+}
+
+#[derive(Subcommand)]
+enum Commands {
+    Test {
+        #[arg(short = 't', long = "token", env = "WP_COM_API_KEY")]
+        token: String,
+    },
+}
+
+#[async_trait]
+trait Testable {
+    async fn test(&self) -> Result<(), anyhow::Error>;
+}
+
+#[derive(Debug)]
+pub struct EmptyAppNotifier;
+
+#[async_trait]
+impl WpAppNotifier for EmptyAppNotifier {
+    async fn requested_with_invalid_authentication(&self) {
+        // no-op
+    }
+}
+
+#[tokio::main]
+async fn main() -> Result<(), anyhow::Error> {
+    let cli = Cli::parse();
+
+    match cli.command {
+        Commands::Test { token } => {
+            let delegate = WpApiClientDelegate {
+                auth_provider: WpAuthenticationProvider::static_with_auth(
+                    WpAuthentication::Bearer {
+                        token: token.clone(),
+                    },
+                )
+                .into(),
+                request_executor: Arc::new(ReqwestRequestExecutor::default()),
+                middleware_pipeline: Arc::new(WpApiMiddlewarePipeline::default()),
+                app_notifier: Arc::new(EmptyAppNotifier),
+            };
+
+            let client = WpComApiClient::new(delegate);
+
+            Oauth2Test {
+                client: &client,
+                token: &token,
+            }
+            .test()
+            .await?;
+            SupportTicketsTest { client: &client }.test().await?;
+            SupportEligibilityTest { client: &client }.test().await?;
+        }
+    }
+
+    Ok(())
+}

wp_com_e2e/src/main.rs

@@ -0,0 +1,27 @@
+use anyhow::{Ok, Result};
+use async_trait::async_trait;
+use wp_api::wp_com::{client::WpComApiClient, oauth2::TokenValidationParameters};
+
+use crate::Testable;
+
+pub struct Oauth2Test<'a> {
+    pub token: &'a String,
+    pub client: &'a WpComApiClient,
+}
+
+#[async_trait]
+impl Testable for Oauth2Test<'_> {
+    async fn test(&self) -> Result<(), anyhow::Error> {
+        println!("== OAuth 2 Token Test ==");
+        self.client
+            .oauth2()
+            .fetch_info(&TokenValidationParameters {
+                client_id: "11".to_string(),
+                token: self.token.clone(),
+            })
+            .await?;
+        println!("✅ Get OAuth 2 Token Info");
+
+        Ok(())
+    }
+}

wp_com_e2e/src/oauth2_tests.rs

@@ -0,0 +1,23 @@
+use anyhow::{Ok, Result};
+use async_trait::async_trait;
+use wp_api::wp_com::client::WpComApiClient;
+
+use crate::Testable;
+
+pub struct SupportEligibilityTest<'a> {
+    pub client: &'a WpComApiClient,
+}
+
+#[async_trait]
+impl Testable for SupportEligibilityTest<'_> {
+    async fn test(&self) -> Result<(), anyhow::Error> {
+        println!("== Support Eligibility Test ==");
+        self.client
+            .support_eligibility()
+            .get_support_eligibility()
+            .await?;
+        println!("✅ Get Support Eligibility");
+
+        Ok(())
+    }
+}

wp_com_e2e/src/support_eligibility_test.rs

@@ -0,0 +1,59 @@
+use anyhow::{Ok, Result};
+use async_trait::async_trait;
+use wp_api::wp_com::{
+    client::WpComApiClient,
+    support_tickets::{AddMessageToSupportConversationParams, CreateSupportTicketParams},
+};
+
+use crate::Testable;
+
+pub struct SupportTicketsTest<'a> {
+    pub client: &'a WpComApiClient,
+}
+
+#[async_trait]
+impl Testable for SupportTicketsTest<'_> {
+    async fn test(&self) -> Result<(), anyhow::Error> {
+        println!("== Support Tickets Test ==");
+        let new_conversation = self
+            .client
+            .support_tickets()
+            .create_support_ticket(&CreateSupportTicketParams {
+                subject: "Mobile Support Test Message".to_string(),
+                message: "This is a test – it can be deleted without replying.".to_string(),
+                application: "jetpack".to_string(),
+                wpcom_site_id: None,
+                tags: vec!["jetpack_mobile".to_string(), "test".to_string()],
+                attachments: vec![],
+            })
+            .await?
+            .data;
+        println!("✅ Create Conversation");
+
+        self.client
+            .support_tickets()
+            .add_message_to_support_conversation(
+                &new_conversation.id,
+                &AddMessageToSupportConversationParams {
+                    message: "Test Message".to_string(),
+                    attachments: vec![],
+                },
+            )
+            .await?;
+        println!("✅ Add Message to Conversation");
+
+        self.client
+            .support_tickets()
+            .get_support_conversation(&new_conversation.id)
+            .await?;
+        println!("✅ Fetch Conversation");
+
+        self.client
+            .support_tickets()
+            .get_support_conversation_list()
+            .await?;
+        println!("✅ Fetch Conversation List");
+
+        Ok(())
+    }
+}