/mnt/hgfs/jamie_On_My_Mac/store/version_control/svn/integralive/library/trunk/Integra/integra_server.h

Go to the documentation of this file.

/* libIntegra multimedia module definition interface
 *
 * Copyright (C) 2007 Jamie Bullock, Henrik Frisk
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 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, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301,
_resolve * USA.
 */


#ifndef NTG_SERVER_H
#define NTG_SERVER_H

#ifdef __cplusplus
extern "C" {
#endif

#include <stdarg.h>
#include "Integra/integra_instance.h"
#include "Integra/integra_model.h"
#include "Integra/integra_error.h"
#include "Integra/integra_path.h"
#include "Integra/integra_connection.h"
#include "Integra/integra_bridge_host.h"

#define RESPONSE_LABEL "response"
#define BASE_URL "db.integralive.org:80/"
#define ADMIN_URL BASE_URL "admin/"
#define NTG_NULL_STRING "None"

typedef struct ntg_class_list_ {
    char **classes;
    int n_classes;
} ntg_class_list;

typedef struct ntg_server_ {

    ntg_class_list *classlist;
    ntg_model *model; 
    ntg_bridge_interface *bridge;
    ntg_instance *root;
    struct ntg_connection_ *connection_list;

} ntg_server;

typedef struct ntg_client_ {
    char *ip;
    int port;
} ntg_client;

ntg_class_list *ntg_classlist(const ntg_server *server);

ntg_definition *ntg_classinfo(ntg_server *server, const char *class_name);

ntg_attribute_list *ntg_attributes(const ntg_server *server, 
        const char *class_name);

char *ntg_new(const ntg_server *server, const char *class_name,
        const char *instance_name, const ntg_path *path);

ntg_error_code ntg_delete(ntg_server *server,const ntg_path *path);

ntg_error_code ntg_rename(const ntg_server *server,const ntg_path *path, const char *name);

ntg_error_code ntg_save(const ntg_server *server,const ntg_path *path, const char *file_path);

ntg_error_code ntg_load(const ntg_server *server,const char *file_path, 
        const ntg_path *path);

ntg_error_code ntg_move(const ntg_server *server,const ntg_path *instance_path,
        const ntg_path *parent_path);


ntg_error_code ntg_set(const ntg_server *server, 
        const ntg_path *attribute_path, const ntg_value *value);

ntg_value *ntg_get(const ntg_server *server, const ntg_path *path);

ntg_node_list *ntg_nodelist(const ntg_server *server, const ntg_path *path);

void ntg_updates(const ntg_server *server, int index);

int ntg_stateindex(const ntg_server *server);


ntg_error_code ntg_runscript(ntg_server *server, const char *script);



typedef void *(* ntg_server_callback)(ntg_server *, int, va_list);
ntg_server *ntg_server_new(void);

void *ntg_server_do(ntg_server_callback, const int argc, ...);

typedef void *(*ntg_bridge_callback)(int argc, void *argv);

void *server_receive_callback(ntg_id id, unsigned int port, const int argc, 
        const ntg_value *message, void (*bridge_send_callback)(const ntg_port *, const ntg_value *));


ntg_bridge_callback ntg_server_run(const char * bridge_file, const int port);

ntg_definition *ntg_get_definition_by_name(const ntg_server *server, 
                                           const char *name);

char *ntg_get_type_by_id(const ntg_server *server, const int id);
char ntg_type_code_from_type_string(const char *type);
char *ntg_get_scope_by_id(const ntg_server *server, const int id);
char *ntg_get_control_attribute_by_id(ntg_server *server, const int id);
char *ntg_get_control_by_control_attribute_id(ntg_server *server, const int id);
char *ntg_get_scale_by_id(ntg_server *server, const int id);
ntg_module_attribute *ntg_get_module_attribute_by_id(const ntg_server *server, const int id);

ntg_default_value *ntg_get_default_value_by_id(ntg_server *server, const int id);
char *ntg_get_unit_by_id(ntg_server *server, const int id);
char *ntg_get_control_by_id(ntg_server *server, const int id);

int ntg_register(ntg_server *server, const char *ip, const int port);

ntg_instance *ntg_server_get_root(const ntg_server *server);

void ntg_server_set_root(ntg_server *server, ntg_instance *root);

ntg_node_list *ntg_server_get_nodelist(const ntg_server *server, 
        ntg_instance *container, ntg_path *parent_path, 
        ntg_node_list *nodelist);

ntg_attribute_list *ntg_server_get_class_attributes(const ntg_server *server, 
        const char *class_name, ntg_attribute_list *attribute_list);

ntg_error_code ntg_server_update_connection(ntg_server *server,
        const ntg_instance *connection_instance,
        const ntg_instance_attribute *instance_attribute);

ntg_error_code ntg_server_new_connection(ntg_server *server, 
        const ntg_instance *connection_instance);

ntg_error_code ntg_server_delete_connection(ntg_server *server, 
        const ntg_instance *connection_instance);

ntg_error_code ntg_server_delete_orphaned_connections(ntg_server *server);

ntg_error_code ntg_server_instance_delete(ntg_server *server, ntg_instance *instance);

ntg_error_code ntg_server_fix_connections(ntg_server *server, 
        ntg_instance *instance, const char *name);

#ifdef __cplusplus
}
#endif

#endif

---