feat: room invitation

Author: dchaofei

wechaty-puppet/schemas/room_invitation.go

@@ -5,6 +5,7 @@ import "time"
 type RoomInvitationPayload struct {
 	Id           string    `json:"id"`
 	InviterId    string    `json:"inviterId"`
+	RoomId       string    `json:"roomId"`
 	Topic        string    `json:"topic"`
 	Avatar       string    `json:"avatar"`
 	Invitation   string    `json:"invitation"`

wechaty/interface/room_invitation.go

@@ -1,8 +1,9 @@
 package _interface
 
 import (
-	"github.com/wechaty/go-wechaty/wechaty-puppet/schemas"
 	"time"
+
+	"github.com/wechaty/go-wechaty/wechaty-puppet/schemas"
 )
 
 type IRoomInvitationFactory interface {
@@ -16,10 +17,12 @@ type IRoomInvitation interface {
 	ToStringAsync() (string, error)
 	Accept() error
 	Inviter() (IContact, error)
+	Room() (IRoom, error)
 	Topic() (string, error)
 	MemberCount() (int, error)
 	MemberList() ([]IContact, error)
 	Date() (time.Time, error)
 	Age() (time.Duration, error)
 	ToJson() (string, error)
+	RawPayload() (schemas.RoomInvitationPayload, error)
 }

wechaty/user/room_invitation.go

@@ -5,6 +5,7 @@ import (
 	"fmt"
 	"time"
 
+	"github.com/wechaty/go-wechaty/wechaty-puppet/schemas"
 	_interface "github.com/wechaty/go-wechaty/wechaty/interface"
 )
 
@@ -98,6 +99,15 @@ func (ri *RoomInvitation) MemberList() ([]_interface.IContact, error) {
 	return contactList, nil
 }
 
+// Room get the room from room invitation
+func (ri *RoomInvitation) Room() (_interface.IRoom, error) {
+	payload, err := ri.GetPuppet().RoomInvitationPayload(ri.id)
+	if err != nil {
+		return nil, err
+	}
+	return ri.GetWechaty().Room().Load(payload.RoomId), nil
+}
+
 // Date get the invitation time
 func (ri *RoomInvitation) Date() (time.Time, error) {
 	payload, err := ri.GetPuppet().RoomInvitationPayload(ri.id)
@@ -124,3 +134,12 @@ func (ri *RoomInvitation) ToJson() (string, error) {
 	marshal, err := json.Marshal(payload)
 	return string(marshal), err
 }
+
+func (ri *RoomInvitation) RawPayload() (schemas.RoomInvitationPayload, error) {
+	payload, err := ri.GetPuppet().RoomInvitationPayload(ri.id)
+	if err != nil {
+		return schemas.RoomInvitationPayload{}, err
+	}
+	
+	return *payload, nil
+}

wechaty/wechaty.go

@@ -26,19 +26,21 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"os"
+	"os/signal"
+	"reflect"
+	"runtime/debug"
+	"time"
+
 	"github.com/lucsky/cuid"
+
 	wp "github.com/wechaty/go-wechaty/wechaty-puppet"
 	puppetservice "github.com/wechaty/go-wechaty/wechaty-puppet-service"
 	"github.com/wechaty/go-wechaty/wechaty-puppet/events"
 	mc "github.com/wechaty/go-wechaty/wechaty-puppet/memory-card"
 	"github.com/wechaty/go-wechaty/wechaty-puppet/schemas"
 	"github.com/wechaty/go-wechaty/wechaty/factory"
-	"github.com/wechaty/go-wechaty/wechaty/interface"
-	"os"
-	"os/signal"
-	"reflect"
-	"runtime/debug"
-	"time"
+	_interface "github.com/wechaty/go-wechaty/wechaty/interface"
 )
 
 // Wechaty ...
@@ -380,6 +382,18 @@ func (w *Wechaty) initPuppetEventBridge() {
 		case schemas.PuppetEventNameRoomInvite:
 			w.puppet.On(name, func(i ...interface{}) {
 				roomInvitation := w.roomInvitation.Load(i[0].(*schemas.EventRoomInvitePayload).RoomInvitationId)
+				room, err := roomInvitation.Room()
+				if err != nil {
+					log.Errorf("emit roominvite room.Room() err: %s\n", err.Error())
+					w.emit(schemas.PuppetEventNameError, NewContext(), err)
+					return
+				}
+				if err := room.Ready(false); err != nil {
+					log.Errorf("emit roominvite room.Ready() err: %s\n", err.Error())
+					w.emit(schemas.PuppetEventNameError, NewContext(), err)
+					return
+				}
+
 				w.emit(name, NewContext(), roomInvitation)
 			})
 		case schemas.PuppetEventNameRoomJoin: