-
+Build WAMR Core and run WASM applications
+================================================
-Build WAMR Core
-=========================
-Please follow the instructions below to build the WAMR core on different platforms.
+WAMR VM core (iwasm) can support building on different platforms:
+- Linux
+- Zephyr
+- Mac
+- VxWorks
+- AliOS-Things
+- Docker
+- Intel Software Guard Extention (SGX)
-Linux
--------------------------
-First of all please install library dependencies of lib gcc.
-Use installation commands below for Ubuntu Linux:
-``` Bash
-sudo apt install lib32gcc-5-dev g++-multilib
-```
-Or in Fedora:
-``` Bash
-sudo dnf install glibc-devel.i686
-```
+After building the iwasm, we can compile some basic WASM applications and run it from the WAMR core. As the WAMR core doesn't include the extended application library, your WASM applications can only use the [WAMR built-in APIs](./doc/wamr_api.md).
-After installing dependencies, build the source code:
-``` Bash
-cd core/iwasm/products/linux/
-mkdir build
-cd build
-cmake ..
-make
-```
-VxWorks
--------------------------
-VxWorks 7 SR0620 release is validated.
+See the [doc/building.md](./doc/building.md) for the detailed instructions.
-First you need to build a VSB. Make sure *UTILS_UNIX* layer is added in the VSB.
-After the VSB is built, export the VxWorks toolchain path by:
-```
-export
+
+ ×
+ HOT Applications
+
+
+
+
+
+
+ 
+
+ Product Name:
+Current Version:
+ +
-
-
-A typical WAMR API usage is shown below (some return value checks are ignored):
-``` C
- static char global_heap_buf[512 * 1024];
-
- char *buffer;
- wasm_module_t module;
- wasm_module_inst_t inst;
- wasm_function_inst_t func;
- wasm_exec_env_t env;
- uint32 argv[2];
-
- bh_memory_init_with_pool(global_heap_buf, sizeof(global_heap_buf));
- wasm_runtime_init();
-
- buffer = read_wasm_binary_to_buffer(…);
- module = wasm_runtime_load(buffer, size, err, err_size);
- inst = wasm_runtime_instantiate(module, 0, 0, err, err_size);
- func = wasm_runtime_lookup_function(inst, "fib", "(i32)i32");
- env = wasm_runtime_create_exec_env(stack_size);
-
- argv[0] = 8;
- if (!wasm_runtime_call_wasm(inst, env, func, 1, argv_buf) ) {
- wasm_runtime_clear_exception(inst);
- }
- /* the return value is stored in argv[0] */
- printf("fib function return: %d\n", argv[0]);
-
- wasm_runtime_destory_exec_env(env);
- wasm_runtime_deinstantiate(inst);
- wasm_runtime_unload(module);
- wasm_runtime_destroy();
- bh_memory_destroy();
-```
-
-
-WASM application library
-========================
-In general, there are 3 classes of API's important for the WASM application:
-- Built-in API's: WAMR provides a minimal API set for developers.
-- 3rd party API's: Programmer can download and include any 3rd party C source code and add it into their own WASM app source tree.
-- Platform native API's: WAMR provides a mechanism to export a native API to the WASM application.
-
-
-Built-in application library
----------------
-Built-in API's include Libc API's, Base library and Extension library reference.
-
-**Libc API's**-This is a minimal set of Libc API's for memory allocation, string manipulation and printing. The header file is located at ```lib/app-libs/libc/lib_base.h```. The current supported API set is listed here: -``` C -void *malloc(size_t size); -void *calloc(size_t n, size_t size); -void free(void *ptr); -int memcmp(const void *s1, const void *s2, size_t n); -void *memcpy(void *dest, const void *src, size_t n); -void *memmove(void *dest, const void *src, size_t n); -void *memset(void *s, int c, size_t n); -int putchar(int c); -int snprintf(char *str, size_t size, const char *format, ...); -int sprintf(char *str, const char *format, ...); -char *strchr(const char *s, int c); -int strcmp(const char *s1, const char *s2); -char *strcpy(char *dest, const char *src); -size_t strlen(const char *s); -int strncmp(const char * str1, const char * str2, size_t n); -char *strncpy(char *dest, const char *src, unsigned long n); -``` - -**Base library**
-Basic support for communication, timers, etc is available. You can refer to the header file ```lib/app-libs/base/wasm_app.h``` which contains the definitions for request and response API's, event pub/sub API's and timer API's. Please note that these API's require the native implementations. -The API set is listed below: -``` C -typedef void(*request_handler_f)(request_t *) ; -typedef void(*response_handler_f)(response_t *, void *) ; - -// Request API's -bool api_register_resource_handler(const char *url, request_handler_f); -void api_send_request(request_t * request, response_handler_f response_handler, void * user_data); -void api_response_send(response_t *response); - -// Event API's -bool api_publish_event(const char *url, int fmt, void *payload, int payload_len); -bool api_subscribe_event(const char * url, request_handler_f handler); - -struct user_timer; -typedef struct user_timer * user_timer_t; - -// Timer API's -user_timer_t api_timer_create(int interval, bool is_period, bool auto_start, void(*on_user_timer_update)(user_timer_t -)); -void api_timer_cancel(user_timer_t timer); -void api_timer_restart(user_timer_t timer, int interval); -``` - -**Library extension reference**
-Currently we provide several kinds of extension library for reference including sensor, connection and GUI. - -Sensor API: In the header file ```lib/app-libs/extension/sensor/sensor.h```, the API set is defined as below: -``` C -sensor_t sensor_open(const char* name, int index, - void(*on_sensor_event)(sensor_t, attr_container_t *, void *), - void *user_data); -bool sensor_config(sensor_t sensor, int interval, int bit_cfg, int delay); -bool sensor_config_with_attr_container(sensor_t sensor, attr_container_t *cfg); -bool sensor_close(sensor_t sensor); -``` -Connection API: In the header file `lib/app-libs/extension/connection/connection.h.`, the API set is defined as below: -``` C -/* Connection event type */ -typedef enum { - /* Data is received */ - CONN_EVENT_TYPE_DATA = 1, - /* Connection is disconnected */ - CONN_EVENT_TYPE_DISCONNECT -} conn_event_type_t; - -typedef void (*on_connection_event_f)(connection_t *conn, - conn_event_type_t type, - const char *data, - uint32 len, - void *user_data); -connection_t *api_open_connection(const char *name, - attr_container_t *args, - on_connection_event_f on_event, - void *user_data); -void api_close_connection(connection_t *conn); -int api_send_on_connection(connection_t *conn, const char *data, uint32 len); -bool api_config_connection(connection_t *conn, attr_container_t *cfg); -``` -GUI API: The API's is list in header file ```lib/app-libs/extension/gui/wgl.h``` which is implemented based open soure 2D graphic library [LittlevGL](https://docs.littlevgl.com/en/html/index.html). Currently supported widgets include button, label, list and check box and more wigdet would be provided in future. - - -The mechanism of exporting native API to WASM application -======================================================= - -The basic working flow for WASM application calling into the native API is shown in the following diagram: - -
-
-
-WAMR provides the macro `EXPORT_WASM_API` to enable users to export a native API to a WASM application. WAMR has implemented a base API for the timer and messaging by using `EXPORT_WASM_API`. This can be a point of reference for extending your own library.
-``` C
-static NativeSymbol extended_native_symbol_defs[] = {
- EXPORT_WASM_API(wasm_register_resource),
- EXPORT_WASM_API(wasm_response_send),
- EXPORT_WASM_API(wasm_post_request),
- EXPORT_WASM_API(wasm_sub_event),
- EXPORT_WASM_API(wasm_create_timer),
- EXPORT_WASM_API(wasm_timer_set_interval),
- EXPORT_WASM_API(wasm_timer_cancel),
- EXPORT_WASM_API(wasm_timer_restart)
-};
-```
-
- **Security attention:** A WebAssembly application should only have access to its own memory space. As a result, the integrator should carefully design the native function to ensure that the memory accesses are safe. The native API to be exported to the WASM application must:
-- Only use 32 bits number for parameters
-- Should not pass data to the structure pointer (do data serialization instead)
-- Should do the pointer address conversion in the native API
-- Should not pass function pointer as callback
-
-Below is a sample of a library extension. All code invoked across WASM and native world must be serialized and de-serialized, and the native world must do a boundary check for every incoming address from the WASM world.
-
-
-
-Steps for exporting native API
-==========================
-
-WAMR implemented a framework for developers to export API's. Below is the procedure to expose the platform API's in three steps:
-
-**Step 1. Create a header file**-Declare the API's for your WASM application source project to include. - -**Step 2. Create a source file**
-Export the platform API's, for example in ``` products/linux/ext_lib_export.c ``` -``` C -#include "lib_export.h" - -static NativeSymbol extended_native_symbol_defs[] = -{ -}; - -#include "ext_lib_export.h" -``` - -**Step 3. Register new API's**
-Use the macro `EXPORT_WASM_API` and `EXPORT_WASM_API2` to add exported API's into the array of ```extended_native_symbol_defs```. -The pre-defined MACRO `EXPORT_WASM_API` should be used to declare a function export: -``` c -#define EXPORT_WASM_API(symbol) {#symbol, symbol} -``` - -Below code example shows how to extend the library to support `customized()`: - -``` -//lib_export_impl.c -void customized() -{ - // your code -} - - -// lib_export_dec.h -#ifndef _LIB_EXPORT_DEC_H_ -#define _LIB_EXPORT_DEC_H_ -#ifdef __cplusplus -extern "C" { -#endif - -void customized(); - -#ifdef __cplusplus -} -#endif -#endif - - -// ext_lib_export.c -#include "lib_export.h" -#include "lib_export_dec.h" - -static NativeSymbol extended_native_symbol_defs[] = -{ - EXPORT_WASM_API(customized) -}; - -#include "ext_lib_export.h" -``` - -Use extended library ------------------------- -In the application source project, it will include the WAMR built-in API's header file and platform extension header files. Assuming the board vendor extends the library which added an API called customized(), the WASM application would be like this: -``` C -#include
-
-Below is the reference implementation of the server application. It provides room temperature measurement service.
-
-``` C
-void on_init()
-{
- api_register_resource_handler("/room_temp", room_temp_handler);
-}
-
-void on_destroy()
-{
-}
-
-void room_temp_handler(request_t *request)
-{
- response_t response[1];
- attr_container_t *payload;
- payload = attr_container_create("room_temp payload");
- if (payload == NULL)
- return;
-
- attr_container_set_string(&payload, "temp unit", "centigrade");
- attr_container_set_int(&payload, "value", 26);
-
- make_response_for_request(request, response);
- set_response(response,
- CONTENT_2_05,
- FMT_ATTR_CONTAINER,
- payload,
- attr_container_get_serialize_length(payload));
-
- api_response_send(response);
- attr_container_destroy(payload);
-}
-```
-
-
-Pub/sub model
--------------------------
-One WASM application acts as the event publisher. It publishes events to notify WASM applications or host/cloud applications which subscribe to the events.
-
-
-
-Below is the reference implementation of the pub application. It utilizes a timer to repeatedly publish an overheat alert event to the subscriber applications. Then the subscriber applications receive the events immediately.
-
-``` C
-/* Timer callback */
-void timer_update(user_timer_t timer
-{
- attr_container_t *event;
-
- event = attr_container_create("event");
- attr_container_set_string(&event,
- "warning",
- "temperature is over high");
-
- api_publish_event("alert/overheat",
- FMT_ATTR_CONTAINER,
- event,
- attr_container_get_serialize_length(event));
-
- attr_container_destroy(event);
-}
-
-void on_init()
-{
- user_timer_t timer;
- timer = api_timer_create(1000, true, true, timer_update);
-}
-
-void on_destroy()
-{
-}
-```
-
-Below is the reference implementation of the sub application.
-``` C
-void overheat_handler(request_t *event)
-{
- printf("Event: %s\n", event->url);
-
- if (event->payload != NULL && event->fmt == FMT_ATTR_CONTAINER)
- attr_container_dump((attr_container_t *) event->payload);
-}
-
-void on_init(
-{
- api_subscribe_event ("alert/overheat", overheat_handler);
-}
-
-void on_destroy()
-{
-}
-```
-**Note:** You can also subscribe this event from host side by using host tool. Please refer `samples/simple` project for deail usage.
Samples and demos
-=========================
-The simple sample
---------
-Please refer to the ```samples/simple``` folder for samples of WASM application life cyle management and programming models.
+=================
-2D graphic user interface with LittlevGL
-------------------------------------------------
-We have 2 samples for 2D graphic user interface.
-
-One of them demonstrates that a graphic user interface application in WebAssembly integrates the LittlevGL, an open-source embedded 2d graphic library. The sample source code is under ```samples/littlevgl```
-
-In this sample, the LittlevGL source code is built into the WebAssembly code with the user application source files. The platform interfaces defined by LittlevGL is implemented in the runtime and exported to the application through the declarations from source "ext_lib_export.c" as below:
-
- EXPORT_WASM_API(display_init),
- EXPORT_WASM_API(display_input_read),
- EXPORT_WASM_API(display_flush),
- EXPORT_WASM_API(display_fill),
- EXPORT_WASM_API(display_vdb_write),
- EXPORT_WASM_API(display_map),
- EXPORT_WASM_API(time_get_ms), };
-
-The runtime component supports building target for Linux and AliOS-Things, Zephyr/STM Nucleo board respectively. The beauty of this sample is the WebAssembly application can have identical display and behavior when running from both runtime environments. That implies we can do the majority of application validation from the desktop environment then load it to the target device as long as two runtime distributions support the same set of the application interface.
+The WAMR samples are located in folder [./samples](./samples). A sample usually contains the WAMR runtime build, WASM applications and test tools. The WARM provides following samples:
+- [Simple](./samples/simple/README.md): The runtime is integrated with most of the WAMR APP libaries and multiple WASM applications are provided for using different WASM API set.
+- [littlevgl](./samples/littlevgl/README.md): Demostrating the graphic user interface application usage on WAMR. The whole [LittlevGL](https://github.com/littlevgl/) 2D user graphic library and the UI application is built into WASM application.
+- [gui](./samples/gui/README.md): Moved the [LittlevGL](https://github.com/littlevgl/) library into the runtime and defined a WASM application interface by wrapping the littlevgl API.
+- [IoT-APP-Store-Demo](./test-tools/IoT-APP-Store-Demo/README.md): A web site for demostrating a WASM APP store usage where we can remotely install and uninstall WASM application on remote devices.
-Below pictures show the WASM application is running on an STM board with an LCD touch panel. When users click the blue button, the WASM application increases the counter, and the latest counter value is displayed on the top banner of the touch panel.
+The graphic user interface demo photo:
-
-
+
+
+
+
+
+Releases and acknowledgments
+============================
+
+WAMR is a community efforts. Since Intel Corp contributed the first release of this open source project, this project has received many good contributions from the community.
+
+See the [major features releasing history and contributor names](./doc/release_ack.md)
+
+
+Roadmap
+=======
+
+See the [roadmap](./doc/roadmap.md) to understand what major features are planed or under development.
+
+Please submit issues for any new feature request, or your plan for contributing new features.
-The sample also provides the native Linux version of application without the runtime under folder "vgl-native-ui-app". It can help to check differences between the implementations in native and WebAssembly.
-
-The other sample demonstrates that a graphic user interface application in WebAssembly programming with WAMR graphic library(WGL), which is implemented based on LittlevGL, an open-source embedded 2d graphic library. The sample source code is under ```samples/gui```
-Unlike `sample/littlevgl/val-wasm-runtime`, in this sample, the LittlevGL source code is built into the WAMR runtime and exported to Webassembly applicaton but not directly built into Webassembly application. And WGL provides a group of WebAssembly wrapper API's for user to write graphic application. These API's are listed in: `+This is a minimal set of Libc API's for memory allocation, string manipulation and printing. The header file is located at ```lib/app-libs/libc/lib_base.h```. The current supported API set is listed here: +``` C +void *malloc(size_t size); +void *calloc(size_t n, size_t size); +void free(void *ptr); +int memcmp(const void *s1, const void *s2, size_t n); +void *memcpy(void *dest, const void *src, size_t n); +void *memmove(void *dest, const void *src, size_t n); +void *memset(void *s, int c, size_t n); +int putchar(int c); +int snprintf(char *str, size_t size, const char *format, ...); +int sprintf(char *str, const char *format, ...); +char *strchr(const char *s, int c); +int strcmp(const char *s1, const char *s2); +char *strcpy(char *dest, const char *src); +size_t strlen(const char *s); +int strncmp(const char * str1, const char * str2, size_t n); +char *strncpy(char *dest, const char *src, unsigned long n); +``` + +**Base library**
+Basic support for communication, timers, etc is available. You can refer to the header file ```lib/app-libs/base/wasm_app.h``` which contains the definitions for request and response API's, event pub/sub API's and timer API's. Please note that these API's require the native implementations. +The API set is listed below: +``` C +typedef void(*request_handler_f)(request_t *) ; +typedef void(*response_handler_f)(response_t *, void *) ; + +// Request API's +bool api_register_resource_handler(const char *url, request_handler_f); +void api_send_request(request_t * request, response_handler_f response_handler, void * user_data); +void api_response_send(response_t *response); + +// Event API's +bool api_publish_event(const char *url, int fmt, void *payload, int payload_len); +bool api_subscribe_event(const char * url, request_handler_f handler); + +struct user_timer; +typedef struct user_timer * user_timer_t; + +// Timer API's +user_timer_t api_timer_create(int interval, bool is_period, bool auto_start, void(*on_user_timer_update)(user_timer_t +)); +void api_timer_cancel(user_timer_t timer); +void api_timer_restart(user_timer_t timer, int interval); +``` + +**Library extension reference**
+Currently we provide several kinds of extension library for reference including sensor, connection and GUI. + +Sensor API: In the header file ```lib/app-libs/extension/sensor/sensor.h```, the API set is defined as below: +``` C +sensor_t sensor_open(const char* name, int index, + void(*on_sensor_event)(sensor_t, attr_container_t *, void *), + void *user_data); +bool sensor_config(sensor_t sensor, int interval, int bit_cfg, int delay); +bool sensor_config_with_attr_container(sensor_t sensor, attr_container_t *cfg); +bool sensor_close(sensor_t sensor); +``` +Connection API: In the header file `lib/app-libs/extension/connection/connection.h.`, the API set is defined as below: +``` C +/* Connection event type */ +typedef enum { + /* Data is received */ + CONN_EVENT_TYPE_DATA = 1, + /* Connection is disconnected */ + CONN_EVENT_TYPE_DISCONNECT +} conn_event_type_t; + +typedef void (*on_connection_event_f)(connection_t *conn, + conn_event_type_t type, + const char *data, + uint32 len, + void *user_data); +connection_t *api_open_connection(const char *name, + attr_container_t *args, + on_connection_event_f on_event, + void *user_data); +void api_close_connection(connection_t *conn); +int api_send_on_connection(connection_t *conn, const char *data, uint32 len); +bool api_config_connection(connection_t *conn, attr_container_t *cfg); +``` +GUI API: The API's is list in header file ```lib/app-libs/extension/gui/wgl.h``` which is implemented based open soure 2D graphic library [LittlevGL](https://docs.littlevgl.com/en/html/index.html). Currently supported widgets include button, label, list and check box and more wigdet would be provided in future. + +The mechanism of exporting native API to WASM application +======================================================= + +The basic working flow for WASM application calling into the native API is shown in the following diagram: + + + + +WAMR provides the macro `EXPORT_WASM_API` to enable users to export a native API to a WASM application. WAMR has implemented a base API for the timer and messaging by using `EXPORT_WASM_API`. This can be a point of reference for extending your own library. +``` C +static NativeSymbol extended_native_symbol_defs[] = { + EXPORT_WASM_API(wasm_register_resource), + EXPORT_WASM_API(wasm_response_send), + EXPORT_WASM_API(wasm_post_request), + EXPORT_WASM_API(wasm_sub_event), + EXPORT_WASM_API(wasm_create_timer), + EXPORT_WASM_API(wasm_timer_set_interval), + EXPORT_WASM_API(wasm_timer_cancel), + EXPORT_WASM_API(wasm_timer_restart) +}; +``` + + **Security attention:** A WebAssembly application should only have access to its own memory space. As a result, the integrator should carefully design the native function to ensure that the memory accesses are safe. The native API to be exported to the WASM application must: +- Only use 32 bits number for parameters +- Should not pass data to the structure pointer (do data serialization instead) +- Should do the pointer address conversion in the native API +- Should not pass function pointer as callback + +Below is a sample of a library extension. All code invoked across WASM and native world must be serialized and de-serialized, and the native world must do a boundary check for every incoming address from the WASM world. + + +
+
+
+Steps for exporting native API
+==========================
+
+WAMR implemented a framework for developers to export API's. Below is the procedure to expose the platform API's in three steps:
+
+**Step 1. Create a header file**+Declare the API's for your WASM application source project to include. + +**Step 2. Create a source file**
+Export the platform API's, for example in ``` products/linux/ext_lib_export.c ``` +``` C +#include "lib_export.h" + +static NativeSymbol extended_native_symbol_defs[] = +{ +}; + +#include "ext_lib_export.h" +``` + +**Step 3. Register new API's**
+Use the macro `EXPORT_WASM_API` and `EXPORT_WASM_API2` to add exported API's into the array of ```extended_native_symbol_defs```. +The pre-defined MACRO `EXPORT_WASM_API` should be used to declare a function export: +``` c +#define EXPORT_WASM_API(symbol) {#symbol, symbol} +``` + +Below code example shows how to extend the library to support `customized()`: + +``` +//lib_export_impl.c +void customized() +{ + // your code +} + + +// lib_export_dec.h +#ifndef _LIB_EXPORT_DEC_H_ +#define _LIB_EXPORT_DEC_H_ +#ifdef __cplusplus +extern "C" { +#endif + +void customized(); + +#ifdef __cplusplus +} +#endif +#endif + + +// ext_lib_export.c +#include "lib_export.h" +#include "lib_export_dec.h" + +static NativeSymbol extended_native_symbol_defs[] = +{ + EXPORT_WASM_API(customized) +}; + +#include "ext_lib_export.h" +``` + +Use extended library +------------------------ +In the application source project, it will include the WAMR built-in API's header file and platform extension header files. Assuming the board vendor extends the library which added an API called customized(), the WASM application would be like this: +``` C +#include
+
+Below is the reference implementation of the server application. It provides room temperature measurement service.
+
+``` C
+void on_init()
+{
+ api_register_resource_handler("/room_temp", room_temp_handler);
+}
+
+void on_destroy()
+{
+}
+
+void room_temp_handler(request_t *request)
+{
+ response_t response[1];
+ attr_container_t *payload;
+ payload = attr_container_create("room_temp payload");
+ if (payload == NULL)
+ return;
+
+ attr_container_set_string(&payload, "temp unit", "centigrade");
+ attr_container_set_int(&payload, "value", 26);
+
+ make_response_for_request(request, response);
+ set_response(response,
+ CONTENT_2_05,
+ FMT_ATTR_CONTAINER,
+ payload,
+ attr_container_get_serialize_length(payload));
+
+ api_response_send(response);
+ attr_container_destroy(payload);
+}
+```
+
+
+Pub/sub model
+-------------------------
+One WASM application acts as the event publisher. It publishes events to notify WASM applications or host/cloud applications which subscribe to the events.
+
+
+
+Below is the reference implementation of the pub application. It utilizes a timer to repeatedly publish an overheat alert event to the subscriber applications. Then the subscriber applications receive the events immediately.
+
+``` C
+/* Timer callback */
+void timer_update(user_timer_t timer
+{
+ attr_container_t *event;
+
+ event = attr_container_create("event");
+ attr_container_set_string(&event,
+ "warning",
+ "temperature is over high");
+
+ api_publish_event("alert/overheat",
+ FMT_ATTR_CONTAINER,
+ event,
+ attr_container_get_serialize_length(event));
+
+ attr_container_destroy(event);
+}
+
+void on_init()
+{
+ user_timer_t timer;
+ timer = api_timer_create(1000, true, true, timer_update);
+}
+
+void on_destroy()
+{
+}
+```
+
+Below is the reference implementation of the sub application.
+``` C
+void overheat_handler(request_t *event)
+{
+ printf("Event: %s\n", event->url);
+
+ if (event->payload != NULL && event->fmt == FMT_ATTR_CONTAINER)
+ attr_container_dump((attr_container_t *) event->payload);
+}
+
+void on_init(
+{
+ api_subscribe_event ("alert/overheat", overheat_handler);
+}
+
+void on_destroy()
+{
+}
+```
+**Note:** You can also subscribe this event from host side by using host tool. Please refer `samples/simple` project for deail usage.
\ No newline at end of file
diff --git a/samples/gui/README.md b/samples/gui/README.md
index 3bfd18dd6..e04e33dc7 100644
--- a/samples/gui/README.md
+++ b/samples/gui/README.md
@@ -1,15 +1,17 @@
Introduction
==============
-This sample demonstrates that a graphic user interface application in WebAssembly programming with WAMR graphic library(WGL) extension. WGL is implemented based on LittlevGL, an open-source embedded 2d graphic library. LittlevGL source code is built into the WAMR runtime and exported to Webassembly application with WGL extension. These extension API's are listed in: `
+Below pictures show the WASM application is running on an STM board with an LCD touch panel. When users click the blue button, the WASM application increases the counter, and the latest counter value is displayed on the top banner of the touch panel. The number on top will plus one each second, and the number on the bottom will plus one when clicked.
-The number on top will plus one each second, and the number on the bottom will plus one when clicked.
+
+
Configure 32 bit or 64 bit build
==============
diff --git a/samples/gui/wasm-runtime-wgl/src/ext_lib_export.c b/samples/gui/wasm-runtime-wgl/src/ext_lib_export.c
index e478b7e45..4f696f0ad 100644
--- a/samples/gui/wasm-runtime-wgl/src/ext_lib_export.c
+++ b/samples/gui/wasm-runtime-wgl/src/ext_lib_export.c
@@ -1,5 +1,5 @@
#include "lib_export.h"
-#include "native_interface.h"
+#include "sensor_api.h"
#include "connection_api.h"
#include "gui_api.h"
diff --git a/samples/gui/wasm-runtime-wgl/src/platform/zephyr/iwasm_main.c b/samples/gui/wasm-runtime-wgl/src/platform/zephyr/iwasm_main.c
index 6c42acc8e..486815504 100644
--- a/samples/gui/wasm-runtime-wgl/src/platform/zephyr/iwasm_main.c
+++ b/samples/gui/wasm-runtime-wgl/src/platform/zephyr/iwasm_main.c
@@ -69,6 +69,9 @@ static bool host_init()
int host_send(void * ctx, const char *buf, int size)
{
+ if (!uart_dev)
+ return 0;
+
for (int i = 0; i < size; i++)
uart_poll_out(uart_dev, buf[i]);
diff --git a/samples/gui/wasm-runtime-wgl/zephyr-build/prj.conf b/samples/gui/wasm-runtime-wgl/zephyr-build/prj.conf
index 2375969e1..79d892054 100644
--- a/samples/gui/wasm-runtime-wgl/zephyr-build/prj.conf
+++ b/samples/gui/wasm-runtime-wgl/zephyr-build/prj.conf
@@ -5,3 +5,5 @@ CONFIG_PRINTK=y
CONFIG_LOG=y
#CONFIG_UART_2=y
CONFIG_UART_INTERRUPT_DRIVEN=y
+CONFIG_STACK_SENTINEL=y
+CONFIG_MAIN_STACK_SIZE=2048
diff --git a/samples/littlevgl/README.md b/samples/littlevgl/README.md
index 18e2527fc..4f37d84fc 100644
--- a/samples/littlevgl/README.md
+++ b/samples/littlevgl/README.md
@@ -1,6 +1,6 @@
Introduction
==============
-This sample demonstrates that a graphic user interface application in WebAssembly integrates the LittlevGL, an open-source embedded 2d graphic library.
+This sample demonstrates that a graphic user interface application in WebAssembly by compiling the LittlevGL, an open-source embedded 2d graphic library into the WASM bytecode.
In this sample, the whole LittlevGL source code is built into the WebAssembly code with the user application. The platform interfaces defined by LittlevGL is implemented in the runtime and exported to the application through the declarations from source "ext_lib_export.c" as below:
@@ -14,12 +14,20 @@ In this sample, the whole LittlevGL source code is built into the WebAssembly co
The runtime component supports building target for Linux and Zephyr/STM Nucleo board. The beauty of this sample is the WebAssembly application can have identical display and behavior when running from both runtime environments. That implies we can do majority of application validation from desktop environment as long as two runtime distributions support the same set of application interface.
+
+Below pictures show the WASM application is running on an STM board with an LCD touch panel.
+
+
+
+
+
+
+The number on top will plus one each second, and the number on the bottom will plus one when clicked. When users click the blue button, the WASM application increases the counter, and the latest counter value is displayed on the top banner of the touch panel.
+
The sample also provides the native Linux version of application without the runtime under folder "vgl-native-ui-app". It can help to check differences between the implementations in native and WebAssembly.
-
-
-The number on top will plus one each second, and the number on the bottom will plus one when clicked.
+
Configure 32 bit or 64 bit build
==============
diff --git a/samples/littlevgl/vgl-wasm-runtime/src/display_indev.h b/samples/littlevgl/vgl-wasm-runtime/src/display_indev.h
index 154071e36..cb8d76e0e 100644
--- a/samples/littlevgl/vgl-wasm-runtime/src/display_indev.h
+++ b/samples/littlevgl/vgl-wasm-runtime/src/display_indev.h
@@ -1,9 +1,10 @@
#ifndef DISPLAY_INDEV_H_
#define DISPLAY_INDEV_H_
#include
+
+
+
+
+
+
+
+
+
+WebAssembly Micro Runtime - APP Store Demo
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 
+
IP :
+ Port :
+ Installed apps :
+
+
+
+
+app is downloading now
+
+
+
+
+
+
+
+
+
+
+
+ List of Installed Apps:
+ +
+ 
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/test-tools/IoT-APP-Store-Demo/wasm_django/devices/templates/appstore.html b/test-tools/IoT-APP-Store-Demo/wasm_django/devices/templates/appstore.html
new file mode 100644
index 000000000..36f1fb8da
--- /dev/null
+++ b/test-tools/IoT-APP-Store-Demo/wasm_django/devices/templates/appstore.html
@@ -0,0 +1,106 @@
+
+{% load static %}
+
+
+
+
+
+
+
+
+ .png'%})
+
+ Product Name:
+ Staus:
+ Current Version:
+
+
+
+
+
+
+
+
+
+
+
+
+WebAssembly Micro Runtime - APP Store Demo
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/test-tools/IoT-APP-Store-Demo/wasm_django/devices/templates/empty.html b/test-tools/IoT-APP-Store-Demo/wasm_django/devices/templates/empty.html
new file mode 100644
index 000000000..6aef0f2a7
--- /dev/null
+++ b/test-tools/IoT-APP-Store-Demo/wasm_django/devices/templates/empty.html
@@ -0,0 +1,119 @@
+
+
+
+
+
+
+
+
+
+
+ 
+
+ Product Name:
+Product Version:
+Preloaded Apps
+ ++
+
+
+
+
\ No newline at end of file
diff --git a/test-tools/IoT-APP-Store-Demo/wasm_django/devices/templates/mysite.html b/test-tools/IoT-APP-Store-Demo/wasm_django/devices/templates/mysite.html
new file mode 100644
index 000000000..88f0e9234
--- /dev/null
+++ b/test-tools/IoT-APP-Store-Demo/wasm_django/devices/templates/mysite.html
@@ -0,0 +1,99 @@
+
+{% load static %}
+
+
+
+
+
+
+
+
+
+
+
+
+ + How to use? +
++ 1. Download a simple runtime (build for ubuntu 16.04 64 bits, other platforms please build + from the source code) +
+
+ 2. In the terminal: cd ~/Download && ./simple -a 39.106.110.7
+
+
+
+
+
+ + Notes: +
We also have a UI-enabled runtime, please download here and enjoy. It may require + a few more setups. +Before running the UI-enabled runtime, please install some required softwares:
+sudo apt-get install libsdl2-2.0-0:i386
For more details please refer to this guide +
+cd ~/Download && ./wasm_runtime_wgl -a 39.106.110.7
+ 3. Return to device page, find your device according to the IP address and click it, you + will enter application installation page +
++ 4. In the application installation page, click the Install Application button, and chose an + app to install. (The "ui_app" is only for UI_enabled_runtimes, simple runtime can't install + this app) +
++ 5. If you want to upload a new application, go to App Store page, choose a file and click + upload +
++ Go Back + Download + simple_runtime + Download + UI_enabled_runtime +
+
+
+
+
+
+
+ Like this project?
+Join us and build a powerful and interesting world for embedded + devices!
+ + ++ View + on GitHub +
+
+
+
+
+
+
+
+
+WebAssembly Micro Runtime - APP Store Demo
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
The devices
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/test-tools/IoT-APP-Store-Demo/wasm_django/devices/tests.py b/test-tools/IoT-APP-Store-Demo/wasm_django/devices/tests.py
new file mode 100755
index 000000000..7ce503c2d
--- /dev/null
+++ b/test-tools/IoT-APP-Store-Demo/wasm_django/devices/tests.py
@@ -0,0 +1,3 @@
+from django.test import TestCase
+
+# Create your tests here.
diff --git a/test-tools/IoT-APP-Store-Demo/wasm_django/devices/views.py b/test-tools/IoT-APP-Store-Demo/wasm_django/devices/views.py
new file mode 100755
index 000000000..4fd4c09c2
--- /dev/null
+++ b/test-tools/IoT-APP-Store-Demo/wasm_django/devices/views.py
@@ -0,0 +1,284 @@
+'''
+ /* Copyright (C) 2019 Intel Corporation. All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+'''
+
+# _*_
+from django.shortcuts import render, render_to_response
+from django.http import HttpResponse, HttpResponseRedirect, HttpResponseNotFound
+import json
+import socket
+import os
+
+# Create your views here.
+
+
+avaliable_list = [
+ {'ID': 'timer', 'Version': '1.0'},
+ {'ID': 'connection', 'Version': '1.0'},
+ {'ID': 'event_publisher', 'Version': '3.0'},
+ {'ID': 'event_subscriber', 'Version': '1.0'},
+ {'ID': 'request_handler', 'Version': '1.0'},
+ {'ID': 'sensor', 'Version': '1.0'},
+ {'ID': 'ui_app', 'Version': '1.0'}
+]
+
+# Help
+def help(req):
+# return "Help" page
+ return render(req, "help.html")
+
+# View
+def index(req):
+ s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+
+ host = '127.0.0.1'
+ port = 8889
+ msg = ""
+ err = ""
+
+ try:
+ s.connect((host, port))
+ s.send(bytes("query:all", encoding='utf8'))
+ s.settimeout(10)
+ msg = s.recv(1024)
+ except socket.timeout as e:
+ err = "empty"
+ print("no client connected")
+ except socket.error as e:
+ err = "refused"
+ print("server not started")
+
+ s.close()
+
+ device_list = []
+ if msg != "":
+ devices = msg.decode('utf-8').split("*")
+ for dev in devices:
+ dev_info = eval(dev)
+ addr = dev_info['addr']
+ port = dev_info['port']
+ apps = dev_info['num']
+ device_list.append({'IP': addr, 'Port': port, 'apps': apps})
+ else:
+ if err == "refused":
+ return render(req, "empty.html")
+
+ dlist = device_list
+
+ return render(req, 'mysite.html', {'dlist': json.dumps(dlist)})
+
+
+def apps(req):
+ open_status = ''
+ search_node = []
+ if req.method == "POST":
+ dev_search = req.POST['mykey']
+ dev_addr = req.POST['voip']
+ dev_port = req.POST['voport']
+ open_status = 'open'
+ for i in avaliable_list:
+ if i['ID'] == dev_search:
+ search_node = [{'ID':dev_search, 'Version': '1.0'}]
+ print("search_node:",search_node)
+ break
+ else:
+ search_node = ["Nothing find"]
+ print( "final:",search_node)
+ else:
+ dev_addr = req.GET['ip']
+ dev_port = req.GET['port']
+ open_status = 'close'
+
+ s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+ host = '127.0.0.1'
+ port = 8889
+ msg = ""
+ err = ""
+
+ try:
+ s.connect((host, port))
+ s.send(bytes("query:"+dev_addr+":"+str(dev_port), encoding='utf8'))
+ msg = s.recv(1024)
+ except socket.error as e:
+ print("unable to connect to server")
+ msg = b"fail"
+ s.close()
+
+ app_list = []
+
+ if msg != "":
+ if msg.decode() == "fail":
+ return render(req, "empty.html")
+ else:
+ dic = eval(msg.decode(encoding='utf8'))
+ app_num = dic["num"]
+ for i in range(app_num):
+ app_list.append(
+ {'pname': dic["applet"+str(i+1)], 'status': 'Installed', 'current_version': '1.0'})
+
+ alist = app_list
+ device_info = []
+ device_info.append(
+ {'IP': dev_addr, 'Port': str(dev_port), 'apps': app_num})
+
+ print(device_info)
+ return render(req, 'application.html', {'alist': json.dumps(alist), 'dlist': json.dumps(device_info), 'llist': json.dumps(avaliable_list),
+ "open_status":json.dumps(open_status),"search_node": json.dumps(search_node),})
+
+
+def appDownload(req):
+ dev_addr = req.GET['ip']
+ dev_port = req.GET['port']
+ app_name = req.GET['name']
+
+ s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+
+ host = '127.0.0.1'
+ port = 8889
+ msg = ""
+
+ app_path = os.path.abspath(os.path.join(os.getcwd(), "static", "upload"))
+ if app_path[-1] != '/':
+ app_path += '/'
+
+ try:
+ s.connect((host, port))
+ s.send(bytes("install:"+dev_addr+":"+str(dev_port)+":"+app_name +
+ ":"+app_path + app_name + ".wasm", encoding='utf8'))
+ msg = s.recv(1024)
+ except socket.error as e:
+ print("unable to connect to server")
+ s.close()
+
+ success = "ok"
+ fail = "Fail!"
+ status = [success, fail]
+ print(msg)
+ if msg == b"fail":
+ return HttpResponse(json.dumps({
+ "status": fail
+ }))
+ elif msg == b"success":
+ return HttpResponse(json.dumps({
+ "status": success
+ }))
+ else:
+ return HttpResponse(json.dumps({
+ "status": eval(msg.decode())["error message"].split(':')[1]
+ }))
+
+
+def appDelete(req):
+ dev_addr = req.GET['ip']
+ dev_port = req.GET['port']
+ app_name = req.GET['name']
+
+ s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+
+ host = '127.0.0.1'
+ port = 8889
+ s.connect((host, port))
+ s.send(bytes("uninstall:"+dev_addr+":" +
+ str(dev_port)+":"+app_name, encoding='utf8'))
+ msg = s.recv(1024)
+ s.close()
+ r = HttpResponse("ok")
+ return r
+
+static_list = [{'ID': 'timer', 'Version': '1.0'}, {'ID': 'connection', 'Version': '1.0'}, {'ID': 'event_publisher', 'Version': '3.0'}, {
+ 'ID': 'event_subscriber', 'Version': '1.0'}, {'ID': 'reuqest_handler', 'Version': '1.0'}, {'ID': 'sensor', 'Version': '1.0'}, {'ID': 'ui_app', 'Version': '1.0'}]
+
+def store(req):
+
+ store_path = os.path.join('static', 'upload')
+ status = []
+
+ print(user_file_list)
+ return render(req, 'appstore.html', {'staticlist': json.dumps(static_list), 'flist': json.dumps(user_file_list),'ulist':json.dumps(status)})
+
+user_file_list = []
+files_list = []
+def uploadapps(req):
+ status = []
+ local_list = ['timer','connection','event_publisher','event_subscriber','reuqest_handler','sensor']
+ req.encoding = 'utf-8'
+ if req.method == 'POST':
+ myfile = req.FILES.get("myfile", None)
+ obj = req.FILES.get('myfile')
+ store_path = os.path.join('static', 'upload')
+ file_path = os.path.join('static', 'upload', obj.name)
+
+ if not os.path.exists(store_path):
+ os.makedirs(store_path)
+
+ file_name = obj.name.split(".")[0]
+ file_prefix = obj.name.split(".")[-1]
+
+
+ if file_prefix != "wasm":
+ status = ["Not a wasm file"]
+ elif file_name in local_list:
+ status = ["This App is preloaded"]
+ elif file_name in files_list:
+ status = ["This App is already uploaded"]
+ else:
+ status = []
+ avaliable_list.append({'ID': file_name, 'Version': '1.0'})
+ user_file_list.append({'ID': file_name, 'Version': '1.0'})
+ files_list.append(file_name)
+
+ print(user_file_list)
+ f = open(file_path, 'wb')
+ for chunk in obj.chunks():
+ f.write(chunk)
+ f.close()
+ return render(req, 'appstore.html', {'staticlist': json.dumps(static_list), 'flist': json.dumps(user_file_list),'ulist':json.dumps(status)})
+
+appname_list = []
+
+def addapps(request):
+ types = ''
+ print("enter addapps")
+ request.encoding = 'utf-8'
+ app_dic = {'ID': '', 'Version': ''}
+
+ # if request.method == 'get':
+ if "NAME" in request.GET:
+ a_name = request.GET['NAME']
+ if a_name != "" and a_name not in appname_list:
+ appname_list.append(a_name)
+ message = request.GET['NAME'] + request.GET['Version']
+ app_dic['ID'] = request.GET['NAME']
+ app_dic['Version'] = request.GET['Version']
+ avaliable_list.append(app_dic)
+ else:
+ types = "Exist"
+ print(avaliable_list)
+ return render(request, 'appstore.html', {'alist': json.dumps(avaliable_list)})
+
+def removeapps(req):
+ app_name = req.GET['name']
+ app_version = req.GET['version']
+ remove_app = {'ID': app_name, 'Version': app_version}
+ avaliable_list.remove(remove_app)
+ user_file_list.remove(remove_app)
+ files_list.remove(app_name)
+ return render(req, 'appstore.html', {'alist': json.dumps(avaliable_list),'flist': json.dumps(user_file_list)})
+
+# Test
+if __name__ == "__main__":
+ print(device_list[0]['IP'])
+ print(device['IP'])
diff --git a/test-tools/IoT-APP-Store-Demo/wasm_django/manage.py b/test-tools/IoT-APP-Store-Demo/wasm_django/manage.py
new file mode 100755
index 000000000..341863cf6
--- /dev/null
+++ b/test-tools/IoT-APP-Store-Demo/wasm_django/manage.py
@@ -0,0 +1,21 @@
+#!/usr/bin/env python
+"""Django's command-line utility for administrative tasks."""
+import os
+import sys
+
+
+def main():
+ os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'mysite.settings')
+ try:
+ from django.core.management import execute_from_command_line
+ except ImportError as exc:
+ raise ImportError(
+ "Couldn't import Django. Are you sure it's installed and "
+ "available on your PYTHONPATH environment variable? Did you "
+ "forget to activate a virtual environment?"
+ ) from exc
+ execute_from_command_line(sys.argv)
+
+
+if __name__ == '__main__':
+ main()
diff --git a/test-tools/IoT-APP-Store-Demo/wasm_django/mysite/__init__.py b/test-tools/IoT-APP-Store-Demo/wasm_django/mysite/__init__.py
new file mode 100755
index 000000000..e69de29bb
diff --git a/test-tools/IoT-APP-Store-Demo/wasm_django/mysite/settings.py b/test-tools/IoT-APP-Store-Demo/wasm_django/mysite/settings.py
new file mode 100755
index 000000000..7eb3685c4
--- /dev/null
+++ b/test-tools/IoT-APP-Store-Demo/wasm_django/mysite/settings.py
@@ -0,0 +1,136 @@
+"""
+Django settings for mysite project.
+
+Generated by 'django-admin startproject' using Django 2.2.2.
+
+For more information on this file, see
+https://docs.djangoproject.com/en/2.2/topics/settings/
+
+For the full list of settings and their values, see
+https://docs.djangoproject.com/en/2.2/ref/settings/
+"""
+
+import os
+from django.conf.global_settings import STATIC_ROOT
+
+# Build paths inside the project like this: os.path.join(BASE_DIR, ...)
+BASE_DIR = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
+
+
+# Quick-start development settings - unsuitable for production
+# See https://docs.djangoproject.com/en/2.2/howto/deployment/checklist/
+
+# SECURITY WARNING: keep the secret key used in production secret!
+SECRET_KEY = '8m05#6yx5wcygj*a+v6+=-y(#o+(z58-3!epq$u@5)64!mmu8q'
+
+# SECURITY WARNING: don't run with debug turned on in production!
+DEBUG = True
+
+ALLOWED_HOSTS = ['*']
+
+
+# Application definition
+
+INSTALLED_APPS = [
+ 'django.contrib.admin',
+ 'django.contrib.auth',
+ 'django.contrib.contenttypes',
+ 'django.contrib.sessions',
+ 'django.contrib.messages',
+ 'django.contrib.staticfiles',
+
+
+ 'devices',
+]
+
+MIDDLEWARE = [
+ 'django.middleware.security.SecurityMiddleware',
+ 'django.contrib.sessions.middleware.SessionMiddleware',
+ 'django.middleware.common.CommonMiddleware',
+ 'django.middleware.csrf.CsrfViewMiddleware',
+ 'django.contrib.auth.middleware.AuthenticationMiddleware',
+ 'django.contrib.messages.middleware.MessageMiddleware',
+ 'django.middleware.clickjacking.XFrameOptionsMiddleware',
+]
+
+ROOT_URLCONF = 'mysite.urls'
+
+TEMPLATES = [
+ {
+ 'BACKEND': 'django.template.backends.django.DjangoTemplates',
+ 'DIRS': [],
+ 'APP_DIRS': True,
+ 'OPTIONS': {
+ 'context_processors': [
+ 'django.template.context_processors.debug',
+ 'django.template.context_processors.request',
+ 'django.contrib.auth.context_processors.auth',
+ 'django.contrib.messages.context_processors.messages',
+ ],
+ },
+ },
+]
+
+WSGI_APPLICATION = 'mysite.wsgi.application'
+
+
+# Database
+# https://docs.djangoproject.com/en/2.2/ref/settings/#databases
+
+DATABASES = {
+ 'default': {
+ 'ENGINE': 'django.db.backends.sqlite3',
+ 'NAME': os.path.join(BASE_DIR, 'db.sqlite3'),
+ }
+}
+
+
+# Password validation
+# https://docs.djangoproject.com/en/2.2/ref/settings/#auth-password-validators
+
+AUTH_PASSWORD_VALIDATORS = [
+ {
+ 'NAME': 'django.contrib.auth.password_validation.UserAttributeSimilarityValidator',
+ },
+ {
+ 'NAME': 'django.contrib.auth.password_validation.MinimumLengthValidator',
+ },
+ {
+ 'NAME': 'django.contrib.auth.password_validation.CommonPasswordValidator',
+ },
+ {
+ 'NAME': 'django.contrib.auth.password_validation.NumericPasswordValidator',
+ },
+]
+
+
+# Internationalization
+# https://docs.djangoproject.com/en/2.2/topics/i18n/
+
+LANGUAGE_CODE = 'en-us'
+
+TIME_ZONE = 'UTC'
+
+USE_I18N = True
+
+USE_L10N = True
+
+USE_TZ = True
+
+APPEND_SLASH = False
+
+
+# Static files (CSS, JavaScript, Images)
+# https://docs.djangoproject.com/en/2.2/howto/static-files/
+
+STATIC_URL = '/static/'
+HERE = os.path.dirname(os.path.abspath(__file__))
+HERE = os.path.join(HERE,'../')
+STATICFILES_DIRS = (os.path.join(HERE,'static/'),)
+#STATICFILES_DIRS = (os.path.join(BASE_DIR,'static'),)
+#STATIC_ROOT = (os.path.join(os.path.dirname(_file_),'static')
+#templates
+TEMPLATE_DIRS=[
+ '/home/xujun/mysite/templates',
+]
+
diff --git a/test-tools/IoT-APP-Store-Demo/wasm_django/mysite/urls.py b/test-tools/IoT-APP-Store-Demo/wasm_django/mysite/urls.py
new file mode 100755
index 000000000..8a74b5509
--- /dev/null
+++ b/test-tools/IoT-APP-Store-Demo/wasm_django/mysite/urls.py
@@ -0,0 +1,41 @@
+#config:utf-8
+
+"""mysite URL Configuration
+
+The `urlpatterns` list routes URLs to views. For more information please see:
+ https://docs.djangoproject.com/en/2.2/topics/http/urls/
+Examples:
+Function views
+ 1. Add an import: from my_app import views
+ 2. Add a URL to urlpatterns: path('', views.home, name='home')
+Class-based views
+ 1. Add an import: from other_app.views import Home
+ 2. Add a URL to urlpatterns: path('', Home.as_view(), name='home')
+Including another URLconf
+ 1. Import the include() function: from django.urls import include, path
+ 2. Add a URL to urlpatterns: path('blog/', include('blog.urls'))
+"""
+from django.contrib import admin
+#from django.conf.urls import include,url
+from django.urls import path,include
+from devices import views as devices_views
+#from login import views as login_views
+
+
+urlpatterns = [
+
+ path('admin/', admin.site.urls),
+ path('',devices_views.index),
+ path('apps/',devices_views.apps),
+ path('appDownload/', devices_views.appDownload),
+ path('appDelete/', devices_views.appDelete),
+ path('appstore/',devices_views.store),
+## path('apps/appstore/',devices_views.storeofdevic),
+## path('search/',devices_views.search),
+ path('upload',devices_views.uploadapps),
+ path('removeapps/',devices_views.removeapps),
+ path('help/',devices_views.help),
+
+]
+
+
diff --git a/test-tools/IoT-APP-Store-Demo/wasm_django/mysite/wsgi.py b/test-tools/IoT-APP-Store-Demo/wasm_django/mysite/wsgi.py
new file mode 100755
index 000000000..45e28c9a1
--- /dev/null
+++ b/test-tools/IoT-APP-Store-Demo/wasm_django/mysite/wsgi.py
@@ -0,0 +1,16 @@
+"""
+WSGI config for mysite project.
+
+It exposes the WSGI callable as a module-level variable named ``application``.
+
+For more information on this file, see
+https://docs.djangoproject.com/en/2.2/howto/deployment/wsgi/
+"""
+
+import os
+
+from django.core.wsgi import get_wsgi_application
+
+os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'mysite.settings')
+
+application = get_wsgi_application()
diff --git a/test-tools/IoT-APP-Store-Demo/wasm_django/server/wasm_server.py b/test-tools/IoT-APP-Store-Demo/wasm_django/server/wasm_server.py
new file mode 100755
index 000000000..1754b368e
--- /dev/null
+++ b/test-tools/IoT-APP-Store-Demo/wasm_django/server/wasm_server.py
@@ -0,0 +1,616 @@
+'''
+ /* Copyright (C) 2019 Intel Corporation. All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+'''
+import select
+import socket
+import queue
+from time import sleep
+import struct
+import threading
+import time
+from ctypes import *
+import json
+import logging
+import os
+
+attr_type_list = [
+ "ATTR_NONE",
+ "ATTR_TYPE_SHORT",
+ "ATTR_TYPE_INT",
+ "ATTR_TYPE_INT64",
+ "ATTR_TYPE_BYTE",
+ "ATTR_TYPE_UINT16",
+ "ATTR_TYPE_FLOAT",
+ "ATTR_TYPE_DOUBLE",
+ "ATTR_TYPE_BOOLEAN",
+ "ATTR_TYPE_STRING",
+ "ATTR_TYPE_BYTEARRAY"
+]
+
+
+Phase_Non_Start = 0
+Phase_Leading = 1
+Phase_Type = 2
+Phase_Size = 3
+Phase_Payload = 4
+
+
+
+class imrt_link_message(object):
+ def __init__(self):
+ self.leading = bytes([0x12, 0x34])
+ self.phase = Phase_Non_Start
+ self.size_in_phase = 0
+ self.message_type = bytes()
+ self.message_size = bytes()
+ self.payload = bytes()
+ self.msg = bytes()
+
+ def set_recv_phase(self, phase):
+ self.phase = phase
+
+ def on_imrt_link_byte_arrive(self, ch):
+ self.msg += ch
+ if self.phase == Phase_Non_Start:
+ if ch == b'\x12':
+ self.set_recv_phase(Phase_Leading)
+ else:
+ return -1
+ elif self.phase == Phase_Leading:
+ if ch == b'\x34':
+ self.set_recv_phase(Phase_Type)
+ else:
+ self.set_recv_phase(Phase_Non_Start)
+ return -1
+ elif self.phase == Phase_Type:
+ self.message_type += ch
+ self.size_in_phase += 1
+
+ if self.size_in_phase == 2:
+ (self.message_type, ) = struct.unpack('!H', self.message_type)
+ self.size_in_phase = 0
+ self.set_recv_phase(Phase_Size)
+ elif self.phase == Phase_Size:
+ self.message_size += ch
+ self.size_in_phase += 1
+
+ if self.size_in_phase == 4:
+ (self.message_size, ) = struct.unpack('!I', self.message_size)
+ self.size_in_phase = 0
+ self.set_recv_phase(Phase_Payload)
+
+ if self.message_size == b'\x00':
+ self.set_recv_phase(Phase_Non_Start)
+ return 0
+
+ self.set_recv_phase(Phase_Payload)
+
+ elif self.phase == Phase_Payload:
+ self.payload += ch
+ self.size_in_phase += 1
+
+ if self.size_in_phase == self.message_size:
+ self.set_recv_phase(Phase_Non_Start)
+ return 0
+
+ return 2
+
+ return 1
+
+
+
+def read_file_to_buffer(file_name):
+ file_object = open(file_name, 'rb')
+ buffer = None
+
+ if not os.path.exists(file_name):
+ logging.error("file {} not found.".format(file_name))
+ return "file not found"
+
+ try:
+ buffer = file_object.read()
+ finally:
+ file_object.close()
+
+ return buffer
+
+def decode_attr_container(msg):
+
+ attr_dict = {}
+
+ buf = msg[26 : ]
+ (total_len, tag_len) = struct.unpack('@IH', buf[0 : 6])
+ tag_name = buf[6 : 6 + tag_len].decode()
+ buf = buf[6 + tag_len : ]
+ (attr_num, ) = struct.unpack('@H', buf[0 : 2])
+ buf = buf[2 : ]
+
+ logging.info("parsed attr:")
+ logging.info("total_len:{}, tag_len:{}, tag_name:{}, attr_num:{}"
+ .format(str(total_len), str(tag_len), str(tag_name), str(attr_num)))
+
+ for i in range(attr_num):
+ (key_len, ) = struct.unpack('@H', buf[0 : 2])
+ key_name = buf[2 : 2 + key_len - 1].decode()
+ buf = buf[2 + key_len : ]
+ (type_index, ) = struct.unpack('@c', buf[0 : 1])
+
+ attr_type = attr_type_list[int(type_index[0])]
+ buf = buf[1 : ]
+
+ if attr_type == "ATTR_TYPE_SHORT":
+ (attr_value, ) = struct.unpack('@h', buf[0 : 2])
+ buf = buf[2 : ]
+ # continue
+ elif attr_type == "ATTR_TYPE_INT":
+ (attr_value, ) = struct.unpack('@I', buf[0 : 4])
+ buf = buf[4 : ]
+ # continue
+ elif attr_type == "ATTR_TYPE_INT64":
+ (attr_value, ) = struct.unpack('@q', buf[0 : 8])
+ buf = buf[8 : ]
+ # continue
+ elif attr_type == "ATTR_TYPE_BYTE":
+ (attr_value, ) = struct.unpack('@c', buf[0 : 1])
+ buf = buf[1 : ]
+ # continue
+ elif attr_type == "ATTR_TYPE_UINT16":
+ (attr_value, ) = struct.unpack('@H', buf[0 : 2])
+ buf = buf[2 : ]
+ # continue
+ elif attr_type == "ATTR_TYPE_FLOAT":
+ (attr_value, ) = struct.unpack('@f', buf[0 : 4])
+ buf = buf[4 : ]
+ # continue
+ elif attr_type == "ATTR_TYPE_DOUBLE":
+ (attr_value, ) = struct.unpack('@d', buf[0 : 8])
+ buf = buf[8 : ]
+ # continue
+ elif attr_type == "ATTR_TYPE_BOOLEAN":
+ (attr_value, ) = struct.unpack('@?', buf[0 : 1])
+ buf = buf[1 : ]
+ # continue
+ elif attr_type == "ATTR_TYPE_STRING":
+ (str_len, ) = struct.unpack('@H', buf[0 : 2])
+ attr_value = buf[2 : 2 + str_len - 1].decode()
+ buf = buf[2 + str_len : ]
+ # continue
+ elif attr_type == "ATTR_TYPE_BYTEARRAY":
+ (byte_len, ) = struct.unpack('@I', buf[0 : 4])
+ attr_value = buf[4 : 4 + byte_len]
+ buf = buf[4 + byte_len : ]
+ # continue
+
+ attr_dict[key_name] = attr_value
+
+ logging.info(str(attr_dict))
+ return attr_dict
+
+class Request():
+ mid = 0
+ url = ""
+ action = 0
+ fmt = 0
+ payload = ""
+ payload_len = 0
+ sender = 0
+
+ def __init__(self, url, action, fmt, payload, payload_len):
+ self.url = url
+ self.action = action
+ self.fmt = fmt
+ # if type(payload) == bytes:
+ # self.payload = bytes(payload, encoding = "utf8")
+ # else:
+ self.payload_len = payload_len
+ if self.payload_len > 0:
+ self.payload = payload
+
+
+ def pack_request(self):
+ url_len = len(self.url) + 1
+ buffer_len = url_len + self.payload_len
+
+ req_buffer = struct.pack('!2BH2IHI',1, self.action, self.fmt, self.mid, self.sender, url_len, self.payload_len)
+ for i in range(url_len - 1):
+ req_buffer += struct.pack('!c', bytes(self.url[i], encoding = "utf8"))
+ req_buffer += bytes([0])
+ for i in range(self.payload_len):
+ req_buffer += struct.pack('!B', self.payload[i])
+
+ return req_buffer, len(req_buffer)
+
+
+ def send(self, conn, is_install):
+ leading = struct.pack('!2B', 0x12, 0x34)
+
+ if not is_install:
+ msg_type = struct.pack('!H', 0x0002)
+ else:
+ msg_type = struct.pack('!H', 0x0004)
+ buff, buff_len = self.pack_request()
+ lenth = struct.pack('!I', buff_len)
+
+ try:
+ conn.send(leading)
+ conn.send(msg_type)
+ conn.send(lenth)
+ conn.send(buff)
+ except socket.error as e:
+ logging.error("device closed")
+ for dev in tcpserver.devices:
+ if dev.conn == conn:
+ tcpserver.devices.remove(dev)
+ return -1
+
+
+def query(conn):
+ req = Request("/applet", 1, 0, "", 0)
+ if req.send(conn, False) == -1:
+ return "fail"
+ time.sleep(0.05)
+ try:
+ receive_context = imrt_link_message()
+ start = time.time()
+ while True:
+ if receive_context.on_imrt_link_byte_arrive(conn.recv(1)) == 0:
+ break
+ elif time.time() - start >= 5.0:
+ return "fail"
+ query_resp = receive_context.msg
+ print(query_resp)
+ except OSError as e:
+ logging.error("OSError exception occur")
+ return "fail"
+
+ res = decode_attr_container(query_resp)
+
+ logging.info('Query device infomation success')
+ return res
+
+def install(conn, app_name, wasm_file):
+ wasm = read_file_to_buffer(wasm_file)
+ if wasm == "file not found":
+ return "failed to install: file not found"
+
+ print("wasm file len:")
+ print(len(wasm))
+ req = Request("/applet?name=" + app_name, 3, 98, wasm, len(wasm))
+ if req.send(conn, True) == -1:
+ return "fail"
+ time.sleep(0.05)
+ try:
+ receive_context = imrt_link_message()
+ start = time.time()
+ while True:
+ if receive_context.on_imrt_link_byte_arrive(conn.recv(1)) == 0:
+ break
+ elif time.time() - start >= 5.0:
+ return "fail"
+ msg = receive_context.msg
+ except OSError as e:
+ logging.error("OSError exception occur")
+ # TODO: check return message
+
+ if len(msg) == 24 and msg[8 + 1] == 65:
+ logging.info('Install application success')
+ return "success"
+ else:
+ res = decode_attr_container(msg)
+ logging.warning('Install application failed: %s' % (str(res)))
+ print(str(res))
+
+ return str(res)
+
+
+def uninstall(conn, app_name):
+ req = Request("/applet?name=" + app_name, 4, 99, "", 0)
+ if req.send(conn, False) == -1:
+ return "fail"
+ time.sleep(0.05)
+ try:
+ receive_context = imrt_link_message()
+ start = time.time()
+ while True:
+ if receive_context.on_imrt_link_byte_arrive(conn.recv(1)) == 0:
+ break
+ elif time.time() - start >= 5.0:
+ return "fail"
+ msg = receive_context.msg
+ except OSError as e:
+ logging.error("OSError exception occur")
+ # TODO: check return message
+
+ if len(msg) == 24 and msg[8 + 1] == 66:
+ logging.info('Uninstall application success')
+ return "success"
+ else:
+ res = decode_attr_container(msg)
+ logging.warning('Uninstall application failed: %s' % (str(res)))
+ print(str(res))
+
+ return str(res)
+
+class Device:
+ def __init__(self, conn, addr, port):
+ self.conn = conn
+ self.addr = addr
+ self.port = port
+ self.app_num = 0
+ self.apps = []
+
+cmd = []
+
+class TCPServer:
+ def __init__(self, server, server_address, inputs, outputs, message_queues):
+ # Create a TCP/IP
+ self.server = server
+ self.server.setblocking(False)
+
+ # Bind the socket to the port
+ self.server_address = server_address
+ print('starting up on %s port %s' % self.server_address)
+ self.server.bind(self.server_address)
+
+ # Listen for incoming connections
+ self.server.listen(10)
+
+ self.cmd_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+ self.cmd_sock.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
+
+ self.cmd_sock.bind(('127.0.0.1', 8889))
+ self.cmd_sock.listen(5)
+
+
+ # Sockets from which we expect to read
+ self.inputs = inputs
+ self.inputs.append(self.cmd_sock)
+
+ # Sockets to which we expect to write
+ # 处理要发送的消息
+ self.outputs = outputs
+ # Outgoing message queues (socket: Queue)
+ self.message_queues = message_queues
+
+ self.devices = []
+ self.conn_dict = {}
+
+ def handler_recever(self, readable):
+ # Handle inputs
+ for s in readable:
+ if s is self.server:
+ # A "readable" socket is ready to accept a connection
+ connection, client_address = s.accept()
+ self.client_address = client_address
+ print('connection from', client_address)
+ # this is connection not server
+ # connection.setblocking(0)
+ self.inputs.append(connection)
+
+ # Give the connection a queue for data we want to send
+ # self.message_queues[connection] = queue.Queue()
+
+ res = query(connection)
+
+ if res != "fail":
+ dev = Device(connection, client_address[0], client_address[1])
+ self.devices.append(dev)
+ self.conn_dict[client_address] = connection
+
+ dev_info = {}
+ dev_info['addr'] = dev.addr
+ dev_info['port'] = dev.port
+ dev_info['apps'] = 0
+
+ logging.info('A new client connected from ("%s":"%s")' % (dev.conn, dev.port))
+
+ elif s is self.cmd_sock:
+ connection, client_address = s.accept()
+ print("web server socket connected")
+ logging.info("Django server connected")
+ self.inputs.append(connection)
+ self.message_queues[connection] = queue.Queue()
+
+ else:
+ data = s.recv(1024)
+ if data != b'':
+ # A readable client socket has data
+ logging.info('received "%s" from %s' % (data, s.getpeername()))
+
+ # self.message_queues[s].put(data)
+ # # Add output channel for response
+
+ # if s not in self.outputs:
+ # self.outputs.append(s)
+
+ if(data.decode().split(':')[0] == "query"):
+ if data.decode().split(':')[1] == "all":
+ resp = []
+ print('start query all devices')
+ for dev in self.devices:
+ dev_info = query(dev.conn)
+ if dev_info == "fail":
+ continue
+ dev_info["addr"] = dev.addr
+ dev_info["port"] = dev.port
+ resp.append(str(dev_info))
+
+ print(resp)
+
+ if self.message_queues[s] is not None:
+ # '*' is used in web server to sperate the string
+ self.message_queues[s].put(bytes("*".join(resp), encoding = 'utf8'))
+ if s not in self.outputs:
+ self.outputs.append(s)
+ else:
+ client_addr = (data.decode().split(':')[1],int(data.decode().split(':')[2]))
+
+ if client_addr in self.conn_dict.keys():
+ print('start query device from (%s:%s)' % (client_addr[0], client_addr[1]))
+ resp = query(self.conn_dict[client_addr])
+ print(resp)
+
+ if self.message_queues[s] is not None:
+ self.message_queues[s].put(bytes(str(resp), encoding = 'utf8'))
+ if s not in self.outputs:
+ self.outputs.append(s)
+ else: # no connection
+ if self.message_queues[s] is not None:
+ self.message_queues[s].put(bytes(str("fail"), encoding = 'utf8'))
+ if s not in self.outputs:
+ self.outputs.append(s)
+ elif(data.decode().split(':')[0] == "install"):
+ client_addr = (data.decode().split(':')[1],int(data.decode().split(':')[2]))
+ app_name = data.decode().split(':')[3]
+ app_file = data.decode().split(':')[4]
+
+ if client_addr in self.conn_dict.keys():
+ print('start install application %s to ("%s":"%s")' % (app_name, client_addr[0], client_addr[1]))
+ res = install(self.conn_dict[client_addr], app_name, app_file)
+ if self.message_queues[s] is not None:
+ logging.info("response {} to cmd server".format(res))
+ self.message_queues[s].put(bytes(res, encoding = 'utf8'))
+ if s not in self.outputs:
+ self.outputs.append(s)
+ elif(data.decode().split(':')[0] == "uninstall"):
+ client_addr = (data.decode().split(':')[1],int(data.decode().split(':')[2]))
+ app_name = data.decode().split(':')[3]
+
+ if client_addr in self.conn_dict.keys():
+ print("start uninstall")
+ res = uninstall(self.conn_dict[client_addr], app_name)
+ if self.message_queues[s] is not None:
+ logging.info("response {} to cmd server".format(res))
+ self.message_queues[s].put(bytes(res, encoding = 'utf8'))
+ if s not in self.outputs:
+ self.outputs.append(s)
+
+
+ # if self.message_queues[s] is not None:
+ # self.message_queues[s].put(data)
+ # if s not in self.outputs:
+ # self.outputs.append(s)
+ else:
+ logging.warning(data)
+
+ # Interpret empty result as closed connection
+ try:
+ for dev in self.devices:
+ if s == dev.conn:
+ self.devices.remove(dev)
+ # Stop listening for input on the connection
+ if s in self.outputs:
+ self.outputs.remove(s)
+ self.inputs.remove(s)
+
+ # Remove message queue
+ if s in self.message_queues.keys():
+ del self.message_queues[s]
+ s.close()
+ except OSError as e:
+ logging.error("OSError raised, unknown connection")
+ return "got it"
+
+ def handler_send(self, writable):
+ # Handle outputs
+ for s in writable:
+ try:
+ message_queue = self.message_queues.get(s)
+ send_data = ''
+ if message_queue is not None:
+ send_data = message_queue.get_nowait()
+ except queue.Empty:
+ self.outputs.remove(s)
+ else:
+ # print "sending %s to %s " % (send_data, s.getpeername)
+ # print "send something"
+ if message_queue is not None:
+ s.send(send_data)
+ else:
+ print("client has closed")
+ # del message_queues[s]
+ # writable.remove(s)
+ # print "Client %s disconnected" % (client_address)
+ return "got it"
+
+ def handler_exception(self, exceptional):
+ # # Handle "exceptional conditions"
+ for s in exceptional:
+ print('exception condition on', s.getpeername())
+ # Stop listening for input on the connection
+ self.inputs.remove(s)
+ if s in self.outputs:
+ self.outputs.remove(s)
+ s.close()
+
+ # Remove message queue
+ del self.message_queues[s]
+ return "got it"
+
+
+def event_loop(tcpserver, inputs, outputs):
+ while inputs:
+ # Wait for at least one of the sockets to be ready for processing
+ print('waiting for the next event')
+ readable, writable, exceptional = select.select(inputs, outputs, inputs)
+ if readable is not None:
+ tcp_recever = tcpserver.handler_recever(readable)
+ if tcp_recever == 'got it':
+ print("server have received")
+ if writable is not None:
+ tcp_send = tcpserver.handler_send(writable)
+ if tcp_send == 'got it':
+ print("server have send")
+ if exceptional is not None:
+ tcp_exception = tcpserver.handler_exception(exceptional)
+ if tcp_exception == 'got it':
+ print("server have exception")
+
+
+ sleep(0.1)
+
+def run_wasm_server():
+ server_address = ('localhost', 8888)
+ server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+ server.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
+ inputs = [server]
+ outputs = []
+ message_queues = {}
+ tcpserver = TCPServer(server, server_address, inputs, outputs, message_queues)
+
+ task = threading.Thread(target=event_loop,args=(tcpserver,inputs,outputs))
+ task.start()
+
+if __name__ == '__main__':
+ logging.basicConfig(level=logging.DEBUG,
+ filename='wasm_server.log',
+ filemode='a',
+ format=
+ '%(asctime)s - %(pathname)s[line:%(lineno)d] - %(levelname)s: %(message)s'
+ )
+ server_address = ('0.0.0.0', 8888)
+ server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+ server.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
+ inputs = [server]
+ outputs = []
+ message_queues = {}
+ tcpserver = TCPServer(server, server_address, inputs, outputs, message_queues)
+ logging.info("TCP Server start at {}:{}".format(server_address[0], "8888"))
+
+ task = threading.Thread(target=event_loop,args=(tcpserver,inputs,outputs))
+ task.start()
+
+ # event_loop(tcpserver, inputs, outputs)
\ No newline at end of file
diff --git a/test-tools/IoT-APP-Store-Demo/wasm_django/static/css/application.css b/test-tools/IoT-APP-Store-Demo/wasm_django/static/css/application.css
new file mode 100644
index 000000000..5876b9426
--- /dev/null
+++ b/test-tools/IoT-APP-Store-Demo/wasm_django/static/css/application.css
@@ -0,0 +1,411 @@
+/* Copyright (C) 2019 Intel Corporation. All rights reserved.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+{% load static %}
+
diff --git a/test-tools/IoT-APP-Store-Demo/wasm_django/static/js/application.js b/test-tools/IoT-APP-Store-Demo/wasm_django/static/js/application.js
new file mode 100644
index 000000000..d359962e3
--- /dev/null
+++ b/test-tools/IoT-APP-Store-Demo/wasm_django/static/js/application.js
@@ -0,0 +1,228 @@
+/* Copyright (C) 2019 Intel Corporation. All rights reserved.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+/*
+ * Dom Location
+ *
+ */
+
+ function setDivCenter(divname)
+// make qn element center aligned
+ {
+ var Top =($(window).height()-$(divname).height())/2;
+ var Left = ($(window).width()-$(divname).width())/2;
+ var scrollTop = $(document).scrollTop();
+ var scrollLeft = $(document).scrollLeft();
+ $(divname).css({posisiton:'absolute','top':Top+scrollTop,'left':Left+scrollLeft});
+
+};
+
+setDivCenter(".middlebox");
+setDivCenter(".deletebox");
+
+function setmain(divname){
+// Set the pop-up window of apps for download at the right place
+ var x = $('#btn').offset().top;
+ var Top = x + $('#btn').height()+15;
+ var y = $('#btn').offset().left;
+ var Left = y + ($('#btn').width()/2)-($(divname).width()/2);
+ console.log(Top,Left)
+ $(divname).css({'top':Top,'left':Left});
+}
+setmain(".main")
+
+/*
+ * download apps
+ *
+ */
+
+function getthis(val)
+//Telling background which app to be loaded from appstore_list and to be installed in the current device.
+{
+
+ /* Get the ip adress and the port of a device, as well as the application ID to be downloaded on this device*/
+ var ip,port,name,version;
+ var ipArr=$("#IPs").text().split(":");
+ ip=ipArr[1];
+ var portArr=$("#ports").text().split(":");
+ port=portArr[1];
+ name = $(val).parent().find("#appsinfo1").text().split(":")[1];
+ version = $(val).parent().find("#appsinfo2").text().split(":")[1];
+ $(".main").fadeOut();
+
+ for (num in alist){
+ if (alist[num]['pname'].trim() == name.trim())
+ {alert("This app has been downloaded.");
+ return;}};
+ $("#loading").fadeIn();
+ var sNode = document.getElementById("APPS");
+ var tempNode= sNode.cloneNode(true);
+ sNode.parentNode.appendChild(tempNode);
+ $("#appinfo1").html("Product Name : "+ name);
+ $("#appinfo2").html("Status : "+"Installing");
+ $("#appinfo3").html("Current_Version : "+ version);
+
+ $.get("/appDownload/",{'ip':ip.trim(),'port':port.trim(),'name':name.trim(),},function (ret) {
+ var status = $.trim(ret.split(":")[1].split("}")[0]);
+ $(".loadapp").html(name+" is downloading now");
+ var msg = JSON.parse(status)
+ console.log(msg)
+ if (JSON.parse(status)=="ok"){
+ $(".middlebox").fadeIn();
+ $(".sourceapp").fadeOut();
+ $("#loading").fadeOut();
+ $(".findapp").html("Download "+name +" successfully");
+ $(".surebtn").click(function (){
+ $(".middlebox").fadeOut();
+ window.location.reload();
+ })}
+ else if (JSON.parse(status)=="Fail!"){
+ alert("Download failed!");
+ $("#loading").fadeOut();
+ sNode.remove();
+ }
+ else {
+ alert("Install app failed:" + msg)
+ $("#loading").fadeOut();
+ sNode.remove();
+ }
+ })
+};
+
+window.onload = function clone()
+//Add & Delete apps to the device.
+{
+ /*Install Apps*/
+ var sourceNode = document.getElementById("APPS");
+ if (alist.length != 0)
+ {
+ $("#appinfo1").html("Product Name : "+ alist[0]['pname']);
+ $("#appinfo2").html("Status : "+ alist[0]['status']);
+ $("#appinfo3").html("Current_Version : "+ alist[0]['current_version']);
+ $("#delete").attr('class','delet0');
+ $("#APPS").attr('class','app0');
+
+ for (var i=1; i
+
+
+
+
+
+
+
+
IP :
+ Port :
+ Installed apps :
+
+
+
+ 
+