package protocol import ( "fmt" "io" ) func ReadResponse(r io.Reader, apiKey ApiKey, apiVersion int16) (correlationID int32, msg Message, err error) { if i := int(apiKey); i < 0 || i >= len(apiTypes) { err = fmt.Errorf("unsupported api key: %d", i) return } t := &apiTypes[apiKey] if t == nil { err = fmt.Errorf("unsupported api: %s", apiNames[apiKey]) return } minVersion := t.minVersion() maxVersion := t.maxVersion() if apiVersion < minVersion || apiVersion > maxVersion { err = fmt.Errorf("unsupported %s version: v%d not in range v%d-v%d", apiKey, apiVersion, minVersion, maxVersion) return } d := &decoder{reader: r, remain: 4} size := d.readInt32() if err = d.err; err != nil { err = dontExpectEOF(err) return } d.remain = int(size) correlationID = d.readInt32() res := &t.responses[apiVersion-minVersion] if res.flexible { // In the flexible case, there's a tag buffer at the end of the response header taggedCount := int(d.readUnsignedVarInt()) for i := 0; i < taggedCount; i++ { d.readUnsignedVarInt() // tagID size := d.readUnsignedVarInt() // Just throw away the values for now d.read(int(size)) } } msg = res.new() res.decode(d, valueOf(msg)) d.discardAll() if err = d.err; err != nil { err = dontExpectEOF(err) } return } func WriteResponse(w io.Writer, apiVersion int16, correlationID int32, msg Message) error { apiKey := msg.ApiKey() if i := int(apiKey); i < 0 || i >= len(apiTypes) { return fmt.Errorf("unsupported api key: %d", i) } t := &apiTypes[apiKey] if t == nil { return fmt.Errorf("unsupported api: %s", apiNames[apiKey]) } minVersion := t.minVersion() maxVersion := t.maxVersion() if apiVersion < minVersion || apiVersion > maxVersion { return fmt.Errorf("unsupported %s version: v%d not in range v%d-v%d", apiKey, apiVersion, minVersion, maxVersion) } r := &t.responses[apiVersion-minVersion] v := valueOf(msg) b := newPageBuffer() defer b.unref() e := &encoder{writer: b} e.writeInt32(0) // placeholder for the response size e.writeInt32(correlationID) r.encode(e, v) err := e.err if err == nil { size := packUint32(uint32(b.Size()) - 4) b.WriteAt(size[:], 0) _, err = b.WriteTo(w) } return err }