seang96/gmessages
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

Expose RCS group creation in provisioning API

Browse source
This commit is contained in:
Tulir Asokan 2023-07-22 19:36:41 +03:00
parent 95fed6ad49
commit f1857d515c
1 changed files with 17 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
provisioning.go
View file

@ -174,6 +174,9 @@ func (prov *ProvisioningAPI) ListContacts(w http.ResponseWriter, r *http.Request
type StartChatRequest struct { type StartChatRequest struct {
Numbers []string `json:"numbers"` Numbers []string `json:"numbers"`
CreateRCSGroup bool `json:"create_rcs_group"`
RCSGroupName string `json:"rcs_group_name"`
} }
type StartChatResponse struct { type StartChatResponse struct {
@ -205,6 +208,10 @@ func (prov *ProvisioningAPI) StartChat(w http.ResponseWriter, r *http.Request) {
Number2: number, Number2: number,
}) })
} }
if req.CreateRCSGroup {
reqData.CreateRCSGroup = proto.Bool(true)
reqData.RCSGroupName = proto.String(req.RCSGroupName)
}
resp, err := user.Client.GetOrCreateConversation(&reqData) resp, err := user.Client.GetOrCreateConversation(&reqData)
if err != nil { if err != nil {
prov.zlog.Err(err).Msg("Failed to start chat") prov.zlog.Err(err).Msg("Failed to start chat")
@ -213,22 +220,18 @@ func (prov *ProvisioningAPI) StartChat(w http.ResponseWriter, r *http.Request) {
ErrCode: "unknown error", ErrCode: "unknown error",
}) })
return return
} else if resp.GetStatus() == gmproto.GetOrCreateConversationResponse_CREATE_RCS { } else if len(req.Numbers) > 1 && resp.GetStatus() == gmproto.GetOrCreateConversationResponse_CREATE_RCS {
prov.zlog.Debug().Msg("Creating RCS group") jsonResponse(w, http.StatusBadRequest, Error{
// TODO this will always create a new group and won't deduplicate Error: "All recipients are on RCS, please create a RCS group",
reqData.CreateRCSGroup = proto.Bool(true) ErrCode: "rcs group",
resp, err = user.Client.GetOrCreateConversation(&reqData) })
if err != nil { return
prov.zlog.Err(err).Msg("Failed to start RCS chat")
jsonResponse(w, http.StatusInternalServerError, Error{
Error: "Failed to start chat",
ErrCode: "unknown error",
})
return
}
} }
if resp.GetConversation() == nil { if resp.GetConversation() == nil {
prov.zlog.Warn().Str("status", resp.GetStatus().String()).Msg("No conversation in chat create response") prov.zlog.Warn().
Int("req_number_count", len(req.Numbers)).
Str("status", resp.GetStatus().String()).
Msg("No conversation in chat create response")
jsonResponse(w, http.StatusInternalServerError, Error{ jsonResponse(w, http.StatusInternalServerError, Error{
Error: "Failed to start chat", Error: "Failed to start chat",
ErrCode: "unknown error", ErrCode: "unknown error",