67 lines
2.8 KiB
C#
67 lines
2.8 KiB
C#
// SparkleShare, a collaboration and sharing tool.
|
|
// Copyright (C) 2010 Hylke Bons <hi@planetpeanut.uk>
|
|
//
|
|
// This program is free software: you can redistribute it and/or modify
|
|
// it under the terms of the GNU Lesser General Public License as
|
|
// published by the Free Software Foundation, either version 3 of the
|
|
// License, or (at your option) any later version.
|
|
//
|
|
// This program is distributed in the hope that it will be useful,
|
|
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
// GNU General Public License for more details.
|
|
//
|
|
// You should have received a copy of the GNU General Public License
|
|
// along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
|
|
using System;
|
|
using System.Collections.Generic;
|
|
|
|
namespace Sparkles {
|
|
|
|
public static class ListenerFactory {
|
|
|
|
static readonly List<BaseListener> listeners = new List<BaseListener> ();
|
|
|
|
|
|
public static BaseListener CreateListener (string folder_name, string folder_identifier)
|
|
{
|
|
// Check if the user wants to use a global custom notification service
|
|
string uri = Configuration.DefaultConfiguration.GetConfigOption ("announcements_url");
|
|
|
|
// Check if the user wants a use a custom notification service for this folder
|
|
if (string.IsNullOrEmpty (uri))
|
|
uri = Configuration.DefaultConfiguration.GetFolderOptionalAttribute (folder_name, "announcements_url");
|
|
|
|
// This is SparkleShare's centralized notification service.
|
|
// It communicates "It's time to sync!" signals between clients.
|
|
//
|
|
// Please see the SparkleShare wiki if you wish to run
|
|
// your own service instead
|
|
if (string.IsNullOrEmpty (uri))
|
|
uri = "tcp://announcements.sparkleshare.org:443";
|
|
|
|
var announce_uri = new Uri (uri);
|
|
|
|
// Use only one listener per notification service to keep
|
|
// the number of connections as low as possible
|
|
foreach (BaseListener listener in listeners) {
|
|
if (listener.Server.Equals (announce_uri)) {
|
|
Logger.LogInfo ("ListenerFactory", "Refered to existing listener for " + announce_uri);
|
|
|
|
// We already seem to have a listener for this server,
|
|
// refer to the existing one instead
|
|
listener.AlsoListenTo (folder_identifier);
|
|
return listener;
|
|
}
|
|
}
|
|
|
|
listeners.Add (new TcpListener (announce_uri, folder_identifier));
|
|
Logger.LogInfo ("ListenerFactory", "Issued new listener for " + announce_uri);
|
|
|
|
return listeners [listeners.Count - 1];
|
|
}
|
|
}
|
|
}
|