Add in the ability to get channel history correctly

Author: Anonymous

src/Slack.jl

@@ -4,6 +4,27 @@ using HTTP
 using CodecZlib
 using JSON
 
+# Message object in the threaded form
+mutable struct threadedMessage
+    edited::Bool
+    ts::String
+    thread_ts::String
+    user::String
+    text::String
+end
+
+# A thread is an array of threadMessage's
+mutable struct thread
+    thread::Array{threadedMessage}
+end
+
+mutable struct message
+    edited::Bool
+    ts::String
+    user::String
+    text::String
+end
+
 include("send.jl")
 export
     sendtoslack,

src/history.jl

@@ -2,29 +2,72 @@
     getchannelhistory(token::String)
 Takes in the Slack App Auth token and channel ID.
 
+Returns the 800 most recent messags (this may not be the case always). Could be time based...
+
 Tokens can be accessed at "https://api.slack.com/apps/random-letters-and-numbers/oauth?"
 """
 function getchannelhistory(token::String, channelid::String)
-    HTTP.setuseragent!("HTTP.jl")
 
+    HTTP.setuseragent!("HTTP.jl")
     url = "https://slack.com/api/conversations.history?token=$(token)&channel=$(channelid)"
-
     r = HTTP.get(url, ["Content-Type" => "application/json"])
 
     json_obj = JSON.parse(String(r.body))
     message_holder = []
+
+    #TODO: Need to figure out a parameter to constrain the time period in which messages are returned.
+
     for (k,v) in json_obj
         if occursin("messages", k)
             for item in v
+
+                # Declare the holder variables
+                edited = false
+                ts = ""
+                thread_ts = ""
+                user = ""
+                text = ""
+
+                # println("Starting to parse a new message") #DEBUG
                 for (key,value) in item
-                    if key == "client_msg_id"
-                        println("client_msg_id: $(value)")
+                    if key == "edited"
+                        edited = true
+
+                    # TODO: also convert this to Date Time and add that for print out.
+                    elseif key == "ts"
+                        ts = value
+
                     elseif key == "text"
-                        println("text: $(value)")
+                        text = value
+
+                    elseif key == "user"
+                        user = value
+
+                    # It's a thread not a message...
+                    elseif key == "thread_ts"
+                        thread_ts = value
                     end
                 end
+
+                # If ts and thread_ts are the same, then this is a thread so call the thread function
+                if ts == thread_ts && ts != ""
+
+                    try
+                        thread_msg = getthreads(token, channelid, ts)
+                        push!(message_holder, thread_msg)
+                    catch
+                        println("Failed to create a threaded message object")
+                    end
+
+                # Else it's a normal message so create it here and push it into an array.
+                else
+                    msg = message(edited, ts, user, text)
+                    push!(message_holder, msg)
+                end
             end
         end
     end
 
+    return(message_holder)
+
 end

src/threads.jl

@@ -1,30 +1,66 @@
 """
     getthreads(token::String)
 Takes in the Slack App Auth token, channel ID, and Time Signature of the parent message.
+Return the first 50 replies ina  thread.
 
 https://api.slack.com/methods/conversations.replies#arg_ts
 """
 function getthreads(token::String, channelid::String, ts::String)
     HTTP.setuseragent!("HTTP.jl")
 
+    # TODO: 50 is an arbitary number, see if there is a limit.
     url = "https://slack.com/api/conversations.replies?token=$(token)&channel=$(channelid)&ts=$(ts)&limit=50"
 
     r = HTTP.get(url, ["Content-Type" => "application/json"])
+    message_holder = []
 
     json_obj = JSON.parse(String(r.body))
     message_holder = []
     for (k,v) in json_obj
         if occursin("messages", k)
             for item in v
-                for (key,value) in item
-                    if key == "text"
-                        println(value)
-                    elseif key == "user"
-                        println("User with ID $(value) said:")
+
+                # Declare the holder variables
+                edited = false
+                ts = ""
+                thread_ts = ""
+                user = ""
+                text = ""
+
+                # println("Starting to look through next Dict/Object") #DEBUG
+                for (key, value) in item
+                    if key == "user"
+                        user = value
+
+                    elseif key == "edited"
+                        edited = true
+
+                    elseif key == "ts"
+                        ts = value
+
+                    elseif key == "thread_ts"
+                        thread_ts = value
+
+                    elseif key == "text"
+                        text = value
                     end
                 end
+
+                # Create the message object.. Handle a failed parse and object creation error.
+                try
+                    new_tm = threadedMessage(edited, ts, thread_ts, user, text)
+
+                    # Push it into the holder array
+                    push!(message_holder, new_tm)
+                catch
+                    println("Enabled to created a threaded message with the following details: $(edited), $(ts), $(thread_ts), $(user), $(text)")
+                end
+
             end
         end
     end
 
+    # Create and Return the Thread object (just an array of messages)
+    return(message_holder)
+
 end