Compare commits

..

No commits in common. "master" and "0.98" have entirely different histories.
master ... 0.98

7 changed files with 31 additions and 79 deletions

View File

@ -1,6 +1,6 @@
ARG SIGNAL_CLI_VERSION=0.14.1 ARG SIGNAL_CLI_VERSION=0.14.1
ARG LIBSIGNAL_CLIENT_VERSION=0.87.4 ARG LIBSIGNAL_CLIENT_VERSION=0.87.4
ARG SIGNAL_CLI_NATIVE_PACKAGE_VERSION=0.14.1+morph027+2 ARG SIGNAL_CLI_NATIVE_PACKAGE_VERSION=0.14.1+morph027+1
ARG SWAG_VERSION=1.16.4 ARG SWAG_VERSION=1.16.4
ARG GRAALVM_VERSION=25.0.2 ARG GRAALVM_VERSION=25.0.2

View File

@ -1024,7 +1024,6 @@ func (a *Api) RemoveAdminsFromGroup(c *gin.Context) {
// @Success 200 {object} []client.GroupEntry // @Success 200 {object} []client.GroupEntry
// @Failure 400 {object} Error // @Failure 400 {object} Error
// @Param number path string true "Registered Phone Number" // @Param number path string true "Registered Phone Number"
// @Param use_only_uuid_as_identifier query bool false "Use UUIDs instead of phone numbers as identifier for (pending|requesting) members"
// @Router /v1/groups/{number} [get] // @Router /v1/groups/{number} [get]
func (a *Api) GetGroups(c *gin.Context) { func (a *Api) GetGroups(c *gin.Context) {
number, err := url.PathUnescape(c.Param("number")) number, err := url.PathUnescape(c.Param("number"))
@ -1033,13 +1032,7 @@ func (a *Api) GetGroups(c *gin.Context) {
return return
} }
useOnlyUuidAsIdentifier := c.DefaultQuery("use_only_uuid_as_identifier", "false") groups, err := a.signalClient.GetGroups(number)
if useOnlyUuidAsIdentifier != "true" && useOnlyUuidAsIdentifier != "false" {
c.JSON(400, Error{Msg: "Couldn't process request - use_only_uuid_as_identifier parameter needs to be either 'true' or 'false'"})
return
}
groups, err := a.signalClient.GetGroups(number, StringToBool(useOnlyUuidAsIdentifier))
if err != nil { if err != nil {
c.JSON(400, Error{Msg: err.Error()}) c.JSON(400, Error{Msg: err.Error()})
return return
@ -1057,7 +1050,6 @@ func (a *Api) GetGroups(c *gin.Context) {
// @Failure 400 {object} Error // @Failure 400 {object} Error
// @Param number path string true "Registered Phone Number" // @Param number path string true "Registered Phone Number"
// @Param groupid path string true "Group ID" // @Param groupid path string true "Group ID"
// @Param use_only_uuid_as_identifier query bool false "Use UUIDs instead of phone numbers as identifier for (pending|requesting) members"
// @Router /v1/groups/{number}/{groupid} [get] // @Router /v1/groups/{number}/{groupid} [get]
func (a *Api) GetGroup(c *gin.Context) { func (a *Api) GetGroup(c *gin.Context) {
number, err := url.PathUnescape(c.Param("number")) number, err := url.PathUnescape(c.Param("number"))
@ -1067,13 +1059,7 @@ func (a *Api) GetGroup(c *gin.Context) {
} }
groupId := c.Param("groupid") groupId := c.Param("groupid")
useOnlyUuidAsIdentifier := c.DefaultQuery("use_only_uuid_as_identifier", "false") groupEntry, err := a.signalClient.GetGroup(number, groupId)
if useOnlyUuidAsIdentifier != "true" && useOnlyUuidAsIdentifier != "false" {
c.JSON(400, Error{Msg: "Couldn't process request - use_only_uuid_as_identifier parameter needs to be either 'true' or 'false'"})
return
}
groupEntry, err := a.signalClient.GetGroup(number, groupId, StringToBool(useOnlyUuidAsIdentifier))
if err != nil { if err != nil {
c.JSON(400, Error{Msg: err.Error()}) c.JSON(400, Error{Msg: err.Error()})
return return

View File

@ -341,18 +341,6 @@ func getSignalCliModeString(signalCliMode SignalCliMode) string {
return "unknown" return "unknown"
} }
func pickGroupMemberIdentifier(number string, uuid string, useOnlyUuidAsIdentifier bool) string {
if useOnlyUuidAsIdentifier {
return uuid
}
if number != "" {
return number
}
return uuid
}
func getRecipientType(s string) (ds.RecpType, error) { func getRecipientType(s string) (ds.RecpType, error) {
// check if the provided recipient is of type 'group' // check if the provided recipient is of type 'group'
if strings.HasPrefix(s, groupPrefix) { // if the recipient starts with 'group.' it is either a group or a username that starts with 'group.' if strings.HasPrefix(s, groupPrefix) { // if the recipient starts with 'group.' it is either a group or a username that starts with 'group.'
@ -1193,7 +1181,7 @@ func (s *SignalClient) updateGroupMembers(number string, groupId string, members
return nil return nil
} }
group, err := s.GetGroup(number, groupId, false) group, err := s.GetGroup(number, groupId)
if err != nil { if err != nil {
return err return err
} }
@ -1255,7 +1243,7 @@ func (s *SignalClient) updateGroupAdmins(number string, groupId string, admins [
return nil return nil
} }
group, err := s.GetGroup(number, groupId, false) group, err := s.GetGroup(number, groupId)
if err != nil { if err != nil {
return err return err
} }
@ -1312,7 +1300,7 @@ func (s *SignalClient) RemoveAdminsFromGroup(number string, groupId string, admi
return s.updateGroupAdmins(number, groupId, admins, false) return s.updateGroupAdmins(number, groupId, admins, false)
} }
func (s *SignalClient) GetGroups(number string, useOnlyUuidAsIdentifier bool) ([]GroupEntry, error) { func (s *SignalClient) GetGroups(number string) ([]GroupEntry, error) {
groupEntries := []GroupEntry{} groupEntries := []GroupEntry{}
var signalCliGroupEntries []SignalCliGroupEntry var signalCliGroupEntries []SignalCliGroupEntry
@ -1353,28 +1341,40 @@ func (s *SignalClient) GetGroups(number string, useOnlyUuidAsIdentifier bool) ([
members := []string{} members := []string{}
for _, val := range signalCliGroupEntry.Members { for _, val := range signalCliGroupEntry.Members {
identifier := pickGroupMemberIdentifier(val.Number, val.Uuid, useOnlyUuidAsIdentifier) identifier := val.Number
if identifier == "" {
identifier = val.Uuid
}
members = append(members, identifier) members = append(members, identifier)
} }
groupEntry.Members = members groupEntry.Members = members
pendingMembers := []string{} pendingMembers := []string{}
for _, val := range signalCliGroupEntry.PendingMembers { for _, val := range signalCliGroupEntry.PendingMembers {
identifier := pickGroupMemberIdentifier(val.Number, val.Uuid, useOnlyUuidAsIdentifier) identifier := val.Number
if identifier == "" {
identifier = val.Uuid
}
pendingMembers = append(pendingMembers, identifier) pendingMembers = append(pendingMembers, identifier)
} }
groupEntry.PendingInvites = pendingMembers groupEntry.PendingInvites = pendingMembers
requestingMembers := []string{} requestingMembers := []string{}
for _, val := range signalCliGroupEntry.RequestingMembers { for _, val := range signalCliGroupEntry.RequestingMembers {
identifier := pickGroupMemberIdentifier(val.Number, val.Uuid, useOnlyUuidAsIdentifier) identifier := val.Number
if identifier == "" {
identifier = val.Uuid
}
requestingMembers = append(requestingMembers, identifier) requestingMembers = append(requestingMembers, identifier)
} }
groupEntry.PendingRequests = requestingMembers groupEntry.PendingRequests = requestingMembers
admins := []string{} admins := []string{}
for _, val := range signalCliGroupEntry.Admins { for _, val := range signalCliGroupEntry.Admins {
identifier := pickGroupMemberIdentifier(val.Number, val.Uuid, useOnlyUuidAsIdentifier) identifier := val.Number
if identifier == "" {
identifier = val.Uuid
}
admins = append(admins, identifier) admins = append(admins, identifier)
} }
groupEntry.Admins = admins groupEntry.Admins = admins
@ -1387,9 +1387,9 @@ func (s *SignalClient) GetGroups(number string, useOnlyUuidAsIdentifier bool) ([
return groupEntries, nil return groupEntries, nil
} }
func (s *SignalClient) GetGroup(number string, groupId string, useOnlyUuidAsIdentifier bool) (*GroupEntry, error) { func (s *SignalClient) GetGroup(number string, groupId string) (*GroupEntry, error) {
groupEntry := GroupEntry{} groupEntry := GroupEntry{}
groups, err := s.GetGroups(number, useOnlyUuidAsIdentifier) groups, err := s.GetGroups(number)
if err != nil { if err != nil {
return nil, err return nil, err
} }

View File

@ -233,6 +233,13 @@ func (r *JsonRpc2Client) ReceiveData(number string, receiveWebhookUrl string) {
} }
log.Debug("json-rpc received data: ", str) log.Debug("json-rpc received data: ", str)
if receiveWebhookUrl != "" {
err = postMessageToWebhook(receiveWebhookUrl, []byte(str))
if err != nil {
log.Error("Couldn't post data to webhook: ", err)
}
}
var resp1 JsonRpc2ReceivedMessage var resp1 JsonRpc2ReceivedMessage
json.Unmarshal([]byte(str), &resp1) json.Unmarshal([]byte(str), &resp1)
if resp1.Method == "receive" { if resp1.Method == "receive" {
@ -247,13 +254,6 @@ func (r *JsonRpc2Client) ReceiveData(number string, receiveWebhookUrl string) {
continue continue
} }
r.receivedMessagesMutex.Unlock() r.receivedMessagesMutex.Unlock()
if receiveWebhookUrl != "" {
err = postMessageToWebhook(receiveWebhookUrl, []byte(str))
if err != nil {
log.Error("Couldn't post data to webhook: ", err)
}
}
} }
var resp2 JsonRpc2MessageResponse var resp2 JsonRpc2MessageResponse

View File

@ -917,12 +917,6 @@ const docTemplate = `{
"name": "number", "name": "number",
"in": "path", "in": "path",
"required": true "required": true
},
{
"type": "boolean",
"description": "Use UUIDs instead of phone numbers as identifier for (pending|requesting) members",
"name": "use_only_uuid_as_identifier",
"in": "query"
} }
], ],
"responses": { "responses": {
@ -1016,12 +1010,6 @@ const docTemplate = `{
"name": "groupid", "name": "groupid",
"in": "path", "in": "path",
"required": true "required": true
},
{
"type": "boolean",
"description": "Use UUIDs instead of phone numbers as identifier for (pending|requesting) members",
"name": "use_only_uuid_as_identifier",
"in": "query"
} }
], ],
"responses": { "responses": {

View File

@ -914,12 +914,6 @@
"name": "number", "name": "number",
"in": "path", "in": "path",
"required": true "required": true
},
{
"type": "boolean",
"description": "Use UUIDs instead of phone numbers as identifier for (pending|requesting) members",
"name": "use_only_uuid_as_identifier",
"in": "query"
} }
], ],
"responses": { "responses": {
@ -1013,12 +1007,6 @@
"name": "groupid", "name": "groupid",
"in": "path", "in": "path",
"required": true "required": true
},
{
"type": "boolean",
"description": "Use UUIDs instead of phone numbers as identifier for (pending|requesting) members",
"name": "use_only_uuid_as_identifier",
"in": "query"
} }
], ],
"responses": { "responses": {

View File

@ -1163,11 +1163,6 @@ paths:
name: number name: number
required: true required: true
type: string type: string
- description: Use UUIDs instead of phone numbers as identifier for (pending|requesting)
members
in: query
name: use_only_uuid_as_identifier
type: boolean
produces: produces:
- application/json - application/json
responses: responses:
@ -1259,11 +1254,6 @@ paths:
name: groupid name: groupid
required: true required: true
type: string type: string
- description: Use UUIDs instead of phone numbers as identifier for (pending|requesting)
members
in: query
name: use_only_uuid_as_identifier
type: boolean
produces: produces:
- application/json - application/json
responses: responses: