Compare commits

..

No commits in common. "main" and "db-migration" have entirely different histories.

22 changed files with 5155 additions and 1349 deletions

View file

@ -1,11 +1,10 @@
stages: stages:
- build - build
- test
- publish - publish
lint: lint:
image: golang:1.17 image: golang:latest
stage: test stage: build
before_script: before_script:
- apt-get update - apt-get update
- apt-get install -y wget golang-go - apt-get install -y wget golang-go
@ -18,30 +17,6 @@ lint:
- diff --color=always go.sum "${CI_PROJECT_DIR}/go.sum" - diff --color=always go.sum "${CI_PROJECT_DIR}/go.sum"
rules: rules:
- when: on_success - when: on_success
needs: []
test sqlite to postgres:
image:
name: registry.gitlab.com/signald/signald:unstable
entrypoint: [""]
stage: test
needs:
- "build:x86"
before_script:
- apt-get update && apt-get install -y postgresql-client
script:
- cd /
- signald --migrate-data
- echo 'CREATE DATABASE signald' | psql -h postgres -U postgres -a
- "${CI_PROJECT_DIR}/signaldctl db-move postgresql://postgres@postgres/signald?sslmode=disable"
- SIGNALD_DATABASE=postgresql://postgres@postgres/signald?sslmode=disable signald --migrate-data
variables:
SIGNALD_VERBOSE_LOGGING: "true"
services:
- name: postgres:latest
alias: postgres
variables:
POSTGRES_HOST_AUTH_METHOD: trust
.build: .build:
stage: build stage: build
@ -62,22 +37,27 @@ test sqlite to postgres:
.build-deb: .build-deb:
stage: build stage: build
image: debian:buster image: debian:buster
before_script: script:
- echo deb http://deb.debian.org/debian buster-backports main > /etc/apt/sources.list.d/backports.list - echo deb http://deb.debian.org/debian buster-backports main > /etc/apt/sources.list.d/backports.list
- apt-get update - apt-get update
- apt-get install -y -t buster-backports git-buildpackage dh-golang bash-completion golang-any golang-github-spf13-cobra-dev golang-github-spf13-viper-dev golang-github-google-uuid-dev golang-github-mattn-go-sqlite3-dev golang-github-lib-pq-dev golang-github-satori-go.uuid-dev wget unzip - apt-get install -y -t buster-backports git-buildpackage dh-golang bash-completion golang-any golang-github-spf13-cobra-dev golang-github-spf13-viper-dev golang-github-google-uuid-dev golang-github-mattn-go-sqlite3-dev golang-github-lib-pq-dev golang-github-satori-go.uuid-dev
- wget -O golang-github-mdp-qrterminal.zip --quiet "https://gitlab.com/api/v4/projects/signald%2Flibraries%2Fgolang-github-mdp-qrterminal/jobs/artifacts/master/download?job=build"
- wget -O golang-github-jedib0t-go-pretty.zip --quiet "https://gitlab.com/api/v4/projects/signald%2Flibraries%2Fgolang-github-jedib0t-go-pretty/jobs/artifacts/master/download?job=build"
- for z in *.zip; do unzip $z; done
- apt-get install -y ./*.deb && rm -vf *.deb - apt-get install -y ./*.deb && rm -vf *.deb
script:
- 'sed -i "s/^Architecture:.*/Architecture: ${ARCH}/g" debian/control' - 'sed -i "s/^Architecture:.*/Architecture: ${ARCH}/g" debian/control'
- go run ./cmd/signaldctl doc -o man - go run ./cmd/signaldctl doc -o man
- go run ./cmd/signaldctl completion bash > debian/package.bash-completion - go run ./cmd/signaldctl completion bash > debian/package.bash-completion
- ls *.1 > debian/manpages - ls *.1 > debian/manpages
- gbp dch --ignore-branch --debian-tag="%(version)s" --git-author --new-version="$(./version.sh | cut -c2-)" - gbp dch --ignore-branch --debian-tag="%(version)s" --git-author --new-version="$(./version.sh)"
- dpkg-buildpackage -us -uc -b - dpkg-buildpackage -us -uc -b
- mv ../*.deb . - mv ../*.deb .
needs:
- project: signald/libraries/golang-github-mdp-qrterminal
job: build
ref: master
artifacts: true
- project: signald/libraries/golang-github-jedib0t-go-pretty
job: build
ref: master
artifacts: true
variables: variables:
SIGNALDCTL_PUBLIC_DOC_MODE: "on" SIGNALDCTL_PUBLIC_DOC_MODE: "on"
artifacts: artifacts:
@ -162,11 +142,9 @@ publish deb:
- aptly repo create signald - aptly repo create signald
- aptly mirror create -ignore-signatures backfill-mirror https://updates.signald.org "${DISTRIBUTION}" main - aptly mirror create -ignore-signatures backfill-mirror https://updates.signald.org "${DISTRIBUTION}" main
- aptly mirror update -ignore-signatures backfill-mirror - aptly mirror update -ignore-signatures backfill-mirror
- aptly repo import backfill-mirror signald signald 'signaldctl (>= 0.3.0)' - aptly repo import backfill-mirror signald signald signaldctl
- aptly repo add signald *.deb - aptly repo add signald *.deb
- gpg1 --import "${SIGNING_KEY_PATH}" - aptly publish repo -config=.aptly.conf -batch -gpg-key="${SIGNING_KEY}" -distribution="${DISTRIBUTION}" "signald" "s3:updates.signald.org:"
- gpg1 --list-secret-keys
- aptly publish repo -config=.aptly.conf -batch -gpg-key="${SIGNING_KEY_ID}" -distribution="${DISTRIBUTION}" "signald" "s3:updates.signald.org:"
variables: variables:
DISTRIBUTION: unstable DISTRIBUTION: unstable
rules: rules:

View file

@ -34,7 +34,6 @@ import (
var ( var (
testing bool testing bool
deviceName string deviceName string
overwrite bool
LinkAccountCmd = &cobra.Command{ LinkAccountCmd = &cobra.Command{
Use: "link", Use: "link",
@ -81,7 +80,6 @@ var (
finishReq := v1.FinishLinkRequest{ finishReq := v1.FinishLinkRequest{
DeviceName: deviceName, DeviceName: deviceName,
SessionId: response.SessionId, SessionId: response.SessionId,
Overwrite: overwrite,
} }
_, err = finishReq.Submit(common.Signald) _, err = finishReq.Submit(common.Signald)
@ -101,5 +99,4 @@ func init() {
} }
LinkAccountCmd.Flags().BoolVarP(&testing, "testing", "t", false, "use the Signal testing server") LinkAccountCmd.Flags().BoolVarP(&testing, "testing", "t", false, "use the Signal testing server")
LinkAccountCmd.Flags().StringVarP(&deviceName, "device-name", "n", name, "the name of this device. shown to other devices on the signal account") LinkAccountCmd.Flags().StringVarP(&deviceName, "device-name", "n", name, "the name of this device. shown to other devices on the signal account")
LinkAccountCmd.Flags().BoolVar(&overwrite, "overwrite", false, "if an account with the same id already exists in signald's database, delete it before linking")
} }

View file

@ -1,36 +0,0 @@
package requestsync
import (
"log"
"github.com/spf13/cobra"
"gitlab.com/signald/signald-go/cmd/signaldctl/common"
"gitlab.com/signald/signald-go/cmd/signaldctl/config"
v1 "gitlab.com/signald/signald-go/signald/client-protocol/v1"
)
var (
account string
RequestSyncCmd = &cobra.Command{
Use: "request-sync",
Short: "Ask other devices on the account to send sync data. Must subscribe for result",
PreRun: func(cmd *cobra.Command, args []string) {
if account == "" {
account = config.Config.DefaultAccount
}
},
Run: func(_ *cobra.Command, _ []string) {
go common.Signald.Listen(nil)
req := &v1.RequestSyncRequest{Account: account}
err := req.Submit(common.Signald)
if err != nil {
panic(err)
}
log.Println("sync requested. Must be subscribed to receive response")
},
}
)
func init() {
RequestSyncCmd.Flags().StringVarP(&account, "account", "a", "", "the signald account to use")
}

View file

@ -23,7 +23,6 @@ import (
"gitlab.com/signald/signald-go/cmd/signaldctl/cmd/account/list" "gitlab.com/signald/signald-go/cmd/signaldctl/cmd/account/list"
"gitlab.com/signald/signald-go/cmd/signaldctl/cmd/account/register" "gitlab.com/signald/signald-go/cmd/signaldctl/cmd/account/register"
"gitlab.com/signald/signald-go/cmd/signaldctl/cmd/account/remoteconfig" "gitlab.com/signald/signald-go/cmd/signaldctl/cmd/account/remoteconfig"
"gitlab.com/signald/signald-go/cmd/signaldctl/cmd/account/requestsync"
"gitlab.com/signald/signald-go/cmd/signaldctl/cmd/account/setprofile" "gitlab.com/signald/signald-go/cmd/signaldctl/cmd/account/setprofile"
"gitlab.com/signald/signald-go/cmd/signaldctl/cmd/account/verify" "gitlab.com/signald/signald-go/cmd/signaldctl/cmd/account/verify"
) )
@ -38,8 +37,7 @@ func init() {
AccountCmd.AddCommand(link.LinkAccountCmd) AccountCmd.AddCommand(link.LinkAccountCmd)
AccountCmd.AddCommand(list.ListAccountCmd) AccountCmd.AddCommand(list.ListAccountCmd)
AccountCmd.AddCommand(register.RegisterAccountCmd) AccountCmd.AddCommand(register.RegisterAccountCmd)
AccountCmd.AddCommand(remoteconfig.RemoteConfigCmd)
AccountCmd.AddCommand(requestsync.RequestSyncCmd)
AccountCmd.AddCommand(setprofile.SetProfileCmd)
AccountCmd.AddCommand(verify.VerifyAccountCmd) AccountCmd.AddCommand(verify.VerifyAccountCmd)
AccountCmd.AddCommand(setprofile.SetProfileCmd)
AccountCmd.AddCommand(remoteconfig.RemoteConfigCmd)
} }

View file

@ -27,14 +27,10 @@ import (
var ( var (
account string account string
name string
avatar string
emoji string
about string
SetProfileCmd = &cobra.Command{ SetProfileCmd = &cobra.Command{
Use: "set-profile [name]", Use: "set-profile name",
Short: "update an account's profile data", Short: "updates the profile data with a new name",
PreRun: func(cmd *cobra.Command, args []string) { PreRun: func(cmd *cobra.Command, args []string) {
if account == "" { if account == "" {
account = config.Config.DefaultAccount account = config.Config.DefaultAccount
@ -43,19 +39,16 @@ var (
common.Must(cmd.Help()) common.Must(cmd.Help())
log.Fatal("No account specified. Please specify with --account or set a default") log.Fatal("No account specified. Please specify with --account or set a default")
} }
if len(args) != 1 {
if len(args) > 0 { common.Must(cmd.Help())
name = args[0] log.Fatal("must specify a name")
} }
}, },
Run: func(_ *cobra.Command, _ []string) { Run: func(_ *cobra.Command, args []string) {
go common.Signald.Listen(nil) go common.Signald.Listen(nil)
req := v1.SetProfile{ req := v1.SetProfile{
Account: account, Account: account,
Name: name, Name: args[0],
AvatarFile: avatar,
Emoji: emoji,
About: about,
} }
err := req.Submit(common.Signald) err := req.Submit(common.Signald)
if err != nil { if err != nil {
@ -68,7 +61,4 @@ var (
func init() { func init() {
SetProfileCmd.Flags().StringVarP(&account, "account", "a", "", "the signald account to use") SetProfileCmd.Flags().StringVarP(&account, "account", "a", "", "the signald account to use")
SetProfileCmd.Flags().StringVarP(&avatar, "avatar", "A", "", "path to avatar file")
SetProfileCmd.Flags().StringVar(&emoji, "emoji", "", "an emoji to be shown next to the about section")
SetProfileCmd.Flags().StringVar(&about, "about", "", "profile about section")
} }

View file

@ -7,7 +7,6 @@ import (
"log" "log"
"os" "os"
"os/user" "os/user"
"strings"
"time" "time"
"github.com/lib/pq" "github.com/lib/pq"
@ -17,25 +16,7 @@ import (
"gitlab.com/signald/signald-go/cmd/signaldctl/common" "gitlab.com/signald/signald-go/cmd/signaldctl/common"
) )
type Migration struct {
InstalledRank int
Version string
Description string
Script string
Checksum int
}
var ( var (
migrations = []Migration{
{InstalledRank: 1, Version: "1", Description: "create tables", Script: "V1__create_tables.sql", Checksum: -1247750968},
{InstalledRank: 2, Version: "12", Description: "create contacts table", Script: "V12__create_contacts_table.sql", Checksum: -852729911},
{InstalledRank: 3, Version: "13", Description: "recipient registration status", Script: "V13__recipient_registration_status.sql", Checksum: 405376321},
{InstalledRank: 4, Version: "14", Description: "multiple identity keys per account", Script: "V14__multiple_identity_keys_per_account.sql", Checksum: -1635788950},
{InstalledRank: 5, Version: "15", Description: "profiles tables", Script: "V15__profiles_tables.sql", Checksum: 809686180},
{InstalledRank: 6, Version: "16", Description: "destination uuid in envelope", Script: "V16__destination_uuid_in_envelope.sql", Checksum: 357656854},
{InstalledRank: 7, Version: "17", Description: "update server ca", Script: "V17__update_server_ca.sql", Checksum: 1647934070},
}
sqlitePath string sqlitePath string
postgresURL string postgresURL string
MoveCmd = &cobra.Command{ MoveCmd = &cobra.Command{
@ -43,7 +24,7 @@ var (
Short: "move a signald database from sqlite to postgres", Short: "move a signald database from sqlite to postgres",
Long: `move a signald sqlite database into a postgres database. Long: `move a signald sqlite database into a postgres database.
If sqlite-path is not specified, the default (~/.config/signald/signald.db) will be used. If sqlite-path is not specified, the default (~/.config/signald/signald.db) will be used.
Please note that signald must NOT be running while this command runs. Please note that signald must NOT be running while this command runs.
After the data is moved, the sqlite file will be deleted`, After the data is moved, the sqlite file will be deleted`,
@ -61,7 +42,7 @@ var (
} }
return nil return nil
}, },
RunE: func(cmd *cobra.Command, args []string) (err error) { RunE: func(cmd *cobra.Command, args []string) error {
source, err := sql.Open("sqlite3", sqlitePath) source, err := sql.Open("sqlite3", sqlitePath)
if err != nil { if err != nil {
return err return err
@ -94,37 +75,77 @@ var (
} }
log.Println("created schema") log.Println("created schema")
migrate := func(fn func(*sql.DB, *sql.DB) error, targetName string) { if err := moveAccounts(source, dest); err != nil {
if err = fn(source, dest); err != nil { log.Println("error migrating accounts table")
log.Println("error moving", targetName) return err
panic(err)
}
log.Println("moved", targetName)
} }
defer func() { log.Println("moved accounts table")
if r := recover(); r != nil && r != err {
// If r is something other than the error returned via the named return, re-panic it
panic(r)
}
}()
migrate(moveAccounts, "accounts table") if err := moveRecipients(source, dest); err != nil {
migrate(moveRecipients, "recipients table") log.Println("error migrating recipients table")
migrate(movePrekeys, "prekeys table") return err
migrate(moveSessions, "sessions table") }
migrate(moveSignedPrekeys, "signed prekeys table") log.Println("moved recipients table")
migrate(moveIdentityKeys, "identity keys table")
migrate(moveAccountData, "account data") if err := movePrekeys(source, dest); err != nil {
migrate(movePendingAccountData, "pending account data table") log.Println("error migrating prekeys table")
migrate(moveSenderKeys, "sender keys table") return err
migrate(moveSenderKeyShared, "sender key shared table") }
migrate(moveGroups, "groups table") log.Println("moved prekeys table")
migrate(moveGroupCredentials, "group credentials table")
migrate(moveContacts, "contacts table") if err := moveSessions(source, dest); err != nil {
migrate(moveProfileKeys, "profile keys table") log.Println("error migrating sessions table")
migrate(moveProfiles, "profiles tables") return err
migrate(moveProfileCapabilities, "profile capabilities tables") }
migrate(moveProfileBadges, "profile badges tables") log.Println("moved sessions table")
if err := moveSignedPrekeys(source, dest); err != nil {
log.Println("error migrating signed prekeys table")
return err
}
log.Println("moved signed prekeys table")
if err := moveIdentityKeys(source, dest); err != nil {
log.Println("error migrating identity keys table")
return err
}
log.Println("moved identity keys table")
if err := moveAccountData(source, dest); err != nil {
log.Println("error migrating account data")
return err
}
log.Println("moved account data table")
if err := movePendingAccountData(source, dest); err != nil {
log.Println("error migrating pending account data tabe")
return err
}
log.Println("moved pending account data table")
if err := moveSenderKeys(source, dest); err != nil {
log.Println("error migrating sender keys table")
return err
}
log.Println("moved sender keys table")
if err := moveSenderKeyShared(source, dest); err != nil {
log.Println("error migrating sender key shared table")
return err
}
log.Println("moved sender key shared table")
if err := moveGroups(source, dest); err != nil {
log.Println("error migrating groups table")
return err
}
log.Println("moved groups table")
if err := moveGroupCredentials(source, dest); err != nil {
log.Println("error migrating group credentials table")
return err
}
log.Println("moved group credentials table")
if err := os.Remove(sqlitePath); err != nil { if err := os.Remove(sqlitePath); err != nil {
log.Println("error deleting sqlite file") log.Println("error deleting sqlite file")
@ -137,28 +158,15 @@ var (
) )
func verifyMigration(source *sql.DB) error { func verifyMigration(source *sql.DB) error {
// Lower bound of the database state. rows, err := source.Query("SELECT * FROM flyway_schema_history WHERE version = 11")
rows, err := source.Query("SELECT version FROM flyway_schema_history ORDER BY installed_rank DESC LIMIT 1")
if err != nil { if err != nil {
return err return err
} }
defer rows.Close() defer rows.Close()
if !rows.Next() { if !rows.Next() {
return errors.New("source database is not up to date! Please update signald and start it to move all data into sqlite before moving data to postgres") return errors.New("source database is not up to date! Please update to signald 0.17.0-16-5101c6ef and start it to move the sqlite database to an acceptable format")
} }
var version string
err = rows.Scan(&version)
if err != nil {
return err
}
expectedMigrationVersion := migrations[len(migrations)-1].Version
if version != expectedMigrationVersion {
return fmt.Errorf("source database must be on migration %s (found %s instead). Please update signald, or file an issue if the migrations are out of date", expectedMigrationVersion, version)
}
return nil return nil
} }
@ -168,24 +176,13 @@ func createSchema(dest *sql.DB) error {
return err return err
} }
for _, migration := range migrations { _, err = dest.Exec("INSERT INTO flyway_schema_history (installed_rank, version, description, type, script, checksum, installed_by, execution_time, success) VALUES ($1, $2, $3, $4, $5, $6, current_user, $7, $8)",
_, err = dest.Exec(` 1, 1, "create tables", "SQL", "V1__create_tables.sql", -1247750968, 0, true)
INSERT INTO flyway_schema_history return err
(installed_rank, version, description, type, script, checksum, installed_by, execution_time, success)
VALUES ($1, $2, $3, 'SQL', $4, $5, current_user, 0, true)
`,
migration.InstalledRank, migration.Version, migration.Description, migration.Script, migration.Checksum,
)
if err != nil {
return err
}
}
return nil
} }
func moveAccounts(source *sql.DB, dest *sql.DB) error { func moveAccounts(source *sql.DB, dest *sql.DB) error {
rows, err := source.Query("SELECT uuid, e164, server FROM accounts") rows, err := source.Query("SELECT uuid, e164, filename, server FROM accounts")
if err != nil { if err != nil {
return err return err
} }
@ -195,13 +192,14 @@ func moveAccounts(source *sql.DB, dest *sql.DB) error {
var ( var (
accountUUID uuid.UUID accountUUID uuid.UUID
e164 string e164 string
filename string
server uuid.UUID server uuid.UUID
) )
err = rows.Scan(&accountUUID, &e164, &server) err = rows.Scan(&accountUUID, &e164, &filename, &server)
if err != nil { if err != nil {
return err return err
} }
_, err = dest.Exec("INSERT INTO signald_accounts (uuid, e164, server) VALUES ($1, $2, $3)", accountUUID, e164, server) _, err = dest.Exec("INSERT INTO signald_accounts (uuid, e164, filename, server) VALUES ($1, $2, $3, $4)", accountUUID, e164, filename, server)
if err != nil { if err != nil {
return err return err
} }
@ -210,9 +208,7 @@ func moveAccounts(source *sql.DB, dest *sql.DB) error {
} }
func moveRecipients(source *sql.DB, dest *sql.DB) error { func moveRecipients(source *sql.DB, dest *sql.DB) error {
rows, err := source.Query("SELECT rowid, account_uuid, uuid, e164, registered FROM recipients" + rows, err := source.Query("SELECT rowid, account_uuid, uuid, e164 FROM recipients")
" WHERE account_uuid IN (SELECT DISTINCT uuid FROM accounts)",
)
if err != nil { if err != nil {
return err return err
} }
@ -222,39 +218,23 @@ func moveRecipients(source *sql.DB, dest *sql.DB) error {
var ( var (
rowID int64 rowID int64
accountUUID uuid.UUID accountUUID uuid.UUID
recipientUUID uuid.NullUUID recipientUUID uuid.UUID
e164 sql.NullString e164 sql.NullString
registered bool
) )
err = rows.Scan(&rowID, &accountUUID, &recipientUUID, &e164, &registered) err = rows.Scan(&rowID, &accountUUID, &recipientUUID, &e164)
if err != nil { if err != nil {
return err return err
} }
_, err = dest.Exec("INSERT INTO signald_recipients (rowid, account_uuid, uuid, e164) VALUES ($1, $2, $3, $4)", rowID, accountUUID, recipientUUID, e164)
if e164.Valid && !strings.HasPrefix(e164.String, "+") {
log.Println("corrupt e164 found, setting to null")
e164.Valid = false
e164.String = ""
}
_, err = dest.Exec("INSERT INTO signald_recipients (rowid, account_uuid, uuid, e164, registered) VALUES ($1, $2, $3, $4, $5)", rowID, accountUUID, recipientUUID, e164, registered)
if err != nil { if err != nil {
return err return err
} }
} }
// start new rowids one above the current max value
_, err = dest.Exec("SELECT setval(pg_get_serial_sequence('signald_recipients', 'rowid'), (SELECT MAX(rowid) FROM signald_recipients)+1)")
if err != nil {
return err
}
return nil return nil
} }
func movePrekeys(source *sql.DB, dest *sql.DB) error { func movePrekeys(source *sql.DB, dest *sql.DB) error {
rows, err := source.Query("SELECT account_uuid, id, record FROM prekeys" + rows, err := source.Query("SELECT account_uuid, id, record FROM prekeys")
" WHERE account_uuid IN (SELECT DISTINCT uuid FROM accounts)",
)
if err != nil { if err != nil {
return err return err
} }
@ -279,10 +259,7 @@ func movePrekeys(source *sql.DB, dest *sql.DB) error {
} }
func moveSessions(source *sql.DB, dest *sql.DB) error { func moveSessions(source *sql.DB, dest *sql.DB) error {
rows, err := source.Query("SELECT account_uuid, recipient, device_id, record FROM sessions" + rows, err := source.Query("SELECT account_uuid, recipient, device_id, record FROM sessions")
" WHERE account_uuid IN (SELECT DISTINCT uuid FROM accounts)" +
" AND recipient IN (SELECT DISTINCT rowid FROM recipients)",
)
if err != nil { if err != nil {
return err return err
} }
@ -317,9 +294,7 @@ func moveSessions(source *sql.DB, dest *sql.DB) error {
} }
func moveSignedPrekeys(source *sql.DB, dest *sql.DB) error { func moveSignedPrekeys(source *sql.DB, dest *sql.DB) error {
rows, err := source.Query("SELECT account_uuid, id, record FROM signed_prekeys" + rows, err := source.Query("SELECT account_uuid, id, record FROM signed_prekeys")
" WHERE account_uuid IN (SELECT DISTINCT uuid FROM accounts)",
)
if err != nil { if err != nil {
return err return err
} }
@ -344,9 +319,7 @@ func moveSignedPrekeys(source *sql.DB, dest *sql.DB) error {
} }
func moveIdentityKeys(source *sql.DB, dest *sql.DB) error { func moveIdentityKeys(source *sql.DB, dest *sql.DB) error {
rows, err := source.Query("SELECT account_uuid, recipient, identity_key, trust_level, added FROM identity_keys" + rows, err := source.Query("SELECT account_uuid, recipient, identity_key, trust_level, added FROM identity_keys")
" WHERE account_uuid IN (SELECT DISTINCT uuid FROM accounts)",
)
if err != nil { if err != nil {
return err return err
} }
@ -373,9 +346,7 @@ func moveIdentityKeys(source *sql.DB, dest *sql.DB) error {
} }
func moveAccountData(source *sql.DB, dest *sql.DB) error { func moveAccountData(source *sql.DB, dest *sql.DB) error {
rows, err := source.Query("SELECT account_uuid, key, value FROM account_data" + rows, err := source.Query("SELECT account_uuid, key, value FROM account_data")
" WHERE account_uuid IN (SELECT DISTINCT uuid FROM accounts)",
)
if err != nil { if err != nil {
return err return err
} }
@ -408,15 +379,15 @@ func movePendingAccountData(source *sql.DB, dest *sql.DB) error {
for rows.Next() { for rows.Next() {
var ( var (
username string accountUUID uuid.UUID
key string key string
value []byte value []byte
) )
err = rows.Scan(&username, &key, &value) err = rows.Scan(&accountUUID, &key, &value)
if err != nil { if err != nil {
return err return err
} }
_, err = dest.Exec("INSERT INTO signald_pending_account_data (username, key, value) VALUES ($1, $2, $3)", username, key, value) _, err = dest.Exec("INSERT INTO signald_pending_account_data (username, key, value) VALUES ($1, $2, $3)", accountUUID, key, value)
if err != nil { if err != nil {
return err return err
} }
@ -425,9 +396,7 @@ func movePendingAccountData(source *sql.DB, dest *sql.DB) error {
} }
func moveSenderKeys(source *sql.DB, dest *sql.DB) error { func moveSenderKeys(source *sql.DB, dest *sql.DB) error {
rows, err := source.Query("SELECT account_uuid, address, device, distribution_id, record, created_at FROM sender_keys" + rows, err := source.Query("SELECT account_uuid, address, device, distribution_id, record, created_at FROM sender_keys")
" WHERE account_uuid IN (SELECT DISTINCT uuid FROM accounts)",
)
if err != nil { if err != nil {
return err return err
} }
@ -463,9 +432,7 @@ func moveSenderKeys(source *sql.DB, dest *sql.DB) error {
} }
func moveSenderKeyShared(source *sql.DB, dest *sql.DB) error { func moveSenderKeyShared(source *sql.DB, dest *sql.DB) error {
rows, err := source.Query("SELECT account_uuid, distribution_id, address, device FROM sender_key_shared" + rows, err := source.Query("SELECT account_uuid, distribution_id, address, device FROM sender_key_shared")
" WHERE account_uuid IN (SELECT DISTINCT uuid FROM accounts)",
)
if err != nil { if err != nil {
return err return err
} }
@ -501,9 +468,7 @@ func moveSenderKeyShared(source *sql.DB, dest *sql.DB) error {
} }
func moveGroups(source *sql.DB, dest *sql.DB) error { func moveGroups(source *sql.DB, dest *sql.DB) error {
rows, err := source.Query("SELECT rowid, account_uuid, group_id, master_key, revision, last_avatar_fetch, distribution_id, group_info FROM groups" + rows, err := source.Query("SELECT rowid, account_uuid, group_id, master_key, revision, last_avatar_fetch, distribution_id, group_info FROM groups")
" WHERE account_uuid IN (SELECT DISTINCT uuid FROM accounts)",
)
if err != nil { if err != nil {
return err return err
} }
@ -529,20 +494,11 @@ func moveGroups(source *sql.DB, dest *sql.DB) error {
return err return err
} }
} }
// start new rowids one above the current max value
_, err = dest.Exec("SELECT setval(pg_get_serial_sequence('signald_groups', 'rowid'), (SELECT MAX(rowid) FROM signald_groups)+1)")
if err != nil {
return err
}
return nil return nil
} }
func moveGroupCredentials(source *sql.DB, dest *sql.DB) error { func moveGroupCredentials(source *sql.DB, dest *sql.DB) error {
rows, err := source.Query("SELECT account_uuid, date, max(credential) FROM group_credentials" + rows, err := source.Query("SELECT account_uuid, date, credential FROM group_credentials")
" WHERE account_uuid IN (SELECT DISTINCT uuid FROM accounts)" +
" GROUP BY account_uuid, date",
)
if err != nil { if err != nil {
return err return err
} }
@ -565,183 +521,3 @@ func moveGroupCredentials(source *sql.DB, dest *sql.DB) error {
} }
return nil return nil
} }
func moveContacts(source *sql.DB, dest *sql.DB) error {
rows, err := source.Query("SELECT account_uuid, recipient, name, color, profile_key, message_expiration_time, inbox_position FROM contacts" +
" WHERE account_uuid IN (SELECT DISTINCT uuid FROM accounts)" +
" AND recipient IN (SELECT DISTINCT rowid FROM recipients)",
)
if err != nil {
return err
}
defer rows.Close()
for rows.Next() {
var (
accountUUID uuid.UUID
recipient int64
name sql.NullString
color sql.NullString
profile_key []byte
message_expiration_time sql.NullInt64
inbox_position sql.NullInt64
)
err = rows.Scan(&accountUUID, &recipient, &name, &color, &profile_key, &message_expiration_time, &inbox_position)
if err != nil {
return err
}
_, err = dest.Exec(`
INSERT INTO signald_contacts
(account_uuid, recipient, name, color, profile_key, message_expiration_time, inbox_position)
VALUES ($1, $2, $3, $4, $5, $6, $7)
`, accountUUID, recipient, name, color, profile_key, message_expiration_time, inbox_position)
if err != nil {
return err
}
}
return nil
}
func moveProfileKeys(source *sql.DB, dest *sql.DB) error {
rows, err := source.Query("SELECT account_uuid, recipient, profile_key, profile_key_credential, request_pending, unidentified_access_mode FROM profile_keys" +
" WHERE account_uuid IN (SELECT DISTINCT uuid FROM accounts)" +
" AND recipient IN (SELECT DISTINCT rowid FROM recipients)",
)
if err != nil {
return err
}
defer rows.Close()
for rows.Next() {
var (
accountUUID uuid.UUID
recipient int64
profile_key []byte
profile_key_credential []byte
request_pending bool
unidentified_access_mode int
)
err = rows.Scan(&accountUUID, &recipient, &profile_key, &profile_key_credential, &request_pending, &unidentified_access_mode)
if err != nil {
return err
}
_, err = dest.Exec(`
INSERT INTO signald_profile_keys
(account_uuid, recipient, profile_key, profile_key_credential, request_pending, unidentified_access_mode)
VALUES ($1, $2, $3, $4, $5, $6)
`, accountUUID, recipient, profile_key, profile_key_credential, request_pending, unidentified_access_mode)
if err != nil {
return err
}
}
return nil
}
func moveProfiles(source *sql.DB, dest *sql.DB) error {
rows, err := source.Query("SELECT account_uuid, recipient, last_update, given_name, family_name, about, emoji, payment_address, badges FROM profiles" +
" WHERE account_uuid IN (SELECT DISTINCT uuid FROM accounts)" +
" AND recipient IN (SELECT DISTINCT rowid FROM recipients)",
)
if err != nil {
return err
}
defer rows.Close()
for rows.Next() {
var (
accountUUID uuid.UUID
recipient int64
last_update int64
given_name string
family_name string
about string
emoji string
payment_address []byte
badges sql.NullString
)
err = rows.Scan(&accountUUID, &recipient, &last_update, &given_name, &family_name, &about, &emoji, &payment_address, &badges)
if err != nil {
return err
}
_, err = dest.Exec(`
INSERT INTO signald_profiles
(account_uuid, recipient, last_update, given_name, family_name, about, emoji, payment_address, badges)
VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9)
`, accountUUID, recipient, last_update, given_name, family_name, about, emoji, payment_address, badges)
if err != nil {
return err
}
}
return nil
}
func moveProfileCapabilities(source *sql.DB, dest *sql.DB) error {
rows, err := source.Query("SELECT account_uuid, recipient, storage, gv1_migration, sender_key, announcement_group, change_number, stories FROM profile_capabilities" +
" WHERE account_uuid IN (SELECT DISTINCT uuid FROM accounts)" +
" AND recipient IN (SELECT DISTINCT rowid FROM recipients)",
)
if err != nil {
return err
}
defer rows.Close()
for rows.Next() {
var (
accountUUID uuid.UUID
recipient int64
storage bool
gv1_migration bool
sender_key bool
announcement_group bool
change_number bool
stories bool
)
err = rows.Scan(&accountUUID, &recipient, &storage, &gv1_migration, &sender_key, &announcement_group, &change_number, &stories)
if err != nil {
return err
}
_, err = dest.Exec(`
INSERT INTO signald_profile_capabilities
(account_uuid, recipient, storage, gv1_migration, sender_key, announcement_group, change_number, stories)
VALUES ($1, $2, $3, $4, $5, $6, $7, $8)
`, accountUUID, recipient, storage, gv1_migration, sender_key, announcement_group, change_number, stories)
if err != nil {
return err
}
}
return nil
}
func moveProfileBadges(source *sql.DB, dest *sql.DB) error {
rows, err := source.Query("SELECT account_uuid, id, category, name, description, sprite6 FROM profile_badges" +
" WHERE account_uuid IN (SELECT DISTINCT uuid FROM accounts)",
)
if err != nil {
return err
}
defer rows.Close()
for rows.Next() {
var (
accountUUID uuid.UUID
id string
category string
name string
description string
sprite6 string
)
err = rows.Scan(&accountUUID, &id, &category, &name, &description, &sprite6)
if err != nil {
return err
}
_, err = dest.Exec(`
INSERT INTO signald_profile_badges
(account_uuid, id, category, name, description, sprite6)
VALUES ($1, $2, $3, $4, $5, $6)
`, accountUUID, id, category, name, description, sprite6)
if err != nil {
return err
}
}
return nil
}

View file

@ -1,22 +1,8 @@
package db package db
var ( var (
pgScheme = ` // from signald in src/main/resources/db/migration/postgresql/V1__create_tables.sql
CREATE TABLE public.flyway_schema_history ( pgScheme = `CREATE TABLE signald_message_queue (
installed_rank integer NOT NULL,
version character varying(50),
description character varying(200) NOT NULL,
type character varying(20) NOT NULL,
script character varying(1000) NOT NULL,
checksum integer,
installed_by character varying(100) NOT NULL,
installed_on timestamp without time zone DEFAULT now() NOT NULL,
execution_time integer NOT NULL,
success boolean NOT NULL
);
-- from signald in src/main/resources/db/migration/postgresql/V1__create_tables.sql
CREATE TABLE signald_message_queue (
id SERIAL PRIMARY KEY, id SERIAL PRIMARY KEY,
account UUID NOT NULL, account UUID NOT NULL,
version INTEGER NOT NULL, version INTEGER NOT NULL,
@ -29,10 +15,9 @@ var (
legacy_message BYTEA, legacy_message BYTEA,
server_received_timestamp BIGINT, server_received_timestamp BIGINT,
server_delivered_timestamp BIGINT, server_delivered_timestamp BIGINT,
server_uuid UUID, server_uuid UUID
destination_uuid TEXT
); );
CREATE TABLE signald_servers ( CREATE TABLE signald_servers (
server_uuid UUID PRIMARY KEY, server_uuid UUID PRIMARY KEY,
service_url TEXT NOT NULL, service_url TEXT NOT NULL,
@ -50,7 +35,7 @@ var (
cds_mrenclave VARCHAR(64), cds_mrenclave VARCHAR(64),
ias_ca BYTEA ias_ca BYTEA
); );
INSERT INTO signald_servers VALUES INSERT INTO signald_servers VALUES
( (
'6e2eb5a8-5706-45d0-8377-127a816411a4', -- server_uuid '6e2eb5a8-5706-45d0-8377-127a816411a4', -- server_uuid
@ -104,78 +89,79 @@ var (
-- ias_ca -- ias_ca
E'\\x00000002000000141e139877c131235200356d48d741b9e8538d4a290000078101000369617300000164adeb7976000000000005582e3530390000054f3082054b308203b3a003020102020900d107765d32a3b094300d06092a864886f70d01010b0500307e310b3009060355040613025553310b300906035504080c0243413114301206035504070c0b53616e746120436c617261311a3018060355040a0c11496e74656c20436f72706f726174696f6e3130302e06035504030c27496e74656c20534758204174746573746174696f6e205265706f7274205369676e696e672043413020170d3136313131343135333733315a180f32303439313233313233353935395a307e310b3009060355040613025553310b300906035504080c0243413114301206035504070c0b53616e746120436c617261311a3018060355040a0c11496e74656c20436f72706f726174696f6e3130302e06035504030c27496e74656c20534758204174746573746174696f6e205265706f7274205369676e696e67204341308201a2300d06092a864886f70d01010105000382018f003082018a02820181009f3c647eb5773cbb512d2732c0d7415ebb55a0fa9ede2e649199e6821db910d53177370977466a6a5e4786ccd2ddebd4149d6a2f6325529dd10cc98737b0779c1a07e29c47a1ae004948476c489f45a5a15d7ac8ecc6acc645adb43d87679df59c093bc5a2e9696c5478541b979e754b573914be55d32ff4c09ddf27219934cd990527b3f92ed78fbf29246abecb71240ef39c2d7107b447545a7ffb10eb060a68a98580219e36910952683892d6a5e2a80803193e407531404e36b315623799aa825074409754a2dfe8f5afd5fe631e1fc2af3808906f28a790d9dd9fe060939b125790c5805d037df56a99531b96de69de33ed226cc1207d1042b5c9ab7f404fc711c0fe4769fb9578b1dc0ec469ea1a25e0ff9914886ef2699b235bb4847dd6ff40b606e6170793c2fb98b314587f9cfd257362dfeab10b3bd2d97673a1a4bd44c453aaf47fc1f2d3d0f384f74a06f89c089f0da6cdb7fceee8c9821a8e54f25c0416d18c46839a5f8012fbdd3dc74d256279adc2c0d55aff6f0622425d1b0203010001a381c93081c630600603551d1f045930573055a053a051864f687474703a2f2f7472757374656473657276696365732e696e74656c2e636f6d2f636f6e74656e742f43524c2f5347582f4174746573746174696f6e5265706f72745369676e696e6743412e63726c301d0603551d0e0416041478437b76a67ebcd0af7e4237eb357c3b8701513c301f0603551d2304183016801478437b76a67ebcd0af7e4237eb357c3b8701513c300e0603551d0f0101ff04040302010630120603551d130101ff040830060101ff020100300d06092a864886f70d01010b05000382018100785f2d60c5c80af42a797610213915da82c9b29e89e0902a25a6c75b16091c68ab204aae711889492c7e1e320911455a8fc13442312e77a63994d99795c8ea4576823cea8ad1e191cfa862fab8a932d3d9b0535a0702d0555f74e520e30330f33480e7adc9d7c81e20703142bf00c528a80b463381fd602a82c7035281aae59562ccb5334ea8903e650b010681f5ce8eb62eac9c414988243aec92f25bf13cdff7ebcc298ee51bba5a3538b66b26cbc45a51de003cad306531ad7cf5d4ef0f8805d1b9133d24135ab3c4641a2f8808349d7333295e0e76ee4bc5227232628efa80d79d92ab4e3d1120f3fb5ad119cd8d544aa1d4a6865e6b57beac5771307e2e3cb9070da47b4bfc8869e01413ea093541de8a792811b74636c5e91452cf0cee59f2fb404acd0bc584cb9c835404734c0e7ec6605cdfcf2ff439b6d4719f702f0e0c3fa04fdb12a6cb2ad1ab1c9af1f8f4c3a08edd72a32b0bb5d0ad256ffd159a683b2a5a1f1d11fa62532f03d754caef0da5735a1e5a884c7e89d91218c9d7008515e5f5992ccc471f3b1bc1aaec24a2997e6ad3' E'\\x00000002000000141e139877c131235200356d48d741b9e8538d4a290000078101000369617300000164adeb7976000000000005582e3530390000054f3082054b308203b3a003020102020900d107765d32a3b094300d06092a864886f70d01010b0500307e310b3009060355040613025553310b300906035504080c0243413114301206035504070c0b53616e746120436c617261311a3018060355040a0c11496e74656c20436f72706f726174696f6e3130302e06035504030c27496e74656c20534758204174746573746174696f6e205265706f7274205369676e696e672043413020170d3136313131343135333733315a180f32303439313233313233353935395a307e310b3009060355040613025553310b300906035504080c0243413114301206035504070c0b53616e746120436c617261311a3018060355040a0c11496e74656c20436f72706f726174696f6e3130302e06035504030c27496e74656c20534758204174746573746174696f6e205265706f7274205369676e696e67204341308201a2300d06092a864886f70d01010105000382018f003082018a02820181009f3c647eb5773cbb512d2732c0d7415ebb55a0fa9ede2e649199e6821db910d53177370977466a6a5e4786ccd2ddebd4149d6a2f6325529dd10cc98737b0779c1a07e29c47a1ae004948476c489f45a5a15d7ac8ecc6acc645adb43d87679df59c093bc5a2e9696c5478541b979e754b573914be55d32ff4c09ddf27219934cd990527b3f92ed78fbf29246abecb71240ef39c2d7107b447545a7ffb10eb060a68a98580219e36910952683892d6a5e2a80803193e407531404e36b315623799aa825074409754a2dfe8f5afd5fe631e1fc2af3808906f28a790d9dd9fe060939b125790c5805d037df56a99531b96de69de33ed226cc1207d1042b5c9ab7f404fc711c0fe4769fb9578b1dc0ec469ea1a25e0ff9914886ef2699b235bb4847dd6ff40b606e6170793c2fb98b314587f9cfd257362dfeab10b3bd2d97673a1a4bd44c453aaf47fc1f2d3d0f384f74a06f89c089f0da6cdb7fceee8c9821a8e54f25c0416d18c46839a5f8012fbdd3dc74d256279adc2c0d55aff6f0622425d1b0203010001a381c93081c630600603551d1f045930573055a053a051864f687474703a2f2f7472757374656473657276696365732e696e74656c2e636f6d2f636f6e74656e742f43524c2f5347582f4174746573746174696f6e5265706f72745369676e696e6743412e63726c301d0603551d0e0416041478437b76a67ebcd0af7e4237eb357c3b8701513c301f0603551d2304183016801478437b76a67ebcd0af7e4237eb357c3b8701513c300e0603551d0f0101ff04040302010630120603551d130101ff040830060101ff020100300d06092a864886f70d01010b05000382018100785f2d60c5c80af42a797610213915da82c9b29e89e0902a25a6c75b16091c68ab204aae711889492c7e1e320911455a8fc13442312e77a63994d99795c8ea4576823cea8ad1e191cfa862fab8a932d3d9b0535a0702d0555f74e520e30330f33480e7adc9d7c81e20703142bf00c528a80b463381fd602a82c7035281aae59562ccb5334ea8903e650b010681f5ce8eb62eac9c414988243aec92f25bf13cdff7ebcc298ee51bba5a3538b66b26cbc45a51de003cad306531ad7cf5d4ef0f8805d1b9133d24135ab3c4641a2f8808349d7333295e0e76ee4bc5227232628efa80d79d92ab4e3d1120f3fb5ad119cd8d544aa1d4a6865e6b57beac5771307e2e3cb9070da47b4bfc8869e01413ea093541de8a792811b74636c5e91452cf0cee59f2fb404acd0bc584cb9c835404734c0e7ec6605cdfcf2ff439b6d4719f702f0e0c3fa04fdb12a6cb2ad1ab1c9af1f8f4c3a08edd72a32b0bb5d0ad256ffd159a683b2a5a1f1d11fa62532f03d754caef0da5735a1e5a884c7e89d91218c9d7008515e5f5992ccc471f3b1bc1aaec24a2997e6ad3'
); );
CREATE TABLE signald_accounts ( CREATE TABLE signald_accounts (
uuid UUID NOT NULL, uuid UUID NOT NULL,
e164 TEXT NOT NULL, e164 TEXT NOT NULL,
filename TEXT NOT NULL,
server UUID NOT NULL REFERENCES signald_servers(server_uuid) ON DELETE CASCADE, server UUID NOT NULL REFERENCES signald_servers(server_uuid) ON DELETE CASCADE,
PRIMARY KEY (uuid, e164, server), PRIMARY KEY (uuid, e164, filename, server),
UNIQUE (e164), UNIQUE (e164),
UNIQUE (filename),
UNIQUE (uuid) UNIQUE (uuid)
); );
CREATE TABLE signald_recipients ( CREATE TABLE signald_recipients (
rowid SERIAL PRIMARY KEY, rowid SERIAL PRIMARY KEY,
account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE, account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE,
uuid UUID, uuid UUID,
e164 TEXT, e164 TEXT,
registered BOOLEAN DEFAULT true, -- from signald in src/main/resources/db/migration/postgresql/V13__recipient_registration_status.sql
UNIQUE (account_uuid, e164, uuid) UNIQUE (account_uuid, e164, uuid)
); );
CREATE TABLE signald_prekeys ( CREATE TABLE signald_prekeys (
account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE, account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE,
id INTEGER NOT NULL, id INTEGER NOT NULL,
record BYTEA NOT NULL, record BYTEA NOT NULL,
PRIMARY KEY (account_uuid, id) PRIMARY KEY (account_uuid, id)
); );
CREATE TABLE signald_sessions ( CREATE TABLE signald_sessions (
account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE, account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE,
recipient INTEGER NOT NULL REFERENCES signald_recipients(rowid) ON DELETE CASCADE, recipient INTEGER NOT NULL REFERENCES signald_recipients(rowid) ON DELETE CASCADE,
device_id INTEGER, device_id INTEGER,
record BYTEA NOT NULL, record BYTEA NOT NULL,
PRIMARY KEY (account_uuid, recipient, device_id) PRIMARY KEY (account_uuid, recipient, device_id)
); );
CREATE TABLE signald_signed_prekeys ( CREATE TABLE signald_signed_prekeys (
account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE, account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE,
id INTEGER NOT NULL, id INTEGER NOT NULL,
record BYTEA NOT NULL, record BYTEA NOT NULL,
PRIMARY KEY (account_uuid, id) PRIMARY KEY (account_uuid, id)
); );
CREATE TABLE signald_identity_keys ( CREATE TABLE signald_identity_keys (
account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE, account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE,
recipient INTEGER NOT NULL, recipient INTEGER NOT NULL,
identity_key BYTEA NOT NULL, identity_key BYTEA NOT NULL,
trust_level TEXT NOT NULL, trust_level TEXT NOT NULL,
added TIMESTAMP WITHOUT TIME ZONE DEFAULT CURRENT_TIMESTAMP, added TIMESTAMP WITHOUT TIME ZONE DEFAULT CURRENT_TIMESTAMP,
PRIMARY KEY (account_uuid, recipient, identity_key) PRIMARY KEY (account_uuid, recipient, identity_key)
); );
CREATE TABLE signald_account_data ( CREATE TABLE signald_account_data (
account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE, account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE,
key TEXT NOT NULL, key TEXT NOT NULL,
value BYTEA NOT NULL, value BYTEA NOT NULL,
PRIMARY KEY (account_uuid, key) PRIMARY KEY (account_uuid, key)
); );
CREATE TABLE signald_pending_account_data ( CREATE TABLE signald_pending_account_data (
username TEXT, username TEXT,
key TEXT NOT NULL, key TEXT NOT NULL,
value BYTEA NOT NULL, value BYTEA NOT NULL,
PRIMARY KEY (username, key) PRIMARY KEY (username, key)
); );
CREATE TABLE signald_sender_keys ( CREATE TABLE signald_sender_keys (
account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE, account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE,
address TEXT NOT NULL, address TEXT NOT NULL,
@ -183,19 +169,19 @@ var (
distribution_id UUID NOT NULL, distribution_id UUID NOT NULL,
record BYTEA NOT NULL, record BYTEA NOT NULL,
created_at TIMESTAMP WITHOUT TIME ZONE NOT NULL, created_at TIMESTAMP WITHOUT TIME ZONE NOT NULL,
PRIMARY KEY (account_uuid, address, device, distribution_id) PRIMARY KEY (account_uuid, address, device, distribution_id)
); );
CREATE TABLE signald_sender_key_shared ( CREATE TABLE signald_sender_key_shared (
account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE, account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE,
distribution_id UUID NOT NULL, distribution_id UUID NOT NULL,
address TEXT NOT NULL, address TEXT NOT NULL,
device INTEGER NOT NULL, device INTEGER NOT NULL,
PRIMARY KEY (account_uuid, address, device) PRIMARY KEY (account_uuid, address, device)
); );
CREATE TABLE signald_groups ( CREATE TABLE signald_groups (
rowid SERIAL PRIMARY KEY, rowid SERIAL PRIMARY KEY,
account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE, account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE,
@ -205,80 +191,29 @@ var (
last_avatar_fetch INTEGER, last_avatar_fetch INTEGER,
distribution_id UUID, distribution_id UUID,
group_info BYTEA, group_info BYTEA,
UNIQUE (account_uuid, group_id) UNIQUE (account_uuid, group_id)
); );
CREATE TABLE signald_group_credentials ( CREATE TABLE signald_group_credentials (
account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE, account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE,
date BIGINT NOT NULL, date BIGINT NOT NULL,
credential BYTEA NOT NULL, credential BYTEA NOT NULL,
PRIMARY KEY (account_uuid, date) PRIMARY KEY (account_uuid, date)
); );
-- from signald in src/main/resources/db/migration/postgresql/V12__create_contacts_table.sql CREATE TABLE public.flyway_schema_history (
CREATE TABLE signald_contacts ( installed_rank integer NOT NULL,
account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE, version character varying(50),
recipient INTEGER NOT NULL REFERENCES signald_recipients(rowid) ON DELETE CASCADE, description character varying(200) NOT NULL,
name TEXT, type character varying(20) NOT NULL,
color TEXT, script character varying(1000) NOT NULL,
profile_key BYTEA, checksum integer,
message_expiration_time INTEGER, installed_by character varying(100) NOT NULL,
inbox_position INTEGER, installed_on timestamp without time zone DEFAULT now() NOT NULL,
execution_time integer NOT NULL,
PRIMARY KEY (account_uuid, recipient) success boolean NOT NULL
);
-- from signald in src/main/resources/db/migration/postgresql/V15__profiles_tables.sql
CREATE TABLE signald_profile_keys (
account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE,
recipient INTEGER NOT NULL REFERENCES signald_recipients(rowid) ON DELETE CASCADE,
profile_key BYTEA DEFAULT NULL,
profile_key_credential BYTEA DEFAULT NULL,
request_pending boolean DEFAULT FALSE,
unidentified_access_mode int DEFAULT 0,
PRIMARY KEY (account_uuid, recipient)
);
CREATE TABLE signald_profiles (
account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE,
recipient INTEGER NOT NULL REFERENCES signald_recipients(rowid) ON DELETE CASCADE,
last_update BIGINT,
given_name TEXT,
family_name TEXT,
about TEXT,
emoji TEXT,
payment_address BYTEA,
badges TEXT,
PRIMARY KEY (account_uuid, recipient)
);
CREATE TABLE signald_profile_capabilities (
account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE,
recipient INTEGER NOT NULL REFERENCES signald_recipients(rowid) ON DELETE CASCADE,
storage BOOLEAN,
gv1_migration BOOLEAN,
sender_key BOOLEAN,
announcement_group BOOLEAN,
change_number BOOLEAN,
stories BOOLEAN,
PRIMARY KEY (account_uuid, recipient)
);
CREATE TABLE signald_profile_badges (
account_uuid UUID NOT NULL REFERENCES signald_accounts(uuid) ON DELETE CASCADE,
id TEXT NOT NULL,
category TEXT NOT NULL,
name TEXT NOT NULL,
description TEXT NOT NULL,
sprite6 TEXT NOT NULL,
PRIMARY KEY (account_uuid, id)
); );
` `
) )

View file

@ -25,7 +25,7 @@ import (
var DeviceCmd = &cobra.Command{ var DeviceCmd = &cobra.Command{
Use: "device", Use: "device",
Aliases: []string{"devices"}, Aliases: []string{"msg", "devices"},
} }
func init() { func init() {

View file

@ -1,102 +0,0 @@
// Copyright © 2021 Finn Herzfeld <finn@janky.solutions>
//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program. If not, see <http://www.gnu.org/licenses/>.
package preview
import (
"encoding/json"
"errors"
"log"
"os"
"strings"
"github.com/jedib0t/go-pretty/v6/table"
"github.com/spf13/cobra"
"gopkg.in/yaml.v2"
"gitlab.com/signald/signald-go/cmd/signaldctl/common"
"gitlab.com/signald/signald-go/cmd/signaldctl/config"
"gitlab.com/signald/signald-go/signald/client-protocol/v1"
)
var (
account string
joinURL string
PreviewGroupCmd = &cobra.Command{
Use: "preview https://signal.group/...",
Short: "preview information about a group without joining",
PreRunE: func(cmd *cobra.Command, args []string) error {
if account == "" {
account = config.Config.DefaultAccount
}
if account == "" {
common.Must(cmd.Help())
log.Fatal("No account specified. Please specify with --account or set a default")
}
if len(args) == 0 {
return errors.New("please specify signald.group URL")
}
joinURL = args[0]
if !strings.HasPrefix(joinURL, "https://signal.group/#") {
return errors.New("invalid group link (must start with https://signal.group/#")
}
return nil
},
RunE: func(_ *cobra.Command, args []string) error {
go common.Signald.Listen(nil)
req := v1.GroupLinkInfoRequest{
Account: account,
Uri: joinURL,
}
info, err := req.Submit(common.Signald)
if err != nil {
return err
}
switch common.OutputFormat {
case common.OutputFormatJSON:
return json.NewEncoder(os.Stdout).Encode(info)
case common.OutputFormatYAML:
return yaml.NewEncoder(os.Stdout).Encode(info)
case common.OutputFormatDefault, common.OutputFormatTable:
t := table.NewWriter()
t.SetOutputMirror(os.Stdout)
joinApproval := "unknown"
switch info.AddFromInviteLink {
case 3:
joinApproval = "yes"
case 1:
joinApproval = "no"
}
t.AppendRows([]table.Row{
table.Row{"Title", info.Title},
table.Row{"Group ID", info.GroupID},
table.Row{"Member Count", info.MemberCount},
table.Row{"Membership Approval", joinApproval},
})
common.StylizeTable(t)
t.Render()
}
return nil
},
}
)

View file

@ -24,7 +24,6 @@ import (
"gitlab.com/signald/signald-go/cmd/signaldctl/cmd/group/join" "gitlab.com/signald/signald-go/cmd/signaldctl/cmd/group/join"
"gitlab.com/signald/signald-go/cmd/signaldctl/cmd/group/leave" "gitlab.com/signald/signald-go/cmd/signaldctl/cmd/group/leave"
"gitlab.com/signald/signald-go/cmd/signaldctl/cmd/group/list" "gitlab.com/signald/signald-go/cmd/signaldctl/cmd/group/list"
"gitlab.com/signald/signald-go/cmd/signaldctl/cmd/group/preview"
"gitlab.com/signald/signald-go/cmd/signaldctl/cmd/group/removemember" "gitlab.com/signald/signald-go/cmd/signaldctl/cmd/group/removemember"
"gitlab.com/signald/signald-go/cmd/signaldctl/cmd/group/show" "gitlab.com/signald/signald-go/cmd/signaldctl/cmd/group/show"
"gitlab.com/signald/signald-go/cmd/signaldctl/cmd/group/update" "gitlab.com/signald/signald-go/cmd/signaldctl/cmd/group/update"
@ -42,7 +41,6 @@ func init() {
GroupCmd.AddCommand(join.JoinGroupCmd) GroupCmd.AddCommand(join.JoinGroupCmd)
GroupCmd.AddCommand(leave.LeaveGroupCmd) GroupCmd.AddCommand(leave.LeaveGroupCmd)
GroupCmd.AddCommand(list.ListGroupCmd) GroupCmd.AddCommand(list.ListGroupCmd)
GroupCmd.AddCommand(preview.PreviewGroupCmd)
GroupCmd.AddCommand(removemember.RemoveMemberCmd) GroupCmd.AddCommand(removemember.RemoveMemberCmd)
GroupCmd.AddCommand(show.ShowGroupCmd) GroupCmd.AddCommand(show.ShowGroupCmd)
GroupCmd.AddCommand(update.UpdateGroupCmd) GroupCmd.AddCommand(update.UpdateGroupCmd)

View file

@ -18,11 +18,8 @@ package send
import ( import (
"encoding/json" "encoding/json"
"fmt" "fmt"
"io"
"io/ioutil"
"log" "log"
"os" "os"
"os/exec"
"path/filepath" "path/filepath"
"strings" "strings"
@ -32,23 +29,17 @@ import (
"gitlab.com/signald/signald-go/cmd/signaldctl/common" "gitlab.com/signald/signald-go/cmd/signaldctl/common"
"gitlab.com/signald/signald-go/cmd/signaldctl/config" "gitlab.com/signald/signald-go/cmd/signaldctl/config"
v1 "gitlab.com/signald/signald-go/signald/client-protocol/v1" "gitlab.com/signald/signald-go/signald/client-protocol/v1"
)
const (
CAPTCHA_HELPER = "signal-captcha-helper"
) )
var ( var (
account string account string
toAddress *v1.JsonAddress toAddress *v1.JsonAddress
toGroup string toGroup string
attachments []string attachments []string
message string
captchaHelper bool
SendMessageCmd = &cobra.Command{ SendMessageCmd = &cobra.Command{
Use: "send {group id | phone number} [message]", Use: "send <group id | phone number> <message>",
Short: "send a message", Short: "send a message",
PreRun: func(cmd *cobra.Command, args []string) { PreRun: func(cmd *cobra.Command, args []string) {
if account == "" { if account == "" {
@ -58,20 +49,9 @@ var (
common.Must(cmd.Help()) common.Must(cmd.Help())
log.Fatal("No account specified. Please specify with --account or set a default") log.Fatal("No account specified. Please specify with --account or set a default")
} }
if len(args) < 1 { if len(args) < 2 {
common.Must(cmd.Help()) common.Must(cmd.Help())
log.Fatal("must specify both destination (either group id or phone number)") log.Fatal("must specify both destination (either group id or phone number) and message")
}
if len(args) == 1 {
messageBytes, err := ioutil.ReadAll(os.Stdin)
if err != nil {
log.Println("error reading message from stdin, perhaps you meant to include it in the command line arguments?")
panic(err)
}
message = string(messageBytes)
} else {
message = strings.Join(args[1:], " ")
} }
to, err := common.StringToAddress(args[0]) to, err := common.StringToAddress(args[0])
if err != nil { if err != nil {
@ -85,7 +65,7 @@ var (
req := v1.SendRequest{ req := v1.SendRequest{
Username: account, Username: account,
MessageBody: message, MessageBody: strings.Join(args[1:], " "),
Attachments: []*v1.JsonAttachment{}, Attachments: []*v1.JsonAttachment{},
RecipientAddress: toAddress, RecipientAddress: toAddress,
RecipientGroupID: toGroup, RecipientGroupID: toGroup,
@ -104,48 +84,6 @@ var (
if err != nil { if err != nil {
log.Fatal("error sending request to signald: ", err) log.Fatal("error sending request to signald: ", err)
} }
resends := []*v1.JsonAddress{}
for _, result := range resp.Results {
if result.ProofRequiredFailure != nil {
if captchaHelper {
err = runCaptchaHelper(result.ProofRequiredFailure.Token)
if err != nil {
log.Println("error running captcha helper: ", err)
}
resends = append(resends, result.Address)
}
}
}
if len(resends) > 0 {
resendReq := v1.SendRequest{
Username: req.Username,
MessageBody: req.MessageBody,
Attachments: req.Attachments,
RecipientGroupID: req.RecipientGroupID,
Members: resends,
Timestamp: resp.Timestamp,
}
resendResponse, err := resendReq.Submit(common.Signald)
if err != nil {
log.Println("error resending messages: ", err)
} else {
for i, originalResult := range resp.Results {
if originalResult.ProofRequiredFailure == nil {
continue
}
for _, result := range resendResponse.Results {
if result.Address.UUID == originalResult.Address.UUID {
resp.Results[i] = result
}
}
}
}
}
switch common.OutputFormat { switch common.OutputFormat {
case common.OutputFormatJSON: case common.OutputFormatJSON:
err := json.NewEncoder(os.Stdout).Encode(resp) err := json.NewEncoder(os.Stdout).Encode(resp)
@ -197,55 +135,7 @@ var (
} }
) )
func runCaptchaHelper(challenge string) error {
if !captchaHelper {
return nil
}
_, err := exec.LookPath(CAPTCHA_HELPER)
if err != nil {
return err
}
cmd := exec.Command(CAPTCHA_HELPER, "--challenge")
stdout, err := cmd.StdoutPipe()
if err != nil {
return err
}
err = cmd.Start()
if err != nil {
return err
}
captchaToken := new(strings.Builder)
_, err = io.Copy(captchaToken, stdout)
if err != nil {
return err
}
err = cmd.Wait()
if err != nil {
return err
}
req := v1.SubmitChallengeRequest{
Account: account,
CaptchaToken: captchaToken.String(),
Challenge: challenge,
}
err = req.Submit(common.Signald)
if err != nil {
return err
}
return nil
}
func init() { func init() {
SendMessageCmd.Flags().StringVarP(&account, "account", "a", "", "local account to use") SendMessageCmd.Flags().StringVarP(&account, "account", "a", "", "local account to use")
SendMessageCmd.Flags().BoolVarP(&captchaHelper, "captcha-helper", "c", false, "Invoke signal-captcha-helper and process the response when a push challenge response appears. After completing the challenge, the message will be redelivered to the failed recipient")
SendMessageCmd.Flags().StringSliceVarP(&attachments, "attachment", "A", []string{}, "attach a file to your outbound message. may be specified multiple times.") SendMessageCmd.Flags().StringSliceVarP(&attachments, "attachment", "A", []string{}, "attach a file to your outbound message. may be specified multiple times.")
} }

View file

@ -15,6 +15,7 @@
package session package session
import ( import (
"github.com/spf13/cobra" "github.com/spf13/cobra"
) )

View file

@ -1,96 +0,0 @@
package cmd
import (
"encoding/json"
"fmt"
"log"
"os"
"github.com/spf13/cobra"
"gitlab.com/signald/signald-go/cmd/signaldctl/common"
"gitlab.com/signald/signald-go/cmd/signaldctl/config"
client_protocol "gitlab.com/signald/signald-go/signald/client-protocol"
v1 "gitlab.com/signald/signald-go/signald/client-protocol/v1"
)
var (
accountIdentifier string
subscribeCmd = &cobra.Command{
Use: "subscribe",
Short: "subscribe to incoming messages from signald",
Long: `subscribe to incoming messages from signald.
if no default account is set, the -a/--account argument is required.
the default output format (-o default) is being worked on, subject to change and should not be relied upon. Thoughts? come by the #signald IRC/matrix room
if you want to future-proof your scripts, use json output (-o json) and parse it.`,
PreRun: func(cmd *cobra.Command, args []string) {
if accountIdentifier == "" {
accountIdentifier = config.Config.DefaultAccount
}
if accountIdentifier == "" {
common.Must(cmd.Help())
log.Fatal("No account specified. Please specify with --account or set a default")
}
},
RunE: func(cmd *cobra.Command, args []string) error {
incoming := make(chan client_protocol.BasicResponse)
go common.Signald.Listen(incoming)
req := v1.SubscribeRequest{Account: accountIdentifier}
err := req.Submit(common.Signald)
if err != nil {
panic(err)
}
for msg := range incoming {
switch common.OutputFormat {
case common.OutputFormatDefault:
if msg.Type != "IncomingMessage" {
continue
}
var data v1.IncomingMessage
err := json.Unmarshal(msg.Data, &data)
if err != nil {
continue
}
if data.DataMessage == nil {
continue
}
group := "-"
if data.DataMessage.GroupV2 != nil {
group = fmt.Sprintf("%s|%d", data.DataMessage.GroupV2.ID, data.DataMessage.GroupV2.Revision)
}
attachment := "-"
if len(data.DataMessage.Attachments) > 0 {
attachment = data.DataMessage.Attachments[0].StoredFilename
}
body := "-"
if data.DataMessage.Body != "" {
body = data.DataMessage.Body
}
fmt.Println(data.DataMessage.Timestamp, data.Account, data.Source.UUID, group, attachment, body)
case common.OutputFormatJSON:
err := json.NewEncoder(os.Stdout).Encode(msg)
if err != nil {
panic(err)
}
default:
log.Fatal("unsupported output format")
}
}
return nil
},
}
)
func init() {
subscribeCmd.Flags().StringVarP(&accountIdentifier, "account", "a", "", "the signald account to use")
RootCmd.AddCommand(subscribeCmd)
}

View file

@ -18,7 +18,6 @@ package config
import ( import (
"log" "log"
"os" "os"
"path"
"gopkg.in/yaml.v2" "gopkg.in/yaml.v2"
) )
@ -55,9 +54,6 @@ func Load() error {
} }
func Save() error { func Save() error {
if err := os.MkdirAll(path.Dir(Path), 0770); err != nil {
return err
}
f, err := os.Create(Path) f, err := os.Create(Path)
if err != nil { if err != nil {
return err return err

File diff suppressed because one or more lines are too long

View file

@ -5,10 +5,10 @@ import (
) )
type BasicResponse struct { type BasicResponse struct {
ID string `json:"id,omitempty"` ID string
Type string `json:"type,omitempty"` Type string
ErrorType string `json:"error_type,omitempty"` ErrorType string
Error json.RawMessage `json:"error,omitempty"` Error json.RawMessage
Data json.RawMessage `json:"data,omitempty"` Data json.RawMessage
Account string `json:"account,omitempty"` Account string
} }

View file

@ -291,7 +291,6 @@ type OfferMessage struct {
} }
type Optional struct { type Optional struct {
Empty bool `json:"empty,omitempty" yaml:"empty,omitempty"`
Present bool `json:"present,omitempty" yaml:"present,omitempty"` Present bool `json:"present,omitempty" yaml:"present,omitempty"`
} }

View file

@ -81,13 +81,6 @@ func mkerr(response client_protocol.BasicResponse) error {
return err return err
} }
return result return result
case "GroupPatchNotAcceptedError":
result := GroupPatchNotAcceptedError{}
err := json.Unmarshal(response.Error, &result)
if err != nil {
return err
}
return result
case "GroupVerificationError": case "GroupVerificationError":
result := GroupVerificationError{} result := GroupVerificationError{}
err := json.Unmarshal(response.Error, &result) err := json.Unmarshal(response.Error, &result)
@ -214,13 +207,6 @@ func mkerr(response client_protocol.BasicResponse) error {
return err return err
} }
return result return result
case "ProtocolInvalidKeyIdError":
result := ProtocolInvalidKeyIdError{}
err := json.Unmarshal(response.Error, &result)
if err != nil {
return err
}
return result
case "ProtocolInvalidMessageError": case "ProtocolInvalidMessageError":
result := ProtocolInvalidMessageError{} result := ProtocolInvalidMessageError{}
err := json.Unmarshal(response.Error, &result) err := json.Unmarshal(response.Error, &result)
@ -228,13 +214,6 @@ func mkerr(response client_protocol.BasicResponse) error {
return err return err
} }
return result return result
case "ProtocolNoSessionError":
result := ProtocolNoSessionError{}
err := json.Unmarshal(response.Error, &result)
if err != nil {
return err
}
return result
case "RateLimitError": case "RateLimitError":
result := RateLimitError{} result := RateLimitError{}
err := json.Unmarshal(response.Error, &result) err := json.Unmarshal(response.Error, &result)
@ -242,13 +221,6 @@ func mkerr(response client_protocol.BasicResponse) error {
return err return err
} }
return result return result
case "SQLError":
result := SQLError{}
err := json.Unmarshal(response.Error, &result)
if err != nil {
return err
}
return result
case "ScanTimeoutError": case "ScanTimeoutError":
result := ScanTimeoutError{} result := ScanTimeoutError{}
err := json.Unmarshal(response.Error, &result) err := json.Unmarshal(response.Error, &result)
@ -284,13 +256,6 @@ func mkerr(response client_protocol.BasicResponse) error {
return err return err
} }
return result return result
case "UnsupportedGroupError":
result := UnsupportedGroupError{}
err := json.Unmarshal(response.Error, &result)
if err != nil {
return err
}
return result
case "UntrustedIdentityError": case "UntrustedIdentityError":
result := UntrustedIdentityError{} result := UntrustedIdentityError{}
err := json.Unmarshal(response.Error, &result) err := json.Unmarshal(response.Error, &result)
@ -344,7 +309,7 @@ func (e AttachmentTooLargeError) Error() string {
return e.Message return e.Message
} }
// AuthorizationFailedError: Indicates the server rejected our credentials or a failed group update. Typically means the linked device was removed by the primary device, or that the account was re-registered. For group updates, this can indicate that we lack permissions. // AuthorizationFailedError: indicates the server rejected our credentials. Typically means the linked device was removed by the primary device, or that the account was re-registered
type AuthorizationFailedError struct { type AuthorizationFailedError struct {
Message string `json:"message,omitempty" yaml:"message,omitempty"` Message string `json:"message,omitempty" yaml:"message,omitempty"`
} }
@ -395,15 +360,6 @@ func (e GroupNotActiveError) Error() string {
return e.Message return e.Message
} }
// GroupPatchNotAcceptedError: Indicates the server rejected our group update. This can be due to errors such as trying to add a user that's already in the group.
type GroupPatchNotAcceptedError struct {
Message string `json:"message,omitempty" yaml:"message,omitempty"`
}
func (e GroupPatchNotAcceptedError) Error() string {
return e.Message
}
type GroupVerificationError struct { type GroupVerificationError struct {
Message string `json:"message,omitempty" yaml:"message,omitempty"` Message string `json:"message,omitempty" yaml:"message,omitempty"`
} }
@ -555,19 +511,6 @@ func (e ProofRequiredError) Error() string {
return e.Message return e.Message
} }
type ProtocolInvalidKeyIdError struct {
ContentHint int32 `json:"content_hint,omitempty" yaml:"content_hint,omitempty"`
GroupId string `json:"group_id,omitempty" yaml:"group_id,omitempty"`
Message string `json:"message,omitempty" yaml:"message,omitempty"`
Sender string `json:"sender,omitempty" yaml:"sender,omitempty"`
SenderDevice int32 `json:"sender_device,omitempty" yaml:"sender_device,omitempty"`
Timestamp int64 `json:"timestamp,omitempty" yaml:"timestamp,omitempty"`
}
func (e ProtocolInvalidKeyIdError) Error() string {
return e.Message
}
type ProtocolInvalidMessageError struct { type ProtocolInvalidMessageError struct {
ContentHint int32 `json:"content_hint,omitempty" yaml:"content_hint,omitempty"` ContentHint int32 `json:"content_hint,omitempty" yaml:"content_hint,omitempty"`
GroupId string `json:"group_id,omitempty" yaml:"group_id,omitempty"` GroupId string `json:"group_id,omitempty" yaml:"group_id,omitempty"`
@ -581,19 +524,6 @@ func (e ProtocolInvalidMessageError) Error() string {
return e.Message return e.Message
} }
type ProtocolNoSessionError struct {
ContentHint int32 `json:"content_hint,omitempty" yaml:"content_hint,omitempty"`
GroupId string `json:"group_id,omitempty" yaml:"group_id,omitempty"`
Message string `json:"message,omitempty" yaml:"message,omitempty"`
Sender string `json:"sender,omitempty" yaml:"sender,omitempty"`
SenderDevice int32 `json:"sender_device,omitempty" yaml:"sender_device,omitempty"`
Timestamp int64 `json:"timestamp,omitempty" yaml:"timestamp,omitempty"`
}
func (e ProtocolNoSessionError) Error() string {
return e.Message
}
type RateLimitError struct { type RateLimitError struct {
Message string `json:"message,omitempty" yaml:"message,omitempty"` Message string `json:"message,omitempty" yaml:"message,omitempty"`
} }
@ -602,14 +532,6 @@ func (e RateLimitError) Error() string {
return e.Message return e.Message
} }
type SQLError struct {
Message string `json:"message,omitempty" yaml:"message,omitempty"`
}
func (e SQLError) Error() string {
return e.Message
}
type ScanTimeoutError struct { type ScanTimeoutError struct {
Message string `json:"message,omitempty" yaml:"message,omitempty"` Message string `json:"message,omitempty" yaml:"message,omitempty"`
} }
@ -652,15 +574,6 @@ func (e UnregisteredUserError) Error() string {
return e.Message return e.Message
} }
// UnsupportedGroupError: returned in response to use v1 groups, which are no longer supported
type UnsupportedGroupError struct {
Message string `json:"message,omitempty" yaml:"message,omitempty"`
}
func (e UnsupportedGroupError) Error() string {
return e.Message
}
type UntrustedIdentityError struct { type UntrustedIdentityError struct {
Identifier string `json:"identifier,omitempty" yaml:"identifier,omitempty"` Identifier string `json:"identifier,omitempty" yaml:"identifier,omitempty"`
IdentityKey **IdentityKey `json:"identity_key,omitempty" yaml:"identity_key,omitempty"` IdentityKey **IdentityKey `json:"identity_key,omitempty" yaml:"identity_key,omitempty"`

View file

@ -16,14 +16,15 @@ func (r *AcceptInvitationRequest) Submit(conn *signald.Signald) (response JsonGr
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -48,14 +49,15 @@ func (r *AddLinkedDeviceRequest) Submit(conn *signald.Signald) (err error) {
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -73,14 +75,15 @@ func (r *AddServerRequest) Submit(conn *signald.Signald) (response string, err e
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -105,45 +108,14 @@ func (r *ApproveMembershipRequest) Submit(conn *signald.Signald) (response JsonG
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
rawResponse := <-responseChannel
if rawResponse.Error != nil {
err = mkerr(rawResponse)
return
}
err = json.Unmarshal(rawResponse.Data, &response)
if err != nil {
rawResponseJson, _ := rawResponse.Data.MarshalJSON()
log.Println("signald-go: error unmarshalling response from signald of type", rawResponse.Type, string(rawResponseJson))
return
}
return response, nil
}
// Submit: Bans users from a group. This works even if the users aren't in the group. If they are currently in the group, they will also be removed.
func (r *BanUserRequest) Submit(conn *signald.Signald) (response JsonGroupV2Info, err error) {
r.Version = "v1"
r.Type = "ban_user"
if r.ID == "" {
r.ID = signald.GenerateID()
}
responseChannel := conn.GetResponseListener(r.ID) responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID) defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r)
if err != nil {
log.Println("signald-go: error submitting request to signald")
return
}
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
@ -168,14 +140,15 @@ func (r *CreateGroupRequest) Submit(conn *signald.Signald) (response JsonGroupV2
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -200,14 +173,15 @@ func (r *DeleteAccountRequest) Submit(conn *signald.Signald) (err error) {
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -224,14 +198,15 @@ func (r *RemoveServerRequest) Submit(conn *signald.Signald) (err error) {
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -249,14 +224,15 @@ func (r *FinishLinkRequest) Submit(conn *signald.Signald) (response Account, err
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -281,14 +257,15 @@ func (r *GenerateLinkingURIRequest) Submit(conn *signald.Signald) (response Link
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -313,14 +290,15 @@ func (r *GetAllIdentities) Submit(conn *signald.Signald) (response AllIdentityKe
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -345,45 +323,14 @@ func (r *GetGroupRequest) Submit(conn *signald.Signald) (response JsonGroupV2Inf
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
rawResponse := <-responseChannel
if rawResponse.Error != nil {
err = mkerr(rawResponse)
return
}
err = json.Unmarshal(rawResponse.Data, &response)
if err != nil {
rawResponseJson, _ := rawResponse.Data.MarshalJSON()
log.Println("signald-go: error unmarshalling response from signald of type", rawResponse.Type, string(rawResponseJson))
return
}
return response, nil
}
// Submit: Query the server for group revision history. The history contains information about the changes between each revision and the user that made the change.
func (r *GetGroupRevisionPagesRequest) Submit(conn *signald.Signald) (response GroupHistoryPage, err error) {
r.Version = "v1"
r.Type = "get_group_revision_pages"
if r.ID == "" {
r.ID = signald.GenerateID()
}
responseChannel := conn.GetResponseListener(r.ID) responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID) defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r)
if err != nil {
log.Println("signald-go: error submitting request to signald")
return
}
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
@ -409,14 +356,15 @@ func (r *GetIdentitiesRequest) Submit(conn *signald.Signald) (response IdentityK
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -441,14 +389,15 @@ func (r *GetLinkedDevicesRequest) Submit(conn *signald.Signald) (response Linked
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -473,14 +422,15 @@ func (r *GetProfileRequest) Submit(conn *signald.Signald) (response Profile, err
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -505,14 +455,15 @@ func (r *RemoteConfigRequest) Submit(conn *signald.Signald) (response RemoteConf
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -536,14 +487,15 @@ func (r *GetServersRequest) Submit(conn *signald.Signald) (response ServerList,
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -568,14 +520,15 @@ func (r *GroupLinkInfoRequest) Submit(conn *signald.Signald) (response JsonGroup
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -600,14 +553,15 @@ func (r *IsIdentifierRegisteredRequest) Submit(conn *signald.Signald) (response
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -632,14 +586,15 @@ func (r *JoinGroupRequest) Submit(conn *signald.Signald) (response JsonGroupJoin
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -663,14 +618,15 @@ func (r *LeaveGroupRequest) Submit(conn *signald.Signald) (response GroupInfo, e
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -695,14 +651,15 @@ func (r *ListAccountsRequest) Submit(conn *signald.Signald) (response AccountLis
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -726,14 +683,15 @@ func (r *ListContactsRequest) Submit(conn *signald.Signald) (response ProfileLis
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -757,14 +715,15 @@ func (r *ListGroupsRequest) Submit(conn *signald.Signald) (response GroupList, e
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -788,14 +747,15 @@ func (r *MarkReadRequest) Submit(conn *signald.Signald) (err error) {
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -813,14 +773,15 @@ func (r *ReactRequest) Submit(conn *signald.Signald) (response SendResponse, err
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -845,14 +806,15 @@ func (r *RefuseMembershipRequest) Submit(conn *signald.Signald) (response JsonGr
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -877,14 +839,15 @@ func (r *RegisterRequest) Submit(conn *signald.Signald) (response Account, err e
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -909,14 +872,15 @@ func (r *RemoteDeleteRequest) Submit(conn *signald.Signald) (response SendRespon
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -941,14 +905,15 @@ func (r *RemoveLinkedDeviceRequest) Submit(conn *signald.Signald) (err error) {
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -966,14 +931,15 @@ func (r *RequestSyncRequest) Submit(conn *signald.Signald) (err error) {
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -991,14 +957,15 @@ func (r *ResetSessionRequest) Submit(conn *signald.Signald) (response SendRespon
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -1023,14 +990,15 @@ func (r *ResolveAddressRequest) Submit(conn *signald.Signald) (response JsonAddr
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -1054,14 +1022,15 @@ func (r *SendRequest) Submit(conn *signald.Signald) (response SendResponse, err
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -1086,45 +1055,14 @@ func (r *SendPaymentRequest) Submit(conn *signald.Signald) (response SendRespons
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
rawResponse := <-responseChannel
if rawResponse.Error != nil {
err = mkerr(rawResponse)
return
}
err = json.Unmarshal(rawResponse.Data, &response)
if err != nil {
rawResponseJson, _ := rawResponse.Data.MarshalJSON()
log.Println("signald-go: error unmarshalling response from signald of type", rawResponse.Type, string(rawResponseJson))
return
}
return response, nil
}
// Submit: Sends a sync message to the account's devices
func (r *SendSyncMessageRequest) Submit(conn *signald.Signald) (response JsonSendMessageResult, err error) {
r.Version = "v1"
r.Type = "send_sync_message"
if r.ID == "" {
r.ID = signald.GenerateID()
}
responseChannel := conn.GetResponseListener(r.ID) responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID) defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r)
if err != nil {
log.Println("signald-go: error submitting request to signald")
return
}
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
@ -1150,14 +1088,15 @@ func (r *SetDeviceNameRequest) Submit(conn *signald.Signald) (err error) {
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -1175,14 +1114,15 @@ func (r *SetExpirationRequest) Submit(conn *signald.Signald) (response SendRespo
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -1206,14 +1146,15 @@ func (r *SetProfile) Submit(conn *signald.Signald) (err error) {
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -1230,14 +1171,15 @@ func (r *SubmitChallengeRequest) Submit(conn *signald.Signald) (err error) {
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -1255,14 +1197,15 @@ func (r *SubscribeRequest) Submit(conn *signald.Signald) (err error) {
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -1280,14 +1223,15 @@ func (r *TrustRequest) Submit(conn *signald.Signald) (err error) {
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -1305,14 +1249,15 @@ func (r *TypingRequest) Submit(conn *signald.Signald) (err error) {
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -1323,38 +1268,6 @@ func (r *TypingRequest) Submit(conn *signald.Signald) (err error) {
} }
// Submit: Unbans users from a group.
func (r *UnbanUserRequest) Submit(conn *signald.Signald) (response JsonGroupV2Info, err error) {
r.Version = "v1"
r.Type = "unban_user"
if r.ID == "" {
r.ID = signald.GenerateID()
}
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r)
if err != nil {
log.Println("signald-go: error submitting request to signald")
return
}
rawResponse := <-responseChannel
if rawResponse.Error != nil {
err = mkerr(rawResponse)
return
}
err = json.Unmarshal(rawResponse.Data, &response)
if err != nil {
rawResponseJson, _ := rawResponse.Data.MarshalJSON()
log.Println("signald-go: error unmarshalling response from signald of type", rawResponse.Type, string(rawResponseJson))
return
}
return response, nil
}
// Submit: See subscribe for more info // Submit: See subscribe for more info
func (r *UnsubscribeRequest) Submit(conn *signald.Signald) (err error) { func (r *UnsubscribeRequest) Submit(conn *signald.Signald) (err error) {
r.Version = "v1" r.Version = "v1"
@ -1362,14 +1275,15 @@ func (r *UnsubscribeRequest) Submit(conn *signald.Signald) (err error) {
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -1387,14 +1301,15 @@ func (r *UpdateContactRequest) Submit(conn *signald.Signald) (response Profile,
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -1419,14 +1334,15 @@ func (r *UpdateGroupRequest) Submit(conn *signald.Signald) (response GroupInfo,
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -1451,14 +1367,15 @@ func (r *VerifyRequest) Submit(conn *signald.Signald) (response Account, err err
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -1482,14 +1399,15 @@ func (r *VersionRequest) Submit(conn *signald.Signald) (response JsonVersionMess
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)
@ -1514,14 +1432,15 @@ func (r *WaitForScanRequest) Submit(conn *signald.Signald) (err error) {
if r.ID == "" { if r.ID == "" {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <-responseChannel rawResponse := <-responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)

View file

@ -25,7 +25,6 @@ type Account struct {
Address *JsonAddress `json:"address,omitempty" yaml:"address,omitempty"` // The address of this account Address *JsonAddress `json:"address,omitempty" yaml:"address,omitempty"` // The address of this account
DeviceId int32 `json:"device_id,omitempty" yaml:"device_id,omitempty"` // The Signal device ID. Official Signal mobile clients (iPhone and Android) have device ID = 1, while linked devices such as Signal Desktop or Signal iPad have higher device IDs. DeviceId int32 `json:"device_id,omitempty" yaml:"device_id,omitempty"` // The Signal device ID. Official Signal mobile clients (iPhone and Android) have device ID = 1, while linked devices such as Signal Desktop or Signal iPad have higher device IDs.
Pending bool `json:"pending,omitempty" yaml:"pending,omitempty"` // indicates the account has not completed registration Pending bool `json:"pending,omitempty" yaml:"pending,omitempty"` // indicates the account has not completed registration
Pni string `json:"pni,omitempty" yaml:"pni,omitempty"`
} }
type AccountList struct { type AccountList struct {
@ -63,19 +62,6 @@ type ApproveMembershipRequest struct {
Members []*JsonAddress `json:"members,omitempty" yaml:"members,omitempty"` // list of requesting members to approve Members []*JsonAddress `json:"members,omitempty" yaml:"members,omitempty"` // list of requesting members to approve
} }
// BanUserRequest: Bans users from a group. This works even if the users aren't in the group. If they are currently in the group, they will also be removed.
type BanUserRequest struct {
Request
Account string `json:"account,omitempty" yaml:"account,omitempty"` // The account to interact with
GroupId string `json:"group_id,omitempty" yaml:"group_id,omitempty"`
Users []*JsonAddress `json:"users,omitempty" yaml:"users,omitempty"` // List of users to ban
}
type BannedGroupMember struct {
Timestamp int64 `json:"timestamp,omitempty" yaml:"timestamp,omitempty"` // Timestamp as milliseconds since Unix epoch of when the user was banned. This field is set by the server.
UUID string `json:"uuid,omitempty" yaml:"uuid,omitempty"`
}
// BooleanMessage: A message containing a single boolean, usually as a response // BooleanMessage: A message containing a single boolean, usually as a response
type BooleanMessage struct { type BooleanMessage struct {
Value bool `json:"value,omitempty" yaml:"value,omitempty"` Value bool `json:"value,omitempty" yaml:"value,omitempty"`
@ -99,10 +85,9 @@ type Capabilities struct {
AnnouncementGroup bool `json:"announcement_group,omitempty" yaml:"announcement_group,omitempty"` AnnouncementGroup bool `json:"announcement_group,omitempty" yaml:"announcement_group,omitempty"`
ChangeNumber bool `json:"change_number,omitempty" yaml:"change_number,omitempty"` ChangeNumber bool `json:"change_number,omitempty" yaml:"change_number,omitempty"`
Gv1Migration bool `json:"gv1-migration,omitempty" yaml:"gv1-migration,omitempty"` Gv1Migration bool `json:"gv1-migration,omitempty" yaml:"gv1-migration,omitempty"`
Gv2 bool `json:"gv2,omitempty" yaml:"gv2,omitempty"` // this capability is deprecated and will always be true Gv2 bool `json:"gv2,omitempty" yaml:"gv2,omitempty"`
SenderKey bool `json:"sender_key,omitempty" yaml:"sender_key,omitempty"` SenderKey bool `json:"sender_key,omitempty" yaml:"sender_key,omitempty"`
Storage bool `json:"storage,omitempty" yaml:"storage,omitempty"` Storage bool `json:"storage,omitempty" yaml:"storage,omitempty"`
Stories bool `json:"stories,omitempty" yaml:"stories,omitempty"`
} }
// ClientMessageWrapper: Wraps all incoming messages sent to the client after a v1 subscribe request is issued // ClientMessageWrapper: Wraps all incoming messages sent to the client after a v1 subscribe request is issued
@ -142,7 +127,6 @@ type DeviceInfo struct {
type FinishLinkRequest struct { type FinishLinkRequest struct {
Request Request
DeviceName string `json:"device_name,omitempty" yaml:"device_name,omitempty"` DeviceName string `json:"device_name,omitempty" yaml:"device_name,omitempty"`
Overwrite bool `json:"overwrite,omitempty" yaml:"overwrite,omitempty"` // overwrite existing account data if the phone number conflicts. false by default
SessionId string `json:"session_id,omitempty" yaml:"session_id,omitempty"` SessionId string `json:"session_id,omitempty" yaml:"session_id,omitempty"`
} }
@ -166,15 +150,6 @@ type GetGroupRequest struct {
Revision int32 `json:"revision,omitempty" yaml:"revision,omitempty"` // the latest known revision, default value (-1) forces fetch from server Revision int32 `json:"revision,omitempty" yaml:"revision,omitempty"` // the latest known revision, default value (-1) forces fetch from server
} }
// GetGroupRevisionPagesRequest: Query the server for group revision history. The history contains information about the changes between each revision and the user that made the change.
type GetGroupRevisionPagesRequest struct {
Request
Account string `json:"account,omitempty" yaml:"account,omitempty"` // The account to interact with
FromRevision int32 `json:"from_revision,omitempty" yaml:"from_revision,omitempty"` // The revision to start the pages from. Note that if this is lower than the revision you joined the group, an AuthorizationFailedError is returned.
GroupId string `json:"group_id,omitempty" yaml:"group_id,omitempty"`
IncludeFirstRevision bool `json:"include_first_revision,omitempty" yaml:"include_first_revision,omitempty"` // Whether to include the first state in the returned pages (default false)
}
// GetIdentitiesRequest: Get information about a known keys for a particular address // GetIdentitiesRequest: Get information about a known keys for a particular address
type GetIdentitiesRequest struct { type GetIdentitiesRequest struct {
Request Request
@ -200,11 +175,6 @@ type GetServersRequest struct {
Request Request
} }
type Gradient struct {
EndColor string `json:"end_color,omitempty" yaml:"end_color,omitempty"`
StartColor string `json:"start_color,omitempty" yaml:"start_color,omitempty"`
}
// GroupAccessControl: group access control settings. Options for each controlled action are: UNKNOWN, ANY, MEMBER, ADMINISTRATOR, UNSATISFIABLE and UNRECOGNIZED // GroupAccessControl: group access control settings. Options for each controlled action are: UNKNOWN, ANY, MEMBER, ADMINISTRATOR, UNSATISFIABLE and UNRECOGNIZED
type GroupAccessControl struct { type GroupAccessControl struct {
Attributes string `json:"attributes,omitempty" yaml:"attributes,omitempty"` // who can edit group info Attributes string `json:"attributes,omitempty" yaml:"attributes,omitempty"` // who can edit group info
@ -212,42 +182,6 @@ type GroupAccessControl struct {
Members string `json:"members,omitempty" yaml:"members,omitempty"` // who can add members Members string `json:"members,omitempty" yaml:"members,omitempty"` // who can add members
} }
// GroupChange: Represents a group change made by a user. This can also represent request link invites. Only the fields relevant to the group change performed will be set. Note that in signald, group changes are currently only received from incoming messages from a message subscription.
type GroupChange struct {
DeleteMembers []*JsonAddress `json:"delete_members,omitempty" yaml:"delete_members,omitempty"` // Represents users that have been removed from the group. This can be from admins removing users, or users choosing to leave the group
DeletePendingMembers []*JsonAddress `json:"delete_pending_members,omitempty" yaml:"delete_pending_members,omitempty"`
DeleteRequestingMembers []*JsonAddress `json:"delete_requesting_members,omitempty" yaml:"delete_requesting_members,omitempty"`
Editor *JsonAddress `json:"editor,omitempty" yaml:"editor,omitempty"` // The user that made the change.
ModifiedProfileKeys []*GroupMember `json:"modified_profile_keys,omitempty" yaml:"modified_profile_keys,omitempty"` // Represents users that have rotated their profile key. Note that signald currently does not expose profile keys to clients. The joined revision property will always be 0 in this list.
ModifyMemberRoles []*GroupMember `json:"modify_member_roles,omitempty" yaml:"modify_member_roles,omitempty"` // Represents users with their new, modified role.
NewAccessControl *GroupAccessControl `json:"new_access_control,omitempty" yaml:"new_access_control,omitempty"` // If not null, then this group change modified one of the access controls. Some of the properties in here will be null.
NewAvatar bool `json:"new_avatar,omitempty" yaml:"new_avatar,omitempty"` // Whether this group change changed the avatar.
NewBannedMembers []*BannedGroupMember `json:"new_banned_members,omitempty" yaml:"new_banned_members,omitempty"`
NewDescription string `json:"new_description,omitempty" yaml:"new_description,omitempty"`
NewInviteLinkPassword bool `json:"new_invite_link_password,omitempty" yaml:"new_invite_link_password,omitempty"` // Whether this group change involved resetting the group invite link.
NewIsAnnouncementGroup string `json:"new_is_announcement_group,omitempty" yaml:"new_is_announcement_group,omitempty"` // Whether this change affected the announcement group setting. Possible values are UNKNOWN, ENABLED or DISABLED
NewMembers []*GroupMember `json:"new_members,omitempty" yaml:"new_members,omitempty"` // Represents users have been added to the group. This can be from group members adding users, or a users joining via a group link that required no approval.
NewPendingMembers []*GroupPendingMember `json:"new_pending_members,omitempty" yaml:"new_pending_members,omitempty"` // Represents a user that has been invited to the group by another user.
NewRequestingMembers []*GroupRequestingMember `json:"new_requesting_members,omitempty" yaml:"new_requesting_members,omitempty"` // Represents users that have requested to join the group via the group link. Note that members requesting to join might not necessarily have the list of users in the group, so they won't be able to send a peer-to-peer group update message to inform users of their request to join. Other users in the group may inform us that the revision has increased, but the members requesting access will have to be obtained from the server instead (which signald will handle). For now, a get_group request has to be made to get the users that have requested to join the group.
NewTimer int32 `json:"new_timer,omitempty" yaml:"new_timer,omitempty"` // New disappearing messages timer value.
NewTitle string `json:"new_title,omitempty" yaml:"new_title,omitempty"`
NewUnbannedMembers []*BannedGroupMember `json:"new_unbanned_members,omitempty" yaml:"new_unbanned_members,omitempty"`
PromotePendingMembers []*GroupMember `json:"promote_pending_members,omitempty" yaml:"promote_pending_members,omitempty"`
PromoteRequestingMembers []*GroupMember `json:"promote_requesting_members,omitempty" yaml:"promote_requesting_members,omitempty"`
Revision int32 `json:"revision,omitempty" yaml:"revision,omitempty"` // The group revision that this change brings the group to.
}
type GroupHistoryEntry struct {
Change *GroupChange `json:"change,omitempty" yaml:"change,omitempty"`
Group *JsonGroupV2Info `json:"group,omitempty" yaml:"group,omitempty"`
}
// GroupHistoryPage: The result of fetching a group's history along with paging data.
type GroupHistoryPage struct {
PagingData *PagingData `json:"paging_data,omitempty" yaml:"paging_data,omitempty"`
Results []*GroupHistoryEntry `json:"results,omitempty" yaml:"results,omitempty"`
}
// GroupInfo: A generic type that is used when the group version is not known // GroupInfo: A generic type that is used when the group version is not known
type GroupInfo struct { type GroupInfo struct {
V1 *JsonGroupInfo `json:"v1,omitempty" yaml:"v1,omitempty"` V1 *JsonGroupInfo `json:"v1,omitempty" yaml:"v1,omitempty"`
@ -263,7 +197,7 @@ type GroupLinkInfoRequest struct {
type GroupList struct { type GroupList struct {
Groups []*JsonGroupV2Info `json:"groups,omitempty" yaml:"groups,omitempty"` Groups []*JsonGroupV2Info `json:"groups,omitempty" yaml:"groups,omitempty"`
LegacyGroups []*JsonGroupInfo `json:"legacyGroups,omitempty" yaml:"legacyGroups,omitempty"` // list of legacy (v1) groups, no longer supported (will always be empty) LegacyGroups []*JsonGroupInfo `json:"legacyGroups,omitempty" yaml:"legacyGroups,omitempty"`
} }
type GroupMember struct { type GroupMember struct {
@ -272,18 +206,6 @@ type GroupMember struct {
UUID string `json:"uuid,omitempty" yaml:"uuid,omitempty"` UUID string `json:"uuid,omitempty" yaml:"uuid,omitempty"`
} }
type GroupPendingMember struct {
AddedByUuid string `json:"added_by_uuid,omitempty" yaml:"added_by_uuid,omitempty"`
Role string `json:"role,omitempty" yaml:"role,omitempty"` // possible values are: UNKNOWN, DEFAULT, ADMINISTRATOR and UNRECOGNIZED
Timestamp int64 `json:"timestamp,omitempty" yaml:"timestamp,omitempty"`
UUID string `json:"uuid,omitempty" yaml:"uuid,omitempty"`
}
type GroupRequestingMember struct {
Timestamp int64 `json:"timestamp,omitempty" yaml:"timestamp,omitempty"`
UUID string `json:"uuid,omitempty" yaml:"uuid,omitempty"`
}
type HangupMessage struct { type HangupMessage struct {
DeviceId int32 `json:"device_id,omitempty" yaml:"device_id,omitempty"` DeviceId int32 `json:"device_id,omitempty" yaml:"device_id,omitempty"`
ID int64 `json:"id,omitempty" yaml:"id,omitempty"` ID int64 `json:"id,omitempty" yaml:"id,omitempty"`
@ -322,7 +244,6 @@ type IncomingMessage struct {
ServerReceiverTimestamp int64 `json:"server_receiver_timestamp,omitempty" yaml:"server_receiver_timestamp,omitempty"` ServerReceiverTimestamp int64 `json:"server_receiver_timestamp,omitempty" yaml:"server_receiver_timestamp,omitempty"`
Source *JsonAddress `json:"source,omitempty" yaml:"source,omitempty"` Source *JsonAddress `json:"source,omitempty" yaml:"source,omitempty"`
SourceDevice int32 `json:"source_device,omitempty" yaml:"source_device,omitempty"` SourceDevice int32 `json:"source_device,omitempty" yaml:"source_device,omitempty"`
StoryMessage *StoryMessage `json:"story_message,omitempty" yaml:"story_message,omitempty"`
SyncMessage *JsonSyncMessage `json:"sync_message,omitempty" yaml:"sync_message,omitempty"` SyncMessage *JsonSyncMessage `json:"sync_message,omitempty" yaml:"sync_message,omitempty"`
Timestamp int64 `json:"timestamp,omitempty" yaml:"timestamp,omitempty"` Timestamp int64 `json:"timestamp,omitempty" yaml:"timestamp,omitempty"`
Type string `json:"type,omitempty" yaml:"type,omitempty"` Type string `json:"type,omitempty" yaml:"type,omitempty"`
@ -373,26 +294,24 @@ type JsonBlockedListMessage struct {
} }
type JsonDataMessage struct { type JsonDataMessage struct {
Attachments []*JsonAttachment `json:"attachments,omitempty" yaml:"attachments,omitempty"` // files attached to the incoming message Attachments []*JsonAttachment `json:"attachments,omitempty" yaml:"attachments,omitempty"` // files attached to the incoming message
Body string `json:"body,omitempty" yaml:"body,omitempty"` // the text body of the incoming message. Body string `json:"body,omitempty" yaml:"body,omitempty"` // the text body of the incoming message.
Contacts []*SharedContact `json:"contacts,omitempty" yaml:"contacts,omitempty"` // if the incoming message has a shared contact, the contact's information will be here Contacts []*SharedContact `json:"contacts,omitempty" yaml:"contacts,omitempty"` // if the incoming message has a shared contact, the contact's information will be here
EndSession bool `json:"endSession,omitempty" yaml:"endSession,omitempty"` EndSession bool `json:"endSession,omitempty" yaml:"endSession,omitempty"`
ExpiresInSeconds int32 `json:"expiresInSeconds,omitempty" yaml:"expiresInSeconds,omitempty"` // the expiry timer on the incoming message. Clients should delete records of the message within this number of seconds ExpiresInSeconds int32 `json:"expiresInSeconds,omitempty" yaml:"expiresInSeconds,omitempty"` // the expiry timer on the incoming message. Clients should delete records of the message within this number of seconds
Group *JsonGroupInfo `json:"group,omitempty" yaml:"group,omitempty"` // if the incoming message was sent to a v1 group, information about that group will be here Group *JsonGroupInfo `json:"group,omitempty" yaml:"group,omitempty"` // if the incoming message was sent to a v1 group, information about that group will be here
GroupV2 *JsonGroupV2Info `json:"groupV2,omitempty" yaml:"groupV2,omitempty"` // if the incoming message was sent to a v2 group, basic identifying information about that group will be here. If group information changes, JsonGroupV2Info.revision is incremented. If the group revision is higher than previously seen, a client can retrieve the group information by calling get_group. GroupV2 *JsonGroupV2Info `json:"groupV2,omitempty" yaml:"groupV2,omitempty"` // if the incoming message was sent to a v2 group, basic identifying information about that group will be here. If group information changes, JsonGroupV2Info.revision is incremented. If the group revision is higher than previously seen, a client can retrieve the group information by calling get_group.
GroupCallUpdate string `json:"group_call_update,omitempty" yaml:"group_call_update,omitempty"` // the eraId string from a group call message update GroupCallUpdate string `json:"group_call_update,omitempty" yaml:"group_call_update,omitempty"` // the eraId string from a group call message update
IsExpirationUpdate bool `json:"is_expiration_update,omitempty" yaml:"is_expiration_update,omitempty"` // whether or not this message changes the expiresInSeconds value for the whole chat. Some messages (remote deletes, reactions, etc) will have expiresInSeconds=0 even though the chat has disappearing messages enabled. Mentions []*JsonMention `json:"mentions,omitempty" yaml:"mentions,omitempty"` // list of mentions in the message
Mentions []*JsonMention `json:"mentions,omitempty" yaml:"mentions,omitempty"` // list of mentions in the message Payment *Payment `json:"payment,omitempty" yaml:"payment,omitempty"` // details about the MobileCoin payment attached to the message, if present
Payment *Payment `json:"payment,omitempty" yaml:"payment,omitempty"` // details about the MobileCoin payment attached to the message, if present Previews []*JsonPreview `json:"previews,omitempty" yaml:"previews,omitempty"` // if the incoming message has a link preview, information about that preview will be here
Previews []*JsonPreview `json:"previews,omitempty" yaml:"previews,omitempty"` // if the incoming message has a link preview, information about that preview will be here ProfileKeyUpdate bool `json:"profileKeyUpdate,omitempty" yaml:"profileKeyUpdate,omitempty"`
ProfileKeyUpdate bool `json:"profileKeyUpdate,omitempty" yaml:"profileKeyUpdate,omitempty"` Quote *JsonQuote `json:"quote,omitempty" yaml:"quote,omitempty"` // if the incoming message is a quote or reply to another message, this will contain information about that message
Quote *JsonQuote `json:"quote,omitempty" yaml:"quote,omitempty"` // if the incoming message is a quote or reply to another message, this will contain information about that message Reaction *JsonReaction `json:"reaction,omitempty" yaml:"reaction,omitempty"` // if the message adds or removes a reaction to another message, this will indicate what change is being made
Reaction *JsonReaction `json:"reaction,omitempty" yaml:"reaction,omitempty"` // if the message adds or removes a reaction to another message, this will indicate what change is being made RemoteDelete *RemoteDelete `json:"remoteDelete,omitempty" yaml:"remoteDelete,omitempty"` // if the inbound message is deleting a previously sent message, indicates which message should be deleted
RemoteDelete *RemoteDelete `json:"remoteDelete,omitempty" yaml:"remoteDelete,omitempty"` // if the inbound message is deleting a previously sent message, indicates which message should be deleted Sticker *v0.JsonSticker `json:"sticker,omitempty" yaml:"sticker,omitempty"` // if the incoming message is a sticker, information about the sicker will be here
Sticker *v0.JsonSticker `json:"sticker,omitempty" yaml:"sticker,omitempty"` // if the incoming message is a sticker, information about the sicker will be here Timestamp int64 `json:"timestamp,omitempty" yaml:"timestamp,omitempty"` // the timestamp that the message was sent at, according to the sender's device. This is used to uniquely identify this message for things like reactions and quotes.
StoryContext *StoryContext `json:"story_context,omitempty" yaml:"story_context,omitempty"` ViewOnce bool `json:"viewOnce,omitempty" yaml:"viewOnce,omitempty"` // indicates the message is a view once message. View once messages typically include no body and a single image attachment. Official Signal clients will prevent the user from saving the image, and once the user has viewed the image once they will destroy the image.
Timestamp int64 `json:"timestamp,omitempty" yaml:"timestamp,omitempty"` // the timestamp that the message was sent at, according to the sender's device. This is used to uniquely identify this message for things like reactions and quotes.
ViewOnce bool `json:"viewOnce,omitempty" yaml:"viewOnce,omitempty"` // indicates the message is a view once message. View once messages typically include no body and a single image attachment. Official Signal clients will prevent the user from saving the image, and once the user has viewed the image once they will destroy the image.
} }
// JsonGroupInfo: information about a legacy group // JsonGroupInfo: information about a legacy group
@ -416,23 +335,21 @@ type JsonGroupJoinInfo struct {
// JsonGroupV2Info: Information about a Signal group // JsonGroupV2Info: Information about a Signal group
type JsonGroupV2Info struct { type JsonGroupV2Info struct {
AccessControl *GroupAccessControl `json:"accessControl,omitempty" yaml:"accessControl,omitempty"` // current access control settings for this group AccessControl *GroupAccessControl `json:"accessControl,omitempty" yaml:"accessControl,omitempty"` // current access control settings for this group
Announcements string `json:"announcements,omitempty" yaml:"announcements,omitempty"` // indicates if the group is an announcements group. Only admins are allowed to send messages to announcements groups. Options are UNKNOWN, ENABLED or DISABLED Announcements string `json:"announcements,omitempty" yaml:"announcements,omitempty"` // indicates if the group is an announcements group. Only admins are allowed to send messages to announcements groups. Options are UNKNOWN, ENABLED or DISABLED
Avatar string `json:"avatar,omitempty" yaml:"avatar,omitempty"` // path to the group's avatar on local disk, if available Avatar string `json:"avatar,omitempty" yaml:"avatar,omitempty"` // path to the group's avatar on local disk, if available
BannedMembers []*BannedGroupMember `json:"banned_members,omitempty" yaml:"banned_members,omitempty"` Description string `json:"description,omitempty" yaml:"description,omitempty"`
Description string `json:"description,omitempty" yaml:"description,omitempty"` ID string `json:"id,omitempty" yaml:"id,omitempty"`
GroupChange *GroupChange `json:"group_change,omitempty" yaml:"group_change,omitempty"` // Represents a peer-to-peer group change done by a user. Will not be set if the group change signature fails verification. This is usually only set inside of incoming messages. InviteLink string `json:"inviteLink,omitempty" yaml:"inviteLink,omitempty"` // the signal.group link, if applicable
ID string `json:"id,omitempty" yaml:"id,omitempty"` MemberDetail []*GroupMember `json:"memberDetail,omitempty" yaml:"memberDetail,omitempty"` // detailed member list
InviteLink string `json:"inviteLink,omitempty" yaml:"inviteLink,omitempty"` // the signal.group link, if applicable Members []*JsonAddress `json:"members,omitempty" yaml:"members,omitempty"`
MemberDetail []*GroupMember `json:"memberDetail,omitempty" yaml:"memberDetail,omitempty"` // detailed member list PendingMemberDetail []*GroupMember `json:"pendingMemberDetail,omitempty" yaml:"pendingMemberDetail,omitempty"` // detailed pending member list
Members []*JsonAddress `json:"members,omitempty" yaml:"members,omitempty"` PendingMembers []*JsonAddress `json:"pendingMembers,omitempty" yaml:"pendingMembers,omitempty"`
PendingMemberDetail []*GroupMember `json:"pendingMemberDetail,omitempty" yaml:"pendingMemberDetail,omitempty"` // detailed pending member list Removed bool `json:"removed,omitempty" yaml:"removed,omitempty"` // will be set to true for incoming messages to indicate the user has been removed from the group
PendingMembers []*JsonAddress `json:"pendingMembers,omitempty" yaml:"pendingMembers,omitempty"` RequestingMembers []*JsonAddress `json:"requestingMembers,omitempty" yaml:"requestingMembers,omitempty"`
Removed bool `json:"removed,omitempty" yaml:"removed,omitempty"` // will be set to true for incoming messages to indicate the user has been removed from the group Revision int32 `json:"revision,omitempty" yaml:"revision,omitempty"`
RequestingMembers []*JsonAddress `json:"requestingMembers,omitempty" yaml:"requestingMembers,omitempty"` Timer int32 `json:"timer,omitempty" yaml:"timer,omitempty"`
Revision int32 `json:"revision,omitempty" yaml:"revision,omitempty"` Title string `json:"title,omitempty" yaml:"title,omitempty"`
Timer int32 `json:"timer,omitempty" yaml:"timer,omitempty"`
Title string `json:"title,omitempty" yaml:"title,omitempty"`
} }
type JsonMention struct { type JsonMention struct {
@ -441,11 +358,31 @@ type JsonMention struct {
UUID string `json:"uuid,omitempty" yaml:"uuid,omitempty"` // The UUID of the account being mentioned UUID string `json:"uuid,omitempty" yaml:"uuid,omitempty"` // The UUID of the account being mentioned
} }
// JsonMessageRequestResponseMessage: Responses to message requests from unknown users or groups type JsonMessageEnvelope struct {
CallMessage *v0.JsonCallMessage `json:"callMessage,omitempty" yaml:"callMessage,omitempty"`
DataMessage *JsonDataMessage `json:"dataMessage,omitempty" yaml:"dataMessage,omitempty"`
HasContent bool `json:"hasContent,omitempty" yaml:"hasContent,omitempty"`
HasLegacyMessage bool `json:"hasLegacyMessage,omitempty" yaml:"hasLegacyMessage,omitempty"`
IsUnidentifiedSender bool `json:"isUnidentifiedSender,omitempty" yaml:"isUnidentifiedSender,omitempty"`
Receipt *v0.JsonReceiptMessage `json:"receipt,omitempty" yaml:"receipt,omitempty"`
Relay string `json:"relay,omitempty" yaml:"relay,omitempty"`
ServerDeliveredTimestamp int64 `json:"serverDeliveredTimestamp,omitempty" yaml:"serverDeliveredTimestamp,omitempty"`
ServerTimestamp int64 `json:"serverTimestamp,omitempty" yaml:"serverTimestamp,omitempty"`
Source *JsonAddress `json:"source,omitempty" yaml:"source,omitempty"`
SourceDevice int32 `json:"sourceDevice,omitempty" yaml:"sourceDevice,omitempty"`
SyncMessage *JsonSyncMessage `json:"syncMessage,omitempty" yaml:"syncMessage,omitempty"`
Timestamp int64 `json:"timestamp,omitempty" yaml:"timestamp,omitempty"`
TimestampISO string `json:"timestampISO,omitempty" yaml:"timestampISO,omitempty"`
Type string `json:"type,omitempty" yaml:"type,omitempty"`
Typing *v0.JsonTypingMessage `json:"typing,omitempty" yaml:"typing,omitempty"`
Username string `json:"username,omitempty" yaml:"username,omitempty"`
UUID string `json:"uuid,omitempty" yaml:"uuid,omitempty"`
}
type JsonMessageRequestResponseMessage struct { type JsonMessageRequestResponseMessage struct {
GroupId string `json:"groupId,omitempty" yaml:"groupId,omitempty"` GroupId string `json:"groupId,omitempty" yaml:"groupId,omitempty"`
Person *JsonAddress `json:"person,omitempty" yaml:"person,omitempty"` Person *JsonAddress `json:"person,omitempty" yaml:"person,omitempty"`
Type string `json:"type,omitempty" yaml:"type,omitempty"` // One of UNKNOWN, ACCEPT, DELETE, BLOCK, BLOCK_AND_DELETE, UNBLOCK_AND_ACCEPT Type string `json:"type,omitempty" yaml:"type,omitempty"`
} }
// JsonPreview: metadata about one of the links in a message // JsonPreview: metadata about one of the links in a message
@ -492,7 +429,6 @@ type JsonSentTranscriptMessage struct {
ExpirationStartTimestamp int64 `json:"expirationStartTimestamp,omitempty" yaml:"expirationStartTimestamp,omitempty"` ExpirationStartTimestamp int64 `json:"expirationStartTimestamp,omitempty" yaml:"expirationStartTimestamp,omitempty"`
IsRecipientUpdate bool `json:"isRecipientUpdate,omitempty" yaml:"isRecipientUpdate,omitempty"` IsRecipientUpdate bool `json:"isRecipientUpdate,omitempty" yaml:"isRecipientUpdate,omitempty"`
Message *JsonDataMessage `json:"message,omitempty" yaml:"message,omitempty"` Message *JsonDataMessage `json:"message,omitempty" yaml:"message,omitempty"`
Story *StoryMessage `json:"story,omitempty" yaml:"story,omitempty"`
Timestamp int64 `json:"timestamp,omitempty" yaml:"timestamp,omitempty"` Timestamp int64 `json:"timestamp,omitempty" yaml:"timestamp,omitempty"`
UnidentifiedStatus map[string]string `json:"unidentifiedStatus,omitempty" yaml:"unidentifiedStatus,omitempty"` UnidentifiedStatus map[string]string `json:"unidentifiedStatus,omitempty" yaml:"unidentifiedStatus,omitempty"`
} }
@ -583,11 +519,6 @@ type OfferMessage struct {
Type string `json:"type,omitempty" yaml:"type,omitempty"` Type string `json:"type,omitempty" yaml:"type,omitempty"`
} }
type PagingData struct {
HasMorePages bool `json:"has_more_pages,omitempty" yaml:"has_more_pages,omitempty"`
NextPageRevision int32 `json:"next_page_revision,omitempty" yaml:"next_page_revision,omitempty"`
}
// Payment: details about a MobileCoin payment // Payment: details about a MobileCoin payment
type Payment struct { type Payment struct {
Note string `json:"note,omitempty" yaml:"note,omitempty"` // note attached to the payment Note string `json:"note,omitempty" yaml:"note,omitempty"` // note attached to the payment
@ -600,8 +531,7 @@ type Profile struct {
Address *JsonAddress `json:"address,omitempty" yaml:"address,omitempty"` Address *JsonAddress `json:"address,omitempty" yaml:"address,omitempty"`
Avatar string `json:"avatar,omitempty" yaml:"avatar,omitempty"` // path to avatar on local disk Avatar string `json:"avatar,omitempty" yaml:"avatar,omitempty"` // path to avatar on local disk
Capabilities *Capabilities `json:"capabilities,omitempty" yaml:"capabilities,omitempty"` Capabilities *Capabilities `json:"capabilities,omitempty" yaml:"capabilities,omitempty"`
Color string `json:"color,omitempty" yaml:"color,omitempty"` // color of the chat with this user Color string `json:"color,omitempty" yaml:"color,omitempty"` // color of the chat with this user
ContactName string `json:"contact_name,omitempty" yaml:"contact_name,omitempty"` // The user's name from local contact names
Emoji string `json:"emoji,omitempty" yaml:"emoji,omitempty"` Emoji string `json:"emoji,omitempty" yaml:"emoji,omitempty"`
ExpirationTime int32 `json:"expiration_time,omitempty" yaml:"expiration_time,omitempty"` ExpirationTime int32 `json:"expiration_time,omitempty" yaml:"expiration_time,omitempty"`
InboxPosition int32 `json:"inbox_position,omitempty" yaml:"inbox_position,omitempty"` InboxPosition int32 `json:"inbox_position,omitempty" yaml:"inbox_position,omitempty"`
@ -636,7 +566,6 @@ type ReceiptMessage struct {
type RefuseMembershipRequest struct { type RefuseMembershipRequest struct {
Request Request
Account string `json:"account,omitempty" yaml:"account,omitempty"` // The account to interact with Account string `json:"account,omitempty" yaml:"account,omitempty"` // The account to interact with
AlsoBan bool `json:"also_ban,omitempty" yaml:"also_ban,omitempty"`
GroupId string `json:"group_id,omitempty" yaml:"group_id,omitempty"` GroupId string `json:"group_id,omitempty" yaml:"group_id,omitempty"`
Members []*JsonAddress `json:"members,omitempty" yaml:"members,omitempty"` // list of requesting members to refuse Members []*JsonAddress `json:"members,omitempty" yaml:"members,omitempty"` // list of requesting members to refuse
} }
@ -729,7 +658,6 @@ type SendPaymentRequest struct {
type SendRequest struct { type SendRequest struct {
Request Request
Account string `json:"account,omitempty" yaml:"account,omitempty"`
Attachments []*JsonAttachment `json:"attachments,omitempty" yaml:"attachments,omitempty"` Attachments []*JsonAttachment `json:"attachments,omitempty" yaml:"attachments,omitempty"`
Members []*JsonAddress `json:"members,omitempty" yaml:"members,omitempty"` // Optionally set to a sub-set of group members. Ignored if recipientGroupId isn't specified Members []*JsonAddress `json:"members,omitempty" yaml:"members,omitempty"` // Optionally set to a sub-set of group members. Ignored if recipientGroupId isn't specified
Mentions []*JsonMention `json:"mentions,omitempty" yaml:"mentions,omitempty"` Mentions []*JsonMention `json:"mentions,omitempty" yaml:"mentions,omitempty"`
@ -754,14 +682,6 @@ type SendSuccess struct {
Unidentified bool `json:"unidentified,omitempty" yaml:"unidentified,omitempty"` Unidentified bool `json:"unidentified,omitempty" yaml:"unidentified,omitempty"`
} }
// SendSyncMessageRequest: Sends a sync message to the account's devices
type SendSyncMessageRequest struct {
Request
Account string `json:"account,omitempty" yaml:"account,omitempty"`
MessageRequestResponse *JsonMessageRequestResponseMessage `json:"message_request_response,omitempty" yaml:"message_request_response,omitempty"` // This can be set to indicate to other devices about a response to an incoming message request from an unknown user or group. Warning: Using the BLOCK and BLOCK_AND_DELETE options relies on other devices to do the blocking, and it does not make you leave the group!
ViewOnceOpenMessage *JsonViewOnceOpenMessage `json:"view_once_open_message,omitempty" yaml:"view_once_open_message,omitempty"` // This can be set to indicate to other devices about having viewed a view-once message.
}
// Server: a Signal server // Server: a Signal server
type Server struct { type Server struct {
Ca string `json:"ca,omitempty" yaml:"ca,omitempty"` // base64 encoded trust store, password must be 'whisper' Ca string `json:"ca,omitempty" yaml:"ca,omitempty"` // base64 encoded trust store, password must be 'whisper'
@ -864,23 +784,6 @@ type SharedContactPhone struct {
Value string `json:"value,omitempty" yaml:"value,omitempty"` // the phone number Value string `json:"value,omitempty" yaml:"value,omitempty"` // the phone number
} }
// StorageChange: Broadcast to subscribed clients when there is a state change from the storage service
type StorageChange struct {
Version int64 `json:"version,omitempty" yaml:"version,omitempty"` // Seems to behave like the group version numbers and increments every time the state changes
}
type StoryContext struct {
Author string `json:"author,omitempty" yaml:"author,omitempty"`
SentTimestamp int64 `json:"sent_timestamp,omitempty" yaml:"sent_timestamp,omitempty"`
}
type StoryMessage struct {
AllowReplies bool `json:"allow_replies,omitempty" yaml:"allow_replies,omitempty"`
File *JsonAttachment `json:"file,omitempty" yaml:"file,omitempty"`
Group *JsonGroupV2Info `json:"group,omitempty" yaml:"group,omitempty"`
Text *TextAttachment `json:"text,omitempty" yaml:"text,omitempty"`
}
type SubmitChallengeRequest struct { type SubmitChallengeRequest struct {
Request Request
Account string `json:"account,omitempty" yaml:"account,omitempty"` Account string `json:"account,omitempty" yaml:"account,omitempty"`
@ -894,16 +797,6 @@ type SubscribeRequest struct {
Account string `json:"account,omitempty" yaml:"account,omitempty"` // The account to subscribe to incoming message for Account string `json:"account,omitempty" yaml:"account,omitempty"` // The account to subscribe to incoming message for
} }
type TextAttachment struct {
BackgroundColor string `json:"background_color,omitempty" yaml:"background_color,omitempty"`
BackgroundGradient *Gradient `json:"background_gradient,omitempty" yaml:"background_gradient,omitempty"`
Preview *JsonPreview `json:"preview,omitempty" yaml:"preview,omitempty"`
Style string `json:"style,omitempty" yaml:"style,omitempty"`
Text string `json:"text,omitempty" yaml:"text,omitempty"`
TextBackgroundColor string `json:"text_background_color,omitempty" yaml:"text_background_color,omitempty"`
TextForegroundColor string `json:"text_foreground_color,omitempty" yaml:"text_foreground_color,omitempty"`
}
// TrustRequest: Trust another user's safety number using either the QR code data or the safety number text // TrustRequest: Trust another user's safety number using either the QR code data or the safety number text
type TrustRequest struct { type TrustRequest struct {
Request Request
@ -930,14 +823,6 @@ type TypingRequest struct {
When int64 `json:"when,omitempty" yaml:"when,omitempty"` When int64 `json:"when,omitempty" yaml:"when,omitempty"`
} }
// UnbanUserRequest: Unbans users from a group.
type UnbanUserRequest struct {
Request
Account string `json:"account,omitempty" yaml:"account,omitempty"` // The account to interact with
GroupId string `json:"group_id,omitempty" yaml:"group_id,omitempty"`
Users []*JsonAddress `json:"users,omitempty" yaml:"users,omitempty"` // List of users to unban
}
// UnsubscribeRequest: See subscribe for more info // UnsubscribeRequest: See subscribe for more info
type UnsubscribeRequest struct { type UnsubscribeRequest struct {
Request Request

View file

@ -99,12 +99,8 @@ func (s *Signald) connect() error {
return nil return nil
} }
func (s *Signald) Close() error {
return s.socket.Close()
}
// Listen listens for events from signald // Listen listens for events from signald
func (s *Signald) Listen(c chan client_protocol.BasicResponse) error { func (s *Signald) Listen(c chan client_protocol.BasicResponse) {
for { for {
msg, err := s.readNext() msg, err := s.readNext()
if err == io.EOF { if err == io.EOF {
@ -112,11 +108,7 @@ func (s *Signald) Listen(c chan client_protocol.BasicResponse) error {
if c != nil { if c != nil {
close(c) close(c)
} }
return nil return
}
if err != nil {
return err
} }
if msg.Type == "unexpected_error" { if msg.Type == "unexpected_error" {
@ -133,7 +125,7 @@ func (s *Signald) Listen(c chan client_protocol.BasicResponse) error {
subscribers <- msg subscribers <- msg
} }
if c != nil && !(msg.ID == "" && msg.Type == "version") { if c != nil {
c <- msg c <- msg
} }
} }
@ -178,6 +170,9 @@ func (s *Signald) readNext() (b client_protocol.BasicResponse, err error) {
} else { } else {
err = json.NewDecoder(s.socket).Decode(&b) err = json.NewDecoder(s.socket).Decode(&b)
} }
if err != nil {
log.Println("signald-go: error decoding message from signald:", err)
return
}
return return
} }

View file

@ -22,14 +22,15 @@ func {{$action.FnName}}(conn *signald.Signald) ({{if ne $action.Response ""}}res
if(r.ID == "") { if(r.ID == "") {
r.ID = signald.GenerateID() r.ID = signald.GenerateID()
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
err = conn.RawRequest(r) err = conn.RawRequest(r)
if err != nil { if err != nil {
log.Println("signald-go: error submitting request to signald") log.Println("signald-go: error submitting request to signald")
return return
} }
responseChannel := conn.GetResponseListener(r.ID)
defer conn.CloseResponseListener(r.ID)
rawResponse := <- responseChannel rawResponse := <- responseChannel
if rawResponse.Error != nil { if rawResponse.Error != nil {
err = mkerr(rawResponse) err = mkerr(rawResponse)