mirror of
https://github.com/1f349/lotus.git
synced 2024-12-22 08:04:06 +00:00
Better list messages encoding
This commit is contained in:
parent
31186402f7
commit
dfc74925cd
1
.gitignore
vendored
1
.gitignore
vendored
@ -1,3 +1,4 @@
|
|||||||
*.sqlite
|
*.sqlite
|
||||||
*.local
|
*.local
|
||||||
.data
|
.data
|
||||||
|
.idea/
|
||||||
|
@ -3,7 +3,9 @@ package api
|
|||||||
import (
|
import (
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"github.com/1f349/lotus/imap"
|
"github.com/1f349/lotus/imap"
|
||||||
|
json2 "github.com/1f349/lotus/imap/json"
|
||||||
"github.com/julienschmidt/httprouter"
|
"github.com/julienschmidt/httprouter"
|
||||||
|
"log"
|
||||||
"net/http"
|
"net/http"
|
||||||
"time"
|
"time"
|
||||||
)
|
)
|
||||||
@ -37,7 +39,10 @@ func SetupApiServer(listen string, auth func(callback AuthCallback) httprouter.H
|
|||||||
rw.WriteHeader(http.StatusForbidden)
|
rw.WriteHeader(http.StatusForbidden)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
_ = json.NewEncoder(rw).Encode(messages)
|
err = json.NewEncoder(rw).Encode(json2.ListMessagesJson(messages))
|
||||||
|
if err != nil {
|
||||||
|
log.Println("list-messages json encode error:", err)
|
||||||
|
}
|
||||||
})))
|
})))
|
||||||
r.GET("/search-messages", auth(imapClient(recv, func(rw http.ResponseWriter, req *http.Request, params httprouter.Params, cli *imap.Client, t statusJson) {
|
r.GET("/search-messages", auth(imapClient(recv, func(rw http.ResponseWriter, req *http.Request, params httprouter.Params, cli *imap.Client, t statusJson) {
|
||||||
status, err := cli.Status(t.Folder)
|
status, err := cli.Status(t.Folder)
|
||||||
|
36
imap/json/list-messages.go
Normal file
36
imap/json/list-messages.go
Normal file
@ -0,0 +1,36 @@
|
|||||||
|
package json
|
||||||
|
|
||||||
|
import (
|
||||||
|
"encoding/json"
|
||||||
|
"github.com/emersion/go-imap"
|
||||||
|
)
|
||||||
|
|
||||||
|
type ListMessagesJson []*imap.Message
|
||||||
|
|
||||||
|
func (l ListMessagesJson) MarshalJSON() ([]byte, error) {
|
||||||
|
a := make([]encodeImapMessage, len(l))
|
||||||
|
for i := range a {
|
||||||
|
a[i] = encodeImapMessage(*l[i])
|
||||||
|
}
|
||||||
|
return json.Marshal(a)
|
||||||
|
}
|
||||||
|
|
||||||
|
type encodeImapMessage imap.Message
|
||||||
|
|
||||||
|
func (e encodeImapMessage) MarshalJSON() ([]byte, error) {
|
||||||
|
body := make(map[string]imap.Literal, len(e.Body))
|
||||||
|
for k, v := range e.Body {
|
||||||
|
body[string(k.FetchItem())] = v
|
||||||
|
}
|
||||||
|
return json.Marshal(map[string]any{
|
||||||
|
"SeqNum": e.SeqNum,
|
||||||
|
"Items": e.Items,
|
||||||
|
"Envelope": e.Envelope,
|
||||||
|
"BodyStructure": e.BodyStructure,
|
||||||
|
"Flags": e.Flags,
|
||||||
|
"InternalDate": e.InternalDate,
|
||||||
|
"Size": e.Size,
|
||||||
|
"Uid": e.Uid,
|
||||||
|
"$Body": body,
|
||||||
|
})
|
||||||
|
}
|
Loading…
Reference in New Issue
Block a user