Class: InvitationRepl

Inherits:
Sinatra::Base
  • Object
show all
Defined in:
src/ruby/invitation-repl.rb

Class Method Summary collapse

Class Method Details

.perform_update(which) ⇒ Object

[View source]

18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
 
# File 'src/ruby/invitation-repl.rb', line 18

def self.perform_update(which)
    # send event invites
    rows = @@neo4j.neo4j_query(<<~END_OF_QUERY).map { |x| {:eid => x['eid'], :email => x['email'], :name => x['name'], :org_email => x['org_email'] } }
        MATCH (u)-[rt:IS_PARTICIPANT]->(e:Event)-[:ORGANIZED_BY]->(ou:User)
        WHERE (u:ExternalUser OR u:PredefinedExternalUser) AND rt.invitation_requested = true AND COALESCE(rt.deleted, false) = false AND COALESCE(e.deleted, false) = false
        RETURN e.id AS eid, u.email AS email, u.name AS name, ou.email AS org_email
    END_OF_QUERY

    if rows.size > 0
        STDERR.puts ">>> Sending #{rows.size} event invites!"
        STDERR.puts '-' * 59
        rows.each.with_index do |row, i|
            # send invitation mail
            STDERR.puts ">>> Sending invite #{i + 1} of #{rows.size}..."
            STDERR.puts '-' * 59
            Main.invite_external_user_for_event(row[:eid], row[:email], row[:org_email])
            sleep 10.0
            # wait for 10 seconds
        end
    end
    
    # send poll run invites
    rows = @@neo4j.neo4j_query(<<~END_OF_QUERY).map { |x| {:prid => x['prid'], :email => x['email'], :name => x['name'], :org_email => x['org_email'] } }
        MATCH (u)-[rt:IS_PARTICIPANT]->(pr:PollRun)-[:RUNS]->(p:Poll)-[:ORGANIZED_BY]->(ou:User)
        WHERE (u:ExternalUser OR u:PredefinedExternalUser) AND rt.invitation_requested = true AND COALESCE(rt.deleted, false) = false AND COALESCE(pr.deleted, false) = false AND COALESCE(p.deleted, false) = false
        RETURN pr.id AS prid, u.email AS email, u.name AS name, ou.email AS org_email
    END_OF_QUERY

    if rows.size > 0
        STDERR.puts ">>> Sending #{rows.size} poll run invites!"
        STDERR.puts '-' * 59
        rows.each.with_index do |row, i|
            # send invitation mail
            STDERR.puts ">>> Sending invite #{i + 1} of #{rows.size}..."
            STDERR.puts '-' * 59
            Main.invite_external_user_for_poll_run(row[:prid], row[:email], row[:org_email])
            unless DEVELOPMENT
                sleep 1.0
            end
            # wait for 10 seconds
        end
    end
end