Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 0bb7f2cd85 | |||
| b61bf52df9 | |||
| f1dd467c95 | |||
| 3136d71032 |
@ -178,6 +178,6 @@ var results = store.query(ctx, "myCollection", {
|
|||||||
limit: 10,
|
limit: 10,
|
||||||
offset: 5,
|
offset: 5,
|
||||||
orderBy: "foo",
|
orderBy: "foo",
|
||||||
orderDirection: store.ASC,
|
orderDirection: store.DIRECTION_ASC,
|
||||||
});
|
});
|
||||||
```
|
```
|
||||||
|
|||||||
@ -4,7 +4,7 @@
|
|||||||
<meta charset="utf-8" />
|
<meta charset="utf-8" />
|
||||||
<title>Client SDK Test suite</title>
|
<title>Client SDK Test suite</title>
|
||||||
<meta name="viewport" content="width=device-width, initial-scale=1.0" />
|
<meta name="viewport" content="width=device-width, initial-scale=1.0" />
|
||||||
<link rel="stylesheet" href="vendor/mocha.css" />
|
<link rel="stylesheet" href="/vendor/mocha.css" />
|
||||||
<style>
|
<style>
|
||||||
body {
|
body {
|
||||||
background-color: white;
|
background-color: white;
|
||||||
@ -13,15 +13,18 @@
|
|||||||
</head>
|
</head>
|
||||||
<body>
|
<body>
|
||||||
<div id="mocha"></div>
|
<div id="mocha"></div>
|
||||||
<script src="vendor/chai.js"></script>
|
<script src="/vendor/chai.js"></script>
|
||||||
<script src="vendor/mocha.js"></script>
|
<script src="/vendor/mocha.js"></script>
|
||||||
<script class="mocha-init">
|
<script class="mocha-init">
|
||||||
mocha.setup('bdd');
|
mocha.setup('bdd');
|
||||||
mocha.checkLeaks();
|
mocha.checkLeaks();
|
||||||
</script>
|
</script>
|
||||||
<script src="/edge/sdk/client.js"></script>
|
<script src="/edge/sdk/client.js"></script>
|
||||||
<script src="test/client-sdk.js"></script>
|
<script src="/test/client-sdk.js"></script>
|
||||||
<script src="test/auth-module.js"></script>
|
<script src="/test/auth-module.js"></script>
|
||||||
|
<script src="/test/net-module.js"></script>
|
||||||
|
<script src="/test/rpc-module.js"></script>
|
||||||
|
<script src="/test/file-module.js"></script>
|
||||||
<script class="mocha-exec">
|
<script class="mocha-exec">
|
||||||
mocha.run();
|
mocha.run();
|
||||||
</script>
|
</script>
|
||||||
|
|||||||
@ -21,128 +21,5 @@ describe('Edge', function() {
|
|||||||
chai.assert.isNull(Edge._conn);
|
chai.assert.isNull(Edge._conn);
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
describe('#send()', function() {
|
|
||||||
this.timeout(5000);
|
|
||||||
|
|
||||||
before(() => {
|
|
||||||
return Edge.connect();
|
|
||||||
});
|
|
||||||
|
|
||||||
after(() => {
|
|
||||||
Edge.disconnect();
|
|
||||||
});
|
|
||||||
|
|
||||||
it('should send a message to the server and echo back', function(done) {
|
|
||||||
const now = new Date();
|
|
||||||
const handler = evt => {
|
|
||||||
chai.assert.equal(evt.detail.now, now.toJSON());
|
|
||||||
Edge.removeEventListener('message', handler);
|
|
||||||
done();
|
|
||||||
}
|
|
||||||
|
|
||||||
// Server should echo back message
|
|
||||||
Edge.addEventListener('message', handler);
|
|
||||||
|
|
||||||
// Send message to server
|
|
||||||
Edge.send({ now });
|
|
||||||
});
|
|
||||||
});
|
|
||||||
|
|
||||||
});
|
});
|
||||||
|
|
||||||
describe('Remote Procedure Call', function() {
|
|
||||||
|
|
||||||
before(() => {
|
|
||||||
return Edge.connect();
|
|
||||||
});
|
|
||||||
|
|
||||||
after(() => {
|
|
||||||
Edge.disconnect();
|
|
||||||
});
|
|
||||||
|
|
||||||
it('should call the remote echo() method and resolve the returned value', function() {
|
|
||||||
const foo = "bar";
|
|
||||||
|
|
||||||
return Edge.rpc('echo', { foo })
|
|
||||||
.then(result => {
|
|
||||||
chai.assert.equal(result.foo, foo);
|
|
||||||
});
|
|
||||||
});
|
|
||||||
|
|
||||||
it('should call the remote throwErrorFromClient() method and reject with an error', function() {
|
|
||||||
return Edge.rpc('throwErrorFromClient')
|
|
||||||
.catch(err => {
|
|
||||||
// Assert that it's an "internal" error
|
|
||||||
// See https://www.jsonrpc.org/specification#error_object
|
|
||||||
chai.assert.equal(err.code, -32603);
|
|
||||||
});
|
|
||||||
});
|
|
||||||
|
|
||||||
it('should call an unregistered method and reject with an error', function() {
|
|
||||||
return Edge.rpc('unregisteredMethod')
|
|
||||||
.catch(err => {
|
|
||||||
// Assert that it's an "method not found" error
|
|
||||||
// See https://www.jsonrpc.org/specification#error_object
|
|
||||||
chai.assert.equal(err.code, -32601);
|
|
||||||
});
|
|
||||||
});
|
|
||||||
|
|
||||||
|
|
||||||
it('should call the add() method repetitively and keep count of the sent values', function() {
|
|
||||||
this.timeout(10000);
|
|
||||||
|
|
||||||
const values = [];
|
|
||||||
for(let i = 0; i <= 1000; i++) {
|
|
||||||
values.push((Math.random() * 1000 | 0));
|
|
||||||
}
|
|
||||||
return Edge.rpc('reset')
|
|
||||||
.then(() => {
|
|
||||||
return Promise.all(values.map(v => Edge.rpc("add", {value: v})));
|
|
||||||
})
|
|
||||||
.then(() => Edge.rpc('total'))
|
|
||||||
.then(remoteTotal => {
|
|
||||||
const localTotal = values.reduce((t, v) => t+v);
|
|
||||||
console.log("Remote total:", remoteTotal, "Local total:", localTotal);
|
|
||||||
chai.assert.equal(remoteTotal, localTotal)
|
|
||||||
})
|
|
||||||
});
|
|
||||||
|
|
||||||
});
|
|
||||||
|
|
||||||
describe('File Module', function() {
|
|
||||||
|
|
||||||
before(() => {
|
|
||||||
return Edge.connect();
|
|
||||||
});
|
|
||||||
|
|
||||||
after(() => {
|
|
||||||
Edge.disconnect();
|
|
||||||
});
|
|
||||||
|
|
||||||
it('should upload then download a blob', function() {
|
|
||||||
const content = JSON.stringify({"date": new Date()});
|
|
||||||
const blob = new Blob([content], {type: "application/json"});
|
|
||||||
|
|
||||||
return Edge.upload(blob)
|
|
||||||
.then(upload => upload.result())
|
|
||||||
.then(result => {
|
|
||||||
|
|
||||||
chai.assert.isNotEmpty(result.blobId);
|
|
||||||
chai.assert.isNotEmpty(result.bucket);
|
|
||||||
|
|
||||||
const blobUrl = Edge.blobUrl(result.bucket, result.blobId);
|
|
||||||
chai.assert.isNotEmpty(blobUrl);
|
|
||||||
|
|
||||||
return fetch(blobUrl)
|
|
||||||
.then(res => res.text())
|
|
||||||
.then(blobContent => {
|
|
||||||
chai.assert.equal(content, blobContent);
|
|
||||||
});
|
|
||||||
})
|
|
||||||
.catch(err => {
|
|
||||||
chai.assert.fail(err);
|
|
||||||
})
|
|
||||||
});
|
|
||||||
|
|
||||||
});
|
|
||||||
|
|||||||
36
misc/client-sdk-testsuite/src/public/test/file-module.js
Normal file
36
misc/client-sdk-testsuite/src/public/test/file-module.js
Normal file
@ -0,0 +1,36 @@
|
|||||||
|
describe('File Module', function () {
|
||||||
|
|
||||||
|
before(() => {
|
||||||
|
return Edge.connect();
|
||||||
|
});
|
||||||
|
|
||||||
|
after(() => {
|
||||||
|
Edge.disconnect();
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should upload then download a blob', function () {
|
||||||
|
const content = JSON.stringify({ "date": new Date() });
|
||||||
|
const blob = new Blob([content], { type: "application/json" });
|
||||||
|
|
||||||
|
return Edge.upload(blob)
|
||||||
|
.then(upload => upload.result())
|
||||||
|
.then(result => {
|
||||||
|
|
||||||
|
chai.assert.isNotEmpty(result.blobId);
|
||||||
|
chai.assert.isNotEmpty(result.bucket);
|
||||||
|
|
||||||
|
const blobUrl = Edge.blobUrl(result.bucket, result.blobId);
|
||||||
|
chai.assert.isNotEmpty(blobUrl);
|
||||||
|
|
||||||
|
return fetch(blobUrl)
|
||||||
|
.then(res => res.text())
|
||||||
|
.then(blobContent => {
|
||||||
|
chai.assert.equal(content, blobContent);
|
||||||
|
});
|
||||||
|
})
|
||||||
|
.catch(err => {
|
||||||
|
chai.assert.fail(err);
|
||||||
|
})
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
49
misc/client-sdk-testsuite/src/public/test/net-module.js
Normal file
49
misc/client-sdk-testsuite/src/public/test/net-module.js
Normal file
@ -0,0 +1,49 @@
|
|||||||
|
describe('Net Module', function () {
|
||||||
|
this.timeout(5000);
|
||||||
|
|
||||||
|
before(() => {
|
||||||
|
return Edge.connect();
|
||||||
|
});
|
||||||
|
|
||||||
|
after(() => {
|
||||||
|
Edge.disconnect();
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should broadcast a message from server', function (done) {
|
||||||
|
const message = { test: 'broadcast', now: Date.now() };
|
||||||
|
|
||||||
|
const handler = (evt) => {
|
||||||
|
const receivedMessage = evt.detail;
|
||||||
|
if (receivedMessage.test !== 'broadcast') return;
|
||||||
|
|
||||||
|
chai.assert.deepEqual(message, evt.detail);
|
||||||
|
|
||||||
|
Edge.removeEventListener('message', handler);
|
||||||
|
done();
|
||||||
|
};
|
||||||
|
|
||||||
|
Edge.addEventListener("message", handler);
|
||||||
|
Edge.send(message);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should send a message to the server and echo back', function(done) {
|
||||||
|
const now = new Date();
|
||||||
|
|
||||||
|
const handler = evt => {
|
||||||
|
const receivedMessage = evt.detail;
|
||||||
|
if (receivedMessage.test !== 'echo') return;
|
||||||
|
|
||||||
|
chai.assert.equal(receivedMessage.now, now.toJSON());
|
||||||
|
|
||||||
|
Edge.removeEventListener('message', handler);
|
||||||
|
done();
|
||||||
|
}
|
||||||
|
|
||||||
|
// Server should echo back message
|
||||||
|
Edge.addEventListener('message', handler);
|
||||||
|
|
||||||
|
// Send message to server
|
||||||
|
Edge.send({ test: 'echo', now });
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
59
misc/client-sdk-testsuite/src/public/test/rpc-module.js
Normal file
59
misc/client-sdk-testsuite/src/public/test/rpc-module.js
Normal file
@ -0,0 +1,59 @@
|
|||||||
|
describe('Remote Procedure Call', function () {
|
||||||
|
|
||||||
|
before(() => {
|
||||||
|
return Edge.connect();
|
||||||
|
});
|
||||||
|
|
||||||
|
after(() => {
|
||||||
|
Edge.disconnect();
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should call the remote echo() method and resolve the returned value', function () {
|
||||||
|
const foo = "bar";
|
||||||
|
|
||||||
|
return Edge.rpc('echo', { foo })
|
||||||
|
.then(result => {
|
||||||
|
console.log(result);
|
||||||
|
chai.assert.equal(result.foo, foo);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should call the remote throwErrorFromClient() method and reject with an error', function () {
|
||||||
|
return Edge.rpc('throwErrorFromClient')
|
||||||
|
.catch(err => {
|
||||||
|
// Assert that it's an "internal" error
|
||||||
|
// See https://www.jsonrpc.org/specification#error_object
|
||||||
|
chai.assert.equal(err.code, -32603);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should call an unregistered method and reject with an error', function () {
|
||||||
|
return Edge.rpc('unregisteredMethod')
|
||||||
|
.catch(err => {
|
||||||
|
// Assert that it's an "method not found" error
|
||||||
|
// See https://www.jsonrpc.org/specification#error_object
|
||||||
|
chai.assert.equal(err.code, -32601);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
|
||||||
|
it('should call the add() method repetitively and keep count of the sent values', function () {
|
||||||
|
this.timeout(10000);
|
||||||
|
|
||||||
|
const values = [];
|
||||||
|
for (let i = 0; i <= 1000; i++) {
|
||||||
|
values.push((Math.random() * 1000 | 0));
|
||||||
|
}
|
||||||
|
return Edge.rpc('reset')
|
||||||
|
.then(() => {
|
||||||
|
return Promise.all(values.map(v => Edge.rpc("add", { value: v })));
|
||||||
|
})
|
||||||
|
.then(() => Edge.rpc('total'))
|
||||||
|
.then(remoteTotal => {
|
||||||
|
const localTotal = values.reduce((t, v) => t + v);
|
||||||
|
console.log("Remote total:", remoteTotal, "Local total:", localTotal);
|
||||||
|
chai.assert.equal(remoteTotal, localTotal)
|
||||||
|
})
|
||||||
|
});
|
||||||
|
|
||||||
|
});
|
||||||
@ -14,9 +14,16 @@ function onInit() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Called for each client message
|
// Called for each client message
|
||||||
function onClientMessage(ctx, data) {
|
function onClientMessage(ctx, message) {
|
||||||
console.log("onClientMessage", data.now);
|
console.log("onClientMessage", message);
|
||||||
net.send(ctx, { now: data.now });
|
|
||||||
|
switch (message.test) {
|
||||||
|
case "broadcast":
|
||||||
|
net.broadcast(message);
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
net.send(ctx, message);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Called for each blob upload request
|
// Called for each blob upload request
|
||||||
|
|||||||
@ -1,6 +1,6 @@
|
|||||||
**/*.go
|
**/*.go
|
||||||
pkg/app/sdk/client/src/**/*.js
|
pkg/sdk/client/src/**/*.js
|
||||||
pkg/app/sdk/client/src/**/*.ts
|
pkg/sdk/client/src/**/*.ts
|
||||||
misc/client-sdk-testsuite/src/**/*
|
misc/client-sdk-testsuite/src/**/*
|
||||||
modd.conf
|
modd.conf
|
||||||
{
|
{
|
||||||
|
|||||||
@ -99,3 +99,5 @@ func (f *File) Readdir(count int) ([]os.FileInfo, error) {
|
|||||||
func (f *File) Stat() (os.FileInfo, error) {
|
func (f *File) Stat() (os.FileInfo, error) {
|
||||||
return f.fi, nil
|
return f.fi, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
var _ http.FileSystem = &FileSystem{}
|
||||||
|
|||||||
@ -59,7 +59,7 @@ func (h *Handler) Load(bdle bundle.Bundle) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
fs := bundle.NewFileSystem("public", bdle)
|
fs := bundle.NewFileSystem("public", bdle)
|
||||||
public := http.FileServer(fs)
|
public := HTML5Fileserver(fs)
|
||||||
sockjs := sockjs.NewHandler(sockJSPathPrefix, h.sockjsOpts, h.handleSockJSSession)
|
sockjs := sockjs.NewHandler(sockJSPathPrefix, h.sockjsOpts, h.handleSockJSSession)
|
||||||
|
|
||||||
if h.server != nil {
|
if h.server != nil {
|
||||||
|
|||||||
54
pkg/http/html5_fileserver.go
Normal file
54
pkg/http/html5_fileserver.go
Normal file
@ -0,0 +1,54 @@
|
|||||||
|
package http
|
||||||
|
|
||||||
|
import (
|
||||||
|
"net/http"
|
||||||
|
"os"
|
||||||
|
"path"
|
||||||
|
"strings"
|
||||||
|
|
||||||
|
"github.com/pkg/errors"
|
||||||
|
"gitlab.com/wpetit/goweb/logger"
|
||||||
|
)
|
||||||
|
|
||||||
|
func HTML5Fileserver(fs http.FileSystem) http.Handler {
|
||||||
|
handler := http.FileServer(fs)
|
||||||
|
|
||||||
|
fn := func(w http.ResponseWriter, r *http.Request) {
|
||||||
|
urlPath := r.URL.Path
|
||||||
|
if !strings.HasPrefix(urlPath, "/") {
|
||||||
|
urlPath = "/" + urlPath
|
||||||
|
r.URL.Path = urlPath
|
||||||
|
}
|
||||||
|
urlPath = path.Clean(urlPath)
|
||||||
|
|
||||||
|
file, err := fs.Open(urlPath)
|
||||||
|
if err != nil {
|
||||||
|
if errors.Is(err, os.ErrNotExist) {
|
||||||
|
r.URL.Path = "/"
|
||||||
|
|
||||||
|
handler.ServeHTTP(w, r)
|
||||||
|
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
logger.Error(r.Context(), "could not open bundle file", logger.E(err))
|
||||||
|
|
||||||
|
http.Error(w, http.StatusText(http.StatusInternalServerError), http.StatusInternalServerError)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
defer func() {
|
||||||
|
if err := file.Close(); err != nil {
|
||||||
|
logger.Error(r.Context(), "could not close file", logger.E(err))
|
||||||
|
|
||||||
|
http.Error(w, http.StatusText(http.StatusInternalServerError), http.StatusInternalServerError)
|
||||||
|
|
||||||
|
return
|
||||||
|
}
|
||||||
|
}()
|
||||||
|
|
||||||
|
handler.ServeHTTP(w, r)
|
||||||
|
}
|
||||||
|
|
||||||
|
return http.HandlerFunc(fn)
|
||||||
|
}
|
||||||
@ -38,9 +38,10 @@ func (m *Module) broadcast(call goja.FunctionCall, rt *goja.Runtime) goja.Value
|
|||||||
}
|
}
|
||||||
|
|
||||||
data := call.Argument(0).Export()
|
data := call.Argument(0).Export()
|
||||||
|
ctx := context.Background()
|
||||||
|
|
||||||
msg := module.NewServerMessage(nil, data)
|
msg := module.NewServerMessage(ctx, data)
|
||||||
if err := m.bus.Publish(context.Background(), msg); err != nil {
|
if err := m.bus.Publish(ctx, msg); err != nil {
|
||||||
panic(rt.ToValue(errors.WithStack(err)))
|
panic(rt.ToValue(errors.WithStack(err)))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -93,6 +93,7 @@ export class Client extends EventTarget {
|
|||||||
const { jsonrpc, id, error, result } = evt.detail;
|
const { jsonrpc, id, error, result } = evt.detail;
|
||||||
|
|
||||||
if (jsonrpc !== '2.0' || id === undefined) return;
|
if (jsonrpc !== '2.0' || id === undefined) return;
|
||||||
|
if (!evt.detail.hasOwnProperty("error") && !evt.detail.hasOwnProperty("result")) return;
|
||||||
|
|
||||||
// Prevent additional handlers to catch this event
|
// Prevent additional handlers to catch this event
|
||||||
evt.stopImmediatePropagation();
|
evt.stopImmediatePropagation();
|
||||||
|
|||||||
Reference in New Issue
Block a user