blob: 210ec0fd5ea1d44abe564e6fc431b8f7b3aff032 [file] [log] [blame]
#!/usr/bin/env python
import os
import imp
from xos.config import Config, XOS_DIR
import inspect
import time
import traceback
import commands
import threading
import json
import pdb
from core.models import *
from xos.logger import Logger, logging
logger = Logger(level=logging.INFO)
missing_links={}
try:
dep_data = open(Config().dependency_graph).read()
except:
dep_data = open(XOS_DIR + '/model-deps').read()
dependencies = json.loads(dep_data)
inv_dependencies = {}
for k, lst in dependencies.items():
for v in lst:
try:
inv_dependencies[v].append(k)
except KeyError:
inv_dependencies[v]=[k]
def plural(name):
if (name.endswith('s')):
return name+'es'
else:
return name+'s'
def walk_deps(fn, object):
model = object.__class__.__name__
try:
deps = dependencies[model]
except:
deps = []
return __walk_deps(fn, object, deps)
def walk_inv_deps(fn, object):
model = object.__class__.__name__
try:
deps = inv_dependencies[model]
except:
deps = []
return __walk_deps(fn, object, deps)
def __walk_deps(fn, object, deps):
model = object.__class__.__name__
ret = []
for dep in deps:
#print "Checking dep %s"%dep
peer=None
link = dep.lower()
try:
peer = getattr(object, link)
except AttributeError:
link = plural(link)
try:
peer = getattr(object, link)
except AttributeError:
if not missing_links.has_key(model+'.'+link):
print "Model %s missing link for dependency %s"%(model, link)
logger.log_exc("WARNING: Model %s missing link for dependency %s."%(model, link))
missing_links[model+'.'+link]=True
if (peer):
try:
peer_objects = peer.all()
except AttributeError:
peer_objects = [peer]
except:
peer_objects = []
for o in peer_objects:
#if (isinstance(o,PlCoreBase)):
if (hasattr(o,'updated')):
fn(o, object)
ret.append(o)
# Uncomment the following line to enable recursion
# walk_inv_deps(fn, o)
return ret
def p(x,source):
print x,x.__class__.__name__
return
def main():
#pdb.set_trace()
s = Slice.objects.filter(name='princeton_sapan62')
#pdb.set_trace()
print walk_inv_deps(p,s[0])
if __name__=='__main__':
main()