}
func (cc *ClientConn) handleTransaction(transaction Transaction) error {
- requestNum := binary.BigEndian.Uint16(transaction.Type)
+ requestNum := binary.BigEndian.Uint16(transaction.Type[:])
if handler, ok := TransactionHandlers[requestNum]; ok {
for _, reqField := range handler.RequiredFields {
field := transaction.GetField(reqField.ID)
transactions, err := handler.Handler(cc, &transaction)
if err != nil {
- return err
+ return fmt.Errorf("error handling transaction: %w", err)
}
for _, t := range transactions {
cc.Server.outbox <- t
// NewReply returns a reply Transaction with fields for the ClientConn
func (cc *ClientConn) NewReply(t *Transaction, fields ...Field) Transaction {
return Transaction{
- Flags: 0x00,
IsReply: 0x01,
- Type: []byte{0x00, 0x00},
+ Type: [2]byte{0x00, 0x00},
ID: t.ID,
clientID: cc.ID,
- ErrorCode: []byte{0, 0, 0, 0},
+ ErrorCode: [4]byte{0, 0, 0, 0},
Fields: fields,
}
}
func (cc *ClientConn) NewErrReply(t *Transaction, errMsg string) Transaction {
return Transaction{
clientID: cc.ID,
- Flags: 0x00,
IsReply: 0x01,
- Type: []byte{0, 0},
+ Type: [2]byte{0, 0},
ID: t.ID,
- ErrorCode: []byte{0, 0, 0, 1},
+ ErrorCode: [4]byte{0, 0, 0, 1},
Fields: []Field{
NewField(FieldError, []byte(errMsg)),
},