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
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
|
using MediaBrowser.Common.Net.Handlers;
using MediaBrowser.Controller;
using MediaBrowser.Controller.Entities;
using MediaBrowser.Controller.Library;
using MediaBrowser.Model.Connectivity;
using MediaBrowser.Model.Dto;
using System;
using System.Threading.Tasks;
namespace MediaBrowser.Api.HttpHandlers
{
/// <summary>
/// Provides a handler to set played status for an item
/// </summary>
public class PlaybackCheckInHandler : BaseSerializationHandler<Kernel, UserItemDataDto>
{
/// <summary>
/// Gets the object to serialize.
/// </summary>
/// <returns>Task{DtoUserItemData}.</returns>
protected override async Task<UserItemDataDto> GetObjectToSerialize()
{
// Get the user
var user = await this.GetCurrentUser().ConfigureAwait(false);
var clientType = ClientType.Other;
if (!string.IsNullOrEmpty(QueryString["client"]))
{
ClientType type;
if (Enum.TryParse(QueryString["client"], true, out type))
{
clientType = type;
}
}
var device = QueryString["device"];
// Get the item
var item = DtoBuilder.GetItemByClientId(QueryString["id"], user.Id);
// Playback start check-in
if (QueryString["type"].Equals("start", StringComparison.OrdinalIgnoreCase))
{
Kernel.UserDataManager.OnPlaybackStart(user, item, clientType, device);
}
else
{
long? positionTicks = null;
if (!string.IsNullOrEmpty(QueryString["positionTicks"]))
{
positionTicks = long.Parse(QueryString["positionTicks"]);
}
// Progress check-ins require position ticks
if (QueryString["type"].Equals("progress", StringComparison.OrdinalIgnoreCase))
{
await Kernel.UserDataManager.OnPlaybackProgress(user, item, positionTicks, clientType, device).ConfigureAwait(false);
}
else if (QueryString["type"].Equals("stopped", StringComparison.OrdinalIgnoreCase))
{
await Kernel.UserDataManager.OnPlaybackStopped(user, item, positionTicks, clientType, device).ConfigureAwait(false);
}
}
var data = item.GetUserData(user, true);
return new DtoBuilder(null).GetDtoUserItemData(data);
}
/// <summary>
/// Gets the current user.
/// </summary>
/// <returns>User.</returns>
/// <exception cref="System.UnauthorizedAccessException"></exception>
public async Task<User> GetCurrentUser()
{
var handler = this;
var id = handler.QueryString["userid"];
var user = ApiService.GetUserById(id);
if (user == null)
{
throw new UnauthorizedAccessException(string.Format("User with Id {0} does not exist", id));
}
var clientType = ClientType.Other;
if (!string.IsNullOrEmpty(handler.QueryString["client"]))
{
ClientType type;
if (Enum.TryParse(handler.QueryString["client"], true, out type))
{
clientType = type;
}
}
var device = handler.QueryString["device"];
await Controller.Kernel.Instance.UserManager.LogUserActivity(user, clientType, device).ConfigureAwait(false);
return user;
}
}
}
|
