Add more logging, safeguards and don't start campaigns by default

src/config.ts

@@ -3,10 +3,12 @@ export var config: {
   apiPassword: string
   feedUrl: string
   interval: number
-  listmonkBaseUrl: string
+  listmonkBaseUrl: string,
+  sendMails: boolean
 }
 
 export function parseConfig() {
+  console.log("Parsing config")
   config = {
     apiUser: parseEnvironmentVariable('LISTMONK_API_USER'),
     apiPassword: parseEnvironmentVariable('LISTMONK_API_PASSWORD'),
@@ -14,12 +16,14 @@ export function parseConfig() {
     interval: Number.parseInt(
       parseEnvironmentVariable('LISTMONK_CHECK_INTERVAL')
     ),
-    listmonkBaseUrl: parseEnvironmentVariable('LISTMONK_BASE_URL')
+    listmonkBaseUrl: parseEnvironmentVariable('LISTMONK_BASE_URL'),
+    sendMails: parseEnvironmentVariable('LISTMONK_SEND_MAILS') === 'true',
   }
   if (Number.isNaN(config.interval)) {
     console.error('LISTMONK_CHECK_INTERVAL must be a number')
     process.exit(1)
   }
+  console.log("Config successfully parsed")
 }
 
 function parseEnvironmentVariable(variableName: string): string {

src/index.ts

@@ -9,24 +9,34 @@ import cron from 'node-cron'
 import { config, parseConfig } from './config'
 
 async function processRssItem(rssItem: FeedItem, campaigns: CampaignDetails[]) {
+  console.log(`Processing RSS item ${rssItem.title} (GUID: ${rssItem.guid})`)
   const campaign = campaigns.find(
     (campaign) =>
       campaign.tags.find((tag) => tag === `id:${rssItem.guid}`) !== undefined
   )
   if (campaign !== undefined) {
+    console.log(`Campaign for GUID ${rssItem.guid} already exists`)
     return
   }
-  console.log(`"${rssItem.title}" doesn't exist.`)
+  console.log(`Creating campaign for GUID ${rssItem.guid}`)
   const details = await createCampaign(
     rssItem.title,
     rssItem.guid,
     rssItem.content
   )
+  if (config.sendMails) {
+    console.log(`Starting campaign for GUID ${rssItem.guid}`)
     await startCampaign(details.id)
   }
+  else {
+    console.log('Sending mails is disabled')
+  }
+
+}
 
 function main() {
   ;(async () => {
+    console.log("Starting main loop")
     const campaigns = await listCampaigns()
     const rssItems = await readRssFeed()
 

src/listmonk.ts

@@ -92,12 +92,17 @@ export interface CampaignListResponse {
 }
 
 export async function listCampaigns(): Promise<CampaignListResponse> {
-  console.log('Fetch campaigns')
+  console.log('Fetching campaigns')
   const response = await listmonkRequest<CampaignListResponse>(
     'get',
     'campaigns?per_page=skip',
     undefined
   )
-  console.log(`Found ${response.total} campaigns`)
+  console.log(`Campaign array has length ${response.results.length}`)
+  console.log(`Response says we should have ${response.total} total campaigns`)
+  if (response.results.length !== response.total) {
+    console.log('ERROR: Campaign array has different length than response total')
+    process.exit(1);
+  }
   return response
 }