(ctx context.Context, keys []api.DeviceMessage, clearUserIDs []string)
| 67 | } |
| 68 | |
| 69 | func (d *Database) StoreRemoteDeviceKeys(ctx context.Context, keys []api.DeviceMessage, clearUserIDs []string) error { |
| 70 | return d.Writer.Do(d.DB, nil, func(txn *sql.Tx) error { |
| 71 | for _, userID := range clearUserIDs { |
| 72 | err := d.DeviceKeysTable.DeleteAllDeviceKeys(ctx, txn, userID) |
| 73 | if err != nil { |
| 74 | return err |
| 75 | } |
| 76 | } |
| 77 | return d.DeviceKeysTable.InsertDeviceKeys(ctx, txn, keys) |
| 78 | }) |
| 79 | } |
| 80 | |
| 81 | func (d *Database) StoreLocalDeviceKeys(ctx context.Context, keys []api.DeviceMessage) error { |
| 82 | // work out the latest stream IDs for each user |
nothing calls this directly
no test coverage detected