初始化项目

Author: leeight

.gitignore

@@ -0,0 +1,4 @@
+node_modules
+main
+parser
+sqlite3

README.md

@@ -0,0 +1,40 @@
+nodejs 还是 golang 呢？
+
+如果使用 golang，可以顺便熟悉这种语言，而且 golang 内置了 smtp 的库，不需要依赖第三方的东东了
+
+发送邮件
+http://golang.org/pkg/net/smtp/
+
+解析邮件的内容（支持附件么？）
+http://golang.org/pkg/net/mail/
+
+数据结构的设计：
+
+  Thread
+    Message 1
+    Message 2
+    ...
+    Message N
+
+  Message
+    List<Header>
+    Body
+    List<Attachment>
+
+  Header
+    Key
+    Value
+
+  Raw
+
+Message-Id
+
+Thread-Topic
+Thread-Index
+
+
+一些规范的阅读
+
+rfc 2045
+rfc 2047
+http://en.wikipedia.org/wiki/Post_Office_Protocol

RFC2047/LICENSE

@@ -0,0 +1,19 @@
+Copyright (c) 2013 Fam Zheng <[email protected]>
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in
+all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+THE SOFTWARE.

RFC2047/README.md

@@ -0,0 +1,29 @@
+RFC2047 for Go
+==============
+An RFC2047 Decoder package for Golang
+
+Usage
+-----
+
+Just import "github.com/famz/RFC2047", then call "RFC2047.Decode" with your
+encoded string and get it decoded! See below for an example.
+
+Install
+-------
+
+Simple as `go get github.com/famz/RFC2047`
+
+Example
+-------
+
+```go
+package main
+import (
+    "github.com/famz/RFC2047"
+    "fmt"
+)
+
+func main() {
+    fmt.Println(RFC2047.Decode("=?UTF-8?B?5YmN5Y+w5pyJ5L2g5L+h?="))
+}
+```

RFC2047/RFC2047.go

@@ -0,0 +1,115 @@
+package RFC2047
+
+import (
+    "io"
+    "io/ioutil"
+    "strings"
+    "encoding/base64"
+    "errors"
+    "fmt"
+    "bytes"
+    "strconv"
+
+    "github.com/qiniu/iconv"
+)
+
+type qDecoder struct {
+    r       io.Reader
+    scratch [2]byte
+}
+
+func (qd qDecoder) Read(p []byte) (n int, err error) {
+    // This method writes at most one byte into p.
+    if len(p) == 0 {
+        return 0, nil
+    }
+    if _, err := qd.r.Read(qd.scratch[:1]); err != nil {
+        return 0, err
+    }
+    switch c := qd.scratch[0]; {
+    case c == '=':
+        if _, err := io.ReadFull(qd.r, qd.scratch[:2]); err != nil {
+            return 0, err
+        }
+        x, err := strconv.ParseInt(string(qd.scratch[:2]), 16, 64)
+        if err != nil {
+            return 0, fmt.Errorf("mail: invalid RFC 2047 encoding: %q", qd.scratch[:2])
+        }
+        p[0] = byte(x)
+    case c == '_':
+        p[0] = ' '
+    default:
+        p[0] = c
+    }
+    return 1, nil
+}
+
+func decodeRFC2047Word(s string) (string, error) {
+    fields := strings.Split(s, "?")
+    if len(fields) != 5 || fields[0] != "=" || fields[4] != "=" {
+        return "", errors.New("string not RFC 2047 encoded")
+    }
+    charset, enc := strings.ToLower(fields[1]), strings.ToLower(fields[2])
+    if charset != "iso-8859-1" &&
+       charset != "utf-8" &&
+       charset != "gb2312" &&
+       charset != "gbk" {
+        return "", fmt.Errorf("charset not supported: %q", charset)
+    }
+
+    in := bytes.NewBufferString(fields[3])
+    var r io.Reader
+    switch enc {
+    case "b":
+        r = base64.NewDecoder(base64.StdEncoding, in)
+    case "q":
+        r = qDecoder{r: in}
+    default:
+        return "", fmt.Errorf("RFC 2047 encoding not supported: %q", enc)
+    }
+
+    dec, err := ioutil.ReadAll(r)
+    if err != nil {
+        return "", err
+    }
+
+    switch charset {
+    case "iso-8859-1":
+        b := new(bytes.Buffer)
+        for _, c := range dec {
+            b.WriteRune(rune(c))
+        }
+        return b.String(), nil
+    case "gbk":
+        cd, err := iconv.Open("utf-8", "gbk")
+        if err != nil {
+            return "", err
+        }
+        defer cd.Close()
+        return cd.ConvString(string(dec)), nil
+    case "gb2312":
+        cd, err := iconv.Open("utf-8", "gb2312")
+        if err != nil {
+            return "", err
+        }
+        defer cd.Close()
+        return cd.ConvString(string(dec)), nil
+    case "utf-8":
+        return string(dec), nil
+    }
+    panic("unreachable")
+}
+
+func Decode(s string) (ret string) {
+    sep := ""
+    for _, p := range strings.Split(s, " ") {
+        r, err := decodeRFC2047Word(p)
+        if err != nil {
+            ret += sep + p
+        } else {
+            ret += sep + r
+        }
+        sep = " "
+    }
+    return
+}

base/parser.go

@@ -0,0 +1,45 @@
+package base
+
+import (
+  "strings"
+  "regexp"
+
+  "../RFC2047"
+)
+
+// 工具类
+// Content-Disposition: attachment;
+//        filename="=?gb2312?B?ob7Wqsq2zca546G/OC4yMcjrv9q/qs2ow/u1pS54bHN4?=";
+//        size=14296; creation-date="Thu, 21 Aug 2014 11:17:27 GMT";
+//        modification-date="Thu, 21 Aug 2014 11:19:56 GMT"
+
+func ParseContentDisposition(cd string) (map[string]string) {
+  var r = regexp.MustCompile(`^"|"$`)
+
+  rv := make(map[string]string)
+  for _, item := range strings.Split(cd, "; ") {
+    var key string
+    var value string
+
+    chunks := strings.SplitN(item, "=", 2)
+    key = chunks[0]
+
+    if len(chunks) == 1 {
+      value = key
+    } else if len(chunks) == 2 {
+      value = chunks[1]
+    }
+
+    if strings.HasPrefix(value, "\"") {
+      value = string(r.ReplaceAll([]byte(value), []byte("")))
+    }
+
+    if key == "filename" {
+      value = RFC2047.Decode(value)
+    }
+
+    rv[key] = value
+  }
+
+  return rv
+}

base/parser_test.go

@@ -0,0 +1,26 @@
+package base_test
+
+import (
+  "testing"
+
+  "../base"
+)
+
+func TestParseContentDisposition(t *testing.T) {
+  rv := base.ParseContentDisposition("hello")
+  if rv["hello"] != "hello" {
+    t.Errorf("base.ParseContentDisposition(%s): expected %s, actual %s",
+      "hello", "hello", rv["hello"])
+  }
+
+
+  expected := "【知识推广】8.21入口开通名单.xlsx"
+  input := "attachment; filename=\"=?gb2312?B?ob7Wqsq2zca546G/OC4yMcjrv9q/qs2ow/u1pS54bHN4?=\"; size=14296; creation-date=\"Thu, 21 Aug 2014 11:17:27 GMT\"; modification-date=\"Thu, 21 Aug 2014 11:19:56 GMT\""
+
+  rv = base.ParseContentDisposition(input)
+
+  if rv["filename"] != expected {
+    t.Errorf("base.ParseContentDisposition(%s): expected %s, actual %s",
+      input, expected, rv["filename"])
+  }
+}

main.go

@@ -0,0 +1,52 @@
+package main
+
+import (
+    "log"
+    "net/mail"
+    "bytes"
+    "io/ioutil"
+    pop3 "github.com/bytbox/go-pop3"
+)
+
+func main() {
+    client, err := pop3.DialTLS("email.baidu.com:995")
+    if err != nil { panic(err) }
+
+    err = client.Auth("liyubei", "zhenxixiaohui@^@262")
+    if err != nil { panic(err) }
+
+    count, size, err := client.Stat()
+    if err != nil { panic(err) }
+
+    log.Printf("Count = %d, Size = %d\n", count, size)
+
+    size, err = client.List(10)
+    if err != nil { panic(err) }
+
+    log.Println(size)
+
+    raw, err := client.Retr(count)
+    if err != nil { panic(err) }
+
+    ioutil.WriteFile("raw.txt", []byte(raw), 0644)
+
+    log.Println(raw)
+    msg, err := mail.ReadMessage(bytes.NewBuffer([]byte(raw)))
+    if err != nil { panic(err) }
+
+    log.Println(msg.Header)
+    log.Println(msg.Header.Get("From"))
+    log.Println(msg.Header.Get("Subject"))
+
+    address, err := mail.ParseAddress(msg.Header.Get("From"))
+    // if err != nil { panic(err) }
+
+    log.Println(address.Name)
+    log.Println(address.Address)
+
+    body, err := ioutil.ReadAll(msg.Body)
+    if err != nil { panic(err) }
+
+    log.Println(string(body))
+}
+