#define _XOPEN_SOURCE 500 #include #include #include #include #include #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"); collect_all_info(); // 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\n", 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_check(&(sink_list[sink_counter])); 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_sink_list(); 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_info(void) { sink_list_reset(sink_list, &sink_counter); pa_operation_unref(pa_context_get_sink_info_list(context, get_sink_info_callback, NULL)); }