From 5717faed659a9eeb86c528ab56822c42eca1ad3f Mon Sep 17 00:00:00 2001
From: Runxi Yu <me@runxiyu.org>
Date: Tue, 12 Aug 2025 11:01:07 +0800
Subject: Refactor

---
 forged/internal/ipc/git2c/client.go | 50 +++++++++++++++++++++++++++++++++++++
 1 file changed, 50 insertions(+)
 create mode 100644 forged/internal/ipc/git2c/client.go

(limited to 'forged/internal/ipc/git2c/client.go')

diff --git a/forged/internal/ipc/git2c/client.go b/forged/internal/ipc/git2c/client.go
new file mode 100644
index 0000000..8b11035
--- /dev/null
+++ b/forged/internal/ipc/git2c/client.go
@@ -0,0 +1,50 @@
+// SPDX-License-Identifier: AGPL-3.0-only
+// SPDX-FileCopyrightText: Copyright (c) 2025 Runxi Yu <https://runxiyu.org>
+
+package git2c
+
+import (
+	"context"
+	"fmt"
+	"net"
+
+	"go.lindenii.runxiyu.org/forge/forged/internal/common/bare"
+)
+
+// Client represents a connection to the git2d backend daemon.
+type Client struct {
+	socketPath string
+	conn       net.Conn
+	writer     *bare.Writer
+	reader     *bare.Reader
+}
+
+// NewClient establishes a connection to a git2d socket and returns a new Client.
+func NewClient(ctx context.Context, socketPath string) (*Client, error) {
+	dialer := &net.Dialer{} //exhaustruct:ignore
+	conn, err := dialer.DialContext(ctx, "unix", socketPath)
+	if err != nil {
+		return nil, fmt.Errorf("git2d connection failed: %w", err)
+	}
+
+	writer := bare.NewWriter(conn)
+	reader := bare.NewReader(conn)
+
+	return &Client{
+		socketPath: socketPath,
+		conn:       conn,
+		writer:     writer,
+		reader:     reader,
+	}, nil
+}
+
+// Close terminates the underlying socket connection.
+func (c *Client) Close() (err error) {
+	if c.conn != nil {
+		err = c.conn.Close()
+		if err != nil {
+			return fmt.Errorf("close underlying socket: %w", err)
+		}
+	}
+	return nil
+}
-- 
cgit v1.2.3