Test and fix tahoe invite w/o share arguments

This commit is contained in:
Jean-Paul Calderone 2021-03-24 13:23:19 -04:00
parent 20d9b84b0e
commit 3963979fbd
2 changed files with 89 additions and 32 deletions

View File

@ -14,7 +14,7 @@ from wormhole import wormhole
from allmydata.util.encodingutil import argv_to_abspath
from allmydata.scripts.common import get_default_nodedir, get_introducer_furl
from allmydata.node import read_config
from allmydata.client import read_config
class InviteOptions(usage.Options):
@ -94,9 +94,9 @@ def invite(options):
nick = options['nick']
remote_config = {
"shares-needed": options["shares-needed"] or config.get('client', 'shares.needed'),
"shares-total": options["shares-total"] or config.get('client', 'shares.total'),
"shares-happy": options["shares-happy"] or config.get('client', 'shares.happy'),
"shares-needed": options["shares-needed"] or config.get_config('client', 'shares.needed'),
"shares-total": options["shares-total"] or config.get_config('client', 'shares.total'),
"shares-happy": options["shares-happy"] or config.get_config('client', 'shares.happy'),
"nickname": nick,
"introducer": introducer_furl,
}

View File

@ -3,6 +3,11 @@ import mock
import json
from os.path import join
try:
from typing import Optional, Tuple
except ImportError:
pass
from twisted.trial import unittest
from twisted.internet import defer
from ..common_util import run_cli
@ -144,10 +149,17 @@ class Invite(GridTestMixin, CLITestMixin, unittest.TestCase):
intro_dir,
)
@defer.inlineCallbacks
def test_invite_success(self):
def _invite_success(self, extra_args=(), tahoe_config=None):
# type: (Tuple[bytes], Optional[bytes]) -> defer.Deferred
"""
successfully send an invite
Exercise an expected-success case of ``tahoe invite``.
:param extra_args: Positional arguments to pass to ``tahoe invite``
before the nickname.
:param tahoe_config: If given, bytes to write to the node's
``tahoe.cfg`` before running ``tahoe invite.
"""
intro_dir = os.path.join(self.basedir, "introducer")
# we've never run the introducer, so it hasn't created
@ -155,6 +167,9 @@ class Invite(GridTestMixin, CLITestMixin, unittest.TestCase):
priv_dir = join(intro_dir, "private")
with open(join(priv_dir, "introducer.furl"), "w") as f:
f.write("pb://fooblam\n")
if tahoe_config is not None:
with open(join(intro_dir, "tahoe.cfg"), "w") as f:
f.write(tahoe_config)
with mock.patch('allmydata.scripts.tahoe_invite.wormhole') as w:
fake_wh = _create_fake_wormhole([
@ -162,14 +177,8 @@ class Invite(GridTestMixin, CLITestMixin, unittest.TestCase):
])
w.create = mock.Mock(return_value=fake_wh)
rc, out, err = yield run_cli(
"-d", intro_dir,
"invite",
"--shares-needed", "1",
"--shares-happy", "1",
"--shares-total", "1",
"foo",
)
def done(result):
rc, out, err = result
self.assertEqual(2, len(fake_wh.messages))
self.assertEqual(
json.loads(fake_wh.messages[0]),
@ -180,16 +189,64 @@ class Invite(GridTestMixin, CLITestMixin, unittest.TestCase):
},
},
)
invite = json.loads(fake_wh.messages[1])
self.assertEqual(
json.loads(fake_wh.messages[1]),
{
"shares-needed": "1",
"shares-total": "1",
"nickname": "foo",
"introducer": "pb://fooblam",
"shares-happy": "1",
},
invite["nickname"], "foo",
)
self.assertEqual(
invite["introducer"], "pb://fooblam",
)
return invite
d = run_cli(
"-d", intro_dir,
"invite",
*(extra_args + ("foo",))
)
d.addCallback(done)
return d
@defer.inlineCallbacks
def test_invite_success(self):
"""
successfully send an invite
"""
invite = yield self._invite_success((
"--shares-needed", "1",
"--shares-happy", "2",
"--shares-total", "3",
))
self.assertEqual(
invite["shares-needed"], "1",
)
self.assertEqual(
invite["shares-happy"], "2",
)
self.assertEqual(
invite["shares-total"], "3",
)
@defer.inlineCallbacks
def test_invite_success_read_share_config(self):
"""
If ``--shares-{needed,happy,total}`` are not given on the command line
then the invitation is generated using the configured values.
"""
invite = yield self._invite_success(tahoe_config="""
[client]
shares.needed = 2
shares.happy = 4
shares.total = 6
""")
self.assertEqual(
invite["shares-needed"], "2",
)
self.assertEqual(
invite["shares-happy"], "4",
)
self.assertEqual(
invite["shares-total"], "6",
)
@defer.inlineCallbacks
def test_invite_no_furl(self):