diff options
| author | 2026-03-08 01:36:31 +0800 | |
|---|---|---|
| committer | 2026-03-08 01:36:31 +0800 | |
| commit | 3a4b9149b94b9b43243fd0b1580625514f7670ee (patch) | |
| tree | 8bc5fc62d795fca09f400205a7bd6c62c2caf20a /protocol/v0v1/server/receivepack/session.go | |
| parent | protocol/v0v1/server: Add PrimaryDataWriter (diff) | |
protocol/v0v1/server/receivepack: Fix report-status
Diffstat (limited to 'protocol/v0v1/server/receivepack/session.go')
| -rw-r--r-- | protocol/v0v1/server/receivepack/session.go | 86 |
1 files changed, 0 insertions, 86 deletions
diff --git a/protocol/v0v1/server/receivepack/session.go b/protocol/v0v1/server/receivepack/session.go index 8682c8e5..b8c4a7dd 100644 --- a/protocol/v0v1/server/receivepack/session.go +++ b/protocol/v0v1/server/receivepack/session.go @@ -159,92 +159,6 @@ afterPushOptions: return req, nil } -// WriteReportStatus writes one classic report-status response. -func (session *Session) WriteReportStatus(result ReportStatusResult) error { - unpackResult := "ok" - if result.UnpackError != "" { - unpackResult = result.UnpackError - } - - err := session.base.WriteData(fmt.Appendf(nil, "unpack %s\n", unpackResult)) - if err != nil { - return err - } - - for _, command := range result.Commands { - line := fmt.Sprintf("ok %s\n", command.Name) - if command.Error != "" { - line = fmt.Sprintf("ng %s %s\n", command.Name, command.Error) - } - - err = session.base.WriteData([]byte(line)) - if err != nil { - return err - } - } - - return session.base.WriteFlush() -} - -// WriteReportStatusV2 writes one report-status-v2 response. -func (session *Session) WriteReportStatusV2(result ReportStatusResult) error { - unpackResult := "ok" - if result.UnpackError != "" { - unpackResult = result.UnpackError - } - - err := session.base.WriteData(fmt.Appendf(nil, "unpack %s\n", unpackResult)) - if err != nil { - return err - } - - for _, command := range result.Commands { - if command.Error != "" { - err = session.base.WriteData(fmt.Appendf(nil, "ng %s %s\n", command.Name, command.Error)) - if err != nil { - return err - } - - continue - } - - err = session.base.WriteData(fmt.Appendf(nil, "ok %s\n", command.Name)) - if err != nil { - return err - } - - if command.RefName != "" { - err = session.base.WriteData(fmt.Appendf(nil, "option refname %s\n", command.RefName)) - if err != nil { - return err - } - } - - if command.OldID != nil { - err = session.base.WriteData(fmt.Appendf(nil, "option old-oid %s\n", *command.OldID)) - if err != nil { - return err - } - } - - if command.NewID != nil { - err = session.base.WriteData(fmt.Appendf(nil, "option new-oid %s\n", *command.NewID)) - if err != nil { - return err - } - } - - if command.ForcedUpdate { - err = session.base.WriteData([]byte("option forced-update\n")) - if err != nil { - return err - } - } - } - - return session.base.WriteFlush() -} - // WriteProgress writes one progress packet. func (session *Session) WriteProgress(p []byte) error { return session.base.WriteProgress(p) |
