import fixes

4 files changed, 24 insertions, 27 deletions

diff --git a/test/lib/test_bsie.py b/test/lib/test_bsie.py
index 277ac67..5b71752 100644
--- a/test/lib/test_bsie.py
+++ b/test/lib/test_bsie.py
@@ -9,10 +9,11 @@ import os
 import unittest
 
 # bsie imports
+from bsie.base import extractor
 from bsie.tools import builder
-from bsie.utils import ns
 from bsie.utils.bsfs import URI, schema
 from bsie.utils.node import Node
+from bsie.utils import bsfs, node, ns
 
 # objects to test
 from bsie.lib.bsie import BSIE
@@ -76,7 +77,6 @@ class TestBSIE(unittest.TestCase):
                 rdfs:domain bsfs:Entity ;
                 rdfs:range xsd:string ;
                 bsfs:unique "true"^^xsd:boolean .
-
             '''))
 
         # specify collect
@@ -207,7 +207,7 @@ class TestBSIE(unittest.TestCase):
             ns.bse.author,
             })
         content_hash = 'a948904f2f0f479b8f8197694b30184b0d2ed1c1cd2a1ec0fb85d299a192a447'
-        subject = Node(ns.bsfs.Entity, self.prefix + content_hash)
+        subject = node.Node(ns.bsfs.File, self.prefix + 'file#' + content_hash)
         testfile = os.path.join(os.path.dirname(__file__), 'testfile.t')
 
         # from_file extracts all available triples
diff --git a/test/tools/test_builder.py b/test/tools/test_builder.py
index bc6f903..62c637c 100644
--- a/test/tools/test_builder.py
+++ b/test/tools/test_builder.py
@@ -10,8 +10,7 @@ import unittest
 
 # bsie imports
 from bsie import base
-from bsie.base import errors
-from bsie.utils.bsfs import URI
+from bsie.utils import bsfs
 
 # objects to test
 from bsie.tools.builder import ExtractorBuilder
@@ -26,12 +25,12 @@ from bsie.tools.builder import _unpack_name
 class TestUtils(unittest.TestCase):
     def test_safe_load(self):
         # invalid module
-        self.assertRaises(errors.LoaderError, _safe_load, 'dBGHMSAYOoKeKMpywDoKZQycENFPvN', 'foobar')
-        self.assertRaises(errors.LoaderError, _safe_load, 'dBGHMSAYOoKeKMpywDoKZQycENFPvN.bar', 'foobar')
+        self.assertRaises(base.errors.LoaderError, _safe_load, 'dBGHMSAYOoKeKMpywDoKZQycENFPvN', 'foobar')
+        self.assertRaises(base.errors.LoaderError, _safe_load, 'dBGHMSAYOoKeKMpywDoKZQycENFPvN.bar', 'foobar')
         # partially valid module
-        self.assertRaises(errors.LoaderError, _safe_load, 'os.foo', 'foobar')
+        self.assertRaises(base.errors.LoaderError, _safe_load, 'os.foo', 'foobar')
         # invalid class
-        self.assertRaises(errors.LoaderError, _safe_load, 'os.path', 'foo')
+        self.assertRaises(base.errors.LoaderError, _safe_load, 'os.path', 'foo')
         # valid module and class
         cls = _safe_load('collections.abc', 'Container')
         import collections.abc
@@ -65,10 +64,10 @@ class TestReaderBuilder(unittest.TestCase):
         self.assertRaises(TypeError, builder.build, None)
         self.assertRaises(ValueError, builder.build, '')
         self.assertRaises(ValueError, builder.build, 'Path')
-        self.assertRaises(errors.BuilderError, builder.build, 'path.Path')
+        self.assertRaises(base.errors.BuilderError, builder.build, 'path.Path')
         # invalid config
         builder = ReaderBuilder({'bsie.reader.stat.Stat': dict(foo=123)})
-        self.assertRaises(errors.BuilderError, builder.build, 'bsie.reader.stat.Stat')
+        self.assertRaises(base.errors.BuilderError, builder.build, 'bsie.reader.stat.Stat')
         builder = ReaderBuilder({'bsie.reader.stat.Stat': 123})
         self.assertRaises(TypeError, builder.build, 'bsie.reader.stat.Stat')
         # no instructions
@@ -143,7 +142,7 @@ class TestExtractorBuilder(unittest.TestCase):
             ]))
 
         # building with invalid args
-        self.assertRaises(errors.BuilderError, ExtractorBuilder(
+        self.assertRaises(base.errors.BuilderError, ExtractorBuilder(
             [{'bsie.extractor.generic.path.Path': {'foo': 123}}]).build, 0)
         # non-dict build specification
         self.assertRaises(TypeError, ExtractorBuilder(
@@ -161,7 +160,7 @@ class TestExtractorBuilder(unittest.TestCase):
 
 class TestPipelineBuilder(unittest.TestCase):
     def test_build(self):
-        prefix = URI('http://example.com/local/file#')
+        prefix = bsfs.URI('http://example.com/local/file#')
         c_schema = '''
             bse:author rdfs:subClassOf bsfs:Predicate ;
                 rdfs:domain bsfs:Entity ;
diff --git a/test/tools/test_pipeline.py b/test/tools/test_pipeline.py
index 0dd8c75..92801ed 100644
--- a/test/tools/test_pipeline.py
+++ b/test/tools/test_pipeline.py
@@ -11,9 +11,8 @@ import unittest
 
 # bsie imports
 from bsie.base import errors
-from bsie.utils import ns
 from bsie.utils.bsfs import URI
-from bsie.utils.node import Node
+from bsie.utils import bsfs, node, ns
 import bsie.extractor.generic.constant
 import bsie.extractor.generic.path
 import bsie.extractor.generic.stat
@@ -68,8 +67,8 @@ class TestPipeline(unittest.TestCase):
         self.assertEqual(hash(pipeline), hash(Pipeline(self.prefix, self.ext2rdr)))
 
         # equivalence respects prefix
-        self.assertNotEqual(pipeline, Pipeline(URI('http://example.com/global/ent#'), self.ext2rdr))
-        self.assertNotEqual(hash(pipeline), hash(Pipeline(URI('http://example.com/global/ent#'), self.ext2rdr)))
+        self.assertNotEqual(pipeline, Pipeline(bsfs.URI('http://example.com/global/ent#'), self.ext2rdr))
+        self.assertNotEqual(hash(pipeline), hash(Pipeline(bsfs.URI('http://example.com/global/ent#'), self.ext2rdr)))
         # equivalence respects extractors/readers
         ext2rdr = {ext: rdr for idx, (ext, rdr) in enumerate(self.ext2rdr.items()) if idx % 2 == 0}
         self.assertNotEqual(pipeline, Pipeline(self.prefix, ext2rdr))
@@ -96,7 +95,7 @@ class TestPipeline(unittest.TestCase):
         pipeline = Pipeline(self.prefix, self.ext2rdr)
         # build objects for tests
         content_hash = 'a948904f2f0f479b8f8197694b30184b0d2ed1c1cd2a1ec0fb85d299a192a447'
-        subject = Node(ns.bsfs.Entity, self.prefix + content_hash)
+        subject = node.Node(ns.bsfs.File, self.prefix + 'file#' + content_hash)
         testfile = os.path.join(os.path.dirname(__file__), 'testfile.t')
         p_filename = pipeline.schema.predicate(ns.bse.filename)
         p_filesize = pipeline.schema.predicate(ns.bse.filesize)
diff --git a/test/utils/test_node.py b/test/utils/test_node.py
index 826f199..c70f0b8 100644
--- a/test/utils/test_node.py
+++ b/test/utils/test_node.py
@@ -8,8 +8,7 @@ Author: Matthias Baumgartner, 2022
 import unittest
 
 # bsie imports
-from bsie.utils.bsfs import URI
-from bsie.utils import ns
+from bsie.utils import bsfs, ns
 
 # objects to test
 from bsie.utils.node import Node
@@ -19,14 +18,14 @@ from bsie.utils.node import Node
 
 class TestNode(unittest.TestCase):
     def test_equality(self):
-        uri = URI('http://example.com/me/entity#1234')
+        uri = bsfs.URI('http://example.com/me/entity#1234')
         node = Node(ns.bsfs.Entity, uri)
         # basic equivalence
-        self.assertEqual(node, Node(ns.bsfs.Entity, URI('http://example.com/me/entity#1234')))
-        self.assertEqual(hash(node), hash(Node(ns.bsfs.Entity, URI('http://example.com/me/entity#1234'))))
+        self.assertEqual(node, Node(ns.bsfs.Entity, bsfs.URI('http://example.com/me/entity#1234')))
+        self.assertEqual(hash(node), hash(Node(ns.bsfs.Entity, bsfs.URI('http://example.com/me/entity#1234'))))
         # equality respects uri
-        self.assertNotEqual(node, Node(ns.bsfs.Entity, URI('http://example.com/me/entity#4321')))
-        self.assertNotEqual(hash(node), hash(Node(ns.bsfs.Entity, URI('http://example.com/me/entity#4321'))))
+        self.assertNotEqual(node, Node(ns.bsfs.Entity, bsfs.URI('http://example.com/me/entity#4321')))
+        self.assertNotEqual(hash(node), hash(Node(ns.bsfs.Entity, bsfs.URI('http://example.com/me/entity#4321'))))
         # equality respects node_type
         self.assertNotEqual(node, Node(ns.bsfs.Foo, uri))
         self.assertNotEqual(hash(node), hash(Node(ns.bsfs.Foo, uri)))
@@ -42,7 +41,7 @@ class TestNode(unittest.TestCase):
         self.assertNotEqual(hash(node), hash(Foo()))
 
     def test_str(self):
-        uri = URI('http://example.com/me/entity#1234')
+        uri = bsfs.URI('http://example.com/me/entity#1234')
         # basic string conversion
         node = Node(ns.bsfs.Entity, uri)
         self.assertEqual(str(node), 'Node(http://bsfs.ai/schema/Entity, http://example.com/me/entity#1234)')
@@ -52,7 +51,7 @@ class TestNode(unittest.TestCase):
         self.assertEqual(str(node), 'Node(http://bsfs.ai/schema/Foo, http://example.com/me/entity#1234)')
         self.assertEqual(repr(node), 'Node(http://bsfs.ai/schema/Foo, http://example.com/me/entity#1234)')
         # string conversion respects uri
-        node = Node(ns.bsfs.Entity, URI('http://example.com/me/entity#4321'))
+        node = Node(ns.bsfs.Entity, bsfs.URI('http://example.com/me/entity#4321'))
         self.assertEqual(str(node), 'Node(http://bsfs.ai/schema/Entity, http://example.com/me/entity#4321)')
         self.assertEqual(repr(node), 'Node(http://bsfs.ai/schema/Entity, http://example.com/me/entity#4321)')