WIP zero binaries.

lakesuperior/api/admin.py

@@ -34,7 +34,6 @@ def migrate(src, dest, start=('/',), **kwargs):
 
     See :py:meth:`Migrator.__init__`.
     """
-    # 1. Retrieve list of resources.
     start_pts = (
             (start,)
             if not isinstance(start, list) and not isinstance(start, tuple)

lakesuperior/migrator.py

@@ -129,6 +129,7 @@ class Migrator:
 
         self.src = src.rstrip('/')
         self.start_pts = start_pts
+        self.zero_binaries = zero_binaries
 
         from lakesuperior.api import resource as rsrc_api
         self.rsrc_api = rsrc_api
@@ -206,11 +207,19 @@ class Migrator:
 
         # Grab binary and set new resource parameters.
         if ldp_type == 'ldp_nr':
-            bin_resp = requests.get('{}/fcr:content'.format(uri))
-            bin_resp.raise_for_status()
-            data = bin_resp.content
             provided_imr = gr.resource(URIRef(iuri))
-            mimetype = bin_resp.headers.get('content-type')
+            if self.zero_binaries:
+                data = b'\x00'
+                mimetype = str(provided_imr.value(
+                        nsc['ebucore'].hasMimeType,
+                        default='application/octet-stream'))
+            else:
+                bin_resp = requests.get('{}/fcr:content'.format(uri))
+                bin_resp.raise_for_status()
+                data = bin_resp.content
+                mimetype = bin_resp.headers.get('content-type')
+
+            import pdb; pdb.set_trace()
             self.rsrc_api.create_or_replace(
                     uid, mimetype=mimetype, provided_imr=provided_imr,
                     stream=BytesIO(data))

lsup-admin

@@ -30,6 +30,8 @@ def bootstrap():
 
     Additional scaffolding files may be parsed to create initial contents.
     '''
+    import lakesuperior.env_setup
+
     rdfly = env.app_globals.rdfly
     nonrdfly = env.app_globals.nonrdfly
 
@@ -43,8 +45,6 @@ def bootstrap():
         click.echo('Aborting.')
         sys.exit(1)
 
-    import lakesuperior.env_setup
-
     click.echo('Initializing graph store at {}'.format(rdfly.store.path))
     with TxnManager(env.app_globals.rdf_store, write=True) as txn:
         rdfly.bootstrap()