CBOR implementation and Native RPC (#116)

Author: remade

.cargo/config

@@ -27,17 +27,6 @@ jobs:
 
       - id: ruff
         if: always()
-<<<<<<< HEAD
-        run: poetry run ruff --format=github python_package/surrealdb/
-
-      - id: Black
-        if: always()
-        run: poetry run black python_package/surrealdb/ --check --verbose --diff --color
-
-      - id: mypy
-        if: always()
-        run: poetry run mypy python_package/surrealdb/
-=======
         run: poetry run ruff check surrealdb/
 
       - id: Black
@@ -47,4 +36,3 @@ jobs:
       - id: mypy
         if: always()
         run: poetry run mypy surrealdb/
->>>>>>> 89bdd361d0a92f69deff137958279ab21161f00c

.github/workflows/stability.yml

@@ -31,17 +31,3 @@ jobs:
       - name: Run Tests
         run: sh scripts/run_tests.sh
 
-  run-rust-unit-tests:
-    needs: run-unit-tests
-    runs-on: ubuntu-latest
-    steps:
-      - name: Checkout code
-        uses: actions/checkout@v2
-  
-      - name: Set up Rust
-        uses: actions-rs/toolchain@v1
-        with:
-          toolchain: stable
-  
-      - name: Build and Run Unit Tests
-        run: cargo test

.github/workflows/unit_tests.yml

@@ -10,6 +10,16 @@ services:
     ports:
       - 8000:8000
 
+  surrealdb_200:
+    image: surrealdb/surrealdb:v2.0.0
+    command: "start"
+    environment:
+      - SURREAL_USER=root
+      - SURREAL_PASS=root
+      - SURREAL_LOG=trace
+    ports:
+      - 8200:8000
+
   surrealdb_121:
     image: surrealdb/surrealdb:v1.2.1
     command: "start"

Cargo.toml

@@ -1,62 +1,59 @@
 from surrealdb import AsyncSurrealDB
 
+
 async def main():
     """Example of how to use the SurrealDB client."""
-    db = AsyncSurrealDB("ws://localhost:8000/database/namespace")
-
-    await db.connect()
-
-    await db.signin({
-        "username": "root",
-        "password": "root",
-    })
-    
-    print("Using methods")
-    print("create: " ,await db.create(
-        "person",
-        {
-            "user": "me",
-            "pass": "safe",
-            "marketing": True,
-            "tags": ["python", "documentation"],
-        },
-    ))
-    print("read: ", await db.select("person"))
-    print("update: ", await db.update("person", {
-        "user":"you",
-        "pass":"very_safe",
-        "marketing": False,
-        "tags": ["Awesome"]
-    }))
-    print("delete: ", await db.delete("person"))
-    
-    # You can also use the query method 
-    # doing all of the above and more in SurrealQl
-    
-    # In SurrealQL you can do a direct insert 
-    # and the table will be created if it doesn't exist
-    print("Using justawait db.query")
-    print("create: ", await db.query("""
-    insert into person {
-        user: 'me',
-        pass: 'very_safe',
-        tags: ['python', 'documentation']
-    };
-    
-    """))
-    print("read: ", await db.query("select * from person"))
-    
-    print("update: ", await db.query("""
-    update person content {
-        user: 'you',
-        pass: 'more_safe',
-        tags: ['awesome']
-    };
-    
-    """))
-    print( "delete: ", await db.query("delete person"))
+    async with AsyncSurrealDB("ws://localhost:8000") as db:
+        await db.use("test", "test")
+        await db.sign_in("root", "root")
+
+        print("Using methods")
+        print("create: ", await db.create(
+            "person",
+            {
+                "user": "me",
+                "pass": "safe",
+                "marketing": True,
+                "tags": ["python", "documentation"],
+            },
+        ))
+        print("read: ", await db.select("person"))
+        print("update: ", await db.update("person", {
+            "user": "you",
+            "pass": "very_safe",
+            "marketing": False,
+            "tags": ["Awesome"]
+        }))
+        print("delete: ", await db.delete("person"))
+
+        # You can also use the query method
+        # doing all of the above and more in SurrealQl
+
+        # In SurrealQL you can do a direct insert
+        # and the table will be created if it doesn't exist
+        print("Using justawait db.query")
+        print("create: ", await db.query("""
+        insert into person {
+            user: 'me',
+            pass: 'very_safe',
+            tags: ['python', 'documentation']
+        };
+
+        """))
+        print("read: ", await db.query("select * from person"))
+
+        print("update: ", await db.query("""
+        update person content {
+            user: 'you',
+            pass: 'more_safe',
+            tags: ['awesome']
+        };
+
+        """))
+        print("delete: ", await db.query("delete person"))
+
 
 if __name__ == "__main__":
     import asyncio
 
-    asyncio.run(main())
+    asyncio.run(main())

docker-compose.yml

@@ -1,53 +1,50 @@
 from surrealdb import SurrealDB
 
-db = SurrealDB("ws://localhost:8000/database/namespace")
-
-db.signin({
-    "username": "root",
-    "password": "root",
-})
-
-print("Using methods")
-print("create: ", db.create(
-    "person",
-    {
-        "user": "me",
-        "pass": "safe",
-        "marketing": True,
-        "tags": ["python", "documentation"],
-    },
-))
-print("read: ", db.select("person"))
-print("update: ", db.update("person", {
-    "user":"you",
-    "pass":"very_safe",
-    "marketing": False,
-    "tags": ["Awesome"]
-}))
-print("delete: ", db.delete("person"))
-
-# You can also use the query method 
-# doing all of the above and more in SurrealQl
-
-# In SurrealQL you can do a direct insert 
-# and the table will be created if it doesn't exist
-print("Using just db.query")
-print("create: ", db.query("""
-insert into person {
-    user: 'me',
-    pass: 'very_safe',
-    tags: ['python', 'documentation']
-};
-
-"""))
-print("read: ", db.query("select * from person"))
-
-print("update: ", db.query("""
-update person content {
-    user: 'you',
-    pass: 'more_safe',
-    tags: ['awesome']
-};
-
-"""))
-print( "delete: ", db.query("delete person"))
+with SurrealDB("ws://localhost:8000") as db:
+    db.use("test", "test")
+    token = db.sign_in("root", "root")
+
+    print("Using methods")
+    print("create: ", db.create(
+        "person",
+        {
+            "user": "me",
+            "pass": "safe",
+            "marketing": True,
+            "tags": ["python", "documentation"],
+        },
+    ))
+    print("read: ", db.select("person"))
+    print("update: ", db.update("person", {
+        "user": "you",
+        "pass": "very_safe",
+        "marketing": False,
+        "tags": ["Awesome"]
+    }))
+    print("delete: ", db.delete("person"))
+
+    # You can also use the query method
+    # doing all of the above and more in SurrealQl
+
+    # In SurrealQL you can do a direct insert
+    # and the table will be created if it doesn't exist
+    print("Using just db.query")
+    print("create: ", db.query("""
+    insert into person {
+        user: 'me',
+        pass: 'very_safe',
+        tags: ['python', 'documentation']
+    };
+
+    """))
+    print("read: ", db.query("select * from person"))
+
+    print("update: ", db.query("""
+    update person content {
+        user: 'you',
+        pass: 'more_safe',
+        tags: ['awesome']
+    };
+
+    """))
+    print("delete: ", db.query("delete person"))

examples/basic_async_example.py

@@ -16,14 +16,13 @@
    "source": [
     "from surrealdb import AsyncSurrealDB\n",
     "\n",
-    "db = AsyncSurrealDB(\"ws://localhost:8000/database/namespace\")\n",
+    "db = AsyncSurrealDB(\"ws://localhost:8000\")\n",
     "\n",
     "await db.connect()\n",
     "\n",
-    "await db.signin({\n",
-    "    \"username\": \"root\",\n",
-    "    \"password\": \"root\",\n",
-    "})"
+    "await db.use(\"test\", \"test\")\n",
+    "\n",
+    "await db.sign_in(\"root\", \"root\")"
    ]
   },
   {

examples/basic_example.py

@@ -1,2 +1,9 @@
+[tool.poetry]
+name = "surrealdb"
+version = "0.1.0"
+description = ""
+authors = ["Maxwell Flitton <>", "Remi A <mail4remi@yahoo.com>"]
+readme = "README.md"
+
 [build-system]
 requires = ["setuptools", "wheel", "setuptools-rust"]