return same device as sent from client if it exists in db (#414)
Signed-off-by: mohit kumar singh <mohitkumarsingh907@gmail.com>main
parent
5d52863b9f
commit
d07a652d8e
|
@ -17,7 +17,10 @@ package routing
|
||||||
import (
|
import (
|
||||||
"net/http"
|
"net/http"
|
||||||
|
|
||||||
|
"context"
|
||||||
|
"database/sql"
|
||||||
"github.com/matrix-org/dendrite/clientapi/auth"
|
"github.com/matrix-org/dendrite/clientapi/auth"
|
||||||
|
"github.com/matrix-org/dendrite/clientapi/auth/authtypes"
|
||||||
"github.com/matrix-org/dendrite/clientapi/auth/storage/accounts"
|
"github.com/matrix-org/dendrite/clientapi/auth/storage/accounts"
|
||||||
"github.com/matrix-org/dendrite/clientapi/auth/storage/devices"
|
"github.com/matrix-org/dendrite/clientapi/auth/storage/devices"
|
||||||
"github.com/matrix-org/dendrite/clientapi/httputil"
|
"github.com/matrix-org/dendrite/clientapi/httputil"
|
||||||
|
@ -41,6 +44,7 @@ type passwordRequest struct {
|
||||||
User string `json:"user"`
|
User string `json:"user"`
|
||||||
Password string `json:"password"`
|
Password string `json:"password"`
|
||||||
InitialDisplayName *string `json:"initial_device_display_name"`
|
InitialDisplayName *string `json:"initial_device_display_name"`
|
||||||
|
DeviceID string `json:"device_id"`
|
||||||
}
|
}
|
||||||
|
|
||||||
type loginResponse struct {
|
type loginResponse struct {
|
||||||
|
@ -105,10 +109,7 @@ func Login(
|
||||||
httputil.LogThenError(req, err)
|
httputil.LogThenError(req, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
// TODO: Use the device ID in the request
|
dev, err := getDevice(req.Context(), r, deviceDB, acc, localpart, token)
|
||||||
dev, err := deviceDB.CreateDevice(
|
|
||||||
req.Context(), acc.Localpart, nil, token, r.InitialDisplayName,
|
|
||||||
)
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return util.JSONResponse{
|
return util.JSONResponse{
|
||||||
Code: http.StatusInternalServerError,
|
Code: http.StatusInternalServerError,
|
||||||
|
@ -131,3 +132,21 @@ func Login(
|
||||||
JSON: jsonerror.NotFound("Bad method"),
|
JSON: jsonerror.NotFound("Bad method"),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// check if device exists else create one
|
||||||
|
func getDevice(
|
||||||
|
ctx context.Context,
|
||||||
|
r passwordRequest,
|
||||||
|
deviceDB *devices.Database,
|
||||||
|
acc *authtypes.Account,
|
||||||
|
localpart, token string,
|
||||||
|
) (dev *authtypes.Device, err error) {
|
||||||
|
dev, err = deviceDB.GetDeviceByID(ctx, localpart, r.DeviceID)
|
||||||
|
if err == sql.ErrNoRows {
|
||||||
|
// device doesn't exist, create one
|
||||||
|
dev, err = deviceDB.CreateDevice(
|
||||||
|
ctx, acc.Localpart, nil, token, r.InitialDisplayName,
|
||||||
|
)
|
||||||
|
}
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
Loading…
Reference in New Issue