Merge pull request #882 from Shinsina/newsletter-scheduled-content-qu…

…ery-improvements `newsletterEmailSchedules` query
parameter1 · Mar 25, 2024 · 4b7556f · 4b7556f
2 parents 22c1994 + 48bdeb7
commit 4b7556f
Show file tree

Hide file tree

Showing 4 changed files with 45 additions and 0 deletions.
diff --git a/services/graphql-server/src/graphql/definitions/email/schedule.js b/services/graphql-server/src/graphql/definitions/email/schedule.js
@@ -11,6 +11,8 @@ extend type Query {
     model: "email.Schedule",
     using: { contentId: "content.$id" },
   )
+  "Query for newsletter schedules by newlsetter product id and specified date range"
+  newsletterEmailSchedules(input: NewsletterEmailSchedulesQueryInput!): [EmailSchedule]!
 }
 
 extend type Mutation {
@@ -88,6 +90,16 @@ input EmailScheduleSortInput {
   order: SortOrder = desc
 }
 
+"Input for retrieiving newsletter schedules for a specified time range"
+input NewsletterEmailSchedulesQueryInput {
+  "The newsletter product id"
+  newsletterId: ObjectID!
+  "The millisecond precision UNIX timestamp to start looking for schedules at (inclusive)"
+  after: Date!
+  "The millsecond precision UNIX timestamp to stop looking for schedules at (inclusive"
+  before: Date!
+}
+
 input QuickCreateEmailSchedulesMutationInput {
   contentId: Int!
   sectionIds: [Int!]!

diff --git a/services/graphql-server/src/graphql/definitions/platform/content/interfaces/content.js b/services/graphql-server/src/graphql/definitions/platform/content/interfaces/content.js
@@ -91,6 +91,8 @@ interface Content @requiresProject(fields: ["type"]) {
   websiteSchedules: [ContentWebsiteSchedule]!
   # Returns the magazine schedules
   magazineSchedules: [MagazineSchedule]! @projection(localField: "_id")
+  # Returns the email schedules
+  emailSchedules: [EmailSchedule]! @projection(localField: "_id")
 
   hasWebsiteSchedule(input: ContentHasWebsiteScheduleInput!): Boolean! @projection(localField: "sectionQuery")
 

diff --git a/services/graphql-server/src/graphql/resolvers/email/schedule.js b/services/graphql-server/src/graphql/resolvers/email/schedule.js
@@ -1,7 +1,9 @@
 const { BaseDB, MongoDB } = require('@parameter1/base-cms-db');
 const { Base4RestPayload } = require('@parameter1/base-cms-base4-rest-api');
 const { dasherize } = require('@parameter1/base-cms-inflector');
+const moment = require('moment');
 const getProjection = require('../../utils/get-projection');
+const buildProjection = require('../../utils/build-projection');
 
 const validateRest = require('../../utils/validate-rest');
 
@@ -15,6 +17,33 @@ const clearSeconds = (date) => {
 };
 
 module.exports = {
+  /**
+   *
+   */
+  Query: {
+
+    newsletterEmailSchedules: async (_, { input }, { basedb }, info) => {
+      const {
+        newsletterId,
+        before,
+        after,
+      } = input;
+      const start = moment(after).toDate();
+      const end = moment(before).toDate();
+      const scheduleSort = { sequence: 1, deploymentDate: 1 };
+      const scheduleQuery = {
+        product: BaseDB.coerceID(newsletterId),
+        status: 1,
+        deploymentDate: { $gte: start, $lte: end },
+      };
+      const projection = buildProjection({ info, type: 'EmailSchedule' });
+      const schedules = await basedb.find('email.Schedule', scheduleQuery, {
+        sort: scheduleSort,
+        projection,
+      });
+      return schedules;
+    },
+  },
   /**
    *
    */

diff --git a/services/graphql-server/src/graphql/resolvers/platform/content.js b/services/graphql-server/src/graphql/resolvers/platform/content.js
@@ -418,6 +418,8 @@ module.exports = {
 
     magazineSchedules: ({ _id }, _, { basedb }) => basedb.find('magazine.Schedule', { 'content.$id': _id }),
 
+    emailSchedules: ({ _id }, _, { basedb }) => basedb.find('email.Schedule', { 'content.$id': _id, status: 1 }),
+
     /**
      * Load primary section of content.
      * If primary section's site matches the current site, return the section.