Keyserver package:

* Implement key lookup & monitoring functions

* Refactor HandleOps response

* Server tests:

- Refactor directory_test.go

Protocol package:

* Implement: KeyLookup, KeyLookupInEpoch, Monitoring

keyserver/encoding.go

@@ -22,13 +22,20 @@ func UnmarshalRequest(msg []byte) (*Request, error) {
 	if err := json.Unmarshal(msg, &req); err != nil {
 		return nil, err
 	}
+	var request interface{}
 	switch req.Type {
 	case RegistrationType:
-		var request RegistrationRequest
-		if err := json.Unmarshal(content, &request); err != nil {
-			return nil, err
-		}
-		req.Request = &request
+		request = new(RegistrationRequest)
+	case KeyLookupType:
+		request = new(KeyLookupRequest)
+	case KeyLookupInEpochType:
+		request = new(KeyLookupInEpochRequest)
+	case MonitoringType:
+		request = new(MonitoringRequest)
 	}
+	if err := json.Unmarshal(content, &request); err != nil {
+		return nil, err
+	}
+	req.Request = request
 	return &req, nil
 }

keyserver/listener.go

@@ -93,11 +93,15 @@ func (server *ConiksServer) makeHandler(acceptableTypes map[int]bool) func(msg [
 		}
 
 		switch req.Type {
+		case KeyLookupType, KeyLookupInEpochType, MonitoringType:
+			server.RLock()
 		default:
 			server.Lock()
 		}
 		response, e := server.dir.HandleOps(req)
 		switch req.Type {
+		case KeyLookupType, KeyLookupInEpochType, MonitoringType:
+			server.RLock()
 		default:
 			server.Unlock()
 		}

keyserver/server.go

@@ -159,6 +159,9 @@ func (server *ConiksServer) Run(tc *TLSConnection) {
 
 	// acceptable types for public connection
 	publicTypes := make(map[int]bool)
+	publicTypes[protocol.KeyLookupType] = true
+	publicTypes[protocol.KeyLookupInEpochType] = true
+	publicTypes[protocol.MonitoringType] = true
 	server.waitStop.Add(1)
 	go func() {
 		server.listenForRequests(publicLn, server.makeHandler(publicTypes))