summaryrefslogtreecommitdiff
path: root/src/socket.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/socket.c')
-rw-r--r--src/socket.c68
1 files changed, 54 insertions, 14 deletions
diff --git a/src/socket.c b/src/socket.c
index 5b42e53..0191ac5 100644
--- a/src/socket.c
+++ b/src/socket.c
@@ -191,6 +191,52 @@ recv_server_sync(MumbleProto__ServerSync *sync, struct context *ctx)
}
static void
+recv_crypt_setup(MumbleProto__CryptSetup *crypt, struct context *ctx)
+{
+ int i;
+
+ if (crypt->has_key) {
+ printf("key: 0x");
+ for (i = 0; i < crypt->key.len; ++i)
+ printf("%x", crypt->key.data[i]);
+ printf("\n");
+
+ }
+ if (crypt->has_client_nonce) {
+ printf("client nonce: 0x");
+ for (i = 0; i < crypt->client_nonce.len; ++i)
+ printf("%x", crypt->client_nonce.data[i]);
+ printf("\n");
+
+ }
+ if (crypt->has_server_nonce) {
+ printf("server nonce: 0x");
+ for (i = 0; i < crypt->server_nonce.len; ++i)
+ printf("%x", crypt->server_nonce.data[i]);
+ printf("\n");
+
+ }
+}
+
+static void
+recv_codec_version(MumbleProto__CodecVersion *codec, struct context *ctx)
+{
+ printf("Codec Version: alpha: %d, beta: %d, pefer_alpha: %d\n",
+ codec->alpha, codec->beta, codec->prefer_alpha);
+}
+
+typedef void (*callback_t)(void *, void *);
+
+static const callback_t callbacks[] = {
+ /* VERSION */ (callback_t) recv_version,
+ [5] = (callback_t) recv_server_sync,
+ [7] = (callback_t) recv_channel_state,
+ [15] = (callback_t) recv_crypt_setup,
+ [21] = (callback_t) recv_codec_version,
+ [127] = NULL,
+};
+
+static void
send_msg(struct context *ctx, ProtobufCMessage *msg)
{
uint8_t pad[128];
@@ -216,8 +262,6 @@ send_msg(struct context *ctx, ProtobufCMessage *msg)
PROTOBUF_C_BUFFER_SIMPLE_CLEAR(&buffer);
}
-typedef void (*callback_t)(void *, void *);
-
static void
recv_msg(struct context *ctx, const callback_t *callbacks, uint32_t callback_size)
{
@@ -293,13 +337,6 @@ do_ping(struct context *ctx)
return TRUE;
}
-static const callback_t callbacks[] = {
- /* VERSION */ (callback_t) recv_version,
- [5] = (callback_t) recv_server_sync,
- [7] = (callback_t) recv_channel_state,
- [127] = NULL,
-};
-
static gboolean
read_cb(GSocket *socket, GIOCondition condition, gpointer data)
{
@@ -346,7 +383,8 @@ bus_call(GstBus *bus, GstMessage *msg, gpointer data)
break;
}
default:
- g_print("unhandled message: %d %s\n", GST_MESSAGE_TYPE(msg), gst_message_type_get_name(GST_MESSAGE_TYPE(msg)));
+ g_print("unhandled message: %d %s\n", GST_MESSAGE_TYPE(msg),
+ gst_message_type_get_name(GST_MESSAGE_TYPE(msg)));
break;
}
@@ -460,8 +498,10 @@ setup_recording_gst_pipeline(struct context *ctx)
gst_object_unref(bus);
gst_bin_add_many(GST_BIN(pipeline),
- src, cutter, resample, conv, capsfilter, encoder, sink, NULL);
- gst_element_link_many(src, cutter, resample, conv, capsfilter, encoder, sink, NULL);
+ src, cutter, resample, conv,
+ capsfilter, encoder, sink, NULL);
+ gst_element_link_many(src, cutter, resample, conv,
+ capsfilter, encoder, sink, NULL);
ctx->sink = GST_APP_SINK(sink);
ctx->record_pipeline = pipeline;
@@ -500,7 +540,7 @@ setup_recording_gst_pipeline(struct context *ctx)
int main(int argc, char **argv)
{
-#if 1
+#if 0
char *host = "localhost";
unsigned int port = 64738;
#else
@@ -524,7 +564,7 @@ int main(int argc, char **argv)
ctx.conn = g_socket_client_connect_to_host(ctx.sock_client,
host, port, NULL, &error);
- ctx.iostream = g_tcp_wrapper_connection_get_base_io_stream(G_TCP_WRAPPER_CONNECTION(ctx.conn));
+ g_object_get(G_OBJECT(ctx.conn), "base-io-stream", &ctx.iostream, NULL);
{
MumbleProto__Version version;