如何在使用带有surrealdb的websockets时指定命名空间

Question

我用websocket连接到超现实的db的/sql端点。

http文档对NS和DB http头说，但我的WebSocket库似乎不支持这一点。

我只想发送一个使用语句，但它似乎被忽略了。

它返回答复：[{"time":"7.383µs","status":"OK","result":null}]

然后，只要我尝试一个select语句，我就会得到：[{"time":"13.028µs","status":"ERR","detail":"Specify a namespace to use"}]

超现实日志显示了它正在执行的两个语句：

[2022-10-10 00:12:21] INFO  surreal::web 127.0.0.1:46148 GET /sql HTTP/1.1 101 "-" 47.774µs
[2022-10-10 00:12:21] DEBUG surrealdb::dbs Executing: USE NS webapp DB webapp
[2022-10-10 00:12:21] DEBUG surrealdb::dbs Executing: SELECT * FROM user

Answer 1

这个答案帮我搬家。

我必须做以下几点：

1. 定义一个可以登录到DB上的范围
2. 在该范围内创建记录
3. 打开websocket到ws://localhost:8000/rpc (我正在向/ws打开它)
4. 创建一个类似于JSON-RPC的请求

定义范围

DEFINE SCOPE admin SESSION 1d
        SIGNUP ( CREATE user SET user = $user, pass = crypto::argon2::generate($pass) )
        SIGNIN ( SELECT * FROM user WHERE user = $user AND crypto::argon2::compare(pass, $pass));

在该范围内创建用户

create user:matiu SET user = "matiu", pass = crypto::argon2::generate("matiu");

连接websocket

use gloo_net::websocket::{futures::WebSocket, Message};
let ws = WebSocket::open("ws://localhost:8080/rpc").unwrap();

将这个json发送到websocket上。

{"id":"1","method":"signin","params":[{"NS":"webapp","DB":"webapp","SC":"admin","user":"matiu","pass":"matiu"}]}

现在，我遇到了麻烦，我的select查询不返回数据:/我可能需要修改范围、权限或其他东西。一旦我弄清楚了我会在这里更新的。

Answer 2

您可以尝试将“使用NS webapp DB webapp”和"SELECT * FROM user“合并到一行代码中。

Answer 3

首先，请知道SurrealDB是测试版，因此会遇到错误。有一个端点没有反映端点的所有下属，比如websocket，所以我们需要一个接一个地添加OpenLiteSpeed：

let surrealhere = "https://yourwebsite.com"

async function main() {
        let username = 'yourusername';
let password = 'yourpass';
let auth = btoa(`${username}:${password}`);
    try {
        // const doit = async () =>{
        let res = await fetch( `${surrealhere}/key/article` ,{
        method : "get",
        headers: {      
    'Authorization': `Basic ${auth}`,
        'Accept': 'application/json',
        'Content-Type' : 'application/json',
        'NS':'my',
        'DB':'my'
        },
   
    })
    results =await res.json()
    if (results.length > 0) {
        results = results[0].result
    }   
    // results = JSON.stringify(results)
    console.log( "xxxxxxxxxxxxxxxxxxxxx"    , results )
    } catch (e) {
        console.error('ERROR', e);
    }
}

注意，我们需要指定主网站let surrealhere = "https://yourwebsite.com"的每个端点，而不是像let surrealhere = "https://yourwebsite.com/surreal"这样的子页面，这样websocket就不会在打开和关闭不同的子页面方面出现混淆。

​

​

​

​