From f2320cd0a665e6b923be9ef5fbeb9ab0420d0147 Mon Sep 17 00:00:00 2001
From: cavis <ryancavis@gmail.com>
Date: Fri, 13 Sep 2024 14:20:12 -0600
Subject: [PATCH] Query line_item_ids within a collection/package

---
 src/query-jobs/boostr_impressions.js | 21 +++++++++++----------
 1 file changed, 11 insertions(+), 10 deletions(-)

diff --git a/src/query-jobs/boostr_impressions.js b/src/query-jobs/boostr_impressions.js
index b6df271..ca61fc3 100644
--- a/src/query-jobs/boostr_impressions.js
+++ b/src/query-jobs/boostr_impressions.js
@@ -6,16 +6,17 @@
 export default async function job(config) {
   const query = `
     SELECT
-      FORMAT_TIMESTAMP("%m/%d/%Y", timestamp) AS Date,
-      external_id AS \`Ad Server Line\`,
-      count(*) AS Impressions
-    FROM ${process.env.BIGQUERY_DATASET}.dt_impressions
-    INNER JOIN ${process.env.BIGQUERY_DATASET}.flights ON (flight_id = id)
-    WHERE timestamp >= ?
-      AND timestamp < ?
-      AND is_duplicate = false
-      AND creative_id IS NOT NULL
-      AND integration_id IN (${config.integrationIds.join(", ")})
+      FORMAT_TIMESTAMP("%m/%d/%Y", i.timestamp) AS Date,
+      COALESCE(x.external_id, f.external_id) AS \`Ad Server Line\`,
+      COUNT(*) AS Impressions
+    FROM ${process.env.BIGQUERY_DATASET}.dt_impressions i
+    INNER JOIN ${process.env.BIGQUERY_DATASET}.flights f ON (i.flight_id = f.id)
+    LEFT JOIN ${process.env.BIGQUERY_DATASET}.flight_collection_external_ids x ON (f.id = x.flight_id AND i.feeder_podcast = x.podcast_id)
+    WHERE i.timestamp >= ?
+      AND i.timestamp < ?
+      AND i.is_duplicate = FALSE
+      AND i.creative_id IS NOT NULL
+      AND f.integration_id IN (${config.integrationIds.join(", ")})
     GROUP BY Date, \`Ad Server Line\`
     ORDER BY Date ASC, \`Ad Server Line\` ASC
   `;