Swift
summaryrefslogtreecommitdiffstats
path: root/Swiften/LinkLocal
diff options
context:
space:
mode:
authorRemko Tronçon <git@el-tramo.be>2009-07-16 16:46:22 (GMT)
committerRemko Tronçon <git@el-tramo.be>2009-07-16 16:46:22 (GMT)
commita5afa80ca54da1b72078b3e508de1d80cceb0c90 (patch)
treeda8c779686e0fef9095e03d19ace1d0f7d3ddc25 /Swiften/LinkLocal
parent3adeaee96ab80cc6552798ad3f5812e934b45677 (diff)
downloadswift-a5afa80ca54da1b72078b3e508de1d80cceb0c90.zip
swift-a5afa80ca54da1b72078b3e508de1d80cceb0c90.tar.bz2
Created Swiften/LinkLocal module.
Diffstat (limited to 'Swiften/LinkLocal')
-rw-r--r--Swiften/LinkLocal/AppleDNSSDService.cpp116
-rw-r--r--Swiften/LinkLocal/AppleDNSSDService.h26
-rw-r--r--Swiften/LinkLocal/DNSSDService.cpp8
-rw-r--r--Swiften/LinkLocal/DNSSDService.h27
-rw-r--r--Swiften/LinkLocal/LinkLocalRoster.cpp21
-rw-r--r--Swiften/LinkLocal/LinkLocalRoster.h19
-rw-r--r--Swiften/LinkLocal/Makefile.inc9
7 files changed, 226 insertions, 0 deletions
diff --git a/Swiften/LinkLocal/AppleDNSSDService.cpp b/Swiften/LinkLocal/AppleDNSSDService.cpp
new file mode 100644
index 0000000..b68b09e
--- /dev/null
+++ b/Swiften/LinkLocal/AppleDNSSDService.cpp
@@ -0,0 +1,116 @@
+#include "Swiften/LinkLocal/AppleDNSSDService.h"
+
+#include <dns_sd.h>
+#include <iostream>
+#include <sys/socket.h>
+
+namespace Swift {
+
+namespace {
+ void handleServiceRegistered(DNSServiceRef sdRef, DNSServiceFlags flags, DNSServiceErrorType errorCode, const char *name, const char *regtype, const char *domain, void *context ) {
+ std::cerr << "Service registered " << name << " " << regtype << " " << domain << std::endl;
+ }
+
+ void handleServiceDiscovered(DNSServiceRef sdRef, DNSServiceFlags flags, uint32_t interfaceIndex, DNSServiceErrorType errorCode, const char *serviceName, const char *regtype, const char *replyDomain, void *context ) {
+ std::cerr << "Service discovered " << interfaceIndex << " " << serviceName << " " << regtype << " " << replyDomain << " " << flags << std::endl;
+ }
+
+ void handleServiceResolved( DNSServiceRef sdRef, DNSServiceFlags flags, uint32_t interfaceIndex, DNSServiceErrorType errorCode, const char *fullname, const char *hosttarget, uint16_t port, uint16_t txtLen, const unsigned char *txtRecord, void *context ) {
+ std::cerr << "Service resolved " << fullname << " " << hosttarget << " " << port << " " << txtLen << " " << /*std::string((const char*) txtRecord, txtLen) <<*/ std::endl;
+ }
+
+ void handleAddressInfoReceived ( DNSServiceRef sdRef, DNSServiceFlags flags, uint32_t interfaceIndex, DNSServiceErrorType errorCode, const char *hostname, const struct sockaddr *address, uint32_t ttl, void *context ) {
+ std::cerr << "Address received " << HostAddress((const unsigned char*) address->sa_data, 4).toString() << std::endl;
+ }
+}
+
+
+AppleDNSSDService::AppleDNSSDService() : thread(0), stopRequested(false) {
+}
+
+AppleDNSSDService::~AppleDNSSDService() {
+ stop();
+}
+
+void AppleDNSSDService::publishService(const std::map<String,String>) {
+}
+
+void AppleDNSSDService::start() {
+ assert(!thread);
+ thread = new boost::thread(boost::bind(&AppleDNSSDService::doStart, shared_from_this()));
+}
+
+void AppleDNSSDService::stop() {
+ if (thread) {
+ stopRequested = true;
+ thread->join();
+ delete thread;
+ stopRequested = false;
+ }
+}
+
+void AppleDNSSDService::doStart() {
+ while (!stopRequested) {
+
+ fd_set fdSet;
+ DNSServiceErrorType result;
+
+ DNSServiceRef registerSDRef;
+ result = DNSServiceRegister(&registerSDRef, 0, 0, "eemi", "_presence._tcp", NULL, NULL, 5269, 0, NULL, handleServiceRegistered, NULL);
+ if (result != kDNSServiceErr_NoError) {
+ std::cerr << "Error 1" << std::endl;
+ }
+ int registerSocket = DNSServiceRefSockFD(registerSDRef);
+ FD_ZERO(&fdSet);
+ FD_SET(registerSocket, &fdSet);
+ select(registerSocket+1, &fdSet, &fdSet, &fdSet, 0);
+ DNSServiceProcessResult(registerSDRef);
+
+ DNSServiceRef browseSDRef;
+ result = DNSServiceBrowse(&browseSDRef, 0, 0, "_presence._tcp", 0, handleServiceDiscovered , 0);
+ if (result != kDNSServiceErr_NoError) {
+ std::cerr << "Error 2" << std::endl;
+ }
+ int browseSocket = DNSServiceRefSockFD(browseSDRef);
+ //while(true) {
+ FD_ZERO(&fdSet);
+ FD_SET(browseSocket, &fdSet);
+ select(browseSocket+1, &fdSet, &fdSet, &fdSet, 0);
+ DNSServiceProcessResult(browseSDRef);
+ //}
+
+
+ DNSServiceRef resolveSDRef;
+ result = DNSServiceResolve(&resolveSDRef, 0, 6, "Remko@Micro", "_presence._tcp.", "local.", handleServiceResolved , 0);
+ if (result != kDNSServiceErr_NoError) {
+ std::cerr << "Error 3" << std::endl;
+ }
+ int resolveSocket = DNSServiceRefSockFD(resolveSDRef);
+ //while(true) {
+ FD_ZERO(&fdSet);
+ FD_SET(resolveSocket, &fdSet);
+ select(resolveSocket+1, &fdSet, &fdSet, &fdSet, 0);
+ DNSServiceProcessResult(resolveSDRef);
+ //}
+
+
+ DNSServiceRef addressSDRef;
+ result = DNSServiceGetAddrInfo(&addressSDRef, 0, 6, kDNSServiceProtocol_IPv4, "Micro.local.", handleAddressInfoReceived, 0);
+ if (result != kDNSServiceErr_NoError) {
+ std::cerr << "Error 4" << std::endl;
+ }
+ int addressSocket = DNSServiceRefSockFD(addressSDRef);
+ //while(true) {
+ std::cout << "GetAddrInfo2" << std::endl;
+ FD_ZERO(&fdSet);
+ FD_SET(addressSocket, &fdSet);
+ select(addressSocket+1, &fdSet, &fdSet, &fdSet, 0);
+ DNSServiceProcessResult(addressSDRef);
+ //}
+
+ // DNSServiceRefDeallocate
+
+ }
+}
+
+}
diff --git a/Swiften/LinkLocal/AppleDNSSDService.h b/Swiften/LinkLocal/AppleDNSSDService.h
new file mode 100644
index 0000000..e6bedf7
--- /dev/null
+++ b/Swiften/LinkLocal/AppleDNSSDService.h
@@ -0,0 +1,26 @@
+#pragma once
+
+#include <boost/enable_shared_from_this.hpp>
+#include <boost/thread.hpp>
+
+#include "Swiften/LinkLocal/DNSSDService.h"
+#include "Swiften/EventLoop/EventOwner.h"
+
+namespace Swift {
+ class AppleDNSSDService : public DNSSDService, public EventOwner, public boost::enable_shared_from_this<AppleDNSSDService> {
+ public:
+ AppleDNSSDService();
+ ~AppleDNSSDService();
+
+ virtual void publishService(const std::map<String,String> properties);
+ virtual void start();
+ virtual void stop();
+
+ private:
+ void doStart();
+
+ private:
+ boost::thread* thread;
+ bool stopRequested;
+ };
+}
diff --git a/Swiften/LinkLocal/DNSSDService.cpp b/Swiften/LinkLocal/DNSSDService.cpp
new file mode 100644
index 0000000..9545981
--- /dev/null
+++ b/Swiften/LinkLocal/DNSSDService.cpp
@@ -0,0 +1,8 @@
+#include "Swiften/LinkLocal/DNSSDService.h"
+
+namespace Swift {
+
+DNSSDService::~DNSSDService() {
+}
+
+}
diff --git a/Swiften/LinkLocal/DNSSDService.h b/Swiften/LinkLocal/DNSSDService.h
new file mode 100644
index 0000000..0899ffd
--- /dev/null
+++ b/Swiften/LinkLocal/DNSSDService.h
@@ -0,0 +1,27 @@
+#pragma once
+
+#include <boost/signal.hpp>
+#include <map>
+
+#include "Swiften/Base/String.h"
+
+namespace Swift {
+ class DNSSDService {
+ public:
+ struct DiscoveredService {
+ String name;
+ String type;
+ String domain;
+ int networkInterface;
+ };
+
+ virtual ~DNSSDService();
+
+ virtual void publishService(const std::map<String,String> properties) = 0;
+ virtual void start() = 0;
+
+ boost::signal<void (const DiscoveredService&)> onServiceAdded;
+ boost::signal<void (const DiscoveredService&)> onServiceRemoved;
+ boost::signal<void ()> onServiceRegistered;
+ };
+}
diff --git a/Swiften/LinkLocal/LinkLocalRoster.cpp b/Swiften/LinkLocal/LinkLocalRoster.cpp
new file mode 100644
index 0000000..6773d51
--- /dev/null
+++ b/Swiften/LinkLocal/LinkLocalRoster.cpp
@@ -0,0 +1,21 @@
+#include <boost/bind.hpp>
+#include <iostream>
+
+#include "Swiften/LinkLocal/LinkLocalRoster.h"
+
+namespace Swift {
+
+LinkLocalRoster::LinkLocalRoster(boost::shared_ptr<DNSSDService> service) : dnsSDService(service) {
+ service->onServiceAdded.connect(boost::bind(&LinkLocalRoster::handleServiceAdded, this, _1));
+ service->onServiceRemoved.connect(boost::bind(&LinkLocalRoster::handleServiceRemoved, this, _1));
+}
+
+void LinkLocalRoster::handleServiceAdded(const DNSSDService::DiscoveredService& service) {
+ std::cout << "Service added " << service.name << " " << service.type << " " << service.domain << std::endl;
+}
+
+void LinkLocalRoster::handleServiceRemoved(const DNSSDService::DiscoveredService& service) {
+ std::cout << "Service removed " << service.name << " " << service.type << " " << service.domain << std::endl;
+}
+
+}
diff --git a/Swiften/LinkLocal/LinkLocalRoster.h b/Swiften/LinkLocal/LinkLocalRoster.h
new file mode 100644
index 0000000..625bf8b
--- /dev/null
+++ b/Swiften/LinkLocal/LinkLocalRoster.h
@@ -0,0 +1,19 @@
+#pragma once
+
+#include <boost/shared_ptr.hpp>
+
+#include "Swiften/LinkLocal/DNSSDService.h"
+
+namespace Swift {
+ class LinkLocalRoster {
+ public:
+ LinkLocalRoster(boost::shared_ptr<DNSSDService> service);
+
+ private:
+ void handleServiceAdded(const DNSSDService::DiscoveredService&);
+ void handleServiceRemoved(const DNSSDService::DiscoveredService&);
+
+ private:
+ boost::shared_ptr<DNSSDService> dnsSDService;
+ };
+}
diff --git a/Swiften/LinkLocal/Makefile.inc b/Swiften/LinkLocal/Makefile.inc
new file mode 100644
index 0000000..54315da
--- /dev/null
+++ b/Swiften/LinkLocal/Makefile.inc
@@ -0,0 +1,9 @@
+SWIFTEN_SOURCES += \
+ Swiften/LinkLocal/DNSSDService.cpp \
+ Swiften/LinkLocal/LinkLocalRoster.cpp
+
+
+ifeq ($(MACOSX),1)
+SWIFTEN_SOURCES += \
+ Swiften/LinkLocal/AppleDNSSDService.cpp
+endif