mirror of
https://github.com/pocketpy/pocketpy
synced 2025-10-20 19:40:18 +00:00
up
This commit is contained in:
parent
f4fe849432
commit
8a99b0779b
6
.gitignore
vendored
6
.gitignore
vendored
@ -1,13 +1,7 @@
|
|||||||
# Byte-compiled / optimized / DLL files
|
|
||||||
__pycache__/
|
__pycache__/
|
||||||
*.py[cod]
|
|
||||||
*$py.class
|
|
||||||
|
|
||||||
.vscode
|
.vscode
|
||||||
.ipynb_checkpoints
|
.ipynb_checkpoints
|
||||||
|
|
||||||
__pypackages__/
|
|
||||||
|
|
||||||
src/main
|
src/main
|
||||||
gmon.out
|
gmon.out
|
||||||
gprof.txt
|
gprof.txt
|
||||||
|
18
plugins/unity/com.bl.pocketpy/JsonRpcServer.cs
Normal file
18
plugins/unity/com.bl.pocketpy/JsonRpcServer.cs
Normal file
@ -0,0 +1,18 @@
|
|||||||
|
using System.Collections;
|
||||||
|
using System.Collections.Generic;
|
||||||
|
using UnityEngine;
|
||||||
|
|
||||||
|
public class JsonRpcServer : MonoBehaviour
|
||||||
|
{
|
||||||
|
// Start is called before the first frame update
|
||||||
|
void Start()
|
||||||
|
{
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
// Update is called once per frame
|
||||||
|
void Update()
|
||||||
|
{
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
@ -1,5 +1,5 @@
|
|||||||
fileFormatVersion: 2
|
fileFormatVersion: 2
|
||||||
guid: dd15753450212f045aa08d30ba3cca6e
|
guid: dd8671c697ad3c0489bc4da5b471619b
|
||||||
MonoImporter:
|
MonoImporter:
|
||||||
externalObjects: {}
|
externalObjects: {}
|
||||||
serializedVersion: 2
|
serializedVersion: 2
|
@ -1,207 +0,0 @@
|
|||||||
using System;
|
|
||||||
using System.Runtime.InteropServices;
|
|
||||||
using UnityEngine;
|
|
||||||
|
|
||||||
namespace pkpy
|
|
||||||
{
|
|
||||||
public static class Bindings
|
|
||||||
{
|
|
||||||
#if UNITY_IOS
|
|
||||||
private const string _libName = "__Internal";
|
|
||||||
#else
|
|
||||||
private const string _libName = "pocketpy";
|
|
||||||
#endif
|
|
||||||
[DllImport(_libName)]
|
|
||||||
internal static extern void pkpy_delete(IntPtr p);
|
|
||||||
[DllImport(_libName)]
|
|
||||||
internal static extern IntPtr pkpy_new_repl(IntPtr vm);
|
|
||||||
[DllImport(_libName)]
|
|
||||||
internal static extern int pkpy_repl_input(IntPtr r, string line);
|
|
||||||
[DllImport(_libName)]
|
|
||||||
internal static extern IntPtr pkpy_new_tvm(bool use_stdio);
|
|
||||||
[DllImport(_libName)]
|
|
||||||
internal static extern bool pkpy_tvm_exec_async(IntPtr vm, string source);
|
|
||||||
[DllImport(_libName)]
|
|
||||||
internal static extern int pkpy_tvm_get_state(IntPtr vm);
|
|
||||||
[DllImport(_libName)]
|
|
||||||
internal static extern string pkpy_tvm_read_jsonrpc_request(IntPtr vm);
|
|
||||||
[DllImport(_libName)]
|
|
||||||
internal static extern void pkpy_tvm_reset_state(IntPtr vm);
|
|
||||||
[DllImport(_libName)]
|
|
||||||
internal static extern void pkpy_tvm_terminate(IntPtr vm);
|
|
||||||
[DllImport(_libName)]
|
|
||||||
internal static extern void pkpy_tvm_write_jsonrpc_response(IntPtr vm, string value);
|
|
||||||
[DllImport(_libName)]
|
|
||||||
internal static extern IntPtr pkpy_new_vm(bool use_stdio);
|
|
||||||
[DllImport(_libName)]
|
|
||||||
internal static extern bool pkpy_vm_add_module(IntPtr vm, string name, string source);
|
|
||||||
[DllImport(_libName)]
|
|
||||||
internal static extern string pkpy_vm_eval(IntPtr vm, string source);
|
|
||||||
[DllImport(_libName)]
|
|
||||||
internal static extern bool pkpy_vm_exec(IntPtr vm, string source);
|
|
||||||
[DllImport(_libName)]
|
|
||||||
internal static extern string pkpy_vm_get_global(IntPtr vm, string name);
|
|
||||||
[DllImport(_libName)]
|
|
||||||
internal static extern string pkpy_vm_read_output(IntPtr vm);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
namespace pkpy
|
|
||||||
{
|
|
||||||
public struct PyOutput
|
|
||||||
{
|
|
||||||
public string stdout;
|
|
||||||
public string stderr;
|
|
||||||
|
|
||||||
public PyOutput(string stdout, string stderr)
|
|
||||||
{
|
|
||||||
this.stdout = stdout;
|
|
||||||
this.stderr = stderr;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public class VM
|
|
||||||
{
|
|
||||||
public IntPtr pointer { get; private set; }
|
|
||||||
|
|
||||||
public VM()
|
|
||||||
{
|
|
||||||
if(this is ThreadedVM)
|
|
||||||
{
|
|
||||||
pointer = Bindings.pkpy_new_tvm(false);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
pointer = Bindings.pkpy_new_vm(false);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public PyOutput read_output()
|
|
||||||
{
|
|
||||||
var _o = Bindings.pkpy_vm_read_output(pointer);
|
|
||||||
return JsonUtility.FromJson<PyOutput>(_o);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void dispose()
|
|
||||||
{
|
|
||||||
Bindings.pkpy_delete(pointer);
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Add a source module into a virtual machine. Return `true` if there is no complie error.
|
|
||||||
/// </summary>
|
|
||||||
public bool add_module(string name, string source)
|
|
||||||
{
|
|
||||||
return Bindings.pkpy_vm_add_module(pointer, name, source);
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Evaluate an expression. Return a json representing the result. If there is any error, return `nullptr`.
|
|
||||||
/// </summary>
|
|
||||||
public string eval(string source)
|
|
||||||
{
|
|
||||||
return Bindings.pkpy_vm_eval(pointer, source);
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Run a given source on a virtual machine. Return `true` if there is no compile error.
|
|
||||||
/// </summary>
|
|
||||||
public bool exec(string source)
|
|
||||||
{
|
|
||||||
return Bindings.pkpy_vm_exec(pointer, source);
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Get a global variable of a virtual machine. Return a json representing the result. If the variable is not found, return `nullptr`.
|
|
||||||
/// </summary>
|
|
||||||
public string get_global(string name)
|
|
||||||
{
|
|
||||||
return Bindings.pkpy_vm_get_global(pointer, name);
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
public enum ThreadState
|
|
||||||
{
|
|
||||||
ready = 0,
|
|
||||||
running,
|
|
||||||
suspended,
|
|
||||||
finished
|
|
||||||
}
|
|
||||||
|
|
||||||
public class ThreadedVM : VM
|
|
||||||
{
|
|
||||||
public ThreadState state => (ThreadState)Bindings.pkpy_tvm_get_state(pointer);
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Run a given source on a threaded virtual machine. The excution will be started in a new thread. Return `true` if there is no compile error.
|
|
||||||
/// </summary>
|
|
||||||
public bool exec_async(string source)
|
|
||||||
{
|
|
||||||
return Bindings.pkpy_tvm_exec_async(pointer, source);
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Read the current JSONRPC request from shared string buffer.
|
|
||||||
/// </summary>
|
|
||||||
public string read_jsonrpc_request()
|
|
||||||
{
|
|
||||||
return Bindings.pkpy_tvm_read_jsonrpc_request(pointer);
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Set the state of a threaded virtual machine to `THREAD_READY`. The current state should be `THREAD_FINISHED`.
|
|
||||||
/// </summary>
|
|
||||||
public void reset_state()
|
|
||||||
{
|
|
||||||
Bindings.pkpy_tvm_reset_state(pointer);
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Emit a KeyboardInterrupt signal to stop a running threaded virtual machine.
|
|
||||||
/// </summary>
|
|
||||||
public void terminate()
|
|
||||||
{
|
|
||||||
Bindings.pkpy_tvm_terminate(pointer);
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Write a JSONRPC response to shared string buffer.
|
|
||||||
/// </summary>
|
|
||||||
public void write_jsonrpc_response(string value)
|
|
||||||
{
|
|
||||||
Bindings.pkpy_tvm_write_jsonrpc_response(pointer, value);
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
namespace pkpy
|
|
||||||
{
|
|
||||||
public class REPL
|
|
||||||
{
|
|
||||||
public IntPtr pointer { get; private set; }
|
|
||||||
public VM vm { get; private set; }
|
|
||||||
|
|
||||||
public REPL(VM vm)
|
|
||||||
{
|
|
||||||
this.vm = vm;
|
|
||||||
pointer = Bindings.pkpy_new_repl(vm.pointer);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void dispose()
|
|
||||||
{
|
|
||||||
Bindings.pkpy_delete(pointer);
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// Input a source line to an interactive console. Return `0` if need more lines, `1` if execution happened, `2` if execution skipped (compile error or empty input).
|
|
||||||
/// </summary>
|
|
||||||
public int input(string line)
|
|
||||||
{
|
|
||||||
return Bindings.pkpy_repl_input(pointer, line);
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
Loading…
x
Reference in New Issue
Block a user