layed out initial structures. began work on registration procedure.

7 files changed, 459 insertions, 0 deletions

diff --git a/alloc.c b/alloc.c
new file mode 100644
index 0000000..ede5d64
--- /dev/null
+++ b/alloc.c
@@ -0,0 +1,44 @@
+#include <u.h>
+#include <libc.h>
+#include <draw.h>
+
+void *
+emalloc(ulong n)
+{
+	void *p;
+
+	p = malloc(n);
+	if(p == nil)
+		sysfatal("malloc: %r");
+	setmalloctag(p, getcallerpc(&n));
+	return p;
+}
+
+void *
+erealloc(void *p, ulong n)
+{
+	void *np;
+
+	np = realloc(p, n);
+	if(np == nil){
+		if(n == 0)
+			return nil;
+		sysfatal("realloc: %r");
+	}
+	if(p == nil)
+		setmalloctag(np, getcallerpc(&p));
+	else
+		setrealloctag(np, getcallerpc(&p));
+	return np;
+}
+
+Image *
+eallocimage(Display *d, Rectangle r, ulong chan, int repl, ulong col)
+{
+	Image *i;
+
+	i = allocimage(d, r, chan, repl, col);
+	if(i == nil)
+		sysfatal("allocimage: %r");
+	return i;
+}
diff --git a/dat.h b/dat.h
new file mode 100644
index 0000000..caf6d01
--- /dev/null
+++ b/dat.h
@@ -0,0 +1,117 @@
+typedef enum {
+	REGISTER,
+	INVITE,
+	ACK,
+	BYE,
+	CANCEL,
+	OPTIONS,
+	NOTIFY,
+	SUBSCRIBE,
+	INFO,
+	MESSAGE,
+	UPDATE,
+	REFER
+} SipMethod;
+
+/* rfc3261 § 21 - Response Codes */
+typedef enum {
+	/* 1xx Provisional */
+	Trying		= 100,
+	Ringing		= 180,
+	CallForwarded	= 181,
+	Queued		= 182,
+	SessionProgress	= 183,
+
+	/* 2xx Successful */
+	OK		= 200,
+
+	/* 3xx Redirection */
+	MultiChoice		= 300,
+	MovedPerm		= 301,
+	MovedTemp		= 302,
+	UseProxy		= 305,
+	AltService		= 380,
+
+	/* 4xx Request Failure */
+	BadRequest		= 400,
+	Unauthorized		= 401,
+	PaymentRequired		= 402,
+	Forbidden		= 403,
+	NotFound		= 404,
+	MethodNotAllowed	= 405,
+	RequestNotAcceptable	= 406,
+	ProxyAuthRequired	= 407,
+	RequestTimeout		= 408,
+	Gone			= 410,
+	EntityTooLarge		= 413,
+	URITooLong		= 414,
+	UnsupportedMedia	= 415,
+	UnsupportedURIScheme	= 416,
+	BadExtension		= 420,
+	ExtensionRequired	= 421,
+	IntervalTooBrief	= 423,
+	TempUnavailable		= 480,
+	CallDoesNotExist	= 481,
+	LoopDetected		= 482,
+	TooManyHops		= 483,
+	AddressIncomplete	= 484,
+	Ambiguous		= 485,
+	BusyHere		= 486,
+	RequestTerminated	= 487,
+	NotAcceptableHere	= 488,
+	RequestPending		= 491,
+	Undecipherable		= 493,
+
+	/* 5xx Server Failure */
+	InternalError		= 500,
+	NotImplemented		= 501,
+	BadGateway		= 502,
+	ServiceUnavailable	= 503,
+	ServerTimeout		= 504,
+	VersionNotSupported	= 505,
+	MessageTooLarge		= 513,
+
+	/* 6xx Global Failures */
+	BusyEverywhere		= 600,
+	Decline			= 603,
+	DoesNotExistAnywhere	= 604,
+	NotAcceptable		= 606,
+	
+} SipStatus;
+
+typedef struct Hdr Hdr;
+typedef struct Hdrtab Hdrtab;
+typedef struct Sipmsg Sipmsg;
+typedef struct Sip Sip;
+
+struct Hdr
+{
+	char *name;
+	char *value;
+	Hdr *next;
+};
+
+struct Hdrtab
+{
+	Hdr *headers[13];
+};
+
+struct Sipmsg
+{
+	Hdrtab;
+	char *version;
+	SipMethod method;
+};
+
+/* SIP UAC (see rfc3261 § 8.1, 12.1.2) */
+struct Sip
+{
+	int version;
+
+	NetConnInfo *nci;
+	int fd;
+
+	int (*reg)(Sip*, char*, char*);
+};
+
+extern int debug;
diff --git a/fns.h b/fns.h
new file mode 100644
index 0000000..e6edb97
--- /dev/null
+++ b/fns.h
@@ -0,0 +1,10 @@
+void *emalloc(ulong);
+void *erealloc(void*, ulong);
+Image *eallocimage(Display*, Rectangle, ulong, int, ulong);
+
+void addheader(Hdrtab*, char*, char*);
+Hdr *getheader(Hdrtab*, char*);
+void delheader(Hdrtab*, char*);
+
+Sip *mksip(int);
+void rmsip(Sip*);
diff --git a/main.c b/main.c
new file mode 100644
index 0000000..6834a6e
--- /dev/null
+++ b/main.c
@@ -0,0 +1,52 @@
+#include <u.h>
+#include <libc.h>
+#include <draw.h>
+#include <thread.h>
+#include "dat.h"
+#include "fns.h"
+
+int debug;
+
+
+void
+usage(void)
+{
+	fprint(2, "usage: %s [-d] addr username password\n", argv0);
+	exits("usage");
+}
+
+void
+threadmain(int argc, char *argv[])
+{
+	Sip *sip;
+	char *addr;
+	int fd;
+
+	ARGBEGIN{
+	default: usage();
+	case 'd':
+		debug++;
+		break;
+	}ARGEND;
+	if(argc != 3)
+		usage();
+
+	addr = netmkaddr(argv[0], "udp", "sip");
+	if(debug)
+		fprint(2, "connecting to %s\n", addr);
+
+	fd = dial(addr, nil, nil, nil);
+	if(fd < 0)
+		sysfatal("couldn't establish the connection");
+
+	if(debug)
+		fprint(2, "connection established\n");
+
+	sip = mksip(fd);
+	if(sip == nil)
+		sysfatal("mksip: %r");
+	sip->reg(sip, argv[1], argv[2]);
+	rmsip(sip);
+
+	threadexitsall(nil);
+}
diff --git a/mkfile b/mkfile
new file mode 100644
index 0000000..dd58425
--- /dev/null
+++ b/mkfile
@@ -0,0 +1,25 @@
+</$objtype/mkfile
+
+MAN=/sys/man/1
+BIN=/$objtype/bin
+TARG=\
+	catphone
+
+OFILES=\
+	main.$O\
+	alloc.$O\
+	sip.$O\
+
+HFILES=\
+	dat.h\
+	fns.h\
+
+</sys/src/cmd/mkone
+
+install:V: man
+
+uninstall:V:
+	for(i in $TARG){
+		rm -f $BIN/$i
+		rm -f $MAN/$i
+	}
diff --git a/readme.md b/readme.md
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/readme.md
diff --git a/sip.c b/sip.c
new file mode 100644
index 0000000..267c49a
--- /dev/null
+++ b/sip.c
@@ -0,0 +1,211 @@
+#include <u.h>
+#include <libc.h>
+#include <bio.h>
+#include <draw.h>
+#include "dat.h"
+#include "fns.h"
+
+static char sipversion[] = "SIP/2.0";
+static char *methodstrtab[] = {
+ [REGISTER]	"REGISTER",
+ [INVITE]	"INVITE",
+ [ACK]		"ACK",
+ [BYE]		"BYE",
+ [CANCEL]	"CANCEL",
+ [OPTIONS]	"OPTIONS",
+ [NOTIFY]	"NOTIFY",
+ [SUBSCRIBE]	"SUBSCRIBE",
+ [INFO]		"INFO",
+ [MESSAGE]	"MESSAGE",
+ [UPDATE]	"UPDATE",
+ [REFER]	"REFER",
+};
+
+static char registerhdr0[] = "REGISTER sip:%s %s\r\n"
+	"Via: %s/UDP %s:%s;branch=z9hG4bK703d971c0c737b8e;rport\r\n"
+	"Contact: <sip:%s-0x82a66a010@%s:%s>;expires=3849\r\n"
+	"Max-Forwards: 70\r\n"
+	"To: <sip:%s@%s>\r\n"
+	"From: <sip:%s@%s>;tag=4a5a693256d38cbc\r\n"
+	"Call-ID: 2cee372fc4be4e45\r\n"
+	"CSeq: 16021 REGISTER\r\n"
+	"User-Agent: catphone (plan9front)\r\n"
+	"Allow: INVITE,ACK,BYE,CANCEL,OPTIONS,NOTIFY,SUBSCRIBE,INFO,MESSAGE,UPDATE,REFER\r\n"
+	"Content-Length: 0\r\n"
+	"\r\n";
+static char registerhdr[] = "REGISTER sip:10.0.0.104 SIP/2.0\r\n"
+	"Via: SIP/2.0/UDP 10.0.1.9:54022;branch=z9hG4bKdf800c31b9a88ffb;rport\r\n"
+	"Contact: <sip:sam-0x82a66a010@10.0.1.9:54022>;expires=3849\r\n"
+	"Max-Forwards: 70\r\n"
+	"Authorization: Digest username=\"sam\", realm=\"asterisk\", nonce=\"0d39ab10\", uri=\"sip:10.0.0.104\", response=\"a12e05b52604b5226763ce577d5c240b\", algorithm=MD5\r\n"
+	"To: <sip:sam@10.0.0.104>\r\n"
+	"From: <sip:sam@10.0.0.104>;tag=4a5a693256d38cbc\r\n"
+	"Call-ID: 2cee372fc4be4e45\r\n"
+	"CSeq: 16022 REGISTER\r\n"
+	"User-Agent: catphone (plan9front)\r\n"
+	"Allow: INVITE,ACK,BYE,CANCEL,OPTIONS,NOTIFY,SUBSCRIBE,INFO,MESSAGE,UPDATE,REFER\r\n"
+	"Content-Length: 0\r\n"
+	"\r\n";
+
+static char *
+getmethodstr(SipMethod m)
+{
+	return methodstrtab[m];
+}
+
+static uint
+hash(char *s)
+{
+	uint h;
+
+	h = 0x811c9dc5;
+	while(*s != 0)
+		h = (h^(uchar)*s++) * 0x1000193;
+	return h % 13;
+}
+
+void
+addheader(Hdrtab *ht, char *name, char *value)
+{
+	Hdr *h, *newh;
+	uint key;
+
+	key = hash(name);
+	newh = emalloc(sizeof(Hdr));
+	newh->name = strdup(name);
+	newh->value = strdup(value);
+	newh->next = nil;
+
+	h = ht->headers[key];
+	if(h == nil){
+		ht->headers[key] = newh;
+		return;
+	}
+	while(h->next != nil)
+		h = h->next;
+	h->next = newh;
+}
+
+Hdr *
+getheader(Hdrtab *ht, char *name)
+{
+	Hdr *h;
+	uint key;
+
+	key = hash(name);
+	for(h = ht->headers[key]; h != nil; h = h->next)
+		if(cistrcmp(h->name, name) == 0)
+			return h;
+	return nil;
+}
+
+void
+delheader(Hdrtab *ht, char *name)
+{
+	Hdr **h, *nh;
+	uint key;
+
+	key = hash(name);
+	h = &ht->headers[key];
+	while(*h != nil){
+		nh = (*h)->next;
+		if(cistrcmp((*h)->name, name) == 0){
+			free((*h)->name);
+			free((*h)->value);
+			free(*h);
+		}
+		*h = nh;
+	}
+}
+
+void
+delheaders(Hdrtab *ht)
+{
+	Hdr *h, *nh;
+	int i;
+
+	for(i = 0; i < nelem(ht->headers); i++)
+		for(h = ht->headers[i]; h != nil; h = nh){
+			nh = h->next;
+			free(h->name);
+			free(h->value);
+			free(h);
+		}
+}
+
+/* rfc3261 § 10 - Registrations */
+static int
+sip_register(Sip *s, char *user, char *pass)
+{
+	Biobuf *bin, *bout;
+	char *line, *p, *kv[2];
+	int n;
+
+	if((bin = Bfdopen(s->fd, OREAD)) == nil)
+		sysfatal("Bfdopen: %r");
+	if((bout = Bfdopen(s->fd, OWRITE)) == nil)
+		sysfatal("Bfdopen: %r");
+
+	/* present yourself */
+	Bprint(bout, registerhdr0, s->nci->rsys, sipversion,
+		sipversion, s->nci->lsys, s->nci->lserv,
+		user, s->nci->lsys, s->nci->lserv,
+		user, s->nci->rsys,
+		user, s->nci->rsys);
+	Bflush(bout);
+
+	/* wait for the challenge */
+	while((line = Brdline(bin, '\n')) != nil){
+		if(strncmp(line, "\r\n", 2) == 0)
+			break;
+
+		p = strchr(line, '\r');
+		*p++ = 0, *p = 0;
+		if(debug)
+			fprint(2, "%s\n", line);
+
+		if(strstr(line, ":") == nil)
+			continue;
+
+		gettokens(line, kv, nelem(kv), ": ");
+		if(debug)
+			fprint(2, "got key=%s value=%s\n", kv[0], kv[1]);
+	}
+
+	/* respond to the challenge */
+
+	/* get the OK */
+
+	Bterm(bin);
+	Bterm(bout);
+
+	return 0;
+}
+
+Sip *
+mksip(int fd)
+{
+	Sip *s;
+
+	s = emalloc(sizeof(Sip));
+	memset(s, 0, sizeof *s);
+	s->version = 2;
+	s->nci = getnetconninfo(nil, fd);
+	if(s->nci == nil){
+		werrstr("couldn't getnetconninfo");
+		free(s);
+		return nil;
+	}
+	s->fd = fd;
+	s->reg = sip_register;
+
+	return s;
+}
+
+void
+rmsip(Sip *s)
+{
+	close(s->fd);
+	freenetconninfo(s->nci);
+	free(s);
+}