wip

FerretDB · AlekSi · Dec 20, 2023 · Dec 12, 2023 · Dec 12, 2023 · Dec 14, 2023
commit 25afee760e1fe8ace8439895f4ce9af1820ab07d
diff --git a/internal/handler/msg_createuser.go b/internal/handler/msg_createuser.go
@@ -17,6 +17,7 @@
 import (
 	"context"
 
+	"github.com/FerretDB/FerretDB/internal/backends"
 	"github.com/FerretDB/FerretDB/internal/handler/common"
 	"github.com/FerretDB/FerretDB/internal/types"
 	"github.com/FerretDB/FerretDB/internal/util/lazyerrors"
@@ -33,33 +34,57 @@

 	// https://www.mongodb.com/docs/manual/reference/command/createUser/

 	username, err := common.GetRequiredParam[string](document, document.Command())
 	if err != nil {
 		return nil, err
 	}
 
-	password, err := common.GetRequiredParam[string](document, "pwd")
+	_, err = common.GetRequiredParam[string](document, "pwd")
 	if err != nil {
 		return nil, err
 	}

 	if err := common.UnimplementedNonDefault(document, "roles", func(v any) bool {
 		roles, ok := v.(*types.Array)
 		return ok && roles.Len() == 0
 	}); err != nil {
 		return nil, err
 	}
 
-	_ = username
-	_ = password
+	dbName, err := common.GetRequiredParam[string](document, "$db")
+	if err != nil {
+		return nil, err
+	}
+
+	db, err := h.b.Database(dbName)
+	if err != nil {
+		return nil, lazyerrors.Error(err)
+	}
+
+	collection, err := db.Collection("system.users")
+	if err != nil {
+		return nil, lazyerrors.Error(err)
+	}
+
+	_, err = collection.InsertAll(ctx, &backends.InsertAllParams{
+		Docs: []*types.Document{must.NotFail(types.NewDocument(
+			"createdUser", username,
+			"roles", []string{},
+			"pwd", "password", // TODO: hash the password.
+		)),
+		},
+	})
+	if err != nil {
+		return nil, lazyerrors.Error(err)
+	}
 
 	// TODO https://github.com/FerretDB/FerretDB/issues/1491
 	var reply wire.OpMsg
 	must.NoError(reply.SetSections(wire.OpMsgSection{
 		Documents: []*types.Document{must.NotFail(types.NewDocument(
 			"ok", float64(1),
 		))},
 	}))

 	return &reply, nil
 }