Page MenuHomeSoftware Heritage
Differential D4200

Add support for revision artifacts
ClosedPublic
Actions

Authored by haltode on Oct 8 2020, 2:08 PM.

Details

Reviewers
seirl
Group Reviewers
Reviewers
Maniphest Tasks
T1926: FUSE filesystem to navigate the archive
T2663: FUSE: add support for revision objects
Commits
rDFUSE6fb734ddef3b: fuse: add support for revision artifacts
Summary

Closes T2663.

What is working:

  • Symlinks in directory entries
  • Submodules in directory entries (interpreted as symlink to rev)
  • Mounting revisions

What needs to be done:

  • Add unit tests (done, but only very basic unit tests, i want to rework the test framework data generation in another diff and add more unit tests)

Related to T1926.

Diff Detail

Repository
rDFUSE FUSE virtual file system
Branch
feature/add-revision-support
Lint
No Linters Available
Unit
No Unit Test Coverage
Build Status
Buildable 16055
Build 24693: Phabricator diff pipeline on jenkinsJenkins console · Jenkins
Build 24692: arc lint + arc unit

Event Timeline

haltode created this revision.Oct 8 2020, 2:08 PM
Herald added a reviewer: Reviewers. · View Herald TranscriptOct 8 2020, 2:08 PM
swh-public-ci added a comment.Oct 8 2020, 2:08 PM

Build has FAILED

Patch application report for D4200 (id=14788)

Rebasing onto ee058855d1...

Current branch diff-target is up to date.
Changes applied before test
commit 95fb3258cf9b3d8640d7efc0a53c20d87aa57d34
Author: Thibault Allançon <haltode@gmail.com>
Date:   Thu Oct 8 14:06:37 2020 +0200

    WIP: add support for revision artifacts

Link to build: https://jenkins.softwareheritage.org/job/DFUSE/job/tests-on-diff/37/
See console output for more information: https://jenkins.softwareheritage.org/job/DFUSE/job/tests-on-diff/37/console

Harbormaster failed remote builds in B16054: Diff 14788!Oct 8 2020, 2:08 PM
haltode updated this revision to Diff 14789.Oct 8 2020, 2:21 PM
  • tests: add missing join() after subprocess.run()
swh-public-ci added a comment.Oct 8 2020, 2:21 PM

Build has FAILED

Patch application report for D4200 (id=14789)

Rebasing onto ee058855d1...

Current branch diff-target is up to date.
Changes applied before test
commit 1b6cae6b9161e676154871e1c211716568805bcd
Author: Thibault Allançon <haltode@gmail.com>
Date:   Thu Oct 8 14:06:37 2020 +0200

    WIP: add support for revision artifacts

commit 84227af536a90dc82a2033caed718081b7822d0b
Author: Thibault Allançon <haltode@gmail.com>
Date:   Thu Oct 8 14:20:16 2020 +0200

    tests: add missing join() after subprocess.run()

Link to build: https://jenkins.softwareheritage.org/job/DFUSE/job/tests-on-diff/38/
See console output for more information: https://jenkins.softwareheritage.org/job/DFUSE/job/tests-on-diff/38/console

Harbormaster failed remote builds in B16055: Diff 14789!Oct 8 2020, 2:21 PM
haltode added inline comments.Oct 8 2020, 2:23 PM
swh/fuse/fuse.py
198

Not sure if we want to use directly the target field here or some getter/setter, because FuseEntry does not have such field (so mypy complains).

haltode edited the summary of this revision. (Show Details)Oct 8 2020, 2:25 PM
haltode added a task: T1926: FUSE filesystem to navigate the archive.
haltode updated this revision to Diff 14791.Oct 8 2020, 2:27 PM

Fix pytest warning

swh-public-ci added a comment.Oct 8 2020, 2:28 PM

Build is green

Patch application report for D4200 (id=14791)

Rebasing onto ee058855d1...

Current branch diff-target is up to date.
Changes applied before test
commit 74607ba9d0b3f123bbb7ddc9a859884e780f46fd
Author: Thibault Allançon <haltode@gmail.com>
Date:   Thu Oct 8 14:26:57 2020 +0200

    tests: add missing join() after subprocess.run()

See https://jenkins.softwareheritage.org/job/DFUSE/job/tests-on-diff/39/ for more details.

Harbormaster completed remote builds in B16057: Diff 14791.Oct 8 2020, 2:28 PM
haltode updated this revision to Diff 14792.Oct 8 2020, 2:30 PM

Move pytest warning commit to a separate diff

swh-public-ci added a comment.Oct 8 2020, 2:30 PM

Build has FAILED

Patch application report for D4200 (id=14792)

Rebasing onto ee058855d1...

Current branch diff-target is up to date.
Changes applied before test
commit a3f5e88621fb79b49d6ef51802f4c4663bd248e9
Author: Thibault Allançon <haltode@gmail.com>
Date:   Thu Oct 8 14:06:37 2020 +0200

    WIP: add support for revision artifacts

Link to build: https://jenkins.softwareheritage.org/job/DFUSE/job/tests-on-diff/40/
See console output for more information: https://jenkins.softwareheritage.org/job/DFUSE/job/tests-on-diff/40/console

Harbormaster failed remote builds in B16058: Diff 14792!Oct 8 2020, 2:30 PM
haltode marked an inline comment as not done.Oct 8 2020, 2:44 PM
haltode updated this revision to Diff 14795.Oct 8 2020, 2:45 PM

Rebasing on master.

swh-public-ci added a comment.Oct 8 2020, 2:46 PM

Build has FAILED

Patch application report for D4200 (id=14795)

Rebasing onto 74607ba9d0...

Current branch diff-target is up to date.
Changes applied before test
commit 8f668ca2f793322a1926541afb83f27b1b9ee997
Author: Thibault Allançon <haltode@gmail.com>
Date:   Thu Oct 8 14:06:37 2020 +0200

    WIP: add support for revision artifacts

Link to build: https://jenkins.softwareheritage.org/job/DFUSE/job/tests-on-diff/42/
See console output for more information: https://jenkins.softwareheritage.org/job/DFUSE/job/tests-on-diff/42/console

Harbormaster failed remote builds in B16061: Diff 14795!Oct 8 2020, 2:46 PM
haltode updated this revision to Diff 14798.Oct 8 2020, 4:09 PM

Rework code architecture

swh-public-ci added a comment.Oct 8 2020, 4:09 PM

Build has FAILED

Patch application report for D4200 (id=14798)

Rebasing onto 74607ba9d0...

Current branch diff-target is up to date.
Changes applied before test
commit 7229a8cf6bb8379d4d05d446d08da009cf04bbf0
Author: Thibault Allançon <haltode@gmail.com>
Date:   Thu Oct 8 14:06:37 2020 +0200

    WIP: add support for revision artifacts

Link to build: https://jenkins.softwareheritage.org/job/DFUSE/job/tests-on-diff/43/
See console output for more information: https://jenkins.softwareheritage.org/job/DFUSE/job/tests-on-diff/43/console

Harbormaster failed remote builds in B16064: Diff 14798!Oct 8 2020, 4:09 PM
haltode updated this revision to Diff 14800.Oct 8 2020, 5:06 PM

Add basic unit tests.

swh-public-ci added a comment.Oct 8 2020, 5:07 PM

Build has FAILED

Patch application report for D4200 (id=14800)

Rebasing onto 74607ba9d0...

Current branch diff-target is up to date.
Changes applied before test
commit 3da472a18e405270632d0d239dc6874c01498971
Author: Thibault Allançon <haltode@gmail.com>
Date:   Thu Oct 8 14:06:37 2020 +0200

    WIP: add support for revision artifacts

Link to build: https://jenkins.softwareheritage.org/job/DFUSE/job/tests-on-diff/44/
See console output for more information: https://jenkins.softwareheritage.org/job/DFUSE/job/tests-on-diff/44/console

Harbormaster failed remote builds in B16067: Diff 14800!Oct 8 2020, 5:07 PM
haltode edited the summary of this revision. (Show Details)Oct 8 2020, 5:07 PM
zack added a subscriber: zack.Oct 9 2020, 8:58 AM
zack added inline comments.
swh/fuse/fs/artifact.py
85

It looks like both Directory and Revision define an __aiter__ method, which is not defined in ArtifactEntry. That's understandable, as some artifacts are not iterable (e.g., content). But it poses the problem of where to document what one iterates on. Either you briefly describe it in both those classes (and do so also in the upcoming classes), or you introduce an intermediate class to distinguish between iterable artifact entries and singleton ones, and document the iterator in the former.

Maybe there is (or will be) some common logic to be factored out in that new intermediate class, dunno.

swh/fuse/fs/entry.py
54

this method is idempotent, right? i.e., if we call it multiple times it won't attempt to create an entry (say, under archive/) multiple times and the second time it's invoked it will just return what had been created the first time, right? (the code calling it seems to expect that property)

If that's the case, the name create_* is misleading, as it doesn't imply idempotency. I'm not sure I've a great alternative suggestion, but ensure_* sounds marginally better (other options could be get_*, init_*, none of which sounds perfect).

No matter how it's called, idempotency being an important property of the contract of using a method, we need a docstring here stating the method is idempotent.

swh/fuse/fs/mountpoint.py
21–23

Is the name property on the root entry ever needed/accessed? I guess/hope not.
Either way, it'd be better to make its dummy value much more clearly dummy, e.g. "DUMMY_ROOT_PATH". Unless it could be made explicitly None, which I doubt it can.

haltode added inline comments.Oct 9 2020, 9:50 AM
swh/fuse/fs/artifact.py
85

The __aiter__ is defined in the upper-level FuseEntry class, we could document there all common methods + examples of which one use them (eg: Content not having an __aiter__ but a content()).

swh/fuse/fs/entry.py
54

It is not idempotent, everytime you call create_child a new object is created. However, with the inode <-> entry mapping we re-use parts of the objects, and there is a TODO in the code about caching the entries of an iterable FuseEntry so we don't need to recreate the same child objects everytime. Maybe we could discuss/measure this memory/performance topic in a separate diff?

swh/fuse/fs/mountpoint.py
21–23

This property is never accessed on the root node indeed, we can make it None.

haltode updated this revision to Diff 14849.Oct 9 2020, 10:06 AM
  • Add get_target() method for symlinks
  • Set Root node name to None
haltode marked an inline comment as done.Oct 9 2020, 10:07 AM
swh-public-ci added a comment.Oct 9 2020, 10:07 AM

Build is green

Patch application report for D4200 (id=14849)

Rebasing onto 74607ba9d0...

Current branch diff-target is up to date.
Changes applied before test
commit 8cee03c105a1a78b25d9fd51b652f2d042b2c771
Author: Thibault Allançon <haltode@gmail.com>
Date:   Thu Oct 8 14:06:37 2020 +0200

    WIP: add support for revision artifacts

See https://jenkins.softwareheritage.org/job/DFUSE/job/tests-on-diff/45/ for more details.

Harbormaster completed remote builds in B16087: Diff 14849.Oct 9 2020, 10:07 AM
haltode updated this revision to Diff 14850.Oct 9 2020, 11:06 AM

Fix style + commit description

haltode retitled this revision from WIP: add support for revision artifacts to Add support for revision artifacts.Oct 9 2020, 11:06 AM
swh-public-ci added a comment.Oct 9 2020, 11:07 AM

Build is green

Patch application report for D4200 (id=14850)

Rebasing onto 74607ba9d0...

Current branch diff-target is up to date.
Changes applied before test
commit d264b560608117175e232c2a0012d247e7326893
Author: Thibault Allançon <haltode@gmail.com>
Date:   Thu Oct 8 14:06:37 2020 +0200

    fuse: add support for revision artifacts
    
    Closes T2663.
    
    - Add a `SymlinkEntry` class (+ rework fs/ class init using dataclasses)
    - Support symlinks, submodules, and mounting revisions
    - Basic unit tests for revision artifacts

See https://jenkins.softwareheritage.org/job/DFUSE/job/tests-on-diff/46/ for more details.

Harbormaster completed remote builds in B16088: Diff 14850.Oct 9 2020, 11:07 AM
haltode updated this revision to Diff 14851.Oct 9 2020, 11:08 AM

Fix type hints

swh-public-ci added a comment.Oct 9 2020, 11:09 AM

Build is green

Patch application report for D4200 (id=14851)

Rebasing onto 74607ba9d0...

Current branch diff-target is up to date.
Changes applied before test
commit 4ce90f555f1a639fe9a8b08bc5fdc82dabda42b4
Author: Thibault Allançon <haltode@gmail.com>
Date:   Thu Oct 8 14:06:37 2020 +0200

    fuse: add support for revision artifacts
    
    Closes T2663.
    
    - Add a `SymlinkEntry` class (+ rework fs/ class init using dataclasses)
    - Support symlinks, submodules, and mounting revisions
    - Basic unit tests for revision artifacts

See https://jenkins.softwareheritage.org/job/DFUSE/job/tests-on-diff/47/ for more details.

Harbormaster completed remote builds in B16089: Diff 14851.Oct 9 2020, 11:09 AM
haltode updated this revision to Diff 14883.Oct 9 2020, 2:04 PM

Rework parents/ directories and symlink, now a parents/ is always present and
parent/ is a symlink to parents/1/ if the commit has at least one parent.

swh-public-ci added a comment.Oct 9 2020, 2:05 PM

Build is green

Patch application report for D4200 (id=14883)

Rebasing onto 74607ba9d0...

Current branch diff-target is up to date.
Changes applied before test
commit c0c992ed725d26404ffb63f478841e41d5ab39cb
Author: Thibault Allançon <haltode@gmail.com>
Date:   Thu Oct 8 14:06:37 2020 +0200

    fuse: add support for revision artifacts
    
    Closes T2663.
    
    - Add a `SymlinkEntry` class (+ rework fs/ class init using dataclasses)
    - Support symlinks, submodules, and mounting revisions
    - Basic unit tests for revision artifacts

See https://jenkins.softwareheritage.org/job/DFUSE/job/tests-on-diff/50/ for more details.

Harbormaster completed remote builds in B16117: Diff 14883.Oct 9 2020, 2:05 PM
haltode updated this revision to Diff 14887.Oct 9 2020, 2:20 PM

Rebasing on master.

swh-public-ci added a comment.Oct 9 2020, 2:20 PM

Build is green

Patch application report for D4200 (id=14887)

Rebasing onto d759b9b3b7...

Current branch diff-target is up to date.
Changes applied before test
commit a6731c0e4cad887c167a62ea8ac937aff50f75f4
Author: Thibault Allançon <haltode@gmail.com>
Date:   Thu Oct 8 14:06:37 2020 +0200

    fuse: add support for revision artifacts
    
    Closes T2663.
    
    - Add a `SymlinkEntry` class (+ rework fs/ class init using dataclasses)
    - Support symlinks, submodules, and mounting revisions
    - Basic unit tests for revision artifacts

See https://jenkins.softwareheritage.org/job/DFUSE/job/tests-on-diff/53/ for more details.

Harbormaster completed remote builds in B16121: Diff 14887.Oct 9 2020, 2:20 PM
seirl requested changes to this revision.Oct 9 2020, 2:36 PM
seirl added a subscriber: seirl.
seirl added inline comments.
swh/fuse/fs/artifact.py
67

This should probably be cached so that if you call get_content() and size() you only fetch the content once?

268

Why do you create a list first and then yield it? Couldn't you just yield the elements one by one?

swh/fuse/fs/entry.py
51

Probably renaming that to get_relative_root_path() would be more explicit.

54

@zack Idempotency is not a concern here as this method doesn't have any side effects. It returns the newly created child.

swh/fuse/fs/mountpoint.py
31

Again, don't create an intermediate list

This revision now requires changes to proceed.Oct 9 2020, 2:36 PM
haltode added inline comments.Oct 9 2020, 2:40 PM
swh/fuse/fs/artifact.py
67

Hm sure, i didn't want to add a cache on-top of the already existing blob cache, but i can put the information in prefetch["length"]

haltode updated this revision to Diff 14890.Oct 9 2020, 2:48 PM
  • Rename get_root_path to get_relative_root_path
  • Cache content size call when possible
  • Remove unnecessary intermediate lists and yield directly
swh-public-ci added a comment.Oct 9 2020, 2:49 PM

Build is green

Patch application report for D4200 (id=14890)

Rebasing onto d759b9b3b7...

Current branch diff-target is up to date.
Changes applied before test
commit 6fb734ddef3b9375a70795e94d2ccfc098a18ad0
Author: Thibault Allançon <haltode@gmail.com>
Date:   Thu Oct 8 14:06:37 2020 +0200

    fuse: add support for revision artifacts
    
    Closes T2663.
    
    - Add a `SymlinkEntry` class (+ rework fs/ class init using dataclasses)
    - Support symlinks, submodules, and mounting revisions
    - Basic unit tests for revision artifacts

See https://jenkins.softwareheritage.org/job/DFUSE/job/tests-on-diff/54/ for more details.

Harbormaster completed remote builds in B16124: Diff 14890.Oct 9 2020, 2:49 PM
haltode marked 4 inline comments as done.Oct 9 2020, 2:49 PM
seirl accepted this revision.Oct 9 2020, 2:54 PM
This revision is now accepted and ready to land.Oct 9 2020, 2:54 PM
Closed by commit rDFUSE6fb734ddef3b: fuse: add support for revision artifacts (authored by haltode). · Explain WhyOct 9 2020, 3:38 PM
This revision was automatically updated to reflect the committed changes.
haltode added a commit: rDFUSE6fb734ddef3b: fuse: add support for revision artifacts.

Revision Contents
Changeset List

PathSize
swh/
fuse/
fs/
155 lines
9 lines
33 lines
29 lines
4 lines
tests/
1 line

Diff 14789

View Options

swh/fuse/fs/artifact.py

  • This file was added.
# Copyright (C) 2016 The Software Heritage developers
# See the AUTHORS file at the top-level directory of this distribution
# License: GNU General Public License version 3, or any later version
# See top-level LICENSE file for more information
import click
from flask import Flask, abort, g
from swh.core import config
from swh.objstorage.api.common import encode_data_server as encode_data
from swh.objstorage.api.common import BytesRequest, error_handler
from swh.storage import get_storage
from swh.storage.vault.api import cooking_tasks # NOQA
from swh.storage.vault.cache import VaultCache
from swh.storage.vault.cooker import DirectoryVaultCooker
from swh.scheduler.celery_backend.config import app as celery_app
from flask_profile import Profiler
cooking_task_name = 'swh.storage.vault.api.cooking_tasks.SWHCookingTask'
DEFAULT_CONFIG = {
'storage': ('dict', {'storage_class': 'local_storage',
'storage_args': [
'dbname=softwareheritage-dev',
'/tmp/objects'
]
}),
'cache': ('dict', {'root': '/tmp/vaultcache'})
}
app = Flask(__name__)
Profiler(app)
app.request_class = BytesRequest
@app.errorhandler(Exception)
def my_error_handler(exception):
return error_handler(exception, encode_data)
@app.before_request
def before_request():
g.cache = VaultCache(**app.config['cache'])
g.cooker = DirectoryVaultCooker(
get_storage(**app.config['storage']),
g.cache
)
@app.route('/')
def index():
return 'SWH vault API server'
@app.route('/vault/directory/', methods=['GET'])
def ls_directory():
return encode_data(list(
g.cache.ls('directory')
))
@app.route('/vault/directory/<dir_id>/', methods=['GET'])
ardumontUnsubmitted
Done
Inline Actions

Maybe explicit that this is to be called when the directory is cooked.
By updating the function name for example, get_cooked_directory.

ardumont: Maybe explicit that this is to be called when the directory is cooked. By updating the…
def get_cooked_directory(dir_id):
if not g.cache.is_cached('directory', dir_id):
abort(404)
return encode_data(g.cache.get('directory', dir_id).decode())
@app.route('/vault/directory/<dir_id>/', methods=['POST'])
def cook_request_directory(dir_id):
task = celery_app.tasks[cooking_task_name]
task.delay(dir_id, app.config['storage'], app.config['cache'])
# Return url to get the content and 201 CREATED
return encode_data('/vault/directory/dir_id/'), 201
@click.command()
@click.argument('config-path', required=1)
@click.option('--host', default='0.0.0.0', help="Host to run the server")
@click.option('--port', default=5000, type=click.INT,
help="Binding port of the server")
@click.option('--debug/--nodebug', default=True,
help="Indicates if the server should run in debug mode")
def launch(config_path, host, port, debug):
app.config.update(config.read(config_path, DEFAULT_CONFIG))
app.run(host, port=int(port), debug=bool(debug))
if __name__ == '__main__':
launch()
View Options

swh/fuse/fs/entry.py

  • This file was added.
# Copyright (C) 2016 The Software Heritage developers
# See the AUTHORS file at the top-level directory of this distribution
# License: GNU General Public License version 3, or any later version
# See top-level LICENSE file for more information
import click
from flask import Flask, abort, g
from swh.core import config
from swh.objstorage.api.common import encode_data_server as encode_data
from swh.objstorage.api.common import BytesRequest, error_handler
from swh.storage import get_storage
from swh.storage.vault.api import cooking_tasks # NOQA
from swh.storage.vault.cache import VaultCache
from swh.storage.vault.cooker import DirectoryVaultCooker
from swh.scheduler.celery_backend.config import app as celery_app
from flask_profile import Profiler
cooking_task_name = 'swh.storage.vault.api.cooking_tasks.SWHCookingTask'
DEFAULT_CONFIG = {
'storage': ('dict', {'storage_class': 'local_storage',
'storage_args': [
'dbname=softwareheritage-dev',
'/tmp/objects'
]
}),
'cache': ('dict', {'root': '/tmp/vaultcache'})
}
app = Flask(__name__)
Profiler(app)
app.request_class = BytesRequest
@app.errorhandler(Exception)
def my_error_handler(exception):
return error_handler(exception, encode_data)
@app.before_request
def before_request():
g.cache = VaultCache(**app.config['cache'])
g.cooker = DirectoryVaultCooker(
get_storage(**app.config['storage']),
g.cache
)
@app.route('/')
def index():
return 'SWH vault API server'
@app.route('/vault/directory/', methods=['GET'])
def ls_directory():
return encode_data(list(
g.cache.ls('directory')
))
@app.route('/vault/directory/<dir_id>/', methods=['GET'])
ardumontUnsubmitted
Done
Inline Actions

Maybe explicit that this is to be called when the directory is cooked.
By updating the function name for example, get_cooked_directory.

ardumont: Maybe explicit that this is to be called when the directory is cooked. By updating the…
def get_cooked_directory(dir_id):
if not g.cache.is_cached('directory', dir_id):
abort(404)
return encode_data(g.cache.get('directory', dir_id).decode())
@app.route('/vault/directory/<dir_id>/', methods=['POST'])
def cook_request_directory(dir_id):
task = celery_app.tasks[cooking_task_name]
task.delay(dir_id, app.config['storage'], app.config['cache'])
# Return url to get the content and 201 CREATED
return encode_data('/vault/directory/dir_id/'), 201
@click.command()
@click.argument('config-path', required=1)
@click.option('--host', default='0.0.0.0', help="Host to run the server")
@click.option('--port', default=5000, type=click.INT,
help="Binding port of the server")
@click.option('--debug/--nodebug', default=True,
help="Indicates if the server should run in debug mode")
def launch(config_path, host, port, debug):
app.config.update(config.read(config_path, DEFAULT_CONFIG))
app.run(host, port=int(port), debug=bool(debug))
if __name__ == '__main__':
launch()
View Options

swh/fuse/fs/mountpoint.py

  • This file was added.
# Copyright (C) 2016 The Software Heritage developers
# See the AUTHORS file at the top-level directory of this distribution
# License: GNU General Public License version 3, or any later version
# See top-level LICENSE file for more information
import click
from flask import Flask, abort, g
from swh.core import config
from swh.objstorage.api.common import encode_data_server as encode_data
from swh.objstorage.api.common import BytesRequest, error_handler
from swh.storage import get_storage
from swh.storage.vault.api import cooking_tasks # NOQA
from swh.storage.vault.cache import VaultCache
from swh.storage.vault.cooker import DirectoryVaultCooker
from swh.scheduler.celery_backend.config import app as celery_app
from flask_profile import Profiler
cooking_task_name = 'swh.storage.vault.api.cooking_tasks.SWHCookingTask'
DEFAULT_CONFIG = {
'storage': ('dict', {'storage_class': 'local_storage',
'storage_args': [
'dbname=softwareheritage-dev',
'/tmp/objects'
]
}),
'cache': ('dict', {'root': '/tmp/vaultcache'})
}
app = Flask(__name__)
Profiler(app)
app.request_class = BytesRequest
@app.errorhandler(Exception)
def my_error_handler(exception):
return error_handler(exception, encode_data)
@app.before_request
def before_request():
g.cache = VaultCache(**app.config['cache'])
g.cooker = DirectoryVaultCooker(
get_storage(**app.config['storage']),
g.cache
)
@app.route('/')
def index():
return 'SWH vault API server'
@app.route('/vault/directory/', methods=['GET'])
def ls_directory():
return encode_data(list(
g.cache.ls('directory')
))
@app.route('/vault/directory/<dir_id>/', methods=['GET'])
ardumontUnsubmitted
Done
Inline Actions

Maybe explicit that this is to be called when the directory is cooked.
By updating the function name for example, get_cooked_directory.

ardumont: Maybe explicit that this is to be called when the directory is cooked. By updating the…
def get_cooked_directory(dir_id):
if not g.cache.is_cached('directory', dir_id):
abort(404)
return encode_data(g.cache.get('directory', dir_id).decode())
@app.route('/vault/directory/<dir_id>/', methods=['POST'])
def cook_request_directory(dir_id):
task = celery_app.tasks[cooking_task_name]
task.delay(dir_id, app.config['storage'], app.config['cache'])
# Return url to get the content and 201 CREATED
return encode_data('/vault/directory/dir_id/'), 201
@click.command()
@click.argument('config-path', required=1)
@click.option('--host', default='0.0.0.0', help="Host to run the server")
@click.option('--port', default=5000, type=click.INT,
help="Binding port of the server")
@click.option('--debug/--nodebug', default=True,
help="Indicates if the server should run in debug mode")
def launch(config_path, host, port, debug):
app.config.update(config.read(config_path, DEFAULT_CONFIG))
app.run(host, port=int(port), debug=bool(debug))
if __name__ == '__main__':
launch()
View Options

swh/fuse/fs/symlink.py

  • This file was added.
# Copyright (C) 2016 The Software Heritage developers
# See the AUTHORS file at the top-level directory of this distribution
# License: GNU General Public License version 3, or any later version
# See top-level LICENSE file for more information
import click
from flask import Flask, abort, g
from swh.core import config
from swh.objstorage.api.common import encode_data_server as encode_data
from swh.objstorage.api.common import BytesRequest, error_handler
from swh.storage import get_storage
from swh.storage.vault.api import cooking_tasks # NOQA
from swh.storage.vault.cache import VaultCache
from swh.storage.vault.cooker import DirectoryVaultCooker
from swh.scheduler.celery_backend.config import app as celery_app
from flask_profile import Profiler
cooking_task_name = 'swh.storage.vault.api.cooking_tasks.SWHCookingTask'
DEFAULT_CONFIG = {
'storage': ('dict', {'storage_class': 'local_storage',
'storage_args': [
'dbname=softwareheritage-dev',
'/tmp/objects'
]
}),
'cache': ('dict', {'root': '/tmp/vaultcache'})
}
app = Flask(__name__)
Profiler(app)
app.request_class = BytesRequest
@app.errorhandler(Exception)
def my_error_handler(exception):
return error_handler(exception, encode_data)
@app.before_request
def before_request():
g.cache = VaultCache(**app.config['cache'])
g.cooker = DirectoryVaultCooker(
get_storage(**app.config['storage']),
g.cache
)
@app.route('/')
def index():
return 'SWH vault API server'
@app.route('/vault/directory/', methods=['GET'])
def ls_directory():
return encode_data(list(
g.cache.ls('directory')
))
@app.route('/vault/directory/<dir_id>/', methods=['GET'])
ardumontUnsubmitted
Done
Inline Actions

Maybe explicit that this is to be called when the directory is cooked.
By updating the function name for example, get_cooked_directory.

ardumont: Maybe explicit that this is to be called when the directory is cooked. By updating the…
def get_cooked_directory(dir_id):
if not g.cache.is_cached('directory', dir_id):
abort(404)
return encode_data(g.cache.get('directory', dir_id).decode())
@app.route('/vault/directory/<dir_id>/', methods=['POST'])
def cook_request_directory(dir_id):
task = celery_app.tasks[cooking_task_name]
task.delay(dir_id, app.config['storage'], app.config['cache'])
# Return url to get the content and 201 CREATED
return encode_data('/vault/directory/dir_id/'), 201
@click.command()
@click.argument('config-path', required=1)
@click.option('--host', default='0.0.0.0', help="Host to run the server")
@click.option('--port', default=5000, type=click.INT,
help="Binding port of the server")
@click.option('--debug/--nodebug', default=True,
help="Indicates if the server should run in debug mode")
def launch(config_path, host, port, debug):
app.config.update(config.read(config_path, DEFAULT_CONFIG))
app.run(host, port=int(port), debug=bool(debug))
if __name__ == '__main__':
launch()
View Options

swh/fuse/fuse.py

Loading...
View Options

swh/fuse/tests/conftest.py

Loading...
About · Developer information · Legal