azurebroadcast-functions/FunctionsContainer.cs at master · bitfox-git/azurebroadcast-functions · GitHub

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
using System;
using System.IO;
using System.Reflection;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Description;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.Azure.WebJobs.Extensions.SignalRService;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;


namespace Bitfox.AzureBroadcast.Functions
{

    public static class FunctionsContainer
    {
        [AppSetting(Default = "AzureSignalRConnectionString")]
        private static string azure { get; set; }

        [FunctionName("info")]
        public static string Info(
        [HttpTrigger(AuthorizationLevel.Anonymous)] HttpRequest req)
        {
            var version = typeof(FunctionsContainer).Assembly.GetName().Version.ToString();
            var signalrsettingfound = azure!="";
            return $@"Version  : {version}
                      AzureSignalRConnectionString found : {signalrsettingfound}";
        }

        [FunctionName("negotiate")]
        public static SignalRConnectionInfo Negotiate(
            [HttpTrigger(AuthorizationLevel.Function)] HttpRequest req,
            [SignalRConnectionInfo(HubName = "general", UserId = "{headers.x-ms-signalr-userid}")] SignalRConnectionInfo connectionInfo)
        {
            return connectionInfo;
        }


        [FunctionName("broadcast")]
        public static Task Broadcast(
            [HttpTrigger(AuthorizationLevel.Function, "post")]HttpRequest req,
            [SignalR(HubName = "general")]IAsyncCollector<SignalRMessage> signalRMessages)
        {

            string message;
            using (StreamReader stream = new StreamReader(req.Body))
            {
                message = stream.ReadToEnd();
            }
            var wrapped = JsonConvert.DeserializeObject<BroadcastMessage>(message);

            return signalRMessages.AddAsync(
                new SignalRMessage
                {
                    UserId = wrapped.toUser,
                    GroupName = wrapped.toGroupName,
                    Target = "newMessage",
                    Arguments = new[] { message }
                });

        }

        [FunctionName("groupaction")]
        public static Task GroupActions(
            [HttpTrigger(AuthorizationLevel.Function, "post")]HttpRequest req,
            [SignalR(HubName = "general")]IAsyncCollector<SignalRGroupAction> signalRGroupAction)
        {
            string gamstring;
            using (StreamReader stream = new StreamReader(req.Body))
            {
                gamstring = stream.ReadToEnd();
            }
            var gam = JsonConvert.DeserializeObject<GroupActionMessage>(gamstring);
            string userId = req.Headers["x-ms-signalr-userid"];

            return signalRGroupAction.AddAsync(
                new SignalRGroupAction
                {
                    Action = gam.groupAction,
                    GroupName = gam.groupName,
                    UserId = userId
                });

        }

    }
}