move sources to src/

1 files changed, 195 insertions, 0 deletions

diff --git a/src/pa-sink-ctl.c b/src/pa-sink-ctl.c
new file mode 100644
index 0000000..5fe67c1
--- /dev/null
+++ b/src/pa-sink-ctl.c
@@ -0,0 +1,195 @@
+#define _XOPEN_SOURCE 500
+#include <string.h>
+#include <stdio.h>
+#include <pulse/pulseaudio.h>
+#include <ncurses.h>
+#include <stdlib.h>
+
+#include "sink_input.h"
+#include "sink.h"
+#include "interface.h"
+#include "pa-sink-ctl.h"
+
+#define VOLUME_MAX UINT16_MAX
+#define VOLUME_BAR_LEN 50
+#define WIDTH 80
+#define HEIGHT 10
+
+sink_info** sink_list = NULL;
+uint32_t sink_counter;
+uint32_t sink_max;
+
+pa_mainloop_api *mainloop_api = NULL;
+pa_context *context = NULL;
+
+// ncurses
+WINDOW *menu_win;
+int chooser;
+int startx;
+int starty;
+
+int main(int argc, char** argv)
+{
+	sink_counter = 0;
+	sink_max = 1;
+	sink_list = sink_list_init(sink_max);
+
+	interface_init();
+	pa_mainloop *m = NULL;
+	int ret = 1;
+
+	if (!(m = pa_mainloop_new())) {
+		printf("error: pa_mainloop_new() failed.\n");
+		return -1;
+	}
+
+	mainloop_api = pa_mainloop_get_api(m);
+
+	if (!(context = pa_context_new(mainloop_api, "pa-sink-ctl"))) {
+		printf("error: pa_context_new() failed.\n");
+		return -1;
+	}
+	
+	// define callback for connection init
+	pa_context_set_state_callback(context, context_state_callback, NULL);
+	if (pa_context_connect(context, "tcp:127.0.0.1:4712", PA_CONTEXT_NOAUTOSPAWN, NULL)) {
+		printf("error: pa_context_connect() failed.\n");
+	}
+
+	if (pa_mainloop_run(m, &ret) < 0) {
+		printf("error: pa_mainloop_run() failed.\n");
+		return -1;
+	}
+
+	return ret;
+}
+/*
+ * is called after connection
+ */
+void context_state_callback(pa_context *c, void *userdata) {
+
+	switch (pa_context_get_state(c)) {
+		case PA_CONTEXT_CONNECTING:
+//			printf("connecting...\n");
+			break;
+
+		case PA_CONTEXT_AUTHORIZING:
+//			printf("authorizing...\n");
+			break;
+
+		case PA_CONTEXT_SETTING_NAME:
+//			printf("setting name\n");
+			break;
+
+		case PA_CONTEXT_READY:
+//			printf("Menue\n");
+			pa_operation_unref(pa_context_get_sink_info_list(c, get_sink_info_callback, NULL));
+//			pa_operation_unref(pa_context_get_sink_input_info_list(c, get_sink_input_info_callback, NULL));
+			break;
+		default:
+			printf("unknown state\n");
+			break;
+	}
+}
+
+/*
+ * the begin of the callback loops
+ */
+void get_sink_info_callback(pa_context *c, const pa_sink_info *i, int is_last, void *userdata) {
+
+	if (is_last < 0) {
+		printf("Failed to get sink information: %s", pa_strerror(pa_context_errno(c)));
+		quit();
+	}
+
+	if (is_last) {
+		pa_operation_unref(pa_context_get_sink_input_info_list(c, get_sink_input_info_callback, NULL));
+		return;
+	}
+
+	sink_list_check(sink_list, &sink_max, sink_counter);
+
+	sink_list[sink_counter] = (sink_info*) calloc(1, sizeof(sink_info));
+	sink_list[sink_counter]->index = i->index;
+	sink_list[sink_counter]->mute = i->mute;
+	
+	sink_list[sink_counter]->name = strdup(i->name);
+	++sink_counter;
+}
+
+/*
+ * is called after sink-input
+ */
+void get_sink_input_info_callback(pa_context *c, const pa_sink_input_info *i, int is_last, void *userdata) {
+	char t[32], k[32]; //,cv[PA_CVOLUME_SNPRINT_MAX];
+
+	if (is_last < 0) {
+		printf("Failed to get sink input information: %s\n", pa_strerror(pa_context_errno(c)));
+		return;
+	}
+
+	if (is_last) {
+		print_sinks();
+		get_input(); 
+		return;
+	}
+
+	if (!(i->client != PA_INVALID_INDEX)) return;
+
+	snprintf(t, sizeof(t), "%u", i->owner_module);
+	snprintf(k, sizeof(k), "%u", i->client);
+
+/*	printf( "Sink Input #%u"
+		"\tClient: %s"
+		"\tSink: %u"
+		"\tMute: %d"
+		"\tVolume: %s"
+		"\tname: %s"
+		"\tpid: %s\n",
+			i->index,
+			i->client != PA_INVALID_INDEX ? k : "n/a",
+			i->sink,
+			i->mute,
+			pa_cvolume_snprint(cv, sizeof(cv), &i->volume),
+			pa_proplist_gets(i->proplist, "application.name"),
+			pa_proplist_gets(i->proplist, "application.process.id"));
+*/
+
+//	const char *name = pa_proplist_gets(i->proplist, "application.name");
+
+	int sink_num = i->sink;
+	int counter = sink_list[sink_num]->input_counter;
+
+	// check the length of the list
+	sink_check_input_list(sink_list[sink_num]);
+	// check the current element of the list
+	sink_input_check(&(sink_list[ sink_num ]->input_list[ counter ]));
+	sink_input_info* input = sink_list[sink_num]->input_list[counter];
+
+	input->name = strdup(pa_proplist_gets(i->proplist, "application.name"));
+	input->index = i->index;
+	input->vol = pa_cvolume_avg(&i->volume);
+
+	++sink_list[sink_num]->input_counter;
+}
+
+void quit(void) {
+	sink_list_clear(sink_list, &sink_max, &sink_counter);
+	interface_clear();
+	exit(0);
+}
+
+/*
+ * is called, after user input
+ */
+void change_callback(pa_context* c, int success, void* userdate) {
+
+
+	// get information about sinks
+	pa_operation_unref(pa_context_get_sink_input_info_list(context, get_sink_input_info_callback, NULL));
+}
+
+void collect_all_infomation(void) {
+	sink_list_reset(sink_list, &sink_counter);
+
+}