优个化吧

docs/protocol_fs.md

@@ -124,33 +124,8 @@
 ```
 
 
-##  7、查看磁盘列表
-```json5
-{
-  "module": "fs",
-  "command": "disk",
-}
-```
-
-响应
-
-```json5
-{
-  "result": "ok/fail",  //结果
-  "reason": "",  //错误原因
-  "data": [
-    {
-      "disk": "/sd0",
-      "total": 1300000,
-      "used": 100232,
-      "free": 1200030,
-    }
-  ]
-}
-```
-
 
-##  8、格式化
+##  7、格式化
 ```json5
 {
   "module": "fs",

rpc/client.go

@@ -9,6 +9,8 @@ import (
 	"net/url"
 )
 
+const CLIENT_BUFFER_SIZE = 1024
+
 type Client struct {
 	Url string
 
@@ -17,6 +19,10 @@ type Client struct {
 	id       uint16
 	conn     net.Conn
 	requests map[uint16]any
+
+	inHeader  [8]byte
+	outHeader [8]byte
+	buffer    [CLIENT_BUFFER_SIZE]byte
 }
 
 func (c *Client) Write(pack *Pack) error {
@@ -54,7 +60,13 @@ func (c *Client) receive() {
 
 		l := int(binary.BigEndian.Uint16(buf[6:])) //长度
 		if l > 0 {
-			b := make([]byte, l)
+			var b []byte
+			if l > CLIENT_BUFFER_SIZE {
+				b = make([]byte, l)
+			} else {
+				b = c.buffer[:] //使用默认buffer
+			}
+
 			//_ = c.conn.SetReadDeadline(time.Now().Add(time.Second * 30))
 			n, err = io.ReadAtLeast(c.conn, b, l)
 			if err != nil {

rpc/device.go

@@ -0,0 +1,46 @@
+package rpc
+
+type DeviceId struct {
+	Id string `json:"id"`
+}
+
+type DeviceItem struct {
+	Id        string         `json:"id"`
+	Name      string         `json:"name"`
+	ProductId string         `json:"product_id"`
+	Station   map[string]any `json:"station,omitempty"`
+}
+
+type DeviceListResponse []DeviceItem
+
+type DeviceCreateRequest DeviceItem
+
+type DeviceDeleteRequest DeviceId
+
+type DevicePropertyRequest struct {
+	Id         string         `json:"id"`
+	ProductId  string         `json:"product_id,omitempty"`
+	Properties map[string]any `json:"properties"`
+}
+
+type DevicePropertyModifyRequest struct {
+	Id         string         `json:"id"`
+	Properties map[string]any `json:"properties"`
+}
+
+type DeviceEventRequest struct {
+	Id    string `json:"id"`
+	Name  string `json:"name,omitempty"`
+	Type  string `json:"type,omitempty"`
+	Level int    `json:"level,omitempty"`
+}
+
+type DeviceActionRequest struct {
+	Id         string         `json:"id"`
+	Name       string         `json:"name"`
+	Parameters map[string]any `json:"parameters"`
+}
+
+type DeviceActionResponse struct {
+	Return map[string]any `json:"return,omitempty"`
+}

rpc/fs.go

@@ -0,0 +1,44 @@
+package rpc
+
+type FsPath struct {
+	Path string `json:"path"`
+}
+
+type FsPathMove struct {
+	Path string `json:"path"`
+	Move string `json:"move"`
+}
+
+type FsItem struct {
+	Name string `json:"name"`
+	Dir  bool   `json:"dir,omitempty"`
+	Size int64  `json:"size,omitempty"`
+	Time int64  `json:"time,omitempty"`
+}
+
+type FsStream struct {
+	Stream uint16 `json:"stream"`
+}
+
+type FsSearchRequest FsPath
+
+type FsSearchResponse []FsItem
+
+type FsDownloadRequest FsPath
+
+type FsDownloadResponse FsStream
+
+type FsUploadRequest FsPath
+
+type FsUploadResponse FsStream
+
+type FsDeleteRequest FsPath
+
+type FsMoveRequest FsPathMove
+
+type FsMakeDirectoryRequest FsPath
+
+type FsFormatRequest struct {
+	Disk string `json:"disk"`
+	Type string `json:"type"`
+}

rpc/pack.go

@@ -68,6 +68,33 @@ func RegisterEncoding(typ uint8, encoder Encoder, decoder Decoder) {
 	decoders[typ] = decoder
 }
 
+type Connect struct {
+	Username string `json:"username"`
+	Password string `json:"password"`
+}
+
+type ConnectAgain struct {
+	Id    string `json:"id"`
+	Token string `json:"token"`
+}
+
+type ConnectAck struct {
+	Id    string `json:"id"`
+	Token string `json:"token"`
+}
+
+type Request[T any] struct {
+	Module  string `json:"module"`
+	Command string `json:"command"`
+	Data    T      `json:"data,omitempty"`
+}
+
+type Response[T any] struct {
+	Result string `json:"result"`
+	Reason string `json:"reason,omitempty"`
+	Data   T      `json:"data,omitempty"`
+}
+
 type Pack struct {
 	Type     uint8
 	Encoding uint8

rpc/payload.go

@@ -0,0 +1 @@
+package rpc