VuoSyphon.m

Go to the documentation of this file.

 
#include "VuoImageRenderer.h"
#include "VuoApp.h"
#include "VuoSyphon.h"
#include "VuoSyphonListener.h"
#include "VuoSyphonSender.h"
#include <Syphon.h>
 
#ifdef VUO_COMPILER
VuoModuleMetadata({
                     "title" : "VuoSyphon",
                     "dependencies" : [
                        "VuoSyphonServerDescription",
                        "VuoList_VuoSyphonServerDescription",
                        "VuoImageRenderer",
                        "VuoSyphonListener",
                        "VuoSyphonSender",
                        "Syphon.framework"
                     ]
                 });
#endif
 
 
VuoList_VuoSyphonServerDescription VuoSyphon_getAvailableServerDescriptions(void)
{
    NSArray *servers = [[SyphonServerDirectory sharedDirectory] serversMatchingName:nil appName:nil];
    VuoList_VuoSyphonServerDescription descriptions = VuoListCreate_VuoSyphonServerDescription();
 
    for (NSDictionary *server in servers)
    {
        VuoText serverUUID = VuoText_make([[server objectForKey:SyphonServerDescriptionUUIDKey] UTF8String]);
        VuoText serverName = VuoText_make([[server objectForKey:SyphonServerDescriptionNameKey] UTF8String]);
        VuoText applicationName = VuoText_make([[server objectForKey:SyphonServerDescriptionAppNameKey] UTF8String]);
 
        VuoSyphonServerDescription description = VuoSyphonServerDescription_make(serverUUID, serverName, applicationName, true);
        VuoListAppendValue_VuoSyphonServerDescription(descriptions, description);
    }
 
    return descriptions;
}
 
VuoList_VuoSyphonServerDescription VuoSyphon_filterServerDescriptions(VuoList_VuoSyphonServerDescription allDescriptions,
                                                                      VuoSyphonServerDescription partialDescription)
{
    VuoList_VuoSyphonServerDescription filteredDescriptions = VuoListCreate_VuoSyphonServerDescription();
 
    unsigned long count = VuoListGetCount_VuoSyphonServerDescription(allDescriptions);
    for (int i = 1; i <= count; ++i)
    {
        VuoSyphonServerDescription description = VuoListGetValue_VuoSyphonServerDescription(allDescriptions, i);
 
        if (partialDescription.useWildcard)
        {
            if (VuoText_compare(description.serverUUID,      (VuoTextComparison){VuoTextComparison_MatchesWildcard, true}, partialDescription.serverUUID)
             && VuoText_compare(description.serverName,      (VuoTextComparison){VuoTextComparison_MatchesWildcard, true}, partialDescription.serverName)
             && VuoText_compare(description.applicationName, (VuoTextComparison){VuoTextComparison_MatchesWildcard, true}, partialDescription.applicationName))
                VuoListAppendValue_VuoSyphonServerDescription(filteredDescriptions, description);
        }
        else
        {
            if ((!partialDescription.serverUUID      || strstr(description.serverUUID,      partialDescription.serverUUID     ) != NULL)
             && (!partialDescription.serverName      || strstr(description.serverName,      partialDescription.serverName     ) != NULL)
             && (!partialDescription.applicationName || strstr(description.applicationName, partialDescription.applicationName) != NULL))
                VuoListAppendValue_VuoSyphonServerDescription(filteredDescriptions, description);
        }
    }
 
    return filteredDescriptions;
}
 
 
void VuoSyphonClient_free(void *syphonClient);
 
VuoSyphonClient VuoSyphonClient_make(void)
{
    VuoSyphonListener *listener = [[VuoSyphonListener alloc] init];
    VuoRegister(listener, VuoSyphonClient_free);
    return (VuoSyphonClient)listener;
}
 
void VuoSyphonClient_connectToServer(VuoSyphonClient syphonClient,
                                     VuoSyphonServerDescription serverDescription,
                                     VuoOutputTrigger(receivedFrame, VuoImage))
{
    VuoApp_init(false);
    VuoSyphonListener *listener = (VuoSyphonListener *)syphonClient;
    [listener startListeningWithServerDescription:serverDescription callback:receivedFrame];
}
 
void VuoSyphonClient_disconnectFromServer(VuoSyphonClient syphonClient)
{
    VuoSyphonListener *listener = (VuoSyphonListener *)syphonClient;
    [listener stopListening];
}
 
void VuoSyphonClient_free(void *syphonClient)
{
    VuoSyphonListener *listener = (VuoSyphonListener *)syphonClient;
    [listener release];
}
 
 
 
void VuoSyphonServer_free(void *server);
 
VuoSyphonServer VuoSyphonServer_make(const char *serverName)
{
    if (!serverName)
        serverName = "Vuo Syphon Server";
 
    VuoApp_init(false);
    VuoSyphonSender *server = [[VuoSyphonSender alloc] init];
    [server initServerWithName:[NSString stringWithUTF8String:serverName]];
    VuoRegister(server, VuoSyphonServer_free);
    return (VuoSyphonServer)server;
}
 
void VuoSyphonServer_publishFrame(VuoSyphonServer server, VuoImage frame)
{
    [(VuoSyphonSender*)server publishFrame:frame];
}
 
void VuoSyphonServer_setName(VuoSyphonServer server, const char *serverName)
{
    if (!serverName)
        return;
 
    [(VuoSyphonSender*)server setName:[NSString stringWithUTF8String:serverName]];
}
 
void VuoSyphonServer_free(void *server)
{
    [(VuoSyphonSender*)server stop];
    [(VuoSyphonSender*)server release];
}