Merge remote-tracking branch 'upstream/dev' into dev
This commit is contained in:
commit
ffe9978284
@ -104,17 +104,11 @@ namespace NadekoBot.Modules.Searches
|
|||||||
if (oldCachedStatuses.TryGetValue(newStatus.ApiLink, out oldStatus) &&
|
if (oldCachedStatuses.TryGetValue(newStatus.ApiLink, out oldStatus) &&
|
||||||
oldStatus.IsLive != newStatus.IsLive)
|
oldStatus.IsLive != newStatus.IsLive)
|
||||||
{
|
{
|
||||||
var msg = $"`{fs.Username}`'s stream is now " +
|
|
||||||
$"**{(newStatus.IsLive ? "ONLINE" : "OFFLINE")}** with " +
|
|
||||||
$"**{newStatus.Views}** viewers.";
|
|
||||||
|
|
||||||
var server = NadekoBot.Client.GetGuild(fs.GuildId);
|
var server = NadekoBot.Client.GetGuild(fs.GuildId);
|
||||||
var channel = server?.GetTextChannel(fs.ChannelId);
|
var channel = server?.GetTextChannel(fs.ChannelId);
|
||||||
if (channel == null)
|
if (channel == null)
|
||||||
return;
|
return;
|
||||||
if (newStatus.IsLive)
|
try { await channel.EmbedAsync(fs.GetEmbed(newStatus).Build()).ConfigureAwait(false); } catch { }
|
||||||
msg += "\n" + fs.GetLink();
|
|
||||||
try { await channel.SendMessageAsync(msg).ConfigureAwait(false); } catch { }
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch (Exception ex)
|
||||||
@ -134,7 +128,7 @@ namespace NadekoBot.Modules.Searches
|
|||||||
switch (stream.Type)
|
switch (stream.Type)
|
||||||
{
|
{
|
||||||
case FollowedStream.FollowedStreamType.Hitbox:
|
case FollowedStream.FollowedStreamType.Hitbox:
|
||||||
var hitboxUrl = $"https://api.hitbox.tv/media/status/{stream.Username}";
|
var hitboxUrl = $"https://api.hitbox.tv/media/status/{stream.Username.ToLowerInvariant()}";
|
||||||
if (checkCache && cachedStatuses.TryGetValue(hitboxUrl, out result))
|
if (checkCache && cachedStatuses.TryGetValue(hitboxUrl, out result))
|
||||||
return result;
|
return result;
|
||||||
using (var http = new HttpClient())
|
using (var http = new HttpClient())
|
||||||
@ -153,7 +147,7 @@ namespace NadekoBot.Modules.Searches
|
|||||||
cachedStatuses.AddOrUpdate(hitboxUrl, result, (key, old) => result);
|
cachedStatuses.AddOrUpdate(hitboxUrl, result, (key, old) => result);
|
||||||
return result;
|
return result;
|
||||||
case FollowedStream.FollowedStreamType.Twitch:
|
case FollowedStream.FollowedStreamType.Twitch:
|
||||||
var twitchUrl = $"https://api.twitch.tv/kraken/streams/{Uri.EscapeUriString(stream.Username)}?client_id=67w6z9i09xv2uoojdm9l0wsyph4hxo6";
|
var twitchUrl = $"https://api.twitch.tv/kraken/streams/{Uri.EscapeUriString(stream.Username.ToLowerInvariant())}?client_id=67w6z9i09xv2uoojdm9l0wsyph4hxo6";
|
||||||
if (checkCache && cachedStatuses.TryGetValue(twitchUrl, out result))
|
if (checkCache && cachedStatuses.TryGetValue(twitchUrl, out result))
|
||||||
return result;
|
return result;
|
||||||
using (var http = new HttpClient())
|
using (var http = new HttpClient())
|
||||||
@ -174,7 +168,7 @@ namespace NadekoBot.Modules.Searches
|
|||||||
cachedStatuses.AddOrUpdate(twitchUrl, result, (key, old) => result);
|
cachedStatuses.AddOrUpdate(twitchUrl, result, (key, old) => result);
|
||||||
return result;
|
return result;
|
||||||
case FollowedStream.FollowedStreamType.Beam:
|
case FollowedStream.FollowedStreamType.Beam:
|
||||||
var beamUrl = $"https://beam.pro/api/v1/channels/{stream.Username}";
|
var beamUrl = $"https://beam.pro/api/v1/channels/{stream.Username.ToLowerInvariant()}";
|
||||||
if (checkCache && cachedStatuses.TryGetValue(beamUrl, out result))
|
if (checkCache && cachedStatuses.TryGetValue(beamUrl, out result))
|
||||||
return result;
|
return result;
|
||||||
using (var http = new HttpClient())
|
using (var http = new HttpClient())
|
||||||
@ -199,6 +193,40 @@ namespace NadekoBot.Modules.Searches
|
|||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
//[NadekoCommand, Usage, Description, Aliases]
|
||||||
|
//[RequireContext(ContextType.Guild)]
|
||||||
|
//public async Task Test(IUserMessage imsg)
|
||||||
|
//{
|
||||||
|
// var channel = (ITextChannel)imsg.Channel;
|
||||||
|
|
||||||
|
// await channel.EmbedAsync(new Discord.API.Embed()
|
||||||
|
// {
|
||||||
|
// Title = "Imqtpie",
|
||||||
|
// Url = "https://twitch.tv/masterkwoth",
|
||||||
|
// Fields = new[] {
|
||||||
|
// new Discord.API.EmbedField()
|
||||||
|
// {
|
||||||
|
// Name = "Status",
|
||||||
|
// Value = "Online",
|
||||||
|
// Inline = true,
|
||||||
|
// },
|
||||||
|
// new Discord.API.EmbedField()
|
||||||
|
// {
|
||||||
|
// Name = "Viewers",
|
||||||
|
// Value = "123123",
|
||||||
|
// Inline = true
|
||||||
|
// },
|
||||||
|
// new Discord.API.EmbedField()
|
||||||
|
// {
|
||||||
|
// Name = "Platform",
|
||||||
|
// Value = "Twitch",
|
||||||
|
// Inline = true
|
||||||
|
// },
|
||||||
|
// },
|
||||||
|
// Color = NadekoBot.OkColor
|
||||||
|
// });
|
||||||
|
//}
|
||||||
|
|
||||||
[NadekoCommand, Usage, Description, Aliases]
|
[NadekoCommand, Usage, Description, Aliases]
|
||||||
[RequireContext(ContextType.Guild)]
|
[RequireContext(ContextType.Guild)]
|
||||||
[RequirePermission(GuildPermission.ManageMessages)]
|
[RequirePermission(GuildPermission.ManageMessages)]
|
||||||
@ -314,8 +342,8 @@ namespace NadekoBot.Modules.Searches
|
|||||||
|
|
||||||
private async Task TrackStream(ITextChannel channel, string username, FollowedStream.FollowedStreamType type)
|
private async Task TrackStream(ITextChannel channel, string username, FollowedStream.FollowedStreamType type)
|
||||||
{
|
{
|
||||||
username = username.ToLowerInvariant().Trim();
|
username = username.Trim();
|
||||||
var stream = new FollowedStream
|
var fs = new FollowedStream
|
||||||
{
|
{
|
||||||
GuildId = channel.Guild.Id,
|
GuildId = channel.Guild.Id,
|
||||||
ChannelId = channel.Id,
|
ChannelId = channel.Id,
|
||||||
@ -323,10 +351,10 @@ namespace NadekoBot.Modules.Searches
|
|||||||
Type = type,
|
Type = type,
|
||||||
};
|
};
|
||||||
|
|
||||||
StreamStatus data;
|
StreamStatus status;
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
data = await GetStreamStatus(stream).ConfigureAwait(false);
|
status = await GetStreamStatus(fs).ConfigureAwait(false);
|
||||||
}
|
}
|
||||||
catch
|
catch
|
||||||
{
|
{
|
||||||
@ -338,30 +366,45 @@ namespace NadekoBot.Modules.Searches
|
|||||||
{
|
{
|
||||||
uow.GuildConfigs.For(channel.Guild.Id, set => set.Include(gc => gc.FollowedStreams))
|
uow.GuildConfigs.For(channel.Guild.Id, set => set.Include(gc => gc.FollowedStreams))
|
||||||
.FollowedStreams
|
.FollowedStreams
|
||||||
.Add(stream);
|
.Add(fs);
|
||||||
await uow.CompleteAsync().ConfigureAwait(false);
|
await uow.CompleteAsync().ConfigureAwait(false);
|
||||||
}
|
}
|
||||||
var msg = $"Stream is currently **{(data.IsLive ? "ONLINE" : "OFFLINE")}** with **{data.Views}** viewers";
|
|
||||||
if (data.IsLive)
|
var msg = $":ok: I will notify this channel when status changes.";
|
||||||
msg += stream.GetLink();
|
await channel.EmbedAsync(fs.GetEmbed(status).Build(), msg).ConfigureAwait(false);
|
||||||
msg = $":ok: I will notify this channel when status changes.\n{msg}";
|
|
||||||
await channel.SendMessageAsync(msg).ConfigureAwait(false);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public static class FollowedStreamExtensions
|
public static class FollowedStreamExtensions
|
||||||
{
|
{
|
||||||
public static string GetLink(this FollowedStream fs)
|
public static EmbedBuilder GetEmbed(this FollowedStream fs, Searches.StreamStatus status)
|
||||||
{
|
{
|
||||||
//todo C#7
|
var embed = new EmbedBuilder().WithTitle(fs.Username)
|
||||||
|
.WithUrl(fs.GetLink())
|
||||||
|
.AddField(efb => efb.WithName("Status")
|
||||||
|
.WithValue(status.IsLive ? "Online" : "Offline")
|
||||||
|
.WithIsInline(true))
|
||||||
|
.AddField(efb => efb.WithName("Viewers")
|
||||||
|
.WithValue(status.IsLive ? status.Views : "-")
|
||||||
|
.WithIsInline(true))
|
||||||
|
.AddField(efb => efb.WithName("Platform")
|
||||||
|
.WithValue(fs.Type.ToString())
|
||||||
|
.WithIsInline(true))
|
||||||
|
.WithColor(status.IsLive ? NadekoBot.OkColor : NadekoBot.ErrorColor);
|
||||||
|
|
||||||
|
return embed;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static string GetLink(this FollowedStream fs) {
|
||||||
if (fs.Type == FollowedStream.FollowedStreamType.Hitbox)
|
if (fs.Type == FollowedStream.FollowedStreamType.Hitbox)
|
||||||
return $"\n`Here is the Link:`【 http://www.hitbox.tv/{fs.Username}/ 】";
|
return $"http://www.hitbox.tv/{fs.Username}/";
|
||||||
else if (fs.Type == FollowedStream.FollowedStreamType.Twitch)
|
else if (fs.Type == FollowedStream.FollowedStreamType.Twitch)
|
||||||
return $"\n`Here is the Link:`【 http://www.twitch.tv/{fs.Username}/ 】";
|
return $"http://www.twitch.tv/{fs.Username}/";
|
||||||
else if (fs.Type == FollowedStream.FollowedStreamType.Beam)
|
else if (fs.Type == FollowedStream.FollowedStreamType.Beam)
|
||||||
return $"\n`Here is the Link:`【 https://beam.pro/{fs.Username}/ 】";
|
return $"https://beam.pro/{fs.Username}/";
|
||||||
return "???";
|
else
|
||||||
|
return "??";
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
@ -13,7 +13,9 @@
|
|||||||
}
|
}
|
||||||
|
|
||||||
public override int GetHashCode() =>
|
public override int GetHashCode() =>
|
||||||
ChannelId.GetHashCode() ^ Username.GetHashCode();
|
ChannelId.GetHashCode() ^
|
||||||
|
Username.GetHashCode() ^
|
||||||
|
Type.GetHashCode();
|
||||||
|
|
||||||
public override bool Equals(object obj)
|
public override bool Equals(object obj)
|
||||||
{
|
{
|
||||||
@ -21,7 +23,9 @@
|
|||||||
if (fs == null)
|
if (fs == null)
|
||||||
return false;
|
return false;
|
||||||
|
|
||||||
return fs.ChannelId == ChannelId && fs.Username.ToLowerInvariant().Trim() == Username.ToLowerInvariant().Trim();
|
return fs.ChannelId == ChannelId &&
|
||||||
|
fs.Username.ToLowerInvariant().Trim() == Username.ToLowerInvariant().Trim() &&
|
||||||
|
fs.Type == Type;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -156,8 +156,8 @@ namespace NadekoBot.Extensions
|
|||||||
return list.ToArray();
|
return list.ToArray();
|
||||||
}
|
}
|
||||||
|
|
||||||
public static Task<IUserMessage> EmbedAsync(this IMessageChannel ch, Discord.API.Embed embed)
|
public static Task<IUserMessage> EmbedAsync(this IMessageChannel ch, Discord.API.Embed embed, string msg = "")
|
||||||
=> ch.SendMessageAsync("", embed: embed);
|
=> ch.SendMessageAsync(msg, embed: embed);
|
||||||
|
|
||||||
public static Task<IUserMessage> SendErrorAsync(this IMessageChannel ch, string error, string title = null, string url = null)
|
public static Task<IUserMessage> SendErrorAsync(this IMessageChannel ch, string error, string title = null, string url = null)
|
||||||
=> ch.SendMessageAsync("", embed: new Embed() { Description = error, Title = title, Url = url, Color = NadekoBot.ErrorColor });
|
=> ch.SendMessageAsync("", embed: new Embed() { Description = error, Title = title, Url = url, Color = NadekoBot.ErrorColor });
|
||||||
|
Loading…
Reference in New Issue
Block a user