paul/yavsc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Implemente la notification de connection

Browse Source 
Ok coté serveur, et interface web
manque le client mobile
This commit is contained in:
Paul Schneider
2016-10-27 17:23:48 +02:00
parent 5a0c3f7f51
commit 01ad21adee
3 changed files with 61 additions and 45 deletions
Download Patch File Download Diff File Expand all files Collapse all files

94
Yavsc/Hubs/ChatHub.cs
View File

@ -19,55 +19,65 @@
// You should have received a copy of the GNU Lesser General Public License
// along with this program. If not, see <http://www.gnu.org/licenses/>.
using System.Threading.Tasks;
using System.Security.Claims;
using System.Security.Principal;
using Microsoft.AspNet.SignalR;
namespace Yavsc
{
public class ChatHub : Hub
public class ChatHub : Hub
{
public override Task OnConnected()
{
public override Task OnConnected()
{
if (Context.User!=null) {
var group = (Context.User.Identity.IsAuthenticated)?
"authenticated":"anonymous";
// Log ("Cx: " + group);
Groups.Add(Context.ConnectionId, group);
} else Groups.Add(Context.ConnectionId, "anonymous");
return base.OnConnected ();
}
public override Task OnDisconnected (bool stopCalled)
{
return base.OnDisconnected (stopCalled);
}
bool isAuth = false;
string userId = null;
if (Context.User!=null) {
isAuth = Context.User.Identity.IsAuthenticated;
userId = Context.User.Identity.Name;
var group = isAuth ?
"authenticated":"anonymous";
// Log ("Cx: " + group);
Groups.Add(Context.ConnectionId, group);
} else Groups.Add(Context.ConnectionId, "anonymous");
Clients.Group("authenticated").notify("connected", Context.ConnectionId, userId);
return base.OnConnected ();
}
public override Task OnDisconnected (bool stopCalled)
{
string userId = Context.User?.Identity.Name;
Clients.Group("authenticated").notify("disconnected", Context.ConnectionId, userId);
return base.OnDisconnected (stopCalled);
}
public override Task OnReconnected ()
{
return base.OnReconnected ();
}
public void Send(string name, string message)
{
Clients.All.addMessage(name,message);
}
[Authorize]
public void AuthSend (string name, string message)
{
Clients.All.addMessage("#"+name,message);
}
[Authorize]
public void PV (string userId, string message)
{
var sender = Context.User.Identity.Name;
// TODO personal black|white list +
// Contact list allowed only +
// only pro
var hubCxContext = Clients.User(userId);
var cli = Clients.Client(hubCxContext.ConnectionId);
cli.addPV(sender,message);
}
{
return base.OnReconnected ();
}
public void Send(string name, string message)
{
Clients.All.addMessage(name,message);
}
[Authorize]
public void AuthSend (string name, string message)
{
Clients.All.addMessage("#"+name,message);
}
[Authorize]
public void PV (string connectionId, string message)
{
var sender = Context.User.Identity.Name;
// TODO personal black|white list +
// Contact list allowed only +
// only pro
var hubCxContext = Clients.User(connectionId);
var cli = Clients.Client(connectionId);
cli.addPV(sender,message);
}
}
}