Atlas › Test
Exact test identity: go.temporal.io/server/common/codec/TestJSONPBEncoderSuite/TestDecodeHistories
go.temporal.io/server/common/codecTestJSONPBEncoderSuite/TestDecodeHistoriesTestDecodeHistories1 other test enter at the same concept.
Expand a file to inspect source; the > gutter marks covered lines.
// NewJSONPBEncoder creates a new JSONPBEncoder.
return JSONPBEncoder{}
}
// NewJSONPBIndentEncoder creates a new JSONPBEncoder with indent.
// Decode History slice from bytes.
var histories []*historypb.History
err := e.DecodeSlice(
data,
func() proto.Message {
history := &historypb.History{}
histories = append(histories, history)
return history
})
}
func (e *JSONPBEncoder) DecodeSlice(
data []byte,
dec := json.NewDecoder(bytes.NewReader(data))
tok, err := dec.Token()
if err != nil {
return err
}
return fmt.Errorf("invalid json: expected [ but found %v", tok)
}
// We need DiscardUnknown here as the history json may have been written by a
// different proto revision
DiscardUnknown: true,
}
var buf json.RawMessage
for dec.More() {
if err := dec.Decode(&buf); err != nil {
return err
}
if err := unmarshaller.Unmarshal([]byte(buf), pb); err != nil {
return err
}
}
}
// generic parameters and slice casting (say from []historyEvent) to
// []proto.Message is impossible
if th, ok := t.(helper); ok {
th.Helper()
}
if len(a) != len(b) {
return false
}
if diff := cmp.Diff(a[i], b[i], protocmp.Transform()); diff != "" {
return assert.Fail(t, fmt.Sprintf("Proto mismatch at index %d (-want +got):\n%v", i, diff))
}
}
}