/*

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
*/

#include "tmxtm.h" 
#include "tmassert.h" 
#include "tmtrace.h" 
#include "tmsubject.h" 
#include "tmtopicmap.h" 
/*
#include <errno.h>
#include <stdarg.h>
#include <ctype.h>
*/
#include "tmvtasidp.h" 

static char q1[] = "\
SELECT * \
 WHERE http://purl.org/tm/amod/a-sidp == null \
   AND http://purl.org/tm/sam/IndicatorData == null";

static char q2[] = "\
SELECT * \
 WHERE http://purl.org/tm/amod/a-sidp != null";

static void my_print_topic(char **bufp, int *sizep,TMSubject sbj, TMTopic t);
static void my_print_assoc(char **bufp, int *sizep,TMSubject sbj, TMTopic t);

static char preamble[] = "<?xml version=\"1.0\"?>\n\
<!DOCTYPE topicMap PUBLIC \"-//TopicMaps.Org//DTD XML Topic Map (XTM) 1.0//EN\"\n\
                          \"http://www.topicmaps.org/xtm/1.0/xtm1.dtd\">\n\
\n\
<topicMap\n\
    xmlns=\"http://www.topicmaps.org/xtm/1.0/\"\n\
    xmlns:xlink=\"http://www.w3.org/1999/xlink\">\n\
\n\n";
 

TMError make_xtm(TMTopicMap topicmap,void chunk(const char *chunk, void *cl), void *cl,
	int chunk_size)
{
	TMResult result = NULL;
	char *buf;
	int size = 4096;
	int i /*,j*/;
	TM_ENTER;
	tm_topicmap_start_transaction(topicmap,"query");
	buf = (char*)TM_ALLOC( tm_topicmap_get_current_transaction_pool(topicmap),
			4096);

	if( tm_topicmap_query(topicmap,q1,&result) != TM_OK)
	{
		fprintf(stderr,"could not execute query '%s', %s\n",
		q1, tm_get_error(tm_topicmap_get_tm(topicmap)) );
		assert(0);
	}
	assert(result);
	assert(result->type == TM_RESULT_SUBJECTS);
	snprintf(buf,size,"%s",preamble);
	chunk(buf,cl);
	*buf = 0;
	for(i=0;i<result->nsubjects;i++)
	{
		my_print_topic(&buf,&size,&(result->subjects[i]),result->topics[i]);
		chunk(buf,cl);
		*buf = 0;
	}
	tm_result_delete(&result);


	if( tm_topicmap_query(topicmap,q2,&result) != TM_OK)
	{
		fprintf(stderr,"could not execute query '%s', %s\n",
		q1, tm_get_error(tm_topicmap_get_tm(topicmap)) );
		assert(0);
	}
	assert(result);
	assert(result->type == TM_RESULT_SUBJECTS);
	for(i=0;i<result->nsubjects;i++)
	{
		my_print_assoc(&buf,&size,&(result->subjects[i]),result->topics[i]);
		chunk(buf,cl);
		*buf = 0;
	}





	snprintf(buf,size,"</topicMap>\n");
	chunk(buf,cl);
	*buf = 0;

	TM_FREE(tm_topicmap_get_current_transaction_pool(topicmap),buf);

	tm_topicmap_end_transaction(topicmap);
	TM_RETURN(TM_OK);
}

void my_print_topic(char **bufp, int *sizep,TMSubject sbj, TMTopic t)
{
	TMList sirs,names;
	int j;
	char b[1024];
	TM_ENTER;
	snprintf(*bufp,*sizep,"<topic id=\"T%d\">\n" , t);
	if( tm_subject_get_value(sbj,"http://purl.org/tm/sam/SubjectIndicators",NULL)
	|| tm_subject_get_value(sbj,"http://purl.org/tm/sam/SubjectAddress",NULL))
	{
		strcat(*bufp,"  <subjectIdentity>\n");
		if( tm_subject_get_value(sbj,"http://purl.org/tm/sam/SubjectIndicators",
						(void**)&sirs ))
		{
			for( ; sirs; sirs=sirs->next)
			{
				sprintf(b,"    <subjectIndicatorRef xlink:href=\"%s\"/>\n" ,
					(char*)sirs->content );
				strcat(*bufp,b);
			}
		}
		strcat(*bufp,"  </subjectIdentity>\n");
	}

	if( tm_subject_get_value(sbj,"http://purl.org/tm/sam/BaseNames",(void**)&names ))
	{
		for( ; names; names=names->next)
		{
			strcat(*bufp,"  <baseName>\n");
			sprintf(b,"    <baseNameString>%s</baseNameString>\n" ,
				(char*)names->content );
			strcat(*bufp,b);
			strcat(*bufp,"  </baseName>\n");
		}
	}
	for(j=0;j<sbj->N;j++)
	{
		char buf[1024];
		if(strcmp(sbj->props[j].prop->fullname,
			"http://purl.org/tm/sam/BaseNames") == 0)
			continue;
		if(strcmp(sbj->props[j].prop->fullname,
			"http://purl.org/tm/sam/SubjectIndicators") == 0)
			continue;
		if(strcmp(sbj->props[j].prop->fullname,
			"http://purl.org/tm/sam/SubjectAddress") == 0)
			continue;
		if(strcmp(sbj->props[j].prop->fullname,
			"http://purl.org/tm/sam/SourceLocators") == 0)
			continue;

		tm_value_to_string(
			sbj->props[j].prop->value_type,
			sbj->props[j].value,
			buf,1024);
		strcat(*bufp,"  <occurrence>\n");
		strcat(*bufp,"    <instanceOf>\n");
		sprintf(b,"      <subjectIndicatorRef xlink:href=\"%s\" />\n",
						sbj->props[j].prop->fullname);
		strcat(*bufp,b);
		strcat(*bufp,"    </instanceOf>\n");
		sprintf(b,"    <resourceData>%s</resourceData>\n",buf);
		strcat(*bufp,b);
		strcat(*bufp,"  </occurrence>\n");
	}

	strcat(*bufp,"</topic>\n");
	TM_EXIT;
}
void my_print_assoc(char **bufp, int *sizep,TMSubject sbj, TMTopic t)
{
	struct asidp_value *Vasidp;
	TMList mp;
	char b[1024];
	int j;

	TM_ENTER;
	tm_subject_get_value(sbj,"http://purl.org/tm/amod/a-sidp",&Vasidp);
	sprintf(b,"<association id=\"%d\">\n" , t);
	strcat(*bufp,b);
	strcat(*bufp,"  <instanceOf>\n");
	sprintf(b,"    <topicRef xlink:href=\"#T%d\" />\n", Vasidp->type.topic);
	strcat(*bufp,b);
	strcat(*bufp,"  </instanceOf>\n");
	for(mp=Vasidp->memberships;mp;mp=mp->next)
	{
		struct a_membership *m;
		m = (struct a_membership *)mp->content;
		strcat(*bufp,"  <roleSpec>\n");
		sprintf(b,"    <topicRef xlink:href=\"#T%d\" />\n", m->role.topic);
		strcat(*bufp,b);
		strcat(*bufp,"  </roleSpec>\n");
		sprintf(b,"  <topicRef xlink:href=\"#T%d\" />\n", m->player.topic);
		strcat(*bufp,b);
	}
	strcat(*bufp,"</association>\n");
	TM_EXIT;

}


#if 0
		TMProperty p = result->prop_heading[j];
		printf("| %-30s\t",p->name);
	}
	printf("%s\n\n","|");
			
	for(i=0;i<result->nrows;i++)
	{
		void **row;
		row = result->vtable[i];
		for(j=0;j<result->ncols;j++)
{
			TMProperty p = result->prop_heading[j];
			printf("| %-30s\t",
			tm_value_as_string(p->value_type,row[j],NULL,0) );
		}
		printf("%s\n","|");
	}
	break;
	default:
			} /* end switch */
			tm_topicmap_end_transaction(topicmap);
		}


#endif