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_by(cls, **kwargs):
25 return cls.query.filter_by(**kwargs).first()
28 def get_latest_n_by(cls, n=3, **kwargs):
29 return cls.query.filter_by(**kwargs)
32 date_checked = Field(DateTime,default=datetime.now)
33 round = Field(Int,default=0)
34 hostname = Field(String,primary_key=True,default=None)
35 loginbase = Field(String)
38 kernel_version = Field(String,default=None)
39 bootcd_version = Field(String,default=None)
40 nm_status = Field(String,default=None)
41 fs_status = Field(String,default=None)
42 dns_status = Field(String,default=None)
43 princeton_comon_dir = Field(Boolean,default=False)
44 princeton_comon_running = Field(Boolean,default=False)
45 princeton_comon_procs = Field(Int,default=None)
48 plc_node_stats = Field(PickleType,default=None)
49 plc_site_stats = Field(PickleType,default=None)
50 plc_pcuid = Field(Int,default=None)
51 comon_stats = Field(PickleType,default=None)
52 port_status = Field(PickleType,default=None)
53 ssh_portused = Field(Int,default=22)
54 ssh_status = Field(Boolean,default=False)
55 ssh_error = Field(String,default=None) # set if ssh_access == False
56 ping_status = Field(Boolean,default=False)
59 observed_category = Field(String,default=None)
60 observed_status = Field(String,default=None)
62 acts_as_versioned(ignore=['date_checked'])
63 # NOTE: this is the child relation
64 #action = ManyToOne('ActionRecord', required=False)
66 class FindbadPCURecord(Entity):
68 def get_all_latest(cls):
69 return cls.query.all()
72 def get_latest_by(cls, **kwargs):
73 return cls.query.filter_by(**kwargs).first()
76 date_checked = Field(DateTime)
77 round = Field(Int,default=0)
78 plc_pcuid = Field(Int)
81 plc_pcu_stats = Field(PickleType,default=None)
82 dns_status = Field(String)
83 port_status = Field(PickleType)
84 entry_complete = Field(String)
88 reboot_trial_status = Field(String)
90 acts_as_versioned(ignore=['date_checked'])