Add option for weekly and daily and hourly events

Author: ebanner

event.rb

@@ -1,6 +1,7 @@
 # frozen_string_literal: true
 
 require "date"
+require "time"
 
 class MeetupEvent
   # Can be used like so:
@@ -20,16 +21,38 @@ def self.parse_duration(iso8601_duration)
     parts.join(", ") + " long"
   end
 
-  def self.within_next_two_weeks?(date_string)
+  def self.within_next_week?(date_string)
     date = Date.parse(date_string)
     today = Date.today
-    date >= today && date <= (today + 14)
+    date >= today && date <= (today + 7)
   end
 
-  def self.format_slack(group)
+  def self.within_next_day?(date_string)
+    date = Date.parse(date_string)
+    today = Date.today
+    # today = Date.parse('2024-07-29T10:00-04:00')
+    date == today
+  end
+
+  def self.within_next_hour?(date_string)
+    datetime = Time.parse(date_string)
+    now = Time.now
+    # now = Time.parse('2024-07-29T18:00-04:00')
+    one_hour_from_now = now + 3600
+    datetime >= now && datetime <= one_hour_from_now
+  end
+
+  def self.format_slack(group, announcement_type)
     return if group["eventSearch"]["count"] == 0
 
-    return unless within_next_two_weeks?(group["eventSearch"]["edges"][0]["node"]["dateTime"])
+    date_string = group["eventSearch"]["edges"][0]["node"]["dateTime"]
+    if announcement_type == "weekly"
+      return unless within_next_week?(date_string)
+    elsif announcement_type == "daily"
+      return unless within_next_day?(date_string)
+    else 
+      return unless within_next_hour?(date_string)
+    end
 
     event_blocks = [{
       type: "section",
@@ -57,9 +80,7 @@ def self.format_slack(group)
           }
         ]
       },
-      {
-        type: "divider"
-      }]
+    ]
 
     if group["name"] == "Tampa Devs"
       event_blocks[0][:text][:text].prepend(":tampadevs: ")

main.rb

@@ -13,6 +13,15 @@ def initialize
   end
 
   def fetch
+    argument = ARGV[0]
+    if argument == '--weekly'
+      announcement_type = 'weekly'
+    elsif argument == '--daily'
+      announcement_type = 'daily'
+    else
+      announcement_type = 'hourly'
+    end
+
     groups = JSON.parse(Net::HTTP.get(URI("https://events.api.tampa.dev/")))
 
     sorted_events = []
@@ -25,18 +34,24 @@ def fetch
     sorted_events.sort! { |a, b| DateTime.parse(a["eventSearch"]["edges"][0]["node"]["dateTime"]) <=> DateTime.parse(b["eventSearch"]["edges"][0]["node"]["dateTime"]) }
 
     sorted_events.each do |group|
-      event = MeetupEvent.format_slack(group)
+      event = MeetupEvent.format_slack(group, announcement_type)
       formatted_events << event unless event.nil?
     end
 
+    # fencepost
+    formatted_events[0...-1].each do |element|
+      element << { type: "divider" }
+    end
+
     if formatted_events.empty?
       puts "No events to post, exiting with nothing to do."
       exit
     end
 
-    Slack.syndicate(formatted_events, @dry_run)
+    Slack.syndicate(formatted_events, announcement_type, @dry_run)
   end
 end
 
 syn = EventSyndicator.new
 syn.fetch
+

slack.rb

@@ -17,9 +17,10 @@ def initialize
     @message = []
   end
 
-  def self.syndicate(events, dry_run)
+  def self.syndicate(events, announcement_type, dry_run)
     return if events.empty?
 
+    @announcement_type = announcement_type
     @payload = payload(events)
 
     if dry_run
@@ -30,12 +31,19 @@ def self.syndicate(events, dry_run)
   end
 
   def self.payload(events)
+    if @announcement_type == 'weekly'
+      header_text = ":balloon: Upcoming Events"
+    elsif @announcement_type == 'daily'
+      header_text = ":earth_americas: Happening Today"
+    else
+      header_text = ":loudspeaker: Happening Soon"
+    end
     header = [
       {
-        type: "section",
+        type: "header",
         text: {
-          type: "mrkdwn",
-          text: ":balloon: Upcoming events:"
+          type: "plain_text",
+          text: header_text,
         }
       },
       {
@@ -44,6 +52,7 @@ def self.payload(events)
     ]
 
     footer = [
+      { type: "divider" },
       {
         type: "actions",
         elements: [
@@ -91,7 +100,13 @@ def self.payload(events)
       }
     ]
 
-    [header, events.reduce([], :concat), footer].reduce([], :concat)
+    elements = [header, events.reduce([], :concat)]
+    puts @announcement_type
+    if @announcement_type == 'weekly'
+      elements << footer
+    end
+    
+    elements.reduce([], :concat)
   end
 
   def self.message_json
@@ -103,7 +118,7 @@ def self.message_json
   def self.post
     return if @payload.length == 0
 
-    targets = [ENV["TD_SLACK_WEBHOOK"], ENV["TBT_SLACK_WEBHOOK"], ENV["TBUX_SLACK_WEBHOOK"]]
+    targets = [ENV["TD_SLACK_WEBHOOK"]]
 
     targets.each do |t|
       uri = URI.parse(t)