Added SILC Local Network Stream API

[runtime.git] / lib / silcutil / silclocalnetstream.c

diff --git a/lib/silcutil/silclocalnetstream.c b/lib/silcutil/silclocalnetstream.c
new file mode 100644 (file)
index 0000000..d93e909
--- /dev/null
+++ b/lib/silcutil/silclocalnetstream.c
@@ -0,0 +1,177 @@
+/*
+
+  silclocalnetstream.c
+
+  Author: Pekka Riikonen <priikone@silcnet.org>
+
+  Copyright (C) 2008 Pekka Riikonen
+
+  This program is free software; you can redistribute it and/or modify
+  it under the terms of the GNU General Public License as published by
+  the Free Software Foundation; version 2 of the License.
+
+  This program is distributed in the hope that it will be useful,
+  but WITHOUT ANY WARRANTY; without even the implied warranty of
+  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+  GNU General Public License for more details.
+
+*/
+
+#include <silcruntime.h>
+
+/************************** Types and definitions ***************************/
+
+/* Local net listener context */
+typedef struct {
+  SilcNetListener listener;
+  char *filepath;
+  SilcNetCallback callback;
+  void *context;
+} *SilcLocalNetListener;
+
+/************************ Static utility functions **************************/
+
+/* Connection accept callback */
+
+static void silc_local_net_accept(SilcResult result, SilcStream stream,
+                                 void *context)
+{
+  SilcLocalNetListener listener = context;
+  const char *remote_ip;
+
+  if (!silc_socket_stream_get_info(stream, NULL, NULL, &remote_ip, NULL)) {
+    silc_stream_destroy(stream);
+    return;
+  }
+
+  /* Make sure the connection comes from local host */
+  if (strcmp(remote_ip, "127.0.0.1")) {
+    SILC_LOG_DEBUG(("Connection is coming from %s, will not accept",
+                   remote_ip));
+    silc_stream_destroy(stream);
+    return;
+  }
+
+  listener->callback(result, stream, listener->context);
+}
+
+/****************************** Public API **********************************/
+
+/* Create listener */
+
+SilcNetListener silc_local_net_create_listener(const char *filepath,
+                                              SilcSchedule schedule,
+                                              SilcNetCallback callback,
+                                              void *context)
+{
+  SilcLocalNetListener listener;
+  SilcUInt16 *local_port;
+  const char *addr = "127.0.0.1";
+  char port[8];
+
+  SILC_LOG_DEBUG(("Creating local network stream listener %s", filepath));
+
+  if (!filepath || !callback) {
+    silc_set_errno(SILC_ERR_INVALID_ARGUMENT);
+    return NULL;
+  }
+
+  /* Make sure file doesn't exist */
+  if (silc_file_stat(filepath, FALSE, NULL)) {
+    silc_set_errno(SILC_ERR_ALREADY_EXISTS);
+    return NULL;
+  }
+
+  listener = silc_calloc(1, sizeof(*listener));
+  if (!listener)
+    return NULL;
+  listener->callback = callback;
+  listener->context = context;
+
+  listener->filepath = silc_strdup(filepath);
+  if (!listener->filepath) {
+    silc_free(listener);
+    return NULL;
+  }
+
+  /* Create local TCP listener */
+  listener->listener =
+    silc_net_tcp_create_listener(&addr, 1, 0, TRUE, FALSE, schedule,
+                                silc_local_net_accept, listener);
+  if (!listener) {
+    silc_free(listener);
+    return NULL;
+  }
+
+  /* Get the bound port */
+  local_port = silc_net_listener_get_port(listener->listener, NULL);
+  if (!local_port) {
+    silc_net_close_listener(listener->listener);
+    silc_free(listener);
+    return NULL;
+  }
+
+  /* Create the file */
+  silc_snprintf(port, sizeof(port), "%d", *local_port);
+  if (silc_file_writefile(filepath, port, strlen(port) + 1)) {
+    silc_free(local_port);
+    silc_net_close_listener(listener->listener);
+    silc_free(listener);
+    return NULL;
+  }
+
+  SILC_LOG_DEBUG(("Created local network stream listener %p", listener));
+
+  silc_free(local_port);
+
+  return (SilcNetListener)listener;
+}
+
+/* Close listener */
+
+void silc_local_net_close_listener(SilcNetListener local_listener)
+{
+  SilcLocalNetListener listener = (SilcLocalNetListener)local_listener;
+
+  SILC_LOG_DEBUG(("Closing local network stream listener %p, %s",
+                 listener, listener->filepath));
+
+  unlink(listener->filepath);
+  silc_net_close_listener(listener->listener);
+  silc_free(listener);
+}
+
+/* Connect to the local network listener */
+
+SilcAsyncOperation silc_local_net_connect(const char *filepath,
+                                         SilcSchedule schedule,
+                                         SilcNetCallback callback,
+                                         void *context)
+{
+  unsigned char *port_data;
+  int port;
+
+  SILC_LOG_DEBUG(("Connecting to local network listner %s", filepath));
+
+  if (!filepath) {
+    silc_set_errno(SILC_ERR_INVALID_ARGUMENT);
+    if (callback)
+      callback(silc_errno, NULL, context);
+    return NULL;
+  }
+
+  /* Read the port from file */
+  port_data = silc_file_readfile(filepath, NULL, NULL);
+  if (!port_data) {
+    if (callback)
+      callback(silc_errno, NULL, context);
+    return NULL;
+  }
+  port = atoi(port_data);
+
+  silc_free(port_data);
+
+  /* Connect */
+  return silc_net_tcp_connect("127.0.0.1", "127.0.0.1", port, schedule,
+                             callback, context);
+}