Add simple POC server

Just to show that this can work:

- Listens until killed.
- Gets a hard-coded test keychain item when connected to.

diff --git a/passage.go b/passage.go
new file mode 100644 (file)
index 0000000..2356712
--- /dev/null
+++ b/passage.go
@@ -0,0 +1,82 @@
+package main
+
+import (
+       "encoding/json"
+       "fmt"
+       "github.com/keybase/go-keychain"
+       "log"
+       "net"
+       "os"
+       "os/signal"
+       "os/user"
+       "syscall"
+)
+
+type Request struct {
+       Account string
+       Service string
+}
+
+func main() {
+       path := getSockPath()
+       syscall.Umask(0077)
+       listener, err := net.Listen("unix", path)
+       if err != nil {
+               log.Fatal(err)
+       }
+       defer listener.Close()
+
+       go func() {
+               for {
+                       conn, err := listener.Accept()
+                       if err != nil {
+                               log.Print(err)
+                               return
+                       }
+                       go handleConnection(conn)
+               }
+       }()
+       log.Print("Open and ready for business on UNIX socket at ", path)
+
+       // Need to catch signals in order for `defer`-ed clean-up items to run.
+       c := make(chan os.Signal, 1)
+       signal.Notify(c, os.Interrupt, os.Kill, syscall.SIGTERM)
+       sig := <-c
+       log.Print("Got signal ", sig)
+}
+
+func getSockPath() string {
+       user, err := user.Current()
+       if err != nil {
+               log.Fatal(err)
+       }
+       return user.HomeDir + "/.passage.sock"
+}
+
+func handleConnection(conn net.Conn) {
+       defer conn.Close()
+
+       var request Request
+       socketData := []byte("{\"service\":\"test item 1000\",\"account\":\"test name\"}")
+       err := json.Unmarshal(socketData, &request)
+       if err != nil {
+               log.Print(err)
+               return
+       }
+
+       query := keychain.NewItem()
+       query.SetSecClass(keychain.SecClassGenericPassword)
+       query.SetService(request.Service)
+       query.SetAccount(request.Account)
+       query.SetMatchLimit(keychain.MatchLimitOne)
+       query.SetReturnData(true)
+       results, err := keychain.QueryItem(query)
+       if err != nil {
+               fmt.Printf("error\n")
+       } else if len(results) != 1 {
+               fmt.Printf("not found\n")
+       } else {
+               password := string(results[0].Data)
+               fmt.Printf(password)
+       }
+}