Class: DrbDb

Inherits:
Object
  • Object
show all
Includes:
Cron, DRbUndumped, Eprint, EventCache, GtkAttributes, Help, Messaging, SQL
Defined in:
lib/DrbDB.rb

Overview

this file is part of manqod manqod is distributed under the CDDL licence the author of manqod is Dobai-Pataky Balint([email protected])

Constant Summary collapse

INIT = 
0
LOADING = 
1
SERVING = 
2

Constants included from Eprint

Eprint::TERM_COLOUR

Instance Attribute Summary collapse

Attributes included from Cron

#scheduler

Instance Method Summary collapse

Methods included from Messaging

#delete_message, #messages, #send_check_messages, #send_message, #sendmail_to_nick, #set_message_read, #unread_messages

Methods included from EventCache

#events, #load_all_events

Methods included from GtkAttributes

#gtk_attribute, #gtk_attribute_of_object, #load_all_attributes

Methods included from Cron

#add_cron, #remove_cron, #reset_cron, #start_cron, #stop_cron

Methods included from Help

#load_all_help, #remove_help_format, #remove_help_item, #save_help_format, #save_help_item

Methods included from SQL

#add_where, #escape_string, #fields, #guess_base, #guess_table, #init_sql, #jruby?, #prepare_sql, #qrow, #query, #rows, #select_last, #top_level, #update_manqod_db

Methods included from Eprint

#ecode, #edebug, #eerror, #eeval, #eexception, #efatal, #einfo, #eprint, #ewarn, #getBinding

Constructor Details

#initialize(connection, main_server_uri) ⇒ DrbDb

Returns a new instance of DrbDb.



19
20
21
22
23
24
25
26
27
 
# File 'lib/DrbDB.rb', line 19

def initialize(connection,main_server_uri)
  @state=INIT
  @connection=connection
  @main_server_uri=main_server_uri
  @moditems=Hash.new #[moditem_id][id][fields]
  @server=nil
#   @relations=Hash.new
#   @server=DRb::DRbServer.new(@connection['uri'],self)
end

Instance Attribute Details

#admin ⇒ Object (readonly)

@server=DRb::DRbServer.new(@connection,self)



28
29
30
 
# File 'lib/DrbDB.rb', line 28

def admin
  @admin
end

#cache ⇒ Object (readonly)

@server=DRb::DRbServer.new(@connection,self)



28
29
30
 
# File 'lib/DrbDB.rb', line 28

def cache
  @cache
end

#client ⇒ Object (readonly)

@server=DRb::DRbServer.new(@connection,self)



28
29
30
 
# File 'lib/DrbDB.rb', line 28

def client
  @client
end

#connection ⇒ Object (readonly)

@server=DRb::DRbServer.new(@connection,self)



28
29
30
 
# File 'lib/DrbDB.rb', line 28

def connection
  @connection
end

#images ⇒ Object (readonly)

@server=DRb::DRbServer.new(@connection,self)



28
29
30
 
# File 'lib/DrbDB.rb', line 28

def images
  @images
end

#main_server ⇒ Object

Returns the value of attribute main_server.



29
30
31
 
# File 'lib/DrbDB.rb', line 29

def main_server
  @main_server
end

#moditems ⇒ Object (readonly)

@server=DRb::DRbServer.new(@connection,self)



28
29
30
 
# File 'lib/DrbDB.rb', line 28

def moditems
  @moditems
end

#relation_builder ⇒ Object (readonly)

@server=DRb::DRbServer.new(@connection,self)



28
29
30
 
# File 'lib/DrbDB.rb', line 28

def relation_builder
  @relation_builder
end

#server ⇒ Object

Returns the value of attribute server.



29
30
31
 
# File 'lib/DrbDB.rb', line 29

def server
  @server
end

#state ⇒ Object (readonly)

@server=DRb::DRbServer.new(@connection,self)



28
29
30
 
# File 'lib/DrbDB.rb', line 28

def state
  @state
end

#uri ⇒ Object (readonly)

@server=DRb::DRbServer.new(@connection,self)



28
29
30
 
# File 'lib/DrbDB.rb', line 28

def uri
  @uri
end

Instance Method Details

#alive? ⇒ Boolean

Returns:

  • (Boolean) 


291
292
293
294
 
# File 'lib/DrbDB.rb', line 291

def alive?
  true
#   server.alive?
end

#auth?(nick, password) ⇒ Boolean

Returns:

  • (Boolean) 


234
235
236
237
238
 
# File 'lib/DrbDB.rb', line 234

def auth?(nick,password)
  r=@users.auth?(nick,password)
  edebug("auth?(#{nick}):#{r}")
  r
end

#changed_ids_of_base(base, ids, nick = nil) ⇒ Object 



255
256
257
258
259
260
261
262
263
 
# File 'lib/DrbDB.rb', line 255

def changed_ids_of_base(base,ids,nick=nil)
  base_moditem=nil
  moditems_with_base(base){|b|
    base_moditem=b
  }
  unless base_moditem.nil?
    base_moditem.rows_changed(ids,nick)
  end
end

#each_moditem(modtype = "list") ⇒ Object 



275
276
277
278
279
 
# File 'lib/DrbDB.rb', line 275

def each_moditem(modtype = "list")
  @moditems.each_value{|m|
    yield m if m.mod_type == modtype
  }
end

#exit ⇒ Object 



304
305
306
307
 
# File 'lib/DrbDB.rb', line 304

def exit
  @server.stop_service
  super
end

#init ⇒ Object 



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
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
 
# File 'lib/DrbDB.rb', line 31

def init
  einfo("Memcached #{Memcached::VERSION}")
  @cache = Memcached.new([@connection['cache_host']],{:prefix_key=>key_name, :default_ttl => 0, :timeout => 30})
  DRb.start_service(@connection["uri"],self)
  @server=DRb.current_server()
  @main_server=DRb::DRbObject.new_with_uri(@main_server_uri)
  @uri=server.uri()
  unless init_sql(@connection['sql_host'],@connection['sql_user'],@connection['sql_password'],@connection['sql_db'])
    eerror("connection to sql server failed: #{@connection['sql_user']}@#{@connection['sql_host']}/#{@connection['sql_db']}")
    return nil
  end
  update_manqod_db
  begin
    begin
      @admin=DRb::DRbObject.new(nil,@connection['admin_uri'])
      we_have_admin=@admin.alive?
    rescue
      ewarn("no admin?")
      sleep 1
    end
  end until we_have_admin
  begin
    @state=LOADING
    load_all_attributes

    admin.rows("select moditems.id,modules.modname,moditems.display from moditems left join modules on modules.id = moditems.modid").each{|moditem|
      begin
        case moditem["modname"]
          when "listing"
            @moditems[moditem["id"].to_i]=DrbListModel.new(self,moditem["id"].to_i).create_skeleton unless @moditems.has_key?(moditem["id"])
            @moditems[moditem["id"].to_i].update(self)
          when "form"
            @moditems[moditem["id"].to_i]=DrbForm.new(self,moditem["id"].to_i).create_skeleton unless @moditems.has_key?(moditem["id"])
          when "relation_builder"
            @relation_builder=@moditems[moditem["id"].to_i]=DrbRelationBuilder.new(self,moditem["id"].to_i) unless @moditems.has_key?(moditem["id"])
          else
            ewarn("not caching #{moditem['display']}[#{moditem['modname']}]")
        end
      rescue =>err
        ewarn("error loading moditem: #{moditem.inspect}")
        eexception(err,:moditem => moditem)
      end
    }
    @images=DrbImages.new(self).load_all
    @users=Users.new(self).load_all
    load_all_events
    load_all_help
    start_cron
    @state=SERVING
  rescue => err
    eexception(err)
    retry
  end

  DRb.thread.join
  einfo("EXITED")
  exit
end

#key_name ⇒ Object 



116
117
118
 
# File 'lib/DrbDB.rb', line 116

def key_name
  @connection['key_name']
end

#lock_id_of_base(base, lid) ⇒ Object 



265
266
267
268
 
# File 'lib/DrbDB.rb', line 265

def lock_id_of_base(base,lid)
  ids=if lid.class == Array then lid else [lid] end
  moditems_with_base(base){|b| ids.each{|iid| b.lock_iter(iid)}}
end

#moditem(mod_id) ⇒ Object 



121
122
123
 
# File 'lib/DrbDB.rb', line 121

def moditem(mod_id)
  @moditems[mod_id.to_i]
end

#moditems_with_base(base) ⇒ Object 



249
250
251
252
253
 
# File 'lib/DrbDB.rb', line 249

def moditems_with_base(base)
  @moditems.each_value{|drblist|
    yield drblist if drblist && drblist.mod_type == "list" && drblist.base == base
  }
end

#mygroups(nick) ⇒ Object 



245
246
247
 
# File 'lib/DrbDB.rb', line 245

def mygroups(nick)
  @users.mygroups(nick)
end

#name ⇒ Object 



113
114
115
 
# File 'lib/DrbDB.rb', line 113

def name
  @connection['name']
end

#reload_client_attributes ⇒ Object 



193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
 
# File 'lib/DrbDB.rb', line 193

def reload_client_attributes
  client.load_all_attributes
  dead=Array.new
  main_server.connected_clients.each_pair{|client_id,cdb|
    if cdb[:db] == client.name
      begin
        einfo("sending reload attribute to #{client_id}")
        cdb[:object].rpc("GtkAttributeStorage.instance.load_all")
      rescue => err
        ewarn("cannot send reload attributes to #{client_id}")
        dead.push(client_id)
      end
    end
  }
  dead.each{|client_id|
    ewarn("killing dead client: #{client_id}")
    remove_client(client_id)
  }
end

#reload_client_events(goid) ⇒ Object 



213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
 
# File 'lib/DrbDB.rb', line 213

def reload_client_events(goid)
  einfo("changed client event: #{goid}")
  client.events(goid,true)
  dead=Array.new
  main_server.connected_clients.each_pair{|client_id,cdb|
    if cdb[:db] == client.name
      begin
        einfo("sending reload event to #{client_id}")
        cdb[:object].rpc("EventCache.instance.reload_events(\"#{goid}\")")
      rescue => err
        ewarn("cannot send reload events to #{client_id}")
        dead.push(client_id)
      end
    end
  }
  dead.each{|client_id|
    ewarn("killing dead client: #{client_id}")
    remove_client(client_id)
  }
end

#reload_client_images ⇒ Object 



174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
 
# File 'lib/DrbDB.rb', line 174

def reload_client_images
  dead=Array.new
  main_server.connected_clients.each_pair{|client_id,cdb|
    if cdb[:db] == client.name
      begin
        einfo("sending reload images to #{client_id}")
        sdb[:object].rpc("DrbImages.instance.load_images")
      rescue => err
        ewarn("cannot send reload images to #{client_id}")
        dead.push(client_id)
      end
    end
  }
  dead.each{|client_id|
    ewarn("killing dead client: #{client_id}")
    remove_client(client_id)
  }
end

#reload_moditem(moditem_id) ⇒ Object 



125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
 
# File 'lib/DrbDB.rb', line 125

def reload_moditem(moditem_id)
  @state=LOADING
  if moditem(moditem_id).nil?
    einfo("creating moditem ##{moditem_id}")
    #moditem added
    admin.rows("select moditems.id,modules.modname,moditems.display
    from moditems 
    left join modules on modules.id = moditems.modid
    where moditems.id='#{moditem_id}'").each{|moditem|
    begin
      case moditem["modname"]
        when "listing"
          @moditems[moditem["id"].to_i]=DrbListModel.new(self,moditem["id"].to_i).create_skeleton unless @moditems.has_key?(moditem["id"])
          @moditems[moditem["id"].to_i].update(self)
        when "form"
          @moditems[moditem["id"].to_i]=DrbForm.new(self,moditem["id"].to_i).create_skeleton unless @moditems.has_key?(moditem["id"])
        else
          eerror("not caching #{moditem['display']}[#{moditem['modname']}]")
      end
    rescue =>err
      ewarn("error loading moditem: #{moditem.inspect}")
      eexception(err,:moditem => moditem)
    end
    }
    
  else
    einfo("reloading moditem ##{moditem_id}")
    case moditem(moditem_id).mod_type
      when "list"
        new_model=DrbListModel.new(self,moditem_id).create_skeleton
        edebug("#{new_model} created")
        new_model.update(self)
        unless @moditems[moditem_id.to_i].nil?
          @moditems[moditem_id.to_i].clients.each_pair{|client_id,client| new_model.subscribe(client_id,client)}
          edebug("#{@moditems[moditem_id.to_i]} abandoned")
        end
        @moditems[moditem_id.to_i]=new_model
        @moditems[moditem_id.to_i].notify_clients(nil,"structure")
      when "form"
        moditem(moditem_id).create_skeleton
    end
  end
  @state=SERVING
end

#reload_users ⇒ Object 



170
171
172
 
# File 'lib/DrbDB.rb', line 170

def reload_users
  @users.load_all
end

#remove_client(client_id) ⇒ Object 



287
288
289
 
# File 'lib/DrbDB.rb', line 287

def remove_client(client_id)
  @moditems.each_value{|m| m.unsubscribe(client_id) if m.mod_type == "list"}
end

#remove_dead_clients ⇒ Object 



281
282
283
284
285
 
# File 'lib/DrbDB.rb', line 281

def remove_dead_clients
  cnt=0
  @moditems.each_value{|m| cnt+=m.remove_dead_clients if m.mod_type == "list"}
  cnt
end

#report_mail(subject, variables) ⇒ Object

def method_missing(sym,*args) p “#self missing method: #sym(#args)” end



300
301
302
 
# File 'lib/DrbDB.rb', line 300

def report_mail(subject, variables)
  @main_server.report_mail(subject,variables)
end

#sendmail(nick, subject, body) ⇒ Object 



239
240
241
 
# File 'lib/DrbDB.rb', line 239

def sendmail(nick,subject,body)
  sendmail_to_nick(nick,subject,body)
end

#serving? ⇒ Boolean

Returns:

  • (Boolean) 


309
310
311
 
# File 'lib/DrbDB.rb', line 309

def serving?
  @state==SERVING
end

#setup_client ⇒ Object 



90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
 
# File 'lib/DrbDB.rb', line 90

def setup_client
  if @connection['client_uri'].length>0
    begin
      @client=DRb::DRbObject.new(nil,@connection['client_uri'])
      einfo("client is alive?(#{@client}): #{@client.alive?}")
      
=begin
      @moditems.each_value{|mi| 
        ecode(mi.class.name)
        mi.update if mi.class == DrbRelationBuilder
      }
=end

    rescue
      @client=nil
      einfo("no client.")
    end
    begin
      @relation_builder.update if @relation_builder && @client
    rescue => err
      eexception(err)
    end
  end
end

#to_s ⇒ Object 



313
314
315
 
# File 'lib/DrbDB.rb', line 313

def to_s
  "[ManqodDb #{name}(#{Process.pid})]"
end

#unlock_id_of_base(base, lid) ⇒ Object 



270
271
272
273
 
# File 'lib/DrbDB.rb', line 270

def unlock_id_of_base(base,lid)
  ids=if lid.class == Array then lid else [lid] end
  moditems_with_base(base){|b| ids.each{|iid| b.unlock_iter(iid)}}
end

#user_in_group?(user_id, group_id) ⇒ Boolean

Returns:

  • (Boolean) 


242
243
244
 
# File 'lib/DrbDB.rb', line 242

def user_in_group?(user_id,group_id)
  @users.user_in_group?(user_id,group_id)
end