[Release] Synchronize for release

Author: reboot-dev-bot

bank/backend/src/account_servicer.py

@@ -13,13 +13,17 @@
     WithdrawResponse,
 )
 from bank.v1.errors_pb2 import OverdraftError
+from reboot.aio.auth.authorizers import allow
 from reboot.aio.contexts import ReaderContext, WriterContext
 
 logging.basicConfig(level=logging.INFO)
 
 
 class AccountServicer(Account.Servicer):
 
+    def authorizer(self):
+        return allow()
+
     async def Open(
         self,
         context: WriterContext,

bank/backend/src/bank_servicer.py

@@ -8,13 +8,17 @@
     TransferRequest,
     TransferResponse,
 )
+from reboot.aio.auth.authorizers import allow
 from reboot.aio.contexts import TransactionContext
 
 logging.basicConfig(level=logging.INFO)
 
 
 class BankServicer(Bank.Servicer):
 
+    def authorizer(self):
+        return allow()
+
     async def SignUp(
         self,
         context: TransactionContext,

bank/backend/tests/account_servicer_test.py

@@ -2,6 +2,7 @@
 from account_servicer import AccountServicer
 from bank.v1.account_rbt import Account, BalanceResponse
 from bank.v1.errors_pb2 import OverdraftError
+from reboot.aio.applications import Application
 from reboot.aio.tests import Reboot
 from unittest import mock
 
@@ -23,7 +24,7 @@ async def asyncTearDown(self) -> None:
     async def test_basics(self) -> None:
         context = self.rbt.create_external_context(name=f"test-{self.id()}")
 
-        await self.rbt.up(servicers=[AccountServicer])
+        await self.rbt.up(Application(servicers=[AccountServicer]))
 
         # Create the state machine by calling its constructor. The fact that the
         # state machine _has_ a constructor means that this step is required
@@ -72,7 +73,7 @@ async def withdraw():
     @mock.patch("account_servicer.send_email")
     async def test_send_welcome_email(self, mock_send_email) -> None:
         await self.rbt.up(
-            servicers=[AccountServicer],
+            Application(servicers=[AccountServicer]),
             # Normally, `rbt.up()` runs the servicers in a separate process, to
             # ensure that accidental use of blocking functions (an easy mistake
             # to make) don't cause the test to lock up. However, in this test

bank/backend/tests/bank_servicer_test.py

@@ -4,6 +4,7 @@
 from bank.v1.bank_rbt import Bank, SignUpResponse
 from bank.v1.errors_pb2 import OverdraftError
 from bank_servicer import BankServicer
+from reboot.aio.applications import Application
 from reboot.aio.tests import Reboot
 
 
@@ -17,7 +18,9 @@ async def asyncTearDown(self) -> None:
         await self.rbt.stop()
 
     async def test_signup(self) -> None:
-        await self.rbt.up(servicers=[BankServicer, AccountServicer])
+        await self.rbt.up(
+            Application(servicers=[BankServicer, AccountServicer])
+        )
         context = self.rbt.create_external_context(name=f"test-{self.id()}")
         bank = Bank.ref("my-bank")
 
@@ -34,7 +37,9 @@ async def test_signup(self) -> None:
         self.assertEqual(response.balance, 0)
 
     async def test_transfer(self):
-        await self.rbt.up(servicers=[BankServicer, AccountServicer])
+        await self.rbt.up(
+            Application(servicers=[BankServicer, AccountServicer])
+        )
         context = self.rbt.create_external_context(name=f"test-{self.id()}")
         bank = Bank.ref("my-bank")
 

hello-constructors/backend/src/hello_servicer.py

@@ -7,11 +7,15 @@
     SendRequest,
     SendResponse,
 )
+from reboot.aio.auth.authorizers import allow
 from reboot.aio.contexts import ReaderContext, WriterContext
 
 
 class HelloServicer(Hello.Servicer):
 
+    def authorizer(self):
+        return allow()
+
     async def Create(
         self,
         context: WriterContext,

hello-constructors/backend/tests/hello_servicer_test.py

@@ -1,6 +1,7 @@
 import unittest
 from hello_constructors.v1.hello_rbt import Hello
 from hello_servicer import HelloServicer
+from reboot.aio.applications import Application
 from reboot.aio.tests import Reboot
 
 
@@ -14,7 +15,7 @@ async def asyncTearDown(self) -> None:
         await self.rbt.stop()
 
     async def test_hello_constructors(self) -> None:
-        await self.rbt.up(servicers=[HelloServicer])
+        await self.rbt.up(Application(servicers=[HelloServicer]))
 
         context = self.rbt.create_external_context(name=f"test-{self.id()}")
 

hello-legacy-grpc/backend/src/deprecated_greeter_servicer.py

@@ -2,10 +2,14 @@
 import random
 from google.protobuf.empty_pb2 import Empty
 from hello_legacy_grpc.v1 import greeter_pb2, greeter_pb2_grpc
+from reboot.aio.auth.authorizers import allow
 
 
 class DeprecatedGreeterServicer(greeter_pb2_grpc.DeprecatedGreeterServicer):
 
+    def authorizer(self):
+        return allow()
+
     async def Greet(
         self,
         request: greeter_pb2.GreetRequest,

hello-legacy-grpc/backend/src/proxy_greeter_servicer.py

@@ -15,7 +15,9 @@ async def Greet(
         # new Reboot service. This proxy servicer will forward traffic to
         # either the RebootGreeter or the DeprecatedGreeter with a 50/50
         # ratio.
-        context = legacy_context.external_context(name=self.Greet.__name__)
+        context = legacy_context.external_context(
+            name="Call into `RebootGreeter`"
+        )
         if random.random() < 0.5:
             # Route to RebootGreeter.
             reboot_greeter = RebootGreeter.ref("my-greeter")

hello-legacy-grpc/backend/src/reboot_greeter_servicer.py

@@ -7,6 +7,7 @@
     GreetResponse,
     RebootGreeter,
 )
+from reboot.aio.auth.authorizers import allow
 from reboot.aio.contexts import (
     Context,
     ReaderContext,
@@ -20,6 +21,9 @@
 
 class RebootGreeterServicer(RebootGreeter.Servicer):
 
+    def authorizer(self):
+        return allow()
+
     async def _get_deprecated_salutation(self, context: Context) -> str:
         """Fetch a salutation from the deprecated Greeter service written in
         legacy gRPC."""

hello-legacy-grpc/backend/tests/greeter_servicer_test.py

@@ -4,6 +4,7 @@
 from hello_legacy_grpc.v1 import greeter_pb2, greeter_pb2_grpc
 from hello_legacy_grpc.v1.greeter_rbt import RebootGreeter
 from proxy_greeter_servicer import ProxyGreeterServicer
+from reboot.aio.applications import Application
 from reboot.aio.tests import Reboot
 from reboot_greeter_servicer import RebootGreeterServicer
 
@@ -19,8 +20,10 @@ async def asyncTearDown(self) -> None:
 
     async def test_reboot_greeter(self) -> None:
         await self.rbt.up(
-            servicers=[RebootGreeterServicer],
-            legacy_grpc_servicers=[DeprecatedGreeterServicer],
+            Application(
+                servicers=[RebootGreeterServicer],
+                legacy_grpc_servicers=[DeprecatedGreeterServicer],
+            ),
         )
 
         context = self.rbt.create_external_context(name=f"test-{self.id()}")
@@ -46,7 +49,9 @@ async def test_reboot_greeter(self) -> None:
         )
 
     async def test_deprecated_greeter(self) -> None:
-        await self.rbt.up(legacy_grpc_servicers=[DeprecatedGreeterServicer])
+        await self.rbt.up(
+            Application(legacy_grpc_servicers=[DeprecatedGreeterServicer])
+        )
 
         context = self.rbt.create_external_context(name=f"test-{self.id()}")
 
@@ -66,10 +71,13 @@ async def test_deprecated_greeter(self) -> None:
     )
     async def test_proxy_greeter(self) -> None:
         await self.rbt.up(
-            servicers=[RebootGreeterServicer],
-            legacy_grpc_servicers=[
-                DeprecatedGreeterServicer, ProxyGreeterServicer
-            ],
+            Application(
+                servicers=[RebootGreeterServicer],
+                legacy_grpc_servicers=[
+                    DeprecatedGreeterServicer,
+                    ProxyGreeterServicer,
+                ],
+            ),
             local_envoy=True,
         )