import (
"github.com/mokejp/linebotapi"
...
)// LINE Bot credential
cred := &linebotapi.Credential{
ChannelId: 1234, // Your Channel ID
ChannelSecret: "****", // Your Channel Secret
Mid: "****", // Your MID
}
// Parse request from Bot API Server
events, err := linebotapi.ParseRequest(req, cred)
if err != nil {
panic(err)
}
for _, event := range events {
// Get event content
content := event.GetEventContent()
if content.IsOperation { // operation event
if content.OpType == linebotapi.OpTypeAdded {
// Added user event
} else if content.OpType == linebotapi.OpTypeBlocked {
// Blocked user event
}
} else if content.IsMessage { // message event
if content.ContentType == linebotapi.ContentTypeText {
// text message
msg, err := content.GetMessageText() // Get text
if err != nil {
panic(err)
}
fmt.Printf(msg.Text)
}
}
}// LINE Bot credential
cred := &linebotapi.Credential{
ChannelId: 1234, // Your Channel ID
ChannelSecret: "****", // Your Channel Secret
Mid: "****", // Your MID
}
// initialize bot API client
client := linebotapi.NewClient(cred)
/*
// For GAE
client.HttpClient = &http.Client{
Transport: &urlfetch.Transport{
Context: c,
},
}
*/
// Send a text message
err = client.SendText([]string{"target mid"}, "Hello!")
if err != nil {
panic(err)
}
// Send multiple messages
err = client.SendMessages([]string{"target mid"},
[]linebotapi.MessageContent{linebotapi.NewMessageText("Hello!"), linebotapi.NewMessageText("Goodbye!")}, 0)package linebotapi_gae
import (
"github.com/mokejp/linebotapi"
"fmt"
"io/ioutil"
"net/http"
"net/http/httputil"
"google.golang.org/appengine"
"google.golang.org/appengine/log"
"google.golang.org/appengine/urlfetch"
)
func init() {
http.HandleFunc("/callback", handler)
}
func handler(w http.ResponseWriter, r *http.Request) {
c := appengine.NewContext(r)
// LINE Bot credential
cred := &linebotapi.Credential{
ChannelId: ****, // Your Channel ID
ChannelSecret: "****", // Your Channel Secret
Mid: "****", // Your MID
}
// Parse request body
dump, err := httputil.DumpRequest(r, true)
log.Debugf(c, string(dump))
result, err := linebotapi.ParseRequest(r, cred)
if err != nil {
panic(err)
}
// initialize bot API client
client := linebotapi.NewClient(cred)
client.HttpClient = &http.Client{
Transport: &urlfetch.Transport{
Context: c,
},
}
// Process received messages
var messages = make(map[string][]*linebotapi.MessageContent)
for _, event := range result {
content := event.GetEventContent()
_, exists := messages[content.From]
if !exists {
messages[content.From] = make([]*linebotapi.MessageContent, 0)
}
if content.IsOperation {
// Operation Event
if content.OpType == linebotapi.OpTypeAdded {
// Added friend
messages[content.From] = append(messages[content.From], linebotapi.NewMessageText("Thank you!"));
}
} else {
if content.ContentType == linebotapi.ContentTypeText {
// Text Message
msg, err := content.GetMessageText()
if err != nil {
panic(err)
}
messages[content.From] = append(messages[content.From], linebotapi.NewMessageText(msg.Text));
} else if (content.ContentType == linebotapi.ContentTypeImage) {
// Image Message
_, err := content.GetMessageImage()
if err != nil {
panic(err)
}
data, err := client.GetMessageContent(content)
if err != nil {
panic(err)
}
defer data.Reader.Close()
// io.Reader to byte[]
buf, err := ioutil.ReadAll(data.Reader)
if err != nil {
panic(err)
}
messages[content.From] = append(messages[content.From], linebotapi.NewMessageText(fmt.Sprintf("Type: %s Length: %d", data.ContentType, len(buf))));
} else if (content.ContentType == linebotapi.ContentTypeVideo) {
// Video Message
_, err := content.GetMessageVideo()
if err != nil {
panic(err)
}
data, err := client.GetMessageContent(content)
if err != nil {
panic(err)
}
defer data.Reader.Close()
// io.Reader to byte[]
buf, err := ioutil.ReadAll(data.Reader)
if err != nil {
panic(err)
}
messages[content.From] = append(messages[content.From], linebotapi.NewMessageText(fmt.Sprintf("Type: %s Length: %d", data.ContentType, len(buf))));
} else if (content.ContentType == linebotapi.ContentTypeAudio) {
// Audio Message
_, err := content.GetMessageAudio()
if err != nil {
panic(err)
}
data, err := client.GetMessageContent(content)
if err != nil {
panic(err)
}
defer data.Reader.Close()
// io.Reader to byte[]
buf, err := ioutil.ReadAll(data.Reader)
if err != nil {
panic(err)
}
messages[content.From] = append(messages[content.From], linebotapi.NewMessageText(fmt.Sprintf("Type: %s Length: %d", data.ContentType, len(buf))));
} else if (content.ContentType == linebotapi.ContentTypeLocation) {
// Location Message
msg, err := content.GetMessageLocation()
if err != nil {
panic(err)
}
messages[content.From] = append(messages[content.From], linebotapi.NewMessageLocation(msg.Text, msg.Title, msg.Latitude, msg.Longitude));
} else if (content.ContentType == linebotapi.ContentTypeSticker) {
// Sticker Message
msg, err := content.GetMessageSticker()
if err != nil {
panic(err)
}
messages[content.From] = append(messages[content.From], linebotapi.NewMessageSticker(msg.StickerPackageId, msg.StickerId, ""));
} else if (content.ContentType == linebotapi.ContentTypeContact) {
// Contact Message
msg, err := content.GetMessageContact()
if err != nil {
panic(err)
}
messages[content.From] = append(messages[content.From], linebotapi.NewMessageText(fmt.Sprintf("mid: %s displayName: %s", msg.Mid, msg.DisplayName)));
}
}
}
for k := range messages {
contacts, err := client.GetUserProfiles([]string{k})
if err != nil {
panic(err)
}
messages[k] = append(messages[k], linebotapi.NewMessageText(fmt.Sprintf("Hello, %s", contacts.Contacts[0].DisplayName)));
err = client.SendMessages([]string{k}, messages[k], 0)
if err != nil {
panic(err)
}
}
}mokejp
MIT