apidata = api.make_auth_from_opts(opts, parser)
model = get_model(opts.load_model)
- mapper = DAFMapper(opts.name, opts.daf, model)
- submission_uri = get_submission_uri(opts.name)
+ if opts.name:
+ mapper = DAFMapper(opts.name, opts.daf, model)
+ submission_uri = get_submission_uri(opts.name)
+
+ if opts.library_url is not None:
+ mapper.library_url = opts.library_url
if opts.load_rdf is not None:
load_into_model(model, 'turtle', opts.load_rdf, submission_uri)
if str(view) == str(libraryOntology['ignore']):
return None
- submissionName = toTypedNode(self.make_submission_name(submission_dir))
+ submission_name = self.make_submission_name(submission_dir)
submissionNode = self.get_submission_node(submission_dir)
- submission_uri = submissionNode.uri
- print "submission:", str(submission_name), str(submissionNode), str(submission_uri)
-
++ submission_uri = str(submissionNode.uri)
+ view_name = fromTypedNode(self.model.get_target(view, dafTermOntology['name']))
- submissionView = RDF.Node(RDF.Uri(str(submission_uri) + '/' + view_name))
++ submissionView = RDF.Node(RDF.Uri(submission_uri + '/' + view_name))
+
self.model.add_statement(
RDF.Statement(self.submissionSet, dafTermOntology['has_submission'], submissionNode))
daf.add_to_model(model, parsed, name)
signal_view_node = RDF.Node(subNS['/view/Signal'].uri)
+
writer = get_serializer()
turtle = writer.serialize_model_to_string(model)
- #print turtle
- self.failUnless(str(signal_view_node) in turtle)
+
+ self.failUnless(str(signal_view_node.uri) in turtle)
statements = list(model.find_statements(
RDF.Statement(
daf_mapper.construct_file_attributes('/tmp/analysis1', libNode, 'filename.bam')
source = daf_mapper.model.get_source(rdfNS['type'], submissionOntology['submission'])
- self.failUnlessEqual(str(source), "<http://jumpgate.caltech.edu/wiki/SubmissionsLog/testfind/analysis1>")
+ self.failUnlessEqual(str(source.uri), "http://jumpgate.caltech.edu/wiki/SubmissionsLog/testfind/analysis1")
view = daf_mapper.model.get_target(source, submissionOntology['has_view'])
- self.failUnlessEqual(str(view.uri), "http://jumpgate.caltech.edu/wiki/SubmissionsLog/testfind/view/Signal")
- self.failUnlessEqual(str(view), "<http://jumpgate.caltech.edu/wiki/SubmissionsLog/testfind/analysis1/Signal>")
-
++ self.failUnlessEqual(str(view.uri), "http://jumpgate.caltech.edu/wiki/SubmissionsLog/testfind/analysis1/Signal")
-
+ def test_library_url(self):
+ daf_mapper = load_daf_mapper('urltest')
+
+ self.failUnlessEqual(daf_mapper.library_url,
+ 'http://jumpgate.caltech.edu/library/')
+ daf_mapper.library_url = 'http://google.com'
+ self.failUnlessEqual(daf_mapper.library_url, 'http://google.com' )
+
def suite():
suite = unittest.makeSuite(TestDAF, 'test')
suite.addTest(unittest.makeSuite(TestDAFMapper, 'test'))