summaryrefslogtreecommitdiff
path: root/NT/src/graph.cpp
blob: 50db271dbdbf0da3ae559cd283d93aec9fdfd364 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
#include "graph.h"

using namespace Rotor;
using namespace std;

bool Graph::check_audio(string audio,string path){
	Logger& logger = Logger::get(id);
	if (audio!="")	{
		audio_filename=path+audio;
		Poco::File f=Poco::File(audio_filename);
		if (f.exists()) {
			//here we should check the audio is actually valid
			audio_loaded=true;
			logger.information("Loading "+audio_filename+" from graph");
			return true;
		}
		logger.error("Audio file "+audio_filename+" not found");
	}
	return false;
}
bool Graph::load_file(std::string filename,std::string media_path){
	Logger& logger = Logger::get(id);
	Poco::File f=Poco::File(filename);
	if (f.exists()) {
		Poco::FileInputStream fis(filename);
		Poco::CountingInputStream countingIstr(fis);
		std::string str;
		Poco::StreamCopier::copyToString(countingIstr, str);
		return parse_json(str,media_path);
	}
	logger.error("Graph "+filename+" not found");
	return false;
}
Node* Graph::find_node(const string &type){
	for (std::unordered_map<string,Node*>::iterator it=nodes.begin();it!=nodes.end();++it) {
		if (it->second->get_type()==type) return it->second;
	}
	return nullptr;
};
Node* Graph::get_node(const std::string &id){
	if (nodes.find(id)!=nodes.end()) return nodes[id];
	return nullptr;
}
bool Graph::parse_json(string &data,string &media_path){
	Logger& logger = Logger::get(id);
	Json::Value root;   // will contain the root value after parsing.
	Json::Reader reader;
	bool parsing_successful = reader.parse( data, root );
	if ( !parsing_successful )
	{
		logger.error("Failed to parse configuration: "+reader.getFormattedErrorMessages());
	    return false;
	}
	//The json validates, now we should attempt to retain nodes which haven't changed
	//for now just clear the existing graph
	clear();
	Node_factory factory(id);
	check_audio(root["audio"].asString(),media_path);
	init(root["id"].asString());
	Json::Value jnodes = root["nodes"];
	for ( uint32_t i = 0; i < jnodes.size(); ++i ) {
		string node_id=jnodes[i]["id"].asString();
		Node* node=factory.create(jnodes[i]);
		if (node) {
			if (nodes.find(node_id)==nodes.end()){
				logger.information("Creating node '"+node_id+"'': '"+jnodes[i]["type"].asString()+"'");
				node->create_connections(nodes);
				nodes[node_id]=node;
			}
			else logger.error("ERROR: duplicate node '"+node_id+"' ");
		}
		else {
			logger.error("ERROR: graph loader cannot find node '"+jnodes[i]["type"].asString()+"'");
			return false;
		}
	}
	return true;
}

//should nodes be identified by uuid rather than name?
//array inlets can be identified by number as this is all they usually are