Merge pull request #481 from AmbireTech/adview-manager-preview-a-video-ad

AdView manager preview for a video ad

Author: elpiel

Cargo.lock

@@ -4,7 +4,7 @@ members = [
     "primitives",
     "adapter",
     "adview-manager",
-    # Server for testing adview manager generated code
+    # `adview-serve` binary - Servers for testing adview manager generated code
     "adview-manager/serve",
     "validator_worker",
     "sentry",

Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 authors = ["Ambire <[email protected]>", "Lachezar Lechev <[email protected]>"]
 edition = "2021"
-name = "serve"
+name = "adview-serve"
 version = "0.1.0"
 license = "AGPL-3.0"
 publish = false

adview-manager/serve/Cargo.toml

@@ -1,3 +1,5 @@
+use std::sync::Arc;
+
 use adex_primitives::{
     supermarket::units_for_slot,
     targeting::{input::Global, Input},
@@ -32,11 +34,12 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
     info!("Tera templates glob path: {templates_glob}");
     // Use globbing
-    let tera = Tera::new(&templates_glob)?;
+    let tera = Arc::new(Tera::new(&templates_glob)?);
 
     // `GET /ad`
+    let ad_tera = tera.clone();
     let get_ad = warp::get().and(warp::path("ad")).then(move || {
-        let tera = tera.clone();
+        let tera = ad_tera.clone();
 
         async move {
             // let logger = logger.clone();
@@ -147,7 +150,68 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         }
     });
 
-    warp::serve(get_ad).run(([127, 0, 0, 1], 3030)).await;
+    // GET /preview/video
+    let get_preview_of_video = warp::get().and(warp::path!("preview" / "video" )).then(move || {
+        let tera = tera.clone();
+
+        async move {
+            let whitelisted_tokens = vec!["0x6B175474E89094C44Da98b954EedeAC495271d0F"
+                .parse()
+                .expect("Valid token Address")];
+            let disabled_video = false;
+            let publisher_addr = "0x0000000000000000626f62627973686d75726461"
+                .parse()
+                .unwrap();
+
+            let options = Options {
+                market_url: "http://placeholder.com".parse().unwrap(),
+                market_slot: DUMMY_IPFS[0],
+                publisher_addr,
+                // All passed tokens must be of the same price and decimals, so that the amounts can be accurately compared
+                whitelisted_tokens,
+                size: Some(Size::new(728, 90)),
+                // TODO: Check this value
+                navigator_language: Some("bg".into()),
+                /// Defaulted
+                disabled_video,
+                disabled_sticky: false,
+            };
+
+            // legacy_728x90
+            let video_ad_unit = adex_primitives::supermarket::units_for_slot::response::AdUnit {
+                /// Same as `ipfs`
+                id: "QmShJ6tsJ7LHLiYGX4EAmPyCPWJuCnvm6AKjweQPnw9qfh"
+                    .parse()
+                    .expect("Valid IPFS"),
+                media_url: "ipfs://Qmevmms1AZgYXS27A9ghSjHn4DSaHMfgYcD2SoGW14RYGy".to_string(),
+                media_mime: "video/mp4".to_string(),
+                target_url: "https://www.stremio.com/downloads".to_string(),
+            };
+
+            let video_html = get_unit_html_with_events(
+                &options,
+                &video_ad_unit,
+                "localhost",
+                DUMMY_CAMPAIGN.id,
+                &DUMMY_CAMPAIGN.validators,
+                false,
+            );
+
+            // let video_html = get_unit_html_with_events(&options, );
+            let html = {
+                let mut context = Context::new();
+                context.insert("ad_code", &video_html);
+
+                tera.render("ad.html", &context).expect("Should render")
+            };
+
+            warp::reply::html(html)
+        }
+    });
+
+    warp::serve(get_ad.or(get_preview_of_video))
+        .run(([127, 0, 0, 1], 3030))
+        .await;
 
     Ok(())
 }

adview-manager/serve/src/main.rs

@@ -196,6 +196,9 @@ fn get_unit_html(
         </div>", style=max_min_size, adex_icon=adex_icon())
 }
 
+/// no_impression - whether or not an IMPRESSION event should be sent with `onload`
+///
+///   [`WAIT_FOR_IMPRESSION`] - The timeout used before sending the IMPRESSION event to all validators
 pub fn get_unit_html_with_events(
     options: &Options,
     ad_unit: &AdUnit,