run nats server with jetstream

.github/workflows/main.yml

@@ -24,20 +24,19 @@ jobs:
 
   test:
     runs-on: ubuntu-latest
+    services:
+      nats:
+        image: nats
+        options: "--jetstream"
     steps:
       - uses: actions/checkout@v3
       - uses: actions/setup-python@v4
         with:
           python-version: "3.8"
       - uses: arduino/setup-task@v1
-      - uses: onichandame/nats-action@master
-        with:
-          port: "4222"
-      - uses: onichandame/nats-client-action@master
-        with:
-          servers: "nats://localhost:4222"
-          cluster: "false"
       - run: task test
+        env:
+          NATS_SERVER: nats://nats:4222
 
   markdownlint-cli:
     runs-on: ubuntu-latest

.markdownlint.yaml

@@ -5,4 +5,4 @@ MD007:          # unordered list indentation
 MD013: false    # do not validate line length
 MD014: false    # allow $ before command output
 MD029:          # ordered list prefix
-  style: "ordered"
+  style: "one"

walnats/_actors/_registry.py

@@ -5,16 +5,14 @@
 
 import nats
 
+from .._constants import DEFAULT_SERVER
 from ._connection import ConnectedActors
 
 
 if TYPE_CHECKING:
     from ._actor import Actor
 
 
-DEFAULT_SERVER = 'nats://localhost:4222'
-
-
 class Actors:
     """Registry of :class:`walnats.Actor` instances.
 

walnats/_constants.py

@@ -1,3 +1,4 @@
+import os
 from typing import Final
 
 import nats.js
@@ -15,3 +16,5 @@
 # Header for the timestamp until which the message has been delayed
 # (in UTC, in seconds, as float).
 HEADER_DELAY = 'Walnats-Delay'
+
+DEFAULT_SERVER = os.environ.get('NATS_SERVER', 'nats://localhost:4222')

walnats/_events/_registry.py

@@ -5,16 +5,14 @@
 
 import nats
 
+from .._constants import DEFAULT_SERVER
 from ._connection import ConnectedEvents
 
 
 if TYPE_CHECKING:
     from ._event import BaseEvent
 
 
-DEFAULT_SERVER = 'nats://localhost:4222'
-
-
 class Events:
     """Registry of :class:`walnats.Event` instances.