1 from elixir import Entity, Field, OneToMany, ManyToOne, ManyToMany
2 from elixir import options_defaults, using_options, setup_all, belongs_to
3 from elixir import String, Integer as Int, DateTime, PickleType, Boolean
4 from datetime import datetime,timedelta
7 from elixir.ext.versioned import *
9 from monitor.database.dborm import mon_metadata, mon_session
10 __metadata__ = mon_metadata
11 __session__ = mon_session
14 class FindbadNodeRecord(Entity):
16 def get_all_latest(cls):
17 return cls.query.all()
20 def get_latest_by(cls, **kwargs):
21 return cls.query.filter_by(**kwargs).first()
24 def get_latest_n_by(cls, n=3, **kwargs):
25 return cls.query.filter_by(**kwargs)
28 date_checked = Field(DateTime,default=datetime.now)
29 round = Field(Int,default=0)
30 hostname = Field(String,primary_key=True,default=None)
31 loginbase = Field(String)
34 kernel_version = Field(String,default=None)
35 bootcd_version = Field(String,default=None)
36 nm_status = Field(String,default=None)
37 fs_status = Field(String,default=None)
38 dns_status = Field(String,default=None)
39 princeton_comon_dir = Field(Boolean,default=False)
40 princeton_comon_running = Field(Boolean,default=False)
41 princeton_comon_procs = Field(Int,default=None)
44 plc_node_stats = Field(PickleType,default=None)
45 plc_site_stats = Field(PickleType,default=None)
46 plc_pcuid = Field(Int,default=None)
47 comon_stats = Field(PickleType,default=None)
48 port_status = Field(PickleType,default=None)
49 ssh_portused = Field(Int,default=22)
50 ssh_status = Field(Boolean,default=False)
51 ssh_error = Field(String,default=None) # set if ssh_access == False
52 ping_status = Field(Boolean,default=False)
55 observed_category = Field(String,default=None)
56 observed_status = Field(String,default=None)
58 acts_as_versioned(ignore=['date_checked'])
59 # NOTE: this is the child relation
60 #action = ManyToOne('ActionRecord', required=False)
62 class FindbadPCURecord(Entity):
64 def get_all_latest(cls):
65 return cls.query.all()
68 def get_latest_by(cls, **kwargs):
69 return cls.query.filter_by(**kwargs).first()
72 date_checked = Field(DateTime)
73 round = Field(Int,default=0)
74 plc_pcuid = Field(Int)
77 plc_pcu_stats = Field(PickleType,default=None)
78 dns_status = Field(String)
79 port_status = Field(PickleType)
80 entry_complete = Field(String)
84 reboot_trial_status = Field(String)
86 acts_as_versioned(ignore=['date_checked'])