-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathAddUserPreferences.cs
More file actions
70 lines (58 loc) · 2.48 KB
/
Copy pathAddUserPreferences.cs
File metadata and controls
70 lines (58 loc) · 2.48 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.Functions.Worker;
using Microsoft.Extensions.Logging;
using HoTeach.Entities;
using HoTeach.Infrastructure; // Assuming you have your MongoDB setup here
using System.Threading.Tasks;
using System.IO;
using System.Text.Json;
using MongoDB.Driver;
using System.Linq;
namespace HoTeach
{
public class AddUserPreferences
{
private readonly ILogger _logger;
private readonly IMongoCollection<UserPreferences> _userPreferencesCollection;
public AddUserPreferences(ILogger<AddUserPreferences> logger)
{
_logger = logger;
var mongoClient = new MongoClient(Environment.GetEnvironmentVariable("Mongo__Url"));
var database = mongoClient.GetDatabase("hoteach-v1");
_userPreferencesCollection = database.GetCollection<UserPreferences>("userpreferences");
}
[Function("AddUserPreferences")]
public async Task<IActionResult> Run(
[HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = "user-preferences")] HttpRequest req)
{
try
{
var principal = AuthHelper.ValidateToken(req);
_logger.LogInformation($"Authenticated user: {principal.Identity.Name}");
}
catch (Exception ex)
{
_logger.LogWarning(ex.Message);
return new UnauthorizedResult();
}
try
{
string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
var preferences = JsonSerializer.Deserialize<UserPreferences>(requestBody);
if (preferences == null || string.IsNullOrEmpty(preferences.UserId))
{
return new BadRequestObjectResult("Invalid user preferences data");
}
await _userPreferencesCollection.InsertOneAsync(preferences);
_logger.LogInformation($"Successfully added user preferences for UserId: {preferences.UserId}");
return new OkObjectResult(new { message = "User preferences added successfully", data = preferences });
}
catch (Exception ex)
{
_logger.LogError($"Error adding user preferences: {ex.Message}");
return new StatusCodeResult(500);
}
}
}
}