From c5ec988bb16f4b3eb62dc46d78a5ff055cc7ff77 Mon Sep 17 00:00:00 2001
From: Ayman Bagabas <ayman.bagabas@gmail.com>
Date: Wed, 16 Nov 2022 15:05:59 -0500
Subject: [PATCH] feat(server): git daemon

Implement a TCP git daemon
Add tests

Reference: https://git-scm.com/book/en/v2/Git-on-the-Server-Git-Daemon
---
 server/db/sqlite/collabs.go | 132 ++++++++++++++++++++++++++++++++++++
 server/git/daemon/daemon.go |   1 -
 2 files changed, 132 insertions(+), 1 deletion(-)
 create mode 100644 server/db/sqlite/collabs.go

diff --git a/server/db/sqlite/collabs.go b/server/db/sqlite/collabs.go
new file mode 100644
index 0000000000000000000000000000000000000000..e373250b46c4a1acd0f3d092775ab42ef0fb2cd4
--- /dev/null
+++ b/server/db/sqlite/collabs.go
@@ -0,0 +1,132 @@
+package sqlite
+
+import (
+	"net/mail"
+	"strconv"
+
+	"github.com/charmbracelet/soft-serve/proto"
+	"github.com/charmbracelet/soft-serve/server/db/types"
+	"golang.org/x/crypto/ssh"
+)
+
+var _ proto.CollaboratorService = &Sqlite{}
+
+// AddCollaborator adds a collaborator to a repository.
+func (d *Sqlite) AddCollaborator(repo string, collab proto.Collaborator) error {
+	r, err := d.GetRepo(repo)
+	if err != nil {
+		return err
+	}
+	switch c := collab.(type) {
+	}
+}
+
+// RemoveCollaborator removes a collaborator from a repository.
+func (d *Sqlite) RemoveCollaborator(repo string, collab proto.Collaborator) error {
+	return nil
+}
+
+// ListCollaborators lists the collaborators of a repository.
+func (d *Sqlite) ListCollaborators(repo string) ([]proto.Collaborator, error) {
+	return nil, nil
+}
+
+type publicKey struct {
+	key *types.PublicKey
+}
+
+// PublicKey returns the collaborator's public key.
+func (k publicKey) PublicKey() ssh.PublicKey {
+	pk, err := ssh.ParsePublicKey([]byte(k.key.PublicKey))
+	if err != nil {
+		return nil
+	}
+	return pk
+}
+
+var _ proto.PublicKeyCollaborator = &collaborator{}
+var _ proto.UserLoginCollaborator = &collaborator{}
+var _ proto.EmailCollaborator = &collaborator{}
+
+type collaborator struct {
+	user *types.User
+	keys []*types.PublicKey
+	db   *Sqlite
+}
+
+func (c *collaborator) init() {
+	if c.keys != nil || len(c.keys) > 0 {
+		return
+	}
+	ks, err := c.db.GetUserPublicKeys(c.user)
+	if err != nil {
+		return
+	}
+	c.keys = ks
+}
+
+// Identifier returns the collaborator's identifier.
+func (c *collaborator) Identifier() string {
+	return strconv.Itoa(c.user.ID)
+}
+
+// Name returns the collaborator's name.
+func (c *collaborator) Name() string {
+	return c.user.Name
+}
+
+// String returns the collaborator's username.
+func (c *collaborator) String() string {
+	return c.user.Name
+}
+
+// Marshal implements proto.PublicKeyCollaborator
+func (c *collaborator) Marshal() []byte {
+	c.init()
+	pk := c.keys[0]
+	return pk.Marshal()
+}
+
+// Type implements proto.PublicKeyCollaborator
+func (c *collaborator) Type() string {
+	c.init()
+	pk := c.keys[0]
+	return pk.Type()
+}
+
+// Verify implements proto.PublicKeyCollaborator
+func (c *collaborator) Verify(data []byte, sig *ssh.Signature) error {
+	c.init()
+	pk := c.keys[0]
+	return pk.Verify(data, sig)
+}
+
+// Login implements proto.UserLoginCollaborator
+func (c *collaborator) Login() string {
+	var login string
+	if c.user.Login != nil {
+		login = *c.user.Login
+	}
+	return login
+}
+
+// Address implements proto.EmailCollaborator
+func (c *collaborator) Address() mail.Address {
+	var addr string
+	if c.user.Email != nil {
+		addr = *c.user.Email
+	}
+	return mail.Address{
+		Name:    c.user.Name,
+		Address: addr,
+	}
+}
+
+// Password implements proto.UserLoginCollaborator
+func (c *collaborator) Password() string {
+	var pwd string
+	if c.user.Password != nil {
+		pwd = *c.user.Password
+	}
+	return pwd
+}
diff --git a/server/git/daemon/daemon.go b/server/git/daemon/daemon.go
index ee5fc1aa127fe7c345a355f88d51f9b1168d4760..9d4247eee8228054a63a97b038894df51d8aabd8 100644
--- a/server/git/daemon/daemon.go
+++ b/server/git/daemon/daemon.go
@@ -59,7 +59,6 @@ func (d *Daemon) Start() error {
 	// loop work cycle with accept connections or interrupt
 	// by system signal
 	for {
-		log.Printf("listener len %d cap %d", len(listen), cap(listen))
 		select {
 		case conn := <-listen:
 			d.wg.Add(1)