created dummy API routes, passing API test

backend/database.go

@@ -103,3 +103,167 @@ func createTables(db *sql.DB) error {
 
 	return nil
 }
+
+// User represents a row in the users table.
+type User struct {
+	UserID       string
+	RootObjectID string
+}
+
+// CreateUser inserts a new user into the users table.
+func CreateUser(userID, rootObjectID string) error {
+	_, err := DB.Exec(
+		"INSERT INTO users (userId, rootObjectId) VALUES (?, ?)",
+		userID, rootObjectID,
+	)
+	if err != nil {
+		return fmt.Errorf("failed to create user: %w", err)
+	}
+	return nil
+}
+
+// GetUser retrieves a user by ID.
+func GetUser(userID string) (User, error) {
+	var user User
+	err := DB.QueryRow(
+		"SELECT userId, rootObjectId FROM users WHERE userId = ?",
+		userID,
+	).Scan(&user.UserID, &user.RootObjectID)
+	if err != nil {
+		if err == sql.ErrNoRows {
+			return User{}, fmt.Errorf("user not found")
+		}
+		return User{}, fmt.Errorf("failed to get user: %w", err)
+	}
+	return user, nil
+}
+
+// UpdateUser updates the rootObjectId for a user.
+func UpdateUser(userID, rootObjectID string) error {
+	result, err := DB.Exec(
+		"UPDATE users SET rootObjectId = ? WHERE userId = ?",
+		rootObjectID, userID,
+	)
+	if err != nil {
+		return fmt.Errorf("failed to update user: %w", err)
+	}
+	rows, err := result.RowsAffected()
+	if err != nil {
+		return fmt.Errorf("failed to check update result: %w", err)
+	}
+	if rows == 0 {
+		return fmt.Errorf("user not found")
+	}
+	return nil
+}
+
+// DeleteUser removes a user by ID.
+func DeleteUser(userID string) error {
+	result, err := DB.Exec("DELETE FROM users WHERE userId = ?", userID)
+	if err != nil {
+		return fmt.Errorf("failed to delete user: %w", err)
+	}
+	rows, err := result.RowsAffected()
+	if err != nil {
+		return fmt.Errorf("failed to check delete result: %w", err)
+	}
+	if rows == 0 {
+		return fmt.Errorf("user not found")
+	}
+	return nil
+}
+
+// Object represents a row in the objects table.
+type Object struct {
+	ObjectID   string
+	UserID     string
+	ObjectData string
+}
+
+// CreateObject inserts a new object into the objects table.
+func CreateObject(objectID, userID, objectData string) error {
+	_, err := DB.Exec(
+		"INSERT INTO objects (objectId, userId, objectData) VALUES (?, ?, ?)",
+		objectID, userID, objectData,
+	)
+	if err != nil {
+		return fmt.Errorf("failed to create object: %w", err)
+	}
+	return nil
+}
+
+// GetObject retrieves an object by ID.
+func GetObject(objectID string) (Object, error) {
+	var obj Object
+	err := DB.QueryRow(
+		"SELECT objectId, userId, objectData FROM objects WHERE objectId = ?",
+		objectID,
+	).Scan(&obj.ObjectID, &obj.UserID, &obj.ObjectData)
+	if err != nil {
+		if err == sql.ErrNoRows {
+			return Object{}, fmt.Errorf("object not found")
+		}
+		return Object{}, fmt.Errorf("failed to get object: %w", err)
+	}
+	return obj, nil
+}
+
+// GetObjectsByUser retrieves all objects belonging to a user.
+func GetObjectsByUser(userID string) ([]Object, error) {
+	rows, err := DB.Query(
+		"SELECT objectId, userId, objectData FROM objects WHERE userId = ?",
+		userID,
+	)
+	if err != nil {
+		return nil, fmt.Errorf("failed to query objects: %w", err)
+	}
+	defer rows.Close()
+
+	var objects []Object
+	for rows.Next() {
+		var obj Object
+		if err := rows.Scan(&obj.ObjectID, &obj.UserID, &obj.ObjectData); err != nil {
+			return nil, fmt.Errorf("failed to scan object: %w", err)
+		}
+		objects = append(objects, obj)
+	}
+	if err := rows.Err(); err != nil {
+		return nil, fmt.Errorf("failed to iterate objects: %w", err)
+	}
+	return objects, nil
+}
+
+// UpdateObject updates the objectData for an object.
+func UpdateObject(objectID, objectData string) error {
+	result, err := DB.Exec(
+		"UPDATE objects SET objectData = ? WHERE objectId = ?",
+		objectData, objectID,
+	)
+	if err != nil {
+		return fmt.Errorf("failed to update object: %w", err)
+	}
+	rows, err := result.RowsAffected()
+	if err != nil {
+		return fmt.Errorf("failed to check update result: %w", err)
+	}
+	if rows == 0 {
+		return fmt.Errorf("object not found")
+	}
+	return nil
+}
+
+// DeleteObject removes an object by ID.
+func DeleteObject(objectID string) error {
+	result, err := DB.Exec("DELETE FROM objects WHERE objectId = ?", objectID)
+	if err != nil {
+		return fmt.Errorf("failed to delete object: %w", err)
+	}
+	rows, err := result.RowsAffected()
+	if err != nil {
+		return fmt.Errorf("failed to check delete result: %w", err)
+	}
+	if rows == 0 {
+		return fmt.Errorf("object not found")
+	}
+	return nil
+}